From 76d96a7a7253d7525300251f80ab15dbcb5ee566 Mon Sep 17 00:00:00 2001 From: daihh Date: Thu, 2 Feb 2023 10:18:47 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=87=E7=AB=A0=E6=9F=A5=E8=AF=A2=E5=8F=82?= =?UTF-8?q?=E6=95=B0=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/ArticleServiceImpl.java | 4 ++-- .../com/xboe/system/user/api/MessageApi.java | 22 +++++++++++++++++++ 2 files changed, 24 insertions(+), 2 deletions(-) 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
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
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 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()); + } + } + /** * 当前登陆人未读消息条数 * */