update 优化计算订单日报

This commit is contained in:
2023-07-14 14:22:36 +08:00
parent af72427dc4
commit 5ed33739bd
3 changed files with 5 additions and 2 deletions

View File

@@ -103,11 +103,11 @@ public class TempController extends BaseController {
public RestApiResponse<?> tempGenerateDailyOrderReports(@RequestBody QueryOrderDTO dto) { public RestApiResponse<?> tempGenerateDailyOrderReports(@RequestBody QueryOrderDTO dto) {
RestApiResponse<?> response = null; RestApiResponse<?> response = null;
try { try {
String startTime = dto.getStartTime(); String startTime = dto.getStartTime();
String endTime = dto.getEndTime(); String endTime = dto.getEndTime();
orderBasicInfoService.generateDailyOrderReports(dto.getStationId(), startTime, endTime); dto.getStationIdList().parallelStream().forEach(x -> orderBasicInfoService.generateDailyOrderReports(x, startTime, endTime));
response = new RestApiResponse<>(); response = new RestApiResponse<>();
} catch (BusinessException e) { } catch (BusinessException e) {
logger.warn("临时接口计算站点订单报表 warn", e); logger.warn("临时接口计算站点订单报表 warn", e);

View File

@@ -51,6 +51,8 @@ public class QueryOrderDTO extends BaseEntity {
*/ */
private String stationId; private String stationId;
private List<String> stationIdList;
/** /**
* 运营商Id * 运营商Id
*/ */

View File

@@ -2053,6 +2053,7 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService {
@Override @Override
public void generateDailyOrderReports(String stationId, String startTime, String endTime) { public void generateDailyOrderReports(String stationId, String startTime, String endTime) {
// logger.info("线程名===={}", Thread.currentThread().getName());
if (StringUtils.isBlank(stationId)) { if (StringUtils.isBlank(stationId)) {
return; return;
} }