| | |
| | | |
| | | Integer queueReadyMax = 0; |
| | | |
| | | Integer bigScrenWaitingSize = 5; |
| | | Integer bigScrenPassedSize = 5; |
| | | Integer bigScrenWaitingFrom = 0; |
| | | Integer bigScrenPassedFrom = 0; |
| | | |
| | | @Override |
| | | public Integer createqueue(QueueSaveReqVO createReqVO) { |
| | | // 插入 |
| | |
| | | public void monitorInfo() { |
| | | log.info("map " + mapBedVsQueue.size() + " priority " + priorityQueue.size() |
| | | + " opening " + openingFlag.get()); |
| | | } |
| | | |
| | | @Override |
| | | public List<QueueDO> callingData(Integer waitingNum, Integer passedNum) { |
| | | //queueMapper. |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | | public List<QueueDO> getRoomQueue(String ip, List<Byte> statusList) { |
| | | List<RoomDO> roomDOList = roomMapper.queueByIp(ip); |
| | | Optional<RoomDO> optionalQueueDO = roomDOList.stream().filter(item -> StringUtils.hasLength(item.getIp())).findFirst(); |
| | | if (!optionalQueueDO.isPresent()) { |
| | | return new ArrayList<QueueDO>(); |
| | | } |
| | | |
| | | Long roomId = optionalQueueDO.get().getRoomId(); |
| | | List<QueueDO> queueDOList = queueMapper.getRoomQueueByStatus(roomId, statusList); |
| | | return queueDOList; |
| | | } |
| | | |
| | | } |