From 126a9ac6c5136562cc531343ca7f0c3d0b47fcd3 Mon Sep 17 00:00:00 2001 From: Tankaikai Date: Thu, 6 Mar 2025 16:41:59 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E5=95=86=E5=93=81=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=8F=98=E5=8A=A8=E5=88=B7=E6=96=B0=E5=BA=93=E5=AD=98=202.=20?= =?UTF-8?q?=E5=95=86=E5=93=81=E4=BF=A1=E6=81=AF=E5=8F=98=E5=8A=A8=E5=8F=91?= =?UTF-8?q?=E7=94=9FMq=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../product/service/impl/ProductRpcServiceImpl.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java index c29b724b7..641b582b2 100644 --- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java +++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ProductRpcServiceImpl.java @@ -167,7 +167,10 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlowMapper.insert(consStockFlow); } } - rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); + ThreadUtil.execAsync(() -> { + rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); + }); + log.info("ProductService.--------------------------------------------库存更新成功"); } @Override @@ -221,6 +224,9 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlowMapper.insert(consStockFlow); } } - rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); + ThreadUtil.execAsync(() -> { + rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)); + }); + log.info("ProductService.--------------------------------------------库存更新成功"); } }