package de.teamsoul.main.mysql;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class methoden_coinsystem {

    public static boolean UserExists(String UID) {
        try {
            PreparedStatement ps = mysql.getConnection().prepareStatement("SELECT * FROM CoinSystem WHERE UID = ?");
            ps.setString(1, UID);
            ResultSet rs = ps.executeQuery();
            return rs.next();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;
    }

    public static void addCoins(int Coins, String UID, String Name) {

        if (UserExists(UID)) {

            try {
                PreparedStatement ps_upCoins = mysql.getConnection().prepareStatement("UPDATE CoinSystem SET Coins = Coins + ? WHERE UID = ?");
                ps_upCoins.setInt(1, Coins);
                ps_upCoins.setString(2, UID);
                ps_upCoins.executeUpdate();

                PreparedStatement ps_upName = mysql.getConnection().prepareStatement("UPDATE CoinSystem SET Name = ? WHERE UID = ?");
                ps_upName.setString(1, Name);
                ps_upName.setString(2, UID);
                ps_upName.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }

        } else {

            try {
                PreparedStatement ps = mysql.getConnection().prepareStatement("INSERT INTO CoinSystem (Name,UID,Coins,DailyCoinsAvailable) VALUES (?,?,?,?)");
                ps.setString(1, Name);
                ps.setString(2, UID);
                ps.setInt(3, Coins);
                ps.setBoolean(4, true);
                ps.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }

        }

    }

    public static void removeCoins(String UID, int Coins) {
        if (UserExists(UID)) {
            try {
                    PreparedStatement ps_remove = mysql.getConnection().prepareStatement("UPDATE CoinSystem SET Coins = Coins - ? WHERE UID = ?");
                    ps_remove.setInt(1, Coins);
                    ps_remove.setString(2, UID);
                    ps_remove.executeUpdate();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static int getConis(String UID) {
        try {
            PreparedStatement ps = mysql.getConnection().prepareStatement("SELECT Coins FROM CoinSystem WHERE UID = ?");
            ps.setString(1, UID);

            ResultSet rs = ps.executeQuery();
            if (rs.next()) {
                return rs.getInt("Coins");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return -1;
    }

    public static boolean ifDailyBonusAvailable(String UID) {
        try {
            PreparedStatement ps = mysql.getConnection().prepareStatement("SELECT DailyCoinsAvailable FROM CoinSystem WHERE UID = ?");
            ps.setString(1, UID);
            ResultSet rs = ps.executeQuery();
            if (rs.next()) {
                return rs.getBoolean("DailyCoinsAvailable");
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;
    }

    public static void deactivateDailyBonus(String UID) {
        try {
            PreparedStatement ps = mysql.getConnection().prepareStatement("UPDATE `CoinSystem` SET `DailyCoinsAvailable`='0' WHERE UID = ?");
            ps.setString(1, UID);
            ps.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }

    public static void activateAllDilayBonusses() {
        try {

            PreparedStatement ps = mysql.getConnection().prepareStatement("UPDATE `CoinSystem` SET DailyCoinsAvailable = true WHERE DailyCoinsAvailable = false");
            ps.executeUpdate();

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}