スプリングデータを使用してグループ内で合計と条件を使用する方法mongodb集約

Question

db.test.aggregate(
    [ { 
     $group: 
     { 
      _id: "$id", 
      "total":{$sum: 1}, 
      "live" : { $sum : {$cond : { if: { $eq: ["$status",A"]},then: 1, else: 0}}}, 
      "chat_hrs" :{ $avg: { $subtract: [ "$end_time", "$start_time" ] } }}}]). 

上記のクエリにmongodb集約を使用するようにspringmvcコーディングを書いてください。

Answer 1

以下の集計パイプラインを使用することができます。生成された

import static org.springframework.data.mongodb.core.aggregation.Aggregation.*; 
import static org.springframework.data.mongodb.core.aggregation.ArithmeticOperators.*; 
import static org.springframework.data.mongodb.core.aggregation.ConditionalOperators.when; 
import static org.springframework.data.mongodb.core.query.Criteria.where; 

Aggregation aggregation = 
      newAggregation(
       project("id"). 
        and(when(where("status").is("A")).then(1).otherwise(0)).as("status"). 
        and(Subtract.valueOf("end_time").subtract("start_time")).as("diffTime"), 
       group("$id").count().as("total").sum("status").as("live").avg("diffTime").as("chat_hrs")); 

モンゴ問合せ：

[{ 
    "$project": { 
     "id": 1, 
     "status": { 
      "$cond": { 
       "if": { 
        "$eq": ["$status", "A"] 
       }, 
       "then": 1, 
       "else": 0 
      } 
     }, 
     "diffTime": { 
      "$subtract": ["$end_time", "$start_time"] 
     } 
    } 
}, { 
    "$group": { 
     "_id": "$id", 
     "total": { 
      "$sum": 1 
     }, 
     "live": { 
      "$sum": "$status" 
     }, 
     "chat_hrs": { 
      "$avg": "$diffTime" 
     } 
    } 
}]