UIPosts

package com.uiposts;

import org.bukkit.Bukkit;
import org.bukkit.ChatColor;
import org.bukkit.Material;
import org.bukkit.command.*;
import org.bukkit.entity.Player;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;
import org.bukkit.event.inventory.InventoryClickEvent;
import org.bukkit.event.player.PlayerInteractEvent;
import org.bukkit.inventory.*;
import org.bukkit.inventory.meta.BookMeta;
import org.bukkit.inventory.meta.ItemMeta;
import org.bukkit.metadata.FixedMetadataValue;
import org.bukkit.plugin.java.JavaPlugin;
import org.bukkit.scheduler.BukkitRunnable;
import java.io.File;
import java.sql.*;
import java.text.SimpleDateFormat;
import java.util.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.io.InputStreamReader;
import java.io.BufferedReader;

/**
 * @pluginName UIPosts
 * @author ScriptIrc Engine
 * @version 2.1
 * @description 支持命令/GUI多端发帖查询删帖，支持分页、权限、统计与优化帮助系统的多功能帖子插件
 * [command]uiposts|主命令:支持chest/book/post/del/info/list/help[/command]
 * [Permission]uiposts.post|允许发帖[/Permission]
 * [Permission]uiposts.reply|允许留言[/Permission]
 * [Permission]uiposts.del|允许删除帖子[/Permission]
 * [Permission]uiposts.admin|管理及高级操作[/Permission]
 */
public class UIPosts extends JavaPlugin implements Listener, TabCompleter {
    private static final String DB_FILE = "uiposts.db";
    private static final String TIME_API = "http://worldtimeapi.org/api/timezone/Asia/Shanghai";
    private static final int POST_LIMIT = 100, REPLY_LIMIT = 50;
    private static final ChatColor PRIMARY = ChatColor.AQUA, SECONDARY = ChatColor.YELLOW, SUCCESS = ChatColor.GREEN, ERROR = ChatColor.RED, INFO = ChatColor.GRAY;
    private Connection connection;
    private Map<String, Object> guiConfig;
    private final Map<UUID, Boolean> awaitingPostInput = new HashMap<>();
    private final Map<UUID, Integer> awaitingReply = new HashMap<>();
    private final Map<UUID, Long> lastPostTime = new HashMap<>();

    @Override
    public void onEnable() {
        Bukkit.getPluginManager().registerEvents(this, this);
        getCommand("uiposts").setTabCompleter(this);
        initDatabase();
        loadConfig();
        getLogger().info("UIPosts v2.1 命令+GUI帖子系统启动！");
    }
    @Override
    public void onDisable() {
        try { if (connection != null && !connection.isClosed()) connection.close(); } catch (Exception ignored) {}
        getLogger().info("UIPosts 插件关闭.");
    }

    // ======= 配置与数据库相关 =======
    private void loadConfig() {
        guiConfig = new HashMap<>();
        Map<String, Object> chestGUI = new HashMap<>();
        chestGUI.put("title", PRIMARY+"§l帖子广场 §f[Chest]{sep}{page}/{pages}");
        chestGUI.put("size", 27);
        chestGUI.put("post_slot", Arrays.asList(10, 11, 12, 13, 14));
        chestGUI.put("next_slot", 25);
        chestGUI.put("prev_slot", 19);
        chestGUI.put("home_slot", 22);
        chestGUI.put("stat_slot", 15);
        chestGUI.put("theme", ChatColor.AQUA.toString());
        chestGUI.put("post_button", SUCCESS+"§l我要发帖");
        chestGUI.put("jump_book", SECONDARY+"§l[切换到书本模式]");
        chestGUI.put("refresh", PRIMARY+"§l刷新/回首页");
        guiConfig.put("chest", chestGUI);
        Map<String, Object> bookGUI = new HashMap<>();
        bookGUI.put("title", PRIMARY+"§l帖子广场 §f[书本]{sep}{page}页");
        bookGUI.put("lines_per_page", 7);
        guiConfig.put("book", bookGUI);
    }
    private void initDatabase() {
        try {
            File dbFile = new File(getDataFolder(), DB_FILE);
            if (!getDataFolder().exists()) getDataFolder().mkdirs();
            boolean init = false;
            if (!dbFile.exists()) {
                dbFile.createNewFile();
                init = true;
            }
            connection = DriverManager.getConnection("jdbc:sqlite:" + dbFile.getPath());
            if (init) {
                Statement st = connection.createStatement();
                st.executeUpdate("CREATE TABLE IF NOT EXISTS posts (id INTEGER PRIMARY KEY AUTOINCREMENT, player VARCHAR, content TEXT, time VARCHAR)");
                st.executeUpdate("CREATE TABLE IF NOT EXISTS replies (id INTEGER PRIMARY KEY AUTOINCREMENT, post_id INTEGER, player VARCHAR, content TEXT, time VARCHAR)");
                st.close();
            }
        } catch (Exception e) { e.printStackTrace(); }
    }

