eight
2024-10-10 05466007a40b6a22d68ef47b784fb3738760d18b
工位状态 动态查看
已修改2个文件
31 ■■■■■ 文件已修改
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/room/vo/MonitorInfoVO.java 5 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java 26 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/room/vo/MonitorInfoVO.java
@@ -2,11 +2,12 @@
import lombok.Data;
import java.util.Map;
@Data
public class MonitorInfoVO {
    private Integer queueNum;
    private Integer activeQueueNum;
    private Integer openingFlag;
    private String  openingInfo;
    private String  operatingInfo;
    private Map<Integer, String> checkTypeBedInfo;
}
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/QueueServiceTxFunctions.java
@@ -411,16 +411,15 @@
    public MonitorInfoVO getMonitorInfo() {
        MonitorInfoVO monitorInfoVO = new MonitorInfoVO();
        monitorInfoVO.setOpeningFlag( openingFlag.get() );
        String[] arrStatInfo = roomBedStatistic();
        monitorInfoVO.setOpeningInfo(arrStatInfo[0]);
        monitorInfoVO.setOperatingInfo(arrStatInfo[1]);
        roomBedStatistic(monitorInfoVO);
        return monitorInfoVO;
    }
    public void monitorInfo() {
        String[] arrStatInfo = roomBedStatistic();
        log.info(" opening " + openingFlag.get() + " openingInfo " + arrStatInfo[0] + " operatingInfo " + arrStatInfo[1] );
        MonitorInfoVO monitorInfoVO = new MonitorInfoVO();
        roomBedStatistic(monitorInfoVO);
        log.info(" opening " + openingFlag.get() + " " + monitorInfoVO.getQueueNum() + " " + monitorInfoVO.getActiveQueueNum() + " " + monitorInfoVO.getCheckTypeBedInfo().toString() );
    }
    private Integer getBedReadyMax(Long roomId, String bedNo) {
@@ -464,7 +463,7 @@
        });
    }
    private String[]  roomBedStatistic() {
    private void roomBedStatistic(MonitorInfoVO monitorInfoVO) {
        Map<Integer, Integer>  mapOpeningCheckBedStatInfo = new HashMap<>();
        Map<Integer, Integer>  mapOpeningReadyBedStatInfo = new HashMap<>();
        Map<Integer, Integer>  mapOperatingCheckBedStatInfo = new HashMap<>();
@@ -487,8 +486,6 @@
            });
        });
        String openingBedInfo = "总数:" + mapBedVsQueue.size() + "  检查工位数: " + mapOpeningCheckBedStatInfo.toString() + "  领用工位数: " + mapOpeningReadyBedStatInfo.toString();
        //运营中工位统计
        HashSet<BedQueueBO> hashSetOperatingBedQueue = new HashSet<>();
        mapCheckTypeVsPriorityQueue.values().forEach(priorityQueue->{
@@ -505,9 +502,18 @@
            });
        });
        String operatingBedInfo = "总数:" + hashSetOperatingBedQueue.size() + "  检查工位数: " + mapOperatingCheckBedStatInfo.toString() + "  领用工位数: " + mapOperatingReadyBedStatInfo.toString();
        Map<Integer, String> mapCheckTypeBedInfo = new HashMap<>();
        mapCheckTypeVsReadyMax.keySet().forEach( checkType -> {
           String str = mapOpeningCheckBedStatInfo.get(checkType) + " " +
                        mapOpeningReadyBedStatInfo.get(checkType) + " " +
                        mapOperatingCheckBedStatInfo.get(checkType) + " " +
                        mapOperatingReadyBedStatInfo.get(checkType) + " ";
            mapCheckTypeBedInfo.put( checkType, str);
        });
        return new String[]{openingBedInfo, operatingBedInfo};
        monitorInfoVO.setCheckTypeBedInfo(mapCheckTypeBedInfo);
        monitorInfoVO.setQueueNum(mapBedVsQueue.size());
        monitorInfoVO.setActiveQueueNum(hashSetOperatingBedQueue.size());
    }
}