package cn.gistack.job.executor.jobhandler;
|
|
import cn.gistack.sm.intelligentCall.feign.OutCallClient;
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.xxl.job.core.log.XxlJobLogger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 智能外呼定时任务执行器
|
* @author zhongrj
|
* @date 2023-06-03
|
*/
|
@Component
|
public class OutCallXxlJob {
|
|
@Autowired
|
private OutCallClient outCallClient;
|
|
/**
|
* 智能外呼定时创建任务执行器
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("createOutCallTaskJobHandler")
|
public ReturnT<String> createOutCallTaskJobHandler(String param){
|
XxlJobLogger.log("开始执行任务...");
|
JSONObject jsonParam = JSON.parseObject(param);
|
String isOver = jsonParam.getString("isOver");
|
String taskScheduleTime = jsonParam.getString("taskScheduleTime");
|
String personNumber = jsonParam.getString("personNumber");
|
String day = jsonParam.getString("day");
|
// 创建外呼任务
|
Object result = outCallClient.createOutCallTaskJobHandler(isOver,taskScheduleTime,personNumber, day);
|
XxlJobLogger.log("任务响应结果：" + result);
|
XxlJobLogger.log("结束自动创建任务...");
|
return ReturnT.SUCCESS;
|
}
|
|
/**
|
* 测试
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("testOutCall")
|
public ReturnT<String> testOutCall(String param){
|
XxlJobLogger.log("开始执行任务...");
|
JSONObject jsonParam = JSON.parseObject(param);
|
String isOver = jsonParam.getString("isOver");
|
String taskScheduleTime = jsonParam.getString("taskScheduleTime");
|
String personNumber = jsonParam.getString("personNumber");
|
String day = jsonParam.getString("day");
|
// 创建外呼任务
|
Object result = outCallClient.testOutCall(isOver,taskScheduleTime,personNumber, day);
|
XxlJobLogger.log("任务响应结果：" + result);
|
XxlJobLogger.log("结束自动创建任务...");
|
return ReturnT.SUCCESS;
|
}
|
}
|
