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

消息通知

Browse Source
This commit is contained in:
Tankaikai
2025-03-18 11:35:18 +08:00
parent 5fbc6b447f
commit f98a988b94
1 changed files with 5 additions and 5 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

@@ -10,10 +10,10 @@ import com.czg.product.dto.ProductStockSubtractDTO;
import com.czg.product.entity.*; import com.czg.product.entity.*;
import com.czg.product.enums.InOutItemEnum; import com.czg.product.enums.InOutItemEnum;
import com.czg.product.enums.InOutTypeEnum; import com.czg.product.enums.InOutTypeEnum;
import com.czg.product.service.ConsStockFlowService;
import com.czg.product.service.ProductRpcService; import com.czg.product.service.ProductRpcService;
import com.czg.product.service.ProductStockFlowService; import com.czg.product.service.ProductStockFlowService;
import com.czg.service.product.mapper.ConsInfoMapper; 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.ProdConsRelationMapper;
import com.czg.service.product.mapper.ProductMapper; import com.czg.service.product.mapper.ProductMapper;
import com.mybatisflex.core.query.QueryWrapper; import com.mybatisflex.core.query.QueryWrapper;
@@ -48,7 +48,7 @@ public class ProductRpcServiceImpl implements ProductRpcService {
private ConsInfoMapper consInfoMapper; private ConsInfoMapper consInfoMapper;
@Resource @Resource
private ConsStockFlowMapper consStockFlowMapper; private ConsStockFlowService consStockFlowService;
@Resource @Resource
private ProductStockFlowService productStockFlowService; private ProductStockFlowService productStockFlowService;
@Resource @Resource
@@ -122,7 +122,7 @@ public class ProductRpcServiceImpl implements ProductRpcService {
consStockFlow.setProductId(dto.getProductId()); consStockFlow.setProductId(dto.getProductId());
//consStockFlow.setSkuId(0L); //consStockFlow.setSkuId(0L);
consStockFlow.setOrderId(orderId); consStockFlow.setOrderId(orderId);
consStockFlowMapper.insert(consStockFlow); consStockFlowService.saveFlow(consStockFlow);
} }
} }
//ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); //ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)));
@@ -193,7 +193,7 @@ public class ProductRpcServiceImpl implements ProductRpcService {
consStockFlow.setProductId(dto.getProductId()); consStockFlow.setProductId(dto.getProductId());
//consStockFlow.setSkuId(0L); //consStockFlow.setSkuId(0L);
consStockFlow.setOrderId(orderId); consStockFlow.setOrderId(orderId);
consStockFlowMapper.insert(consStockFlow); consStockFlowService.saveFlow(consStockFlow);
} }
} }
//ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); //ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)));
@@ -267,7 +267,7 @@ public class ProductRpcServiceImpl implements ProductRpcService {
// consStockFlow.setSkuId(0L); // consStockFlow.setSkuId(0L);
consStockFlow.setOrderId(orderId); consStockFlow.setOrderId(orderId);
consStockFlow.setRemark("订单退款退菜归还库存"); consStockFlow.setRemark("订单退款退菜归还库存");
consStockFlowMapper.insert(consStockFlow); consStockFlowService.saveFlow(consStockFlow);
} }
} }
//ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId))); //ThreadUtil.execAsync(() -> rabbitPublisher.sendProductInfoChangeMsg(Convert.toStr(shopId)));