区域刷新，区域黑名单，世界黑名单完成

src/main/java/com/yuyu/srwildentity/JDBC/JdbcSqlClass.java

@@ -0,0 +1,224 @@
+package com.yuyu.srwildentity.JDBC;
+
+import org.bukkit.ChatColor;
+
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.UUID;
+
+
+/**
+ * @author 峰。
+ * @version 1.0
+ * @project SrDisassemble
+ * @date 2024/6/19 16:05:42
+ * @description JDBC
+ */
+public class JdbcSqlClass {
+    private static String driver;
+    private static String url;
+    private static String user;
+    private static String password;
+
+
+
+    public static List<UUID> getUUIDByAreaAndEntity(String area, String entity){
+        List<UUID> uuids = new ArrayList<>();
+        Connection connection = openConnection();
+        String sql = "select * from areaentity where area = '"+area+"' and entityname = '"+entity+"'";
+        try {
+            Statement statement = connection.createStatement();
+            ResultSet resultSet = statement.executeQuery(sql);
+            while (resultSet.next()) {
+                uuids.add(UUID.fromString(resultSet.getString("uuid")));
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+        return uuids;
+    }
+
+
+    public static Connection openConnection() {
+        //注册驱动
+        try {
+            Class.forName(JdbcSqlClass.driver);
+            //获取连接
+            Connection conn = DriverManager.getConnection(JdbcSqlClass.url, JdbcSqlClass.user, JdbcSqlClass.password);
+            return conn;
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+
+    public static String getDriver() {
+        return driver;
+    }
+
+    public static String getUrl() {
+        return url;
+    }
+
+    public static String getUser() {
+        return user;
+    }
+
+    public static String getPassword() {
+        return password;
+    }
+
+    public static void setDriver(String driver) {
+        JdbcSqlClass.driver = driver;
+    }
+
+    public static void setUrl(String url) {
+        JdbcSqlClass.url = url;
+    }
+
+    public static void setUser(String user) {
+        JdbcSqlClass.user = user;
+    }
+
+    public static void setPassword(String password) {
+        JdbcSqlClass.password = password;
+    }
+
+
+    public static void initTable() {
+        try {
+            Connection connection = openConnection();
+
+            Statement stmt = connection.createStatement();
+
+            //执行Sql语句
+            String createTable = " create table if not exists areaentity\t(  " +
+                    "area       varchar(255) null comment '区域名称',\n" +
+                    "    entityname varchar(255) null,\n" +
+                    "    uuid       varchar(255) null comment '实体uuid')";
+
+            boolean rs = stmt.execute(createTable);
+
+
+
+            String sql = "select column_name\n" +
+                    "from INFORMATION_SCHEMA.COLUMNS\n" +
+                    "where TABLE_NAME = 'areaentity'";
+
+            //手动注入所有列
+            List<String> columns = new ArrayList<>();
+            columns.add("area");
+            columns.add("entityname");
+            columns.add("uuid");
+
+            try {
+                ResultSet resultSet = stmt.executeQuery(sql);
+                List<String> lists = new ArrayList<>();
+                int index = 0;
+                while (resultSet.next()) {
+                    String columnName = resultSet.getString("column_name");
+                    lists.add(columnName);
+                    index++;
+                }
+                List<String> missColumn = new ArrayList<>();
+                for (String columnName : columns) {
+                    if (!lists.contains(columnName)) {
+                        missColumn.add(columnName);
+                    }
+                }
+                //新增列
+                for (String columnName : missColumn) {
+                    addColumn(columnName);
+                }
+
+            } catch (SQLException e) {
+                throw new RuntimeException(e);
+            }
+
+
+            connection.close();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    private static int  addColumn(String columns) {
+        String sql = null;
+        if (columns.equals("area")) {
+            sql = "ALTER TABLE areaentity\n" +
+                    "ADD area varchar(255)  null  comment '区域名'";
+        } else if (columns.equals("entityname")) {
+            sql = "ALTER TABLE areaentity\n" +
+                    "ADD      entityname varchar(255) null comment '打开gui的名称'";
+        } else if (columns.equals("uuid")) {
+            sql = "ALTER TABLE areaentity\n" +
+                    "ADD   uuid       varchar(255) null comment '实体uuid'";
+        }
+
+        if (sql != null) {
+            try {
+                Statement stmt = openConnection().createStatement();
+                int i = stmt.executeUpdate(sql);
+                return i;
+            } catch (SQLException e) {
+                throw new RuntimeException(e);
+            }
+        }
+        return 0;
+    }
+
+    public static void setChartseUtf8() {
+        try {
+            Statement connection = openConnection().createStatement();
+
+            //执行Sql语句
+
+            String sql = "ALTER TABLE areaentity CONVERT TO CHARACTER SET utf8mb4;";
+            boolean rs = connection.execute(sql);
+
+            connection.close();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    public static void deleteData(){
+        //先清空数据库,再插入
+        String sqlDelete = "DELETE FROM areaentity";
+
+        Connection connection = openConnection();
+
+        try {
+            Statement statement = connection.createStatement();
+            boolean execute = statement.execute(sqlDelete);
+            if (execute){
+                System.out.println(ChatColor.RED+"区域实体数据清空");
+            }
+            statement.close();
+            connection.close();
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+
+    public static void saveData(HashMap<UUID, String> hashMap){
+        Connection connection = openConnection();
+        try {
+            Statement statement = connection.createStatement();
+            for (UUID uuid : hashMap.keySet()) {
+                String s = hashMap.get(uuid);
+                String[] split = s.split("/");
+                String area = split[0];
+                String entity = split[1];
+                String uuidString = uuid.toString();
+                String sql = "INSERT INTO areaentity(area,entityname,uuid) VALUES('"+area+"','"+entity+"','"+uuidString+"')";
+                statement.executeUpdate(sql);
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

src/main/java/com/yuyu/srwildentity/config/condition/LevelRefresh.java

@@ -0,0 +1,38 @@
+package com.yuyu.srwildentity.config.condition;
+
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @BelongsProject: SrWildEntity
+ * @BelongsPackage: com.yuyu.srwildentity.config.condition
+ * @FileName: LevelRefresh
+ * @Author: 峰。
+ * @Date: 2024/4/25-22:06
+ * @Version: 1.0
+ * @Description: 按照等级记录怪物
+ */
+public class LevelRefresh {
+    private final int riskMax;
+    private final int riskMin;
+    //                      群系名
+    private final HashMap<String, List<EntityCondition>> entityConditionHashMap;
+
+    public int getRiskMax() {
+        return riskMax;
+    }
+
+    public int getRiskMin() {
+        return riskMin;
+    }
+
+    public HashMap<String, List<EntityCondition>> getEntityConditionHashMap() {
+        return entityConditionHashMap;
+    }
+
+    public LevelRefresh(int riskMax, int riskMin, HashMap<String, List<EntityCondition>> entityConditionHashMap) {
+        this.riskMax = riskMax;
+        this.riskMin = riskMin;
+        this.entityConditionHashMap = entityConditionHashMap;
+    }
+}

src/main/java/com/yuyu/srwildentity/pojo/AreaRefresh.java

@@ -0,0 +1,105 @@
+package com.yuyu.srwildentity.pojo;
+
+import com.yuyu.srwildentity.JDBC.JdbcSqlClass;
+import com.yuyu.srwildentity.config.condition.EntityCondition;
+
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * @author 峰。
+ * @version 1.0
+ * @project SrWildEntity
+ * @date 2024/7/8 23:13:33
+ * @description 区域刷新的类
+ */
+public class AreaRefresh {
+    private final int x1;
+    private final int z1;
+    private final int x2;
+    private final int z2;
+    private final int y1;
+    private final int y2;
+    private final String worldName;
+    private final String area;
+    private final HashMap<String,EntityCondition> entityConditionList;
+    private HashMap<String,Integer> entityNums;//用于记录怪物区域的怪物数量
+
+    public AreaRefresh(int x1, int z1, int x2, int z2, String worldName, HashMap<String,EntityCondition> entityConditionList, int y1, int y2, String area) {
+        if (x2 >= x1){
+            this.x2 = x2;
+            this.x1 = x1;
+        }else {
+            this.x2 = x1;
+            this.x1 = x2;
+        }
+        if (z2 >= z1){
+            this.z2 = z2;
+            this.z1 = z1;
+        }else {
+            this.z2 = z1;
+            this.z1 = z2;
+        }
+        if (y2 >= y1){
+            this.y2 = y2;
+            this.y1 = y1;
+        }else {
+            this.y2 = y1;
+            this.y1 = y2;
+        }
+        this.area = area;
+        this.worldName = worldName;
+        this.entityConditionList = entityConditionList;
+        this.entityNums = new HashMap<>();
+
+
+        //属性初始化完成后,查询数据库
+
+    }
+
+
+
+    public String getArea() {
+        return area;
+    }
+
+    public void setEntityNums(String entityName, int num) {
+        this.entityNums.put(entityName, num);
+    }
+
+    public int getY1() {
+        return y1;
+    }
+
+    public int getY2() {
+        return y2;
+    }
+
+    public int getX1() {
+        return x1;
+    }
+
+    public int getZ1() {
+        return z1;
+    }
+
+    public int getX2() {
+        return x2;
+    }
+
+    public int getZ2() {
+        return z2;
+    }
+
+    public String getWorldName() {
+        return worldName;
+    }
+
+    public HashMap<String, Integer> getEntityNums() {
+        return entityNums;
+    }
+
+    public HashMap<String, EntityCondition> getEntityConditionList() {
+        return entityConditionList;
+    }
+}

src/main/java/com/yuyu/srwildentity/pojo/BlackListArea.java

@@ -0,0 +1,81 @@
+package com.yuyu.srwildentity.pojo;
+
+/**
+ * @author 峰。
+ * @version 1.0
+ * @project SrWildEntity
+ * @date 2024/7/7 14:23:54
+ * @description 黑名单区域
+ */
+public class BlackListArea {
+    private String worldName;
+    private int x1;
+    private int y1;
+    private int x2;
+    private int y2;
+
+    public BlackListArea(String worldName, int x1, int y1, int x2, int y2) {
+        this.worldName = worldName;
+        this.setXY(x1,y1,x2,y2);
+    }
+
+    /**
+     * 此方法可以固定x1>x2   y1>y2
+     * @param x1
+     * @param y1
+     * @param x2
+     * @param y2
+     */
+    public void setXY(int x1, int y1,int x2, int y2) {
+        if (x1 > x2) {
+            this.x1 = x1;
+            this.x2 = x2;
+        }else {
+            this.x1 = x2;
+            this.x2 = x1;
+        }
+
+        if (y1 > y2) {
+            this.y1 = y1;
+            this.y2 = y2;
+        }else {
+            this.y1 = y2;
+            this.y2 = y1;
+        }
+    }
+
+    public String getWorldName() {
+        return worldName;
+    }
+
+    public boolean isPointInRectangle(int x, int z) {
+        // 确保x1 < x2 和 z1 < z2，如果不是，则交换它们（但在这个示例中，我们假设输入总是有效的）
+
+        // 检查x坐标是否在范围内
+        if (x >= x1 && x <= x2) {
+            // 检查z坐标是否在范围内
+            if (z >= y1 && z <= y2) {
+                return true; // 如果两个条件都满足，则点在矩形内
+            }
+        }
+
+        // 如果不满足任一条件，则点在矩形外
+        return false;
+    }
+
+    public int getX1() {
+        return x1;
+    }
+
+    public int getY1() {
+        return y1;
+    }
+
+    public int getX2() {
+        return x2;
+    }
+
+    public int getY2() {
+        return y2;
+    }
+}

src/main/resources/LEVEL_1.yml

@@ -1,3 +1,5 @@
+RISK_MAX: 10 #当最大危险度为多少时读取这个yml文件，10的时候会读取
+RISK_MIN: 0 #当最小危险度为多少时读取这个yml文件，0的时候不会读取
 DESERT:
   ZOMBIE: #指出entity在该群系的刷新条件
     type: 0 #0表示生成mc原生实体，1表示生成MM怪物,不能为空！

src/main/resources/areaRefresh.yml

@@ -0,0 +1,10 @@
+Area_Number: 1
+area_1:
+  x1: 100
+  z1: 100
+  x2: 200
+  z2: 200
+  yMax: 10
+  yMin: 20  #此处给出一个大概y轴刷新范围，增大刷新的概率
+  worldName: TravelersDreamCompact
+  refreshList: [ZOMBIE]

src/main/resources/area_Entity.yml

@@ -0,0 +1,12 @@
+area_1:
+  ZOMBIE: #指出entity在该群系的刷新条件
+    type: 0 #0表示生成mc原生实体，1表示生成MM怪物,不能为空！
+    site: 1 #刷新位置,数字代表不同的刷新位置
+    light: 15 #刷新亮度
+    refreshTime: 20 #单位为秒
+    nums: 2 #entity的刷新数量，注意，这里的数量会和通群系中其他entity相关，总数不会超过config.yml中的定义
+    yMax: 150 #极限刷新高度
+    yMin: 60 #最小刷新高度
+    riskMax: 10  #刷新危险度的范围
+    riskMin: 0 #条件是小于等于riskMin大于riskMax，即riskMin<= risklevel < riskMax 才会刷新
+    weight: 1.0 #权重越高，刷新的概率越高，最高为1.0

src/main/resources/blacklistArea.yml

@@ -0,0 +1,13 @@
+blacklistNums: 2 #黑名单区域的数量
+blacklist_1:  #黑名单区域
+  world_name: TravelersDreamCompact
+  x1: 100
+  z1: 100
+  x2: 200
+  z2: 200
+blacklist_2:  #黑名单区域
+  world_name: TravelersDreamCompact
+  x1: 1000
+  z1: 100
+  x2: 2000
+  z2: 200

src/main/resources/blacklistWorld.yml

@@ -0,0 +1,3 @@
+#世界黑名单
+blacklistWorld:
+  - TravelersDreamCompact

src/main/resources/datasource.yml

@@ -0,0 +1,6 @@
+database:
+  sql:
+    user: root
+    password:
+    driver: com.mysql.cj.jdbc.Driver
+    url: jdbc:mysql://localhost:3306/mc_service

target/classes/areaRefresh.yml

@@ -0,0 +1,10 @@
+Area_Number: 1
+area_1:
+  x1: 100
+  z1: 100
+  x2: 200
+  z2: 200
+  yMax: 10
+  yMin: 20  #此处给出一个大概y轴刷新范围，增大刷新的概率
+  worldName: TravelersDreamCompact
+  refreshList: [ZOMBIE]

target/classes/area_Entity.yml

@@ -0,0 +1,12 @@
+area_1:
+  ZOMBIE: #指出entity在该群系的刷新条件
+    type: 0 #0表示生成mc原生实体，1表示生成MM怪物,不能为空！
+    site: 1 #刷新位置,数字代表不同的刷新位置
+    light: 15 #刷新亮度
+    refreshTime: 20 #单位为秒
+    nums: 2 #entity的刷新数量，注意，这里的数量会和通群系中其他entity相关，总数不会超过config.yml中的定义
+    yMax: 150 #极限刷新高度
+    yMin: 60 #最小刷新高度
+    riskMax: 10  #刷新危险度的范围
+    riskMin: 0 #条件是小于等于riskMin大于riskMax，即riskMin<= risklevel < riskMax 才会刷新
+    weight: 1.0 #权重越高，刷新的概率越高，最高为1.0

target/classes/blacklistArea.yml

@@ -0,0 +1,13 @@
+blacklistNums: 2 #黑名单区域的数量
+blacklist_1:  #黑名单区域
+  world_name: TravelersDreamCompact
+  x1: 100
+  z1: 100
+  x2: 200
+  z2: 200
+blacklist_2:  #黑名单区域
+  world_name: TravelersDreamCompact
+  x1: 1000
+  z1: 100
+  x2: 2000
+  z2: 200

target/classes/blacklistWorld.yml

@@ -0,0 +1,3 @@
+#世界黑名单
+blacklistWorld:
+  - TravelersDreamCompact