feat:佛山三院接收消息统一接口

src/main/java/com/docus/server/CxfConfig.java

@@ -1,6 +1,7 @@
 package com.docus.server;
 
 import com.docus.server.message.consts.HospitalWsMethod;
+import com.docus.server.message.service.FsSyWebServiceUnifyMessageService;
 import com.docus.server.message.service.SdWebServiceUnifyMessageService;
 import com.docus.server.message.service.UnifyMessageService;
 import org.apache.cxf.Bus;
@@ -22,6 +23,13 @@ public class CxfConfig {
 
     private SdWebServiceUnifyMessageService sdWebServiceUnifyMessageService;
 
+    private FsSyWebServiceUnifyMessageService fsSyWebServiceUnifyMessageService;
+
+    @Autowired
+    public void setFsSyWebServiceUnifyMessageService(FsSyWebServiceUnifyMessageService fsSyWebServiceUnifyMessageService) {
+        this.fsSyWebServiceUnifyMessageService = fsSyWebServiceUnifyMessageService;
+    }
+
     @Autowired
     public void setUnifyMessageService(UnifyMessageService unifyMessageService) {
         this.unifyMessageService = unifyMessageService;
@@ -58,6 +66,15 @@ public class CxfConfig {
         return endpoint;
     }
 
+    @Bean
+    @Qualifier("fssyEndPoint")
+    public Endpoint fssyEndPoint() {
+        EndpointImpl endpoint = new EndpointImpl(springBus(), fsSyWebServiceUnifyMessageService);
+        endpoint.publish("/fssy");
+        return endpoint;
+    }
+
+
 //    @Bean
 //    @Qualifier("wsRecordSubmitEndPoint")
 //    public Endpoint wsRecordSubmitEndPoint() {

src/main/java/com/docus/server/message/consts/HospitalWsMethod.java

@@ -10,4 +10,14 @@ public interface HospitalWsMethod {
      * 电子病历提交信息推送
      */
     String WS_RECORD_SUBMIT = "WS_RECORD_SUBMIT";
+
+    /**
+     * 佛山三院用户推送
+     */
+    String WS_FSSY_USER = "WS_FSSY_USER";
+
+    /**
+     * 佛山三院科室推送
+     */
+    String WS_FSSY_DEPT = "WS_FSSY_DEPT";
 }

src/main/java/com/docus/server/message/service/FsSyWebServiceUnifyMessageService.java

@@ -0,0 +1,12 @@
+package com.docus.server.message.service;
+
+import javax.jws.WebService;
+
+/**
+ * @author WYBDEV
+ */
+@WebService
+public interface FsSyWebServiceUnifyMessageService {
+
+    String pushInformation(String message);
+}

src/main/java/com/docus/server/message/service/FsSyWebServiceUnifyMessageServiceImpl.java

@@ -0,0 +1,44 @@
+package com.docus.server.message.service;
+
+import com.docus.server.message.consts.HospitalWsMethod;
+import com.docus.server.message.util.XmlUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.w3c.dom.Node;
+
+/**
+ * @author WYBDEV
+ */
+@Service
+public class FsSyWebServiceUnifyMessageServiceImpl implements  FsSyWebServiceUnifyMessageService{
+
+    private UnifyMessageService unifyMessageService;
+
+    @Autowired
+    public void setUnifyMessageService(UnifyMessageService unifyMessageService) {
+        this.unifyMessageService = unifyMessageService;
+    }
+
+    @Override
+    public String pushInformation(String message) {
+        String methodNamePath="/Request/Header/MethodName";
+        String methodName;
+        try {
+            XmlUtil xmlUtil = XmlUtil.of(message);
+            Node node = xmlUtil.getNode(methodNamePath);
+            methodName = node.getTextContent();
+        }catch (Exception ex){
+            return "获取方法名出错："+methodNamePath;
+        }
+
+        if("AddDepts".equals(methodName)){
+            return unifyMessageService.pushInformation(HospitalWsMethod.WS_FSSY_DEPT,message);
+        }
+        if("AddUsers".equals(methodName)){
+            return unifyMessageService.pushInformation(HospitalWsMethod.WS_FSSY_USER,message);
+        }
+        return "未对接方法"+methodName+"，请联系开发人员！";
+    }
+
+
+}

src/main/java/com/docus/server/message/service/SdWebServiceUnifyMessageServiceImpl.java

@@ -1,8 +1,6 @@
-package com.docus.server.message.service.impl;
+package com.docus.server.message.service;
 
 import com.docus.server.message.consts.HospitalWsMethod;
-import com.docus.server.message.service.SdWebServiceUnifyMessageService;
-import com.docus.server.message.service.UnifyMessageService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 

src/main/java/com/docus/server/message/service/UnifyMessageServiceImpl.java

@@ -1,4 +1,4 @@
-package com.docus.server.message.service.impl;
+package com.docus.server.message.service;
 
 import com.docus.core.util.Func;
 import com.docus.infrastructure.redis.service.IdService;
@@ -11,8 +11,6 @@ import com.docus.server.message.enums.DataFormatEnum;
 import com.docus.server.message.mapper.UnifyMessageMapper;
 import com.docus.server.message.result.MessageInfo;
 import com.docus.server.message.result.ResultUtil;
-import com.docus.server.message.service.MessageCarrier;
-import com.docus.server.message.service.UnifyMessageService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;