From d8171199e6167ed1c27b838512c2863abf0d1020 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期三, 16 十月 2024 18:08:03 +0800
Subject: [PATCH] 大屏数据

---
 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/callingscreen/CallingScreenServiceImpl.java |   73 +++++++++++++++++++++++++++++++++++-
 1 files changed, 71 insertions(+), 2 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 f73da77..8f77ace 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
@@ -1,7 +1,11 @@
 package cn.lihu.jh.module.ecg.service.callingscreen;
 
+import cn.lihu.jh.framework.common.pojo.PageResult;
+import cn.lihu.jh.module.ecg.controller.admin.checktype.vo.CheckTypePageReqVO;
+import cn.lihu.jh.module.ecg.dal.dataobject.checktype.CheckTypeDO;
 import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO;
 import cn.lihu.jh.module.ecg.dal.dataobject.room.RoomDO;
+import cn.lihu.jh.module.ecg.dal.mysql.checktype.CheckTypeMapper;
 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.QueueStatusEnum;
@@ -12,6 +16,7 @@
 
 import javax.annotation.Resource;
 import java.util.*;
+import java.util.stream.Collectors;
 
 /**
  * 鎺掗槦 Service 瀹炵幇绫�
@@ -29,7 +34,14 @@
     @Resource
     private RoomMapper roomMapper;
 
+    @Resource
+    private CheckTypeMapper checkTypeMapper;
+
     BigScreenConfig bigScreenConfig;
+
+    Map<Integer, Integer> mapCheckTypeVsDisplayColumn = null;
+
+    Map<Integer, List<QueueDO>> mapDisplaySlotVsCallingData = new HashMap<>();
 
     Integer waitingFrom = 0;
     Integer passedFrom = 0;
@@ -41,7 +53,31 @@
 
     @Override
     public Map<Integer, List<QueueDO>> callingData() {
-        List<Byte> queueStatusList = new ArrayList<>();
+        if (null == mapCheckTypeVsDisplayColumn) {
+            getDisplayColumnConfig();
+        } else {
+            mapDisplaySlotVsCallingData.values().stream().forEach(slotQueueList -> slotQueueList.clear());
+        }
+
+        List<Integer> queueStatusList = new ArrayList<>();
+        queueStatusList.add(QueueStatusEnum.READY.getStatus());
+        queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
+        queueStatusList.add(QueueStatusEnum.WAITING.getStatus());
+        queueStatusList.add(QueueStatusEnum.RECALLED.getStatus());
+        queueStatusList.add(QueueStatusEnum.PASSED.getStatus());
+        List<QueueDO> queueDOList = queueMapper.getQueueByStatus( queueStatusList );
+        queueDOList.stream().forEach(queueDO -> {
+            List<QueueDO> listSolt = getDisplatSlotByQueue( queueDO.getBookCheckType(), queueDO.getStatus());
+            listSolt.add( queueDO );
+        });
+
+        mapDisplaySlotVsCallingData.values().stream().forEach(slotQueueList -> slotQueueList.sort(null));
+        return mapDisplaySlotVsCallingData;
+    }
+
+    @Override
+    public Map<Integer, List<QueueDO>> callingData2() {
+        List<Integer> queueStatusList = new ArrayList<>();
         queueStatusList.add(QueueStatusEnum.READY.getStatus());
         queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
         List<QueueDO> listReady = queueMapper.getQueueByStatus( queueStatusList );
@@ -83,7 +119,7 @@
     }
 
     @Override
-    public List<QueueDO> getRoomQueue(String ip, List<Byte> statusList) {
+    public List<QueueDO> getRoomQueue(String ip, List<Integer> statusList) {
         List<RoomDO> roomDOList = roomMapper.queueByIp(ip);
         Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst();
         if (!optionalQueueDO.isPresent()) {
@@ -95,4 +131,37 @@
         return queueDOList;
     }
 
+    private void getDisplayColumnConfig() {
+        CheckTypePageReqVO checkTypePageReqVO = new CheckTypePageReqVO();
+        checkTypePageReqVO.setPageSize(-1);
+        PageResult<CheckTypeDO> pageResult = checkTypeMapper.selectPage(checkTypePageReqVO);
+        mapCheckTypeVsDisplayColumn = pageResult.getList().stream().collect(Collectors.toMap(CheckTypeDO::getValue, item -> item.getCallingColumn()));
+
+        int displayColCnt = (int) mapCheckTypeVsDisplayColumn.values().stream().distinct().count();
+        for (int i=0; i<displayColCnt; i++) {
+            mapDisplaySlotVsCallingData.put(i*1000 + 0, new ArrayList<>());
+            mapDisplaySlotVsCallingData.put(i*1000 + 1, new ArrayList<>());
+            mapDisplaySlotVsCallingData.put(i*1000 + 2, new ArrayList<>());
+        }
+    }
+
+    private List<QueueDO> getDisplatSlotByQueue( Integer checkType, Integer queueStatus ) {
+        return mapDisplaySlotVsCallingData.get(mapCheckTypeVsDisplayColumn.get(checkType)*1000 + getDisplatSlotByQueueStatus(queueStatus));
+    }
+
+    private Integer getDisplatSlotByQueueStatus( Integer queueStatus ) {
+        if (QueueStatusEnum.READY.getStatus() == queueStatus)
+            return 0;
+        else if (QueueStatusEnum.ONSTAGE.getStatus() == queueStatus)
+            return 0;
+        else if (QueueStatusEnum.WAITING.getStatus() == queueStatus)
+            return 1;
+        else if (QueueStatusEnum.RECALLED.getStatus() == queueStatus)
+            return 1;
+        else if (QueueStatusEnum.PASSED.getStatus() == queueStatus)
+            return 2;
+        else
+            return 0;
+    }
+
 }

--
Gitblit v1.9.3