| 'use strict';
|
|
|
| const LS_KEY = 'wb2api.key', LS_THEME = 'wb2api.theme';
|
| let theme = localStorage.getItem(LS_THEME) || 'auto';
|
| let view = 'accounts';
|
| let overviewData = null, cfgLoaded = null;
|
| let logPin = true, loginState = null, loginTimer = null;
|
| let refTimer = null;
|
|
|
| let mdFilter = { q: '', realm: '', cap: '', effort: '', promo: '', sort: 'default' };
|
| let mdAll = [], mdProbes = {}, mdProbeOf = () => undefined;
|
| let reqFilter = { q: '', outcome: '' };
|
| let reqEntries = [];
|
| let usDim = 'account', usCreditDim = 'account', usSort = 'total';
|
| let usageData = null;
|
| let reqRangeState = null;
|
|
|
| const $ = id => document.getElementById(id);
|
|
|
|
|
|
|
| function effTheme() {
|
| return theme === 'auto' ? (matchMedia('(prefers-color-scheme: light)').matches ? 'light' : 'dark') : theme;
|
| }
|
| function applyTheme() {
|
| const eff = effTheme();
|
| document.documentElement.dataset.theme = eff;
|
| $('icoTheme').innerHTML = eff === 'light'
|
| ? '<circle cx="8" cy="8" r="3"/><path d="M8 1v2M8 13v2M1 8h2M13 8h2M3.2 3.2l1.4 1.4M11.4 11.4l1.4 1.4M12.8 3.2l-1.4 1.4M4.6 11.4l-1.4 1.4"/>'
|
| : '<path d="M13.2 9.6A5.6 5.6 0 0 1 6.4 2.8a5.6 5.6 0 1 0 6.8 6.8z"/>';
|
| $('btnTheme').title = eff === 'light' ? '切换到深色' : '切换到浅色';
|
| }
|
| addEventListener('change', applyTheme);
|
| $('btnTheme').onclick = () => {
|
| theme = effTheme() === 'light' ? 'dark' : 'light';
|
| localStorage.setItem(LS_THEME, theme);
|
| applyTheme();
|
| };
|
| applyTheme();
|
|
|
|
|
| async function api(path, opts = {}) {
|
| const h = Object.assign({}, opts.headers || {});
|
| const k = localStorage.getItem(LS_KEY);
|
| if (k) h['Authorization'] = 'Bearer ' + k;
|
| if (opts.body) h['Content-Type'] = 'application/json';
|
| const r = await fetch('/panel/api/' + path, Object.assign({}, opts, { headers: h }));
|
| if (r.status === 401) { openKey(); throw new Error('密钥无效或未填写'); }
|
| const d = await r.json().catch(() => ({}));
|
| if (!r.ok) throw new Error(d.error || ('HTTP ' + r.status));
|
| return d;
|
| }
|
| function toast(msg, cls) {
|
| const el = document.createElement('div');
|
| el.className = 'tst ' + (cls || '');
|
| el.textContent = msg;
|
| $('toasts').appendChild(el);
|
| setTimeout(() => el.remove(), 3600);
|
| }
|
|
|
|
|
|
|
| function esc(s) {
|
| return String(s == null ? '' : s)
|
| .replace(/&/g, '&')
|
| .replace(/</g, '<')
|
| .replace(/>/g, '>')
|
| .replace(/"/g, '"')
|
| .replace(/'/g, ''');
|
| }
|
| function ago(iso) {
|
| if (!iso || iso.startsWith('0001-')) return '—';
|
| const s = (Date.now() - new Date(iso)) / 1000;
|
| if (s < 0) return '刚刚';
|
| if (s < 60) return Math.floor(s) + ' 秒前';
|
| if (s < 3600) return Math.floor(s / 60) + ' 分钟前';
|
| if (s < 86400) return Math.floor(s / 3600) + ' 小时前';
|
| return Math.floor(s / 86400) + ' 天前';
|
| }
|
| function dur(sec) {
|
| sec = Math.max(0, Math.round(sec));
|
| const h = Math.floor(sec / 3600), m = Math.floor(sec % 3600 / 60), s = sec % 60;
|
| return h ? h + '时' + String(m).padStart(2, '0') + '分' : m ? m + '分' + String(s).padStart(2, '0') + '秒' : s + '秒';
|
| }
|
| function parseAPITime(value) {
|
| const text = String(value || '');
|
| if (!text || text.startsWith('0001-')) return 0;
|
| const ms = Date.parse(text);
|
| return Number.isFinite(ms) ? ms : 0;
|
| }
|
| function fmtLocalDateTime(ms) {
|
| const d = new Date(ms);
|
| const p = n => String(n).padStart(2, '0');
|
| return d.getFullYear() + '-' + p(d.getMonth() + 1) + '-' + p(d.getDate()) + ' ' +
|
| p(d.getHours()) + ':' + p(d.getMinutes());
|
| }
|
|
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
|
|
| const TRANGE_PRESETS = [
|
| ['today', '今天'],
|
| ['24', '近 24 小时'],
|
| ['72', '近 3 天'],
|
| ['168', '近 7 天'],
|
| ['720', '近 30 天'],
|
| ['0', '全部历史'],
|
| ['custom', '自定义…'],
|
| ];
|
| const TRANGE_DEFAULT = '72';
|
| const trangeStates = new Map();
|
|
|
|
|
|
|
| function dtLocalValue(d) {
|
| const p = n => String(n).padStart(2, '0');
|
| return d.getFullYear() + '-' + p(d.getMonth() + 1) + '-' + p(d.getDate()) + 'T' +
|
| p(d.getHours()) + ':' + p(d.getMinutes());
|
| }
|
| function dtLocalParse(s) {
|
| if (!s) return null;
|
| const d = new Date(s);
|
| return isNaN(d.getTime()) ? null : d;
|
| }
|
|
|
|
|
| function trangeMidnight() {
|
| const d = new Date();
|
| d.setHours(0, 0, 0, 0);
|
| return d;
|
| }
|
|
|
| function trangeState(id) {
|
| if (!trangeStates.has(id)) {
|
|
|
| trangeStates.set(id, { preset: TRANGE_DEFAULT, from: trangeMidnight(), to: new Date() });
|
| }
|
| return trangeStates.get(id);
|
| }
|
|
|
|
|
| function trangeRender(id) {
|
| const host = $(id);
|
| if (!host) return;
|
| const st = trangeState(id);
|
| const custom = st.preset === 'custom';
|
| host.innerHTML =
|
| '<select class="tr-preset" aria-label="时间范围">' +
|
| TRANGE_PRESETS.map(([v, label]) =>
|
| '<option value="' + v + '"' + (v === st.preset ? ' selected' : '') + '>' + esc(label) + '</option>').join('') +
|
| '</select>' +
|
| '<span class="tr-custom"' + (custom ? '' : ' hidden') + '>' +
|
| '<input type="datetime-local" class="tr-from" value="' + esc(st.from ? dtLocalValue(st.from) : '') + '" aria-label="起始时间">' +
|
| '<span class="tr-sep">→</span>' +
|
| '<input type="datetime-local" class="tr-to" value="' + esc(st.to ? dtLocalValue(st.to) : '') + '" aria-label="结束时间">' +
|
| '</span>';
|
| const preset = host.querySelector('.tr-preset');
|
| if (preset) preset.onchange = () => {
|
| st.preset = preset.value;
|
|
|
|
|
| if (st.preset === 'custom' && (!st.from || !st.to)) { st.from = trangeMidnight(); st.to = new Date(); }
|
| trangeRender(id);
|
| trangeEmit(id);
|
| };
|
| const fromEl = host.querySelector('.tr-from');
|
| const toEl = host.querySelector('.tr-to');
|
| const readCustom = () => {
|
| st.from = dtLocalParse(fromEl.value);
|
| st.to = dtLocalParse(toEl.value);
|
|
|
| const bad = st.from && st.to && st.from > st.to;
|
| fromEl.classList.toggle('tr-bad', !!bad);
|
| toEl.classList.toggle('tr-bad', !!bad);
|
| if (bad) return;
|
| trangeEmit(id);
|
| };
|
| if (fromEl) fromEl.onchange = readCustom;
|
| if (toEl) toEl.onchange = readCustom;
|
| }
|
|
|
| const trangeHandlers = new Map();
|
|
|
|
|
| function trangeBind(id, onChange, preset) {
|
| trangeHandlers.set(id, onChange);
|
| if (preset) trangeState(id).preset = preset;
|
| trangeRender(id);
|
| }
|
| function trangeEmit(id) {
|
| const fn = trangeHandlers.get(id);
|
| if (fn) fn();
|
| }
|
|
|
|
|
|
|
|
|
|
|
| function trangeQuery(id, rolling) {
|
| const st = trangeState(id);
|
| const q = new URLSearchParams();
|
| const sec = d => Math.floor(d.getTime() / 1000);
|
| if (st.preset === 'custom') {
|
| if (st.from) q.set('from', sec(st.from));
|
| if (st.to) q.set('to', sec(st.to));
|
| return q;
|
| }
|
| if (st.preset === 'today') {
|
| q.set('from', sec(trangeMidnight()));
|
| return q;
|
| }
|
| if (st.preset === '0') return q;
|
| if (rolling) { q.set('hours', st.preset); return q; }
|
| q.set('from', sec(new Date(Date.now() - Number(st.preset) * 3600 * 1000)));
|
| return q;
|
| }
|
|
|
|
|
| function trangeLabel(id) {
|
| const st = trangeState(id);
|
| const found = TRANGE_PRESETS.find(p => p[0] === st.preset);
|
| if (st.preset !== 'custom') return found ? found[1] : '';
|
| if (!st.from && !st.to) return '自定义';
|
| const f = d => d ? (d.getMonth() + 1) + '-' + String(d.getDate()).padStart(2, '0') + ' ' +
|
| String(d.getHours()).padStart(2, '0') + ':' + String(d.getMinutes()).padStart(2, '0') : '…';
|
| return f(st.from) + ' → ' + f(st.to);
|
| }
|
| function rateLimitMeta(row, now) {
|
| const model = String(row && row.model || '未知模型');
|
| const kind = String(row && row.kind || 'rate_limit');
|
| const resetAt = parseAPITime(row && row.reset_at);
|
| const until = parseAPITime(row && row.until);
|
| const deadline = resetAt || until;
|
| const remaining = deadline > now ? Math.round((deadline - now) / 1000) : 0;
|
| if (kind === 'model_unavailable') {
|
| return {
|
| model,
|
| kind,
|
| detail: remaining ? '预计 ' + dur(remaining) + ' 后重试' : '等待重新探测',
|
| title: model + '\n模型当前不可用' + (deadline ? '\n最早重试：' + fmtLocalDateTime(deadline) : ''),
|
| };
|
| }
|
| let detail = resetAt
|
| ? '预计 ' + fmtLocalDateTime(resetAt) + ' 解封' + (remaining ? '（剩余 ' + dur(remaining) + '）' : '')
|
| : (until ? '预计 ' + fmtLocalDateTime(until) + ' 恢复（剩余 ' + dur(remaining) + '）' : '预计解封时间未知');
|
| const title = [model, resetAt ? '上游重置：' + fmtLocalDateTime(resetAt) : '上游重置：时间未知'];
|
| if (until && resetAt && until < resetAt) {
|
| detail += ' · 网关最快 ' + dur(Math.max(0, Math.round((until - now) / 1000))) + ' 后重试';
|
| title.push('网关最早重试：' + fmtLocalDateTime(until));
|
| }
|
| return { model, kind, detail, title: title.join('\n') };
|
| }
|
| function rateLimitRowsHtml(rows, now) {
|
| const list = Array.isArray(rows) ? rows.filter(row => row && row.model) : [];
|
| if (!list.length) return '';
|
| return '<div class="rate-limits">' + list.map(row => {
|
| const m = rateLimitMeta(row, now);
|
| return '<div class="rate-limit ' + (m.kind === 'model_unavailable' ? 'model-unavailable' : '') +
|
| '" title="' + esc(m.title) + '"><b>' + esc(m.model) + '</b><span>' + esc(m.detail) + '</span></div>';
|
| }).join('') + '</div>';
|
| }
|
|
|
| function formatTokenCount(tokens) {
|
| if (tokens == null || tokens === '') return '—';
|
| const n = Number(tokens);
|
| if (!Number.isFinite(n) || n < 0) return '—';
|
| if (n < 1000) return String(Math.round(n));
|
| const units = [['k', 1e3], ['m', 1e6], ['b', 1e9]];
|
| let unit = units[0];
|
| for (const candidate of units) {
|
| if (n >= candidate[1]) unit = candidate;
|
| }
|
| let value = n / unit[1];
|
| let rounded = Number(value.toFixed(1));
|
|
|
| const next = units[units.indexOf(unit) + 1];
|
| if (next && rounded >= 1000) {
|
| unit = next;
|
| value = n / unit[1];
|
| rounded = Number(value.toFixed(1));
|
| }
|
| return rounded + unit[0];
|
| }
|
|
|
| function formatLatency(ms) {
|
| if (ms == null || ms === '') return '—';
|
| const n = Number(ms);
|
| if (!Number.isFinite(n) || n <= 0) return '—';
|
| return n < 1000 ? Math.round(n) + 'ms' : (n / 1000).toFixed(1).replace(/\.0$/, '') + 's';
|
| }
|
| function formatRate(rate) {
|
| if (rate == null || rate === '') return '—';
|
| const n = Number(rate);
|
| if (!Number.isFinite(n) || n < 0) return '—';
|
| return n.toFixed(1) + 'tok/s';
|
| }
|
|
|
|
|
| function openKey() { $('keyVeil').classList.add('on'); setTimeout(() => $('keyInput').focus(), 60); }
|
| $('btnKey').onclick = async () => {
|
| const v = $('keyInput').value.trim();
|
| if (!v) return;
|
| localStorage.setItem(LS_KEY, v);
|
| try {
|
| await api('overview');
|
| $('keyErr').hidden = true;
|
| $('keyVeil').classList.remove('on');
|
| start();
|
| } catch (e) { $('keyErr').hidden = false; }
|
| };
|
| $('keyInput').addEventListener('keydown', e => { if (e.key === 'Enter') $('btnKey').click(); });
|
|
|
|
|
| |
| |
|
|
| let lastPackages = null;
|
| let lastPackagesAt = 0;
|
| let expFetching = false;
|
| const EXP_FRESH_MS = 2 * 60 * 1000;
|
|
|
| const TITLES = { accounts: '账号池', usage: '用量', packages: '积分构成', taskscenter: '任务中心', models: '模型与档位', config: '配置', logs: '运行日志' };
|
| function go(v) {
|
| view = v;
|
| document.querySelectorAll('.view').forEach(s => s.hidden = s.id !== 'view-' + v);
|
| document.querySelectorAll('.nav a').forEach(a => a.classList.toggle('on', a.dataset.view === v));
|
| $('ttl').textContent = TITLES[v];
|
| if (v === 'models' && !$('mdBody').children.length) loadModels();
|
| if (v === 'config') loadConfig();
|
| if (v === 'logs') loadLogs();
|
| if (v === 'usage') loadUsage();
|
| if (v === 'packages') loadPackages();
|
| if (v === 'accounts') loadExpiry();
|
| if (v === 'taskscenter') reattachQueueView();
|
| }
|
| document.querySelectorAll('.nav a').forEach(a => a.onclick = e => { e.preventDefault(); go(a.dataset.view); history.replaceState(null, '', '#' + a.dataset.view); });
|
| |
| |
| |
| |
| |
|
|
| setTimeout(() => {
|
| const hash = (location.hash || '#accounts').slice(1);
|
| go(hash in TITLES ? hash : 'accounts');
|
| }, 0);
|
|
|
|
|
| function renderAccounts(list) {
|
| const tb = $('accBody');
|
| if (!list.length) {
|
| tb.innerHTML = '<tr><td colspan="9"><div class="empty"><div class="big">账号池是空的</div>点击右上角「添加账号」，用浏览器登录一个 WorkBuddy 账号</div></td></tr>';
|
| return;
|
| }
|
|
|
| const maxCred = Math.max(1, ...list.map(s => s.credits || 0));
|
| tb.innerHTML = list.map(s => {
|
| const bl = (new Date(s.breaker_until || 0) - Date.now()) / 1000;
|
| const dg = (new Date(s.degrade_until || 0) - Date.now()) / 1000;
|
| const cool = Math.max(s.cool_remaining_sec || 0, bl > 0 ? bl : 0, dg > 0 ? dg : 0);
|
| let cls = '', tag;
|
| if (s.disabled) { cls = 'off'; tag = '<span class="tag bad">已禁用</span>'; }
|
| else if (s.paused) { cls = 'off'; tag = '<span class="tag warn">已暂停选号</span>'; }
|
| else if (cool > 0) {
|
| cls = 'cool';
|
| const kind = bl > Math.max(s.cool_remaining_sec || 0, dg > 0 ? dg : 0) ? '熔断'
|
| : (dg > (s.cool_remaining_sec || 0) ? '连败降权' : (s.cool_kind === 'hard_credit' ? '积分冷却' : '限流冷却'));
|
| tag = '<span class="tag warn">' + kind + ' · ' + dur(cool) + '</span>';
|
| } else tag = '<span class="tag ok">可用</span>' + (s.in_flight ? '' : '');
|
| const note = s.reason ? '<div class="hint" style="font-size:11.5px;color:var(--ink-3);margin-top:3px">' + esc(s.reason) + '</div>' : '';
|
| const rateLimits = rateLimitRowsHtml(s.rate_limited_models, Date.now());
|
| const short = s.uid.length > 16 ? s.uid.slice(0, 16) + '…' : s.uid;
|
| const cred = s.credits == null ? '—' : (s.credits_total > 0 ? s.credits + '<span class="of">/' + s.credits_total + '</span>' : String(s.credits));
|
| const pct = s.credits_total > 0
|
| ? Math.min(100, Math.round((s.credits || 0) / s.credits_total * 100))
|
| : Math.round((s.credits || 0) / maxCred * 100);
|
|
|
|
|
| let credTip = s.credits_total > 0 ? '剩余 ' + s.credits + ' / 总额 ' + s.credits_total + '（' + pct + '%）' : '积分（相对池内最高）';
|
| const costs = (s.model_costs || []).filter(c => c.model);
|
| if (costs.length) {
|
| credTip += '\n实测单价（credits/1K）：\n' + costs.map(c =>
|
| ' ' + c.model + '：' + (c.cost_per_1k <= 0 ? '免费' : c.cost_per_1k)).join('\n');
|
| }
|
| const frozen = s.disabled || cool > 0;
|
| const tu = s.token_usage || {};
|
| const req = tu.request_count || 0;
|
| const totalTok = formatTokenCount(tu.total_tokens);
|
| const totalTokUnit = totalTok === '—' ? '' : '<em>tok</em>';
|
| const latency = formatLatency(tu.last_latency_ms);
|
| const rate = formatRate(tu.last_tokens_per_second);
|
| const usageTitle = '最近一次：' + req + ' 次 / ' + totalTok + ' / 延迟 ' + latency + ' / ' + rate;
|
| return '<tr class="' + cls + '" title="uid: ' + esc(s.uid) + '">' +
|
| '<td class="mark" aria-hidden="true"><i></i></td>' +
|
| '<td class="who"><div class="nm">' + (s.nickname ? esc(s.nickname) : '<span style="color:var(--ink-3)">未命名</span>') + (s.realm === 'global' ? ' <span class="realm-tag">国际版</span>' : '') + '</div><div class="id">' + esc(short) + '</div></td>' +
|
| '<td>' + tag + note + rateLimits + '</td>' +
|
| '<td class="cred" title="' + esc(credTip) + '"><div class="n">' + cred + '</div><div class="bar"><i style="width:' + pct + '%"></i></div></td>' +
|
| '<td class="num">' + (s.success_count || 0) + ' <span style="color:var(--ink-3)">/</span> <span style="color:var(--bad)">' + (s.err_total || 0) + '</span></td>' +
|
| '<td class="num">' + (s.in_flight || 0) + '</td>' +
|
| '<td class="num usage-cell" title="' + esc(usageTitle) + '"><span class="usage-line" aria-label="' + esc(usageTitle) + '">' +
|
| '<span class="usage-item usage-count"><b>' + req + '</b><em>次</em></span>' +
|
| '<span class="usage-item usage-total"><b>' + totalTok + '</b>' + totalTokUnit + '</span>' +
|
| '<span class="usage-item usage-latency"><b>' + latency + '</b></span>' +
|
| '<span class="usage-item usage-rate"><b>' + rate + '</b></span>' +
|
| '</span></td>' +
|
| '<td class="num" style="color:var(--ink-3)">' + ago(s.last_success) + '</td>' +
|
| '<td class="acts">' +
|
| '<button class="xs ghost" data-a="checkin" data-u="' + esc(s.uid) + '"' + (s.checkin_done ? ' title="今日已签到；点击可重新签到并刷新余额"' : '') + '>' + (s.checkin_done ? '已签' : '签到') + '</button>' +
|
| '<button class="xs ghost" data-a="balance" data-u="' + esc(s.uid) + '">余额</button>' +
|
| '<button class="xs ghost" data-a="tasks" data-u="' + esc(s.uid) + '">任务</button>' +
|
| (frozen ? '<button class="xs primary" data-a="revive" data-u="' + esc(s.uid) + '">解冻</button>'
|
| : (s.paused ? '<button class="xs primary" data-a="resume" data-u="' + esc(s.uid) + '">恢复选号</button>'
|
| : '<button class="xs ghost" data-a="pause" data-u="' + esc(s.uid) + '" title="退出选号，但照常签到 / 活跃上报 / 保活 / 刷新余额">暂停选号</button>')) +
|
| (s.disabled ? '' : '<button class="xs ghost" data-a="disable" data-u="' + esc(s.uid) + '">禁用</button>') +
|
| '<button class="xs ghost danger" data-a="remove" data-u="' + esc(s.uid) + '">移除</button>' +
|
| '</td></tr>';
|
| }).join('');
|
| }
|
|
|
|
|
|
|
| function renderModelLocks(rows) {
|
| const tb = $('mlBody');
|
| if (!tb) return;
|
| const note = $('mlNote');
|
| if (!rows || !rows.length) {
|
| tb.innerHTML = '<tr><td colspan="8"><div class="empty">当前没有模型级限流 —— 所有模型均可选</div></td></tr>';
|
| if (note) note.textContent = '';
|
| return;
|
| }
|
| const STATE = { locked: ['bad', '整池不可用'], starved: ['warn', '没号可用'], partial: ['warn', '部分限流'] };
|
| const left = iso => {
|
| const ms = parseAPITime(iso);
|
| return ms ? dur(Math.max(0, Math.round((ms - Date.now()) / 1000))) : '—';
|
| };
|
| tb.innerHTML = rows.map(r => {
|
| const st = STATE[r.state] || ['mute', r.state || '—'];
|
| const realm = r.realm === 'global' ? '国际版' : '国内版';
|
| return '<tr>' +
|
| '<td>' + esc(r.model) + '</td>' +
|
| '<td><span class="realm-tag">' + realm + '</span></td>' +
|
| '<td><span class="tag ' + st[0] + '">' + st[1] + '</span></td>' +
|
| '<td class="num">' + (r.servable || 0) + ' / ' + (r.total || 0) + '</td>' +
|
| '<td class="num">' + (r.locked || 0) + '</td>' +
|
| '<td class="num">' + left(r.unlock_at || r.fully_unlock_at) + '</td>' +
|
| '<td class="num">' + left(r.fully_unlock_at) + '</td>' +
|
| '<td>' + (r.reason ? '<div class="note">' + esc(r.reason) + '</div>' : '—') + '</td>' +
|
| '</tr>';
|
| }).join('');
|
| if (note) {
|
| const bad = rows.filter(r => r.state === 'locked' || r.state === 'starved').length;
|
| note.textContent = bad ? bad + ' 个模型整池不可用' : rows.length + ' 个模型部分限流';
|
| }
|
| }
|
|
|
| async function loadOverview(quiet) {
|
| try {
|
| const d = await api('overview');
|
| overviewData = d;
|
| $('sTotal').textContent = d.total;
|
| $('sHealthy').textContent = d.healthy;
|
| $('sCooling').textContent = d.cooling;
|
| $('sDisabled').textContent = d.disabled;
|
| const remSum = (d.accounts || []).reduce((a, s) => a + (s.credits || 0), 0);
|
| const totSum = (d.accounts || []).reduce((a, s) => a + (s.credits_total || 0), 0);
|
| $('sCredits').textContent = totSum > 0 ? remSum + ' / ' + totSum : remSum;
|
| $('sSticky').textContent = d.sticky_sessions;
|
| $('navSub').textContent = 'v' + d.version;
|
| $('navVer').textContent = 'v' + d.version;
|
| $('navRedis').textContent = d.redis_mode === 'upstash' ? 'Redis 镜像' : '本地内存';
|
| $('navState').textContent = d.healthy > 0 ? '服务正常' : (d.total ? '无可用账号' : '待添加账号');
|
| const p = $('navPulse');
|
| p.className = 'pulse' + (d.healthy > 0 ? '' : (d.total ? ' warn' : ' bad'));
|
| $('accNote').textContent = d.in_flight_full ? d.in_flight_full + ' 个账号在途占满' : '';
|
| const up = Math.floor(d.uptime_sec);
|
| $('subMeta').textContent = '运行 ' + (up >= 86400 ? Math.floor(up / 86400) + ' 天 ' : '') + Math.floor(up % 86400 / 3600) + ' 时 ' + Math.floor(up % 3600 / 60) + ' 分';
|
| renderAccounts(d.accounts || []);
|
| renderModelLocks(d.model_locks);
|
| } catch (e) { if (!quiet) toast(e.message, 'err'); }
|
| }
|
|
|
| $('accBody').addEventListener('click', async ev => {
|
| const b = ev.target.closest('button[data-a]');
|
| if (!b) return;
|
| const u = b.dataset.u, a = b.dataset.a;
|
| if (a === 'remove' && !confirm('移除账号将删除池状态与 auths/ 下的凭证文件，且不可恢复。确认移除？')) return;
|
| if (a === 'disable' && !confirm('禁用后该账号不再参与选号（保号任务默认也跳过），需手动解冻才能恢复。若只是想临时让位、仍要保号，请改用「暂停选号」。确认禁用？')) return;
|
| b.disabled = true;
|
| try {
|
| if (a === 'checkin') {
|
| const r = await api('accounts/' + encodeURIComponent(u) + '/checkin', { method: 'POST' });
|
| toast('签到完成' + (r.credits != null ? '，积分 ' + r.credits + (r.credits_total > 0 ? '/' + r.credits_total : '') : '') + (r.checkin_message ? '（' + r.checkin_message + '）' : ''), 'ok');
|
| } else if (a === 'balance') {
|
| const r = await api('accounts/' + encodeURIComponent(u) + '/balance', { method: 'POST' });
|
| toast('余额已更新：' + r.credits + (r.credits_total > 0 ? ' / ' + r.credits_total : ''), 'ok');
|
| } else if (a === 'revive') {
|
| await api('accounts/' + encodeURIComponent(u) + '/revive', { method: 'POST' });
|
| toast('已解冻', 'ok');
|
| } else if (a === 'disable') {
|
| await api('accounts/' + encodeURIComponent(u) + '/disable', { method: 'POST' });
|
| toast('已禁用', 'ok');
|
| } else if (a === 'pause') {
|
| await api('accounts/' + encodeURIComponent(u) + '/pause', { method: 'POST' });
|
| toast('已暂停选号（签到 / 保活照常）', 'ok');
|
| } else if (a === 'resume') {
|
| await api('accounts/' + encodeURIComponent(u) + '/resume', { method: 'POST' });
|
| toast('已恢复选号', 'ok');
|
| } else if (a === 'tasks') {
|
| openTasks(u);
|
| } else if (a === 'remove') {
|
| const r = await api('accounts/' + encodeURIComponent(u) + '/remove', { method: 'POST' });
|
| toast(r.file_error ? '已移除（凭证文件删除失败：' + r.file_error + '）' : '已移除', 'ok');
|
| }
|
| } catch (e) { toast(e.message, 'err'); }
|
| finally { b.disabled = false; loadOverview(true); }
|
| });
|
|
|
| $('btnCheckinAll').onclick = async () => {
|
| try { await api('checkin_all', { method: 'POST' }); toast('全部签到已开始，结果见日志', 'ok'); }
|
| catch (e) { toast(e.message, 'err'); }
|
| };
|
| $('btnKeepaliveAll').onclick = async () => {
|
| try { await api('keepalive_all', { method: 'POST' }); toast('全部保活已开始，结果见日志', 'ok'); }
|
| catch (e) { toast(e.message, 'err'); }
|
| };
|
| $('btnTravelAll').onclick = async () => {
|
| try { await api('travel_all', { method: 'POST' }); toast('旅行巡检已开始（含领养链路），结果见日志', 'ok'); }
|
| catch (e) { toast(e.message, 'err'); }
|
| };
|
| $('btnActivityAll').onclick = async () => {
|
| try { await api('activity_all', { method: 'POST' }); toast('活跃上报已开始，结果见日志', 'ok'); }
|
| catch (e) { toast(e.message, 'err'); }
|
| };
|
|
|
|
|
| |
| |
|
|
| function fmtK(n) { n = Number(n || 0); return n >= 1000 ? Math.round(n / 1000) + 'K' : String(n); }
|
| function probeDays(ts) {
|
| if (!ts) return null;
|
| const t = new Date(String(ts).replace(' ', 'T'));
|
| const d = (Date.now() - t.getTime()) / 86400000;
|
| return isNaN(d) ? null : Math.floor(d);
|
| }
|
| function outCell(m, pr) {
|
| if (!pr) return '<td class="num">' + (m.max_output_tokens ? fmtK(m.max_output_tokens) : '—') + '</td>';
|
| const tip = '声称 ' + (pr.claimed ? fmtK(pr.claimed) : '?') + ' · 实测 ' + (pr.measured ? fmtK(pr.measured) : '?') +
|
| (pr.note ? ' · ' + pr.note : '') + (pr.tested_at ? ' · 探测于 ' + pr.tested_at : '');
|
| const days = probeDays(pr.tested_at);
|
| const stale = days !== null && days > 30 ? ' · ' + days + ' 天前' : '';
|
| if (pr.verdict === 'clamped' && pr.measured) {
|
| if (pr.claimed && pr.measured < pr.claimed) {
|
| const x = pr.claimed / pr.measured;
|
| const xs = (x >= 10 ? Math.round(x) : Math.round(x * 10) / 10) + '×';
|
| return '<td class="num" title="' + esc(tip) + '"><span style="color:var(--warn);font-weight:600">' +
|
| fmtK(pr.measured) + ' ⚠</span><div class="note">钳制 ' + xs + stale + '</div></td>';
|
| }
|
| return '<td class="num" title="' + esc(tip) + '"><span style="color:var(--ok)">' + fmtK(pr.measured) +
|
| (pr.claimed && pr.measured > pr.claimed ? ' ↑' : ' ✓') + '</span></td>';
|
| }
|
| if (pr.verdict === 'at_least' && pr.measured)
|
| return '<td class="num" title="' + esc(tip) + '"><span style="color:var(--ink-3)">≥' + fmtK(pr.measured) + '</span></td>';
|
| return '<td class="num" title="' + esc(tip) + '"><span style="color:var(--ink-3)">?</span><div class="note">未测出' + stale + '</div></td>';
|
| }
|
|
|
| |
| |
| |
|
|
| function rateCell(m) {
|
| const tip = m.promo_note ? ' title="' + esc(m.promo_note) + '"' : '';
|
| if (m.promo_factor != null && m.promo_credits) {
|
| const base = m.credits ? ' <s style="color:var(--ink-3);font-size:11.5px">' + esc(m.credits) + '</s>' : '';
|
| const label = m.promo_label ? ' <span class="tag ok">' + esc(m.promo_label) + '</span>' : '';
|
| return '<span' + tip + ' style="cursor:help"><b>' + esc(m.promo_credits) + '</b>' + label + base + '</span>';
|
| }
|
| if (m.promo_label) {
|
| return '<span' + tip + ' style="cursor:help">' + (m.credits ? esc(m.credits) : '—') +
|
| ' <span class="tag warn">' + esc(m.promo_label) + '</span></span>';
|
| }
|
| return m.credits ? esc(m.credits) : '—';
|
| }
|
|
|
| async function loadModels() {
|
| const tb = $('mdBody');
|
| tb.innerHTML = '<tr><td colspan="7"><div class="empty">正在向上游查询…</div></td></tr>';
|
| try {
|
|
|
| const [d, pr] = await Promise.all([api('models'), api('model_probes').catch(() => ({}))]);
|
| mdAll = d.models || [];
|
| mdProbes = pr.probes || {};
|
| if (!mdAll.length) {
|
| tb.innerHTML = '<tr><td colspan="7"><div class="empty">上游未返回模型</div></td></tr>';
|
| $('mdCount').textContent = '';
|
| $('mdNote').textContent = '上游未返回模型';
|
| return;
|
| }
|
|
|
| const probeKeys = Object.keys(mdProbes);
|
| mdProbeOf = id => mdProbes[id] || mdProbes[probeKeys.find(k => k.endsWith(':' + id))];
|
| const hit = mdAll.filter(m => mdProbeOf(m.id)).length;
|
| $('mdNote').textContent = mdAll.length + ' 个模型 · 已刷新降级缓存' + (hit ? ' · ' + hit + ' 个有实测上限' : '');
|
| renderModels();
|
| } catch (e) {
|
| mdAll = [];
|
| tb.innerHTML = '<tr><td colspan="7"><div class="empty">' + esc(e.message) + '</div></td></tr>';
|
| $('mdCount').textContent = '';
|
| }
|
| }
|
|
|
| |
| |
| |
|
|
|
|
|
|
| function mdRateValue(m) {
|
| const raw = (m.promo_credits != null && m.promo_credits !== '') ? m.promo_credits : m.credits;
|
| const n = parseFloat(String(raw == null ? '' : raw).replace(/[^\d.]/g, ''));
|
| return Number.isFinite(n) ? n : Infinity;
|
| }
|
|
|
|
|
| function mdSearchText(m) {
|
| return [m.id, m.name, m.vendor, m.description, (m.tags || []).join(' ')]
|
| .filter(Boolean).join(' ').toLowerCase();
|
| }
|
|
|
|
|
| function mdMatch(m, f) {
|
| f = f || mdFilter;
|
| if (f.q) {
|
| const text = mdSearchText(m);
|
|
|
| for (const kw of f.q.toLowerCase().split(/\s+/).filter(Boolean)) {
|
| if (!text.includes(kw)) return false;
|
| }
|
| }
|
| if (f.realm && !String(m.id || '').startsWith(f.realm + ':')) return false;
|
| if (f.cap === 'tool' && !m.supports_tool_call) return false;
|
| if (f.cap === 'vision' && !m.supports_images) return false;
|
| if (f.cap === 'reasoning' && !m.supports_reasoning) return false;
|
| if (f.cap === 'default' && !m.is_default) return false;
|
| if (f.effort === 'off') {
|
| if (!m.can_disable_thinking) return false;
|
| } else if (f.effort && !(m.supported_efforts || []).includes(f.effort)) {
|
| return false;
|
| }
|
| const factor = m.promo_factor == null ? null : Number(m.promo_factor);
|
| if (f.promo === 'promo' && factor == null && !m.promo_label) return false;
|
| if (f.promo === 'free' && !(factor === 0)) return false;
|
| if (f.promo === 'discount' && !(factor != null && factor > 0)) return false;
|
| return true;
|
| }
|
|
|
|
|
| function mdSortList(list, f) {
|
| f = f || mdFilter;
|
| const out = list.slice();
|
| const num = v => { const n = Number(v || 0); return Number.isFinite(n) ? n : 0; };
|
| if (f.sort === 'rate') out.sort((a, b) => mdRateValue(a) - mdRateValue(b));
|
| else if (f.sort === 'context') out.sort((a, b) => num(b.context_length) - num(a.context_length));
|
| else if (f.sort === 'output') out.sort((a, b) => num(b.max_output_tokens) - num(a.max_output_tokens));
|
| else if (f.sort === 'name') out.sort((a, b) => String(a.id || '').localeCompare(String(b.id || '')));
|
| return out;
|
| }
|
|
|
|
|
| function mdRowHtml(m, pr) {
|
| const eff = (m.supported_efforts || []).slice();
|
| if (m.can_disable_thinking && eff.length && !eff.includes('off')) eff.push('off（可关）');
|
| const effs = eff.length ? eff.map(e => '<span class="tag warn">' + esc(e) + '</span>').join(' ')
|
| : '<span style="color:var(--ink-3);font-size:12.5px">' + (m.supports_reasoning ? '固定档 · 默认 ' + esc(m.default_effort || '?') : '不支持思考') + '</span>';
|
|
|
| const caps = [];
|
| if (m.is_default) caps.push('<span class="tag ok">默认</span>');
|
| if (m.supports_tool_call) caps.push('<span class="tag warn">工具</span>');
|
| if (m.supports_images) caps.push('<span class="tag warn">视觉</span>');
|
| if (m.supports_reasoning && !m.can_disable_thinking) caps.push('<span class="tag warn">思考常开</span>');
|
| const capHtml = caps.length ? '<div class="id" style="margin-top:2px">' + caps.join(' ') + '</div>' : '';
|
| const tip = m.description ? ' title="' + esc(m.description) + '"' : '';
|
| return '<tr><td class="mark" aria-hidden="true"><i></i></td><td class="who"' + tip + '><div class="nm">' + esc(m.id) + '</div><div class="id">' + esc(m.name || '') + '</div>' + capHtml + '</td>' +
|
| '<td class="num">' + rateCell(m) + '</td>' +
|
| '<td>' + (m.default_effort ? '<span class="tag ok">' + esc(m.default_effort) + '</span>' : '<span style="color:var(--ink-3)">—</span>') + '</td>' +
|
| '<td class="efs" style="white-space:normal">' + effs + '</td>' +
|
| '<td class="num">' + (m.context_length ? Math.round(m.context_length / 1000) + 'K' : '—') + '</td>' +
|
| outCell(m, pr) + '</tr>';
|
| }
|
|
|
| function renderModels() {
|
| const tb = $('mdBody');
|
| const list = mdSortList(mdAll.filter(m => mdMatch(m)));
|
| if (!list.length) {
|
| tb.innerHTML = '<tr><td colspan="7"><div class="empty">没有符合当前筛选条件的模型</div></td></tr>';
|
| } else {
|
| tb.innerHTML = list.map(m => mdRowHtml(m, mdProbeOf(m.id))).join('');
|
| }
|
| const filtered = list.length !== mdAll.length;
|
| $('mdCount').textContent = !mdAll.length ? ''
|
| : filtered ? '命中 ' + list.length + ' / ' + mdAll.length + ' 个模型'
|
| : mdAll.length + ' 个模型';
|
| $('mdCount').className = filtered ? 'note src-off' : 'note';
|
| }
|
|
|
| function resetModelFilter() {
|
| mdFilter = { q: '', realm: '', cap: '', effort: '', promo: '', sort: 'default' };
|
| $('mdQ').value = ''; $('mdRealm').value = ''; $('mdCap').value = '';
|
| $('mdEffort').value = ''; $('mdPromo').value = ''; $('mdSort').value = 'default';
|
| renderModels();
|
| }
|
|
|
|
|
| let mdQTimer = null;
|
| $('mdQ').oninput = () => {
|
| clearTimeout(mdQTimer);
|
| mdQTimer = setTimeout(() => { mdFilter.q = $('mdQ').value.trim(); renderModels(); }, 120);
|
| };
|
| for (const [id, key] of [['mdRealm', 'realm'], ['mdCap', 'cap'], ['mdEffort', 'effort'], ['mdPromo', 'promo'], ['mdSort', 'sort']]) {
|
| const el = $(id);
|
| if (!el) continue;
|
| el.onchange = () => { mdFilter[key] = el.value; renderModels(); };
|
| }
|
| $('mdReset').onclick = resetModelFilter;
|
| $('btnModels').onclick = loadModels;
|
|
|
|
|
| let logCh = 'all';
|
| $('logChips').addEventListener('click', ev => {
|
| const b = ev.target.closest('button[data-ch]');
|
| if (!b) return;
|
| logCh = b.dataset.ch;
|
| document.querySelectorAll('#logChips .chip').forEach(c => c.classList.toggle('on', c === b));
|
| loadLogs();
|
| });
|
| async function loadLogs() {
|
| const box = $('logBox');
|
| const atEnd = box.scrollTop + box.clientHeight >= box.scrollHeight - 24;
|
| const limit = ($('reqLimit') && $('reqLimit').value) || 100;
|
|
|
|
|
| const rq = trangeQuery('reqRange', false);
|
| rq.set('limit', limit);
|
| try {
|
| const [d, metrics, requestRows] = await Promise.all([
|
| api('logs'),
|
| api('request_metrics').catch(() => ({})),
|
| api('request_logs?' + rq.toString()).catch(() => ({ entries: [] })),
|
| ]);
|
|
|
|
|
|
|
| const archiveOn = !!(metrics && metrics.archive && metrics.archive.enabled);
|
| const recent = archiveOn ? (requestRows.entries || []) : (metrics.recent || []);
|
| renderRequestMetrics(metrics, recent);
|
| const entries = (d.entries || []).filter(e => logCh === 'all' || e.ch === logCh);
|
| box.innerHTML = entries.length
|
| ? entries.map(e => {
|
| const lvl = /error|失败|错误/.test(e.text) ? ' e' : /warn|冷却|熔断/.test(e.text) ? ' w' : '';
|
| const t = e.ts ? new Date(e.ts).toLocaleTimeString('zh-CN', { hour12: false }) : '';
|
| const ch = logCh === 'all' ? '<i class="lch c-' + esc(e.ch) + '">' + ({ task: '任务', chat: '对话', sys: '系统' }[e.ch] || e.ch) + '</i>' : '';
|
| return '<span class="ln' + lvl + '">' + ch + esc(t + ' ' + e.text) + '</span>';
|
| }).join('')
|
| : '<span style="color:var(--ink-3)">暂无日志</span>';
|
| if (logPin && atEnd) box.scrollTop = box.scrollHeight;
|
| const counts = {};
|
| for (const e of (d.entries || [])) counts[e.ch] = (counts[e.ch] || 0) + 1;
|
| $('logNote').textContent = logCh === 'all'
|
| ? '任务 ' + (counts.task || 0) + ' · 对话 ' + (counts.chat || 0) + ' · 系统 ' + (counts.sys || 0)
|
| : (logCh === 'task' ? '任务' : logCh === 'chat' ? '对话' : '系统') + ' ' + entries.length + ' 行';
|
| } catch (e) { }
|
| }
|
|
|
| function renderRequestMetrics(m, entries) {
|
| m = m || {};
|
| const a = m.archive || {};
|
| $('reqSummary').textContent =
|
| '已完成 ' + fmtTok(m.completed) +
|
| ' · 成功 ' + (m.success_rate == null ? '—' : Number(m.success_rate).toFixed(1) + '%') +
|
| ' · HTTP ' + (m.http_success_rate == null ? '—' : Number(m.http_success_rate).toFixed(1) + '%') +
|
| ' · 平均 ' + fmtMs(m.avg_duration_ms) +
|
| ' · 进行中 ' + String(m.in_flight || 0);
|
| $('reqNote').textContent = a.enabled
|
| ? 'JSONL 归档 ' + fmtBytes(a.bytes) + (a.dropped_writes ? ' · 丢弃 ' + a.dropped_writes + ' 条' : '') +
|
| (a.last_error ? ' · 错误：' + a.last_error : '')
|
| : '仅内存指标，JSONL 归档已关闭';
|
|
|
| reqEntries = entries || [];
|
| renderRequestTable();
|
| }
|
|
|
| |
|
|
| function reqMatch(e, f) {
|
| f = f || reqFilter;
|
| if (f.outcome && String(e && e.outcome || '') !== f.outcome) return false;
|
| if (f.q) {
|
| const text = [e && e.client_ip, e && e.user_agent, e && e.model, e && e.account, e && e.request_id]
|
| .filter(Boolean).join(' ').toLowerCase();
|
| for (const kw of f.q.toLowerCase().split(/\s+/).filter(Boolean)) {
|
| if (!text.includes(kw)) return false;
|
| }
|
| }
|
| return true;
|
| }
|
|
|
| function reqOutcomeTag(e) {
|
| const outcome = String(e && e.outcome || '');
|
| const label = { success: '成功', http_error: 'HTTP 错误', stream_error: '流错误', interrupted: '中断' }[outcome] || outcome || '—';
|
| const cls = outcome === 'success' ? 'ok'
|
| : outcome === 'interrupted' ? 'warn'
|
| : outcome ? 'bad' : 'mute';
|
| return '<span class="tag ' + cls + '">' + esc(String(e && e.status || '—') + ' ' + label) + '</span>';
|
| }
|
|
|
| function reqTokenCell(e) {
|
| const total = Number(e && e.total_tokens || 0) ||
|
| (Number(e && e.prompt_tokens || 0) + Number(e && e.completion_tokens || 0));
|
| return total ? fmtTok(total) : '—';
|
| }
|
|
|
| function reqCreditCell(e) {
|
| if (!e || !e.credit_known) return '<span class="muted">—</span>';
|
| const v = Number(e.credit);
|
| return Number.isFinite(v) ? trimFixed(v.toFixed(2)) : '<span class="muted">—</span>';
|
| }
|
|
|
| |
|
|
| function renderRequestTable() {
|
| const list = reqEntries.filter(e => reqMatch(e));
|
| const tb = $('reqBody');
|
| if (!tb) return;
|
| tb.innerHTML = list.map(e => {
|
| const when = e && e.time ? new Date(e.time).toLocaleTimeString('zh-CN', { hour12: false }) : '—';
|
| const ip = e && e.client_ip ? e.client_ip : '';
|
| const ua = e && e.user_agent ? e.user_agent : '';
|
| const rid = e && e.request_id ? e.request_id : '';
|
| return '<tr title="' + esc(requestLogText(e)) + '">' +
|
| '<td class="num">' + esc(when) + '</td>' +
|
| '<td>' + reqOutcomeTag(e) + '</td>' +
|
| '<td>' + esc(e && e.model || '—') + '</td>' +
|
| '<td>' + esc(e && e.account || '—') + '</td>' +
|
| '<td>' + (ip ? '<span class="clip ip" title="' + esc(ip) + '">' + esc(ip) + '</span>' : '<span class="muted">—</span>') + '</td>' +
|
| '<td>' + (ua ? '<span class="clip" title="' + esc(ua) + '">' + esc(ua) + '</span>' : '<span class="muted">—</span>') + '</td>' +
|
| '<td class="num">' + fmtMs(e && e.duration_ms) + '</td>' +
|
| '<td class="num">' + reqTokenCell(e) + '</td>' +
|
| '<td class="num">' + reqCreditCell(e) + '</td>' +
|
| '<td>' + (rid ? '<span class="clip rid" title="' + esc(rid) + '">' + esc(rid) + '</span>' : '<span class="muted">—</span>') + '</td>' +
|
| '</tr>';
|
| }).join('') || '<tr><td colspan="10" class="empty">' +
|
| (reqEntries.length ? '没有符合当前筛选条件的请求记录' : '暂无请求记录') + '</td></tr>';
|
|
|
| const filtered = list.length !== reqEntries.length;
|
|
|
|
|
| const hasSource = reqEntries.some(e => e && (e.client_ip || e.user_agent));
|
| $('reqCount').textContent = !reqEntries.length ? ''
|
| : (filtered ? '命中 ' + list.length + ' / ' + reqEntries.length + ' 条' : reqEntries.length + ' 条') +
|
| (hasSource ? '' : ' · 来源未记录');
|
| $('reqCount').className = (filtered || !hasSource) ? 'note src-off' : 'note';
|
| }
|
|
|
| |
| |
|
|
| let reqQTimer = null;
|
| if ($('reqQ')) $('reqQ').oninput = () => {
|
| clearTimeout(reqQTimer);
|
| reqQTimer = setTimeout(() => { reqFilter.q = $('reqQ').value.trim(); renderRequestTable(); }, 150);
|
| };
|
| if ($('reqOutcome')) $('reqOutcome').onchange = () => {
|
| reqFilter.outcome = $('reqOutcome').value;
|
| renderRequestTable();
|
| };
|
| if ($('reqLimit')) $('reqLimit').onchange = loadLogs;
|
| if ($('btnReqReload')) $('btnReqReload').onclick = loadLogs;
|
|
|
|
|
| if ($('reqRange')) trangeBind('reqRange', loadLogs, '0');
|
|
|
| function requestLogText(e) {
|
| const when = e && e.time ? new Date(e.time).toLocaleTimeString('zh-CN', { hour12: false }) : '—';
|
| const outcomeLabel = { success: '成功', http_error: 'HTTP 错误', stream_error: '流错误', interrupted: '中断' };
|
| const token = Number(e && e.total_tokens || 0) ||
|
| (Number(e && e.prompt_tokens || 0) + Number(e && e.completion_tokens || 0));
|
| let credit = 'credit —';
|
| if (e && e.credit_known) {
|
| const value = Number(e.credit);
|
| if (Number.isFinite(value)) credit = String(Number(value.toFixed(2))) + ' credit';
|
| }
|
| return [
|
| when,
|
| String(e && e.status || '—') + ' ' + (outcomeLabel[e && e.outcome] || (e && e.outcome) || '—'),
|
| e && e.model || '—',
|
| e && e.account || '—',
|
| e && e.client_ip || '—',
|
| e && e.user_agent || '—',
|
| fmtMs(e && e.duration_ms),
|
| fmtTok(token) + ' tok',
|
| credit,
|
| cacheRateText(e && e.cache_hit_tokens, e && e.cache_miss_tokens) === '—' ? '' : '命中 ' + cacheRateText(e && e.cache_hit_tokens, e && e.cache_miss_tokens),
|
| e && e.request_id || '—',
|
| ].filter(Boolean).join(' | ');
|
| }
|
|
|
| |
|
|
| function cacheRateText(hit, miss) {
|
| const h = Number(hit || 0), m = Number(miss || 0), total = h + m;
|
| if (!total) return '—';
|
| return String(Math.round(h / total * 1000) / 10) + '%';
|
| }
|
|
|
| function fmtBytes(bytes) {
|
| const n = Number(bytes || 0);
|
| if (n < 1024) return n + ' B';
|
| if (n < 1024 * 1024) return (n / 1024).toFixed(1) + ' KB';
|
| return (n / 1024 / 1024).toFixed(1) + ' MB';
|
| }
|
| $('btnLogPin').onclick = () => {
|
| logPin = !logPin;
|
| $('btnLogPin').textContent = '自动滚动：' + (logPin ? '开' : '关');
|
| };
|
|
|
|
|
| const CFG_MAP = {
|
| listen: ['listen'], api_key: ['api_key'],
|
| package_detail_limit: ['panel', 'package_detail_limit'],
|
| checkin_hours: ['schedule', 'checkin_hours'], checkin_enabled: ['schedule', 'checkin_enabled'], growth_hours: ['schedule', 'growth_hours'], growth_enabled: ['schedule', 'growth_enabled'],
|
| travel_hours: ['schedule', 'travel_hours'], travel_enabled: ['schedule', 'travel_enabled'],
|
| activity_hours: ['schedule', 'activity_hours'], activity_enabled: ['schedule', 'activity_enabled'],
|
| keepalive_hours: ['schedule', 'keepalive_hours'], keepalive_enabled: ['schedule', 'keepalive_enabled'],
|
| balance_refresh_enabled: ['schedule', 'balance_refresh_enabled'], balance_refresh_minutes: ['schedule', 'balance_refresh_minutes'],
|
| include_disabled_in_tasks: ['schedule', 'include_disabled_in_tasks'],
|
| max_in_flight: ['pool', 'max_in_flight'], max_in_flight_global: ['pool', 'max_in_flight_global'],
|
| breaker_threshold: ['pool', 'breaker_threshold'],
|
| degrade_threshold: ['pool', 'degrade_threshold'], degrade_cooldown: ['pool', 'degrade_cooldown'],
|
| degrade_cooldown_max: ['pool', 'degrade_cooldown_max'],
|
| cost_explore_interval: ['pool', 'cost_explore_interval'],
|
| credit_floor: ['pool', 'credit_floor'],
|
| prefer_expiring: ['pool', 'prefer_expiring'], expiring_soon: ['pool', 'expiring_soon'],
|
| soft_rate: ['cooldown', 'soft_rate'], soft_rate_max: ['cooldown', 'soft_rate_max'],
|
| breaker_cooldown: ['pool', 'breaker_cooldown'], breaker_cooldown_max: ['pool', 'breaker_cooldown_max'],
|
| idle_weight_per_hour: ['pool', 'idle_weight_per_hour'], idle_weight_max: ['pool', 'idle_weight_max'],
|
| ttl: ['session_sticky', 'ttl'],
|
| timeout_seconds: ['upstream', 'timeout_seconds'], header_timeout_seconds: ['upstream', 'header_timeout_seconds'],
|
| idle_timeout_seconds: ['upstream', 'idle_timeout_seconds'], user_agent: ['upstream', 'user_agent'],
|
| prompt_mode: ['prompt', 'mode'], prompt_file: ['prompt', 'file'],
|
| sanitize_blacklist_fingerprints: ['features', 'sanitize_blacklist_fingerprints'],
|
| session_sticky_enabled: ['session_sticky', 'enabled'],
|
| request_client_info: ['logging', 'request_client_info'],
|
| };
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
|
|
| const CLEARABLE_CFG = new Set(['user_agent', 'prompt_file']);
|
|
|
| function dig(obj, path) { return path.reduce((o, k) => (o == null ? undefined : o[k]), obj); }
|
| function put(obj, path, val) {
|
| let o = obj;
|
| for (let i = 0; i < path.length - 1; i++) { if (typeof o[path[i]] !== 'object' || o[path[i]] === null) o[path[i]] = {}; o = o[path[i]]; }
|
| o[path[path.length - 1]] = val;
|
| }
|
|
|
| async function loadConfig() {
|
| try {
|
| const d = await api('config');
|
| cfgLoaded = d.config;
|
| $('cfgPath').textContent = d.path || '';
|
| const f = $('cfgForm');
|
| for (const [name, path] of Object.entries(CFG_MAP)) {
|
| const el = f.elements[name];
|
| if (!el) continue;
|
| const v = dig(cfgLoaded, path);
|
| if (el.type === 'checkbox') el.checked = !!v;
|
| else if (Array.isArray(v)) el.value = v.join(', ');
|
| else el.value = v == null ? '' : v;
|
| }
|
| markDurationFields();
|
| $('cfgNote').textContent = '';
|
| } catch (e) { toast('读取配置失败：' + e.message, 'err'); }
|
| }
|
| function collectConfig() {
|
| const f = $('cfgForm'), out = {};
|
| for (const [name, path] of Object.entries(CFG_MAP)) {
|
| const el = f.elements[name];
|
| if (!el) continue;
|
| let v;
|
| if (el.type === 'checkbox') v = el.checked;
|
| else if (el.type === 'number') { v = el.value.trim() === '' ? undefined : Number(el.value); }
|
| else {
|
| const raw = el.value.trim();
|
|
|
| if (raw === '') v = CLEARABLE_CFG.has(name) ? '' : undefined;
|
| else if (name.endsWith('_hours')) v = raw.split(/[,，\s]+/).filter(Boolean).map(Number);
|
| else v = raw;
|
| }
|
| if (v !== undefined) put(out, path, v);
|
| }
|
| return out;
|
| }
|
| |
| |
| |
|
|
| const DURATION_RE = /^(\d+(\.\d+)?(ns|us|µs|ms|s|m|h))+$/;
|
| const DURATION_FIELDS = ['soft_rate', 'soft_rate_max', 'breaker_cooldown', 'breaker_cooldown_max',
|
| 'degrade_cooldown', 'degrade_cooldown_max', 'cost_explore_interval', 'expiring_soon', 'ttl'];
|
| const DURATION_TIP = '格式应为 Go 时长：30m / 2h / 600s / 1h30m';
|
| function durationBad(name) {
|
| const el = $('cfgForm').elements[name];
|
| if (!el) return false;
|
| const v = el.value.trim();
|
| return v !== '' && !DURATION_RE.test(v);
|
| }
|
| function markDurationFields() {
|
| for (const name of DURATION_FIELDS) {
|
| const el = $('cfgForm').elements[name];
|
| if (!el) continue;
|
| const bad = durationBad(name);
|
| el.classList.toggle('invalid', bad);
|
| el.title = bad ? DURATION_TIP : '';
|
| }
|
| }
|
| $('cfgForm').addEventListener('input', ev => {
|
| if (DURATION_FIELDS.includes(ev.target.name)) markDurationFields();
|
| });
|
| $('btnEye').onclick = () => {
|
| const el = $('cfgKey');
|
| const show = el.type === 'password';
|
| el.type = show ? 'text' : 'password';
|
| $('btnEye').textContent = show ? '隐藏' : '显示';
|
| };
|
| $('btnCfgReload').onclick = loadConfig;
|
| $('cfgForm').onsubmit = async ev => {
|
| ev.preventDefault();
|
|
|
| markDurationFields();
|
| const firstBad = DURATION_FIELDS.find(durationBad);
|
| if (firstBad) {
|
| const el = $('cfgForm').elements[firstBad];
|
| el.focus();
|
| toast('「' + (el.closest('.fld')?.querySelector('.lb')?.textContent || firstBad) + '」' + DURATION_TIP, 'err');
|
| return;
|
| }
|
| const btn = $('btnCfgSave');
|
| btn.disabled = true; btn.textContent = '保存中…';
|
| try {
|
| const r = await api('config', { method: 'POST', body: JSON.stringify(collectConfig()) });
|
| const n = (r.restart_required || []).length;
|
| toast(n ? '配置已保存，其中 ' + n + ' 项需重启进程生效' : '配置已保存并立即生效', 'ok');
|
|
|
| const k = $('cfgKey').value.trim();
|
| if (k) localStorage.setItem(LS_KEY, k);
|
| loadConfig();
|
| loadOverview(true);
|
| } catch (e) { toast('保存失败：' + e.message, 'err'); }
|
| finally { btn.disabled = false; btn.textContent = '保存配置'; }
|
| };
|
|
|
|
|
| function openAdd() {
|
| $('addVeil').classList.add('on');
|
|
|
| switchAddTab('login');
|
| $('addPick').hidden = false;
|
| $('addLoad').hidden = true; $('addReady').hidden = true;
|
| $('addDone').hidden = true; $('addErr').hidden = true;
|
| $('importDone').hidden = true; $('importErr').hidden = true;
|
| $('btnCopyUrl').hidden = true; $('btnOpenUrl').hidden = true;
|
| $('btnStartLogin').hidden = false; $('btnStartLogin').disabled = false;
|
| stopPoll();
|
| }
|
| function switchAddTab(tab) {
|
| document.querySelectorAll('#addTabs .tab').forEach(b => b.classList.toggle('on', b.dataset.tab === tab));
|
| $('addTabLogin').hidden = tab !== 'login';
|
| $('addTabImport').hidden = tab !== 'import';
|
| }
|
| document.querySelectorAll('#addTabs .tab').forEach(b => {
|
| b.onclick = () => switchAddTab(b.dataset.tab);
|
| });
|
| function startAddLogin() {
|
| const realm = (document.querySelector('input[name="addRealm"]:checked') || {}).value || 'cn';
|
| $('btnStartLogin').disabled = true;
|
| $('addLoad').hidden = false; $('addErr').hidden = true;
|
| api('login/start', { method: 'POST', body: JSON.stringify({ realm }) }).then(r => {
|
| loginState = r.state;
|
| $('addUrl').textContent = r.url;
|
| $('addPick').hidden = true;
|
| $('addLoad').hidden = true; $('addReady').hidden = false;
|
| $('btnStartLogin').hidden = true;
|
| $('btnCopyUrl').hidden = false; $('btnOpenUrl').hidden = false;
|
| loginTimer = setInterval(pollLogin, 3000);
|
| }).catch(e => {
|
| $('addLoad').hidden = true;
|
| $('btnStartLogin').disabled = false;
|
| $('addErr').hidden = false;
|
| $('addErr').textContent = e.message;
|
| });
|
| }
|
| function stopPoll() { if (loginTimer) { clearInterval(loginTimer); loginTimer = null; } }
|
| async function pollLogin() {
|
| if (!loginState) return;
|
| try {
|
| const r = await api('login/poll?state=' + encodeURIComponent(loginState));
|
| if (r.done) {
|
| stopPoll();
|
| $('addReady').hidden = true;
|
| $('addDone').hidden = false;
|
| $('addDone').textContent = '已添加 ' + (r.nickname || r.uid) + (r.realm === 'global' ? '（国际版）' : '') + (r.credits >= 0 ? ' · 积分 ' + r.credits + (r.credits_total > 0 ? '/' + r.credits_total : '') : '') + '，账号已载入池中';
|
| setTimeout(() => { closeAdd(); loadOverview(true); }, 1600);
|
| }
|
| } catch (e) {
|
| stopPoll();
|
| $('addReady').hidden = true;
|
| $('addErr').hidden = false;
|
| $('addErr').textContent = e.message + '（关闭后重新添加）';
|
| }
|
| }
|
| function closeAdd() { stopPoll(); loginState = null; $('addVeil').classList.remove('on'); }
|
| $('btnCloseAdd').onclick = closeAdd;
|
| $('btnStartLogin').onclick = startAddLogin;
|
| $('btnOpenUrl').onclick = () => open($('addUrl').textContent, '_blank');
|
| $('btnCopyUrl').onclick = () => navigator.clipboard.writeText($('addUrl').textContent)
|
| .then(() => toast('链接已复制', 'ok'), () => toast('复制失败，请手动选择复制', 'err'));
|
| $('importFile').onchange = async () => {
|
| const file = $('importFile').files[0];
|
| if (!file) return;
|
| $('importDone').hidden = true; $('importErr').hidden = true;
|
| const fd = new FormData();
|
| fd.append('file', file);
|
| const h = {};
|
| const k = localStorage.getItem(LS_KEY);
|
| if (k) h['Authorization'] = 'Bearer ' + k;
|
| try {
|
| const r = await fetch('/panel/api/import/cockpit', { method: 'POST', body: fd, headers: h });
|
| const d = await r.json();
|
| if (!r.ok) throw new Error(d.error || ('HTTP ' + r.status));
|
| $('importDone').hidden = false;
|
| $('importDone').textContent = '导入完成：成功 ' + d.imported + ' 个' + (d.skipped ? '，跳过 ' + d.skipped + ' 个' : '');
|
| if (d.errors && d.errors.length) {
|
| console.warn('import errors:', d.errors);
|
| }
|
| loadOverview(true);
|
| } catch (e) {
|
| $('importErr').hidden = false;
|
| $('importErr').textContent = '导入失败：' + e.message;
|
| }
|
| $('importFile').value = '';
|
| };
|
|
|
|
|
| $('btnAdd').onclick = openAdd;
|
| $('btnRefresh').onclick = async () => {
|
| const b = $('btnRefresh');
|
| b.disabled = true; b.textContent = '刷新中…';
|
| try {
|
| await api('balance_all', { method: 'POST' });
|
| await loadOverview(true);
|
| toast('余额已从上游刷新', 'ok');
|
| } catch (e) { toast('刷新失败：' + e.message, 'err'); await loadOverview(true); }
|
| finally { b.disabled = false; b.textContent = '刷新'; }
|
| if (view === 'logs') loadLogs();
|
| };
|
|
|
|
|
| function refreshVisible() {
|
| if (view === 'accounts') loadOverview(true);
|
| else if (view === 'logs') loadLogs();
|
| else if (view === 'taskscenter') reattachQueueView();
|
| }
|
| function start() {
|
| loadOverview(true);
|
| if (refTimer) clearInterval(refTimer);
|
| refTimer = setInterval(refreshVisible, 5000);
|
| checkAuthGate();
|
| }
|
| async function checkAuthGate() {
|
| try { await api('overview'); }
|
| catch (e) { if (String(e.message).includes('密钥') || String(e.message).includes('api_key')) return; }
|
| }
|
| start();
|
|
|
|
|
| let taskUID = null;
|
|
|
|
|
|
|
|
|
| const AUTO_TASKS = {
|
| 'chat_5': '上报 5 条对话活跃事件（自动补足差额）',
|
| 'first_buddy': '上报解锁 → 同意协议 → 领取第一只 Buddy',
|
| 'Model_chat_GLM5.2': '接受任务 → glm-5.2 真实对话一次 → 对齐模型上报',
|
| 'RichMeow_Chat': '桌面指纹事件链上报（已验证可点亮）',
|
| 'Buddy_App': '上报「进入 Buddy 应用」事件链（已验证可点亮）',
|
| 'Buddy_App_QQ': '上报「进入企鹅教师助手」事件链（已验证可点亮）',
|
| 'automation_1': '上报「定时任务创建」事件（已验证可点亮）',
|
| 'Library_read': '上报「读资料库介绍」事件（已验证可点亮）',
|
| 'template_5': '上报「使用模板创建任务」事件组 ×5（三账号实测点亮）',
|
| 'playbook_prompt': '上报「灵感案例做同款发送 Prompt」事件组（三账号实测点亮）',
|
| 'create_canvas': '上报「设计创意画布创建」事件组（三账号实测点亮，+300 分）',
|
| 'expert_5': '真实专家召唤+使用链 ×5（专家市场+真实 chat，三账号实测点亮）',
|
| 'Expert_team_use_3': '真实专家团召唤+使用链 ×3（三账号实测点亮）',
|
| 'Hp_Appearance': '设置主题 API + 皮肤生效事件（两账号实测点亮）',
|
| 'black_cat': '夜猫子：23:00–08:00 窗口内 glm-5.2 对话补足（窗口外提示等 23 点排程）',
|
| 'Expert_lighthouse': '真实轻量云专家召唤+使用链（真实对话 requestId，两账号实测点亮）',
|
| 'skill_1': '真实对话 + skill_info 技能加载事件（实测点亮）',
|
| 'school_season': '校园日（小程序口径）：accept → mini 对话+activityId 上报 → 领奖（+100c+5e）',
|
| 'Sequential_Tasks_1': '小程序首对话（小程序口径）：accept → mini 对话上报 → 领奖（+100c+5e）',
|
| 'Sequential_Tasks_2': '小程序选专家对话（小程序口径）：市场专家 id → accept → expert_actual_use 上报 → 领奖（+200c+5e）',
|
| 'Sequential_Tasks_3': '小程序五次对话（小程序口径）：accept → mini 对话上报 ×5（自动补差额）→ 领奖（+300c+5e）',
|
| 'Sequential_Tasks_4': '小程序定时任务（预留，每日零点解锁一环）：accept → 定时任务创建事件 → 领奖（判据待解锁验证）',
|
| 'Sequential_Tasks_5': '小程序使用 GLM5.2（预留）：accept → 带模型字段的 mini 对话上报 → 领奖（判据待解锁验证）',
|
| 'Sequential_Tasks_6': '小程序十次对话（预留）：accept → mini 对话上报 ×target（自动补差额）→ 领奖',
|
| 'Sequential_Tasks_7': '体验灵感功能（预留，疑 PC 口径）：accept → 灵感事件组（PC+mp 双形态）→ 领奖（判据待解锁验证）'
|
| };
|
|
|
| function openTasks(uid) {
|
| taskUID = uid;
|
| $('taskWho').textContent = uid.slice(0, 16);
|
| $('taskVeil').classList.add('on');
|
| $('btnTaskReload').hidden = false;
|
| loadTasks();
|
| }
|
| function closeTasks() { $('taskVeil').classList.remove('on'); taskUID = null; }
|
| $('btnCloseTask').onclick = closeTasks;
|
| $('btnTaskReload').onclick = loadTasks;
|
|
|
|
|
| $('btnTaskAcceptAll').onclick = async () => {
|
| if (!taskUID) return;
|
| const btn = $('btnTaskAcceptAll');
|
| btn.disabled = true; btn.textContent = '接受中…';
|
| try {
|
| const r = await api('accounts/' + encodeURIComponent(taskUID) + '/tasks/accept_all', { method: 'POST' });
|
| const n = r.accepted || 0;
|
| if (r.failed && r.failed.length) {
|
| toast(`已接受 ${n} 个，${r.failed.length} 个被上游拒绝（可重试）`, 'err');
|
| } else {
|
| toast(n ? `已接受 ${n} 个任务` : (r.message || '所有任务均已接受'), 'ok');
|
| }
|
| } catch (e) { toast(e.message, 'err'); }
|
| finally { btn.disabled = false; btn.textContent = '全部接受'; loadTasks(); }
|
| };
|
|
|
|
|
| $('btnTaskAutoAll').onclick = async () => {
|
| if (!taskUID) return;
|
| const btn = $('btnTaskAutoAll');
|
| if (!confirm('将依次执行：补报对话事件、领取 Buddy、glm-5.2 对话、尝试上报。\n过程约 1-2 分钟（含真实对话），确认继续？')) return;
|
| btn.disabled = true; btn.textContent = '执行中…';
|
| try {
|
| const r = await api('accounts/' + encodeURIComponent(taskUID) + '/tasks/auto_all', { method: 'POST' });
|
| const okN = (r.results || []).filter(x => x.status === 'done').length;
|
| const skipN = (r.results || []).filter(x => x.status === 'skipped').length;
|
| const errN = (r.results || []).filter(x => x.status === 'error').length;
|
| toast(`执行完成：成功 ${okN} 项，跳过 ${skipN} 项${errN ? '，失败 ' + errN + ' 项' : ''}`, errN ? 'err' : 'ok');
|
| console.log('auto_all results:', r.results);
|
| } catch (e) { toast(e.message, 'err'); }
|
| finally { btn.disabled = false; btn.textContent = '一键完成可自动任务'; loadTasks(); }
|
| };
|
|
|
| async function loadTasks() {
|
| if (!taskUID) return;
|
| const st = $('taskState'), tb = $('taskTable');
|
| st.hidden = false;
|
| st.className = 'state';
|
| st.innerHTML = '<span class="dots">查询中</span>';
|
| tb.hidden = true;
|
| try {
|
| const d = await api('accounts/' + encodeURIComponent(taskUID) + '/tasks');
|
| const list = d.tasks || [];
|
| if (!list.length) {
|
| st.className = 'state';
|
| st.textContent = '该账号暂无任务';
|
| return;
|
| }
|
|
|
| list.sort((a, b) => (a.claimed - b.claimed) || (b.claimable - a.claimable) || String(a.task_code).localeCompare(String(b.task_code)));
|
| $('taskBody').innerHTML = list.map(t => {
|
|
|
| const cur = t.current ?? 0, tgt = t.target ?? 0;
|
| const prog = tgt ? cur + ' / ' + tgt : (tgt === 0 && cur > 0 ? String(cur) : '—');
|
| const parts = [];
|
| if (t.credit) parts.push('+' + t.credit + ' 分');
|
| if (t.energy) parts.push('+' + t.energy + ' 能');
|
| if (t.reward_buddy) parts.push('Buddy');
|
| const reward = parts.length ? parts.join(' ') : '—';
|
| const badge = t.claimed ? '<span class="tag ok">已领取</span>'
|
| : t.claimable ? '<span class="tag warn">可领取</span>'
|
| : t.locked ? '<span class="tag mute">未解锁</span>'
|
| : t.accept_status === 'accepted' ? '<span class="tag mute">进行中</span>'
|
| : '<span class="tag mute">未接受</span>';
|
| const acted = t.claimed || t.locked ? ''
|
| : t.claimable ? '<button class="xs primary" data-t="claim" data-c="' + esc(t.task_code) + '">领取</button>'
|
| : AUTO_TASKS[t.task_code] ? '<button class="xs primary" data-t="auto" data-c="' + esc(t.task_code) + '" title="' + esc(AUTO_TASKS[t.task_code]) + '">一键完成</button>'
|
| : t.accept_status === 'accepted' ? ''
|
| : '<button class="xs" data-t="accept" data-c="' + esc(t.task_code) + '">接受</button>';
|
|
|
| const tip = [t.title, t.task_desc || t.description, t.jump_url ? '跳转：' + t.jump_url : ''].filter(Boolean).join('\n');
|
| return '<tr title="' + esc(tip) + '"><td class="mark" aria-hidden="true"><i></i></td>' +
|
| '<td class="who"><div class="nm">' + esc(t.title || t.task_code) + '</div><div class="id">' + esc(t.task_code) + (t.tag ? ' · ' + esc(t.tag) : '') + '</div></td>' +
|
| '<td class="num">' + esc(prog) + '</td>' +
|
| '<td class="num">' + esc(reward) + '</td>' +
|
| '<td>' + badge + '</td>' +
|
| '<td class="acts">' + acted + '</td></tr>';
|
| }).join('');
|
| st.hidden = true;
|
| tb.hidden = false;
|
| } catch (e) {
|
| st.className = 'state err';
|
| st.textContent = e.message;
|
| }
|
| }
|
|
|
| $('taskBody').addEventListener('click', async ev => {
|
| const b = ev.target.closest('button[data-t]');
|
| if (!b || !taskUID) return;
|
| const kind = b.dataset.t, code = b.dataset.c;
|
| b.disabled = true;
|
| try {
|
| if (kind === 'auto') {
|
|
|
| b.textContent = '执行中…';
|
| const r = await api('accounts/' + encodeURIComponent(taskUID) + '/tasks/auto', {
|
| method: 'POST', body: JSON.stringify({ task_code: code })
|
| });
|
| if (r.skipped) {
|
| toast(r.message || '已跳过', 'ok');
|
| } else {
|
| const advanced = r.progress_before !== r.progress_after;
|
| let msg = r.message || '已执行';
|
| if (r.progress_after) msg += `（进度 ${r.progress_before} → ${r.progress_after}）`;
|
| if (r.claimed) msg += '，奖励已自动到账';
|
| else if (r.claimable) msg += r.claim_error ? '，可点「领取」重试' : '';
|
| else if (r.attempt && !advanced) msg += '；进度未动，该任务可能需要官方客户端';
|
| toast(msg, (r.claimed || advanced) ? 'ok' : 'err');
|
| }
|
| loadOverview(true);
|
| } else {
|
| const path = 'accounts/' + encodeURIComponent(taskUID) + '/tasks/' + (kind === 'claim' ? 'claim' : 'accept');
|
| const body = kind === 'claim' ? { task_code: code } : { task_codes: [code] };
|
| await api(path, { method: 'POST', body: JSON.stringify(body) });
|
| toast(kind === 'claim' ? '已领取奖励' : '已接受任务', 'ok');
|
| if (kind === 'claim') loadOverview(true);
|
| }
|
| } catch (e) { toast(e.message, 'err'); }
|
| finally { loadTasks(); }
|
| });
|
|
|
|
|
|
|
| function staskHTML(t) {
|
| if (!t) return '<span class="stask todo"><span class="mark">·</span>—</span>';
|
| if (t.status === 'claimed') return '<span class="stask ok"><span class="mark">✓</span>已领</span>';
|
| if (t.status === 'completed') return '<span class="stask warn"><span class="mark">◆</span>可领</span>';
|
| if (t.status === 'in_progress') {
|
| const fr = t.target_count ? '<span class="fr">' + t.progress + '/' + t.target_count + '</span>' : '';
|
| return '<span class="stask warn"><span class="mark">◐</span>' + fr + '</span>';
|
| }
|
| return '<span class="stask todo"><span class="mark">○</span>未做</span>';
|
| }
|
| const LUCK_SVG = '<svg viewBox="0 0 16 16" fill="none" stroke="currentColor" stroke-width="1.4"><path d="M3.2 5.2 5 1.8l3 2.4 3-2.4 1.8 3.4-1.4 2.6 1.4 2.6-3.4 2.2H6l-3.4-2.2 1.4-2.6z" opacity=".9"/><circle cx="8" cy="9" r="1.1" fill="currentColor" stroke="none"/></svg>';
|
| const SCHOOL_TITLES = {
|
| share_invite: '分享活动 +100c', desktop_chat_1_time: '桌面端体验 +100c（单次）',
|
| chat_3_times: '和 AI 对话 3 次 +50c', expert_use: '召唤开学季专家 +50c',
|
| task_student_verify: '学生认证 +100c（需真实认证，不做）',
|
| };
|
|
|
| |
| |
| |
| |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| const QR_EXP = new Array(512), QR_LOG = new Array(256);
|
| (() => {
|
| let x = 1;
|
| for (let i = 0; i < 255; i++) { QR_EXP[i] = x; QR_LOG[x] = i; x <<= 1; if (x & 0x100) x ^= 0x11d; }
|
| for (let i = 255; i < 512; i++) QR_EXP[i] = QR_EXP[i - 255];
|
| })();
|
| const gmul = (a, b) => (a && b) ? QR_EXP[QR_LOG[a] + QR_LOG[b]] : 0;
|
|
|
|
|
| const QR_V = [[19, 7], [34, 10], [55, 15], [80, 20], [108, 26]];
|
|
|
| const QR_ALIGN = [[], [6, 18], [6, 22], [6, 26], [6, 30]];
|
| const QR_MASK = (r, c) => (r + c) % 2 === 0;
|
|
|
|
|
| function qrGenPoly(deg) {
|
| let g = [1];
|
| for (let i = 0; i < deg; i++) {
|
| const a = QR_EXP[i], ng = new Array(g.length + 1).fill(0);
|
| ng[0] = g[0];
|
| for (let j = 1; j < g.length; j++) ng[j] = g[j] ^ gmul(a, g[j - 1]);
|
| ng[g.length] = gmul(a, g[g.length - 1]);
|
| g = ng;
|
| }
|
| return g;
|
| }
|
|
|
|
|
| function rsRem(data, deg) {
|
| const g = qrGenPoly(deg);
|
| const res = data.concat(new Array(deg).fill(0));
|
| for (let i = 0; i < data.length; i++) {
|
| const f = res[i];
|
| if (f) for (let j = 0; j < g.length; j++) res[i + j] ^= gmul(g[j], f);
|
| }
|
| return res.slice(data.length);
|
| }
|
|
|
|
|
| function qrDataCodewords(text, dataCap) {
|
| const bytes = Array.from(new TextEncoder().encode(text));
|
| const bits = [];
|
| const push = (val, n) => { for (let i = n - 1; i >= 0; i--) bits.push((val >> i) & 1); };
|
| push(4, 4);
|
| push(bytes.length, 8);
|
| for (const b of bytes) push(b, 8);
|
| const cap = dataCap * 8;
|
| push(0, Math.min(4, cap - bits.length));
|
| while (bits.length % 8) bits.push(0);
|
| const out = [];
|
| for (let i = 0; i < bits.length; i += 8) {
|
| let v = 0; for (const b of bits.slice(i, i + 8)) v = (v << 1) | b;
|
| out.push(v);
|
| }
|
| for (let p = 0; out.length < dataCap; p ^= 1) out.push(p ? 0x11 : 0xEC);
|
| return out;
|
| }
|
|
|
|
|
| function qrMatrix(text) {
|
| const bytes = Array.from(new TextEncoder().encode(text));
|
|
|
| let ver = 0;
|
| for (let v = 0; v < QR_V.length; v++) { if (bytes.length + 2 <= QR_V[v][0]) { ver = v + 1; break; } }
|
| if (!ver) throw new Error('QR: text too long (>' + QR_V[4][0] + ' bytes)');
|
| const [dataCap, ecCap] = QR_V[ver - 1];
|
| const n = 17 + 4 * ver;
|
|
|
| const M = Array.from({ length: n }, () => new Array(n).fill(false));
|
| const F = Array.from({ length: n }, () => new Array(n).fill(false));
|
|
|
| const setF = (r, c, v) => { M[r][c] = v; F[r][c] = true; };
|
|
|
| const finder = (r0, c0) => {
|
| for (let r = -1; r <= 7; r++) for (let c = -1; c <= 7; c++) {
|
| const rr = r0 + r, cc = c0 + c;
|
| if (rr < 0 || cc < 0 || rr >= n || cc >= n) continue;
|
| const dark = r >= 0 && r <= 6 && c >= 0 && c <= 6 && (r === 0 || r === 6 || c === 0 || c === 6 || (r >= 2 && r <= 4 && c >= 2 && c <= 4));
|
| setF(rr, cc, dark);
|
| }
|
| };
|
| finder(0, 0); finder(0, n - 7); finder(n - 7, 0);
|
|
|
| for (let r = 8; r <= n - 9; r++) setF(r, 6, r % 2 === 0);
|
| for (let c = 8; c <= n - 9; c++) setF(6, c, c % 2 === 0);
|
|
|
| const align = QR_ALIGN[ver - 1] || [];
|
| for (const ar of align) for (const ac of align) {
|
| if (F[ar][ac]) continue;
|
| for (let r = -2; r <= 2; r++) for (let c = -2; c <= 2; c++)
|
| setF(ar + r, ac + c, Math.max(Math.abs(r), Math.abs(c)) !== 1);
|
| }
|
|
|
|
|
|
|
| let fmt = (1 << 3) | 0;
|
| let rem = fmt << 10;
|
| for (let i = 14; i >= 10; i--) if ((rem >> i) & 1) rem ^= 0x537 << (i - 10);
|
| fmt = ((fmt << 10) | rem) ^ 0x5412;
|
| const fb = i => (fmt >> i) & 1;
|
|
|
| for (let i = 0; i <= 5; i++) setF(i, 8, !!fb(i));
|
| setF(7, 8, !!fb(6)); setF(8, 8, !!fb(7));
|
|
|
| for (let i = 8; i <= 14; i++) setF(n - 15 + i, 8, !!fb(i));
|
| for (let i = 0; i <= 7; i++) setF(8, n - 1 - i, !!fb(i));
|
| setF(8, 7, !!fb(8));
|
| for (let i = 9; i <= 14; i++) setF(8, 14 - i, !!fb(i));
|
|
|
| setF(n - 8, 8, true);
|
|
|
|
|
|
|
| const dcw = qrDataCodewords(text, dataCap);
|
| const cw = dcw.concat(rsRem(dcw, ecCap));
|
| const bits = [];
|
| for (const b of cw) for (let i = 7; i >= 0; i--) bits.push((b >> i) & 1);
|
|
|
|
|
| let bi = 0, up = true;
|
| for (let x = n - 1; x > 0; x -= 2) {
|
| if (x === 6) x--;
|
| for (let i = 0; i < n; i++) {
|
| const r = up ? n - 1 - i : i;
|
| for (const c of [x, x - 1]) {
|
| if (F[r][c]) continue;
|
| const bit = bi < bits.length ? bits[bi++] : 0;
|
| M[r][c] = bit ? !QR_MASK(r, c) : QR_MASK(r, c);
|
| }
|
| }
|
| up = !up;
|
| }
|
| return M;
|
| }
|
|
|
|
|
| function qrSVG(M, px) {
|
| const n = M.length, q = 4, total = n + q * 2;
|
| let s = '<svg viewBox="0 0 ' + total + ' ' + total + '" width="' + px + '" height="' + px + '" shape-rendering="crispEdges" role="img" style="background:#fff">';
|
| for (let r = 0; r < n; r++) for (let c = 0; c < n; c++)
|
| if (M[r][c]) s += '<rect x="' + (c + q) + '" y="' + (r + q) + '" width="1" height="1"/>';
|
| return s + '</svg>';
|
| }
|
|
|
|
|
| |
|
|
| function copyText(text) {
|
| if (navigator.clipboard && window.isSecureContext) return navigator.clipboard.writeText(text);
|
| return new Promise((resolve, reject) => {
|
| const ta = document.createElement('textarea');
|
| ta.value = text;
|
| ta.style.cssText = 'position:fixed;opacity:0';
|
| document.body.appendChild(ta);
|
| ta.select();
|
| try { document.execCommand('copy') ? resolve() : reject(new Error('copy failed')); }
|
| catch (e) { reject(e); }
|
| finally { ta.remove(); }
|
| });
|
| }
|
|
|
| function vcCard(v) {
|
| const expired = v.valid_to && new Date(v.valid_to) < new Date();
|
| return '<div class="vc' + (expired ? ' expired' : '') + '">' +
|
| '<div class="hd"><span class="nm">' + esc(v.prize_name || v.sku_code || '券') + '</span>' +
|
| (expired ? '<span class="tag bad">已过期</span>' : '<span class="tag ok">可使用</span>') + '</div>' +
|
| '<div class="meta">' +
|
| (v.valid_to ? '有效期至 ' + esc(v.valid_to) : '长期有效') +
|
| (v.granted_at ? ' · ' + esc(v.granted_at.slice(0, 10)) + ' 抽中' : '') +
|
| '</div>' +
|
| '<div class="sep"></div>' +
|
| '<div class="ft"><span class="lab">券码</span><code>' + esc(v.code || '-') + '</code>' +
|
| '<span class="acts">' +
|
| (v.code ? '<button class="xs ghost" data-qr="' + esc(v.code) + '">二维码</button>' : '') +
|
| '<button class="xs ghost" data-copy="' + esc(v.code || '') + '">复制</button>' +
|
| '</span></div>' +
|
| '</div>';
|
| }
|
|
|
| async function loadSchoolVouchers() {
|
| const body = $('vcBody');
|
| $('vcVeil').classList.add('on');
|
| body.innerHTML = '<div class="state"><span class="dots">查询中</span></div>';
|
| $('vcNote').textContent = '';
|
| try {
|
| const d = await api('school/vouchers');
|
| const arr = d.accounts || [];
|
| const ok = arr.filter(a => !a.error);
|
| const total = ok.reduce((n, a) => n + (a.vouchers || []).length, 0);
|
| body.innerHTML = ok.filter(a => (a.vouchers || []).length).map(a =>
|
| '<div class="vc-acct"><span class="nm">' + esc(a.nickname || a.uid) + '</span>' +
|
| '<span>' + a.vouchers.length + ' 张</span></div>' +
|
| a.vouchers.map(vcCard).join('')
|
| ).join('') || '<div class="empty"><div class="big">🎟️</div>还没有抽到券</div>';
|
| $('vcNote').textContent = total ? total + ' 张券 · ' + ok.filter(a => !(a.vouchers || []).length).length + ' 个账号未抽中' : '';
|
| const errs = arr.filter(a => a.error);
|
| if (errs.length) {
|
| body.insertAdjacentHTML('beforeend', '<div class="note" style="color:var(--warn);margin-top:8px">查询失败：' +
|
| errs.map(a => esc(a.nickname || a.uid.slice(0, 8)) + '（' + esc(a.error) + '）').join('、') + '</div>');
|
| }
|
| body.querySelectorAll('button[data-copy]').forEach(b => b.onclick = async () => {
|
| try { await copyText(b.dataset.copy); toast('券码已复制', 'ok'); }
|
| catch (e) { toast('复制失败，请手动选择券码', 'err'); }
|
| });
|
|
|
| body.querySelectorAll('button[data-qr]').forEach(b => b.onclick = () => {
|
| const card = b.closest('.vc');
|
| const old = card.querySelector('.vc-qr');
|
| if (old) { old.remove(); return; }
|
| const box = document.createElement('div');
|
| box.className = 'vc-qr';
|
| try { box.innerHTML = qrSVG(qrMatrix(b.dataset.qr), 148); }
|
| catch (e) { box.innerHTML = '<span class="note">二维码生成失败：' + esc(e.message) + '</span>'; }
|
| card.appendChild(box);
|
| });
|
| } catch (e) {
|
| body.innerHTML = '<div class="state err">' + esc(e.message) + '</div>';
|
| }
|
| }
|
| $('btnSchoolVouchers').onclick = loadSchoolVouchers;
|
| $('btnVcClose').onclick = () => $('vcVeil').classList.remove('on');
|
| $('btnVcRefresh').onclick = loadSchoolVouchers;
|
|
|
| |
| |
|
|
| let queueTimer = null, lastQueueSeq = 0;
|
| const GROWTH_TITLES = {};
|
| $('btnScanAll').onclick = async () => {
|
| const b = $('btnScanAll');
|
|
|
|
|
| if (queueTimer) { clearInterval(queueTimer); queueTimer = null; }
|
| b.disabled = true; b.textContent = '扫描中…';
|
| try {
|
| const d = await api('tasks/scan_all', { method: 'POST' });
|
| renderQueue(groupItems(d), null, '没有待办任务 🎉', '全部账号的成长任务与开学季活动都已完成，明日再来。');
|
| } catch (e) { toast(e.message, 'err'); }
|
| finally { b.disabled = false; b.textContent = '扫描待办'; }
|
| };
|
| $('btnRunQueue').onclick = async () => {
|
| const conc = Number($('qcConc').value) || 1;
|
| if (!confirm('扫描全部账号待办并排队执行（账号并发 ' + conc + '，账号内串行）。\n含真实对话的任务耗时较长，确认继续？')) return;
|
| const b = $('btnRunQueue');
|
| b.disabled = true; b.textContent = '启动中…';
|
| try {
|
| const r = await api('tasks/run_queue', { method: 'POST', body: JSON.stringify({ concurrency: conc }) });
|
| if (!r.started) { toast(r.message || '没有待办任务', 'ok'); return; }
|
| lastQueueSeq = r.seq || 0;
|
| toast('队列已启动：' + r.total + ' 项（并发 ' + conc + '）', 'ok');
|
| startQueuePolling();
|
| } catch (e) { toast(e.message, 'err'); }
|
| finally { b.disabled = false; b.textContent = '执行全部待办'; }
|
| };
|
|
|
| function groupItems(d) {
|
| const groups = [];
|
| for (const a of (d.accounts || [])) {
|
| const rows = [];
|
| for (const t of (a.growth || [])) {
|
| GROWTH_TITLES[t.task_code] = t.title || t.task_code;
|
| rows.push({ kind: 'growth', code: t.task_code, prog: t.target ? t.current + '/' + t.target : '—', status: 'scan' });
|
| }
|
| if (rows.length) groups.push({ uid: a.uid, nick: a.nickname, rows });
|
| }
|
| return groups;
|
| }
|
| const ST_WORDS = { done: '完成', running: '执行中', error: '失败', skipped: '跳过', pending: '排队', scan: '待执行' };
|
| function qrowHTML(it) {
|
| const isSchool = it.kind === 'school';
|
| const title = isSchool ? '开学季闭环' : (GROWTH_TITLES[it.code] || it.code);
|
| const dotCls = it.status === 'scan' ? 'wait' : it.status === 'running' ? 'run' : it.status === 'error' ? 'err' : it.status === 'skipped' ? 'skip' : it.status === 'done' ? 'done' : 'wait';
|
| const stWord = it.status === 'scan' ? '待执行' : (ST_WORDS[it.status] || it.status);
|
| return '<div class="qrow" title="' + esc(it.message || '') + '">' +
|
| '<span class="code">' + esc(it.code) + '</span>' +
|
| '<span class="name"><span class="t">' + esc(title) + '</span>' + (isSchool ? '<span class="tag mute">开学季</span>' : '') + '</span>' +
|
| '<span class="prog">' + esc(it.prog || '') + '</span>' +
|
| '<span class="st"><span class="qdot ' + dotCls + '"></span>' + stWord + '</span>' +
|
| '<span class="msg">' + esc(it.message || '') + '</span>' +
|
| '</div>';
|
| }
|
| function renderQueue(groups, progress, emptyTitle, emptyDesc) {
|
| const empty = $('tcEmpty'), list = $('qcList');
|
| if (!groups.length) {
|
| empty.style.display = '';
|
| if (emptyTitle) empty.querySelector('.t').textContent = emptyTitle;
|
| if (emptyDesc) empty.querySelector('.d').textContent = emptyDesc;
|
| list.innerHTML = '';
|
| $('qProg').hidden = true; $('qcSummary').textContent = '';
|
| return;
|
| }
|
| empty.style.display = 'none';
|
| empty.style.display = 'none';
|
| let total = 0;
|
| list.innerHTML = groups.map(g => {
|
| total += g.rows.length;
|
| return '<div class="qgroup"><header><span class="nm">' + esc(g.nick || g.uid.slice(0, 12)) + '</span><span class="cnt">' + g.rows.length + ' 项待办</span></header>' +
|
| g.rows.map(qrowHTML).join('') + '</div>';
|
| }).join('');
|
| $('qcSummary').textContent = total + ' 项';
|
| updateProgress(progress);
|
| }
|
| function updateProgress(q) {
|
| if (!q || !q.items) { $('qProg').hidden = true; return; }
|
| const total = q.items.length;
|
| const done = q.items.filter(it => it.status === 'done' || it.status === 'error' || it.status === 'skipped').length;
|
| $('qProg').hidden = false;
|
| $('qBarFill').style.width = (total ? Math.round(done / total * 100) : 0) + '%';
|
| $('qProgText').textContent = (q.running ? '执行中 ' : '已结束 ') + done + ' / ' + total;
|
| }
|
|
|
| function groupsFromQueue(items) {
|
| const by = new Map();
|
| for (const it of items) {
|
| if (!by.has(it.uid)) by.set(it.uid, { uid: it.uid, nick: it.nickname, rows: [] });
|
| by.get(it.uid).rows.push({
|
| kind: it.kind, code: it.code,
|
| prog: it.kind === 'school' ? '—' : '',
|
| status: it.status, message: it.message,
|
| });
|
| }
|
| return Array.from(by.values());
|
| }
|
| function startQueuePolling() {
|
| if (queueTimer) clearInterval(queueTimer);
|
| queueTimer = setInterval(async () => {
|
| let q;
|
| try { q = await api('tasks/queue'); } catch (e) { return; }
|
| if (!q.started) return;
|
|
|
| if (lastQueueSeq && q.seq !== lastQueueSeq) return;
|
| if (q.running) {
|
| renderQueue(groupsFromQueue(q.items || []), q);
|
| return;
|
| }
|
|
|
|
|
| renderQueue(groupsFromQueue(q.items || []), q);
|
| clearInterval(queueTimer); queueTimer = null;
|
| toast('任务队列执行结束', 'ok');
|
| }, 3000);
|
| }
|
|
|
|
|
| function reattachQueueView() {
|
|
|
|
|
|
|
|
|
| (async () => {
|
| try {
|
| const q = await api('tasks/queue');
|
| if (queueTimer) return;
|
| if (q.started && q.running && (!lastQueueSeq || q.seq === lastQueueSeq)) startQueuePolling();
|
| } catch (e) { }
|
| })();
|
| }
|
|
|
|
|
| |
|
|
|
|
| function fmtTok(n) {
|
| n = Number(n || 0);
|
| if (n >= 1e9) return (n / 1e9).toFixed(2) + 'B';
|
| if (n >= 1e6) return (n / 1e6).toFixed(2) + 'M';
|
| if (n >= 1e3) return (n / 1e3).toFixed(1) + 'k';
|
| return String(n);
|
| }
|
| function fmtMs(ms) {
|
| ms = Number(ms || 0);
|
| if (!ms) return '—';
|
| if (ms >= 1000) return (ms / 1000).toFixed(2) + 's';
|
| return Math.round(ms) + 'ms';
|
| }
|
| function fmtRate(r) { return r ? Number(r).toFixed(1) + ' tok/s' : '—'; }
|
| function trimFixed(s) {
|
| if (!String(s).includes('.')) return String(s);
|
| return String(s).replace(/0+$/, '').replace(/\.$/, '');
|
| }
|
| function fmtCredit(n) {
|
| const v = Number(n || 0);
|
| if (!Number.isFinite(v)) return '—';
|
| return trimFixed(v.toFixed(2));
|
| }
|
| function fmtCreditRatio(v, samples, tokens) {
|
| if (!samples || !tokens) return '—';
|
| const n = Number(v || 0);
|
| if (!Number.isFinite(n)) return '—';
|
| return trimFixed(n.toFixed(4)) + ' / 1M';
|
| }
|
| function fmtModelRate(rate) {
|
| const s = String(rate || '').trim();
|
| return s ? 'x' + s : '—';
|
| }
|
|
|
| function usStat(v, k, cls) {
|
| return '<div class="stat ' + (cls || '') + '"><div class="v">' + esc(v) +
|
| '</div><div class="k">' + esc(k) + '</div></div>';
|
| }
|
|
|
| |
|
|
| function usKpi(v, k, cls, sub, bar) {
|
| return '<div class="kpi ' + (cls || '') + '">' +
|
| '<div class="k">' + esc(k) + '</div>' +
|
| '<div class="v">' + esc(v) + '</div>' +
|
| (bar || '') +
|
| (sub ? '<div class="s">' + esc(sub) + '</div>' : '') +
|
| '</div>';
|
| }
|
|
|
| |
|
|
| function usMixBar(prompt, completion, total) {
|
| const t = Number(total || 0);
|
| if (!t) return '';
|
| const pp = Math.max(0, Math.min(100, Number(prompt || 0) / t * 100));
|
| const pc = Math.max(0, Math.min(100, Number(completion || 0) / t * 100));
|
| return '<span class="us-mix" title="prompt ' + pp.toFixed(1) + '% · completion ' + pc.toFixed(1) + '%">' +
|
| '<i class="p" style="width:' + pp.toFixed(2) + '%"></i>' +
|
| '<i class="c" style="width:' + pc.toFixed(2) + '%"></i>' +
|
| '</span>';
|
| }
|
|
|
|
|
| function usPct(part, total) {
|
| const t = Number(total || 0);
|
| if (!t) return '—';
|
| return (Number(part || 0) / t * 100).toFixed(1) + '%';
|
| }
|
|
|
| |
|
|
| function usRow(name, sub, a, mid, withPerf) {
|
| return '<tr>' +
|
| '<td class="mark" aria-hidden="true"></td>' +
|
| '<td>' + esc(name) + (sub ? '<div class="note">' + esc(sub) + '</div>' : '') + '</td>' +
|
| (mid || '') +
|
| '<td class="num">' + fmtTok(a.requests) + '</td>' +
|
| '<td class="num">' + (a.errors ? '<span style="color:var(--warn)">' + fmtTok(a.errors) + '</span>' : '—') + '</td>' +
|
| '<td class="num">' + fmtTok(a.prompt_tokens) + '</td>' +
|
| '<td class="num">' + fmtTok(a.completion_tokens) + '</td>' +
|
| '<td class="num">' + fmtTok(a.total_tokens) +
|
| usMixBar(a.prompt_tokens, a.completion_tokens, a.total_tokens) + '</td>' +
|
| (withPerf
|
| ? '<td class="num">' + fmtMs(a.avg_latency_ms) + '</td>' +
|
| '<td class="num">' + fmtRate(a.avg_tokens_per_second) + '</td>'
|
| : '') +
|
| '</tr>';
|
| }
|
|
|
| |
| |
|
|
| const US_DIMS = {
|
| account: { key: 'by_account', title: '账号', withRealm: true, withPerf: true, span: 10 },
|
| model: { key: 'by_model', title: '模型', withRealm: false, withPerf: false, span: 7 },
|
| realm: { key: 'by_realm', title: 'realm', withRealm: false, withPerf: false, span: 7 },
|
| };
|
|
|
|
|
| function usSortRows(rows, sort) {
|
| const out = rows.slice();
|
| const num = v => { const n = Number(v || 0); return Number.isFinite(n) ? n : 0; };
|
| const val = a => sort === 'requests' ? num(a.requests)
|
| : sort === 'errors' ? num(a.errors)
|
| : sort === 'latency' ? num(a.avg_latency_ms)
|
| : num(a.total_tokens);
|
| out.sort((a, b) => val(b) - val(a));
|
| return out;
|
| }
|
|
|
| function usDimHead(dim) {
|
| const m = US_DIMS[dim] || US_DIMS.account;
|
| return '<tr><th class="mark" aria-hidden="true"></th><th>' + esc(m.title) + '</th>' +
|
| (m.withRealm ? '<th>域</th>' : '') +
|
| '<th class="num">请求</th><th class="num">失败</th>' +
|
| '<th class="num">Prompt</th><th class="num">Completion</th><th class="num">合计</th>' +
|
| (m.withPerf ? '<th class="num">均延迟</th><th class="num">均速率</th>' : '') +
|
| '</tr>';
|
| }
|
|
|
| |
|
|
| function usTabsHtml(dims, active, counts) {
|
| return dims.map(([k, label]) => {
|
| const n = counts ? counts[k] : null;
|
| return '<button data-dim="' + k + '"' + (k === active ? ' class="on"' : '') + '>' +
|
| esc(label) + (n == null ? '' : '<span class="cnt">' + n + '</span>') + '</button>';
|
| }).join('');
|
| }
|
|
|
| const US_DIM_TABS = [['account', '按账号'], ['model', '按模型'], ['realm', '按域']];
|
|
|
| function renderUsageDim() {
|
| const d = usageData || {};
|
| const m = US_DIMS[usDim] || US_DIMS.account;
|
| const rows = usSortRows(d[m.key] || [], usSort);
|
| $('usDimTabs').innerHTML = usTabsHtml(US_DIM_TABS, usDim, {
|
| account: (d.by_account || []).length,
|
| model: (d.by_model || []).length,
|
| realm: (d.by_realm || []).length,
|
| });
|
| $('usDimHead').innerHTML = usDimHead(usDim);
|
| $('usDimBody').innerHTML = rows.map(x =>
|
| usRow(usDim === 'account' ? String(x.key || '').slice(0, 8) : x.key,
|
| usDim === 'account' ? (x.extra || '') : '',
|
| x,
|
| usDim === 'account' ? '<td class="num">' + esc(x.realm || '') + '</td>' : '',
|
| m.withPerf)
|
| ).join('') || '<tr><td colspan="' + m.span + '" class="empty">暂无数据</td></tr>';
|
| $('usDimNote').textContent = rows.length + ' 行 · 请求数含失败尝试';
|
| }
|
|
|
|
|
| function usCreditHead(dim) {
|
| return dim === 'model'
|
| ? '<tr><th class="mark" aria-hidden="true"></th><th>模型</th><th>积分倍率</th>' +
|
| '<th class="num">请求</th><th class="num">扣除积分</th>' +
|
| '<th class="num">有效样本 Token</th><th class="num">积分 / 1M Token</th><th class="num">缓存命中率</th></tr>'
|
| : '<tr><th class="mark" aria-hidden="true"></th><th>账号</th>' +
|
| '<th class="num">请求</th><th class="num">扣除积分</th>' +
|
| '<th class="num">有效样本 Token</th><th class="num">积分 / 1M Token</th><th class="num">缓存命中率</th></tr>';
|
| }
|
|
|
| |
|
|
| function cacheRateCell(hit, miss) {
|
| const h = Number(hit || 0), m = Number(miss || 0), total = h + m;
|
| if (!total) return '<span class="muted">—</span>';
|
| const pct = h / total * 100;
|
| const color = pct >= 90 ? 'var(--ok)' : (pct >= 80 ? 'var(--warn)' : 'var(--bad)');
|
| const txt = trimFixed(pct.toFixed(1)) + '%';
|
| return '<span style="color:' + color + '" title="命中 ' + fmtTok(h) + ' / 未命中 ' + fmtTok(m) + ' tok">' + txt + '</span>';
|
| }
|
|
|
| function renderCreditDim() {
|
| const d = usageData || {};
|
| $('usCreditHead').innerHTML = usCreditHead(usCreditDim);
|
| const empty = '暂无积分扣除记录；升级前仅含 Token 的历史不会伪造积分。';
|
| if (usCreditDim === 'model') {
|
| const models = d.credit_by_model || [];
|
| $('usCreditBody').innerHTML = models.map(row =>
|
| '<tr>' +
|
| '<td class="mark" aria-hidden="true"></td>' +
|
| '<td>' + esc(row.key || '—') + '</td>' +
|
| '<td>' + esc(fmtModelRate(row.rate)) + '</td>' +
|
| '<td class="num">' + fmtTok(row.requests) + '</td>' +
|
| '<td class="num">' + fmtCredit(row.credits) + '</td>' +
|
| '<td class="num">' + fmtTok(row.credit_tokens) + '</td>' +
|
| '<td class="num">' + fmtCreditRatio(row.credits_per_1m_tokens, row.credit_samples, row.credit_tokens) + '</td>' +
|
| '<td class="num">' + cacheRateCell(row.cache_hit_tokens, row.cache_miss_tokens) + '</td>' +
|
| '</tr>'
|
| ).join('') || '<tr><td colspan="8" class="empty">' + empty + '</td></tr>';
|
| } else {
|
| const accounts = d.credit_by_account || [];
|
| $('usCreditBody').innerHTML = accounts.map(row => {
|
| const uid = String(row.key || '');
|
| const account = row.nickname || uid.slice(0, 8) || '—';
|
| return '<tr>' +
|
| '<td class="mark" aria-hidden="true"></td>' +
|
| '<td>' + esc(account) + '<div class="note">' + esc(row.realm || '') + ' · ' + esc(uid.slice(0, 8)) + '</div></td>' +
|
| '<td class="num">' + fmtTok(row.requests) + '</td>' +
|
| '<td class="num">' + fmtCredit(row.credits) + '</td>' +
|
| '<td class="num">' + fmtTok(row.credit_tokens) + '</td>' +
|
| '<td class="num">' + fmtCreditRatio(row.credits_per_1m_tokens, row.credit_samples, row.credit_tokens) + '</td>' +
|
| '<td class="num">' + cacheRateCell(row.cache_hit_tokens, row.cache_miss_tokens) + '</td>' +
|
| '</tr>';
|
| }).join('') || '<tr><td colspan="7" class="empty">' + empty + '</td></tr>';
|
| }
|
| $('usCreditTabs').innerHTML = usTabsHtml([['account', '按账号'], ['model', '按模型']], usCreditDim, {
|
| account: (d.credit_by_account || []).length,
|
| model: (d.credit_by_model || []).length,
|
| });
|
| }
|
|
|
| function renderUsage(d) {
|
| usageData = d || {};
|
| const t = usageData.totals || {};
|
| const total = Number(t.total_tokens || 0);
|
| const pt = Number(t.prompt_tokens || 0);
|
| const ct = Number(t.completion_tokens || 0);
|
| const reqs = Number(t.requests || 0);
|
| const errs = Number(t.errors || 0);
|
| const okRate = reqs ? (reqs - errs) / reqs * 100 : null;
|
|
|
| const pctW = (part) => total ? Math.max(0, Math.min(100, Number(part || 0) / total * 100)).toFixed(2) + '%' : '0%';
|
|
|
|
|
| $('usStats').innerHTML =
|
| usKpi(fmtTok(reqs), '请求数', 'c-accent',
|
| errs ? '其中失败 ' + errs + ' 次' : '全部成功') +
|
| usKpi(fmtTok(total), '总 token', 'c-accent',
|
| 'prompt ' + usPct(pt, total) + ' · completion ' + usPct(ct, total),
|
| '<div class="kbar"><i style="width:' + pctW(pt) + ';background:var(--accent)"></i>' +
|
| '<i style="width:' + pctW(ct) + ';background:var(--ok)"></i></div>') +
|
| usKpi(fmtTok(pt), 'prompt', 'c-soft', '占比 ' + usPct(pt, total)) +
|
| usKpi(fmtTok(ct), 'completion', 'c-ok', '占比 ' + usPct(ct, total)) +
|
| usKpi(String(errs), '失败尝试', errs ? 'c-warn' : 'c-mute',
|
| okRate == null ? '—' : (errs ? '成功率 ' + okRate.toFixed(1) + '%' : '成功率 100%')) +
|
| usKpi(fmtMs(t.avg_latency_ms), '平均延迟', 'c-soft',
|
| t.avg_tokens_per_second ? '吐字 ' + fmtRate(t.avg_tokens_per_second) : '无速率样本');
|
|
|
|
|
|
|
| const winLabel = trangeLabel('usRange');
|
|
|
|
|
| const rangeEcho = usageData.window_from
|
| ? String(usageData.window_from).replace('T', ' ').slice(0, 16) +
|
| (usageData.window_to ? ' → ' + String(usageData.window_to).replace('T', ' ').slice(0, 16) : ' → 现在')
|
| : '';
|
| const note = (rangeEcho || winLabel ? (rangeEcho || winLabel) + ' · ' : '') +
|
| (usageData.buckets || 0) + ' 个分桶' +
|
| (usageData.since ? ' · 数据自 ' + usageData.since.replace('T', ' ') : '') +
|
| (usageData.file_bytes ? ' · 文件 ' + (usageData.file_bytes / 1024).toFixed(1) + ' KB' : '');
|
| $('usNote').textContent = note;
|
| $('usNote').title = note;
|
|
|
|
|
| $('usCreditStats').innerHTML =
|
| usKpi(fmtCredit(t.credits), '扣除积分', 'c-accent', '按上游 usage.credit 累计') +
|
| usKpi(fmtTok(t.credit_tokens), '匹配 Token', 'c-mute', '与积分同时观测到的 Token') +
|
| usKpi(fmtCreditRatio(t.credits_per_1m_tokens, t.credit_samples, t.credit_tokens),
|
| '平均积分 / 1M Token', 'c-ok', '越低越划算') +
|
| usKpi(String(t.credit_samples || 0), '有效积分样本', 'c-mute', '缺字段的历史不参与折算') +
|
| usKpi(cacheRateText(t.cache_hit_tokens, t.cache_miss_tokens), '缓存命中率', 'c-mute',
|
| '上游前缀缓存命中 / (命中+未命中)；低命中意味着费用数倍放大');
|
| $('usCreditNote').textContent =
|
| (usageData.credit_by_account || []).length + ' 个账号 · ' +
|
| (usageData.credit_by_model || []).length + ' 个模型倍率分组 · 仅统计与积分同时观测到的 Token';
|
|
|
| renderUsageDim();
|
| renderCreditDim();
|
| renderUsageChart(usageData.series || []);
|
| }
|
|
|
|
|
| if ($('usDimTabs')) $('usDimTabs').addEventListener('click', ev => {
|
| const b = ev.target.closest('button[data-dim]');
|
| if (!b) return;
|
| usDim = b.dataset.dim;
|
| renderUsageDim();
|
| });
|
| if ($('usCreditTabs')) $('usCreditTabs').addEventListener('click', ev => {
|
| const b = ev.target.closest('button[data-dim]');
|
| if (!b) return;
|
| usCreditDim = b.dataset.dim;
|
| renderCreditDim();
|
| });
|
| if ($('usSort')) $('usSort').onchange = () => {
|
| usSort = $('usSort').value;
|
| renderUsageDim();
|
| };
|
|
|
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
|
|
|
|
|
|
| function parsePointTime(p) {
|
|
|
| const s = p.t.length === 13 ? p.t + ':00:00' : p.t + 'T00:00:00';
|
| const d = new Date(s);
|
| return isNaN(d.getTime()) ? null : d.getTime();
|
| }
|
|
|
|
|
| function fmtTokTimeLabel(p) {
|
| const d = new Date(p.t);
|
| return p.scope === 'day'
|
| ? (d.getMonth() + 1) + '-' + String(d.getDate()).padStart(2, '0')
|
| : String(d.getHours()).padStart(2, '0') + ':00';
|
| }
|
|
|
| function renderUsageChart(series) {
|
| const host = $('usChart');
|
|
|
|
|
| const pts = [];
|
| for (const p of series) {
|
| const t = parsePointTime(p);
|
| if (t === null) continue;
|
| const pt = Number(p.prompt_tokens || 0);
|
| const ct = Number(p.completion_tokens || 0);
|
| pts.push({ t, scope: p.scope, raw: p.t, pt, ct, tt: Number(p.total_tokens || 0) || (pt + ct),
|
| req: p.requests || 0 });
|
| }
|
| if (!pts.length) {
|
| host.innerHTML = '<div class="us-empty">暂无用量数据。发起一次对话后再刷新。</div>';
|
| $('usChartNote').textContent = '—';
|
| return;
|
| }
|
|
|
| const W = 1200, H = 200, PL = 58, PR = 14, PT = 18, PB = 30;
|
| const iw = W - PL - PR, ih = H - PT - PB;
|
|
|
| const t0 = pts[0].t;
|
| const t1 = pts[pts.length - 1].t;
|
| const span = Math.max(1, t1 - t0);
|
|
|
| const max = Math.max(1, ...pts.map(p => p.tt));
|
| const peak = pts.reduce((a, b) => (b.tt > a.tt ? b : a), pts[0]);
|
| const avg = pts.reduce((s, p) => s + p.tt, 0) / pts.length;
|
| $('usChartNote').textContent =
|
| pts.length + ' 个点 · 峰值 ' + fmtTok(peak.tt) + ' @ ' + fmtTokTimeLabel(peak) +
|
| ' · 均值 ' + fmtTok(avg);
|
|
|
|
|
|
|
| let minGap = Infinity;
|
| for (let i = 1; i < pts.length; i++) minGap = Math.min(minGap, pts[i].t - pts[i - 1].t);
|
| if (!isFinite(minGap) || minGap <= 0) minGap = span;
|
| const slot = iw * (minGap / span);
|
| const bw = Math.max(2, Math.min(30, slot * 0.7));
|
|
|
|
|
|
|
| const xOf = t => PL + bw / 2 + (t - t0) / span * Math.max(1, iw - bw);
|
| const yOf = v => PT + ih - ih * (v / max);
|
|
|
| let out = '<svg viewBox="0 0 ' + W + ' ' + H + '" role="img" ' +
|
| 'preserveAspectRatio="xMidYMid meet">';
|
|
|
|
|
|
|
|
|
| out += '<defs>' +
|
| '<linearGradient id="usGradP" x1="0" y1="0" x2="0" y2="1">' +
|
| '<stop offset="0" style="stop-color:var(--accent);stop-opacity:1"/>' +
|
| '<stop offset="1" style="stop-color:var(--accent);stop-opacity:.6"/></linearGradient>' +
|
| '<linearGradient id="usGradC" x1="0" y1="0" x2="0" y2="1">' +
|
| '<stop offset="0" style="stop-color:var(--ok);stop-opacity:1"/>' +
|
| '<stop offset="1" style="stop-color:var(--ok);stop-opacity:.6"/></linearGradient>' +
|
| '</defs>';
|
|
|
|
|
| for (let i = 0; i <= 4; i++) {
|
| const y = PT + ih - (ih * i / 4);
|
| out += '<line class="gl" x1="' + PL + '" y1="' + y.toFixed(1) + '" x2="' + (W - PR) +
|
| '" y2="' + y.toFixed(1) + '"/>';
|
| out += '<text class="tk" x="' + (PL - 6) + '" y="' + (y + 3.5).toFixed(1) +
|
| '" text-anchor="end">' + fmtTok(max * i / 4) + '</text>';
|
| }
|
|
|
|
|
|
|
| if (avg > 0 && avg < max) {
|
| const y = yOf(avg);
|
| out += '<line class="avg" x1="' + PL + '" y1="' + y.toFixed(1) + '" x2="' + (W - PR) +
|
| '" y2="' + y.toFixed(1) + '"/>';
|
| out += '<text class="tk-avg" x="' + (PL + 5) + '" y="' + (y - 4).toFixed(1) +
|
| '" text-anchor="start">均值 ' + fmtTok(avg) + '</text>';
|
| }
|
|
|
|
|
| const yBase = PT + ih;
|
| for (const p of pts) {
|
| const x = xOf(p.t) - bw / 2;
|
| const hTot = ih * (p.tt / max);
|
| const hP = p.tt ? hTot * (p.pt / p.tt) : 0;
|
| const hC = Math.max(p.tt && p.ct ? 1 : 0, hTot - hP);
|
|
|
|
|
|
|
| if (hP > 0) out += '<rect class="usbar" x="' + x.toFixed(2) + '" y="' + (yBase - hP).toFixed(2) +
|
| '" width="' + bw.toFixed(2) + '" height="' + hP.toFixed(2) +
|
| '" fill="url(#usGradP)"' + (hC > 0 ? '' : ' rx="1.5"') + '/>';
|
| if (hC > 0) out += '<rect class="usbar" x="' + x.toFixed(2) + '" y="' + (yBase - hP - hC).toFixed(2) +
|
| '" width="' + bw.toFixed(2) + '" height="' + hC.toFixed(2) +
|
| '" fill="url(#usGradC)" rx="1.5"/>';
|
| out += '<title>' + esc(p.raw) + ' ' + fmtTok(p.pt) + ' prompt / ' +
|
| fmtTok(p.ct) + ' completion / ' + p.req + ' 次</title>';
|
| }
|
|
|
|
|
| {
|
| const px = xOf(peak.t);
|
| const py = yOf(peak.tt);
|
| const anchor = px > W - PR - 90 ? 'end' : 'middle';
|
| out += '<text class="tk-peak" x="' + Math.max(PL, Math.min(W - PR, px)).toFixed(1) +
|
| '" y="' + Math.max(10, py - 5).toFixed(1) + '" text-anchor="' + anchor + '">' +
|
| '峰值 ' + fmtTok(peak.tt) + '</text>';
|
| }
|
|
|
|
|
| out += '<line class="ax" x1="' + PL + '" y1="' + yBase + '" x2="' + (W - PR) +
|
| '" y2="' + yBase + '"/>';
|
|
|
|
|
|
|
| const TICKS = Math.min(6, pts.length);
|
| const usedLabel = new Set();
|
| for (let k = 0; k < TICKS; k++) {
|
| const target = t0 + span * (TICKS === 1 ? 0.5 : k / (TICKS - 1));
|
| let bi = 0, best = Infinity;
|
| for (let i = 0; i < pts.length; i++) {
|
| const d = Math.abs(pts[i].t - target);
|
| if (d < best) { best = d; bi = i; }
|
| }
|
| if (usedLabel.has(bi)) continue;
|
| usedLabel.add(bi);
|
| const p = pts[bi];
|
|
|
| const cx = xOf(p.t);
|
| const anchor = cx < PL + 14 ? 'start' : (cx > W - PR - 14 ? 'end' : 'middle');
|
| out += '<text class="tk" x="' + Math.max(PL, Math.min(W - PR, cx)).toFixed(1) +
|
| '" y="' + (PT + ih + 15) + '" text-anchor="' + anchor + '">' + esc(fmtTokTimeLabel(p)) + '</text>';
|
| }
|
|
|
|
|
| let prevDay = null;
|
| for (const p of pts) {
|
| const d = new Date(p.t).getDate();
|
| if (prevDay !== null && d !== prevDay) {
|
| const x = xOf(p.t).toFixed(1);
|
| out += '<line class="gl" x1="' + x + '" y1="' + PT + '" x2="' + x + '" y2="' +
|
| (PT + ih) + '" style="opacity:.45"/>';
|
| }
|
| prevDay = d;
|
| }
|
|
|
| out += '</svg>';
|
| host.innerHTML = out;
|
| }
|
|
|
| function fmtTokTip(v) { return fmtTok(v); }
|
|
|
| let usageRateWarmAt = 0;
|
| async function warmUsageModelRates() {
|
| if (Date.now() - usageRateWarmAt < 10 * 60 * 1000) return;
|
| try {
|
| await api('models');
|
| } catch (e) {
|
|
|
| }
|
| usageRateWarmAt = Date.now();
|
| }
|
|
|
| async function loadUsage() {
|
| const q = trangeQuery('usRange', true);
|
| try {
|
| await warmUsageModelRates();
|
| const d = await api('usage?' + q.toString());
|
| renderUsage(d);
|
| } catch (e) {
|
|
|
| usageData = null;
|
| $('usChart').innerHTML = '<div class="us-empty">读取用量失败：' + esc(e.message) + '</div>';
|
| $('usChartNote').textContent = '—';
|
| $('usStats').innerHTML = '';
|
| $('usCreditStats').innerHTML = '';
|
| $('usNote').textContent = '—';
|
| $('usCreditNote').textContent = '—';
|
| $('usDimNote').textContent = '—';
|
| $('usDimHead').innerHTML = '';
|
| $('usCreditHead').innerHTML = '';
|
| $('usDimTabs').innerHTML = usTabsHtml(US_DIM_TABS, usDim, null);
|
| $('usCreditTabs').innerHTML = usTabsHtml([['account', '按账号'], ['model', '按模型']], usCreditDim, null);
|
| $('usDimBody').innerHTML = '<tr><td colspan="10" class="empty">读取用量失败</td></tr>';
|
| $('usCreditBody').innerHTML = '<tr><td colspan="7" class="empty">读取用量失败</td></tr>';
|
| }
|
| }
|
|
|
| if ($('btnUsage')) $('btnUsage').onclick = loadUsage;
|
|
|
| if ($('usRange')) trangeBind('usRange', loadUsage);
|
|
|
|
|
| |
| |
| |
|
|
|
|
| const PK_COLORS = ['#4f8cff', '#25b08b', '#e8a33d', '#c96bd6', '#e2607a',
|
| '#5aa9e6', '#8fbf3f', '#b58b5a', '#7d8fa8', '#d4785c'];
|
| const PK_ACCOUNT_COLORS = ['#4f8cff', '#25b08b', '#e8a33d', '#c96bd6',
|
| '#e2607a', '#20a4a4', '#8fbf3f', '#d4785c',
|
| '#7c83db', '#c48a2f', '#b45f8c', '#5aa9e6'];
|
|
|
| function pkColor(i) { return PK_COLORS[i % PK_COLORS.length]; }
|
|
|
|
|
| function pkAccountColorMap(list) {
|
| const uids = (list || [])
|
| .filter(a => a && !a.error && a.uid)
|
| .map(a => String(a.uid))
|
| .sort();
|
| const colors = new Map();
|
| uids.forEach((uid, i) => colors.set(uid, PK_ACCOUNT_COLORS[i % PK_ACCOUNT_COLORS.length]));
|
| return colors;
|
| }
|
|
|
| |
|
|
| function pkBySource(packs) {
|
| const m = new Map();
|
| for (const p of packs) {
|
|
|
|
|
|
|
|
|
| const k = (p.package_code || '') + '|' + (p.name || '(未命名)');
|
| const e = m.get(k) || {
|
| key: k, name: p.name || '(未命名)', code: p.package_code || '',
|
| n: 0, remain: 0, size: 0, used: 0, minEnd: '', minCreated: '',
|
| };
|
| e.n += 1;
|
| e.remain += Number(p.remain || 0);
|
| e.size += Number(p.size || 0);
|
| e.used += Number(p.used || 0);
|
| const t = (p.end_time || '').slice(0, 10);
|
| if (t && (!e.minEnd || t < e.minEnd)) e.minEnd = t;
|
| const c = (p.created_at || '').slice(0, 10);
|
| if (c && (!e.minCreated || c < e.minCreated)) e.minCreated = c;
|
| m.set(k, e);
|
| }
|
| return [...m.values()].sort((a, b) => b.size - a.size);
|
| }
|
|
|
| const PK_DEFAULT_DETAIL_LIMIT = 5;
|
|
|
| function pkDetailLimitValue(raw) {
|
| const n = Number(raw);
|
| return Number.isFinite(n) && n > 0 ? Math.floor(n) : PK_DEFAULT_DETAIL_LIMIT;
|
| }
|
|
|
| function pkDetailLimit(cfg) {
|
| return pkDetailLimitValue(cfg && cfg.panel && cfg.panel.package_detail_limit);
|
| }
|
|
|
| const PK_DAY_MS = 24 * 3600 * 1000;
|
|
|
| function pkExpiryMs(p) {
|
| const raw = Number(p && p.expires_at);
|
| if (Number.isFinite(raw) && raw > 0) return raw;
|
| const text = String((p && p.end_time) || '').trim();
|
| if (!text) return null;
|
| let iso = text.includes('T') ? text : text.replace(' ', 'T');
|
| if (!/(?:Z|[+-]\d\d:\d\d)$/.test(iso)) iso += '+08:00';
|
| const parsed = Date.parse(iso);
|
| return Number.isFinite(parsed) ? parsed : null;
|
| }
|
|
|
|
|
|
|
|
|
|
|
|
|
| function pkDetailCompare(a, b) {
|
| const sizeOf = p => {
|
| const n = Number(p && p.size);
|
| return Number.isFinite(n) ? n : 0;
|
| };
|
| const mode = (typeof pkSortMode === 'string' && pkSortMode) || 'end_asc';
|
| if (mode === 'size_desc') {
|
| const d = sizeOf(b) - sizeOf(a);
|
| if (d !== 0) return d;
|
| }
|
| const ea = pkExpiryMs(a), eb = pkExpiryMs(b);
|
| if (ea == null && eb != null) return 1;
|
| if (ea != null && eb == null) return -1;
|
| if (ea != null && eb != null && ea !== eb) return ea - eb;
|
| return sizeOf(b) - sizeOf(a);
|
| }
|
|
|
| function pkDetailGroups(packs, limit) {
|
| const active = [], used = [];
|
| let usedSize = 0, restSize = 0, restRemain = 0;
|
| for (const p of packs || []) {
|
| const remain = Number(p && p.remain);
|
| if (remain > 0) {
|
| active.push(p);
|
| continue;
|
| }
|
| used.push(p);
|
| const size = Number(p && p.size);
|
| if (Number.isFinite(size)) usedSize += size;
|
| }
|
| active.sort(pkDetailCompare);
|
| used.sort(pkDetailCompare);
|
| const visible = active.slice(0, pkDetailLimitValue(limit));
|
| const rest = active.slice(visible.length);
|
| for (const p of rest) {
|
| const size = Number(p && p.size);
|
| if (Number.isFinite(size)) restSize += size;
|
| const remain = Number(p && p.remain);
|
| if (Number.isFinite(remain)) restRemain += remain;
|
| }
|
| return { visible, rest, used, restSize, restRemain, usedSize };
|
| }
|
|
|
| function pkCreditOpacity(days) {
|
| if (days == null || !Number.isFinite(Number(days))) return 1;
|
| return 0.25 + 0.75 * Math.max(0, Math.min(29, Number(days) - 1)) / 29;
|
| }
|
|
|
| function pkExpiryText(expiresAt) {
|
| if (!expiresAt) return '无到期时间';
|
| const diff = expiresAt - Date.now();
|
| if (diff <= 0) return '已到期';
|
| const minutes = Math.max(1, Math.ceil(diff / 60000));
|
| if (minutes < 60) return '剩余 ' + minutes + ' 分钟';
|
| const hours = Math.ceil(diff / 3600000);
|
| if (hours < 24) return '剩余 ' + hours + ' 小时';
|
| return '剩余 ' + Math.ceil(diff / PK_DAY_MS) + ' 天';
|
| }
|
|
|
| function pkExpiryDateTime(expiresAt) {
|
| if (!expiresAt) return '—';
|
| return new Date(expiresAt).toLocaleString('zh-CN', {
|
| timeZone: 'Asia/Shanghai', hour12: false,
|
| year: 'numeric', month: '2-digit', day: '2-digit',
|
| hour: '2-digit', minute: '2-digit', second: '2-digit',
|
| });
|
| }
|
|
|
| function pkAccountSegments(a, now) {
|
| let balance = Math.max(0, Number(a.remain || 0));
|
| const out = [];
|
| for (const p of a.packages || []) {
|
| const remain = Number(p.remain || 0);
|
| if (!Number.isFinite(remain) || remain <= 0 || balance <= 0) continue;
|
| const amount = Math.min(balance, remain);
|
| const expiresAt = pkExpiryMs(p);
|
| out.push({
|
| amount,
|
| expiresAt,
|
| days: expiresAt == null ? null : Math.max(0, Math.ceil((expiresAt - now) / PK_DAY_MS)),
|
| source: p.name || '积分',
|
| uid: String(a.uid || ''),
|
| accountName: a.nickname || String(a.uid || '').slice(0, 8) || '未命名账号',
|
| });
|
| balance -= amount;
|
| }
|
| return out.sort((x, y) => {
|
| if (x.expiresAt == null && y.expiresAt != null) return 1;
|
| if (x.expiresAt != null && y.expiresAt == null) return -1;
|
| return (x.expiresAt || 0) - (y.expiresAt || 0);
|
| });
|
| }
|
|
|
|
|
|
|
| function summarizeCreditDays(list, now) {
|
| const buckets = new Map();
|
| let unavailable = 0;
|
| for (const a of list || []) {
|
| if (a.error || !Number.isFinite(Number(a.remain))) {
|
| unavailable++;
|
| continue;
|
| }
|
| for (const segment of pkAccountSegments(a, now)) {
|
| if (segment.days == null) continue;
|
| let row = buckets.get(segment.days);
|
| if (!row) {
|
| row = { days: segment.days, credits: 0, segments: [] };
|
| buckets.set(segment.days, row);
|
| }
|
| row.credits += segment.amount;
|
| row.segments.push(segment);
|
| }
|
| }
|
| const rows = [...buckets.values()].sort((a, b) => a.days - b.days);
|
| for (const row of rows) {
|
| row.segments.sort((a, b) =>
|
| (a.expiresAt || Infinity) - (b.expiresAt || Infinity) ||
|
| a.accountName.localeCompare(b.accountName) ||
|
| a.source.localeCompare(b.source));
|
| }
|
| return { rows, accountCount: (list || []).length, unavailable };
|
| }
|
|
|
| function renderExpiryDistribution(list, now) {
|
| const summary = summarizeCreditDays(list, now);
|
| const colors = pkAccountColorMap(list);
|
| const rows = summary.rows.map(row => {
|
| const total = row.credits || 1;
|
| const nodes = row.segments.map(segment => {
|
| const color = colors.get(segment.uid) || 'var(--accent)';
|
| const title = segment.source + '\n' + fmtTok(segment.amount) + ' 积分\n到期时间 ' +
|
| pkExpiryDateTime(segment.expiresAt) + '（' + pkExpiryText(segment.expiresAt) + '）\n' +
|
| segment.accountName;
|
| return '<span class="pk-expiry-seg" style="--seg-color:' + color +
|
| ';opacity:' + pkCreditOpacity(segment.days).toFixed(5) +
|
| ';flex:' + Math.max(0.008, segment.amount / total).toFixed(4) +
|
| ' 1 0" title="' + esc(title) + '" aria-label="' + esc(title) + '"></span>';
|
| }).join('');
|
| return '<div class="pk-expiry-row"><span>' + esc(row.days === 0 ? '已到期' : row.days + ' 天') +
|
| '</span><div class="pk-expiry-track">' + nodes + '</div><b>' + esc(fmtTok(row.credits)) +
|
| '</b></div>';
|
| }).join('');
|
| const foot = summary.accountCount + ' 个账号' +
|
| (summary.unavailable ? ' · ' + summary.unavailable + ' 个未获取余额' : '');
|
| const legend = (list || []).filter(a =>
|
| a && !a.error && a.uid && pkAccountSegments(a, now).some(s => s.days != null)
|
| ).map(a => '<span><i style="background:' + (colors.get(String(a.uid)) || 'var(--accent)') +
|
| '"></i>' + esc(a.nickname || String(a.uid).slice(0, 8)) + '</span>').join('');
|
| const hdr = '<div class="pk-expiry-hdr"><span>剩余天数</span><span style="text-align:center">各账号该批剩余</span><b>剩余积分</b></div>';
|
| $('pkExpiry').innerHTML = (rows
|
| ? hdr + '<div class="pk-expiry-chart">' + rows + '</div>'
|
| : '<div class="pk-expiry-empty">暂无可汇总积分</div>') +
|
| (legend ? '<div class="pk-expiry-legend">' + legend + '</div>' : '') +
|
| '<div class="pk-expiry-foot">' + esc(foot) + '</div>';
|
| }
|
|
|
| function renderPackages(d, detailLimit) {
|
| const list = (d.accounts || []);
|
| const now = Date.now();
|
| const expiryColors = pkAccountColorMap(list);
|
| renderExpiryDistribution(list, now);
|
| if (!list.length) {
|
| $('pkSummary').innerHTML = '<div class="empty">没有账号</div>';
|
| return;
|
| }
|
|
|
|
|
| const names = [];
|
| for (const a of list) for (const s of pkBySource(a.packages || [])) {
|
| if (!names.includes(s.key)) names.push(s.key);
|
| }
|
| names.sort((x, y) => {
|
| const sz = n => Math.max(...list.map(a => {
|
| const f = pkBySource(a.packages || []).find(s => s.key === n);
|
| return f ? f.size : 0;
|
| }));
|
| return sz(y) - sz(x);
|
| });
|
| const colorOf = n => pkColor(names.indexOf(n));
|
|
|
| const labelOf = {};
|
| for (const a of list) for (const s of pkBySource(a.packages || [])) labelOf[s.key] = s;
|
|
|
| const maxRemain = Math.max(1, ...list.map(a => Number(a.remain || 0)));
|
|
|
| $('pkSummary').innerHTML = list.map(a => {
|
| if (a.error) {
|
| return '<div class="pk-card"><div class="who"><span class="nm">' +
|
| esc((a.nickname || a.uid.slice(0, 8))) + '</span>' +
|
| '<span class="realm">' + esc(a.realm || '') + '</span></div>' +
|
| '<div class="err">查询失败：' + esc(a.error) + '</div></div>';
|
| }
|
| const srcs = pkBySource(a.packages || []);
|
| const total = Math.max(1, Number(a.size || 0));
|
| const bar = srcs.map(s =>
|
| '<i style="width:' + (s.size / total * 100).toFixed(2) + '%;background:' +
|
| colorOf(s.key) + '" title="' + esc(s.name) + ' ' + fmtTok(s.size) + '"></i>'
|
| ).join('');
|
| const legend = srcs.map(s =>
|
| '<span><i style="background:' + colorOf(s.key) + '"></i>' +
|
| esc(s.name.replace(/^CodeBuddy/, '')) + ' x' + s.n + ' · ' + fmtTok(s.size) +
|
| (s.minCreated ? ' · 首发 ' + esc(s.minCreated.slice(5)) : '') + '</span>'
|
| ).join('');
|
| const expiry = pkAccountSegments(a, now);
|
| const expiryTotal = Math.max(1, expiry.reduce((sum, s) => sum + s.amount, 0));
|
| const expiryColor = expiryColors.get(String(a.uid)) || 'var(--accent)';
|
| const expiryBar = expiry.length ? '<div class="expirybar" role="img" aria-label="积分到期分布">' +
|
| expiry.map(s => {
|
| const title = s.source + '\n' + fmtTok(s.amount) + ' 积分\n到期时间 ' +
|
| pkExpiryDateTime(s.expiresAt) + '（' + pkExpiryText(s.expiresAt) + '）';
|
| return '<i style="background:' + expiryColor +
|
| ';opacity:' + pkCreditOpacity(s.days).toFixed(5) +
|
| ';flex:' + Math.max(0.008, s.amount / expiryTotal).toFixed(4) +
|
| ' 1 0" title="' + esc(title) + '"></i>';
|
| }).join('') + '</div>' : '';
|
| return '<div class="pk-card">' +
|
| '<div class="who"><span class="nm">' + esc(a.nickname || a.uid.slice(0, 8)) + '</span>' +
|
| '<span class="realm">' + esc(a.realm || '') + '</span></div>' +
|
| '<div class="big">' + fmtTok(a.remain) + '</div>' +
|
| '<div class="sub">共 ' + fmtTok(a.size) + ' · ' + (a.packages || []).length +
|
| ' 个包 · 占最高 ' + (Number(a.remain || 0) / maxRemain * 100).toFixed(0) + '%</div>' +
|
| '<div class="mixbar">' + bar + '</div>' +
|
| expiryBar +
|
| '<div class="pk-legend">' + legend + '</div>' +
|
| '</div>';
|
| }).join('');
|
|
|
| $('pkNote').textContent = list.length + ' 个账号 · 实时查询上游';
|
|
|
|
|
| $('pkDetail').innerHTML = list.map(a => {
|
| if (a.error) return '';
|
| const groups = pkDetailGroups(a.packages || [], detailLimit);
|
| const rowOf = (p, rowGroup) => {
|
| const k = (p.package_code || '') + '|' + (p.name || '(未命名)');
|
| const sub = (p.sub_product_code || '').replace(/^sp_tcaca_codebuddyide_?/, '') ||
|
| (p.package_code || '').replace(/^TCACA_/, '');
|
| return '<tr' + (rowGroup ? ' class="pk-hidden-row pk-' + rowGroup +
|
| '-row" data-pk-row="' + rowGroup + '" hidden' : '') +
|
| '><td class="mark" aria-hidden="true"><i style="background:' +
|
| colorOf(k) + '"></i></td>' +
|
| '<td>' + esc(p.name || '(未命名)') +
|
| (sub ? '<div class="note">' + esc(sub) + '</div>' : '') + '</td>' +
|
| '<td class="num">' + fmtTok(p.size) + '</td>' +
|
| '<td class="num">' + fmtTok(p.remain) + '</td>' +
|
| '<td class="num">' + fmtTok(p.used) + '</td>' +
|
| '<td class="num">' + esc((p.created_at || '').slice(0, 16).replace('T', ' ') || '—') + '</td>' +
|
| '<td class="num">' + esc((p.end_time || '').slice(0, 10) || '—') + '</td>' +
|
| '</tr>';
|
| };
|
| const groupSummary = (group, label, count, size, remain) =>
|
| '<tr class="pk-group-summary"><td colspan="7"><button type="button" class="pk-group-toggle"' +
|
| ' data-pk-group="' + group + '" data-count="' + count + '" data-size="' + size +
|
| '" data-remain="' + remain + '" aria-expanded="false">' + label + '，展开</button></td></tr>';
|
| const rows = groups.visible.map(p => rowOf(p, '')).join('');
|
| const restSummary = groups.rest.length
|
| ? groupSummary('rest', '其余未用完 ' + groups.rest.length + ' 个包（面额合计 ' +
|
| fmtTok(groups.restSize) + ' · 剩余 ' + fmtTok(groups.restRemain) + '）',
|
| groups.rest.length, groups.restSize, groups.restRemain) +
|
| groups.rest.map(p => rowOf(p, 'rest')).join('')
|
| : '';
|
| const usedSummary = groups.used.length
|
| ? groupSummary('used', '已用完 ' + groups.used.length + ' 个包（面额合计 ' +
|
| fmtTok(groups.usedSize) + '）', groups.used.length, groups.usedSize, 0) +
|
| groups.used.map(p => rowOf(p, 'used')).join('')
|
| : '';
|
| return '<div class="box"><header><h3>' +
|
| esc(a.nickname || a.uid.slice(0, 8)) + ' · ' + esc(a.realm || '') +
|
| '</h3><span class="grow"></span><span class="note">余额 ' + fmtTok(a.remain) +
|
| ' / 总额 ' + fmtTok(a.size) + ' · 可用 ' + (groups.visible.length + groups.rest.length) + ' 个包' +
|
| (groups.used.length ? ' / 已用完 ' + groups.used.length + ' 个' : '') +
|
| ' · 默认展示最早到期 ' + pkDetailLimitValue(detailLimit) + ' 条（' +
|
| esc(PK_SORT_LABELS[pkSortMode] || '') + '）</span>' +
|
| '</header><div class="tbl-wrap"><table class="acc"><thead><tr>' +
|
| '<th class="mark" aria-hidden="true"></th><th>包名 / 来源</th>' +
|
| '<th class="num">面额</th><th class="num">剩余</th><th class="num">已用</th>' +
|
| '<th class="num">发放</th><th class="num">到期</th>' +
|
| '</tr></thead><tbody>' + rows + restSummary + usedSummary + '</tbody></table></div></div>';
|
| }).join('');
|
| }
|
|
|
| if ($('pkDetail')) $('pkDetail').addEventListener('click', ev => {
|
| const btn = ev.target.closest('button[data-pk-group]');
|
| if (!btn) return;
|
| const body = btn.closest('tbody');
|
| if (!body) return;
|
| const group = btn.dataset.pkGroup;
|
| const expanded = btn.getAttribute('aria-expanded') === 'true';
|
| body.querySelectorAll('tr[data-pk-row="' + group + '"]').forEach(row => { row.hidden = expanded; });
|
| const count = btn.dataset.count || '0';
|
| const size = btn.dataset.size || '0';
|
| const remain = btn.dataset.remain || '0';
|
| btn.setAttribute('aria-expanded', String(!expanded));
|
| if (group === 'rest') {
|
| btn.textContent = expanded
|
| ? '其余未用完 ' + count + ' 个包（面额合计 ' + fmtTok(size) + ' · 剩余 ' +
|
| fmtTok(remain) + '），展开'
|
| : '收起其余未用完 ' + count + ' 个包';
|
| } else {
|
| btn.textContent = expanded
|
| ? '已用完 ' + count + ' 个包（面额合计 ' + fmtTok(size) + '），展开'
|
| : '收起已用完 ' + count + ' 个包';
|
| }
|
| });
|
|
|
|
|
| |
| |
| |
| |
| |
| |
| |
| |
|
|
| const LS_PK_SORT = 'pkSortMode';
|
| let pkSortMode = localStorage.getItem(LS_PK_SORT) || 'end_asc';
|
| const PK_SORT_LABELS = { end_asc: '按到期升序 · 近的在前', size_desc: '按面额降序' };
|
|
|
| let lastDetailLimit = PK_DEFAULT_DETAIL_LIMIT;
|
|
|
|
|
| if ($('pkSort')) {
|
| $('pkSort').value = pkSortMode;
|
| if ($('pkSort').value !== pkSortMode) {
|
| pkSortMode = 'end_asc';
|
| localStorage.setItem(LS_PK_SORT, pkSortMode);
|
| }
|
| $('pkSort').onchange = () => {
|
| pkSortMode = $('pkSort').value;
|
| localStorage.setItem(LS_PK_SORT, pkSortMode);
|
| if (lastPackages) renderPackages(lastPackages, lastDetailLimit);
|
| };
|
| }
|
|
|
| async function loadPackages() {
|
| $('pkSummary').innerHTML = '<div class="empty">查询中…（逐账号向上游实时查询）</div>';
|
| $('pkDetail').innerHTML = '';
|
| $('pkExpiry').innerHTML = '<div class="pk-expiry-empty">查询中…</div>';
|
| try {
|
| const [d, c] = await Promise.all([
|
| api('packages'),
|
| api('config').catch(() => null),
|
| ]);
|
| lastPackages = d;
|
| lastPackagesAt = Date.now();
|
| lastDetailLimit = pkDetailLimit(c && c.config);
|
| renderPackages(d, lastDetailLimit);
|
| } catch (e) {
|
| $('pkSummary').innerHTML = '<div class="empty">读取失败：' + esc(e.message) + '</div>';
|
| $('pkExpiry').innerHTML = '<div class="pk-expiry-empty">读取失败：' + esc(e.message) + '</div>';
|
| }
|
| }
|
|
|
|
|
| |
| |
| |
|
|
|
|
|
|
|
|
| function expBatches(packs) {
|
| const byDay = new Map();
|
| for (const p of packs || []) {
|
| const r = Number(p.remain || 0);
|
| const t = (p.end_time || '').slice(0, 10);
|
| if (r <= 0 || !t) continue;
|
| byDay.set(t, (byDay.get(t) || 0) + r);
|
| }
|
| return [...byDay.entries()]
|
| .map(([date, remain]) => ({ date, remain }))
|
| .sort((a, b) => (a.date < b.date ? -1 : 1));
|
| }
|
|
|
| function expDaysLeft(dateStr, today) {
|
| return Math.round((new Date(dateStr + 'T00:00:00') - today) / 86400000);
|
| }
|
|
|
| function renderExpiry(d) {
|
| const list = (d.accounts || []);
|
| const today = new Date(); today.setHours(0, 0, 0, 0);
|
| const rows = list.map(a => {
|
| if (a.error) {
|
| return '<div class="exp-row"><span class="exp-dot" style="background:var(--ink-3)"></span>' +
|
| '<span class="exp-nm">' + esc(a.nickname || a.uid.slice(0, 8)) + '</span>' +
|
| '<span class="exp-main err">查询失败：' + esc(a.error) + '</span></div>';
|
| }
|
| const bs = expBatches(a.packages).filter(b => expDaysLeft(b.date, today) >= 0);
|
| if (!bs.length) {
|
| return '<div class="exp-row"><span class="exp-dot" style="background:var(--ok)"></span>' +
|
| '<span class="exp-nm">' + esc(a.nickname || a.uid.slice(0, 8)) + '</span>' +
|
| '<span class="exp-main">7 天内无到期积分</span></div>';
|
| }
|
| const first = bs[0];
|
| const days = expDaysLeft(first.date, today);
|
| const daily = Math.ceil(first.remain / Math.max(1, days));
|
| const week = bs.filter(b => expDaysLeft(b.date, today) <= 7)
|
| .reduce((s, b) => s + b.remain, 0);
|
|
|
|
|
|
|
| const cls = days <= 3 ? 'var(--bad)' : days <= 7 ? 'var(--warn)' : 'var(--ok)';
|
| const dayWord = days === 0 ? '今天到期' : days === 1 ? '明天到期' : days + ' 天后到期';
|
| const more = bs.length > 4 ? ' 等 ' + bs.length + ' 批' : '';
|
| const rest = bs.slice(1, 4).map(b =>
|
| '随后 ' + esc(b.date.slice(5)) + ' · ' + fmtTok(b.remain)).join(' ') + more;
|
| return '<div class="exp-row"><span class="exp-dot" style="background:' + cls + '"></span>' +
|
| '<span class="exp-nm">' + esc(a.nickname || a.uid.slice(0, 8)) + '</span>' +
|
| '<span class="exp-main">最近到期 <b>' + esc(first.date) + '</b>（' + dayWord +
|
| '）· 该批 <b>' + fmtTok(first.remain) + '</b> 积分 · 到期前日均需耗 ≥<b>' +
|
| fmtTok(daily) + '</b>' +
|
| (week > first.remain ? ' · 7 天内合计 ' + fmtTok(week) : '') +
|
| (rest ? '<div class="note">' + rest + '</div>' : '') +
|
| '</span></div>';
|
| }).join('');
|
| $('expList').innerHTML = rows || '<div class="empty">没有账号</div>';
|
|
|
| const ageMin = lastPackages ? Math.floor((Date.now() - lastPackagesAt) / 60000) : 0;
|
| $('expNote').textContent = (lastPackagesAt && ageMin > 0)
|
| ? list.length + ' 个账号 · ' + ageMin + ' 分钟前的数据，可点「检查」刷新'
|
| : list.length + ' 个账号 · 实时查询上游';
|
| $('expBox').hidden = false;
|
| }
|
|
|
| async function loadExpiry(force) {
|
| if (!$('expBox')) return;
|
| if (expFetching) return;
|
| const fresh = lastPackages && (Date.now() - lastPackagesAt) < EXP_FRESH_MS;
|
| if (fresh && !force) { renderExpiry(lastPackages); return; }
|
| expFetching = true;
|
| $('expBox').hidden = false;
|
| if (!$('expList').children.length) $('expList').innerHTML = '<div class="empty">查询中…（逐账号向上游实时查询）</div>';
|
| $('expNote').textContent = '查询中…';
|
| try {
|
| const d = await api('packages');
|
| lastPackages = d;
|
| lastPackagesAt = Date.now();
|
| renderExpiry(d);
|
| } catch (e) {
|
| $('expNote').textContent = '查询失败：' + esc(e.message);
|
| }
|
| expFetching = false;
|
| }
|
|
|
| if ($('btnExp')) $('btnExp').onclick = () => loadExpiry(true);
|
|
|
| if ($('btnPk')) $('btnPk').onclick = loadPackages;
|
|
|
