54 lines
1.6 KiB
Go
54 lines
1.6 KiB
Go
package main
|
|
|
|
import (
|
|
"time"
|
|
|
|
"mongo.games.com/goserver/core"
|
|
"mongo.games.com/goserver/core/logger"
|
|
"mongo.games.com/goserver/core/schedule"
|
|
|
|
"mongo.games.com/game/model"
|
|
)
|
|
|
|
func init() {
|
|
core.RegisteHook(core.HOOK_BEFORE_START, func() error {
|
|
//每日凌晨4点执行清理任务
|
|
//0 0 4 * * *
|
|
task := schedule.NewTask("定期清理cardlog", "0 0 4 * * *", func() error {
|
|
logger.Logger.Info("@@@执行定期清理任务@@@")
|
|
tNow := time.Now()
|
|
tStart := tNow.AddDate(0, -3, 0)
|
|
changeInfo, err := model.RemoveCoinLog(tStart.Unix())
|
|
if err != nil {
|
|
logger.Logger.Warnf("定期清理coinlog失败: %v", err)
|
|
} else {
|
|
logger.Logger.Warnf("定期清理coinlog成功: updated:%v removed:%v", changeInfo.Updated, changeInfo.Removed)
|
|
}
|
|
//APIlog
|
|
changeInfo, err = model.RemoveAPILog(tStart.Unix())
|
|
if err != nil {
|
|
logger.Logger.Warnf("定期清理APIlog失败: %v", err)
|
|
} else {
|
|
logger.Logger.Warnf("定期清理APIlog成功: updated:%v removed:%v", changeInfo.Updated, changeInfo.Removed)
|
|
}
|
|
return nil
|
|
})
|
|
if task != nil {
|
|
logger.Logger.Info("@@@执行定期清理任务@@@加入调度")
|
|
schedule.AddTask(task.Taskname, task)
|
|
}
|
|
|
|
//每日凌晨执行汇总任务
|
|
//0 0 0 * * *
|
|
//taskDay := schedule.NewTask("定期汇总玩家金币总额", "0 0 0 * * *", func() error {
|
|
// logger.Logger.Info("@@@执行定期汇总任务@@@")
|
|
// return model.AggregatePlayerCoin()
|
|
//})
|
|
//if taskDay != nil {
|
|
// logger.Logger.Info("@@@执行定期汇总任务@@@加入调度")
|
|
// schedule.AddTask(taskDay.Taskname, taskDay)
|
|
//}
|
|
return nil
|
|
})
|
|
}
|