zhongrj
2023-06-19 07d02c7766ee86922c190c8ea170b352df485050
skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/SendSmsXxlJob.java
@@ -7,6 +7,7 @@
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;
@@ -29,12 +30,28 @@
    */
   @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;