PenaSide/customer
3
0
Fork 0
generated from PenaSide/GolangTemplate
Code Issues 1 Pull Requests 2 Actions Packages Projects Releases Wiki Activity

fix pipeline

Browse Source
This commit is contained in:
pasha1coil 2023-11-22 21:07:18 +03:00 committed by skeris
parent c149d6a743
commit ae5e06be33
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
internal/interface/repository/history.go
View File

@ -117,19 +117,14 @@ func (receiver *HistoryRepository) GetRecentTariffs(ctx context.Context, userID
ID string `bson:"tariffID"` ID string `bson:"tariffID"`
} }
filter := bson.D{ filter := bson.D{
{fields.History.UserID, userID}, {Key: fields.History.UserID, Value: userID},
{fields.History.IsDeleted, false}, {Key: fields.History.IsDeleted, Value: false},
} }
pipeline := mongo.Pipeline{ findOptions := options.Find()
{{"$match", filter}}, findOptions.SetSort(bson.D{{"createdAt", -1}})
{{"$unwind", "$rawDetails"}}, findOptions.SetLimit(100)
{{"$match", bson.D{{"rawDetails.Key", "tariffs"}}}},
{{"$unwind", "$rawDetails.Value"}}, cursor, err := receiver.mongoDB.Find(ctx, filter, findOptions)
{{"$group", bson.D{{"_id", "$rawDetails.Value.Key.id"}}}},
{{"$sort", bson.D{{"createdAt", -1}}}}, // -1 specifies descending order
{{"$limit", 100}},
}
cursor, err := receiver.mongoDB.Aggregate(ctx, pipeline)
if err != nil { if err != nil {
receiver.logger.Error("failed to get recent tariffs on <GetRecentTariffs> of <HistoryRepository>", receiver.logger.Error("failed to get recent tariffs on <GetRecentTariffs> of <HistoryRepository>",
zap.String("userId", userID), zap.String("userId", userID),