| | |
| | | import java.util.concurrent.atomic.AtomicInteger; |
| | | import javax.annotation.Resource; |
| | | |
| | | import cn.lihu.jh.module.ecg.controller.admin.room.vo.MonitorInfoVO; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.StringUtils; |
| | | import org.springframework.validation.annotation.Validated; |
| | | |
| | | import cn.lihu.jh.framework.common.exception.enums.GlobalErrorCodeConstants; |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Integer getOpeningFlag() { |
| | | return openingFlag.get(); |
| | | public MonitorInfoVO getMonitorInfo() { |
| | | MonitorInfoVO monitorInfoVO = new MonitorInfoVO(); |
| | | monitorInfoVO.setOpeningFlag( openingFlag.get() ); |
| | | monitorInfoVO.setQueueNum( mapBedVsQueue.size() ); |
| | | monitorInfoVO.setActiveQueueNum( priorityQueue.size() ); |
| | | return monitorInfoVO; |
| | | } |
| | | |
| | | /** |
| | |
| | | |
| | | public void closeBiz() { |
| | | openingFlag.set(0); |
| | | startBedReload(); |
| | | } |
| | | |
| | | @Override |
| | |
| | | + " 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; |
| | | } |
| | | |
| | | } |