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呼即办定时任务-结束自动创建任务..."); } }