local skynet = require "skynet"
require "utils.init"

local mysqld_count = tonumber(skynet.getenv("thread"))
local mysqld
skynet.init(function()
	local idx = math.randomInt(1, mysqld_count)
    mysqld = skynet.localname(".mysql" .. idx)

end)

local table_insert = table.insert

local mysqlproxy = {}


setmetatable(mysqlproxy, { __index = function(t, k)
	local cmd = string.upper(k)
    local f = function (self, ...)
        if k == "query" then
			--print(...)
        end
		local ok, result = pcall(skynet.call, mysqld, "lua", cmd, ...)
		if not ok then
			skynet.error(cmd, ..., "\n", debug.traceback(coroutine.running(), nil))
			return
		end
		return result
	end
	t[k] = f
	return f
end})

function mysqlproxy:insertEmail(params)
	local pms = {
		key = string.format("%s", 0),
		roleId = params.roleId,
		emailId = params.emailId,
		createtime = params.createtime or skynet.timex(),
		contentPms = params.contentPms or {},
		rewardPms = params.rewardPms or {},
		title = params.title or "",
		stitle = params.stitle or "",
		content = params.content or "",
		attachments = params.attachments or "",
	}

	local email = require("models.Email").new(pms)
	email:create()
	return true
end

return mysqlproxy