| | |
| | | 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; |
| | |
| | | |
| | | @Autowired |
| | | private MdkApi mdkApi; |
| | | |
| | | @Autowired |
| | | private MessageInfoService messageInfoService; |
| | | |
| | | private Map<String, StScheduleSchemeDTO> schemeMap = new HashMap<>(); |
| | | |
| | |
| | | |
| | | String advice = entry.getValue().getResult().get("advice").toString(); |
| | | if(adviceValues.compareTo(BigDecimal.ZERO) != 0){ |
| | | saveScheduleSuggest("各制氧机组建议", advice, scheduleObj, scheduleTime, adviceValues, scheduleScheme.getAdjustRate()); |
| | | saveScheduleSuggest("各制氧机组建议", advice, scheduleObj, scheduleTime, adviceValues, scheduleScheme.getAdjustRate(), scheduleScheme.getModelId(), scheduleScheme.getId()); |
| | | } |
| | | |
| | | } else if (entry.getKey().equals(CODE01)) { |
| | |
| | | mcsApi.createScheduleSuggest(suggest); |
| | | } |
| | | |
| | | private void saveScheduleSuggest(String title, String content, String scheduleObj, Date scheduleTime, BigDecimal adjustValue, int adjustRate) { |
| | | private void saveScheduleSuggest(String title, String content, String scheduleObj, Date scheduleTime, BigDecimal adjustValue, int adjustRate, String modelId, String schemeId) { |
| | | if (StringUtils.isBlank(content)) { |
| | | logger.info(title + "调整值为空,不产生建议"); |
| | | return; |
| | |
| | | suggest.setContent(content); |
| | | suggest.setScheduleObj(scheduleObj); |
| | | suggest.setScheduleTime(scheduleTime); |
| | | suggest.setModelId(modelId); |
| | | suggest.setSchemeId(schemeId); |
| | | suggest.setSort(0); |
| | | mcsApi.createScheduleSuggest(suggest); |
| | | } |