This commit is contained in:
Coloryr committed 2020-05-02 23:32:23 +08:00
1 parent 1fe3e096c6
commit 47a7ea7ee5
9 files changed
+76 -37

No files matched your search

@@ -21,6 +21,8 @@ public interface ISide {
boolean SendList(String data);
void SendAll();
void Clear(String player);
void ClearAll();
@@ -278,17 +278,20 @@ public class CommandEX {
} else if (args.length != 4) {
AllMusic.Side.SendMessage(sender, AllMusic.getMessage().getCommand().getError());
} else {
PosOBJ obj = SendInfo.SetPot(Name, args[1], args[2], args[3]);
if (obj == null) {
try {
PosOBJ obj = SendInfo.SetPot(Name, args[1], args[2], args[3]);
if (obj == null) {
AllMusic.Side.SendMessage(sender, AllMusic.getMessage().getCommand().getError());
} else {
String temp = AllMusic.getMessage().getHud().getSet()
.replace("%Hud%", args[1])
.replace("%x%", args[2])
.replace("%y%", args[3]);
AllMusic.Side.SendMessage(sender, temp);
}
} catch (Exception e) {
AllMusic.Side.SendMessage(sender, AllMusic.getMessage().getCommand().getError());
} else {
String temp = AllMusic.getMessage().getHud().getSet()
.replace("%Hub%", args[1])
.replace("%x%", args[2])
.replace("%y%", args[3]);
AllMusic.Side.SendMessage(sender, temp);
}
}
}
} else if (AllMusic.getConfig().isNeedPermission() && AllMusic.Side.checkPermission(Name, "AllMusic.addmusic"))
@@ -4,6 +4,7 @@ import Color_yr.AllMusic.AllMusic;
import Color_yr.AllMusic.MusicPlay.SendInfo.SendInfo;
import net.md_5.bungee.api.connection.ProxiedPlayer;
import net.md_5.bungee.api.event.PlayerDisconnectEvent;
import net.md_5.bungee.api.event.PostLoginEvent;
import net.md_5.bungee.api.plugin.Listener;
import net.md_5.bungee.event.EventHandler;
@@ -12,11 +13,4 @@ public class EventBC implements Listener {
public void onPlayerquit(final PlayerDisconnectEvent event) {
AllMusic.removeNowPlayPlayer(event.getPlayer().getName());
}
@EventHandler
public void onPlayerJoin(net.md_5.bungee.api.event.PostLoginEvent e) {
ProxiedPlayer player = e.getPlayer();
String Name = player.getName();
SendInfo.SendSave(Name);
}
}
@@ -15,11 +15,4 @@ public class EventBukkit implements Listener {
public void onPlayerQuit(final PlayerQuitEvent e) {
AllMusic.removeNowPlayPlayer(e.getPlayer().getName());
}
@EventHandler
public void onPlayJoin(PlayerJoinEvent e) {
Player player = e.getPlayer();
String Name = player.getName();
SendInfo.SendSave(Name);
}
}
@@ -65,6 +65,7 @@ class PlayGo extends Thread {
PlayMusic.nowLyric = null;
PlayMusic.NowPlayMusic = null;
closeTimer();
SendInfo.clear();
}
@Override
@@ -108,6 +109,7 @@ class PlayGo extends Thread {
AllMusic.Side.bqt(info);
startTimer();
AllMusic.Side.Send("[Play]" + url, true);
AllMusic.Side.SendAll();
try {
while (PlayMusic.MusicAllTime > 0) {
SendInfo.SendNowData();
@@ -11,7 +11,7 @@ public class SaveOBJ {
public SaveOBJ() {
EnableList = false;
List = new PosOBJ(2, 80);
Lyric = new PosOBJ(2, 40);
Lyric = new PosOBJ(2, 55);
Info = new PosOBJ(2, 2);
}
@@ -155,19 +155,21 @@ public class SendInfo {
}
public static void SendSave(String Name) {
try {
Thread.sleep(3000);
SaveOBJ obj = AllMusic.getConfig().getInfoSave(Name);
if (obj == null) {
obj = new SaveOBJ();
AllMusic.getConfig().setInfoSave(obj, Name);
AllMusic.save();
AllMusic.Side.RunTask(()-> {
try {
Thread.sleep(2000);
SaveOBJ obj = AllMusic.getConfig().getInfoSave(Name);
if (obj == null) {
obj = new SaveOBJ();
AllMusic.getConfig().setInfoSave(obj, Name);
AllMusic.save();
}
String data = new Gson().toJson(obj);
AllMusic.Side.Send(data, Name, null);
} catch (Exception e1) {
AllMusic.log.warning("§d[AllMusic]§c数据发送发生错误");
e1.printStackTrace();
}
String data = new Gson().toJson(obj);
AllMusic.Side.Send(data, Name, null);
} catch (Exception e1) {
AllMusic.log.warning("§d[AllMusic]§c数据发送发生错误");
e1.printStackTrace();
}
});
}
}
@@ -4,6 +4,7 @@ import Color_yr.AllMusic.API.ISide;
import Color_yr.AllMusic.AllMusic;
import Color_yr.AllMusic.AllMusicBC;
import Color_yr.AllMusic.MusicPlay.SendInfo.SaveOBJ;
import com.google.gson.Gson;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import net.md_5.bungee.api.CommandSender;
@@ -151,6 +152,27 @@ public class SideBC implements ISide {
return Save;
}
@Override
public void SendAll() {
Collection<ProxiedPlayer> values = ProxyServer.getInstance().getPlayers();
for (ProxiedPlayer players : values) {
String Name = players.getName();
try {
SaveOBJ obj = AllMusic.getConfig().getInfoSave(Name);
if (obj == null) {
obj = new SaveOBJ();
AllMusic.getConfig().setInfoSave(obj, Name);
AllMusic.save();
}
String data = new Gson().toJson(obj);
Send(data, Name, null);
} catch (Exception e1) {
AllMusic.log.warning("§d[AllMusic]§c数据发送发生错误");
e1.printStackTrace();
}
}
}
@Override
public void Clear(String player) {
Send("[clear]", player, null);
@@ -4,6 +4,7 @@ import Color_yr.AllMusic.API.ISide;
import Color_yr.AllMusic.AllMusic;
import Color_yr.AllMusic.AllMusicBukkit;
import Color_yr.AllMusic.MusicPlay.SendInfo.SaveOBJ;
import com.google.gson.Gson;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import net.md_5.bungee.api.chat.ClickEvent;
@@ -124,6 +125,26 @@ public class SideBukkit implements ISide {
return Save;
}
@Override
public void SendAll() {
for (Player player : Bukkit.getOnlinePlayers()) {
String Name = player.getName();
try {
SaveOBJ obj = AllMusic.getConfig().getInfoSave(Name);
if (obj == null) {
obj = new SaveOBJ();
AllMusic.getConfig().setInfoSave(obj, Name);
AllMusic.save();
}
String data = new Gson().toJson(obj);
Send(data, Name, null);
} catch (Exception e1) {
AllMusic.log.warning("§d[AllMusic]§c数据发送发生错误");
e1.printStackTrace();
}
}
}
@Override
public void Clear(String player) {
Send("[clear]", player, null);