异常处理

modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java

@@ -52,7 +52,7 @@ public class MessageMailQueueReceiver {
     @RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE)
     public void processImppMail(SysMessage msg, Channel channel, Message message) {
         try {
-            LOGGER.info("【MQ-IMPP_MESSAGE_MAIL_QUEUE】数据接收成功：{}",msg);
+            LOGGER.info("【MQ-IMPP_MESSAGE_MAIL_QUEUE】数据接收成功：{}", msg);
             if (msg.getMessageSendTime() == null) {
                 msg.setMessageSendTime(TimeTool.getNowTime(true));
             }
@@ -63,16 +63,16 @@ public class MessageMailQueueReceiver {
             mailUtil.setSubject(msg.getMessageTitle());
             mailUtil.setContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.valueOfDescription(msg.getMessageContentType()));
             mailUtil.setBody(msg.getMessageContent());
-
-            if(msg.getMessageReceiverType().intValue() == ImppEnumUtil.MESSAGE_RECEIVER_TYPE.URGENT.getValue()){
+            if(msg.getMessageReceiverType() != null){
+                if (msg.getMessageReceiverType().intValue() == ImppEnumUtil.MESSAGE_RECEIVER_TYPE.URGENT.getValue()) {
                     // 判断是否为系统紧急提示 微服注册状态提示
                     mailUtil.setTo(sysConfigService.getSysConfigByCode(PlatformConstWords.CONTACT_MAIL).getConfigValue());
                     // 次数过于频繁
 //                mailUtil.send();
 
-            } else if(msg.getMessageReceiverType().intValue() == ImppEnumUtil.MESSAGE_RECEIVER_TYPE.EXTERNAL.getValue()){
+                } else if (msg.getMessageReceiverType().intValue() == ImppEnumUtil.MESSAGE_RECEIVER_TYPE.EXTERNAL.getValue()) {
                     //判断是否为外部邮件
-                mailUtil.setTo(StringUtils.split(msg.getMessageReceiversNameRdd(),","));
+                    mailUtil.setTo(StringUtils.split(msg.getMessageReceiversNameRdd(), ","));
                     mailUtil.send();
 
                 } else if (msg.getMessageReceiverType().intValue() == ImppEnumUtil.MESSAGE_RECEIVER_TYPE.INTERNAL.getValue()) {
@@ -106,8 +106,11 @@ public class MessageMailQueueReceiver {
                     msg.setMessageReceiversNameRdd(StringUtils.join(receiverName, ","));
                     sysMessageService.updateSysMessage(msg);
                 }
+            }
             //信息已处理
-            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
+            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+        }catch (NullPointerException e){
+            LOGGER.error(e.getMessage());
         } catch (Exception e) {
             LOGGER.error("【MQ-IMPP_MESSAGE_MAIL_QUEUE】处理出错：{}",e.getMessage(),e);
             //丢弃这条消息