package com.garnixmc.garnixclans.manager;

import com.garnixmc.garnixclans.object.Clan;
import com.garnixmc.garnixclans.object.ClanPlayer;
import org.bukkit.Bukkit;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import static com.garnixmc.garnixclans.GarnixClans.*;

public class ClanManager {

    private List<Clan> clans = new ArrayList<>();
    private List<ClanPlayer> clanPlayers = new ArrayList<>();

    public List<Clan> getClans() {
        return clans;
    }

    public List<ClanPlayer> getClanPlayers() {
        return clanPlayers;
    }

    public Clan getClanByTag(String tag) {
        return clans.stream().filter(clan -> clan.getTag().equalsIgnoreCase(tag)).findFirst().orElse(null);
    }

    public ClanPlayer getClanByPlayer(String player) {
        return clanPlayers.stream().filter(p -> p.getPlayerName().equalsIgnoreCase(player)).findFirst().orElse(null);
    }

    public boolean existsClan(String tag) {
        return getClanByTag(tag) != null;
    }

    public void loadAll() {
        try {
            clans.clear();
            clanPlayers.clear();
            Connection connection = getLocalService().connection;
            PreparedStatement preparedStatement = connection
                    .prepareStatement("select * from " + getLocalService().table_name);
            ResultSet resultSet = preparedStatement.executeQuery();
            while (resultSet.next()) {
                Clan clan = getClanByTag(resultSet.getString("tag"));
                if (clan == null) {
                    clan = new Clan(resultSet.getString("tag"),
                            resultSet.getString("colorTag"),
                            resultSet.getString("name"),
                            resultSet.getString("founded"),
                            resultSet.getDouble("bank"),
                            resultSet.getString("founder"),
                            null,
                            null);
                    clans.add(clan);
                }
            }
            PreparedStatement preparedStatement2 = connection
                    .prepareStatement("select * from " + getLocalService().table_name_2);
            ResultSet resultSet2 = preparedStatement2.executeQuery();
            while (resultSet2.next()) {
                ClanPlayer clanPlayer = getClanByPlayer(resultSet2.getString("playerName"));
                if (clanPlayer == null) {
                    clanPlayer = new ClanPlayer(resultSet2.getString("playerName"),
                            resultSet2.getString("clan"),
                            resultSet2.getString("lastLogin"),
                            resultSet2.getInt("neutralKills"),
                            resultSet2.getInt("civilKills"),
                            resultSet2.getInt("neutralDeaths"),
                            resultSet2.getInt("civilDeaths"), false);
                    clanPlayers.add(clanPlayer);
                }
            }
        } catch (
                Exception exception) {
            exception.printStackTrace();
        }
    }

    public void insertClan(String tag, String colorTag, String name, String founded, String founder) {
        Clan clan = new Clan(tag,
                colorTag,
                name, founded, 0D,
                founder,
                null,
                null);
        clans.add(clan);
        Bukkit.getScheduler().runTaskAsynchronously(getInstance(), () -> {
            try {
                Connection connection = getLocalService().connection;
                PreparedStatement preparedStatement = connection
                        .prepareStatement("insert into " + getLocalService().table_name
                                + " (tag, colorTag, name, founded, bank, founder, members, trusteds)" +
                                " VALUES (?,?,?,?,?,?,?,?)");
                preparedStatement.setString(1, tag);
                preparedStatement.setString(2, colorTag);
                preparedStatement.setString(3, name);
                preparedStatement.setString(4, founded);
                preparedStatement.setDouble(5, 0D);
                preparedStatement.setString(6, founder);
                preparedStatement.setString(7, "null");
                preparedStatement.setString(8, "null");
                preparedStatement.executeUpdate();
                preparedStatement.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        });
    }

    public void updateClan(Clan clan, boolean async) {
        if (async) {
            Bukkit.getScheduler().runTaskAsynchronously(getInstance(), () -> {
                try {
                    Connection connection = getLocalService().connection;
                    PreparedStatement preparedStatement = connection
                            .prepareStatement("update " + getLocalService().table_name_2
                                    + " set tag = ?, colorTag = ?,bank = ?, members = ?," +
                                    " trusteds = ? where founder = ?");
                    preparedStatement.setString(1, clan.getTag());
                    preparedStatement.setString(2, clan.getColorTag());
                    preparedStatement.setDouble(3, clan.getBank());
                    preparedStatement.setString(4, clan.getMembers() != null ? getApi().setSplited(clan.getMembers()) : null);
                    preparedStatement.setString(5, clan.getTrusteds() != null ? getApi().setSplited(clan.getTrusteds()) : null);
                    preparedStatement.setString(6, clan.getFounder());
                    preparedStatement.executeUpdate();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            });
        } else {
            try {
                Connection connection = getLocalService().connection;
                PreparedStatement preparedStatement = connection
                        .prepareStatement("update " + getLocalService().table_name_2
                                + " set tag = ?, colorTag = ?,bank = ?, members = ?," +
                                " trusteds = ? where founder = ?");
                preparedStatement.setString(1, clan.getTag());
                preparedStatement.setString(2, clan.getColorTag());
                preparedStatement.setDouble(3, clan.getBank());
                preparedStatement.setString(4, clan.getMembers() != null ? getApi().setSplited(clan.getMembers()) : null);
                preparedStatement.setString(5, clan.getTrusteds() != null ? getApi().setSplited(clan.getTrusteds()) : null);
                preparedStatement.setString(6, clan.getFounder());
                preparedStatement.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}