This commit is contained in:
xy
2026-04-02 09:33:33 +08:00
parent dbe09d70f4
commit c0cccc3479
2 changed files with 5 additions and 2 deletions

View File

@@ -286,6 +286,9 @@ public class CustomReportServiceImpl implements CustomReportService {
DictData gridSideDictData = dicDataFeignClient.getDicDataByCode(GRID_SIDE_DICT_CODE).getData();
CsLinePO gridSideLine = linePOList.stream().filter(linePO -> linePO.getPosition().equals(gridSideDictData.getId())).findFirst().orElse(null);
CsLinePO loadSideLine = linePOList.stream().filter(linePO -> linePO.getPosition().equals(loadSideDictData.getId())).findFirst().orElse(null);
if(Objects.isNull(gridSideLine) || Objects.isNull(loadSideLine)) {
throw new BusinessException("电网侧与负载侧监测点缺失,无法生成报告!");
}
String tempId = getTempId(queryParam.getTempId(), Objects.isNull(gridSideLine)? loadSideLine.getLineId():gridSideLine.getLineId());

View File

@@ -20,13 +20,13 @@ public class DataTask {
private final IDataTaskService taskService;
@Scheduled(cron = "0 0 2 * * ?")
@Scheduled(cron = "0 0 4 * * ?")
public void csHarmonicJob() {
String date = DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN);
taskService.channelHarmonic(date);
}
@Scheduled(cron = "0 0 3 * * ?")
@Scheduled(cron = "0 0 5 * * ?")
public void csAlarmJob() {
String date = DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN);
taskService.channelRunAlarm(date);