just refactopr 工位信息维护 分流队列维护

eight

2025-04-08 d88aeadb43f3aa1ce9fe6a358c5466e721a53038

just refactopr    工位信息维护  分流队列维护

 README.md

@@ -35,3 +35,11 @@
05. å°å±ï¼š éƒ½æ˜¯å·²ç»åˆ†æµçš„ æœ‰å·¥ä½å’Œå†…部序号


### å¼€è¯Šè®¾ç½®
开诊时间：6:30~23:59 1
工位概况： 8 2 1    ã€å¼€æ”¾çš„工位  æœ‰åŒ»ç”Ÿçš„工位  å‚与分流的工位(医生暂停的不计入)】
常规心电图 3 0 0 0  
动态心电 1 2 1 1    ã€å¼€æ”¾çš„检查/领用工位 å¼€æ”¾çš„安装工位 æœ‰åŒ»ç”Ÿçš„检查/领用工位 æœ‰åŒ»ç”Ÿçš„安装工位】
动态血压 1 2 1 1
平板运动心电 1 0 0 0
动脉硬化监测 1 0 0 0

 jh-module-ecg/jh-module-ecg-api/src/main/java/cn/lihu/jh/module/ecg/enums/BedOpTypeEnum.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,29 @@
package cn.lihu.jh.module.ecg.enums;

import cn.lihu.jh.framework.common.core.IntArrayValuable;
import lombok.AllArgsConstructor;
import lombok.Getter;

import java.util.Arrays;

/**
 * é€šç”¨çŠ¶æ€æžšä¸¾
 *
 * @author èŠ‹é“源码
 */
@Getter
@AllArgsConstructor
public enum BedOpTypeEnum {
    OP_CHECK(0, "检查"),
    OP_RECEIVE(1, "领用"),
    OP_INSTALL(2, "安装");

    /**
     * æ“ä½œç±»åž‹å€¼
     */
    private final Integer opType;
    /**
     * æ“ä½œç±»åž‹å
     */
    private final String name;
}

 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/room/vo/MonitorInfoVO.java

@@ -8,9 +8,9 @@

@Data
public class MonitorInfoVO {
    private Integer queueNum;
    private Integer activeQueueNum;
    private Integer priorityQueueNum;
    private Integer openingBedNum;
    private Integer docBedNum;
    private Integer routingBedNum;
    private Integer openingFlag;
    private Map<Integer, String> checkTypeBedInfo;
    private ConcurrentHashMap<String, BedQueueBO> mapBedVsQueue;

 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/dal/dataobject/room/RoomDO.java

@@ -65,9 +65,7 @@
    private Integer[] checkTypes;

    /**
     * 0 æ£€æŸ¥
     * 1 é¢†ç”¨
     * 2 è£…机
     * @see cn.lihu.jh.module.ecg.enums.BedOpTypeEnum
     */
    private Integer opType;
}

 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/BedQueueBO.java

@@ -12,6 +12,10 @@
    String roomName;
    AtomicInteger queueNum = new AtomicInteger(0);
    Integer maxQueueNum;

    /**
     * @see cn.lihu.jh.module.ecg.enums.BedStatusEnum
      */
    Integer status;
    Integer[] checkTypes;
    Integer opType;

 jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java

