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

/**
 * 三色标签定时任务执行器
 * @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.log("开始执行任务...");

		// 校园安全检查
		// 根据类型创建任务
		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("结束自动创建任务...");
	}


	/**
	 * 创建校园安全发送短信定时任务
	 */
	@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呼即办定时任务-结束自动创建任务...");
	}

}