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()); + } + } }