314bc5df
 zhengshouren
提交服务器初始代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
local skynet = require "skynet"
local harbor = require "skynet.harbor"
local json = require("shared.json")
local redisproxy = require("shared.redisproxy")
require "shared.init"
require "utils.init"
require "RedisKeys"
require "skynet.manager"
local ipairs = ipairs
local table_insert = table.insert
local tarr2tab = table.array2Table
local string_format = string.format
local pointDataMark = {}
local utils = {}
local CHECK_MAIL_STATUS_INTERVAL = 60
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
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
55
56
57
58
59
60
61
62
63
64
65
|
local function mailQuene()
local delayEmail = tonum(redisproxy:hget("autoincrement_set", "delay_email"))
if delayEmail == 0 then
return
end
local begin = math.max(delayEmail - 100, 1)
local mails = redisproxy:pipelining(function (red)
for id = begin, delayEmail do
red:hgetall(string.format("delayEmail:%s", id))
end
end)
if not mails then
return
end
local now = skynet.timex()
local mailList = {}
for index, data in ipairs(mails) do
if next(data) then
local email = tarr2tab(data)
if tonum(email.startTime) <= now then
table_insert(mailList, email)
if #mailList > 100 then
break
end
end
end
end
if #mailList == 0 then
return
end
redisproxy:pipelining(function (red)
for _, email in ipairs(mailList) do
red:del(string_format("delayEmail:%s", email.id))
end
end)
table.sort(mailList, function(a, b)
return tonum(a.id) < tonum(b.id)
end)
for _, email in ipairs(mailList) do
local gid = redisproxy:hincrby("autoincrement_set", "email", 1)
if email.mid then
redisproxy:hmset(string_format("globalEmail:%s", gid),
"id", gid,
"createtime", email.endTime,
"title", email.title,
|
eb4b0152
 zhouhaihai
邮件增加 stitle
|
66
|
"stitle", email.stitle,
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
67
68
69
70
71
72
73
74
75
76
|
"content", email.content,
"attachments", email.attachments,
"endtime", email.endTime,
"mid", email.mid,
"timestamp", email.startTime
)
else
redisproxy:hmset(string_format("globalEmail:%s", gid),
"id", gid,
"createtime", email.endTime,
|
|
eb4b0152
zhouhaihai
邮件增加 stitle
|
77
|
"stitle", email.stitle,
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
"content", email.content,
"attachments", email.attachments,
"endtime", email.endTime,
"timestamp", email.startTime
)
end
end
redisproxy:hset("autoincrement_set", "emailTimestamp", now)
end
-- @desc: 定时邮件队列检测
local function check_mail_queue()
pcall(mailQuene)
skynet.timeout(CHECK_MAIL_STATUS_INTERVAL, check_mail_queue)
end
|
|
c384626d
zhouhaihai
好友
|
94
95
|
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
96
|
local CMD = {}
|
|
c384626d
zhouhaihai
好友
|
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
local cacheWorldMsg = {}
local CACHE_WORLD_MSG_COUNT = 50
function CMD.sendWorldMsg(channel, msg)
cacheWorldMsg[channel] = cacheWorldMsg[channel] or {}
table.insert(cacheWorldMsg[channel], msg)
for i = #cacheWorldMsg[channel] - CACHE_WORLD_MSG_COUNT, 1, -1 do
table.remove(cacheWorldMsg[channel], i)
end
end
function CMD.getWorldMsg(channel)
local msgs = cacheWorldMsg[channel] or {}
return msgs
end
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
114
115
116
117
118
119
|
function CMD.start()
check_mail_queue()
end
local function __init__()
skynet.dispatch("lua", function(_, _, command, ...)
|
|
c384626d
zhouhaihai
好友
|
120
121
122
123
124
125
126
127
|
local f = CMD[command]
if f then
if command == "sendWorldMsg" then
skynet.ignoreret()
f(...)
else
skynet.ret(skynet.pack(f(...)))
end
|
|
314bc5df
zhengshouren
提交服务器初始代码
|
128
129
130
131
132
133
134
|
end
end)
redisd = harbor.queryname("REDIS")
skynet.register("GLOBALD")
end
skynet.start(__init__)
|