shasteel-biz/src/main/java/com/iailab/module/shasteel/job/task/RunScheduleGasTask.java

@@ -9,6 +9,8 @@
import com.iailab.module.model.api.mdk.dto.MdkScheduleRespDTO;
import com.iailab.module.model.enums.CommonConstant;
import com.iailab.module.model.enums.ScheduleTriggerMethodEnum;
import com.iailab.module.shasteel.job.entity.MessageInfoEntity;
import com.iailab.module.shasteel.job.service.MessageInfoService;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -44,6 +46,9 @@

    @Autowired
    private MdkApi mdkApi;

    @Autowired
    private MessageInfoService messageInfoService;

    /**
     * 煤气调度调整方向
@@ -114,6 +119,19 @@
            saveScheduleSuggest("宏发12W煤气柜预警", result.get("LDG_2_warning_advice"), "LDG2_ALARM", predictTime, result.get("adjustValueLDG12W"), scheme.getAdjustRate(), scheme.getModelId(), scheme.getId());
            saveScheduleSuggest("转炉特钢12W煤气柜预警", result.get("LDG_3_warning_advice"), "LDGt_ALARM", predictTime, result.get("adjustValueLDG12WT"), scheme.getAdjustRate(), scheme.getModelId(), scheme.getId());

            // BFG应急预案
            if(!Objects.equals(result.get("BFG_Emergency_plan").toString(), "")){
                MessageInfoEntity messageInfoEntity = new MessageInfoEntity();
                messageInfoEntity.setTitle("BFG应急预案");
                messageInfoEntity.setContent(mdkScheduleRespDTO.getResult().get("BFG_Emergency_plan").toString());
                messageInfoEntity.setSendTime(mdkScheduleRespDTO.getScheduleTime());
                messageInfoEntity.setReadStatus("0");
                messageInfoEntity.setBusinessKey(mdkScheduleRespDTO.getScheduleCode());
                messageInfoEntity.setMessageSource("系统运行预警");
                messageInfoEntity.setCreateDate(new Date());
                messageInfoService.create(messageInfoEntity);
            }

            // 模拟调整
            MdkPredictSimAdjustReqDTO simAdjustReqDTO = new MdkPredictSimAdjustReqDTO();
            simAdjustReqDTO.setPredictTime(predictTime);