PenaSide/codeword
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update protobuf

Browse Source
This commit is contained in:
Pavel 2024-04-25 20:44:32 +03:00
parent 2ecb506c79
commit 5863c5ec74
2 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
docs/proto/promo.proto
View File

@ -4,18 +4,25 @@ package codeword;
option go_package = "./codeword_rpc"; option go_package = "./codeword_rpc";
import "google/protobuf/empty.proto";
message Time { message Time {
int64 from = 1; int64 from = 1;
int64 to = 2; int64 to = 2;
} }
service PromoCodeService { service PromoCodeService {
rpc GetAllPromoActivations(Time) returns (PromoActivationResp); rpc GetAllPromoActivations(google.protobuf.Empty) returns (PromoActivationResp);
} }
message PromoActivationResp { message PromoActivationResp {
message UserTime {
string UserID = 1;
int64 Time = 2;
}
message Activations { message Activations {
repeated string values = 1; repeated UserTime values = 1;
} }
map<string, Activations> response = 1; map<string, Activations> response = 1;
} }

10
internal/repository/promocode_stats.go
View File

@ -93,19 +93,12 @@ func (r *StatsRepository) GetAllPromoActivations(ctx context.Context, req *codew
{ {
"$unwind": "$usageArray.v", "$unwind": "$usageArray.v",
}, },
{
"$match": bson.M{
"usageArray.v.time": bson.M{
"$gte": req.From,
"$lte": req.To,
},
},
},
{ {
"$group": bson.M{ "$group": bson.M{
"_id": "$_id", "_id": "$_id",
"users": bson.M{"$push": bson.M{ "users": bson.M{"$push": bson.M{
"UserID": "$usageArray.v.userID", "UserID": "$usageArray.v.userID",
"Time": "$usageArray.v.time",
}}, }},
}, },
}, },
@ -122,6 +115,7 @@ func (r *StatsRepository) GetAllPromoActivations(ctx context.Context, req *codew
ID string `bson:"_id"` ID string `bson:"_id"`
Users []struct { Users []struct {
UserID string `bson:"UserID"` UserID string `bson:"UserID"`
Time int64
} `bson:"users"` } `bson:"users"`
} }
err := cursor.Decode(&data) err := cursor.Decode(&data)