local _M = {}


--[=[使用python 调用的话eg：

	import requests

	@params 指处理方法中的 query
	@data 指处理方法中的 body
	@return 'success' 成功

	status = requests.post("http://127.0.0.1:8001/clearcache", params = {"key": "zhaolu1234dangge"}, data = "", timeout = 300).text

	if status != 'success' :
		print("错误")
]=]


--[=[
	解码后
	body = {
		"src/csvdata/init.lua",
		"unitCsv",
		"story_cgCsv",
	}
]=]
function _M.hotfix_csvdata(query, body)
	if not body or body == "" then
		return 'no body'
	end

	local ok, result = pcall(json.decode, body)
	if not ok or type(result) ~= 'table' then
		return "decode error"
	end

	csvdb.hotfix(table.unpack(result))

	return 'success'
end

-- 热更新代码  -- 针对 agent 执行发送过来的代码 -- 代码要规范~ 

--[=[ eg:
1. *Action 
	body = """
		_hotfixActions = _hotfixActions or {}
		_hotfixActions["Gm.clientRequest"] = function(agent, data)
			bin = MsgPack.pack({ cmd = "testtest" })
			SendPacket(actionCodes.Gm_receiveResponse, bin)
		end
	"""

2. 修改 global 方法 和 变量 直接覆盖
	body = """
		function a()
			print(123)
		end

		globalCsv["asdasd"] = 12

		HEHE = 123
	"""

3. 修改 class 类 方法
	1. 修改role的方法
	body = """
		local role = ...
		_hotfixClass = _hotfixClass or {}
		_hotfixClass["Role"] = _hotfixClass["Role"] or {}
		local hotfixFunc = function(hotfixclass)
			function hotfixclass:getItemCount(itemId)
				return self:getProperty("id") .. "__" .. self:getProperty("uid") .. "__" .. itemId
			end
		end
		table.insert(_hotfixClass["Role"], hotfixFunc)
		if role then
			hotfixFunc(role)
		end
	"""
	2. 修改hero的方法
	body = """
		local role = ...
		_hotfixClass = _hotfixClass or {}
		_hotfixClass["Hero"] = _hotfixClass["Hero"] or {}
		local hotfixFunc = function(hotfixclass)
			function hotfixclass:getBattleValue()
				return self:getProperty("id") + "98700000000"
			end
		end
		table.insert(_hotfixClass["Hero"], hotfixFunc)
		if role and role.heros then
			for _, hero in pairs(role.heros) do
				hotfixFunc(hero)
			end
		end
	"""

	3. 其他的类仿照上面的写法
]=]

function _M.hotfix_code(query, body)
	if not body or body == "" then
		return "no body"
	end
	local ok = pcall(load, body)
	if not ok then 
		return "code error"
	end

	skynet.error(string.format("hotfix_code time: %s, code: %s", skynet.timex(), body))
	
	pcall(skynet.call, '.watchdog', "lua", "hotfix", body)
	return 'success'
end

local function proc_online(cmd, roleId, pms)
	local agent = datacenter.get("agent", roleId)
	if agent then
		local ok, result = pcall(skynet.call, agent.serv, "lua", cmd, pms)
		return ok and result or "指令在线失败"
	end
	return "not_online"
end

function _M.gm_action(query)
	local gmFuncs = require "actions.GmAction"
	if not query.cmd or not query.id or not gmFuncs[query.cmd] then return "指令不存在" end
	-- 在线操作
	query.id = tonumber(query.id)
	local isOn = proc_online(query.cmd, query.id, query)
	if isOn ~= "not_online" then
		return isOn
	end
	-- 离线操作
	local role = require("models.Role").new({key = string.format("%d", query.id)})
	local ret = role:load()
	if not ret then
		return "角色不存在"
	end
	role:loadAll()
	role:startActionUcode()
	local status = gmFuncs[query.cmd](role, query)
	role:endActionUcode()
    role:saveRoleData()
	
	return status
end

function _M.pay_action(query)
	local gmFuncs = require "actions.GmAction"
	if not query.cmd or not query.order or not gmFuncs[query.cmd] then return "指令不存在" end
	local mysqlproxy = require "shared.mysqlproxy"
	local res = mysqlproxy:query(string.format("SELECT roleid FROM `Order` WHERE `id` = %s", query.order))
	if res[1] then 
		query.id = res[1]["roleid"]
	else
		return "订单非法"
	end
	-- 在线操作
	query.id = tonumber(query.id)
	local isOn = proc_online(query.cmd, query.id, query)
	if isOn ~= "not_online" then
		return isOn
	end
	-- 离线操作
	local role = require("models.Role").new({key = string.format("%d", query.id)})
	local ret = role:load()
	if not ret then
		return "角色不存在"
	end
	role:loadAll()
	role:startActionUcode()
	local status = gmFuncs[query.cmd](role, query)
	role:endActionUcode()
    role:saveRoleData()
	
	return status
end

function _M.query_role(query)
	if not query.uid then return "not found" end
	local user = redisproxy:get(string.format("uid:%s", query.uid))
	if not user then return "not found" end
	local roleId = redisproxy:get(string.format("user:%s", string.upper(user)))
	if not roleId then return "not found" end
	return json.encode({roleId, user})
end

function _M.broadcast(query)
	local msg = {}
	local handle = {
		["common"] = {
			code = actionCodes.Sys_commonNotice,
			exec = function()
				msg["body"] = query.content
			end
		},
		["maintain"] = {
			code = actionCodes.Sys_maintainNotice,
			exec = function()
				msg["body"] = query.content
			end
		},
		["custom"] = {
			code = actionCodes.Sys_customNotice,
			exec = function()
				msg["title"] = query.title
				msg["body"] = query.content
				msg["logout"] = query.logout
			end
		},
		["game"] = {
			code = actionCodes.Sys_gameNotice,
			exec = function()
				msg["new"] = query.status
				msg["channels"] = query.channels
			end
		},
	}
	if not handle[query.cmd] then return "错误" end
	handle[query.cmd].exec()
	mcast_util.pub_world(handle[query.cmd].code, MsgPack.pack(msg))
	return "广播成功"
end

function _M.endless_season_check()
	mcast_util.pub_world(actionCodes.Sys_endlessSeason, "")
	return "success"
end

function _M.online(query)
	local count = datacenter.get("onlineCount") or 0
	return count
end

function _M.dbqlen(query)
	return skynet.call(redisd, "debug", "INFO")
end

function _M.account_init(query, body)
	if not query.id  or not body or body == "" then return "指令不存在" end

	local ok, result = pcall(json.decode, body)
	if not ok or type(result) ~= 'table' then
		return "decode body error"
	end
	query.id = tonumber(query.id)
	local agent = datacenter.get("agent", query.id)
	if agent and agent.serv then
		-- local ok, result = pcall(skynet.call, agent.serv, "role", "accountInit", result)
		-- return ok and result or "指令在线失败"
		skynet.call(agent.serv, "role", "accountInit", result)
		return "成功"
	else
		return "角色不在线"
	end
end

return _M