1. 用到的文档数据结构
TradeRate文档里面内嵌Label文档
1.Label（标签文档）
/* 1 */
{
"_id" : ObjectId("593e3f0bf8d9771d344547e6"),
"_class" : "com.shuyun.customer.center.domain.Label",
"labelName" : "spring",
"titleId" : NumberLong(71677914), //标题id
}
/* 2 */
{
"_id" : ObjectId("5940a18436ebf318d4333a61"),
"_class" : "com.shuyun.customer.center.domain.Label",
"labelName" : "mongo",
"titleId" : NumberLong(71677914)
}
2.TradeRate（评价文档）
/* 1*/
{
"_id" : ObjectId("000000010131788772406286"),
"_class" : "com.shuyun.customer.center.domain.TradeRate",
"titleId" : NumberLong(71677914), //标题id
"numIid":NumberLong(41808091712) //子标题id
"created" : ISODate("2017-06-03T14:48:23.000Z") , // 创建时间
"labels" : [ //子文档
{
"_id" : ObjectId("5940a17e36ebf318d4333a5e"),
"labelName" : "spring", //标签名
"titileId" : NumberLong(71677914) //标题id
},
{
"_id" : ObjectId("5940a18436ebf318d4333a61"),
"labelName" : "mongo",
"titleId" : NumberLong(71677914)
}
]
}
/* 2 */
{
"_id" : ObjectId("000000003370954519376596"),
"_class" : "com.shuyun.customer.center.domain.TradeRate",
"titleId" : NumberLong(71677914),
"numIid":NumberLong(41808091712) , //子标题id
"created" : ISODate("2017-06-08T14:48:23.000Z")
}
```
2. 实现增删改
（1）实现 Label文档的数据保存
```
Label label=new Label();
label.setLabelName("spring");
label.setTitleId(71677914);
mongoTemplate.save(label)
```
（2）实现 Label文档的删除同时删除TradeRate文档里面用到的label数据
这里涉及到了对子文档的删除操作
```
mongoTemplate.remove(Query.query(Criteria.where("_id").is(id)),Label.class);
Query query =newQuery(Criteria.where("titleId").is(titleId));
Update update =newUpdate();
update.pull("labels",Query.query(Criteria.where("id").is(id)));
mongoTemplate.updateMulti(query,update,TradeRate.class);
```
（3）实现 修改Label文档的labelName字段，同时修改TradeRate文档里用到的相应名字
这里涉及到了对子文档的修改操作
mongoTemplate.updateFirst(Query.query(Criteria.where("_id").is(label.getId())),Update.update("labelName",label.getLabelName()),Label.class);
Query query = Query.query(Criteria.where("shopId").is(label.getShopId()).and("labels._id").is(newObjectId(label.getId())));Update update = Update.update("labels.$.labelName",label.getLabelName());
mongoTemplate.updateMulti(query,update,TradeRate.class);
（4）实现批量保存或者修改TradeRate的子文档Label
Query query = Query.query(Criteria.where("_id").in(labelSign.getOidList()));
Update update =newUpdate();
Update.AddToSetBuilder builder = update.addToSet("labels");
builder.each(labelSign.getLabels().toArray());
mongoTemplate.updateMulti(query,update,TradeRate.class);
（5）根据相应的条件删除子文档数组中的某个元素
Query query =newQuery(Criteria.where("_id").is(oid));
Update update =newUpdate();
update.pull("labels",Query.query(Criteria.where("id").is(labelId)));
mongoTemplate.updateMulti(query,update,TradeRate.class);
3. 实现根据时间做统计分析
需求：根据相应条件按天统计出TradeRate文档的子文档不同标签的数目（一个月内）
条件：
created: 评价时间 说明：时间范围
titleId: 标题id 说明：例子：8907067067
numIid:子标题id 说明：子标题list集合
publicListstatisticsLabel(StatisticQueryVO param) {
Date endDate = DateUtils.dayStart(newDate());
Calendar calendar = Calendar.getInstance();
calendar.setTime(endDate);
calendar.add(Calendar.DATE,-30);
Date startDate = calendar.getTime();
/**查询条件*/
DBObject dateObject = BasicDBObjectBuilder.start("$gte",startDate).add("$lt",endDate).get();
BasicDBObject dbObject =newBasicDBObject("titleId",param.getTitleId())
.append("created",dateObject)
.append("labels", newBasicDBObject("$exists", true));
if(param.getGoodIds() !=null&& param.getGoodIds().size() >0) {
dbObject.append("numIid", newBasicDBObject("$in",param.getGoodIds()));
}
DBObject match =newBasicDBObject("$match",dbObject);
/**创建$unwind操作,用于切分数组*/
DBObject unwind =newBasicDBObject("$unwind","$labels");
/** Group操作*/
DBObject groupFields =newBasicDBObject("_id", newBasicDBObject("labelName","$labels.labelName")
.append("date", newBasicDBObject("year", newBasicDBObject("$year","$created"))
.append("month", newBasicDBObject("$month","$created"))
.append("day", newBasicDBObject("$dayOfMonth","$created"))));
groupFields.put("counts", newBasicDBObject("$sum",1));
DBObject group =newBasicDBObject("$group",groupFields);
/**定义显示的结果名称*/
DBObject projectFields =newBasicDBObject();
projectFields.put("date","$_id.date");
projectFields.put("labels", newBasicDBObject("labelName","$_id.labelName").append("countNum","$counts"));
DBObject project =newBasicDBObject("$project",projectFields);
/**对结果再次分组*/
DBObject groupAgainFields =newBasicDBObject("_id","$date");
groupAgainFields.put("labelSum", newBasicDBObject("$push","$labels"));
DBObject reshapeGroup =newBasicDBObject("$group",groupAgainFields);
DBObject sortField =newBasicDBObject("$sort", newBasicDBObject("_id",1));
List dbObjectList = Lists.newArrayList();
dbObjectList.add(match);
dbObjectList.add(unwind);
dbObjectList.add(group);
dbObjectList.add(project);
dbObjectList.add(reshapeGroup);
dbObjectList.add(sortField);
AggregationOutput output =mongoTemplate.getCollection("tradeRate").aggregate(dbObjectList);
List resultList = Lists.newArrayList();
DateModel dateModel;
StatisticResultVO statisticResultVO;
//遍历结果
for(DBObject result : output.results()) {
statisticResultVO =newStatisticResultVO();
dateModel = JsonUtils.parse(result.get("_id").toString(),DateModel.class);
statisticResultVO.setDate(newGregorianCalendar(dateModel.getYear(),dateModel.getMonth()-1,dateModel.getDay()+1).getTime());
statisticResultVO.setLabelSumList(JsonUtils.parse2List(result.get("labelSum").toString(),LabelSum.class));
resultList.add(statisticResultVO);
}
returnresultList;
}