    // ============ 命令与补全 =============
    @Override
    public boolean onCommand(CommandSender sender, Command cmd, String label, String[] args) {
        if (args.length == 0) {
            if (sender instanceof Player) {
                openChestGUI((Player)sender, 1);
            } else {
                sender.sendMessage(INFO+"请加参数，或用/uiposts help 查看帮助。");
            }
            return true;
        }
        String sub = args[0].toLowerCase();
        // --- 子命令分发 ---
        switch (sub) {
            case "help": case "?":
                sendHelp(sender);
                break;
            case "chest":
                if (sender instanceof Player) openChestGUI((Player)sender, 1);
                else sender.sendMessage(ERROR+"仅玩家有效");
                break;
            case "book":
                if (sender instanceof Player) openBookGUI((Player)sender, 1);
                else sender.sendMessage(ERROR+"仅玩家有效");
                break;
            case "post": // /uiposts post <内容>
                if (!(sender instanceof Player)) { sender.sendMessage(ERROR+"仅玩家可发帖"); return true; }
                Player p = (Player)sender;
                if (!p.hasPermission("uiposts.post")) { p.sendMessage(ERROR+"无权限 uiposts.post"); return true;}
                String msg = joinArgs(args, 1);
                if (msg.length() == 0) { p.sendMessage(INFO+"请输入帖子内容: /uiposts post <内容>"); return true;}
                if (msg.length() > POST_LIMIT) { p.sendMessage(ERROR+"已截断内容为"+POST_LIMIT+"字"); msg = msg.substring(0, POST_LIMIT); }
                long now = System.currentTimeMillis();
                if(lastPostTime.containsKey(p.getUniqueId()) && (now-lastPostTime.get(p.getUniqueId())<5000)) {
                    p.sendMessage(ERROR+"冷却中，5秒后再试！");
                    return true;
                }
                savePost(p, msg);
                lastPostTime.put(p.getUniqueId(), now);
                p.sendMessage(SUCCESS+"发帖成功！");
                break;
            case "del": // /uiposts del <id>
                if (args.length < 2) { sender.sendMessage(INFO+"用法: /uiposts del <帖子ID>"); return true;}
                int delId = safeInt(args[1], -1);
                if (delId < 1) { sender.sendMessage(ERROR+"帖子ID无效"); return true;}
                if (!sender.hasPermission("uiposts.del") && !(sender.hasPermission("uiposts.admin"))) {
                    sender.sendMessage(ERROR+"无权删除帖子（需要uiposts.del）");
                    return true;
                }
                Post delp = getPostById(delId);
                if (delp == null) { sender.sendMessage(ERROR+"未找到帖子#"+delId); return true; }
                boolean isOwner = (sender instanceof Player) && delp.player.equalsIgnoreCase(sender.getName());
                if (!isOwner && !sender.hasPermission("uiposts.admin")) {
                    sender.sendMessage(ERROR+"只能删除自己帖子，或需要uiposts.admin权限");
                    return true;
                }
                deletePost(delId);
                sender.sendMessage(SUCCESS+"已删除帖子 #"+delId);
                break;
            case "info": // /uiposts info <id>
                if (args.length < 2) { sender.sendMessage(INFO+"/uiposts info <帖子ID>"); return true;}
                int infoId = safeInt(args[1], -1);
                if (infoId < 1) { sender.sendMessage(ERROR+"帖子ID无效"); return true;}
                Post post = getPostById(infoId);
                if (post == null) { sender.sendMessage(ERROR+"未找到帖子 #"+infoId); return true;}
                sender.sendMessage(primaryTitle("帖子 #"+infoId));
                sender.sendMessage(SECONDARY+"作者："+ChatColor.WHITE+post.player+"  时间："+post.time);
                sender.sendMessage(INFO+"内容："+ChatColor.RESET+post.content);
                List<Reply> replies = getReplies(infoId);
                if (replies.isEmpty()) sender.sendMessage(INFO+"暂无留言");
                else {
                    sender.sendMessage(SECONDARY+"留言（共"+replies.size()+"条）：");
                    for (Reply r : replies) sender.sendMessage(INFO+" - "+r.player+"："+r.content);
                }
                break;
            case "list": // /uiposts list [页]
                int page = args.length>=2?safeInt(args[1], 1):1;
                if (page<1) page=1;
                int perPage = 5, total = countPosts(), totalPages = Math.max(1, (total+perPage-1)/perPage);
                List<Post> posts = getPostsByPage(page, perPage);
                sender.sendMessage(primaryTitle("帖子列表 第"+page+"/"+totalPages+"页（"+total+"条）"));
                if (posts.isEmpty()) sender.sendMessage(INFO+"暂无帖子！");
                else
                    for (Post pp:posts) sender.sendMessage(
                        ChatColor.GREEN+"#"+pp.id+ChatColor.WHITE+" ["+pp.player+"] "+ChatColor.GRAY+shorten(pp.content, 24)
                        +ChatColor.DARK_GRAY+"（"+pp.time+"）"
                    );
                sender.sendMessage(INFO+"用 /uiposts info <id> 查询详情, /uiposts del <id> 删除, /uiposts post <内容> 发新帖");
                break;
            default:
                if (sub.equals("reply") && sender instanceof Player) {
                    sender.sendMessage(INFO+"留言请在帖子详情界面内操作。");
                } else {
                    sendHelp(sender);
                }
        }
        return true;
    }
    @Override
    public List<String> onTabComplete(CommandSender s, Command c, String l, String[] a) {
        List<String> res = new ArrayList<>();
        if (a.length == 1)
            res = Arrays.asList("chest","book","help","post","del","info","list");
        else if (a.length == 2 && Arrays.asList("del", "info").contains(a[0].toLowerCase())) {
            List<Post> posts = getPostsByPage(1, 50);
            for(Post p:posts)
                res.add(String.valueOf(p.id));
        }
        return res;
    }
    private int safeInt(String x, int def) { try{return Integer.parseInt(x);}catch(Exception e){return def;} }
    private String joinArgs(String[] arr, int idx) {
        if (idx>=arr.length) return "";
        StringBuilder sb=new StringBuilder();
        for(int i=idx;i<arr.length;i++) {
            if(i>idx) sb.append(" ");
            sb.append(arr[i]);
        }
        return sb.toString().trim();
    }
    private String shorten(String str, int n) { return str.length()>n?str.substring(0,n)+"...":str; }
    private String primaryTitle(String s){return PRIMARY+""+ChatColor.BOLD+"§l"+s;}

