feat: 增加 role_by_uid http接口和查询所有服的角色信息的协议

zhangqijia
1 parent 7356e583
Showing 4 changed files with 56 additions and 0 deletions Show diff stats
src/ProtocolCode.lua
src/actions/HttpAction.lua
src/actions/RoleAction.lua
src/utils/MysqlUtil.lua
@@ -66,6 +66,7 @@ actionCodes = {
 	Role_worldLineRewardRpc = 147, -- 世界线一键领取奖励
 	Role_itemConvertDevilTicketRpc = 148, -- 兑换魔鬼训练营门票
 	Role_unRegisterRpc = 149, --注销账号
+	Role_searchAllRoleRpc = 150, --查询所有服的角色信息
  
 	Adv_startAdvRpc = 151,
 	Adv_startHangRpc = 152,
+require "utils.MysqlUtil"
  
 local _M = {}
  
@@ -264,4 +265,20 @@ function _M.hero_draw_pro(query)
 	return gmFuncs[query.cmd]()
 end
  
+function _M.role_by_uid(query)
+    local res = roleByUid(query.uid)
+	local rsp = {}
+    rsp.code = 0
+	if not res then
+		rsp.code = -1
+        return json.encode(rsp)
+	end
+
+	rsp.id = res["id"]
+	rsp.name = res["name"]
+	rsp.level = res["level"]
+	rsp.code = 0
+    return json.encode(rsp)
+end
+
 return _M
 \ No newline at end of file
@@ -520,6 +520,36 @@ function _M.unRegisterRpc(agent, data)
 	return true
 end
  
+function _M.searchAllRoleRpc(agent, data)
+	local role = agent.role
+	local uid = role:getProperty("uid")
+    if not uid then return 0 end
+
+	local res = roleByUid(uid)
+	if not res then return 1 end
+
+
+	local serverId = skynet.getenv("servId")
+	local codeurl = skynet.getenv("codeurl")
+	local content = {
+		serverid = serverId,
+		uid = uid,
+	}
+
+	local status, body = httpc.get(codeurl, "/search_role?" .. httpGetFormatData(content), {})
+	if status ~= 200 then return 2 end
+
+	local result = json.decode(body)
+	local ret = tonum(result.code)
+	if ret ~= 0 then return 3 end
+
+	local rsp = result.data
+	table.insert(rsp, {serverId=serverId, name=res.name, level=res.level} )
+	SendPacket(actionCodes.Role_unRegisterRpc, MsgPack.pack(rsp))
+	return true
+end
+
+
 function _M.changeNameRpc(agent, data)
 	local role = agent.role
 	local roleId = role:getProperty("id")
@@ -74,4 +74,12 @@ function roleUnRegister(roleId)
         return false
     end
     return true
+end
+
+function roleByUid(uid)
+    local res = mysqlproxy:query(string.format("SELECT id, name, level, FROM `Role` WHERE `del` = 0 and `uid` = %s", uid))
+    if res["errno"] or not next(res) then
+        return false
+    end
+    return true, res[1]
 end
 \ No newline at end of file