make
/
b23_src


			
				
					
						
						
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134
							local skynet = require "skynet"
require "skynet.manager"
local logger = require "logger"
local queue = require "skynet.queue"
local md5 = require "md5"
local synchronized = queue()
local cjson = require "cjson"
local asset = require "model.asset"
local common_fun = require "model.common_fun"

local mailbox

local table_insert = table.insert

local authz = {acc = "yytx", pwd = "lee@YY-Games.520"}
-- Generate request data
local content = {acc = authz.acc, pwd = authz.pwd, sign = false}
content.sign = string.sub(md5.sumhexa(content.acc .. content.pwd), 9, 24)

local function create_html_page(text)
    return string.format(
        "<!DOCTYPE html><html><head><meta charset='UTF-8'></head> <body>%s</body> </html>",
        string.gsub(text, "[\n]", "<br/>"))
end

local whitelist = {
    -- ["192.168.1.23"] = true,
}

local function func(args, ipaddr, header)
    logger.trace("处理来自主机 %s 的发送邮件请求", ipaddr)
    -- 验证主机id
    -- if not whitelist[ipaddr] then
    --     return cjson.encode({errno = 403, host = header.host, info = "不信任ip"})
    -- end
    -- 验证gm账号
    -- local code = string.sub(args.code, 1, 16)
    -- if code ~= content.sign then
    --     return cjson.encode({state = 403, msg = "账号或密码错误"})
    -- end

    local mtype = tonumber(args.ntype)
    local json = cjson.decode(args.json)
    local attach = json.attach or {}

    local detail = json.attach or {}
    local errno = 0
    local info = "成功"

    ----------------------------- THIS ----------------------------------
    -- if attach ~= nil then
    --     for i=1, #attach, 2 do
    --         local id = attach[i]
    --         local num = attach[i+1]
    --         if not id or not num or num <= 0 then
    --             errno = 1
    --             info = "格式错误"
    --             break
    --         end
            
    --         errno = common_fun.goods_check(id)
    --         if errno == 0 then
    --             table_insert(detail, {id = id, num = num})
    --         else
    --             info = "错误的道具id:"..id
    --             break
    --         end
    --     end
    -- else
    --     detail = {}
    -- end

    -- if errno ~= 0 then
    --     return cjson.encode({state = errno, msg = info})
    -- end

    for _, v in ipairs(detail) do
        if not v.id or not v.num or v.num <= 0 then
            errno = 1
            info = "格式错误"
            break
        end
        local goods_type = common_fun.goods_type(v.id)
        if goods_type== GOODS_NONE then
            errno = 1
            info = "错误的道具id"
        end
    end

    if errno ~= 0 then
        return cjson.encode({state = errno, msg = info})
    end

    local body = json.content
    local source = {
        module = "sendmail",
        brief = "GM发送的邮件",
        context = string.format("GM ip: %s  tm = %s",
                                ipaddr, os.time())
    }
    local receiver
    mailbox = mailbox or skynet.localname(".mailbox")
    local subject = tonumber(json.title)

    if type(subject) ~= 'number' then
        return cjson.encode({state = 400, msg = "错误的title"})
    end
    for k, v in pairs(detail) do
        logger.trace("=======k=%s--v=%s----", v.id, v.num)
    end
    if mtype == 2 then -- 全服邮件
        skynet.call(mailbox, "lua", "broadcast", subject, body, detail,
                    source)
    elseif mtype == 1 then -- 给特定玩家
        receiver = json.roles
        skynet.call(mailbox, "lua", "off_line_mail", receiver, subject,
                    body, detail, source)
    else
        return cjson.encode({state = 400, msg = "ntype不存在"})
    end

    return cjson.encode({state = 0, msg = "success"})
end

-- http://192.168.108.4:9002/mail?code=xxxx&ntype=3&json={"roles":["00-6527363693544497152","00-6527368552515657728"],"attach":[100041, 100, 100037, 100],"title":"这是标题","content":"这是正文"}
local mail = function(args, ipaddr, header)
    return synchronized(function()
        -- return create_html_page(func(args, ipaddr, header))
        return func(args, ipaddr, header)
    end)
end

return mail