package org.springblade.xxljob.jobhandler; import cn.hutool.core.date.DatePattern; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; import org.apache.commons.lang3.StringUtils; import org.springblade.core.tool.utils.DateUtil; import org.springblade.modules.eCallEventTwo.dto.EcOrderParamDTO; import org.springblade.modules.eCallEventTwo.service.EcOrderService; 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; @Component public class SynchronizationEhjb { @Autowired private EcOrderService ecOrderService; @XxlJob("ehjbJobHandler") public void ehjbJobHandler() { String param = XxlJobHelper.getJobParam(); XxlJobHelper.log("开始执行任务..." + param); // 校园安全检查 // 根据类型创建任务 XxlJobHelper.log("开始执行任务...E呼即办定时任务"); LocalDateTime localDateTime; if (StringUtils.isNotBlank(param)) { // 时间字符串转LocalDateTime localDateTime = cn.hutool.core.date.DateUtil.parseLocalDateTime(param, DatePattern.NORM_DATETIME_PATTERN); } else { // 获取当前日期时间 localDateTime = LocalDateTime.now(); } // 创建居住证发送短信定时任务 EcOrderParamDTO ecOrderParamDTO = new EcOrderParamDTO(); // 获取前一天的开始时间 LocalDateTime yesterdayStart = localDateTime.minus(1, ChronoUnit.DAYS).with(LocalTime.MIN); // 获取前一天的结束时间 LocalDateTime yesterdayEnd = localDateTime.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呼即办定时任务-结束自动创建任务..."); } }