一、普通求總數

db.sendlog.find({"event":1000000000001}).count()

二、分組統計並求最大時間

db.sendlog.group({  
    key:{template:"$template",event:"$event",channel:"$channel"},//根據mongodb中的欄位分組
    initial: { failureNum:0,failureSendTime:"1990-01-01 00:00:00" },//初始化欄位
    cond: { event: 1000000000001 ,success:"1"},//條件篩選
    reduce: function ( curr, result) { 
        result.failureNum++;//數量統計
        if(curr.failureSendTime>result.failureSendTime){
            result.failureSendTime=curr.failureSendTime;//求最大失敗時間
        }
     }
    ,
     finalize: function(result) {
          
      }
   }
    )
	
 

 由於是公司資料庫，真正欄位就不顯示了，直接對應上方的欄位匹配

三、在java中用mongotemplate進行查詢

1.導包

		<!--mongodb -->
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-mongodb</artifactId>
		</dependency>

2.寫配置

spring.data.mongodb.uri=mongodb://使用者名稱:密碼@IP:埠/資料庫名
例如：
spring.data.mongodb.uri=mongodb://user:
 
[email protected]:27017/log

3.程式碼

 @Autowired
    private MongoTemplate mongoTemplate;

        /**
         * 查詢統計傳送失敗資料
         */
        public List<MessageEventStatistic> querySuccessStatistic(Long eventId ) {
            Criteria criteria=Criteria.where("event").is(eventId).and("success").is("1");
            GroupByResults<MessageEventStatistic> group = mongoTemplate.group(
                    criteria,
                    "msgSmsSendLog",
                    new GroupBy("event","template", "channel")
                            .initialDocument("{ failureNum: 0 ,failureSendTime:\"1990-01-01 00:00:00\"}")
                            .reduceFunction("function(curr, result){ result.failureNum++; if(curr.failureSendTime>result.failureSendTime){ result.failureSendTime=curr.failureSendTime; }}"),
                    MessageEventStatistic.class);//返回接收類，記得返回的欄位要和類的欄位一致
            Iterator<MessageEventStatistic> iterator = group.iterator();
            List<MessageEventStatistic> list=new ArrayList<>();
            while(iterator.hasNext()){
                MessageEventStatistic next = iterator.next();
                next.setSuccessSendTime(DateUtil.parseTime(next.getSuccessSendTimeStr()));
                list.add(next);
                System.out.println(next.toString());
            }
       return list;
    }