diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java index d3e47994..259574ba 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java @@ -8,9 +8,11 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.context.properties.ConfigurationPropertiesScan; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.cloud.openfeign.EnableFeignClients; +import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.annotation.EnableScheduling; +@EnableAsync @EnableConfigurationProperties @ConfigurationPropertiesScan(basePackages = {"com.xhpc.activity.config"}) @EnableScheduling diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingHistoryOrderServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingHistoryOrderServiceImpl.java index 13ada4f3..fefe858a 100644 --- a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingHistoryOrderServiceImpl.java +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingHistoryOrderServiceImpl.java @@ -11,6 +11,7 @@ import com.xhpc.activity.mapper.XhpcClearingHistoryOrderMapper; import com.xhpc.activity.mapper.XhpcHistoryOrderMapper; import com.xhpc.activity.mapper.XhpcOperatorMapper; import com.xhpc.activity.service.XhpcClearingHistoryOrderService; +import com.xhpc.activity.task.AsyncService; import com.xhpc.activity.vo.ClearingOrderVo; import com.xhpc.common.core.exception.CustomException; import com.xhpc.common.core.utils.StringUtils; @@ -55,6 +56,8 @@ public class XhpcClearingHistoryOrderServiceImpl extends BaseService implements @Resource TokenService tokenService; + @Resource + AsyncService asyncService; @Override public List getPage(Map params) { @@ -106,12 +109,13 @@ public class XhpcClearingHistoryOrderServiceImpl extends BaseService implements String orderIds = orderDomainList.stream().map(n -> n.getClearingOrderId().toString()).collect(Collectors.joining(",")); if (StringUtils.isNotEmpty(orderIds)){ - historyOrderMapper.updateStatusBatchByOrderIds(orderIds, orderVo.getStatus(), orderVo.getCheckBy()); + asyncService.updateCheckStatusAsync(orderIds, orderVo.getStatus(), orderVo.getCheckBy()); } return true; } + @Override public void export(HttpServletResponse response, Map params) throws IOException { List list = historyOrderMapper.getListPage(params); 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 new file mode 100644 index 00000000..81a66710 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AsyncService.java @@ -0,0 +1,19 @@ +package com.xhpc.activity.task; + + +import com.xhpc.activity.mapper.XhpcClearingHistoryOrderMapper; +import org.springframework.scheduling.annotation.Async; +import org.springframework.stereotype.Service; + +import javax.annotation.Resource; + +@Service +public class AsyncService { + @Resource + XhpcClearingHistoryOrderMapper historyOrderMapper; + + @Async + public void updateCheckStatusAsync(String orderIds, Integer status, String checkBy){ + historyOrderMapper.updateStatusBatchByOrderIds(orderIds, status, checkBy); + } +}