【景宁】景宁 只要存在相同诊断、患者的门诊记录则当再次随访处理

陈昶聿

8 小时以前 64f3a44f835a917c7d4157856ea4a1ede84b26a9

 smartor/src/main/java/com/smartor/service/impl/PatMedOuthospServiceImpl.java

@@ -21,6 +21,7 @@
import java.time.ZoneId;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 患者门诊记录Service业务层处理
@@ -51,6 +52,8 @@

    @Autowired
    private PatArchiveMapper patArchiveMapper;
    @Autowired
    private ServiceTaskmedicalMapper serviceTaskmedicalMapper;


    /**
@@ -76,8 +79,8 @@
        PatMedOuthospQueryReq patMedOuthospQueryReq = DtoConversionUtils.sourceToTarget(patMedOuthosp, PatMedOuthospQueryReq.class);
        patMedOuthospQueryReq.setBeginAdmitdate(patMedOuthosp.getBeginTime());
        patMedOuthospQueryReq.setEndAdmitdate(patMedOuthosp.getEndTime());
        if(!CollectionUtils.isEmpty(patMedOuthosp.getDeptcodes())) {
            String result = String.join(",",   patMedOuthosp.getDeptcodes());
        if (!CollectionUtils.isEmpty(patMedOuthosp.getDeptcodes())) {
            String result = String.join(",", patMedOuthosp.getDeptcodes());
            patMedOuthospQueryReq.setDeptcode(result);
        }

@@ -85,7 +88,7 @@
        if (patMedOuthosp.getPageNum() != null) {
            for (PatMedOuthosp patMedOuthosp1 : patMedOuthospQueryResps) {
                PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patMedOuthosp1.getPatid());
                if (patArchive.getBirthdate() != null) {
                if (ObjectUtils.isNotEmpty(patArchive) && patArchive.getBirthdate() != null) {
                    Map<String, String> map = calculateAge(patArchive.getBirthdate().toInstant().atZone(ZoneId.systemDefault()).toLocalDate(), LocalDate.now());
                    patArchive.setAge(ObjectUtils.isNotEmpty(map.get("age")) ? Long.valueOf(map.get("age")) : null);
                    patArchive.setAgeUnit(map.get("ageUnit"));
@@ -309,7 +312,7 @@
        PatMedOuthospQueryReq req = new PatMedOuthospQueryReq();
        String deptcodes = CollectionUtils.isEmpty(patMedReq.getDeptcodeList()) ? null : String.join(",", patMedReq.getDeptcodeList());
        req.setBeginAdmitdate(patMedReq.getStartDate());
        req.setEndAdmitdate(DateUtils.addDays(patMedReq.getEndDate(),1));
        req.setEndAdmitdate(DateUtils.addDays(patMedReq.getEndDate(), 1));
        req.setDeptcode(deptcodes);
        req.setOrgid(patMedReq.getOrgid());
//        req.setCampusid(patMedReq.getCampusid());
@@ -475,7 +478,8 @@
    }

    //封装serviceSubtask
    private ServiceSubtask boxedServiceSubtask(ServiceTask serviceTask, PatMedOuthosp patMedOuthosp, PatArchive patArchive) {
    @Override
    public ServiceSubtask boxedServiceSubtask(ServiceTask serviceTask, PatMedOuthosp patMedOuthosp, PatArchive patArchive) {
        ServiceSubtask serviceSubtask = DtoConversionUtils.sourceToTarget(serviceTask, ServiceSubtask.class);
        serviceSubtask.setTaskid(serviceTask.getTaskid());
        if (StringUtils.isNotEmpty(serviceTask.getLibtemplateid()))
@@ -509,6 +513,7 @@
        serviceSubtask.setVisitDeptCode(patMedOuthosp.getDeptcode());
        serviceSubtask.setVisitDeptName(patMedOuthosp.getDeptname());
        serviceSubtask.setUpdateTime(new Date());
        serviceSubtask.setAdmindate(patMedOuthosp.getAdmitdate());
        //设置发送时间
        if (serviceTask.getSendDay() == null) serviceTask.setSendDay(1L);
        Date newDate = addDays(patMedOuthosp.getAdmitdate(), serviceTask.getSendDay().intValue());
@@ -530,6 +535,185 @@
        return serviceSubtask;
    }

    /**
     *
     * @param patMedOuthosp
     * @param visitTimeNum
     * @return
     */
    @Override
    public Integer dealPatMedOuthosp(PatMedOuthosp patMedOuthosp, Integer visitTimeNum){
        Integer num = 0;

        //景宁 存在相同诊断的门诊记录则新增再次随访,否则新增随访
        if(ObjectUtils.isNotEmpty(patMedOuthosp.getOrgid()) &&
                patMedOuthosp.getOrgid().equals("47255004333112711A1001")){
            PatMedOuthosp patMedOuthospVo = new PatMedOuthosp();
            List<PatMedOuthosp> patMedOuthosps = new ArrayList<>();
            patMedOuthospVo.setOrgid(patMedOuthosp.getOrgid());
            patMedOuthospVo.setPatid(patMedOuthosp.getPatid());
            patMedOuthospVo.setIcd10code(patMedOuthosp.getIcd10code());
            // 同一个患者 + 同一个诊断，历史上已经有门诊随访记录（排除本次就诊，本次在调用前已落库）
            patMedOuthosps = selectPatMedOuthospList(patMedOuthospVo);
            Long currentId = patMedOuthosp.getId();
            List<Long> ids = patMedOuthosps.stream().map(PatMedOuthosp::getId).filter(ObjectUtils::isNotEmpty)
                    .filter(id -> !id.equals(currentId))
                    .distinct()
                    .collect(Collectors.toList());
            ServiceSubtaskEntity serviceSubtask = new ServiceSubtaskEntity();
            //景宁 只要存在相同诊断、患者的门诊记录则当再次随访处理
            serviceSubtask.setInhospids(ids);
            serviceSubtask.setServiceType("3");
            List<ServiceSubtask> serviceSubtasks = CollectionUtils.isEmpty(ids)
                    ? new ArrayList<>()
                    : serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtask);
            if(CollectionUtils.isEmpty(serviceSubtasks)){
                num = followUpByPatMedOuthosp(patMedOuthosp, visitTimeNum);
            }else {
                num = followUpAgainByPatMedOuthosp(patMedOuthosp, visitTimeNum, ids);
            }
        }else {
            ServiceSubtaskEntity serviceSubtask = new ServiceSubtaskEntity();
            serviceSubtask.setInhospid(patMedOuthosp.getId());
            serviceSubtask.setServiceType("3");
            serviceSubtask.setVisitCount(1);
            List<ServiceSubtask> serviceSubtasks = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtask);
            if(CollectionUtils.isEmpty(serviceSubtasks)){
                num = followUpByPatMedOuthosp(patMedOuthosp, visitTimeNum);
            }else {
                num = followUpAgainByPatMedOuthosp(patMedOuthosp, visitTimeNum, null);
            }
        }
        return num;
    }

    /**
     * 门诊首次随访
     * @param patMedOuthosp
     * @return
     */
    @Override
    public Integer followUpByPatMedOuthosp(PatMedOuthosp patMedOuthosp, Integer visitTimeNum) {
//        if(ObjectUtils.isEmpty(patMedOuthosp.getFudate())){
            Date adminDate = patMedOuthosp.getAdmitdate();
            Date fuDate = addDays(adminDate, visitTimeNum);
            patMedOuthosp.setFudate(fuDate);
//        }

        PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patMedOuthosp.getPatid());

        //根据患者科室，获取该疾病的长期任务
        ServiceTaskdept serviceTaskdept = new ServiceTaskdept();
        serviceTaskdept.setLongtask(1L);
        serviceTaskdept.setDeptCode(patMedOuthosp.getDeptcode());
        serviceTaskdept.setServiceType("3");
        List<ServiceTaskdept> serviceTaskdeptList = serviceTaskdeptMapper.selectServiceTaskdeptList(serviceTaskdept);
        if (CollectionUtils.isEmpty(serviceTaskdeptList) || serviceTaskdeptList.size() == 0) {
            patMedOuthosp.setDeptcheckFlag("2");
            patMedOuthosp.setRemark("通过部门,没有找到门诊随访任务ID");
            updatePatMedOuthosp(patMedOuthosp);
        } else {
            for (ServiceTaskdept serviceTaskdept1 : serviceTaskdeptList) {
                writeInSubTask(serviceTaskdept1.getTaskId(), true, patMedOuthosp, patArchive, 1);
            }
        }

        // 根据患者的疾病，获取该疾病的长期任务
