|
@@ -141,6 +141,9 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
|
@Autowired
|
|
|
private MusicAlbumService musicAlbumService;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private UserOrderService userOrderService;
|
|
|
+
|
|
|
//验证订单是否可以下单,获取订单金额信息
|
|
|
private static final Map<GoodTypeEnum, Function<OrderReq.OrderReqInfo, HttpResponseResult<OrderCreateRes>>> orderCreate = new HashMap<>();
|
|
|
//插入订单后执行
|
|
@@ -282,7 +285,7 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
|
|
|
|
|
|
|
@Override
|
|
|
- @Transactional(rollbackFor = Exception.class)
|
|
|
+// @Transactional(rollbackFor = Exception.class)
|
|
|
public void setSuccessStatus() {
|
|
|
OrderSearch query = new OrderSearch();
|
|
|
query.setPaymentVersion(EPaymentVersion.V1);
|
|
@@ -291,7 +294,7 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
|
for (UserOrderVo userOrderVo : userOrderVos) {
|
|
|
DistributedLock.of(redissonClient)
|
|
|
.runIfLockCanGet(CacheNameEnum.LOCK_EXECUTE_ORDER.getRedisKey(userOrderVo.getOrderNo())
|
|
|
- , () -> testOrderSuccess(userOrderVo.getOrderNo()), 60L, TimeUnit.SECONDS);
|
|
|
+ , () -> userOrderService.testOrderSuccess(userOrderVo.getOrderNo()), 60L, TimeUnit.SECONDS);
|
|
|
}
|
|
|
|
|
|
query.setPaymentVersion(EPaymentVersion.V2);
|
|
@@ -1312,6 +1315,7 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
|
return BigDecimal.ZERO;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public void testOrderSuccess(String orderNo) {
|
|
|
if (StringUtil.isEmpty(orderNo)) {
|