From 5fbc6b447fed6cf86c702979bbfc23555b76d1c5 Mon Sep 17 00:00:00 2001 From: Tankaikai Date: Tue, 18 Mar 2025 11:33:48 +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 --- .../service/impl/ProductRpcServiceImpl.java | 14 +++++++++----- 1 file changed, 9 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 05f5c0ff7..6ccf1bce9 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 @@ -11,7 +11,11 @@ import com.czg.product.entity.*; import com.czg.product.enums.InOutItemEnum; import com.czg.product.enums.InOutTypeEnum; import com.czg.product.service.ProductRpcService; -import com.czg.service.product.mapper.*; +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; import jakarta.annotation.Resource; import lombok.extern.slf4j.Slf4j; @@ -46,7 +50,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { @Resource private ConsStockFlowMapper consStockFlowMapper; @Resource - private ProductStockFlowMapper productStockFlowMapper; + private ProductStockFlowService productStockFlowService; @Resource private RabbitPublisher rabbitPublisher; @@ -77,7 +81,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { flow.setInOutType(InOutTypeEnum.OUT.value()); flow.setInOutItem(InOutItemEnum.ORDER_OUT.value()); flow.setOrderId(orderId); - productStockFlowMapper.insert(flow); + productStockFlowService.saveFlow(flow); // 查询商品绑定耗材信息 List relationList = prodConsRelationMapper.selectListByQuery(QueryWrapper.create().eq(ProdConsRelation::getProductId, dto.getProductId())); if (CollUtil.isEmpty(relationList)) { @@ -149,7 +153,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { flow.setInOutType(InOutTypeEnum.IN.value()); flow.setInOutItem(InOutItemEnum.ORDER_IN.value()); flow.setOrderId(orderId); - productStockFlowMapper.insert(flow); + productStockFlowService.saveFlow(flow); // 查询商品绑定耗材信息 List relationList = prodConsRelationMapper.selectListByQuery(QueryWrapper.create().eq(ProdConsRelation::getProductId, dto.getProductId())); if (CollUtil.isEmpty(relationList)) { @@ -222,7 +226,7 @@ public class ProductRpcServiceImpl implements ProductRpcService { flow.setInOutType(InOutTypeEnum.IN.value()); flow.setInOutItem(InOutItemEnum.ORDER_IN.value()); flow.setOrderId(orderId); - productStockFlowMapper.insert(flow); + productStockFlowService.saveFlow(flow); // 查询商品绑定耗材信息 List relationList = prodConsRelationMapper.selectListByQuery(QueryWrapper.create().eq(ProdConsRelation::getProductId, dto.getProductId())); if (CollUtil.isEmpty(relationList)) {