新版邀请活动充值给自己加积分

common/constant.go

@@ -700,6 +700,7 @@ const (
 	InviteScoreTypeBind     = 1  // 绑定邀请码
 	InviteScoreTypePay      = 2  // 充值
 	InviteScoreTypeRecharge = 3  // 充值完成
+	InviteScoreTypePayMe    = 4  // 充值（给自己）
 )
 
 func InMatchChannel(ls []string, n string) bool {

dbproxy/mq/c_invite.go

@@ -169,6 +169,7 @@ func init() {
 
 			case common.InviteScoreTypePay:
 				// 更新充值积分,上级积分增加
+				add(log.SnId, log.Score, 0, 10000)
 				var psnid int32
 				if len(log.Rate) > 0 {
 					add(log.InviteSnId, log.Score, log.Money, log.Rate[0])

dbproxy/svc/l_invitescore.go

@@ -102,6 +102,22 @@ func SaveInviteScore(req *model.InviteScore, rechargeScore int64) (b bool, err e
 					logger.Logger.Errorf("SaveInviteScore Insert 1 error:%v", err)
 					return false, err
 				}
+				// 自己加积分
+				err = c.Insert(&model.InviteScore{
+					Id:         bson.NewObjectId(),
+					Platform:   req.Platform,
+					SnId:       req.SnId,
+					InviteSnId: req.InviteSnId,
+					Tp:         common.InviteScoreTypePayMe,
+					Score:      req.Score,
+					Ts:         req.Ts,
+					Money:      req.Money,
+					Rate:       req.Rate,
+				})
+				if err != nil {
+					logger.Logger.Errorf("SaveInviteScore Insert me error:%v", err)
+					return false, err
+				}
 			}
 		} else {
 			// 没有充值成功记录
@@ -110,6 +126,25 @@ func SaveInviteScore(req *model.InviteScore, rechargeScore int64) (b bool, err e
 				logger.Logger.Errorf("SaveInviteScore Insert 2 error:%v", err)
 				return false, err
 			}
+			if req.Tp == common.InviteScoreTypePay {
+				// 自己加积分
+				err = c.Insert(&model.InviteScore{
+					Id:         bson.NewObjectId(),
+					Platform:   req.Platform,
+					SnId:       req.SnId,
+					InviteSnId: req.InviteSnId,
+					Tp:         common.InviteScoreTypePayMe,
+					Score:      req.Score,
+					Ts:         req.Ts,
+					Money:      req.Money,
+					Rate:       req.Rate,
+				})
+				if err != nil {
+					logger.Logger.Errorf("SaveInviteScore Insert me 2 error:%v", err)
+					return false, err
+				}
+			}
+
 			newReq := *req
 			if newReq.Tp != common.InviteScoreTypeRecharge {
 				newReq.Id = bson.NewObjectId()

worldsrv/welfmgr.go

@@ -1063,7 +1063,7 @@ func (this *WelfareMgr) BlindBoxInfo(p *Player, bid int32) {
 			if cyc == 1 || blindBox.Cycle == model.WelfareOpen {
 				p.WelfData.BlindBoxId = 0
 			}
-		}                               // == 1代表当日循环
+		} // == 1代表当日循环
 		if p.WelfData.BlindBoxId == 0 { // 未领取过发随机Date
 
 			idx := bid