From 0c4c2d94b9ec61c96fb124ae7878d9f13777dd64 Mon Sep 17 00:00:00 2001
From: wyb <1977763549@qq.com>
Date: Fri, 24 Nov 2023 10:30:15 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A6=82=E6=9E=9C=E5=AD=98=E5=9C=A8=EF=BC=8C?=
 =?UTF-8?q?=E4=B8=8D=E5=86=8D=E6=9F=A5=E8=AF=A2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/docus/server/AppRunBootstrap.java       | 2 ++
 .../message/busservice/impl/SdBusinessServiceImpl.java    | 3 +++
 .../server/message/dao/TrInpatientOutpatientDao.java      | 6 ++++++
 .../message/dao/impl/TrInpatientOutpatientDaoImpl.java    | 8 ++++++++
 4 files changed, 19 insertions(+)

diff --git a/src/main/java/com/docus/server/AppRunBootstrap.java b/src/main/java/com/docus/server/AppRunBootstrap.java
index 76613b9..87ab35c 100644
--- a/src/main/java/com/docus/server/AppRunBootstrap.java
+++ b/src/main/java/com/docus/server/AppRunBootstrap.java
@@ -1,6 +1,8 @@
 package com.docus.server;
 
 
+import com.docus.infrastructure.core.utils.SpringUtil;
+import com.docus.server.message.dao.TrInpatientOutpatientDao;
 import lombok.extern.slf4j.Slf4j;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
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 a8c9dc7..7077c72 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
@@ -120,6 +120,9 @@ public class SdBusinessServiceImpl implements SdBusinessService {
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void trInpatientOutPatient(String patientId) {
+       if (trInpatientOutpatientDao.exists(patientId)){
+           return;
+       }
         String sdRyIndex = tBasicMapper.getSdRyIndex(patientId);
         if (Func.isBlank(sdRyIndex)) {
             log.warn("patientId：{} 没有患者索引！", patientId);
diff --git a/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java b/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java
index 79c0f89..39e6fa8 100644
--- a/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java
+++ b/src/main/java/com/docus/server/message/dao/TrInpatientOutpatientDao.java
@@ -20,4 +20,10 @@ public interface TrInpatientOutpatientDao extends IBaseDao<TrInpatientOutpatient
      * @param inpatientId 住院病案主键
      */
     void deleteTrInpatientOutpatientByInpatientId(String inpatientId);
+    /**
+     * 根据住院病案主键查询是否已经有关联关系
+     * @param inpatientId 住院病案主键
+     * @return 存在true 不存在 false
+     */
+    boolean exists(String inpatientId);
 }
diff --git a/src/main/java/com/docus/server/message/dao/impl/TrInpatientOutpatientDaoImpl.java b/src/main/java/com/docus/server/message/dao/impl/TrInpatientOutpatientDaoImpl.java
index b1f6bb1..849626f 100644
--- a/src/main/java/com/docus/server/message/dao/impl/TrInpatientOutpatientDaoImpl.java
+++ b/src/main/java/com/docus/server/message/dao/impl/TrInpatientOutpatientDaoImpl.java
@@ -36,4 +36,12 @@ public class TrInpatientOutpatientDaoImpl extends BaseDaoImpl<TrInpatientOutpati
         wrapper.eq(TrInpatientOutpatient::getPatientId, inpatientId);
         baseMapper.delete(wrapper);
     }
+
+    @Override
+    public boolean exists(String inpatientId) {
+        LambdaQueryWrapper<TrInpatientOutpatient> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(TrInpatientOutpatient::getPatientId, inpatientId);
+        wrapper.last(" LIMIT 1");
+        return   baseMapper.selectCount(wrapper)>1;
+    }
 }