上传埋点逻辑代码

This commit is contained in:
liwei1dao 2023-06-08 16:27:59 +08:00
parent 057fa83752
commit 44d965b9e6

View File

@ -73,6 +73,8 @@ func (this *Buried) ActiveCondition(uid string, condiIds ...int32) (err error) {
conf *cfg.GameBuriedCondiData conf *cfg.GameBuriedCondiData
bdatas *pb.DBBuried bdatas *pb.DBBuried
model *buriedModel model *buriedModel
bdata *pb.DBBuriedItem
ok bool
chanage bool chanage bool
) )
if model, err = this.modelBuried.getburiedModel(uid); err != nil { if model, err = this.modelBuried.getburiedModel(uid); err != nil {
@ -85,7 +87,7 @@ func (this *Buried) ActiveCondition(uid string, condiIds ...int32) (err error) {
if conf, err = this.configure.getburiedcondidata(v); err != nil { if conf, err = this.configure.getburiedcondidata(v); err != nil {
return return
} }
if bdata, ok := bdatas.Items[conf.Type]; ok { if bdata, ok = bdatas.Items[conf.Type]; ok {
if conf.Rtype == rtype2 { if conf.Rtype == rtype2 {
ok = false ok = false
for _, v1 := range bdata.Condi { for _, v1 := range bdata.Condi {
@ -98,6 +100,15 @@ func (this *Buried) ActiveCondition(uid string, condiIds ...int32) (err error) {
break break
} }
} }
}
} else {
bdata = &pb.DBBuriedItem{
Btype: conf.Type,
Condi: make([]*pb.DBBuriedConItem, 0),
}
bdatas.Items[conf.Type] = bdata
}
if !ok { if !ok {
bdata.Condi = append(bdata.Condi, &pb.DBBuriedConItem{ bdata.Condi = append(bdata.Condi, &pb.DBBuriedConItem{
Conid: v, Conid: v,
@ -107,10 +118,9 @@ func (this *Buried) ActiveCondition(uid string, condiIds ...int32) (err error) {
Finish: pb.BuriedItemFinishState_buried_unfinish, Finish: pb.BuriedItemFinishState_buried_unfinish,
Timestamp: time.Now().Unix(), Timestamp: time.Now().Unix(),
}) })
}
chanage = true chanage = true
} }
}
} }
if chanage { if chanage {
err = model.updateUserBurieds(uid, bdatas) err = model.updateUserBurieds(uid, bdatas)