diff --git a/servers/boe-server-all/src/main/java/com/xboe/module/article/service/impl/ArticleServiceImpl.java b/servers/boe-server-all/src/main/java/com/xboe/module/article/service/impl/ArticleServiceImpl.java
index 6e441ac9..f5649fb9 100644
--- a/servers/boe-server-all/src/main/java/com/xboe/module/article/service/impl/ArticleServiceImpl.java
+++ b/servers/boe-server-all/src/main/java/com/xboe/module/article/service/impl/ArticleServiceImpl.java
@@ -77,8 +77,8 @@ public class ArticleServiceImpl implements IArticleService{
 //		Article article = dao.findOne(FieldFilters.eq("status", Article.STATUS_PUBLISH), FieldFilters.eq("deleted", false), FieldFilters.eq("enabled", true),
 //				FieldFilters.isNotNull("coverurl"), FieldFilters.ne("coverurl", ""));
 //		articles.add(article);
-		List<Article> tops =dao.findList(1, oc, null,FieldFilters.eq("status", Article.STATUS_PUBLISH), FieldFilters.eq("deleted", false), FieldFilters.eq("enabled", true),
-				FieldFilters.isNotNull("coverurl"), FieldFilters.ne("coverurl", ""));
+		List<Article> tops =dao.findList(1, oc,FieldFilters.eq("status", Article.STATUS_PUBLISH), FieldFilters.eq("deleted", false), FieldFilters.eq("enabled", true),
+				FieldFilters.isNotNull("coverurl"),FieldFilters.ne("coverurl", ""));
 		articles.add(tops.get(0));
 		
 		QueryBuilder builder = QueryBuilder.from(Article.class);
diff --git a/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java b/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java
index 4d7ff5d7..0488e181 100644
--- a/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java
+++ b/servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java
@@ -105,6 +105,28 @@ public class MessageApi extends ApiBaseController {
             return error("发布消息失败",e.getMessage());
         }
     }
+    
+    @PostMapping("/batch-send")
+    @AutoLog(module = "消息",action = "批量发送消息")
+    public JsonResponse<Boolean> batchSave(@RequestBody Message message){
+        if(StringUtil.isBlank(message.getTitle())){
+            return badRequest("标题不能为空");
+        }
+        if(StringUtil.isBlank(message.getContent())){
+            return badRequest("内容不能为空");
+        }
+        try {
+            message.setIsRead(false);
+            message.setMsgType(1);
+            message.setMsgTime(LocalDateTime.now());
+            MessageSender.send(message);
+            return success(true);
+        } catch (Exception e) {
+            log.error("发布消息失败",e);
+            return error("发布消息失败",e.getMessage());
+        }
+    }
+    
     /**
      * 当前登陆人未读消息条数
      * */