捏脸埋点

This commit is contained in:
meixiongfeng 2022-11-10 14:31:51 +08:00
parent ccb28422c4
commit 261988250a
2 changed files with 22 additions and 13 deletions

View File

@ -7,7 +7,6 @@ import (
"go_dreamfactory/modules" "go_dreamfactory/modules"
"go_dreamfactory/pb" "go_dreamfactory/pb"
"go_dreamfactory/sys/configure" "go_dreamfactory/sys/configure"
cfg "go_dreamfactory/sys/configure/structs"
"go_dreamfactory/sys/db" "go_dreamfactory/sys/db"
"go_dreamfactory/utils" "go_dreamfactory/utils"
@ -123,16 +122,19 @@ func (this *Privilege) CreatePrivilegeCard(session comm.IUserSession, cId string
this.SendDailyMail(session, session.GetUserId(), 1) this.SendDailyMail(session, session.GetUserId(), 1)
} }
if code = this.DispenseRes(session, []*cfg.Gameatn{conf.DisposableReward}, true); code != pb.ErrorCode_Success { if code = this.DispenseRes(session, conf.DisposableReward, true); code != pb.ErrorCode_Success {
return return
} }
atn.T = conf.Id atn.T = conf.Id
res = append(res, atn) // 加资源 res = append(res, atn) // 加资源
res = append(res, &pb.UserAssets{ for _, v := range conf.DisposableReward {
A: conf.DisposableReward.A, res = append(res, &pb.UserAssets{
T: conf.DisposableReward.T, A: v.A,
N: conf.DisposableReward.N, T: v.T,
}) N: v.N,
})
}
// 推送 // 推送
session.SendMsg(string(this.GetType()), PrivilegeGetListResp, &pb.PrivilegeGetListResp{Data: []*pb.DBPrivilege{data}}) session.SendMsg(string(this.GetType()), PrivilegeGetListResp, &pb.PrivilegeGetListResp{Data: []*pb.DBPrivilege{data}})
return return
@ -163,18 +165,21 @@ func (this *Privilege) RenewPrivilegeCard(session comm.IUserSession, cId string)
mapData["eTime"] = v.ETime mapData["eTime"] = v.ETime
this.modelPrivilege.modifyPrivilegeData(session.GetUserId(), v.Id, mapData) this.modelPrivilege.modifyPrivilegeData(session.GetUserId(), v.Id, mapData)
// 发放奖励 // 发放奖励
if code = this.DispenseRes(session, []*cfg.Gameatn{conf.DisposableReward}, true); code != pb.ErrorCode_Success { if code = this.DispenseRes(session, conf.DisposableReward, true); code != pb.ErrorCode_Success {
break break
} }
session.SendMsg(string(this.GetType()), PrivilegeGetListResp, &pb.PrivilegeGetListResp{Data: []*pb.DBPrivilege{v}}) session.SendMsg(string(this.GetType()), PrivilegeGetListResp, &pb.PrivilegeGetListResp{Data: []*pb.DBPrivilege{v}})
atn.T = conf.Id atn.T = conf.Id
res = append(res, atn) // 加资源 res = append(res, atn) // 加资源
res = append(res, &pb.UserAssets{ for _, v := range conf.DisposableReward {
A: conf.DisposableReward.A, res = append(res, &pb.UserAssets{
T: conf.DisposableReward.T, A: v.A,
N: conf.DisposableReward.N, T: v.T,
}) N: v.N,
})
}
} else { } else {
code = pb.ErrorCode_PrivilegeRenewTime code = pb.ErrorCode_PrivilegeRenewTime
} }

View File

@ -82,5 +82,9 @@ func (this *apiComp) Create(session comm.IUserSession, req *pb.UserCreateReq) (c
if err := session.SendMsg(string(this.module.GetType()), UserSubTypeCreate, &pb.UserCreateResp{IsSucc: true}); err != nil { if err := session.SendMsg(string(this.module.GetType()), UserSubTypeCreate, &pb.UserCreateResp{IsSucc: true}); err != nil {
code = pb.ErrorCode_SystemError code = pb.ErrorCode_SystemError
} }
if req.Figure != 0 {
this.module.ModuleRtask.SendToRtask(session, comm.Rtype72, 1)
}
return return
} }