通道拥挤时 修改状态

This commit is contained in:
wangw 2025-04-22 11:41:58 +08:00
parent 9f6172b95c
commit 96ed240fc2
2 changed files with 10 additions and 1 deletions

View File

@ -111,7 +111,9 @@ public class TempOrdersTask {
// .lt(Orders::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)));
List<PayDetails> payDetailsList = payDetailsDao.selectList(new LambdaQueryWrapper<PayDetails>()
.eq(PayDetails::getState, 0)
.lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)));
.lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15))
.last(" order by create_time asc limit 1800")
);
if (CollUtil.isEmpty(payDetailsList)) {
return;
}

View File

@ -123,6 +123,13 @@ public class WuyouController {
payType);
if (baseResp.getCode() == null) {
if (baseResp.getErrorMsg().contains("通道拥挤")) {
order.setStatus(3);
ordersService.update(order, new LambdaQueryWrapper<Orders>()
.eq(Orders::getOrdersId, order.getOrdersId()).eq(Orders::getUserId, order.getUserId()));
payDetails.setState(2);
payDetailsDao.update(payDetails, new LambdaQueryWrapper<PayDetails>()
.eq(PayDetails::getId, payDetails.getId()).eq(PayDetails::getUserId, payDetails.getUserId()));
return Result.error("系统繁忙,请稍后再尝试购买");
}
return Result.error(baseResp.getErrorMsg());