From 3c910a4ad74a1e8d46559bb1318220f143b033e5 Mon Sep 17 00:00:00 2001 From: sk <123456@qq.com> Date: Wed, 10 Jul 2024 15:00:56 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E5=85=85=E5=80=BC?= =?UTF-8?q?=E9=87=91=E9=A2=9D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- dbproxy/svc/l_dbshoplog.go | 4 ++-- dbproxy/svc/l_itemlog.go | 3 +++ 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/dbproxy/svc/l_dbshoplog.go b/dbproxy/svc/l_dbshoplog.go index baa4c28..6b25c0a 100644 --- a/dbproxy/svc/l_dbshoplog.go +++ b/dbproxy/svc/l_dbshoplog.go @@ -114,8 +114,8 @@ func GetMoneyTotal(platform string, snid int32) int64 { } tc := new(m) err = c.Pipe([]bson.M{ - {"$match": bson.M{"snid": snid, "state": 1, "consumenum": bson.M{"$gt": 0}}}, - {"$group": bson.M{"_id": nil, "total": bson.M{"$sum": "$consumenum"}}}, + {"$match": bson.M{"snid": snid, "state": 1, "consumetypenum": bson.M{"$gt": 0}}}, + {"$group": bson.M{"_id": nil, "total": bson.M{"$sum": "$consumetypenum"}}}, }).AllowDiskUse().One(tc) if err != nil && !errors.Is(err, mgo.ErrNotFound) { logger.Logger.Error("GetMoneyTotal error:", err) diff --git a/dbproxy/svc/l_itemlog.go b/dbproxy/svc/l_itemlog.go index fe8cf0e..2ddbbaa 100644 --- a/dbproxy/svc/l_itemlog.go +++ b/dbproxy/svc/l_itemlog.go @@ -73,6 +73,7 @@ func GetItemCount(platform string, snid, id int32, tp int) (count int64) { swapN = tc.Count // 比赛返回 + tc = new(m) err = c.Pipe([]bson.M{ {"$match": bson.M{"snid": snid, "logtype": 0, "itemid": id, "typeid": common.GainWay_MatchSignup}}, {"$group": bson.M{"_id": nil, "count": bson.M{"$sum": "$count"}}}, @@ -84,6 +85,7 @@ func GetItemCount(platform string, snid, id int32, tp int) (count int64) { matchN = tc.Count // 消耗总数量 + tc = new(m) err = c.Pipe([]bson.M{ {"$match": bson.M{"snid": snid, "logtype": 1, "itemid": id}}, {"$group": bson.M{"_id": nil, "count": bson.M{"$sum": "$count"}}}, @@ -95,6 +97,7 @@ func GetItemCount(platform string, snid, id int32, tp int) (count int64) { costN = tc.Count // 获得总数量 + tc = new(m) err = c.Pipe([]bson.M{ {"$match": bson.M{"snid": snid, "logtype": 0, "itemid": id}}, {"$group": bson.M{"_id": nil, "count": bson.M{"$sum": "$count"}}},