代码提交

liusheng

2025-07-23 5a6f20263ef584485ae3df8b6f25b4e2fb970293

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

@@ -73,6 +73,22 @@

    @Override
    public Integer selectPatMedInhospList(PatMedInhosp patMedInhosp) {
        Long patArchiveCount = hnGatherPatArchiveMapper.selectPatArchiveCount(null);
        Long patOffst = (patArchiveCount + 1000 - 1) / 1000;
        PatArchive patArchive = new PatArchive();
        Long patSize = 0L;
        for (int i = 0; i <= patOffst; i++) {
            patArchive.setPs(1000);
            patArchive.setPn(1000 * i);
            List<PatArchive> patArchives = hnGatherPatArchiveMapper.selectPatArchiveList(patArchive);
            if (patArchives != null && !patArchives.isEmpty()) {
                patArchiveMapper.insertPatArchive(patArchives);
            }
            patSize = patSize + patArchives.size();
        }
        log.info("patArchives处理结束一共:{}", patSize);


        Long count = hnGatherPatArchiveMapper.selectPatMedInhospListCount(null);
        Long aa = (count + 1000 - 1) / 1000;
        //进行分页查询
@@ -82,18 +98,12 @@
            List<PatMedInhosp> patMedInhospList = hnGatherPatArchiveMapper.selectPatMedInhospList(patMedInhosp);
            for (PatMedInhosp pm : patMedInhospList) {
                String patno = pm.getPatno();
                PatArchive patArchive = new PatArchive();
                PatArchive pa = new PatArchive();
                //先去我们自己的表里通过patno查询该患者是否存在
                patArchive.setPatientno(patno);
                List<PatArchive> patArchives = patArchiveMapper.selectPatArchiveList(patArchive);
                pa.setPatientno(patno);
                List<PatArchive> patArchives = patArchiveMapper.selectPatArchiveList(pa);
                if (CollectionUtils.isEmpty(patArchives)) {
                    //不存在，则通过patno去HIS表hzjbxx查询
                    List<PatArchive> patArchives1 = hnGatherPatArchiveMapper.selectPatArchiveList(patArchive);
                    //把查询出来的数据存到pat_archive表
                    PatArchive pa = patArchives1.get(0);
                    pa.setId(null);
                    patArchiveMapper.insertPatArchiveSingle(pa);
                    pm.setPatid(pa.getId());
                    continue;
                } else {
                    //直接将patid放到出入院表中
                    pm.setPatid(patArchives.get(0).getId());
@@ -103,7 +113,6 @@
                patMedInhospMapper.insertPatMedInhospBatch(patMedInhospList);
            }
        }

        return null;
    }