修改曜智外呼。

postdischarge-admin/src/main/resources/application.yml

@@ -31,8 +31,10 @@ xinelu:
   rich-text-picture-url: /richTextPictureUrl
   # 资讯富文本的上传路径
   info-rich-text-picture-url: /infoRichTextPictureUrl
-  # 资讯富文本的上传路径
+  # 百度外呼通话录音地址
   phone-dial-record-video: /phoneDialRecordVideo
+  # 曜智外呼通话录音地址
+  yz-phone-dial-record-video: /yzPhoneDialRecordVideo
 
 # 开发环境配置
 server:
@@ -305,6 +307,11 @@ yzaiobs:
   roleId: 1001
   routeNum: 1
   callPhone: 1234
+
+# 外呼选项
+outboundCall:
+  type: yzaiobs
+
 xinyilu-database:
   # 公共机构ID（新医路，用于宣教库公共库查询）
   id: 46

postdischarge-common/src/main/java/com/xinelu/common/config/SystemBusinessConfig.java

@@ -91,6 +91,8 @@ public class SystemBusinessConfig {
 	 */
 	private String phoneDialRecordVideo;
 
+	private String yzPhoneDialRecordVideo;
+
     public String getName() {
         return name;
     }
@@ -245,4 +247,12 @@ public class SystemBusinessConfig {
 	public void setPhoneDialRecordVideo(String phoneDialRecordVideo) {
 		this.phoneDialRecordVideo = phoneDialRecordVideo;
 	}
+
+	public String getYzPhoneDialRecordVideo() {
+		return yzPhoneDialRecordVideo;
+	}
+
+	public void setYzPhoneDialRecordVideo(String yzPhoneDialRecordVideo) {
+		this.yzPhoneDialRecordVideo = yzPhoneDialRecordVideo;
+	}
 }

postdischarge-manage/src/main/java/com/xinelu/manage/service/signpatientmanageroutenode/impl/SignPatientManageRouteNodeServiceImpl.java

@@ -1,5 +1,6 @@
 package com.xinelu.manage.service.signpatientmanageroutenode.impl;
 
+import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
 import com.xinelu.common.annotation.DataScope;
@@ -13,7 +14,13 @@ import com.xinelu.common.constant.TemplateTypeConstants;
 import com.xinelu.common.constant.TriggerConditionOperatorConstants;
 import com.xinelu.common.constant.TriggerLogicConstants;
 import com.xinelu.common.constant.VisitMethodConstants;
-import com.xinelu.common.enums.*;
+import com.xinelu.common.enums.MessageStatusEnum;
+import com.xinelu.common.enums.NodeExecuteResultStatusEnum;
+import com.xinelu.common.enums.NodeExecuteStatusEnum;
+import com.xinelu.common.enums.PhoneDialMethodEnum;
+import com.xinelu.common.enums.QuestionTypeEnum;
+import com.xinelu.common.enums.RouteCheckStatusEnum;
+import com.xinelu.common.enums.RouteNodeNameEnum;
 import com.xinelu.common.exception.ServiceException;
 import com.xinelu.common.utils.SecurityUtils;
 import com.xinelu.common.utils.StringUtils;
@@ -38,7 +45,11 @@ import com.xinelu.manage.domain.specialdiseasetriggercondition.SpecialDiseaseTri
 import com.xinelu.manage.domain.textmessage.TextMessage;
 import com.xinelu.manage.domain.wechattemplate.WechatTemplate;
 import com.xinelu.manage.dto.patientinfo.PatientInfoDto;
-import com.xinelu.manage.dto.signpatientmanageroutenode.*;
+import com.xinelu.manage.dto.signpatientmanageroutenode.AppletPatientTaskDto;
+import com.xinelu.manage.dto.signpatientmanageroutenode.PatientTaskDto;
+import com.xinelu.manage.dto.signpatientmanageroutenode.RouteNodeCheckDto;
+import com.xinelu.manage.dto.signpatientmanageroutenode.SignPatientManageRouteNodeDto;
+import com.xinelu.manage.dto.signpatientmanageroutenode.UploadRobotPublishRecordDto;
 import com.xinelu.manage.mapper.labelfieldcontent.LabelFieldContentMapper;
 import com.xinelu.manage.mapper.patientinfo.PatientAllInfoViewMapper;
 import com.xinelu.manage.mapper.patientinfo.PatientInfoMapper;
@@ -62,13 +73,23 @@ import com.xinelu.manage.service.propagandainfo.IPropagandaInfoService;
 import com.xinelu.manage.service.questioninfo.IQuestionInfoService;
 import com.xinelu.manage.service.signpatientmanageroutenode.ISignPatientManageRouteNodeService;
 import com.xinelu.manage.service.specialdiseaseroute.ISpecialDiseaseRouteService;
+import com.xinelu.manage.service.yzaiobs.IYZAIOBSService;
 import com.xinelu.manage.vo.labelfieldcontent.LabelFieldInfoContentVo;
 import com.xinelu.manage.vo.patientinfo.PatientInfoVo;
 import com.xinelu.manage.vo.patientinfo.PatientNextTaskVo;
 import com.xinelu.manage.vo.patientquestionsubmitresult.PatientQuestionSubmitResultVO;
 import com.xinelu.manage.vo.propagandainfo.PropagandaMaterialsVo;
 import com.xinelu.manage.vo.questionInfo.QuestionVO;
-import com.xinelu.manage.vo.signpatientmanageroutenode.*;
+import com.xinelu.manage.vo.signpatientmanageroutenode.AIDialRecordVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.AppletRouteNodeListVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.PatientManageNodeInfoVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.PatientManageNodeListVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.PatientTaskVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.SignPatientManageNodeAuditVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.SignPatientManageRouteNodeInfoVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.SignPatientManageRouteNodeVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.SignPatientTaskVo;
+import com.xinelu.manage.vo.signpatientmanageroutenode.UploadRobotPublishRecordVo;
 import com.xinelu.manage.vo.specialdiseasenode.PatientSpecialDiseaseNodeVo;
 import com.xinelu.manage.vo.specialdiseasenode.SpecialDiseaseNodeVO;
 import com.xinelu.manage.vo.specialdiseaseroute.SpecialDiseaseRouteVO;
@@ -93,6 +114,7 @@ import org.jsoup.Jsoup;
 import org.jsoup.nodes.Document;
 import org.jsoup.nodes.Element;
 import org.jsoup.select.Elements;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -148,8 +170,12 @@ public class SignPatientManageRouteNodeServiceImpl implements ISignPatientManage
 	private PhoneDialRecordMapper phoneDialRecordMapper;
 	@Resource
 	private IAIOBService aiobService;
+	@Resource
+	private IYZAIOBSService iyzaiobsService;
+	@Value("${outboundCall.type}")
+	private String callType;
 
-    /**
+	/**
      * 查询签约患者管理任务路径节点
      *
      * @param id 签约患者管理任务路径节点主键
@@ -587,31 +613,65 @@ public class SignPatientManageRouteNodeServiceImpl implements ISignPatientManage
 
 		PhoneDialRecord phoneDialRecord = phoneDialRecordMapper.getLastRecord(id);
 
-		String phoneResultJson = signPatientManageRouteNode.getPhoneResultJson();
+		if (StringUtils.equals("yzaiobs", callType)) {
-		if (StringUtils.isNotBlank(phoneResultJson)) {
+			String phoneResultJson = signPatientManageRouteNode.getPhoneResultJson();
-			JSONObject resultJson = JSONObject.parseObject(phoneResultJson);
+			if (StringUtils.isNotBlank(phoneResultJson)) {
-			JSONArray record = resultJson.getJSONArray("record");
+				JSONObject resultJson = JSONObject.parseObject(phoneResultJson);
-			recordVo.setRecord(record);
 
-			if(ObjectUtils.isEmpty(phoneDialRecord) || StringUtils.isBlank(phoneDialRecord.getCtUuid())) {
+				// 通话记录文字
-				// 从任务中解析ctuuid
+				String interactions = resultJson.getString("interactions");
-				String ctuuid = resultJson.getString("contactUUID");
+				// 解析
-				if (StringUtils.isNotBlank(ctuuid)) {
+				if (StringUtils.isNotBlank(interactions)) {
-					String videoUrl = aiobService.getPhoneDialRecord(ctuuid);
+					recordVo.setRecord(JSONArray.parseArray(JSON.toJSONString(iyzaiobsService.parseRecord(interactions))));
-					recordVo.setPhoneDialRecordVideo(videoUrl);
+				} else {
+					recordVo.setRecord(new JSONArray());
 				}
-				return recordVo;
+
+				if(ObjectUtils.isEmpty(phoneDialRecord) || StringUtils.isBlank(phoneDialRecord.getPhoneDialRecordVideo())) {
+					// 从任务中解析ctuuid
+					String mediaPath = resultJson.getString("mediaPath");
+					if (StringUtils.isNotBlank(mediaPath)) {
+						String videoUrl = iyzaiobsService.saveVideo(mediaPath, signPatientManageRouteNode.getId() + "");
+						recordVo.setPhoneDialRecordVideo(videoUrl);
+						if (ObjectUtils.isNotEmpty(phoneDialRecord)) {
+							phoneDialRecord.setPhoneDialRecordVideo(videoUrl);
+							phoneDialRecordMapper.updatePhoneDialRecord(phoneDialRecord);
+						}
+					}
+					return recordVo;
+				} else {
+					recordVo.setPhoneDialRecordVideo(phoneDialRecord.getPhoneDialRecordVideo());
+					return recordVo;
+				}
+			}
+		} else if (StringUtils.equals("aiobs", callType)) {
+			String phoneResultJson = signPatientManageRouteNode.getPhoneResultJson();
+			if (StringUtils.isNotBlank(phoneResultJson)) {
+				JSONObject resultJson = JSONObject.parseObject(phoneResultJson);
+				JSONArray record = resultJson.getJSONArray("record");
+				recordVo.setRecord(record);
+
+				if(ObjectUtils.isEmpty(phoneDialRecord) || StringUtils.isBlank(phoneDialRecord.getCtUuid())) {
+					// 从任务中解析ctuuid
+					String ctuuid = resultJson.getString("contactUUID");
+					if (StringUtils.isNotBlank(ctuuid)) {
+						String videoUrl = aiobService.getPhoneDialRecord(ctuuid);
+						recordVo.setPhoneDialRecordVideo(videoUrl);
+					}
+					return recordVo;
+				}
+			}
+
+			if (StringUtils.isBlank(phoneDialRecord.getPhoneDialRecordVideo())) {
+				String videoUrl = aiobService.getPhoneDialRecord(phoneDialRecord.getCtUuid());
+				phoneDialRecord.setPhoneDialRecordVideo(videoUrl);
+				phoneDialRecordMapper.updatePhoneDialRecord(phoneDialRecord);
+				recordVo.setPhoneDialRecordVideo(videoUrl);
+			} else {
+				recordVo.setPhoneDialRecordVideo(phoneDialRecord.getPhoneDialRecordVideo());
 			}
 		}
 
-		if (StringUtils.isBlank(phoneDialRecord.getPhoneDialRecordVideo())) {
-			String videoUrl = aiobService.getPhoneDialRecord(phoneDialRecord.getCtUuid());
-			phoneDialRecord.setPhoneDialRecordVideo(videoUrl);
-			phoneDialRecordMapper.updatePhoneDialRecord(phoneDialRecord);
-			recordVo.setPhoneDialRecordVideo(videoUrl);
-		} else {
-			recordVo.setPhoneDialRecordVideo(phoneDialRecord.getPhoneDialRecordVideo());
-		}
 
 		return recordVo;
 	}

postdischarge-manage/src/main/java/com/xinelu/manage/service/yzaiobs/IYZAIOBSService.java

@@ -4,6 +4,8 @@ import com.alibaba.fastjson2.JSONObject;
 import com.aliyuncs.exceptions.ClientException;
 import com.xinelu.manage.dto.aiob.CreateDutyDto;
 import com.xinelu.manage.dto.aiob.DutyCallbackDto;
+import com.xinelu.manage.vo.yzaiobs.CallRecord;
+import java.util.List;
 
 /**
  * 曜智·智能外呼平台Service接口
@@ -20,7 +22,7 @@ public interface IYZAIOBSService {
 	 * @Author haown
 	 * @Date 2025-12-17 16:27
 	*/
-	JSONObject createDuty(CreateDutyDto createDutyDto);
+	String createDuty(CreateDutyDto createDutyDto);
 
 	/**
 	 * @description 任务执行回调方法
@@ -32,11 +34,12 @@ public interface IYZAIOBSService {
 	JSONObject taskCallBack(DutyCallbackDto callbackDto) throws ClientException;
 
 	/**
-	 * @description 单通电话数据回传接口
+	 * @description 通话录音保存到本地
-	 * @Param  * @param null
 	 * @return null
 	 * @Author haown
 	 * @Date 2025-12-26 15:59
 	*/
-	JSONObject phoneCallBack();
+	String saveVideo(String downloadPath, String nodeId);
+
+	List<CallRecord> parseRecord(String interactions);
 }

