ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingTraceModelGXJTask.java

@@ -5,6 +5,7 @@
import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.module.ansteel.coking.service.*;
import com.iailab.module.ansteel.common.constant.CommonConstant;
import com.iailab.module.ansteel.common.enums.TraceProcessTypeEnum;
import com.iailab.module.model.api.mcs.McsApi;
import com.iailab.module.model.api.mdk.MdkApi;
import org.slf4j.Logger;
@@ -49,7 +50,7 @@
    @Autowired
    private MdkApi mdkApi;

    private final static String process = "干熄焦工序";
    private final static String process = TraceProcessTypeEnum.GXJ.getProcess();

    private final static String reportName = "干熄焦工序异常溯源";

@@ -60,6 +61,9 @@
    private final static String total = "steamTotal1";

    private final static String SugObj = "GXJ";

    @Autowired
    private CokingTraceChartService cokingTraceChartService;

    private static final String jsonStr = "{\"result\":{" +
            " \"steamProd\":[[0.76,0.76],[07,0.72],[0.74,0.68]]," +
@@ -92,16 +96,20 @@
            Date startDate = calendar.getTime();
            String clock = DateUtils.format(startDate);

            // 调用模型
/*            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
            dto.setScheduleTime(calendar.getTime());
            dto.setScheduleCode(params);
            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
            Map<String, Object> result = mdkScheduleRespDTO.getResult();
            calendar.add(Calendar.DAY_OF_YEAR, 1);
            calendar.add(Calendar.MINUTE, -3);
            Date collectStartDate = calendar.getTime();

            JSONObject jsonObject = new JSONObject(result);
            JSONObject result2 = (JSONObject) JSON.toJSON(jsonObject.get("result"));*/
            // 调用模型
//            MdkScheduleReqDTO dto = new MdkScheduleReqDTO();
//            dto.setScheduleTime(calendar.getTime());
//            dto.setScheduleCode(params);
//            MdkScheduleRespDTO mdkScheduleRespDTO = mdkApi.doSchedule(dto);
//            logger.info(params + "调度方案执行完成，" + mdkScheduleRespDTO);
//
//            Map<String, Object> tResult = mdkScheduleRespDTO.getResult();
//            JSONObject result = new JSONObject(tResult);
//            logger.info("result===" +  JSONObject.toJSONString(result));

            JSONObject jsonObject = JSONObject.parseObject(jsonStr);
            JSONObject result = (JSONObject) JSON.toJSON(jsonObject.get("result"));
@@ -113,19 +121,23 @@
            // 保存报告
            String analyDate = DateUtils.format(startDate);
            String analyContent = clock + " " + result.getString("steamHomeIndexInfo");
            String content = result.getString(total);
            String relId = cokingTraceReportService.save(process, reportName, analyDate, clock, analyContent);

            // 保存一级分析指标
            cokingAnalyIndService.saveAnalyInd(relId, process, analyDate, analyContent);

            // 保存优化建议
            cokingTraceSuggestService.saveTraceSuggest(relId, process, clock, total, SugObj);
            cokingTraceSuggestService.saveTraceSuggest(relId, process, clock, content, SugObj);

            // 保存偏差值
            cokingTraceDeviationService.saveTraceDeviation(relId, process, clock, result, CommonConstant.COKE_INDEX_CHARTCODE, row, SugObj);

            // 保存溯源指标
            cokingTraceIndService.saveTraceInd(relId, indType, clock);
            cokingTraceIndService.saveTraceInd(relId, indType, clock, collectStartDate, endDate);

            // 保存溯源折线图
            cokingTraceChartService.save(relId, clock, indType, startDate, endDate);

        } catch (Exception ex) {
            logger.error("RunCokingTraceModelGXJTask运行异常");