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

@@ -131,7 +131,9 @@
                // 调整速率
                String scheduleObjLDG = "LDG";
                BigDecimal adjustValue = new BigDecimal(mdkScheduleRespDTO.getResult().get(flag).toString());
                if (gasAdjustMode.containsKey(scheduleObjLDG) && gasAdjustMode.get(scheduleObjLDG).equals(adjustValue) &&
                if (adjustValue.compareTo(BigDecimal.ZERO) == 0) {
                    logger.info("转炉实时调度建议 flag为0");
                }else if (gasAdjustMode.containsKey(scheduleObjLDG) && gasAdjustMode.get(scheduleObjLDG).equals(adjustValue) &&
                        gasLastSugTime.containsKey(scheduleObjLDG) && (calendar.getTime().getTime() - gasLastSugTime.get(scheduleObjLDG).getTime() <= mdkScheduleRespDTO.getAdjustRate().longValue() * 60 * 1000)) {
                    logger.info("转炉实时调度建议在有效期内");
                } else {
@@ -150,9 +152,10 @@
                            logger.error("转炉实时调度建议保存失败");
                        }
                    }
                    // 更新调整速率
                    gasAdjustMode.put(scheduleObjLDG, adjustValue);
                    gasLastSugTime.put(scheduleObjLDG, calendar.getTime());
                }
                gasAdjustMode.put(scheduleObjLDG, adjustValue);
                gasLastSugTime.put(scheduleObjLDG, calendar.getTime());
                // 预警
                Object earlywarning = mdkScheduleRespDTO.getResult().get(warningKey);
                if (earlywarning != null && StringUtils.isNotBlank(earlywarning.toString())) {
@@ -175,7 +178,9 @@
                // 调整速率
                String scheduleObjCOG = "COG";
                BigDecimal adjustValue = new BigDecimal(mdkScheduleRespDTO.getResult().get(flag).toString());
                if (gasAdjustMode.containsKey(scheduleObjCOG) && gasAdjustMode.get(scheduleObjCOG).equals(adjustValue) &&
                if (adjustValue.compareTo(BigDecimal.ZERO) == 0) {
                    logger.info("焦炉实时调度建议 flag为0");
                }else if (gasAdjustMode.containsKey(scheduleObjCOG) && gasAdjustMode.get(scheduleObjCOG).equals(adjustValue) &&
                        gasLastSugTime.containsKey(scheduleObjCOG) && (calendar.getTime().getTime() - gasLastSugTime.get(scheduleObjCOG).getTime() <= mdkScheduleRespDTO.getAdjustRate().longValue() * 60 * 1000)) {
                    logger.info("焦炉实时调度建议在有效期内");
                }else {
@@ -225,6 +230,9 @@
                            logger.error("焦炉实时调度建议保存失败");
                        }
                    }
                    // 更新调整速率
                    gasAdjustMode.put(scheduleObjCOG, adjustValue);
                    gasLastSugTime.put(scheduleObjCOG, calendar.getTime());
                }

                // 预警
@@ -267,7 +275,9 @@
                // 调整速率
                String scheduleObjBFG = "BFG";
                BigDecimal adjustValue = new BigDecimal(mdkScheduleRespDTO.getResult().get(flag).toString());
                if (gasAdjustMode.containsKey(scheduleObjBFG) && gasAdjustMode.get(scheduleObjBFG).equals(adjustValue) &&
                if (adjustValue.compareTo(BigDecimal.ZERO) == 0) {
                    logger.info("高炉实时调度建议 flag为0");
                }else if (gasAdjustMode.containsKey(scheduleObjBFG) && gasAdjustMode.get(scheduleObjBFG).equals(adjustValue) &&
                        gasLastSugTime.containsKey(scheduleObjBFG) && (calendar.getTime().getTime() - gasLastSugTime.get(scheduleObjBFG).getTime() <= mdkScheduleRespDTO.getAdjustRate().longValue() * 60 * 1000)) {
                    logger.info("高炉实时调度建议在有效期内");
                }else {
@@ -317,6 +327,9 @@
                            logger.error("高炉实时调度建议保存失败");
                        }
                    }
                    // 更新调整速率
                    gasAdjustMode.put(scheduleObjBFG, adjustValue);
                    gasLastSugTime.put(scheduleObjBFG, calendar.getTime());
                }
                // 预警
                Object earlywarning = mdkScheduleRespDTO.getResult().get(warningKey);