1
mirror of https://github.com/CarmJos/UltraDepository.git synced 2026-06-05 00:58:22 +08:00

Compare commits

...

5 Commits

Author SHA1 Message Date
carm afd62a493d [v1.3.3] 版本更新
- [A] 支持通过 PlugMan 等插件进行热重载。
2022-01-21 23:19:09 +08:00
carm c841a7b1b3 [v1.3.2] 版本更新
- [F] 修复Javadoc错误
2022-01-21 13:13:43 +08:00
carm dc57e822b5 [v1.3.1] 版本更新
- [F] 修复Javadoc错误
2022-01-21 13:09:45 +08:00
carm 54cc9c070b [v1.3.1] 版本更新
- [U] 修改预测仓库配置文件的位置,使其在初次启动时自动生成,避免用户完全不知道还有预设仓库这回事。
2022-01-21 13:03:43 +08:00
carm fa07564548 [v1.3.0] [A] 添加Java注释,修改debug消息位置。 2022-01-17 13:54:32 +08:00
13 changed files with 87 additions and 25 deletions
+4 -4
View File
@@ -17,18 +17,18 @@
## 预设配置截图 ## 预设配置截图
### 渔夫仓库 ([fishman.yml](files/fishman.yml)) ### 渔夫仓库 ([fishman.yml](../../src/main/resources/depositories/fishman.yml))
![fishman](images/fishman.png) ![fishman](images/fishman.png)
### 矿工仓库 ([miner.yml](files/miner.yml)) ### 矿工仓库 ([miner.yml](../../src/main/resources/depositories/miner.yml))
![miner](images/miner.png) ![miner](images/miner.png)
### 农夫仓库 ([farmer.yml](files/farmer.yml)) ### 农夫仓库 ([farmer.yml](../../src/main/resources/depositories/farmer.yml))
![farmer](images/farmer.png) ![farmer](images/farmer.png)
### 猎人仓库 ([hunter.yml](files/hunter.yml)) ### 猎人仓库 ([hunter.yml](../../src/main/resources/depositories/hunter.yml))
![hunter](images/hunter.png) ![hunter](images/hunter.png)
+2 -2
View File
@@ -32,7 +32,7 @@
进入仓库后的物品玩家可以选择拿出或直接按量出售,且每日的出售数量上限和每件物品的价格可以自定义。 进入仓库后的物品玩家可以选择拿出或直接按量出售,且每日的出售数量上限和每件物品的价格可以自定义。
插件支持针对不同的权限配置仓库的容量,由此可以制作付费享用的”农业仓库“、”战斗仓库“、”伐木仓库“... 插件支持针对不同的权限配置仓库的容量,由此可以制作付费享用的”作物仓库“、”药剂师仓库“、”伐木仓库“...
综上,该插件不但提供了一种功能特权,对其合理配置之后也将大大为玩家带来便利。 综上,该插件不但提供了一种功能特权,对其合理配置之后也将大大为玩家带来便利。
@@ -218,7 +218,7 @@
文件名即仓库的ID,**强烈推荐使用纯英文**。以`.`开头的仓库配置不会被加载。部分符号可能会影响正常读取,请避免使用。 文件名即仓库的ID,**强烈推荐使用纯英文**。以`.`开头的仓库配置不会被加载。部分符号可能会影响正常读取,请避免使用。
随本项目预设了几个常用的仓库类型,可以 [在这里](.examples/depositories) 找到您需要的仓库配置加以修改后使用。 随本项目预设了几个常用的仓库类型,可以 [在这里](.examples/depositories) 直接下载您需要的仓库配置加以修改后使用。
您也可以 [点击这里](src/main/resources/depositories/.example-depository.yml) 查看一份*详细的仓库配置示例*,以制作您自己的仓库。 您也可以 [点击这里](src/main/resources/depositories/.example-depository.yml) 查看一份*详细的仓库配置示例*,以制作您自己的仓库。
+1 -1
View File
@@ -15,7 +15,7 @@
<groupId>cc.carm.plugin</groupId> <groupId>cc.carm.plugin</groupId>
<artifactId>ultradepository</artifactId> <artifactId>ultradepository</artifactId>
<packaging>jar</packaging> <packaging>jar</packaging>
<version>1.2.6</version> <version>1.3.3</version>
<name>UltraDepository</name> <name>UltraDepository</name>
<description>超级仓库插件,支持设定不同物品的存储仓库。</description> <description>超级仓库插件,支持设定不同物品的存储仓库。</description>
@@ -60,9 +60,6 @@ public class UltraDepository extends EasyPlugin {
return false; return false;
} }
log("加载用户系统...");
userManager = new UserManager();
log("加载经济系统..."); log("加载经济系统...");
if (Bukkit.getPluginManager().getPlugin("Vault") != null) { if (Bukkit.getPluginManager().getPlugin("Vault") != null) {
economyManager = new EconomyManager(); economyManager = new EconomyManager();
@@ -76,11 +73,15 @@ public class UltraDepository extends EasyPlugin {
log("加载仓库管理器..."); log("加载仓库管理器...");
depositoryManager = new DepositoryManager(); depositoryManager = new DepositoryManager();
getDepositoryManager().loadDepositories(); getDepositoryManager().loadDepositories();
GUI.initialize(this);
log("加载用户系统...");
userManager = new UserManager();
log("注册监听器..."); log("注册监听器...");
regListener(new UserListener()); regListener(new UserListener());
regListener(new CollectListener()); regListener(new CollectListener());
GUI.initialize(this);
log("注册指令..."); log("注册指令...");
registerCommand("UltraDepository", new DepositoryCommand()); registerCommand("UltraDepository", new DepositoryCommand());
@@ -107,6 +108,9 @@ public class UltraDepository extends EasyPlugin {
else return plugin.getDescription().getVersion(); else return plugin.getDescription().getVersion();
})); }));
} }
getUserManager().loadPlayersData();
return true; return true;
} }
@@ -123,6 +127,7 @@ public class UltraDepository extends EasyPlugin {
log("卸载监听器..."); log("卸载监听器...");
Bukkit.getServicesManager().unregisterAll(this); Bukkit.getServicesManager().unregisterAll(this);
} }
public static DataStorage getStorage() { public static DataStorage getStorage() {
@@ -95,4 +95,8 @@ public class PluginMessages extends MessagesRoot {
"&f数目输入错误,请输入正确的数字!" "&f数目输入错误,请输入正确的数字!"
); );
public static final EasyMessage LOAD_FAILED = new EasyMessage(
"&c您的背包数据未被正确加载,请重新进入!"
);
} }
@@ -1,6 +1,7 @@
package cc.carm.plugin.ultradepository.listener; package cc.carm.plugin.ultradepository.listener;
import cc.carm.plugin.ultradepository.UltraDepository; import cc.carm.plugin.ultradepository.UltraDepository;
import cc.carm.plugin.ultradepository.configuration.PluginMessages;
import cc.carm.plugin.ultradepository.data.UserData; import cc.carm.plugin.ultradepository.data.UserData;
import org.bukkit.entity.Player; import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler; import org.bukkit.event.EventHandler;
@@ -19,15 +20,13 @@ public class UserListener implements Listener {
if (event.getLoginResult() != AsyncPlayerPreLoginEvent.Result.ALLOWED) { if (event.getLoginResult() != AsyncPlayerPreLoginEvent.Result.ALLOWED) {
return; return;
} }
UUID uuid = event.getUniqueId(); UltraDepository.getUserManager().loadDataCache(event.getUniqueId());
UltraDepository.getInstance().debug("尝试加载玩家 " + event.getName() + " 的数据...");
UltraDepository.getUserManager().getDataCache().put(uuid, UltraDepository.getUserManager().loadData(uuid));
} }
@EventHandler(priority = EventPriority.MONITOR) @EventHandler(priority = EventPriority.MONITOR)
public void onPreLoginMonitor(AsyncPlayerPreLoginEvent event) { public void onPreLoginMonitor(AsyncPlayerPreLoginEvent event) {
if (event.getLoginResult() != AsyncPlayerPreLoginEvent.Result.ALLOWED) { if (event.getLoginResult() != AsyncPlayerPreLoginEvent.Result.ALLOWED) {
UltraDepository.getUserManager().getDataCache().remove(event.getUniqueId()); UltraDepository.getUserManager().removeDataCache(event.getUniqueId());
} }
} }
@@ -36,7 +35,7 @@ public class UserListener implements Listener {
UserData data = UltraDepository.getUserManager().getData(e.getPlayer().getUniqueId()); UserData data = UltraDepository.getUserManager().getData(e.getPlayer().getUniqueId());
if (data == null) { if (data == null) {
e.setResult(PlayerLoginEvent.Result.KICK_OTHER); e.setResult(PlayerLoginEvent.Result.KICK_OTHER);
e.setKickMessage(UltraDepository.getInstance().getName() + " 数据未被正确加载,请重新进入。"); e.setKickMessage(PluginMessages.LOAD_FAILED.get(e.getPlayer()));
} }
} }
@@ -44,7 +43,8 @@ public class UserListener implements Listener {
public void onQuit(PlayerQuitEvent event) { public void onQuit(PlayerQuitEvent event) {
Player player = event.getPlayer(); Player player = event.getPlayer();
UUID playerUUID = player.getUniqueId(); UUID playerUUID = player.getUniqueId();
UltraDepository.getInstance().getScheduler().runAsync(() -> UltraDepository.getUserManager().unloadData(playerUUID, true)); UltraDepository.getInstance().getScheduler()
.runAsync(() -> UltraDepository.getUserManager().unloadData(playerUUID, true));
} }
} }
@@ -6,6 +6,7 @@ import cc.carm.plugin.ultradepository.configuration.PluginMessages;
import cc.carm.plugin.ultradepository.configuration.depository.Depository; import cc.carm.plugin.ultradepository.configuration.depository.Depository;
import cc.carm.plugin.ultradepository.configuration.depository.DepositoryItem; import cc.carm.plugin.ultradepository.configuration.depository.DepositoryItem;
import cc.carm.plugin.ultradepository.event.DepositoryCollectItemEvent; import cc.carm.plugin.ultradepository.event.DepositoryCollectItemEvent;
import cc.carm.plugin.ultradepository.util.JarUtil;
import com.google.common.collect.HashMultimap; import com.google.common.collect.HashMultimap;
import org.bukkit.Bukkit; import org.bukkit.Bukkit;
import org.bukkit.Material; import org.bukkit.Material;
@@ -18,6 +19,7 @@ import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
import java.io.File; import java.io.File;
import java.io.IOException;
import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@@ -46,9 +48,13 @@ public class DepositoryManager {
if (!folder.exists()) { if (!folder.exists()) {
folder.mkdir(); folder.mkdir();
UltraDepository.getInstance().saveResource( try {
"depositories/.example-depository.yml", false JarUtil.copyFolderFromJar(
); "depositories", UltraDepository.getInstance().getDataFolder(),
JarUtil.CopyOption.COPY_IF_NOT_EXIST
);
} catch (IOException ignore) {
}
} else if (folder.isDirectory()) { } else if (folder.isDirectory()) {
folder.delete(); folder.delete();
@@ -4,6 +4,7 @@ import cc.carm.plugin.ultradepository.UltraDepository;
import cc.carm.plugin.ultradepository.data.UserData; import cc.carm.plugin.ultradepository.data.UserData;
import cc.carm.plugin.ultradepository.storage.DataStorage; import cc.carm.plugin.ultradepository.storage.DataStorage;
import cc.carm.plugin.ultradepository.util.DateIntUtil; import cc.carm.plugin.ultradepository.util.DateIntUtil;
import org.bukkit.Bukkit;
import org.bukkit.entity.Player; import org.bukkit.entity.Player;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
@@ -20,6 +21,27 @@ public class UserManager {
return dataCache; return dataCache;
} }
public void loadPlayersData() {
if (Bukkit.getOnlinePlayers().size() < 1) return;
UltraDepository.getInstance().log("加载当前在线玩家数据...");
// 用于热加载时重载玩家数据。
Bukkit.getOnlinePlayers().forEach(player -> loadDataCache(player.getUniqueId()));
}
public @NotNull UserData loadDataCache(@NotNull UUID userUUID) {
UserData data = loadData(userUUID);
UltraDepository.getUserManager().getDataCache().put(userUUID, data);
return data;
}
public boolean removeDataCache(@NotNull UUID userUUID) {
boolean contains = getDataCache().containsKey(userUUID);
getDataCache().remove(userUUID);
return contains;
}
public @Nullable UserData getData(@NotNull UUID userUUID) { public @Nullable UserData getData(@NotNull UUID userUUID) {
return getDataCache().get(userUUID); return getDataCache().get(userUUID);
} }
@@ -32,7 +54,7 @@ public class UserManager {
try { try {
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
DataStorage storage = UltraDepository.getStorage(); DataStorage storage = UltraDepository.getStorage();
UltraDepository.getInstance().debug("正通过 " + storage.getClass().getSimpleName() + " 加载 " + userUUID + " 的用户数据..."); UltraDepository.getInstance().debug("正通过 " + storage.getClass().getSimpleName() + " 加载 " + userUUID + " 的用户数据...(" + System.currentTimeMillis() + ")");
UserData data = UltraDepository.getStorage().loadData(userUUID); UserData data = UltraDepository.getStorage().loadData(userUUID);
if (data == null) { if (data == null) {
@@ -56,7 +78,7 @@ public class UserManager {
UserData data = getData(uuid); UserData data = getData(uuid);
if (data == null) return; if (data == null) return;
if (save) saveData(data); if (save) saveData(data);
dataCache.remove(uuid); removeDataCache(uuid);
} }
public void saveData(UserData data) { public void saveData(UserData data) {
@@ -64,7 +86,7 @@ public class UserManager {
long start = System.currentTimeMillis(); long start = System.currentTimeMillis();
DataStorage storage = UltraDepository.getStorage(); DataStorage storage = UltraDepository.getStorage();
UltraDepository.getInstance().debug("正通过 " + storage.getClass().getSimpleName() + " 保存 " + data.getUserUUID() + " 的用户数据..."); UltraDepository.getInstance().debug("正通过 " + storage.getClass().getSimpleName() + " 保存 " + data.getUserUUID() + " 的用户数据...(" + System.currentTimeMillis() + ")");
storage.saveUserData(data); storage.saveUserData(data);
UltraDepository.getInstance().debug("通过 " + storage.getClass().getSimpleName() + " 保存 " + data.getUserUUID() + " 的用户数据完成," + UltraDepository.getInstance().debug("通过 " + storage.getClass().getSimpleName() + " 保存 " + data.getUserUUID() + " 的用户数据完成," +
@@ -1,6 +1,7 @@
package cc.carm.plugin.ultradepository.storage; package cc.carm.plugin.ultradepository.storage;
import cc.carm.plugin.ultradepository.data.UserData; import cc.carm.plugin.ultradepository.data.UserData;
import cc.carm.plugin.ultradepository.manager.UserManager;
import org.jetbrains.annotations.NotNull; import org.jetbrains.annotations.NotNull;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
@@ -8,14 +9,38 @@ import java.util.UUID;
public interface DataStorage { public interface DataStorage {
/**
* 在插件加载存储源时执行。
*
* @return 是否初始化成功
*/
boolean initialize(); boolean initialize();
/**
* 在插件被卸载时执行。
*/
void shutdown(); void shutdown();
/**
* 用于加载用户数据的方法。<b>该方法将会被异步运行!</b>
* <br>该方法一般无需自行执行,见 {@link UserManager#loadData(UUID)}
* <br>
* <br>若不存在该用户的数据,请返回 null 。
* <br>若加载出现任何错误,请抛出异常。
*
* @param uuid 用户UUID
* @throws Exception 当出现任何错误时抛出
*/
@Nullable @Nullable
UserData loadData(@NotNull UUID uuid) throws Exception; UserData loadData(@NotNull UUID uuid) throws Exception;
/**
* 用于保存用户数据的方法。 <b>该方法将会被异步运行!</b>
* <br>该方法一般无需自行执行,见 {@link UserManager#saveData(UserData)}
*
* @param data 用户数据
* @throws Exception 当出现任何错误时抛出
*/
void saveUserData(@NotNull UserData data) throws Exception; void saveUserData(@NotNull UserData data) throws Exception;
/** /**