智能外呼为接同短信通知修改，外呼统计查询修改

zhongrj

2023-06-29 0e06fd9184c0cda32a8c55ed1f4a295305d647fd

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

@@ -27,9 +27,6 @@
   @Autowired
   private OutCallClient outCallClient;

   @Autowired
   private IXxlJobInfoService xxlJobInfoService;

   /**
    * 智能外呼定时创建任务执行器
    * @param param
@@ -47,30 +44,27 @@
      // 创建外呼任务
      List<String> result = outCallClient.createOutCallTaskJobHandler(isOver,taskScheduleTime,personNumber, day);
      XxlJobLogger.log("任务响应结果..." + result);
      if (result.get(2).equals("true")) {
         Integer jobId = 11;
         // 获取任务id
         String taskId = result.get(1);
         // 修改定时任务
         XxlJobInfo jobInfo = xxlJobInfoService.getById(jobId);
         // 解析参数
         Map mapParams = (Map) jobInfo.getExecutorParam();
         String time = mapParams.get("time").toString();
         XxlJobInfoVO xxlJobInfo = new XxlJobInfoVO();
         xxlJobInfo.setId(jobId);
         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);
         }
      }
      // 创建外呼短信发送任务记录
      Boolean flag = createCallSmsNoticeTask(result);
      XxlJobLogger.log("外呼短信通知任务创建结果:" + flag);
      XxlJobLogger.log("结束自动创建任务...");
      return ReturnT.SUCCESS;
   }

   /**
    * 创建外呼短信发送任务记录
    * @param result
    */
   private Boolean createCallSmsNoticeTask(List<String> result) {
      Boolean flag = false;
      if (null != result && result.size() > 0) {
         if (result.get(2).equals("true")) {
            // 获取任务id
            String taskId = result.get(1);
            flag = outCallClient.createCallSmsNoticeTask(taskId);
         }
      }
      return flag;
   }

   /**
@@ -86,31 +80,10 @@
      String taskScheduleTime = jsonParam.getString("taskScheduleTime");
      // 创建外呼任务
      List<String> result = outCallClient.createOutCallTaskByNotConnectJobHandler(taskScheduleTime);
      if (null != result && result.size() > 0) {
         if (result.get(2).equals("true")) {
            Integer jobId = 14;
            // 获取任务id
            String taskId = result.get(1);
            // 修改定时任务（前一天未接通今天又呼叫未接的短息通知）
            XxlJobInfo jobInfo = xxlJobInfoService.getById(jobId);
            // 解析参数
            Map mapParams = (Map) jobInfo.getExecutorParam();
            String time = mapParams.get("time").toString();
            XxlJobInfoVO xxlJobInfo = new XxlJobInfoVO();
            xxlJobInfo.setId(jobId);
            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("任务响应结果..." + result);
      // 创建外呼短信发送任务记录
      Boolean flag = createCallSmsNoticeTask(result);
      XxlJobLogger.log("外呼短信通知任务创建结果:" + flag);
      XxlJobLogger.log("结束自动创建任务...");
      return ReturnT.SUCCESS;
   }
@@ -121,17 +94,17 @@
    * @return
    * @throws Exception
    */
   @XxlJob("testOutCall")
   @XxlJob("testOutCall_0628")
   public ReturnT<String> testOutCall(String param){
      XxlJobLogger.log("开始执行任务...");
//      JSONObject jsonParam = JSON.parseObject(param);
      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);
      Object result = outCallClient.testOutCall("","","", "");
      XxlJobLogger.log("任务响应结果：" + result);
      XxlJobLogger.log("结束自动创建任务...");
      return ReturnT.SUCCESS;
   }