czg_team/cashier-client
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

支付事务手动提交测试

Browse Source
This commit is contained in:
SongZhang
2024-10-16 17:32:57 +08:00
parent eae849e1e1
commit 5d7eb46e8a
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/chaozhanggui/system/cashierservice/service/PayService.java
View File

@@ -51,6 +51,7 @@ import javax.annotation.Resource;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
import java.util.*; import java.util.*;
import java.util.concurrent.TimeUnit;
import static com.chaozhanggui.system.cashierservice.sign.CodeEnum.ACCOUNTEIXST; import static com.chaozhanggui.system.cashierservice.sign.CodeEnum.ACCOUNTEIXST;
import static com.chaozhanggui.system.cashierservice.sign.CodeEnum.SUCCESS; import static com.chaozhanggui.system.cashierservice.sign.CodeEnum.SUCCESS;
@@ -1019,12 +1020,14 @@ public class PayService {
orderInfo.setPayOrderNo("cash".concat(SnowFlakeUtil.generateOrderNo())); orderInfo.setPayOrderNo("cash".concat(SnowFlakeUtil.generateOrderNo()));
tbOrderInfoMapper.updateByPrimaryKeySelective(orderInfo); tbOrderInfoMapper.updateByPrimaryKeySelective(orderInfo);
ThreadUtil.sleep(10);
// 提交当前事务 // 提交当前事务
transactionTemplate.execute((TransactionCallback<Void>) status -> { transactionTemplate.execute((TransactionCallback<Void>) status -> {
status.flush(); // 提交 status.flush(); // 提交
return null; return null;
}); });
log.info("已经手动提交事务");
ThreadUtil.sleep(10, TimeUnit.SECONDS);
//更新购物车状态 //更新购物车状态
int cartCount = tbCashierCartMapper.updateByOrderId(orderId, "final"); int cartCount = tbCashierCartMapper.updateByOrderId(orderId, "final");