314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
1
2
3
4
5
6 
 | 
  require "shared.init"
  require "utils.init"
  require "GlobalVar"
  require "RedisKeys"
  require "ProtocolCode"
  require "skynet.manager"
 
 | 
314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
7
8
9
10 
 | 
  
  skynet = require "skynet"
  
  redisproxy = require("shared.redisproxy")
 
 | 
314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
11
12
13
14
15
16
17
18
19
20
21
22 
 | 
  
  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)
 
 | 
1b20cfdb
 
  zhouhaihai
 
赛季更新完善 无尽冒险排行榜
 | 
23
24
25 
 | 
  		redisproxy:hsetnx("adv_season", "idx", 0)
  		redisproxy:hsetnx("adv_season", "chapter", globalCsv.adv_endless_default_chapter)
  		redisproxy:hsetnx("adv_season", "overTime", 0)
 
 | 
314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
26
27
28
29
30
31
32
33
34
35
36 
 | 
  	end
  end
  
  local steps = {
  	[1] = {
  		handler = initRedisDb,
  		desc = "initialize redis database "
  	}
  }
  
  skynet.start(function ()
 
 | 
a5486ede
 
  zhouhaihai
 
csvdata 修改为 share...
 | 
37 
 | 
  	redisd = skynet.localname(".redis")
 
 | 
314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
38
39
40 
 | 
  
  	redisproxy = require("shared.redisproxy")
  
 
 | 
be83d162
 
  zhouahaihai
 
登陆成功。 增加数据结构修正功能
 | 
41 
 | 
  	local new = redisproxy:hsetnx("autoincrement_set", "server_start", os.date("%Y%m%d", skynet.timex())) == 1
 
 | 
314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
42
43
44
45
46 
 | 
  	if not new then
  		print("server has been initialized...")
  		skynet.exit()
  		return
  	end
 
 | 
a5486ede
 
  zhouhaihai
 
csvdata 修改为 share...
 | 
47
48 
 | 
  	csvdb = require "shared.csvdata"
  	globalCsv = csvdb["GlobalDefineCsv"]
 
 | 
314bc5df
 
  zhengshouren
 
提交服务器初始代码
 | 
49
50
51
52
53
54
55
56 
 | 
  
  	for _, action in ipairs(steps) do
  		print(action.desc .. "start ...")
  		action.handler()
  		print(action.desc .. "finished ...")
  	end
  	skynet.exit()
  end)
 
 |