-
+
{TREND_METRICS.map((item) => (
))}
+
diff --git a/ops-center/src/OpsCenterApp.jsx b/ops-center/src/OpsCenterApp.jsx
index 7d0e75b..54e461e 100644
--- a/ops-center/src/OpsCenterApp.jsx
+++ b/ops-center/src/OpsCenterApp.jsx
@@ -4,17 +4,20 @@ import CasinoOutlined from "@mui/icons-material/CasinoOutlined";
import InsightsOutlined from "@mui/icons-material/InsightsOutlined";
import RefreshOutlined from "@mui/icons-material/RefreshOutlined";
import { useCallback, useEffect, useMemo, useState } from "react";
+import { PERMISSIONS } from "@/app/permissions";
import { Button } from "@/shared/ui/Button.jsx";
import { DataState } from "@/shared/ui/DataState.jsx";
import { PageHead } from "@/shared/ui/PageHead.jsx";
import { useToast } from "@/shared/ui/ToastProvider.jsx";
-import { DEFAULT_POOL_ID, fetchOpsDashboard, saveLuckyGiftConfig } from "./api.js";
+import { adjustLuckyGiftPool, DEFAULT_POOL_ID, fetchOpsDashboard, saveLuckyGiftConfig } from "./api.js";
import { AppsView } from "./components/AppsView.jsx";
import { ConfigsView } from "./components/ConfigsView.jsx";
import { DrawsView } from "./components/DrawsView.jsx";
import { LuckyGiftConfigDialog } from "./components/LuckyGiftConfigDialog.jsx";
+import { LuckyGiftPoolAdjustmentDialog } from "./components/LuckyGiftPoolAdjustmentDialog.jsx";
import { OpsShell } from "./components/OpsShell.jsx";
import { OverviewView } from "./components/OverviewView.jsx";
+import { formatNumber } from "./format.js";
const views = [
{ icon: InsightsOutlined, key: "overview", label: "数据总览" },
@@ -37,13 +40,20 @@ export function initialOpsCenterView(search = globalThis.location?.search || "")
return viewKeys.has(requested) ? requested : "overview";
}
-export function OpsCenterApp() {
+const denyPermission = () => false;
+
+export function OpsCenterApp({ can = denyPermission }) {
// 主后台旧入口通过 ?view=configs 进入独立 HTML；只接受白名单视图，异常参数仍回到总览。
const [activeView, setActiveView] = useState(() => initialOpsCenterView());
const [state, setState] = useState({ data: initialDashboard, error: "", loaded: false, loading: true });
const [dialog, setDialog] = useState(null);
+ const [poolDialog, setPoolDialog] = useState(null);
+ const [adjustingPool, setAdjustingPool] = useState(false);
const [savingConfig, setSavingConfig] = useState(false);
const { showToast } = useToast();
+ const canCreditPool = can(PERMISSIONS.luckyGiftPoolCredit);
+ const canDebitPool = can(PERMISSIONS.luckyGiftPoolDebit);
+ const canUpdateConfig = can(PERMISSIONS.luckyGiftUpdate);
const loadDashboard = useCallback(async () => {
setState((current) => ({ ...current, error: "", loading: true }));
@@ -124,6 +134,18 @@ export function OpsCenterApp() {
setDialog({ config: structuredClone(config), mode: "edit" });
}, []);
+ const openPoolAdjustment = useCallback((pool, direction) => {
+ if (!pool) {
+ return;
+ }
+ // 幂等键绑定一次弹窗会话，而不是一次 fetch；网络超时或 409 后弹窗保留，后续重试不会重复入账。
+ setPoolDialog({
+ adjustmentId: createPoolAdjustmentID(),
+ direction,
+ pool: structuredClone(pool),
+ });
+ }, []);
+
const handleSaveConfig = useCallback(
async (config) => {
setSavingConfig(true);
@@ -142,6 +164,31 @@ export function OpsCenterApp() {
[loadDashboard, showToast],
);
+ const handleAdjustPool = useCallback(
+ async (request) => {
+ setAdjustingPool(true);
+ try {
+ const result = await adjustLuckyGiftPool(request);
+ const adjustment = result.adjustment || {};
+ const action = request.direction === "out" ? "扣减" : "添加";
+ showToast(
+ `已${action}水位 ${request.appCode} / ${request.poolId} / ${request.strategyVersion}：${formatNumber(
+ adjustment.balance_before,
+ )} → ${formatNumber(adjustment.balance_after)}`,
+ "success",
+ );
+ setPoolDialog(null);
+ await loadDashboard();
+ } catch (error) {
+ // owner 可能已经成功但响应丢失；保留表单与 adjustment_id，用户重试时由 owner 返回首次结果而不重复调整。
+ showToast(error.message || "调整奖池水位失败", "error");
+ } finally {
+ setAdjustingPool(false);
+ }
+ },
+ [loadDashboard, showToast],
+ );
+
const defaultAppCode = data.apps[0]?.app_code ?? data.apps[0]?.appCode ?? "";
return (
@@ -170,13 +217,29 @@ export function OpsCenterApp() {
loading={state.loading && !state.loaded}
onRetry={loadDashboard}
>
- {activeView === "overview" ?
: null}
+ {activeView === "overview" ? (
+
openPoolAdjustment(pool, "in")}
+ onDebit={(pool) => openPoolAdjustment(pool, "out")}
+ />
+ ) : null}
{activeView === "configs" ? (
openPoolAdjustment(pool, "in")}
+ onDebit={(pool) => openPoolAdjustment(pool, "out")}
onEdit={openEditConfig}
/>
) : null}
@@ -195,7 +258,27 @@ export function OpsCenterApp() {
onSubmit={handleSaveConfig}
/>
) : null}
+ {poolDialog ? (
+ setPoolDialog(null)}
+ onSubmit={handleAdjustPool}
+ />
+ ) : null}