shasteel-biz/src/main/java/com/iailab/module/shasteel/mq/consumer/ModelAlarmConsumer.java

@@ -94,6 +94,12 @@
        log.info("已全部预测完成，清空finishModuleMap");
        ModelPredictFinishConsumer.finishModuleMap.clear();

        if (!ModelPredictFinishConsumer.finishAlarmMap.contains(predictTime.getTime())) {
            log.info("已全部预测完成，预警消息为空");
            return;
        }
        ModelPredictFinishConsumer.finishAlarmMap.clear();

        log.info("查找需要执行的调度方案");
        List<StScheduleSchemeDTO> scheduleSchemeList = mcsApi.listScheduleScheme(ScheduleTriggerMethodEnum.EVENT.getCode(), routingKey);
        if (CollectionUtils.isEmpty(scheduleSchemeList)) {