package cn.gistack.job.executor.jobhandler;
|
|
import cn.gistack.alerts.notice.feign.NoticeClient;
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.xxl.job.core.log.XxlJobLogger;
|
import feign.Request;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* 告警定时任务执行器
|
* @author zhongrj
|
* @date 2023-06-03
|
*/
|
@Component
|
public class AlarmXxlJob {
|
|
@Autowired
|
private NoticeClient noticeClient;
|
|
/**
|
* 策略1: 水位信息接收不到-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterInfoNotHandle")
|
public ReturnT<String> waterInfoNotHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位信息接收不到","","waterInfoNotHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略2: 水位数据异常-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterDataExcHandle")
|
public ReturnT<String> waterDataExcHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位数据异常","","waterDataExcHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略3: 水位超低于死水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterLessDeadHandle")
|
public ReturnT<String> waterLessDeadHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位超低于死水位","","waterLessDeadHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略4: 水位高于死水位，低于旱警水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterMoreDeadLessHJHandle")
|
public ReturnT<String> waterMoreDeadLessHJHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位高于死水位，低于旱警水位","","waterMoreDeadLessHJHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略5: 水位接近汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterComeOverHandle")
|
public ReturnT<String> waterComeOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位接近汛限告警","","waterComeOverHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略6: 水位初次超汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterFirstOverHandle")
|
public ReturnT<String> waterFirstOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位初次超汛限告警","","waterFirstOverHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略7: 水位小幅超汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterSmallScaleOverHandle")
|
public ReturnT<String> waterSmallScaleOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位小幅超汛限告警","","waterSmallScaleOverHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略8: 水位大幅超汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterBigScaleOverHandle")
|
public ReturnT<String> waterBigScaleOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位大幅超汛限告警","","waterBigScaleOverHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略9: 水位接近设计洪水位告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterComeDesignHandle")
|
public ReturnT<String> waterComeDesignHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位接近设计洪水位告警","","waterComeDesignHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略10: 水位超设计洪水位告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterMoreDesignHandle")
|
public ReturnT<String> waterMoreDesignHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位超设计洪水位告警","","waterMoreDesignHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略11: 水位超校核洪水位告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterMoreCheckHandle")
|
public ReturnT<String> waterMoreCheckHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("水位超校核洪水位告警","","waterMoreCheckHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略12: 近1h水位陡升-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterComeOneHourUpHandle")
|
public ReturnT<String> waterComeOneHourUpHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡升","","waterComeOneHourUpHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略13: 近1h水位陡降-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterComeOneHourDownHandle")
|
public ReturnT<String> waterComeOneHourDownHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡降","","waterComeOneHourDownHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略14: 暴雨降雨预警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("rainstormHandle")
|
public ReturnT<String> rainstormHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("暴雨降雨预警","","rainstormHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略15: 已降大雨告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("alreadyHeavyRainHandle")
|
public ReturnT<String> alreadyHeavyRainHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("已降大雨告警","","alreadyHeavyRainHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略16: 已降暴雨告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("alreadyRainstormHandle")
|
public ReturnT<String> alreadyRainstormHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("已降暴雨告警","","alreadyRainstormHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略17: 2小时降雨告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("twoHourRainHandle")
|
public ReturnT<String> twoHourRainHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("2小时降雨告警","","twoHourRainHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略18: 6小时降雨告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("sixHourRainHandle")
|
public ReturnT<String> sixHourRainHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("6小时降雨告警","","sixHourRainHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略19: 大坝安全监测告警-监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyHandle")
|
public ReturnT<String> damSafetyHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetyHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略20: 大坝安全监测告警-测压管水位大于校核洪水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyHandle")
|
public ReturnT<String> damSafetySyHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("测压管水位大于校核洪水位","","damSafetySyHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略21: 大坝安全监测告警-渗压监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyNoneHandle")
|
public ReturnT<String> damSafetySyNoneHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetySyNoneHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略22: 大坝安全监测告警-渗流监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySlNoneHandle")
|
public ReturnT<String> damSafetySlNoneHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetySlNoneHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略23: 大坝安全监测告警-位移监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyWyNoneHandle")
|
public ReturnT<String> damSafetyWyNoneHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetyWyNoneHandle");
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
}
|
