From d01f602b0a7f18f24ba84f67405c77bf38272e4d Mon Sep 17 00:00:00 2001
From: wyb <1977763549@qq.com>
Date: Mon, 6 Nov 2023 15:41:35 +0800
Subject: [PATCH] =?UTF-8?q?=E7=97=85=E6=A1=88=E7=AD=BE=E5=87=BA=EF=BC=8C?=
 =?UTF-8?q?=E5=A6=82=E6=9E=9C=E6=9C=89=E5=AE=9D=E5=AE=9D=EF=BC=8C=E5=AE=9D?=
 =?UTF-8?q?=E5=AE=9D=E4=B9=9F=E9=9C=80=E8=A6=81=E7=94=9F=E6=88=90=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dao/mapper/TBasicMapper.java              |  2 ++
 .../service/impl/MzZyHisServiceImpl.java      | 27 +++++++++++++++----
 src/main/resources/mapper/TBasicMapper.xml    |  3 +++
 3 files changed, 27 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java b/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java
index 7977dc5..bf48bd8 100644
--- a/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java
+++ b/src/main/java/com/docus/server/collection/infrastructure/dao/mapper/TBasicMapper.java
@@ -23,4 +23,6 @@ public interface TBasicMapper{
     Integer update(@Param("tBasic") TBasic tBasic);
 
     String getPatientIdByJzh(@Param("jzh") String jzh);
+
+    List<String> getPatientIdByMomJzh(@Param("momJzh") String momJzh);
 }
diff --git a/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java b/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java
index a4d5f75..47a03ce 100644
--- a/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java
+++ b/src/main/java/com/docus/server/collection/service/impl/MzZyHisServiceImpl.java
@@ -19,10 +19,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -43,7 +40,6 @@ public class MzZyHisServiceImpl implements MzZyHisService {
 
     @Override
     public void firstPageCheckout(FirstPageCheckoutInDTO dto) {
-        System.out.println(dto);
         PatientInfoDTO patientInfo = dto.getPatientInfo();
         //验证基础数据是否存在
         String patientId = tBasicMapper.getPatientIdByJzh(patientInfo.getInpatientNo());
@@ -67,6 +63,27 @@ public class MzZyHisServiceImpl implements MzZyHisService {
         if (result.getCode().equals(ResultCode.FAILED.getCode())) {
             throw new RuntimeException(commonResult.getMsg());
         }
+        babyTaskCompensate(patientInfo.getInpatientNo(),collectorIds);
+    }
+
+    /**
+     * 根据母亲的住院流水号，查询宝宝的病案主键，进行任务补偿
+     * @param momJzh 母亲住院流水号
+     * @param collectorIds 采集器id
+     */
+    private void babyTaskCompensate(String momJzh, List<String> collectorIds) {
+        List<String> babyPatientIds=tBasicMapper.getPatientIdByMomJzh(momJzh);
+        if(Func.isNotEmpty(babyPatientIds)){
+            // 进行任务补偿
+            CompensateTasRequest request = new CompensateTasRequest();
+            request.setPatientIds(babyPatientIds);
+            request.setPriority(4);
+            request.setCollectorIds(collectorIds);
+            collectTaskService.compensateTask(request);
+            for (String babyPatientId : babyPatientIds) {
+                medicalrecordService.signOutOrBackRepair(babyPatientId);
+            }
+        }
     }
 
     private List<String> systemMappingCollectorIds(FirstPageCheckoutInDTO dto) {
diff --git a/src/main/resources/mapper/TBasicMapper.xml b/src/main/resources/mapper/TBasicMapper.xml
index 83d0fc8..3a92f97 100644
--- a/src/main/resources/mapper/TBasicMapper.xml
+++ b/src/main/resources/mapper/TBasicMapper.xml
@@ -88,5 +88,8 @@
     <select id="getPatientIdByJzh" resultType="java.lang.String">
         select patient_id from `docus_medicalrecord`.`t_basic` where jzh=#{jzh}
     </select>
+    <select id="getPatientIdByMomJzh" resultType="java.lang.String">
+        select patient_id from `docus_medicalrecord`.`t_basic` where mother_inpatient_no=#{momJzh}
+    </select>
 
 </mapper>