~yxh/ecg.git - Gitblit

			@@ -71,7 +71,7 @@
			ConcurrentHashMap<String, BedBO> mapOpeningBed = new ConcurrentHashMap<>();

			// 装机工位..不进入分流队列
			Map<Integer, PriorityBlockingQueue<BedBO>> mapCheckTypeRoutingQueue = new HashMap();
			ConcurrentHashMap<Integer, PriorityBlockingQueue<BedBO>> mapCheckTypeRoutingQueue = new ConcurrentHashMap<>();

			Map<Integer, CheckTypeDO> mapCheckTypeVsReadyMax = null;

			@@ -260,7 +260,7 @@

			// 常规或者领用时医生取下一位患者
			public ErrorCode nextPatient(Long roomId, String bedNo) {
			QueueDO firstReadyQueueItem = queueMapper.getFirstItemByBedAndStatus(roomId, bedNo, QueueStatusEnum.READY.getStatus());
			QueueDO firstReadyQueueItem = queueMapper.getBedFirstQueueItemByStatus(roomId, bedNo, QueueStatusEnum.READY.getStatus());
			// 该工位没有 [候诊中中] 人员
			if (null == firstReadyQueueItem) {
			return QUEUE_NOT_READY_PATIENT;
			@@ -270,9 +270,9 @@
			firstReadyQueueItem.setStatus(QueueStatusEnum.ONSTAGE.getStatus());
			queueMapper.updateById( firstReadyQueueItem );

			// 分流队列中该工位候诊中中人的数量减一
			// 分流队列中该工位【候诊中】患者数量减一
			BedBO bo = mapOpeningBed.get( Utils.formatRoomBed( roomId, bedNo ) );
			bo.readyPatNum.getAndDecrement(); // 可能已经【并发的】在 hurry-up 中改变了值
			bo.readyPatNum--; // 可能已经在 hurry-up 中改变了值

			refreshBedPriorityLevelInRoutingQueue(bo);
			return GlobalErrorCodeConstants.SUCCESS;
			@@ -281,27 +281,23 @@
			// 装机时医生取下一位患者
			public ErrorCode nextInstallPatient(Long roomId, String bedNo) {
			// 从 DB 把序号最小的 [已领用] [已召回-安装] 的人设置为 [安装中]
			QueueDO firstItem = queueMapper.getFirstItemByRoomAndStatus(roomId, List.of(QueueStatusEnum.RECEIVED.getStatus(), QueueStatusEnum.RECALLED_INSTALL.getStatus()));
			QueueDO firstItem = queueMapper.getRoomFirstQueueItemByStatus(roomId, List.of(QueueStatusEnum.RECEIVED.getStatus(), QueueStatusEnum.RECALLED_INSTALL.getStatus()));
			// 该工位没有 [已领用] \| [已召回-安装] 人员
			if (null == firstItem) {
			return QUEUE_NOT_READY_PATIENT;
			}

			firstItem.setStatus( QueueStatusEnum.INSTALLING.getStatus() );
			firstItem.setBedNo( bedNo );
			firstItem.setBedNo( bedNo ); // 转到安装工位
			queueMapper.updateById( firstItem );

			// 检查项目.亲和性处理逻辑
			// 检查项目.亲和性处理逻辑: 变为【安装中】后拉其他检查项来亲和
			CheckTypeDO checkTypeDO = getCheckTypeItem( firstItem.getBookCheckType() );
			if (checkTypeDO.getAffinityCheckTypes().length > 0) {
			procAffinityWhenSomeOneEntryInstalling(firstItem.getPatId(), roomId, bedNo, checkTypeDO.getAffinityCheckTypes() );
			}

			// 装机工位不进入分流队列
			// 分流队列中该工位 [已领用]人的数量减一
			//BedQueueBO bo = mapBedVsQueue.get( Utils.formatRoomBed( roomId, bedNo ) );
			//bo.queueNum.getAndDecrement(); // 可能已经【并发的】在 hurry-up 中改变了值
			//refreshRoutingQueue(bo);
			// 装机工位不参与分流

			return GlobalErrorCodeConstants.SUCCESS;
			}
			@@ -372,7 +368,7 @@
			BedBO bedBO = getBedQueueBO(roomId, bedNo);

			// 处理过号-回来的人
			while (bedBO.readyPatNum.get() < bedBO.maxReadyPatNum) {
			while (bedBO.getReadyPatNum() < bedBO.getMaxReadyPatNum()) {
			// 查看当前工位是否有过号-回来的患者
			Integer updateNum = queueMapper.queueRecalledPatient(
			bedBO.getRoomId(),
			@@ -394,8 +390,8 @@

			curSeqNum.getAndIncrement();

			// 可能已经【并发的】在 nextPatient 中改变了值
			bedBO.readyPatNum.incrementAndGet();
			// 可能已经在 nextPatient 中改变了值
			bedBO.readyPatNum++;

			// 可能已经【并发的】在 nextPatient 中改变了分流队列顺序
			refreshBedPriorityLevelInRoutingQueue(bedBO);
			@@ -423,11 +419,11 @@
			if (null == bedBO)
			return;

			int curQueueNum = bedBO.readyPatNum.get();
			if (curQueueNum > bedBO.maxReadyPatNum)
			int curQueueNum = bedBO.getReadyPatNum();
			if (curQueueNum > bedBO.getMaxReadyPatNum())
			throw new RuntimeException("hurryupOneCheckType: exceed max queue number!");

			if (curQueueNum == bedBO.maxReadyPatNum)
			if (curQueueNum == bedBO.getMaxReadyPatNum())
			return;

			// 查看是否有排队中的患者
			@@ -455,8 +451,8 @@

			curSeqNum.getAndIncrement();

			// 可能已经【并发的】在 nextPatient 中改变了值
			bedBO.readyPatNum.incrementAndGet();
			// 可能已经在 nextPatient 中改变了值
			bedBO.readyPatNum++;

			// 可能已经【并发的】在 nextPatient 中改变了分流队列顺序
			refreshBedPriorityLevelInRoutingQueue(bedBO);
			@@ -499,7 +495,7 @@
			}

			private void hurryupOneBedCheckTypeList(BedBO bedBO) {
			while (bedBO.readyPatNum.get() < bedBO.maxReadyPatNum) {
			while (bedBO.getReadyPatNum() < bedBO.getMaxReadyPatNum()) {
			// 抢占是否有排队中的患者
			Integer updateNum = queueMapper.preemptWaitingPatientWithBedCheckTypes(
			bedBO.getRoomId(),
			@@ -525,7 +521,7 @@

			curSeqNum.getAndIncrement();

			bedBO.readyPatNum.incrementAndGet();
			bedBO.readyPatNum++;
			}

			// 改变了分流队列顺序
			@@ -584,7 +580,7 @@
			queueStatusList.add(QueueStatusEnum.READY.getStatus()); //[候诊中]
			List<QueueDO> queueDOList = queueMapper.getBedQueueByStatus(bedBO.getRoomId(), bedBO.getBedNo(), queueStatusList);
			bedBO.setMaxReadyPatNum( getBedReadyMax(bedBO) );
			bedBO.setReadyPatNum(new AtomicInteger(queueDOList.size()));
			bedBO.setReadyPatNum( queueDOList.size() );

			Integer[] checkTypes = bedBO.getCheckTypes();
			Arrays.stream(checkTypes).forEach(checkType -> {
			@@ -624,8 +620,10 @@
			Integer[] checkTypes = bedBO.getCheckTypes();
			Arrays.stream(checkTypes).forEach(checkType -> {
			PriorityBlockingQueue<BedBO> routingQueue = mapCheckTypeRoutingQueue.get(checkType);
			routingQueue.remove(bedBO);
			routingQueue.offer(bedBO);
			if (null != routingQueue) {
			routingQueue.remove(bedBO);
			routingQueue.offer(bedBO);
			}
			});
			}

			@@ -638,6 +636,7 @@
			for (int i = 0; i < affinityItems.size(); i++) {
			QueueDO queueItem = affinityItems.get(i);
			queueItem.setStatus(QueueStatusEnum.AFFINITY_INSTALL.getStatus()); //改变排队状态
			queueItem.setAffinityItem(1);
			queueItem.setRoomId(roomId_operator);
			queueItem.setBedNo(bedNo_operator); // 跟随到装机工位
			queueMapper.updateById(queueItem);