...
|
...
|
@@ -100,11 +100,11 @@ public class ProductMqListener extends AbstractMqListener { |
|
|
logger.info("[step(3/6)=getProductIBO][productId={}][cost={}ms]", productId, costStatistics.getCost());
|
|
|
|
|
|
//2、增量时,为状态为1的skn生成newCodeId
|
|
|
Map<Integer, Integer> sknNewCodeMap = new HashMap<>();
|
|
|
Map<Integer, Integer> productSknCodeMap = new HashMap<>();
|
|
|
if(productIBO.getStatus()==1){
|
|
|
sknNewCodeMap = productSknCodeService.queryForIncrement(Arrays.asList(productIBO.getProductSkn()));
|
|
|
productSknCodeMap = productSknCodeService.queryForIncrement(Arrays.asList(productIBO.getProductSkn()));
|
|
|
}
|
|
|
productIBO.setNewCodeId(MapUtils.getIntValue(sknNewCodeMap,productIBO.getProductSkn(),0));
|
|
|
productIBO.setProductSknCode(MapUtils.getIntValue(productSknCodeMap,productIBO.getProductSkn(),0));
|
|
|
logger.info("[step(4/6)=setNewCodeId][productId={}][cost={}ms]", productId, costStatistics.getCost());
|
|
|
|
|
|
// 3、构建ProductPrice
|
...
|
...
|
|