From 32323aa1e856cf5a781c461d0a44c8ca13189c11 Mon Sep 17 00:00:00 2001
From: sk <123456@qq.com>
Date: Thu, 27 Jun 2024 15:04:11 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E7=89=88=E9=82=80=E8=AF=B7=E6=B4=BB?=
 =?UTF-8?q?=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dbproxy/mq/c_invite.go  | 6 +++---
 dbproxy/svc/u_player.go | 2 +-
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/dbproxy/mq/c_invite.go b/dbproxy/mq/c_invite.go
index 8dcc9e5..b6bae94 100644
--- a/dbproxy/mq/c_invite.go
+++ b/dbproxy/mq/c_invite.go
@@ -179,7 +179,7 @@ func init() {
 
 			case common.InviteScoreTypePay:
 				// 更新充值积分,上级积分增加
-				add(log.SnId, 0, 0, log.Tp, log.Score, log.Money, 10000, false)
+				add(log.SnId, 0, 0, common.InviteScoreTypePayMe, log.Score, log.Money, 10000, false)
 				var psnid int32
 				if len(log.Rate) > 0 {
 					add(log.InviteSnId, log.SnId, 1, log.Tp, log.Score, log.Money, log.Rate[0], true)
@@ -201,13 +201,13 @@ func init() {
 					add(psnid, log.SnId, 3, log.Tp, log.Score, log.Money, log.Rate[2], false)
 				}
 				if addRechargeScore {
-					add(log.InviteSnId, log.SnId, 0, common.InviteScoreTypeRecharge, log.RechargeScore, log.Money, 10000, true)
+					add(log.InviteSnId, log.SnId, 1, common.InviteScoreTypeRecharge, log.RechargeScore, log.Money, 10000, true)
 				}
 
 			case common.InviteScoreTypeRecharge:
 				// 更新自己的积分
 				if addRechargeScore {
-					add(log.InviteSnId, log.SnId, 0, log.Tp, log.RechargeScore, log.Money, 10000, true)
+					add(log.InviteSnId, log.SnId, 1, log.Tp, log.RechargeScore, log.Money, 10000, true)
 				} else {
 					// 只增加充值金额
 					add(log.InviteSnId, log.SnId, 0, log.Tp, 0, log.Money, 10000, true)
diff --git a/dbproxy/svc/u_player.go b/dbproxy/svc/u_player.go
index 3cae6d2..92a5804 100644
--- a/dbproxy/svc/u_player.go
+++ b/dbproxy/svc/u_player.go
@@ -395,7 +395,7 @@ func (svc *PlayerDataSvc) GetPlayerDataBySnId(args *model.GetPlayerDataBySnIdArg
 		code, _ = GetInviteCode(ret.Pd.Platform, ret.Pd.SnId)
 		ret.Pd.ICode = code
 		ret.Pd.IScoreTs = time.Now()
-		cplayerdata.Update(bson.M{"snid": args.SnId}, bson.M{"icode": code, "iscorets": ret.Pd.IScoreTs})
+		cplayerdata.Update(bson.M{"snid": args.SnId}, bson.M{"$set": bson.M{"icode": code, "iscorets": ret.Pd.IScoreTs}})
 	}
 	f(ret.Pd)
 	if args.CorrectData && ret.Pd != nil {