| | |
| | | * @param params |
| | | * @return |
| | | */ |
| | | boolean createCallTaskByParam(Map<String, Object> params); |
| | | Object createCallTaskByParam(Map<String, Object> params); |
| | | } |
| | |
| | | * @return |
| | | */ |
| | | @Override |
| | | public boolean createCallTaskByParam(Map<String, Object> params) { |
| | | public Object createCallTaskByParam(Map<String, Object> params) { |
| | | // 自动创建任务的 4个条件 1:呼叫人数 2:调度时间 3:是否超汛限 4:多少天内呼叫过的不呼叫(天数) |
| | | //1. 调用中台接口查询出所有需要发任务的水库巡查责任人相关信息(该处需要将是否超汛限条件传入) |
| | | JSONArray jsonArray = getZtWaterMangerData(params); |
| | |
| | | params.put("list",setForListMap(taskRandomList)); |
| | | // 调度时间处理 |
| | | params.put("taskScheduleTime",new SimpleDateFormat("yyyy-MM-dd").format(new Date())+ " " +params.get("taskScheduleTime") + ":00"); |
| | | // 创建任务 |
| | | createTask(params); |
| | | //5. 返回 |
| | | return true; |
| | | // 创建任务并返回结果 |
| | | return createTask(params); |
| | | } |
| | | |
| | | /** |
| | |
| | | map.put("personNumber",jsonParam.getString("personNumber")); |
| | | map.put("day",jsonParam.getString("day")); |
| | | // 创建外呼任务 |
| | | callService.createCallTaskByParam(map); |
| | | Object result = callService.createCallTaskByParam(map); |
| | | XxlJobLogger.log("任务响应结果:" + result); |
| | | XxlJobLogger.log("结束自动创建任务..."); |
| | | return ReturnT.SUCCESS; |
| | | } |