自动开服添加验证

duhui 2021-08-27 14:24:00 +08:00
parent 3b249bc281
commit 5e844807d5
1 changed files with 16 additions and 4 deletions

View File

@ -2,6 +2,7 @@ package com.jmfy.utils;
import com.jmfy.dao.ServerInfoDao; import com.jmfy.dao.ServerInfoDao;
import com.jmfy.model.AutoServerSetting; import com.jmfy.model.AutoServerSetting;
import com.jmfy.model.CServerOpenTime;
import com.jmfy.model.ServerInfo; import com.jmfy.model.ServerInfo;
import com.jmfy.model.vo.ServerStatusEnum; import com.jmfy.model.vo.ServerStatusEnum;
import com.jmfy.redisProperties.RedisUserKey; import com.jmfy.redisProperties.RedisUserKey;
@ -109,14 +110,25 @@ public class AutoServerManager {
* @throws Exception * @throws Exception
*/ */
private void startServers(ServerInfo newServer) throws Exception { private void startServers(ServerInfo newServer) throws Exception {
// 新服务器状态更新 // 脚本,重启服务器
updateServer(newServer,ServerStatusEnum.FLUENT.getId(),1,newServer.getServer_id()); AutoServerManager.getInstance().delUser(newServer);
// 验证新服状态
CServerOpenTime cServerOpenTime = serverInfoDao.getOpenServerTime(newServer.getServer_id());
if (null == cServerOpenTime) {
LOGGER.error("新服自动开服失败1================={}",newServer.toString());
return;
}
if (cServerOpenTime.getOpenTime() == null || "".equals(cServerOpenTime.getOpenTime()) || cServerOpenTime.getVersion() <= 0){
LOGGER.error("新服自动开服失败2================={}",newServer.toString());
return;
}
// 旧服务器状态更新 // 旧服务器状态更新
String serverId = String.valueOf(Integer.valueOf(newServer.getServer_id())-1); String serverId = String.valueOf(Integer.valueOf(newServer.getServer_id())-1);
ServerInfo oldServer = serverInfoDao.getServerinfo(serverId); ServerInfo oldServer = serverInfoDao.getServerinfo(serverId);
updateServer(oldServer,ServerStatusEnum.CROWDING.getId(),0,serverId); updateServer(oldServer,ServerStatusEnum.CROWDING.getId(),0,serverId);
// 脚本 // 新服务器状态更新
AutoServerManager.getInstance().delUser(newServer); updateServer(newServer,ServerStatusEnum.FLUENT.getId(),1,newServer.getServer_id());
} }
/** /**