新增基岩版支持 一些指令变更

src/tax/cute/mcpingplugin/BETypeset.java

@@ -0,0 +1,64 @@
+package tax.cute.mcpingplugin;
+
+import tax.cute.minecraftserverpingbe.MCBePing;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.OutputStream;
+
+public class BETypeset {
+    private String motdText;
+
+    public BETypeset(String motdText) {
+        this.motdText = motdText;
+    }
+
+    public static BETypeset getTypeset(String host,int port,String typesetText) throws IOException{
+        final String description = "%description";
+        final String default_mode = "%default_mode";
+        final String version = "%version";
+        final String protocol_num = "%protocol_num";
+        final String type = "%type";
+        final String online_players = "%online_players";
+        final String max_players = "%max_players";
+        final String delay = "%delay";
+        final String world_name = "%world_name";
+
+        MCBePing motd = MCBePing.getMotd(host, port,2000);
+
+        String motdText = typesetText
+                .replace(description,String.valueOf(motd.getDescription()))
+                .replace(default_mode,String.valueOf(motd.getDefault_mode()))
+                .replace(version,String.valueOf(motd.getVersion()))
+                .replace(world_name,String.valueOf(motd.getWorld_name()))
+                .replace(protocol_num,String.valueOf(motd.getProtocol_num()))
+                .replace(type,motd.getType())
+                .replace(online_players,String.valueOf(motd.getOnline_players()))
+                .replace(max_players,String.valueOf(motd.getMax_players()))
+                .replace(delay,String.valueOf(motd.getDelay()));
+        return new BETypeset(motdText);
+    }
+
+    public String getMotdText() {
+        return this.motdText;
+    }
+
+    public static void createTypesetFile(String path) throws IOException{
+        File file = new File(path);
+        if(file.exists()) return;
+        String text =
+                "[ 描述 ] %description" +
+                        "\n[ 版本 ] %version(%protocol_num)" +
+                        "\n[ 人数 ] %online_players/%max_players" +
+                        "\n[ 延迟 ] %delayms" +
+                        "\n[ 类型 ] %type" +
+                        "\n[ 默认模式 ] %default_mode" +
+                        "\n[ 世界名称 ] %world_name"
+                ;
+        OutputStream out = new FileOutputStream(path);
+        out.write(text.getBytes());
+        out.flush();
+        out.close();
+    }
+}

src/tax/cute/mcpingplugin/Config.java

