smartor.git - Gitblit

			@@ -8,23 +8,27 @@
			import com.google.gson.Gson;
			import com.ruoyi.common.core.domain.entity.SysDept;
			import com.ruoyi.common.core.redis.RedisCache;
			import com.ruoyi.common.dx.MessageSend;
			import com.ruoyi.common.core.service.IConfigService;
			import com.ruoyi.satisfaction.api.SatisfactionFacade;
			import com.ruoyi.message.sms.provider.sltd.ws.MessageSend;
			import com.ruoyi.common.exception.base.BaseException;
			import com.ruoyi.common.utils.*;
			import com.ruoyi.common.core.service.IConfigService;
			import com.ruoyi.common.utils.http.HttpUtils;
			import com.ruoyi.common.utils.spring.SpringUtils;
			import com.ruoyi.message.SendResult;
			import com.ruoyi.message.sms.SmsSendRequest;
			import com.ruoyi.message.sms.SmsSenderFactory;
			import com.ruoyi.message.wechat.WechatSendRequest;
			import com.ruoyi.message.wechat.WechatSenderFactory;
			import com.ruoyi.system.domain.SysConfig;
			import com.ruoyi.system.mapper.SysConfigMapper;
			import com.ruoyi.system.service.ISysConfigService;
			import com.smartor.common.FtpService;
			import com.smartor.common.MtSubmitSmUtil;
			import com.smartor.common.ScheduleSubtaskBuilder;
			import com.smartor.config.PhoneUtils;
			import com.smartor.domain.DTO.ServiceSubtaskDetailDTO;
			import com.smartor.domain.DTO.*;
			import com.smartor.domain.*;
			import com.smartor.domain.VO.HeLibraryCountVO;
			import com.smartor.domain.VO.ServiceSubtaskCotinueCountVO;
			import com.smartor.domain.VO.*;
			import com.smartor.domain.entity.ServiceSubtaskEntity;
			import com.smartor.mapper.*;
			import com.smartor.service.*;
			@@ -40,12 +44,13 @@
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.web.bind.annotation.PostMapping;
			import org.springframework.web.bind.annotation.RequestBody;

			import java.io.IOException;
			import java.math.BigDecimal;
			import java.math.RoundingMode;
			import java.net.URLEncoder;
			import java.nio.charset.StandardCharsets;
			import java.security.MessageDigest;
			import java.text.DecimalFormat;
			import java.text.SimpleDateFormat;
			import java.time.*;
			@@ -57,6 +62,8 @@
			import java.util.regex.Pattern;
			import java.util.stream.Collectors;

			import static cn.hutool.core.convert.Convert.toHex;

			/**
			* 单一任务（随访）Service业务层处理
			*
			@@ -66,6 +73,16 @@
			@Slf4j
			@Service
			public class ServiceSubtaskServiceImpl implements IServiceSubtaskService {

			/**
			* 满意度模块对外门面（常驻 Bean）。
			* <p>
			* 随访统计里的「满意度指数」（{@code getSfStatisticsJoy}）只能通过它取数；
			* 满意度模块关闭时门面返回全零 Map，不影响随访统计的其它字段与启动。
			*/
			@Autowired
			private SatisfactionFacade satisfactionFacade;

			@Autowired
			private ServiceSubtaskMapper serviceSubtaskMapper;

			@@ -86,6 +103,8 @@

			@Autowired
			private IServiceTaskdeptService serviceTaskdeptService;
			@Autowired
			private IServiceTaskmedicalService serviceTaskmedicalService;

			@Autowired
			private IServiceTaskdiagService serviceTaskdiagService;
			@@ -160,10 +179,16 @@
			private ISysConfigService configService;

			@Autowired
			private MtSubmitSmUtil mtSubmitSmUtil;
			private SysConfigMapper sysConfigMapper;

			/**
			* 消息发送方工厂（短信/微信公众号），替代原来直接调用各站点发送代码的写法
			*/
			@Autowired
			private SmsSenderFactory smsSenderFactory;

			@Autowired
			private SysConfigMapper sysConfigMapper;
			private WechatSenderFactory wechatSenderFactory;

			@Autowired
			private RedisTemplate redisTemplate;
			@@ -186,9 +211,6 @@
			@Value("${req_path}")
			private String req_path;

			@Value("${xhsmsPath}")
			private String xhsmsPath;

			@Value("${phoneUpEveryHour}")
			private Integer phoneUpEveryHour;
			@Value("${phoneEndHour}")
			@@ -201,6 +223,13 @@

			@Value("${spring.profiles.active}")
			private String active;

			@Autowired
			private ServiceOutPathMapper serviceOutPathMapper;

			private static final String KEY_SEP = "\u0001";
			@Autowired
			private PatMedOperationItemMapper patMedOperationItemMapper;

			/**
			* 查询单一任务（随访）
			@@ -267,6 +296,7 @@
			e.printStackTrace();
			}

			findServiceTaskScheduleVO(serviceTaskVO);
			return serviceTaskVO;
			}

			@@ -396,31 +426,13 @@
			}
			}
			serviceTaskVO.setPatTaskRelevances(patTaskRelevances);
			findServiceTaskScheduleVO(serviceTaskVO);
			return serviceTaskVO;
			}

			@Override
			public List<ServiceSubtaskRes> patItem(ServiceSubtaskEntity serviceSubtaskEntity) {
			if (serviceSubtaskEntity.getSendstateView() != null) {
			// 1：待随访（1 被领取、2 待发送、3 已发送、5 发送失败、7、超时）；2：已完成（ 6 已完成）、3：无需随访（4 不执行）
			if (serviceSubtaskEntity.getSendstateView() == 1)
			serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(1L, 2L, 3L, 5L, 7L)));
			if (serviceSubtaskEntity.getSendstateView() == 2)
			serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(6L)));
			if (serviceSubtaskEntity.getSendstateView() == 3)
			serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(4L)));
			}
			//患者获取随访任务-需要查询同个患者（身份证）所有的任务景宁
			if (StringUtils.isNotEmpty(serviceSubtaskEntity.getOrgid()) && serviceSubtaskEntity.getOrgid().equals("47255004333112711A1001")) {
			if(ObjectUtils.isNotEmpty(serviceSubtaskEntity.getPatid())){
			PatArchive patArchive = patArchiveService.selectPatArchiveByPatid(serviceSubtaskEntity.getPatid());
			if(ObjectUtils.isNotEmpty(patArchive) && StringUtils.isNotEmpty(patArchive.getIdcardno())){
			serviceSubtaskEntity.setPatid(null);
			serviceSubtaskEntity.setSfzh(patArchive.getIdcardno());
			}
			}
			}
			List<ServiceSubtask> selectServiceSubtaskList = this.selectServiceSubtaskList(serviceSubtaskEntity);
			List<ServiceSubtask> selectServiceSubtaskList = getServiceSubtasks(serviceSubtaskEntity);

			List<ServiceSubtaskRes> serviceSubtaskResList = new ArrayList<>();
			for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) {
			@@ -456,6 +468,52 @@
			serviceSubtaskResList.add(serviceSubtaskRes);
			}
			return serviceSubtaskResList;
			}

			public List<ServiceSubtask> getServiceSubtasks(ServiceSubtaskEntity serviceSubtaskEntity) {
			if (serviceSubtaskEntity.getSendstateView() != null) {
			// 1：待随访（1 被领取、2 待发送、3 已发送、5 发送失败、7、超时）；2：已完成（ 6 已完成）、3：无需随访（4 不执行）
			if (serviceSubtaskEntity.getSendstateView() == 1)
			serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(1L, 2L, 3L, 5L, 7L)));
			if (serviceSubtaskEntity.getSendstateView() == 2)
			serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(6L)));
			if (serviceSubtaskEntity.getSendstateView() == 3)
			serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(4L)));
			}
			//患者获取随访任务-需要查询同个患者（身份证）所有的任务景宁
			if (StringUtils.isNotEmpty(serviceSubtaskEntity.getOrgid()) && serviceSubtaskEntity.getOrgid().equals("47255004333112711A1001")) {
			if (ObjectUtils.isNotEmpty(serviceSubtaskEntity.getPatid())) {
			PatArchive patArchive = patArchiveService.selectPatArchiveByPatid(serviceSubtaskEntity.getPatid());
			if (ObjectUtils.isNotEmpty(patArchive) && StringUtils.isNotEmpty(patArchive.getIdcardno())) {
			serviceSubtaskEntity.setPatid(null);
			serviceSubtaskEntity.setSfzh(patArchive.getIdcardno());
			}
			}
			}
			List<ServiceSubtask> selectServiceSubtaskList = this.selectServiceSubtaskList(serviceSubtaskEntity);
			return selectServiceSubtaskList;
			}

			@Override
			public Integer transferDept(TransferDeptVO transferDeptVO) {
			log.info("transferDept的入参为：{}", transferDeptVO);
			//查询该患者的子任务信息
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(transferDeptVO.getSubId());
			if (ObjectUtils.isEmpty(serviceSubtask)) throw new BaseException("转患者失败，请联系管理员处理");
			//删除该患者的信息通过subid
			serviceSubtaskMapper.deleteServiceSubtaskById(transferDeptVO.getSubId());

			//修改患者的离院科室病区通过inhospid和患者的任务生成状态
			PatMedInhosp patMedInhosp = new PatMedInhosp();
			patMedInhosp.setInhospid(serviceSubtask.getInhospid());
			patMedInhosp.setLeaveldeptcode(transferDeptVO.getLeavelDeptCode());
			patMedInhosp.setLeaveldeptname(transferDeptVO.getLeavelDeptName());
			patMedInhosp.setLeavehospitaldistrictcode(transferDeptVO.getLeavehospitaldistrictcode());
			patMedInhosp.setLeavehospitaldistrictname(transferDeptVO.getLeavehospitaldistrictname());
			patMedInhosp.setDeptcheckFlag("0");
			patMedInhosp.setWardcheckFlag("0");
			patMedInhosp.setDiagcheckFlag("0");
			return patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
			}

			public Map<String, String> calculateAge(LocalDate birthdate, LocalDate today) {
			@@ -557,7 +615,6 @@
			// return map;
			// }


			/**
			* 统计任务各种状态的数量（已优化）
			* 优化说明：
			@@ -594,15 +651,126 @@
			}

			/**
			* 统计任务各种状态的数量（已优化）
			* 优化说明：
			* 1. 使用数据库层聚合计算，替代应用层遍历
			* 2. 性能提升 10-100 倍（取决于数据量）
			* 3. 降低内存占用和网络传输
			*
			* @param serviceSubtaskEntity 查询条件
			* @return 各状态统计结果
			*/
			@Override
			public Map<String, Object> countByCondition(ServiceSubtaskEntity serviceSubtaskEntity) {
			// 直接调用数据库统计方法，在数据库层完成聚合计算
			Map<String, Object> result = serviceSubtaskMapper.countByCondition(serviceSubtaskEntity);
			// 处理空异常
			if (MapUtils.isEmpty(result)) {
			result = new HashMap<>();
			// 确保所有 key 都有值，避免空指针异常
			// MyBatis 的 SUM 在没有匹配行时会返回 null
			result.putIfAbsent("wzx", 0);
			result.putIfAbsent("ysf", 0);
			result.putIfAbsent("fssb", 0);
			result.putIfAbsent("yfs", 0);
			result.putIfAbsent("blq", 0);
			result.putIfAbsent("total", 0);
			result.putIfAbsent("wxsf", 0);
			result.putIfAbsent("xsf", 0);
			result.putIfAbsent("dsf", 0);
			result.putIfAbsent("dfs", 0);
			result.putIfAbsent("yfs", 0);
			result.putIfAbsent("ywc", 0);
			result.putIfAbsent("yc", 0);
			result.putIfAbsent("jg", 0);
			}
			return result;
			}

			/**
			* 新增单一任务（随访）
			*
			* @param serviceSubtask 单一任务（随访）
			* @return 结果
			*/
			@Override
			public int insertServiceSubtask(ServiceSubtask serviceSubtask) {
			serviceSubtask.setCreateTime(DateUtils.getNowDate());
			return serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			public Map<String, Object> insertServiceSubtask(ServiceSubtask serviceSubtask) {
			List<ServiceSubtask> serviceSubtasks = null;
			//先查询一下该患者是否已经创建根据serviceType,sendstate,inhospid,patid,orgid
			//这样判断主要是为了想让新华医院的外部导入患者创建任务，也能用这个接口
			if (StringUtils.isEmpty(serviceSubtask.getPatfrom()) \|\| !serviceSubtask.getPatfrom().equals("2")) {
			ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity();
			serviceSubtaskVO.setServiceType(serviceSubtask.getServiceType());
			serviceSubtaskVO.setInhospid(serviceSubtask.getInhospid());
			serviceSubtaskVO.setSendstates(new ArrayList<>(Arrays.asList(1L, 2L, 3L, 5L, 7L)));
			serviceSubtaskVO.setPatid(serviceSubtask.getPatid());
			serviceSubtaskVO.setOrgid(serviceSubtask.getOrgid());
			serviceSubtaskVO.setCampusid(serviceSubtask.getCampusid());
			serviceSubtasks = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO);
			}
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			String format = null;
			if (CollectionUtils.isNotEmpty(serviceSubtasks)) {
			ServiceSubtask serviceSubtask1 = serviceSubtasks.get(0);
			ServiceOutPath serviceOutPath = new ServiceOutPath();
			serviceOutPath.setSubId(serviceSubtask1.getId());
			List<ServiceOutPath> serviceOutPaths = serviceOutPathMapper.selectServiceOutPathList(serviceOutPath);
			if (CollectionUtils.isNotEmpty(serviceOutPaths))
			format = String.format("%03X", serviceOutPaths.get(0).getId());
			else format = getOutPath(serviceSubtask1, rsaPublicKeyExample);
			serviceSubtask = serviceSubtask1;
			} else {
			//如果不存在，则新增
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			if (ObjectUtils.isNotEmpty(serviceTask)) {
			serviceSubtask.setTaskDesc(serviceTask.getTaskDesc());
			serviceSubtask.setTaskName(serviceTask.getTaskName());
			serviceSubtask.setTemplatename(serviceTask.getTemplatename());
			}

			serviceSubtask.setCreateTime(DateUtils.getNowDate());
			serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			//修改住院满意度状态（避免重复查询）
			if (serviceSubtask.getServiceType() != null && "6".equals(serviceSubtask.getServiceType())) {
			Long inhospid = serviceSubtask.getInhospid();
			if (inhospid != null) {
			PatMedInhosp patMedInhosp = new PatMedInhosp();
			patMedInhosp.setInhospMydFlag("1");
			patMedInhosp.setInhospid(inhospid);
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
			}
			}
			format = getOutPath(serviceSubtask, rsaPublicKeyExample);
			}

			Map<String, Object> result = new HashMap<>();
			if (StringUtils.isNotEmpty(format))
			result.put("url", StringUtils.isNotEmpty(req_path) ? localIP + ":" + req_path + "/wt?p=" + format : localIP + "/wt?p=" + format);
			else result.put("url", null);
			result.put("subId", serviceSubtask.getId());
			return result;
			}

			private String getOutPath(ServiceSubtask serviceSubtask, RSAPublicKeyExample rsaPublicKeyExample) {
			String format;
			String taskId = rsaPublicKeyExample.encryptedData(serviceSubtask.getTaskid().toString(), pub_key);
			String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);
			String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key);
			ServiceOutPath serviceOutPath = new ServiceOutPath();
			serviceOutPath.setParam1(taskId);
			serviceOutPath.setParam2(patid);
			serviceOutPath.setCreateTime(new Date());
			serviceOutPath.setParam6(subId);
			serviceOutPath.setOrgid(serviceSubtask.getOrgid());
			serviceOutPath.setTaskId(serviceSubtask.getTaskid());
			serviceOutPath.setSubId(serviceSubtask.getId());
			iServiceOutPathService.insertServiceOutPath(serviceOutPath);
			//转成16进制
			format = String.format("%03X", serviceOutPath.getId());
			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			iServiceOutPathService.updateServiceOutPath(serviceOutPath);
			return format;
			}

			/**
			@@ -619,8 +787,12 @@
			patMedInhosp.setInhospstate("0");
			List<PatMedInhosp> patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
			PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(serviceSubtask1.getPatid());

			if (patMedInhospList.size() > 0) {
			//景宁新增再次随访不能触发患者再入院
			boolean inhospAgain = true;
			if (serviceSubtask1.getOrgid().equals("47255004333112711A1001")) {
			inhospAgain = false;
			}
			if (patMedInhospList.size() > 0 && inhospAgain) {
			serviceSubtask1.setIsVisitAgain(2);
			serviceSubtask1.setRemark(StringUtils.isNotEmpty(serviceSubtask.getRemark()) ? serviceSubtask.getRemark() + ";患者再入院了" : "患者再入院了");
			serviceSubtask1.setSendstate(4L);
			@@ -671,6 +843,7 @@
			serviceSubtask.setUpdateTime(DateUtils.getNowDate());
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 6)
			serviceSubtask.setFinishtime(new Date());

			return serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			}

			@@ -688,7 +861,6 @@
			svyTaskTemplateService.deleteSvyTaskTemplateBySvyid(serviceSubtask.getTemplateid());
			} else if (serviceSubtask.getType().equals("1"))
			ivrTaskTemplateService.deleteIvrTaskTemplateByID(serviceSubtask.getTemplateid());


			String tempName = svyTaskTemplateService.selectSvyTaskTemplateBySvyid(Long.valueOf(taskTempid)).getSvyname();
			serviceSubtask.setTemplateid(taskTempid.longValue());
			@@ -873,6 +1045,36 @@

			log.info("----serviceTaskSchedule的值为：{}", scheduleVO);
			serviceTaskScheduleService.saveScheduleWithDetail(scheduleVO);
			} else if (serviceTaskVO.getAppltype().equals("6")) {
			ServiceTaskmedical serviceTaskmedical = new ServiceTaskmedical();
			serviceTaskmedical.setTaskId(serviceTask.getTaskid());
			serviceTaskmedical.setTaskName(serviceTask.getTaskName());
			serviceTaskmedical.setServiceType(serviceTaskVO.getServiceType());
			serviceTaskmedical.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			if (serviceTaskVO.getLongTask() == 1) serviceTaskmedical.setLongtask(1L);
			serviceTaskmedical.setMedicalCode(serviceTaskVO.getIcd10code());
			serviceTaskmedical.setMedicalName(serviceTaskVO.getIcd10name());
			serviceTaskmedical.setGuid(serviceTask.getGuid());
			serviceTaskmedical.setOrgid(serviceTask.getOrgid());
			serviceTaskmedical.setCreateTime(new Date());
			serviceTaskmedical.setDeptCode(serviceTaskVO.getDeptcode());
			serviceTaskmedical.setDeptName(serviceTaskVO.getDeptname());
			serviceTaskmedical.setWardCode(serviceTaskVO.getLeavehospitaldistrictcode());
			serviceTaskmedical.setWardName(serviceTaskVO.getLeavehospitaldistrictname());
			//南华附一的icd10code是有重复的，所以不能用南华附一的icd10code去查询
			log.info("----serviceTaskmedical的值为：{}", serviceTaskmedical);
			if (!StringUtils.isEmpty(serviceTaskVO.getMedicalName())) {
			String[] medicalNames = serviceTaskVO.getMedicalName().split(",");
			String[] medicalcodes = serviceTaskVO.getMedicalCode().split(",");
			String[] medicalCompanys = serviceTaskVO.getMedicalCompany().split(",");
			for (int i = 0; i < medicalNames.length; i++) {
			serviceTaskmedical.setMedicalCode(medicalNames[i]);
			serviceTaskmedical.setMedicalName(medicalcodes[i]);
			if (ObjectUtils.isNotEmpty(medicalCompanys))
			serviceTaskmedical.setMedicalCompany(medicalCompanys[i]);
			serviceTaskmedicalService.insertServiceTaskmedical(serviceTaskmedical);
			}
			}
			} else {
			ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
			serviceTaskdept.setTaskId(serviceTask.getTaskid());
			@@ -909,8 +1111,8 @@
			//将任务信息放到服务表中
			ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceSubtask.class);
			serviceSubtask.setTaskid(serviceTask.getTaskid().longValue());
			serviceSubtask.setTemplatename(tempName);
			serviceSubtask.setTemplateid(tempid);
			serviceSubtask.setTemplatename(ObjectUtils.isNotEmpty(tempid) ? tempName : serviceTask.getTemplatename());
			serviceSubtask.setTemplateid(ObjectUtils.isNotEmpty(tempid) ? tempid : serviceTask.getTemplateid());
			serviceSubtask.setLibtemplateid(ObjectUtils.isEmpty(serviceTask.getLibtemplateid()) ? null : Long.valueOf(serviceTask.getLibtemplateid()));
			serviceSubtask.setLibtemplatename(serviceTask.getLibtemplatename());
			//新增
			@@ -965,10 +1167,8 @@
			if (schedule == null) {
			throw new BaseException("appltype=5 任务组：未找到 taskid=" + serviceTask.getTaskid() + " 的计划");
			}
			List<ServiceTaskScheduleDetail> detailList =
			serviceTaskScheduleService.selectDetailByScheduleid(schedule.getId());
			scheduleSubtaskBuilder.buildSubtasksForPatient(
			serviceTask, serviceTaskVO.getPreachformList(), schedule, detailList, patTaskRelevance, serviceSubtask);
			List<ServiceTaskScheduleDetail> detailList = serviceTaskScheduleService.selectDetailByScheduleid(schedule.getId());
			scheduleSubtaskBuilder.buildSubtasksForPatient(serviceTask, serviceTaskVO.getPreachformList(), schedule, detailList, patTaskRelevance, serviceSubtask);
			continue;
			}

			@@ -1023,7 +1223,7 @@
			redisCache.removeElementFromList("cache-3", serviceSubtask.getId().toString());
			redisCache.removeElementFromList("cache-4", serviceSubtask.getId().toString());
			//将出入院表的数据，还原成还未处理的状态
			if (serviceSubtask.getServiceType().equals("2")) {
			if (serviceSubtask.getServiceType().equals("2") \|\| serviceSubtask.getServiceType().equals("13")) {
			ServiceTask st = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			//如果任务是长期任务，需要将该患者的出入院数据还原成还未处理的状态
			if (st != null && st.getLongTask() == 1) {
			@@ -1044,6 +1244,16 @@
			patMedOuthosp.setServerState("0");
			patMedOuthospService.updatePatMedOuthosp(patMedOuthosp);
			}
			}
			} else if (serviceSubtask.getServiceType().equals("19")) {
			ServiceTask st = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			//如果任务是长期任务，需要将该患者的出院详情状态还原成还未处理的状态
			if (st != null && st.getLongTask() == 1
			&& ObjectUtils.isNotEmpty(serviceSubtask.getOperationItemId())) {
			PatMedOperationItem patMedOperationItem = new PatMedOperationItem();
			patMedOperationItem.setOpercheckFlag("0");
			patMedOperationItem.setId(serviceSubtask.getOperationItemId());
			patMedOperationItemMapper.updatePatMedOperationItem(patMedOperationItem);
			}
			}
			}
			@@ -1146,6 +1356,54 @@
			}
			}

			} else if (serviceTaskVO.getAppltype().equals("6")) {
			ServiceTaskmedical serviceTaskmedical = new ServiceTaskmedical();
			serviceTaskmedical.setTaskId(serviceTask.getTaskid());
			serviceTaskmedical.setTaskName(serviceTask.getTaskName());
			if (StringUtils.isEmpty(serviceTaskVO.getMedicalCode())) {
			throw new BaseException("药品编码为空");
			}
			serviceTaskmedical.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			serviceTaskmedical.setMedicalName(serviceTaskVO.getMedicalName());
			serviceTaskmedical.setGuid(serviceTask1.getGuid());
			serviceTaskmedical.setServiceType(serviceTask1.getServiceType());
			serviceTaskmedical.setOrgid(serviceTask1.getOrgid());
			serviceTaskmedical.setDeptCode(serviceTask1.getDeptcode());
			serviceTaskmedical.setDeptName(serviceTask1.getDeptname());
			serviceTaskmedical.setWardCode(serviceTask1.getLeavehospitaldistrictcode());
			serviceTaskmedical.setWardName(serviceTask1.getLeavehospitaldistrictname());
			serviceTaskmedical.setUpdateTime(new Date());
			if (StringUtils.isNotEmpty(serviceTaskVO.getMedicalCode())) {
			String[] medicalCodes = serviceTaskVO.getMedicalCode().split(",");
			String[] medicalNames = serviceTaskVO.getMedicalName().split(",");
			String[] medicalCompanys = serviceTaskVO.getMedicalCompany().split(",");
			if (!active.equals("nhfy") && !active.equals("druid")) {
			if (medicalCodes.length != medicalNames.length && medicalNames.length != medicalCompanys.length) {
			throw new BaseException("药品编码和药品名称数量不一致或者药品名称和药品公司数量不一致");
			}
			}

			for (int i = 0; i < medicalCodes.length; i++) {
			//先查询一下是否存在
			ServiceTaskmedical serviceTaskmedical1 = new ServiceTaskmedical();
			serviceTaskmedical1.setTaskId(serviceTaskVO.getTaskid());
			serviceTaskmedical1.setMedicalCode(medicalCodes[i]);
			serviceTaskmedical1.setMedicalName(medicalNames[i]);
			serviceTaskmedical1.setMedicalCompany(medicalCompanys[i]);
			List<ServiceTaskmedical> serviceTaskmedicals = serviceTaskmedicalService.selectServiceTaskmedicalList(serviceTaskmedical1);
			serviceTaskmedical.setMedicalCode(medicalCodes[i]);
			serviceTaskmedical.setMedicalName(medicalNames[i]);
			serviceTaskmedical.setMedicalCompany(medicalCompanys[i]);
			log.info("----serviceTaskmedical更新的值为：{}", serviceTaskmedical);
			if (CollectionUtils.isNotEmpty(serviceTaskmedicals)) {
			serviceTaskmedical.setId(serviceTaskmedicals.get(0).getId());
			serviceTaskmedicalService.updateServiceTaskmedical(serviceTaskmedical);
			} else {
			serviceTaskmedicalService.insertServiceTaskmedical(serviceTaskmedical);
			}
			}
			}

			} else if (serviceTaskVO.getAppltype().equals("4")) {
			ServiceTaskoper serviceTaskoper = new ServiceTaskoper();
			// if (StringUtils.isEmpty(serviceTaskVO.getOpcode())) {
			@@ -1229,6 +1487,8 @@
			ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceSubtask.class);
			serviceSubtask.setLibtemplateid(ObjectUtils.isEmpty(serviceTaskVO.getLibtemplateid()) ? null : Long.valueOf(serviceTaskVO.getLibtemplateid()));
			serviceSubtask.setLibtemplatename(serviceTaskVO.getLibtemplatename());
			serviceSubtask.setTemplateid(serviceTask.getTemplateid());
			serviceSubtask.setTemplatename(serviceTask.getTemplatename());
			serviceSubtask.setSendname(patTaskRelevance.getName());
			serviceSubtask.setAge(patTaskRelevance.getAge());
			serviceSubtask.setSfzh(patTaskRelevance.getSfzh());
			@@ -1263,12 +1523,10 @@
			if (schedule == null) {
			throw new BaseException("appltype=5 任务组：未找到 taskid=" + serviceTask.getTaskid() + " 的计划");
			}
			List<ServiceTaskScheduleDetail> detailList =
			serviceTaskScheduleService.selectDetailByScheduleid(schedule.getId());
			List<ServiceTaskScheduleDetail> detailList = serviceTaskScheduleService.selectDetailByScheduleid(schedule.getId());
			serviceSubtask.setUpdateBy(serviceTask.getUpdateBy());
			serviceSubtask.setCreateBy(serviceTask.getUpdateBy());
			scheduleSubtaskBuilder.buildSubtasksForPatient(
			serviceTask, serviceTaskVO.getPreachformList(), schedule, detailList, patTaskRelevance, serviceSubtask);
			scheduleSubtaskBuilder.buildSubtasksForPatient(serviceTask, serviceTaskVO.getPreachformList(), schedule, detailList, patTaskRelevance, serviceSubtask);
			continue;
			}
			if (patTaskRelevance.getIsoperation() == 2) {
			@@ -1730,7 +1988,7 @@
			Long id = serviceSubtask.getId();
			//先更新一下分数
			double score = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			serviceSubtask.setScore(BigDecimal.valueOf(score));
			serviceSubtask.setScore(String.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setUpdateTime(new Date());
			log.error("先更新一下分数,电话的serviceSubtask的值为：{}", serviceSubtask);
			@@ -1824,236 +2082,48 @@
			//用来标记，是否有匹配上的
			Integer flag = 0;
			//1-AI识别
			String url = configService.selectConfigByKey("sys.voice.match.ai.url",phoneCallReqYQVO.getOrgid());
			String url = configService.selectConfigByKey("sys.voice.match.ai.url", phoneCallReqYQVO.getOrgid());

			if (ObjectUtils.isNotEmpty(url)) {
			PhoneCallBackYQVO aiMatchResult = AiMatch(url, phoneCallReqYQVO, phoneCallBackYQVO,
			ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate,
			ivrTaskTemplateScripts, scriptId, flag, phoneCallReqYQVO.getUuid());
			if(aiMatchResult != null){
			return aiMatchResult;
			}
			} else {
			//是选择题
			for (int j = 0; j < ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().size(); j++) {
			log.error("phoneCallReqYQVO.getAsrtext()的值为：{}", phoneCallReqYQVO.getAsrtext());
			if (StringUtils.isEmpty(phoneCallReqYQVO.getAsrtext())) {
			continue;
			if (ObjectUtils.isNotEmpty(url)) {
			PhoneCallBackYQVO aiMatchResult = AiMatch(url, phoneCallReqYQVO, phoneCallBackYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate, ivrTaskTemplateScripts, scriptId, flag, phoneCallReqYQVO.getUuid());
			if (aiMatchResult != null) {
			return aiMatchResult;
			}
			boolean matchedFlag = false;
			//包含
			Matcher matcher = null;
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex())) {
			Pattern pattern = Pattern.compile(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex());
			matcher = pattern.matcher(phoneCallReqYQVO.getAsrtext());
			}
			//不包含
			Matcher matcher2 = null;
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2())) {
			Pattern pattern2 = Pattern.compile(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2());
			matcher2 = pattern2.matcher(phoneCallReqYQVO.getAsrtext());
			}

			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() && StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches() \|\| StringUtils.isEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() \|\| StringUtils.isEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches()) {
			matchedFlag = true;
			}
			//说明匹配正确了
			if(matchedFlag){
			//这里应该先判断类型，去再修改，设置IsUserOperation是单选题的改法
			log.info("匹配正确了吗--------------");
			ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).setIsUserOperation(1);
			serviceTaskScriptTargetoptionMapper.updateIvrTaskTemplateTargetoption(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j));

			//将患者的回签写进service_subtask_detail中
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ivrTaskTemplateScriptVO.setQuestionResult(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getOptiondesc());
			ServiceSubtaskDetail serviceSubtaskDetail = getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate);
			//修改一下语音路径（改成前端可以访问的，存到数据库中）
			if (StringUtils.isNotEmpty(serviceSubtaskDetail.getQuestionvoice())) {
			String questionvoice = serviceSubtaskDetail.getQuestionvoice();
			String[] split = questionvoice.split("\\\\");
			if (split.length > 0) {
			String lastPart = split[split.length - 1];
			serviceSubtaskDetail.setQuestionvoice(voicePathPrefix + lastPart);
			}
			} else {
			//是选择题
			for (int j = 0; j < ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().size(); j++) {
			log.error("phoneCallReqYQVO.getAsrtext()的值为：{}", phoneCallReqYQVO.getAsrtext());
			if (StringUtils.isEmpty(phoneCallReqYQVO.getAsrtext())) {
			continue;
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			serviceSubTaskDetailReq.setGuid(phoneCallReqYQVO.getGuid());
			serviceSubTaskDetailReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);

			//判断一下当前的问题是不是满意度问题，并且dutyDeptCode是否有值，并且选项是不是异常选项，如果全符合，则往满意度问题异常表新增
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getDutyDeptCode()) && 1 == ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getIsabnormal()) {
			ServiceSubtaskDetailTrace subtaskDetailTrace = new ServiceSubtaskDetailTrace();
			//用taskid、subid和scriptid去获取detailid
			ServiceSubtaskDetail ssd = new ServiceSubtaskDetail();
			ssd.setSubId(serviceSubtask.getId());
			ssd.setTaskid(serviceSubtask.getTaskid());
			ssd.setScriptid(StringUtils.isNotEmpty(scriptId) ? Long.valueOf(scriptId) : null);
			List<ServiceSubtaskDetail> serviceSubtaskDetails = serviceSubtaskDetailMapper.selectServiceSubtaskDetailList(ssd);
			subtaskDetailTrace.setDetailId(CollectionUtils.isNotEmpty(serviceSubtaskDetails) ? serviceSubtaskDetails.get(0).getId() : null);

			subtaskDetailTrace.setSubId(serviceSubtask.getId());
			subtaskDetailTrace.setTaskid(serviceSubtask.getTaskid());
			subtaskDetailTrace.setTemplateid(ivrTaskTemplateScriptVO.getId());
			subtaskDetailTrace.setTemplatequestionnum(ivrTaskTemplateScriptVO.getScriptno());
			subtaskDetailTrace.setSwitchid(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getId());
			subtaskDetailTrace.setQuestiontext(ivrTaskTemplateScriptVO.getScriptContent());
			subtaskDetailTrace.setQuestionvoice(null);
			subtaskDetailTrace.setCategoryname(ivrTaskTemplateScriptVO.getScriptAssortname());
			subtaskDetailTrace.setCategoryid(ivrTaskTemplateScriptVO.getScriptAssortid());
			//获取所有选项
			String optionDescStr = Optional.ofNullable(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList()).filter(list -> !list.isEmpty()).map(list -> list.stream().map(IvrTaskTemplateTargetoption::getOptiondesc).filter(Objects::nonNull).collect(Collectors.joining("&"))).orElse("");
			subtaskDetailTrace.setTargetid(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getId());
			subtaskDetailTrace.setTargetvalue(optionDescStr);
			subtaskDetailTrace.setMatchedtext(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getOptiondesc());
			subtaskDetailTrace.setValueType(serviceSubtaskDetails.get(0).getValueType());
			subtaskDetailTrace.setTemplateType(1);

			SvyLibScriptCategory svyLibScriptCategory = svyLibScriptCategoryMapper.selectSvyLibScriptCategoryById(ivrTaskTemplateScriptVO.getScriptAssortid());
			subtaskDetailTrace.setType(svyLibScriptCategory.getType());
			subtaskDetailTrace.setScriptid(ivrTaskTemplateScriptVO.getId());
			subtaskDetailTrace.setAsrtext(phoneCallReqYQVO.getAsrtext());
			subtaskDetailTrace.setRecordpath(phoneCallReqYQVO.getRecordpath());
			subtaskDetailTrace.setPatid(serviceSubtask.getPatid());
			JSONObject patdescJson = new JSONObject();
			patdescJson.put("sendname", serviceSubtask.getSendname());
			patdescJson.put("phone", serviceSubtask.getPhone());
			patdescJson.put("age", serviceSubtask.getAge());
			patdescJson.put("sex", serviceSubtask.getSex() != null ? serviceSubtask.getSex() == 1 ? "男" : "女" : null);
			subtaskDetailTrace.setPatdesc(patdescJson.toJSONString());
			subtaskDetailTrace.setTodeptcode(ivrTaskTemplateScriptVO.getDutyDeptCode());
			subtaskDetailTrace.setTodeptname(ivrTaskTemplateScriptVO.getDutyDeptName());
			subtaskDetailTrace.setOrgid(serviceSubtask.getOrgid());
			subtaskDetailTrace.setHandleFlag("0");
			subtaskDetailTrace.setGuid(phoneCallReqYQVO.getGuid());
			subtaskDetailTrace.setCreateTime(new Date());
			subtaskDetailTrace.setUpdateTime(new Date());
			subtaskDetailTrace.setOrgid(phoneCallReqYQVO.getOrgid());
			traceService.insertServiceSubtaskDetailTtrace(subtaskDetailTrace);
			boolean matchedFlag = false;
			//包含
			Matcher matcher = null;
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex())) {
			Pattern pattern = Pattern.compile(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex());
			matcher = pattern.matcher(phoneCallReqYQVO.getAsrtext());
			}
			//不包含
			Matcher matcher2 = null;
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2())) {
			Pattern pattern2 = Pattern.compile(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2());
			matcher2 = pattern2.matcher(phoneCallReqYQVO.getAsrtext());
			}

			//判断一下，这个选项结果是不是还有继续问下去的必要，例如选项结果是别人不想继续回答问题，就要结束掉
			if (ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getIsEnd() == 1) {
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "noVoice");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask.getJsy());
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			return phoneCallBackYQVO;
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() && StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches() \|\| StringUtils.isEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() \|\| StringUtils.isEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches()) {
			matchedFlag = true;
			}
			//说明匹配正确了
			if (matchedFlag) {
			//这里应该先判断类型，去再修改，设置IsUserOperation是单选题的改法
			log.info("匹配正确了吗--------------");
			ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).setIsUserOperation(1);
			serviceTaskScriptTargetoptionMapper.updateIvrTaskTemplateTargetoption(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j));

			flag = 1;
			//将当前前的播报状态删除，给下一题让位
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			// //获取下一题
			log.error("获取下一题的信息：{}", ivrTaskTemplateScriptVO);
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("1") \|\| ivrTaskTemplateScriptVO.getBranchFlag().equals("0") && ivrTaskTemplateScriptVO.getNextScriptno() != null && ivrTaskTemplateScriptVO.getNextScriptno() != 0) {
			Long nextQuestion = null;
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("1")) {
			nextQuestion = ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getNextQuestion();
			//更新分数
			double score = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			score = BigDecimal.valueOf(score).add(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getScore()).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score);
			} else {
			nextQuestion = ivrTaskTemplateScriptVO.getNextScriptno();
			//更新分数
			Object obj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			Double score = (obj == null ? new Double(0.00) : new Double(((Double) obj).doubleValue()));
			score = BigDecimal.valueOf(score).add(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getScore()).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);
			}
			if (nextQuestion == null \|\| nextQuestion == 0L) {
			//如果下一题为空，或者为0，则挂机
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(6L);
			ss.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(ss);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");

			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "noVoice");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask.getJsy());
			//将结果写进detail表
			ServiceSubTaskDetailReq ssdReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList2 = new ArrayList<>();
			serviceSubtaskDetailList.add(getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate));
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList2);
			ssdReq.setGuid(phoneCallReqYQVO.getGuid());
			ssdReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(ssdReq);
			return phoneCallBackYQVO;
			}

			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (script.getSort() == nextQuestion.intValue()) {
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = StringUtils.isNotEmpty(script.getIvrtext()) ? script.getIvrtext() : script.getScriptContent();
			log.error("下一题问题：{}", scriptContent);
			log.error("下一题的子任务是：{}", serviceSubtask);
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + getObject(serviceSubtask, scriptContent));
			//将该患者的Redis中的题目ID，进行修改
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid().trim() + "-" + phoneCallReqYQVO.getPhone().trim(), script.getId().toString(), 120, TimeUnit.MINUTES);
			//删除无响应
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			}
			}
			} else if (ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getNextScriptno() == 0) {
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			//更新一下分数
			double score = 0.0;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (double) scoreObj;
			serviceSubtask.setScore(BigDecimal.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			//设置结束语
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask1.getJsy());
			Long id = serviceSubtask.getId();
			Map<String, String> map = delRedisValue(null, id.toString());
			log.error("map的值为：{}", map);
			if (ObjectUtils.isNotEmpty(map))
			redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			// return phoneCallBackYQVO;

			}
			} else {
			log.info("没有匹配上----------------------------");
			//flag=0,说明没匹配上，也要把患者说的话记录下来
			if (j == ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().size() - 1 && flag == 0) {
			//将患者的回签写进service_subtask_detail中
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ivrTaskTemplateScriptVO.setQuestionResult(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getOptiondesc());
			ServiceSubtaskDetail serviceSubtaskDetail = getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate);
			//修改一下语音路径（改成前端可以访问的，存到数据库中）
			if (StringUtils.isNotEmpty(serviceSubtaskDetail.getQuestionvoice())) {
			@@ -2065,17 +2135,203 @@
			}
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			//如果没有匹配上，这个必须为null
			serviceSubtaskDetailList.get(0).setMatchedtext("");
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			serviceSubTaskDetailReq.setGuid(phoneCallReqYQVO.getGuid());
			serviceSubTaskDetailReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);

			//判断一下当前的问题是不是满意度问题，并且dutyDeptCode是否有值，并且选项是不是异常选项，如果全符合，则往满意度问题异常表新增
			if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getDutyDeptCode()) && 1 == ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getIsabnormal()) {
			ServiceSubtaskDetailTrace subtaskDetailTrace = new ServiceSubtaskDetailTrace();
			//用taskid、subid和scriptid去获取detailid
			ServiceSubtaskDetail ssd = new ServiceSubtaskDetail();
			ssd.setSubId(serviceSubtask.getId());
			ssd.setTaskid(serviceSubtask.getTaskid());
			ssd.setScriptid(StringUtils.isNotEmpty(scriptId) ? Long.valueOf(scriptId) : null);
			List<ServiceSubtaskDetail> serviceSubtaskDetails = serviceSubtaskDetailMapper.selectServiceSubtaskDetailList(ssd);
			subtaskDetailTrace.setDetailId(CollectionUtils.isNotEmpty(serviceSubtaskDetails) ? serviceSubtaskDetails.get(0).getId() : null);

			subtaskDetailTrace.setSubId(serviceSubtask.getId());
			subtaskDetailTrace.setTaskid(serviceSubtask.getTaskid());
			subtaskDetailTrace.setTemplateid(ivrTaskTemplateScriptVO.getId());
			subtaskDetailTrace.setTemplatequestionnum(ivrTaskTemplateScriptVO.getScriptno());
			subtaskDetailTrace.setSwitchid(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getId());
			subtaskDetailTrace.setQuestiontext(ivrTaskTemplateScriptVO.getScriptContent());
			subtaskDetailTrace.setQuestionvoice(null);
			subtaskDetailTrace.setCategoryname(ivrTaskTemplateScriptVO.getScriptAssortname());
			subtaskDetailTrace.setCategoryid(ivrTaskTemplateScriptVO.getScriptAssortid());
			//获取所有选项
			String optionDescStr = Optional.ofNullable(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList()).filter(list -> !list.isEmpty()).map(list -> list.stream().map(IvrTaskTemplateTargetoption::getOptiondesc).filter(Objects::nonNull).collect(Collectors.joining("&"))).orElse("");
			subtaskDetailTrace.setTargetid(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getId());
			subtaskDetailTrace.setTargetvalue(optionDescStr);
			subtaskDetailTrace.setMatchedtext(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getOptiondesc());
			subtaskDetailTrace.setValueType(serviceSubtaskDetails.get(0).getValueType());
			subtaskDetailTrace.setTemplateType(1);

			SvyLibScriptCategory svyLibScriptCategory = svyLibScriptCategoryMapper.selectSvyLibScriptCategoryById(ivrTaskTemplateScriptVO.getScriptAssortid());
			subtaskDetailTrace.setType(svyLibScriptCategory.getType());
			subtaskDetailTrace.setScriptid(ivrTaskTemplateScriptVO.getId());
			subtaskDetailTrace.setAsrtext(phoneCallReqYQVO.getAsrtext());
			subtaskDetailTrace.setRecordpath(phoneCallReqYQVO.getRecordpath());
			subtaskDetailTrace.setPatid(serviceSubtask.getPatid());
			JSONObject patdescJson = new JSONObject();
			patdescJson.put("sendname", serviceSubtask.getSendname());
			patdescJson.put("phone", serviceSubtask.getPhone());
			patdescJson.put("age", serviceSubtask.getAge());
			patdescJson.put("sex", serviceSubtask.getSex() != null ? serviceSubtask.getSex() == 1 ? "男" : "女" : null);
			subtaskDetailTrace.setPatdesc(patdescJson.toJSONString());
			subtaskDetailTrace.setTodeptcode(ivrTaskTemplateScriptVO.getDutyDeptCode());
			subtaskDetailTrace.setTodeptname(ivrTaskTemplateScriptVO.getDutyDeptName());
			subtaskDetailTrace.setOrgid(serviceSubtask.getOrgid());
			subtaskDetailTrace.setHandleFlag("0");
			subtaskDetailTrace.setGuid(phoneCallReqYQVO.getGuid());
			subtaskDetailTrace.setCreateTime(new Date());
			subtaskDetailTrace.setUpdateTime(new Date());
			subtaskDetailTrace.setOrgid(phoneCallReqYQVO.getOrgid());
			traceService.insertServiceSubtaskDetailTtrace(subtaskDetailTrace);
			}

			//判断一下，这个选项结果是不是还有继续问下去的必要，例如选项结果是别人不想继续回答问题，就要结束掉
			if (ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getIsEnd() == 1) {
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "noVoice");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask.getJsy());
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			return phoneCallBackYQVO;
			}

			flag = 1;
			//将当前前的播报状态删除，给下一题让位
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			// //获取下一题
			log.error("获取下一题的信息：{}", ivrTaskTemplateScriptVO);
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("1") \|\| ivrTaskTemplateScriptVO.getBranchFlag().equals("0") && ivrTaskTemplateScriptVO.getNextScriptno() != null && ivrTaskTemplateScriptVO.getNextScriptno() != 0) {
			Long nextQuestion = null;
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("1")) {
			nextQuestion = ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getNextQuestion();
			//更新分数
			double score = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			score = BigDecimal.valueOf(score).add(new BigDecimal(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getScore())).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score);
			} else {
			nextQuestion = ivrTaskTemplateScriptVO.getNextScriptno();
			//更新分数
			Object obj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			Double score = (obj == null ? new Double(0.00) : new Double(((Double) obj).doubleValue()));
			score = BigDecimal.valueOf(score).add(new BigDecimal(ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(j).getScore())).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);
			}
			if (nextQuestion == null \|\| nextQuestion == 0L) {
			//如果下一题为空，或者为0，则挂机
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(6L);
			ss.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(ss);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");

			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "noVoice");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask.getJsy());
			//将结果写进detail表
			ServiceSubTaskDetailReq ssdReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList2 = new ArrayList<>();
			serviceSubtaskDetailList.add(getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate));
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList2);
			ssdReq.setGuid(phoneCallReqYQVO.getGuid());
			ssdReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(ssdReq);
			return phoneCallBackYQVO;
			}

			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (script.getSort() == nextQuestion.intValue()) {
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = StringUtils.isNotEmpty(script.getIvrtext()) ? script.getIvrtext() : script.getScriptContent();
			log.error("下一题问题：{}", scriptContent);
			log.error("下一题的子任务是：{}", serviceSubtask);
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + getObject(serviceSubtask, scriptContent));
			//将该患者的Redis中的题目ID，进行修改
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid().trim() + "-" + phoneCallReqYQVO.getPhone().trim(), script.getId().toString(), 120, TimeUnit.MINUTES);
			//删除无响应
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			}
			}
			} else if (ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getNextScriptno() == 0) {
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			//更新一下分数
			double score = 0.0;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (double) scoreObj;
			serviceSubtask.setScore(String.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			//设置结束语
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask1.getJsy());
			Long id = serviceSubtask.getId();
			Map<String, String> map = delRedisValue(null, id.toString());
			log.error("map的值为：{}", map);
			if (ObjectUtils.isNotEmpty(map))
			redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			// return phoneCallBackYQVO;

			}
			} else {
			log.info("没有匹配上----------------------------");
			//flag=0,说明没匹配上，也要把患者说的话记录下来
			if (j == ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().size() - 1 && flag == 0) {
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ServiceSubtaskDetail serviceSubtaskDetail = getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate);
			//修改一下语音路径（改成前端可以访问的，存到数据库中）
			if (StringUtils.isNotEmpty(serviceSubtaskDetail.getQuestionvoice())) {
			String questionvoice = serviceSubtaskDetail.getQuestionvoice();
			String[] split = questionvoice.split("\\\\");
			if (split.length > 0) {
			String lastPart = split[split.length - 1];
			serviceSubtaskDetail.setQuestionvoice(voicePathPrefix + lastPart);
			}
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			//如果没有匹配上，这个必须为null
			serviceSubtaskDetailList.get(0).setMatchedtext("");
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			serviceSubTaskDetailReq.setGuid(phoneCallReqYQVO.getGuid());
			serviceSubTaskDetailReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			}
			continue;
			}
			continue;
			}
			}
			}
			//都没有匹配到
			if (StringUtils.isEmpty(phoneCallBackYQVO.getValue())) {
			log.info("都没有匹配到-------------------------");
			@@ -2097,7 +2353,7 @@
			Double score = null;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (Double) scoreObj;
			serviceSubtask.setScore(BigDecimal.valueOf(score));
			serviceSubtask.setScore(String.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			@@ -2131,7 +2387,7 @@
			Double score = null;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (Double) scoreObj;
			score = BigDecimal.valueOf(score).add(script.getScore()).doubleValue();
			score = BigDecimal.valueOf(score).add(new BigDecimal(script.getScore())).doubleValue();

			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);
			}
			@@ -2186,7 +2442,7 @@
			Double score = null;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (Double) scoreObj;
			score = BigDecimal.valueOf(score).add(ivrTaskTemplateScriptVO.getScore()).doubleValue();
			score = BigDecimal.valueOf(score).add(new BigDecimal(ivrTaskTemplateScriptVO.getScore())).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);

			}
			@@ -2202,7 +2458,7 @@
			Double score = null;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (Double) scoreObj;
			serviceSubtask.setScore(BigDecimal.valueOf(score));
			serviceSubtask.setScore(String.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtask.setSendstate(6L);
			@@ -2224,7 +2480,6 @@
			return phoneCallBackYQVO;
			}


			private String getObject(ServiceSubtask serviceSubtask, String scriptContent) {
			Map<String, Map<String, String>> param = getParam(serviceSubtask.getTaskid());
			for (Map<String, String> map : param.values()) {
			@@ -2241,7 +2496,6 @@

			return scriptContent;
			}


			/**
			* 获取任务里的通配符
			@@ -2291,7 +2545,6 @@
			}
			return map;
			}


			/**
			* 雨绮任务拉取
			@@ -2361,7 +2614,6 @@
			log.info("-----------实际拉取的电话数据量：{}", CollectionUtils.isNotEmpty(pullTaskVOList) ? pullTaskVOList.size() : null);
			return pullTaskVOList;
			}


			private List<PullTaskVO> getPullTaskList(List<String> subIds, String cacheName) {
			log.error("任务拉取subIds的值是多少：{}", subIds);
			@@ -2434,7 +2686,6 @@

			return pullTaskVOList;
			}


			@Override
			public Integer saveQuestionAnswerPhone(ServiceSubTaskDetailReq serviceSubTaskDetailReq) {
			@@ -2694,12 +2945,12 @@
			* @return
			*/
			@Override
			@Cacheable(value = "sfStatistics", key = "T(org.springframework.util.DigestUtils).md5DigestAsHex(#serviceSubtaskCountReq.toString().getBytes())", unless = "#result == null or #result.isEmpty()")
			// @Cacheable(value = "sfStatistics", key = "T(org.springframework.util.DigestUtils).md5DigestAsHex(#serviceSubtaskCountReq.toString().getBytes())", unless = "#result == null or #result.isEmpty()")
			public List<ServiceSubtaskStatistic> getSfStatistics(ServiceSubtaskCountReq serviceSubtaskCountReq) {
			log.info("getSfStatistics的入参为：{}", serviceSubtaskCountReq);
			String drcode = "drcode";
			//缙云人民根据经管医生分组
			if(serviceSubtaskCountReq.getOrgid().equals("47246116333112211A1001")){
			if (serviceSubtaskCountReq.getOrgid().equals("47246116333112211A1001")) {
			drcode = "management_doctor_code";
			}
			String groupKey = drcode;
			@@ -2728,6 +2979,10 @@
			collect = rawData.stream().collect(Collectors.groupingBy(subtask -> Optional.ofNullable(subtask.getDrcode()).orElse("Unknown")));
			break;
			case "management_doctor_code":
			rawData = rawData.stream().peek(item -> {
			item.setDrname(item.getManagementDoctor());
			item.setDrcode(item.getManagementDoctorCode());
			}).collect(Collectors.toList());
			collect = rawData.stream().collect(Collectors.groupingBy(subtask -> Optional.ofNullable(subtask.getManagementDoctorCode()).orElse("Unknown")));
			break;
			case "deptcode":
			@@ -2812,6 +3067,8 @@
			ssRate.setOrgid(serviceSubtaskCountReq.getOrgid());
			ssRate.setStarttime(serviceSubtaskCountReq.getStartTime());
			ssRate.setEndtime(serviceSubtaskCountReq.getEndTime());
			ssRate.setStartOutHospTime(serviceSubtaskCountReq.getHospitalStartTime());
			ssRate.setEndOutHospTime(serviceSubtaskCountReq.getHospitalEndTime());
			ssRate.setVisitCount(serviceSubtaskCountReq.getVisitCount());
			ssRate.setServiceTypeList(serviceSubtaskCountReq.getServiceType());
			if (serviceSubtaskCountReq.getEndTime() != null && new Date().before(serviceSubtaskCountReq.getEndTime())) {
			@@ -2826,7 +3083,6 @@
			}
			return jsRates;
			}


			public List<ServiceSubtaskStatistic> getSfStatisticsExport(ServiceSubtaskCountReq serviceSubtaskCountReq) {
			List<ServiceSubtaskStatistic> sfStatistics = getSfStatistics(serviceSubtaskCountReq);
			@@ -2903,6 +3159,8 @@
			if (serviceSubtaskCountReq.getEndTime() != null && new Date().before(serviceSubtaskCountReq.getEndTime())) {
			ss.setEndtime(new Date());
			}
			ss.setStartOutHospTime(serviceSubtaskCountReq.getHospitalStartTime());
			ss.setEndOutHospTime(serviceSubtaskCountReq.getHospitalEndTime());
			Double jsRate = serviceSubtaskMapper.selectTimelyRate(ss);
			statistic.setRate(jsRate);
			if (ObjectUtils.isNotEmpty(statistic)) {
			@@ -2912,13 +3170,15 @@
			if (CollectionUtils.isNotEmpty(serviceSubtaskStatistics)) {
			for (ServiceSubtaskStatistic serviceSubtaskStatistic : serviceSubtaskStatistics) {
			//所有满意度数量
			//满意度模块化后：满意度指数据此改为调用满意度模块门面；
			//模块关闭时门面返回全零 Map（与被迁移实现的实际输出一致），不影响随访统计其它字段。
			if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getDeptcodes())) {
			Map<String, Object> satisfactionIndex = getSatisfactionIndex("1", serviceSubtaskStatistic.getDeptcode(), orgid, serviceSubtaskCountReq.getIvrCategoryid(), serviceSubtaskCountReq.getSvyCategoryid());
			Map<String, Object> satisfactionIndex = satisfactionFacade.getSatisfactionIndex("1", serviceSubtaskStatistic.getDeptcode(), orgid, serviceSubtaskCountReq.getIvrCategoryid(), serviceSubtaskCountReq.getSvyCategoryid());
			serviceSubtaskStatistic.setJoyAllCount(satisfactionIndex.get("mydtmzl") != null ? (Integer) satisfactionIndex.get("mydtmzl") : 0);
			serviceSubtaskStatistic.setJoyCount(satisfactionIndex.get("mydtbl") != null ? (Integer) satisfactionIndex.get("mydtbl") : 0);
			serviceSubtaskStatistic.setJoyTotal((Double) satisfactionIndex.get("wcbl"));
			} else if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getLeavehospitaldistrictcodes())) {
			Map<String, Object> satisfactionIndex = getSatisfactionIndex("2", serviceSubtaskStatistic.getLeavehospitaldistrictcode(), orgid, serviceSubtaskCountReq.getIvrCategoryid(), serviceSubtaskCountReq.getSvyCategoryid());
			Map<String, Object> satisfactionIndex = satisfactionFacade.getSatisfactionIndex("2", serviceSubtaskStatistic.getLeavehospitaldistrictcode(), orgid, serviceSubtaskCountReq.getIvrCategoryid(), serviceSubtaskCountReq.getSvyCategoryid());
			serviceSubtaskStatistic.setJoyAllCount(satisfactionIndex.get("mydtmzl") != null ? (Integer) satisfactionIndex.get("mydtmzl") : 0);
			serviceSubtaskStatistic.setJoyCount(satisfactionIndex.get("mydtbl") != null ? (Integer) satisfactionIndex.get("mydtbl") : 0);
			serviceSubtaskStatistic.setJoyTotal((Double) satisfactionIndex.get("wcbl"));
			@@ -2928,103 +3188,6 @@

			return serviceSubtaskStatistics;
			}


			/**
			* 获取满意度题目总量
			* type : 1-科室 2病区
			* code: 科室或病区code
			*
			* @return
			*/
			private Map<String, Object> getSatisfactionIndex(String type, String code, String orgid, Long ivrCategoryid, Long svyCategoryid) {
			Map<String, Object> map = new HashMap<>();
			List<ServiceTask> serviceTasks = null;
			if (type.equals("1")) {
			ServiceTask serviceTask = new ServiceTask();
			serviceTask.setDeptcode(code);
			serviceTask.setOrgid(orgid);
			serviceTasks = serviceTaskService.selectServiceTaskList(serviceTask);
			} else if (type.equals("2")) {
			ServiceTask serviceTask = new ServiceTask();
			serviceTask.setLeavehospitaldistrictcode(code);
			serviceTask.setOrgid(orgid);
			serviceTasks = serviceTaskService.selectServiceTaskList(serviceTask);
			}

			//获取满意度题目总量
			BigDecimal mydtmzlsum = new BigDecimal(0);
			//获取满意度题目填报量
			BigDecimal mydtblsum = new BigDecimal(0);
			if (CollectionUtils.isNotEmpty(serviceTasks)) {
			//获取满意度题目总量
			for (ServiceTask serviceTask : serviceTasks) {
			if (serviceTask.getType().equals("1")) {
			//语音
			Long templateid = serviceTask.getTemplateid();
			IvrTaskTemplateScript ivrTaskTemplateScript = new IvrTaskTemplateScript();
			ivrTaskTemplateScript.setTemplateID(templateid);
			ivrTaskTemplateScript.setOrgid(serviceTask.getOrgid());
			//先默认为1吧，assortid=1 代表是满意度
			ivrTaskTemplateScript.setScriptAssortid(ivrCategoryid);
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript);
			if (CollectionUtils.isNotEmpty(ivrTaskTemplateScripts)) {
			//需要先计算出发送量，再乘以单个问券满意度题目数量，得到满意度题目总量（包含了未做的）
			ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity();
			serviceSubtaskVO.setTaskid(serviceTask.getTaskid());
			List<Long> sendstates = new ArrayList<>(Arrays.asList(3L, 5L, 6L));
			serviceSubtaskVO.setSendstates(sendstates);
			List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskBySendstate(serviceSubtaskVO);
			if (CollectionUtils.isNotEmpty(serviceSubtaskList)) {
			int mydtmzlCount = ivrTaskTemplateScripts.size() * serviceSubtaskList.size();
			mydtmzlsum.add(new BigDecimal(mydtmzlCount));
			}

			}
			} else if (serviceTask.getType().equals("2")) {
			//问卷
			SvyTaskTemplateScript svyTaskTemplateScript = new SvyTaskTemplateScript();
			svyTaskTemplateScript.setTemplateID(serviceTask.getTemplateid());
			svyTaskTemplateScript.setOrgid(serviceTask.getOrgid());
			svyTaskTemplateScript.setCategoryid(svyCategoryid);
			List<SvyTaskTemplateScript> svyTaskTemplateScriptList = svyTaskTemplateScriptService.selectSvyTaskTemplateScriptList(svyTaskTemplateScript);
			if (CollectionUtils.isNotEmpty(svyTaskTemplateScriptList)) {
			ServiceSubtaskEntity serviceSubtaskEntity = new ServiceSubtaskEntity();
			serviceSubtaskEntity.setTaskid(serviceTask.getTaskid());
			List<Long> sendstates = new ArrayList<>(Arrays.asList(3L, 5L, 6L));
			serviceSubtaskEntity.setSendstates(sendstates);
			List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskBySendstate(serviceSubtaskEntity);
			if (CollectionUtils.isNotEmpty(serviceSubtaskList)) {
			int mydtmzlCount = svyTaskTemplateScriptList.size() * serviceSubtaskList.size();
			mydtmzlsum.add(new BigDecimal(mydtmzlCount));
			}
			}
			}

			//获取满意度题目填报量
			ServiceSubtaskDetail serviceSubtaskDetail = new ServiceSubtaskDetail();
			serviceSubtaskDetail.setTaskid(serviceTask.getTaskid());
			if (serviceTask.getType().equals("1")) serviceSubtaskDetail.setCategoryid(ivrCategoryid);
			if (serviceTask.getType().equals("2")) serviceSubtaskDetail.setCategoryid(svyCategoryid);
			serviceSubtaskDetail.setOrgid(serviceTask.getOrgid());
			List<ServiceSubtaskDetail> serviceSubtaskDetails = serviceSubtaskDetailMapper.selectServiceSubtaskDetailList(serviceSubtaskDetail);
			if (CollectionUtils.isNotEmpty(serviceSubtaskDetails))
			mydtblsum.add(new BigDecimal(serviceSubtaskDetails.size()));
			}


			}
			//满意度题目总量
			map.put("mydtmzl", mydtmzlsum.intValue());
			map.put("mydtbl", mydtblsum.intValue());
			map.put("wcbl", 0.0);
			if (mydtmzlsum.intValue() != 0) {
			map.put("wcbl", mydtblsum.divide(mydtmzlsum, 2, RoundingMode.HALF_UP).doubleValue());
			}

			return map;
			}


			private ServiceSubtaskStatistic getStatistic(List<ServiceSubtask> serviceSubtaskList, String followUpCountStyle, Integer visitCount) {
			ServiceSubtaskStatistic serviceSubtaskStatistic = new ServiceSubtaskStatistic();
			@@ -3150,6 +3313,24 @@
			serviceSubtaskStatistic.setWeChat(serviceSubtaskStatistic.getWeChat() + 1L);
			}
			}

			//首次随访人工成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("1")) {
			serviceSubtaskStatistic.setManualSuccess(serviceSubtaskStatistic.getManualSuccess() + 1L);
			}
			//首次随访语音成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("3")) {
			serviceSubtaskStatistic.setVoiceSuccess(serviceSubtaskStatistic.getVoiceSuccess() + 1L);
			}
			//首次随访短信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("4")) {
			serviceSubtaskStatistic.setSmsSuccess(serviceSubtaskStatistic.getSmsSuccess() + 1L);
			}
			//首次随访微信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("5")) {
			serviceSubtaskStatistic.setWeChatSuccess(serviceSubtaskStatistic.getWeChatSuccess() + 1L);
			}

			if (serviceSubtaskStatistic.getNeedFollowUp() > 0) {
			double rate = (double) (serviceSubtaskStatistic.getFollowUpSuccess() + serviceSubtaskStatistic.getFollowUpFail()) / serviceSubtaskStatistic.getNeedFollowUp();
			serviceSubtaskStatistic.setFollowUpRate(percentFormat.format(rate));
			@@ -3245,6 +3426,24 @@
			serviceSubtaskStatistic.setWeChatAgain(serviceSubtaskStatistic.getWeChatAgain() + 1L);
			}
			}

			//再次随访人工成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("1")) {
			serviceSubtaskStatistic.setManualAgainSuccess(serviceSubtaskStatistic.getManualAgainSuccess() + 1L);
			}
			//再次随访语音成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("3")) {
			serviceSubtaskStatistic.setVoiceAgainSuccess(serviceSubtaskStatistic.getVoiceAgainSuccess() + 1L);
			}
			//再次随访短信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("4")) {
			serviceSubtaskStatistic.setSmsAgainSuccess(serviceSubtaskStatistic.getSmsAgainSuccess() + 1L);
			}
			//再次随访微信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("5")) {
			serviceSubtaskStatistic.setWeChatAgainSuccess(serviceSubtaskStatistic.getWeChatAgainSuccess() + 1L);
			}

			if (serviceSubtaskStatistic.getNeedFollowUp() > 0) {
			double rate = (double) (serviceSubtaskStatistic.getFollowUpSuccessAgain() + serviceSubtaskStatistic.getFollowUpFailAgain()) / serviceSubtaskStatistic.getNeedFollowUpAgain();
			serviceSubtaskStatistic.setFollowUpRateAgain(percentFormat.format(rate));
			@@ -3399,6 +3598,24 @@
			serviceSubtaskStatistic.setWeChat(serviceSubtaskStatistic.getWeChat() + 1L);
			}
			}

			//首次随访人工成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("1")) {
			serviceSubtaskStatistic.setManualSuccess(serviceSubtaskStatistic.getManualSuccess() + 1L);
			}
			//首次随访语音成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("3")) {
			serviceSubtaskStatistic.setVoiceSuccess(serviceSubtaskStatistic.getVoiceSuccess() + 1L);
			}
			//首次随访短信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("4")) {
			serviceSubtaskStatistic.setSmsSuccess(serviceSubtaskStatistic.getSmsSuccess() + 1L);
			}
			//首次随访微信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("5")) {
			serviceSubtaskStatistic.setWeChatSuccess(serviceSubtaskStatistic.getWeChatSuccess() + 1L);
			}

			if (serviceSubtaskStatistic.getNeedFollowUp() > 0) {
			double rate = (double) (serviceSubtaskStatistic.getFollowUpSuccess() + serviceSubtaskStatistic.getFollowUpFail()) / serviceSubtaskStatistic.getNeedFollowUp();
			serviceSubtaskStatistic.setFollowUpRate(percentFormat.format(rate));
			@@ -3550,6 +3767,24 @@
			serviceSubtaskStatistic.setWeChatAgain(serviceSubtaskStatistic.getWeChatAgain() + 1L);
			}
			}

			//再次随访人工成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("1")) {
			serviceSubtaskStatistic.setManualAgainSuccess(serviceSubtaskStatistic.getManualAgainSuccess() + 1L);
			}
			//再次随访语音成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("3")) {
			serviceSubtaskStatistic.setVoiceAgainSuccess(serviceSubtaskStatistic.getVoiceAgainSuccess() + 1L);
			}
			//再次随访短信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("4")) {
			serviceSubtaskStatistic.setSmsAgainSuccess(serviceSubtaskStatistic.getSmsAgainSuccess() + 1L);
			}
			//再次随访微信成功
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate().equals(6L) && ObjectUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) && serviceSubtask.getCurrentPreachform().equals("5")) {
			serviceSubtaskStatistic.setWeChatAgainSuccess(serviceSubtaskStatistic.getWeChatAgainSuccess() + 1L);
			}

			if (serviceSubtaskStatistic.getNeedFollowUp() > 0) {
			double rate = (double) (serviceSubtaskStatistic.getFollowUpSuccessAgain() + serviceSubtaskStatistic.getFollowUpFailAgain()) / serviceSubtaskStatistic.getNeedFollowUpAgain();
			serviceSubtaskStatistic.setFollowUpRateAgain(percentFormat.format(rate));
			@@ -3583,7 +3818,6 @@
			}
			return serviceSubtaskStatistic;
			}


			private ServiceSubtaskStatistic getStatisticJoy(List<ServiceSubtask> serviceSubtaskList, List<ServiceSubtaskCount> joySubCount) {
			ServiceSubtaskStatistic serviceSubtaskStatistic = new ServiceSubtaskStatistic();
			@@ -3707,7 +3941,6 @@
			if (subCounts == null) {
			subCounts = new ArrayList<>();
			}


			for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
			List<ServiceSubtaskCount> subCountTemp = subCounts.stream().filter(r -> r.getSubTaskId().equals(serviceSubtask.getId())).collect(Collectors.toList());
			@@ -3887,16 +4120,17 @@
			iServiceOutPathService.insertServiceOutPath(serviceOutPath);
			//转成16进制
			String format = String.format("%03X", serviceOutPath.getId());
			String url = "";
			SendMagParam sendMagParam = new SendMagParam();
			url = localIP + ":" + req_path + "/sf?p=" + format;
			sendMagParam.setUrl(url);
			sendMagParam.setContent("【新华医院】您好，邀请您填写出院随访调查表，请点击" + sendMagParam.getUrl() + "填写。感谢您配合！");
			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			serviceOutPath.setUrl(url);
			iServiceOutPathService.updateServiceOutPath(serviceOutPath);
			SendMagParam sendMagParam = new SendMagParam();
			sendMagParam.setUrl(localIP + ":" + req_path + "/sf?p=" + format);
			sendMagParam.setContent("【新华医院】您好，邀请您填写出院随访调查表，请点击" + sendMagParam.getUrl() + "填写。感谢您配合！");
			Map<String, String> map = new HashMap<>();
			map.put("phone", serviceSubtask.getPhone());
			map.put("content", sendMagParam.getContent());
			HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(map));
			//短信发送已收口到 ruoyi-message 模块；与原实现一致：不判断发送结果
			smsSenderFactory.send(active, SmsSendRequest.of(serviceSubtask.getPhone(), sendMagParam.getContent(), serviceSubtask.getOrgid()));
			redisCache.setCacheObject(subTaskId + "recordAccept-hungup", "1", 10, TimeUnit.MINUTES);
			if (StringUtils.isNotEmpty(serviceSubtask.getRemark()))
			serviceSubtask.setRemark("电话发送拒接,短信补偿发送成功");
			@@ -3977,6 +4211,10 @@
			* voiceInfo - visitCount = 1 && currentPreachForm = "3"
			* smsInfo - visitCount = 1 && currentPreachForm = "4"
			* wechatInfo - visitCount = 1 && currentPreachForm = "5"
			* manualSuccessInfo - visitCount = 1 && currentPreachForm = "1" && sendstate = 6
			* voiceSuccessInfo - visitCount = 1 && currentPreachForm = "3" && sendstate = 6
			* smsSuccessInfo - visitCount = 1 && currentPreachForm = "4" && sendstate = 6
			* wechatSuccessInfo - visitCount = 1 && currentPreachForm = "5" && sendstate = 6
			* abnormalInfo - visitCount = 1 && excep = "1"
			* needFollowUpAgainInfo - visitCount > 1 && sendstate != 4
			* pendingFollowUpAgainInfo - visitCount > 1 && sendstate = 2
			@@ -3986,6 +4224,10 @@
			* voiceAgainInfo - visitCount > 1 && currentPreachForm = "3"
			* smsAgainInfo - visitCount > 1 && currentPreachForm = "4"
			* wechatAgainInfo - visitCount > 1 && currentPreachForm = "5"
			* manualAgainSuccessInfo - visitCount > 1 && currentPreachForm = "1" && sendstate = 6
			* voiceAgainSuccessInfo - visitCount > 1 && currentPreachForm = "3" && sendstate = 6
			* smsAgainSuccessInfo - visitCount > 1 && currentPreachForm = "4" && sendstate = 6
			* wechatAgainSuccessInfo - visitCount > 1&& currentPreachForm = "5" && sendstate = 6
			* abnormalAgainInfo- visitCount = 1 && excep = "1"
			* taskSituation1Info - taskSituation = 1
			* taskSituation2Info - taskSituation = 2
			@@ -4069,6 +4311,26 @@
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setCurrentPreachform("5");
			break;
			case "manualSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("1");
			break;
			case "voiceSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("3");
			break;
			case "smsSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("4");
			break;
			case "wechatSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("5");
			break;
			case "abnormalInfo":
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setExcep("1");
			@@ -4105,6 +4367,26 @@
			serviceSubtaskCountReq.setVisitCount(2);
			serviceSubtaskCountReq.setCurrentPreachform("5");
			break;
			case "manualAgainSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(1);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("1");
			break;
			case "voiceAgainSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(2);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("3");
			break;
			case "smsAgainSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(2);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("4");
			break;
			case "wechatAgainSuccessInfo":
			serviceSubtaskCountReq.setVisitCount(2);
			serviceSubtaskCountReq.setSendstates(new ArrayList<>(Collections.singletonList(6L)));
			serviceSubtaskCountReq.setCurrentPreachform("5");
			break;
			case "abnormalAgainInfo":
			serviceSubtaskCountReq.setVisitCount(2);
			serviceSubtaskCountReq.setExcep("1");
			@@ -4135,7 +4417,6 @@
			break;
			}
			}


			/**
			* 获取随访统计比例
			@@ -4358,7 +4639,6 @@
			return result;
			}


			/**
			* @param serviceSubtask
			* @param preachform
			@@ -4390,12 +4670,11 @@
			serviceSubtaskPreachform1.setRemark(remark);
			serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(serviceSubtaskPreachform1);


			//如果当前的preachform已经是最后一个了，那直接将serviceSubtask的sendstate状态改成5就行了(全失败了)
			if (serviceSubtaskPreachform1.getSort() == spSize.size() && failSendstate.equals("4")) {
			serviceSubtask.setCurrentPreachform(preachform);
			serviceSubtask.setSendstate(5L);
			serviceSubtask.setRemark(remark + ";所有发送方式均未获取结果，任务失败");
			serviceSubtask.setRemark(remark + ";所有执行方式均未获取结果，任务失败");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			return true;
			} else {
			@@ -4436,7 +4715,6 @@
			}
			return visitTime;
			}


			/**
			* 计算总计行
			@@ -4768,6 +5046,12 @@
			String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key);
			String taskId = rsaPublicKeyExample.encryptedData(serviceSubtask.getTaskid().toString(), pub_key);

			//丽水中医院发送的是微信公众号
			if (StringUtils.isNotEmpty(serviceSubtask.getOrgid()) && serviceSubtask.getOrgid().equals("47231022633110211A2101")) {
			resultMap = wechatSubTask(subid);
			return resultMap;
			}

			//发送数据的封装
			ServiceOutPath serviceOutPath = new ServiceOutPath();
			serviceOutPath.setParam1(taskId);
			@@ -4778,15 +5062,17 @@
			serviceOutPath.setOrgid(serviceSubtask.getOrgid());
			iServiceOutPathService.insertServiceOutPath(serviceOutPath);
			String format = String.format("%03X", serviceOutPath.getId());
			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			iServiceOutPathService.updateServiceOutPath(serviceOutPath);

			String url = "";
			SendMagParam sendMagParam = new SendMagParam();
			sendMagParam.setType("4");
			sendMagParam.setPhone(serviceSubtask.getPhone());
			sendMagParam.setUrl(StringUtils.isNotEmpty(req_path) ? localIP + ":" + req_path + "/wt?p=" + format : localIP + "/wt?p=" + format);
			url = StringUtils.isNotEmpty(req_path) ? localIP + ":" + req_path + "/wt?p=" + format : localIP + "/wt?p=" + format;
			sendMagParam.setUrl(url);

			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			serviceOutPath.setUrl(url);
			iServiceOutPathService.updateServiceOutPath(serviceOutPath);
			SysConfig sysConfig = new SysConfig();

			sysConfig = sysConfigMapper.checkConfigKeyUnique("wj.sms.template");
			@@ -4796,22 +5082,94 @@
			sendMagParam.setContent(smsContemt.replace("${wjurl}", sendMagParam.getUrl()));
			}

			//短信发送：各站点对接方式差异较大，已收口到 ruoyi-message 模块
			if (active.equals("nhfy")) {
			Map<String, Object> smsResult = mtSubmitSmUtil.submitSm(sendMagParam.getPhone(), sendMagParam.getContent());
			if (smsResult != null && smsResult.get("result") != null && smsResult.get("result").toString().equals("0")) {
			SendResult smsResult = smsSenderFactory.send(active,
			SmsSendRequest.of(sendMagParam.getPhone(), sendMagParam.getContent(), serviceSubtask.getOrgid()));
			if (smsResult.isOk()) {
			resultMap.put("code", "200");
			resultMap.put("msg", "发送成功");
			serviceSubtask.setRemark(StringUtils.isNotEmpty(serviceSubtask.getRemark()) ? serviceSubtask.getRemark() + ";短信发送成功" : "短信发送成功");
			serviceSubtask.setRemark(StringUtils.isNotEmpty(serviceSubtask.getRemark()) ? serviceSubtask.getRemark() + ";短信发送成功(手动提交)" : "短信发送成功(手动提交)");
			log.info("是否发送成功：{}", serviceSubtask.getRemark());
			updateServiceSubtask(serviceSubtask);
			serviceSubtask.setSendstate(3L);
			serviceSubtask.setCurrentPreachform("4");
			}
			}
			return resultMap;
			}

			@Override
			public List<ServiceSubtaskDetailRatioExport> statQuestionOption(List<Long> taskIds, Date startOutHospTime, Date endOutHospTime) {
			return serviceSubtaskMapper.statQuestionOption(taskIds, startOutHospTime, endOutHospTime);
			public Map<String,Object> wechatSubTask(Long subid){
			log.info("wechatSubTask的入参为：{}", subid);
			Map<String, Object> resultMap = new HashMap<>();
			resultMap.put("code", "500");
			resultMap.put("msg", "发送失败");
			try{
			//获取随访的基本信息
			ServiceSubtask serviceSubtask = selectServiceSubtaskById(subid);
			//获取患者信息
			PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(serviceSubtask.getPatid());

			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);
			String subId = rsaPublicKeyExample.encryptedData(serviceSubtask.getId().toString(), pub_key);
			String taskId = rsaPublicKeyExample.encryptedData(serviceSubtask.getTaskid().toString(), pub_key);
			String url = localIP + ":" + req_path + "/outsideChainwt?param1=" + taskId + "&param2=" + patid + "&param3="
			+ URLEncoder.encode(serviceSubtask.getTaskName(), StandardCharsets.UTF_8.toString()) + "&param5=false"
			+ "$param6=" + subId;

			ServiceOutPath serviceOutPath = new ServiceOutPath();
			serviceOutPath.setParam1(taskId);
			serviceOutPath.setParam2(patid);
			serviceOutPath.setParam3(serviceSubtask.getTaskName());
			serviceOutPath.setParam6(subId);
			serviceOutPath.setCreateTime(new Date());
			serviceOutPath.setOrgid(serviceSubtask.getOrgid());
			iServiceOutPathService.insertServiceOutPath(serviceOutPath);
			String format = String.format("%03X", serviceOutPath.getId());
			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			serviceOutPath.setUrl(url);
			iServiceOutPathService.updateServiceOutPath(serviceOutPath);

			//his患者id校验（与原实现一致：先校验这一项）
			if (StringUtils.isEmpty(serviceSubtask.getPatidHis())) {
			resultMap.put("code", -1);
			resultMap.put("message", "发送异常：" + "【公众号】公众号发送失败,his系统的患者id为空");
			return resultMap;
			}

			//机构配置校验、报文签名与返回判定均已收口到 ruoyi-message 的发送方实现
			WechatSendRequest wechatRequest = new WechatSendRequest();
			wechatRequest.setOrgid(serviceSubtask.getOrgid());
			wechatRequest.setIdCard(serviceSubtask.getSfzh());
			wechatRequest.setUrl(url);
			wechatRequest.setTitle(serviceSubtask.getTaskName());
			wechatRequest.setContent(serviceSubtask.getTaskDesc());
			wechatRequest.setPhone(patArchive.getTelcode());
			wechatRequest.setPatientName(serviceSubtask.getSendname());
			wechatRequest.setPatidHis(patArchive.getPatidHis());
			SendResult wechatResult = wechatSenderFactory.send(active, wechatRequest);

			//发送完成后，修改状态
			serviceSubtask.setSendstate(3L);
			if (wechatResult.isOk()) {
			serviceSubtask.setResult("success");
			resultMap.put("code", "200");
			resultMap.put("msg", "发送成功");
			} else {
			log.error("【sfHandlle】公众号发送失败，患者信息：{}，错误信息：{}", serviceSubtask, wechatResult.getMessage());
			resultMap.put("code", -1);
			resultMap.put("message", "【公众号】公众号发送失败");
			return resultMap;
			}
			} catch (Exception e) {
			String guid = UUID.randomUUID().toString();
			log.error("【sfHandlle】长期任务公众号发送失败，原因：{}，GUID：{}", e.getMessage(), guid);
			resultMap.put("code", -1);
			resultMap.put("message", "【公众号】长期任务公众号发送失败，原因：" + e.getMessage());
			return resultMap;
			}
			return resultMap;
			}

			private Boolean saveServiceSubtaskDetail(ServiceSubtask serviceSubtask) {
			@@ -5002,7 +5360,7 @@
			String format = String.format("%03X", serviceOutPath.getId());
			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			String url = ip + ":" + req_path + "/wt?p=" + format;
			String url = StringUtils.isNotEmpty(req_path) ? ip + ":" + req_path + "/wt?p=" + format : ip + "/wt?p=" + format;
			content = url;
			serviceOutPath.setUrl(url);
			iServiceOutPathService.updateServiceOutPath(serviceOutPath);
			@@ -5026,10 +5384,10 @@
			// serviceSubtask.setNurseName(patMedInhosp1.getNurseName());
			// serviceSubtask.setDrcode(patMedInhosp1.getDrcode());
			// serviceSubtask.setDrname(patMedInhosp1.getDrname());
			if(StringUtils.isNotEmpty(serviceTaskdept.getDeptType()) && serviceTaskdept.getDeptType().equals("1")){
			if (StringUtils.isNotEmpty(serviceTaskdept.getDeptType()) && serviceTaskdept.getDeptType().equals("1")) {
			serviceSubtask.setDeptcode(serviceTaskdept.getDeptCode());
			serviceSubtask.setDeptname(serviceTaskdept.getDeptName());
			}else {
			} else {
			serviceSubtask.setLeavehospitaldistrictcode(serviceTaskdept.getDeptCode());
			serviceSubtask.setLeavehospitaldistrictname(serviceTaskdept.getDeptName());
			}
			@@ -5059,27 +5417,61 @@
			Date newDate = new Date();
			serviceSubtask.setLongSendTime(newDate);
			serviceSubtask.setVisitTime(newDate);
			// 院区：/scanGenerateSubtask 是匿名接口（SecurityConfig permitAll），取不到登录用户；
			// 而 service_task.campusid 在本库是占位值 '1'，直接沿用会让统计接口（@AddOrgId 按院区过滤）查不到数据。
			// 这里用任务配置的病区（其次科室）反查 sys_dept.campusid 落库，保证问卷统计能按院区取到。
			String campusIdByDept = queryCampusIdByDeptCode(serviceSubtask.getLeavehospitaldistrictcode(), serviceTask.getOrgid());
			if (StringUtils.isEmpty(campusIdByDept)) {
			campusIdByDept = queryCampusIdByDeptCode(serviceSubtask.getDeptcode(), serviceTask.getOrgid());
			}
			if (StringUtils.isNotEmpty(campusIdByDept)) {
			serviceSubtask.setCampusid(campusIdByDept);
			}
			// 只配了科室（没有病区）的满意度任务：这道答卷在按病区筛选的报表里统计不到，留日志便于运维发现
			if (StringUtils.isEmpty(serviceSubtask.getLeavehospitaldistrictcode())
			&& ("6".equals(serviceSubtask.getServiceType()) \|\| "14".equals(serviceSubtask.getServiceType()))) {
			log.warn("【扫码生成任务】满意度子任务没有病区，按病区筛选的报表将统计不到该答卷：taskid={}, deptcode={}, campusid={}",
			serviceSubtask.getTaskid(), serviceSubtask.getDeptcode(), serviceSubtask.getCampusid());
			}
			return serviceSubtask;
			}

			/**
			* 按科室/病区编码反查所属院区（查不到返回 null）
			*/
			private String queryCampusIdByDeptCode(String deptCode, String orgid) {
			if (StringUtils.isEmpty(deptCode)) {
			return null;
			}
			try {
			SysDept sysDept = sysDept2Mapper.selectDeptByCode(deptCode, orgid);
			return sysDept == null ? null : sysDept.getCampusid();
			} catch (Exception e) {
			log.warn("按编码反查院区失败：deptCode={}, orgid={}, err={}", deptCode, orgid, e.getMessage());
			return null;
			}
			}

			/**
			* Ai 匹配选项
			*
			* @param questionText
			* @param voiceText
			* @param options
			* @return
			*/
			public Integer matchOptionIndex(String url, String questionText, String voiceText, List<IvrTaskTemplateTargetoption> options, String uuid){
			@Override
			public Integer matchOptionIndex(String url, String questionText, String voiceText, List<IvrTaskTemplateTargetoption> options, String uuid) {
			JSONObject jsonObject = new JSONObject();
			jsonObject.put("userQuestion",questionText);
			jsonObject.put("userAnswer",voiceText);
			jsonObject.put("userQuestion", questionText);
			jsonObject.put("userAnswer", voiceText);
			jsonObject.put("options", options);
			jsonObject.put("uuid", uuid);
			String jsonString = jsonObject.toJSONString();
			String result = null;

			// String url = "http://localhost:8099/matchOptionIndex";
			if(StringUtils.isNotEmpty(url)){
			if (StringUtils.isNotEmpty(url)) {
			try {
			Map<String, String> headers = new HashMap<>();
			headers.put("Content-Type", "application/json");
			@@ -5089,24 +5481,177 @@
			log.error("AI识别失败", e);
			}
			}
			if(StringUtils.isNotEmpty(result) && result.matches("^-?\\d+$")){
			if (StringUtils.isNotEmpty(result) && result.matches("^-?\\d+$")) {
			return Integer.parseInt(result);
			}else {
			} else {
			return -1;
			}
			}

			public PhoneCallBackYQVO AiMatch(String url, PhoneCallReqYQVO phoneCallReqYQVO, PhoneCallBackYQVO phoneCallBackYQVO,
			IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO, ServiceSubtask serviceSubtask, IvrTaskTemplate ivrTaskTemplate,
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts, String scriptId, Integer flag, String uuid){
			public PhoneCallBackSHVO getFirstQues(PhoneCallReqYQVO phoneCallReqYQVO) {
			//用于返回
			PhoneCallBackSHVO phoneCallBackSHVO = new PhoneCallBackSHVO();

			//根据手机号获取用户的的子任务信息
			ServiceSubtaskEntity serviceSubtaskVO = new ServiceSubtaskEntity();
			serviceSubtaskVO.setPhone(phoneCallReqYQVO.getPhone());
			serviceSubtaskVO.setType("1");
			serviceSubtaskVO.setSendstate(2L);
			List<ServiceSubtask> serviceSubtasks = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO);
			if (CollectionUtils.isNotEmpty(serviceSubtasks)) {
			ServiceSubtask serviceSubtask = serviceSubtasks.get(0);
			IvrTaskTemplate ivrTaskTemplate = ivrTaskTemplateService.selectIvrTaskTemplateByID(serviceSubtask.getTemplateid());

			//通过任务模板中的"第一次问题编号"获取第一个问题;
			IvrTaskTemplateScript ivrTaskTemplateScript = null;
			IvrTaskTemplateScript ivrTaskTemplateScript1 = new IvrTaskTemplateScript();
			ivrTaskTemplateScript1.setTemplateID(ivrTaskTemplate.getId());
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript1);

			for (IvrTaskTemplateScript ivrTaskTemplateScript2 : ivrTaskTemplateScripts) {
			if (ivrTaskTemplate.getFirstQuestionNum() == Long.valueOf(ivrTaskTemplateScript2.getSort())) {
			ivrTaskTemplateScript = ivrTaskTemplateScript2;
			break;
			}
			}
			//获取开场白
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());

			phoneCallBackSHVO.setSubId(serviceSubtask.getId());
			phoneCallBackSHVO.setScriptId(ivrTaskTemplateScript.getId());
			phoneCallBackSHVO.setSort(ivrTaskTemplateScript.getSort());
			phoneCallBackSHVO.setTaskTemplateid(ivrTaskTemplateScript.getTemplateID());
			phoneCallBackSHVO.setScriptContent(serviceTask.getKcb() + "," + ivrTaskTemplateScript.getScriptContent());
			}
			return phoneCallBackSHVO;
			}

			/**
			* 三汇ASR结果处理
			*
			* @param phoneCallResultYQVO
			* @return
			*/
			public PhoneCallBackSHVO processResust(PhoneCallResultYQVO phoneCallResultYQVO) {
			PhoneCallBackSHVO phoneCallBackSHVO = new PhoneCallBackSHVO();
			//通过scriptid，获取所有的结果
			String url = configService.selectConfigByKey("sys.voice.match.ai.url", phoneCallResultYQVO.getOrgid());
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(phoneCallResultYQVO.getSubId());
			IvrTaskTemplate ivrTaskTemplate = ivrTaskTemplateService.selectIvrTaskTemplateByID(serviceSubtask.getTemplateid());
			IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO = iIvrTaskTemplateScriptService.getTaskTempScriptInfoByid(Long.valueOf(phoneCallResultYQVO.getScriptId()));
			Integer i = matchOptionIndex(url, phoneCallResultYQVO.getScriptContent(), phoneCallResultYQVO.getAsrResult(), ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList(), phoneCallResultYQVO.getUuid());
			if (i >= 0) {
			String optiondesc = ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().get(i).getOptiondesc();
			//将患者的回答写进service_subtask_detail中
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ivrTaskTemplateScriptVO.setQuestionResult(optiondesc);

			PhoneCallReqYQVO phoneCallReqYQVO = new PhoneCallReqYQVO();
			phoneCallReqYQVO.setTaskid("" + serviceSubtask.getId());
			phoneCallReqYQVO.setPhone(phoneCallResultYQVO.getPhone());
			phoneCallReqYQVO.setAsrtext(phoneCallResultYQVO.getAsrResult());
			ServiceSubtaskDetail serviceSubtaskDetail = getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate);
			//修改一下语音路径（改成前端可以访问的，存到数据库中）
			if (StringUtils.isNotEmpty(serviceSubtaskDetail.getQuestionvoice())) {
			String questionvoice = serviceSubtaskDetail.getQuestionvoice();
			String[] split = questionvoice.split("\\\\");
			if (split.length > 0) {
			String lastPart = split[split.length - 1];
			serviceSubtaskDetail.setQuestionvoice(voicePathPrefix + lastPart);
			}
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			serviceSubTaskDetailReq.setGuid(phoneCallResultYQVO.getGuid());
			serviceSubTaskDetailReq.setOrgid(phoneCallResultYQVO.getOrgid());
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);

			IvrTaskTemplateScript ivrTaskTemplateScript = new IvrTaskTemplateScript();
			ivrTaskTemplateScript.setTemplateID(ivrTaskTemplateScriptVO.getTemplateID());
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript);

			//获取下一题
			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getNextScriptno() == 0) {
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			phoneCallBackSHVO.setScriptContent(serviceTask.getJsy());
			phoneCallBackSHVO.setTaskTemplateid(script.getTemplateID());
			phoneCallBackSHVO.setSort(script.getSort());
			phoneCallBackSHVO.setScriptId(script.getId());
			phoneCallBackSHVO.setSubId(serviceSubtask.getId());
			phoneCallBackSHVO.setStatus("0");
			} else if (script.getSort() == ivrTaskTemplateScriptVO.getNextScriptno().intValue()) {
			phoneCallBackSHVO.setScriptContent(script.getScriptContent());
			phoneCallBackSHVO.setTaskTemplateid(script.getTemplateID());
			phoneCallBackSHVO.setSort(script.getSort());
			phoneCallBackSHVO.setScriptId(script.getId());
			phoneCallBackSHVO.setSubId(serviceSubtask.getId());
			break;
			}
			}
			//把缓存清除
			redisCache.deleteObject(phoneCallResultYQVO.getSubId() + "-" + phoneCallResultYQVO.getScriptId());
			} else {
			//再将重复询问
			//记录一下这个问题被问题的次数
			Object cacheObject = redisCache.getCacheObject(phoneCallResultYQVO.getSubId() + "-" + phoneCallResultYQVO.getScriptId());
			if (cacheObject == null \|\| (Integer) cacheObject < ivrTaskTemplate.getMateNum()) {

			// 获取选项集合中的 optiondesc 用于引导患者
			List<IvrTaskTemplateTargetoption> optionList = ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList();
			String optionDescStr = "";
			if (optionList != null && !optionList.isEmpty()) {
			optionDescStr = optionList.stream().map(IvrTaskTemplateTargetoption::getTargetvalue).filter(StringUtils::isNotEmpty).collect(Collectors.joining("或"));
			}

			String scriptContent = "请问" + phoneCallResultYQVO.getScriptContent();
			if (StringUtils.isNotEmpty(optionDescStr)) {
			scriptContent += "，你可以回答：" + optionDescStr;
			}
			phoneCallBackSHVO.setScriptContent(scriptContent);
			phoneCallBackSHVO.setTaskTemplateid(phoneCallResultYQVO.getTaskTemplateid());
			phoneCallBackSHVO.setSort(phoneCallResultYQVO.getSort());
			phoneCallBackSHVO.setScriptId(phoneCallResultYQVO.getScriptId());
			phoneCallBackSHVO.setSubId(phoneCallResultYQVO.getSubId());
			if (cacheObject == null)
			redisCache.setCacheObject(phoneCallResultYQVO.getSubId() + "-" + phoneCallResultYQVO.getScriptId(), 1, 120, TimeUnit.MINUTES);
			else
			redisCache.setCacheObject(phoneCallResultYQVO.getSubId() + "-" + phoneCallResultYQVO.getScriptId(), (Integer) cacheObject + 1, 120, TimeUnit.MINUTES);
			} else if ((Integer) cacheObject >= ivrTaskTemplate.getMateNum()) {
			//如果已经问了规定次数，就不问了，继续问下一题（这个要商量一下，是继续问下一题，还是停了，是不是要做个开关）
			IvrTaskTemplateScript ivrTaskTemplateScript = new IvrTaskTemplateScript();
			ivrTaskTemplateScript.setTemplateID(ivrTaskTemplateScriptVO.getTemplateID());
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript);
			//获取下一题
			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (script.getSort() == ivrTaskTemplateScriptVO.getNextScriptno().intValue()) {
			phoneCallBackSHVO.setScriptContent(script.getScriptContent());
			phoneCallBackSHVO.setTaskTemplateid(script.getTemplateID());
			phoneCallBackSHVO.setSort(script.getSort());
			phoneCallBackSHVO.setScriptId(script.getId());
			phoneCallBackSHVO.setSubId(serviceSubtask.getId());
			break;
			}
			}
			//把缓存清除
			redisCache.deleteObject(phoneCallResultYQVO.getSubId() + "-" + phoneCallResultYQVO.getScriptId());
			}
			}
			return phoneCallBackSHVO;
			}

			public PhoneCallBackYQVO AiMatch(String url, PhoneCallReqYQVO phoneCallReqYQVO, PhoneCallBackYQVO phoneCallBackYQVO, IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO, ServiceSubtask serviceSubtask, IvrTaskTemplate ivrTaskTemplate, List<IvrTaskTemplateScript> ivrTaskTemplateScripts, String scriptId, Integer flag, String uuid) {
			PhoneCallBackYQVO back = null;
			List<IvrTaskTemplateTargetoption> options = ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList();
			String voiceText = phoneCallReqYQVO.getAsrtext();
			String questionText = StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrtext()) ? ivrTaskTemplateScriptVO.getIvrtext() : ivrTaskTemplateScriptVO.getScriptContent();
			Integer matched = -1;
			log.info("AI匹配:url = {},questionText = {},voiceText = {},options = {},uuid ={}",
			url,questionText,voiceText,options,uuid);
			matched = matchOptionIndex(url, questionText, voiceText, options, uuid);
			//说明匹配正确了
			if(matched != null && matched >= 0){
			if (matched != null && matched >= 0) {
			IvrTaskTemplateTargetoption chosenOption = options.get(matched);
			//这里应该先判断类型，去再修改，设置IsUserOperation是单选题的改法
			log.info("匹配正确了吗--------------");
			@@ -5197,7 +5742,8 @@
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask.getJsy());
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			return phoneCallBackYQVO;
			back = phoneCallBackYQVO;
			return back;
			}

			flag = 1;
			@@ -5205,20 +5751,21 @@
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			// //获取下一题
			log.error("获取下一题的信息：{}", ivrTaskTemplateScriptVO);
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("1") \|\| ivrTaskTemplateScriptVO.getBranchFlag().equals("0") && ivrTaskTemplateScriptVO.getNextScriptno() != null && ivrTaskTemplateScriptVO.getNextScriptno() != 0) {
			//branchFlag为null时按分支0处理，避免NPE
			if ("1".equals(ivrTaskTemplateScriptVO.getBranchFlag()) \|\| "0".equals(ivrTaskTemplateScriptVO.getBranchFlag()) && ivrTaskTemplateScriptVO.getNextScriptno() != null && ivrTaskTemplateScriptVO.getNextScriptno() != 0) {
			Long nextQuestion = null;
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("1")) {
			if ("1".equals(ivrTaskTemplateScriptVO.getBranchFlag())) {
			nextQuestion = chosenOption.getNextQuestion();
			//更新分数
			double score = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			score = BigDecimal.valueOf(score).add(chosenOption.getScore()).doubleValue();
			score = BigDecimal.valueOf(score).add(new BigDecimal(chosenOption.getScore())).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score);
			} else {
			nextQuestion = ivrTaskTemplateScriptVO.getNextScriptno();
			//更新分数
			Object obj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			Double score = (obj == null ? new Double(0.00) : new Double(((Double) obj).doubleValue()));
			score = BigDecimal.valueOf(score).add(chosenOption.getScore()).doubleValue();
			score = BigDecimal.valueOf(score).add(new BigDecimal(String.valueOf(chosenOption.getScore()))).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);
			}
			if (nextQuestion == null \|\| nextQuestion == 0L) {
			@@ -5240,15 +5787,9 @@
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask.getJsy());
			//将结果写进detail表
			ServiceSubTaskDetailReq ssdReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList2 = new ArrayList<>();
			serviceSubtaskDetailList.add(getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate));
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList2);
			ssdReq.setGuid(phoneCallReqYQVO.getGuid());
			ssdReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(ssdReq);
			return phoneCallBackYQVO;
			//明细在本题匹配成功时已落库（见上方 saveQuestionAnswerPhone），这里不再重复保存
			back = phoneCallBackYQVO;
			return back;
			}

			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			@@ -5265,6 +5806,15 @@
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			}
			}
			//下一题脚本没找到时，兜底重问当前题，避免调用方误判为未处理而退回正则识别
			if (StringUtils.isEmpty(phoneCallBackYQVO.getValue())) {
			log.error("下一题脚本未找到，重问当前题，nextQuestion：{}", nextQuestion);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + getObject(serviceSubtask, questionText));
			}
			back = phoneCallBackYQVO;
			return back;
			} else if (ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getNextScriptno() == 0) {
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			phoneCallBackYQVO.setType("text");
			@@ -5273,7 +5823,7 @@
			double score = 0.0;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (double) scoreObj;
			serviceSubtask.setScore(BigDecimal.valueOf(score));
			serviceSubtask.setScore(String.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			@@ -5285,8 +5835,7 @@
			Long id = serviceSubtask.getId();
			Map<String, String> map = delRedisValue(null, id.toString());
			log.error("map的值为：{}", map);
			if (ObjectUtils.isNotEmpty(map))
			redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			if (ObjectUtils.isNotEmpty(map)) redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			@@ -5294,39 +5843,121 @@
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			// return phoneCallBackYQVO;
			//结束语已拼进返回值，挂机由平台按返回值执行
			back = phoneCallBackYQVO;
			return back;

			}
			} else {
			log.info("没有匹配上----------------------------");
			//flag=0,说明没匹配上，也要把患者说的话记录下来
			if (matched == ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().size() - 1 && flag == 0) {
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ServiceSubtaskDetail serviceSubtaskDetail = getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate);
			//修改一下语音路径（改成前端可以访问的，存到数据库中）
			if (StringUtils.isNotEmpty(serviceSubtaskDetail.getQuestionvoice())) {
			String questionvoice = serviceSubtaskDetail.getQuestionvoice();
			String[] split = questionvoice.split("\\\\");
			if (split.length > 0) {
			String lastPart = split[split.length - 1];
			serviceSubtaskDetail.setQuestionvoice(voicePathPrefix + lastPart);
			//AI没有匹配上：由AI分支自己按"没问清就重问"的次数处理，不再退回正则识别
			log.info("ai没有匹配上----------------------------");
			//没匹配上也要把患者说的话记录下来（matchedtext置空，与正则路径口径一致）
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ServiceSubtaskDetail serviceSubtaskDetail = getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate);
			//修改一下语音路径（改成前端可以访问的，存到数据库中）
			if (StringUtils.isNotEmpty(serviceSubtaskDetail.getQuestionvoice())) {
			String questionvoice = serviceSubtaskDetail.getQuestionvoice();
			String[] split = questionvoice.split("\\\\");
			if (split.length > 0) {
			String lastPart = split[split.length - 1];
			serviceSubtaskDetail.setQuestionvoice(voicePathPrefix + lastPart);
			}
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			//如果没有匹配上，这个必须为null
			serviceSubtaskDetailList.get(0).setMatchedtext("");
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			serviceSubTaskDetailReq.setGuid(phoneCallReqYQVO.getGuid());
			serviceSubTaskDetailReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);

			String mateKey = phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid();
			Integer count = null;
			Object countObj = redisCache.getCacheObject(mateKey);
			if (ObjectUtils.isNotEmpty(countObj)) count = (Integer) countObj;
			if (count != null && count >= ivrTaskTemplate.getMateNum()) {
			//没匹配次数已经用满，不能再重问了
			boolean noNextQuestion = ("0".equals(ivrTaskTemplateScriptVO.getBranchFlag()) \|\| "1".equals(ivrTaskTemplateScriptVO.getBranchFlag()))
			&& (ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getNextScriptno() == 0);
			if (noNextQuestion) {
			//已经是最后一题，直接挂机
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask1.getJsy());
			//更新一下分数
			Double score = null;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (Double) scoreObj;
			serviceSubtask.setScore(String.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask.getJsy(), 120, TimeUnit.MINUTES);
			//去redis中，把该子任务ID删除
			Long id = serviceSubtask.getId();
			Map<String, String> map = delRedisValue(null, id.toString());
			if (ObjectUtils.isNotEmpty(map)) {
			redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			}
			} else {
			//还有下一题，按nextScriptno继续提问
			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (script.getSort() == ivrTaskTemplateScriptVO.getNextScriptno().intValue()) {
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = StringUtils.isNotEmpty(script.getIvrtext()) ? script.getIvrtext() : script.getScriptContent();
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + getObject(serviceSubtask, scriptContent));
			//将该患者的Redis中的题目ID，进行修改
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid().trim() + "-" + phoneCallReqYQVO.getPhone().trim(), script.getId().toString(), 120, TimeUnit.MINUTES);
			//更新一下分数
			Double score = null;
			Object scoreObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			if (ObjectUtils.isNotEmpty(scoreObj)) score = (Double) scoreObj;
			score = BigDecimal.valueOf(score).add(new BigDecimal(script.getScore())).doubleValue();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);
			//换题成功，没匹配次数清零
			redisCache.deleteObject(mateKey);
			}
			}
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			//如果没有匹配上，这个必须为null
			serviceSubtaskDetailList.get(0).setMatchedtext("");
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			serviceSubTaskDetailReq.setGuid(phoneCallReqYQVO.getGuid());
			serviceSubTaskDetailReq.setOrgid(phoneCallReqYQVO.getOrgid());
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			} else {
			//还没问满次数，用noMatchText引导患者重答
			redisCache.setCacheObject(mateKey, count == null ? 1 : count + 1, 120, TimeUnit.MINUTES);
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			phoneCallBackYQVO.setValue(ivrTaskTemplateScriptVO.getNoMatchText() + getObject(serviceSubtask, StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getIvrtext()) ? ivrTaskTemplateScriptVO.getIvrtext() : ivrTaskTemplateScriptVO.getScriptContent()));
			}
			back = phoneCallBackYQVO;
			return back;
			}
			return back;
			}

			//获取任务组信息
			private void findServiceTaskScheduleVO(ServiceTaskVO serviceTaskVO) {
			if (StringUtils.isNotEmpty(serviceTaskVO.getAppltype()) && serviceTaskVO.getAppltype().equals("5")) {
			//任务组信息
			ServiceTaskSchedule schedule = serviceTaskScheduleService.selectByTaskid(serviceTaskVO.getTaskid());
			if (ObjectUtils.isNotEmpty(schedule)) {
			ServiceTaskScheduleVO serviceTaskScheduleVO = DtoConversionUtils.sourceToTarget(schedule, ServiceTaskScheduleVO.class);
			List<ServiceTaskScheduleDetail> scheduleDetailList = serviceTaskScheduleService.selectDetailByScheduleid(schedule.getId());
			serviceTaskScheduleVO.setDetailList(scheduleDetailList);
			serviceTaskVO.setServiceTaskScheduleVO(serviceTaskScheduleVO);
			}
			}
			}

			@Test
			public void TestMatch(){
			public void TestMatch() {
			String questionText = "您好,请问您是患者本人还是家属？\n";
			String voiceText = "我自己";
			String matchedText = "";
			@@ -5342,12 +5973,17 @@
			options.add(ivrTaskTemplateTargetoption3);
			//1-AI识别
			String url = configService.selectConfigByKey("sys.voice.match.ai.url");
			Integer matched = matchOptionIndex(url, questionText,voiceText,options,"1");
			if(ObjectUtils.isNotEmpty(matched)){
			if(matched >= 0){
			Integer matched = matchOptionIndex(url, questionText, voiceText, options, "1");
			if (ObjectUtils.isNotEmpty(matched)) {
			if (matched >= 0) {
			matchedText = options.get(matched).getTargetvalue();
			}
			}
			log.info("ai匹配成功，匹配结果是:" + matchedText);
			}

			// ---------------------------------------------------------------------
			// 说明：原私有 getWXCode / encode 已随发送方一起收口到 ruoyi-message 模块
			// （XinHuaMpApi），此处已删除，避免三份拷贝各写一套签名逻辑。
			// ---------------------------------------------------------------------
			}