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.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.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;
|
|
/**
|
* 校园安全自查定时任务-绿色
|
*/
|
@XxlJob("campusSecurityJobHandler")
|
public void campusSecurityJobHandler (String param){
|
XxlJobHelper.log("开始执行任务...");
|
JSONObject jsonParam = JSON.parseObject(param);
|
String color = jsonParam.getString("color");
|
// 校园安全检查
|
Integer reportType = 6;
|
// 根据类型创建任务
|
boolean result = taskService.createTaskJob(reportType,color);
|
XxlJobHelper.log("任务响应结果..." + result);
|
// 创建外呼短信发送任务记录
|
XxlJobHelper.log("结束自动创建任务...");
|
}
|
|
}
|
