From 755a7970f2da85adb7ebcc382fac7b3317a99a50 Mon Sep 17 00:00:00 2001
From: wyb <1977763549@qq.com>
Date: Wed, 28 Jun 2023 15:52:05 +0800
Subject: [PATCH] =?UTF-8?q?mq=20=E6=8D=95=E8=8E=B7=E5=BC=82=E5=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../collection/receiver/MzZyMqReceiver.java   | 36 ++++++++++++++-----
 1 file changed, 28 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java b/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java
index dffae87..5e8751e 100644
--- a/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java
+++ b/src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java
@@ -30,8 +30,13 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_createDepartment")
     public void revCreateDepartment(String message){
         log.info("注册科室 队列接收信息：{}",message);
-        DeptDto deptDto= MzZyParser.parseCreateDept(message);
-        powerDeptService.register(deptDto);
+        try {
+            DeptDto deptDto= MzZyParser.parseCreateDept(message);
+            powerDeptService.register(deptDto);
+        }catch (Exception ex){
+            log.error("处理注册科室 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 
 
@@ -43,8 +48,13 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_updateDepartment")
     public void revUpdateDepartment(String message){
         log.info("变更科室 队列接收信息：{}",message);
-        DeptDto deptDto=MzZyParser.parseUpdateDept(message);
-        powerDeptService.register(deptDto);
+        try {
+            DeptDto deptDto=MzZyParser.parseUpdateDept(message);
+            powerDeptService.register(deptDto);
+        }catch (Exception ex){
+            log.error("处理变更科室 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 
 
@@ -55,8 +65,13 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_createPractitioner")
     public void revCreatePractitioner(String message){
         log.info("人员注册 队列接收信息：{}",message);
-        UserDto userDto=MzZyParser.parseCreateUser(message);
-        powerUserService.register(userDto);
+        try {
+            UserDto userDto=MzZyParser.parseCreateUser(message);
+            powerUserService.register(userDto);
+        }catch (Exception ex){
+            log.error("处理人员注册 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 
 
@@ -67,7 +82,12 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_updatePractitioner")
     public void revUpdatePractitioner(String message){
         log.info("人员变更 队列接收信息：{}",message);
-        UserDto userDto=MzZyParser.parseUpdateUser(message);
-        powerUserService.register(userDto);
+        try {
+            UserDto userDto=MzZyParser.parseUpdateUser(message);
+            powerUserService.register(userDto);
+        }catch (Exception ex){
+            log.error("处理人员注册 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 }