From bf5cf3bcad13498390a4d4659638c6ba810cf606 Mon Sep 17 00:00:00 2001 From: wyb <1977763549@qq.com> Date: Mon, 30 Oct 2023 17:21:31 +0800 Subject: [PATCH] =?UTF-8?q?=E6=A0=B9=E6=8D=AE=E6=AF=8D=E4=BA=B2=E6=9F=A5?= =?UTF-8?q?=E6=AF=8D=E5=A9=B4=E5=85=B3=E7=B3=BB=E4=BD=BF=E7=94=A8=E9=9B=86?= =?UTF-8?q?=E5=90=88=EF=BC=8C=E5=8F=AF=E8=83=BD=E5=A4=9A=E4=B8=AA=E5=AE=9D?= =?UTF-8?q?=E5=AE=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../busservice/impl/SdBusinessServiceImpl.java | 18 +++++++++++------- .../server/message/mapper/TBasicMapper.java | 2 +- 2 files changed, 12 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java b/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java index 23e756f..653caf4 100644 --- a/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java +++ b/src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java @@ -174,13 +174,16 @@ public class SdBusinessServiceImpl implements SdBusinessService { TBasic tBasic = tBasicMapper.getTBasicInfo(parentPatientId); // 查医院患者索引 String parentIndex = tBasicMapper.getSdRyIndex(parentPatientId); + List babyPatientIds = new ArrayList<>(); // 查母婴关联关系 - MaternalInfantRelationship maternalInfantRelationship = tBasicMapper.getMiRelationByPatientIndexAndAdmissTimes(parentIndex, tBasic.getAdmissTimes().toString()); - // 根据宝宝的患者索引查病案主键,进行补偿 - String babyPatientId = tBasicMapper.getPatientIdBySdRyIndex(maternalInfantRelationship.getBabyId()); - List patientIds = Collections.singletonList(babyPatientId); - log.info("补偿婴儿任务 patientIds:{} collectId:{}", patientIds, babyCollectorIds); - compensateTask(patientIds, babyCollectorIds); + List maternalInfantRelationship = tBasicMapper.getMiRelationByPatientIndexAndAdmissTimes(parentIndex, tBasic.getAdmissTimes().toString()); + // 根据宝宝的患者索引查病案主键,进行补偿,可能多个宝宝 + for (MaternalInfantRelationship infantRelationship : maternalInfantRelationship) { + String babyPatientId = tBasicMapper.getPatientIdBySdRyIndex(infantRelationship.getBabyId()); + babyPatientIds.add(babyPatientId); + } + log.info("补偿婴儿任务 patientIds:{} collectId:{}", babyPatientIds, babyCollectorIds); + compensateTask(babyPatientIds, babyCollectorIds); } } catch (Exception ex) { log.error("判断是否产科与生成婴儿任务错误了,patientId:" + parentPatientId, ex); @@ -190,7 +193,8 @@ public class SdBusinessServiceImpl implements SdBusinessService { /** * 是否是产科的患者 - * @param patientId 病案主键 + * + * @param patientId 病案主键 * @param haveBabyQuery 产科患者的查询条件,如果为空,直接判定不是产科 * @return 根据产科患者查询条件,判定是否是产科的患者 */ diff --git a/src/main/java/com/docus/server/message/mapper/TBasicMapper.java b/src/main/java/com/docus/server/message/mapper/TBasicMapper.java index 1f8ff8d..1b87892 100644 --- a/src/main/java/com/docus/server/message/mapper/TBasicMapper.java +++ b/src/main/java/com/docus/server/message/mapper/TBasicMapper.java @@ -139,7 +139,7 @@ public interface TBasicMapper { * @param parentTimes 母亲住院次数 * @return 母婴关联关系 */ - MaternalInfantRelationship getMiRelationByPatientIndexAndAdmissTimes(@Param("parentIndex")String parentIndex, @Param("parentTimes") String parentTimes); + List getMiRelationByPatientIndexAndAdmissTimes(@Param("parentIndex")String parentIndex, @Param("parentTimes") String parentTimes); /** * 根据医院患者索引查询病案主键