@@ -14,6 +14,7 @@
import cn.lihu.jh.module.ecg.dal.mysql.devrent.DevRentMapper;
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.BedOpTypeEnum;
import cn.lihu.jh.module.ecg.enums.BedStatusEnum;
import cn.lihu.jh.module.ecg.enums.QueueStatusEnum;
import cn.lihu.jh.module.infra.api.config.ConfigApi;
@@ -67,14 +68,12 @@
    AtomicInteger openingFlag = new AtomicInteger(0);
    AtomicInteger curSeqNum = new AtomicInteger(0);

    ConcurrentHashMap<String, BedQueueBO > mapBedVsQueue = new ConcurrentHashMap<>();
    // ç»´æŠ¤ å¼€æ”¾çš„工位
    ConcurrentHashMap<String, BedQueueBO > mapOpeningBed = new ConcurrentHashMap<>();

    // è£…机工位..不进入优先队列
    Map<Integer, PriorityBlockingQueue<BedQueueBO>> mapCheckTypePriorityQueue = new HashMap();

    // åŸºäºŽç±»åž‹çš„, è£…机准备的优先队列
    // Map<Integer, PriorityBlockingQueue<BedQueueBO>> mapReadyPriorityQueue = new HashMap();

    // è£…机工位..不进入分流队列
    Map<Integer, PriorityBlockingQueue<BedQueueBO>> mapCheckTypeRoutingQueue = new HashMap();
    
    Map<Integer, CheckTypeDO> mapCheckTypeVsReadyMax = null;

    /**
@@ -84,7 +83,7 @@
     * @return
     */
    public ErrorCode bedOpen(Long roomId, String roomName, String bedNo) {
        BedQueueBO bedQueueBO2 = mapBedVsQueue.get( Utils.formatRoomBed(roomId, bedNo) );
        BedQueueBO bedQueueBO2 = mapOpeningBed.get( Utils.formatRoomBed(roomId, bedNo) );
        if (null != bedQueueBO2) {
            log.error("bedOpen mapBedVsQueue has existed. " + roomId + " " + bedNo);
            return QUEUE_BED_EXIST;
@@ -115,25 +114,29 @@
        bedQueueBO.setStatus(BedStatusEnum.OPENING.getStatus());
        bedQueueBO.setCheckTypes( roomDO.getCheckTypes() );
        bedQueueBO.setOpType( roomDO.getOpType() );
        mapBedVsQueue.put( Utils.formatRoomBed(roomId, bedNo), bedQueueBO);
        mapOpeningBed.put( Utils.formatRoomBed(roomId, bedNo), bedQueueBO);

        return GlobalErrorCodeConstants.SUCCESS;
    }

    public ErrorCode bedClose(Long roomId, String bedNo) {
        BedQueueBO bedQueueBO = mapBedVsQueue.get( Utils.formatRoomBed(roomId, bedNo) );
        BedQueueBO bedQueueBO = mapOpeningBed.get( Utils.formatRoomBed(roomId, bedNo) );
        if (null == bedQueueBO) {
            log.error("bedClose mapBedVsQueue DONOT existed. " + roomId + " " + bedNo);
            return QUEUE_BED_NOT_EXIST;
        }

        // é™¤äº†åˆ¤æ–­ å‡†å¤‡å€™è¯Šä¸­ çš„人数，还需要 åˆ¤æ–­ è¿‡å·çš„人数
        //if (bedQueueBO.getQueueNum().get() >0)
        //    return QUEUE_HAVE_PATIENT;
        // æ£€æŸ¥æ˜¯å¦è¿˜æœ‰æ‚£è€…需要处理
        List<Integer> queueStatusList = new ArrayList<>();
        queueStatusList.add(QueueStatusEnum.READY.getStatus());
        queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus());
        queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus());
        queueStatusList.add(QueueStatusEnum.PASSED.getStatus());
        queueStatusList.add(QueueStatusEnum.PASSED_INSTALL.getStatus());
        queueStatusList.add(QueueStatusEnum.RECALLED.getStatus());
        queueStatusList.add(QueueStatusEnum.RECALLED_INSTALL.getStatus());
        queueStatusList.add(QueueStatusEnum.AFFINITY.getStatus());
        queueStatusList.add(QueueStatusEnum.AFFINITY_INSTALL.getStatus());
        List<QueueDO>  queueDOList = queueMapper.getBedQueueByStatus(roomId, bedNo, queueStatusList);
        if (queueDOList.size() > 0)
            return QUEUE_HAVE_PATIENT;
