Jelajahi Sumber

新增苹果手机推送

18339543638 1 tahun lalu
induk
melakukan
2ff0f451d2

+ 9 - 6
nb-service/web-service/src/main/java/com/nb/web/service/bus/hospital/HospitalManagerRegister.java

@@ -21,21 +21,24 @@ public class HospitalManagerRegister {
     private ScriptManager scriptManager;
     private ConfigStorageManager configStorageManager;
 
+    private HospitalManager hospitalManager;
     public HospitalManagerRegister(ScriptManager scriptManager, ConfigStorageManager configStorageManager) {
         this.scriptManager = scriptManager;
         this.configStorageManager = configStorageManager;
+        hospitalManager=new HospitalManager("1000",scriptManager,configStorageManager);
     }
 
     public void register(String hospitalId){
-        managerMap.computeIfAbsent(hospitalId,k->
-                new HospitalManager(k,scriptManager,configStorageManager)
-        );
+//        managerMap.computeIfAbsent(hospitalId,k->
+//                new HospitalManager(k,scriptManager,configStorageManager)
+//        );
     };
 
     public HospitalManager get(String hospitalId){
-        return  managerMap.computeIfAbsent(hospitalId,k->
-                new HospitalManager(k,scriptManager,configStorageManager)
-        );
+        return hospitalManager;
+//        return  managerMap.computeIfAbsent(hospitalId,k->
+//                new HospitalManager(k,scriptManager,configStorageManager)
+//        );
     }
 
 

+ 3 - 2
nb-service/web-service/src/main/java/com/nb/web/service/bus/websocket/auth/HospitalAuthFilter.java

@@ -30,10 +30,11 @@ public class HospitalAuthFilter implements IWebSocketAuthFilter {
     public boolean auth(HttpRequest httpRequest, HttpResponse httpResponse, ChannelContext channelContext) {
         String authorization = httpRequest.getParam("Authorization");
         String version = httpRequest.getParam("Version");
-        String hospitalId = codeCheck.getHospitalId(authorization);
+        String hospitalId = codeCheck.getHospitalId("1000");
+        HisScriptSession hisScriptSession =  hospitalManagerRegister.get(hospitalId).getScriptSession();
+
         if (CharSequenceUtil.isNotBlank(hospitalId)) {
             channelContext.set(Constants.HOSPITAL_ID,hospitalId);
-            HisScriptSession hisScriptSession =  hospitalManagerRegister.get(hospitalId).getScriptSession();
             //绑定
             hisScriptSession.bindChannel(channelContext,version);
             log.info("医院脚本连接成功,医院编码【{}】",authorization);