Tengo la siguiente tubería de agregación para calcular las marcas mejor calificadas de una colección de teléfonos con sus reseñas integradas.
public Document findTopRatedBrands(int minReviews, int results) { UnwindOperation unwindOperation = unwind("reviews"); GroupOperation groupOperation = group("$brand").avg("$reviews.rating") .as("avgRating").count().as("numReviews"); MatchOperation matchOperation = match(new Criteria("numReviews").gte(minReviews)); SortOperation sortOperation = sort(Sort.by(Sort.Direction.DESC, "avgRating", "numReviews")); LimitOperation limitOperation = limit(results); ProjectionOperation projectionOperation = project().andExpression("_id").as ("brand").andExpression("avgRating").as("rating").andExclude("_id") .andExpression("numReviews").as("reviews"); Aggregation aggregation = newAggregation(unwindOperation, groupOperation, matchOperation, sortOperation, limitOperation, projectionOperation); AggregationResults<Phone> result = mongoOperations .aggregate(aggregation, "phones", Phone.class); return result.getRawResults(); }Un ejemplo de documento en la colección de teléfonos es este:
{ "_id": { "$oid": "61e1cc8f452d0aef89d9125f" }, "brand": "Samsung", "name": "Samsung Galaxy S7", "releaseYear": 2016, "reviews": [{ "_id": { "$oid": "61d4403b86913bee0245c171" }, "rating": 2, "dateOfReview": { "$date": "2019-12-24T00:00:00.000Z" }, "title": "Won't do that again.", "body": "I could not use with my carrier. Sent it back.", "username": "bigrabbit324" }] }Me gustaría ordenar por avgRating (redondeado al primer decimal) y, en segundo lugar, por el número de reseñas. Ahora, la calificación promedio no está redondeada, por lo que siempre da valores diferentes, por lo que tampoco puedo ordenar por número de revisiones. He visto la clase ArithmeticOperators.Round pero no entiendo cómo incluirla aquí si es posible.
Un ejemplo de resultado es el siguiente:
[Document{{brand=Nokia, rating=3.25, reviews=4}}]Me gustaría tener 3.2 como calificación.
Esto funciona en Mongo Compass:
$project: { _id: 0, brand: '$_id', rating: { $round: ['$avgRating', 1] } }tratar
ProjectionOperation roundAverageRating = Aggregation.project("avgRating", "numReviews") .and(ArithmeticOperators.Round.roundValueOf("avgRating").place(1)) .as("avgRatingRounded");