From 8d828e0e2c2c6a7ddaabbe5f746fcbdc88d13527 Mon Sep 17 00:00:00 2001
From: wyb <1977763549@qq.com>
Date: Wed, 23 Aug 2023 09:31:15 +0800
Subject: [PATCH] =?UTF-8?q?=E6=98=AF=E5=90=A6=E9=87=8D=E7=97=87=E6=82=A3?=
 =?UTF-8?q?=E8=80=85=EF=BC=8C=E4=BD=BF=E7=94=A8=E5=BC=82=E6=AD=A5=E6=8F=90?=
 =?UTF-8?q?=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/TBasicServiceImpl.java       | 25 ++++++++++++++++---
 1 file changed, 22 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/docus/server/collection/service/impl/TBasicServiceImpl.java b/src/main/java/com/docus/server/collection/service/impl/TBasicServiceImpl.java
index 1fc367c..434f306 100644
--- a/src/main/java/com/docus/server/collection/service/impl/TBasicServiceImpl.java
+++ b/src/main/java/com/docus/server/collection/service/impl/TBasicServiceImpl.java
@@ -17,6 +17,8 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.util.Date;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @BelongsProject: docus-webservice-sdry
@@ -39,6 +41,9 @@ public class TBasicServiceImpl implements ITBasicService {
     @Resource
     private SdRyHospitalRpc sdRyHospitalRpc;
 
+    @Resource
+    private ThreadPoolExecutor threadPoolExecutor;
+
     @Override
     @Transactional
     public void setTBasic(TBasicDto tBasicDto) throws Exception {
@@ -119,9 +124,10 @@ public class TBasicServiceImpl implements ITBasicService {
         //持久化
         tBasicMapper.insert(tBasic);
         tBasicMapper.insertExtend(tBasicExtend);
-        sdRyHospitalRpc.confirmAndUpdIcuRecordState(tBasic.getInpatientNo(),tBasic.getAdmissTimes());
+        confirmAndUpdIcuRecordState(tBasic.getInpatientNo(),tBasic.getAdmissTimes());
     }
 
+
     @Override
     @Transactional
     public void updateTBasic(TBasicDto tBasicDto) throws Exception {
@@ -202,7 +208,7 @@ public class TBasicServiceImpl implements ITBasicService {
         //持久化
         tBasicMapper.update(tBasic);
         tBasicMapper.updateExtend(tBasicExtend);
-        sdRyHospitalRpc.confirmAndUpdIcuRecordState(tBasic.getInpatientNo(),tBasic.getAdmissTimes());
+        confirmAndUpdIcuRecordState(tBasic.getInpatientNo(),tBasic.getAdmissTimes());
     }
 
     @Override
@@ -289,7 +295,7 @@ public class TBasicServiceImpl implements ITBasicService {
         //持久化
         tBasicMapper.update(tBasic);
         tBasicMapper.updateExtend(tBasicExtend);
-        sdRyHospitalRpc.confirmAndUpdIcuRecordState(tBasic.getInpatientNo(),tBasic.getAdmissTimes());
+        confirmAndUpdIcuRecordState(tBasic.getInpatientNo(),tBasic.getAdmissTimes());
     }
 
 
@@ -319,6 +325,19 @@ public class TBasicServiceImpl implements ITBasicService {
         TBasic tBasic= tBasicMapper.getByPatientId(patientId);
         return Func.isNotEmpty(tBasic) && Func.isNotBlank(tBasic.getInpatientNo()) && tBasic.getInpatientNo().toUpperCase().contains("B");
     }
+
+
+    public void confirmAndUpdIcuRecordState(String inpatientNo,Integer admissTimes){
+        threadPoolExecutor.execute(()->{
+            // 此处异步，睡眠一秒保证事务提交
+            try {
+                TimeUnit.SECONDS.sleep(1);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+            sdRyHospitalRpc.confirmAndUpdIcuRecordState(inpatientNo,admissTimes);
+        });
+    }
 }