From e4bbdaaceab80b2528924510308ef2b7c0334471 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期日, 01 九月 2024 13:13:21 +0800
Subject: [PATCH] update

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/BedOpenCallable.java |   20 +++++++-------------
 1 files changed, 7 insertions(+), 13 deletions(-)

diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/BedOpenCallable.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/BedOpenCallable.java
index ce858c6..51fe0a2 100644
--- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/BedOpenCallable.java
+++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/BedOpenCallable.java
@@ -1,20 +1,9 @@
 package cn.lihu.jh.module.ecg.service.queue;
 
 import cn.lihu.jh.framework.common.exception.ErrorCode;
-import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
-import cn.lihu.jh.module.ecg.dal.mysql.queue.queueMapper;
-import cn.lihu.jh.module.ecg.dal.mysql.room.RoomMapper;
-import cn.lihu.jh.module.ecg.enums.BedStatusEnum;
-import cn.lihu.jh.module.ecg.enums.QueueStatusEnum;
+import cn.lihu.jh.framework.common.exception.enums.GlobalErrorCodeConstants;
 
-import java.util.ArrayList;
-import java.util.List;
 import java.util.concurrent.Callable;
-import java.util.concurrent.ConcurrentHashMap;
-import java.util.concurrent.PriorityBlockingQueue;
-import java.util.concurrent.atomic.AtomicInteger;
-
-import static cn.lihu.jh.module.ecg.service.queue.QueueService.MAX_QUEUE_NUM;
 
 public class BedOpenCallable implements Callable<ErrorCode> {
 
@@ -31,7 +20,12 @@
     }
 
     public ErrorCode call() throws Exception {
-        return queueService.bedOpen(roomId, bedNo);
+        ErrorCode ec = queueService.bedOpen(roomId, bedNo);
+        if (GlobalErrorCodeConstants.SUCCESS.equals(ec)) {
+            queueService.hurryup();
+        }
+
+        return ec;
     }
 
 }

--
Gitblit v1.9.3