dbseed.lua
1.47 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
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)