carm/cn2b2t-project
carm/cn2b2t-project
1
Fork 0
mirror of https://github.com/CarmJos/cn2b2t-project.git synced 2024-09-19 13:55:45 +00:00
Code Releases Activity

移除服务器自动添加

Browse Source
This commit is contained in:
carm 2020-06-11 22:14:18 +08:00
parent bd36204847
commit fdc35c4dbc
2 changed files with 0 additions and 120 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
2b2t-core/src/main/java/org.cn2b2t.core/modules/DataServerInfo.java
View File

@ -1,61 +0,0 @@
package org.cn2b2t.core.modules;
public class DataServerInfo {
private String serverID;
private String hostName;
private int port;
private String serverGroup;
private int players;
public DataServerInfo(String serverID, String hostName, int port, String serverGroup, int players) {
this.serverGroup = serverGroup;
this.serverID = serverID;
this.hostName = hostName;
this.port = port;
this.players = players;
}
public int getPlayers() {
return players;
}
public void setPlayers(int players) {
this.players = players;
}
public String getServerID() {
return serverID;
}
public void setServerID(String serverID) {
this.serverID = serverID;
}
public String getServerGroup() {
return serverGroup;
}
public void setServerGroup(String serverGroup) {
this.serverGroup = serverGroup;
}
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
public String getHostName() {
return hostName;
}
public void setHostName(String hostName) {
this.hostName = hostName;
}
}

59
2b2t-core/src/main/java/org.cn2b2t.core/modules/LocalServerInfo.java
View File

@ -1,59 +0,0 @@
package org.cn2b2t.core.modules;
import org.bukkit.Bukkit;
import org.cn2b2t.core.managers.utils.DataManager;
import org.cn2b2t.core.managers.utils.ServersManager;
public class LocalServerInfo extends DataServerInfo {
public LocalServerInfo(String serverID, String hostName, int port, String serverGroup) {
super(serverID, hostName, port, serverGroup, Bukkit.getOnlinePlayers().size());
}
@Override
public int getPlayers() {
return Bukkit.getOnlinePlayers().size();
}
public void register() {
writeInfo();
if (!this.getServerGroup().equalsIgnoreCase("SYSTEM")) {
sendRegisterRequest();
}
}
public void unregister() {
deleteInfo();
if (!this.getServerGroup().equalsIgnoreCase("SYSTEM")) {
sendUnregisterRequest();
}
}
public void writeInfo() {
DataManager.getConnection().update(ServersManager.databaseTable,
new String[]{"servergroup", "hostname", "port", "players"},
new Object[]{LocalServerInfo.this.getServerGroup(), LocalServerInfo.this.getHostName(), LocalServerInfo.this.getPort(), getPlayers()},
new String[]{"serverid"}, new Object[]{LocalServerInfo.this.getServerID()});
}
public void deleteInfo() {
DataManager.getConnection().delete(ServersManager.databaseTable, "serverid", LocalServerInfo.this.getServerID());
}
public void sendRegisterRequest() {
DataManager.getTempConnection().insert("messager_" + ServersManager.messageChannel,
new String[]{"start", "lasttime", "sign", "message"},
new Object[]{System.currentTimeMillis(), 1500, ServersManager.messageChannel, ServersManager.Operation.ADD.name() + ":" + LocalServerInfo.this.getServerID()});
}
public void sendUnregisterRequest() {
DataManager.getTempConnection().insert("messager_" + ServersManager.messageChannel,
new String[]{"start", "lasttime", "sign", "message"},
new Object[]{System.currentTimeMillis(), 1500, ServersManager.messageChannel, ServersManager.Operation.REMOVE.name() + ":" + LocalServerInfo.this.getServerID()});
}
}