diff --git a/dbproxy/svc/l_lotterycode.go b/dbproxy/svc/l_lotterycode.go index c542a21..502f9ae 100644 --- a/dbproxy/svc/l_lotterycode.go +++ b/dbproxy/svc/l_lotterycode.go @@ -83,7 +83,8 @@ func (svc *LotteryCodeSvc) GetJoinNum(req *model.GetLotteryCodeReq, resp *int) ( tc := new(m) err = c.Pipe([]bson.M{ {"$match": bson.M{"snid": bson.M{"$gt": 0}, "cid": req.CId, "startts": req.StartTs}}, - {"$group": bson.M{"_id": bson.M{"snid": "$snid"}, "count": bson.M{"$sum": "$count"}}}, + {"$group": bson.M{"_id": bson.M{"snid": "$snid"}}}, + {"$count": "count"}, }).AllowDiskUse().One(tc) if err != nil && !errors.Is(err, mgo.ErrNotFound) { logger.Logger.Warn("GetJoinNum error:", err)