Compare commits

..

No commits in common. "fe0904c4fb95dae9e578c19101fa5045ddf077d9" and "7c11fc955bc8098956009a231d885c37077933b2" have entirely different histories.

6 changed files with 9 additions and 18 deletions

View File

@ -12,7 +12,6 @@ var (
type BankruptLog struct { type BankruptLog struct {
LogId bson.ObjectId `bson:"_id"` LogId bson.ObjectId `bson:"_id"`
SnId int32 //玩家id SnId int32 //玩家id
Channel string // 渠道
Platform string //平台名称 Platform string //平台名称
GameId int //游戏id GameId int //游戏id
GameFreeID int32 //房间id GameFreeID int32 //房间id
@ -27,11 +26,10 @@ func NewBankruptLog() *BankruptLog {
return log return log
} }
func NewBankruptLogEx(snid int32, gamefreeid int32, createtime, usecoin int64, platform, channel string, gameId int) *BankruptLog { func NewBankruptLogEx(snid int32, gamefreeid int32, createtime, usecoin int64, platform string, gameId int) *BankruptLog {
cl := NewBankruptLog() cl := NewBankruptLog()
cl.SnId = snid cl.SnId = snid
cl.Platform = platform cl.Platform = platform
cl.Channel = channel
cl.GameId = gameId cl.GameId = gameId
cl.GameFreeID = gamefreeid cl.GameFreeID = gamefreeid

View File

@ -13,15 +13,12 @@ var TaskMgr = &Task{}
type Task struct { type Task struct {
ActivityType map[int32][]*server.DB_Task ActivityType map[int32][]*server.DB_Task
TaskType map[int32][]*server.DB_Task
} }
func (m *Task) Load(fileFullPath string) error { func (m *Task) Load(fileFullPath string) error {
m.ActivityType = make(map[int32][]*server.DB_Task) m.ActivityType = make(map[int32][]*server.DB_Task)
m.TaskType = make(map[int32][]*server.DB_Task)
for _, v := range PBDB_TaskMgr.Datas.GetArr() { for _, v := range PBDB_TaskMgr.Datas.GetArr() {
m.ActivityType[v.GetActivityType()] = append(m.ActivityType[v.GetActivityType()], v) m.ActivityType[v.GetActivityType()] = append(m.ActivityType[v.GetActivityType()], v)
m.TaskType[v.GetTaskType()] = append(m.TaskType[v.GetTaskType()], v)
} }
for _, v := range m.ActivityType { for _, v := range m.ActivityType {
sort.Slice(v, func(i, j int) bool { sort.Slice(v, func(i, j int) bool {
@ -35,10 +32,6 @@ func (m *Task) Reload(fileFullPath string) error {
return m.Load(fileFullPath) return m.Load(fileFullPath)
} }
func (m *Task) GetActivityType(tp int32) []*server.DB_Task { func (m *Task) Get(tp int32) []*server.DB_Task {
return m.ActivityType[tp] return m.ActivityType[tp]
} }
func (m *Task) GetTaskType(tp int32) []*server.DB_Task {
return m.TaskType[tp]
}

View File

@ -121,7 +121,7 @@ func init() {
CostCoin := p.takeCoin - msg.GetReturnCoin() CostCoin := p.takeCoin - msg.GetReturnCoin()
logger.Logger.Infof("NewBankruptLogEx: snid:%v GetReturnCoin:%v coin:%v CostCoin:%v", p.SnId, msg.GetReturnCoin(), p.takeCoin, CostCoin) logger.Logger.Infof("NewBankruptLogEx: snid:%v GetReturnCoin:%v coin:%v CostCoin:%v", p.SnId, msg.GetReturnCoin(), p.takeCoin, CostCoin)
log := model.NewBankruptLogEx(p.SnId, scene.dbGameFree.GetId(), p.CreateTime.Unix(), CostCoin, p.Platform, p.Channel, scene.gameId) log := model.NewBankruptLogEx(p.SnId, scene.dbGameFree.GetId(), p.CreateTime.Unix(), CostCoin, p.Platform, scene.gameId)
if log != nil { if log != nil {
LogChannelSingleton.WriteLog(log) LogChannelSingleton.WriteLog(log)
} }

View File

@ -103,7 +103,7 @@ func CSTaskList(s *netlib.Session, packetId int, data interface{}, sid int64) er
Tp: msg.GetTp(), Tp: msg.GetTp(),
} }
for _, v := range srvdata.TaskMgr.GetActivityType(msg.GetTp()) { for _, v := range srvdata.TaskMgr.Get(msg.GetTp()) {
item := &taskproto.TaskData{ item := &taskproto.TaskData{
Id: v.Id, Id: v.Id,
N: GetTaskTimes(p, v.Id), N: GetTaskTimes(p, v.Id),

View File

@ -2246,7 +2246,7 @@ func (this *Player) OnDayTimer(login, continuous bool, t int) {
// 重置每日任务 // 重置每日任务
if this.WelfData != nil { if this.WelfData != nil {
if this.WelfData.Task != nil { if this.WelfData.Task != nil {
for _, v := range srvdata.TaskMgr.GetActivityType(common.TaskActivityTypeEveryDay) { for _, v := range srvdata.TaskMgr.Get(common.TaskActivityTypeEveryDay) {
this.WelfData.Task[v.GetId()] = &model.TaskData{} this.WelfData.Task[v.GetId()] = &model.TaskData{}
} }
this.WelfData.Task[common.TaskIDInvitePlayGame] = &model.TaskData{} this.WelfData.Task[common.TaskIDInvitePlayGame] = &model.TaskData{}
@ -2313,7 +2313,7 @@ func (this *Player) OnWeekTimer() {
// 重置周任务 // 重置周任务
if this.WelfData != nil { if this.WelfData != nil {
if this.WelfData.Task != nil { if this.WelfData.Task != nil {
for _, v := range srvdata.TaskMgr.GetActivityType(common.TaskActivityTypeWeek) { for _, v := range srvdata.TaskMgr.Get(common.TaskActivityTypeWeek) {
this.WelfData.Task[v.GetId()] = &model.TaskData{} this.WelfData.Task[v.GetId()] = &model.TaskData{}
} }
} }
@ -4459,7 +4459,7 @@ func (this *Player) ResetTaskN(tp int32) {
return return
} }
for _, v := range srvdata.TaskMgr.GetActivityType(tp) { for _, v := range srvdata.TaskMgr.Get(tp) {
data := this.WelfData.Task[v.GetId()] data := this.WelfData.Task[v.GetId()]
if data != nil { if data != nil {
data.N = 0 data.N = 0
@ -4472,7 +4472,7 @@ func (this *Player) ResetTask(tp int32) {
return return
} }
for _, v := range srvdata.TaskMgr.GetActivityType(tp) { for _, v := range srvdata.TaskMgr.Get(tp) {
this.WelfData.Task[v.GetId()] = &model.TaskData{} this.WelfData.Task[v.GetId()] = &model.TaskData{}
} }
} }

View File

@ -157,7 +157,7 @@ func (t *TaskHandle) AllTask(id int, data any) {
logger.Logger.Tracef("AllTask taskID:%v %v", id, p.WelfData.Task[int32(id)]) logger.Logger.Tracef("AllTask taskID:%v %v", id, p.WelfData.Task[int32(id)])
change := map[int32][]*taskproto.TaskData{} change := map[int32][]*taskproto.TaskData{}
for _, v := range srvdata.TaskMgr.GetTaskType(int32(id)) { for _, v := range srvdata.TaskMgr.Get(int32(id)) {
if !info.Debug { if !info.Debug {
// 游戏类型 // 游戏类型
switch v.GetGameType() { switch v.GetGameType() {