外呼短信通知逻辑修改

zhongrj

2023-06-17 3e27630f0102a9fa590ce029df0994535eb86bd6

 skjcmanager/skjcmanager-service/skjcmanager-xxljob/src/main/java/cn/gistack/job/executor/jobhandler/OutCallXxlJob.java

@@ -47,27 +47,45 @@
      // 创建外呼任务
      List<String> result = outCallClient.createOutCallTaskJobHandler(isOver,taskScheduleTime,personNumber, day);
      XxlJobLogger.log("任务响应结果..." + result);
//      if (result.get(2).equals("true")) {
//         // 获取任务id
//         String taskId = result.get(1);
//         // 修改定时任务
//         XxlJobInfo jobInfo = xxlJobInfoService.getById(11);
//         // 解析参数
//         Map mapParams = (Map) jobInfo.getExecutorParam();
//         String time = mapParams.get("time").toString();
//         XxlJobInfoVO xxlJobInfo = new XxlJobInfoVO();
//         xxlJobInfo.setId(11);
//         Map<String, Object> map = new HashMap<>(2);
//         map.put("taskId", taskId);
//         map.put("time", time);
//         xxlJobInfo.setExecutorParam(map);
//         Object o = xxlJobInfoService.updateXxlJobById(xxlJobInfo);
//         if (Boolean.parseBoolean(o.toString())) {
//            XxlJobLogger.log("外呼未接通短信通知定时任务修改成功！任务ID:" + taskId);
//         }else {
//            XxlJobLogger.log("外呼未接通短信通知定时任务修改失败！任务ID:" + taskId);
//         }
//      }
      if (result.get(2).equals("true")) {
         // 获取任务id
         String taskId = result.get(1);
         // 修改定时任务
         XxlJobInfo jobInfo = xxlJobInfoService.getById(11);
         // 解析参数
         Map mapParams = (Map) jobInfo.getExecutorParam();
         String time = mapParams.get("time").toString();
         XxlJobInfoVO xxlJobInfo = new XxlJobInfoVO();
         xxlJobInfo.setId(11);
         Map<String, Object> map = new HashMap<>(2);
         map.put("taskId", taskId);
         map.put("time", time);
         xxlJobInfo.setExecutorParam(map);
         Object o = xxlJobInfoService.updateXxlJobById(xxlJobInfo);
         if (Boolean.parseBoolean(o.toString())) {
            XxlJobLogger.log("外呼未接通短信通知定时任务修改成功！任务ID:" + taskId);
         }else {
            XxlJobLogger.log("外呼未接通短信通知定时任务修改失败！任务ID:" + taskId);
         }
      }
      XxlJobLogger.log("结束自动创建任务...");
      return ReturnT.SUCCESS;
   }

   /**
    * 智能外呼未接通呼叫
    * @param param
    * @return
    * @throws Exception
    */
   @XxlJob("createOutCallTaskByNotConnectJobHandler_test")
   public ReturnT<String> createOutCallTaskByNotConnectJobHandler(String param){
      XxlJobLogger.log("开始执行智能外呼未接通呼叫任务...");
      JSONObject jsonParam = JSON.parseObject(param);
      String taskScheduleTime = jsonParam.getString("taskScheduleTime");
      // 创建外呼任务
      List<String> result = outCallClient.createOutCallTaskByNotConnectJobHandler(taskScheduleTime);
      XxlJobLogger.log("任务响应结果..." + result);
      XxlJobLogger.log("结束自动创建任务...");
      return ReturnT.SUCCESS;
   }