新增执行调度方案并下发点位接口

 iailab-module-model/iailab-module-model-api/src/main/java/com/iailab/module/model/api/mdk/MdkApi.java

@@ -58,4 +58,8 @@
    @PostMapping(PREFIX + "/predict-item/influenceFactorHandle")
    @Operation(summary = "影响因素计算")
    void influenceFactorHandle(@RequestBody MmPredictInfluenceFactorHandleReqVO reqVO);

    @PostMapping(PREFIX + "/schedule-scheme-out")
    @Operation(summary = "执行调度方案并下发点位")
    MdkScheduleRespDTO doScheduleAndOut(@Valid @RequestBody MdkScheduleReqDTO reqDTO);
}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/MdkApiImpl.java

@@ -429,4 +429,30 @@
    public void influenceFactorHandle(MmPredictInfluenceFactorHandleReqVO reqVO) {
        influenceFactorService.influenceFactorHandle(reqVO);
    }

    @Override
    public MdkScheduleRespDTO doScheduleAndOut(MdkScheduleReqDTO reqDTO) {
        MdkScheduleRespDTO resp = new MdkScheduleRespDTO();
        resp.setScheduleCode(reqDTO.getScheduleCode());
        resp.setScheduleTime(reqDTO.getScheduleTime());
        try {
            log.info("调度计算开始: " + System.currentTimeMillis());
            log.info("reqDTO=" + JSON.toJSONString(reqDTO));
            ScheduleResultVO scheduleResult = scheduleModelHandler.doSchedule(reqDTO.getScheduleCode(), reqDTO.getScheduleTime(),
                    reqDTO.getDynamicDataLength(), reqDTO.getDynamicSettings());
            resp.setStatusCode(scheduleResult.getResultCode());
            resp.setResult(scheduleResult.getResult());
            stScheduleRecordService.create(scheduleResult);
            stScheduleSchemeService.updateTime(scheduleResult.getSchemeId(), scheduleResult.getScheduleTime(), scheduleResult.getResultCode());
            log.info("调度计算结束: " + System.currentTimeMillis());
            log.info("调度计算结果开始下发");
            scheduleModelOut(resp);
            log.info("调度计算结果开始下发结束");
        } catch (Exception ex) {
            log.info("调度计算异常: " + System.currentTimeMillis());
            ex.printStackTrace();
            return resp;
        }
        return resp;
    }
}