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-03 16:27:36 +08:00
parent 4c1e0b6304
commit dd74371be2
3 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoRpcServiceImpl.java
View File

@@ -112,6 +112,7 @@ public class OrderInfoRpcServiceImpl implements OrderInfoRpcService {
}
@Override
//@GlobalTransactional
public void paySuccessCallback(Long orderId) {
// 下单后商品库存扣减，耗材扣减，流水记录
OrderInfo orderInfo = orderInfoMapper.selectOneById(orderId);
@@ -136,8 +137,13 @@ public class OrderInfoRpcServiceImpl implements OrderInfoRpcService {
data.put("num", NumberUtil.sub(num, refundNum));
dataList.add(data);
}
// 调用商品服务扣减库存
productRpcService.paySuccessSubtractStock(shopId, orderId, dataList);
try {
// 调用商品服务扣减库存
productRpcService.paySuccessSubtractStock(shopId, orderId, dataList);
} catch (Exception e) {
log.error("调用商品服务扣减库存失败", e);
throw e;
}
}
@Override
@@ -167,8 +173,13 @@ public class OrderInfoRpcServiceImpl implements OrderInfoRpcService {
data.put("num", NumberUtil.sub(num, refundNum));
dataList.add(data);
}
// 调用商品服务恢复库存
productRpcService.orderCancelRecoverStock(shopId, orderId, dataList);
try {
// 调用商品服务扣减库存
productRpcService.orderCancelRecoverStock(shopId, orderId, dataList);
} catch (Exception e) {
log.error("调用商品服务恢复库存", e);
throw e;
}
}
@Override