diff --git a/src/main/java/com/docus/server/collection/infrastructure/receiver/MzZyMqReceiver.java b/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java
similarity index 59%
rename from src/main/java/com/docus/server/collection/infrastructure/receiver/MzZyMqReceiver.java
rename to src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java
index 8669e8c..8d0180d 100644
--- a/src/main/java/com/docus/server/collection/infrastructure/receiver/MzZyMqReceiver.java
+++ b/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java
@@ -1,7 +1,10 @@
-package com.docus.server.collection.infrastructure.receiver;
+package com.docus.server.collection.receiver;
 
+import com.docus.server.collection.dto.DeptDto;
+import com.docus.server.collection.dto.UserDto;
 import com.docus.server.collection.service.IPowerDeptService;
 import com.docus.server.collection.service.IPowerUserService;
+import com.docus.server.collection.xml.parsers.MzZyParser;
 import com.neusoft.nhip.ibmmq.jms.JmsIbmListener;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -9,7 +12,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * @author jiashi
- * 梅州中医医院 MQ 消费者监听
+ * 梅州中医医院 MQ 监听
  */
 @Component
 @Slf4j
@@ -26,8 +29,9 @@ public class MzZyMqReceiver {
      */
     @JmsIbmListener(destination = "TJ_createDepartment")
     public void revCreateDepartment(String message){
-        log.info("注册科室 队列信息：{}",message);
-
+        log.info("注册科室 队列接收信息：{}",message);
+        DeptDto deptDto= MzZyParser.parseCreateDept(message);
+        powerDeptService.register(deptDto);
     }
 
 
@@ -38,8 +42,9 @@ public class MzZyMqReceiver {
      */
     @JmsIbmListener(destination = "TJ_updateDepartment")
     public void revUpdateDepartment(String message){
-        log.info("变更科室 队列信息：{}",message);
-
+        log.info("变更科室 队列接收信息：{}",message);
+        DeptDto deptDto=MzZyParser.parseUpdateDept(message);
+        powerDeptService.register(deptDto);
     }
 
 
@@ -49,8 +54,9 @@ public class MzZyMqReceiver {
      */
     @JmsIbmListener(destination = "TJ_createPractitioner")
     public void revCreatePractitioner(String message){
-        log.info("人员注册 队列信息：{}",message);
-
+        log.info("人员注册 队列接收信息：{}",message);
+        UserDto userDto=MzZyParser.parseCreateUser(message);
+        powerUserService.register(userDto);
     }
 
 
@@ -60,7 +66,8 @@ public class MzZyMqReceiver {
      */
     @JmsIbmListener(destination = "TJ_updatePractitione")
     public void revUpdatePractitioner(String message){
-        log.info("人员变更 队列信息：{}",message);
-
+        log.info("人员变更 队列接收信息：{}",message);
+        UserDto userDto=MzZyParser.parseUpdateUser(message);
+        powerUserService.register(userDto);
     }
 }
diff --git a/src/main/java/com/docus/server/collection/xml/parsers/MzZyParser.java b/src/main/java/com/docus/server/collection/xml/parsers/MzZyParser.java
new file mode 100644
index 0000000..c0d47fe
--- /dev/null
+++ b/src/main/java/com/docus/server/collection/xml/parsers/MzZyParser.java
@@ -0,0 +1,31 @@
+package com.docus.server.collection.xml.parsers;
+
+import com.docus.server.collection.dto.DeptDto;
+import com.docus.server.collection.dto.UserDto;
+
+/**
+ * 梅州中医 XML 解析
+ * @author jishi
+ */
+public class MzZyParser {
+    public static DeptDto parseCreateDept(String xml){
+
+        return null;
+    }
+
+    public static DeptDto parseUpdateDept(String xml){
+
+        return null;
+    }
+
+    public static UserDto parseCreateUser(String xml){
+
+        return null;
+    }
+
+
+    public static UserDto parseUpdateUser(String xml){
+
+        return null;
+    }
+}