From 9b18e467d407c66ecc3c46a197aca45dcc3f8056 Mon Sep 17 00:00:00 2001
From: eight <641137800@qq.com>
Date: 星期二, 27 八月 2024 09:11:02 +0800
Subject: [PATCH] update
---
jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueServiceImpl.java | 200 +++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 197 insertions(+), 3 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 c16b26d..fd31e8c 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
@@ -4,6 +4,7 @@
import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueStatisticDO;
import cn.lihu.jh.module.ecg.dal.dataobject.room.RoomDO;
import cn.lihu.jh.module.ecg.dal.mysql.room.RoomMapper;
+import cn.lihu.jh.module.ecg.enums.BedStatusEnum;
import cn.lihu.jh.module.ecg.enums.QueueStatusEnum;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
@@ -32,8 +33,6 @@
@Service
@Validated
public class QueueServiceImpl implements QueueService {
-
- final static Integer MAX_QUEUE_NUM = 3;
@Resource
private queueMapper queueMapper;
@@ -75,6 +74,195 @@
validatequeueExists(id);
// 鍒犻櫎
queueMapper.deleteById(id);
+ }
+
+ @Override
+ public Integer startBedOpen(Long roomId, String bedNo) {
+ Future<Integer> future = singleThreadExecutor.submit( new BedOpenCallable(this, roomId, bedNo));
+
+ try {
+ Integer ret = future.get();
+ return ret;
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ } catch (ExecutionException e) {
+ e.printStackTrace();
+ }
+
+ return 100;
+ }
+
+ @Override
+ public Integer startBedClose(Long roomId, String bedNo) {
+ Future<Integer> future = singleThreadExecutor.submit( new BedCloseCallable(this, roomId, bedNo));
+
+ try {
+ Integer ret = future.get();
+ return ret;
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ } catch (ExecutionException e) {
+ e.printStackTrace();
+ }
+
+ return 100;
+ }
+
+ @Override
+ public Integer startBedDoctorPause(Long roomId, String bedNo, Long docId, String docName) {
+ Future<Integer> future = singleThreadExecutor.submit(
+ new BedDoctorPauseCallable(this, roomId, bedNo, docId, docName)
+ );
+
+ try {
+ Integer ret = future.get();
+ return ret;
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ } catch (ExecutionException e) {
+ e.printStackTrace();
+ }
+
+ return 100;
+ }
+
+ @Override
+ public Integer startBedDoctorOn(Long roomId, String bedNo, Long docId, String docName) {
+ Future<Integer> future = singleThreadExecutor.submit(
+ new BedDoctorOnCallable(this, roomId, bedNo, docId, docName)
+ );
+
+ try {
+ Integer ret = future.get();
+ return ret;
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ } catch (ExecutionException e) {
+ e.printStackTrace();
+ }
+
+ return 100;
+ }
+
+ @Override
+ public Integer startBedDoctorOff(Long roomId, String bedNo, Long docId, String docName) {
+ Future<Integer> future = singleThreadExecutor.submit(
+ new BedDoctorOffCallable(this, roomId, bedNo, docId, docName)
+ );
+
+ try {
+ Integer ret = future.get();
+ return ret;
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ } catch (ExecutionException e) {
+ e.printStackTrace();
+ }
+
+ return 100;
+ }
+
+
+ /**
+ * 宸插叧闂� 鎴栬�� 鍏抽棴涓紝鍙互寮�閫氬伐浣�
+ * @param roomId
+ * @param bedNo
+ * @return
+ */
+ @Override
+ public Integer bedOpen(Long roomId, String bedNo) {
+ // DB update
+ List statusList = new ArrayList<BedStatusEnum>();
+ statusList.add(BedStatusEnum.CLOSED);
+ statusList.add(BedStatusEnum.CLOSING);
+ Integer updateNum = roomMapper.setBedStatus(roomId, bedNo,
+ BedStatusEnum.OPENING, statusList);
+ if ( null==updateNum || 0 == updateNum )
+ return 310;
+
+ List<Byte> queueStatusList = new ArrayList<>();
+ queueStatusList.add(QueueStatusEnum.READY.getStatus());
+ List<QueueDO> queueDOList = queueMapper.getDoctorQueueByStatus(roomId, bedNo, queueStatusList);
+
+ // 鏂板宸ヤ綅 浼樺厛闃熷垪
+ BedQueueBO bedQueueBO = new BedQueueBO();
+ bedQueueBO.setRoomId(roomId);
+ bedQueueBO.setBedNo(bedNo);
+ bedQueueBO.setMaxQueueNum(MAX_QUEUE_NUM);
+ bedQueueBO.setQueueNum(new AtomicInteger(queueDOList.size()));
+ priorityQueue.offer(bedQueueBO);
+ mapBedVsQueue.put(String.format("%09d%s", roomId, bedNo), bedQueueBO);
+ return 0;
+ }
+
+ @Override
+ public Integer bedClose(Long roomId, String bedNo) {
+ BedQueueBO bedQueueBO = mapBedVsQueue.get(String.format("%09d%s", roomId, bedNo));
+ if (null == bedQueueBO)
+ return 320;
+
+ // DB update
+ List statusList = new ArrayList<BedStatusEnum>();
+ statusList.add(BedStatusEnum.OPENING);
+ statusList.add(BedStatusEnum.DOCTOR_ON);
+ statusList.add(BedStatusEnum.PAUSE);
+ Integer updateNum = roomMapper.setBedStatus(roomId, bedNo,
+ BedStatusEnum.CLOSING, statusList);
+ if ( null==updateNum || 0 == updateNum )
+ return 321;
+
+ return 0;
+ }
+
+ @Override
+ public Integer bedDoctorPause(Long roomId, String bedNo, Long docId, String docName) {
+ BedQueueBO bedQueueBO = mapBedVsQueue.get(String.format("%09d%s", roomId, bedNo));
+ if (null == bedQueueBO)
+ return 320;
+
+ // DB update
+ List statusList = new ArrayList<BedStatusEnum>();
+ statusList.add(BedStatusEnum.DOCTOR_ON);
+ Integer updateNum = roomMapper.setBedDoctorPause(roomId, bedNo, docId, docName,
+ BedStatusEnum.PAUSE, statusList);
+ if ( null==updateNum || 0 == updateNum )
+ return 331;
+
+ return 0;
+ }
+
+ @Override
+ public Integer bedDoctorOn(Long roomId, String bedNo, Long docId, String docName) {
+ BedQueueBO bedQueueBO = mapBedVsQueue.get(String.format("%09d%s", roomId, bedNo));
+ if (null == bedQueueBO)
+ return 320;
+
+ // DB update
+ List statusList = new ArrayList<BedStatusEnum>();
+ statusList.add(BedStatusEnum.OPENING);
+ Integer updateNum = roomMapper.setBedDoctorOn(roomId, bedNo, docId, docName,
+ BedStatusEnum.DOCTOR_ON, statusList);
+ if ( null==updateNum || 0 == updateNum )
+ return 341;
+
+ return 0;
+ }
+
+ @Override
+ public Integer bedDoctorOff(Long roomId, String bedNo, Long docId, String docName) {
+ BedQueueBO bedQueueBO = mapBedVsQueue.get(String.format("%09d%s", roomId, bedNo));
+ if (null == bedQueueBO)
+ return 320;
+
+ // DB update
+ List statusList = new ArrayList<BedStatusEnum>();
+ statusList.add(BedStatusEnum.DOCTOR_ON);
+ Integer updateNum = roomMapper.setBedDoctorOff(roomId, bedNo, docId, docName,
+ BedStatusEnum.OPENING, statusList);
+ if ( null==updateNum || 0 == updateNum )
+ return 351;
+
+ return 0;
}
private void validatequeueExists(Integer id) {
@@ -276,6 +464,9 @@
}
public void startBiz() {
+ if (1 == openingFlag.get())
+ return;
+
// 娓呴櫎闈炲綋澶╃殑鎺掗槦浜哄憳
queueMapper.clearQueue();
@@ -283,6 +474,10 @@
openingFlag.set(1);
hurryup();
+ }
+
+ public void closeBiz() {
+ openingFlag.set(0);
}
@Override
@@ -307,4 +502,3 @@
}
}
-
--
Gitblit v1.9.3