集合设计

父级集合 — 消息推送概览

MsgPushInfoVo

字段名 字段类型 备注
_id String 主键
userId String 用户ID
userAccount String 学号/教职工号
userType String 用户类型
schoolId String 学校代码
noReadCount String 未读消息数量
pushFlag String 是否开启消息推送(0:关闭，1：开启)
childInfoList List 推送信息列表

子级集合 — 消息推送详情

MsgPushChildInfoVo

字段名 字段类型 备注
pushTime String 推送时间
pushType String 推送类型: 人工推送，自动推送
content String 推送内容
knowLibId String AI问题所属知识库分类ID
knowLibName String AI问题所属知识库分类名称
question String AI问题
answer String AI回复JSON串
answerCode String AI场景代码
readStatus String 已读状态（0：未读，1：已读）
updateStatus String 数据更新状态（1：已更新， 0：未更新）

分页查询实现——原生实现

  1. db.msgPushInfo.find(
  2.     {"schoolId": "LIANYI", "userAccount": "student"}, 
  3.   {"_id": 1}
  4. ).pretty();
  7. db.msgPushInfo.aggregate([
  8.   {$match: {"_id": ObjectId("5eeacaa0edca59111d0d2a81")}},
  9.   {$project: {"childInfoList" : 1, "_id": 0}},
  10.   {$unwind: "$childInfoList"},
  11.   {$match : { "childInfoList.updateStatus" : "1", "childInfoList.answerCode" : { $ne :"noData" }}},
  12.   {$sort: {"childInfoList.pushTime": -1}},
  13.   {$skip: 0},
  14.   {$limit: 10}
  15. ]).pretty();
  17. aggregate: mongodb的聚合（aggregate）使用的是管道（pipeline）的模式，上一个阶段的处理的结果做为
  18. 下一个阶段的输入
  20. - {$match:{"_id": ObjectId("5eeacaa0edca59111d0d2a81")}}
  21. 匹配主键为5eeacaa0edca59111d0d2a81的记录，数据导入时未设置主键，该主键默认由mongodb自动生成，
  22. 需要先查询主文档获得
  24. - {$project: {"childInfoList": 1, "_id": 0}}
  25. 设置投影，只显示childInfoList字段
  27. - {$unwind: "$childInfoList"}
  28. 将childInfoList字段结果集展开
  30. - {$sort: {"childInfoList.pushTime": -1}}
  31. 按照推送时间倒序排序
  33. - {$skip: 0}
  34. 分页参数，第一页， 第N页取值 (N-1)
  36. - {$limit: 10}
  37. 单页条数

分页查询实现——MongoTemplate方式

  1. @Test
  2. public void mongoPage() {
  3.     Document queryObject = new Document();
  4.     queryObject.put("schoolId","LIANYI");
  5.     queryObject.put("userAccount","student");
  7.     Document fieldObject = new Document();
  8.     fieldObject.put("_id",true);
  9.     Query query = new BasicQuery(queryObject, fieldObject);
  10.     Map<String, ObjectId> findMap = mongoTemplate.findOne(query, Map.class, "msgPushInfo");
  11.     ObjectId _id = findMap.get("_id");
  13.     //        AggregationOperation matchOperation = Aggregation.match(Criteria.where("schoolId").is("LIANYI").and("userAccount").is("student"));
  15.     // 匹配指定主键的记录（match:搜索条件criteria）
  16.     AggregationOperation matchOperation = Aggregation.match(Criteria.where("_id").is(_id));
  18.     // 要查询的字段信息（project:列出所有本次查询的字段，包括查询条件的字段和需要搜索的字段）
  19.     AggregationOperation projectOperation = Aggregation.project("childInfoList");
  21.     // 对查询的字段展开详情信息（unwind：某一个字段是集合，将该字段分解成数组）
  22.     AggregationOperation unwindOperation = Aggregation.unwind("childInfoList");
  24.     // 匹配 更更新AI回答，且正确回复的数据(updateStatus=1, answerCode != noData)
  25.     AggregationOperation match2Operation = Aggregation.match(
  26.         Criteria.where("childInfoList.updateStatus").is("1").and("childInfoList.answerCode").ne("noData"));
  28.     // 排序
  29.     AggregationOperation sortOperation = Aggregation.sort(Sort.Direction.DESC, "childInfoList.pushTime");
  31.     // 页码
  32.     AggregationOperation skipOperation = Aggregation.skip(0L);
  34.     // 每页条数
  35.     AggregationOperation limitOperation = Aggregation.limit(10L);
  37.     Aggregation aggregation = Aggregation.newAggregation(matchOperation, projectOperation, unwindOperation, sortOperation, skipOperation, limitOperation);
  39.     AggregationResults<Map> results = mongoTemplate.aggregate(aggregation, "msgPushInfo", Map.class);
  40.     List<Map> batch = results.getMappedResults();
  41.     List<MsgPushChildInfoVo> list = batch.stream().map(a -> JSON.parseObject(JSON.toJSONString(a.get("childInfoList")), MsgPushChildInfoVo.class)).collect(Collectors.toList());
  42.     System.out.println(list);
  44. }