miduo_server/serverlogic/src/main/java/com/ljsd/GameApplication.java

126 lines
5.0 KiB
Java

package com.ljsd;
import com.google.gson.Gson;
import com.ljsd.common.mogodb.util.MongoKeys;
import com.ljsd.jieling.config.json.CoreSettings;
import com.ljsd.jieling.config.json.ServerConfiguration;
import com.ljsd.jieling.config.json.ServerProperties;
import com.ljsd.jieling.core.CoreLogic;
import com.ljsd.jieling.db.mongo.MongoUtil;
import com.ljsd.jieling.db.redis.RedisKey;
import com.ljsd.jieling.db.redis.RedisUtil;
import com.ljsd.jieling.network.NetManager;
import com.ljsd.jieling.util.ConfigurableApplicationContextManager;
import util.TimeUtils;
import com.ljsd.jieling.logic.dao.ServerConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Scanner;
@Configuration
@EnableAutoConfiguration
@ComponentScan
@EnableScheduling
public class GameApplication {
private static final Logger LOGGER = LoggerFactory.getLogger(GameApplication.class);
public static ServerProperties serverProperties;
public static int serverId = 0;
public static int areaId = 0;
public static boolean start = false;
public static ServerConfig serverConfig;
public static void main(String[] args) throws Exception {
start = true;
ConfigurableApplicationContextManager.init(args);
//init servercfg
ServerConfiguration serverConfiguration = ConfigurableApplicationContextManager.getBean(ServerConfiguration.class);
serverProperties = serverConfiguration.getServerProperties();
serverId = serverProperties.getId();
CoreSettings coreSettings = ConfigurableApplicationContextManager.getBean(CoreSettings.class);
GameApplication.areaId = coreSettings.getArea();
LOGGER.info("ServerProperties ->{},coreIp=>{}", serverProperties.toString());
GameLogicService.getInstance().init();
//设置开服时间
setRegisterTime();// might loop
GameLogicService.getInstance().onStart();
NetManager.getInstance().init();
//控制台gm
Scanner sc = new Scanner(System.in);
while(sc.hasNext())
{
try {
String cmd = sc.nextLine();
if(cmd.startsWith("//"))
{
System.out.println("gmgmgm:" + cmd.substring(2));
String cmd2 = cmd.substring(2);
GmService.exeCmd(cmd2);
}
}catch (Exception e){
System.out.print("gmException"+e);
}
}
}
private static void setRegisterTime() throws Exception {
ServerConfig serverConfigTmp = MongoUtil.getInstence().getMyMongoTemplate().findById(1, ServerConfig.class);
if( null == serverConfigTmp ){
serverConfigTmp = new ServerConfig();
if (GameApplication.serverProperties.isAutoOpen()) {
int startbefore = 60; //开服白名单时间
long needtime = TimeUtils.DifferMintFromLast(RedisUtil.getInstence().getObject(GameApplication.serverId + RedisKey.Delimiter_colon + RedisKey.AUTOOPENTIME ,"",String.class,-1));
while (needtime - startbefore > 0) {
long sleepTime = needtime - startbefore;
try {
LOGGER.error("预计" + sleepTime + "分钟后开服");
Thread.sleep(1000 * 60);
} catch (Exception e) {
LOGGER.error("休眠异常", e.getMessage(), e);
}
needtime = TimeUtils.DifferMintFromLast(RedisUtil.getInstence().getObject(GameApplication.serverId + RedisKey.Delimiter_colon + RedisKey.AUTOOPENTIME ,"",String.class,-1));
}
}
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
long serverOenTime = TimeUtils.getAppointTime(0);
String format = simpleDateFormat.format(serverOenTime);
serverConfigTmp.setOpenTime(format);
serverConfigTmp.setCacheOpenTime(serverOenTime);
serverConfigTmp.setId(1);
serverConfigTmp.setWorldLevel(1);
MongoUtil.getInstence().getMyMongoTemplate().saveWithoutMongoRoot(serverConfigTmp);
}else{
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String openTime = serverConfigTmp.getOpenTime();
Date date = simpleDateFormat.parse(openTime);
serverConfigTmp.setCacheOpenTime(date.getTime());
}
serverConfig = serverConfigTmp;
}
public static void close() throws Exception{
start = false;
NetManager.getInstance().exit();
ConfigurableApplicationContextManager.getInstance().exit();
}
}