@@ -150,13 +153,13 @@
            return ROOM_INVALID_STATUS;
        }

        mapBedVsQueue.remove( Utils.formatRoomBed(roomId, bedNo) );
        removePriorityQueue(bedQueueBO);
        mapOpeningBed.remove( Utils.formatRoomBed(roomId, bedNo) );
        removeRoutingQueue(bedQueueBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

    public ErrorCode bedDoctorPause(Long roomId, String bedNo, Long docId, String docName) {
        BedQueueBO bedQueueBO = mapBedVsQueue.get( Utils.formatRoomBed(roomId, bedNo) );
        BedQueueBO bedQueueBO = mapOpeningBed.get( Utils.formatRoomBed(roomId, bedNo) );
        if (null == bedQueueBO) {
            log.error("bedDoctorPause mapBedVsQueue DONOT existed. " + roomId + " " + bedNo);
            return QUEUE_BED_NOT_EXIST;
@@ -172,12 +175,12 @@
        }

        bedQueueBO.setStatus(BedStatusEnum.PAUSE.getStatus());
        removePriorityQueue(bedQueueBO);
        removeRoutingQueue(bedQueueBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

    public ErrorCode bedDoctorResume(Long roomId, String bedNo, Long docId, String docName) {
        BedQueueBO bedQueueBO = mapBedVsQueue.get( Utils.formatRoomBed(roomId, bedNo) );
        BedQueueBO bedQueueBO = mapOpeningBed.get( Utils.formatRoomBed(roomId, bedNo) );
        if (null == bedQueueBO || !bedQueueBO.getStatus().equals(BedStatusEnum.PAUSE.getStatus())) {
            log.error("bedDoctorResume mapBedVsQueue DONOT existed OR NOT Paused. " + roomId + " " + bedNo);
            return QUEUE_BED_NOT_EXIST;
@@ -194,12 +197,12 @@
        }

        bedQueueBO.setStatus(BedStatusEnum.DOCTOR_ON.getStatus());
        addPriorityQueue(bedQueueBO);
        addRoutingQueue(bedQueueBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

    public ErrorCode bedDoctorOn(Long roomId, String bedNo, Long docId, String docName) {
        BedQueueBO bedQueueBO = mapBedVsQueue.get( Utils.formatRoomBed(roomId, bedNo) );
        BedQueueBO bedQueueBO = mapOpeningBed.get( Utils.formatRoomBed(roomId, bedNo) );
        if (null == bedQueueBO) {
            log.error("bedDoctorOn mapBedVsQueue DONOT existed. " + roomId + " " + bedNo);
            return QUEUE_BED_NOT_EXIST;
@@ -215,12 +218,12 @@
        }

        bedQueueBO.setStatus(BedStatusEnum.DOCTOR_ON.getStatus());
        addPriorityQueue(bedQueueBO);
        addRoutingQueue(bedQueueBO);
        return GlobalErrorCodeConstants.SUCCESS;
    }

    public ErrorCode bedDoctorOff(Long roomId, String bedNo, Long docId, String docName) {
        BedQueueBO bedQueueBO = mapBedVsQueue.get( Utils.formatRoomBed( roomId, bedNo ) );
        BedQueueBO bedQueueBO = mapOpeningBed.get( Utils.formatRoomBed( roomId, bedNo ) );
        if (null == bedQueueBO) {
            log.error("bedDoctorOff mapBedVsQueue DONOT existed. " + roomId + " " + bedNo);
            return QUEUE_BED_NOT_EXIST;
@@ -236,7 +239,7 @@
            return ROOM_INVALID_STATUS;
        }

        removePriorityQueue(bedQueueBO);
        removeRoutingQueue(bedQueueBO);

        bedQueueBO.setStatus(BedStatusEnum.OPENING.getStatus());
        return GlobalErrorCodeConstants.SUCCESS;
@@ -253,11 +256,11 @@
            return QUEUE_NOT_READY_PATIENT;
        }

        // ä¼˜å…ˆé˜Ÿåˆ—中 è¯¥å·¥ä½ å€™è¯Šä¸­ä¸­äººçš„数量 å‡ä¸€
        // åˆ†æµé˜Ÿåˆ—中 è¯¥å·¥ä½ å€™è¯Šä¸­ä¸­äººçš„数量 å‡ä¸€
        BedQueueBO bo = mapBedVsQueue.get( Utils.formatRoomBed( roomId, bedNo ) );
        bo.queueNum.getAndDecrement(); // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 hurry-up ä¸­æ”¹å˜äº†å€¼

        refreshPriorityQueue(bo);
        refreshRoutingQueue(bo);
        return GlobalErrorCodeConstants.SUCCESS;
    }
    */
@@ -274,11 +277,11 @@
        firstReadyQueueItem.setStatus(QueueStatusEnum.ONSTAGE.getStatus());
        queueMapper.updateById( firstReadyQueueItem );

        // ä¼˜å…ˆé˜Ÿåˆ—中 è¯¥å·¥ä½ å€™è¯Šä¸­ä¸­äººçš„数量 å‡ä¸€
        BedQueueBO bo = mapBedVsQueue.get( Utils.formatRoomBed( roomId, bedNo ) );
        // åˆ†æµé˜Ÿåˆ—中 è¯¥å·¥ä½ å€™è¯Šä¸­ä¸­äººçš„数量 å‡ä¸€
        BedQueueBO bo = mapOpeningBed.get( Utils.formatRoomBed( roomId, bedNo ) );
        bo.queueNum.getAndDecrement(); // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 hurry-up ä¸­æ”¹å˜äº†å€¼

        refreshPriorityQueue(bo);
        refreshRoutingQueue(bo);
        return GlobalErrorCodeConstants.SUCCESS;
    }

@@ -301,22 +304,22 @@
            procAffinityWhenSomeOneEntryInstalling(firstItem.getPatId(), roomId, bedNo, checkTypeDO.getAffinityCheckTypes() );
        }

        // è£…机工位 æ— ä¼˜å…ˆé˜Ÿåˆ—
        // ä¼˜å…ˆé˜Ÿåˆ—中 è¯¥å·¥ä½ [已领用]人的数量 å‡ä¸€
        // è£…机工位 ä¸è¿›å…¥ åˆ†æµé˜Ÿåˆ—
        // åˆ†æµé˜Ÿåˆ—中 è¯¥å·¥ä½ [已领用]人的数量 å‡ä¸€
        //BedQueueBO bo = mapBedVsQueue.get( Utils.formatRoomBed( roomId, bedNo ) );
        //bo.queueNum.getAndDecrement(); // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 hurry-up ä¸­æ”¹å˜äº†å€¼
        //refreshPriorityQueue(bo);
        //refreshRoutingQueue(bo);

        return GlobalErrorCodeConstants.SUCCESS;
    }

    /**
     * 1. æ¯å¤©å¼€è¯Šå‰ ä»ŽDB同步工位的患者队列数据到 å·¥ä½ä¼˜å…ˆé˜Ÿåˆ—
     * 1. æ¯å¤©å¼€è¯Šå‰ ä»ŽDB同步工位的患者队列数据到 å·¥ä½åˆ†æµé˜Ÿåˆ—
     * 2. æœåŠ¡è¿ç»´é‡å¯æ—¶
     */
    public ErrorCode bedReload() {
        mapCheckTypePriorityQueue.clear();
        mapBedVsQueue.clear();
        mapCheckTypeRoutingQueue.clear();
        mapOpeningBed.clear();

        // æ¸…除非当天的排队人员
        queueMapper.clearQueue();
@@ -331,22 +334,22 @@
        List<RoomDO> roomDOList = roomMapper.simpleRoomList(bedStatusEnumList);
        List<BedQueueBO> bedQueueBOList = roomDOList.stream().map(item -> BeanUtils.toBean(item, BedQueueBO.class)).toList();

        // ä»ŽDB èŽ·å– é˜Ÿåˆ—中 å€™è¯Šä¸­ä¸­äººå‘˜ç»Ÿè®¡ åˆ—表
        // ä»ŽDB èŽ·å– é˜Ÿåˆ—中 ã€å€™è¯Šä¸­ã€‘人员统计 åˆ—表
        List<Integer> queueStatusList = new ArrayList<>();
        queueStatusList.add(QueueStatusEnum.READY.getStatus());
        List<QueueStatisticDO> queueStatisticDOList = queueMapper.queueStatistic(queueStatusList);

        bedQueueBOList.forEach(item -> {
            item.maxQueueNum = getBedReadyMax(item.roomId, item.bedNo);
            item.setMaxQueueNum( getBedReadyMax(item.roomId, item.bedNo) );
            Optional<QueueStatisticDO> queueStatisticDOOptional = queueStatisticDOList.stream().filter(it->it.getRoomId()==item.roomId && it.getBedNo().equals(item.getBedNo())).findFirst();
            int queueNum = queueStatisticDOOptional.isPresent() ? queueStatisticDOOptional.get().getTotalInStatus() : 0;
            if ( item.maxQueueNum < queueNum )
            if ( item.getMaxQueueNum() < queueNum )
                throw new RuntimeException("init: exceed max queue number!");

            item.queueNum.set( queueNum );
            mapBedVsQueue.put( Utils.formatRoomBed(item.roomId, item.bedNo), item);
            item.setQueueNum( new AtomicInteger(queueNum) );
            mapOpeningBed.put( Utils.formatRoomBed(item.roomId, item.bedNo), item);
            if (BedStatusEnum.DOCTOR_ON.getStatus() == item.getStatus()) {
                addPriorityQueue(item);
                addRoutingQueue(item);
            }
        });

@@ -375,7 +378,7 @@
        if (0 == openingFlag.get())
            return;

        mapBedVsQueue.values().forEach(bedQueueBO -> hurryupOneBed(bedQueueBO.roomId, bedQueueBO.bedNo));
        mapOpeningBed.values().forEach(bedQueueBO -> hurryupOneBed(bedQueueBO.roomId, bedQueueBO.bedNo));
    }

    /**
@@ -395,7 +398,7 @@
                    bedQueueBO.getRoomName(),
                    bedQueueBO.getBedNo(),
                    curSeqNum.get() + 1,  // è¿‡å·å›žæ¥ï¼ŒæŽ’到当前的下一位
                    QueueStatusEnum.RECALLED.getStatus(), // ä¸éœ€è¦å¤„理 [安装召回], åŽŸå› : å®‰è£…工位 æ²¡æœ‰ä¼˜å…ˆé˜Ÿåˆ—
                    QueueStatusEnum.RECALLED.getStatus(), // ä¸éœ€è¦å¤„理 [安装召回], åŽŸå› : å®‰è£…工位 ä¸è¿›å…¥åˆ†æµé˜Ÿåˆ—
                    QueueStatusEnum.READY.getStatus());
            if (null == updateNum || 0 == updateNum)
                break;
@@ -413,8 +416,8 @@
            // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 nextPatient ä¸­æ”¹å˜äº†å€¼
            bedQueueBO.queueNum.incrementAndGet();

            // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 nextPatient ä¸­æ”¹å˜äº†ä¼˜å…ˆé˜Ÿåˆ—顺序
            refreshPriorityQueue(bedQueueBO);
            // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 nextPatient ä¸­æ”¹å˜äº†åˆ†æµé˜Ÿåˆ—顺序
            refreshRoutingQueue(bedQueueBO);
        }

        // å¤„理 æŽ’队中 æ‚£è€…
@@ -430,12 +433,12 @@
     */
    public void hurryupOneCheckType(Integer checkType) {

        PriorityBlockingQueue<BedQueueBO> priorityQueue = mapCheckTypePriorityQueue.get(checkType);
        if (null == priorityQueue)
        PriorityBlockingQueue<BedQueueBO> routingQueue = mapCheckTypeRoutingQueue.get(checkType);
        if (null == routingQueue)
            return;

        while (true) {
            BedQueueBO bedQueueBO = priorityQueue.peek();
            BedQueueBO bedQueueBO = routingQueue.peek();
            if (null == bedQueueBO)
                return;

@@ -474,8 +477,8 @@
            // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 nextPatient ä¸­æ”¹å˜äº†å€¼
            bedQueueBO.queueNum.incrementAndGet();

            // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 nextPatient ä¸­æ”¹å˜äº†ä¼˜å…ˆé˜Ÿåˆ—顺序
            refreshPriorityQueue(bedQueueBO);
            // å¯èƒ½å·²ç»ã€å¹¶å‘的】在 nextPatient ä¸­æ”¹å˜äº†åˆ†æµé˜Ÿåˆ—顺序
            refreshRoutingQueue(bedQueueBO);
        }
    }

@@ -497,7 +500,7 @@
    }

    public BedQueueBO getBedQueueBO(Long roomId, String bedNo) {
        return mapBedVsQueue.get( Utils.formatRoomBed(roomId, bedNo) );
        return mapOpeningBed.get( Utils.formatRoomBed(roomId, bedNo) );
    }

    public MonitorInfoVO getMonitorInfo() {
@@ -511,7 +514,7 @@
    public void monitorInfo() {
        MonitorInfoVO monitorInfoVO = new MonitorInfoVO();
        roomBedStatistic(monitorInfoVO);
        log.info(" opening " + openingFlag.get() + " " + monitorInfoVO.getQueueNum() + " " + monitorInfoVO.getActiveQueueNum() + " " + monitorInfoVO.getCheckTypeBedInfo().toString() );
        log.info(" opening " + openingFlag.get() + " " + monitorInfoVO.getOpeningBedNum() + " " + monitorInfoVO.getDocBedNum() + " " + monitorInfoVO.getCheckTypeBedInfo().toString() );
    }

    private void hurryupOneBedCheckTypeList(BedQueueBO bedQueueBO) {
@@ -544,8 +547,8 @@
            bedQueueBO.queueNum.incrementAndGet();
        }

        // æ”¹å˜äº†ä¼˜å…ˆé˜Ÿåˆ—顺序
        refreshPriorityQueue(bedQueueBO);
        // æ”¹å˜äº†åˆ†æµé˜Ÿåˆ—顺序
        refreshRoutingQueue(bedQueueBO);
    }

    /**
@@ -586,49 +589,56 @@
        for (int i=0; i<checkTypes.length; i++) {
            CheckTypeDO checkTypeDO = mapCheckTypeVsReadyMax.get(checkTypes[i]);
            Integer tmp = checkTypeDO.getReadyNum();
            ret = ret < tmp ? tmp : ret;  //取大值
            ret = ret < tmp ? tmp : ret;  //【候诊中】数量 å–大值
        }
        return ret;
    }

    private void addPriorityQueue(BedQueueBO bedQueueBO) {
    private void addRoutingQueue(BedQueueBO bedQueueBO) {
        // è£…机工位 ä¸è¿› åˆ†æµé˜Ÿåˆ—，不接收 ã€æŽ’队中】患者分流
        if (BedOpTypeEnum.OP_INSTALL.getOpType() == bedQueueBO.getOpType())
            return;

        Integer[] checkTypes = bedQueueBO.getCheckTypes();
        Arrays.stream(checkTypes).forEach(checkType -> {
            CheckTypeDO checkTypeDO = mapCheckTypeVsReadyMax.get(checkType);
            // è£…机工位 ä¸è¿› ä¼˜å…ˆé˜Ÿåˆ—，不从排队中接收人
            if (checkTypeDO.getNeedDevReady() == 1 && bedQueueBO.getOpType() == 2) {
                return;
            }
            
            PriorityBlockingQueue<BedQueueBO> priorityQueue = mapCheckTypePriorityQueue.get(checkType);
            if (null == priorityQueue) {
                priorityQueue = new PriorityBlockingQueue<BedQueueBO>();
                mapCheckTypePriorityQueue.put( checkType, priorityQueue );
            PriorityBlockingQueue<BedQueueBO> routingQueue = mapCheckTypeRoutingQueue.get(checkType);
            if (null == routingQueue) {
                routingQueue = new PriorityBlockingQueue<BedQueueBO>();
                mapCheckTypeRoutingQueue.put( checkType, routingQueue );
            }

            if (!priorityQueue.contains(bedQueueBO)) {
                priorityQueue.offer(bedQueueBO);
            if (!routingQueue.contains(bedQueueBO)) {
                routingQueue.offer(bedQueueBO);
            } else {
                log.error("bedDoctorResume priorityQueue still exist!. " + bedQueueBO.getRoomId() + " " + bedQueueBO.getBedNo());
                log.error("bedDoctorResume routingQueue still exist!. " + bedQueueBO.getRoomId() + " " + bedQueueBO.getBedNo());
            }
        });
    }

    private void removePriorityQueue(BedQueueBO bedQueueBO) {
    private void removeRoutingQueue(BedQueueBO bedQueueBO) {
        // è£…机工位 ä¸è¿› åˆ†æµé˜Ÿåˆ—，不接收 ã€æŽ’队中】患者分流
        if (BedOpTypeEnum.OP_INSTALL.getOpType() == bedQueueBO.getOpType())
            return;

        Integer[] checkTypes = bedQueueBO.getCheckTypes();
        Arrays.stream(checkTypes).forEach(checkType -> {
            PriorityBlockingQueue<BedQueueBO> priorityBlockingQueue = mapCheckTypePriorityQueue.get(checkType);
            if (null != priorityBlockingQueue)
                priorityBlockingQueue.remove(bedQueueBO);
            PriorityBlockingQueue<BedQueueBO> routingQueue = mapCheckTypeRoutingQueue.get(checkType);
            if (null != routingQueue)
                routingQueue.remove(bedQueueBO);
        });
    }

    private void refreshPriorityQueue(BedQueueBO bedQueueBO) {
    private void refreshRoutingQueue(BedQueueBO bedQueueBO) {
        // è£…机工位 ä¸è¿› åˆ†æµé˜Ÿåˆ—，不接收 ã€æŽ’队中】患者分流
        if (BedOpTypeEnum.OP_INSTALL.getOpType() == bedQueueBO.getOpType())
            return;

        Integer[] checkTypes = bedQueueBO.getCheckTypes();
        Arrays.stream(checkTypes).forEach(checkType -> {
            PriorityBlockingQueue<BedQueueBO> priorityQueue = mapCheckTypePriorityQueue.get(checkType);
            priorityQueue.remove(bedQueueBO);
            priorityQueue.offer(bedQueueBO);
            PriorityBlockingQueue<BedQueueBO> routingQueue = mapCheckTypeRoutingQueue.get(checkType);
            routingQueue.remove(bedQueueBO);
            routingQueue.offer(bedQueueBO);
        });
    }

@@ -660,7 +670,7 @@
        });

        //开通的 å’Œ è¿è¥ä¸­ çš„工位统计
        mapBedVsQueue.values().forEach( bedQueueBO -> {
        mapOpeningBed.values().forEach(bedQueueBO -> {
            Integer[] checkTypes = bedQueueBO.getCheckTypes();
            Arrays.stream(checkTypes).forEach(checkType -> {
                if (bedQueueBO.opType == 0 || bedQueueBO.opType == 1)
@@ -677,10 +687,10 @@
            });
        });

        // æŽ¥æ”¶..排队中患者..的优先队列
        // æŽ¥æ”¶..排队中患者..的分流队列
        HashSet<BedQueueBO> hashSetOperatingBedQueue = new HashSet<>();
        mapCheckTypePriorityQueue.values().forEach(priorityQueue->{
            priorityQueue.stream().forEach(bedQueueBO -> hashSetOperatingBedQueue.add(bedQueueBO));
        mapCheckTypeRoutingQueue.values().forEach(routingQueue->{
            routingQueue.stream().forEach(bedQueueBO -> hashSetOperatingBedQueue.add(bedQueueBO));
        });


@@ -694,10 +704,13 @@
        });

        monitorInfoVO.setCheckTypeBedInfo(mapCheckTypeBedInfo);
        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 );
        monitorInfoVO.setOpeningBedNum(mapOpeningBed.size());
        monitorInfoVO.setDocBedNum((int) mapOpeningBed.values().stream().filter(item ->
                item.getStatus() == BedStatusEnum.DOCTOR_ON.getStatus() ||
                item.getStatus() == BedStatusEnum.PAUSE.getStatus())
            .count());
        monitorInfoVO.setRoutingBedNum( hashSetOperatingBedQueue.size() );
        monitorInfoVO.setMapBedVsQueue(mapOpeningBed);
    }

}