package com.joban.auctionhouse.listing; import com.joban.auctionhouse.AuctionHouse; import lombok.Getter; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; @Getter public class ListingManager { private final AuctionHouse plugin; private final Map activeListings; private final Map> expiredListings; private final Map sellCooldowns; public ListingManager(AuctionHouse plugin) { this.plugin = plugin; this.activeListings = new ConcurrentHashMap<>(); this.expiredListings = new ConcurrentHashMap<>(); this.sellCooldowns = new ConcurrentHashMap<>(); } public void loadListings() { List loaded = plugin.getDatabaseManager().loadListings(); this.activeListings.clear(); for (AuctionListing listing : loaded) { this.activeListings.put(listing.getId(), listing); } plugin.getLogger().info("Loaded " + loaded.size() + " active listings"); } public void saveListings() { for (AuctionListing listing : this.activeListings.values()) { plugin.getDatabaseManager().saveListing(listing); } for (List listings : this.expiredListings.values()) { for (AuctionListing listing : listings) { plugin.getDatabaseManager().saveListing(listing); } } } public void createListing(AuctionListing listing) { this.activeListings.put(listing.getId(), listing); plugin.getDatabaseManager().saveListing(listing); } public void removeListing(UUID listingId) { this.activeListings.remove(listingId); plugin.getDatabaseManager().deleteListing(listingId); } public AuctionListing getListing(UUID listingId) { return this.activeListings.get(listingId); } public List getActiveListings() { return new ArrayList<>(this.activeListings.values()); } public List getPlayerListings(UUID playerUuid) { return this.activeListings.values().stream() .filter(listing -> listing.getSellerUuid().equals(playerUuid)) .collect(Collectors.toList()); } public List getExpiredListings(UUID playerUuid) { List cached = this.expiredListings.get(playerUuid); if (cached == null) { cached = plugin.getDatabaseManager().loadExpiredListings(playerUuid); this.expiredListings.put(playerUuid, cached); } return new ArrayList<>(cached); } public void addExpiredListing(AuctionListing listing) { listing.setExpired(true); this.activeListings.remove(listing.getId()); List playerExpired = this.expiredListings.computeIfAbsent( listing.getSellerUuid(), k -> new ArrayList<>()); playerExpired.add(listing); plugin.getDatabaseManager().saveListing(listing); Player player = Bukkit.getPlayer(listing.getSellerUuid()); if (player != null && player.isOnline()) { player.sendMessage(plugin.getConfigManager().getMessageWithPrefix("listing-expired")); } } public void removeExpiredListing(UUID playerUuid, UUID listingId) { List playerExpired = this.expiredListings.get(playerUuid); if (playerExpired != null) { playerExpired.removeIf(listing -> listing.getId().equals(listingId)); } plugin.getDatabaseManager().deleteListing(listingId); } public void checkExpiredListings() { int durationHours = plugin.getConfigManager().getListingDurationHours(); List toExpire = new ArrayList<>(); for (AuctionListing listing : this.activeListings.values()) { if (listing.hasExpired(durationHours)) { toExpire.add(listing); } } for (AuctionListing listing : toExpire) { addExpiredListing(listing); } if (!toExpire.isEmpty()) { plugin.getLogger().info("Expired " + toExpire.size() + " listing(s)"); } } public List searchListings(String query) { String lowerQuery = query.toLowerCase(); return this.activeListings.values().stream() .filter(listing -> { String itemName = listing.getItem().getType().name().toLowerCase(); if (listing.getItem().hasItemMeta() && listing.getItem().getItemMeta().hasDisplayName()) { String displayName = listing.getItem().getItemMeta().getDisplayName().toLowerCase(); return displayName.contains(lowerQuery) || itemName.contains(lowerQuery); } return itemName.contains(lowerQuery); }) .collect(Collectors.toList()); } public boolean isOnCooldown(UUID playerUuid) { Long lastSell = this.sellCooldowns.get(playerUuid); if (lastSell == null) return false; long cooldown = plugin.getConfigManager().getSellCooldownSeconds() * 1000L; return System.currentTimeMillis() - lastSell < cooldown; } public long getRemainingCooldown(UUID playerUuid) { Long lastSell = this.sellCooldowns.get(playerUuid); if (lastSell == null) return 0; long cooldown = plugin.getConfigManager().getSellCooldownSeconds() * 1000L; long remaining = cooldown - (System.currentTimeMillis() - lastSell); return Math.max(0, remaining / 1000); } public void setCooldown(UUID playerUuid) { this.sellCooldowns.put(playerUuid, System.currentTimeMillis()); } }