@@ -0,0 +1,271 @@
+package tax.cute.mcpingplugin;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import tax.cute.mcpingplugin.Util.Util;
+
+import java.io.*;
+
+public class Config {
+    private static final String name = "[MCPing]";
+
+    private String path;
+    private JSONArray owner;
+    private JSONArray bindServerList;
+    private String enable;
+    private String mcPingCmd;
+
+    public Config(
+            String path,
+            JSONArray owner,
+            JSONArray bindServerList,
+            String enable,
+            String mcPingCmd
+    ) {
+        this.path = path;
+        this.owner = owner;
+        this.bindServerList = bindServerList;
+        this.enable = enable;
+        this.mcPingCmd = mcPingCmd;
+    }
+
+    public static Config getConfig(String path) throws IOException {
+        File file = new File(path);
+        //Create a configuration file when it is judged that the configuration file does not exist
+        if (!file.exists()) if (!createConfig(path)) System.err.println(name + "Create config failure");
+
+        //initialization
+        JSONArray owner = new JSONArray();
+        String enable = "false";
+        String mcPingCmd = null;
+        JSONArray bindServer = new JSONArray();
+
+        //Read config file text
+        String jsonStr = Util.readText(path);
+        JSONObject json = JSONObject.parseObject(jsonStr);
+
+        //Determine whether the configuration file is json
+        if (json == null) {
+            createConfig(path);
+            jsonStr = Util.readText(path);
+            json = JSONObject.parseObject(jsonStr);
+        }
+
+        JSONObject config = new JSONObject();
+
+        //Determine whether it is json, if not, it will be reset
+        if (json.containsKey("Config")) {
+            if (json.get("Config") instanceof JSONObject) {
+                config = json.getJSONObject("Config");
+            }
+        }
+
+        if (config.containsKey("Enable")) {
+            if (config.get("Enable") instanceof String) {
+                if (Util.isBoolean(config.getString("Enable"))) {
+                    enable = config.getString("Enable");
+                } else {
+                    System.err.println(name + "\"Config\\Enable\"Unexpected type");
+                }
+            } else {
+                System.err.println(name + "\"Config\\Enable\"Unexpected type");
+            }
+        } else {
+            System.err.println(name + "\"Config\\Enable\"Missing");
+        }
+
+        if (config.containsKey("CMD")) {
+            if (config.get("CMD") instanceof String) {
+                mcPingCmd = config.getString("CMD");
+            } else {
+                System.err.println(name + "\"Config\\CMD\"Unexpected type");
+            }
+        } else {
+            System.err.println(name + "\"Config\\CMD\"Missing");
+        }
+
+        if (json.containsKey("Owner")) {
+            if (json.get("Owner") instanceof JSONArray) {
+                owner = json.getJSONArray("Owner");
+            } else {
+                System.err.println(name + "\"Owner\"Unexpected type");
+            }
+        } else {
+            System.err.println(name + "\"Owner\"Missing");
+        }
+
+        if (json.containsKey("BindServer")) {
+            if (json.get("BindServer") instanceof JSONArray) {
+                bindServer = json.getJSONArray("BindServer");
+            } else {
+                System.err.println(name + "\"BindServer\"Unexpected type");
+            }
+        } else {
+            System.err.println(name + "\"BindServer\"Missing");
+        }
+
+        return new Config(path, owner, bindServer, enable, mcPingCmd);
+    }
+
+    public static boolean createConfig(String path) {
+        try {
+            JSONObject json = new JSONObject();
+
+            JSONArray bindServer = new JSONArray();
+
+            JSONArray owner = new JSONArray();
+
+            JSONObject config = new JSONObject();
+            config.put("Enable", "true");
+            config.put("CMD", "/mcmotd");
+
+            json.put("Owner", owner);
+            json.put("BindServer", bindServer);
+            json.put("Config", config);
+
+            String jsonStr = JSON.toJSONString(json);
+
+            OutputStream out = new FileOutputStream(path);
+            out.write(jsonStr.getBytes());
+            out.flush();
+            out.close();
+        } catch (IOException e) {
+            File file = new File(path);
+            file.delete();
+            return false;
+        }
+        return true;
+    }
+
+    public void writeConfig() throws IOException {
+        JSONObject json = new JSONObject();
+        JSONObject config = new JSONObject();
+        config.put("Enable", this.enable);
+        config.put("CMD", this.mcPingCmd);
+
+        json.put("Owner", this.owner);
+        json.put("Config", config);
+        json.put("BindServer", this.bindServerList);
+
+        String jsonStr = JSON.toJSONString(json);
+
+        OutputStream out = new FileOutputStream(path);
+        out.write(jsonStr.getBytes());
+        out.flush();
+        out.close();
+    }
+
+    public boolean isEnable() {
+        return Boolean.parseBoolean(this.enable);
+    }
+
+    public String getPath() {
+        return this.path;
+    }
+
+    public String getMcPingCmd() {
+        return this.mcPingCmd;
+    }
+
+    public JSONArray getOwner() {
+        return this.owner;
+    }
+
+    public boolean isOwner(long qqNum) {
+        return this.owner.contains(String.valueOf(qqNum));
+    }
+
+    public JSONArray getBindServerList() {
+        return this.bindServerList;
+    }
+
+    public void setEnable(boolean args) throws IOException {
+        this.enable = String.valueOf(args);
+        writeConfig();
+    }
+
+    public void setMcPingCmd(String args) throws IOException {
+        this.mcPingCmd = args;
+        writeConfig();
+    }
+
+    public boolean addOwner(long qqNum) throws IOException {
+        if (isOwner(qqNum)) return false;
+        this.owner.add(String.valueOf(qqNum));
+        writeConfig();
+        return true;
+    }
+
+    public boolean removeOwner(long qqNum) throws IOException {
+        if (!isOwner(qqNum)) return false;
+        this.owner.remove(String.valueOf(qqNum));
+        writeConfig();
+        return true;
+    }
+
+    public JSONObject getServer(long groupNum) {
+        for (int i = 0; i < this.bindServerList.size(); i++) {
+            if (this.bindServerList.get(i) instanceof JSONObject) {
+                JSONObject server = this.bindServerList.getJSONObject(i);
+                if (server.containsKey("GroupNum")) {
+                    if (server.get("GroupNum") instanceof String) {
+                        if (Util.isNum(server.getString("GroupNum"))) {
+                            if (server.getString("GroupNum").equals(String.valueOf(groupNum))) {
+                                return this.bindServerList.getJSONObject(i);
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        return null;
+    }
+
+    public int getServerIndex(long groupNum) {
+        for (int i = 0; i < this.bindServerList.size(); i++) {
+            if (this.bindServerList.get(i) instanceof JSONObject) {
+                JSONObject server = this.bindServerList.getJSONObject(i);
+                if (server.containsKey("GroupNum")) {
+                    if (server.get("GroupNum") instanceof String) {
+                        if (Util.isNum(server.getString("GroupNum"))) {
+                            if (server.getString("GroupNum").equals(String.valueOf(groupNum))) {
+                                return i;
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        return -1;
+    }
+
+    public boolean addBindServer(long groupNum, String cmd, String host) throws IOException {
+        if (getServer(groupNum) != null) {
+            return false;
+        }
+
+        JSONObject server = new JSONObject();
+        server.put("GroupNum", String.valueOf(groupNum));
+        server.put("CMD", cmd);
+        server.put("Host", host);
+        this.bindServerList.add(server);
+        writeConfig();
+        return true;
+    }
+
+    public boolean removeBindServer(long groupNum) throws IOException {
+        int index = getServerIndex(groupNum);
+        if (index == -1) return false;
+        this.bindServerList.remove(index);
+        writeConfig();
+        return true;
+    }
+
+    public int removeAllBindServer() throws IOException{
+        int count = this.bindServerList.size();
+        this.bindServerList.clear();
+        writeConfig();
+        return count;
+    }
+}