From 3034cf73ed5a404aba506f0cf8ee04ab8d814fa0 Mon Sep 17 00:00:00 2001 From: haown <454902499@qq.com> Date: Fri, 20 Sep 2024 17:16:09 +0800 Subject: [PATCH] =?UTF-8?q?=E7=99=BE=E5=BA=A6=E5=A4=96=E5=91=BC=E5=88=9B?= =?UTF-8?q?=E5=BB=BA=E5=AE=9E=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/aibo/AIOBController.java | 17 +++++++ .../manage/dto/aibo/ActualTimeTaskDto.java | 50 +++++++++++++++++++ .../manage/service/aibo/IAIOBService.java | 10 ++++ .../service/aibo/impl/AIOBServiceImpl.java | 27 +++++++++- 4 files changed, 103 insertions(+), 1 deletion(-) create mode 100644 postdischarge-manage/src/main/java/com/xinelu/manage/dto/aibo/ActualTimeTaskDto.java diff --git a/postdischarge-manage/src/main/java/com/xinelu/manage/controller/aibo/AIOBController.java b/postdischarge-manage/src/main/java/com/xinelu/manage/controller/aibo/AIOBController.java index 4676debf..9bd62040 100644 --- a/postdischarge-manage/src/main/java/com/xinelu/manage/controller/aibo/AIOBController.java +++ b/postdischarge-manage/src/main/java/com/xinelu/manage/controller/aibo/AIOBController.java @@ -4,12 +4,14 @@ import com.alibaba.fastjson2.JSONObject; import com.aliyuncs.exceptions.ClientException; import com.xinelu.common.core.controller.BaseController; import com.xinelu.common.core.domain.R; +import com.xinelu.manage.dto.aibo.ActualTimeTaskDto; import com.xinelu.manage.dto.aibo.CreateTaskDto; import com.xinelu.manage.dto.aibo.TaskCallbackDto; import com.xinelu.manage.service.aibo.IAIOBService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import javax.annotation.Resource; +import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; @@ -52,6 +54,21 @@ public class AIOBController extends BaseController { return R.ok(aiobService.createTask(createTaskDto)); } + @ApiOperation("创建实时任务") + @GetMapping("/createActualTimeTask") + public R createActualTimeTask(ActualTimeTaskDto actualTimeTaskDto) { + actualTimeTaskDto.setRobotId("8e5d5e08-9e82-44a7-ab38-c20f56388b25"); + actualTimeTaskDto.setMobile("15166940975"); + actualTimeTaskDto.setSecretType(2); + JSONObject dialogVar = new JSONObject(); + dialogVar.fluentPut("patient_name", "张三") + .fluentPut("department_name", "山东省立医院"); + actualTimeTaskDto.setDialogVar(dialogVar); + actualTimeTaskDto.setCallBackUrl("http://8.131.93.145:54011/api/taskCallBack"); + actualTimeTaskDto.setExtJson("646"); + return R.ok(aiobService.createActualTimeTask(actualTimeTaskDto)); + } + /** * @description 任务状态变更 * @param taskId 任务id diff --git a/postdischarge-manage/src/main/java/com/xinelu/manage/dto/aibo/ActualTimeTaskDto.java b/postdischarge-manage/src/main/java/com/xinelu/manage/dto/aibo/ActualTimeTaskDto.java new file mode 100644 index 00000000..1f7c49b6 --- /dev/null +++ b/postdischarge-manage/src/main/java/com/xinelu/manage/dto/aibo/ActualTimeTaskDto.java @@ -0,0 +1,50 @@ +package com.xinelu.manage.dto.aibo; + +import com.alibaba.fastjson2.JSONObject; +import lombok.Data; + +/** + * @description: 百度外呼创建实时任务传输对象 + * @author: haown + * @create: 2024-09-20 15:35 + **/ +@Data +public class ActualTimeTaskDto { + + /** + * 外呼机器人唯一标识 + */ + private String robotId; + + /** + * 被叫号码 + */ + private String mobile; + + /** + * 加密类型， 1：系统加密，即被叫号码采用系统的加密方式，AES128加密； + * 2：不加密，即被叫号码为明文； + * 3：自定义加密，即被叫号码采用客户自定义的加密方式，需在配置台-隐私配置-其他配置中配置自定义加解密服务地址，便于请求解密 + */ + private Integer secretType; + + /** + * 呼叫截止时间，yyyy-MM-dd HH:mm:ss，默认为空，则不限制呼叫截止时间 + */ + private String stopDate; + + /** + * 变量信息，用于短信或机器人对话中使用 + */ + private JSONObject dialogVar; + + /** + * 任务级别，指定当前任务回调的地址，如果没有配置默认按照全局配置推送 + */ + private String callBackUrl; + + /** + * 调用方的业务随路数据, 字符串，百度侧原文回传 + */ + private String extJson; +} diff --git a/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/IAIOBService.java b/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/IAIOBService.java index e1ca4789..14941612 100644 --- a/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/IAIOBService.java +++ b/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/IAIOBService.java @@ -2,6 +2,7 @@ package com.xinelu.manage.service.aibo; import com.alibaba.fastjson2.JSONObject; import com.aliyuncs.exceptions.ClientException; +import com.xinelu.manage.dto.aibo.ActualTimeTaskDto; import com.xinelu.manage.dto.aibo.CreateTaskDto; import com.xinelu.manage.dto.aibo.ImportTaskDto; import com.xinelu.manage.dto.aibo.TaskCallbackDataDto; @@ -33,6 +34,15 @@ public interface IAIOBService { */ String createTask(CreateTaskDto createTaskDto); + /** + * @description 创建实时任务 + * @param actualTimeTaskDto 百度外呼创建实时任务传输对象 + * @return memberId 被叫号码系统唯一标识，可根据该标识查询通话记录 + * @Author haown + * @Date 2024-9-20 16:15 + */ + Long createActualTimeTask(ActualTimeTaskDto actualTimeTaskDto); + /** * @description 任务状态变更 * @param taskId 任务id diff --git a/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/impl/AIOBServiceImpl.java b/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/impl/AIOBServiceImpl.java index 4b084518..72e7cbc7 100644 --- a/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/impl/AIOBServiceImpl.java +++ b/postdischarge-manage/src/main/java/com/xinelu/manage/service/aibo/impl/AIOBServiceImpl.java @@ -30,6 +30,7 @@ import com.xinelu.manage.domain.signpatientmanageroute.SignPatientManageRoute; import com.xinelu.manage.domain.signpatientmanageroutenode.SignPatientManageRouteNode; import com.xinelu.manage.domain.signpatientrecord.SignPatientRecord; import com.xinelu.manage.domain.textmessage.TextMessage; +import com.xinelu.manage.dto.aibo.ActualTimeTaskDto; import com.xinelu.manage.dto.aibo.AiboRecord; import com.xinelu.manage.dto.aibo.CreateTaskDto; import com.xinelu.manage.dto.aibo.CustomerInfoDto; @@ -219,6 +220,30 @@ public class AIOBServiceImpl implements IAIOBService { // } } + /** + * @description 创建实时任务 + * @param actualTimeTaskDto 百度外呼创建实时任务传输对象 + * @return memberId 被叫号码系统唯一标识，可根据该标识查询通话记录 + * @Author haown + * @Date 2024-9-20 16:15 + */ + @Override public Long createActualTimeTask(ActualTimeTaskDto actualTimeTaskDto) { + String accessToken = getAccessToken(); + HttpHeaders headers = new HttpHeaders(); + headers.setContentType(MediaType.APPLICATION_JSON); + headers.set("Authorization", accessToken); + + HttpEntity requestEntity = new HttpEntity<>((JSONObject)JSON.toJSON(actualTimeTaskDto), headers); + RestTemplate restTemplate = new RestTemplate(); + ResponseEntity responseEntity = restTemplate.exchange(url + "/v3/console/realtime/status/create", HttpMethod.POST, requestEntity, String.class); + JSONObject object = JSON.parseObject(responseEntity.getBody()); + if (object == null || object.getInteger("code") == null || object.getInteger("code") != 200) { + throw new ServiceException("创建任务失败，" + object.getString("msg")); + } + JSONObject data = object.getJSONObject("data"); + return data.getLong("memberId"); + } + /** * @description 任务状态变更 * @param taskId 任务id @@ -316,7 +341,7 @@ public class AIOBServiceImpl implements IAIOBService { public JSONObject taskCallBack(Integer callbackType, TaskCallbackDataDto data) throws ClientException { JSONObject retObj = new JSONObject(); retObj.fluentPut("code", 200).fluentPut("msg", "success"); - if (callbackType == 0) { + if (callbackType == 0 || callbackType == 3) { // 是否发送短信标识 boolean needSendSms = false; // 根据id查询任务