bug 445 497 565

2026-05-25 15:49:49 +08:00
parent 232577caaa
commit 5132de3680
13 changed files with 316 additions and 177 deletions
--- a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/doctorstation/controller/DoctorStationAdviceController.java
+++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/doctorstation/controller/DoctorStationAdviceController.java
@@ -77,8 +77,10 @@ public class DoctorStationAdviceController {
     */
    @PostMapping(value = "/save-advice")
    @RepeatSubmit(interval = 5000, message = "请勿重复提交医嘱，请稍候再试")
-    public R<?> saveAdvice(@RequestBody AdviceSaveParam adviceSaveParam) {
-        return iDoctorStationAdviceAppService.saveAdvice(adviceSaveParam, AdviceOpType.SAVE_ADVICE.getCode());
+    public R<?> saveAdvice(@RequestBody AdviceSaveParam adviceSaveParam,
+                           @RequestParam(required = false, defaultValue = "1") String adviceOpType) {
+        // 🔧 Bug #445 修复：使用前端传入的 adviceOpType 参数（1=保存草稿，2=签发），而非硬编码
+        return iDoctorStationAdviceAppService.saveAdvice(adviceSaveParam, adviceOpType);
    }

    /**
--- a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inhospitalnursestation/appservice/impl/AdviceProcessAppServiceImpl.java
+++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/inhospitalnursestation/appservice/impl/AdviceProcessAppServiceImpl.java
@@ -178,11 +178,24 @@ public class AdviceProcessAppServiceImpl implements IAdviceProcessAppService {
        inpatientAdviceParam.setEncounterIds(null);
        Integer exeStatus = inpatientAdviceParam.getExeStatus();
        inpatientAdviceParam.setExeStatus(null);
-        // requestStatus由前端tab传入，通过QueryWrapper自动添加到SQL外层WHERE过滤
+        // 提取requestStatus手动处理，支持COMPLETED(3)和CHECK_VERIFIED(10)同时查询
+        Integer requestStatus = inpatientAdviceParam.getRequestStatus();
+        inpatientAdviceParam.setRequestStatus(null);
        // 构建查询条件
        QueryWrapper<InpatientAdviceParam> queryWrapper
                = HisQueryUtils.buildQueryWrapper(inpatientAdviceParam, null, null, null);

+        // 手动拼接requestStatus条件：COMPLETED(3)时同时包含CHECK_VERIFIED(10)
+        // UNION查询外层列名为request_status（T1.status_enum AS request_status），不是status_enum
+        if (requestStatus != null) {
+            if (RequestStatus.COMPLETED.getValue().equals(requestStatus)) {
+                queryWrapper.in("request_status",
+                        RequestStatus.COMPLETED.getValue(), RequestStatus.CHECK_VERIFIED.getValue());
+            } else {
+                queryWrapper.eq("request_status", requestStatus);
+            }
+        }
+
        // 手动拼接住院患者id条件
        if (encounterIds != null && !encounterIds.isEmpty()) {
            List<Long> encounterIdList
@@ -315,19 +328,29 @@ public class AdviceProcessAppServiceImpl implements IAdviceProcessAppService {
        Long practitionerId = SecurityUtils.getLoginUser().getPractitionerId();
        Date checkDate = new Date();
        if (!serviceRequestList.isEmpty()) {
-            // 更新服务请求状态已完成
-            serviceRequestService.updateCompleteRequestStatus(
-                    serviceRequestList.stream().map(PerformInfoDto::getRequestId).toList(), practitionerId, checkDate);
-            List<ServiceRequest> serviceRequests = serviceRequestService
-                    .listByIds(serviceRequestList.stream().map(PerformInfoDto::getRequestId).collect(Collectors.toList()));
-            for (ServiceRequest serviceRequest : serviceRequests) {
-                // 判断医嘱类型
+            List<Long> serviceReqIds = serviceRequestList.stream().map(PerformInfoDto::getRequestId).toList();
+            // 先查询服务请求，按 categoryEnum 分流：检查类(23)走 CHECK_VERIFIED，其余走 COMPLETED
+            List<ServiceRequest> allServiceRequests = serviceRequestService.listByIds(serviceReqIds);
+            List<Long> checkReqIds = allServiceRequests.stream()
+                    .filter(sr -> ActivityDefCategory.TEST.getValue().equals(sr.getCategoryEnum()))
+                    .map(ServiceRequest::getId).toList();
+            List<Long> otherReqIds = allServiceRequests.stream()
+                    .filter(sr -> !ActivityDefCategory.TEST.getValue().equals(sr.getCategoryEnum()))
+                    .map(ServiceRequest::getId).toList();
+            // 检查类 → 已校对（CHECK_VERIFIED=10）
+            if (!checkReqIds.isEmpty()) {
+                serviceRequestService.updateCheckVerifiedStatus(checkReqIds, practitionerId, checkDate);
+            }
+            // 其他类 → 已完成（COMPLETED=3）
+            if (!otherReqIds.isEmpty()) {
+                serviceRequestService.updateCompleteRequestStatus(otherReqIds, practitionerId, checkDate);
+            }
+            // 处理转科/出院等特殊医嘱
+            for (ServiceRequest serviceRequest : allServiceRequests) {
                if (ActivityDefCategory.TRANSFER.getValue().equals(serviceRequest.getCategoryEnum())) {
-                    // 更新患者状态 待转科
                    encounterService.updateEncounterStatus(serviceRequest.getEncounterId(),
                            EncounterZyStatus.PENDING_TRANSFER.getValue());
                } else if (ActivityDefCategory.DISCHARGE.getValue().equals(serviceRequest.getCategoryEnum())) {
-                    // 更新患者状态 待出院
                    encounterService.updateEncounterStatus(serviceRequest.getEncounterId(),
                            EncounterZyStatus.AWAITING_DISCHARGE.getValue());
                }
@@ -442,6 +465,15 @@ public class AdviceProcessAppServiceImpl implements IAdviceProcessAppService {
            List<ServiceRequestUseExe> actUseExeList = this.assemblyActivity(activityList);
            // 处理诊疗执行
            this.exeActivity(actUseExeList, exeDate);
+            // 检查类医嘱执行后，状态改为"待接收"（PENDING_RECEIVE=11）
+            List<Long> actReqIds = activityList.stream().map(AdviceExecuteDetailParam::getRequestId).toList();
+            List<ServiceRequest> executedReqs = serviceRequestService.listByIds(actReqIds);
+            List<Long> checkReqIds = executedReqs.stream()
+                    .filter(sr -> ActivityDefCategory.TEST.getValue().equals(sr.getCategoryEnum()))
+                    .map(ServiceRequest::getId).toList();
+            if (!checkReqIds.isEmpty()) {
+                serviceRequestService.updatePendingReceiveStatus(checkReqIds);
+            }
        }

        return R.ok(null, MessageUtils.createMessage(PromptMsgConstant.Common.M00004, new Object[]{"医嘱执行"}));
--- a/openhis-server-new/openhis-application/src/main/resources/mapper/regdoctorstation/RequestFormManageAppMapper.xml
+++ b/openhis-server-new/openhis-application/src/main/resources/mapper/regdoctorstation/RequestFormManageAppMapper.xml
@@ -47,10 +47,19 @@
                       ) THEN 5
                       WHEN EXISTS (
                           SELECT 1 FROM wor_service_request ws
-                           INNER JOIN lab_specimen ls ON ls.service_id = ws.id
                           WHERE ws.prescription_no = drf.prescription_no AND ws.delete_flag = '0'
-                             AND ls.collection_status_enum >= 1
+                             AND ws.status_enum = 12
                       ) THEN 4
+                       WHEN EXISTS (
+                           SELECT 1 FROM wor_service_request ws
+                           WHERE ws.prescription_no = drf.prescription_no AND ws.delete_flag = '0'
+                             AND ws.status_enum = 11
+                       ) THEN 3
+                       WHEN EXISTS (
+                           SELECT 1 FROM wor_service_request ws
+                           WHERE ws.prescription_no = drf.prescription_no AND ws.delete_flag = '0'
+                             AND ws.status_enum = 10
+                       ) THEN 2
                       WHEN EXISTS (
                           SELECT 1 FROM wor_service_request ws
                           WHERE ws.prescription_no = drf.prescription_no AND ws.delete_flag = '0'
--- a/openhis-server-new/openhis-common/src/main/java/com/openhis/common/enums/RequestStatus.java
+++ b/openhis-server-new/openhis-common/src/main/java/com/openhis/common/enums/RequestStatus.java
@@ -57,7 +57,22 @@ public enum RequestStatus implements HisEnumInterface {
    /**
     * 未知
     */
-    UNKNOWN(9, "unknown", "未知");
+    UNKNOWN(9, "unknown", "未知"),
+
+    /**
+     * 已校对（检查申请：护士校对通过）
+     */
+    CHECK_VERIFIED(10, "check_verified", "已校对"),
+
+    /**
+     * 待接收（检查申请：等待医技科室接单）
+     */
+    PENDING_RECEIVE(11, "pending_receive", "待接收"),
+
+    /**
+     * 已接收（检查申请：医技科室已接单）
+     */
+    CHECK_RECEIVED(12, "check_received", "已接收");

    @EnumValue
    private final Integer value;
--- a/openhis-server-new/openhis-domain/src/main/java/com/openhis/workflow/service/IServiceRequestService.java
+++ b/openhis-server-new/openhis-domain/src/main/java/com/openhis/workflow/service/IServiceRequestService.java
@@ -39,6 +39,22 @@ public interface IServiceRequestService extends IService<ServiceRequest> {
     */
    void updateCompleteRequestStatus(List<Long> serReqIdList, Long practitionerId, Date checkDate);

+    /**
+     * 更新检查申请状态：已校对（护士校对检查申请后状态为CHECK_VERIFIED，而非COMPLETED）
+     *
+     * @param serReqIdList 服务请求id列表
+     * @param practitionerId 校对人
+     * @param checkDate 校对时间
+     */
+    void updateCheckVerifiedStatus(List<Long> serReqIdList, Long practitionerId, Date checkDate);
+
+    /**
+     * 更新检查申请状态：待接收（护士执行检查申请后状态为PENDING_RECEIVE）
+     *
+     * @param serReqIdList 服务请求id列表
+     */
+    void updatePendingReceiveStatus(List<Long> serReqIdList);
+
    /**
     * 获取执行过的诊疗数据
     *
--- a/openhis-server-new/openhis-domain/src/main/java/com/openhis/workflow/service/impl/ServiceRequestServiceImpl.java
+++ b/openhis-server-new/openhis-domain/src/main/java/com/openhis/workflow/service/impl/ServiceRequestServiceImpl.java
@@ -66,6 +66,31 @@ public class ServiceRequestServiceImpl extends ServiceImpl<ServiceRequestMapper,
                        .eq(ServiceRequest::getDeleteFlag, DelFlag.NO.getCode()));
    }

+    /**
+     * 更新检查申请状态：已校对（护士校对检查申请后状态为CHECK_VERIFIED，而非COMPLETED）
+     *
+     * @param serReqIdList 服务请求id列表
+     */
+    @Override
+    public void updateCheckVerifiedStatus(List<Long> serReqIdList, Long practitionerId, Date checkDate) {
+        baseMapper.update(new ServiceRequest().setStatusEnum(RequestStatus.CHECK_VERIFIED.getValue())
+                .setPerformerCheckId(SecurityUtils.getLoginUser().getPractitionerId()).setCheckTime(DateUtils.getNowDate()),
+                new LambdaUpdateWrapper<ServiceRequest>().in(ServiceRequest::getId, serReqIdList)
+                        .eq(ServiceRequest::getDeleteFlag, DelFlag.NO.getCode()));
+    }
+
+    /**
+     * 更新检查申请状态：待接收（护士执行检查申请后状态为PENDING_RECEIVE）
+     *
+     * @param serReqIdList 服务请求id列表
+     */
+    @Override
+    public void updatePendingReceiveStatus(List<Long> serReqIdList) {
+        baseMapper.update(new ServiceRequest().setStatusEnum(RequestStatus.PENDING_RECEIVE.getValue()),
+                new LambdaUpdateWrapper<ServiceRequest>().in(ServiceRequest::getId, serReqIdList)
+                        .eq(ServiceRequest::getDeleteFlag, DelFlag.NO.getCode()));
+    }
+
    /**
     * 获取执行过的诊疗数据
     *