local skynet = require "skynet"
  local sharedata = require "skynet.sharedata"
  local codecache = require "skynet.codecache"  -- 清空缓存用
  
  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("错误")
  ]=]
  
  

  -- 清空缓存

  function _M.clearcache(query, body)
  	skynet.error(string.format("clearcache time: %s", skynet.timex()))
  	codecache.clear()
  	return 'success'
  end
  

  --重新加载 需要修改的csvdb  -- 单字段修改 优先使用hotfix_csvdata

  --[=[ eg:
  	body = """
  		csvdb["itemCsv"][1]["name"] = "测试一下"
  	"""
  ]=]
  

  function _M.reload_csvdata(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

  	local ok, status = pcall(skynet.call, 'CSVDATA', "lua", "reload", body)

  	if status == "ok" then	

  		skynet.error(string.format("reload_csvdata time: %s, code: %s", skynet.timex(), body))

  		return 'success'

  	else
  		return 'error update'

  	end

  end
  

  --指定更新某个字段值
  --[=[
  	解码后
  	body = {
  		{"itemCsv", 1, "name", "测试一下"},
  		{"itemCsv", 2, "name", "测试一下"}
  	}
  ]=]
  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
  	local ok, status = pcall(skynet.call, 'CSVDATA', "lua", "hotfix", result)
  
  	if status == "ok" then	
  		skynet.error(string.format("hotfix_csvdata time: %s, code: %s", skynet.timex(), body))
  		return 'success'
  	else
  		return 'error update'
  	end
  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
  
  
  
  
  return _M