Anura/AnuraCore
3
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

*Added socket function (not ready)

Browse Source
This commit is contained in:
Lukas
2015-01-04 22:29:47 +01:00
parent 7c39188903
commit 580ceca2f4
1 changed files with 22 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/de/anura/core/events/VotifierListener.java
View File

@@ -12,6 +12,9 @@ import java.io.ByteArrayOutputStream;
import java.io.DataInputStream; import java.io.DataInputStream;
import java.io.DataOutputStream; import java.io.DataOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintStream;
import java.net.Socket;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import org.bukkit.Bukkit; import org.bukkit.Bukkit;
@@ -30,18 +33,21 @@ public class VotifierListener implements Listener, PluginMessageListener {
public void onVotifierEvent(VotifierEvent event) { public void onVotifierEvent(VotifierEvent event) {
Vote vote = event.getVote(); Vote vote = event.getVote();
String timestamp = vote.getTimeStamp(); String timestamp = vote.getTimeStamp();
try { try {
timestampInt = Integer.parseInt(timestamp); timestampInt = Integer.parseInt(timestamp);
} catch (NumberFormatException ex) { } catch (NumberFormatException ex) {
timestampInt = (int) (System.currentTimeMillis() / 1000); 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 { try {
ResultSet rs1 = Core.getMySql().querySelect("SELECT * FROM `players` WHERE name = '" + vote.getUsername() + "'"); ResultSet rs1 = Core.getMySql().querySelect("SELECT * FROM `players` WHERE name = '" + vote.getUsername() + "'");
if (!rs1.next()) { if (!rs1.next()) {
System.out.println("Database doesn't contain player!");
return; return;
} }
System.out.println("Found Player in Database!");
addPlayerMoney(25, vote);
playerId = rs1.getInt("id"); playerId = rs1.getInt("id");
ResultSet rs2 = Core.getMySql().querySelect("SELECT * FROM `voteUsers` WHERE playerId = '" + playerId + "'"); ResultSet rs2 = Core.getMySql().querySelect("SELECT * FROM `voteUsers` WHERE playerId = '" + playerId + "'");
if (rs2.first()) { if (rs2.first()) {
@@ -66,9 +72,6 @@ public class VotifierListener implements Listener, PluginMessageListener {
} }
public void addPlayerMoney(int money, Vote vote) { public void addPlayerMoney(int money, Vote vote) {
/*if (Bukkit.getPlayer(vote.getUsername()) != null) {
Money.payMoney(Bukkit.getPlayer(vote.getUsername()), money);
} else {*/
try { try {
ByteArrayOutputStream stream = new ByteArrayOutputStream(); ByteArrayOutputStream stream = new ByteArrayOutputStream();
DataOutputStream out = new DataOutputStream(stream); DataOutputStream out = new DataOutputStream(stream);
@@ -76,10 +79,21 @@ public class VotifierListener implements Listener, PluginMessageListener {
out.writeUTF(vote.getUsername()); out.writeUTF(vote.getUsername());
out.writeInt(money); 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) { } catch (Exception ex) {
Errors.reportException(ex); Errors.reportException(ex);
//}
} }
} }