| | |
| | | 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; |
| | | |
| | |
| | | */ |
| | | @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); |
| | | Object result = smsRecordClient.sendSmsByOutCallNotConnect(taskId, time); |
| | | XxlJobLogger.log("任务响应结果:" + result); |
| | | XxlJobLogger.log("结束自动创建任务..."); |
| | | return ReturnT.SUCCESS; |