diff --git a/src/main/java/com/jmfy/handler/GMHandler.java b/src/main/java/com/jmfy/handler/GMHandler.java index 50475b3..2f7849a 100644 --- a/src/main/java/com/jmfy/handler/GMHandler.java +++ b/src/main/java/com/jmfy/handler/GMHandler.java @@ -144,15 +144,7 @@ public class GMHandler extends BaseHandler { * @throws Exception */ private boolean oneUserBanner(CUserInfo coreUserInfo, int serverId, JSONObject json, int type, HttpSession session) throws Exception { - ServerInfo coreServerList = serverListDao.getServerInfo(String.valueOf(coreUserInfo.getServerid())); - if (null == coreServerList) { - LOGGER.error("服务器列表为空,serverId:{}", coreUserInfo.getServerid()); - return false; - } - if (!coreServerList.getServer_id().equals(String.valueOf(serverId))) { - LOGGER.error("db库里面的服务器id与传参不一致, dbServerId:{},valueServerId:{}", coreServerList.getServer_id(),serverId); - return false; - } + int hefuServerId = HeFuManager.getHefuServerId(serverId); // 获取拼接参数 String cmd = getCmd(json, coreUserInfo, type); if ("".equals(cmd) || cmd == null){ @@ -160,7 +152,7 @@ public class GMHandler extends BaseHandler { return false; } - String rpcString = RedisUtil.getInstence().getObject(RedisUserKey.LOGIC_SERVER_INFO, String.valueOf(coreServerList.getServer_id()), String.class, -1); + String rpcString = RedisUtil.getInstence().getObject(RedisUserKey.LOGIC_SERVER_INFO, String.valueOf(hefuServerId), String.class, -1); if (null == rpcString) { LOGGER.error("获取rpc参数报错:serverId:{}", coreUserInfo.getServerid()); return false;