1. 商品信息变动刷新库存
2. 商品信息变动发生Mq消息
This commit is contained in:
@@ -108,11 +108,11 @@ public class ProductRpcServiceImpl implements ProductRpcService {
|
||||
consStockFlowMapper.insert(consStockFlow);
|
||||
}
|
||||
}
|
||||
try {
|
||||
/*try {
|
||||
rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
|
||||
} catch (Exception e) {
|
||||
log.error("发送商品信息变更Mq消息失败:", e);
|
||||
}
|
||||
}*/
|
||||
log.info("ProductService.--------------------------------------------库存更新成功");
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user