From 3e696d457f13338a7eb5ad0935a7d2c7affcf605 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期五, 23 八月 2024 11:02:36 +0800
Subject: [PATCH] update

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java |   23 ++++++++++++++---------
 1 files changed, 14 insertions(+), 9 deletions(-)

diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java
index 48d615c..f7bd7f9 100644
--- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java
+++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java
@@ -227,9 +227,7 @@
         if (0 == openingFlag.get())
             return;
 
-        singleThreadExecutor.execute( () -> {
-            hurryup();
-        });
+        startHurryUp();
     }
 
     private void nextPatient(Long roomId, String bedNo) {
@@ -248,9 +246,7 @@
         priorityQueue.remove(bo);
         priorityQueue.offer(bo);
 
-        singleThreadExecutor.execute( () -> {
-            hurryup();
-        });
+        startHurryUp();
     }
 
     public void finishNextPatient(Long roomId, String bedNo) {
@@ -301,16 +297,25 @@
     }
 
     @Override
-    public Integer passedPatientReturn(Long roomId, String bedNo, String patId) {
+    public Integer recallPatient(Long roomId, String bedNo, String patId) {
         Integer updateNum = queueMapper.passedPatientReturn(roomId, bedNo, patId,
                 QueueStatusEnum.PASSED.getStatus(), QueueStatusEnum.PASSED_RETURN.getStatus());
+        startHurryUp();
         return updateNum;
     }
 
     @Override
-    public Integer queueJump(String patId, Byte jumped) {
+    public Integer patientJump(String patId, Byte jumped) {
         Integer updateNum = queueMapper.queueJump(patId, QueueStatusEnum.WAITING.getStatus(), jumped);
-        return null;
+        startHurryUp();
+        return updateNum;
+    }
+
+    private void startHurryUp() {
+        singleThreadExecutor.execute( () -> {
+            hurryup();
+        });
     }
 
 }
+

--
Gitblit v1.9.3