Complete
This commit is contained in:
Izzel_Aliz
@@ -0,0 +1,19 @@
|
||||
package com.ilummc.bugrepgui.bungee;
|
||||
|
||||
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
||||
import net.md_5.bungee.api.event.ChatEvent;
|
||||
import net.md_5.bungee.api.plugin.Listener;
|
||||
import net.md_5.bungee.event.EventHandler;
|
||||
|
||||
public class BungeeListener implements Listener {
|
||||
@EventHandler
|
||||
public void onChat(ChatEvent evt) {
|
||||
if (!(evt.getSender() instanceof ProxiedPlayer)) {
|
||||
return;
|
||||
}
|
||||
ProxiedPlayer p = (ProxiedPlayer) evt.getSender();
|
||||
if (Main.config.getString("stop-sign").equals(evt.getMessage())) {
|
||||
GlobalNotify.notifyt(p);
|
||||
}
|
||||
}
|
||||
}
|
||||
167
target/classes/com/ilummc/bugrepgui/bungee/GlobalNotify.java
Normal file
167
target/classes/com/ilummc/bugrepgui/bungee/GlobalNotify.java
Normal file
@@ -0,0 +1,167 @@
|
||||
package com.ilummc.bugrepgui.bungee;
|
||||
|
||||
import java.sql.Connection;
|
||||
import java.sql.DriverManager;
|
||||
import java.sql.ResultSet;
|
||||
import java.sql.SQLException;
|
||||
import java.sql.Statement;
|
||||
import java.util.Collection;
|
||||
import java.util.Iterator;
|
||||
|
||||
import com.ilummc.bugrepgui.Storage;
|
||||
|
||||
import net.md_5.bungee.api.connection.ProxiedPlayer;
|
||||
|
||||
public class GlobalNotify {
|
||||
private static Connection c = null;
|
||||
private static Statement state = null;
|
||||
public static String format = Main.lang.getString("join-notify");
|
||||
public static String format2 = Main.lang.getString("join-notify2");
|
||||
|
||||
public static void init() {
|
||||
Thread post = new Thread(new Runnable() {
|
||||
long spd = Main.config.getInt("check-speed");
|
||||
@Override
|
||||
public void run() {
|
||||
while (true) {
|
||||
Collection<ProxiedPlayer> l = Main.server.getPlayers();
|
||||
Iterator<ProxiedPlayer> it = l.iterator();
|
||||
while(it.hasNext()){
|
||||
ProxiedPlayer p = it.next();
|
||||
check(p.getName());
|
||||
try {
|
||||
Thread.sleep(spd);
|
||||
} catch (InterruptedException e) {
|
||||
Main.printException(e.getMessage());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
});
|
||||
post.start();
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation")
|
||||
public static void notifyt(ProxiedPlayer player) {
|
||||
Collection<ProxiedPlayer> l = Main.server.getPlayers();
|
||||
Iterator<ProxiedPlayer> it = l.iterator();
|
||||
while(it.hasNext()){
|
||||
ProxiedPlayer p = it.next();
|
||||
if(p.hasPermission("bugrepgui.notify")){
|
||||
p.sendMessage(Main.lang.getString("notify-op").replaceAll("%player%", player.getName()));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@SuppressWarnings("deprecation")
|
||||
public static void sends(String player, String[] msg){
|
||||
ProxiedPlayer p = Main.server.getPlayer(player);
|
||||
for (int i = 0; i < msg.length; i++) {
|
||||
if (msg[i] != null && msg[i] != "")
|
||||
p.sendMessage(getPrefix() + msg[i]);
|
||||
}
|
||||
}
|
||||
public static String getPrefix(){
|
||||
return Storage.compile(Main.lang.getString("prefix"));
|
||||
}
|
||||
public static void check(String player) {
|
||||
connect();
|
||||
String sql = "SELECT SERIAL,EXEMSG,EXENAME FROM br_bug WHERE REPNAME = '" + player
|
||||
+ "' AND (EXECUTED = 1 OR EXECUTED = 2) AND BACK = 0 ORDER BY SERIAL ASC;";
|
||||
String send[] = new String[12];
|
||||
Integer[] ser = new Integer[6];
|
||||
try {
|
||||
ResultSet res = state.executeQuery(sql);
|
||||
int limit = 0;
|
||||
while (((limit += 2) < 12) && res.next()) {
|
||||
Integer serial = res.getInt("SERIAL");
|
||||
String msg = res.getString("EXEMSG");
|
||||
String exename = res.getString("EXENAME");
|
||||
String str = format.replaceAll("%serial%", serial.toString()).replaceAll("%exename%", exename)
|
||||
.replaceAll("%reply%", msg);
|
||||
String str2 = format2.replaceAll("%serial%", serial.toString()).replaceAll("%exename%", exename)
|
||||
.replaceAll("%reply%", msg);
|
||||
send[limit - 2] = Storage.compile(str);
|
||||
send[limit - 1] = Storage.compile(str2);
|
||||
ser[limit / 2] = serial;
|
||||
}
|
||||
res.close();
|
||||
} catch (SQLException e) {
|
||||
Main.printException(e.getMessage());
|
||||
}
|
||||
sends(player, send);
|
||||
close();
|
||||
setback(ser);
|
||||
}
|
||||
|
||||
public static void setback(Integer[] ser) {
|
||||
connect();
|
||||
for (int i = 1; i < (ser.length) && (ser[i] != null); i++) {
|
||||
String sql2 = "UPDATE br_bug SET BACK = 1 WHERE SERIAL = " + ser[i].toString() + ";";
|
||||
try {
|
||||
state.executeUpdate(sql2);
|
||||
} catch (SQLException e) {
|
||||
Main.printException(e.getMessage());
|
||||
}
|
||||
}
|
||||
close();
|
||||
}
|
||||
|
||||
public static void setback(String ser) {
|
||||
connect();
|
||||
String sql = "UPDATE br_bug SET BACK = 1 WHERE SERIAL = " + ser + ";";
|
||||
try {
|
||||
state.executeUpdate(sql);
|
||||
} catch (SQLException e) {
|
||||
Main.printException(e.getMessage());
|
||||
}
|
||||
close();
|
||||
}
|
||||
|
||||
public static void connect() {
|
||||
if (!conMySQL()) {
|
||||
Main.log.warning("[BugRepGUI] MySQL connect failed!");
|
||||
Main.log.warning("**************************************************");
|
||||
Main.log.warning("[BugRepGUI] Must check the MySQL server settings!!");
|
||||
Main.log.warning("[BugRepGUI] Must check the MySQL server settings!!");
|
||||
Main.log.warning("**************************************************");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public static void close() {
|
||||
try {
|
||||
state.close();
|
||||
state = null;
|
||||
c.close();
|
||||
} catch (Exception e) {
|
||||
Main.printException(e.getMessage());
|
||||
}
|
||||
}
|
||||
public static boolean conMySQL() {
|
||||
String url = "jdbc:mysql://" + Main.config.getString("mysql-url") + ":"
|
||||
+ Main.config.getString("mysql-port") + "/" +Main.config.getString("mysql-db");
|
||||
try {
|
||||
Class.forName("com.mysql.jdbc.Driver");
|
||||
c = DriverManager.getConnection(url, Main.config.getString("mysql-username"),
|
||||
Main.config.getString("mysql-password"));
|
||||
state = c.createStatement();
|
||||
} catch (SQLException e) {
|
||||
Main.printException(e.getMessage());
|
||||
return false;
|
||||
} catch (ClassNotFoundException e) {
|
||||
Main.printException(e.getMessage());
|
||||
return false;
|
||||
}
|
||||
String sql = "CREATE TABLE IF NOT EXISTS br_bug " + "(SERIAL INT PRIMARY KEY AUTO_INCREMENT NOT NULL,"
|
||||
+ " REPNAME TEXT NOT NULL, " + " REPTIME TEXT NOT NULL, "
|
||||
+ " REPMSG TEXT NOT NULL, " + " EXENAME TEXT, " + " EXETIME TEXT, "
|
||||
+ " EXEMSG TEXT, " + " EXECUTED INT, " + " BACK INT);";
|
||||
try {
|
||||
state.executeUpdate(sql);
|
||||
} catch (SQLException e) {
|
||||
Main.printException(e.getMessage());
|
||||
}
|
||||
return true;
|
||||
}
|
||||
}
|
||||
84
target/classes/com/ilummc/bugrepgui/bungee/Main.java
Normal file
84
target/classes/com/ilummc/bugrepgui/bungee/Main.java
Normal file
@@ -0,0 +1,84 @@
|
||||
package com.ilummc.bugrepgui.bungee;
|
||||
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.nio.file.CopyOption;
|
||||
import java.nio.file.Files;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
import net.md_5.bungee.api.ProxyServer;
|
||||
import net.md_5.bungee.api.plugin.Plugin;
|
||||
import net.md_5.bungee.config.Configuration;
|
||||
import net.md_5.bungee.config.ConfigurationProvider;
|
||||
import net.md_5.bungee.config.YamlConfiguration;
|
||||
|
||||
public class Main extends Plugin {
|
||||
static Logger log;
|
||||
static File folder;
|
||||
static Configuration config;
|
||||
static Configuration lang;
|
||||
static File cf;
|
||||
static File lf;
|
||||
static ProxyServer server;
|
||||
|
||||
public void onEnable() {
|
||||
this.init(this.getDataFolder(), this.getLogger());
|
||||
this.getLogger().info("BungeeCord mode is on!");
|
||||
this.getProxy().getPluginManager().registerListener(this, new BungeeListener());
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onDisable() {
|
||||
try {
|
||||
ConfigurationProvider.getProvider(YamlConfiguration.class).save(config, cf);
|
||||
ConfigurationProvider.getProvider(YamlConfiguration.class).save(lang, lf);
|
||||
} catch (Exception e) {
|
||||
printException(e.getMessage());
|
||||
}
|
||||
this.getLogger().info("BugRepGUI disabled! Thanks for chosing us!");
|
||||
}
|
||||
|
||||
public void init(File f, Logger log) {
|
||||
if (!this.getDataFolder().exists()) {
|
||||
this.getDataFolder().mkdir();
|
||||
}
|
||||
Main.log = log;
|
||||
Main.folder = f;
|
||||
Main.server = this.getProxy();
|
||||
cf = new File(f + "/config.yml");
|
||||
try {
|
||||
if (!cf.exists()) {
|
||||
Files.copy(getResourceAsStream("config.yml"), cf.toPath(), new CopyOption[0]);
|
||||
}
|
||||
reloadConfig();
|
||||
lf = new File(f + "/lang_"+config.getString("lang")+".yml");
|
||||
if (!lf.exists()) {
|
||||
Files.copy(getResourceAsStream("lang_" + config.getString("lang") + ".yml"), lf.toPath(),
|
||||
new CopyOption[0]);
|
||||
}
|
||||
reloadLang();
|
||||
} catch (Exception e) {
|
||||
printException(e.getMessage());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
private void reloadConfig() {
|
||||
try {
|
||||
config = ConfigurationProvider.getProvider(YamlConfiguration.class).load(cf);
|
||||
} catch (IOException e) {
|
||||
printException(e.getMessage());
|
||||
}
|
||||
}
|
||||
private void reloadLang() {
|
||||
try {
|
||||
lang = ConfigurationProvider.getProvider(YamlConfiguration.class).load(lf);
|
||||
} catch (IOException e) {
|
||||
printException(e.getMessage());
|
||||
}
|
||||
}
|
||||
|
||||
public static void printException(String msg) {
|
||||
log.warning("Error: " + msg);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user