141 lines
3.5 KiB
Go
141 lines
3.5 KiB
Go
package task
|
|
|
|
import (
|
|
"go_dreamfactory/comm"
|
|
"go_dreamfactory/lego/core"
|
|
"go_dreamfactory/lego/sys/log"
|
|
"go_dreamfactory/modules"
|
|
"go_dreamfactory/pb"
|
|
cfg "go_dreamfactory/sys/configure/structs"
|
|
|
|
"go.mongodb.org/mongo-driver/bson/primitive"
|
|
)
|
|
|
|
const ( //Redis
|
|
TableTaskActive core.SqlTable = "taskactive" //活跃度表
|
|
)
|
|
|
|
type ModelTaskActive struct {
|
|
modules.MCompModel
|
|
moduleTask *ModuleTask
|
|
}
|
|
|
|
func (this *ModelTaskActive) Init(service core.IService, module core.IModule, comp core.IModuleComp, options core.IModuleOptions) (err error) {
|
|
err = this.MCompModel.Init(service, module, comp, options)
|
|
this.moduleTask = module.(*ModuleTask)
|
|
this.TableName = string(TableTaskActive)
|
|
return
|
|
}
|
|
|
|
//初始化活跃度
|
|
func (this *ModelTaskActive) initActiveReward(uid string) {
|
|
data := this.moduleTask.configure.getTaskActiveList()
|
|
|
|
for _, conf := range data {
|
|
objId := primitive.NewObjectID().Hex()
|
|
ta := &pb.DBTaskActive{
|
|
Id: objId,
|
|
Uid: uid,
|
|
Tag: conf.IdTag,
|
|
RId: conf.Key,
|
|
}
|
|
if err := this.moduleTask.modelTaskActive.AddList(uid, ta.Id, ta); err != nil {
|
|
log.Errorf("uid:%v tag:%v initActiv add err %v", uid, err)
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
func (this *ModelTaskActive) getActiveList(uid string) (list []*pb.DBTaskActive) {
|
|
if err := this.GetList(uid, &list); err != nil {
|
|
log.Errorf("getActiveList err:%v", err)
|
|
return list
|
|
}
|
|
return
|
|
}
|
|
|
|
//获取玩家活跃度列表
|
|
func (this *ModelTaskActive) getActiveListByTag(uid string, taskTag comm.TaskTag) (list []*pb.DBTaskActive) {
|
|
al := []*pb.DBTaskActive{}
|
|
if err := this.GetList(uid, &al); err != nil {
|
|
log.Errorf("getUserActiveList err:%v", err)
|
|
return al
|
|
}
|
|
|
|
for _, v := range al {
|
|
if v.Tag == int32(taskTag) {
|
|
list = append(list, v)
|
|
}
|
|
}
|
|
|
|
return list
|
|
}
|
|
|
|
//获取玩家活跃记录 id 唯一ID
|
|
func (this *ModelTaskActive) getUserActive(uid, id string, taskTag comm.TaskTag) *pb.DBTaskActive {
|
|
record := this.getActiveListByTag(uid, taskTag)
|
|
for _, v := range record {
|
|
if v.Id == id {
|
|
return v
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (this *ModelTaskActive) updateReceive(uid, id string, taskTag comm.TaskTag, data map[string]interface{}) (err error) {
|
|
if len(data) == 0 {
|
|
return
|
|
}
|
|
return this.moduleTask.modelTaskActive.ChangeList(uid, id, data)
|
|
}
|
|
|
|
//领取处理
|
|
func (this *ModelTaskActive) receiveHandle(uid, id string, conf *cfg.Game_activeRewardData,
|
|
ua *pb.DBTaskActive, taskTag comm.TaskTag) (code pb.ErrorCode) {
|
|
if conf == nil {
|
|
code = pb.ErrorCode_ConfigNoFound
|
|
return
|
|
}
|
|
//玩家活跃度数
|
|
// userActiveTotal := this.moduleTask.modelTask.countActive(uid, taskTag)
|
|
|
|
ue, err := this.moduleTask.ModuleUser.GetUserExpand(uid)
|
|
if err != nil {
|
|
code = pb.ErrorCode_DBError
|
|
return
|
|
}
|
|
if ua.Received == 0 { //未领取
|
|
if ue.Activeday >= conf.Active {
|
|
//更新玩家领取状态
|
|
update := map[string]interface{}{
|
|
"received": 1, //标识已领取
|
|
}
|
|
if err := this.updateReceive(uid, ua.Id, taskTag, update); err != nil {
|
|
log.Errorf("updateReceive err %v", err)
|
|
code = pb.ErrorCode_DBError
|
|
return
|
|
}
|
|
} else {
|
|
code = pb.ErrorCode_TaskActiveNoenough
|
|
}
|
|
} else {
|
|
code = pb.ErrorCode_TaskReceived
|
|
}
|
|
return
|
|
}
|
|
|
|
//清空任务
|
|
func (this *ModelTaskActive) clearTask(uid string, taskTag ...comm.TaskTag) {
|
|
if len(taskTag) == 0 {
|
|
log.Errorf("least one param for taskTag")
|
|
return
|
|
}
|
|
data := this.getActiveListByTag(uid, taskTag[0])
|
|
for _, v := range data {
|
|
if err := this.moduleTask.modelTaskActive.DelListlds(uid, v.Id); err != nil {
|
|
log.Errorf("uid: %v err:%v", uid, err)
|
|
return
|
|
}
|
|
}
|
|
}
|