没有异常调用质控接口

src/main/java/com/docus/server/report/api/MedicalRecordService.java

@@ -0,0 +1,18 @@
+package com.docus.server.report.api;
+
+import com.docus.infrastructure.web.api.CommonResult;
+
+/**
+ * 病案基础服务
+ *
+ * @author wyb
+ */
+public interface MedicalRecordService {
+    /**
+     * 根据病案主键和配置自动质控
+     *
+     * @param patientId 案主键
+     * @return 质控接口返回参数
+     */
+    CommonResult<String> cqcAudit(String patientId);
+}

src/main/java/com/docus/server/report/api/impl/MedicalRecordServiceImpl.java

@@ -0,0 +1,37 @@
+package com.docus.server.report.api.impl;
+
+import cn.hutool.http.HttpUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.TypeReference;
+import com.docus.core.util.Func;
+import com.docus.infrastructure.core.exception.BaseException;
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.server.report.api.MedicalRecordService;
+import com.docus.server.report.config.ApplicationBusinessConfig;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+@Slf4j
+public class MedicalRecordServiceImpl implements MedicalRecordService {
+    @Autowired
+    private ApplicationBusinessConfig businessConfig;
+
+    @Override
+    public CommonResult<String> cqcAudit(String patientId) {
+        String nisApproveUrl = businessConfig.getNisApproveUrl();
+        if(Func.isBlank(nisApproveUrl)){
+            throw new BaseException("未配置质控地址！");
+        }
+        // 地址是否已经自带参数了
+        if (nisApproveUrl.contains("?")) {
+            nisApproveUrl=nisApproveUrl+"&";
+        }else {
+            nisApproveUrl=nisApproveUrl+"?";
+        }
+        nisApproveUrl=nisApproveUrl+"patientId="+patientId;
+        String reusltStr = HttpUtil.get(nisApproveUrl);
+        return JSON.parseObject(reusltStr,new TypeReference<CommonResult<String>>(){});
+    }
+}

src/main/java/com/docus/server/report/config/ApplicationBusinessConfig.java

@@ -7,6 +7,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * 应用业务配置
+ *
  * @author wyb
  */
 @Component
@@ -19,4 +20,6 @@ public class ApplicationBusinessConfig {
     private String getTaskUrl;
     @Value("${docus.task.taskCancelUrl:}")
     private String getTaskCancelUrl;
+    @Value("${docus.basic.nisApproveUrl:}")
+    private String nisApproveUrl;
 }

src/main/java/com/docus/server/report/listener/NisReportDownloadWaitHandler.java

@@ -1,10 +1,14 @@
 package com.docus.server.report.listener;
 
+import com.docus.infrastructure.core.exception.BaseException;
 import com.docus.infrastructure.redis.service.RedisOps;
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.infrastructure.web.api.ResultCode;
 import com.docus.server.collection.entity.TBasic;
 import com.docus.server.collection.mapper.TBasicMapper;
 import com.docus.server.common.util.RedisKeyExpirationHandler;
 import com.docus.server.common.util.RedisKeyExpirationListener;
+import com.docus.server.report.api.MedicalRecordService;
 import com.docus.server.report.config.SdRyReportQueryConfig;
 import com.docus.server.report.consts.ReportDownloadWait;
 import com.docus.server.report.mapper.AfScanAssortMapper;
@@ -34,6 +38,8 @@ public class NisReportDownloadWaitHandler extends RedisKeyExpirationHandler {
     private AfScanAssortMapper scanAssortMapper;
     @Resource
     private ShunDePeopleBusinessService shunDePeopleBusinessService;
+    @Resource
+    private MedicalRecordService medicalRecordService;
 
     @PostConstruct
     public void registerRedisKeyExpireListener() {
@@ -88,8 +94,12 @@ public class NisReportDownloadWaitHandler extends RedisKeyExpirationHandler {
     }
 
     private void nisQualityControl(String patientId) {
-        // todo 调用护理质控接口等待 质控那边开发
         log.info("调用护理质控：{}", patientId);
+        CommonResult<String> result = medicalRecordService.cqcAudit(patientId);
+        log.info("{} 护理质控结果：{}", patientId, result);
+        if (!ResultCode.SUCCESS.getCode().equals(result.getCode())) {
+            throw new BaseException(result.getMsg());
+        }
     }
 
 

src/main/resources/bootstrap.yml

@@ -95,6 +95,9 @@ docus:
   task:
     getTaskUrl: http://localhost:9296/api/noviewtask/GetTask
     taskCancelUrl: http://localhost:9296/api/collector/task/cancel
+  basic:
+    # 护理审批
+    nisApproveUrl: http://192.168.16.85:9102/qc/tBasicCqc/cqcAudit?hp=token1
 mybatis-plus:
   configuration:
     map-underscore-to-camel-case: true