package com.smartor.service.impl;
|
|
import com.ruoyi.common.core.domain.entity.SysDept;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.DtoConversionUtils;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.smartor.domain.*;
|
import com.smartor.mapper.*;
|
import com.smartor.service.IPatMedInhospService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 患者住院记录Service业务层处理
|
*
|
* @author smartor
|
* @date 2023-03-04
|
*/
|
@Slf4j
|
@Service
|
public class PatMedInhospServiceImpl implements IPatMedInhospService {
|
@Autowired
|
private PatMedInhospMapper patMedInhospMapper;
|
|
@Autowired
|
private ServiceTaskdeptMapper serviceTaskdeptMapper;
|
|
@Autowired
|
private PatArchiveMapper patArchiveMapper;
|
@Autowired
|
private TemplateDeptMapper templateDeptMapper;
|
@Autowired
|
private PatArchiveImportMapper patArchiveImportMapper;
|
@Autowired
|
private Icd10AssociationMapper icd10AssociationMapper;
|
@Autowired
|
private SvyTaskTemplateMapper svyTaskTemplateMapper;
|
@Autowired
|
private IvrTaskTemplateMapper ivrTaskTemplateMappte;
|
@Autowired
|
private ServiceTaskMapper serviceTaskMapper;
|
@Autowired
|
private ServiceSubtaskMapper serviceSubtaskMapper;
|
@Autowired
|
private SysUserDeptMapper sysUserDeptMapper;
|
@Value("${createTaskServiceType}")
|
private List<String> createTaskServiceType;
|
|
//记录长期任务基础信息
|
List<IvrLibaTemplate> libaTemplates = new ArrayList<>();
|
List<IvrTaskTemplate> ivrTaskTemplates = new ArrayList<>();
|
List<ServiceTask> serviceTaskList = new ArrayList<>();
|
|
/**
|
* 查询患者住院记录
|
*
|
* @param inhospid 患者住院记录主键
|
* @return 患者住院记录
|
*/
|
@Override
|
public PatMedInhosp selectPatMedInhospByInhospid(Long inhospid) {
|
return patMedInhospMapper.selectPatMedInhospByInhospid(inhospid);
|
}
|
|
/**
|
* 查询患者住院记录列表
|
*
|
* @param patMedInhosp 患者住院记录
|
* @return 患者住院记录
|
*/
|
@Override
|
public List<PatMedInhosp> selectPatMedInhospList(PatMedInhosp patMedInhosp) {
|
return patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
}
|
|
/**
|
* 查询当前登陆人自己（病区、部门）的患者住院记录列表
|
*
|
* @param patMedInhospVO
|
* @return
|
*/
|
public List<PatMedInhosp> selectPatMedInhospListByCondition(PatMedInhospVO patMedInhospVO) {
|
return patMedInhospMapper.selectPatMedInhospListByCondition(patMedInhospVO);
|
}
|
|
|
@Override
|
public PatMedInhosp getDeptCodeByPatId(PatMedInhosp patMedInhosp) {
|
List<PatMedInhosp> patMedInhosps = selectPatMedInhospList(patMedInhosp);
|
if (!org.springframework.util.CollectionUtils.isEmpty(patMedInhosps)) {
|
|
if (patMedInhosp.getInhospstate().equals("0")) {
|
//先去掉时间为空的
|
patMedInhosps.removeIf(PatMedInhosp -> PatMedInhosp.getStarttime() == null);
|
Collections.sort(patMedInhosps, Comparator.comparing(PatMedInhosp::getStarttime).reversed());
|
} else if (patMedInhosp.getInhospstate().equals("1")) {
|
//先去掉时间为空的
|
patMedInhosps.removeIf(PatMedInhosp -> PatMedInhosp.getEndtime() == null);
|
Collections.sort(patMedInhosps, Comparator.comparing(PatMedInhosp::getEndtime).reversed());
|
}
|
}
|
if (patMedInhosps != null && patMedInhosps.size() > 0) return patMedInhosps.get(0);
|
else return null;
|
}
|
|
/**
|
* 查询出入院人次
|
*
|
* @param patMedReq
|
* @return
|
*/
|
@Override
|
public PatMedRes selectPatMedInhospListCount(PatMedReq patMedReq) {
|
PatMedRes patMedRes = null;
|
// 获取当前登陆人的部门权限
|
if (org.springframework.util.CollectionUtils.isEmpty(patMedReq.getDeptcodeList())) {
|
Long userId = SecurityUtils.getUserId();
|
List<SysDept> sysDepts = sysUserDeptMapper.selectDeptListByUserId(userId);
|
List<String> deptCode = new ArrayList<>();
|
for (SysDept sysDept : sysDepts) {
|
deptCode.add(sysDept.getDeptId().toString());
|
}
|
patMedReq.setDeptcodeList(deptCode);
|
patMedRes = patMedInhospMapper.selectPatMedInhospCount(patMedReq);
|
}
|
return patMedRes;
|
}
|
|
/**
|
* 新增患者住院记录
|
*
|
* @param patMedInhosp 患者住院记录
|
* @return 结果
|
*/
|
@Override
|
public int insertPatMedInhosp(PatMedInhosp patMedInhosp) {
|
patMedInhosp.setCreateTime(DateUtils.getNowDate());
|
patMedInhosp.setUpdateTime(DateUtils.getNowDate());
|
return patMedInhospMapper.insertPatMedInhosp(patMedInhosp);
|
}
|
|
/**
|
* 修改患者住院记录
|
*
|
* @param patMedInhosp 患者住院记录
|
* @return 结果
|
*/
|
@Override
|
public int updatePatMedInhosp(PatMedInhosp patMedInhosp) {
|
patMedInhosp.setUpdateTime(DateUtils.getNowDate());
|
return patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
|
}
|
|
/**
|
* 批量删除患者住院记录
|
*
|
* @param inhospids 需要删除的患者住院记录主键
|
* @return 结果
|
*/
|
@Override
|
public int deletePatMedInhospByInhospids(Long[] inhospids) {
|
return patMedInhospMapper.deletePatMedInhospByInhospids(inhospids);
|
}
|
|
/**
|
* 删除患者住院记录信息
|
*
|
* @param inhospid 患者住院记录主键
|
* @return 结果
|
*/
|
@Override
|
public int deletePatMedInhospByInhospid(Long inhospid) {
|
return patMedInhospMapper.deletePatMedInhospByInhospid(inhospid);
|
}
|
|
/**
|
* 删除患者住院记录信息
|
*
|
* @param inhospno 患者住院编码
|
* @return 结果
|
*/
|
@Override
|
public int deletePatMedInhospByInhospno(String inhospno) {
|
return patMedInhospMapper.deletePatMedInhospByInhospno(inhospno);
|
}
|
|
|
@Override
|
public int dealOutHospInfo() {
|
PatMedInhosp patMedInhosp = new PatMedInhosp();
|
//获取需要出院随访，未处理的数据
|
patMedInhosp.setCheckFlag("0");
|
patMedInhosp.setInhospstate("1");
|
List<PatMedInhosp> patMedInhosps = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
log.error("dealOutHospInfo需要处理的出院患者信息：{}", patMedInhosps);
|
|
for (PatMedInhosp patMedInhosp1 : patMedInhosps) {
|
try {
|
//根据患者所在科室，获取该科室的长期任务
|
ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
|
serviceTaskdept.setLongtask(1L);
|
serviceTaskdept.setDeptCode(patMedInhosp1.getLeaveldeptcode());
|
serviceTaskdept.setServiceType("2");
|
List<ServiceTaskdept> serviceTaskdepts = serviceTaskdeptMapper.selectServiceTaskdeptList(serviceTaskdept);
|
//如果部门模板为空（暂定，将出入院表的check_flag设置为2 ，long_task_reason 记录原因）
|
if (CollectionUtils.isEmpty(serviceTaskdepts) || serviceTaskdepts.size() == 0) {
|
patMedInhosp1.setCheckFlag("2");
|
patMedInhosp1.setLongTaskReason("该患者所在科室，未配置长期任务");
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
continue;
|
} else if (serviceTaskdepts.size() > 1) {
|
//如果查询出多个任务，那就取第一个，并在患者备注一下
|
List<Long> tempList = serviceTaskdepts.stream().map(ServiceTaskdept::getTaskId).collect(Collectors.toList());
|
patMedInhosp1.setLongTaskReason("该患者所在科室，有多个出院随访长期任务:" + tempList);
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
ServiceTaskdept serviceTaskdept1 = serviceTaskdepts.get(0);
|
serviceTaskdepts = new ArrayList<>();
|
serviceTaskdepts.add(serviceTaskdept1);
|
}
|
|
//获取患者信息
|
PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patMedInhosp1.getPatid());
|
writeInSubTask(serviceTaskdepts, patMedInhosp1, patArchive);
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("人员处理出异常了：{}", e.getMessage());
|
}
|
}
|
|
//获取未处理在院的数据(如果刚刚出院的患者数据的出院时间,在下面查询出的入院时间之前,那之前的出院患者的数据,也得停掉,因为又入院了)
|
patMedInhosp.setCheckFlag("0");
|
patMedInhosp.setInhospstate("0");
|
List<PatMedInhosp> patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
if (CollectionUtils.isNotEmpty(patMedInhospList) && patMedInhospList.size() > 0) {
|
dealInHospInfo(patMedInhospList);
|
}
|
return 1;
|
}
|
|
/**
|
* 获取出院，住院，门诊服务人次
|
*
|
* @param patMedReq
|
* @return
|
*/
|
@Override
|
public List<PatMedRes> getDeptRanking(PatMedReq patMedReq) {
|
|
return patMedInhospMapper.getDeptRanking(patMedReq);
|
}
|
|
@Override
|
public List<PatMedInhosp> getDocAndPat(PatMedInhosp patMedInhosp) {
|
List<PatMedInhosp> patMedInhospList = patMedInhospMapper.selectPatMedInhospList(patMedInhosp);
|
if (StringUtils.isNotEmpty(patMedInhosp.getPatname()) || StringUtils.isNotEmpty(patMedInhosp.getNurseName()) || StringUtils.isNotEmpty(patMedInhosp.getDrname())) {
|
//获取外部导入信息,并将外部患者放到patMedInhospList中
|
PatArchiveImport patArchiveImport = new PatArchiveImport();
|
if (StringUtils.isNotEmpty(patMedInhosp.getPatname())) {
|
patArchiveImport.setName(patMedInhosp.getPatname());
|
}
|
if (StringUtils.isNotEmpty(patMedInhosp.getNurseName()))
|
patArchiveImport.setCreateBy(patMedInhosp.getNurseName());
|
if (StringUtils.isNotEmpty(patMedInhosp.getDrname()))
|
patArchiveImport.setCreateBy(patMedInhosp.getDrname());
|
List<PatArchiveImport> patArchiveImports = patArchiveImportMapper.selectPatArchiveImportList(patArchiveImport);
|
if (CollectionUtils.isNotEmpty(patArchiveImports)) {
|
for (PatArchiveImport patArchiveImport1 : patArchiveImports) {
|
PatMedInhosp patMedInhosp1 = new PatMedInhosp();
|
patMedInhosp1.setPatname(patArchiveImport1.getName());
|
patMedInhosp1.setSex(patArchiveImport1.getSex());
|
patMedInhosp1.setNurseName(patArchiveImport1.getCreateBy());
|
patMedInhosp1.setOutImport(1);
|
patMedInhosp1.setTelcode(patArchiveImport1.getTelcode());
|
patMedInhospList.add(patMedInhosp1);
|
}
|
}
|
}
|
|
return patMedInhospList;
|
}
|
|
private Date addDays(Date date, Integer days) {
|
if (days == null) {
|
days = 1;
|
}
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date);
|
calendar.add(Calendar.DAY_OF_MONTH, days);
|
return calendar.getTime();
|
}
|
|
//将患者放到subtask中
|
private void writeInSubTask(List<ServiceTaskdept> serviceTaskdepts, PatMedInhosp patMedInhosp1, PatArchive patArchive) {
|
String longTaskReason = patMedInhosp1.getLongTaskReason();
|
if (StringUtils.isEmpty(longTaskReason)) longTaskReason = "";
|
for (ServiceTaskdept std : serviceTaskdepts) {
|
Long taskid = std.getTaskId();
|
ServiceTask st = new ServiceTask();
|
st.setTaskid(taskid);
|
st.setSendState(2L);
|
List<ServiceTask> serviceTasks = serviceTaskMapper.selectServiceTaskList(st);
|
if (CollectionUtils.isEmpty(serviceTasks)) {
|
log.error("该患者出院随访长期任务不存在,任务ID为：{}", taskid);
|
patMedInhosp1.setCheckFlag("2");
|
patMedInhosp1.setLongTaskReason(longTaskReason + " & 该患者出院随访长期任务不存在,任务ID为:" + taskid);
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
continue;
|
}
|
ServiceTask serviceTask = serviceTasks.get(0);
|
if (!createTaskServiceType.contains(serviceTask.getServiceType())) {
|
//不是允许的服务类型，则continue
|
log.error("该患者出院随访长期任务的服务类型不在自动生成的服务类型列表中,任务ID为：{}", taskid);
|
patMedInhosp1.setCheckFlag("2");
|
patMedInhosp1.setLongTaskReason(longTaskReason + " & 该患者出院随访长期任务的服务类型不在自动生成的服务类型列表中,任务ID为：" + taskid);
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
continue;
|
}
|
//封装serviceSubtask
|
ServiceSubtask serviceSubtask = boxedServiceSubtask(serviceTask, patMedInhosp1, patArchive);
|
Integer i = 0;
|
//在新增之前，先通过患者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());
|
Boolean aBoolean = serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
|
if (aBoolean) i = 1;
|
} else {
|
//相反,则将当有的数据停掉
|
serviceSubtask.setResult("error");
|
serviceSubtask.setFinishtime(new Date());
|
serviceSubtask.setSendstate(4L);
|
serviceSubtask.setRemark("当前患者出院时间后有待执行的出院随访长期任务");
|
}
|
}
|
}
|
i = serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
|
if (i == 1) {
|
//将check_flag改成1（已处理）
|
PatMedInhosp patMedInhosp2 = new PatMedInhosp();
|
patMedInhosp2.setInhospid(patMedInhosp1.getInhospid());
|
patMedInhosp2.setCheckFlag("1");
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp2);
|
} else {
|
//生成子任务失败，
|
log.error("生成子任务失败serviceSubtask为：{}", serviceSubtask);
|
PatMedInhosp patMedInhosp2 = new PatMedInhosp();
|
patMedInhosp2.setInhospid(patMedInhosp1.getInhospid());
|
patMedInhosp2.setRemark("生成子任务失败");
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp2);
|
}
|
}
|
}
|
|
//封装serviceSubtask
|
private ServiceSubtask boxedServiceSubtask(ServiceTask serviceTask, PatMedInhosp patMedInhosp1, PatArchive patArchive) {
|
ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTask, ServiceSubtask.class);
|
serviceSubtask.setTaskid(serviceTask.getTaskid());
|
if (StringUtils.isNotEmpty(serviceTask.getLibtemplateid()))
|
serviceSubtask.setLibtemplateid(Long.valueOf(serviceTask.getLibtemplateid()));
|
serviceSubtask.setNurseId(patMedInhosp1.getNurseId());
|
serviceSubtask.setNurseName(patMedInhosp1.getNurseName());
|
serviceSubtask.setInhospid(patMedInhosp1.getInhospid());
|
serviceSubtask.setDrcode(patMedInhosp1.getDrcode());
|
serviceSubtask.setDrname(patMedInhosp1.getDrname());
|
serviceSubtask.setDeptcode(patMedInhosp1.getLeaveldeptcode());
|
serviceSubtask.setDeptname(patMedInhosp1.getLeaveldeptname());
|
serviceSubtask.setTemplateid(serviceTask.getTemplateid());
|
serviceSubtask.setTemplatename(serviceTask.getTemplatename());
|
serviceSubtask.setPatid(patArchive.getId());
|
serviceSubtask.setSendname(patArchive.getName());
|
serviceSubtask.setSfzh(patArchive.getIdcardno());
|
serviceSubtask.setPhone(patArchive.getTelcode());
|
if (StringUtils.isBlank(patArchive.getTelcode())) serviceSubtask.setPhone(patArchive.getRelativetelcode());
|
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());
|
//设置发送时间
|
if (serviceTask.getSendDay() == null) serviceTask.setSendDay(1L);
|
Date newDate = addDays(patMedInhosp1.getEndtime(), serviceTask.getSendDay().intValue());
|
serviceSubtask.setLongSendTime(newDate);
|
//患者发送时间
|
if (StringUtils.isNotEmpty(patArchive.getNotrequiredFlag()) && patArchive.getNotrequiredFlag().equals("1")) {
|
String remark = patArchive.getNotrequiredreason();
|
serviceSubtask.setRemark(remark);
|
serviceSubtask.setResult("error");
|
serviceSubtask.setFinishtime(new Date());
|
//不执行
|
serviceSubtask.setSendstate(4L);
|
}
|
return serviceSubtask;
|
}
|
|
//处理入院信息
|
private void dealInHospInfo(List<PatMedInhosp> patMedInhospList) {
|
for (PatMedInhosp patMedInhosp1 : patMedInhospList) {
|
try {
|
//获取当前入院患者的待执行的出院子任务随访信息
|
ServiceSubtaskVO subtask = new ServiceSubtaskVO();
|
subtask.setPatid(patMedInhosp1.getPatid());
|
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(patMedInhosp1.getStarttime())) {
|
//如果当前循环的子任务的出院时间在“准备新增的子任务”的出院时间之前，则将循环的子任务停掉
|
log.error("患者再入院的serviceSubtask1为:{}", serviceSubtask1);
|
serviceSubtask1.setSendstate(4L);
|
serviceSubtask1.setRemark("患者再入院");
|
serviceSubtask1.setResult("error");
|
serviceSubtask1.setFinishtime(new Date());
|
serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
|
// patMedInhosp1.setCheckFlag("1");
|
}
|
}
|
}
|
//将患入的入院数据设置为已处理
|
patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
|
} catch (Exception e) {
|
log.error("入院数据信息出异常了：{},{}", patMedInhosp1, e.getMessage());
|
}
|
}
|
}
|
|
}
|
