package com.kodari.diamondalert.tracker; import com.kodari.diamondalert.config.ConfigManager; import java.util.*; public class MiningTracker { private final ConfigManager configManager; // UUID -> list of timestamps (ms) ของแต่ละบล็อกที่ขุด private final Map> miningLog = new HashMap<>(); // UUID -> จำนวนครั้งที่แจ้งเตือนแล้วในรอบนี้ private final Map alertCount = new HashMap<>(); public MiningTracker(ConfigManager configManager) { this.configManager = configManager; } /** * บันทึกการขุด 1 บล็อก และคืนค่าจำนวนบล็อกที่ขุดในช่วงเวลาที่กำหนด */ public int recordAndCount(UUID playerId) { long now = System.currentTimeMillis(); long windowMs = configManager.getTimeWindowSeconds() * 1000L; Deque log = miningLog.computeIfAbsent(playerId, k -> new ArrayDeque<>()); log.addLast(now); // ลบ timestamps ที่เก่าเกินช่วงเวลา while (!log.isEmpty() && now - log.peekFirst() > windowMs) { log.pollFirst(); } return log.size(); } /** * ตรวจสอบว่าควรแจ้งเตือนหรือไม่ และอัปเดตตัวนับ * คืน true ถ้าควรส่งการแจ้งเตือน */ public boolean shouldAlert(UUID playerId, int currentCount) { int max = configManager.getMaxBlocks(); int every = configManager.getAlertEvery(); if (currentCount < max) { return false; } int excess = currentCount - max; if (every <= 0) { // แจ้งเตือนเฉพาะตอนครั้งแรกที่ถึง threshold int prev = alertCount.getOrDefault(playerId, 0); if (prev == 0) { alertCount.put(playerId, 1); return true; } return false; } // แจ้งเตือนทุก `every` บล็อกหลังจาก threshold int expectedAlerts = (excess / every) + 1; int prevAlerts = alertCount.getOrDefault(playerId, 0); if (expectedAlerts > prevAlerts) { alertCount.put(playerId, expectedAlerts); return true; } return false; } /** * รีเซ็ตข้อมูลผู้เล่นเมื่อหน้าต่างเวลาผ่านไปหมดแล้ว */ public void resetIfExpired(UUID playerId) { long now = System.currentTimeMillis(); long windowMs = configManager.getTimeWindowSeconds() * 1000L; Deque log = miningLog.get(playerId); if (log == null || log.isEmpty()) { alertCount.remove(playerId); return; } if (now - log.peekFirst() > windowMs) { miningLog.remove(playerId); alertCount.remove(playerId); } } public void clearAll() { miningLog.clear(); alertCount.clear(); } public int getCurrentCount(UUID playerId) { long now = System.currentTimeMillis(); long windowMs = configManager.getTimeWindowSeconds() * 1000L; Deque log = miningLog.get(playerId); if (log == null) return 0; log.removeIf(t -> now - t > windowMs); return log.size(); } }