141 lines
3.4 KiB
Go
141 lines
3.4 KiB
Go
// package 更新任务触发后的数据更新
|
|
package rtask
|
|
|
|
import (
|
|
"go_dreamfactory/comm"
|
|
"go_dreamfactory/modules/task"
|
|
"go_dreamfactory/pb"
|
|
cfg "go_dreamfactory/sys/configure/structs"
|
|
"time"
|
|
|
|
"github.com/pkg/errors"
|
|
"go.mongodb.org/mongo-driver/bson/primitive"
|
|
"go.mongodb.org/mongo-driver/mongo"
|
|
)
|
|
|
|
// 覆盖更新
|
|
func (this *ModelRtaskRecord) overrideUpdate(uid string, cfg *cfg.GameRdtaskCondiData, vals ...int32) (err error) {
|
|
var paramLen int
|
|
if paramLen, err = lenParam(cfg, vals...); err != nil {
|
|
return err
|
|
}
|
|
|
|
record := &pb.DBRtaskRecord{}
|
|
if err2 := this.Get(uid, record); err2 != nil {
|
|
if err2 != mongo.ErrNoDocuments {
|
|
return errors.Wrapf(err, "获取玩家任务记录 err: %v rtype[%v]", uid, cfg.Id)
|
|
} else {
|
|
err = err2
|
|
}
|
|
}
|
|
|
|
if record.Vals == nil {
|
|
data := &pb.RtaskData{
|
|
Rtype: cfg.Type,
|
|
Data: toMap(vals...),
|
|
Timestamp: time.Now().Unix(),
|
|
}
|
|
record.Vals = map[int32]*pb.RtaskData{
|
|
cfg.Id: data,
|
|
}
|
|
record.Id = primitive.NewObjectID().Hex()
|
|
record.Uid = uid
|
|
|
|
if err := this.Add(uid, record); err != nil {
|
|
return errors.Wrapf(err, "添加玩家任务记录 err: %v rtype[%v]", uid, cfg.Id)
|
|
}
|
|
} else {
|
|
if v, ok := record.Vals[cfg.Id]; ok {
|
|
m := hasUpdateData(paramLen, v, vals...)
|
|
if len(m) > 0 {
|
|
update := map[string]interface{}{
|
|
"vals": m,
|
|
}
|
|
err = this.Change(uid, update)
|
|
}
|
|
} else {
|
|
data := &pb.RtaskData{
|
|
Rtype: cfg.Type,
|
|
Data: toMap(vals...),
|
|
Timestamp: time.Now().Unix(),
|
|
}
|
|
record.Vals[cfg.Id] = data
|
|
|
|
update := map[string]interface{}{
|
|
"vals": record.Vals,
|
|
}
|
|
err = this.Change(uid, update)
|
|
}
|
|
}
|
|
|
|
this.listenTask(uid, cfg.Id)
|
|
return
|
|
}
|
|
|
|
// 累计更新 - 招募等
|
|
func (this *ModelRtaskRecord) addUpdate(uid string, cfg *cfg.GameRdtaskCondiData, vals ...int32) (err error) {
|
|
record := &pb.DBRtaskRecord{Uid: uid}
|
|
err = this.Get(uid, record)
|
|
if err != nil {
|
|
if err != mongo.ErrNoDocuments {
|
|
return errors.Wrapf(err, "获取玩家任务记录 err: %v rtype[%v]", uid, cfg.Id)
|
|
}
|
|
}
|
|
|
|
if record.Vals == nil {
|
|
record.Id = primitive.NewObjectID().Hex()
|
|
data := &pb.RtaskData{
|
|
Data: toMap(vals...),
|
|
Rtype: cfg.Type,
|
|
Timestamp: time.Now().Unix(),
|
|
}
|
|
|
|
record.Vals = map[int32]*pb.RtaskData{
|
|
cfg.Id: data,
|
|
}
|
|
if err := this.Add(uid, record); err != nil {
|
|
return errors.Wrapf(err, "添加玩家任务记录 err: %v rtype[%v]", uid, cfg.Id)
|
|
}
|
|
} else {
|
|
//查找任务数据
|
|
if v, ok := record.Vals[cfg.Id]; ok {
|
|
newCount := make([]int32, len(vals))
|
|
srcCount := v.Data[0]
|
|
newCount[0] = srcCount + vals[0]
|
|
v.Data = toMap(newCount...)
|
|
v.Timestamp = time.Now().Unix()
|
|
|
|
update := map[string]interface{}{
|
|
"vals": record.Vals,
|
|
}
|
|
err = this.Change(uid, update)
|
|
} else {
|
|
record.Vals[cfg.Id] = &pb.RtaskData{
|
|
Data: toMap(vals...),
|
|
Rtype: cfg.Type,
|
|
Timestamp: time.Now().Unix(),
|
|
}
|
|
update := map[string]interface{}{
|
|
"vals": record.Vals,
|
|
}
|
|
err = this.Change(uid, update)
|
|
}
|
|
}
|
|
this.listenTask(uid, cfg.Id)
|
|
return
|
|
}
|
|
|
|
func (this *ModelRtaskRecord) listenTask(uid string, cfgId int32) {
|
|
//日/周/成就任务监听触发
|
|
tl := new(task.TaskListen)
|
|
tl.Uid = uid
|
|
tl.TaskType = comm.TaskType(cfgId)
|
|
if im, err := this.service.GetModule(comm.ModuleTask); err == nil {
|
|
if mt, ok := im.(*task.ModuleTask); ok {
|
|
mt.GetEventApp().Dispatch(comm.EventTaskChanged, tl)
|
|
}
|
|
} else {
|
|
this.moduleRtask.Printf("get ModuleTask err: %v", err)
|
|
}
|
|
}
|