From f301614936ea843c3ff610fda9620e7d741f4c55 Mon Sep 17 00:00:00 2001
From: wangw <1594593906@qq.com>
Date: Fri, 14 Mar 2025 11:20:22 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E8=B6=85=E6=97=B6=20?=
 =?UTF-8?q?=E5=8F=96=E6=B6=88=E8=AE=A2=E5=8D=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../order/service/impl/OrderInfoServiceImpl.java   | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java
index fc4af1174..d60ba4096 100644
--- a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java
+++ b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderInfoServiceImpl.java
@@ -1,8 +1,10 @@
 package com.czg.service.order.service.impl;
 
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.convert.Convert;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.exceptions.ValidateException;
+import cn.hutool.core.thread.ThreadUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.ObjectUtil;
 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);
             } else {
                 if (!orderInfo.getStatus().equals(OrderStatusEnums.CANCELLED.getCode())) {
-                    updateChain()
-                            .set(OrderInfo::getStatus, OrderStatusEnums.CANCELLED.getCode())
-                            .eq(OrderInfo::getId, param.getOrderId())
-                            .update();
-                    rabbitPublisher.sendOrderCancelMsg(orderInfo.getId().toString());
+                    ThreadUtil.execAsync(() -> {
+                        updateChain()
+                                .set(OrderInfo::getStatus, OrderStatusEnums.CANCELLED.getCode())
+                                .eq(OrderInfo::getId, param.getOrderId())
+                                .update();
+                        rabbitPublisher.sendOrderCancelMsg(orderInfo.getId().toString());
+                    });
                 }
                 throw new ValidateException("订单已过期,请重新下单");
             }