81 lines
1.9 KiB
Lua
81 lines
1.9 KiB
Lua
local skynet = require "skynet"
|
||
local oo = require "Class"
|
||
local log = require "Log"
|
||
local redisKeyUrl = require "RedisKeyUrl"
|
||
local sqlUrl = require "SqlUrl"
|
||
local json =require "json"
|
||
local errorInfo = require "ErrorInfo"
|
||
local dataType = require "DataType"
|
||
|
||
local TaskList = oo.class()
|
||
|
||
function TaskList:Init()
|
||
self.allTask = {} --所有任务
|
||
end
|
||
|
||
function TaskList:OnNewDay() --跨天
|
||
|
||
end
|
||
|
||
--每5秒调一次
|
||
function TaskList:On5SecTimer()
|
||
|
||
end
|
||
|
||
--从DB中载入数据
|
||
function TaskList:LoadDB()
|
||
--加载兑换码列表
|
||
local sql = string.format(sqlUrl.selectInfoFromRedeemList , self.Status_StartBonus )
|
||
local queryData = skynet.server.db:Query( "game" , sql )
|
||
for k, v in pairs(queryData) do
|
||
self:NewRedeemListRecord( v.Code , v.Status , v.BonusPlayerCount , json:decode(v.Data))
|
||
log.info(string.format("加载兑换码信息 兑换码Code %s " , v.Code ))
|
||
end
|
||
end
|
||
|
||
--保存数据到DB
|
||
function TaskList:SaveDB()
|
||
local sql = nil
|
||
local queryData = nil
|
||
|
||
--保存兑换码列表
|
||
for k, v in pairs(self.redeemList) do
|
||
sql = string.format(sqlUrl.updateDataToRedeemList , json:encode(v.data) , v.redeemCode )
|
||
queryData = skynet.server.db:Query( "game" , sql )
|
||
if 1 ~= queryData.affected_rows then
|
||
log.info("修改兑换码数据失败，不存在该Code" , v.redeemCode )
|
||
else
|
||
log.info("成功保存兑换码列表" , v.redeemCode )
|
||
end
|
||
end
|
||
end
|
||
|
||
--新增任务
|
||
function TaskList:Add()
|
||
local lastTaskId = self:GetID()
|
||
end
|
||
|
||
--删除任务
|
||
function TaskList:Remove()
|
||
|
||
end
|
||
|
||
--开始任务
|
||
function TaskList:Start()
|
||
|
||
end
|
||
|
||
--停止任务
|
||
function TaskList:Stop()
|
||
|
||
end
|
||
|
||
--获取任务ID
|
||
function TaskList:GetID()
|
||
local redisKey = string.format( redisKeyUrl.MultiServerTaskID )
|
||
local lastTaskId = skynet.server.redis:incr(redisKey)
|
||
return lastTaskId
|
||
end
|
||
|
||
skynet.server.taskList = TaskList
|
||
return TaskList |