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

发放券问题 事务嵌套

Browse Source
This commit is contained in:
wangw
2025-12-12 09:46:35 +08:00
parent 4e15007e17
commit 6295ddf73b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoCustomServiceImpl.java
View File

@@ -1220,6 +1220,7 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
* 其它支付为 tb_order_payment.id * 其它支付为 tb_order_payment.id
*/ */
@Override @Override
@Transactional
public void upOrderInfo(OrderInfo orderInfo, BigDecimal payAmount, LocalDateTime payTime, Long payOrderId, PayEnums payType) { public void upOrderInfo(OrderInfo orderInfo, BigDecimal payAmount, LocalDateTime payTime, Long payOrderId, PayEnums payType) {
OrderInfo upOrderInfo = new OrderInfo() OrderInfo upOrderInfo = new OrderInfo()
.setId(orderInfo.getId()) .setId(orderInfo.getId())
@@ -1247,10 +1248,10 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
orderDetailService.updateOrderDetailStatus(orderInfo.getId(), OrderStatusEnums.DONE.getCode()); orderDetailService.updateOrderDetailStatus(orderInfo.getId(), OrderStatusEnums.DONE.getCode());
if (orderInfo.getUserId() != null) { if (orderInfo.getUserId() != null) {
exShopUserInfo(orderInfo); ThreadUtil.execAsync(() -> exShopUserInfo(orderInfo));
} }
if (StrUtil.isNotBlank(orderInfo.getTableCode())) { if (StrUtil.isNotBlank(orderInfo.getTableCode())) {
exTable(orderInfo); ThreadUtil.execAsync(() -> exTable(orderInfo));
} }
// 保存消息参数（避免闭包中引用的变量被修改） // 保存消息参数（避免闭包中引用的变量被修改）
final Long orderId = orderInfo.getId(); final Long orderId = orderInfo.getId();
@@ -1279,7 +1280,7 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
} }
//订单回调后 跟用户相关的部分 //订单回调后 跟用户相关的部分
@Async // @Async
public void exShopUserInfo(OrderInfo orderInfo) { public void exShopUserInfo(OrderInfo orderInfo) {
ShopUser shopUser = shopUserService.getShopUserInfo(orderInfo.getShopId(), orderInfo.getUserId()); ShopUser shopUser = shopUserService.getShopUserInfo(orderInfo.getShopId(), orderInfo.getUserId());
if (shopUser == null) { if (shopUser == null) {
@@ -1332,7 +1333,6 @@ public class OrderInfoCustomServiceImpl implements OrderInfoCustomService {
} }
} }
@Async
public void exTable(OrderInfo orderInfo) { public void exTable(OrderInfo orderInfo) {
ShopTable table = shopTableService.getOneByTableCode(orderInfo.getShopId(), orderInfo.getTableCode()); ShopTable table = shopTableService.getOneByTableCode(orderInfo.getShopId(), orderInfo.getTableCode());
if (table != null) { if (table != null) {