From 6e9a55146866cd357592a0e0e8aa7b73cf9f036d Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期三, 13 十一月 2024 11:10:57 +0800
Subject: [PATCH] 领用界面 患者队列顺序 @检查项目亲和性

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceImpl.java |   37 +++++++++++++++++++++----------------
 1 files changed, 21 insertions(+), 16 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 477871b..6b9a90b 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
@@ -198,7 +198,7 @@
             e.printStackTrace();
         }
 
-        System.out.println("startBedDoctorOff ========");
+        //System.out.println("startBedDoctorOff ========");
         return ECG_INNER_ERROR;
     }
 
@@ -217,7 +217,7 @@
             e.printStackTrace();
         }
 
-        System.out.println("startNextPatient ========");
+        //System.out.println("startNextPatient ========");
         return ECG_INNER_ERROR;
     }
 
@@ -323,18 +323,17 @@
         // 澶勭悊 妫�鏌ラ」鐩�.浜插拰鎬� 閫昏緫
         CheckTypeDO checkTypeDO = queueServiceTxFunctions.getCheckTypeItem( queueSaveReqVO.getBookCheckType() );
         if ( checkTypeDO.getAffinityCheckTypes().length > 0) {
-            List<QueueDO> affinityItems = queueMapper.getCurPatGivenCheckItems(queueSaveReqVO.getPatId(), checkTypeDO.getAffinityCheckTypes());
-            //List<Integer> affinityItemIDs = affinityItems.stream().map(queueItem -> queueItem.getId()).toList();
-            //queueSaveReqVO.setAffinityItems(affinityItemIDs);
+            List<QueueDO> affinityItems = queueMapper.getCurPatGivenCheckTypes(queueSaveReqVO.getPatId(), checkTypeDO.getAffinityCheckTypes());
 
             for (int i=0; i < affinityItems.size(); i++) {
                 QueueDO queueItem = affinityItems.get(i);
                 if (QueueStatusEnum.READY.getStatus() == queueItem.getStatus()
-                        || QueueStatusEnum.ONSTAGE.getStatus() == queueItem.getStatus()) {
-                    queueSaveReqVO.setStatus(QueueStatusEnum.AFFINITY_ALREADY.getStatus()); //鏀瑰彉 鎺掗槦鐘舵��
+                    || QueueStatusEnum.ONSTAGE.getStatus() == queueItem.getStatus()) {
+                    queueSaveReqVO.setStatus(QueueStatusEnum.AFFINITY_WAITING.getStatus()); //鏀瑰彉 鎺掗槦鐘舵��
                     queueSaveReqVO.setRoomId(queueItem.getRoomId());
                     queueSaveReqVO.setRoomName(queueItem.getRoomName());
                     queueSaveReqVO.setBedNo(queueItem.getBedNo());
+                    queueSaveReqVO.setSeqNum(queueItem.getSeqNum());
                     break;
                 }
             }
@@ -346,6 +345,7 @@
         DevRentDO devRent = BeanUtils.toBean(queueSaveReqVO, DevRentDO.class);
         devRent.setState( DevRentStateEnum.FREE.getState() );
         devRent.setPatDetails( queueSaveReqVO.getPatDetails() );
+        devRent.setCheckType( queueSaveReqVO.getBookCheckType() );
         devRentMapper.insert(devRent);
 
         startHurryUpOneCheckType( queue.getBookCheckType() );
@@ -371,10 +371,6 @@
     // 棰嗙敤 鍙彿
     @Override
     public void finishReceiveNextPatient(Long roomId, String bedNo) {
-        // 浠� DB 鎶� [灏辫瘖涓璢 鐨勪汉 璁剧疆涓� 銆愬凡棰嗙敤銆�
-        //Integer ret =  queueMapper.updateBedQueueStatus(roomId, bedNo,
-        //        QueueStatusEnum.ONSTAGE.getStatus(), QueueStatusEnum.RECEIVED.getStatus());
-
         // 浠� DB 妫�鏌� 璇ュ伐浣� 鏄惁鏈� [灏辫瘖涓璢 浜哄憳锛岃嫢鏈夊氨.鏀惧純鍙栦笅涓�浣�
         List<Integer> queueStatusList = new ArrayList<>();
         queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
@@ -388,11 +384,7 @@
     // 瑁呮満 鍙彿
     @Override
     public void finishInstallNextPatient(Long roomId, String bedNo) {
-        // 浠� DB 鎶� [瀹夎涓璢 鐨勪汉 璁剧疆涓� [宸插氨璇奭
-        //Integer ret =  queueMapper.updateBedQueueStatus(roomId, bedNo,
-        //        QueueStatusEnum.INSTALLING.getStatus(), QueueStatusEnum.FINISH.getStatus());
-
-        // 浠� DB 妫�鏌� 璇ュ伐浣� 鏄惁鏈� [灏辫瘖涓璢 浜哄憳锛岃嫢鏈夊氨.鏀惧純鍙栦笅涓�浣�
+        // 浠� DB 妫�鏌� 璇ュ伐浣� 鏄惁鏈� [瀹夎涓璢 浜哄憳锛岃嫢鏈夊氨.鏀惧純鍙栦笅涓�浣�
         List<Integer> queueStatusList = new ArrayList<>();
         queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus());
         Integer num = queueMapper.bedQueueStatisticByStatus(roomId, bedNo, queueStatusList);
@@ -574,7 +566,19 @@
         queueStatusList.add(QueueStatusEnum.READY.getStatus());
         queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
         queueStatusList.add(QueueStatusEnum.PASSED.getStatus());
+        queueStatusList.add(QueueStatusEnum.AFFINITY_WAITING.getStatus());
         List<QueueDO> queueDOList = getBedQueueByStatus(roomId, bedNo, queueStatusList);
+
+        //鎶奫杩囧彿鐨刔鎸埌鍚庨潰
+        ListIterator<QueueDO> iterator = queueDOList.listIterator();
+        while (iterator.hasNext()) {
+            QueueDO item = iterator.next();
+            if (item.getStatus() == QueueStatusEnum.PASSED.getStatus()) {
+                iterator.remove();
+                queueDOList.add(item);
+            }
+        }
+
         return queueDOList;
     }
 
@@ -583,6 +587,7 @@
         List<Integer> queueStatusList = new ArrayList<>();
         queueStatusList.add(QueueStatusEnum.RECEIVED.getStatus());
         queueStatusList.add(QueueStatusEnum.PASSED_INSTALL.getStatus());
+        queueStatusList.add(QueueStatusEnum.AFFINITY_RECEIVED.getStatus());
         List<QueueDO> queueDOList = getRoomQueueByStatus(roomId, queueStatusList);
 
         queueStatusList.clear();

--
Gitblit v1.9.3