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)));