過去に報酬を配布した確認するメソッドを追加

Author: miyabi033

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

@@ -67,7 +67,7 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command cmd, @N
                 }
             }
             case "forcegive" -> {
-                if(args.length < 2){
+                if(args.length < 3){
                     sender.sendMessage("引数が足りません");
                     return true;
                 }
@@ -87,6 +87,22 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command cmd, @N
                     throw new RuntimeException(e);
                 }
             }
+            case "checkreward" -> {
+                if(args.length < 2){
+                    sender.sendMessage("引数が足りません");
+                    return true;
+                }
+                RewardAdminService adminService = Pointed.getInstance().getRewardAdminService();
+                try {
+                    if(adminService.rewardExists(Integer.parseInt(args[1]))){
+                        sender.sendMessage("指定したリワードは存在します");
+                    }else {
+                        sender.sendMessage("指定したリワードは存在しません...");
+                    }
+                } catch (NumberFormatException e) {
+                    sender.sendMessage("rewardIDを数字で入力してください!!!! : " + args[1]);
+                }
+            }
             default -> sender.sendMessage(Util.f("/ptteam <set> <teamID>"));
         }
 

src/main/java/dev/felnull/pointed/teams/manager/reward/RewardAdminService.java

@@ -6,6 +6,7 @@
 import dev.felnull.pointed.teams.manager.reward.data.RewardSummary;
 import org.jetbrains.annotations.Nullable;
 
+import java.sql.Connection;
 import java.sql.SQLException;
 import java.time.LocalDate;
 import java.util.List;
@@ -74,4 +75,7 @@ void dispatchByBuckets(long teamSubjectId, String scope,
 
     /** 詳細（コマンド付き） */
     RewardDetail getRewardDetail(int rewardId, boolean onlyEnabledCommands) throws SQLException;
+
+    /** 過去にその報酬を配布したか */
+    boolean hasEverDistributedRewardToPlayer(long playerSubjectId, int rewardId) throws SQLException;
 }

src/main/java/dev/felnull/pointed/teams/manager/reward/impl/RewardAdminServiceImpl.java

@@ -1,6 +1,7 @@
 package dev.felnull.pointed.teams.manager.reward.impl;
 
 import dev.felnull.pointed.Pointed;
+import dev.felnull.pointed.core.database.Db;
 import dev.felnull.pointed.core.database.Names;
 import dev.felnull.pointed.teams.manager.reward.RankingService;
 import dev.felnull.pointed.teams.manager.reward.RewardAdminService;
@@ -763,7 +764,7 @@ public boolean rewardExists(long rewardId) {
 
     // ==== 存在確認（トランザクション版・接続使い回し）====
     public boolean rewardExists(Connection con, long rewardId) throws SQLException {
-        final String sql = "SELECT 1 FROM rewards WHERE id = ? LIMIT 1";
+        final String sql = "SELECT 1 FROM " + Names.t("rewards") + " WHERE id = ? LIMIT 1";
         try (PreparedStatement ps = con.prepareStatement(sql)) {
             ps.setLong(1, rewardId);
             try (ResultSet rs = ps.executeQuery()) {
@@ -774,7 +775,7 @@ public boolean rewardExists(Connection con, long rewardId) throws SQLException {
 
     // もし名前で唯一ならこっちも（任意）
     public boolean rewardExistsByName(Connection con, String name) throws SQLException {
-        final String sql = "SELECT 1 FROM rewards WHERE name = ? LIMIT 1";
+        final String sql = "SELECT 1 FROM " + Names.t("rewards") + " WHERE name = ? LIMIT 1";
         try (PreparedStatement ps = con.prepareStatement(sql)) {
             ps.setString(1, name);
             try (ResultSet rs = ps.executeQuery()) {
@@ -783,4 +784,22 @@ public boolean rewardExistsByName(Connection con, String name) throws SQLExcepti
         }
     }
 
+    @Override
+    public boolean hasEverDistributedRewardToPlayer(
+            long playerSubjectId,
+            int rewardId
+    ) throws SQLException {
+        Connection con = Db.get().getConnection();
+        final String sql =
+                "SELECT 1 FROM " + Names.t("reward_dispatch_log") +
+                        " WHERE player_subject_id = ? AND reward_id = ? LIMIT 1";
+        try (PreparedStatement ps = con.prepareStatement(sql)) {
+            ps.setLong(1, playerSubjectId);
+            ps.setInt(2, rewardId);
+            try (ResultSet rs = ps.executeQuery()) {
+                return rs.next();
+            }
+        }
+    }
+
 }