还没有标签。
'; + } + + async function refreshTags() { + if (!tagRoot) return; + var json = await api("/api/tags/tree", undefined, "GET"); + renderTagAdminTree(json.data); + } + + function clearTagDnd() { + tagDraggingId = null; + if (!tagRoot) return; + tagRoot.classList.remove("drag-over"); + tagRoot.querySelectorAll(".drag-src,.drag-over").forEach(function (el) { + el.classList.remove("drag-src", "drag-over"); }); + } + + if (tagRoot) { + if (Array.isArray(window.__ADMIN_TAG_TREE__)) renderTagAdminTree(window.__ADMIN_TAG_TREE__); + else refreshTags(); + + tagRoot.addEventListener("click", function (e) { + var tog = e.target.closest(".toggler"); + if (!tog) return; + var li = tog.closest("li"); + var ul = null; + if (li) { + for (var i = 0; i < li.children.length; i++) { + if (li.children[i].tagName === "UL") ul = li.children[i]; + } + } + if (!ul) return; + var open = ul.classList.toggle("open"); + tog.setAttribute("aria-expanded", open ? "true" : "false"); + }); + + tagRoot.addEventListener("dragstart", function (e) { + if (e.target.closest("button")) return; + var row = e.target.closest(".tag-node"); + if (!row) return; + tagDraggingId = row.getAttribute("data-id"); + e.dataTransfer.setData("text/plain", tagDraggingId); + e.dataTransfer.effectAllowed = "move"; + row.classList.add("drag-src"); + }); + + tagRoot.addEventListener("dragend", clearTagDnd); + + tagRoot.addEventListener("dragover", function (e) { + if (!tagDraggingId) return; + e.preventDefault(); + e.dataTransfer.dropEffect = "move"; + var row = e.target.closest(".tag-node[data-drop-id]"); + tagRoot.querySelectorAll(".drag-over").forEach(function (el) { + el.classList.remove("drag-over"); + }); + if (row) row.classList.add("drag-over"); + else tagRoot.classList.add("drag-over"); + }); + + tagRoot.addEventListener("dragleave", function (e) { + if (e.target === tagRoot && !e.relatedTarget) tagRoot.classList.remove("drag-over"); + }); + + tagRoot.addEventListener("drop", async function (e) { + var id = tagDraggingId; + var row = e.target.closest(".tag-node[data-drop-id]"); + var dropTarget = row ? row.getAttribute("data-drop-id") : null; + clearTagDnd(); + if (!id || dropTarget === id) return; + try { + await api("/api/tags/" + id, { parentId: dropTarget ? Number(dropTarget) : null }, "PATCH"); + toast(dropTarget ? "已移动到目标标签下" : "已移回顶层"); + await refreshTags(); + } catch (err) { + toast(err.message); + } + }); + } + + /* ============ 批量选择 / 批量状态 ============ */ + function selectedEntryIds() { + var ids = []; + document.querySelectorAll(".entry-check:checked").forEach(function (c) { + ids.push(Number(c.getAttribute("data-id"))); + }); + return ids; + } + + function updateBatchCount() { + var el = document.getElementById("batch-count"); + if (el) el.textContent = "已选 " + selectedEntryIds().length + " 项"; + } + + document.addEventListener("change", function (e) { + var ck = e.target; + if (ck.classList && ck.classList.contains("entry-check-all")) { + document.querySelectorAll(".entry-check").forEach(function (c) { + c.checked = ck.checked; + }); + updateBatchCount(); + } else if (ck.classList && ck.classList.contains("entry-check")) { + updateBatchCount(); + } }); document.addEventListener("click", async function (e) { @@ -63,28 +196,32 @@ var name = prompt(parentId ? "新增子标签名称：" : "新增顶层标签组名称："); if (!name) return; await api("/api/tags", { name: name, parentId: parentId ? Number(parentId) : null }); - toast("标签已创建"); refresh(); + await refreshTags(); + toast("标签已创建"); } if (action === "tag-rename") { var name2 = prompt("重命名为：", btn.getAttribute("data-name")); if (!name2 || name2 === btn.getAttribute("data-name")) return; await api("/api/tags/" + btn.getAttribute("data-id"), { name: name2 }, "PATCH"); - toast("已重命名"); refresh(); + await refreshTags(); + toast("已重命名"); } if (action === "tag-move") { - var target3 = prompt("移动到哪个标签之下？填其 ID（留空移到顶层）：\n" + btn.getAttribute("data-ids")); + var target3 = prompt("移动到哪个标签之下？填其 ID（留空移到顶层）："); if (target3 === null) return; await api("/api/tags/" + btn.getAttribute("data-id"), { parentId: target3.trim() ? Number(target3.trim()) : null }, "PATCH"); - toast("已移动"); refresh(); + await refreshTags(); + toast("已移动"); } if (action === "tag-delete") { if (!confirm("删除该标签？其子标签将上移一级，关联关系解除。")) return; await api("/api/tags/" + btn.getAttribute("data-id"), undefined, "DELETE"); - toast("已删除"); refresh(); + await refreshTags(); + toast("已删除"); } if (action === "entry-status") { @@ -99,6 +236,24 @@ toast("已删除"); refresh(); } + if (action === "entry-select-all") { + var checks = Array.prototype.slice.call(document.querySelectorAll(".entry-check")); + var allOn = checks.length > 0 && checks.every(function (c) { return c.checked; }); + checks.forEach(function (c) { c.checked = !allOn; }); + var allEl = document.querySelector(".entry-check-all"); + if (allEl) allEl.checked = !allOn; + updateBatchCount(); + } + + if (action === "entry-batch") { + var ids = selectedEntryIds(); + if (!ids.length) { toast("请先勾选条目"); return; } + var status = btn.getAttribute("data-status"); + await api("/api/admin/entries/status", { ids: ids, status: status }, "POST"); + toast(status === "active" ? "已上架 " + ids.length + " 条" : "已灰掉 " + ids.length + " 条"); + refresh(); + } + if (action === "comment-delete") { if (!confirm("删除该评论？")) return; await api("/api/comments/" + btn.getAttribute("data-id"), undefined, "DELETE"); @@ -203,4 +358,4 @@ .catch(function (err) { toast(err.message); }); }); } -})(); +})(); \ No newline at end of file diff --git a/src/routes/admin.routes.js b/src/routes/admin.routes.js index 4583395..2e3595d 100644 --- a/src/routes/admin.routes.js +++ b/src/routes/admin.routes.js @@ -2,6 +2,7 @@ import { Router } from "express"; import * as userService from "../services/user.service.js"; import * as sourceService from "../services/source.service.js"; import * as commentService from "../services/comment.service.js"; +import * as entryService from "../services/entry.service.js"; import * as searchService from "../services/search.service.js"; import * as audit from "../services/audit.service.js"; import { requireAdmin } from "../middleware/auth.js"; @@ -134,3 +135,16 @@ adminRouter.get("/api/admin/entries", requireAdmin, async (req, res) => { }); res.json({ ok: true, data: result }); }); + +adminRouter.post("/api/admin/entries/status", requireAdmin, async (req, res) => { + const ids = Array.isArray(req.body.ids) ? req.body.ids : []; + const status = String(req.body.status || ""); + const updated = await entryService.setStatusBulk(ids, status); + await audit.log({ + actor: actor(req), + action: "entries.status", + target: "", + detail: `${status} × ${updated}`, + }); + res.json({ ok: true, data: { updated } }); +}); diff --git a/src/routes/pages.routes.js b/src/routes/pages.routes.js index e32f34c..d772d1c 100644 --- a/src/routes/pages.routes.js +++ b/src/routes/pages.routes.js @@ -73,7 +73,8 @@ pagesRouter.get("/entries", async (req, res, next) => { pagesRouter.get("/entries/:slug", async (req, res, next) => { try { const entry = await entryService.getBySlug(req.params.slug); - if (!entry || entry.status === "greyed") { + const preview = req.query.preview === "1" && Boolean(req.session.userId); + if (!entry || (entry.status === "greyed" && !preview)) { return res.status(404).send("条目不存在或已下架"); } const comments = await commentService.listForEntry(entry.id); @@ -119,12 +120,25 @@ pagesRouter.get("/admin", async (req, res, next) => { try { if (!req.session.userId) return res.redirect("/login"); const isAdmin = req.session.role === "admin"; - const [sources, users, comments, entries, tagTreeAdmin] = await Promise.all([ + const status = ["active", "greyed", "pending", "all"].includes(req.query.status) + ? req.query.status + : "all"; + const page = Math.max(1, Number(req.query.page) || 1); + const perPage = 50; + const [ + sources, + users, + comments, + entries, + tagTreeAdmin, + statusCounts, + ] = await Promise.all([ sourceService.listSources(), isAdmin ? userService.listUsers() : Promise.resolve([]), commentService.listAll({}), - searchService.searchEntries({ status: "all", perPage: 50 }), + searchService.searchEntries({ status, perPage, page }), tagService.attachCounts(await tagService.buildTree()), + searchService.statusCounts(), ]); res.render("admin", { title: "管理台 · Awesome Index", @@ -133,6 +147,10 @@ pagesRouter.get("/admin", async (req, res, next) => { users, comments, entries: entries.items, + status, + statusCounts, + page, + totalPages: Math.max(1, Math.ceil(entries.total / entries.perPage)), isAdmin, tagTreeAdmin, }); diff --git a/src/services/entry.service.js b/src/services/entry.service.js index 901ae6b..ebdd871 100644 --- a/src/services/entry.service.js +++ b/src/services/entry.service.js @@ -158,6 +158,25 @@ export async function setStatusDirect(id, status) { return getById(id); } +export async function setStatusBulk(ids, status) { + if (!STATUSES.includes(status)) throw httpError(400, `未知状态：${status}`); + const clean = [...new Set(ids.map(Number).filter(Number.isFinite))]; + if (!clean.length) throw httpError(400, "没有选中条目"); + const existing = await all( + `SELECT id FROM entries WHERE id IN (${clean.map(() => "?").join(",")})`, + clean + ); + const realIds = existing.map((r) => Number(r.id)); + if (!realIds.length) throw httpError(400, "没有选中条目"); + await run( + `UPDATE entries SET status = ?, updated_at = now(), + verified_at = CASE WHEN ? = 'active' THEN now() ELSE verified_at END + WHERE id IN (${realIds.map(() => "?").join(",")})`, + [status, status, ...realIds] + ); + return realIds.length; +} + export async function deleteEntry(id) { await run(`DELETE FROM entry_tags WHERE entry_id = ?`, [id]); await run(`DELETE FROM comments WHERE entry_id = ?`, [id]); diff --git a/src/services/search.service.js b/src/services/search.service.js index 454837a..9623e5e 100644 --- a/src/services/search.service.js +++ b/src/services/search.service.js @@ -90,6 +90,16 @@ export async function typeCounts() { return map; } +export async function statusCounts() { + const rows = await all(`SELECT status, COUNT(*) AS c FROM entries GROUP BY status`); + const map = { all: 0, active: 0, pending: 0, greyed: 0 }; + for (const r of rows) { + map[r.status] = Number(r.c); + map.all += Number(r.c); + } + return map; +} + export async function randomActive() { return get(`SELECT * FROM entries WHERE status = 'active' ORDER BY random() LIMIT 1`); } diff --git a/src/views/admin.ejs b/src/views/admin.ejs index b9405b3..0d688ba 100644 --- a/src/views/admin.ejs +++ b/src/views/admin.ejs @@ -16,14 +16,44 @@// table: entries · 状态 active | greyed | pending
+// table: entries · 状态 active | greyed | pending · 预览 = 按当前状态模拟前台展示
全部收录条目。灰掉 = 暂不可见但保留数据；删除为物理删除，需确认。
-| 标题 | 类型 | 状态 | 更新时间 | 操作 | |
|---|---|---|---|---|---|
| + | 标题 | +类型 | +状态 | +更新时间 | +操作 | +
|---|---|---|---|---|---|
| 当前筛选下没有条目 | |||||
|
<%= e.title %> <%= (e.tags || []).join(' · ') || '—' %> @@ -38,6 +68,7 @@ | |||||