//        ServiceTaskdiag serviceTaskdiag = new ServiceTaskdiag();
//        serviceTaskdiag.setLongtask(1L);
//        serviceTaskdiag.setIcd10code(patMedOuthosp.getIcd10code());
//        List<ServiceTaskdiag> serviceTaskdiags = serviceTaskdiagMapper.selectServiceTaskdiagList(serviceTaskdiag);
//        //如果部门模板为空（将deptIsNull设置为true）
//        if (org.apache.commons.collections4.CollectionUtils.isEmpty(serviceTaskdiags) || serviceTaskdiags.size() == 0) {
//            patMedOuthosp.setDiagcheckFlag("2");
//            patMedOuthosp.setRemark("通过icd10,没有找到门诊随访任务ID");
//            updatePatMedOuthosp(patMedOuthosp);
//        } else {
//            for (ServiceTaskdiag serviceTaskdept1 : serviceTaskdiags) {
//                writeInSubTask(serviceTaskdept1.getTaskId(), true, patMedOuthosp, patArchive, 2);
//            }
//        }
        return 1;
    }
    /**
     * 门诊再次随访
     * @param patMedOuthosp
     * @return
     */
    @Override
    public Integer followUpAgainByPatMedOuthosp(PatMedOuthosp patMedOuthosp, Integer visitTimeNum, List<Long> inhospids) {
        Date adminDate = patMedOuthosp.getAdmitdate();
        Date newDate = addDays(adminDate, visitTimeNum);

        Integer i = 0;
        String deptcode = patMedOuthosp.getDeptcode();
        Long patid = patMedOuthosp.getPatid();
        //查看有无进行中的任务
        ServiceSubtaskEntity serviceSubtaskEntity0 = new ServiceSubtaskEntity();
        serviceSubtaskEntity0.setOrgid(patMedOuthosp.getOrgid());
        serviceSubtaskEntity0.setSendstates(new ArrayList<>(Arrays.asList(1L, 2L, 3L, 7L)));
        serviceSubtaskEntity0.setPatid(patid);
        //景宁根据诊断再次随访
        if(ObjectUtils.isNotEmpty(patMedOuthosp.getOrgid()) &&
                patMedOuthosp.getOrgid().equals("47255004333112711A1001") && !CollectionUtils.isEmpty(inhospids)){
            serviceSubtaskEntity0.setInhospids(inhospids);
        }else {
            serviceSubtaskEntity0.setDeptcode(deptcode);
        }

        serviceSubtaskEntity0.setSort(0);
        List<ServiceSubtask> serviceSubtaskList0 = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskEntity0);
        if (!CollectionUtils.isEmpty(serviceSubtaskList0)) {
            for (ServiceSubtask serviceSubtask0 : serviceSubtaskList0) {
                serviceSubtask0.setSendstate(6L);
                serviceSubtask0.setUpdateTime(new Date());
                serviceSubtask0.setFinishtime(adminDate);
                serviceSubtaskMapper.updateServiceSubtask(serviceSubtask0);

                ServiceSubtask serviceSubtask1 = DtoConversionUtils.sourceToTarget(serviceSubtask0, ServiceSubtask.class);
                serviceSubtask1.setId(null);
                serviceSubtask1.setSendstate(2L);
                serviceSubtask1.setUpid(serviceSubtask0.getId().intValue());
                //老数据的visit_count可能为空，默认按第1次算
                Integer visitCount = ObjectUtils.isEmpty(serviceSubtask0.getVisitCount()) ? 1 : serviceSubtask0.getVisitCount();
                serviceSubtask1.setVisitCount(visitCount + 1);
                serviceSubtask1.setVisitType(serviceSubtask0.getVisitType());
                serviceSubtask1.setVisitDeptCode(serviceSubtask0.getVisitDeptCode());
                serviceSubtask1.setVisitDeptName(serviceSubtask0.getVisitDeptName());
                //新任务科室是当前出院科室
                serviceSubtask1.setDeptcode(patMedOuthosp.getDeptcode());
                serviceSubtask1.setCreateTime(new Date());
                serviceSubtask1.setUpdateTime(new Date());
                serviceSubtask1.setFinishtime(null);
                serviceSubtask1.setAdmindate(adminDate);

                serviceSubtask1.setVisitTime(newDate);
                serviceSubtask1.setLongSendTime(newDate);
                i = i + serviceSubtaskMapper.insertServiceSubtask(serviceSubtask1);
            }
        } else {
            //查看已完成的任务
//            ServiceSubtaskEntity serviceSubtaskEntity = new ServiceSubtaskEntity();
//            serviceSubtaskEntity0.setOrgid(patMedOuthosp.getOrgid());
//            serviceSubtaskEntity.setSendstates(new ArrayList<>(Arrays.asList(6L)));
//            serviceSubtaskEntity.setPatid(patid);
//            serviceSubtaskEntity.setDeptcode(deptcode);
//            serviceSubtaskEntity.setSort(0);
//            List<ServiceSubtask> serviceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(serviceSubtaskEntity);
//            if(!CollectionUtils.isEmpty(serviceSubtaskList)){
//                ServiceSubtask serviceSubtask = serviceSubtaskList.get(0);
//                serviceSubtask.setSendstate(2L);
//                serviceSubtask.setCreateTime(new Date());
//                serviceSubtask.setUpdateTime(new Date());
//
//                serviceSubtask.setVisitTime(newDate);
//                serviceSubtask.setLongSendTime(newDate);
//                i = serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
//            }
        }
        return i;
    }

    private Date addDays(Date date, Integer days) {
        if (days == null) {
            days = 1;