From 7ed2d5c8966a03ba396c081d5702cb38daa6cfee Mon Sep 17 00:00:00 2001 From: duhui Date: Tue, 10 May 2022 18:37:06 +0800 Subject: [PATCH] =?UTF-8?q?1.=E6=B7=BB=E5=8A=A0=E9=87=8D=E8=BD=BD=E5=BC=80?= =?UTF-8?q?=E6=9C=8D=E6=97=B6=E9=97=B4gm=E5=91=BD=E4=BB=A4=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=202.=E8=81=8A=E5=A4=A9=E4=BF=A1=E6=81=AF=E5=AE=8C?= =?UTF-8?q?=E5=96=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/ljsd/GameApplication.java | 16 +++++++++--- .../ljsd/jieling/chat/ChatRedisEntity.java | 13 +++++++++- .../ljsd/jieling/chat/logic/ChatLogic.java | 4 +-- .../jieling/kefu/Cmd_reloadserverconfig.java | 25 +++++++++++++++++++ 4 files changed, 52 insertions(+), 6 deletions(-) create mode 100644 serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_reloadserverconfig.java diff --git a/serverlogic/src/main/java/com/ljsd/GameApplication.java b/serverlogic/src/main/java/com/ljsd/GameApplication.java index 350f93b8f..62a00b825 100644 --- a/serverlogic/src/main/java/com/ljsd/GameApplication.java +++ b/serverlogic/src/main/java/com/ljsd/GameApplication.java @@ -11,6 +11,7 @@ import com.ljsd.jieling.logic.dao.ServerConfig; import com.ljsd.jieling.logic.rank.CrossRankManager; import com.ljsd.jieling.network.NetManager; import com.ljsd.jieling.util.ConfigurableApplicationContextManager; +import com.ljsd.jieling.util.TaskKit; import config.SGameSetting; import manager.STableManager; import org.slf4j.Logger; @@ -23,6 +24,7 @@ import util.TimeUtils; import java.io.File; import java.util.Scanner; +import java.util.concurrent.TimeUnit; @Configuration @@ -81,7 +83,7 @@ public class GameApplication { } } - private static void setRegisterTime() throws Exception { + public static void setRegisterTime() throws Exception { ServerConfig serverConfigTmp = MongoUtil.getInstence().getMyMongoTemplate().findById(1, ServerConfig.class); if(serverConfigTmp == null){ serverConfigTmp = new ServerConfig(); @@ -112,15 +114,23 @@ public class GameApplication { serverConfigTmp.setRestartTime(TimeUtils.getTimeStamp2(TimeUtils.now())); MongoUtil.getInstence().getMyMongoTemplate().saveWithoutMongoRoot(serverConfigTmp); serverConfig = serverConfigTmp; + LOGGER.info("============================读取数据库serverConfig信息完成"); } + public static void test() { + try { + TaskKit.scheduleWithFixedDelay(()->{ + LOGGER.info("**************当前开服时间:{},缓存:{}",serverConfig.getOpenTime(),TimeUtils.getTimeStamp2(serverConfig.getCacheOpenTime())); + },30,5, TimeUnit.SECONDS); + }catch (Exception e){ + LOGGER.error(e.getMessage()); + } + } public static void close() throws Exception{ start = false; NetManager.getInstance().exit(); ConfigurableApplicationContextManager.getInstance().exit(); - - } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/chat/ChatRedisEntity.java b/serverlogic/src/main/java/com/ljsd/jieling/chat/ChatRedisEntity.java index 1a7e4256e..25ae0ceed 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/chat/ChatRedisEntity.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/chat/ChatRedisEntity.java @@ -19,15 +19,18 @@ public class ChatRedisEntity { private int status; + private String openId; + public ChatRedisEntity(){}; - public ChatRedisEntity(int uid, String name, int type, String message, Long time, int status) { + public ChatRedisEntity(int uid, String name, int type, String message, Long time, int status, String openId) { this.uid = uid; this.name = name; this.type = type; this.message = message; this.time = time; this.status = status; + this.openId = openId; } public int getUid() { @@ -77,4 +80,12 @@ public class ChatRedisEntity { public void setStatus(int status) { this.status = status; } + + public String getOpenId() { + return openId; + } + + public void setOpenId(String openId) { + this.openId = openId; + } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java index 54d5f5744..acf736a31 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/chat/logic/ChatLogic.java @@ -92,7 +92,7 @@ public class ChatLogic { } break; - case 4: + case 4: //跨服 int group = GlobleSystemLogic.getInstence().getCrossGroup(); if(group==-1){ MessageUtil.sendMessage(iSession, 1, MessageTypeProto.MessageType.GET_CHAT_MESSAGE_REPONSE_VALUE, null, true); @@ -263,7 +263,7 @@ public class ChatLogic { if(user.getPlayerInfoManager().getSilence() == 1 || user.getPlayerInfoManager().getSkyEyeBanTime()>System.currentTimeMillis()){ silence = 1; } - ChatRedisEntity chatRedisEntity = new ChatRedisEntity(user.getId(), user.getPlayerInfoManager().getNickName(), chatType, message, TimeUtils.now(), silence); + ChatRedisEntity chatRedisEntity = new ChatRedisEntity(user.getId(), user.getPlayerInfoManager().getNickName(), chatType, message, TimeUtils.now(), silence, user.getPlayerInfoManager().getOpenId()); String chatInfo = gson.toJson(chatRedisEntity); long l = redisUtil.lGetListSize(key); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_reloadserverconfig.java b/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_reloadserverconfig.java new file mode 100644 index 000000000..1a91b2aa6 --- /dev/null +++ b/serverlogic/src/main/java/com/ljsd/jieling/kefu/Cmd_reloadserverconfig.java @@ -0,0 +1,25 @@ +package com.ljsd.jieling.kefu; + +import com.ljsd.GameApplication; +import com.ljsd.jieling.db.mongo.MongoUtil; +import com.ljsd.jieling.logic.dao.GuilidManager; +import com.ljsd.jieling.logic.dao.PlayerManager; +import com.ljsd.jieling.logic.dao.root.GuildInfo; +import com.ljsd.jieling.logic.dao.root.User; +import com.ljsd.jieling.logic.family.CrossDeathPathLogic; +import config.SGuildSetting; +import util.TimeUtils; + +public class Cmd_reloadserverconfig extends GmAbstract { + + @Override + public boolean exec(String[] args) throws Exception { + return false; + } + + @Override + public String exec2(String[] args) throws Exception { + GameApplication.setRegisterTime(); + return "true"; + } +}