czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1. 商品信息变动刷新库存

Browse Source 
2. 商品信息变动发生Mq消息
This commit is contained in:
Tankaikai
2025-03-06 16:41:59 +08:00
parent b9e023df97
commit 126a9ac6c5
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java
View File

@@ -167,7 +167,10 @@ public class ProductRpcServiceImpl implements ProductRpcService {
consStockFlowMapper.insert(consStockFlow); consStockFlowMapper.insert(consStockFlow);
} }
} }
rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); ThreadUtil.execAsync(() -> {
rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
});
log.info("ProductService.--------------------------------------------库存更新成功");
} }
@Override @Override
@@ -221,6 +224,9 @@ public class ProductRpcServiceImpl implements ProductRpcService {
consStockFlowMapper.insert(consStockFlow); consStockFlowMapper.insert(consStockFlow);
} }
} }
rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); ThreadUtil.execAsync(() -> {
rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId));
});
log.info("ProductService.--------------------------------------------库存更新成功");
} }
} }