From 6f3dccfb2b810d85afd305842b211fa2975da33a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=AE=87=E5=AE=99=E7=9A=AE=E7=9A=AE=E5=A8=83?=
 <2964346877@qq.com>
Date: Thu, 12 Oct 2023 11:35:15 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=87=BA=E9=99=A2=E7=A7=91?=
 =?UTF-8?q?=E5=AE=A4=E5=92=8C=E7=97=85=E5=8C=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../busservice/impl/SdBusinessServiceImpl.java    | 15 ++++++++++++++-
 .../docus/server/message/mapper/TBasicMapper.java |  7 +++++++
 src/main/resources/mapper/TBasicMapper.xml        |  8 ++++++++
 3 files changed, 29 insertions(+), 1 deletion(-)

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 57438df..1cb993e 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
@@ -3,6 +3,7 @@ package com.docus.server.message.busservice.impl;
 import com.alibaba.fastjson.JSONObject;
 import com.docus.core.util.FileUtil;
 import com.docus.core.util.Func;
+import com.docus.core.util.ObjectUtil;
 import com.docus.infrastructure.core.exception.BaseException;
 import com.docus.infrastructure.web.api.CommonResult;
 import com.docus.infrastructure.web.api.ResultCode;
@@ -306,6 +307,11 @@ public class SdBusinessServiceImpl implements SdBusinessService {
         HisZyCyYzDTO hisZyCyYzDTO = null;
 
         List<HisZyCyYzDTO> zyCyYzDtos = response.getData();
+        HisZyCyYzDTO dto = zyCyYzDtos.get(0);
+        if(ObjectUtil.isNotEmpty(dto)){
+            updateDisDeptAndWardCode(patientId,dto);
+        }
+
         // 3 5 状态可更新时间
         List<String> status = Arrays.asList("3", "5");
         for (HisZyCyYzDTO zyCyYzDTO : zyCyYzDtos) {
@@ -318,7 +324,6 @@ public class SdBusinessServiceImpl implements SdBusinessService {
         if (Objects.isNull(hisZyCyYzDTO)) {
             return false;
         }
-
         // 更新出院时间
         tBasicMapper.updateDisDateTime(patientId, hisZyCyYzDTO.getStop_time());
         // 再次判断
@@ -326,6 +331,14 @@ public class SdBusinessServiceImpl implements SdBusinessService {
         return count2 > 0;
     }
 
+    private void updateDisDeptAndWardCode(String patientId,HisZyCyYzDTO dto){
+        String deptCode = dto.getDept_code();
+        String deptCodeName = dto.getDept_code_name();
+        String wardCode = dto.getWard_code();
+        String wardCodeName = dto.getWard_code_name();
+        tBasicMapper.updateDisDeptAndWardCode(patientId,deptCode,deptCodeName,wardCode,wardCodeName);
+    }
+
     /**
      * 判断医嘱返回结果是否是空
      *
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 5d15e37..bfd06f8 100644
--- a/src/main/java/com/docus/server/message/mapper/TBasicMapper.java
+++ b/src/main/java/com/docus/server/message/mapper/TBasicMapper.java
@@ -66,6 +66,13 @@ public interface TBasicMapper {
      */
     int updateDisDateTime(@Param("patientId") String patientId, @Param("disDate") String disDate);
 
+    int updateDisDeptAndWardCode(@Param("patientId") String patientId,
+                                 @Param("deptCode") String deptCode,
+                                 @Param("deptCodeName") String deptCodeName,
+                                 @Param("wardCode") String wardCode,
+                                 @Param("wardCodeName") String wardCodeName);
+
+
     /**
      * 更新基础信息，是否重症患者
      *
diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml
index 696464e..74ae6cc 100644
--- a/src/main/resources/mapper/TBasicMapper.xml
+++ b/src/main/resources/mapper/TBasicMapper.xml
@@ -35,6 +35,14 @@
         set `emr_submit`=#{emrSubmitState}
         where patient_id=#{patientId}
     </update>
+    <update id="updateDisDeptAndWardCode">
+        update `docus_medicalrecord`.`t_basic`
+        set `dis_dept`=#{deptCode},
+         `dis_dept_name`=#{deptCodeName},
+         `ward_code`=#{wardCode},
+         `ward_name`=#{wardCodeName}
+        where patient_id=#{patientId}
+    </update>
 
 
     <select id="getPatientIdsByInpatientNoAndTimes" resultType="java.lang.String">