diff --git a/skyeye-promote/skyeye-mq/src/main/java/com/skyeye/mq/job/impl/NoticeSendServiceImpl.java b/skyeye-promote/skyeye-mq/src/main/java/com/skyeye/mq/job/impl/NoticeSendServiceImpl.java
index 3802e96b..4551f320 100644
--- a/skyeye-promote/skyeye-mq/src/main/java/com/skyeye/mq/job/impl/NoticeSendServiceImpl.java
+++ b/skyeye-promote/skyeye-mq/src/main/java/com/skyeye/mq/job/impl/NoticeSendServiceImpl.java
@@ -3,6 +3,7 @@
  ******************************************************************************/
 package com.skyeye.mq.job.impl;
 
+import cn.hutool.core.collection.CollectionUtil;
 import cn.hutool.json.JSONUtil;
 import com.skyeye.common.constans.MqConstants;
 import com.skyeye.common.util.MailUtil;
@@ -46,9 +47,9 @@ public class NoticeSendServiceImpl implements RocketMQListener<String> {
             List<Map<String, Object>> beans = JSONUtil.toList(email, null);
             for (int i = 0; i < beans.size(); i++) {
                 Map<String, Object> bean = beans.get(i);
-                if (bean != null && !bean.isEmpty()) {
+                if (CollectionUtil.isNotEmpty(bean)) {
                     // 邮件账号不为空，发送邮件
-                    new MailUtil().send(bean.get("userEmail").toString(), map.get("title").toString(), map.get("content").toString());
+                    new MailUtil().send(bean.get("email").toString(), map.get("title").toString(), map.get("content").toString());
                 }
             }
             // 任务完成