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("结束自动创建任务..."); } }