diff --git a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/TempController.java b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/TempController.java index 25aa6485a..7d494f3b7 100644 --- a/jsowell-admin/src/main/java/com/jsowell/api/uniapp/TempController.java +++ b/jsowell-admin/src/main/java/com/jsowell/api/uniapp/TempController.java @@ -103,11 +103,11 @@ public class TempController extends BaseController { public RestApiResponse tempGenerateDailyOrderReports(@RequestBody QueryOrderDTO dto) { RestApiResponse response = null; try { - String startTime = dto.getStartTime(); String endTime = dto.getEndTime(); - orderBasicInfoService.generateDailyOrderReports(dto.getStationId(), startTime, endTime); + dto.getStationIdList().parallelStream().forEach(x -> orderBasicInfoService.generateDailyOrderReports(x, startTime, endTime)); + response = new RestApiResponse<>(); } catch (BusinessException e) { logger.warn("临时接口计算站点订单报表 warn", e); diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/dto/QueryOrderDTO.java b/jsowell-pile/src/main/java/com/jsowell/pile/dto/QueryOrderDTO.java index 9b8ab1ad9..60464e16c 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/dto/QueryOrderDTO.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/dto/QueryOrderDTO.java @@ -51,6 +51,8 @@ public class QueryOrderDTO extends BaseEntity { */ private String stationId; + private List stationIdList; + /** * 运营商Id */ diff --git a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java index 55ae0845a..6b77e67d8 100644 --- a/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java +++ b/jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java @@ -2053,6 +2053,7 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService { @Override public void generateDailyOrderReports(String stationId, String startTime, String endTime) { + // logger.info("线程名===={}", Thread.currentThread().getName()); if (StringUtils.isBlank(stationId)) { return; }