package fr.elyra.core.modules; import fr.elyra.core.ElyraCore; import fr.elyra.core.api.Module; import fr.elyra.core.data.Job; import fr.elyra.core.data.JobProgress; import org.bukkit.configuration.ConfigurationSection; import org.bukkit.entity.Player; import org.bukkit.event.EventHandler; import org.bukkit.event.Listener; import org.bukkit.event.block.BlockBreakEvent; import org.bukkit.event.entity.EntityDeathEvent; import java.sql.ResultSet; import java.sql.SQLException; import java.util.*; public class JobsModule extends Module implements Listener { private Map jobs; private Map> playerJobs; private int maxJobsPerPlayer; public JobsModule(ElyraCore plugin) { super(plugin, "Jobs"); this.jobs = new HashMap<>(); this.playerJobs = new HashMap<>(); } @Override public void onEnable() { plugin.saveResource("jobs.yml", false); loadJobs(); plugin.getServer().getPluginManager().registerEvents(this, plugin); setEnabled(true); } @Override public void onDisable() { saveAllJobs(); setEnabled(false); } private void loadJobs() { var config = plugin.getConfigManager().getConfig("jobs.yml"); this.maxJobsPerPlayer = config.getInt("max-jobs-per-player", 2); ConfigurationSection jobsSection = config.getConfigurationSection("jobs"); if (jobsSection != null) { for (String jobId : jobsSection.getKeys(false)) { Job job = new Job(); job.setId(jobId); job.setName(jobsSection.getString(jobId + ".name")); job.setDescription(jobsSection.getString(jobId + ".description")); job.setIcon(jobsSection.getString(jobId + ".icon")); job.setMaxLevel(jobsSection.getInt(jobId + ".max-level", 100)); jobs.put(jobId, job); } } plugin.getLogger().info(jobs.size() + " jobs charges."); } public JobProgress getJobProgress(UUID uuid, String jobId) { return playerJobs.computeIfAbsent(uuid, k -> new HashMap<>()) .computeIfAbsent(jobId, k -> loadJobProgress(uuid, jobId)); } private JobProgress loadJobProgress(UUID uuid, String jobId) { try (ResultSet rs = plugin.getDatabaseManager().query( "SELECT * FROM player_jobs WHERE uuid = ? AND job = ?", uuid.toString(), jobId)) { if (rs.next()) { JobProgress progress = new JobProgress(uuid, jobId); progress.setLevel(rs.getInt("level")); progress.setXp(rs.getDouble("xp")); return progress; } } catch (SQLException e) { plugin.getLogger().severe("Erreur lors du chargement du job " + jobId); e.printStackTrace(); } return new JobProgress(uuid, jobId); } public void saveJobProgress(JobProgress progress) { plugin.getDatabaseManager().executeAsync( "INSERT INTO player_jobs (uuid, job, level, xp) VALUES (?, ?, ?, ?) " + "ON DUPLICATE KEY UPDATE level=?, xp=?", progress.getPlayerUuid().toString(), progress.getJobId(), progress.getLevel(), progress.getXp(), progress.getLevel(), progress.getXp() ); } private void saveAllJobs() { for (Map jobs : playerJobs.values()) { for (JobProgress progress : jobs.values()) { saveJobProgress(progress); } } } public boolean joinJob(Player player, String jobId) { if (!jobs.containsKey(jobId)) { return false; } UUID uuid = player.getUniqueId(); Map playerJobsMap = playerJobs.computeIfAbsent(uuid, k -> new HashMap<>()); if (playerJobsMap.size() >= maxJobsPerPlayer) { return false; } if (playerJobsMap.containsKey(jobId)) { return false; } playerJobsMap.put(jobId, new JobProgress(uuid, jobId)); return true; } public boolean leaveJob(Player player, String jobId) { UUID uuid = player.getUniqueId(); Map playerJobsMap = playerJobs.get(uuid); if (playerJobsMap == null || !playerJobsMap.containsKey(jobId)) { return false; } playerJobsMap.remove(jobId); plugin.getDatabaseManager().executeAsync( "DELETE FROM player_jobs WHERE uuid = ? AND job = ?", uuid.toString(), jobId ); return true; } public void addXp(Player player, String jobId, double amount) { JobProgress progress = getJobProgress(player.getUniqueId(), jobId); boolean leveledUp = progress.addXp(amount); if (leveledUp) { Map replacements = Map.of( "job", jobs.get(jobId).getName(), "level", String.valueOf(progress.getLevel()) ); plugin.getMessageManager().send(player, "jobs.level-up", replacements); } saveJobProgress(progress); } @EventHandler public void onBlockBreak(BlockBreakEvent event) { Player player = event.getPlayer(); UUID uuid = player.getUniqueId(); Map playerJobsMap = playerJobs.get(uuid); if (playerJobsMap == null) return; if (playerJobsMap.containsKey("miner")) { addXp(player, "miner", 5.0); } if (playerJobsMap.containsKey("lumberjack")) { addXp(player, "lumberjack", 5.0); } } @EventHandler public void onEntityDeath(EntityDeathEvent event) { if (event.getEntity().getKiller() instanceof Player player) { UUID uuid = player.getUniqueId(); Map playerJobsMap = playerJobs.get(uuid); if (playerJobsMap != null && playerJobsMap.containsKey("hunter")) { addXp(player, "hunter", 10.0); } } } public Collection getJobs() { return jobs.values(); } public Job getJob(String id) { return jobs.get(id); } public Map getPlayerJobs(UUID uuid) { return playerJobs.getOrDefault(uuid, new HashMap<>()); } }