package org.springblade.xxljob.jobhandler;
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springblade.core.tool.utils.DateUtil;
|
import org.springblade.modules.eCallEventTwo.dto.EcOrderParamDTO;
|
import org.springblade.modules.eCallEventTwo.service.EcOrderService;
|
import org.springblade.modules.task.service.ITaskService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.time.LocalDateTime;
|
import java.time.LocalTime;
|
import java.time.temporal.ChronoUnit;
|
|
/**
|
* 三色标签定时任务执行器
|
* @author zhongrj
|
* @date 2024-01-10
|
*/
|
@Component
|
public class LabelHandleJob {
|
|
private static Logger logger = LoggerFactory.getLogger(LabelHandleJob.class);
|
|
@Autowired
|
private ITaskService taskService;
|
|
@Autowired
|
private EcOrderService ecOrderService;
|
|
/**
|
* 三色定时任务
|
*/
|
@XxlJob("threeColourJobHandler")
|
public void threeColourJobHandler (){
|
String param = XxlJobHelper.getJobParam();
|
|
XxlJobHelper.log("开始执行任务..."+param);
|
|
// 校园安全检查
|
// 根据类型创建任务
|
boolean result = taskService.createTaskJob(param);
|
XxlJobHelper.log("任务响应结果..." + result);
|
// 创建外呼短信发送任务记录
|
XxlJobHelper.log("结束自动创建任务...");
|
}
|
|
/**
|
* 创建居住证发送短信定时任务
|
*/
|
@XxlJob("residenceSendSmsJobHandler")
|
public void residenceJobHandler (String param){
|
XxlJobHelper.log("开始执行任务...创建居住证发送短信定时任务");
|
// 创建居住证发送短信定时任务
|
boolean result = taskService.createResidenceSendSms(param);
|
XxlJobHelper.log("任务响应结果..." + result);
|
// 创建居住证发送短信定时任务
|
XxlJobHelper.log("结束自动创建任务...");
|
}
|
|
/**
|
* 创建校园安全发送短信定时任务
|
*/
|
@XxlJob("schoolSendSmsJobHandler")
|
public void schoolJobHandler (String param){
|
XxlJobHelper.log("开始执行任务...创建校园安全发送短信定时任务");
|
// 创建居住证发送短信定时任务
|
boolean result = taskService.createSchoolSendSms(param);
|
XxlJobHelper.log("任务响应结果..." + result);
|
// 创建居住证发送短信定时任务
|
XxlJobHelper.log("结束自动创建任务...");
|
}
|
|
|
/**
|
* 创建校园安全发送短信定时任务 0 15 0 * * ?
|
*/
|
@XxlJob("ehjbJobHandler")
|
public void ehjbJobHandler (){
|
XxlJobHelper.log("开始执行任务...E呼即办定时任务");
|
// 创建居住证发送短信定时任务
|
EcOrderParamDTO ecOrderParamDTO = new EcOrderParamDTO();
|
// 获取当前日期时间
|
LocalDateTime now = LocalDateTime.now();
|
// 获取前一天的开始时间
|
LocalDateTime yesterdayStart = now.minus(1, ChronoUnit.DAYS).with(LocalTime.MIN);
|
// 获取前一天的结束时间
|
LocalDateTime yesterdayEnd = now.minus(1, ChronoUnit.DAYS).with(LocalTime.MAX);
|
ecOrderParamDTO.setEndTime(yesterdayEnd.format(DateUtil.DATETIME_FORMATTER));
|
ecOrderParamDTO.setStartTime(yesterdayStart.format(DateUtil.DATETIME_FORMATTER));
|
boolean result = ecOrderService.SynchronizeData(ecOrderParamDTO);
|
XxlJobHelper.log("任务响应结果..." + result);
|
XxlJobHelper.log("E呼即办定时任务-结束自动创建任务...");
|
}
|
|
}
|
