From b0d113cceb99f59be67b025f28037289c4674a98 Mon Sep 17 00:00:00 2001
From: panshuling321 <panshuling321@163.com>
Date: Wed, 29 Jun 2022 11:38:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=8F=90=E7=8E=B0=E7=94=B3?=
 =?UTF-8?q?=E8=AF=B7=E4=BF=AE=E6=94=B9=E4=B8=BA=E5=BC=82=E6=AD=A5=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/XhpcClearingCheckoutServiceImpl.java  | 10 +++++-----
 .../com/xhpc/activity/task/AsyncService.java   | 18 ++++++++++++++++++
 2 files changed, 23 insertions(+), 5 deletions(-)

diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingCheckoutServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingCheckoutServiceImpl.java
index eae1fbf0..2f2374b8 100644
--- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingCheckoutServiceImpl.java
+++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingCheckoutServiceImpl.java
@@ -13,6 +13,7 @@ import com.xhpc.activity.mapper.XhpcClearingCheckoutMapper;
 import com.xhpc.activity.mapper.XhpcClearingHistoryOrderMapper;
 import com.xhpc.activity.mapper.XhpcClearingReceiptMapper;
 import com.xhpc.activity.service.XhpcClearingCheckoutService;
+import com.xhpc.activity.task.AsyncService;
 import com.xhpc.activity.utils.DownloadUtil;
 import com.xhpc.activity.vo.CheckoutBankVo;
 import com.xhpc.activity.vo.ClearingReceiptVo;
@@ -68,6 +69,8 @@ public class XhpcClearingCheckoutServiceImpl extends BaseService implements Xhpc
     @Resource
     TokenService tokenService;
 
+    @Resource
+    AsyncService asyncService;
 
     @Override
     public List<XhpcClearingCheckoutDomain> getPage(Map<String, Object> params) {
@@ -169,13 +172,10 @@ public class XhpcClearingCheckoutServiceImpl extends BaseService implements Xhpc
         checkoutMapper.insert(domain);
 
         if (StringUtils.isEmpty(domain.getClearingOrderIds())) {
-            historyOrderMapper.updateCheckoutByOperator(domain.getOperatorId(), domain.getClearingCheckoutId());
+            asyncService.updateCheckoutByOperatorAsync(domain.getOperatorId(), domain.getClearingCheckoutId());
         } else {
-            // ...
-            historyOrderMapper.updateCheckoutByOrderId(domain.getClearingOrderIds(), domain.getClearingCheckoutId());
+            asyncService.updateCheckoutByOrderIdsAsync(domain.getClearingOrderIds(), domain.getClearingCheckoutId());
         }
-
-
         return true;
     }
 
diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AsyncService.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AsyncService.java
index 81a66710..ea554722 100644
--- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AsyncService.java
+++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AsyncService.java
@@ -12,8 +12,26 @@ public class AsyncService {
     @Resource
     XhpcClearingHistoryOrderMapper historyOrderMapper;
 
+    /**
+     * 审核待清分订单处理
+     * @param orderIds
+     * @param status
+     * @param checkBy
+     */
     @Async
     public void updateCheckStatusAsync(String orderIds, Integer status, String checkBy){
         historyOrderMapper.updateStatusBatchByOrderIds(orderIds, status, checkBy);
     }
+
+
+    @Async
+    public void updateCheckoutByOperatorAsync(Long operatorId, Long checkoutId){
+        historyOrderMapper.updateCheckoutByOperator(operatorId, checkoutId);
+    }
+
+
+    @Async
+    public void updateCheckoutByOrderIdsAsync(String orderIds, Long checkoutId){
+        historyOrderMapper.updateCheckoutByOrderId(orderIds, checkoutId);
+    }
 }