From b39f9e15518fda74d33c9e3fbfb3818db5027093 Mon Sep 17 00:00:00 2001 From: eight <641137800@qq.com> Date: 星期一, 18 十一月 2024 10:00:56 +0800 Subject: [PATCH] 亲和-叫号处理 --- jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/doctor/DoctorController.java | 195 +++++++++++++++++++++++++++++++++++------------- 1 files changed, 141 insertions(+), 54 deletions(-) diff --git a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/doctor/DoctorController.java b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/doctor/DoctorController.java index 10926c0..47bf81c 100644 --- a/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/doctor/DoctorController.java +++ b/jh-module-ecg/jh-module-ecg-biz/src/main/java/cn/lihu/jh/module/ecg/controller/admin/doctor/DoctorController.java @@ -28,8 +28,7 @@ import static cn.lihu.jh.framework.common.exception.enums.GlobalErrorCodeConstants.SUCCESS; import static cn.lihu.jh.framework.common.pojo.CommonResult.error; import static cn.lihu.jh.framework.common.pojo.CommonResult.success; -import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.ECG_INNER_ERROR; -import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.PATIENT_NOT_EXISTS; +import static cn.lihu.jh.module.ecg.enums.ErrorCodeConstants.*; @Tag(name = "绠$悊鍚庡彴 - 鍖荤敓鍙彿") @RestController @@ -136,15 +135,12 @@ { queueService.finishNextPatient(roomId, bedNo); - List<Byte> queueStatusList = new ArrayList<>(); - queueStatusList.add(QueueStatusEnum.RECALLED.getStatus()); - queueStatusList.add(QueueStatusEnum.READY.getStatus()); - queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus()); - queueStatusList.add(QueueStatusEnum.PASSED.getStatus()); - List<QueueDO> queueDOList = queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList); + List<QueueDO> queueDOList = queueService.getToBeCheckedPatient(roomId, bedNo); // 杩囨护鍑� 灏辫瘖涓殑锛屽噯澶囧彨鍙� - QueueDO onStageItem = queueDOList.stream().filter(item -> Objects.equals(item.getStatus(), QueueStatusEnum.ONSTAGE.getStatus())).findFirst().orElse(null); + QueueDO onStageItem = queueDOList.stream().filter(item -> + item.getStatus() == QueueStatusEnum.ONSTAGE.getStatus() && item.getAffinityItem() == 0 + ).findFirst().orElse(null); if (null != onStageItem) { CallSaveReqVO callSaveReqVO = BeanUtils.toBean(onStageItem, CallSaveReqVO.class); callSaveReqVO.setId(null); @@ -165,15 +161,12 @@ { queueService.finishReceiveNextPatient(roomId, bedNo); - List<Byte> queueStatusList = new ArrayList<>(); - queueStatusList.add(QueueStatusEnum.RECALLED.getStatus()); - queueStatusList.add(QueueStatusEnum.READY.getStatus()); - queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus()); - queueStatusList.add(QueueStatusEnum.PASSED.getStatus()); - List<QueueDO> queueDOList = queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList); + List<QueueDO> queueDOList = queueService.getToBeCheckedPatient(roomId, bedNo); // 杩囨护鍑� 灏辫瘖涓殑锛屽噯澶囧彨鍙� - QueueDO onStageItem = queueDOList.stream().filter(item -> Objects.equals(item.getStatus(), QueueStatusEnum.ONSTAGE.getStatus())).findFirst().orElse(null); + QueueDO onStageItem = queueDOList.stream().filter(item -> + item.getStatus() == QueueStatusEnum.ONSTAGE.getStatus() && item.getAffinityItem() == 0 + ).findFirst().orElse(null); if (null != onStageItem) { CallSaveReqVO callSaveReqVO = BeanUtils.toBean(onStageItem, CallSaveReqVO.class); callSaveReqVO.setId(null); @@ -194,26 +187,24 @@ { queueService.finishInstallNextPatient(roomId, bedNo); - List<Byte> queueStatusList = new ArrayList<>(); - queueStatusList.add(QueueStatusEnum.RECEIVED.getStatus()); - List<QueueDO> queueDOList = queueService.getRoomQueueByStatus(roomId, queueStatusList); + List<QueueDO> queueDOList = queueService.getToBeInstalledPatient(roomId, bedNo); // 寰呭畨瑁呯殑鎮h�� - queueStatusList.clear(); - queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus()); - List<QueueDO> installingQueueDOList = queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList); - queueDOList.addAll(0, installingQueueDOList ); - + List<QueueDO> installingQueueDOList = queueDOList.stream().filter(queueDO -> + queueDO.getStatus() == QueueStatusEnum.INSTALLING.getStatus() && queueDO.getAffinityItem() == 0 + ).toList(); // 杩囨护鍑� [瀹夎涓璢 鐨勶紝鍑嗗鍙彿 璇ュ伐浣嶅簲璇� 鏈�澶氬彧鏈変竴涓� [瀹夎涓璢 if (installingQueueDOList.size() > 0) { QueueDO onStageItem = installingQueueDOList.getFirst(); CallSaveReqVO callSaveReqVO = BeanUtils.toBean(onStageItem, CallSaveReqVO.class); callSaveReqVO.setId(null); + callSaveReqVO.setCallType(1); // 瑁呮満鍙彿 callService.createCall(callSaveReqVO); } return success(BeanUtils.toBean(queueDOList, QueueRespVO.class)); } + // 甯歌妫�鏌ヨ繃鍙枫�侀鐢ㄨ繃鍙� @GetMapping("/pass-next-patient") @Operation(summary = "杩囧彿銆佷笅涓�浣嶆偅鑰�") @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") @@ -225,12 +216,7 @@ { queueService.passNextPatient(roomId, bedNo); - List<Byte> queueStatusList = new ArrayList<>(); - queueStatusList.add(QueueStatusEnum.RECALLED.getStatus()); - queueStatusList.add(QueueStatusEnum.READY.getStatus()); - queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus()); - queueStatusList.add(QueueStatusEnum.PASSED.getStatus()); - List<QueueDO> queueDOList = queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList); + List<QueueDO> queueDOList = queueService.getToBeCheckedPatient(roomId, bedNo); // 杩囨护鍑� 灏辫瘖涓殑锛屽噯澶囧彨鍙� QueueDO onStageItem = queueDOList.stream().filter(item -> Objects.equals(item.getStatus(), QueueStatusEnum.ONSTAGE.getStatus())).findFirst().orElse(null); @@ -243,16 +229,42 @@ return success(BeanUtils.toBean(queueDOList, QueueRespVO.class)); } - @GetMapping("/call-again") - @Operation(summary = "閲嶅彨銆佹偅鑰�") + @GetMapping("/pass-install-next-patient") + @Operation(summary = "瀹夎杩囧彿銆佷笅涓�浣嶆偅鑰�") @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") - public CommonResult<String> callAgainPatient( + public CommonResult<List<QueueRespVO>> passInstallNextPatient( @RequestParam("roomId") Long roomId, @RequestParam("bedNo") String bedNo) { - List<Byte> queueStatusList = new ArrayList<>(); + queueService.passInstallNextPatient(roomId, bedNo); + + List<QueueDO> queueDOList = queueService.getToBeInstalledPatient(roomId, bedNo); + + List<QueueDO> installingQueueDOList = queueDOList.stream().filter(queueDO -> queueDO.getStatus() == QueueStatusEnum.INSTALLING.getStatus()).toList(); + // 杩囨护鍑� [瀹夎涓璢 鐨勶紝鍑嗗鍙彿 璇ュ伐浣嶅簲璇� 鏈�澶氬彧鏈変竴涓� [瀹夎涓璢 + if (installingQueueDOList.size() > 0) { + QueueDO onStageItem = installingQueueDOList.getFirst(); + CallSaveReqVO callSaveReqVO = BeanUtils.toBean(onStageItem, CallSaveReqVO.class); + callSaveReqVO.setId(null); + callSaveReqVO.setCallType(1); // 瑁呮満鍙彿 + callService.createCall(callSaveReqVO); + } + + return success(BeanUtils.toBean(queueDOList, QueueRespVO.class)); + } + + @GetMapping("/call-again") + @Operation(summary = "[甯歌妫�鏌鎴朳棰嗙敤] 閲嶅彨銆佹偅鑰�") + @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") + @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") + @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") + public CommonResult<String> callPatientAgain( + @RequestParam("roomId") Long roomId, + @RequestParam("bedNo") String bedNo) + { + List<Integer> queueStatusList = new ArrayList<>(); queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus()); List<QueueDO> queueDOList = queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList); @@ -272,40 +284,60 @@ return success("鎿嶄綔鎴愬姛"); } - @GetMapping("/get-patient-list") - @Operation(summary = "鍙栨偅鑰呭垪琛�") + + @GetMapping("/call-install-again") + @Operation(summary = "閲嶅彨銆佹偅鑰�") @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") - public CommonResult<List<QueueRespVO>> getPatientList( + public CommonResult<String> callInstallingPatientAgain( @RequestParam("roomId") Long roomId, @RequestParam("bedNo") String bedNo) { - List<Byte> queueStatusList = new ArrayList<>(); - queueStatusList.add(QueueStatusEnum.RECALLED.getStatus()); - queueStatusList.add(QueueStatusEnum.READY.getStatus()); - queueStatusList.add(QueueStatusEnum.ONSTAGE.getStatus()); - queueStatusList.add(QueueStatusEnum.PASSED.getStatus()); + List<Integer> queueStatusList = new ArrayList<>(); + queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus()); List<QueueDO> queueDOList = queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList); + + if (queueDOList.isEmpty()) + return success("鏃犲畨瑁呬腑鐨勬偅鑰�"); + + if (queueDOList.size() > 1) { + log.error("room {} bed {} have {} 瀹夎涓殑鎮h��", roomId, bedNo, queueDOList.size()); + return error(ECG_INNER_ERROR); + } + + QueueDO onStageItem = queueDOList.get(0); + CallSaveReqVO callSaveReqVO = BeanUtils.toBean(onStageItem, CallSaveReqVO.class); + callSaveReqVO.setId(null); + callSaveReqVO.setCallType(1); // 瑁呮満鍙彿 + callService.callAgain(callSaveReqVO); + + return success("鎿嶄綔鎴愬姛"); + } + + @GetMapping("/get-to-be-checked-list") + @Operation(summary = "鍙� [甯歌妫�鏌 鎴� [寰呴鐢╙ 鎮h�呭垪琛�") + @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") + @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") + @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") + public CommonResult<List<QueueRespVO>> getToBeCheckedPatientList( + @RequestParam("roomId") Long roomId, + @RequestParam("bedNo") String bedNo) + { + List<QueueDO> queueDOList = queueService.getToBeCheckedPatient(roomId, bedNo); return success(BeanUtils.toBean(queueDOList, QueueRespVO.class)); } - @GetMapping("/get-received-patient-list") - @Operation(summary = "鍙栧凡棰嗙敤鎮h�呭垪琛�") + @GetMapping("/get-to-be-installed-list") + @Operation(summary = "鍙� [寰呭畨瑁匽 鎮h�呭垪琛�") @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") - public CommonResult<List<QueueRespVO>> getReceivedPatientList( + public CommonResult<List<QueueRespVO>> getToBeInstalledPatientList( @RequestParam("roomId") Long roomId, @RequestParam("bedNo") String bedNo) { - List<Byte> queueStatusList = new ArrayList<>(); - queueStatusList.add(QueueStatusEnum.RECEIVED.getStatus()); - List<QueueDO> queueDOList = queueService.getRoomQueueByStatus(roomId, queueStatusList); - - queueStatusList.clear(); - queueStatusList.add(QueueStatusEnum.INSTALLING.getStatus()); - queueDOList.addAll(0, queueService.getBedQueueByStatus(roomId, bedNo, queueStatusList) ); + List<QueueDO> queueDOList = queueService.getToBeInstalledPatient(roomId, bedNo); return success(BeanUtils.toBean(queueDOList, QueueRespVO.class)); } @@ -322,6 +354,33 @@ return success(patientStatisticVO); } + @GetMapping("/get-dev-ready-statistic") + @Operation(summary = "璁惧棰嗙敤缁熻") + @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") + @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") + @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") + public CommonResult<PatientStatisticVO> getDevReadyStatistic( + @RequestParam("roomId") Long roomId, + @RequestParam("bedNo") String bedNo) + { + PatientStatisticVO patientStatisticVO = queueService.getBedDevReadyStatistic(roomId, bedNo); + return success(patientStatisticVO); + } + + + @GetMapping("/get-dev-install-statistic") + @Operation(summary = "璁惧瑁呮満缁熻") + @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") + @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") + @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") + public CommonResult<PatientStatisticVO> getDevInstallStatistic( + @RequestParam("roomId") Long roomId, + @RequestParam("bedNo") String bedNo) + { + PatientStatisticVO patientStatisticVO = queueService.getBedDevInstallStatistic(roomId, bedNo); + return success(patientStatisticVO); + } + @GetMapping("/recall-patient") @Operation(summary = "杩囧彿鐥呬汉鍙洖") @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") @@ -331,9 +390,37 @@ public CommonResult<String> recallPatient( @RequestParam("roomId") Long roomId, @RequestParam("bedNo") String bedNo, - @RequestParam("patId") String patId ) + @RequestParam("patId") String patId, + @RequestParam("checkType") Integer checkType, + @RequestParam("roomId_operator") Long roomId_operator, + @RequestParam("bedNo_operator") String bedNo_operator ) { - Integer result = queueService.recallPatient(roomId, bedNo, patId); + Integer result = queueService.recallPatient(roomId, bedNo, patId, checkType); + if (null == result || 0 == result) + return error(PATIENT_NOT_EXISTS); + + return success("鎿嶄綔鎴愬姛"); + } + + @GetMapping("/recall-install-patient") + @Operation(summary = "杩囧彿瀹夎鐥呬汉鍙洖") + @Parameter(name = "roomId", description = "璇婂缂栧彿", required = true, example = "116") + @Parameter(name = "bedNo", description = "宸ヤ綅缂栧彿", required = true, example = "B2") + @Parameter(name = "patId", description = "鎮h�呯紪鍙�", required = true, example = "B2") + @Parameter(name = "checkType", description = "妫�鏌ョ被鍨�", required = true, example = "100") + @PreAuthorize("@ss.hasPermission('ecg:doctor:task')") + public CommonResult<String> recallInstallPatient( + @RequestParam("roomId") Long roomId, + @RequestParam("bedNo") String bedNo, + @RequestParam("patId") String patId, + @RequestParam("checkType") Integer checkType, + @RequestParam("roomId_operator") Long roomId_operator, + @RequestParam("bedNo_operator") String bedNo_operator ) + { + if (roomId != roomId_operator) + return error(QUEUE_RECALL_INSTALL_NOT_CUR_ROOM); + + Integer result = queueService.recallInstallPatient(roomId, bedNo, patId, checkType, roomId_operator, bedNo_operator); if (null == result || 0 == result) return error(PATIENT_NOT_EXISTS); -- Gitblit v1.9.3