package Test;
import java.sql.ResultSet;
import java.sql.SQLException;
import net.risingworld.api.Plugin;
import net.risingworld.api.Server;
import net.risingworld.api.database.Database;
import net.risingworld.api.events.EventMethod;
import net.risingworld.api.events.Listener;
import net.risingworld.api.events.player.PlayerCommandEvent;
import net.risingworld.api.events.player.PlayerSpawnEvent;
import net.risingworld.api.objects.Player;


public class Test extends Plugin implements Listener{
   protected Database db    = null;
    @Override
    public void onEnable()
    {

        Database db = getSQLiteConnection(getPath() + "/users/Money.db");

        db.execute("CREATE TABLE IF NOT EXISTS 'Money' ('player_name' CHAR(64) NOT NULL DEFAULT ('[NoName]'), 'Player_money' INTEGER NOT NULL DEFAULT ( 0 ));");
//      db.close();
        registerEventListener(this);

    }
    @Override
    public void onDisable()
    {
        if (db != null)

            db.close();
    }
@EventMethod
public void onSpawn(PlayerSpawnEvent event) throws SQLException
{
        Player p = event.getPlayer();
   String playerName = p.getName();
   String query = "INSERT INTO Money ('player_name', 'Player_money') VALUES ('"+playerName+"', 2000);";


    }



@EventMethod
  public void onCommand(PlayerCommandEvent event) throws SQLException
          {
      Player p = event.getPlayer();
       String playerName = p.getName();
    Database db = getSQLiteConnection(getPath() + "/users/Money.db");
    String query = "SELECT * FROM Money WHERE 'player_name' = '"+playerName+"'";
            try (ResultSet result = db.executeQuery(query))
        {
            //String fromwhom = result.getString("player_name");
            if(result.next())
            {
                String Money_Player = result.getString("player_name");
                                 p.sendTextMessage("EB: "+Money_Player);
                int Money_Money = result.getInt("player_money");
                                p.setAttribute("money",Money_Money);
                        }
        }
                        catch (SQLException e)
        {
            e.printStackTrace();
        }


    String command = event.getCommand();
    Server server = getServer();
    String[] cmd = command.split(" ");
    if (cmd[0].equals("/help"))
    {
      String helpme = command.substring(6);
      p.sendTextMessage(helpme);
      if (cmd.length > 1) {
        if (helpme.equals("mail"))
        {
          p.sendTextMessage(helpme);
         int money =(int)p.getAttribute("money");
          p.sendTextMessage("EB: "+money);
          p.sendTextMessage("/mail (To player) - will allow you to Write a Message to a player");
          p.sendTextMessage("/read Reads your messages)");
        }
        else if (helpme.equals("Effnet"))
        {
          p.sendTextMessage("/en Drink Will Quench Your Thirst for 50 EffBucks");
          p.sendTextMessage("/en FeedMe will Fill your Hunger for 50 EffBucks");
          p.sendTextMessage("@user will send a Private Message to a user)");
          p.sendTextMessage("/transfer xx to player will Transfer xx Amt of Effbucks to that Plsyer.");
        }
      }
    }
    else if (cmd[0].equals("/en"))
    {
      String ECmd = command.substring(4);
      p.sendTextMessage(ECmd);
      if (cmd.length > 1) {
        if (ECmd.equals("Drink"))
        {


          server.broadcastTextMessage("[#58ca32]" + playerName + "[#6878f5] Drinks up!");
          db.executeUpdate("UPDATE Money SET player_name = '"+playerName+"', Player_money=666 WHERE player_name = '"+playerName+"'");


          //db.executeUpdate ("INSERT INTO EffNet ('Player_user','Player_money') VALUES ('"+playerName+"','"+totalmoney+"');");
          p.setThirst(100);
         // p.sendTextMessage(WDP);
        }
        else if (ECmd.equals("FeedMe"))
        {
          p.sendTextMessage("Yummy!g!");
          server.broadcastTextMessage("[#58ca32]" + playerName + "[#6878f5] Odered a Pizza From Mario's Perfect Pizza!");
          p.setHunger(100);

        }
      }
    }

}

}