浏览代码

优化代码

xiaochan 2 年之前
父节点
当前提交
695ccc8657

+ 4 - 2
src/main/java/thyyxxk/webserver/service/externalhttp/DrgWebServices.java

@@ -3,6 +3,8 @@ package thyyxxk.webserver.service.externalhttp;
 import com.alibaba.fastjson.JSONObject;
 import com.dtflys.forest.annotation.JSONBody;
 import com.dtflys.forest.annotation.Post;
+import com.dtflys.forest.callback.OnError;
+import com.dtflys.forest.callback.OnSuccess;
 import thyyxxk.webserver.entity.vo.DrgGroupTestVO;
 
 /**
@@ -18,8 +20,8 @@ public interface DrgWebServices {
     @Post(url = "http://172.16.32.126:8080/drg_web/drgGroupThird/V2/setListDrg.action")
     JSONObject drgQuality(@JSONBody JSONObject obj);
 
-    @Post(url = "http://172.16.32.126:8082/etlClient/callHisData.action")
-    JSONObject etlClient(@JSONBody JSONObject obj);
+    @Post(url = "http://172.16.32.126:8082/etlClient/callHisData.action", async = true)
+    void etlClient(@JSONBody JSONObject obj);
 
     @Post(url = "http://172.16.32.126:8080/drg_web/drgGroupThird/getAllDrgResults.action")
     JSONObject getDrgCaseQualityControlGroup(@JSONBody JSONObject obj);

+ 1 - 6
src/main/java/thyyxxk/webserver/service/inpatient/PatientService.java

@@ -138,16 +138,11 @@ public class PatientService {
                 JSONArray groupInfo = res.getJSONObject("result").getJSONArray("group_info");
                 if (groupInfo != null) {
                     JSONObject item = groupInfo.getJSONObject(0);
-                    p.setGroupInfoName(item.getString("name"));
-                    p.setGroupInfoWeight(item.getString("weight"));
-                    p.setGroupInfoBl(item.getString("bl"));
-                    p.setGroupInfoProfit(item.getString("profit"));
-                    p.setGroupInfoFeeStand(item.getString("fee_stand"));
                     return ResultVoUtil.success(item);
                 }
             }
         }
-        return ResultVoUtil.success(null);
+        return ResultVoUtil.success();
     }
 
 

+ 2 - 7
src/main/java/thyyxxk/webserver/service/zhuyuanyisheng/YiZhuLuRuServer.java

@@ -306,12 +306,7 @@ public class YiZhuLuRuServer {
         } finally {
             sqlSession.close();
         }
-
-
-        ThreadUtil.execAsync(() -> {
-            drgOrderUpdate(patInfo.getInpatientNo() + "_" + patInfo.getAdmissTimes() + "_" + patInfo.getLedgerSn());
-        });
-
+        drgOrderUpdate(patInfo.getInpatientNo() + "_" + patInfo.getAdmissTimes() + "_" + patInfo.getLedgerSn());
         sendAMessageToTheNurse(param, userCode, patInfo, "新增医嘱");
         return ResultVoUtil.success(ExceptionEnum.SUCCESS_AND_NOTIFICATION);
     }
@@ -343,7 +338,7 @@ public class YiZhuLuRuServer {
     }
 
     /**
-     * 在开医嘱时 drg 需要调用一下这个接口
+     * 在开医嘱时 drg 需要调用一下这个接口,接口已经做了异步的请求
      *
      * @param patientNo 患者id
      */