From 09ad90bf59bda77d7f58d6ebd0e85a17b9f46f71 Mon Sep 17 00:00:00 2001
From: panshuling321 <panshuling321@163.com>
Date: Wed, 29 Jun 2022 17:32:39 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=BC=82=E6=AD=A5=E5=A4=84?=
 =?UTF-8?q?=E7=90=86=E4=B8=AD=E9=97=B4=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../xhpc/activity/domain/XhpcClearingCheckoutDomain.java    | 2 +-
 .../service/impl/XhpcClearingCheckoutServiceImpl.java       | 1 +
 .../src/main/java/com/xhpc/activity/task/AsyncService.java  | 6 ++++++
 3 files changed, 8 insertions(+), 1 deletion(-)

diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcClearingCheckoutDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcClearingCheckoutDomain.java
index a3e15dc6..15aa4124 100644
--- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcClearingCheckoutDomain.java
+++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcClearingCheckoutDomain.java
@@ -57,7 +57,7 @@ public class XhpcClearingCheckoutDomain implements Serializable {
      */
     private BigDecimal receivedServiceAmount;
     /**
-     * 状态（0-已审核待清分，1-提现中，2-审核失败，3-审核成功，4-转账失败，5-转账成功，6-提现完成）
+     * 状态（0-已审核待清分，1-提现中，2-审核失败，3-审核成功，4-转账失败，5-转账成功，6-提现完成, 99-中间过渡状态，大量数据异步处理展示）
      */
     private Integer status;
 
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 2f2374b8..6b09fd91 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
@@ -169,6 +169,7 @@ public class XhpcClearingCheckoutServiceImpl extends BaseService implements Xhpc
             throw new CustomException("短信验证码错误，请重试");
         }
 
+        domain.setStatus(99);
         checkoutMapper.insert(domain);
 
         if (StringUtils.isEmpty(domain.getClearingOrderIds())) {
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 ea554722..d643cc2c 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
@@ -1,6 +1,7 @@
 package com.xhpc.activity.task;
 
 
+import com.xhpc.activity.mapper.XhpcClearingCheckoutMapper;
 import com.xhpc.activity.mapper.XhpcClearingHistoryOrderMapper;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
@@ -12,6 +13,9 @@ public class AsyncService {
     @Resource
     XhpcClearingHistoryOrderMapper historyOrderMapper;
 
+    @Resource
+    XhpcClearingCheckoutMapper checkoutMapper;
+
     /**
      * 审核待清分订单处理
      * @param orderIds
@@ -27,11 +31,13 @@ public class AsyncService {
     @Async
     public void updateCheckoutByOperatorAsync(Long operatorId, Long checkoutId){
         historyOrderMapper.updateCheckoutByOperator(operatorId, checkoutId);
+        checkoutMapper.updateStatusByIds(checkoutId.toString(), 1);
     }
 
 
     @Async
     public void updateCheckoutByOrderIdsAsync(String orderIds, Long checkoutId){
         historyOrderMapper.updateCheckoutByOrderId(orderIds, checkoutId);
+        checkoutMapper.updateStatusByIds(checkoutId.toString(), 1);
     }
 }