| | |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public String createTask(Map<String,Object> map) { |
|---|
| | | public List<String> createTask(Map<String,Object> map) { |
|---|
| | | List<Map<String, String>> params = (List<Map<String, String>>) map.get("list"); |
|---|
| | | String requestUrl = url + CREATE_TASK_URL; |
|---|
| | | LocalDateTime now = LocalDateTime.now(); |
|---|
| | |
|---|
| | | if (response.getStatusCode() != HttpStatus.OK) { |
|---|
| | | log.error("创建智能外呼任务失败：{}", response.getStatusCode()); |
|---|
| | | } |
|---|
| | | return response.getBody(); |
|---|
| | | JSONObject jsonObject = JSON.parseObject(response.getBody()); |
|---|
| | | Boolean success = jsonObject.getBoolean("success"); |
|---|
| | | String taskId = ""; |
|---|
| | | if (success){ |
|---|
| | | //通过任务名称查询taskId |
|---|
| | | taskId = callTaskMapper.getTaskIdByTaskName(taskName); |
|---|
| | | } |
|---|
| | | List<String> list = new ArrayList<>(); |
|---|
| | | list.add(response.getBody()); |
|---|
| | | list.add(taskId); |
|---|
| | | list.add(success.toString()); |
|---|
| | | // 返回 |
|---|
| | | return list; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | @Override |
|---|
| | | public String createCallTaskByParam(Map<String, Object> params) { |
|---|
| | | public List<String> createCallTaskByParam(Map<String, Object> params) { |
|---|
| | | // 自动创建任务的 4个条件 1：呼叫人数 2：调度时间 3：是否超汛限 4：多少天内呼叫过的不呼叫（天数） |
|---|
| | | //1. 调用中台接口查询出所有需要发任务的水库巡查责任人相关信息（该处需要将是否超汛限条件传入） |
|---|
| | | JSONArray jsonArray = getZtWaterMangerData(params); |
|---|
