Authored by wangnan

fix

... ... @@ -128,12 +128,13 @@ public class StorageMqListener extends AbstractMqListener implements ChannelAwar
if (productId == null) {
return;
}
this.updateProductIndex(productId, System.currentTimeMillis(), key);
Integer productSkn = null;
Product product = productService.getById(productId);
if (product != null) {
productSkn = product.getErpProductId();
}
this.updateProductIndex(productId,productSkn, System.currentTimeMillis(), key);
//更新ProductPoolIndex
updateProductPoolByProductSkn(productSkn, key);
storageSkuIndexService.deleteStorageSkuIndex(storage.getErpSkuId(), begin, key);
... ...