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

更新任务数据

Browse Source
This commit is contained in:
wh_zcy 2022-11-18 23:09:56 +08:00
parent ddc356cad0
commit ba29beb85f
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
modules/rtask/updateHandle.go
View File

@ -20,11 +20,9 @@ func (this *ModelRtaskRecord) overrideUpdate(uid string, cfg *cfg.GameRdtaskCond
} }
record := &pb.DBRtaskRecord{} record := &pb.DBRtaskRecord{}
if err2 := this.Get(uid, record); err2 != nil { if err := this.Get(uid, record); err != nil {
if err2 != mongo.ErrNoDocuments { if err != mongo.ErrNoDocuments {
return errors.Wrapf(err, "获取玩家任务记录 err: %v rtype[%v]", uid, cfg.Id) return errors.Wrapf(err, "获取玩家任务记录 err: %v rtype[%v]", uid, cfg.Id)
} else {
err = err2
} }
} }
@ -34,11 +32,15 @@ func (this *ModelRtaskRecord) overrideUpdate(uid string, cfg *cfg.GameRdtaskCond
if v, ok := record.Vals[cfg.Id]; ok { if v, ok := record.Vals[cfg.Id]; ok {
m := hasUpdateData(paramLen, v, vals...) m := hasUpdateData(paramLen, v, vals...)
v.Data = m
if len(m) > 0 { if len(m) > 0 {
update := map[string]interface{}{ update := map[string]interface{}{
"vals": m, "vals": v,
} }
err = this.Change(uid, update) if err = this.Change(uid, update); err != nil {
return
}
} }
} else { } else {
data := &pb.RtaskData{ data := &pb.RtaskData{
@ -51,7 +53,9 @@ func (this *ModelRtaskRecord) overrideUpdate(uid string, cfg *cfg.GameRdtaskCond
update := map[string]interface{}{ update := map[string]interface{}{
"vals": record.Vals, "vals": record.Vals,
} }
err = this.Change(uid, update) if err = this.Change(uid, update); err != nil {
return
}
} }
this.listenTask(uid, cfg.Id) this.listenTask(uid, cfg.Id)