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.ExecutorService;
|
import java.util.concurrent.Executors;
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位信息接收不到","","waterInfoNotHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略2: 水位数据异常-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterDataExcHandle")
|
public ReturnT<String> waterDataExcHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位数据异常","","waterDataExcHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略3: 水位超低于死水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterLessDeadHandle")
|
public ReturnT<String> waterLessDeadHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位超低于死水位","","waterLessDeadHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略4: 水位高于死水位，低于旱警水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterMoreDeadLessHJHandle")
|
public ReturnT<String> waterMoreDeadLessHJHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位高于死水位，低于旱警水位","","waterMoreDeadLessHJHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略5: 水位接近汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterComeOverHandle")
|
public ReturnT<String> waterComeOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位接近汛限告警","","waterComeOverHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略6: 水位初次超汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterFirstOverHandle")
|
public ReturnT<String> waterFirstOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位初次超汛限告警","","waterFirstOverHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略7: 水位小幅超汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterSmallScaleOverHandle")
|
public ReturnT<String> waterSmallScaleOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位小幅超汛限告警","","waterSmallScaleOverHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略8: 水位大幅超汛限告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterBigScaleOverHandle")
|
public ReturnT<String> waterBigScaleOverHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位大幅超汛限告警","","waterBigScaleOverHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略9: 水位接近设计洪水位告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterComeDesignHandle")
|
public ReturnT<String> waterComeDesignHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位接近设计洪水位告警","","waterComeDesignHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略10: 水位超设计洪水位告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterMoreDesignHandle")
|
public ReturnT<String> waterMoreDesignHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位超设计洪水位告警","","waterMoreDesignHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略11: 水位超校核洪水位告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("waterMoreCheckHandle")
|
public ReturnT<String> waterMoreCheckHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("暴雨降雨预警","","rainstormHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略15: 已降大雨告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("alreadyHeavyRainHandle")
|
public ReturnT<String> alreadyHeavyRainHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("已降大雨告警","","alreadyHeavyRainHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略16: 已降暴雨告警-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("alreadyRainstormHandle")
|
public ReturnT<String> alreadyRainstormHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
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("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("监测数据缺失","","damSafetyHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略20: 大坝安全监测告警-测压管水位大于校核洪水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyHandle")
|
public ReturnT<String> damSafetySyHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("测压管水位大于校核洪水位","","damSafetySyHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略21: 大坝安全监测告警-渗压监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyNoneHandle")
|
public ReturnT<String> damSafetySyNoneHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("渗压监测数据缺失","","damSafetySyNoneHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略22: 大坝安全监测告警-渗流监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySlNoneHandle")
|
public ReturnT<String> damSafetySlNoneHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("渗流监测数据缺失","","damSafetySlNoneHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略23: 大坝安全监测告警-位移监测数据缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyWyNoneHandle")
|
public ReturnT<String> damSafetyWyNoneHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("变形监测数据缺失","","damSafetyWyNoneHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略24: 大坝安全监测告警-渗压资料缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyDataMissingHandle")
|
public ReturnT<String> damSafetySyDataMissingHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("渗压资料缺失","","damSafetySyDataMissingHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略25: 大坝安全监测告警-变形资料缺失-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyBxDataMissingHandle")
|
public ReturnT<String> damSafetyBxDataMissingHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("变形资料缺失","","damSafetyBxDataMissingHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略26: 大坝安全监测告警-水位低于管底高程-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyLessThenPipeHandle")
|
public ReturnT<String> damSafetySyLessThenPipeHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位低于管底高程","","damSafetySyLessThenPipeHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略27: 大坝安全监测告警-水位大于管口高程-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyHigherThenNozzleHandle")
|
public ReturnT<String> damSafetySyHigherThenNozzleHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位大于管口高程","","damSafetySyHigherThenNozzleHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略28: 大坝安全监测告警-水位大于坝顶高程-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyHigherThenBdElevationHandle")
|
public ReturnT<String> damSafetySyHigherThenBdElevationHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位大于坝顶高程","","damSafetySyHigherThenBdElevationHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略29: 大坝安全监测告警-水位大于库水位-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyHigherThenWaterLevelHandle")
|
public ReturnT<String> damSafetySyHigherThenWaterLevelHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位大于库水位","","damSafetySyHigherThenWaterLevelHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略30: 大坝安全监测告警-水位长期不变，五日变幅小于5cm，十日变幅大于5cm小于8cm，三十日变幅大于8cm小于10cm-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyYellowChangeHandle")
|
public ReturnT<String> damSafetySyYellowChangeHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位变幅黄色告警","","damSafetySyYellowChangeHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略31: 大坝安全监测告警-渗压水位一日变幅大于0.5米小于1米，五日变幅大于1米小于2米，十日变幅大于2米小于5米，三十日变幅大于5米小于10米-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyOrangeChangeHandle")
|
public ReturnT<String> damSafetySyOrangeChangeHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位变幅橙色告警","","damSafetySyOrangeChangeHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略32: 大坝安全监测告警-渗压水位一日变幅大于1米小于2米，五日变幅大于2米小于5米，十日变幅大于5米小于10米，三十日变幅大于10米-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyRedChangeHandle")
|
public ReturnT<String> damSafetySyRedChangeHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("水位变幅红色告警","","damSafetySyRedChangeHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略33: 大坝安全监测告警-近1h水位陡降-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySyRz1hChangeHandle")
|
public ReturnT<String> damSafetySyRz1hChangeHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("近1h水位陡升陡降","","damSafetySyRz1hChangeHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略34: 大坝安全监测告警-变形值大于2cm小于5cm-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyWyOver2Less5Handle")
|
public ReturnT<String> damSafetyWyOver2Less5Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("变形值大于2cm小于5cm","","damSafetyWyOver2Less5Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略35: 大坝安全监测告警-变形值大于5cm小于10cm-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyWyOver5Less10Handle")
|
public ReturnT<String> damSafetyWyOver5Less10Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("变形值大于5cm小于10cm","","damSafetyWyOver5Less10Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略36: 大坝安全监测告警-变形值大于10cm以上-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyWyOver10Handle")
|
public ReturnT<String> damSafetyWyOver10Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("变形值大于10cm以上","","damSafetyWyOver10Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略37: 大坝安全监测告警-近1h变形值大于10cm以上-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetyWy1hChangeOver10Handle")
|
public ReturnT<String> damSafetyWy1hChangeOver10Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("近1h变形值大于10cm以上","","damSafetyWy1hChangeOver10Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
/**
|
* 策略38: 大坝安全监测告警-渗流量一日大于5L小于8L，连续3日增加-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySlOver5Less8Handle")
|
public ReturnT<String> damSafetySlOver5Less8Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于5L小于8L连续3日增加","","damSafetySlOver5Less8Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略39: 大坝安全监测告警-渗流量一日大于8L小于10L，连续3日增加-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySlOver8Less10Handle")
|
public ReturnT<String> damSafetySlOver8Less10Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于8L小于10L连续3日增加","","damSafetySlOver8Less10Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略40: 大坝安全监测告警-渗流量一日大于10L以上，连续3日增加-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("damSafetySlOver10Handle")
|
public ReturnT<String> damSafetySlOver10Handle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("渗流量一日大于10L连续3日增加","","damSafetySlOver10Handle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 策略41: 视频告警-视频信息接收不到-定时任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("videoOfflineHandle")
|
public ReturnT<String> videoOfflineHandle(String param){
|
XxlJobLogger.log("开始执行任务...");
|
// 创建外呼任务
|
ExecutorService executorService = Executors.newSingleThreadExecutor();
|
executorService.submit(() -> {
|
// 这里是你的异步任务逻辑
|
noticeClient.createAlarmNoticeTaskJobHandler("视频信息接收不到","","videoOfflineHandle");
|
});
|
|
XxlJobLogger.log("结束自动创建任务...");
|
// 返回
|
return ReturnT.SUCCESS;
|
}
|
|
|
}
|
