import express, { type Router } from "express";
|
import path from "node:path";
|
import { fileURLToPath } from "node:url";
|
import type { AppConfig } from "../config/types.js";
|
import {
|
loadLdapConfig,
|
loadPagesConfig,
|
loadUserScenariosConfig,
|
} from "../config/loadConfig.js";
|
import { requireAuth } from "../middleware/requireAuth.js";
|
import {
|
buildScenarioImageMapForUser,
|
loadHomeCatalogForUser,
|
resolveScenarioForUser,
|
scenarioToSlides,
|
} from "../services/scenarioLookup.js";
|
import {
|
createUserScenario,
|
deleteUserScenario,
|
STAYTIME_MAX,
|
STAYTIME_MIN,
|
} from "../services/userScenarios.js";
|
import { verifyCredentials } from "../utils/ldapAuth.js";
|
import { resolveBoardUrl } from "../utils/resolveBoardUrl.js";
|
import { loadWarehousePlansGroupedByDate } from "../services/warehouseCalendarData.js";
|
import {
|
coerceParamsFromRequest,
|
executeDataSourceById,
|
} from "../services/sqlDataSource.js";
|
import { buildMonthRows, formatDateKey } from "../utils/calendarMonth.js";
|
|
const __dirname = path.dirname(fileURLToPath(import.meta.url));
|
|
function shiftMonth(
|
year: number,
|
month: number,
|
delta: number
|
): { year: number; month: number } {
|
const d = new Date(year, month - 1 + delta, 1);
|
return { year: d.getFullYear(), month: d.getMonth() + 1 };
|
}
|
|
type ScenarioViewSlide = {
|
id: string;
|
title: string;
|
staytime: number;
|
boardUrl: string;
|
};
|
|
type ScenarioViewSlidesData = {
|
documentTitle: string;
|
scenarioId: string;
|
scenarioName: string;
|
scenarioImage: string;
|
slides: ScenarioViewSlide[];
|
slidesJson: string;
|
startIndex: number;
|
};
|
|
function buildScenarioViewSlides(
|
appCfg: AppConfig,
|
username: string,
|
scenarioId: string,
|
pageIdHint: string
|
): ScenarioViewSlidesData | null {
|
const resolved = resolveScenarioForUser(username, scenarioId);
|
if (!resolved) {
|
return null;
|
}
|
const sc = resolved.scenario;
|
const rawSlides = scenarioToSlides(sc);
|
const slides = rawSlides.map((p) => ({
|
id: p.id,
|
title: p.title,
|
staytime:
|
typeof p.staytime === "number" && p.staytime > 0 ? p.staytime : 30,
|
boardUrl: resolveBoardUrl(appCfg.dataEasePublicBase, p.boardUrl),
|
}));
|
let startIndex = 0;
|
if (pageIdHint) {
|
const idx = slides.findIndex((p) => p.id === pageIdHint);
|
if (idx >= 0) {
|
startIndex = idx;
|
}
|
}
|
return {
|
documentTitle: sc.name,
|
scenarioId: sc.id,
|
scenarioName: sc.name,
|
scenarioImage: sc.image,
|
slides,
|
slidesJson: JSON.stringify(slides),
|
startIndex,
|
};
|
}
|
|
export function createBoardRouter(appCfg: AppConfig): Router {
|
const router = express.Router();
|
|
router.get("/check/", (req, res) => {
|
if (req.session.user) {
|
res.status(200).type("text/plain").send("ok");
|
return;
|
}
|
res.status(401).type("text/plain").send("unauthorized");
|
});
|
|
router.get("/login", (req, res) => {
|
if (req.session.user) {
|
res.redirect("/board/");
|
return;
|
}
|
res.render("login", {
|
basePath: "/board",
|
error: null as string | null,
|
});
|
});
|
|
router.use(express.json());
|
|
router.post("/api/login", async (req, res) => {
|
const username = String(req.body?.username ?? "").trim();
|
const password = String(req.body?.password ?? "");
|
if (!username || !password) {
|
res.status(400).json({ ok: false, error: "缺少用户名或密码" });
|
return;
|
}
|
const skipAd = appCfg.skipLdapAuthForDebug === true;
|
if (!skipAd) {
|
const ldapCfg = loadLdapConfig();
|
const result = await verifyCredentials(username, password, ldapCfg);
|
if (!result.ok) {
|
const status =
|
result.reason === "connection_error" ? 503 : 401;
|
const msg =
|
result.reason === "user_not_found"
|
? "用户不存在"
|
: result.reason === "connection_error"
|
? "目录服务不可用"
|
: "用户名或密码错误";
|
res.status(status).json({ ok: false, error: msg });
|
return;
|
}
|
}
|
req.session.user = { username };
|
const next = String(req.body?.next ?? "");
|
const safeNext =
|
next.startsWith("/board/") && !next.includes("//") ? next : "/board/";
|
await new Promise<void>((resolve, reject) => {
|
req.session.save((err) => (err != null ? reject(err) : resolve()));
|
});
|
res.json({ ok: true, redirect: safeNext });
|
});
|
|
router.post("/api/logout", (req, res) => {
|
req.session.destroy((err) => {
|
if (err) {
|
res.status(500).json({ ok: false, error: "登出失败" });
|
return;
|
}
|
res.clearCookie("board.sid", { path: "/" });
|
res.json({ ok: true });
|
});
|
});
|
|
router.use(
|
"/static",
|
express.static(path.join(__dirname, "../../public/board"))
|
);
|
|
router.get("/", requireAuth, (req, res) => {
|
const username = req.session.user!.username;
|
const categories = loadHomeCatalogForUser(username);
|
res.render("home", {
|
basePath: "/board",
|
username,
|
categories,
|
scenarioImagesJson: JSON.stringify(buildScenarioImageMapForUser(username)),
|
});
|
});
|
|
router.get("/warehouse-calendar", requireAuth, async (req, res) => {
|
const now = new Date();
|
const qy = Number(req.query.year);
|
const qm = Number(req.query.month);
|
const year =
|
Number.isFinite(qy) && qy >= 2000 && qy <= 2100 ? qy : now.getFullYear();
|
const month =
|
Number.isFinite(qm) && qm >= 1 && qm <= 12 ? qm : now.getMonth() + 1;
|
|
const monthTitle = new Date(year, month - 1, 1).toLocaleString("zh-CN", {
|
year: "numeric",
|
month: "long",
|
});
|
|
const prev = shiftMonth(year, month, -1);
|
const next = shiftMonth(year, month, 1);
|
|
const todayKey = formatDateKey(
|
now.getFullYear(),
|
now.getMonth() + 1,
|
now.getDate()
|
);
|
const baseLocals = {
|
basePath: "/board",
|
username: req.session.user!.username,
|
year,
|
month,
|
monthTitle,
|
todayKey,
|
prevYear: prev.year,
|
prevMonth: prev.month,
|
nextYear: next.year,
|
nextMonth: next.month,
|
weekdayLabels: ["一", "二", "三", "四", "五", "六", "日"],
|
};
|
|
try {
|
const plansByDate = await loadWarehousePlansGroupedByDate(year, month);
|
const rows = buildMonthRows(year, month, plansByDate);
|
res.render("warehouseCalendar", {
|
...baseLocals,
|
rows,
|
dataError: null as string | null,
|
});
|
} catch (err) {
|
const msg = err instanceof Error ? err.message : String(err);
|
const rows = buildMonthRows(year, month, {});
|
res.status(503).render("warehouseCalendar", {
|
...baseLocals,
|
rows,
|
dataError: `数据加载失败：${msg}`,
|
});
|
}
|
});
|
|
/** 按 datasrc.json 的 id 执行 SQL，参数来自 query（除 id 外均传入存储过程/语句） */
|
router.get("/api/datasrc/query", requireAuth, async (req, res) => {
|
const id = String(req.query.id ?? "").trim();
|
if (!id) {
|
res.status(400).json({ ok: false, error: "缺少参数 id" });
|
return;
|
}
|
const raw = { ...req.query } as Record<string, unknown>;
|
delete raw.id;
|
try {
|
const params = coerceParamsFromRequest(raw);
|
const data = await executeDataSourceById(id, params);
|
res.json({ ok: true, data });
|
} catch (e) {
|
const msg = e instanceof Error ? e.message : String(e);
|
res.status(500).json({ ok: false, error: msg });
|
}
|
});
|
|
/** 同上，参数来自 JSON body */
|
router.post("/api/datasrc/query", requireAuth, async (req, res) => {
|
const id = String(req.body?.id ?? "").trim();
|
if (!id) {
|
res.status(400).json({ ok: false, error: "缺少参数 id" });
|
return;
|
}
|
const raw = { ...(req.body ?? {}) } as Record<string, unknown>;
|
delete raw.id;
|
try {
|
const params = coerceParamsFromRequest(raw);
|
const data = await executeDataSourceById(id, params);
|
res.json({ ok: true, data });
|
} catch (e) {
|
const msg = e instanceof Error ? e.message : String(e);
|
res.status(500).json({ ok: false, error: msg });
|
}
|
});
|
|
/** 用户场景管理（仅显示/修改 user 级别） */
|
router.get("/config/scenarios", requireAuth, (req, res) => {
|
const username = req.session.user!.username;
|
const { pages } = loadPagesConfig();
|
const userScenarios = loadUserScenariosConfig().users[username]?.scenarios ?? [];
|
res.render("userScenarios", {
|
basePath: "/board",
|
username,
|
allPages: pages,
|
userScenarios,
|
staytimeMin: STAYTIME_MIN,
|
staytimeMax: STAYTIME_MAX,
|
});
|
});
|
|
router.post("/api/user-scenarios/delete", requireAuth, (req, res) => {
|
const username = req.session.user!.username;
|
const scenarioId = String(req.body?.scenarioId ?? "").trim();
|
if (!scenarioId) {
|
res.status(400).json({ ok: false, error: "缺少 scenarioId" });
|
return;
|
}
|
const result = deleteUserScenario(username, scenarioId);
|
if (!result.ok) {
|
res.status(400).json({ ok: false, error: result.error });
|
return;
|
}
|
res.json({ ok: true });
|
});
|
|
router.post("/api/user-scenarios/create", requireAuth, (req, res) => {
|
const username = req.session.user!.username;
|
const name = String(req.body?.name ?? "");
|
const pages = Array.isArray(req.body?.pages) ? req.body.pages : [];
|
const pageRefs = pages.map((x: any) => ({
|
pageId: String(x?.pageId ?? "").trim(),
|
staytime: Number(x?.staytime),
|
}));
|
const result = createUserScenario(username, name, pageRefs);
|
if (!result.ok) {
|
res.status(400).json({ ok: false, error: result.error });
|
return;
|
}
|
res.json({ ok: true, scenario: result.scenario });
|
});
|
|
/** 默认：多 iframe 叠放、按 staytime 切换可见层（不轮改 src） */
|
router.get("/view", requireAuth, (req, res) => {
|
const scenarioId = String(req.query.scenarioId ?? "");
|
const pageIdHint = String(req.query.pageId ?? "");
|
const username = req.session.user!.username;
|
const data = buildScenarioViewSlides(appCfg, username, scenarioId, pageIdHint);
|
if (!data) {
|
res.status(404).send("场景不存在");
|
return;
|
}
|
res.render("view", {
|
basePath: "/board",
|
...data,
|
});
|
});
|
|
/** 旧版：单 iframe 定时切换 src */
|
router.get("/view-i", requireAuth, (req, res) => {
|
const scenarioId = String(req.query.scenarioId ?? "");
|
const pageIdHint = String(req.query.pageId ?? "");
|
const username = req.session.user!.username;
|
const data = buildScenarioViewSlides(appCfg, username, scenarioId, pageIdHint);
|
if (!data) {
|
res.status(404).send("场景不存在");
|
return;
|
}
|
res.render("view-i", {
|
basePath: "/board",
|
documentTitle: data.documentTitle,
|
scenarioId: data.scenarioId,
|
scenarioName: data.scenarioName,
|
scenarioImage: data.scenarioImage,
|
slidesJson: data.slidesJson,
|
startIndex: data.startIndex,
|
});
|
});
|
|
/** 兼容旧链接，重定向到 /view */
|
router.get("/view-tabs", requireAuth, (req, res) => {
|
const q = req.url.includes("?")
|
? req.url.slice(req.url.indexOf("?"))
|
: "";
|
res.redirect(302, "/board/view" + q);
|
});
|
|
return router;
|
}
|
