基层智治-后台
blame | history | patch | commit | commitdiff | ignore whitespace
linwe
2024-08-09 8b7258c9427882bb1798f1502eaa35184c6e374e 
 src/main/java/org/springblade/xxljob/jobhandler/LabelHandleJob.java


@@ -1,33 +1,19 @@


package org.springblade.xxljob.jobhandler;




import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.xxl.job.core.biz.model.ReturnT;


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.io.BufferedInputStream;


import java.io.BufferedReader;


import java.io.DataOutputStream;


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;




/**


 * 三色标签定时任务执行器


@@ -42,15 +28,14 @@


    @Autowired


   private ITaskService taskService;




   @Autowired


   private EcOrderService ecOrderService;




    /**


     * 三色定时任务


     */


    @XxlJob("threeColourJobHandler")


    public void threeColourJobHandler (String param){


      XxlJobHelper.log("开始执行任务...");


    public void threeColourJobHandler (){


      String param = XxlJobHelper.getJobParam();




      XxlJobHelper.log("开始执行任务..."+param);




      // 校园安全检查


      // 根据类型创建任务


@@ -87,25 +72,6 @@


   }






   /**


    * 创建校园安全发送短信定时任务 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);


      ecOrderParamDTO.setStartTime(yesterdayStart);


      boolean result = ecOrderService.SynchronizeData(ecOrderParamDTO);


      XxlJobHelper.log("任务响应结果..." + result);


      XxlJobHelper.log("E呼即办定时任务-结束自动创建任务...");


   }






}