~liusheng/smartor.git

			@@ -6,14 +6,13 @@
			import com.google.gson.Gson;
			import com.ruoyi.common.core.redis.RedisCache;
			import com.ruoyi.common.exception.base.BaseException;
			import com.ruoyi.common.utils.DateUtils;
			import com.ruoyi.common.utils.DtoConversionUtils;
			import com.ruoyi.common.utils.RSAPublicKeyExample;
			import com.ruoyi.common.utils.*;
			import com.smartor.common.FtpService;
			import com.smartor.common.SendService;
			import com.smartor.config.PhoneUtils;
			import com.smartor.domain.*;
			import com.smartor.mapper.*;
			import com.smartor.service.IServiceSubtaskService;
			import com.smartor.service.IServiceTaskService;
			import com.smartor.service.*;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.collections4.CollectionUtils;
			import org.apache.commons.lang3.ObjectUtils;
			@@ -23,11 +22,18 @@
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;

			import java.io.UnsupportedEncodingException;
			import java.math.BigDecimal;
			import java.text.SimpleDateFormat;
			import java.time.LocalDate;
			import java.time.LocalTime;
			import java.time.ZoneId;
			import java.time.format.DateTimeFormatter;
			import java.util.*;
			import java.util.concurrent.TimeUnit;
			import java.util.regex.Matcher;
			import java.util.regex.Pattern;
			import java.util.stream.Collectors;

			/**
			* 单一任务（随访）Service业务层处理
			@@ -42,7 +48,7 @@
			private ServiceSubtaskMapper serviceSubtaskMapper;

			@Autowired
			private ServiceSubtaskDetailMapper ivrTaskcalldetailMapper;
			private ServiceSubtaskDetailMapper serviceSubtaskDetailMapper;

			@Autowired
			private IServiceTaskService serviceTaskService;
			@@ -59,9 +65,53 @@
			@Autowired
			private IvrLibaExtemplatescriptMapper ivrLibaExtemplatescriptMapper;

			@Autowired
			private IIvrTaskTemplateService ivrTaskTemplateService;

			@Autowired
			private ISvyTaskTemplateService svyTaskTemplateService;

			@Autowired
			private IIvrTaskTemplateScriptService iIvrTaskTemplateScriptService;

			@Autowired
			private IServiceOutPathService iServiceOutPathService;

			@Autowired
			private FtpService ftpService;

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

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

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

			@Autowired
			private SendService sendService;

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

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

			@Value("${ruoyi.profile}")
			private String profile;

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

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

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

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

			/**
			* 查询单一任务（随访）
			@@ -77,23 +127,27 @@
			/**
			* 查询单一任务（随访）列表
			*
			* @param ServiceSubtask 单一任务（随访）
			* @param serviceSubtaskVO 单一任务（随访）
			* @return 单一任务（随访）
			*/
			@Override
			public List<ServiceSubtask> selectServiceSubtaskList(ServiceSubtask ServiceSubtask) {
			return serviceSubtaskMapper.selectServiceSubtaskList(ServiceSubtask);
			public List<ServiceSubtask> selectServiceSubtaskList(ServiceSubtaskVO serviceSubtaskVO) {
			return serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO);
			}

			@Override
			public ServiceTaskVO queryTaskByCondition(ServiceSubtask ServiceSubtask) {
			public ServiceTaskVO queryTaskByCondition(ServiceSubtask serviceSubtask) {
			//定义患者与单一任务关联表集合
			List<PatTaskRelevance> patTaskRelevances = new ArrayList<>();
			List<ServiceSubtask> list = selectServiceSubtaskList(ServiceSubtask);
			ServiceSubtaskVO serviceSubtaskVO = DtoConversionUtils.sourceToTarget(serviceSubtask, ServiceSubtaskVO.class);
			List<ServiceSubtask> list = selectServiceSubtaskList(serviceSubtaskVO);

			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			if (CollectionUtils.isEmpty(list) \|\| list.size() == 0) {
			return new ServiceTaskVO();
			return DtoConversionUtils.sourceToTarget(serviceTask, ServiceTaskVO.class);
			}
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(ServiceSubtask.getTaskid());


			//将查出来的数据倒入ServiceSubtaskVO中
			ServiceTaskVO serviceTaskVO = DtoConversionUtils.sourceToTarget(serviceTask, ServiceTaskVO.class);
			serviceTaskVO.setShowDate(serviceTask.getShowDate());
			@@ -126,12 +180,24 @@
			//获取到患者信息，并放入到集合中
			patTaskRelevance.setName(serviceSubtask1.getSendname());
			patTaskRelevance.setAge(serviceSubtask1.getAge());
			patTaskRelevance.setFinishtime(serviceSubtask1.getFinishtime());
			patTaskRelevance.setSfzh(serviceSubtask1.getSfzh());
			patTaskRelevance.setPhone(serviceSubtask1.getPhone());
			patTaskRelevance.setTelcode(serviceSubtask1.getPhone());
			patTaskRelevance.setAddr(serviceSubtask1.getAddr());
			patTaskRelevance.setDiagname(serviceSubtask1.getDiagname());
			patTaskRelevance.setPatid(serviceSubtask1.getPatid());
			patTaskRelevance.setSendState(serviceSubtask1.getSendstate());
			patTaskRelevance.setSendStatus(serviceSubtask1.getSendstate());
			patTaskRelevance.setDeptCode(serviceSubtask1.getDeptcode());
			patTaskRelevance.setDeptName(serviceSubtask1.getDeptname());
			patTaskRelevance.setLeavehospitaldistrictcode(serviceSubtask1.getLeavehospitaldistrictcode());
			patTaskRelevance.setLeavehospitaldistrictname(serviceSubtask1.getLeavehospitaldistrictname());
			patTaskRelevance.setInhosptime(serviceSubtask1.getInhosptime());
			patTaskRelevance.setDrname(serviceSubtask1.getDrname());
			patTaskRelevance.setDrcode(serviceSubtask1.getDrcode());
			patTaskRelevance.setEndtime(serviceSubtask1.getEndtime());
			patTaskRelevance.setNurseId(serviceSubtask1.getNurseId());
			patTaskRelevance.setNurseName(serviceSubtask1.getNurseName());
			patTaskRelevances.add(patTaskRelevance);
			}
			if (serviceSubtask1.getHospType().equals("2")) {
			@@ -140,12 +206,25 @@
			patTaskRelevance.setAge(serviceSubtask1.getAge());
			patTaskRelevance.setSfzh(serviceSubtask1.getSfzh());
			patTaskRelevance.setPhone(serviceSubtask1.getPhone());
			patTaskRelevance.setTelcode(serviceSubtask1.getPhone());
			patTaskRelevance.setFinishtime(serviceSubtask1.getFinishtime());
			patTaskRelevance.setAddr(serviceSubtask1.getAddr());
			patTaskRelevance.setDeptName(serviceSubtask1.getDeptname());
			patTaskRelevance.setDeptCode(serviceSubtask1.getDeptcode());
			patTaskRelevance.setBedNo(serviceSubtask1.getBedNo());
			patTaskRelevance.setDiagname(serviceSubtask1.getDiagname());
			patTaskRelevance.setPatid(serviceSubtask1.getPatid());
			patTaskRelevance.setSendState(serviceSubtask1.getSendstate());
			patTaskRelevance.setSendStatus(serviceSubtask1.getSendstate());
			patTaskRelevance.setLeavehospitaldistrictcode(serviceSubtask1.getLeavehospitaldistrictcode());
			patTaskRelevance.setLeavehospitaldistrictname(serviceSubtask1.getLeavehospitaldistrictname());
			patTaskRelevance.setInhosptime(serviceSubtask1.getInhosptime());
			patTaskRelevance.setStarttime(serviceSubtask1.getStarttime());
			patTaskRelevance.setDrname(serviceSubtask1.getDrname());
			patTaskRelevance.setDrcode(serviceSubtask1.getDrcode());
			patTaskRelevance.setEndtime(serviceSubtask1.getEndtime());
			patTaskRelevance.setStarttime(serviceSubtask1.getStarttime());
			patTaskRelevance.setNurseId(serviceSubtask1.getNurseId());
			patTaskRelevance.setNurseName(serviceSubtask1.getNurseName());
			patTaskRelevances.add(patTaskRelevance);
			}
			}
			@@ -155,10 +234,41 @@
			}

			@Override
			public List<ServiceSubtask> patItem(ServiceSubtask serviceSubtask) {
			public List<ServiceSubtask> patItem(ServiceSubtaskVO serviceSubtaskVO) {
			List<ServiceSubtask> selectServiceSubtaskList = this.selectServiceSubtaskList(serviceSubtaskVO);
			//根据出院时间倒序
			// List<ServiceSubtask> sortedServiceSubtaskList = selectServiceSubtaskList.stream().sorted(Comparator.comparing(ServiceSubtask::getEndtime).reversed()).collect(Collectors.toList());
			return selectServiceSubtaskList;
			}

			@Override
			public Map<String, Object> patItemCount(ServiceSubtaskVO serviceSubtaskVO) {
			serviceSubtaskVO.setPageSize(99999999);
			serviceSubtaskVO.setPageNum(1);
			List<ServiceSubtask> selectServiceSubtaskList = this.selectServiceSubtaskList(serviceSubtaskVO);
			Map<String, Object> map = new HashMap<>();
			Integer wzx = 0;
			Integer ysf = 0;
			Integer yc = 0;
			Integer fssb = 0;
			Integer yfs = 0;
			Integer blq = 0;
			for (ServiceSubtask serviceSubtask : selectServiceSubtaskList) {
			if (serviceSubtask.getSendstate() == 4L) wzx = wzx + 1;
			else if (serviceSubtask.getSendstate() != 4L) ysf = ysf + 1;
			if (serviceSubtask.getSendstate() == 5L) fssb = fssb + 1;
			if (serviceSubtask.getSendstate() == 3L) yfs = yfs + 1;
			if (serviceSubtask.getSendstate() == 1L) blq = blq + 1;
			if (serviceSubtask.getExcep().equals("1")) yc = yc + 1;
			}
			map.put("wzx", wzx);
			map.put("ysf", ysf);
			map.put("yc", yc);
			map.put("fssb", fssb);
			map.put("yfs", yfs);
			map.put("blq", blq);

			return this.selectServiceSubtaskList(serviceSubtask);
			return map;
			}

			/**
			@@ -206,21 +316,48 @@
			*/
			@Transactional(rollbackFor = Exception.class)
			@Override
			public int insertOrUpdateTask(ServiceTaskVO serviceTaskVO) {
			public Map<String, Integer> insertOrUpdateTask(ServiceTaskVO serviceTaskVO) {
			if (ObjectUtils.isEmpty(serviceTaskVO)) {
			log.info("任务入参为空，请检查入参");
			throw new BaseException("任务入参为空，请检查入参");
			}
			Integer integer = 1;
			Integer integer = null;
			ServiceTask serviceTask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceTask.class);
			serviceTask.setTextParam(JSON.toJSONString(serviceTaskVO.getTextParam()));
			if (serviceTaskVO.getIsoperation() != null && serviceTaskVO.getIsoperation() == 1) {
			//往任务表中，新增任务
			if (ObjectUtils.isNotEmpty(serviceTaskVO.getSendTimeslot()))
			serviceTask.setSendTimeSlot(JSON.toJSONString(serviceTaskVO.getSendTimeslot()));
			if (serviceTask.getSendState() == null) serviceTask.setSendState(1);
			serviceTask.setTemplateid(serviceTaskVO.getLibtemplateid());
			if (serviceTask.getSendState() == null) {
			serviceTask.setSendState(1L);
			serviceTaskVO.setSendState(1L);
			}
			if (StringUtils.isNotEmpty(serviceTaskVO.getLibtemplateid())) {
			serviceTask.setLibtemplateid(serviceTaskVO.getLibtemplateid());
			}
			serviceTask.setTemplateid(serviceTaskVO.getTemplateid());

			serviceTask.setLeaveldeptcodes(serviceTaskVO.getLeaveldeptcodes());
			serviceTask.setLeavehospitaldistrictcode(serviceTask.getLeavehospitaldistrictcode());
			serviceTaskService.insertServiceTask(serviceTask);
			if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1) {
			//这里需要将任务id与任务模板ID，在任务模板中绑定
			Map<String, Integer> map = new HashMap<>();
			if (StringUtils.isNotEmpty(serviceTaskVO.getType()) && serviceTaskVO.getType().equals("1")) {
			IvrTaskTemplate ivrTaskTemplate = new IvrTaskTemplate();
			ivrTaskTemplate.setTaskid(serviceTask.getTaskid());
			ivrTaskTemplate.setId(serviceTaskVO.getTemplateid());
			ivrTaskTemplateService.updateIvrTaskTemplate(ivrTaskTemplate);
			} else if (StringUtils.isNotEmpty(serviceTaskVO.getType()) && serviceTaskVO.getType().equals("2")) {
			SvyTaskTemplate svyTaskTemplate = new SvyTaskTemplate();
			svyTaskTemplate.setTaskid(serviceTask.getTaskid());
			svyTaskTemplate.setId(serviceTaskVO.getTemplateid());
			svyTaskTemplateService.updateSvyTaskTemplate(svyTaskTemplate);
			}
			map.put("subTaskId", null);
			map.put("taskId", serviceTask.getTaskid().intValue());
			return map;
			}

			//将任务信息放到服务表中
			ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceSubtask.class);
			@@ -232,15 +369,28 @@
			//将任务信息新增到随访服务表中
			serviceSubtask.setSendname(patTaskRelevance.getName());
			serviceSubtask.setAge(patTaskRelevance.getAge());
			serviceSubtask.setSfzh(patTaskRelevance.getSfzh());
			serviceSubtask.setPhone(patTaskRelevance.getPhone());
			serviceSubtask.setSfzh(patTaskRelevance.getIdcardno());
			serviceSubtask.setPhone(patTaskRelevance.getTelcode());
			serviceSubtask.setAddr(patTaskRelevance.getAddr());
			serviceSubtask.setPatid(patTaskRelevance.getPatid());
			serviceSubtask.setCreateTime(DateUtils.getNowDate());
			serviceSubtask.setSendstate(1L);
			if (serviceTaskVO.getLongTask() == 1) serviceSubtask.setSendstate(2L);
			serviceSubtask.setDeptcode(patTaskRelevance.getDeptCode());
			serviceSubtask.setDeptname(patTaskRelevance.getDeptName());
			serviceSubtask.setLeavehospitaldistrictcode(patTaskRelevance.getLeavehospitaldistrictcode());
			serviceSubtask.setLeavehospitaldistrictname(patTaskRelevance.getLeavehospitaldistrictname());
			serviceSubtask.setType(serviceTaskVO.getHospType());
			serviceSubtask.setHospType(patTaskRelevance.getHospType());
			serviceSubtask.setOpenid(patTaskRelevance.getOpenid());
			serviceSubtask.setDrname(patTaskRelevance.getDrname());
			serviceSubtask.setDrcode(patTaskRelevance.getDrcode());
			serviceSubtask.setInhosptime(patTaskRelevance.getInhosptime());
			serviceSubtask.setEndtime(patTaskRelevance.getEndtime());
			serviceSubtask.setNurseId(patTaskRelevance.getNurseId());
			serviceSubtask.setNurseName(patTaskRelevance.getNurseName());
			if (serviceTaskVO.getLongTask() == 1)
			serviceSubtask.setLongSendTime(patTaskRelevance.getLongSendTime());
			serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			integer = serviceSubtask.getId().intValue();
			}
			@@ -252,24 +402,54 @@
			serviceTask.setSendTimeSlot(JSON.toJSONString(serviceTaskVO.getSendTimeslot()));
			//修改操作，需要将stopState状态+1
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceTask.getTaskid());
			serviceTask.setStopState(serviceTask1.getStopState() + 1);
			serviceTask.setTemplateid(serviceTaskVO.getLibtemplateid());
			long l = serviceTask1.getStopState() + 1;
			serviceTask.setStopState(l);
			if (serviceTaskVO.getLibtemplateid() != null)
			serviceTask.setLibtemplateid(serviceTaskVO.getLibtemplateid().toString());
			serviceTask.setTemplateid(serviceTaskVO.getTemplateid());
			serviceTask.setLongTask(serviceTaskVO.getLongTask());
			serviceTaskService.updateServiceTask(serviceTask);

			if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1) {
			//这里需要将任务id与任务模板ID，在任务模板中绑定
			Map<String, Integer> map = new HashMap<>();
			if (StringUtils.isNotEmpty(serviceTaskVO.getType()) && serviceTaskVO.getType().equals("1")) {
			IvrTaskTemplate ivrTaskTemplate = new IvrTaskTemplate();
			ivrTaskTemplate.setTaskid(serviceTask.getTaskid());
			ivrTaskTemplate.setId(serviceTaskVO.getTemplateid());
			ivrTaskTemplateService.updateIvrTaskTemplate(ivrTaskTemplate);
			} else if (StringUtils.isNotEmpty(serviceTaskVO.getType()) && serviceTaskVO.getType().equals("2")) {
			SvyTaskTemplate svyTaskTemplate = new SvyTaskTemplate();
			svyTaskTemplate.setTaskid(serviceTask.getTaskid());
			svyTaskTemplate.setId(serviceTaskVO.getTemplateid());
			svyTaskTemplateService.updateSvyTaskTemplate(svyTaskTemplate);
			}
			map.put("subTaskId", null);
			map.put("taskId", serviceTask.getTaskid().intValue());
			return map;
			}
			if (CollectionUtils.isNotEmpty(serviceTaskVO.getPatTaskRelevances())) {
			for (PatTaskRelevance patTaskRelevance : serviceTaskVO.getPatTaskRelevances()) {

			ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceSubtask.class);
			serviceSubtask.setSendname(patTaskRelevance.getName());
			serviceSubtask.setAge(patTaskRelevance.getAge());
			serviceSubtask.setSfzh(patTaskRelevance.getSfzh());
			serviceSubtask.setPhone(patTaskRelevance.getPhone());
			serviceSubtask.setPhone(patTaskRelevance.getTelcode());
			serviceSubtask.setAddr(patTaskRelevance.getAddr());
			serviceSubtask.setPatid(patTaskRelevance.getPatid());
			serviceSubtask.setOpenid(patTaskRelevance.getOpenid());
			serviceSubtask.setDeptcode(patTaskRelevance.getDeptCode());
			serviceSubtask.setLeavehospitaldistrictname(patTaskRelevance.getLeavehospitaldistrictname());
			serviceSubtask.setLeavehospitaldistrictcode(patTaskRelevance.getLeavehospitaldistrictcode());
			serviceSubtask.setDeptname(patTaskRelevance.getDeptName());
			serviceSubtask.setType(serviceTaskVO.getHospType());
			serviceSubtask.setCreateTime(DateUtils.getNowDate());
			serviceSubtask.setDrname(patTaskRelevance.getDrname());
			serviceSubtask.setDrcode(patTaskRelevance.getDrcode());
			serviceSubtask.setInhosptime(patTaskRelevance.getInhosptime());
			serviceSubtask.setHospType(patTaskRelevance.getHospType());
			serviceSubtask.setEndtime(patTaskRelevance.getEndtime());
			serviceSubtask.setNurseId(patTaskRelevance.getNurseId());
			serviceSubtask.setNurseName(patTaskRelevance.getNurseName());
			serviceSubtask.setTextParam(new Gson().toJson(serviceTaskVO.getTextParam()));
			if (patTaskRelevance.getIsoperation() != null) {
			if (patTaskRelevance.getIsoperation() == 2)
			@@ -286,13 +466,15 @@
			}
			}
			}
			return integer;
			Map<String, Integer> map = new HashMap<>();
			map.put("subTaskId", integer);
			map.put("taskId", serviceTask.getTaskid().intValue());
			return map;
			}


			@Override
			public void phoneCallBack(PhoneCallBackVO phoneCallBackVO) {

			phoneCallBackVO.setTextResult(phoneCallBackVO.getTextResult().substring(0, phoneCallBackVO.getTextResult().length() - 1));
			SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("YYYY-MM-dd HH:mm:ss");

			@@ -335,6 +517,11 @@
			if (noVoice == ivrTaskTemplateVO.getNoVoiceNum().intValue()) {
			//已经问了对应的遍数，就判断是否还有下一题
			if (nowQuestion.getTargetid() == IvrTaskTemplateScriptVOs.size()) {
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(5L);
			ss.setRemark("电话无响应");
			serviceSubtaskMapper.updateServiceSubtask(ss);
			//没有下一题了，就挂断电话，播放结束语
			redisCache.setCacheObject(phoneCallBackVO.getUuid() + "hangup", 1, 120, TimeUnit.MINUTES);
			phoneUtils.ttsPlayback(ivrTaskTemplateVO.getRevisitAfter(), phoneCallBackVO.getUuid());
			@@ -380,7 +567,7 @@
			if (StringUtils.isNotEmpty(nowQuestion.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() && StringUtils.isNotEmpty(nowQuestion.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches() \|\| StringUtils.isEmpty(nowQuestion.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && StringUtils.isNotEmpty(nowQuestion.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() \|\| StringUtils.isEmpty(nowQuestion.getIvrTaskScriptTargetoptionList().get(j).getTargetregex2()) && StringUtils.isNotEmpty(nowQuestion.getIvrTaskScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches()) {
			//说明匹配正确了
			//这里应该先判断类型，去再修改，设置IsUserOperation是单选题的改法
			nowQuestion.getIvrTaskScriptTargetoptionList().get(j).setIsUserOperation(true);
			nowQuestion.getIvrTaskScriptTargetoptionList().get(j).setIsUserOperation(1);
			serviceTaskScriptTargetoptionMapper.updateIvrTaskTemplateTargetoption(nowQuestion.getIvrTaskScriptTargetoptionList().get(j));

			//将静默置为0
			@@ -411,6 +598,10 @@
			return;
			} else if (nextQuestion > IvrTaskTemplateScriptVOs.size()) {
			//没有下一题了，就结束了
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(6L);
			serviceSubtaskMapper.updateServiceSubtask(ss);
			String date = simpleDateFormat1.format(new Date());
			log.error("没有下一题了，就结束了: {},uuid为：{}", date, phoneCallBackVO.getUuid());
			redisCache.setCacheObject(phoneCallBackVO.getUuid() + "hangup", 1, 120, TimeUnit.MINUTES);
			@@ -452,6 +643,11 @@
			return;
			} else {
			//就可以挂断电话了
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(6L);
			serviceSubtaskMapper.updateServiceSubtask(ss);

			String date = simpleDateFormat1.format(new Date());
			log.info("就可以挂断电话了------: {},uuid为：{}", date, phoneCallBackVO.getUuid());
			redisCache.setCacheObject(phoneCallBackVO.getUuid() + "hangup", 1, 120, TimeUnit.MINUTES);
			@@ -492,7 +688,7 @@
			Pattern pattern2 = Pattern.compile(ivrLibaExtemplatescript.getSelfRegex2());
			matcher2 = pattern2.matcher(returnQues.getContent());
			}
			log.info("++++++++++++++++++++++++++通用库是否为空：selfRegex : {} , selfRegex2 : {}", ivrLibaExtemplatescript.getSelfRegex(), ivrLibaExtemplatescript.getSelfRegex2());
			log.error("++++++++++++++++++++++++++通用库是否为空：selfRegex : {} , selfRegex2 : {}", ivrLibaExtemplatescript.getSelfRegex(), ivrLibaExtemplatescript.getSelfRegex2());
			if (StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex()) && matcher.matches() && StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex2()) && matcher2.matches() \|\| StringUtils.isEmpty(ivrLibaExtemplatescript.getSelfRegex()) && StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex2()) && matcher2.matches() \|\| StringUtils.isEmpty(ivrLibaExtemplatescript.getSelfRegex2()) && StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex()) && matcher.matches()) {
			QuestionMessage questionMessage = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "returnQues");
			IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO = returnQues.getNowQuestion();
			@@ -506,7 +702,6 @@
			nowQuestion1.setScriptVoice(null);
			questionMessage.setNowQuestion(nowQuestion1);
			redisCache.setCacheObject(phoneCallBackVO.getUuid() + "returnQues", questionMessage, 120, TimeUnit.MINUTES);

			redisCache.setCacheObject(phoneCallBackVO.getUuid() + "isOver", 1, 120, TimeUnit.MINUTES);
			}
			//调用“15、tts合成和播放， tts_playback”将结果传回
			@@ -522,6 +717,707 @@
			}
			}
			}

			/**
			* 电话ASR通话回调(雨绮)
			*
			* @param phoneCallReqYQVO
			*/
			@Override
			public PhoneCallBackYQVO phoneCallBackYQ(PhoneCallReqYQVO phoneCallReqYQVO) {
			//判断是否挂机
			String hangupState = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "- hangup");
			Object cacheObject1 = redisCache.getCacheObject(phoneCallReqYQVO.getTaskid() + "recordAccept-hungup");
			if (StringUtils.isNotEmpty(hangupState) && hangup.equals("1") \|\| ObjectUtils.isNotEmpty(cacheObject1) && String.valueOf(cacheObject1).equals("1")) {
			return new PhoneCallBackYQVO();
			}
			if ("AsrCallback".equals(phoneCallReqYQVO.getOperate()) && phoneCallReqYQVO.getEnd_time() != null && phoneCallReqYQVO.getEnd_time() != -1) {
			//处理挂断
			if (phoneCallReqYQVO.getAsrtext().contains("拨叫的用户正忙")) {
			//判断 recordAccept-hungup 是否有值，如果有，则说明不用处理了，之前已经处理过了（recordAccept-hungup这个主要是给“通话记录用的，”）
			Object cacheObject = redisCache.getCacheObject(phoneCallReqYQVO.getTaskid() + "recordAccept-hungup");
			if (ObjectUtils.isNotEmpty(cacheObject) && String.valueOf(cacheObject).equals("1")) {
			return new PhoneCallBackYQVO();
			}
			ServiceSubtask serviceSubtask2 = new ServiceSubtask();
			serviceSubtask2.setRemark("电话发送成功（患者挂断）");
			serviceSubtask2.setSenduuid(phoneCallReqYQVO.getUuid());
			serviceSubtask2.setId(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask2);
			Map<String, String> req = new HashMap<>();
			req.put("uuid", phoneCallReqYQVO.getUuid());
			req.put("caller", phoneCallReqYQVO.getPhone());
			HttpUtil.postJsonRequest(hangup, new Gson().toJson(req));
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- hangup", "1", 2, TimeUnit.MINUTES);
			//这个时候就需要走补偿机制了，先暂定走短信
			getSmsCompensate(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			return new PhoneCallBackYQVO();
			}
			}
			//定义一个分数的变量
			Boolean aBoolean1 = redisCache.hasKey(phoneCallReqYQVO.getUuid() + "SCORE");
			if (!aBoolean1) redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", 0.0, 120, TimeUnit.MINUTES);
			PhoneCallBackYQVO phoneCallBackYQVO = new PhoneCallBackYQVO();
			//channel_create 通道创建的时候，可以执行一些其它操作，譬如发个短信之类的; 我们的业务可以不用管 PlayEventCallback 这个是播放语音的,暂时用不到 End_time()= -1或null表示当前的asrtext不是一句完整的话
			if (phoneCallReqYQVO.getOperate().equals("channel_create")) {
			return phoneCallBackYQVO;
			}
			//PlayEventCallback 这个是播放语音的 playstart：放音开始（问题播报开始） playstop：放音结束（问题播报结束）
			if (phoneCallReqYQVO.getOperate().equals("PlayEventCallback")) {
			String cacheJSY = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "- jsy");
			if (phoneCallReqYQVO.getOperate().equals("PlayEventCallback") && phoneCallReqYQVO.getPlaystop() == false) {
			//判断redis中是否有结束语
			if (StringUtils.isEmpty(cacheJSY)) {
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop", false, 120, TimeUnit.MINUTES);
			log.error("PlayEventCallbackPlaystop的值为-------：{}", false);
			}
			} else {
			//如果结束语不为空，则要挂电话了
			if (StringUtils.isNotEmpty(cacheJSY)) {
			Map<String, String> req = new HashMap<>();
			req.put("uuid", phoneCallReqYQVO.getUuid());
			req.put("caller", phoneCallReqYQVO.getPhone());
			// HttpUtils.sendPost(hangup, new Gson().toJson(req));
			HttpUtil.postJsonRequest(hangup, new Gson().toJson(req));
			//删除结束语的患存
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "- jsy");
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid() + "recordAccept-hungup", "2", 10, TimeUnit.MINUTES);
			} else {
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop", true, 120, TimeUnit.MINUTES);
			log.error("-------PlayEventCallbackPlaystop的值为：{}", true);
			}
			}
			return phoneCallBackYQVO;
			}
			//获取放音是否结束
			Object isPlayEventOverObj = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "PlayEventCallbackPlaystop");
			if (ObjectUtils.isNotEmpty(isPlayEventOverObj)) {
			Boolean isPlayEventOver = (Boolean) isPlayEventOverObj;
			if (!isPlayEventOver) {
			return phoneCallBackYQVO;
			}
			}

			//通过子任务ID获取到模板信息
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			IvrTaskTemplate ivrTaskTemplate = ivrTaskTemplateService.selectIvrTaskTemplateByID(serviceSubtask.getTemplateid());
			//获取模板问题
			IvrTaskTemplateScript ivrTaskTemplateScript = new IvrTaskTemplateScript();
			ivrTaskTemplateScript.setTemplateID(serviceSubtask.getTemplateid());
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript);
			//获取问题ID 和序号
			String scriptId = redisCache.getCacheObject(phoneCallReqYQVO.getTaskid().trim() + "-" + phoneCallReqYQVO.getPhone().trim());
			log.error("scriptId是多少：{}", scriptId);
			//当前题的信息
			IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO = iIvrTaskTemplateScriptService.getTaskTempScriptInfoByid(Long.valueOf(scriptId));
			//判断UUID是否存在
			Boolean aBoolean = redisCache.hasKey(phoneCallReqYQVO.getUuid());
			if (!aBoolean) {
			//给静默设置一个默认次数在redis中
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "noVoice", 0, 120, TimeUnit.MINUTES);
			//如果不存在，就把当前的UUID做为key，放到对象中去
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid(), phoneCallReqYQVO, 120, TimeUnit.MINUTES);
			}

			if ("SilentCallback".equals(phoneCallReqYQVO.getOperate())) {
			//如果是静默回调
			Integer num = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "noVoice");
			//判断静默回调次数是否小与模板规定的次数
			if (num < ivrTaskTemplate.getNoVoiceNum()) {
			//小与的话,就继续问患者
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = ivrTaskTemplateScriptVO.getScriptContent();
			log.error("SilentCallback的问题内容scriptContent：{}", scriptContent);
			phoneCallBackYQVO.setValue(getObject(serviceSubtask, scriptContent));
			//将静默次数加1
			Integer noVoiceNum = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "noVoice");
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "noVoice", noVoiceNum + 1, 120, TimeUnit.MINUTES);
			return phoneCallBackYQVO;
			} else {
			log.error("静默次数达到,挂掉电话：{}", num);
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(5L);
			ss.setRemark("电话静默");
			serviceSubtaskMapper.updateServiceSubtask(ss);
			//大与等于的话,直接挂断
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			phoneCallBackYQVO.setValue(serviceTask1.getJsy());
			//将结果写到detail中
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			serviceSubtaskDetailList.add(getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate));
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			//去redis中，把该子任务ID删除
			Long id = serviceSubtask.getId();
			//先更新一下分数
			double score = redisCache.getCacheObject(phoneCallReqYQVO.getUuid() + "SCORE");
			serviceSubtask.setScore(BigDecimal.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			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");
			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 if ("AsrCallback".equals(phoneCallReqYQVO.getOperate()) && phoneCallReqYQVO.getEnd_time() != null && phoneCallReqYQVO.getEnd_time() != -1) {

			// 先对通话进行通用库匹配一次
			String extemplateID = ivrTaskTemplate.getSubmoduleID();
			if (StringUtils.isNotEmpty(extemplateID)) {
			String[] split = extemplateID.split(",");
			List<String> list = Arrays.asList(split);
			List<Long> list1 = new ArrayList<>();
			for (String str : list) {
			list1.add(Long.valueOf(str));
			}
			List<IvrLibaExtemplatescript> ivrLibaExtemplatescripts = ivrLibaExtemplatescriptMapper.queryIvrLibaExtemplatescriptList(list1);
			IvrLibaExtemplatescript les = null;
			for (IvrLibaExtemplatescript ivrLibaExtemplatescript : ivrLibaExtemplatescripts) {
			Matcher matcher = null;
			if (StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex())) {
			Pattern pattern = Pattern.compile(ivrLibaExtemplatescript.getSelfRegex());
			matcher = pattern.matcher(phoneCallReqYQVO.getAsrtext());
			}

			Matcher matcher2 = null;
			if (StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex2())) {
			Pattern pattern2 = Pattern.compile(ivrLibaExtemplatescript.getSelfRegex2());
			matcher2 = pattern2.matcher(phoneCallReqYQVO.getAsrtext());
			}
			if (StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex()) && matcher.matches() && StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex2()) && matcher2.matches() \|\| StringUtils.isEmpty(ivrLibaExtemplatescript.getSelfRegex()) && StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex2()) && matcher2.matches() \|\| StringUtils.isEmpty(ivrLibaExtemplatescript.getSelfRegex2()) && StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex()) && matcher.matches()) {
			//将通用库匹配的，放到返回值中
			// phoneCallBackYQVO.setValue(phoneCallBackYQVO.getValue() + ivrLibaExtemplatescript.getSwitchText());
			phoneCallBackYQVO.setCommonValue(ivrLibaExtemplatescript.getSwitchText());
			les = ivrLibaExtemplatescript;
			}
			break;
			}
			if (ObjectUtils.isNotEmpty(les)) {
			//对匹配的结果处理一下(看看是不是需要挂机)
			if (les.getIsEnd() != null && les.getIsEnd() == 1) {
			ServiceSubtask ss = new ServiceSubtask();
			ss.setId(serviceSubtask.getId());
			ss.setSendstate(6L);
			ss.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(ss);
			//可以挂机了
			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() + les.getSwitchText());
			//将结果写进detail表
			ServiceSubTaskDetailReq serviceSubTaskDetailReq = new ServiceSubTaskDetailReq();
			List<ServiceSubtaskDetail> serviceSubtaskDetailList = new ArrayList<>();
			ivrTaskTemplateScriptVO.setExtemplateText(les.getSwitchText());
			serviceSubtaskDetailList.add(getServiceSubtaskDetail(phoneCallReqYQVO, ivrTaskTemplateScriptVO, serviceSubtask, ivrTaskTemplate));
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			return phoneCallBackYQVO;
			}
			}
			}

			//如果是文本回调
			//根据问题ID获取该问题的类型
			if (ivrTaskTemplateScriptVO.getScriptType().equals("1")) {
			//用来标记，是否有匹配上的
			Integer flag = 0;
			//是选择题
			for (int j = 0; j < ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList().size(); j++) {
			log.error("phoneCallReqYQVO.getAsrtext()的值为：{}", phoneCallReqYQVO.getAsrtext());
			if (StringUtils.isEmpty(phoneCallReqYQVO.getAsrtext())) {
			continue;
			}
			//包含
			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()) {
			//说明匹配正确了
			//这里应该先判断类型，去再修改，设置IsUserOperation是单选题的改法
			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);
			}
			}
			serviceSubtaskDetailList.add(serviceSubtaskDetail);
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			//判断一下，这个选项结果是不是还有继续问下去的必要，例如选项结果是别人不想继续回答问题，就要结束掉
			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());
			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(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);
			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);
			saveQuestionAnswerPhone(ssdReq);
			return phoneCallBackYQVO;
			}

			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (script.getSort() == nextQuestion.intValue()) {
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = script.getScriptContent();
			log.error("下一题问题：{}", scriptContent);
			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);
			//设置结束语
			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 {
			//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);
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			}
			continue;
			}
			}
			//都没有匹配到
			if (StringUtils.isEmpty(phoneCallBackYQVO.getValue())) {
			Integer count = null;
			Object countObj = redisCache.getCacheObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			if (ObjectUtils.isNotEmpty(countObj)) count = (Integer) countObj;
			if (count != null && count >= ivrTaskTemplate.getMateNum()) {
			//如果count已经大于或等于没有匹配次数
			if (ivrTaskTemplateScriptVO.getBranchFlag().equals("0") && ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getBranchFlag().equals("0") && ivrTaskTemplateScriptVO.getNextScriptno() == 0 \|\| ivrTaskTemplateScriptVO.getBranchFlag().equals("1") && ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getBranchFlag().equals("1") && ivrTaskTemplateScriptVO.getNextScriptno() == 0) {
			//如果是最后一道题，或者没有下一题了，就直接挂机
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			if (StringUtils.isNotEmpty(phoneCallBackYQVO.getValue()))
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + phoneCallBackYQVO.getValue() + serviceTask1.getJsy());
			else 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(BigDecimal.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);

			//在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());
			redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			// return phoneCallBackYQVO;
			} else {
			//根据ivrTaskTemplateScriptVO.getNextScriptno()获取下一题进行提问
			for (IvrTaskTemplateScript script : ivrTaskTemplateScripts) {
			if (script.getSort() == ivrTaskTemplateScriptVO.getNextScriptno().intValue()) {
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = 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(script.getScore()).doubleValue();

			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);
			}
			}
			}
			} else {
			if (count == null)
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid(), 1, 120, TimeUnit.MINUTES);
			else
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid(), count + 1, 120, TimeUnit.MINUTES);

			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setValue(ivrTaskTemplateScriptVO.getNoMatchText() + getObject(serviceSubtask, ivrTaskTemplateScriptVO.getScriptContent()));
			}
			}

			} else {
			//不是选择题,直接记录答案，将结果写到detail中
			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);
			serviceSubTaskDetailReq.setServiceSubtaskDetailList(serviceSubtaskDetailList);
			saveQuestionAnswerPhone(serviceSubTaskDetailReq);
			// String xh = idSort.split("-")[1];

			//如果选项分支为1的话，则需要根据问题上的nextScriptno进行跳转
			//问答题没有跳转
			if (ivrTaskTemplateScriptVO.getNextScriptno() != null && ivrTaskTemplateScriptVO.getNextScriptno() != 0) {
			for (IvrTaskTemplateScript ivrTaskTemplateScript1 : ivrTaskTemplateScripts) {
			if (ivrTaskTemplateScriptVO.getNextScriptno().intValue() == ivrTaskTemplateScript1.getSort()) {
			phoneCallBackYQVO.setType("text");
			phoneCallBackYQVO.setSilent_interval(ivrTaskTemplate.getSilencetime().intValue());
			String scriptContent = ivrTaskTemplateScript1.getScriptContent();
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + getObject(serviceSubtask, scriptContent));
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid().trim() + "&&" + "mate" + "&&" + phoneCallReqYQVO.getUuid());
			redisCache.setCacheObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone(), ivrTaskTemplateScript1.getId().toString());

			//更新一下分数
			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();
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "SCORE", score, 120, TimeUnit.MINUTES);

			}
			}
			} else if (ivrTaskTemplateScriptVO.getNextScriptno() == null \|\| ivrTaskTemplateScriptVO.getNextScriptno() == 0) {
			//没有下一题了，就结束了
			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(BigDecimal.valueOf(score));
			serviceSubtask.setFinishtime(new Date());
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtask.setSendstate(6L);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);

			//去redis中，把该子任务ID删除
			Long id = serviceSubtask.getId();
			Map<String, String> map = delRedisValue(null, id.toString());
			redisCache.setCacheObject(map.get("cacheName"), map.get("val"));
			//在redis中保存一下结束语，在调用挂电话的方法时删除
			redisCache.setCacheObject(phoneCallReqYQVO.getUuid() + "- jsy", serviceTask1.getJsy(), 120, TimeUnit.MINUTES);
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			}
			}
			}
			log.error("phoneCallBackYQVO的返回值是：{}", phoneCallBackYQVO);
			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()) {
			for (String key : map.keySet()) {
			scriptContent = scriptContent.replace(key, StringUtils.isNotEmpty(map.get(key)) ? map.get(key) : "");
			}
			}
			scriptContent = scriptContent.replace("${name}", StringUtils.isNotEmpty(serviceSubtask.getSendname()) ? serviceSubtask.getSendname() : "");
			scriptContent = scriptContent.replace("${dzz}", StringUtils.isNotEmpty(serviceSubtask.getAddr()) ? serviceSubtask.getAddr() : "");
			scriptContent = scriptContent.replace("${phone}", StringUtils.isNotEmpty(serviceSubtask.getTelcode()) ? serviceSubtask.getTelcode() : "");

			return scriptContent;
			}


			/**
			* 获取任务里的通配符
			*
			* @param taskId
			* @return
			*/
			private Map<String, Map<String, String>> getParam(Long taskId) {
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(taskId);
			ObjectMapper objectMapper = new ObjectMapper();
			Map<String, Map<String, String>> serviceTaskMap = null;
			try {
			serviceTaskMap = objectMapper.readValue(serviceTask.getTextParam(), Map.class);
			} catch (JsonProcessingException e) {
			e.printStackTrace();
			}
			return serviceTaskMap;
			}

			private Map<String, String> delRedisValue(String cache, String id) {
			id = "," + id + ",";
			String val = "";
			String cacheName = "";
			Map<String, String> map = new HashMap<>();

			if (StringUtils.isNotEmpty(cache)) {
			val = redisCache.getCacheObject(cache);
			if (!StringUtils.isEmpty(val)) {
			if (val.contains(id)) {
			val = val.replaceAll(id, "");
			}
			}
			map.put("val", val);
			map.put("cacheName", cache);
			return map;
			}

			for (int i = 0; i < 6; i++) {
			val = redisCache.getCacheObject("cache-0" + i);
			if (!StringUtils.isEmpty(val)) {
			if (val.contains(id)) {
			val = val.replaceAll(id, "");
			map.put("val", val);
			map.put("cacheName", "cache-0" + i);
			}
			}
			}
			return map;
			}


			/**
			* 雨绮任务拉取
			*
			* @return
			*/
			@Override
			public List<PullTaskVO> taskPull() {
			//pullTaskVOList用于数据返回
			List<PullTaskVO> pullTaskVOList = new ArrayList<>();
			String value0 = redisCache.getCacheObject("cache-0");
			log.error("任务拉取value0的值是多少：{}", value0);
			// cache-0为立即发起的,其它的先推迟
			if (!StringUtils.isEmpty(value0)) {
			pullTaskVOList = getPullTaskList(value0, "cache-0");
			//将cache-0的数据，转移到cache-00中
			redisCache.deleteObject("cache-00");
			String cache00 = redisCache.getCacheObject("cache-00");
			if (!StringUtils.isEmpty(cache00))
			redisCache.setCacheObject("cache-00", cache00 + "," + value0, 120, TimeUnit.MINUTES);
			else redisCache.setCacheObject("cache-00", value0, 120, TimeUnit.MINUTES);
			redisCache.deleteObject("cache-0");
			} else {
			for (int i = 1; i < 6; i++) {
			//取出从cache-1 到 cache-5的第一个子任务信息
			String value = redisCache.getCacheObject("cache-" + i);
			if (StringUtils.isEmpty(value)) continue;
			List<PullTaskVO> pullTaskVOList2 = getPullTaskList(value, "cache-" + i);
			if (CollectionUtils.isNotEmpty(pullTaskVOList2) && pullTaskVOList2.size() > 0) {
			pullTaskVOList.addAll(pullTaskVOList2);
			}
			//将cache-i的数据，转移不对劲cache-0i中
			String cache0i = redisCache.getCacheObject("cache-0" + i);
			if (!StringUtils.isEmpty(cache0i)) redisCache.setCacheObject("cache-0" + i, cache0i + "," + value);
			else redisCache.setCacheObject("cache-0" + i, value);
			redisCache.deleteObject("cache-" + i);
			}
			}
			if (CollectionUtils.isNotEmpty(pullTaskVOList)) {
			//给回调参数赋值
			for (PullTaskVO pullTaskVO : pullTaskVOList) {
			pullTaskVO.setAsrcallback(ASRCallBackPath);
			}
			}
			return pullTaskVOList;
			}


			private List<PullTaskVO> getPullTaskList(String subIds, String cacheName) {
			log.error("任务拉取subIds的值是多少：{}", subIds);
			//pullTaskVOList用于数据返回
			List<PullTaskVO> pullTaskVOList = new ArrayList<>();
			//newValue0用于保存没有处理的子任务
			String newValue0 = "";
			//根据,获取子任务的ID
			String[] split = subIds.split(",,");
			for (int i = 0; i < split.length; i++) {
			if (cacheName.equals("cache-0") && i < 5 \|\| !cacheName.equals("cache-0") && i < 1) {
			PullTaskVO pullTaskVO = new PullTaskVO();
			String subId = split[i].trim().replace(",", "");
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(subId));
			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			IvrTaskTemplate ivrTaskTemplate = ivrTaskTemplateService.selectIvrTaskTemplateByID(serviceSubtask.getTemplateid());
			if (ObjectUtils.isEmpty(ivrTaskTemplate)) continue;
			//通过任务模板中的"第一次问题编号"获取第一个问题;
			IvrTaskTemplateScript ivrTaskTemplateScript = null;
			IvrTaskTemplateScript ivrTaskTemplateScript1 = new IvrTaskTemplateScript();
			ivrTaskTemplateScript1.setTemplateID(ivrTaskTemplate.getId());
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript1);
			aa:
			for (IvrTaskTemplateScript ivrTaskTemplateScript2 : ivrTaskTemplateScripts) {
			if (ivrTaskTemplate.getFirstQuestionNum() == Long.valueOf(ivrTaskTemplateScript2.getSort())) {
			ivrTaskTemplateScript = ivrTaskTemplateScript2;
			break aa;
			}
			}
			//如果ivrTaskTemplateScript为空，也就没有往下执行的必要了
			if (ObjectUtils.isEmpty(ivrTaskTemplateScript)) return null;
			//获取通配符匹配过后的问题
			String scrContent = getObject(serviceSubtask, ivrTaskTemplateScript.getScriptContent());
			String kcb = serviceTask.getKcb() + "," + scrContent;
			// String kcb = ivrTaskTemplate.getRevisitBefore();

			//封装返回数据
			//taskId = 子任务ID + 问题ID +问题序号
			pullTaskVO.setTaskid(subId);
			pullTaskVO.setAppkey(app_key_yq);
			pullTaskVO.setSections(LocalTime.now().format(DateTimeFormatter.ofPattern("hh:mm")) + "-" + LocalTime.now().plusMinutes(1).format(DateTimeFormatter.ofPattern("hh:mm")));
			pullTaskVO.setPhones(serviceSubtask.getPhone());
			pullTaskVO.setPrologue(kcb);
			if (cacheName.equals("cache-0")) pullTaskVO.setDisplayNo("2");
			else pullTaskVO.setDisplayNo("2");
			pullTaskVOList.add(pullTaskVO);
			redisCache.setCacheObject(subId.trim() + "-" + serviceSubtask.getPhone().trim(), ivrTaskTemplateScript.getId().toString(), 120, TimeUnit.MINUTES);
			// redisCache.setCacheObject(subId.trim() + "-" + serviceSubtask.getPhone().trim() + "-firstSort", 1, 120, TimeUnit.MINUTES);
			} else {
			if (StringUtils.isEmpty(newValue0)) {
			newValue0 = "," + split[i].trim() + ",";
			} else {
			newValue0 = newValue0 + "," + split[i].trim() + ",";
			}
			redisCache.setCacheObject(cacheName, newValue0);
			}
			}

			return pullTaskVOList;
			}


			//下面的代码不能删除，上面的方法只是配合电话端联调用的，
			// @Override
			@@ -759,27 +1655,99 @@
			// }

			@Override
			public Integer saveQuestionAnswer(ServiceSubTaskDetailReq serviceSubTaskDetailReq) {
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			Long tid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskDetailReq.getParam1(), pri_key));
			Long pid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskDetailReq.getParam2(), pri_key));
			ServiceSubtask ivrTaskSingle = new ServiceSubtask();
			ivrTaskSingle.setTaskid(tid);
			ivrTaskSingle.setPatid(pid);
			List<ServiceSubtask> selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(ivrTaskSingle);
			if (CollectionUtils.isEmpty(selectServiceSubtaskList) \|\| selectServiceSubtaskList.size() == 0) {
			log.error("报错了，selectServiceSubtaskList数据为空了：{}", ivrTaskSingle);
			return 0;
			}
			public Integer saveQuestionAnswerPhone(ServiceSubTaskDetailReq serviceSubTaskDetailReq) {
			int i = 0;
			//随访
			for (ServiceSubtaskDetail serviceSubtaskDetail : serviceSubTaskDetailReq.getServiceSubtaskDetailList()) {
			serviceSubtaskDetail.setSubId(selectServiceSubtaskList.get(0).getId());
			serviceSubtaskDetail.setId(UUID.randomUUID().toString());
			serviceSubtaskDetail.setCreateTime(new Date());
			i = ivrTaskcalldetailMapper.insertServiceSubtaskDetail(serviceSubtaskDetail);
			if (StringUtils.isNotEmpty(serviceSubTaskDetailReq.getParam1())) {
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			Long tid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskDetailReq.getParam1(), pri_key));
			Long pid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskDetailReq.getParam2(), pri_key));
			ServiceSubtaskVO ivrTaskSingle = new ServiceSubtaskVO();
			ivrTaskSingle.setTaskid(tid);
			ivrTaskSingle.setPatid(pid);
			List<ServiceSubtask> selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(ivrTaskSingle);
			if (CollectionUtils.isEmpty(selectServiceSubtaskList) \|\| selectServiceSubtaskList.size() == 0) {
			log.error("报错了，selectServiceSubtaskList数据为空了：{}", ivrTaskSingle);
			return 0;
			}
			//随访
			for (ServiceSubtaskDetail serviceSubtaskDetail : serviceSubTaskDetailReq.getServiceSubtaskDetailList()) {
			serviceSubtaskDetail.setSubId(selectServiceSubtaskList.get(0).getId());
			serviceSubtaskDetail.setId(UUID.randomUUID().toString());
			serviceSubtaskDetail.setCreateTime(new Date());
			i = serviceSubtaskDetailMapper.insertServiceSubtaskDetail(serviceSubtaskDetail);
			}
			} else {
			if (serviceSubTaskDetailReq != null && CollectionUtils.isNotEmpty(serviceSubTaskDetailReq.getServiceSubtaskDetailList())) {
			for (ServiceSubtaskDetail serviceSubtaskDetail : serviceSubTaskDetailReq.getServiceSubtaskDetailList()) {
			serviceSubtaskDetail.setCreateTime(new Date());
			//先根据子任务id,任务ID和问题序号查询一下，该问题是否已经有值，如果有值，直接修改，如果为空，直接插入
			ServiceSubtaskDetail ssd = new ServiceSubtaskDetail();
			ssd.setSubId(serviceSubtaskDetail.getSubId());
			ssd.setTaskid(serviceSubtaskDetail.getTaskid());
			ssd.setTemplatequestionnum(serviceSubtaskDetail.getTemplatequestionnum());
			List<ServiceSubtaskDetail> serviceSubtaskDetails = serviceSubtaskDetailMapper.selectServiceSubtaskDetailList(ssd);
			if (CollectionUtils.isNotEmpty(serviceSubtaskDetails) && StringUtils.isNotEmpty(serviceSubtaskDetails.get(0).getMatchedtext())) {
			serviceSubtaskDetail.setId(serviceSubtaskDetails.get(0).getId());
			serviceSubtaskDetailMapper.updateServiceSubtaskDetail(serviceSubtaskDetail);
			} else {
			i = serviceSubtaskDetailMapper.insertServiceSubtaskDetail(serviceSubtaskDetail);
			}
			}
			}
			}
			return i;
			}

			@Override
			public Integer recordAccept(PhoneCallRecordVO phoneCallRecordVO) {
			Object cacheObject = redisCache.getCacheObject("recordAccept-hungup");
			if (ObjectUtils.isNotEmpty(cacheObject) && String.valueOf(cacheObject).equals("2")) {
			// if (phoneCallRecordVO.getAnswered() != null && phoneCallRecordVO.getAnswered() == true) {
			log.error("有人接电话了，并且完了");
			//说明有人接了
			int startIndex = phoneCallRecordVO.getRecord_path().indexOf("voice") + "voice".length() + 1; // 加1是跳过/符号
			int endIndex = phoneCallRecordVO.getRecord_path().lastIndexOf("/");
			String result = phoneCallRecordVO.getRecord_path().substring(startIndex, endIndex);
			//下载文件
			ftpService.downloadFolder("/" + LocalDate.now().toString(), profile + "/upload/vadio/voice/" + LocalDate.now().toString());
			} else if (phoneCallRecordVO.getHangup_cause().equals("NO_USER_RESPONSE") \|\| ObjectUtils.isNotEmpty(cacheObject) && !String.valueOf(cacheObject).equals("2")) {
			//无人接听
			getSmsCompensate(Long.valueOf(phoneCallRecordVO.getTaskid()));
			}
			redisCache.deleteObject("recordAccept-hungup");
			return 1;
			}

			@Override
			public List<ServiceSubtaskCount> getSfFzInfoEveryMonth(ServiceSubtaskCountReq serviceSubtaskCountReq) {
			if (serviceSubtaskCountReq.getUserId() == null) {
			Long userId = SecurityUtils.getUserId();
			serviceSubtaskCountReq.setUserId(userId);
			}
			if (serviceSubtaskCountReq.getStartTime() == null) {
			LocalDate of = LocalDate.of(LocalDate.now().getYear(), 1, 1);
			serviceSubtaskCountReq.setStartTime(Date.from(of.atStartOfDay(ZoneId.systemDefault()).toInstant()));
			}
			if (serviceSubtaskCountReq.getEndTime() == null) {
			serviceSubtaskCountReq.setEndTime(new Date());
			}
			List<ServiceSubtaskCount> sfFzInfoEveryMonth = serviceSubtaskMapper.getSfFzInfoEveryMonth(serviceSubtaskCountReq);
			List<ServiceSubtaskCount> result = sfFzInfoEveryMonth.stream().collect(Collectors.groupingBy(ServiceSubtaskCount::getMonth, Collectors.groupingBy(ServiceSubtaskCount::getServiceType, Collectors.summingLong(ServiceSubtaskCount::getCount)))).entrySet().stream().flatMap(monthEntry -> monthEntry.getValue().entrySet().stream().map(typeEntry -> new ServiceSubtaskCount(monthEntry.getKey(), typeEntry.getKey(), typeEntry.getValue()))).collect(Collectors.toList());

			List<ServiceSubtaskCount> result2 = new ArrayList<>();
			//根据服务类型进行筛选
			if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getServiceType())) {
			for (ServiceSubtaskCount serviceSubtaskCount : result) {
			for (Long type : serviceSubtaskCountReq.getServiceType()) {
			if (type == serviceSubtaskCount.getServiceType()) {
			result2.add(serviceSubtaskCount);
			}
			}
			}
			} else {
			result2 = result;
			}
			return result2;
			}

			private IvrTaskTemplateScriptVO getNextQuestion(List<IvrTaskTemplateScriptVO> IvrTaskTemplateScriptVOList, IvrTaskTemplateScriptVO IvrTaskTemplateScriptVO) {
			@@ -793,4 +1761,77 @@
			return null;
			}

			private ServiceSubtaskDetail getServiceSubtaskDetail(PhoneCallReqYQVO phoneCallReqYQVO, IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO, ServiceSubtask serviceSubtask, IvrTaskTemplate ivrTaskTemplate) {
			ServiceSubtaskDetail serviceSubtaskDetail = new ServiceSubtaskDetail();
			serviceSubtaskDetail.setSubId(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			ServiceSubtask serviceSubtask1 = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			if (serviceSubtask1 != null) {
			serviceSubtaskDetail.setTaskid(serviceSubtask1.getTaskid());
			serviceSubtaskDetail.setPatid(serviceSubtask1.getPatid());
			}
			serviceSubtaskDetail.setUuid(phoneCallReqYQVO.getUuid());
			serviceSubtaskDetail.setPhone(phoneCallReqYQVO.getPhone());
			serviceSubtaskDetail.setOperate(serviceSubtask.getCreateBy());
			serviceSubtaskDetail.setDisplayno(phoneCallReqYQVO.getPhone());
			serviceSubtaskDetail.setAssigntime(System.currentTimeMillis());
			serviceSubtaskDetail.setStarttime(System.currentTimeMillis());
			serviceSubtaskDetail.setAnswertime(System.currentTimeMillis());
			serviceSubtaskDetail.setAsrtext("无应答");
			if (StringUtils.isNotEmpty(phoneCallReqYQVO.getAsrtext()))
			serviceSubtaskDetail.setAsrtext(phoneCallReqYQVO.getAsrtext());
			serviceSubtaskDetail.setBeginTime(System.currentTimeMillis());
			serviceSubtaskDetail.setEndTime(System.currentTimeMillis());
			serviceSubtaskDetail.setSentEnd(1L);
			serviceSubtaskDetail.setTemplateid(ivrTaskTemplate.getId().toString());
			serviceSubtaskDetail.setTemplatequestionnum(ivrTaskTemplateScriptVO.getId());
			serviceSubtaskDetail.setQuestiontext(ivrTaskTemplateScriptVO.getScriptContent());
			serviceSubtaskDetail.setQuestionvoice(phoneCallReqYQVO.getRecordpath());
			serviceSubtaskDetail.setCategoryname(ivrTaskTemplateScriptVO.getScriptType());
			serviceSubtaskDetail.setTargetoptions(ivrTaskTemplateScriptVO.getTargetOptions());
			serviceSubtaskDetail.setExtemplateText(ivrTaskTemplateScriptVO.getExtemplateText());

			int i = 1;
			for (IvrTaskTemplateTargetoption ivrTaskTemplateTargetoption : ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList()) {
			if (ivrTaskTemplateTargetoption.getIsUserOperation() == 1) {
			serviceSubtaskDetail.setMatchedtext(ivrTaskTemplateTargetoption.getTargetvalue());
			}
			serviceSubtaskDetail.setTargetvalue(StringUtils.isEmpty(serviceSubtaskDetail.getTargetvalue()) ? ivrTaskTemplateTargetoption.getTargetvalue() : serviceSubtaskDetail.getTargetvalue() + "&" + ivrTaskTemplateTargetoption.getTargetvalue());
			}

			serviceSubtaskDetail.setAddtime(new Date());
			serviceSubtaskDetail.setIsupload(0L);
			serviceSubtaskDetail.setUploadTime(new Date());
			serviceSubtaskDetail.setDelFlag("0");
			serviceSubtaskDetail.setValueType(ivrTaskTemplateScriptVO.getScriptType());
			return serviceSubtaskDetail;
			}

			private void getSmsCompensate(Long subTaskId) {
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(subTaskId);
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			String taskId = rsaPublicKeyExample.encryptedData(serviceSubtask.getTaskid().toString(), pub_key);
			String patid = rsaPublicKeyExample.encryptedData(serviceSubtask.getPatid().toString(), pub_key);
			ServiceOutPath serviceOutPath = new ServiceOutPath();
			serviceOutPath.setParam1(taskId);
			serviceOutPath.setParam2(patid);
			serviceOutPath.setCreateTime(new Date());
			iServiceOutPathService.insertServiceOutPath(serviceOutPath);
			//转成16进制
			String format = String.format("%03X", serviceOutPath.getId());
			serviceOutPath.setRadix(format);
			serviceOutPath.setUpdateTime(new Date());
			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());
			String result = HttpUtil.postJsonRequest(xhsmsPath, new Gson().toJson(map));
			redisCache.setCacheObject(subTaskId + "recordAccept-hungup", "1", 10, TimeUnit.MINUTES);
			if (StringUtils.isNotEmpty(serviceSubtask.getRemark()))
			serviceSubtask.setRemark("电话发送拒接,短信补偿发送成功");
			else serviceSubtask.setRemark("短信补偿发送成功");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			}
			}