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); } }