package cn.gistack.job.executor.jobhandler;
|
|
import cn.gistack.alerts.sms.feign.ISmsRecordClient;
|
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.jetbrains.annotations.NotNull;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 短信定时发送任务执行器
|
* @author zhongrj
|
* @date 2023-06-03
|
*/
|
@Component
|
public class SendSmsXxlJob {
|
|
@Autowired
|
private ISmsRecordClient smsRecordClient;
|
|
/**
|
* 外呼未接通-发送短信
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("sendSmsByOutCallNotConnect")
|
public ReturnT<String> createOutCallTaskJobHandler(String param){
|
return getStringReturnT(param);
|
}
|
|
/**
|
* 外呼前一天未接通呼叫又未接通-发送短信(调度时间不一致，参数不一致)
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("sendSmsByBeforeOneDayOutCallNotConnect")
|
public ReturnT<String> sendSmsByBeforeOneDayOutCallNotConnect(String param){
|
return getStringReturnT(param);
|
}
|
|
@NotNull
|
private ReturnT<String> getStringReturnT(String param) {
|
XxlJobLogger.log("开始执行任务...");
|
JSONObject jsonParam = JSON.parseObject(param);
|
String taskId = jsonParam.getString("taskId");
|
String time = jsonParam.getString("time");
|
// 外呼未接通-发送短信
|
Object result = smsRecordClient.sendSmsByOutCallNotConnect(taskId, time);
|
XxlJobLogger.log("任务响应结果：" + result);
|
XxlJobLogger.log("结束自动创建任务...");
|
return ReturnT.SUCCESS;
|
}
|
}
|
