package basic.bukkit;

import java.sql.Connection;
import java.sql.DriverManager;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.bukkit.Bukkit;
import org.bukkit.ChatColor;
import org.bukkit.command.Command;
import org.bukkit.command.CommandSender;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.player.PlayerJoinEvent;
import org.bukkit.plugin.java.JavaPlugin;



public class main extends JavaPlugin implements Listener
 {

    public void onEnable() {
        getServer().getPluginManager().registerEvents(this,this);

    }
    public void disEnable() {


    }
    @EventHandler
    public void onPlayerJoin(PlayerJoinEvent e) {//玩家加入取得基本資料
       Player p = e.getPlayer();

       String name = p.getName();
       String uuid=p.getPlayer().getUniqueId().toString();
       String ip = e.getPlayer().getAddress().getHostString();
       setplayer(name,ip,uuid);



    }

    public void setplayer(String name,String ip,String uuid){     //建立玩家基本資料


      try{
          Connection connection = DriverManager.getConnection("jdbc:mysql://localhost/minecraft?useSSL=false", "root", "pass");
            if(!Find("player","uid",uuid)){

                Statement stat = connection.createStatement();
                stat.executeUpdate( "INSERT INTO player(player_name,ipv4,uid) VALUES (" +" ' "+name+" ' "+", '"+ip+"' ,"+"'"+uuid+"'"+")");
                setplayermoney(name);


        }


      }
         catch(SQLException e1) {
            e1.printStackTrace();
         }
    }
    public void setplayermoney(String name) {//新增玩家初始金額
        try{
              Connection connection = DriverManager.getConnection("jdbc:mysql://localhost/money?useSSL=false", "root", "pass");

              String date=getDateTime();

              Statement stat = connection.createStatement();
              stat.executeUpdate("CREATE TABLE " +name+ "(date datetime, pay integer,income integer,who char(20),Totalassets integer)");


              stat.executeUpdate("INSERT INTO"+" "+name+"(date,pay,income,who,Totalassets) VALUES (" +" ' "+date+" ' "+",0,0,"+" ' "+name+" ' ,"+50+")");





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

    }

    public boolean Find(String x,String y,String z){//搜尋器
        try{
            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost/minecraft?useSSL=false", "root", "pass");
            Statement statement = connection.createStatement();
            ResultSet resultSet = null;
            String selectSql="SELECT * FROM "+ x + " WHERE "+  y+"= '"+z+" ' ";
            resultSet = statement.executeQuery(selectSql);



            boolean canFind = resultSet.next();

            return canFind;
        }catch(SQLException e){
            e.printStackTrace();
            return false;
        }
    }
    public String getDateTime(){//取得現在時間
        SimpleDateFormat sdFormat = new SimpleDateFormat("yyyy/MM/dd hh:mm:ss");
        Date date = new Date();
        String strDate = sdFormat.format(date);
        //System.out.println(strDate);
        return strDate;
        }
    public  boolean onCommand(CommandSender sender ,Command cmd,String cmdlable,String[] args)//指令庫
    {
        Player p = (Player) sender;
        if(cmdlable.equals("bal"))
        {
            bal(p);
            return true;
        }
        else if(cmdlable.equals("pay"))
        {
            p.sendMessage(args[0]);
            Player p2 = Bukkit.getPlayer(args[0]); //args[0]=玩家名字
            String income=args[1];


            if(p2==null) {//該玩家不存在
                p.sendMessage(ChatColor.RED+"該玩家不存在或是不再線上");
            }
            else
            {
                try{

                  int changearg = Integer.parseInt(income);



                  pay(p,p2,changearg);

                }catch(NumberFormatException e){

                   p.sendMessage(ChatColor.RED+"輸入轉帳金額錯誤");
                }

            }
            return true;
        }

        return false;
    }

    public void bal(Player p) {//查詢金額
        try{

            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost/money?useSSL=false", "root", "pass");
            String query = "SELECT `Totalassets` FROM `"+p.getName()+"` ORDER BY date DESC LIMIT 0 , 1";
            Statement stmt = connection.createStatement();
            ResultSet rs = stmt.executeQuery(query);
              while (rs.next()) {
                        int Totalassets= rs.getInt("Totalassets");
                        p.sendMessage(ChatColor.GREEN+"您的帳戶總額:"+ChatColor.YELLOW+Totalassets);

                    }

            rs.close();
            stmt.close();
          }
             catch(SQLException e1) {
                e1.printStackTrace();
             }


    }
    public void pay(Player p, Player p2, int income)//付款
    {
        try{

            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost/money?useSSL=false", "root", "pass");
            String query = "SELECT `Totalassets` FROM `"+p.getName()+"` ORDER BY date DESC LIMIT 0 , 1";
            Statement stmt = connection.createStatement();
            ResultSet rs = stmt.executeQuery(query);
              while (rs.next()) {
                       int Totalassets= rs.getInt("Totalassets");
                       if(Totalassets<income)
                       {
                           p.sendMessage(ChatColor.RED+"餘額不足");
                       }
                       else
                       {

                           String date=getDateTime();
                           Totalassets-=income;
                           stmt.executeUpdate("INSERT INTO"+" "+p.getName()+"(date,pay,income,who,Totalassets) VALUES (" +" ' "+date+" ' "+","+income+","+"0"+","+" ' "+p2.getName()+" ' ,"+Totalassets+")");
                           pay2(p,p2,income);

                           p.sendMessage(ChatColor.WHITE+"您像 "+p2.getName()+" 支付了 "+income+" 元");
                           p.sendMessage(ChatColor.GREEN+"交易成功:已從 "+ChatColor.YELLOW+p.getName()+ChatColor.GREEN+" 的帳戶轉移 "+ChatColor.YELLOW+ income+ChatColor.GREEN+" 元 至 "+ChatColor.YELLOW+p2.getName()+ChatColor.GREEN+" 的帳戶");

                       }


                    }


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

    }
    public void pay2(Player p, Player p2, int income)//付款
    {
        try{

            Connection connection = DriverManager.getConnection("jdbc:mysql://localhost/money?useSSL=false", "root", "pass");
            String query = "SELECT `Totalassets` FROM `"+p2.getName()+"` ORDER BY date DESC LIMIT 0 , 1";
            Statement stmt = connection.createStatement();
            ResultSet rs = stmt.executeQuery(query);
              while (rs.next()) {
                  String date=getDateTime();
                  int Totalassets= rs.getInt("Totalassets");
                  Totalassets+=income;
                  stmt.executeUpdate("INSERT INTO"+" "+p2.getName()+"(date,pay,income,who,Totalassets) VALUES (" +" ' "+date+" ' "+",0,"+income+","+" ' "+p.getName()+" ' ,"+Totalassets+")");
                  p.sendMessage(ChatColor.GREEN+"交易成功:已從 "+ChatColor.YELLOW+p.getName()+ChatColor.GREEN+" 的帳戶轉移 "+ChatColor.YELLOW+ income+ChatColor.GREEN+" 元 至 "+ChatColor.YELLOW+p2.getName()+ChatColor.GREEN+" 的帳戶");

                    }


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

    }



}