postdischarge-manage/src/main/java/com/xinelu/manage/service/yzaiobs/impl/YZAIOBSServiceImpl.java

@@ -1,9 +1,12 @@
 package com.xinelu.manage.service.yzaiobs.impl;
 
+import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONArray;
 import com.alibaba.fastjson2.JSONObject;
 import com.aliyuncs.exceptions.ClientException;
+import com.xinelu.common.config.SystemBusinessConfig;
+import com.xinelu.common.constant.Constants;
 import com.xinelu.common.constant.PhoneMessageRemindConstants;
 import com.xinelu.common.constant.TaskCreateTypeConstant;
 import com.xinelu.common.constant.TaskStatisticsTypeConstants;
@@ -51,14 +54,24 @@ import com.xinelu.manage.service.yzaiobs.IYZAIOBSService;
 import com.xinelu.manage.vo.labelfieldcontent.LabelFieldInfoContentVo;
 import com.xinelu.manage.vo.questionsubject.QuestionSubjectVO;
 import com.xinelu.manage.vo.yzaiobs.CallRecord;
+import java.io.BufferedInputStream;
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
 import java.math.BigDecimal;
+import java.net.HttpURLConnection;
+import java.net.URL;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.Arrays;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Objects;
+import java.util.Set;
 import java.util.stream.Collectors;
 import javax.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.ObjectUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Value;
