From f98a988b945dbb4f4eca2e311b83f1191d2a4c49 Mon Sep 17 00:00:00 2001 From: Tankaikai Date: Tue, 18 Mar 2025 11:35:18 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=80=9A=E7=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../product/service/impl/ProductRpcServiceImpl.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 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 6ccf1bce9..a6ccd27cd 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 @@ -10,10 +10,10 @@ import com.czg.product.dto.ProductStockSubtractDTO; import com.czg.product.entity.*; import com.czg.product.enums.InOutItemEnum; import com.czg.product.enums.InOutTypeEnum; +import com.czg.product.service.ConsStockFlowService; import com.czg.product.service.ProductRpcService; import com.czg.product.service.ProductStockFlowService; import com.czg.service.product.mapper.ConsInfoMapper; -import com.czg.service.product.mapper.ConsStockFlowMapper; import com.czg.service.product.mapper.ProdConsRelationMapper; import com.czg.service.product.mapper.ProductMapper; import com.mybatisflex.core.query.QueryWrapper; @@ -48,7 +48,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { private ConsInfoMapper consInfoMapper; @Resource - private ConsStockFlowMapper consStockFlowMapper; + private ConsStockFlowService consStockFlowService; @Resource private ProductStockFlowService productStockFlowService; @Resource @@ -122,7 +122,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlow.setProductId(dto.getProductId()); //consStockFlow.setSkuId(0L); consStockFlow.setOrderId(orderId); - consStockFlowMapper.insert(consStockFlow); + consStockFlowService.saveFlow(consStockFlow); } } //ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); @@ -193,7 +193,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { consStockFlow.setProductId(dto.getProductId()); //consStockFlow.setSkuId(0L); consStockFlow.setOrderId(orderId); - consStockFlowMapper.insert(consStockFlow); + consStockFlowService.saveFlow(consStockFlow); } } //ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); @@ -267,7 +267,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { // consStockFlow.setSkuId(0L); consStockFlow.setOrderId(orderId); consStockFlow.setRemark("订单退款退菜归还库存"); - consStockFlowMapper.insert(consStockFlow); + consStockFlowService.saveFlow(consStockFlow); } } //ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)));