scope一覧取得機能を追加

Author: miyabi033

src/main/java/dev/felnull/pointed/core/commands/PtCommand.java

@@ -1,8 +1,11 @@
 package dev.felnull.pointed.core.commands;
 
+import dev.felnull.pointed.Pointed;
+import dev.felnull.pointed.core.database.api.PointServiceImpl;
 import dev.felnull.pointed.core.database.data.RankRow;
 import dev.felnull.pointed.core.database.api.PointService;
 import dev.felnull.pointed.core.util.Util;
+import dev.felnull.pointed.teams.manager.reward.RewardAdminService;
 import org.bukkit.Bukkit;
 import org.bukkit.OfflinePlayer;
 import org.bukkit.command.Command;
@@ -231,10 +234,17 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command cmd, @N
                             shown++;
                         }
                     }
-
                     default -> sender.sendMessage(Util.f("&e/pt rank <daily|weekly|global> <PLAYER|TEAM|SYSTEM> <スコープ> [...]"));
                 }
             }
+            case "scope" -> {
+                PointServiceImpl pointService = Pointed.getInstance().getPointService();
+                sender.sendMessage("====Scope一覧====");
+                for(String scope : pointService.listAllScopes()){
+                    sender.sendMessage("・ " + scope);
+                }
+                sender.sendMessage("=================");
+            }
 
         }
 
@@ -244,7 +254,7 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command cmd, @N
     @Override
     public List<String> onTabComplete(@NotNull CommandSender sender, @NotNull Command cmd, @NotNull String label, String[] args) {
         if (args.length == 1) {
-            return List.of("getnow", "gettotal", "get", "add", "sub", "set", "rank");
+            return List.of("getnow", "gettotal", "get", "add", "sub", "set", "rank", "scope");
         }
         // サブコマンド毎の type 補完
         if (args.length == 2 && List.of("getnow","gettotal","get","add","sub","set").contains(args[0].toLowerCase())) {

src/main/java/dev/felnull/pointed/core/database/api/PointService.java

@@ -2,6 +2,8 @@
 
 import dev.felnull.pointed.core.database.data.RankRow;
 
+import java.util.List;
+
 public interface PointService {
 
     //subjectType = "PLAYER"とか"TEAM"とか
@@ -29,4 +31,7 @@ public interface PointService {
 
     //すべての scope で subject を完全削除（accounts/履歴を消し、subjects も削除
     boolean deleteSubjectEverywhere(String subjectType, String subjectKey);
+
+    List<String> listScopes(String subjectType, String subjectKey);
+    List<String> listAllScopes();
 }

src/main/java/dev/felnull/pointed/core/database/api/PointServiceImpl.java

@@ -443,4 +443,42 @@ public boolean deleteSubjectEverywhere(String subjectType, String subjectKey) {
             throw new RuntimeException(e);
         }
     }
+
+    @Override
+    public List<String> listScopes(String subjectType, String subjectKey) {
+        List<String> scopes = new ArrayList<>();
+        try (Connection con = ds.getConnection();
+             PreparedStatement ps = con.prepareStatement(
+                     "SELECT a.scope FROM " + Names.t("accounts") + " a " +
+                             "JOIN " + Names.t("subjects") + " s ON s.id=a.subject_id " +
+                             "WHERE s.type=? AND s.subject_key=?")) {
+            ps.setString(1, subjectType);
+            ps.setString(2, subjectKey);
+            try (ResultSet rs = ps.executeQuery()) {
+                while (rs.next()) {
+                    scopes.add(rs.getString(1));
+                }
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+        return scopes;
+    }
+
+    @Override
+    public List<String> listAllScopes() {
+        List<String> scopes = new ArrayList<>();
+        try (Connection con = ds.getConnection();
+             PreparedStatement ps = con.prepareStatement(
+                     "SELECT DISTINCT scope FROM " + Names.t("accounts"))) {
+            try (ResultSet rs = ps.executeQuery()) {
+                while (rs.next()) {
+                    scopes.add(rs.getString(1));
+                }
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException(e);
+        }
+        return scopes;
+    }
 }