@@ -76,6 +89,7 @@ import org.springframework.web.client.RestTemplate;
  * @create: 2025-12-17 17:18
  **/
 @Service
+@Slf4j
 public class YZAIOBSServiceImpl implements IYZAIOBSService {
 	@Value("${yzaiobs.url}")
 	private String url;
@@ -121,8 +135,10 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 	private PatientQuestionOptionResultMapper patientQuestionOptionResultMapper;
 	@Resource
 	private LabelFieldContentMapper labelFieldContentMapper;
+	@Resource
+	private SystemBusinessConfig systemBusinessConfig;
 
-	@Override public JSONObject createDuty(CreateDutyDto createDutyDto) {
+	@Override public String createDuty(CreateDutyDto createDutyDto) {
 		createDutyDto.setUserId(userId);
 		createDutyDto.setRoleId(roleId);
 		createDutyDto.setRouteNum(routeNum);
@@ -131,68 +147,33 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 		RestTemplate restTemplate = new RestTemplate();
 		HttpHeaders headers = new HttpHeaders();
 		headers.setContentType(MediaType.APPLICATION_JSON);
+		log.info("创建外呼任务-传输对象:{}", com.alibaba.fastjson.JSONObject.toJSONString(createDutyDto, SerializerFeature.WriteMapNullValue));
 		String requestBody = JSON.toJSONString(createDutyDto);
 		HttpEntity<String> requestEntity = new HttpEntity<>(requestBody, headers);
 		ResponseEntity<String> responseEntity = restTemplate.postForEntity(url + "/duty/createDuty", requestEntity, String.class);
 		JSONObject object = JSON.parseObject(responseEntity.getBody());
-
-
-		/*try {
-			HttpPost httpPost = new HttpPost(url);
-			httpPost.setHeader("Content-Type", "application/json");
-			httpPost.setEntity(new StringEntity(JSON.toJSONString(createDutyDto)));
-			CloseableHttpClient httpclient = HttpClients.createDefault();
-			CloseableHttpResponse response = httpclient.execute(httpPost);
-			int status
-		} catch (UnsupportedEncodingException e) {
-			throw new RuntimeException(e);
-		} catch (ClientProtocolException e) {
-			throw new RuntimeException(e);
-		} catch (IOException e) {
-			throw new RuntimeException(e);
-		}*/
-		/*{
-			"flag": true,
-			"message": "任务名已存在!!!",
-			"ret": 0,
-			"success": false // 任务创建结果，true表示创建成功，false表示创建失败
-		}*/
-
-		/*{
-			"flag": true,
-			"message": "入库成功",
-			"ret": 0, // 0表示成功，非0表示失败
-			"success": true, // 任务创建结果，true表示创建成功，false表示创建失败
-			"value": {
-			"166": [ // 已创建的任务id
-			{
-				"id": 1045, // 任务资源id
-				"phoneNumber": "18156017972", // 用户手机号
-				"downLoadState": false // 音频是否下载完成
-			}
-		]
-		}
-		}*/
 		if (object == null || object.getBoolean("success") == null || !object.getBoolean("success")) {
-			throw new ServiceException("创建任务失败，" + object.getString("message"));
+			log.info("创建外呼任务失败-原因:{}", object.getString("message"));
+			return null;
 		}
+		log.info("创建外呼任务成功-返回值:{}", com.alibaba.fastjson.JSONObject.toJSONString(object, SerializerFeature.WriteMapNullValue));
 		JSONObject data = object.getJSONObject("value");
-		//Set<String> taskIds = data.keySet();
+		Set<String> taskIds = data.keySet();
-		//Iterator<String> iterator = taskIds.iterator();
+		Iterator<String> iterator = taskIds.iterator();
-		//String taskId = iterator.next();
+		String taskId = iterator.next();
-		return data;
+		log.info("创建外呼任务成功-任务id:{}", taskId);
+		return taskId;
 	}
 
 	@Override public JSONObject taskCallBack(DutyCallbackDto callbackDto) throws ClientException {
 		// 从data中获取任务id
+		log.info("外呼回调接口开始执行-------");
 		JSONArray JSONArr = callbackDto.getData();
 		if (!CollectionUtils.isEmpty(JSONArr)) {
 			for (int i = 0; i < JSONArr.size(); i++) {
 				JSONObject jsonObject = JSONArr.getJSONObject(i);
-				System.out.println("数据回调-----------------------");
+				log.info("数据{}:{}", i, com.alibaba.fastjson.JSONObject.toJSONString(jsonObject, SerializerFeature.WriteMapNullValue));
-				System.out.println("数据" + i + ":"+jsonObject.toJSONString());
 				DutyCallbackDataDto dutyCallbackDataDto = JSON.parseObject(jsonObject.toJSONString(), DutyCallbackDataDto.class);
-				System.out.println("数据转实体类" + i + ":" +dutyCallbackDataDto.toString());
 				// 是否发送短信标识
 				boolean needSendSms = false;
 				// 是否重拨
@@ -246,7 +227,7 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 						// signPatientManageRouteNode.setPhoneResultJson(com.alibaba.fastjson.JSON.toJSONString(data, SerializerFeature.WriteMapNullValue));
 					}
 
-					signPatientManageRouteNode.setPhoneResultJson(callbackDto.toString());
+					signPatientManageRouteNode.setPhoneResultJson(com.alibaba.fastjson.JSON.toJSONString(dutyCallbackDataDto, SerializerFeature.WriteMapNullValue));
 
 					signPatientManageRouteNodeMapper.updateSignPatientManageRouteNode(signPatientManageRouteNode);
 
@@ -268,7 +249,7 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 
 						// 发送短信
 						if (needSendSms) {
-							//System.out.println("发送短信-------------------------------------------");
+							log.info("发送短信......................");
 							iaiobService.sendSms(signPatientManageRoute.getPatientId(), signPatientManageRouteNode);
 						}
 						// 重拨
@@ -293,7 +274,7 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 					PhoneDialRecord phoneDialRecord = new PhoneDialRecord();
 					phoneDialRecord.setPatientId(signPatientManageRoute.getPatientId());
 					phoneDialRecord.setManageRouteNodeId(signPatientManageRouteNode.getId());
-					phoneDialRecord.setPatientPhone(callbackDto.getPhoneNum());
+					phoneDialRecord.setPatientPhone(dutyCallbackDataDto.getPhoneNumber());
 					phoneDialRecord.setDialTime(LocalDateTime.now());
 					phoneDialRecord.setPhoneTemplateId(signPatientManageRouteNode.getScriptInfoId() + "");
 					phoneDialRecord.setPhoneDialMethod(signPatientManageRouteNode.getPhoneDialMethod());
@@ -303,7 +284,7 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 
 					phoneDialRecord.setCtUuid(dutyCallbackDataDto.getCallid());
 					// 通话录音地址
-					phoneDialRecord.setPhoneDialRecordVideo(iaiobService.videoPath(dutyCallbackDataDto.getMediaPath(), dutyCallbackDataDto.getCallid()));
+					phoneDialRecord.setPhoneDialRecordVideo(saveVideo(dutyCallbackDataDto.getMediaPath(), dutyCallbackDataDto.getCustId()));
 
 					phoneDialRecordMapper.insertPhoneDialRecord(phoneDialRecord);
 
@@ -330,7 +311,41 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 		return retObj;
 	}
 
-	@Override public JSONObject phoneCallBack() {
+	@Override
+	public String saveVideo(String downloadPath, String nodeId) {
+		if (StringUtils.isBlank(downloadPath)) {
+			throw new ServiceException("暂未获取到录音，请稍后再试!");
+		}
+		String url = systemBusinessConfig.getProfile() + systemBusinessConfig.getPhoneDialRecordVideo() + "/" + nodeId + ".wav";
+		File outputPath = new File(url);
+		File dir = outputPath.getParentFile();
+		if (!dir.exists()){
+			dir.mkdirs();
+		}
+		try {
+			outputPath.createNewFile(); // 创建文件
+			URL fileUrl = new URL(downloadPath);
+			HttpURLConnection connection = (HttpURLConnection)fileUrl.openConnection();
+			connection.setRequestMethod("GET");
+			connection.connect();
+			if (connection.getResponseCode() == HttpURLConnection.HTTP_OK) {
+				InputStream inputStream = new BufferedInputStream(connection.getInputStream());
+				FileOutputStream outputStream = new FileOutputStream(outputPath);
+				byte[] buffer = new byte[1024];
+				int bytesRead;
+				while ((bytesRead = inputStream.read(buffer)) != -1) {
+					outputStream.write(buffer, 0, bytesRead);
+				}
+				outputStream.close();
+				inputStream.close();
+				log.info("保存到本地的录音地址：{}", Constants.RESOURCE_PREFIX + systemBusinessConfig.getPhoneDialRecordVideo() + "/" + nodeId + ".wav");
+				return Constants.RESOURCE_PREFIX + systemBusinessConfig.getPhoneDialRecordVideo() + "/" + nodeId + ".wav";
+			} else {
+				throw new ServiceException("下载录音失败，请稍后再试");
+			}
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
 		return null;
 	}
 
@@ -343,8 +358,11 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 	 * @Date 2025-12-25 15:45
 	*/
 	private void parseQuestionInfo(String callResultTypes, String interactions, SignPatientManageRouteNode node, Long patientInfoId, Long taskExecuteRecordId) {
+		PatientInfo patientInfo = patientInfoMapper.selectPatientInfoById(patientInfoId);
 
-		if(StringUtils.isBlank(interactions)) {
+		if(StringUtils.isBlank(interactions) || StringUtils.isBlank(callResultTypes)) {
+			// 返回一个空的问卷
+			genenrateQuestion(node, patientInfo, taskExecuteRecordId);
 			return;
 		}
 		List<String> callResultIntents = Arrays.asList(callResultTypes.split(","));
@@ -353,7 +371,7 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 		if (CollectionUtils.isEmpty(recordList)) {
 			return;
 		}
-		PatientInfo patientInfo = patientInfoMapper.selectPatientInfoById(patientInfoId);
+
 		// 查询患者画像信息
 		List<LabelFieldInfoContentVo> labelFieldContentList = labelFieldContentMapper.selectByPatientId(patientInfoId);
 
@@ -391,9 +409,9 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 			boolean hasQuestion = false;
 			String aiobQuestionName = "";
 			for (int i = 0; i < recordList.size(); i++) {
-				if (recordList.get(i).getContent().contains(questionNameAlias.replaceAll("\\p{P}", ""))) {
+				if (recordList.get(i).getContextText().contains(questionNameAlias.replaceAll("\\p{P}", ""))) {
 					hasQuestion = true;
-					aiobQuestionName = recordList.get(i).getContent();
+					aiobQuestionName = recordList.get(i).getContextText();
 					break;
 				}
 			}
@@ -502,7 +520,11 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 		//questionSubmitResultMapper.updatePatientQuestionSubmitResult(patientQuestionSubmitResult);
 	}
 
-	private List<CallRecord> parseRecord(String interactions) {
+	@Override
+	public List<CallRecord> parseRecord(String interactions) {
+		if (StringUtils.isBlank(interactions)) {
+			return null;
+		}
 		// 先用|分隔完整的问题与答案，再用:分隔角色
 		List<CallRecord> retList = new ArrayList<>();
 		List<String> records = Arrays.asList(interactions.split("\\|"));
@@ -513,7 +535,26 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 			CallRecord callRecord = new CallRecord();
 			String[] str1 = record.split(":");
 			callRecord.setRole(str1[0]);
-			callRecord.setContent(str1[1]);
+			if (StringUtils.equals("机器人", str1[0])) {
+				callRecord.setRole("speech");
+				if (str1.length > 1) {
+					if(StringUtils.isNotBlank(str1[1])) {
+						// 用^分隔
+						String[] content = str1[1].split("\\^");
+						for (int i = 0; i < content.length; i++) {
+							if (StringUtils.contains(content[i], "txt=")) {
+								callRecord.setContextText(content[i].replaceAll("txt=", ""));
+							}
+						}
+					}
+				}
+			} else if (StringUtils.equals("用户", str1[0])) {
+				callRecord.setRole("voice");
+				if (str1.length > 1) {
+					callRecord.setContextText(str1[1]);
+				}
+			}
+
 			retList.add(callRecord);
 		}
 		return retList;
@@ -529,12 +570,92 @@ public class YZAIOBSServiceImpl implements IYZAIOBSService {
 	*/
 	private String getReply(List<CallRecord> callRecordList, String question) {
 		for (int i = 0; i < callRecordList.size(); i++) {
-			if (StringUtils.equals(callRecordList.get(i).getContent(), question)) {
+			if (StringUtils.equals(callRecordList.get(i).getContextText(), question)) {
-				if (StringUtils.equals("用户",callRecordList.get(i+1).getRole())) {
+				if (StringUtils.equals("voice",callRecordList.get(i+1).getRole())) {
-					return callRecordList.get(i+1).getContent();
+					return callRecordList.get(i+1).getContextText();
 				}
 			}
 		}
 		return null;
 	}
+
+	private void genenrateQuestion(SignPatientManageRouteNode node, PatientInfo patientInfo, Long taskExecuteRecordId) {
+		QuestionInfo questionInfo = questionInfoMapper.selectQuestionInfoById(node.getQuestionInfoId());
+		// 1、保存patient_question_submit_result
+		PatientQuestionSubmitResult patientQuestionSubmitResult = new PatientQuestionSubmitResult();
+		patientQuestionSubmitResult.setTaskExecuteRecordId(taskExecuteRecordId);
+		patientQuestionSubmitResult.setPatientName(patientInfo.getPatientName());
+		patientQuestionSubmitResult.setPatientId(patientInfo.getId());
+		patientQuestionSubmitResult.setManageRouteId(node.getManageRouteId());
+		patientQuestionSubmitResult.setManageRouteName(node.getManageRouteName());
+		patientQuestionSubmitResult.setManageRouteNodeId(node.getId());
+		patientQuestionSubmitResult.setManageRouteNodeName(node.getRouteNodeName());
+		patientQuestionSubmitResult.setQuestionInfoId(questionInfo.getId());
+		patientQuestionSubmitResult.setDepartmentId(questionInfo.getDepartmentId());
+		patientQuestionSubmitResult.setDepartmentName(questionInfo.getDepartmentName());
+		patientQuestionSubmitResult.setDiseaseTypeId(questionInfo.getDiseaseTypeId());
+		patientQuestionSubmitResult.setDiseaseTypeName(questionInfo.getDiseaseTypeName());
+		patientQuestionSubmitResult.setQuestionnaireName(questionInfo.getQuestionnaireName());
+		patientQuestionSubmitResult.setQuestionnaireDescription(questionInfo.getQuestionnaireDescription());
+		patientQuestionSubmitResult.setAnsweringMethod(questionInfo.getAnsweringMethod());
+		patientQuestionSubmitResult.setQuestionnaireId(questionInfo.getQuestionnaireId());
+		patientQuestionSubmitResult.setQuestionCount(questionInfo.getQuestionCount());
+		patientQuestionSubmitResult.setQuestionnaireTotalScore(questionInfo.getQuestionnaireTotalScore());
+		patientQuestionSubmitResult.setResidentId(patientInfo.getResidentId());
+		patientQuestionSubmitResult.setCreateTime(LocalDateTime.now());
+		questionSubmitResultMapper.insertPatientQuestionSubmitResult(patientQuestionSubmitResult);
+		// 2、保存patient_question_subject_result
+		List<QuestionSubjectVO> questionSubjectList = questionSubjectMapper.selectQuestionSubjectBy(node.getQuestionInfoId());
+		questionSubjectList.forEach(questionSubjectVO -> {
+			PatientQuestionSubjectResult patientQuestionSubjectResult = new PatientQuestionSubjectResult();
+			BeanUtils.copyProperties(questionSubjectVO, patientQuestionSubjectResult);
+			patientQuestionSubjectResult.setId(null);
+			patientQuestionSubjectResult.setQuestionSubmitResultId(patientQuestionSubmitResult.getId());
+			patientQuestionSubjectResult.setCreateTime(LocalDateTime.now());
+			//不管是否是 填空题，都 写入回答 文本
+			patientQuestionSubjectResult.setFillBlanksAnswer(null);
+
+			patientQuestionSubjectResult.setQuestionSubjectId(questionSubjectVO.getId());
+			patientQuestionSubjectResultMapper.insertPatientQuestionSubjectResult(patientQuestionSubjectResult);
+
+			// 3、保存patient_question_option_result
+			QuestionSubjectOption questionSubjectOptionQuery = new QuestionSubjectOption();
+			questionSubjectOptionQuery.setQuestionnaireSubjectId(questionSubjectVO.getId());
+			List<QuestionSubjectOption> questionSubjectOptions = questionSubjectOptionMapper.selectQuestionSubjectOptionList(questionSubjectOptionQuery);
+			List<PatientQuestionOptionResult> patientQuestionOptionResults = new ArrayList<>();
+
+			questionSubjectOptions.forEach(questionSubjectOption -> {
+				PatientQuestionOptionResult patientQuestionOptionResult = new PatientQuestionOptionResult();
+				BeanUtils.copyProperties(questionSubjectOption, patientQuestionOptionResult);
+				patientQuestionOptionResult.setOptionChooseSign(0);
+				patientQuestionOptionResult.setOptionChooseSign(0);
+				patientQuestionOptionResult.setId(null);
+				patientQuestionOptionResult.setCreateTime(LocalDateTime.now());
+				patientQuestionOptionResult.setQuestionSubjectResultId(patientQuestionSubjectResult.getId());
+
+				patientQuestionOptionResult.setQuestionSubjectOptionId(questionSubjectOption.getId());
+
+				patientQuestionOptionResults.add(patientQuestionOptionResult);
+			});
+
+			if (!CollectionUtils.isEmpty(patientQuestionOptionResults)) {
+				List<PatientQuestionOptionResult> remarkableFlag = patientQuestionOptionResults.stream()
+					.filter(Objects::nonNull)
+					.filter(item -> StringUtils.isNotBlank(item.getRemarkableFlag()) && Objects.nonNull(item.getOptionChooseSign()) && item.getOptionChooseSign().equals(0) && ContentedAndRemarkableFlagEnum.REMARKABLE.getInfo().equals(item.getRemarkableFlag()))
+					.collect(Collectors.toList());
+				if (!CollectionUtils.isEmpty(remarkableFlag)) {
+					patientQuestionSubmitResult.setRemarkableFlag(ContentedAndRemarkableFlagEnum.REMARKABLE.getInfo());
+				}
+				List<PatientQuestionOptionResult> contentedFlag = patientQuestionOptionResults.stream()
+					.filter(Objects::nonNull)
+					.filter(item -> org.apache.commons.lang3.StringUtils.isNotBlank(item.getContentedFlag()) && Objects.nonNull(item.getOptionChooseSign()) && item.getOptionChooseSign().equals(0) && ContentedAndRemarkableFlagEnum.DISCONTENTED.getInfo().equals(item.getRemarkableFlag()))
+					.collect(Collectors.toList());
+				if (!CollectionUtils.isEmpty(contentedFlag)) {
+					patientQuestionSubmitResult.setContentedFlag(ContentedAndRemarkableFlagEnum.DISCONTENTED.getInfo());
+				}
+			}
+			questionSubmitResultMapper.updatePatientQuestionSubmitResult(patientQuestionSubmitResult);
+			patientQuestionOptionResultMapper.saveQuestionOptionList(patientQuestionOptionResults);
+		});
+	}
 }

postdischarge-manage/src/main/java/com/xinelu/manage/vo/yzaiobs/CallRecord.java

@@ -17,6 +17,6 @@ public class CallRecord {
 	/**
 	 * 说话内容
 	 */
-	private String content;
+	private String contextText;
 
 }

postdischarge-quartz/src/main/java/com/xinelu/quartz/task/YZAIOBSTask.java

@@ -163,6 +163,9 @@ public class YZAIOBSTask {
 					createDutyDto.setStartDate(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
 					createDutyDto.setNoticeSwitch(1);
 					createDutyDto.setDeduplicationSwitch(true);
+					JSONObject repStrategy = new JSONObject();
+					repStrategy.fluentPut("hangState", "").fluentPut("state", "").fluentPut("intention", "");
+					createDutyDto.setRepStrategy(repStrategy);
 					//3、开始组装本任务下的客户变量
 					//遍历最内层任务节点
 					JSONArray dataArr = new JSONArray();
@@ -176,8 +179,7 @@ public class YZAIOBSTask {
 								List<LabelFieldInfoContentVo> labelFieldContentList = labelFieldContentMapper.selectByPatientId(patientInfo.getId());
 								// 处理变量
 								JSONObject jsonObject = new JSONObject();
-								//TODO 需要验证是任务id还是患者id
+								jsonObject.fluentPut("手机号", patientInfo.getPatientPhone()).fluentPut("custId", node.getId() + "");
-								jsonObject.fluentPut("手机号", patientInfo.getPatientPhone()).fluentPut("custId", node.getId());
 								if (StringUtils.isNotBlank(scriptInfo.getVariables())) {
 									List<String> variables = Arrays.asList(scriptInfo.getVariables().split("\\|"));
 									variables.forEach(variable -> {
@@ -192,30 +194,30 @@ public class YZAIOBSTask {
 					});
 
 					createDutyDto.setDataArr(dataArr);
-					JSONObject taskObj = iyzaiobsService.createDuty(createDutyDto);
+					String taskId = iyzaiobsService.createDuty(createDutyDto);
-					String taskId = taskObj.keySet().iterator().next();
+					if (StringUtils.isNotBlank(taskId)) {
+						routeNodeGroupListByScriptInfoId.get(scriptInfoId).forEach(nodeForTask -> {
+							ScriptInfoTaskInfo scriptInfoTaskInfo = new ScriptInfoTaskInfo();
+							scriptInfoTaskInfo.setScriptInfoId(scriptInfoId);
+							scriptInfoTaskInfo.setTaskId(taskId);
+							scriptInfoTaskInfo.setRobotId(scriptInfo.getRobotPublishId());
+							scriptInfoTaskInfo.setCreateTime(LocalDateTime.now());
+							scriptInfoTaskInfo.setSn(sn);
+							scriptInfoTaskInfo.setSignPatientManageRouteNodeId(nodeForTask.getId());
+							scriptInfoTaskInfo.setSignPatientManageRouteId(nodeForTask.getManageRouteId());
+							scriptInfoTaskInfo.setAiobTaskType(AiobTaskTypeContant.BATCHTASK);
+							//进入拔打记录表（用于后续重拨处理等判断)----有时间再优化为批量插入
+							scriptInfoTaskInfoMapper.insertScriptInfoTaskInfo(scriptInfoTaskInfo);
 
-					routeNodeGroupListByScriptInfoId.get(scriptInfoId).forEach(nodeForTask -> {
+							//设置拨打状态
-						ScriptInfoTaskInfo scriptInfoTaskInfo = new ScriptInfoTaskInfo();
+							SignPatientManageRouteNode signPatientManageRouteNode_DialStatus = new SignPatientManageRouteNode();
-						scriptInfoTaskInfo.setScriptInfoId(scriptInfoId);
+							// signPatientManageRouteNode_DialStatus.setManageRouteId(routeId);
-						scriptInfoTaskInfo.setTaskId(taskId);
+							signPatientManageRouteNode_DialStatus.setId(nodeForTask.getId());
-						scriptInfoTaskInfo.setRobotId(scriptInfo.getRobotPublishId());
+							signPatientManageRouteNode_DialStatus.setDialStatus(DialStatusEnum.DIALED.getInfo());
-						scriptInfoTaskInfo.setCreateTime(LocalDateTime.now());
+							signPatientManageRouteNode_DialStatus.setTaskIdExt(taskId);
-						scriptInfoTaskInfo.setSn(sn);
+							signPatientManageRouteNodeMapper.updateDialStatusByNodeId(signPatientManageRouteNode_DialStatus);
-						scriptInfoTaskInfo.setSignPatientManageRouteNodeId(nodeForTask.getId());
+						});
-						scriptInfoTaskInfo.setSignPatientManageRouteId(nodeForTask.getManageRouteId());
+					}
-						scriptInfoTaskInfo.setAiobTaskType(AiobTaskTypeContant.BATCHTASK);
-						//进入拔打记录表（用于后续重拨处理等判断)----有时间再优化为批量插入
-						scriptInfoTaskInfoMapper.insertScriptInfoTaskInfo(scriptInfoTaskInfo);
-
-						//设置拨打状态
-						SignPatientManageRouteNode signPatientManageRouteNode_DialStatus = new SignPatientManageRouteNode();
-						// signPatientManageRouteNode_DialStatus.setManageRouteId(routeId);
-						signPatientManageRouteNode_DialStatus.setId(nodeForTask.getId());
-						signPatientManageRouteNode_DialStatus.setDialStatus(DialStatusEnum.DIALED.getInfo());
-						signPatientManageRouteNode_DialStatus.setTaskIdExt(taskId);
-						signPatientManageRouteNodeMapper.updateDialStatusByNodeId(signPatientManageRouteNode_DialStatus);
-					});
 				}
 			});
 		});
@@ -292,19 +294,21 @@ public class YZAIOBSTask {
 				createDutyDto.setDutyName(dutyName);
 				createDutyDto.setDutyType(scriptInfo.getRobotPublishId());
 				createDutyDto.setDutySceneId(Integer.parseInt(scriptInfo.getRobotPublishId()));
-				createDutyDto.setOutboundPeriods("[\"09:00~11:35\",\"15:55~23:30\"]");
+				createDutyDto.setOutboundPeriods("[\"09:00~11:30\",\"14:00~17:30\"]");
 				createDutyDto.setStartDate(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
+				createDutyDto.setEndDate(LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
+				JSONObject repStrategy = new JSONObject();
 				if (StringUtils.isNotBlank(node.getPhoneRedialTimes())) {
 					createDutyDto.setDuplication(PhoneRedialTimesEnum.getValueByInfo(node.getPhoneRedialTimes()).getValue());
+					createDutyDto.setPeriod(node.getPhoneTimeInterval());
+					repStrategy.fluentPut("hangState", "").fluentPut("state", "1,2,4,5,6,7,8").fluentPut("intention", "");
 				} else {
-					createDutyDto.setDuplication(0);
+					repStrategy.fluentPut("hangState", "").fluentPut("state", "").fluentPut("intention", "");
 				}
-				createDutyDto.setPeriod(node.getPhoneTimeInterval());
-				createDutyDto.setNoticeSwitch(1);
-				createDutyDto.setDeduplicationSwitch(true);
-				JSONObject repStrategy = new JSONObject();
-				repStrategy.fluentPut("hangState", "").fluentPut("state", "1,2,4,5,6,7,8").fluentPut("intention", "");
 				createDutyDto.setRepStrategy(repStrategy);
+				createDutyDto.setDeduplicationSwitch(true);
+				createDutyDto.setNoticeSwitch(1);
+
 
 				//遍历最内层任务节点
 				JSONArray dataArr = new JSONArray();
@@ -317,8 +321,7 @@ public class YZAIOBSTask {
 						List<LabelFieldInfoContentVo> labelFieldContentList = labelFieldContentMapper.selectByPatientId(patientInfo.getId());
 						// 处理变量
 						JSONObject jsonObject = new JSONObject();
-						//TODO 需要验证是任务id还是患者id
+						jsonObject.fluentPut("custId", node.getId() + "").fluentPut("手机号", patientInfo.getPatientPhone());
-						jsonObject.fluentPut("custId", node.getId()).fluentPut("手机号", patientInfo.getPatientPhone());
 						if (StringUtils.isNotBlank(scriptInfo.getVariables())) {
 							List<String> variables = Arrays.asList(scriptInfo.getVariables().split("\\|"));
 							variables.forEach(variable -> {
@@ -332,12 +335,15 @@ public class YZAIOBSTask {
 				}
 
 				createDutyDto.setDataArr(dataArr);
-				JSONObject taskObj = iyzaiobsService.createDuty(createDutyDto);
+				String taskId = iyzaiobsService.createDuty(createDutyDto);
 				//设置拨打状态
-				SignPatientManageRouteNode signPatientManageRouteNode_DialStatus = new SignPatientManageRouteNode();
+				if (StringUtils.isNotBlank(taskId)) {
-				signPatientManageRouteNode_DialStatus.setId(node.getId());
+					SignPatientManageRouteNode signPatientManageRouteNode_DialStatus = new SignPatientManageRouteNode();
-				signPatientManageRouteNode_DialStatus.setDialStatus(DialStatusEnum.DIALED.getInfo());
+					signPatientManageRouteNode_DialStatus.setId(node.getId());
-				signPatientManageRouteNodeMapper.updateDialStatusByNodeId(signPatientManageRouteNode_DialStatus);
+					signPatientManageRouteNode_DialStatus.setDialStatus(DialStatusEnum.DIALED.getInfo());
+					signPatientManageRouteNode_DialStatus.setTaskIdExt(taskId);
+					signPatientManageRouteNodeMapper.updateDialStatusByNodeId(signPatientManageRouteNode_DialStatus);
+				}
 			});
 		}
 		log.info("曜智智能外呼创建实时任务定时任务执行完成......");