|
@@ -203,7 +203,7 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
public void setSuccessStatus() {
|
|
public void setSuccessStatus() {
|
|
OrderSearch query = new OrderSearch();
|
|
OrderSearch query = new OrderSearch();
|
|
query.setStatus("WAIT_PAY,PAYING");
|
|
query.setStatus("WAIT_PAY,PAYING");
|
|
- List<UserOrderVo> userOrderVos = selectList(query);
|
|
|
|
|
|
+ List<UserOrderVo> userOrderVos = selectAllList(query);
|
|
for (UserOrderVo userOrderVo : userOrderVos) {
|
|
for (UserOrderVo userOrderVo : userOrderVos) {
|
|
testOrderSuccess(userOrderVo);
|
|
testOrderSuccess(userOrderVo);
|
|
}
|
|
}
|
|
@@ -244,8 +244,8 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
- public List<UserOrderVo> selectList(OrderSearch query) {
|
|
|
|
- return baseMapper.selectList(query);
|
|
|
|
|
|
+ public List<UserOrderVo> selectAllList(OrderSearch query) {
|
|
|
|
+ return baseMapper.selectAllList(query);
|
|
}
|
|
}
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@@ -346,7 +346,7 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
search.setStatus(OrderStatusEnum.WAIT_PAY.getCode());
|
|
search.setStatus(OrderStatusEnum.WAIT_PAY.getCode());
|
|
search.setEndTime(LocalDateTime.now().minusMinutes(30));
|
|
search.setEndTime(LocalDateTime.now().minusMinutes(30));
|
|
//查询待支付订单
|
|
//查询待支付订单
|
|
- List<UserOrderVo> waitPayOrderList = baseMapper.selectList(search);
|
|
|
|
|
|
+ List<UserOrderVo> waitPayOrderList = baseMapper.selectAllList(search);
|
|
for (UserOrderVo orderVo : waitPayOrderList) {
|
|
for (UserOrderVo orderVo : waitPayOrderList) {
|
|
//取消订单要获取锁,防止在轮询取消时,用户修改订单状态
|
|
//取消订单要获取锁,防止在轮询取消时,用户修改订单状态
|
|
boolean b = DistributedLock.of(redissonClient)
|
|
boolean b = DistributedLock.of(redissonClient)
|
|
@@ -357,7 +357,7 @@ public class UserOrderServiceImpl extends ServiceImpl<UserOrderDao, UserOrder> i
|
|
search.setStatus(OrderStatusEnum.PAYING.getCode());
|
|
search.setStatus(OrderStatusEnum.PAYING.getCode());
|
|
search.setEndTime(LocalDateTime.now().minusMinutes(120));
|
|
search.setEndTime(LocalDateTime.now().minusMinutes(120));
|
|
//查询待支付中订单
|
|
//查询待支付中订单
|
|
- List<UserOrderVo> payingOrderList = baseMapper.selectList(search);
|
|
|
|
|
|
+ List<UserOrderVo> payingOrderList = baseMapper.selectAllList(search);
|
|
for (UserOrderVo orderVo : payingOrderList) {
|
|
for (UserOrderVo orderVo : payingOrderList) {
|
|
//取消订单要获取锁,防止在轮询取消时,用户修改订单状态
|
|
//取消订单要获取锁,防止在轮询取消时,用户修改订单状态
|
|
boolean b = DistributedLock.of(redissonClient)
|
|
boolean b = DistributedLock.of(redissonClient)
|