diff --git a/src/de/anura/core/events/VotifierListener.java b/src/de/anura/core/events/VotifierListener.java index 026c164..42b23fa 100644 --- a/src/de/anura/core/events/VotifierListener.java +++ b/src/de/anura/core/events/VotifierListener.java @@ -12,6 +12,9 @@ import java.io.ByteArrayOutputStream; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; +import java.io.OutputStream; +import java.io.PrintStream; +import java.net.Socket; import java.sql.ResultSet; import java.sql.SQLException; import org.bukkit.Bukkit; @@ -30,18 +33,21 @@ public class VotifierListener implements Listener, PluginMessageListener { public void onVotifierEvent(VotifierEvent event) { Vote vote = event.getVote(); String timestamp = vote.getTimeStamp(); - try { timestampInt = Integer.parseInt(timestamp); } catch (NumberFormatException ex) { timestampInt = (int) (System.currentTimeMillis() / 1000); } - addPlayerMoney(25, vote); + + System.out.println("Got vote from " + vote.getServiceName() + " Username: " + vote.getUsername() + " with Adress: " + vote.getAddress() + "@" + vote.getTimeStamp()); try { ResultSet rs1 = Core.getMySql().querySelect("SELECT * FROM `players` WHERE name = '" + vote.getUsername() + "'"); if (!rs1.next()) { + System.out.println("Database doesn't contain player!"); return; } + System.out.println("Found Player in Database!"); + addPlayerMoney(25, vote); playerId = rs1.getInt("id"); ResultSet rs2 = Core.getMySql().querySelect("SELECT * FROM `voteUsers` WHERE playerId = '" + playerId + "'"); if (rs2.first()) { @@ -66,9 +72,6 @@ public class VotifierListener implements Listener, PluginMessageListener { } public void addPlayerMoney(int money, Vote vote) { - /*if (Bukkit.getPlayer(vote.getUsername()) != null) { - Money.payMoney(Bukkit.getPlayer(vote.getUsername()), money); - } else {*/ try { ByteArrayOutputStream stream = new ByteArrayOutputStream(); DataOutputStream out = new DataOutputStream(stream); @@ -76,10 +79,21 @@ public class VotifierListener implements Listener, PluginMessageListener { out.writeUTF(vote.getUsername()); out.writeInt(money); - Iterables.get(AnuraCore.getInstance().getServer().getOnlinePlayers(), 0).sendPluginMessage(AnuraCore.getInstance(), "BungeeCord", stream.toByteArray()); + if (AnuraCore.getInstance().getServer().getOnlinePlayers().isEmpty()) { + Socket so = new Socket("localhost", 26656); + OutputStream os = so.getOutputStream(); + PrintStream ps = new PrintStream(os, true); + ps.println("X3Nw;a+F!R_p~(Wj#LZc"); + ps.println("vote"); + ps.println(vote.getUsername()); + ps.println(money + ""); + } else { + Player p = Iterables.get(AnuraCore.getInstance().getServer().getOnlinePlayers(), 0); + p.sendPluginMessage(AnuraCore.getInstance(), "BungeeCord", stream.toByteArray()); + } + } catch (Exception ex) { Errors.reportException(ex); - //} } } @@ -108,4 +122,4 @@ public class VotifierListener implements Listener, PluginMessageListener { } } -} \ No newline at end of file +}