package com.hyperxstudio.auction.data; import com.hyperxstudio.auction.HXAuctionPlugin; import org.bukkit.Bukkit; import org.bukkit.configuration.ConfigurationSection; import org.bukkit.configuration.file.FileConfiguration; import org.bukkit.configuration.file.YamlConfiguration; import org.bukkit.inventory.ItemStack; import java.io.File; import java.io.IOException; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; public class AuctionDataManager { private final HXAuctionPlugin plugin; private final File dataFile; private FileConfiguration data; private final Map activeItems; private final Map expiredItems; private final Map soldItems; public AuctionDataManager(HXAuctionPlugin plugin) { this.plugin = plugin; this.dataFile = new File(plugin.getDataFolder() + "/data", "auctions.yml"); this.activeItems = new ConcurrentHashMap<>(); this.expiredItems = new ConcurrentHashMap<>(); this.soldItems = new ConcurrentHashMap<>(); loadData(); } private void loadData() { if (!dataFile.exists()) { dataFile.getParentFile().mkdirs(); try { dataFile.createNewFile(); } catch (IOException e) { e.printStackTrace(); } } data = YamlConfiguration.loadConfiguration(dataFile); loadItems("active", activeItems); loadItems("expired", expiredItems); loadItems("sold", soldItems); } private void loadItems(String section, Map map) { ConfigurationSection sec = data.getConfigurationSection(section); if (sec == null) return; for (String key : sec.getKeys(false)) { try { UUID id = UUID.fromString(key); UUID seller = UUID.fromString(sec.getString(key + ".seller")); String sellerName = sec.getString(key + ".sellerName"); ItemStack item = sec.getItemStack(key + ".item"); double price = sec.getDouble(key + ".price"); String currency = sec.getString(key + ".currency", "vault"); long listTime = sec.getLong(key + ".listTime"); long expireTime = sec.getLong(key + ".expireTime"); boolean expired = sec.getBoolean(key + ".expired"); boolean sold = sec.getBoolean(key + ".sold"); AuctionItem auctionItem = new AuctionItem(id, seller, sellerName, item, price, currency, listTime, expireTime, expired, sold); map.put(id, auctionItem); } catch (Exception e) { plugin.getLogger().warning("Failed to load auction item: " + key); } } } public void saveAll() { data = new YamlConfiguration(); saveItems("active", activeItems); saveItems("expired", expiredItems); saveItems("sold", soldItems); try { data.save(dataFile); } catch (IOException e) { e.printStackTrace(); } } private void saveItems(String section, Map map) { for (Map.Entry entry : map.entrySet()) { AuctionItem item = entry.getValue(); String path = section + "." + item.getId().toString(); data.set(path + ".seller", item.getSeller().toString()); data.set(path + ".sellerName", item.getSellerName()); data.set(path + ".item", item.getItem()); data.set(path + ".price", item.getPrice()); data.set(path + ".currency", item.getCurrency()); data.set(path + ".listTime", item.getListTime()); data.set(path + ".expireTime", item.getExpireTime()); data.set(path + ".expired", item.isExpired()); data.set(path + ".sold", item.isSold()); } } public void addItem(AuctionItem item) { activeItems.put(item.getId(), item); saveAll(); } public void removeItem(UUID id) { activeItems.remove(id); saveAll(); } public void expireItem(AuctionItem item) { item.setExpired(true); activeItems.remove(item.getId()); expiredItems.put(item.getId(), item); saveAll(); } public void sellItem(AuctionItem item) { item.setSold(true); activeItems.remove(item.getId()); soldItems.put(item.getId(), item); saveAll(); } public AuctionItem getItem(UUID id) { return activeItems.get(id); } public List getAllActiveItems() { return new ArrayList<>(activeItems.values()); } public List getPlayerActiveItems(UUID player) { return activeItems.values().stream() .filter(item -> item.getSeller().equals(player)) .collect(Collectors.toList()); } public List getPlayerExpiredItems(UUID player) { return expiredItems.values().stream() .filter(item -> item.getSeller().equals(player)) .collect(Collectors.toList()); } public void removeExpiredItem(UUID id) { expiredItems.remove(id); saveAll(); } public void expireItemByUsername(String username) { List items = activeItems.values().stream() .filter(item -> item.getSellerName().equalsIgnoreCase(username)) .collect(Collectors.toList()); for (AuctionItem item : items) { expireItem(item); } } }