...
|
...
|
@@ -85,7 +85,8 @@ public class TblSiteMqListener extends AbstractMqListener implements ChannelAwar |
|
|
//update productIndex
|
|
|
List<Integer> skns = tblProductService.getSknsBySiteId(tblSite.getSiteId());
|
|
|
if (CollectionUtils.isNotEmpty(skns)) {
|
|
|
updateProductIndexForTbl(skns, begin, key);
|
|
|
logger.info("[func=updateData][step=updateProductIndexForTbl][tableName=tblSite][id={}][skn size is [{}] ]",tblSite.getSiteId(), skns.size());
|
|
|
updateProductIndexForTbl(skns, begin, key);
|
|
|
}
|
|
|
String idValue = data.get(idField).toString();
|
|
|
logger.info("[func=updateData][step=success][tableName=tblSite][id={}][cost={}ms]", idValue, (System.currentTimeMillis() - begin));
|
...
|
...
|
@@ -105,10 +106,9 @@ public class TblSiteMqListener extends AbstractMqListener implements ChannelAwar |
|
|
if(tblSite!=null){
|
|
|
List<Integer> skns = tblProductService.getSknsBySiteId(tblSite.getSiteId());
|
|
|
if (CollectionUtils.isNotEmpty(skns)) {
|
|
|
updateProductIndexForTbl(skns, begin, key);
|
|
|
updateProductIndexForTbl(skns, begin, key);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
logger.info("[func=deleteData][step=success][tableName=tblSite][id={}][cost={}ms]", id, (System.currentTimeMillis() - begin));
|
|
|
}
|
|
|
} |
...
|
...
|
|