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-03-14 11:20:22 +08:00
parent c566cc2dd2
commit f301614936
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java
View File

@@ -1,8 +1,10 @@
package com.czg.service.order.service.impl; package com.czg.service.order.service.impl;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.exceptions.ValidateException; import cn.hutool.core.exceptions.ValidateException;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
@@ -247,11 +249,13 @@ public class OrderInfoServiceImpl extends ServiceImpl<OrderInfoMapper, OrderInfo
redisService.set(RedisCst.classKeyExpired.EXPIRED_ORDER + param.getOrderId(), "", 60 * 15); redisService.set(RedisCst.classKeyExpired.EXPIRED_ORDER + param.getOrderId(), "", 60 * 15);
} else { } else {
if (!orderInfo.getStatus().equals(OrderStatusEnums.CANCELLED.getCode())) { if (!orderInfo.getStatus().equals(OrderStatusEnums.CANCELLED.getCode())) {
updateChain() ThreadUtil.execAsync(() -> {
.set(OrderInfo::getStatus, OrderStatusEnums.CANCELLED.getCode()) updateChain()
.eq(OrderInfo::getId, param.getOrderId()) .set(OrderInfo::getStatus, OrderStatusEnums.CANCELLED.getCode())
.update(); .eq(OrderInfo::getId, param.getOrderId())
rabbitPublisher.sendOrderCancelMsg(orderInfo.getId().toString()); .update();
rabbitPublisher.sendOrderCancelMsg(orderInfo.getId().toString());
});
} }
throw new ValidateException("订单已过期,请重新下单"); throw new ValidateException("订单已过期,请重新下单");
} }