From 612127d7830372cda153b4af4a41c5e3b9f7e4f0 Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期四, 29 八月 2024 18:28:32 +0800 Subject: [PATCH] update job scheduler --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueService.java | 47 +++++++++++++++++++++++++++++++---------------- 1 files changed, 31 insertions(+), 16 deletions(-) diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueService.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueService.java index 7edae08..7bae87b 100644 --- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueService.java +++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/service/queue/queueService.java @@ -1,11 +1,16 @@ package cn.lihu.jh.module.ecg.service.queue; -import cn.lihu.jh.module.ecg.controller.admin.queue.vo.*; -import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO; -import cn.lihu.jh.framework.common.pojo.PageResult; - +import javax.annotation.Resource; import javax.validation.Valid; import java.util.List; + +import cn.lihu.jh.framework.common.exception.ErrorCode; +import cn.lihu.jh.framework.common.pojo.CommonResult; +import cn.lihu.jh.module.ecg.controller.admin.queue.vo.*; +import cn.lihu.jh.module.ecg.controller.admin.room.vo.RoomRespVO; +import cn.lihu.jh.module.ecg.dal.dataobject.queue.QueueDO; +import cn.lihu.jh.framework.common.pojo.PageResult; +import org.springframework.scheduling.config.ScheduledTaskRegistrar; /** * 鎺掗槦 Service 鎺ュ彛 @@ -14,7 +19,10 @@ */ public interface QueueService { + void setQueueReadyMax(Integer max); void startBiz(); + void closeBiz(); + void resetScheduler(); /** * 鍒涘缓鎺掗槦 @@ -39,6 +47,23 @@ void deletequeue(Integer id); /** + * + */ + ErrorCode startBedOpen(Long roomId, String bedNo); + ErrorCode startBedClose(Long roomId, String bedNo); + ErrorCode startBedDoctorPause(Long roomId, String bedNo, Long docId, String docName); + ErrorCode startBedDoctorResume(Long roomId, String bedNo, Long docId, String docName); + ErrorCode startBedDoctorOn(Long roomId, String bedNo, Long docId, String docName); + ErrorCode startBedDoctorOff(Long roomId, String bedNo, Long docId, String docName); + + ErrorCode bedOpen(Long roomId, String bedNo); + ErrorCode bedClose(Long roomId, String bedNo); + ErrorCode bedDoctorPause(Long roomId, String bedNo, Long docId, String docName); + ErrorCode bedDoctorResume(Long roomId, String bedNo, Long docId, String docName); + ErrorCode bedDoctorOn(Long roomId, String bedNo, Long docId, String docName); + ErrorCode bedDoctorOff(Long roomId, String bedNo, Long docId, String docName); + CommonResult<RoomRespVO> getRoom(Long roomId, String bedNo, Long docId); + /** * 鑾峰緱鎺掗槦 * * @param id 缂栧彿 @@ -61,16 +86,6 @@ void queue(QueueSaveReqVO queueSaveReqVO); /** - * 绯荤粺閲嶅惎鏃讹紝浠嶥B鍚屾宸ヤ綅鐨勬偅鑰呴槦鍒楁暟鎹埌 宸ヤ綅浼樺厛闃熷垪 - */ - void initQueue(); - - /** - * 寮�璇婂墠涓�鍒伙紝瀵� 灏辫瘖鍑嗗鐨� 浜哄憳 閲嶆柊鎺掑簭 - */ - void reorderQueue(); - - /** * 鎶婂尰鐢熷�欒瘖鐨勯槦鍒楀婊� */ void hurryup(); @@ -89,7 +104,7 @@ PatientStatisticVO getPatientStatistic(Long roomId, String bedNo); - Integer passedPatientReturn(Long roomId, String bedNo, String patId); + Integer recallPatient(Long roomId, String bedNo, String patId); - Integer queueJump( String patId, Byte jumped ); + Integer patientJump(String patId, Byte jumped ); } -- Gitblit v1.9.3