From dadd95ea351e9747fb66bcc0e57f3ebcae5de73a Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期五, 11 四月 2025 14:57:58 +0800
Subject: [PATCH] update

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/callingscreen/CallingScreenServiceImpl.java |   54 ++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 40 insertions(+), 14 deletions(-)

diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/callingscreen/CallingScreenServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/callingscreen/CallingScreenServiceImpl.java
index e152f46..b629f61 100644
--- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/callingscreen/CallingScreenServiceImpl.java
+++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/callingscreen/CallingScreenServiceImpl.java
@@ -66,7 +66,7 @@
         // 鏄剧ず鍒� 瀵瑰簲鐨勬鏌ョ被鍨嬪悕鍒楄〃
         Map<Integer, List<String>> _map = new HashMap<>();
         mapDisplayColName.keySet().forEach(key -> {
-            _map.put(key, mapDisplayColName.get(key).stream().map(item->item.getName()).toList());
+            _map.put(key, mapDisplayColName.get(key).stream().map(item->item.getName()+item.getSeqPrefix()).toList());
         });
         return _map;
     }
@@ -100,18 +100,41 @@
             columnQueueData.add( queueDO );
         });
 
+        mapDisplayColQueue.values().forEach( _queueDOList -> {
+            //鎶� [浜插拰鐨刔 鎸埌涓婚」鍚庨潰
+            List<QueueDO> affinityWaitingList = new ArrayList<>();
+            ListIterator<QueueDO> iterator = _queueDOList.listIterator();
+            while (iterator.hasNext()) {
+                QueueDO item = iterator.next();
+                if (item.getStatus() == QueueStatusEnum.AFFINITY.getStatus()) {
+                    iterator.remove();
+                    affinityWaitingList.add(item);
+                }
+            }
+            affinityWaitingList.forEach( affinityWaitingItem -> {
+                for (int i = _queueDOList.size()-1; i >= 0; i--) {
+                    if ( affinityWaitingItem.getSeqNum() == _queueDOList.get(i).getSeqNum() ) {
+                        _queueDOList.add(i + 1, affinityWaitingItem);
+                        break;
+                    }
+                }
+            });
+        });
+
         return mapDisplayColQueue;
     }
 
     @Override
-    public List<QueueDO> getRoomCheckRelatedPatient(String ip) {
-        List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
-        Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
-        if (!optionalQueueDO.isPresent()) {
-            return  new ArrayList<QueueDO>();
+    public List<QueueDO> getRoomCheckRelatedPatient(String ip, Long roomId) {
+        if (null == roomId) {
+            List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
+            Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
+            if (!optionalQueueDO.isPresent()) {
+                return new ArrayList<QueueDO>();
+            }
+            roomId = optionalQueueDO.get().getRoomId();
         }
 
-        Long roomId = optionalQueueDO.get().getRoomId();
         List<Integer> queueStatusList = new ArrayList<>();
         queueStatusList.add(QueueStatusEnum.RECALLED.getStatus());
         queueStatusList.add(QueueStatusEnum.READY.getStatus());
@@ -143,14 +166,17 @@
     }
 
     @Override
-    public List<QueueDO> getRoomInstallRelatedPatient(String ip) {
-        List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
-        Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
-        if (!optionalQueueDO.isPresent()) {
-            return  new ArrayList<QueueDO>();
-        }
+    public List<QueueDO> getRoomInstallRelatedPatient(String ip, Long roomId) {
+        if (null == roomId) {
+            List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
+            Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
+            if (!optionalQueueDO.isPresent()) {
+                return new ArrayList<QueueDO>();
+            }
 
-        Long roomId = optionalQueueDO.get().getRoomId();
+            roomId = optionalQueueDO.get().getRoomId();
+        }
+        
         List<Integer> queueStatusList = new ArrayList<>();
         queueStatusList.add(QueueStatusEnum.RECEIVED.getStatus());
         queueStatusList.add(QueueStatusEnum.PASSED_INSTALL.getStatus());

--
Gitblit v1.9.3