smartor.git - Gitblit

			@@ -5,6 +5,7 @@
			import com.fasterxml.jackson.databind.ObjectMapper;
			import com.google.gson.Gson;
			import com.ruoyi.common.core.redis.RedisCache;
			import com.ruoyi.common.dx.MessageSend;
			import com.ruoyi.common.exception.base.BaseException;
			import com.ruoyi.common.utils.*;
			import com.smartor.common.FtpService;
			@@ -12,11 +13,13 @@
			import com.smartor.domain.*;
			import com.smartor.mapper.*;
			import com.smartor.service.*;
			import com.sun.org.apache.bcel.internal.generic.NEW;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.collections4.CollectionUtils;
			import org.apache.commons.lang3.ObjectUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.cache.annotation.Cacheable;
			import org.springframework.data.redis.core.ListOperations;
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.stereotype.Service;
			@@ -26,8 +29,8 @@
			import java.math.RoundingMode;
			import java.text.DecimalFormat;
			import java.text.SimpleDateFormat;
			import java.time.Duration;
			import java.time.LocalDate;
			import java.time.LocalDateTime;
			import java.time.LocalTime;
			import java.time.ZoneId;
			import java.time.format.DateTimeFormatter;
			@@ -48,6 +51,9 @@
			public class ServiceSubtaskServiceImpl implements IServiceSubtaskService {
			@Autowired
			private ServiceSubtaskMapper serviceSubtaskMapper;

			@Autowired
			private ServiceSubtaskPreachformMapper serviceSubtaskPreachformMapper;

			@Autowired
			private ServiceSubtaskDetailMapper serviceSubtaskDetailMapper;
			@@ -75,6 +81,9 @@

			@Autowired
			private IvrLibaExtemplatescriptMapper ivrLibaExtemplatescriptMapper;

			@Autowired
			private ISvyTaskTemplateScriptService svyTaskTemplateScriptService;

			@Autowired
			private IIvrTaskTemplateService ivrTaskTemplateService;
			@@ -146,6 +155,11 @@
			return serviceSubtaskMapper.selectServiceSubtaskById(id);
			}

			@Override
			public List<ServiceSubtask> selectServiceSubtaskByDiagname(ServiceSubtask serviceSubtask) {
			return serviceSubtaskMapper.selectServiceSubtaskByDiagname(serviceSubtask);
			}

			/**
			* 查询单一任务（随访）列表
			*
			@@ -170,9 +184,20 @@

			ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			if (CollectionUtils.isEmpty(list) \|\| list.size() == 0) {
			return DtoConversionUtils.sourceToTarget(serviceTask, ServiceTaskVO.class);
			}
			ServiceTaskVO serviceTaskVO = DtoConversionUtils.sourceToTarget(serviceTask, ServiceTaskVO.class);
			ObjectMapper objectMapper = new ObjectMapper();
			try {
			List<Map<String, Object>> mapList = objectMapper.readValue(serviceTask.getPreachformDesc(), List.class);
			serviceTaskVO.setPreachformList(mapList);
			//
			// String result = mapList.stream().map(mapList1 -> mapList1.get("preachform")).map(String::valueOf).collect(Collectors.joining(","));
			// serviceTaskVO.setPreachform(result);
			} catch (JsonProcessingException e) {
			e.printStackTrace();
			}

			return serviceTaskVO;
			}

			//将查出来的数据倒入ServiceSubtaskVO中
			ServiceTaskVO serviceTaskVO = DtoConversionUtils.sourceToTarget(serviceTask, ServiceTaskVO.class);
			@@ -253,6 +278,23 @@
			patTaskRelevance.setNurseName(serviceSubtask1.getNurseName());
			patTaskRelevances.add(patTaskRelevance);
			}

			//获取该患者所有的执行状态
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setTaskid(serviceTask.getTaskid());
			serviceSubtaskPreachform.setSubid(serviceSubtask1.getId());
			List<ServiceSubtaskPreachform> serviceSubtaskPreachformList = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform);
			List<Map<String, Object>> resultList = serviceSubtaskPreachformList.stream().map(item -> {
			Map<String, Object> map = new HashMap<>();
			map.put("sort", item.getSort());
			map.put("preachform", item.getPreachform());
			map.put("compensateTime", item.getCompensateTime());
			return map;
			}).collect(Collectors.toList());
			serviceTaskVO.setPreachformList(resultList);

			// String result = resultList.stream().map(mapList1 -> mapList1.get("preachform")).map(String::valueOf).collect(Collectors.joining(","));
			// serviceTaskVO.setPreachform(result);
			}

			serviceTaskVO.setPatTaskRelevances(patTaskRelevances);
			@@ -297,7 +339,8 @@
			if (serviceSubtask.getSendstate() >= 3L \|\| serviceSubtask.getSendstate() == 1L) yfs = yfs + 1;
			if (serviceSubtask.getSendstate() == 2L) dsf = dsf + 1;
			if (serviceSubtask.getSendstate() == 1L) blq = blq + 1;
			if (serviceSubtask.getExcep().equals("1")) yc = yc + 1;
			if (StringUtils.isNotEmpty(serviceSubtask.getExcep()) && !serviceSubtask.getExcep().equals("0"))
			yc = yc + 1;
			}
			map.put("wzx", wzx);
			map.put("ysf", ysf);
			@@ -339,15 +382,18 @@

			if (patMedInhospList.size() > 0) {
			serviceSubtask1.setIsVisitAgain(2);
			serviceSubtask1.setRemark(serviceSubtask1.getRemark()+";患者再入院了");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
			return "无需再次随访，患者再入院了";
			} else if (serviceSubtask1.getSendstate() == 4L) {
			serviceSubtask1.setIsVisitAgain(2);
			serviceSubtask1.setRemark(serviceSubtask1.getRemark()+";无需再次随访，任务被标记不在执行");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
			return "无需再次随访，任务被标记不在执行";
			} else if (StringUtils.isNotEmpty(patArchive.getNotrequiredFlag()) && patArchive.getNotrequiredFlag().equals("1")) {
			serviceSubtask1.setIsVisitAgain(2);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
			serviceSubtask1.setRemark(serviceSubtask1.getRemark()+";无需再次随访，患者被标记不需要被服务");
			return "无需再次随访，患者被标记不需要被服务";
			} else if (ObjectUtils.isNotEmpty(serviceSubtask1.getIsVisitAgain()) && serviceSubtask1.getIsVisitAgain() == 2) {
			return "无需再次随访，该任务已经再次随访过了";
			@@ -414,6 +460,16 @@
			throw new BaseException("任务入参为空，请检查入参");
			}
			ServiceTask serviceTask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceTask.class);
			if (CollectionUtils.isEmpty(serviceTaskVO.getPreachformList())) throw new BaseException("任务的发送方式为空");
			//将preachfromList放到serviceTask中的preachfrom中
			ObjectMapper mapper = new ObjectMapper();
			try {
			String preachformList = mapper.writeValueAsString(serviceTaskVO.getPreachformList());
			serviceTask.setPreachformDesc(preachformList);
			} catch (JsonProcessingException e) {
			e.printStackTrace();
			}

			serviceTask.setTextParam(JSON.toJSONString(serviceTaskVO.getTextParam()));
			if (serviceTaskVO.getIsoperation() != null && serviceTaskVO.getIsoperation() == 1) {
			//新增模板信息
			@@ -460,7 +516,7 @@
			ServiceTaskdiag serviceTaskdiag = new ServiceTaskdiag();
			serviceTaskdiag.setTaskId(serviceTask.getTaskid());
			serviceTaskdiag.setTaskName(serviceTask.getTaskName());
			serviceTaskdiag.setLongtask(0L);
			serviceTaskdiag.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			if (serviceTaskVO.getLongTask() == 1) serviceTaskdiag.setLongtask(1L);
			serviceTaskdiag.setIcd10code(serviceTaskVO.getIcd10code());
			serviceTaskdiag.setIcd10name(serviceTaskVO.getIcd10name());
			@@ -481,11 +537,10 @@
			serviceTaskoper.setOpdesc(serviceTaskVO.getOpdesc());
			serviceTaskoper.setTaskId(serviceTask.getTaskid());
			serviceTaskoper.setTaskName(serviceTask.getTaskName());
			serviceTaskoper.setLongtask(0L);
			serviceTaskoper.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			serviceTaskoper.setGuid(serviceTask.getGuid());
			serviceTaskoper.setOrgid(serviceTask.getOrgid());
			serviceTaskoper.setCreateTime(new Date());
			if (serviceTaskVO.getLongTask() == 1) serviceTaskoper.setLongtask(1L);
			if (StringUtils.isNotEmpty(serviceTaskVO.getOpcode())) {
			String[] opcodes = serviceTaskVO.getOpcode().split(",");
			for (String opcode : opcodes) {
			@@ -500,8 +555,7 @@
			serviceTaskdept.setTaskId(serviceTask.getTaskid());
			serviceTaskdept.setTaskName(serviceTask.getTaskName());
			serviceTaskdept.setOrgid(serviceTask.getOrgid());
			serviceTaskdept.setLongtask(0L);
			if (serviceTaskVO.getLongTask() == 1) serviceTaskdept.setLongtask(1L);
			serviceTaskdept.setLongtask(Long.valueOf(serviceTaskVO.getLongTask()));
			if (StringUtils.isNotEmpty(serviceTaskVO.getDeptcode())) {
			String[] deptcodes = serviceTaskVO.getDeptcode().split(",");
			for (String deptCode : deptcodes) {
			@@ -522,17 +576,20 @@
			}
			}
			}
			if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1 && serviceTaskVO.getPatCycle() == 0L) {
			Map<String, Integer> map = new HashMap<>();
			map.put("taskId", serviceTask.getTaskid().intValue());
			return map;
			}
			//长期任务，也允许加人了
			// if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1 && serviceTaskVO.getPatCycle() == 0L) {
			// Map<String, Integer> map = new HashMap<>();
			// map.put("taskId", serviceTask.getTaskid().intValue());
			// return map;
			// }

			//将任务信息放到服务表中
			ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceSubtask.class);
			serviceSubtask.setTaskid(serviceTask.getTaskid().longValue());
			serviceSubtask.setTemplatename(tempName);
			serviceSubtask.setTemplateid(tempid);
			serviceSubtask.setLibtemplateid(ObjectUtils.isEmpty(serviceTaskVO.getLibtemplateid()) ? null : Long.valueOf(serviceTaskVO.getLibtemplateid()));
			serviceSubtask.setLibtemplatename(serviceTaskVO.getLibtemplatename());
			//新增
			if (CollectionUtils.isNotEmpty(serviceTaskVO.getPatTaskRelevances())) {
			for (PatTaskRelevance patTaskRelevance : serviceTaskVO.getPatTaskRelevances()) {
			@@ -545,6 +602,7 @@
			serviceSubtask.setAddr(patTaskRelevance.getAddr());
			serviceSubtask.setPatid(patTaskRelevance.getPatid());
			serviceSubtask.setCreateTime(DateUtils.getNowDate());
			serviceSubtask.setInhospid(patTaskRelevance.getHospid());
			serviceSubtask.setSendstate(1L);
			if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1)
			serviceSubtask.setSendstate(2L);
			@@ -565,11 +623,29 @@
			serviceSubtask.setNurseName(patTaskRelevance.getNurseName());
			serviceSubtask.setCreateBy(serviceTask.getCreateBy());
			serviceSubtask.setUpdateBy(serviceTask.getCreateBy());
			serviceSubtask.setVisitTime(patTaskRelevance.getVisitTime());
			serviceSubtask.setVisitTime(patTaskRelevance.getVisittime());
			if (serviceTaskVO.getLongTask() != null && serviceTaskVO.getLongTask() == 1)
			serviceSubtask.setLongSendTime(patTaskRelevance.getLongSendTime());
			serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			serviceSubtask.getId().intValue();

			//需要按service_task里的preachform的顺序将发送方式保存到service_subtask_preachform表中
			if (StringUtils.isNotEmpty(serviceTaskVO.getPreachformList())) {
			List<Map<String, Object>> pfList = serviceTaskVO.getPreachformList();
			for (Map<String, Object> map : pfList) {
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setSort(ObjectUtils.isEmpty(map.get("sort")) ? 0 : Long.valueOf(map.get("sort").toString()));
			serviceSubtaskPreachform.setPreachform(ObjectUtils.isEmpty(map.get("preachform")) ? "" : map.get("preachform").toString());
			serviceSubtaskPreachform.setCompensateTime(ObjectUtils.isEmpty(map.get("compensateTime")) ? "" : map.get("compensateTime").toString());
			serviceSubtaskPreachform.setTaskid(serviceTask.getTaskid());
			serviceSubtaskPreachform.setSubid(serviceSubtask.getId());
			//这个sendstate需要在数据库设置一个默认值为“1”
			serviceSubtaskPreachform.setSendstate("1");
			serviceSubtaskPreachform.setOrgid(serviceTask.getOrgid());
			serviceSubtaskPreachform.setCreateTime(new Date());
			serviceSubtaskPreachformMapper.insertServiceSubtaskPreachform(serviceSubtaskPreachform);
			}
			}
			}
			}

			@@ -579,8 +655,6 @@
			serviceTask.setSendTimeSlot(JSON.toJSONString(serviceTaskVO.getSendTimeslot()));
			//修改操作，需要将stopState状态+1
			ServiceTask serviceTask1 = serviceTaskService.selectServiceTaskByTaskid(serviceTask.getTaskid());
			// long l = serviceTask1.getStopState() + 1;
			// serviceTask.setStopState(l);
			//获取到该任务所有的服务，并从队列里删除
			ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO();
			serviceSubtaskVO.setTaskid(serviceTask1.getTaskid());
			@@ -595,9 +669,9 @@
			}
			if (CollectionUtils.isNotEmpty(serviceSubtaskList)) {
			for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
			log.info("insertOrUpdateTask需要移除的subId为：{}", serviceSubtask.getId().toString());
			log.error("sfSend需要移除的subId为：{}", serviceSubtask.getId().toString());
			serviceSubtaskMapper.deleteServiceSubtaskById(serviceSubtask.getId());
			redisCache.removeElementFromList("cache-exist", serviceSubtask.getId().toString());
			// redisCache.removeElementFromList("cache-exist", serviceSubtask.getId().toString());
			redisCache.removeElementFromList("cache-0", serviceSubtask.getId().toString());
			redisCache.removeElementFromList("cache-1", serviceSubtask.getId().toString());
			redisCache.removeElementFromList("cache-2", serviceSubtask.getId().toString());
			@@ -612,123 +686,117 @@
			serviceTask.setLongTask(serviceTaskVO.getLongTask());
			serviceTask.setUpdateTime(new Date());
			serviceTaskService.updateServiceTask(serviceTask);
			if (serviceTaskVO.getAppltype().equals("1") \|\| serviceTaskVO.getAppltype().equals("2")) {


			if (StringUtils.isNotEmpty(serviceTaskVO.getDeptcode())) {
			String[] deptcodes = serviceTaskVO.getDeptcode().split(",");
			for (String deptCode : deptcodes) {
			ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
			serviceTaskdept.setTaskId(serviceTask.getTaskid());
			serviceTaskdept.setTaskName(serviceTask.getTaskName());
			serviceTaskdept.setLongtask(0L);
			serviceTaskdept.setOrgid(serviceTaskVO.getOrgid());
			if (serviceTaskVO.getLongTask() == 1) serviceTaskdept.setLongtask(1L);
			serviceTaskdept.setDeptCode(deptCode);
			serviceTaskdept.setDeptType("1");
			serviceTaskdept.setServiceType(serviceTaskVO.getServiceType());
			ServiceTaskdept st = new ServiceTaskdept();
			st.setDeptCode(deptCode);
			st.setTaskId(serviceTask.getTaskid());
			List<ServiceTaskdept> serviceTaskdepts = serviceTaskdeptService.selectServiceTaskdeptList(st);
			if (CollectionUtils.isEmpty(serviceTaskdepts)) {
			serviceTaskdeptService.insertServiceTaskdept(serviceTaskdept);
			} else {
			serviceTaskdeptService.updateServiceTaskdept(serviceTaskdept);
			if (StringUtils.isNotEmpty(serviceTaskVO.getAppltype())) {
			if (serviceTaskVO.getAppltype().equals("1") \|\| serviceTaskVO.getAppltype().equals("2")) {
			if (StringUtils.isNotEmpty(serviceTaskVO.getDeptcode())) {
			String[] deptcodes = serviceTaskVO.getDeptcode().split(",");
			for (String deptCode : deptcodes) {
			ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
			serviceTaskdept.setTaskId(serviceTask.getTaskid());
			serviceTaskdept.setTaskName(serviceTask.getTaskName());
			serviceTaskdept.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			serviceTaskdept.setOrgid(serviceTaskVO.getOrgid());
			serviceTaskdept.setDeptCode(deptCode);
			serviceTaskdept.setDeptType("1");
			serviceTaskdept.setServiceType(serviceTaskVO.getServiceType());
			ServiceTaskdept st = new ServiceTaskdept();
			st.setDeptCode(deptCode);
			st.setTaskId(serviceTask.getTaskid());
			List<ServiceTaskdept> serviceTaskdepts = serviceTaskdeptService.selectServiceTaskdeptList(st);
			if (CollectionUtils.isEmpty(serviceTaskdepts)) {
			serviceTaskdeptService.insertServiceTaskdept(serviceTaskdept);
			} else {
			serviceTaskdeptService.updateServiceTaskdept(serviceTaskdept);
			}
			}
			}
			}
			if (StringUtils.isNotEmpty(serviceTaskVO.getLeavehospitaldistrictcode())) {
			String[] leavehospitaldistrictcodes = serviceTaskVO.getLeavehospitaldistrictcode().split(",");
			for (String districtcode : leavehospitaldistrictcodes) {
			ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
			serviceTaskdept.setTaskId(serviceTask.getTaskid());
			serviceTaskdept.setTaskName(serviceTask.getTaskName());
			serviceTaskdept.setLongtask(0L);
			serviceTaskdept.setOrgid(serviceTaskVO.getOrgid());
			if (serviceTaskVO.getLongTask() == 1) serviceTaskdept.setLongtask(1L);
			serviceTaskdept.setDeptCode(districtcode);
			serviceTaskdept.setDeptType("2");
			serviceTaskdept.setServiceType(serviceTaskVO.getServiceType());
			//先通过任务ID、部门code,判断ServiceTaskdept是否存在，不存在则新增，存在则修改
			ServiceTaskdept st = new ServiceTaskdept();
			st.setDeptCode(districtcode);
			st.setTaskId(serviceTask.getTaskid());
			List<ServiceTaskdept> serviceTaskdepts = serviceTaskdeptService.selectServiceTaskdeptList(st);
			if (CollectionUtils.isEmpty(serviceTaskdepts)) {
			serviceTaskdeptService.insertServiceTaskdept(serviceTaskdept);
			} else {
			serviceTaskdeptService.updateServiceTaskdept(serviceTaskdept);
			if (StringUtils.isNotEmpty(serviceTaskVO.getLeavehospitaldistrictcode())) {
			String[] leavehospitaldistrictcodes = serviceTaskVO.getLeavehospitaldistrictcode().split(",");
			for (String districtcode : leavehospitaldistrictcodes) {
			ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
			serviceTaskdept.setTaskId(serviceTask.getTaskid());
			serviceTaskdept.setTaskName(serviceTask.getTaskName());
			serviceTaskdept.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			serviceTaskdept.setOrgid(serviceTaskVO.getOrgid());
			serviceTaskdept.setDeptCode(districtcode);
			serviceTaskdept.setDeptType("2");
			serviceTaskdept.setServiceType(serviceTaskVO.getServiceType());
			//先通过任务ID、部门code,判断ServiceTaskdept是否存在，不存在则新增，存在则修改
			ServiceTaskdept st = new ServiceTaskdept();
			st.setDeptCode(districtcode);
			st.setTaskId(serviceTask.getTaskid());
			List<ServiceTaskdept> serviceTaskdepts = serviceTaskdeptService.selectServiceTaskdeptList(st);
			if (CollectionUtils.isEmpty(serviceTaskdepts)) {
			serviceTaskdeptService.insertServiceTaskdept(serviceTaskdept);
			} else {
			serviceTaskdeptService.updateServiceTaskdept(serviceTaskdept);
			}
			}
			}
			}
			} else if (serviceTaskVO.getAppltype().equals("3")) {
			ServiceTaskdiag serviceTaskdiag = new ServiceTaskdiag();
			serviceTaskdiag.setTaskId(serviceTask.getTaskid());
			serviceTaskdiag.setTaskName(serviceTask.getTaskName());
			if (StringUtils.isEmpty(serviceTaskVO.getIcd10code())) {
			throw new BaseException("疾病编码为空");
			}
			// serviceTaskdiag.setIcd10code(serviceTaskVO.getIcd10code());

			serviceTaskdiag.setLongtask(1L);
			serviceTaskdiag.setIcd10name(serviceTaskVO.getIcd10name());
			serviceTaskdiag.setGuid(serviceTask.getGuid());
			serviceTaskdiag.setOrgid(serviceTask.getOrgid());
			serviceTaskdiag.setUpdateTime(new Date());
			if (StringUtils.isNotEmpty(serviceTaskVO.getIcd10code())) {
			String[] icd10codes = serviceTaskVO.getIcd10code().split(",");
			for (String icdcode : icd10codes) {
			//先查询一下是否存在
			ServiceTaskdiag serviceTaskdiag2 = new ServiceTaskdiag();
			serviceTaskdiag2.setTaskId(serviceTaskVO.getTaskid());
			serviceTaskdiag2.setIcd10code(icdcode);
			List<ServiceTaskdiag> serviceTaskdiags = serviceTaskdiagService.selectServiceTaskdiagList(serviceTaskdiag2);
			serviceTaskdiag.setIcd10code(icdcode);
			log.info("----serviceTaskdiag更新的值为：{}", serviceTaskdiag);
			if (CollectionUtils.isNotEmpty(serviceTaskdiags)) {
			serviceTaskdiag.setId(serviceTaskdiags.get(0).getId());
			serviceTaskdiagService.updateServiceTaskdiag(serviceTaskdiag);
			} else {
			serviceTaskdiagService.insertServiceTaskdiag(serviceTaskdiag);
			} else if (serviceTaskVO.getAppltype().equals("3")) {
			ServiceTaskdiag serviceTaskdiag = new ServiceTaskdiag();
			serviceTaskdiag.setTaskId(serviceTask.getTaskid());
			serviceTaskdiag.setTaskName(serviceTask.getTaskName());
			if (StringUtils.isEmpty(serviceTaskVO.getIcd10code())) {
			throw new BaseException("疾病编码为空");
			}
			serviceTaskdiag.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			serviceTaskdiag.setIcd10name(serviceTaskVO.getIcd10name());
			serviceTaskdiag.setGuid(serviceTask.getGuid());
			serviceTaskdiag.setOrgid(serviceTask.getOrgid());
			serviceTaskdiag.setUpdateTime(new Date());
			if (StringUtils.isNotEmpty(serviceTaskVO.getIcd10code())) {
			String[] icd10codes = serviceTaskVO.getIcd10code().split(",");
			for (String icdcode : icd10codes) {
			//先查询一下是否存在
			ServiceTaskdiag serviceTaskdiag2 = new ServiceTaskdiag();
			serviceTaskdiag2.setTaskId(serviceTaskVO.getTaskid());
			serviceTaskdiag2.setIcd10code(icdcode);
			List<ServiceTaskdiag> serviceTaskdiags = serviceTaskdiagService.selectServiceTaskdiagList(serviceTaskdiag2);
			serviceTaskdiag.setIcd10code(icdcode);
			log.info("----serviceTaskdiag更新的值为：{}", serviceTaskdiag);
			if (CollectionUtils.isNotEmpty(serviceTaskdiags)) {
			serviceTaskdiag.setId(serviceTaskdiags.get(0).getId());
			serviceTaskdiagService.updateServiceTaskdiag(serviceTaskdiag);
			} else {
			serviceTaskdiagService.insertServiceTaskdiag(serviceTaskdiag);
			}
			}
			}
			}


			} else if (serviceTaskVO.getAppltype().equals("4")) {
			ServiceTaskoper serviceTaskoper = new ServiceTaskoper();
			if (StringUtils.isEmpty(serviceTaskVO.getOpcode())) {
			throw new BaseException("手术编码为空");
			}
			} else if (serviceTaskVO.getAppltype().equals("4")) {
			ServiceTaskoper serviceTaskoper = new ServiceTaskoper();
			if (StringUtils.isEmpty(serviceTaskVO.getOpcode())) {
			throw new BaseException("手术编码为空");
			}
			// serviceTaskoper.setOpcode(serviceTaskVO.getOpcode());
			serviceTaskoper.setOpdesc(serviceTaskVO.getOpdesc());
			serviceTaskoper.setTaskId(serviceTask.getTaskid());
			serviceTaskoper.setTaskName(serviceTask.getTaskName());
			serviceTaskoper.setLongtask(1L);
			serviceTaskoper.setGuid(serviceTask.getGuid());
			serviceTaskoper.setOrgid(serviceTask.getOrgid());
			serviceTaskoper.setCreateTime(new Date());
			if (StringUtils.isNotEmpty(serviceTaskVO.getOpcode())) {
			String[] opcodes = serviceTaskVO.getOpcode().split(",");
			for (String opcode : opcodes) {
			//先查询一下是否存在
			ServiceTaskoper serviceTaskoper2 = new ServiceTaskoper();
			serviceTaskoper2.setTaskId(serviceTaskVO.getTaskid());
			serviceTaskoper2.setOpcode(serviceTaskVO.getOpcode());
			List<ServiceTaskoper> serviceTaskopers = serviceTaskoperService.selectServiceTaskoperList(serviceTaskoper2);
			serviceTaskoper.setOpdesc(serviceTaskVO.getOpdesc());
			serviceTaskoper.setTaskId(serviceTask.getTaskid());
			serviceTaskoper.setTaskName(serviceTask.getTaskName());
			serviceTaskoper.setLongtask(Long.valueOf(serviceTask.getLongTask()));
			serviceTaskoper.setGuid(serviceTask.getGuid());
			serviceTaskoper.setOrgid(serviceTask.getOrgid());
			serviceTaskoper.setCreateTime(new Date());
			if (StringUtils.isNotEmpty(serviceTaskVO.getOpcode())) {
			String[] opcodes = serviceTaskVO.getOpcode().split(",");
			for (String opcode : opcodes) {
			//先查询一下是否存在
			ServiceTaskoper serviceTaskoper2 = new ServiceTaskoper();
			serviceTaskoper2.setTaskId(serviceTaskVO.getTaskid());
			serviceTaskoper2.setOpcode(serviceTaskVO.getOpcode());
			List<ServiceTaskoper> serviceTaskopers = serviceTaskoperService.selectServiceTaskoperList(serviceTaskoper2);

			serviceTaskoper.setOpcode(opcode);
			log.info("----serviceTaskoper的值为：{}", serviceTaskoper);
			if (CollectionUtils.isNotEmpty(serviceTaskopers)) {
			serviceTaskoper.setId(serviceTaskopers.get(0).getId());
			serviceTaskoperService.updateServiceTaskoper(serviceTaskoper);
			} else {
			serviceTaskoperService.insertServiceTaskoper(serviceTaskoper);
			serviceTaskoper.setOpcode(opcode);
			log.info("----serviceTaskoper的值为：{}", serviceTaskoper);
			if (CollectionUtils.isNotEmpty(serviceTaskopers)) {
			serviceTaskoper.setId(serviceTaskopers.get(0).getId());
			serviceTaskoperService.updateServiceTaskoper(serviceTaskoper);
			} else {
			serviceTaskoperService.insertServiceTaskoper(serviceTaskoper);
			}
			}
			}
			}

			}
			if (ObjectUtils.isNotEmpty(serviceTaskVO.getIvrTaskTemplateVO())) {
			IvrTaskTemplate ivrTaskTemplate = new IvrTaskTemplate();
			@@ -751,6 +819,8 @@
			if (CollectionUtils.isNotEmpty(serviceTaskVO.getPatTaskRelevances())) {
			for (PatTaskRelevance patTaskRelevance : serviceTaskVO.getPatTaskRelevances()) {
			ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTaskVO, ServiceSubtask.class);
			serviceSubtask.setLibtemplateid(ObjectUtils.isEmpty(serviceTaskVO.getLibtemplateid()) ? null : Long.valueOf(serviceTaskVO.getLibtemplateid()));
			serviceSubtask.setLibtemplatename(serviceTaskVO.getLibtemplatename());
			serviceSubtask.setSendname(patTaskRelevance.getName());
			serviceSubtask.setAge(patTaskRelevance.getAge());
			serviceSubtask.setSfzh(patTaskRelevance.getSfzh());
			@@ -771,12 +841,13 @@
			serviceSubtask.setEndtime(patTaskRelevance.getEndtime());
			serviceSubtask.setNurseId(patTaskRelevance.getNurseId());
			serviceSubtask.setNurseName(patTaskRelevance.getNurseName());
			serviceSubtask.setVisitTime(patTaskRelevance.getVisitTime());
			serviceSubtask.setVisitTime(patTaskRelevance.getVisittime());
			serviceSubtask.setTextParam(new Gson().toJson(serviceTaskVO.getTextParam()));
			if (patTaskRelevance.getIsoperation() != null) {
			if (patTaskRelevance.getIsoperation() == 2)
			if (patTaskRelevance.getIsoperation() == 2) {
			serviceSubtask.setUpdateBy(serviceTask.getUpdateBy());
			serviceSubtaskMapper.updateServiceSubtaskByCondition(serviceSubtask);
			serviceSubtaskMapper.updateServiceSubtaskByCondition(serviceSubtask);
			}
			if (patTaskRelevance.getIsoperation() == 1) {
			serviceSubtask.setSendstate(1L);
			serviceSubtask.setUpdateBy(serviceTask.getUpdateBy());
			@@ -788,6 +859,36 @@
			serviceSubtaskMapper.deleteServiceSubtaskByCondition(serviceTaskVO.getTaskid(), patTaskRelevance.getPatid());
			}
			serviceSubtask.getTaskid().intValue();
			}
			}
			// 有可能会把发送顺序也修改了（需要根据taskId将所有的sendstate！=4,5,6的subTask拉出来，进行修改一下）
			ServiceSubtaskVO ssVo = new ServiceSubtaskVO();
			ssVo.setTaskid(serviceTaskVO.getTaskid());
			ssVo.setDelFlag("0");
			List<Long> ssList = new ArrayList<>();
			ssList.add(1l);
			ssList.add(2L);
			ssList.add(3L);
			ssVo.setSendstates(ssList);
			List<ServiceSubtask> ssTaskList = serviceSubtaskMapper.selectServiceSubtaskBySendstate(ssVo);
			for (int i = 0; i < ssTaskList.size(); i++) {
			ServiceSubtask serviceSubtask = ssTaskList.get(i);
			serviceSubtaskPreachformMapper.deleteServiceSubtaskPreachformBySubid(serviceSubtask.getId());
			if (StringUtils.isNotEmpty(serviceTaskVO.getPreachformList())) {
			List<Map<String, Object>> pfList = serviceTaskVO.getPreachformList();
			for (Map<String, Object> map : pfList) {
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setSort(ObjectUtils.isEmpty(map.get("sort")) ? 0 : Long.valueOf(map.get("sort").toString()));
			serviceSubtaskPreachform.setPreachform(ObjectUtils.isEmpty(map.get("preachform")) ? "" : map.get("preachform").toString());
			serviceSubtaskPreachform.setCompensateTime(ObjectUtils.isEmpty(map.get("compensateTime")) ? "" : map.get("compensateTime").toString());
			serviceSubtaskPreachform.setTaskid(serviceTask.getTaskid());
			serviceSubtaskPreachform.setSubid(serviceSubtask.getId());
			//这个sendstate需要在数据库设置一个默认值为“1”
			serviceSubtaskPreachform.setSendstate("1");
			serviceSubtaskPreachform.setOrgid(serviceTask.getOrgid());
			// serviceSubtaskPreachform.setSort(Long.valueOf(i));
			serviceSubtaskPreachformMapper.insertServiceSubtaskPreachform(serviceSubtaskPreachform);
			}
			}
			}
			}
			@@ -1050,12 +1151,12 @@
			@Override
			public PhoneCallBackYQVO phoneCallBackYQ(PhoneCallReqYQVO phoneCallReqYQVO) {
			//先把该subId从cache_exist中剔除，只要有回调就剔除（目的是，尽快让cache-exist为空，去缓存下一批要打的电话;这里剔除不影响电话的正常业务）
			redisCache.removeElementFromList("cache-exist", phoneCallReqYQVO.getTaskid());
			// redisCache.removeElementFromList("cache-exist", phoneCallReqYQVO.getTaskid());

			//判断是否挂机
			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")) {
			if (StringUtils.isNotEmpty(hangupState) && hangupState.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) {
			@@ -1064,6 +1165,8 @@
			//判断 recordAccept-hungup 是否有值，如果有，则说明不用处理了，之前已经处理过了（recordAccept-hungup这个主要是给"通话记录用的，"）
			Object cacheObject = redisCache.getCacheObject(phoneCallReqYQVO.getTaskid() + "recordAccept-hungup");
			if (ObjectUtils.isNotEmpty(cacheObject) && String.valueOf(cacheObject).equals("1")) {
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			setFailPreachForm(serviceSubtask, "3", "拨叫的用户正忙", "4");
			return new PhoneCallBackYQVO();
			}
			//如果发送状态为6，就说明已经打完了，也没有必要继续往下走了
			@@ -1085,8 +1188,12 @@
			//先把默认的recordAccept-hungup删除，再更新
			redisCache.deleteObject(phoneCallReqYQVO.getTaskid() + "recordAccept-hungup");
			redisCache.setCacheObject(phoneCallReqYQVO.getTaskid() + "recordAccept-hungup", "1", 10, TimeUnit.MINUTES);

			//记录电话发送状态
			setFailPreachForm(serviceSubtask2, "3", "电话发送成功（患者挂断）", "4");

			//这个时候就需要走补偿机制了，先暂定走短信
			getSmsCompensate(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			// getSmsCompensate(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			return new PhoneCallBackYQVO();
			}
			}
			@@ -1115,6 +1222,9 @@
			req.put("caller", phoneCallReqYQVO.getPhone());
			// HttpUtils.sendPost(hangup, new Gson().toJson(req));
			HttpUtil.postJsonRequest(hangup, new Gson().toJson(req));
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(phoneCallReqYQVO.getTaskid()));
			//记录电话发送状态
			setFailPreachForm(serviceSubtask, "3", "通话正常结束", "9");
			//删除结束语的患存
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "- jsy");
			} else {
			@@ -1122,6 +1232,7 @@
			log.error("-------PlayEventCallbackPlaystop的值为：{}", true);
			}
			}

			return phoneCallBackYQVO;
			}
			//获取放音是否结束
			@@ -1198,6 +1309,9 @@
			serviceSubtask.setUpdateTime(new Date());
			log.error("先更新一下分数,电话的serviceSubtask的值为：{}", serviceSubtask);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "静默次数达到" + num + "次", "4");

			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());
			@@ -1252,6 +1366,8 @@
			ss.setSendstate(6L);
			ss.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(ss);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			//可以挂机了
			redisCache.deleteObject(serviceSubtask.getId() + "-" + serviceSubtask.getPhone());
			redisCache.deleteObject(phoneCallReqYQVO.getUuid() + "SCORE");
			@@ -1336,6 +1452,8 @@
			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;
			}

			@@ -1367,6 +1485,9 @@
			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");
			@@ -1414,6 +1535,8 @@
			serviceSubtask.setSendstate(6L);
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			//设置结束语
			phoneCallBackYQVO.setValue(phoneCallBackYQVO.getCommonValue() + serviceTask1.getJsy());
			Long id = serviceSubtask.getId();
			@@ -1484,7 +1607,8 @@
			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);
			@@ -1588,7 +1712,8 @@
			serviceSubtask.setRemark("电话拨打已完成");
			serviceSubtask.setSendstate(6L);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);

			//记录状态
			setFailPreachForm(serviceSubtask, "3", "电话拨打已完成", "9");
			//去redis中，把该子任务ID删除
			Long id = serviceSubtask.getId();
			Map<String, String> map = delRedisValue(null, id.toString());
			@@ -1685,8 +1810,8 @@
			List<String> cacheList = new ArrayList<>();
			ListOperations<String, String> listOps = redisTemplate.opsForList();
			//必须等ache-exist全部打完才能拉取下一批（主要是怕所有的数据都堆在电话的缓存里，在规定的时间打不完）
			long existSize = listOps.size("cache-exist");
			if (existSize > 0) return pullTaskVOList;
			// long existSize = listOps.size("cache-exist");
			// if (existSize > 0) return pullTaskVOList;
			int count = 0;
			long size = listOps.size("cache-0");
			log.error("---------打电话之前缓存中的数据量：{}", size);
			@@ -1696,17 +1821,18 @@
			count = Math.min(phoneCount(), (int) size);
			if (count != 0) {
			cacheList = listOps.range("cache-0", 0, count - 1);
			} else {
			return null;
			}
			}


			log.error("任务拉取cache-0的值是多少：{}", cacheList);
			log.info("任务拉取cache-0的值是多少：{}", cacheList);
			// cache-0为立即发起的,其它的先推迟
			if (!CollectionUtils.isEmpty(cacheList)) {
			pullTaskVOList = getPullTaskList(cacheList, "cache-0");
			// 删除已处理的数据
			listOps.trim("cache-0", count, -1);
			log.error("打电话之后缓存中的数据量---------：{}", listOps.size("cache-0"));
			log.info("打电话之后缓存中的数据量---------：{}", listOps.size("cache-0"));
			} else {
			for (int i = 1; i < 6; i++) {
			//取出从cache-1 到 cache-5的第一个子任务信息
			@@ -1728,15 +1854,15 @@
			}
			}
			//existList用来记录接下来需要执行的子任务ID
			List<String> existList = new ArrayList<>();
			// List<String> existList = new ArrayList<>();
			if (CollectionUtils.isNotEmpty(pullTaskVOList)) {
			//给回调参数赋值
			for (PullTaskVO pullTaskVO : pullTaskVOList) {
			existList.add(pullTaskVO.getTaskid());
			// existList.add(pullTaskVO.getTaskid());
			pullTaskVO.setAsrcallback(ASRCallBackPath);
			}
			}
			if (existList.size() != 0) redisCache.setCacheListRight("cache-exist", existList);
			// if (existList.size() != 0) redisCache.setCacheListRight("cache-exist", existList);
			log.error("-----------实际拉取的电话数据量：{}", CollectionUtils.isNotEmpty(pullTaskVOList) ? pullTaskVOList.size() : null);
			return pullTaskVOList;
			}
			@@ -1813,241 +1939,6 @@
			}


			//下面的代码不能删除，上面的方法只是配合电话端联调用的，
			// @Override
			// public PhoneCallBackVO phoneCallBack(PhoneCallBackVO phoneCallBackVO) {
			// log.error("phoneCallBackVO的入参：{},{},{},{},{},{},{}", phoneCallBackVO.getResultType(), phoneCallBackVO.getUuid(), phoneCallBackVO.getErrResult(), phoneCallBackVO.getTextResult(), phoneCallBackVO.getHangUpResult(), phoneCallBackVO.getEnumState(), phoneCallBackVO.getUint8());
			// //获取数据
			// Boolean aBoolean = redisCache.hasKey(phoneCallBackVO.getUuid());
			// if (!aBoolean) {
			// throw new BaseException("该uuid不存在");
			// }
			// Integer hangupValue = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "hangup");
			// if (hangupValue != null && hangupValue == 1) {
			// //hangupValue == 1 随访结束，直接可以挂电话
			// PhoneUtils phoneUtils = new PhoneUtils();
			// phoneUtils.hangup(phoneCallBackVO.getUuid(), null, null, null, null, null, null, null);
			//
			// }
			//
			// Map<String, Object> map = redisCache.getCacheObject(phoneCallBackVO.getUuid());
			//// ObjectMapper objectMapper = new ObjectMapper();
			//// Map<String, Object> map = null;
			//// try {
			//// map = objectMapper.readValue(cacheObject, Map.class);
			//// } catch (JsonProcessingException e) {
			//// e.printStackTrace();
			//// }
			//
			// ServiceSubtask ServiceSubtask = (ServiceSubtask) map.get("ServiceSubtask");
			// List<IvrLibaTemplateScriptVO> ivrLibaTemplateScriptVOs = (List<IvrLibaTemplateScriptVO>) map.get("ivrLibaTemplateScriptVO");
			// //将uuid更新到数据库中
			// ServiceSubtask.setSenduuid(phoneCallBackVO.getUuid());
			// ServiceSubtaskMapper.updateServiceSubtask(ServiceSubtask);
			//
			// //获取模板信息
			// IvrLibaTemplateVO ivrLibaTemplateVO = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "ivrLibaTemplateVO");
			//
			//
			// //首先判断resultType
			// if (phoneCallBackVO.getResultType() == 1) {
			// //呼叫结果接口: 1
			// if (phoneCallBackVO.getUint8() == 1) {
			// //呼叫失败，去redis中记录一下失败次数，进行再次呼叫
			// Integer integer = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "uint8");
			// if (integer != null) {
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "uint8", integer + 1, 120, TimeUnit.MINUTES);
			// } else {
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "uint8", 1, 120, TimeUnit.MINUTES);
			// }
			//
			// if (integer != null && integer == ServiceSubtask.getRecallcount().intValue()) {
			// log.info("无人接听：{}, {}", phoneCallBackVO.getErrResult(), phoneCallBackVO.getUuid());
			// //连续打规定次，如果要没人接，那就结束
			// ServiceSubtask.setResult(phoneCallBackVO.getErrResult());
			// ServiceSubtaskMapper.updateServiceSubtask(ServiceSubtask);
			// redisCache.deleteObject(phoneCallBackVO.getUuid() + "uint8");
			// } else if (integer != null && integer < ServiceSubtask.getRecallcount().intValue()) {
			// //进行重拨
			// PhoneUtils phoneUtils = new PhoneUtils();
			// phoneUtils.ob(null, null, null, null, null, null, null, ServiceSubtask.getPhone(), phoneCallBackVO.getUuid(), true);
			// }
			// }
			//
			// } else if (phoneCallBackVO.getResultType() == 2) {
			// //通话状态更新接口: 2
			// if (phoneCallBackVO.getEnumState() == 0) {
			// // 0-振铃
			// Integer integer = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "enumState");
			//
			// if (integer != null && integer < ServiceSubtask.getRecallcount().intValue()) {
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "enumState", integer + 1, 120, TimeUnit.MINUTES);
			// } else if (integer == null) {
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "enumState", 1, 120, TimeUnit.MINUTES);
			// } else if (integer != null && integer == ServiceSubtask.getRecallcount().intValue()) {
			// ServiceSubtask.setResult("无人接听");
			// ServiceSubtaskMapper.updateServiceSubtask(ServiceSubtask);
			// redisCache.deleteObject(phoneCallBackVO.getUuid() + "enumState");
			// }
			// } else if (phoneCallBackVO.getEnumState() == 2) {
			// //患者挂断电话
			// log.info("患者挂断电话：{}", phoneCallBackVO.getUuid());
			// ServiceSubtask.setResult(phoneCallBackVO.getHangUpResult());
			// ServiceSubtaskMapper.updateServiceSubtask(ServiceSubtask);
			// redisCache.deleteObject(phoneCallBackVO.getUuid() + "enumState");
			// }
			//
			//
			// } else if (phoneCallBackVO.getResultType() == 3) {
			// //语音识别结果上报接口: 3
			// Integer noVoice = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "noVoice");
			// QuestionMessage returnQues = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "returnQues");
			// IvrLibaTemplateScriptVO nowQuestion = returnQues.getNowQuestion();
			// PhoneUtils phoneUtils = new PhoneUtils();
			//
			// if (StringUtils.isEmpty(phoneCallBackVO.getTextResult())) {
			// //无回话
			// //判断noVoice是否已经到了最大值
			// if (noVoice == ivrLibaTemplateVO.getNoVoiceNum().intValue()) {
			// //已经问了对应的遍数，就判断是否还有下一题
			// if (nowQuestion.getTargetid() == ivrLibaTemplateScriptVOs.size()) {
			// //没有下一题了，就挂断电话，播放结束语
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "hangup", 1, 120, TimeUnit.MINUTES);
			// phoneUtils.ttsPlayback(ivrLibaTemplateVO.getRevisitAfter(), phoneCallBackVO.getUuid());
			// } else {
			// //有下一题
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "noVoice", 0, 120, TimeUnit.MINUTES);
			// IvrLibaTemplateScriptVO nextQuestion = getNextQuestion(ivrLibaTemplateScriptVOs, nowQuestion);
			// // 问题，去调用"tts合成和播放"接口
			// phoneUtils.ttsPlayback(nowQuestion.getQuestionText(), phoneCallBackVO.getUuid());
			// }
			// } else {
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "noVoice", noVoice + 1, 120, TimeUnit.MINUTES);
			// //调用ivrLibaTemplateScriptVO中的slienceText(静默话术)
			// String slienceText = nowQuestion.getSlienceText();
			// //静默话术 + 问题，去调用"tts合成和播放"接口
			// phoneUtils.ttsPlayback(slienceText + nowQuestion.getQuestionText(), phoneCallBackVO.getUuid());
			// return new PhoneCallBackVO();
			// }
			//
			// } else {
			// //有回话，对回答的问题,进行正则匹配（这里只针对选择题，其它题型不行）
			// for (int j = 0; j < nowQuestion.getIvrLibaScriptTargetoptionList().size(); j++) {
			// //包含
			// Matcher matcher = null;
			// if (StringUtils.isNotEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex())) {
			// Pattern pattern = Pattern.compile(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex());
			// matcher = pattern.matcher(phoneCallBackVO.getTextResult());
			// }
			// //不包含
			// Matcher matcher2 = null;
			// if (StringUtils.isNotEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex2())) {
			// Pattern pattern2 = Pattern.compile(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex2());
			// matcher2 = pattern2.matcher(phoneCallBackVO.getTextResult());
			// }
			// log.info("phoneCallBack--Targetregex的值为：{}, phoneCallBack--Targetregex2的值为：{}", nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex(), nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex2());
			// if (StringUtils.isNotEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches() && StringUtils.isNotEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() \|\| StringUtils.isEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex()) && StringUtils.isNotEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex2()) && matcher2.matches() \|\| StringUtils.isEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex2()) && StringUtils.isNotEmpty(nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getTargetregex()) && matcher.matches()) {
			// //说明匹配正确了
			// //这里应该先判断类型，去再修改，设置IsUserOperation是单选题的改法
			// nowQuestion.getIvrLibaScriptTargetoptionList().get(j).setIsUserOperation(true);
			// ivrLibaScriptTargetoptionMapper.updateIvrLibaTemplateTargetoption(nowQuestion.getIvrLibaScriptTargetoptionList().get(j));
			//
			//
			// //将静默置为0
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "noVoice", 0, 120, TimeUnit.MINUTES);
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "mateNum", 0, 120, TimeUnit.MINUTES);
			// //获取下一题
			// Integer nextQuestion = nowQuestion.getIvrLibaScriptTargetoptionList().get(j).getNextQuestion();
			// for (IvrLibaTemplateScriptVO script : ivrLibaTemplateScriptVOs) {
			// if (script.getTargetid() == nextQuestion) {
			// QuestionMessage questionMessage = new QuestionMessage();
			// questionMessage.setNowQuestion(script);
			// questionMessage.setQuestionList(ivrLibaTemplateScriptVOs);
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "returnQues", questionMessage, 120, TimeUnit.MINUTES);
			// break;
			// }
			// }
			// break;
			// } else {
			// //没有匹配到
			// Integer mateNum = redisCache.getCacheObject(phoneCallBackVO.getUuid() + "mateNum");
			// //无匹配次数去判断是否到最大询问次数，并且所有的选项都匹配完了
			// if (mateNum == ivrLibaTemplateVO.getMateNum().intValue() && j == nowQuestion.getIvrLibaScriptTargetoptionList().size() - 1) {
			// //如果下一题为空.则新的数据返回,并加上感谢语
			// if (nowQuestion.getTargetid() < ivrLibaTemplateScriptVOs.size()) {
			// QuestionMessage questionMessage = new QuestionMessage();
			// IvrLibaTemplateScriptVO nextQuestion = getNextQuestion(ivrLibaTemplateScriptVOs, nowQuestion);
			// questionMessage.setQuestionList(ivrLibaTemplateScriptVOs);
			// questionMessage.setNowQuestion(nextQuestion);
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "returnQues", questionMessage, 120, TimeUnit.MINUTES);
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "mateNum", 0, 120, TimeUnit.MINUTES);
			// } else {
			// //就可以挂断电话了
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "hangup", 1, 120, TimeUnit.MINUTES);
			// phoneUtils.ttsPlayback(ivrLibaTemplateVO.getRevisitAfter(), phoneCallBackVO.getUuid());
			// break;
			// }
			// } else if (mateNum < ivrLibaTemplateVO.getMateNum().intValue() && j == nowQuestion.getIvrLibaScriptTargetoptionList().size() - 1) {
			// //没有问到规定次数
			// mateNum = mateNum + 1;
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "mateNum", mateNum, 120, TimeUnit.MINUTES);
			// }
			// }
			//
			// }
			// //选项匹配完成后，需要再去通过库再进行匹配一次
			// String extemplateID = ivrLibaTemplateVO.getSubmoduleID();
			// String[] split = extemplateID.split(",");
			// List<String> list = Arrays.asList(split);
			// List<Long> list1 = new ArrayList<>();
			// if (StringUtils.isNotEmpty(extemplateID)) {
			// for (String str : list) {
			// list1.add(Long.valueOf(str));
			// }
			// List<IvrLibaExtemplatescript> ivrLibaExtemplatescripts = ivrLibaExtemplatescriptMapper.queryIvrLibaExtemplatescriptList(list1);
			// for (IvrLibaExtemplatescript ivrLibaExtemplatescript : ivrLibaExtemplatescripts) {
			// Matcher matcher = null;
			// if (StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex())) {
			// Pattern pattern = Pattern.compile(ivrLibaExtemplatescript.getSelfRegex());
			// matcher = pattern.matcher(returnQues.getContent());
			// }
			//
			// Matcher matcher2 = null;
			// if (StringUtils.isNotEmpty(ivrLibaExtemplatescript.getSelfRegex2())) {
			// Pattern pattern2 = Pattern.compile(ivrLibaExtemplatescript.getSelfRegex2());
			// matcher2 = pattern2.matcher(returnQues.getContent());
			// }
			// log.info("++++++++++++++++++++++++++通用库是否为空：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");
			// IvrLibaTemplateScriptVO ivrLibaTemplateScriptVO = returnQues.getNowQuestion();
			// ivrLibaTemplateScriptVO.setSubmoduleText(ivrLibaExtemplatescript.getSwitchText());
			// ivrLibaTemplateScriptVO.setSubmoduleVoice(ivrLibaExtemplatescript.getSwitchWav());
			// redisCache.setCacheObject(phoneCallBackVO.getUuid() + "returnQues", questionMessage, 120, TimeUnit.MINUTES);
			// if (ivrLibaExtemplatescript.getIsEnd() == 1) {
			// //将问题置空
			// IvrLibaTemplateScriptVO nowQuestion1 = questionMessage.getNowQuestion();
			// nowQuestion1.setQuestionText(null);
			// nowQuestion1.setQuestionVoice(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"将结果传回
			//
			//
			// }
			// break;
			// }
			// }
			//
			// }
			// }
			// return phoneCallBackVO;
			// }

			@Override
			public Integer saveQuestionAnswerPhone(ServiceSubTaskDetailReq serviceSubTaskDetailReq) {
			int i = 0;
			@@ -2065,8 +1956,15 @@
			}
			//随访
			for (ServiceSubtaskDetail serviceSubtaskDetail : serviceSubTaskDetailReq.getServiceSubtaskDetailList()) {
			if (serviceSubtaskDetail.getScriptid() != null) {
			//设置一下问题分类
			IvrTaskTemplateScript ivrTaskTemplateScript = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptByID(serviceSubtaskDetail.getScriptid());
			if (ivrTaskTemplateScript != null)
			serviceSubtaskDetail.setCategoryid(ivrTaskTemplateScript.getAssortid());
			}

			serviceSubtaskDetail.setSubId(selectServiceSubtaskList.get(0).getId());
			serviceSubtaskDetail.setId(UUID.randomUUID().toString());
			// serviceSubtaskDetail.setId(UUID.randomUUID().toString());
			serviceSubtaskDetail.setCreateTime(new Date());
			serviceSubtaskDetail.setGuid(selectServiceSubtaskList.get(0).getGuid());
			serviceSubtaskDetail.setOrgid(serviceSubTaskDetailReq.getOrgid());
			@@ -2076,6 +1974,12 @@
			} else {
			if (serviceSubTaskDetailReq != null && CollectionUtils.isNotEmpty(serviceSubTaskDetailReq.getServiceSubtaskDetailList())) {
			for (ServiceSubtaskDetail serviceSubtaskDetail : serviceSubTaskDetailReq.getServiceSubtaskDetailList()) {
			if (serviceSubtaskDetail.getScriptid() != null) {
			//设置一下问题分类
			IvrTaskTemplateScript ivrTaskTemplateScript = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptByID(serviceSubtaskDetail.getScriptid());
			if (ivrTaskTemplateScript != null)
			serviceSubtaskDetail.setCategoryid(ivrTaskTemplateScript.getAssortid());
			}
			serviceSubtaskDetail.setCreateTime(new Date());
			serviceSubtaskDetail.setGuid(serviceSubTaskDetailReq.getGuid());
			serviceSubtaskDetail.setOrgid(serviceSubTaskDetailReq.getOrgid());
			@@ -2112,9 +2016,13 @@
			Object cacheObject = redisCache.getCacheObject(phoneCallRecordVO.getTaskid() + "recordAccept-hungup");
			if (phoneCallRecordVO.getHangup_cause().equals("NO_USER_RESPONSE") \|\| ObjectUtils.isNotEmpty(cacheObject) && String.valueOf(cacheObject).equals("1")) {
			//无人接听
			getSmsCompensate(Long.valueOf(phoneCallRecordVO.getTaskid()));
			//记录电话发送状态
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(Long.valueOf(phoneCallRecordVO.getTaskid()));
			setFailPreachForm(serviceSubtask, "3", "无人接听", "4");
			//进行短信补偿
			// getSmsCompensate(Long.valueOf(phoneCallRecordVO.getTaskid()));
			redisCache.deleteObject(phoneCallRecordVO.getTaskid() + "recordAccept-hungup");
			redisCache.removeElementFromList("cache-exist", phoneCallRecordVO.getTaskid());
			// redisCache.removeElementFromList("cache-exist", phoneCallRecordVO.getTaskid());
			} else if (ObjectUtils.isNotEmpty(cacheObject) && String.valueOf(cacheObject).equals("2")) {
			// if (phoneCallRecordVO.getAnswered() != null && phoneCallRecordVO.getAnswered() == true) {
			log.error("有人接电话了，并且完了");
			@@ -2130,13 +2038,14 @@
			serviceSubtask.setUpdateTime(new Date());
			log.error("电话拨打已完成serviceSubtask的值为:{}", serviceSubtask);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			setFailPreachForm(serviceSubtask, StringUtils.isNotEmpty(serviceSubtask.getCurrentPreachform()) ? serviceSubtask.getCurrentPreachform() : "3", "电话拨打已完成", "9");
			//下载文件
			ftpService.downloadFolder("/" + LocalDate.now().toString(), profile + "/upload/vadio/voice/" + LocalDate.now().toString());
			redisCache.deleteObject(phoneCallRecordVO.getTaskid() + "recordAccept-hungup");
			} else {
			//患者拒绝随访
			//先把该subId从cache_exist中剔除，只要有回调就剔除（目的是，尽快让cache-exist为空，去缓存下一批要打的电话;这里剔除不影响电话的正常业务）
			redisCache.removeElementFromList("cache-exist", phoneCallRecordVO.getTaskid());
			// redisCache.removeElementFromList("cache-exist", phoneCallRecordVO.getTaskid());
			ServiceSubtask serviceSubtask = new ServiceSubtask();
			serviceSubtask.setRemark("电话接通成功，患者拒绝随访");
			serviceSubtask.setId(Long.valueOf(phoneCallRecordVO.getTaskid()));
			@@ -2147,8 +2056,10 @@
			// 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());
			// ftpService.downloadFolder("/" + LocalDate.now().toString(), profile + "/upload/vadio/voice/" + LocalDate.now().toString());
			redisCache.deleteObject(phoneCallRecordVO.getTaskid() + "recordAccept-hungup");
			ServiceSubtask ss = serviceSubtaskMapper.selectServiceSubtaskById(serviceSubtask.getId());
			setFailPreachForm(ss, StringUtils.isNotEmpty(ss.getCurrentPreachform()) ? ss.getCurrentPreachform() : "3", "电话接通成功，患者拒绝随访", "5");
			}

			return 1;
			@@ -2217,6 +2128,36 @@
			return result;
			}

			@Override
			public List<PatArchiveSrmVO> sendMsgTemplate(List<PatArchiveSrmVO> patArchiveSrmVOS) {
			//用来记录发送失败的
			List<PatArchiveSrmVO> sendError = new ArrayList<>();

			for (PatArchiveSrmVO patArchiveSrmVO : patArchiveSrmVOS) {
			SimpleDateFormat simpleDateFormat = new SimpleDateFormat("YYYY年MM月dd日HH:mm");
			String timestamp = simpleDateFormat.format(patArchiveSrmVO.getVisitTime());

			StringBuilder stringBuilder = new StringBuilder();
			if (patArchiveSrmVO.getSrmTemplate().equals("入院准备中心-无检查")) {
			stringBuilder.append(patArchiveSrmVO.getName() + ",您好！主管医生已为您安排住院，请于当天");
			} else if (patArchiveSrmVO.getSrmTemplate().equals("入院准备中心-空腹检查")) {
			stringBuilder.append(patArchiveSrmVO.getName() + ",您好！主管医生已为您安排住院，请当天空腹并于");
			} else if (patArchiveSrmVO.getSrmTemplate().equals("日间病房—择期病人检查")) {
			stringBuilder.append(patArchiveSrmVO.getName() + ",您好！主管医生已为您安排住院前检查，请当天空腹并于");
			}

			stringBuilder.append(timestamp + "之前携带医保卡或电子医保卡身份证凭此条短信到1号楼3楼南入院准备中心入院登记窗口，办理正式住院手续，完成各项检查后再到相应病区护士站报到。");
			stringBuilder.append("入院准备中心电话：89975977。入院办理须知:https://mp.weixin.qq.com/s/OCkotuRyQ8Ld2owFF0YErw");

			String data = MessageSend.sendMsg(stringBuilder.toString(), "6", patArchiveSrmVO.getPhone(), LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss")));
			if (StringUtils.isNotEmpty(data) && data.contains("result=0")) {
			sendError.add(patArchiveSrmVO);
			}
			}

			return sendError;
			}

			/**
			* 获取随访统计比例
			*
			@@ -2224,14 +2165,15 @@
			* @return
			*/
			@Override
			@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.error("getSfStatistics的入参为：{}", serviceSubtaskCountReq);
			log.info("getSfStatistics的入参为：{}", serviceSubtaskCountReq);
			List<ServiceSubtaskStatistic> serviceSubtaskStatistics = new ArrayList<>();
			List<ServiceSubtask> rawData = serviceSubtaskMapper.getSfStatistics(serviceSubtaskCountReq);

			// List<ServiceSubtask> rawData = serviceSubtaskMapper.getSfStatistics(serviceSubtaskCountReq);

			// 根据条件进行分组
			Map<String, List<ServiceSubtask>> collect = new HashMap<>();


			if (serviceSubtaskCountReq.getLeavehospitaldistrictcodes() != null && serviceSubtaskCountReq.getLeavehospitaldistrictcodes().size() > 0) {
			if (serviceSubtaskCountReq.getDrcode() != null && !serviceSubtaskCountReq.getDrcode().isEmpty()) {
			collect = serviceSubtaskMapper.getSfStatistics(serviceSubtaskCountReq).stream().collect(Collectors.groupingBy(subtask -> Optional.ofNullable(subtask.getDrname()).orElse("Unknown")));
			@@ -2245,7 +2187,7 @@
			collect = serviceSubtaskMapper.getSfStatistics(serviceSubtaskCountReq).stream().collect(Collectors.groupingBy(subtask -> Optional.ofNullable(subtask.getDeptname()).orElse("Unknown")));
			}
			}


			for (List<ServiceSubtask> serviceSubtaskList : collect.values()) {
			if (CollectionUtils.isEmpty(serviceSubtaskList)) {
			continue;
			@@ -2259,14 +2201,14 @@
			// 如果有医生编码，设置医生编码用于及时率查询
			if (serviceSubtaskCountReq.getDrcode() != null && !serviceSubtaskCountReq.getDrcode().isEmpty()) {
			ss.setDrcode(serviceSubtaskList.get(0).getDrcode());
			}else {
			} else {
			if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getLeavehospitaldistrictcodes())) {
			ss.setLeavehospitaldistrictcode(serviceSubtaskList.get(0).getLeavehospitaldistrictcode());
			} else if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getDeptcodes())) {
			ss.setDeptcode(serviceSubtaskList.get(0).getDeptcode());
			}
			}


			ss.setStarttime(serviceSubtaskCountReq.getStartTime());
			ss.setEndtime(serviceSubtaskCountReq.getEndTime());
			if (serviceSubtaskCountReq.getEndTime() != null && new Date().before(serviceSubtaskCountReq.getEndTime())) {
			@@ -2282,6 +2224,20 @@
			return serviceSubtaskStatistics;
			}

			@Override
			public List<ServiceSubtaskStatistic> getSfStatisticsExport(ServiceSubtaskCountReq serviceSubtaskCountReq) {
			List<ServiceSubtaskStatistic> sfStatistics = getSfStatistics(serviceSubtaskCountReq);
			// 添加总计行
			if (CollectionUtils.isNotEmpty(sfStatistics)) {
			ServiceSubtaskStatistic totalRow = calculateTotalRow(sfStatistics);
			totalRow.setLeavehospitaldistrictname("总计");
			totalRow.setDeptname("总计");
			sfStatistics.add(totalRow);
			}

			return sfStatistics;
			}

			/**
			* 获取随访统计比例
			*
			@@ -2289,12 +2245,14 @@
			* @return
			*/
			@Override
			@Cacheable(value = "sfStatisticsJoy", key = "T(org.springframework.util.DigestUtils).md5DigestAsHex(#serviceSubtaskCountReq.toString().getBytes())", unless = "#result == null or #result.isEmpty()")
			public List<ServiceSubtaskStatistic> getSfStatisticsJoy(ServiceSubtaskCountReq serviceSubtaskCountReq) {
			log.error("getSfStatistics的入参为：{}", serviceSubtaskCountReq);
			List<ServiceSubtaskStatistic> serviceSubtaskStatistics = new ArrayList<>();

			// 根据条件进行分组
			Map<String, List<ServiceSubtask>> collect = new HashMap<>();
			String orgid = null;

			if (serviceSubtaskCountReq.getLeavehospitaldistrictcodes() != null && serviceSubtaskCountReq.getLeavehospitaldistrictcodes().size() > 0) {
			if (serviceSubtaskCountReq.getDrcode() != null && !serviceSubtaskCountReq.getDrcode().isEmpty()) {
			@@ -2310,24 +2268,21 @@
			collect = serviceSubtaskMapper.getSfStatistics(serviceSubtaskCountReq).stream().collect(Collectors.groupingBy(subtask -> Optional.ofNullable(subtask.getDeptname()).orElse("Unknown")));
			}
			}
			List<ServiceSubtaskCount> joySubCount=serviceSubtaskMapper.getSfStatisticsJoy(serviceSubtaskCountReq);
			List<ServiceSubtaskCount> joySubCount = serviceSubtaskMapper.getSfStatisticsJoy(serviceSubtaskCountReq);
			for (List<ServiceSubtask> serviceSubtaskList : collect.values()) {
			if (CollectionUtils.isEmpty(serviceSubtaskList)) {
			continue;
			}
			ServiceSubtaskStatistic statistic = getStatisticJoy(serviceSubtaskList,joySubCount);
			if(statistic.getJoyCount()!=0&&statistic.getJoyAllCount()!=0) {
			Double joyTotal = Double.parseDouble(statistic.getJoyCount() + "") / Double.parseDouble(statistic.getJoyAllCount() + "") * 100;
			statistic.setJoyTotal(String.format("%.2f", joyTotal)+"%");
			}
			ServiceSubtaskStatistic statistic = getStatisticJoy(serviceSubtaskList, joySubCount);
			//及时率
			ServiceSubtask ss = new ServiceSubtask();
			ss.setOrgid(serviceSubtaskList.get(0).getOrgid());
			orgid = serviceSubtaskList.get(0).getOrgid();
			ss.setOrgid(orgid);

			// 如果有医生编码，设置医生编码用于及时率查询
			if (serviceSubtaskCountReq.getDrcode() != null && !serviceSubtaskCountReq.getDrcode().isEmpty()) {
			ss.setDrcode(serviceSubtaskList.get(0).getDrcode());
			}else {
			} else {
			if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getLeavehospitaldistrictcodes())) {
			ss.setLeavehospitaldistrictcode(serviceSubtaskList.get(0).getLeavehospitaldistrictcode());
			} else if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getDeptcodes())) {
			@@ -2342,13 +2297,125 @@
			}
			Double jsRate = serviceSubtaskMapper.selectTimelyRate(ss);
			statistic.setRate(jsRate);

			if (ObjectUtils.isNotEmpty(statistic)) {
			serviceSubtaskStatistics.add(statistic);
			}
			}
			if (CollectionUtils.isNotEmpty(serviceSubtaskStatistics)) {
			for (ServiceSubtaskStatistic serviceSubtaskStatistic : serviceSubtaskStatistics) {
			//所有满意度数量
			if (CollectionUtils.isNotEmpty(serviceSubtaskCountReq.getDeptcodes())) {
			Map<String, Object> satisfactionIndex = 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());
			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"));
			}
			}
			}

			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.setAssortid(ivrCategoryid);
			List<IvrTaskTemplateScript> ivrTaskTemplateScripts = iIvrTaskTemplateScriptService.selectIvrTaskTemplateScriptList(ivrTaskTemplateScript);
			if (CollectionUtils.isNotEmpty(ivrTaskTemplateScripts)) {
			//需要先计算出发送量，再乘以单个问券满意度题目数量，得到满意度题目总量（包含了未做的）
			ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO();
			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)) {
			ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO();
			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 = 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) {
			ServiceSubtaskStatistic serviceSubtaskStatistic = new ServiceSubtaskStatistic();
			@@ -2362,10 +2429,16 @@
			serviceSubtaskStatistic.setDrname(serviceSubtaskList.get(0).getDrname());
			//出院人次
			serviceSubtaskStatistic.setDischargeCount(serviceSubtaskList.size());
			//记录过滤患者详情
			List<ServiceSubtask> filterServiceSubtasks = new ArrayList<>();
			for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
			//无需随访人次
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 4) {
			serviceSubtaskStatistic.setNonFollowUp(serviceSubtaskStatistic.getNonFollowUp() + 1L);
			if (serviceSubtask.getTaskSituation() !=null && serviceSubtask.getTaskSituation() == 6) {
			serviceSubtaskStatistic.setFilterCount(serviceSubtaskStatistic.getFilterCount() + 1L);
			filterServiceSubtasks.add(serviceSubtask);
			}
			}
			//应随访人次
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() != 4) {
			@@ -2380,7 +2453,7 @@
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 2) {
			serviceSubtaskStatistic.setPendingFollowUp(serviceSubtaskStatistic.getPendingFollowUp() + 1L);
			}
			if (serviceSubtask.getSendstate() != null && ( serviceSubtask.getSendstate() == 6)) {
			if (serviceSubtask.getSendstate() != null && (serviceSubtask.getSendstate() == 6)) {
			serviceSubtaskStatistic.setFollowUpSuccess(serviceSubtaskStatistic.getFollowUpSuccess() + 1L);
			}
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 5) {
			@@ -2437,15 +2510,32 @@
			serviceSubtaskStatistic.setAbnormalAgain(serviceSubtaskStatistic.getAbnormalAgain() + 1L);
			}
			}


			//随访情况
			if (serviceSubtask.getTaskSituation() != null && serviceSubtask.getTaskSituation() == 1) {
			serviceSubtaskStatistic.setTaskSituation1(serviceSubtaskStatistic.getTaskSituation1() + 1);
			}
			if (serviceSubtask.getTaskSituation() != null && serviceSubtask.getTaskSituation() == 2) {
			serviceSubtaskStatistic.setTaskSituation2(serviceSubtaskStatistic.getTaskSituation2() + 1);
			}
			if (serviceSubtask.getTaskSituation() != null && serviceSubtask.getTaskSituation() == 3) {
			serviceSubtaskStatistic.setTaskSituation3(serviceSubtaskStatistic.getTaskSituation3() + 1);
			}
			if (serviceSubtask.getTaskSituation() != null && serviceSubtask.getTaskSituation() == 4) {
			serviceSubtaskStatistic.setTaskSituation4(serviceSubtaskStatistic.getTaskSituation4() + 1);
			}
			if (serviceSubtask.getTaskSituation() != null && serviceSubtask.getTaskSituation() == 5) {
			serviceSubtaskStatistic.setTaskSituation5(serviceSubtaskStatistic.getTaskSituation5() + 1);
			}
			if (serviceSubtask.getTaskSituation() != null && serviceSubtask.getTaskSituation() == 7) {
			serviceSubtaskStatistic.setTaskSituation6(serviceSubtaskStatistic.getTaskSituation6() + 1);
			}
			}

			serviceSubtaskStatistic.setFilterCountList(filterServiceSubtasks);

			return serviceSubtaskStatistic;
			}

			private ServiceSubtaskStatistic getStatisticJoy(List<ServiceSubtask> serviceSubtaskList,List<ServiceSubtaskCount> joySubCount) {
			private ServiceSubtaskStatistic getStatisticJoy(List<ServiceSubtask> serviceSubtaskList, List<ServiceSubtaskCount> joySubCount) {
			ServiceSubtaskStatistic serviceSubtaskStatistic = new ServiceSubtaskStatistic();
			//格式化为两位小数的百分比
			DecimalFormat percentFormat = new DecimalFormat("##.##%");
			@@ -2461,13 +2551,12 @@
			serviceSubtaskStatistic.setJoyAllCount(0);
			for (ServiceSubtask serviceSubtask : serviceSubtaskList) {
			//满意度
			List<ServiceSubtaskCount> joyCountTemp= joySubCount.stream().filter(r->r.getSubTaskId().equals(serviceSubtask.getId()))
			.collect(Collectors.toList());
			if(joyCountTemp!=null&&joyCountTemp.size()>0){
			if(ObjectUtils.isNotEmpty(joyCountTemp.get(0).getJoyCount()))
			serviceSubtaskStatistic.setJoyCount(serviceSubtaskStatistic.getJoyCount()+joyCountTemp.get(0).getJoyCount());
			if(ObjectUtils.isNotEmpty(joyCountTemp.get(0).getJoyAllCount()))
			serviceSubtaskStatistic.setJoyAllCount(serviceSubtaskStatistic.getJoyAllCount()+joyCountTemp.get(0).getJoyAllCount());
			List<ServiceSubtaskCount> joyCountTemp = joySubCount.stream().filter(r -> r.getSubTaskId().equals(serviceSubtask.getId())).collect(Collectors.toList());
			if (joyCountTemp != null && joyCountTemp.size() > 0) {
			if (ObjectUtils.isNotEmpty(joyCountTemp.get(0).getJoyCount()))
			serviceSubtaskStatistic.setJoyCount(serviceSubtaskStatistic.getJoyCount() + joyCountTemp.get(0).getJoyCount());
			if (ObjectUtils.isNotEmpty(joyCountTemp.get(0).getJoyAllCount()))
			serviceSubtaskStatistic.setJoyAllCount(serviceSubtaskStatistic.getJoyAllCount() + joyCountTemp.get(0).getJoyAllCount());
			}
			//无需随访人次
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 4) {
			@@ -2486,7 +2575,7 @@
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 2) {
			serviceSubtaskStatistic.setPendingFollowUp(serviceSubtaskStatistic.getPendingFollowUp() + 1L);
			}
			if (serviceSubtask.getSendstate() != null && ( serviceSubtask.getSendstate() == 6)) {
			if (serviceSubtask.getSendstate() != null && (serviceSubtask.getSendstate() == 6)) {
			serviceSubtaskStatistic.setFollowUpSuccess(serviceSubtaskStatistic.getFollowUpSuccess() + 1L);
			}
			if (serviceSubtask.getSendstate() != null && serviceSubtask.getSendstate() == 5) {
			@@ -2544,9 +2633,7 @@
			}
			}


			}


			return serviceSubtaskStatistic;
			}
			@@ -2580,6 +2667,7 @@
			serviceSubtaskDetail.setAssigntime(System.currentTimeMillis());
			serviceSubtaskDetail.setStarttime(System.currentTimeMillis());
			serviceSubtaskDetail.setAnswertime(System.currentTimeMillis());
			serviceSubtaskDetail.setCategoryid(ivrTaskTemplateScriptVO.getAssortid());
			serviceSubtaskDetail.setAsrtext("无应答");
			if (StringUtils.isNotEmpty(phoneCallReqYQVO.getAsrtext()))
			serviceSubtaskDetail.setAsrtext(phoneCallReqYQVO.getAsrtext());
			@@ -2611,6 +2699,11 @@
			return serviceSubtaskDetail;
			}

			/**
			* 电话的补偿方法（老）
			*
			* @param subTaskId
			*/
			private void getSmsCompensate(Long subTaskId) {
			ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(subTaskId);
			RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample();
			@@ -2641,6 +2734,34 @@
			serviceSubtask.setSendstate(3L);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);

			//需要在servicePreachform里记录一下短信状态
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setPreachform("4");
			serviceSubtaskPreachform.setSubid(subTaskId);
			serviceSubtaskPreachform.setTaskid(serviceSubtask.getTaskid());
			serviceSubtaskPreachform.setOrgid(serviceSubtask.getOrgid());
			List<ServiceSubtaskPreachform> serviceSubtaskPreachforms = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform);
			if (CollectionUtils.isNotEmpty(serviceSubtaskPreachforms)) {
			ServiceSubtaskPreachform serviceSubtaskPreachform1 = serviceSubtaskPreachforms.get(0);
			serviceSubtaskPreachform1.setSendstate("9");
			serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(serviceSubtaskPreachform1);
			} else if (CollectionUtils.isEmpty(serviceSubtaskPreachforms)) {
			//如果为空的话，说明用户没有选短信发送方式，这个时候需要强制新增一条
			//获取sort的最大值
			ServiceSubtaskPreachform ssp = new ServiceSubtaskPreachform();
			ssp.setSubid(subTaskId);
			ssp.setTaskid(serviceSubtask.getTaskid());
			ssp.setOrgid(serviceSubtask.getOrgid());
			List<ServiceSubtaskPreachform> sspf2 = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(ssp);

			serviceSubtaskPreachform.setSort(0L);
			if (CollectionUtils.isNotEmpty(sspf2)) {
			serviceSubtaskPreachform.setSort(Long.valueOf(sspf2.size()));
			}
			serviceSubtaskPreachform.setSendstate("2");
			serviceSubtaskPreachformMapper.insertServiceSubtaskPreachform(serviceSubtaskPreachform);
			}

			}

			//通过当前时间，拉取电话总数
			@@ -2649,22 +2770,181 @@
			LocalTime currentTime = LocalTime.now();
			// 目标时间（晚上 8 点）
			LocalTime targetTime = LocalTime.of(phoneEndHour, 0);
			// 计算当前时间到目标时间的时长
			Duration duration = Duration.between(currentTime, targetTime);
			// 获取剩余时间的小时数
			long remainingHours = 0;
			long remainingMinutes = duration.toMinutes();
			//如果超过8点,就设置为0
			//距离结束时间小于20分钟，就不拉取了
			if (remainingMinutes < 20) remainingHours = 0;
			else if (remainingMinutes < 60 && remainingMinutes > 20) remainingHours = 1;
			else if (remainingMinutes > 60) remainingHours = remainingMinutes / 60;
			// 计算剩余可以打的电话数
			int remainingCalls = (int) (remainingHours * phoneUpEveryHour);
			return remainingCalls;
			// // 计算当前时间到目标时间的时长
			// Duration duration = Duration.between(currentTime, targetTime);
			// // 获取剩余时间的小时数
			// long remainingHours = 0;
			// long remainingMinutes = duration.toMinutes();
			// //如果超过8点,就设置为0
			// //距离结束时间小于20分钟，就不拉取了
			// if (remainingMinutes < 20) remainingHours = 0;
			// else if (remainingMinutes < 60 && remainingMinutes > 20) remainingHours = 1;
			// else if (remainingMinutes > 60) remainingHours = remainingMinutes / 60;
			// // 计算剩余可以打的电话数
			// int remainingCalls = (int) (remainingHours * phoneUpEveryHour);
			// return remainingCalls;
			if (currentTime.isBefore(targetTime)) {
			//如果当前时间还在截止时间内，则继续发
			return phoneUpEveryHour;
			}
			return 0;
			}

			public List<ServiceSubtaskCount> getSfStatisticsJoydetails(ServiceSubtaskCountReq serviceSubtaskCountReq) {
			return serviceSubtaskMapper.getSfStatisticsJoydetails(serviceSubtaskCountReq);
			return serviceSubtaskMapper.getSfStatisticsJoydetails(serviceSubtaskCountReq);
			}


			/**
			* @param serviceSubtask
			* @param preachform
			* @param remark
			* @param failSendstate
			* @return
			*/
			public Boolean setFailPreachForm(ServiceSubtask serviceSubtask, String preachform, String remark, String failSendstate) {
			//将状态设置为失败
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setSubid(serviceSubtask.getId());
			serviceSubtaskPreachform.setTaskid(serviceSubtask.getTaskid());
			serviceSubtaskPreachform.setOrgid(serviceSubtask.getOrgid());
			//获取该患者的发送方式总数
			List<ServiceSubtaskPreachform> spSize = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform);

			serviceSubtaskPreachform.setPreachform(preachform);
			//1:未发送状态
			serviceSubtaskPreachform.setSendstate("1");
			if (preachform.equals("3")) {
			//电话进入队列后，状态会变成2
			serviceSubtaskPreachform.setSendstate("2");
			}
			List<ServiceSubtaskPreachform> serviceSubtaskPreachforms = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform);
			if (CollectionUtils.isNotEmpty(serviceSubtaskPreachforms)) {
			ServiceSubtaskPreachform serviceSubtaskPreachform1 = serviceSubtaskPreachforms.get(0);
			serviceSubtaskPreachform1.setSendstate(failSendstate);
			serviceSubtaskPreachform1.setRemark(remark);
			serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(serviceSubtaskPreachform1);

			//如果当前的preachform已经是最后一个了，那直接将serviceSubtask的sendstate状态改成5就行了(全失败了)
			if (serviceSubtaskPreachform1.getSort() == spSize.size() && failSendstate.equals("4")) {
			serviceSubtask.setCurrentPreachform(preachform);
			serviceSubtask.setSendstate(5L);
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			return true;
			}
			}

			serviceSubtask.setCurrentPreachform(preachform);
			serviceSubtask.setSendstate(3L);
			//如果等于9，则说明电话正常结束了
			if (failSendstate.equals("9")) serviceSubtask.setSendstate(6L);
			serviceSubtask.setVisitTime(getNextVisitTime(serviceSubtask.getId(), serviceSubtask.getTaskid(), serviceSubtask.getVisitTime()));
			serviceSubtaskMapper.updateServiceSubtask(serviceSubtask);
			return true;
			}

			private Date getNextVisitTime(Long subid, Long taskid, Date visitTime) {
			ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform();
			serviceSubtaskPreachform.setSubid(subid);
			serviceSubtaskPreachform.setTaskid(taskid);
			List<ServiceSubtaskPreachform> serviceSubtaskPreachforms = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform);
			if (CollectionUtils.isNotEmpty(serviceSubtaskPreachforms)) {
			String compensateTime = serviceSubtaskPreachforms.get(0).getCompensateTime();
			int hoursToAdd = Integer.valueOf(compensateTime) * 24;
			Calendar calendar = Calendar.getInstance();
			calendar.setTime(visitTime);
			calendar.add(Calendar.HOUR_OF_DAY, hoursToAdd);
			Date newDate = calendar.getTime();
			return newDate;
			}
			return visitTime;
			}


			/**
			* 计算总计行
			* @param statistics 统计数据列表
			* @return 总计行数据
			*/
			private ServiceSubtaskStatistic calculateTotalRow(List<ServiceSubtaskStatistic> statistics) {
			ServiceSubtaskStatistic total = new ServiceSubtaskStatistic();

			// 初始化数值字段
			total.setDischargeCount(0);
			total.setNonFollowUp(0L);
			total.setFilterCount(0L);
			total.setFollowUpNeeded(0L);
			total.setNeedFollowUp(0L);
			total.setPendingFollowUp(0L);
			total.setFollowUpSuccess(0L);
			total.setFollowUpFail(0L);
			total.setManual(0L);
			total.setSms(0L);
			total.setWeChat(0L);
			total.setAbnormal(0L);
			total.setNeedFollowUpAgain(0L);
			total.setPendingFollowUpAgain(0L);
			total.setFollowUpSuccessAgain(0L);
			total.setFollowUpFailAgain(0L);
			total.setManualAgain(0L);
			total.setSmsAgain(0L);
			total.setWeChatAgain(0L);
			total.setAbnormalAgain(0L);
			total.setTaskSituation1(0);
			total.setTaskSituation2(0);
			total.setTaskSituation3(0);
			total.setTaskSituation4(0);
			total.setTaskSituation5(0);
			total.setTaskSituation6(0);

			// 累加各个字段的值
			for (ServiceSubtaskStatistic stat : statistics) {
			if (stat.getDischargeCount() != null) {
			total.setDischargeCount(total.getDischargeCount() + stat.getDischargeCount());
			}
			total.setNonFollowUp(total.getNonFollowUp() + (stat.getNonFollowUp() != null ? stat.getNonFollowUp() : 0L));
			total.setFilterCount(total.getFilterCount() + (stat.getFilterCount() != null ? stat.getFilterCount() : 0L));
			total.setFollowUpNeeded(total.getFollowUpNeeded() + (stat.getFollowUpNeeded() != null ? stat.getFollowUpNeeded() : 0L));
			total.setNeedFollowUp(total.getNeedFollowUp() + (stat.getNeedFollowUp() != null ? stat.getNeedFollowUp() : 0L));
			total.setPendingFollowUp(total.getPendingFollowUp() + (stat.getPendingFollowUp() != null ? stat.getPendingFollowUp() : 0L));
			total.setFollowUpSuccess(total.getFollowUpSuccess() + (stat.getFollowUpSuccess() != null ? stat.getFollowUpSuccess() : 0L));
			total.setFollowUpFail(total.getFollowUpFail() + (stat.getFollowUpFail() != null ? stat.getFollowUpFail() : 0L));
			total.setManual(total.getManual() + (stat.getManual() != null ? stat.getManual() : 0L));
			total.setSms(total.getSms() + (stat.getSms() != null ? stat.getSms() : 0L));
			total.setWeChat(total.getWeChat() + (stat.getWeChat() != null ? stat.getWeChat() : 0L));
			total.setAbnormal(total.getAbnormal() + (stat.getAbnormal() != null ? stat.getAbnormal() : 0L));
			total.setNeedFollowUpAgain(total.getNeedFollowUpAgain() + (stat.getNeedFollowUpAgain() != null ? stat.getNeedFollowUpAgain() : 0L));
			total.setPendingFollowUpAgain(total.getPendingFollowUpAgain() + (stat.getPendingFollowUpAgain() != null ? stat.getPendingFollowUpAgain() : 0L));
			total.setFollowUpSuccessAgain(total.getFollowUpSuccessAgain() + (stat.getFollowUpSuccessAgain() != null ? stat.getFollowUpSuccessAgain() : 0L));
			total.setFollowUpFailAgain(total.getFollowUpFailAgain() + (stat.getFollowUpFailAgain() != null ? stat.getFollowUpFailAgain() : 0L));
			total.setManualAgain(total.getManualAgain() + (stat.getManualAgain() != null ? stat.getManualAgain() : 0L));
			total.setSmsAgain(total.getSmsAgain() + (stat.getSmsAgain() != null ? stat.getSmsAgain() : 0L));
			total.setWeChatAgain(total.getWeChatAgain() + (stat.getWeChatAgain() != null ? stat.getWeChatAgain() : 0L));
			total.setAbnormalAgain(total.getAbnormalAgain() + (stat.getAbnormalAgain() != null ? stat.getAbnormalAgain() : 0L));
			total.setTaskSituation1(total.getTaskSituation1() + (stat.getTaskSituation1() != null ? stat.getTaskSituation1() : 0));
			total.setTaskSituation2(total.getTaskSituation2() + (stat.getTaskSituation2() != null ? stat.getTaskSituation2() : 0));
			total.setTaskSituation3(total.getTaskSituation3() + (stat.getTaskSituation3() != null ? stat.getTaskSituation3() : 0));
			total.setTaskSituation4(total.getTaskSituation4() + (stat.getTaskSituation4() != null ? stat.getTaskSituation4() : 0));
			total.setTaskSituation5(total.getTaskSituation5() + (stat.getTaskSituation5() != null ? stat.getTaskSituation5() : 0));
			total.setTaskSituation6(total.getTaskSituation6() + (stat.getTaskSituation6() != null ? stat.getTaskSituation6() : 0));
			}

			// 计算总计行的比率字段
			DecimalFormat percentFormat = new DecimalFormat("##.##%");
			if (total.getNeedFollowUp() > 0) {
			double rate = (double) (total.getFollowUpSuccess() + total.getFollowUpFail()) / total.getNeedFollowUp();
			total.setFollowUpRate(percentFormat.format(rate));
			} else {
			total.setFollowUpRate("0.00%");
			}

			if (total.getNeedFollowUpAgain() > 0) {
			double rateAgain = (double) (total.getFollowUpSuccessAgain() + total.getFollowUpFailAgain()) / total.getNeedFollowUpAgain();
			total.setFollowUpRateAgain(percentFormat.format(rateAgain));
			} else {
			total.setFollowUpRateAgain("0.00%");
			}

			return total;
			}
			}