From 11e73608f1a558c094811aae97a5bccd60317bc2 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期三, 13 十一月 2024 10:24:34 +0800
Subject: [PATCH] Fix Bug: 工位 准备中数量 不对

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java |   21 ++++++---------------
 1 files changed, 6 insertions(+), 15 deletions(-)

diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java
index 8a38c87..6c7db20 100644
--- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java
+++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java
@@ -274,18 +274,6 @@
         firstReadyQueueItem.setStatus(QueueStatusEnum.ONSTAGE.getStatus());
         queueMapper.updateById( firstReadyQueueItem );
 
-        // 妫�鏌ラ」鐩�.浜插拰鎬� 澶勭悊閫昏緫
-        CheckTypeDO checkTypeDO = getCheckTypeItem( firstReadyQueueItem.getBookCheckType() );
-        if (checkTypeDO.getAffinityCheckTypes().length > 0) {
-            List<QueueDO> affinityItems = queueMapper.getCurPatGivenCheckTypesAndStatus(firstReadyQueueItem.getPatId(), checkTypeDO.getAffinityCheckTypes(), QueueStatusEnum.AFFINITY_WAITING.getStatus());
-            if (!affinityItems.isEmpty()) {
-                QueueDO tmpQueueDO = affinityItems.get(0);
-                tmpQueueDO.setStatus( QueueStatusEnum.READY.getStatus() );
-                queueMapper.updateById( tmpQueueDO );
-                return GlobalErrorCodeConstants.SUCCESS;   // 鍑嗗涓� 鏁伴噺娌℃湁鍙樺寲锛屾晠鐩存帴杩斿洖
-            }
-        }
-
         // 浼樺厛闃熷垪涓� 璇ュ伐浣� 灏辫瘖鍑嗗涓汉鐨勬暟閲� 鍑忎竴
         BedQueueBO bo = mapBedVsQueue.get( Utils.formatRoomBed( roomId, bedNo ) );
         bo.queueNum.getAndDecrement(); // 鍙兘宸茬粡銆愬苟鍙戠殑銆戝湪 hurry-up 涓敼鍙樹簡鍊�
@@ -304,6 +292,7 @@
         }
 
         firstItem.setStatus( QueueStatusEnum.INSTALLING.getStatus() );
+        firstItem.setBedNo( bedNo );
         queueMapper.updateById( firstItem );
 
         // 妫�鏌ラ」鐩�.浜插拰鎬� 澶勭悊閫昏緫
@@ -314,6 +303,7 @@
             for (int i = 0; i < affinityItems.size(); i++) {
                 QueueDO queueItem = affinityItems.get(i);
                 queueItem.setStatus(QueueStatusEnum.AFFINITY_RECEIVED.getStatus()); //鏀瑰彉 鎺掗槦鐘舵��
+                queueItem.setBedNo( bedNo );  // 璺熼殢鍒� 瑁呮満 宸ヤ綅
                 queueMapper.updateById(queueItem);
             }
         }
@@ -473,9 +463,9 @@
                 for (int i = 0; i < affinityItems.size(); i++) {
                     QueueDO queueItem = affinityItems.get(i);
                     queueItem.setStatus(QueueStatusEnum.AFFINITY_WAITING.getStatus()); //鏀瑰彉 鎺掗槦鐘舵��
-                    queueItem.setRoomId(queueItem.getRoomId());
-                    queueItem.setRoomName(queueItem.getRoomName());
-                    queueItem.setBedNo(queueItem.getBedNo());
+                    queueItem.setRoomId(queueDO.getRoomId());
+                    queueItem.setRoomName(queueDO.getRoomName());
+                    queueItem.setBedNo(queueDO.getBedNo());
                     queueItem.setSeqNum(curSeqNum.get() + 1);  // 浣跨敤鍚屼竴涓� 鍐呴儴搴忓彿
                     queueMapper.updateById(queueItem);
                 }
@@ -629,6 +619,7 @@
         monitorInfoVO.setQueueNum(mapBedVsQueue.size());
         monitorInfoVO.setActiveQueueNum((int) mapBedVsQueue.values().stream().filter(item -> item.getStatus() == BedStatusEnum.DOCTOR_ON.getStatus()).count());
         monitorInfoVO.setPriorityQueueNum( hashSetOperatingBedQueue.size() );
+        monitorInfoVO.setMapBedVsQueue( mapBedVsQueue );
     }
 
 }

--
Gitblit v1.9.3