    // ===== 自定义方法补充 =====
    // parse: 用于将原始title字符串进行变量替换
    private String parse(String raw, Player p, int page, int pages) {
        return raw.replace("{player}", p.getName()).replace("{page}", String.valueOf(page)).replace("{pages}", String.valueOf(pages));
    }
    // showBookForPost: 展示某帖子详情（留言、发帖界面调用）
    private void showBookForPost(Player p, Post post) {
        ItemStack book = new ItemStack(Material.WRITTEN_BOOK);
        BookMeta meta = (BookMeta) book.getItemMeta();
        StringBuilder sb = new StringBuilder();
        sb.append(PRIMARY+"【"+post.player+"】 "+ChatColor.GRAY+post.time+"\n");
        sb.append(ChatColor.RESET).append(wrapLines(post.content,25)).append("\n");
        List<Reply> replies = getReplies(post.id);
        for (Reply r : replies) sb.append(ChatColor.GRAY+"- "+r.player+": "+wrapLines(r.content,20)+"\n");
        sb.append("\n"+SECONDARY+"输入留言内容（聊天发送），'取消'退出");
        meta.setAuthor("UIPosts");
        meta.setTitle("回复帖子");
        meta.setPages(Collections.singletonList(sb.toString()));
        book.setItemMeta(meta);
        p.getInventory().setItem(p.getInventory().getHeldItemSlot(), book);
        new BukkitRunnable(){public void run(){p.openBook(book);}}.runTaskLater(this,2L);
        askForReplyInput(p, post.id);
    }
    
    // 其余已实现方法略
    // ...

    // ========== 其余代码与之前版本一致 ==========
    // ......
    // (数据库管理、聊天事件、分页、发帖、回复、工具方法、数据结构等均与原有代码一致)
    
    // ... getInternetTime、wrapLines、数据库操作等 ...
    // ===== 数据结构=======
    private static class Post {
        int id; String player; String content; String time;
        Post(int id, String player, String content, String time) { this.id = id; this.player = player; this.content = content; this.time = time; }
    }
    private static class Reply { String player; String content; String time; Reply(String pl, String c, String t) { player = pl; content = c; time = t; } }
}