hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-09 19:06:49 +08:00
Code Issues Packages Projects Releases Wiki Activity

文章查询参数问题

Browse Source
This commit is contained in:
daihh
2023-02-02 10:18:47 +08:00
parent c94f2ad4e5
commit 76d96a7a72
2 changed files with 24 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
servers/boe-server-all/src/main/java/com/xboe/module/article/service/impl/ArticleServiceImpl.java
View File

@@ -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);

22
servers/boe-server-all/src/main/java/com/xboe/system/user/api/MessageApi.java
View File

@@ -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());
}
}
/**
* 当前登陆人未读消息条数
* */