liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传埋点完成推送

Browse Source
This commit is contained in:
liwei1dao 2024-01-11 18:57:55 +08:00
parent 6e99c1fcba
commit bea34c2b0e
1 changed files with 23 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
modules/buried/module.go
View File

@ -94,13 +94,14 @@ func (this *Buried) Rpc_ModuleBuriedTrigger(ctx context.Context, req *pb.Rpc_Mod
//完成任务 //完成任务
func (this *Buried) CompleteCondition(session comm.IUserSession, condiId int32) (err error) { func (this *Buried) CompleteCondition(session comm.IUserSession, condiId int32) (err error) {
var ( var (
uid string uid string
model *buriedModel model *buriedModel
bdatas *pb.DBBuried bdatas *pb.DBBuried
bitem *pb.DBBuriedConItem bitem *pb.DBBuriedConItem
conf *cfg.GameBuriedCondiData conf *cfg.GameBuriedCondiData
ok bool ok bool
bdata *pb.DBBuriedItem bdata *pb.DBBuriedItem
progress []*pb.ConIProgress
) )
uid = session.GetUserId() uid = session.GetUserId()
if model, err = this.modelBuried.getburiedModel(uid); err != nil { if model, err = this.modelBuried.getburiedModel(uid); err != nil {
@ -137,6 +138,7 @@ func (this *Buried) CompleteCondition(session comm.IUserSession, condiId int32)
} }
v1.Value = conf.Value v1.Value = conf.Value
v1.Finish = pb.BuriedItemFinishState_buried_finish v1.Finish = pb.BuriedItemFinishState_buried_finish
progress = append(progress, comm.GetBuriedConIProgress(conf, v1))
} }
} }
} }
@ -166,11 +168,13 @@ func (this *Buried) CompleteCondition(session comm.IUserSession, condiId int32)
bitem.State = pb.BuriedItemState_Sleep bitem.State = pb.BuriedItemState_Sleep
} }
bdata.Condi = append(bdata.Condi, bitem) bdata.Condi = append(bdata.Condi, bitem)
progress = append(progress, comm.GetBuriedConIProgress(conf, bitem))
} }
if err = model.updateUserBurieds(uid, bdatas); err != nil { if err = model.updateUserBurieds(uid, bdatas); err != nil {
this.Error("更新用户埋点数据错误!", log.Field{Key: "err", Value: err.Error()}) this.Error("更新用户埋点数据错误!", log.Field{Key: "err", Value: err.Error()})
return return
} }
session.SendMsg(string(this.GetType()), "change", &pb.BuriedChangePush{Conitems: progress})
return return
} }
@ -393,14 +397,15 @@ func (this *Buried) CheckCondition(session comm.IUserSession, condiIds ...int32)
// 设置任务完成状态并校验 // 设置任务完成状态并校验
func (this *Buried) FinishConditionAndCheck(session comm.IUserSession, finishcondiIds []int32, condiIds ...int32) (condis []*pb.ConIProgress, err error) { func (this *Buried) FinishConditionAndCheck(session comm.IUserSession, finishcondiIds []int32, condiIds ...int32) (condis []*pb.ConIProgress, err error) {
var ( var (
uid string uid string
model *buriedModel model *buriedModel
bdatas *pb.DBBuried bdatas *pb.DBBuried
bitem *pb.DBBuriedConItem bitem *pb.DBBuriedConItem
conf *cfg.GameBuriedCondiData conf *cfg.GameBuriedCondiData
ok bool ok bool
chanage bool chanage bool
bdata *pb.DBBuriedItem progress []*pb.ConIProgress
bdata *pb.DBBuriedItem
) )
uid = session.GetUserId() uid = session.GetUserId()
if model, err = this.modelBuried.getburiedModel(uid); err != nil { if model, err = this.modelBuried.getburiedModel(uid); err != nil {
@ -445,6 +450,7 @@ func (this *Buried) FinishConditionAndCheck(session comm.IUserSession, finishcon
v1.Value = conf.Value v1.Value = conf.Value
v1.Finish = pb.BuriedItemFinishState_buried_finish v1.Finish = pb.BuriedItemFinishState_buried_finish
chanage = true chanage = true
progress = append(progress, comm.GetBuriedConIProgress(conf, v1))
} }
} }
} }
@ -475,6 +481,7 @@ func (this *Buried) FinishConditionAndCheck(session comm.IUserSession, finishcon
} }
bdata.Condi = append(bdata.Condi, bitem) bdata.Condi = append(bdata.Condi, bitem)
chanage = true chanage = true
progress = append(progress, comm.GetBuriedConIProgress(conf, bitem))
} }
} }
@ -538,6 +545,7 @@ func (this *Buried) FinishConditionAndCheck(session comm.IUserSession, finishcon
this.Error("更新用户埋点数据错误!", log.Field{Key: "err", Value: err.Error()}) this.Error("更新用户埋点数据错误!", log.Field{Key: "err", Value: err.Error()})
return return
} }
session.SendMsg(string(this.GetType()), "change", &pb.BuriedChangePush{Conitems: progress})
} }
return return