| | |
| | | } |
| | | |
| | | // 根据条件查找方案 |
| | | List<StScheduleSchemeDTO> schemeList = mcsApi.listScheduleScheme(ScheduleTriggerMethodEnum.EVENT.getCode(), params); |
| | | List<StScheduleSchemeDTO> schemeList = mcsApi.listScheduleScheme(ScheduleTriggerMethodEnum.JOB.getCode(), params); |
| | | if (CollectionUtils.isEmpty(schemeList)) { |
| | | logger.info("方案为空"); |
| | | return; |
| | |
| | | dto.setScheduleTime(scheduleTime); |
| | | dto.setScheduleCode(scheme.getCode()); |
| | | MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto); |
| | | |
| | | // 结果写入测点 |
| | | |
| | | |
| | | mdkApi.scheduleModelOut(mdkScheduleRespDTO); |
| | | } |
| | | logger.info(params + "调度方案执行完成"); |
| | | } catch (Exception ex) { |