| | |
| | | |
| | | @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; |
| | | //进行分页查询 |
| | |
| | | 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()); |
| | |
| | | patMedInhospMapper.insertPatMedInhospBatch(patMedInhospList); |
| | | } |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | |