mirror of
https://github.com/CarmJos/EasyPlugin.git
synced 2026-06-04 16:48:16 +08:00
Compare commits
55 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 043fb99591 | |||
| 67af1b0dd4 | |||
| 1293ce1c35 | |||
| 069e243aa2 | |||
| a598cd4051 | |||
| af1cb7ae69 | |||
| 2463e62391 | |||
| adba8d774c | |||
| b42968c9a7 | |||
| 47b97fb97b | |||
| 2d286301d3 | |||
| 061d2a5ac9 | |||
| b2c248e0ae | |||
| 6f95fb156d | |||
| 21db2f59a4 | |||
| 326434a760 | |||
| 1be0541740 | |||
| 869811dd3f | |||
| 5bcb02ddf1 | |||
| 85ffc66c61 | |||
| 000ef51afe | |||
| 1ada26a919 | |||
| 95d2921c02 | |||
| 6ec015308c | |||
| 3a3906352f | |||
| 6e52cdef7c | |||
| a186ff896c | |||
| 8b13d4358f | |||
| c6a7312e3a | |||
| 8c347525ca | |||
| 66cb00431e | |||
| ba8e2b2929 | |||
| ed505357f3 | |||
| 54939f0f14 | |||
| bc3dd32f85 | |||
| 22ee1a157a | |||
| 00f1ff20fa | |||
| 91136a506d | |||
| edb8e0849a | |||
| 4e6caae8c9 | |||
| dd592cb764 | |||
| 5784215209 | |||
| 0eb774f560 | |||
| 4e24a87f12 | |||
| 44357d401f | |||
| d758e460f8 | |||
| 2caa33eb76 | |||
| 9450ef79fc | |||
| 89a17264f2 | |||
| 7923de25fb | |||
| bc046c02e4 | |||
| 1d279a16a8 | |||
| 17b7c23c54 | |||
| 1b7f60fe43 | |||
| de4dbbe637 |
@@ -14,9 +14,9 @@ jobs:
|
||||
packages-deploy:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/checkout@v2
|
||||
- uses: actions/checkout@v6
|
||||
- name: "Set up JDK"
|
||||
uses: actions/setup-java@v2
|
||||
uses: actions/setup-java@v5
|
||||
with:
|
||||
java-version: '8'
|
||||
distribution: 'adopt'
|
||||
@@ -35,9 +35,9 @@ jobs:
|
||||
github-deploy:
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/checkout@v2
|
||||
- uses: actions/checkout@v6
|
||||
- name: "Set up JDK"
|
||||
uses: actions/setup-java@v2
|
||||
uses: actions/setup-java@v5
|
||||
with:
|
||||
java-version: '8'
|
||||
distribution: 'adopt'
|
||||
@@ -59,7 +59,7 @@ jobs:
|
||||
run: |
|
||||
rm -rf docs
|
||||
mkdir -vp docs
|
||||
cp -vrf target/site/apidocs/* docs/
|
||||
cp -vrf target/reports/apidocs/* docs/
|
||||
cp -vrf .documentation/javadoc/JAVADOC-README.md docs/README.md
|
||||
|
||||
- name: "Generate Javadoc sitemap"
|
||||
@@ -112,21 +112,21 @@ jobs:
|
||||
name: "Deploy Project (Central)"
|
||||
runs-on: ubuntu-latest
|
||||
steps:
|
||||
- uses: actions/checkout@v2
|
||||
- uses: actions/checkout@v6
|
||||
- name: "Set up JDK"
|
||||
uses: actions/setup-java@v2
|
||||
uses: actions/setup-java@v5
|
||||
with:
|
||||
java-version: '11'
|
||||
java-version: '8'
|
||||
distribution: 'adopt'
|
||||
cache: maven
|
||||
server-id: ossrh
|
||||
server-id: central
|
||||
server-username: MAVEN_USERNAME
|
||||
server-password: MAVEN_PASSWORD
|
||||
gpg-private-key: ${{ secrets.MAVEN_GPG_PRIVATE_KEY }} # Value of the GPG private key to import
|
||||
gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase
|
||||
|
||||
- name: "Central Deploy"
|
||||
run: mvn -B -Possrh deploy --file pom.xml -DskipTests
|
||||
run: mvn -B -Pcentral deploy --file pom.xml -DskipTests
|
||||
env:
|
||||
MAVEN_USERNAME: ${{ secrets.OSSRH_USER }}
|
||||
MAVEN_PASSWORD: ${{ secrets.OSSRH_PASS }}
|
||||
|
||||
@@ -14,9 +14,9 @@ jobs:
|
||||
runs-on: ubuntu-latest
|
||||
|
||||
steps:
|
||||
- uses: actions/checkout@v2
|
||||
- uses: actions/checkout@v6
|
||||
- name: "Set up JDK"
|
||||
uses: actions/setup-java@v2
|
||||
uses: actions/setup-java@v5
|
||||
with:
|
||||
cache: maven
|
||||
java-version: '8'
|
||||
|
||||
@@ -179,9 +179,6 @@ dependencies {
|
||||
若您觉得本插件做的不错,您可以通过捐赠支持我!
|
||||
|
||||
感谢您对开源项目的支持!
|
||||
|
||||
<img height=25% width=25% src="https://raw.githubusercontent.com/CarmJos/CarmJos/main/img/donate-code.jpg" alt=""/>
|
||||
|
||||
## 开源协议
|
||||
|
||||
本项目源码采用 [The MIT License](https://opensource.org/licenses/MIT) 开源协议。
|
||||
@@ -201,4 +198,4 @@ dependencies {
|
||||
> MIT 协议是所有开源许可中最宽松的一个,除了必须包含许可声明外,再无任何限制。
|
||||
>
|
||||
> *以上文字来自 [五种开源协议GPL,LGPL,BSD,MIT,Apache](https://www.oschina.net/question/54100_9455) 。*
|
||||
</details>
|
||||
</details>
|
||||
|
||||
+1
-1
@@ -6,7 +6,7 @@
|
||||
<parent>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<properties>
|
||||
|
||||
@@ -34,7 +34,7 @@ public class ColorParser {
|
||||
public static @NotNull String clear(@NotNull String text) {
|
||||
text = HEX_PATTERN.matcher(text).replaceAll("");
|
||||
text = GRADIENT_PATTERN.matcher(text).replaceAll("");
|
||||
text = COLOR_PATTERN.matcher(text).replaceAll("");
|
||||
text = FORMAT_PATTERN.matcher(text).replaceAll("");
|
||||
return text;
|
||||
}
|
||||
|
||||
|
||||
@@ -19,32 +19,7 @@ public class ColorParseTest {
|
||||
System.out.println(parse("&<#AAAAAA>&l我&r真&(#666666)的&<#BBBBBB>&o爱死&<#111111>你&<#FFFFFF>了&r!"));
|
||||
System.out.println(parse("&r正常的颜色理应&c&l不受影响&r。"));
|
||||
|
||||
System.out.println(clear("&f测试&<#AAAAAA>清理颜色代码&<#111111> &&这样应该&(#666666)不被影响 &f。"));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void formatReadTest() {
|
||||
LinkedHashMap<Integer, String> formats = new LinkedHashMap<>();
|
||||
String text = "&k&l &m&1我&k爱你爱你爱你&o吗?";
|
||||
Matcher matcher = ColorParser.FORMAT_PATTERN.matcher(text);
|
||||
while (matcher.find()) {
|
||||
String code = matcher.group();
|
||||
formats.put(matcher.start(), code);
|
||||
text = matcher.replaceFirst("");
|
||||
matcher.reset(text);
|
||||
}
|
||||
|
||||
formats.forEach((index, code) -> System.out.println(index + " -> " + code));
|
||||
|
||||
String[] parts = text.split("");
|
||||
StringBuilder builder = new StringBuilder();
|
||||
for (int i = 0; i < parts.length; i++) {
|
||||
String format = formats.get(i);
|
||||
if (format != null) builder.append(ColorParser.parseBaseColor(format));
|
||||
builder.append(parts[i]);
|
||||
}
|
||||
|
||||
System.out.println(builder);
|
||||
System.out.println(clear("&f&l测试&<#AAAAAA>清理颜色代码&<#111111> &&这样应该&(#666666)不被影响 &f。"));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
<parent>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<properties>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
+1
-1
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -19,7 +19,7 @@ import java.util.stream.IntStream;
|
||||
public class GUI {
|
||||
|
||||
private static JavaPlugin plugin;
|
||||
private static final HashMap<UUID, GUI> openedGUIs = new HashMap<>();
|
||||
private static final Map<UUID, GUI> openedGUIs = new HashMap<>();
|
||||
|
||||
public static void initialize(JavaPlugin plugin) {
|
||||
GUI.plugin = plugin;
|
||||
@@ -29,42 +29,32 @@ public class GUI {
|
||||
return plugin;
|
||||
}
|
||||
|
||||
public static HashMap<UUID, GUI> getOpenedGUIs() {
|
||||
public static Map<UUID, GUI> getOpenedGUIs() {
|
||||
return openedGUIs;
|
||||
}
|
||||
|
||||
protected GUIType type;
|
||||
protected String title;
|
||||
public HashMap<Integer, GUIItem> items;
|
||||
public Inventory inv;
|
||||
protected final @NotNull GUIType type;
|
||||
protected @NotNull String title;
|
||||
protected Inventory inv;
|
||||
|
||||
/**
|
||||
* 当玩家点击目标GUI时是否取消
|
||||
*/
|
||||
boolean cancelOnTarget = true;
|
||||
protected final SortedMap<Integer, GUIItem> items = new TreeMap<>();
|
||||
protected ItemStack emptyItem = null;
|
||||
|
||||
/**
|
||||
* 当玩家点击自己背包时是否取消
|
||||
*/
|
||||
boolean cancelOnSelf = true;
|
||||
|
||||
/**
|
||||
* 当玩家点击界面外时是否取消
|
||||
*/
|
||||
boolean cancelOnOuter = true;
|
||||
protected boolean cancelOnTarget = true; // 当玩家点击GUI时是否取消对应事件
|
||||
protected boolean cancelOnSelf = true; // 当玩家点击自己背包时是否取消对应事件
|
||||
protected boolean cancelOnOuter = true; // 当玩家点击界面外时是否取消对应事件
|
||||
|
||||
protected final Map<String, Object> flags = new LinkedHashMap<>();
|
||||
|
||||
protected GUIListener listener;
|
||||
|
||||
public GUI(GUIType type, String title) {
|
||||
public GUI(@NotNull GUIType type, @NotNull String title) {
|
||||
this.type = type;
|
||||
this.title = ColorParser.parse(title);
|
||||
this.items = new HashMap<>();
|
||||
}
|
||||
|
||||
public Map<@NotNull Integer, @NotNull GUIItem> getItems() {
|
||||
return new HashMap<>(items);
|
||||
public SortedMap<@NotNull Integer, @NotNull GUIItem> getItems() {
|
||||
return items;
|
||||
}
|
||||
|
||||
public final void setItem(int index, @Nullable GUIItem item) {
|
||||
@@ -75,16 +65,64 @@ public class GUI {
|
||||
}
|
||||
}
|
||||
|
||||
public void setItemStack(int index, @Nullable ItemStack item) {
|
||||
setItem(index, item == null ? null : new GUIItem(item));
|
||||
}
|
||||
|
||||
public void setItem(GUIItem item, int... index) {
|
||||
for (int i : index) {
|
||||
setItem(i, item);
|
||||
}
|
||||
}
|
||||
|
||||
public void setItemStack(ItemStack item, int... index) {
|
||||
for (int i : index) {
|
||||
setItemStack(i, item);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 设置GUI上方(箱子部分)
|
||||
* @param row 行数,1为第1行
|
||||
* @param column 列数,1为第1列
|
||||
* @param item GUIItem
|
||||
*/
|
||||
public void setItem(int row, int column, @NotNull GUIItem item){
|
||||
if(row <= 0 || column <= 0) throw new IllegalArgumentException("行数和列数都不能小于等于零");
|
||||
if(row > type.getLines()) throw new IllegalArgumentException("行数("+row+")大于GUI大小限制("+type.getLines()+")");
|
||||
if(column > 9) throw new IllegalArgumentException("列数("+column+")不能大于9");
|
||||
setItem(9*(row-1)+column-1, item);
|
||||
}
|
||||
|
||||
public GUIItem getItem(int index) {
|
||||
return this.items.get(index);
|
||||
}
|
||||
|
||||
public void setEmptyItem(ItemStack item) {
|
||||
this.emptyItem = item;
|
||||
}
|
||||
|
||||
protected void fillEmptySlots(@NotNull Inventory inventory) {
|
||||
if (emptyItem == null) return;
|
||||
IntStream.range(0, inventory.getSize())
|
||||
.filter(i -> inventory.getItem(i) == null)
|
||||
.forEach(index -> inventory.setItem(index, emptyItem));
|
||||
}
|
||||
|
||||
protected void applyToInventory(Inventory inventory) {
|
||||
IntStream.range(0, inventory.getSize()).forEach(index -> inventory.setItem(index, new ItemStack(Material.AIR)));
|
||||
getItems().forEach((index, item) -> inventory.setItem(index, item.getDisplay()));
|
||||
fillEmptySlots(inventory);
|
||||
}
|
||||
|
||||
public void updateTitle(@NotNull String title) {
|
||||
this.title = ColorParser.parse(title);
|
||||
if (this.inv != null) {
|
||||
this.inv = Bukkit.createInventory(null, this.type.getSize(), this.title);
|
||||
applyToInventory(this.inv);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* 更新玩家箱子的视图
|
||||
*/
|
||||
@@ -92,8 +130,7 @@ public class GUI {
|
||||
this.onUpdate();
|
||||
if (this.inv != null) {
|
||||
List<HumanEntity> viewers = this.inv.getViewers();
|
||||
IntStream.range(0, this.inv.getSize()).forEach(index -> inv.setItem(index, new ItemStack(Material.AIR)));
|
||||
getItems().forEach((index, item) -> inv.setItem(index, item.getDisplay()));
|
||||
applyToInventory(this.inv);
|
||||
viewers.forEach(p -> ((Player) p).updateInventory());
|
||||
}
|
||||
}
|
||||
@@ -148,22 +185,22 @@ public class GUI {
|
||||
throw new IllegalStateException("被取消或不存在的GUI");
|
||||
}
|
||||
|
||||
Inventory inv = Bukkit.createInventory(null, this.type.getSize(), this.title);
|
||||
IntStream.range(0, inv.getSize()).forEach(index -> inv.setItem(index, new ItemStack(Material.AIR)));
|
||||
getItems().forEach((index, item) -> inv.setItem(index, item.getDisplay()));
|
||||
Inventory ui = Bukkit.createInventory(null, this.type.getSize(), this.title);
|
||||
applyToInventory(ui);
|
||||
|
||||
GUI previous = getOpenedGUI(player);
|
||||
if (previous != null) {
|
||||
if (previous != null && previous.listener != null) {
|
||||
previous.listener.close(player);
|
||||
}
|
||||
|
||||
setOpenedGUI(player, this);
|
||||
|
||||
this.inv = inv;
|
||||
player.openInventory(inv);
|
||||
this.inv = ui;
|
||||
player.openInventory(ui);
|
||||
|
||||
if (listener == null) {
|
||||
Bukkit.getPluginManager().registerEvents(listener = new GUIListener(this), getPlugin());
|
||||
this.listener = new GUIListener(this);
|
||||
Bukkit.getPluginManager().registerEvents(this.listener, getPlugin());
|
||||
}
|
||||
}
|
||||
|
||||
@@ -211,4 +248,11 @@ public class GUI {
|
||||
getOpenedGUIs().remove(player.getUniqueId());
|
||||
}
|
||||
|
||||
public static void closeAll() {
|
||||
Set<HumanEntity> viewers = new HashSet<>();
|
||||
getOpenedGUIs().values().stream().flatMap(gui -> gui.inv.getViewers().stream()).forEach(viewers::add);
|
||||
viewers.forEach(HumanEntity::closeInventory);
|
||||
getOpenedGUIs().clear();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -10,11 +10,11 @@ import java.util.Set;
|
||||
|
||||
public class GUIItem {
|
||||
|
||||
ItemStack display;
|
||||
boolean actionActive = true;
|
||||
protected ItemStack display;
|
||||
protected boolean actionActive = true;
|
||||
|
||||
public Set<GUIClickAction> actions = new HashSet<>();
|
||||
public Set<GUIClickAction> actionsIgnoreActive = new HashSet<>();
|
||||
protected final Set<GUIClickAction> actions = new HashSet<>();
|
||||
protected final Set<GUIClickAction> actionsIgnoreActive = new HashSet<>();
|
||||
|
||||
public GUIItem(ItemStack display) {
|
||||
this.display = display;
|
||||
@@ -78,6 +78,14 @@ public class GUIItem {
|
||||
|
||||
}
|
||||
|
||||
public Set<GUIClickAction> getActions() {
|
||||
return actions;
|
||||
}
|
||||
|
||||
public Set<GUIClickAction> getActionsIgnoreActive() {
|
||||
return actionsIgnoreActive;
|
||||
}
|
||||
|
||||
public abstract static class GUIClickAction {
|
||||
public abstract void run(ClickType type, Player player);
|
||||
}
|
||||
|
||||
@@ -6,12 +6,13 @@ import org.bukkit.event.HandlerList;
|
||||
import org.bukkit.event.Listener;
|
||||
import org.bukkit.event.inventory.InventoryClickEvent;
|
||||
import org.bukkit.event.inventory.InventoryCloseEvent;
|
||||
import org.bukkit.event.inventory.InventoryCreativeEvent;
|
||||
import org.bukkit.event.inventory.InventoryDragEvent;
|
||||
import org.bukkit.event.player.PlayerQuitEvent;
|
||||
|
||||
public class GUIListener implements Listener {
|
||||
|
||||
GUI currentGUI;
|
||||
protected final GUI currentGUI;
|
||||
|
||||
public GUIListener(GUI gui) {
|
||||
this.currentGUI = gui;
|
||||
|
||||
@@ -12,6 +12,7 @@ public enum GUIType {
|
||||
FOUR_BY_NINE(4, 36),
|
||||
FIVE_BY_NINE(5, 45),
|
||||
SIX_BY_NINE(6, 54),
|
||||
|
||||
CANCEL(0, 0);
|
||||
|
||||
private final int lines;
|
||||
|
||||
@@ -4,36 +4,54 @@ import cc.carm.lib.easyplugin.gui.GUIItem;
|
||||
import cc.carm.lib.easyplugin.gui.GUIType;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.bukkit.event.inventory.ClickType;
|
||||
import org.bukkit.inventory.Inventory;
|
||||
import org.bukkit.inventory.ItemStack;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
import org.jetbrains.annotations.Nullable;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Optional;
|
||||
import java.util.Set;
|
||||
import java.util.function.Function;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.IntStream;
|
||||
|
||||
public class AutoPagedGUI extends CommonPagedGUI {
|
||||
|
||||
public static Function<Player, ItemStack> defaultPreviousPage = null;
|
||||
public static Function<Player, ItemStack> defaultNextPage = null;
|
||||
|
||||
ItemStack previousPageUI;
|
||||
ItemStack nextPageUI;
|
||||
int previousPageSlot = -1;
|
||||
int nextPageSlot = -1;
|
||||
protected ItemStack previousPageUI;
|
||||
protected ItemStack nextPageUI;
|
||||
protected ItemStack noPreviousPageUI;
|
||||
protected ItemStack noNextPageUI;
|
||||
protected int previousPageSlot = -1;
|
||||
protected int nextPageSlot = -1;
|
||||
|
||||
public AutoPagedGUI(GUIType type, String name, int[] range) {
|
||||
super(type, name, range);
|
||||
public AutoPagedGUI(@NotNull GUIType type, @NotNull String title, int[] range) {
|
||||
super(type, title, range);
|
||||
}
|
||||
|
||||
public AutoPagedGUI(GUIType type, String name, int a, int b) {
|
||||
super(type, name, a, b);
|
||||
public AutoPagedGUI(@NotNull GUIType type, @NotNull String title, int a, int b) {
|
||||
super(type, title, a, b);
|
||||
}
|
||||
|
||||
public void setPreviousPageUI(ItemStack lastPageUI) {
|
||||
public void setPreviousPageUI(@Nullable ItemStack lastPageUI) {
|
||||
this.previousPageUI = lastPageUI;
|
||||
}
|
||||
|
||||
public void setNextPageUI(ItemStack nextPageUI) {
|
||||
public void setNoPreviousPageUI(@Nullable ItemStack noPreviousPageUI) {
|
||||
this.noPreviousPageUI = noPreviousPageUI;
|
||||
}
|
||||
|
||||
public void setNextPageUI(@Nullable ItemStack nextPageUI) {
|
||||
this.nextPageUI = nextPageUI;
|
||||
}
|
||||
|
||||
public void setNoNextPageUI(@Nullable ItemStack noNextPageUI) {
|
||||
this.noNextPageUI = noNextPageUI;
|
||||
}
|
||||
|
||||
public void setPreviousPageSlot(int slot) {
|
||||
this.previousPageSlot = slot;
|
||||
}
|
||||
@@ -42,12 +60,31 @@ public class AutoPagedGUI extends CommonPagedGUI {
|
||||
this.nextPageSlot = slot;
|
||||
}
|
||||
|
||||
@Override
|
||||
protected void fillEmptySlots(@NotNull Inventory inventory) {
|
||||
if (emptyItem == null) return;
|
||||
Set<Integer> rangeSet = Arrays.stream(this.range).boxed().collect(Collectors.toSet());
|
||||
if (previousPageSlot >= 0) rangeSet.add(previousPageSlot);
|
||||
if (nextPageSlot >= 0) rangeSet.add(nextPageSlot);
|
||||
IntStream.range(0, inventory.getSize())
|
||||
.filter(i -> inventory.getItem(i) == null)
|
||||
.filter(i -> !rangeSet.contains(i))
|
||||
.forEach(index -> inventory.setItem(index, emptyItem));
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void openGUI(Player user) {
|
||||
if (previousPageSlot >= 0) {
|
||||
if (hasPreviousPage()) {
|
||||
setItem(previousPageSlot, new GUIItem(
|
||||
previousPageUI == null ? getDefaultPreviousPage(user) : previousPageUI) {
|
||||
ItemStack finalPreviousPageUI;
|
||||
if(previousPageUI != null)
|
||||
finalPreviousPageUI = previousPageUI;
|
||||
else if (defaultPreviousPage != null)
|
||||
finalPreviousPageUI = defaultPreviousPage.apply(user);
|
||||
else
|
||||
finalPreviousPageUI = null;
|
||||
setItem(previousPageSlot, new GUIItem(finalPreviousPageUI) {
|
||||
@Override
|
||||
public void onClick(Player clicker, ClickType type) {
|
||||
if (type == ClickType.RIGHT) {
|
||||
@@ -59,14 +96,20 @@ public class AutoPagedGUI extends CommonPagedGUI {
|
||||
}
|
||||
});
|
||||
} else {
|
||||
setItem(previousPageSlot, null);
|
||||
setItem(previousPageSlot, this.noPreviousPageUI == null ? null : new GUIItem(noPreviousPageUI));
|
||||
}
|
||||
}
|
||||
|
||||
if (nextPageSlot >= 0) {
|
||||
if (hasNextPage()) {
|
||||
setItem(nextPageSlot, new GUIItem(
|
||||
nextPageUI == null ? getDefaultNextPage(user) : nextPageUI) {
|
||||
ItemStack finalNextPageUI;
|
||||
if(previousPageUI != null)
|
||||
finalNextPageUI = nextPageUI;
|
||||
else if (defaultNextPage != null)
|
||||
finalNextPageUI = defaultNextPage.apply(user);
|
||||
else
|
||||
finalNextPageUI = null;
|
||||
setItem(nextPageSlot, new GUIItem(finalNextPageUI) {
|
||||
@Override
|
||||
public void onClick(Player clicker, ClickType type) {
|
||||
if (type == ClickType.RIGHT) {
|
||||
@@ -78,19 +121,12 @@ public class AutoPagedGUI extends CommonPagedGUI {
|
||||
}
|
||||
});
|
||||
} else {
|
||||
setItem(nextPageSlot, null);
|
||||
setItem(nextPageSlot, this.noNextPageUI == null ? null : new GUIItem(noNextPageUI));
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
super.openGUI(user);
|
||||
}
|
||||
|
||||
private static ItemStack getDefaultNextPage(Player player) {
|
||||
return defaultNextPage != null ? defaultNextPage.apply(player) : null;
|
||||
}
|
||||
|
||||
private static ItemStack getDefaultPreviousPage(Player player) {
|
||||
return defaultPreviousPage != null ? defaultPreviousPage.apply(player) : null;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -4,70 +4,38 @@ package cc.carm.lib.easyplugin.gui.paged;
|
||||
import cc.carm.lib.easyplugin.gui.GUIItem;
|
||||
import cc.carm.lib.easyplugin.gui.GUIType;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.bukkit.inventory.Inventory;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
import java.util.stream.Collectors;
|
||||
import java.util.stream.IntStream;
|
||||
|
||||
public class CommonPagedGUI extends PagedGUI {
|
||||
|
||||
private int[] range;
|
||||
protected final int[] range;
|
||||
|
||||
private CommonPagedGUI(GUIType type, String name) {
|
||||
super(type, name);
|
||||
public CommonPagedGUI(@NotNull GUIType type, @NotNull String title, int a, int b) {
|
||||
this(type, title, toRange(type, a, b));
|
||||
}
|
||||
|
||||
public CommonPagedGUI(GUIType type, String Name, int a, int b) {
|
||||
this(type, Name, toRange(type, a, b));
|
||||
}
|
||||
|
||||
public CommonPagedGUI(GUIType type, String Name, int[] range) {
|
||||
super(type, Name);
|
||||
public CommonPagedGUI(@NotNull GUIType type, @NotNull String title, int[] range) {
|
||||
super(type, title);
|
||||
Arrays.sort(range);
|
||||
this.range = range;
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
/*
|
||||
int[] matrix = new int[]{
|
||||
0, 1, 2, 3, 4, 5, 6, 7, 8,
|
||||
9, 10, 11, 12, 13, 14, 15, 16, 17,
|
||||
18, 19, 20, 21, 22, 23, 24, 25, 26,
|
||||
27, 28, 29, 30, 31, 32, 33, 34, 35,
|
||||
36, 37, 38, 39, 40, 41, 42, 43, 44,
|
||||
45, 46, 47, 48, 49, 50, 51, 52, 53
|
||||
}
|
||||
*/
|
||||
|
||||
private static int[] toRange(GUIType type, int a, int b) {
|
||||
if (a > b) {
|
||||
a = a ^ b;
|
||||
b = a ^ b;
|
||||
a = a ^ b;
|
||||
}
|
||||
|
||||
int lineA = getLine(a);
|
||||
int columnA = getColumn(a);
|
||||
int lineB = getLine(b);
|
||||
int columnB = getColumn(b);
|
||||
|
||||
if (lineB > type.getLines())
|
||||
throw new IndexOutOfBoundsException("页面内容范围超过了GUI的大小");
|
||||
|
||||
int[] range = new int[(lineB - lineA + 1) * (columnB - columnA + 1)];
|
||||
|
||||
for (int i = 0, l = 0; i < type.getSize(); i++) {
|
||||
int li = getLine(i);
|
||||
int ci = getColumn(i);
|
||||
if (li >= lineA && li <= lineB && ci >= columnA && ci <= columnB) {
|
||||
range[l] = i;
|
||||
l++;
|
||||
}
|
||||
}
|
||||
|
||||
return range;
|
||||
@Override
|
||||
protected void fillEmptySlots(@NotNull Inventory inventory) {
|
||||
if (emptyItem == null) return;
|
||||
Set<Integer> rangeSet = Arrays.stream(this.range).boxed().collect(Collectors.toSet());
|
||||
IntStream.range(0, inventory.getSize())
|
||||
.filter(i -> inventory.getItem(i) == null)
|
||||
.filter(i -> !rangeSet.contains(i))
|
||||
.forEach(index -> inventory.setItem(index, emptyItem));
|
||||
}
|
||||
|
||||
private static int getLine(int i) {
|
||||
@@ -112,8 +80,9 @@ public class CommonPagedGUI extends PagedGUI {
|
||||
*
|
||||
* @return 最后一页的页码
|
||||
*/
|
||||
@Override
|
||||
public int getLastPageNumber() {
|
||||
return (this.container.size() / range.length) + ((this.container.size() % range.length) == 0 ? 0 : 1);
|
||||
return getLastPageNumber(range.length);
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -132,6 +101,8 @@ public class CommonPagedGUI extends PagedGUI {
|
||||
super.openGUI(player);
|
||||
return;
|
||||
}
|
||||
if(page > getLastPageNumber())
|
||||
page = getLastPageNumber();
|
||||
List<GUIItem> list = new ArrayList<>();
|
||||
int start = (page - 1) * range.length;
|
||||
for (int i = start; i < start + range.length; i++) {
|
||||
@@ -155,4 +126,44 @@ public class CommonPagedGUI extends PagedGUI {
|
||||
super.openGUI(player);
|
||||
}
|
||||
|
||||
|
||||
/*
|
||||
int[] matrix = new int[]{
|
||||
0, 1, 2, 3, 4, 5, 6, 7, 8,
|
||||
9, 10, 11, 12, 13, 14, 15, 16, 17,
|
||||
18, 19, 20, 21, 22, 23, 24, 25, 26,
|
||||
27, 28, 29, 30, 31, 32, 33, 34, 35,
|
||||
36, 37, 38, 39, 40, 41, 42, 43, 44,
|
||||
45, 46, 47, 48, 49, 50, 51, 52, 53
|
||||
}
|
||||
*/
|
||||
private static int[] toRange(GUIType type, int a, int b) {
|
||||
if (a > b) {
|
||||
a = a ^ b;
|
||||
b = a ^ b;
|
||||
a = a ^ b;
|
||||
}
|
||||
|
||||
int lineA = getLine(a);
|
||||
int columnA = getColumn(a);
|
||||
int lineB = getLine(b);
|
||||
int columnB = getColumn(b);
|
||||
|
||||
if (lineB > type.getLines())
|
||||
throw new IndexOutOfBoundsException("页面内容范围超过了GUI的大小");
|
||||
|
||||
int[] range = new int[(lineB - lineA + 1) * (columnB - columnA + 1)];
|
||||
|
||||
int l = 0;
|
||||
for (int i = 0; i < type.getSize(); i++) {
|
||||
int li = getLine(i);
|
||||
int ci = getColumn(i);
|
||||
if (li >= lineA && li <= lineB && ci >= columnA && ci <= columnB) {
|
||||
range[l] = i;
|
||||
l++;
|
||||
}
|
||||
}
|
||||
|
||||
return range;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -4,44 +4,78 @@ package cc.carm.lib.easyplugin.gui.paged;
|
||||
import cc.carm.lib.easyplugin.gui.GUI;
|
||||
import cc.carm.lib.easyplugin.gui.GUIItem;
|
||||
import cc.carm.lib.easyplugin.gui.GUIType;
|
||||
import org.bukkit.inventory.ItemStack;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
public abstract class PagedGUI extends GUI {
|
||||
|
||||
List<GUIItem> container = new ArrayList<>();
|
||||
public int page = 1;
|
||||
protected List<GUIItem> container = new ArrayList<>();
|
||||
protected int page = 1;
|
||||
|
||||
public PagedGUI(GUIType type, String name) {
|
||||
super(type, name);
|
||||
protected PagedGUI(@NotNull GUIType type, @NotNull String title) {
|
||||
super(type, title);
|
||||
}
|
||||
|
||||
public int addItem(GUIItem i) {
|
||||
public int setCurrentPage(int page) {
|
||||
this.page = Math.max(1, page);
|
||||
return this.page;
|
||||
}
|
||||
|
||||
public int getCurrentPage() {
|
||||
return page;
|
||||
}
|
||||
|
||||
|
||||
public int getLastPageNumber() {
|
||||
return getLastPageNumber(getGUIType().getSize());
|
||||
}
|
||||
|
||||
/**
|
||||
* 得到最后一页的页码
|
||||
*
|
||||
* @return 最后一页的页码
|
||||
*/
|
||||
public int getLastPageNumber(int size) {
|
||||
return (this.container.size() / size) + ((this.container.size() % size) == 0 ? 0 : 1);
|
||||
}
|
||||
|
||||
public int addItem(@NotNull GUIItem i) {
|
||||
container.add(i);
|
||||
return container.size() - 1;
|
||||
}
|
||||
|
||||
public int addItem(int index, @NotNull GUIItem i) {
|
||||
container.add(index, i);
|
||||
return container.size() - 1;
|
||||
}
|
||||
|
||||
public int addItemStack(@NotNull ItemStack itemStack) {
|
||||
return addItem(new GUIItem(itemStack));
|
||||
}
|
||||
|
||||
/**
|
||||
* 从GUI中移除一个物品
|
||||
*
|
||||
* @param item 物品
|
||||
*/
|
||||
public void removeItem(GUIItem item) {
|
||||
public void removeItem(@NotNull GUIItem item) {
|
||||
container.remove(item);
|
||||
}
|
||||
|
||||
/**
|
||||
* 从GUI中移除一个物品
|
||||
*
|
||||
* @param slot 物品格子数
|
||||
* @param index 物品格子数
|
||||
*/
|
||||
public void removeItem(int slot) {
|
||||
container.remove(slot);
|
||||
public void removeItem(int index) {
|
||||
container.remove(index);
|
||||
}
|
||||
|
||||
public List<GUIItem> getItemsContainer() {
|
||||
return new ArrayList<>(container);
|
||||
public @NotNull List<GUIItem> getPagedContainer() {
|
||||
return this.container;
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -55,7 +89,7 @@ public abstract class PagedGUI extends GUI {
|
||||
*/
|
||||
public void goPreviousPage() {
|
||||
if (hasPreviousPage()) {
|
||||
page--;
|
||||
this.page--;
|
||||
this.onPageChange(this.page);
|
||||
} else throw new IndexOutOfBoundsException();
|
||||
}
|
||||
@@ -66,7 +100,7 @@ public abstract class PagedGUI extends GUI {
|
||||
*/
|
||||
public void goNextPage() {
|
||||
if (hasNextPage()) {
|
||||
page++;
|
||||
this.page++;
|
||||
this.onPageChange(this.page);
|
||||
} else throw new IndexOutOfBoundsException();
|
||||
}
|
||||
|
||||
@@ -0,0 +1,21 @@
|
||||
import org.junit.Test;
|
||||
|
||||
public class PageTest {
|
||||
|
||||
|
||||
@Test
|
||||
public void test() {
|
||||
System.out.println(maxPage(0, 10));
|
||||
System.out.println(maxPage(10, 10));
|
||||
System.out.println(maxPage(5, 10));
|
||||
System.out.println(maxPage(15, 10));
|
||||
System.out.println(maxPage(19, 10));
|
||||
System.out.println(maxPage(20, 10));
|
||||
|
||||
}
|
||||
|
||||
int maxPage(int contents, int size) {
|
||||
if (contents == 0 || size == 0) return 1;
|
||||
return (contents / size) + ((contents % size) == 0 ? 0 : 1);
|
||||
}
|
||||
}
|
||||
+1
-1
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
<parent>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<properties>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
+1
-1
@@ -6,7 +6,7 @@
|
||||
<parent>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<properties>
|
||||
|
||||
@@ -0,0 +1,52 @@
|
||||
package cc.carm.lib.easyplugin.user;
|
||||
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.util.Objects;
|
||||
|
||||
public abstract class AbstractUserData<K> implements UserData<K> {
|
||||
|
||||
protected final @NotNull K key;
|
||||
|
||||
/**
|
||||
* Used to mark the data as dropping (save and unload) status.
|
||||
*/
|
||||
protected boolean dropping = false;
|
||||
|
||||
protected AbstractUserData(@NotNull K key) {
|
||||
this.key = key;
|
||||
}
|
||||
|
||||
@Override
|
||||
public @NotNull K key() {
|
||||
return key;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param dropping true if the data is dropping, false otherwise
|
||||
*/
|
||||
public void setDropping(boolean dropping) {
|
||||
this.dropping = dropping;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return true if the data is dropping, false otherwise
|
||||
*/
|
||||
public boolean isDropping() {
|
||||
return dropping;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object o) {
|
||||
if (this == o) return true;
|
||||
if (o == null || getClass() != o.getClass()) return false;
|
||||
AbstractUserData<?> abstractUserData = (AbstractUserData<?>) o;
|
||||
return key.equals(abstractUserData.key);
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return Objects.hash(key);
|
||||
}
|
||||
|
||||
}
|
||||
@@ -2,31 +2,17 @@ package cc.carm.lib.easyplugin.user;
|
||||
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
|
||||
import java.util.Objects;
|
||||
public interface UserData<K> {
|
||||
|
||||
public abstract class UserData<K> {
|
||||
@NotNull K key();
|
||||
|
||||
protected final @NotNull K key;
|
||||
|
||||
protected UserData(@NotNull K key) {
|
||||
this.key = key;
|
||||
}
|
||||
|
||||
public @NotNull K getKey() {
|
||||
return key;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object o) {
|
||||
if (this == o) return true;
|
||||
if (o == null || getClass() != o.getClass()) return false;
|
||||
UserData<?> userData = (UserData<?>) o;
|
||||
return key.equals(userData.key);
|
||||
}
|
||||
|
||||
@Override
|
||||
public int hashCode() {
|
||||
return Objects.hash(key);
|
||||
}
|
||||
/**
|
||||
* @param dropping true if the data is dropping, false otherwise
|
||||
*/
|
||||
void setDropping(boolean dropping);
|
||||
|
||||
/**
|
||||
* @return true if the data is dropping, false otherwise
|
||||
*/
|
||||
boolean isDropping();
|
||||
}
|
||||
|
||||
@@ -1,15 +1,12 @@
|
||||
package cc.carm.lib.easyplugin.user;
|
||||
|
||||
import cc.carm.lib.easyplugin.EasyPlugin;
|
||||
import com.google.common.collect.ImmutableSet;
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.OfflinePlayer;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
import org.jetbrains.annotations.Nullable;
|
||||
import org.jetbrains.annotations.Unmodifiable;
|
||||
|
||||
import java.util.*;
|
||||
import java.util.Collection;
|
||||
import java.util.Collections;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
@@ -21,7 +18,7 @@ import java.util.function.Supplier;
|
||||
import java.util.logging.Logger;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
public abstract class UserDataManager<K, U extends AbstractUserData<K>> implements UserDataRegistry<K, U> {
|
||||
|
||||
protected final @NotNull EasyPlugin plugin;
|
||||
|
||||
@@ -47,6 +44,7 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
this.dataCache = cacheMap;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void shutdown() {
|
||||
this.executor.shutdown();
|
||||
}
|
||||
@@ -55,14 +53,11 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
return plugin;
|
||||
}
|
||||
|
||||
protected @NotNull Logger getLogger() {
|
||||
@Override
|
||||
public @NotNull Logger getLogger() {
|
||||
return getPlugin().getLogger();
|
||||
}
|
||||
|
||||
public String serializeKey(@NotNull K key) {
|
||||
return key.toString();
|
||||
}
|
||||
|
||||
public abstract @NotNull U emptyUser(@NotNull K key);
|
||||
|
||||
public @NotNull U errorUser(@NotNull K key) {
|
||||
@@ -73,36 +68,17 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
|
||||
protected abstract void saveData(@NotNull U data) throws Exception;
|
||||
|
||||
public @NotNull CompletableFuture<U> load(@NotNull K key) {
|
||||
return load(key, false);
|
||||
}
|
||||
|
||||
public @NotNull CompletableFuture<U> load(@NotNull K key, boolean cache) {
|
||||
return load(key, () -> cache);
|
||||
}
|
||||
|
||||
public @NotNull Map<K, U> getDataCache() {
|
||||
@Override
|
||||
public @NotNull Map<K, U> cache() {
|
||||
return dataCache;
|
||||
}
|
||||
|
||||
@Unmodifiable
|
||||
public @NotNull Set<U> list() {
|
||||
return ImmutableSet.copyOf(getDataCache().values());
|
||||
}
|
||||
|
||||
public @NotNull U get(@NotNull K key) {
|
||||
return Optional.ofNullable(getNullable(key)).orElseThrow(() -> new NullPointerException("User " + key + " not found."));
|
||||
}
|
||||
|
||||
public @Nullable U getNullable(@NotNull K key) {
|
||||
return getDataCache().get(key);
|
||||
}
|
||||
|
||||
public @NotNull Optional<@Nullable U> getOptional(@NotNull K key) {
|
||||
return Optional.ofNullable(getNullable(key));
|
||||
}
|
||||
|
||||
@Override
|
||||
public @NotNull CompletableFuture<U> load(@NotNull K key, @NotNull Supplier<Boolean> cacheCondition) {
|
||||
U cached = getNullable(key);
|
||||
if (cached != null) {
|
||||
return CompletableFuture.supplyAsync(() -> cached); // Return cached data async.
|
||||
}
|
||||
return CompletableFuture.supplyAsync(() -> {
|
||||
String identifier = serializeKey(key);
|
||||
|
||||
@@ -124,14 +100,15 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
}
|
||||
|
||||
}, executor).thenApply((data) -> {
|
||||
if (cacheCondition.get()) dataCache.put(key, data);
|
||||
if (cacheCondition.get() && !data.isDropping()) dataCache.put(key, data);
|
||||
return data;
|
||||
});
|
||||
}
|
||||
|
||||
@Override
|
||||
public @NotNull CompletableFuture<Boolean> save(@NotNull U user) {
|
||||
return CompletableFuture.supplyAsync(() -> {
|
||||
String identifier = serializeKey(user.getKey());
|
||||
String identifier = serializeKey(user.key());
|
||||
|
||||
try {
|
||||
long s1 = System.currentTimeMillis();
|
||||
@@ -148,17 +125,18 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
}, executor);
|
||||
}
|
||||
|
||||
public @NotNull CompletableFuture<Boolean> unload(@NotNull K key) {
|
||||
return unload(key, true);
|
||||
}
|
||||
|
||||
@Override
|
||||
public @NotNull CompletableFuture<Boolean> unload(@NotNull K key, boolean save) {
|
||||
U data = getNullable(key);
|
||||
if (data == null) return CompletableFuture.completedFuture(false);
|
||||
|
||||
data.setDropping(true); // Mark the data as unloading.
|
||||
if (save) {
|
||||
return save(data).thenApply(result -> {
|
||||
this.dataCache.remove(key);
|
||||
// Check if the data is still unloading,
|
||||
// which cloud be interrupted by the next load.
|
||||
if (data.isDropping()) {
|
||||
this.dataCache.remove(key);
|
||||
}
|
||||
return result;
|
||||
});
|
||||
} else {
|
||||
@@ -168,6 +146,7 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public @NotNull CompletableFuture<Boolean> modify(@NotNull K key, @NotNull Consumer<U> consumer) {
|
||||
U cached = getNullable(key);
|
||||
if (cached != null) {
|
||||
@@ -176,13 +155,14 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
return true;
|
||||
}, executor);
|
||||
} else {
|
||||
return load(key, false).thenApply((data) -> {
|
||||
return load(key, true).thenApply((data) -> {
|
||||
consumer.accept(data);
|
||||
return data;
|
||||
}).thenCompose(this::save);
|
||||
}).thenCompose(data -> unload(key, true));
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public <V> @NotNull CompletableFuture<V> peek(@NotNull K key, @NotNull Function<U, V> function) {
|
||||
U cached = getNullable(key);
|
||||
if (cached != null) {
|
||||
@@ -192,10 +172,6 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
}
|
||||
}
|
||||
|
||||
public @NotNull CompletableFuture<Map<K, U>> loadOnline(@NotNull Function<Player, ? extends K> function) {
|
||||
return loadGroup(Bukkit.getOnlinePlayers(), function, OfflinePlayer::isOnline);
|
||||
}
|
||||
|
||||
public <T> @NotNull CompletableFuture<Map<K, U>> loadGroup(@NotNull Collection<? extends T> users,
|
||||
@NotNull Function<? super T, ? extends K> function,
|
||||
@NotNull Predicate<T> cacheCondition) {
|
||||
@@ -218,31 +194,24 @@ public abstract class UserDataManager<K, U extends UserData<K>> {
|
||||
return task.thenApply(Collections::unmodifiableMap);
|
||||
}
|
||||
|
||||
public @NotNull CompletableFuture<Map<K, U>> loadGroup(@NotNull Collection<K> allKeys,
|
||||
@NotNull Predicate<K> cacheCondition) {
|
||||
return loadGroup(allKeys, Function.identity(), cacheCondition);
|
||||
}
|
||||
|
||||
public @NotNull CompletableFuture<Map<K, U>> loadGroup(@NotNull Collection<K> allKeys) {
|
||||
return loadGroup(allKeys, (v) -> false);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void saveAll() {
|
||||
if (getDataCache().isEmpty()) return;
|
||||
for (U u : getDataCache().values()) {
|
||||
if (cache().isEmpty()) return;
|
||||
for (U u : cache().values()) {
|
||||
try {
|
||||
saveData(u);
|
||||
} catch (Exception e) {
|
||||
getPlugin().error("保存用户 " + serializeKey(u.getKey()) + " 数据失败,请检查相关配置!");
|
||||
getPlugin().error("保存用户 " + serializeKey(u.key()) + " 数据失败,请检查相关配置!");
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public int unloadAll(boolean save) {
|
||||
if (save) saveAll();
|
||||
int size = getDataCache().size();
|
||||
getDataCache().clear();
|
||||
int size = cache().size();
|
||||
cache().clear();
|
||||
return size;
|
||||
}
|
||||
|
||||
|
||||
@@ -0,0 +1,93 @@
|
||||
package cc.carm.lib.easyplugin.user;
|
||||
|
||||
import com.google.common.collect.ImmutableSet;
|
||||
import org.bukkit.Bukkit;
|
||||
import org.bukkit.OfflinePlayer;
|
||||
import org.bukkit.entity.Player;
|
||||
import org.jetbrains.annotations.NotNull;
|
||||
import org.jetbrains.annotations.Nullable;
|
||||
import org.jetbrains.annotations.Unmodifiable;
|
||||
|
||||
import java.util.Collection;
|
||||
import java.util.Map;
|
||||
import java.util.Optional;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.function.Consumer;
|
||||
import java.util.function.Function;
|
||||
import java.util.function.Predicate;
|
||||
import java.util.function.Supplier;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
public interface UserDataRegistry<K, U extends UserData<K>> {
|
||||
|
||||
void shutdown();
|
||||
|
||||
@NotNull Logger getLogger();
|
||||
|
||||
@NotNull Map<K, U> cache();
|
||||
|
||||
default String serializeKey(@NotNull K key) {
|
||||
return key.toString();
|
||||
}
|
||||
|
||||
default @NotNull CompletableFuture<U> load(@NotNull K key) {
|
||||
return load(key, false);
|
||||
}
|
||||
|
||||
default @NotNull CompletableFuture<U> load(@NotNull K key, boolean cache) {
|
||||
return load(key, () -> cache);
|
||||
}
|
||||
|
||||
@Unmodifiable
|
||||
default @NotNull Set<U> list() {
|
||||
return ImmutableSet.copyOf(cache().values());
|
||||
}
|
||||
|
||||
default @NotNull U get(@NotNull K key) {
|
||||
return Optional.ofNullable(getNullable(key)).orElseThrow(() -> new NullPointerException("User " + key + " not found."));
|
||||
}
|
||||
|
||||
default @Nullable U getNullable(@NotNull K key) {
|
||||
return cache().get(key);
|
||||
}
|
||||
|
||||
default @NotNull Optional<@Nullable U> getOptional(@NotNull K key) {
|
||||
return Optional.ofNullable(getNullable(key));
|
||||
}
|
||||
|
||||
@NotNull CompletableFuture<U> load(@NotNull K key, @NotNull Supplier<Boolean> cacheCondition);
|
||||
|
||||
@NotNull CompletableFuture<Boolean> save(@NotNull U user);
|
||||
|
||||
default @NotNull CompletableFuture<Boolean> unload(@NotNull K key) {
|
||||
return unload(key, true);
|
||||
}
|
||||
|
||||
@NotNull CompletableFuture<Boolean> unload(@NotNull K key, boolean save);
|
||||
|
||||
@NotNull CompletableFuture<Boolean> modify(@NotNull K key, @NotNull Consumer<U> consumer);
|
||||
|
||||
<V> @NotNull CompletableFuture<V> peek(@NotNull K key, @NotNull Function<U, V> function);
|
||||
|
||||
default @NotNull CompletableFuture<Map<K, U>> loadOnline(@NotNull Function<Player, ? extends K> function) {
|
||||
return loadGroup(Bukkit.getOnlinePlayers(), function, OfflinePlayer::isOnline);
|
||||
}
|
||||
|
||||
<T> @NotNull CompletableFuture<Map<K, U>> loadGroup(@NotNull Collection<? extends T> users,
|
||||
@NotNull Function<? super T, ? extends K> function,
|
||||
@NotNull Predicate<T> cacheCondition);
|
||||
|
||||
default @NotNull CompletableFuture<Map<K, U>> loadGroup(@NotNull Collection<K> allKeys,
|
||||
@NotNull Predicate<K> cacheCondition) {
|
||||
return loadGroup(allKeys, Function.identity(), cacheCondition);
|
||||
}
|
||||
|
||||
default @NotNull CompletableFuture<Map<K, U>> loadGroup(@NotNull Collection<K> allKeys) {
|
||||
return loadGroup(allKeys, (v) -> false);
|
||||
}
|
||||
|
||||
void saveAll();
|
||||
|
||||
int unloadAll(boolean save);
|
||||
}
|
||||
+1
-1
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<parent>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<relativePath>../../pom.xml</relativePath>
|
||||
</parent>
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
@@ -15,7 +15,7 @@
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
<artifactId>easyplugin-parent</artifactId>
|
||||
<packaging>pom</packaging>
|
||||
<version>1.5.9</version>
|
||||
<version>1.5.14</version>
|
||||
<modules>
|
||||
<module>base/color</module>
|
||||
<module>base/utils</module>
|
||||
@@ -117,14 +117,14 @@
|
||||
<dependency>
|
||||
<groupId>org.spigotmc</groupId>
|
||||
<artifactId>spigot-api</artifactId>
|
||||
<version>1.13.2-R0.1-SNAPSHOT</version>
|
||||
<version>1.19-R0.1-20220725.090125-47</version>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.jetbrains</groupId>
|
||||
<artifactId>annotations</artifactId>
|
||||
<version>23.0.0</version>
|
||||
<version>26.1.0</version>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
|
||||
@@ -142,12 +142,12 @@
|
||||
<dependency>
|
||||
<groupId>me.clip</groupId>
|
||||
<artifactId>placeholderapi</artifactId>
|
||||
<version>2.10.9</version>
|
||||
<version>2.12.2</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>com.github.MilkBowl</groupId>
|
||||
<artifactId>VaultAPI</artifactId>
|
||||
<version>1.7</version>
|
||||
<version>1.7.1</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>cc.carm.lib</groupId>
|
||||
@@ -162,7 +162,7 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-surefire-plugin</artifactId>
|
||||
<version>2.22.1</version>
|
||||
<version>3.5.6</version>
|
||||
<configuration>
|
||||
<useSystemClassLoader>false</useSystemClassLoader>
|
||||
</configuration>
|
||||
@@ -170,7 +170,7 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-compiler-plugin</artifactId>
|
||||
<version>3.8.1</version>
|
||||
<version>3.15.0</version>
|
||||
<configuration>
|
||||
<source>${project.jdk.version}</source>
|
||||
<target>${project.jdk.version}</target>
|
||||
@@ -181,12 +181,12 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-jar-plugin</artifactId>
|
||||
<version>3.2.0</version>
|
||||
<version>3.5.0</version>
|
||||
</plugin>
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-source-plugin</artifactId>
|
||||
<version>3.2.0</version>
|
||||
<version>3.4.0</version>
|
||||
<executions>
|
||||
<execution>
|
||||
<phase>package</phase>
|
||||
@@ -203,7 +203,7 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-gpg-plugin</artifactId>
|
||||
<version>3.0.1</version>
|
||||
<version>3.2.8</version>
|
||||
<executions>
|
||||
<execution>
|
||||
<id>sign-artifacts</id>
|
||||
@@ -223,7 +223,7 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-release-plugin</artifactId>
|
||||
<version>2.5.3</version>
|
||||
<version>3.3.1</version>
|
||||
<configuration>
|
||||
<autoVersionSubmodules>true</autoVersionSubmodules>
|
||||
<useReleaseProfile>false</useReleaseProfile>
|
||||
@@ -237,7 +237,7 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-javadoc-plugin</artifactId>
|
||||
<version>3.2.0</version>
|
||||
<version>3.12.0</version>
|
||||
<configuration>
|
||||
<classifier>javadoc</classifier>
|
||||
<detectJavaApiLink>false</detectJavaApiLink>
|
||||
@@ -258,7 +258,7 @@
|
||||
<plugin>
|
||||
<groupId>org.apache.maven.plugins</groupId>
|
||||
<artifactId>maven-shade-plugin</artifactId>
|
||||
<version>3.2.3</version>
|
||||
<version>3.6.2</version>
|
||||
<executions>
|
||||
<execution>
|
||||
<phase>package</phase>
|
||||
@@ -296,17 +296,24 @@
|
||||
<profiles>
|
||||
|
||||
<profile>
|
||||
<id>ossrh</id>
|
||||
<distributionManagement>
|
||||
<snapshotRepository>
|
||||
<id>ossrh</id>
|
||||
<url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
|
||||
</snapshotRepository>
|
||||
<repository>
|
||||
<id>ossrh</id>
|
||||
<url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
|
||||
</repository>
|
||||
</distributionManagement>
|
||||
<id>central</id>
|
||||
<build>
|
||||
<plugins>
|
||||
<plugin>
|
||||
<groupId>org.sonatype.central</groupId>
|
||||
<artifactId>central-publishing-maven-plugin</artifactId>
|
||||
<version>0.10.0</version>
|
||||
<extensions>true</extensions>
|
||||
<configuration>
|
||||
<publishingServerId>central</publishingServerId>
|
||||
<autoPublish>true</autoPublish>
|
||||
<excludeArtifacts>
|
||||
<excludeArtifact>configured-demo</excludeArtifact>
|
||||
</excludeArtifacts>
|
||||
</configuration>
|
||||
</plugin>
|
||||
</plugins>
|
||||
</build>
|
||||
</profile>
|
||||
|
||||
<profile>
|
||||
|
||||
@@ -0,0 +1,13 @@
|
||||
{
|
||||
"$schema": "https://docs.renovatebot.com/renovate-schema.json",
|
||||
"extends": [
|
||||
"config:recommended"
|
||||
],
|
||||
"packageRules": [
|
||||
{
|
||||
"matchUpdateTypes": ["minor", "patch"],
|
||||
"matchCurrentVersion": "!/^0/",
|
||||
"automerge": true
|
||||
}
|
||||
]
|
||||
}
|
||||
Reference in New Issue
Block a user