| | |
|---|
| | | iPatMedInhospService.dealOutHospInfo(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // /** |
|---|
| | | // * 处理患者信息，进入子任务表(微信小程序) |
|---|
| | | // */ |
|---|
| | | // public void dealOutHospInfoXHC() { |
|---|
| | | // PatMedInhosp patMedInhosp = new PatMedInhosp(); |
|---|
| | | // //获取未处理的数据 |
|---|
| | | // List<ServicePatientTemp> servicePatientTemps = iServicePatientTempService.selectServicePatientTempList(new ServicePatientTemp()); |
|---|
| | | // |
|---|
| | | // for (ServicePatientTemp servicePatientTemp : servicePatientTemps) { |
|---|
| | | // Long tid = null; |
|---|
| | | // if (servicePatientTemp.getType() != null && servicePatientTemp.getType() == 1) { |
|---|
| | | // IvrTaskTemplate ivrTaskTemplate = iIvrTaskTemplateService.selectIvrTaskTemplateByID(servicePatientTemp.getTempId()); |
|---|
| | | // tid = ivrTaskTemplate.getTaskid(); |
|---|
| | | // } else if (servicePatientTemp.getType() != null && servicePatientTemp.getType() == 2) { |
|---|
| | | // SvyTaskTemplate svyTaskTemplate = svyTaskTemplateService.selectSvyTaskTemplateBySvyid(servicePatientTemp.getTempId()); |
|---|
| | | // tid = svyTaskTemplate.getTaskid(); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // ServiceTask serviceTask = serviceTaskMapper.selectServiceTaskByTaskid(tid); |
|---|
| | | // ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTask, ServiceSubtask.class); |
|---|
| | | // serviceSubtask.setTaskid(serviceTask.getTaskid()); |
|---|
| | | // serviceSubtask.setTemplateid(servicePatientTemp.getTempId()); |
|---|
| | | // serviceSubtask.setTemplatename(stt.getTemplateName()); |
|---|
| | | // serviceSubtask.setPatid(patArchive.getId()); |
|---|
| | | // serviceSubtask.setSendname(patArchive.getName()); |
|---|
| | | // serviceSubtask.setSfzh(patArchive.getIdcardno()); |
|---|
| | | // serviceSubtask.setPhone(patArchive.getTelcode()); |
|---|
| | | // serviceSubtask.setSex(patArchive.getSex()); |
|---|
| | | // serviceSubtask.setAge(patArchive.getAge()); |
|---|
| | | // serviceSubtask.setSendstate(2L); |
|---|
| | | // serviceSubtask.setStarttime(patMedInhosp1.getStarttime()); |
|---|
| | | // serviceSubtask.setEndtime(patMedInhosp1.getEndtime()); |
|---|
| | | // serviceSubtask.setServiceType("2"); |
|---|
| | | // serviceSubtask.setPreachform(serviceTask.getPreachform()); |
|---|
| | | // serviceSubtask.setHospType("2"); |
|---|
| | | // serviceSubtask.setCreateTime(new Date()); |
|---|
| | | // serviceSubtask.setUpdateTime(new Date()); |
|---|
| | | // serviceSubtask.setCreateBy(patMedInhosp1.getNurseName()); |
|---|
| | | // serviceSubtask.setLeavehospitaldistrictcode(patMedInhosp1.getLeavehospitaldistrictcode()); |
|---|
| | | // serviceSubtask.setLeavehospitaldistrictname(patMedInhosp1.getLeavehospitaldistrictname()); |
|---|
| | | // //设置发送时间 |
|---|
| | | // Date newDate = addDays(patMedInhosp1.getEndtime(), stt.getSendDay()); |
|---|
| | | // serviceSubtask.setLongSendTime(newDate); |
|---|
| | | // //患者发送时间 |
|---|
| | | // if (StringUtils.isNotEmpty(patArchive.getNotrequiredFlag()) && patArchive.getNotrequiredFlag().equals("1")) { |
|---|
| | | // remark = patArchive.getNotrequiredreason(); |
|---|
| | | // serviceSubtask.setRemark(remark); |
|---|
| | | // serviceSubtask.setResult("error"); |
|---|
| | | // serviceSubtask.setFinishtime(new Date()); |
|---|
| | | // //不执行 |
|---|
| | | // serviceSubtask.setSendstate(4L); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // //在新增之前，先通过患者ID，sendstate=2查询一下，在所有长期任务中，是不是还有该患者待执行的任务，有的话,比较之前的endtime是否小于当前的endtaime,如果之前的小于现在的，则直接将之前的停掉（原因再入院） |
|---|
| | | // ServiceSubtaskVO subtask = new ServiceSubtaskVO(); |
|---|
| | | // subtask.setPatid(patArchive.getId()); |
|---|
| | | // subtask.setSendstate(2L); |
|---|
| | | // List<ServiceSubtask> selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(subtask); |
|---|
| | | // log.error("该患者待执行的任务:{}", selectServiceSubtaskList); |
|---|
| | | // if (CollectionUtils.isNotEmpty(selectServiceSubtaskList) && selectServiceSubtaskList.size() > 0) { |
|---|
| | | // for (ServiceSubtask serviceSubtask1 : selectServiceSubtaskList) { |
|---|
| | | // if (Objects.isNull(serviceSubtask1.getLongSendTime())) { |
|---|
| | | // //不是长期任务，不处理 |
|---|
| | | // continue; |
|---|
| | | // } |
|---|
| | | // if (serviceSubtask1.getEndtime().before(serviceSubtask.getEndtime())) { |
|---|
| | | // //如果当前循环的子任务的出院时间在“准备新增的子任务”的出院时间之前，则将循环的子任务停掉 |
|---|
| | | // serviceSubtask1.setSendstate(4L); |
|---|
| | | // serviceSubtask1.setRemark("患者再入院"); |
|---|
| | | // serviceSubtask1.setResult("error"); |
|---|
| | | // serviceSubtask1.setFinishtime(new Date()); |
|---|
| | | // serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1); |
|---|
| | | // } else { |
|---|
| | | // //相反,则将当有的数据停掉 |
|---|
| | | // serviceSubtask.setResult("error"); |
|---|
| | | // serviceSubtask.setFinishtime(new Date()); |
|---|
| | | // serviceSubtask.setSendstate(4L); |
|---|
| | | // serviceSubtask.setRemark("患者再入院"); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // serviceSubtaskMapper.insertServiceSubtask(serviceSubtask); |
|---|
| | | // //将check_flag改成1（已处理） |
|---|
| | | // PatMedInhosp patMedInhosp2 = new PatMedInhosp(); |
|---|
| | | // patMedInhosp2.setInhospid(patMedInhosp1.getInhospid()); |
|---|
| | | // patMedInhosp2.setCheckFlag("1"); |
|---|
| | | // patMedInhospMapper.updatePatMedInhosp(patMedInhosp2); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // return 1; |
|---|
| | | // } |
|---|
| | | /** |
|---|
| | | * 处理患者信息，进入子任务表(微信小程序) |
|---|
| | | */ |
|---|
| | | public void dealOutHospInfoXHC() { |
|---|
| | | PatMedInhosp patMedInhosp = new PatMedInhosp(); |
|---|
| | | //获取未处理的数据 |
|---|
| | | List<ServicePatientTemp> servicePatientTemps = iServicePatientTempService.selectServicePatientTempList(new ServicePatientTemp()); |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | |
|---|
| | | log.error("是否需要更新：{}", patMedInhosps.size()); |
|---|
| | | if (CollectionUtils.isNotEmpty(patMedInhosps)) { |
|---|
| | | patMedInhosp.setInhospid(patMedInhosps.get(0).getInhospid()); |
|---|
| | | log.error("------患者出入院修改信息：{}",patMedInhosp); |
|---|
| | | log.error("------患者出入院修改信息：{}", patMedInhosp); |
|---|
| | | patMedInhospService.updatePatMedInhosp(patMedInhosp); |
|---|
| | | } else { |
|---|
| | | log.error("----患者出入院新增信息：{}",patMedInhosp); |
|---|
| | | log.error("----患者出入院新增信息：{}", patMedInhosp); |
|---|
| | | patMedInhospService.insertPatMedInhosp(patMedInhosp); |
|---|
| | | } |
|---|
| | | |
|---|
