package com.smartor.service.impl; import com.ruoyi.common.core.redis.RedisCache; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.DtoConversionUtils; import com.ruoyi.common.utils.RSAPublicKeyExample; import com.ruoyi.common.utils.StringUtils; import com.smartor.domain.*; import com.smartor.mapper.*; import com.smartor.service.IServiceSubtaskAnswerService; import com.smartor.service.IServiceTaskService; 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.stereotype.Service; import java.math.BigDecimal; import java.util.*; /** * 任务问卷问题选项Service业务层处理 * * @author ruoyi * @date 2024-07-18 */ @Slf4j @Service public class ServiceSubtaskAnswerServiceImpl implements IServiceSubtaskAnswerService { @Autowired private ServiceSubtaskAnswerMapper serviceSubtaskAnswerMapper; @Autowired private ServiceSubtaskMapper serviceSubtaskMapper; @Autowired private ServiceSubtaskPreachformMapper serviceSubtaskPreachformMapper; @Autowired private RedisCache redisCache; @Autowired private ServiceSubtaskDetailMapper serviceSubtaskDetailMapper; @Autowired private IServiceTaskService serviceTaskService; @Autowired private PatArchiveMapper patArchiveMapper; @Autowired private PatMedInhospMapper patMedInhospMapper; @Autowired private PatMedOuthospMapper patMedOuthospMapper; @Value("${pri_key}") private String pri_key; @Value("${dealDeptCode}") private String dealDeptCode; /** * 查询任务问卷问题选项 * * @param id 任务问卷问题选项主键 * @return 任务问卷问题选项 */ @Override public ServiceSubtaskAnswer selectServiceSubtaskAnswerById(Long id) { return serviceSubtaskAnswerMapper.selectServiceSubtaskAnswerById(id); } /** * 查询任务问卷问题选项列表 * * @param serviceSubtaskAnswer 任务问卷问题选项 * @return 任务问卷问题选项 */ @Override public List selectServiceSubtaskAnswerList(ServiceSubtaskAnswer serviceSubtaskAnswer) { return serviceSubtaskAnswerMapper.selectServiceSubtaskAnswerList(serviceSubtaskAnswer); } /** * 新增任务问卷问题选项 * * @param serviceSubtaskAnswer 任务问卷问题选项 * @return 结果 */ @Override public int insertServiceSubtaskAnswer(ServiceSubtaskAnswer serviceSubtaskAnswer) { serviceSubtaskAnswer.setCreateTime(DateUtils.getNowDate()); return serviceSubtaskAnswerMapper.insertServiceSubtaskAnswer(serviceSubtaskAnswer); } /** * 修改任务问卷问题选项 * * @param serviceSubtaskAnswer 任务问卷问题选项 * @return 结果 */ @Override public int updateServiceSubtaskAnswer(ServiceSubtaskAnswer serviceSubtaskAnswer) { serviceSubtaskAnswer.setUpdateTime(DateUtils.getNowDate()); return serviceSubtaskAnswerMapper.updateServiceSubtaskAnswer(serviceSubtaskAnswer); } /** * 批量删除任务问卷问题选项 * * @param ids 需要删除的任务问卷问题选项主键 * @return 结果 */ @Override public int deleteServiceSubtaskAnswerByIds(Long[] ids) { return serviceSubtaskAnswerMapper.deleteServiceSubtaskAnswerByIds(ids); } /** * 删除任务问卷问题选项信息 * * @param id 任务问卷问题选项主键 * @return 结果 */ @Override public int deleteServiceSubtaskAnswerById(Long id) { return serviceSubtaskAnswerMapper.deleteServiceSubtaskAnswerById(id); } @Override public Integer saveQuestionAnswer(ServiceSubTaskAnswerReq serviceSubTaskAnswerReq, Long flag) { Long tid = null; Long pid = null; Double score = null; Long isabno = 0L; Set allKeys = redisCache.getAllKeys(); if (ObjectUtils.isNotEmpty(serviceSubTaskAnswerReq)) { //需要立即执行 RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); if (flag == 0) { tid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskAnswerReq.getParam1(), pri_key)); pid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskAnswerReq.getParam2(), pri_key)); } else if (flag == 1) { tid = Long.valueOf(serviceSubTaskAnswerReq.getParam1()); pid = Long.valueOf(serviceSubTaskAnswerReq.getParam2()); } if (serviceSubTaskAnswerReq.getType() != null && serviceSubTaskAnswerReq.getType() == 2) { allKeys = new HashSet<>(); allKeys.add(pid + "-" + tid + "-WJscriptCache"); } else if (serviceSubTaskAnswerReq.getType() != null && serviceSubTaskAnswerReq.getType() == 1) { allKeys = new HashSet<>(); allKeys.add(pid + "-" + tid + "-SFscriptCache"); } } Long nextScriptno = null; aa: for (String key : allKeys) { String[] split = key.split("-"); //先判断，是不是当前提交人的，不是当前提交人的，跳过 try { if (ObjectUtils.isNotEmpty(split[0]) && ObjectUtils.isNotEmpty(split[1]) && !Long.valueOf(split[0]).equals(pid) && !Long.valueOf(split[1]).equals(tid)) { continue; } } catch (Exception e) { //这里之所以要处理异常，是因为有的KEY就不是我们要的KEY,没有去截取；有异常不处理，直接下一个 continue; } if (key.contains("-WJscriptCache")) { List cacheList = redisCache.getCacheList(key); cacheList.sort(Comparator.comparingLong(SvyLibTemplateScriptVO::getSort)); log.error("问卷回答结果：{}", cacheList); for (int i = 0; i < cacheList.size(); i++) { if (i == 0) { //这个时间要找到第一题 for (SvyLibTemplateScriptVO svyLibTemplateScriptVO : cacheList) { if (svyLibTemplateScriptVO.getSort() == 1L) { //说明是第一题 SvyTaskTemplateScriptVO svyTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(cacheList.get(0), SvyTaskTemplateScriptVO.class); List svyLibTemplateTargetoptions = cacheList.get(0).getSvyLibTemplateTargetoptions(); List svyTaskTemplateTargetoptions = DtoConversionUtils.sourceToTarget(svyLibTemplateTargetoptions, SvyTaskTemplateTargetoption.class); svyTaskTemplateScriptVO.setSvyTaskTemplateTargetoptions(svyTaskTemplateTargetoptions); Map map = setWJInfo(svyTaskTemplateScriptVO, tid, pid); if (map == null) continue aa; if (!Objects.isNull(map.get("nextScriptNo"))) nextScriptno = Long.valueOf(map.get("nextScriptNo")); if (score == null) { score = Double.valueOf(map.get("score")); } else { score = score + Double.valueOf(map.get("score")); } } } } else { SvyTaskTemplateScriptVO svyTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(cacheList.get(i), SvyTaskTemplateScriptVO.class); List svyTaskTemplateTargetoptions = DtoConversionUtils.sourceToTarget(cacheList.get(i).getSvyLibTemplateTargetoptions(), SvyTaskTemplateTargetoption.class); svyTaskTemplateScriptVO.setSvyTaskTemplateTargetoptions(svyTaskTemplateTargetoptions); if (svyTaskTemplateScriptVO.getSort() != null && svyTaskTemplateScriptVO.getSort().equals(nextScriptno)) { log.error("svyTaskTemplateScriptVO的值为：{}", svyTaskTemplateScriptVO); Map map = setWJInfo(svyTaskTemplateScriptVO, Long.valueOf(split[1]), Long.valueOf(split[0])); log.error("map的信息为：{}", map); if (!Objects.isNull(map.get("nextScriptNo"))) nextScriptno = Long.valueOf(map.get("nextScriptNo")); if (score == null) { score = Double.valueOf(map.get("score")); } else { score = score + Double.valueOf(map.get("score")); } } } } } else if (key.contains("-SFscriptCache")) { List cacheList = redisCache.getCacheList(key); cacheList.sort(Comparator.comparingLong(IvrLibaTemplateScriptVO::getSort)); log.error("电话随访问卷回答结果：{}", cacheList); for (int i = 0; i < cacheList.size(); i++) { if (i == 0) { //这个时间要找到第一题 for (IvrLibaTemplateScriptVO ivrLibaTemplateScriptVO : cacheList) { if (ivrLibaTemplateScriptVO.getSort() == 1L) { //说明是第一题 IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(cacheList.get(0), IvrTaskTemplateScriptVO.class); List ivrLibaTemplateTargetoptions = cacheList.get(0).getIvrLibaScriptTargetoptionList(); List ivrTaskTemplateTargetoptions = DtoConversionUtils.sourceToTarget(ivrLibaTemplateTargetoptions, IvrTaskTemplateTargetoption.class); ivrTaskTemplateScriptVO.setIvrTaskScriptTargetoptionList(ivrTaskTemplateTargetoptions); Map map = setSFInfo(ivrTaskTemplateScriptVO, tid, pid); if (!Objects.isNull(map.get("nextScriptNo"))) nextScriptno = Long.valueOf(map.get("nextScriptNo")); if (score == null) { score = Double.valueOf(map.get("score")); } else { score = score + Double.valueOf(map.get("score")); } } } } else { IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(cacheList.get(i), IvrTaskTemplateScriptVO.class); List ivrTaskTemplateTargetoptions = DtoConversionUtils.sourceToTarget(cacheList.get(i).getIvrLibaScriptTargetoptionList(), IvrTaskTemplateTargetoption.class); ivrTaskTemplateScriptVO.setIvrTaskScriptTargetoptionList(ivrTaskTemplateTargetoptions); if (ivrTaskTemplateScriptVO.getSort() != null && Long.valueOf(ivrTaskTemplateScriptVO.getSort()).equals(nextScriptno)) { Map map = setSFInfo(ivrTaskTemplateScriptVO, Long.valueOf(split[1]), Long.valueOf(split[0])); log.error("map的信息为：{}", map); if (!Objects.isNull(map.get("nextScriptNo"))) nextScriptno = Long.valueOf(map.get("nextScriptNo")); if (score == null) { score = Double.valueOf(map.get("score")); } else { score = score + Double.valueOf(map.get("score")); } } } } } else { continue; } //将该key和value从redis中，删除 redisCache.deleteObject(key); //查询出该任务中正在执行的患者信息 ServiceSubtaskVO ssVO = new ServiceSubtaskVO(); ssVO.setTaskid(tid); ssVO.setPatid(pid); ssVO.setSendstate(3L); List serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(ssVO); ServiceSubtask serviceSubtask = new ServiceSubtask(); serviceSubtask.setTaskid(tid); serviceSubtask.setPatid(pid); serviceSubtask.setSubmit(1L); serviceSubtask.setSendstate(6L); serviceSubtask.setExcep(serviceSubTaskAnswerReq.getExcep()); serviceSubtask.setFinishtime(new Date()); serviceSubtask.setUpdateTime(new Date()); log.error("将该key和value从redis中,serviceSubtask的值为--------：{}", serviceSubtask); if (score != null) serviceSubtask.setScore(BigDecimal.valueOf(score)); serviceSubtaskMapper.updateServiceSubtaskByCondition(serviceSubtask); //将当前发送状态改成9完成 ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform(); serviceSubtaskPreachform.setPreachform(serviceSubtaskList.get(0).getCurrentPreachform()); serviceSubtaskPreachform.setSubid(serviceSubtask.getId()); serviceSubtaskPreachform.setTaskid(serviceSubtask.getTaskid()); List serviceSubtaskPreachforms = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform); if (CollectionUtils.isNotEmpty(serviceSubtaskPreachforms)) { ServiceSubtaskPreachform ssp = serviceSubtaskPreachforms.get(0); ssp.setSendstate("9"); serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(ssp); } } return 1; } @Override public Boolean saveMYDQuestionAnswer(ServiceSubTaskMYDAnswerReq serviceSubTaskMYDAnswerReq) { //用来处理投诉建议的部门 String dealDept = null; Long patid = null; List patMedInhospList = null; List patMedOuthosps = null; List idList = new ArrayList<>(); if (serviceSubTaskMYDAnswerReq.getMzzy().equals("1")) { //住院 PatMedInhosp patMedInhosp = new PatMedInhosp(); patMedInhosp.setSerialnum(serviceSubTaskMYDAnswerReq.getSerialnum()); patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp); if (CollectionUtils.isNotEmpty(patMedInhospList)) patid = patMedInhospList.get(0).getPatid(); } else if (serviceSubTaskMYDAnswerReq.getMzzy().equals("2")) { //门诊 PatMedOuthosp patMedOuthosp = new PatMedOuthosp(); patMedOuthosp.setSerialnum(serviceSubTaskMYDAnswerReq.getSerialnum()); patMedOuthosps = patMedOuthospMapper.selectPatMedOuthospList(patMedOuthosp); if (CollectionUtils.isNotEmpty(patMedOuthosps)) patid = patMedOuthosps.get(0).getPatid(); } else if (serviceSubTaskMYDAnswerReq.getMzzy().equals("3")) { //指定一个部门，用来处理投诉建议 dealDept = dealDeptCode; String serialnum = serviceSubTaskMYDAnswerReq.getSerialnum(); PatArchive patArchive = new PatArchive(); patArchive.setPatientno(serialnum); List patArchives = patArchiveMapper.selectPatArchiveList(patArchive); if (CollectionUtils.isNotEmpty(patArchives)) { patid = patArchives.get(0).getId(); } } if (CollectionUtils.isNotEmpty(serviceSubTaskMYDAnswerReq.getSvyLibTemplateScriptVOS())) { Double score = null; List svyLibTemplateScriptVOS = serviceSubTaskMYDAnswerReq.getSvyLibTemplateScriptVOS(); Long nextScriptno = null; for (int i = 0; i < svyLibTemplateScriptVOS.size(); i++) { if (i == 0) { //这个时间要找到第一题 for (SvyLibTemplateScriptVO svyLibTemplateScriptVO : svyLibTemplateScriptVOS) { if (svyLibTemplateScriptVO.getSort() == 1L) { //说明是第一题 SvyTaskTemplateScriptVO svyTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(svyLibTemplateScriptVOS.get(0), SvyTaskTemplateScriptVO.class); List svyLibTemplateTargetoptions = svyLibTemplateScriptVOS.get(0).getSvyLibTemplateTargetoptions(); List svyTaskTemplateTargetoptions = DtoConversionUtils.sourceToTarget(svyLibTemplateTargetoptions, SvyTaskTemplateTargetoption.class); svyTaskTemplateScriptVO.setSvyTaskTemplateTargetoptions(svyTaskTemplateTargetoptions); Map map = setWJInfo(svyTaskTemplateScriptVO, Long.valueOf(serviceSubTaskMYDAnswerReq.getTaskId()), patid); if (map == null) continue; if (!Objects.isNull(map.get("nextScriptNo"))) nextScriptno = Long.valueOf(map.get("nextScriptNo")); if (score == null) { score = Double.valueOf(map.get("score")); } else { score = score + Double.valueOf(map.get("score")); } if (!Objects.isNull(map.get("id"))) { idList.add(Long.valueOf(map.get("id"))); } } } } else { SvyTaskTemplateScriptVO svyTaskTemplateScriptVO = DtoConversionUtils.sourceToTarget(svyLibTemplateScriptVOS.get(i), SvyTaskTemplateScriptVO.class); List svyTaskTemplateTargetoptions = DtoConversionUtils.sourceToTarget(svyLibTemplateScriptVOS.get(i).getSvyLibTemplateTargetoptions(), SvyTaskTemplateTargetoption.class); svyTaskTemplateScriptVO.setSvyTaskTemplateTargetoptions(svyTaskTemplateTargetoptions); if (svyTaskTemplateScriptVO.getSort() != null && svyTaskTemplateScriptVO.getSort().equals(nextScriptno)) { log.error("svyTaskTemplateScriptVO的值为：{}", svyTaskTemplateScriptVO); Map map = setWJInfo(svyTaskTemplateScriptVO, Long.valueOf(serviceSubTaskMYDAnswerReq.getTaskId()), patid); log.error("map的信息为：{}", map); if (!Objects.isNull(map.get("nextScriptNo"))) nextScriptno = Long.valueOf(map.get("nextScriptNo")); if (score == null) { score = Double.valueOf(map.get("score")); } else { score = score + Double.valueOf(map.get("score")); } if (!Objects.isNull(map.get("id"))) { idList.add(Long.valueOf(map.get("id"))); } } } } ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(Long.valueOf(serviceSubTaskMYDAnswerReq.getTaskId())); PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patid); if (!Objects.isNull(serviceTask)) { ServiceSubtask serviceSubtask = new ServiceSubtask(); serviceSubtask.setTaskid(serviceTask.getTaskid()); serviceSubtask.setTaskName(serviceTask.getTaskName()); serviceSubtask.setTaskDesc(serviceTask.getTaskDesc()); serviceSubtask.setTemplateid(serviceTask.getTemplateid()); serviceSubtask.setTemplatename(serviceTask.getTemplatename()); serviceSubtask.setLibtemplateid(Long.valueOf(serviceTask.getLibtemplateid())); if (CollectionUtils.isNotEmpty(patMedInhospList)) { serviceSubtask.setHospType("2"); serviceSubtask.setDeptname(patMedInhospList.get(0).getDeptname()); serviceSubtask.setDeptcode(patMedInhospList.get(0).getDeptcode()); serviceSubtask.setLeavehospitaldistrictcode(patMedInhospList.get(0).getLeavehospitaldistrictcode()); serviceSubtask.setLeavehospitaldistrictname(patMedInhospList.get(0).getLeavehospitaldistrictname()); serviceSubtask.setDrname(patMedInhospList.get(0).getDrname()); serviceSubtask.setDrcode(patMedInhospList.get(0).getDrcode()); serviceSubtask.setNurseName(patMedInhospList.get(0).getNurseName()); serviceSubtask.setNurseId(patMedInhospList.get(0).getNurseId()); serviceSubtask.setInhospid(patMedInhospList.get(0).getInhospid()); serviceSubtask.setServiceType("6"); } else if (CollectionUtils.isNotEmpty(patMedOuthosps)) { serviceSubtask.setHospType("1"); serviceSubtask.setAdmindate(patMedOuthosps.get(0).getAdmitdate()); serviceSubtask.setHospno(patMedOuthosps.get(0).getOuthospno()); serviceSubtask.setDeptname(patMedOuthosps.get(0).getDeptname()); serviceSubtask.setDeptcode(patMedOuthosps.get(0).getDeptcode()); serviceSubtask.setDrname(patMedOuthosps.get(0).getDrname()); serviceSubtask.setDrcode(patMedOuthosps.get(0).getDrcode()); serviceSubtask.setServiceType("14"); } if (!Objects.isNull(patArchive)) { serviceSubtask.setPatid(patArchive.getId()); serviceSubtask.setSendname(patArchive.getName()); serviceSubtask.setSex(patArchive.getSex()); serviceSubtask.setPhone(patArchive.getTelcode()); serviceSubtask.setSfzh(patArchive.getIdcardno()); serviceSubtask.setAddr(patArchive.getPlaceOfResidence()); serviceSubtask.setOrgid(patArchive.getOrgid()); } if (StringUtils.isNotEmpty(dealDept)) { //投诉建议的处理部门 serviceSubtask.setDeptcode(dealDept); serviceSubtask.setServiceType("15"); } serviceSubtask.setSubmit(1L); serviceSubtask.setSendstate(6L); serviceSubtask.setType("2"); serviceSubtask.setExcep(null); serviceSubtask.setFinishtime(new Date()); serviceSubtask.setUpdateTime(new Date()); serviceSubtask.setCreateTime(new Date()); serviceSubtask.setVisitTime(new Date()); if (score != null) serviceSubtask.setScore(BigDecimal.valueOf(score)); serviceSubtaskMapper.insertServiceSubtask(serviceSubtask); //将当前发送状态改成9完成 ServiceSubtaskPreachform serviceSubtaskPreachform = new ServiceSubtaskPreachform(); serviceSubtaskPreachform.setPreachform(serviceSubtask.getCurrentPreachform()); serviceSubtaskPreachform.setSubid(serviceSubtask.getId()); serviceSubtaskPreachform.setTaskid(serviceSubtask.getTaskid()); List serviceSubtaskPreachforms = serviceSubtaskPreachformMapper.selectServiceSubtaskPreachformList(serviceSubtaskPreachform); if (CollectionUtils.isNotEmpty(serviceSubtaskPreachforms)) { ServiceSubtaskPreachform ssp = serviceSubtaskPreachforms.get(0); ssp.setSendstate("9"); serviceSubtaskPreachformMapper.updateServiceSubtaskPreachform(ssp); } for (Long detailId : idList) { ServiceSubtaskDetail serviceSubtaskDetail = new ServiceSubtaskDetail(); serviceSubtaskDetail.setId(detailId); serviceSubtaskDetail.setSubId(serviceSubtask.getId()); serviceSubtaskDetailMapper.updateServiceSubtaskDetail(serviceSubtaskDetail); } } } return true; } /** * 将问题保存到缓存中 * * @param serviceSubTaskCacheReq * @return */ @Override public Integer saveQuestionCache(ServiceSubTaskCacheReq serviceSubTaskCacheReq, Long flag) { try { RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); Long tid = null; Long pid = null; if (flag == 0L) { tid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskCacheReq.getParam1(), pri_key)); pid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskCacheReq.getParam2(), pri_key)); } else if (flag == 1L) { tid = Long.valueOf(serviceSubTaskCacheReq.getParam1()); pid = Long.valueOf(serviceSubTaskCacheReq.getParam2()); } if (CollectionUtils.isNotEmpty(serviceSubTaskCacheReq.getSvyLibTemplateScriptVOS()) && serviceSubTaskCacheReq.getSvyLibTemplateScriptVOS().size() > 0) { //问卷 redisCache.deleteObject(pid + "-" + tid + "-WJscriptCache"); redisCache.setCacheListRight(pid + "-" + tid + "-WJscriptCache", serviceSubTaskCacheReq.getSvyLibTemplateScriptVOS()); //设置过期时间 3天 Long tims = Long.valueOf(3 * 24 * 3600); boolean expire = redisCache.expire(pid + "-" + tid + "-WJscriptCache", tims); return 1; } else if (CollectionUtils.isNotEmpty(serviceSubTaskCacheReq.getIvrLibaTemplateScriptVOList()) && serviceSubTaskCacheReq.getIvrLibaTemplateScriptVOList().size() > 0) { //问卷 redisCache.deleteObject(pid + "-" + tid + "-SFscriptCache"); redisCache.setCacheListRight(pid + "-" + tid + "-SFscriptCache", serviceSubTaskCacheReq.getIvrLibaTemplateScriptVOList()); //设置过期时间 3天 Long tims = Long.valueOf(3 * 24 * 3600); redisCache.expire(pid + "-" + tid + "-SFscriptCache", tims); return 1; } } catch (Exception e) { e.printStackTrace(); log.error("缓存保存失败：{}", e.getMessage()); return 0; } return 0; } @Override public Map getQuestionCache(ServiceSubTaskCacheReq serviceSubTaskCacheReq, Long flag) { Map map = new HashMap<>(); RSAPublicKeyExample rsaPublicKeyExample = new RSAPublicKeyExample(); Long tid = null; Long pid = null; Long subId = null; if (flag == 0L) { tid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskCacheReq.getParam1(), pri_key)); pid = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskCacheReq.getParam2(), pri_key)); //这个是有问题的，先这样，合并代码的时候没有把param6合进来 if (StringUtils.isNotEmpty(serviceSubTaskCacheReq.getParam6())) { subId = Long.valueOf(rsaPublicKeyExample.decryptedData(serviceSubTaskCacheReq.getParam6(), pri_key)); } } else if (flag == 1L) { tid = Long.valueOf(serviceSubTaskCacheReq.getParam1()); pid = Long.valueOf(serviceSubTaskCacheReq.getParam2()); if (StringUtils.isNotEmpty(serviceSubTaskCacheReq.getParam6())) subId = Long.valueOf(serviceSubTaskCacheReq.getParam6()); } ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO(); serviceSubtaskVO.setTaskid(tid); serviceSubtaskVO.setPatid(pid); serviceSubtaskVO.setSubId(subId); List selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); if (CollectionUtils.isEmpty(selectServiceSubtaskList) || selectServiceSubtaskList.size() == 0) { map.put("submit", 0); } else { map.put("submit", selectServiceSubtaskList.get(0).getSubmit()); if (selectServiceSubtaskList.get(0).getSubmit() == 1) { return map; } } //问卷 List svyTaskTemplateScriptVOList = redisCache.getCacheList(pid + "-" + tid + "-WJscriptCache"); map.put("result", svyTaskTemplateScriptVOList); return map; } @Override public Map selectPatQuestionResult(ServiceSubTaskQueryReq serviceSubTaskQueryReq) { log.error("selectPatQuesTionResult的入参为：{}", serviceSubTaskQueryReq); Map map = new HashMap<>(); //获取本次的问答结果 Map scriptInfoByCondition = serviceTaskService.getScriptInfoByCondition(serviceSubTaskQueryReq.getTaskid(), serviceSubTaskQueryReq.getPatid(), serviceSubTaskQueryReq.getIsFinish(), serviceSubTaskQueryReq.getPatfrom()); map = getMap(scriptInfoByCondition, serviceSubTaskQueryReq.getSubId(), serviceSubTaskQueryReq.getPatid()); //获取上次的问答结果 ServiceSubtask serviceSubtask = serviceSubtaskMapper.selectServiceSubtaskById(serviceSubTaskQueryReq.getSubId()); map.put("upScriptResult", null); map.put("upTaskName", null); if (ObjectUtils.isNotEmpty(serviceSubtask) && serviceSubtask.getUpid() != null) { Map scriptInfoByCondition2 = serviceTaskService.getScriptInfoByCondition(serviceSubTaskQueryReq.getTaskid(), serviceSubTaskQueryReq.getPatid(), serviceSubTaskQueryReq.getIsFinish(), serviceSubTaskQueryReq.getPatfrom()); Map map1 = getMap(scriptInfoByCondition2, Long.valueOf(serviceSubtask.getUpid()), serviceSubTaskQueryReq.getPatid()); if (!map1.isEmpty()) { map.put("upScriptResult", map1.get("scriptResult")); map.put("upTaskName", map1.get("taskName")); } } return map; } private Map getMap(Map scriptInfoByCondition, Long subid, Long patid) { Map map = new HashMap<>(); if (ObjectUtils.isNotEmpty(scriptInfoByCondition) && ObjectUtils.isNotEmpty(scriptInfoByCondition.get("script"))) { // log.error("-----------scriptInfoByCondition的值为：{}", scriptInfoByCondition); if (scriptInfoByCondition.get("type").equals("1")) { List ivrTaskTemplateScriptVOS = (List) scriptInfoByCondition.get("script"); List ivrLibaTemplateScriptVOList = DtoConversionUtils.sourceToTarget(ivrTaskTemplateScriptVOS, IvrLibaTemplateScriptVO.class); for (IvrLibaTemplateScriptVO ivrLibaTemplateScriptVO : ivrLibaTemplateScriptVOList) { Map scriptResult = getScriptResult(subid, patid, ivrLibaTemplateScriptVO.getId()); if (ObjectUtils.isNotEmpty(scriptResult)) { ivrLibaTemplateScriptVO.setScriptResult(scriptResult.get("asrtext")); ivrLibaTemplateScriptVO.setScriptResultId(scriptResult.get("asrtextId")); } } map.put("scriptResult", ivrLibaTemplateScriptVOList); map.put("taskName", scriptInfoByCondition.get("taskName")); } else if (scriptInfoByCondition.get("type").equals("2")) { List svyLibTemplateScriptVOList = (List) scriptInfoByCondition.get("script"); for (SvyLibTemplateScriptVO svyLibTemplateScriptVO : svyLibTemplateScriptVOList) { Map scriptResult = getScriptResult(subid, patid, svyLibTemplateScriptVO.getId()); if (ObjectUtils.isNotEmpty(scriptResult)) { if (StringUtils.isNotEmpty(scriptResult.get("asrtext"))) svyLibTemplateScriptVO.setScriptResult(StringUtils.isNotEmpty(scriptResult.get("asrtext")) ? scriptResult.get("asrtext").replaceAll("^(\"|')(.*)\\1$", "$2") : ""); svyLibTemplateScriptVO.setScriptResultId(scriptResult.get("asrtextId")); if (StringUtils.isNotEmpty(scriptResult.get("answerps"))) svyLibTemplateScriptVO.setAnswerps(scriptResult.get("answerps")); } } map.put("scriptResult", svyLibTemplateScriptVOList); map.put("taskName", scriptInfoByCondition.get("taskName")); } else if (scriptInfoByCondition.get("type").equals("3")) { //宣教不需要查看 List heLibraryList = (List) scriptInfoByCondition.get("script"); map.put("scriptResult", heLibraryList); map.put("taskName", scriptInfoByCondition.get("taskName")); } } return map; } private Map getScriptResult(Long subid, Long pid, Long sid) { Map map = new HashMap<>(); ServiceSubtaskDetail serviceSubtaskDetail = new ServiceSubtaskDetail(); serviceSubtaskDetail.setSubId(subid); serviceSubtaskDetail.setPatid(pid); serviceSubtaskDetail.setScriptid(sid); List serviceSubtaskDetails = serviceSubtaskDetailMapper.selectServiceSubtaskDetailList(serviceSubtaskDetail); if (CollectionUtils.isNotEmpty(serviceSubtaskDetails)) { map.put("asrtext", serviceSubtaskDetails.get(0).getAsrtext()); map.put("asrtextId", "" + serviceSubtaskDetails.get(0).getId()); map.put("answerps", serviceSubtaskDetails.get(0).getAnswerps()); return map; } return null; } private Map setWJInfo(SvyTaskTemplateScriptVO svyTaskTemplateScriptVO, Long taskid, Long patid) { ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO(); serviceSubtaskVO.setTaskid(taskid); serviceSubtaskVO.setPatid(patid); List selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); String score = "0"; //下题跳转 String nextScriptNo = null; ServiceSubtaskDetailVO serviceSubtaskDetailVO = new ServiceSubtaskDetailVO(); List answerList = new ArrayList<>(); if (svyTaskTemplateScriptVO.getScriptType().equals("1") || svyTaskTemplateScriptVO.getScriptType().equals("2")) { //1、2为单选或多选 for (SvyTaskTemplateTargetoption svyTaskTemplateTargetoption : svyTaskTemplateScriptVO.getSvyTaskTemplateTargetoptions()) { //将问题选项记录下来 if (StringUtils.isEmpty(serviceSubtaskDetailVO.getTargetvalue())) { serviceSubtaskDetailVO.setTargetvalue(svyTaskTemplateTargetoption.getOptioncontent()); } else { serviceSubtaskDetailVO.setTargetvalue(serviceSubtaskDetailVO.getTargetvalue() + "&" + svyTaskTemplateTargetoption.getOptioncontent()); } } nextScriptNo = svyTaskTemplateScriptVO.getNextScriptno(); if (svyTaskTemplateScriptVO.getScore() != null) { score = String.valueOf(svyTaskTemplateScriptVO.getScore()); } serviceSubtaskDetailVO.setAsrtext(StringUtils.isEmpty(svyTaskTemplateScriptVO.getScriptResult()) ? "" : svyTaskTemplateScriptVO.getScriptResult().replaceAll("^\"|\"$", "")); serviceSubtaskDetailVO.setMatchedtext(StringUtils.isEmpty(svyTaskTemplateScriptVO.getScriptResult()) ? "" : svyTaskTemplateScriptVO.getScriptResult().replaceAll("^\"|\"$", "")); // if (StringUtils.isEmpty(serviceSubtaskDetailVO.getAsrtext())) { // nextScriptNo = svyTaskTemplateScriptVO.getNextScriptno().toString(); // } // serviceSubtaskDetailVO.setSvyTaskTemplateTargetoptions(svyTaskTemplateScriptVO.getSvyTaskTemplateTargetoptions()); } else { //非单多选 if (StringUtils.isNotEmpty(svyTaskTemplateScriptVO.getScriptResult())) { serviceSubtaskDetailVO.setAsrtext(svyTaskTemplateScriptVO.getScriptResult()); if (svyTaskTemplateScriptVO.getScore() != null) { score = String.valueOf(svyTaskTemplateScriptVO.getScore()); } } nextScriptNo = svyTaskTemplateScriptVO.getNextScriptno().toString(); } ServiceTask serviceTask = serviceTaskService.selectServiceTaskByTaskid(taskid); serviceSubtaskDetailVO.setQuestiontext(svyTaskTemplateScriptVO.getScriptContent()); serviceSubtaskDetailVO.setTaskid(Long.valueOf(taskid)); serviceSubtaskDetailVO.setTargetid(svyTaskTemplateScriptVO.getTargetid() != null ? svyTaskTemplateScriptVO.getTargetid().intValue() : null); serviceSubtaskDetailVO.setPatid(Long.valueOf(patid)); serviceSubtaskDetailVO.setScriptid(svyTaskTemplateScriptVO.getId()); serviceSubtaskDetailVO.setTemplatequestionnum(StringUtils.isNotEmpty(svyTaskTemplateScriptVO.getScriptno()) ? Long.valueOf(svyTaskTemplateScriptVO.getScriptno()) : null); serviceSubtaskDetailVO.setValueType(svyTaskTemplateScriptVO.getScriptType()); serviceSubtaskDetailVO.setComment(null); serviceSubtaskDetailVO.setCreateTime(new Date()); serviceSubtaskDetailVO.setUpdateTime(new Date()); if (ObjectUtils.isNotEmpty(serviceTask)) { serviceSubtaskDetailVO.setGuid(serviceTask.getGuid()); serviceSubtaskDetailVO.setOrgid(serviceTask.getOrgid()); } serviceSubtaskDetailVO.setSubId(CollectionUtils.isNotEmpty(selectServiceSubtaskList) ? selectServiceSubtaskList.get(0).getId() : null); serviceSubtaskDetailVO.setTemplatequestionnum(svyTaskTemplateScriptVO.getId()); ServiceSubtaskDetail serviceSubtaskDetail = DtoConversionUtils.sourceToTarget(serviceSubtaskDetailVO, ServiceSubtaskDetail.class); serviceSubtaskDetailMapper.insertServiceSubtaskDetail(serviceSubtaskDetail); Map map = new HashMap<>(); map.put("nextScriptNo", nextScriptNo); map.put("score", score); map.put("id", "" + serviceSubtaskDetail.getId()); return map; } private Map setSFInfo(IvrTaskTemplateScriptVO ivrTaskTemplateScriptVO, Long taskid, Long patid) { ServiceSubtaskVO serviceSubtaskVO = new ServiceSubtaskVO(); serviceSubtaskVO.setTaskid(taskid); serviceSubtaskVO.setPatid(patid); List selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskVO); String score = "0"; //下题跳转 String nextScriptNo = null; ServiceSubtaskDetailVO serviceSubtaskDetailVO = new ServiceSubtaskDetailVO(); List answerList = new ArrayList<>(); if (ivrTaskTemplateScriptVO.getScriptType().equals("1") || ivrTaskTemplateScriptVO.getScriptType().equals("2")) { //1、2为单选或多选 for (IvrTaskTemplateTargetoption ivrTaskTemplateTargetoption : ivrTaskTemplateScriptVO.getIvrTaskScriptTargetoptionList()) { //将问题选项记录下来 if (StringUtils.isEmpty(serviceSubtaskDetailVO.getTargetvalue())) { serviceSubtaskDetailVO.setTargetvalue(ivrTaskTemplateTargetoption.getTargetvalue()); } else { serviceSubtaskDetailVO.setTargetvalue(serviceSubtaskDetailVO.getTargetvalue() + "&" + ivrTaskTemplateTargetoption.getTargetvalue()); } } nextScriptNo = ivrTaskTemplateScriptVO.getNextScriptno().toString(); if (ivrTaskTemplateScriptVO.getScore() != null) { score = String.valueOf(ivrTaskTemplateScriptVO.getScore()); } if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getQuestionResult())) { serviceSubtaskDetailVO.setAsrtext(ivrTaskTemplateScriptVO.getQuestionResult().replaceAll("^\"|\"$", "")); serviceSubtaskDetailVO.setMatchedtext(ivrTaskTemplateScriptVO.getQuestionResult().replaceAll("^\"|\"$", "")); } } else { //非单多选 if (StringUtils.isNotEmpty(ivrTaskTemplateScriptVO.getQuestionResult())) { serviceSubtaskDetailVO.setAsrtext(ivrTaskTemplateScriptVO.getQuestionResult().replaceAll("^\"|\"$", "")); serviceSubtaskDetailVO.setMatchedtext(ivrTaskTemplateScriptVO.getQuestionResult().replaceAll("^\"|\"$", "")); nextScriptNo = ivrTaskTemplateScriptVO.getNextScriptno().toString(); if (ivrTaskTemplateScriptVO.getScore() != null) { score = String.valueOf(ivrTaskTemplateScriptVO.getScore()); } } } serviceSubtaskDetailVO.setTargetid(ivrTaskTemplateScriptVO.getTargetid() != null ? ivrTaskTemplateScriptVO.getTargetid().intValue() : null); serviceSubtaskDetailVO.setQuestiontext(ivrTaskTemplateScriptVO.getScriptContent()); serviceSubtaskDetailVO.setTaskid(Long.valueOf(taskid)); serviceSubtaskDetailVO.setPatid(Long.valueOf(patid)); serviceSubtaskDetailVO.setScriptid(ivrTaskTemplateScriptVO.getScriptID()); serviceSubtaskDetailVO.setTemplatequestionnum(ivrTaskTemplateScriptVO.getId()); serviceSubtaskDetailVO.setValueType(ivrTaskTemplateScriptVO.getScriptType()); serviceSubtaskDetailVO.setComment(null); serviceSubtaskDetailVO.setCreateTime(new Date()); serviceSubtaskDetailVO.setGuid(ivrTaskTemplateScriptVO.getGuid()); serviceSubtaskDetailVO.setOrgid(ivrTaskTemplateScriptVO.getOrgid()); serviceSubtaskDetailVO.setUpdateTime(new Date()); serviceSubtaskDetailVO.setSubId(selectServiceSubtaskList.get(0).getId()); serviceSubtaskDetailVO.setTemplatequestionnum(ivrTaskTemplateScriptVO.getId()); ServiceSubtaskDetail serviceSubtaskDetail = DtoConversionUtils.sourceToTarget(serviceSubtaskDetailVO, ServiceSubtaskDetail.class); serviceSubtaskDetailMapper.insertServiceSubtaskDetail(serviceSubtaskDetail); Map map = new HashMap<>(); map.put("nextScriptNo", nextScriptNo); map.put("score", score); return map; } }