require "shared.init"
require "utils.init"
require "GlobalVar"
require "RedisKeys"
require "ProtocolCode"
require "skynet.manager"

skynet = require "skynet"

redisproxy = require("shared.redisproxy")

SendPacket = function ( ... ) end

local function initRedisDb( ... )
	local servId = tonumber(skynet.getenv("servId"))
	if servId then
		redisproxy:hsetnx("autoincrement_set", "role", servId * MAX_ROLE_NUM)
		redisproxy:hsetnx("autoincrement_set", "union", servId * MAX_ROLE_NUM)
		redisproxy:hsetnx("autoincrement_set", "trade", servId * MAX_ROLE_NUM * 100)
		redisproxy:hsetnx("autoincrement_set", "email", 0)
		redisproxy:hsetnx("autoincrement_set", "emailTimestamp", 0)
		redisproxy:hsetnx("autoincrement_set", "delay_email", 0)
		redisproxy:hsetnx("adv_season", "idx", 0)
		redisproxy:hsetnx("adv_season", "chapter", globalCsv.adv_endless_default_chapter)
		redisproxy:hsetnx("adv_season", "overTime", 0)
	end
end

local steps = {
	[1] = {
		handler = initRedisDb,
		desc = "initialize redis database "
	}
}

skynet.start(function ()
	redisproxy = require("shared.redisproxy")

	local new = redisproxy:hsetnx("autoincrement_set", "server_start", os.date("%Y%m%d", skynet.timex())) == 1
	if not new then
		print("server has been initialized...")
		skynet.exit()
		return
	end
	csvdb = require "shared.csvdata"
	globalCsv = csvdb["GlobalDefineCsv"]

	for _, action in ipairs(steps) do
		print(action.desc .. "start ...")
		action.handler()
		print(action.desc .. "finished ...")
	end
	skynet.exit()
end)