From ca64d931ce30254e34d64ce28cf3a53e54a9159f Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期一, 26 八月 2024 09:32:50 +0800 Subject: [PATCH] update --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java | 27 +++++++++++++++++++++++++++ 1 files changed, 27 insertions(+), 0 deletions(-) diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java index 6bdd64e..8a806d3 100644 --- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java +++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java @@ -77,6 +77,33 @@ queueMapper.deleteById(id); } + @Override + public Integer bedControl(Long roomId, String bedNo, Integer status) { + // 钀ヤ笟鏈熼棿涓嶈兘鍏抽棴宸ヤ綅 + if ( status == 0 && openingFlag.get() == 1 ) + return 301; + + // 褰撳墠鐘舵�� + roomMapper.select + + // DB update + Integer updateNum = roomMapper.setBedStatus(roomId, bedNo, status); + if ( null==updateNum || 0 == updateNum ) + return 310; + + if ( status == 10 ) { + BedQueueBO bedQueueBO = new BedQueueBO(); + bedQueueBO.setRoomId(roomId); + bedQueueBO.setBedNo(bedNo); + bedQueueBO.setMaxQueueNum(MAX_QUEUE_NUM); + bedQueueBO.setQueueNum(new AtomicInteger(0)); + priorityQueue.offer(bedQueueBO); + mapBedVsQueue.put(String.format("%09d%s", bedQueueBO.roomId, bedQueueBO.bedNo), bedQueueBO); + } + + return 0; + } + private void validatequeueExists(Integer id) { if (queueMapper.selectById(id) == null) { throw exception(QUEUE_NOT_EXISTS); -- Gitblit v1.9.3