通过E呼即办数据统计

linwe

2024-05-29 c10d6358b9f014375a13821465bc978d0c0da22e

 src/main/java/org/springblade/xxljob/jobhandler/LabelHandleJob.java

@@ -7,6 +7,8 @@
import com.xxl.job.core.handler.annotation.XxlJob;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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;
@@ -17,6 +19,12 @@
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.ZoneId;
import java.time.ZonedDateTime;
import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.TimeUnit;
@@ -34,6 +42,9 @@
    @Autowired
   private ITaskService taskService;

   @Autowired
   private EcOrderService ecOrderService;

    /**
     * 三色定时任务
     */
@@ -49,4 +60,53 @@
      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("结束自动创建任务...");
   }


   /**
    * 创建校园安全发送短信定时任务
    */
   @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);
      ecOrderParamDTO.setStartTime(yesterdayStart);
      boolean result = ecOrderService.SynchronizeData(ecOrderParamDTO);
      XxlJobHelper.log("任务响应结果..." + result);
      // 创建居住证发送短信定时任务
      XxlJobHelper.log("E呼即办定时任务-结束自动创建任务...");
   }

}