yuyang/XH-Power-Cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新审核待清分订单改成异步执行

Browse Source
This commit is contained in:
panshuling321 2022-06-29 11:22:54 +08:00
parent d05148e8c0
commit 9743fe4047
3 changed files with 26 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java
View File

@ -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

6
xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcClearingHistoryOrderServiceImpl.java
View File

@ -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<XhpcClearingHistoryOrderDomain> getPage(Map<String, Object> 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<String, Object> params) throws IOException {
List<XhpcClearingHistoryOrderDomain> list = historyOrderMapper.getListPage(params);

19
xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/task/AsyncService.java Normal file
View File

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