Files
AI-Account-Toolkit/ob12api/static/manage.js
2026-03-16 09:24:05 +08:00

503 lines
22 KiB
JavaScript
Raw Blame History

This file contains ambiguous Unicode characters
This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.
/* ===== Auth ===== */
const TOKEN = localStorage.getItem('adminToken');
const api = (url, opts = {}) => {
opts.headers = { ...opts.headers, 'Authorization': 'Bearer ' + TOKEN, 'Content-Type': 'application/json' };
return fetch(url, opts).then(r => { if (r.status === 401) { logout(); throw new Error('unauthorized'); } return r.json(); });
};
function checkAuth() {
if (!TOKEN) { location.href = '/static/login.html'; return; }
api('/admin/status').catch(() => logout());
}
function logout() {
localStorage.removeItem('adminToken');
location.href = '/static/login.html';
}
/* ===== Toast ===== */
function showToast(msg, type = 'info') {
const colors = { success: 'bg-green-600', error: 'bg-red-600', info: 'bg-gray-900' };
const el = document.createElement('div');
el.className = `fixed bottom-4 right-4 ${colors[type] || colors.info} text-white px-4 py-2.5 rounded-lg shadow-lg text-sm font-medium z-[200] animate-slide-up`;
el.textContent = msg;
document.body.appendChild(el);
setTimeout(() => { el.style.opacity = '0'; el.style.transition = 'opacity .3s'; setTimeout(() => el.remove(), 300); }, 2000);
}
/* ===== Tabs ===== */
function switchTab(tab) {
['accounts', 'settings', 'chat'].forEach(t => {
document.getElementById('panel' + t.charAt(0).toUpperCase() + t.slice(1)).classList.toggle('hidden', t !== tab);
const btn = document.getElementById('tab' + t.charAt(0).toUpperCase() + t.slice(1));
btn.classList.toggle('border-primary', t === tab);
btn.classList.toggle('border-transparent', t !== tab);
btn.classList.toggle('text-muted-foreground', t !== tab);
});
if (tab === 'settings') loadSettings();
if (tab === 'accounts') loadAccounts();
if (tab === 'chat') loadChatModels();
}
/* ===== Accounts ===== */
let _accounts = [];
function loadAccounts() {
api('/admin/accounts').then(d => {
_accounts = d.accounts || [];
const s = d.stats || {};
document.getElementById('statTotal').textContent = s.total ?? _accounts.length;
document.getElementById('statActive').textContent = s.active ?? '-';
document.getElementById('statCost').textContent = '$' + (s.cost ?? 0).toFixed(2);
document.getElementById('statRequests').textContent = s.requests ?? '-';
renderAccounts();
}).catch(() => showToast('加载账号失败', 'error'));
}
let _pageSize = 20;
let _currentPage = 1;
function renderAccounts() {
const box = document.getElementById('accountList');
const filter = document.getElementById('accountFilter').value;
const filtered = _accounts.map((a, i) => ({ ...a, _idx: i })).filter(a => {
if (filter === 'active') return a.active === true;
if (filter === 'expired') return a.active !== true;
return true;
});
const totalPages = Math.max(1, Math.ceil(filtered.length / _pageSize));
if (_currentPage > totalPages) _currentPage = totalPages;
const start = (_currentPage - 1) * _pageSize;
const paged = filtered.slice(start, start + _pageSize);
if (!filtered.length) {
box.innerHTML = `<tr><td colspan="6" class="text-center text-muted-foreground py-6 text-sm">${_accounts.length ? '无匹配账号' : '暂无账号,点击右上角添加'}</td></tr>`;
} else {
box.innerHTML = paged.map(a => {
const active = a.active === true;
const atTag = a.at_mask ? `<span class="text-green-600 font-mono text-xs">${a.at_mask}</span>` : '<span class="text-red-500">无</span>';
const rtTag = a.rt_mask ? `<span class="text-green-600 font-mono text-xs">${a.rt_mask}</span>` : '<span class="text-red-500">无</span>';
const statusHtml = active
? `<span class="inline-flex items-center gap-1.5 text-green-600"><span class="w-1.5 h-1.5 rounded-full bg-green-500"></span><span data-expires="${a.expires_at}"></span></span>`
: `<span class="inline-flex items-center gap-1.5 text-muted-foreground"><span class="w-1.5 h-1.5 rounded-full bg-gray-400"></span>已过期</span>`;
const checked = _selected.has(a._idx) ? 'checked' : '';
return `<tr class="border-b border-border hover:bg-secondary/50 transition-colors">
<td class="px-4 py-2.5 w-8"><input type="checkbox" data-idx="${a._idx}" ${checked} onchange="toggleSelect(${a._idx})" class="rounded"></td>
<td class="px-4 py-2.5 font-medium">${a.email || '未知邮箱'}</td>
<td class="px-4 py-2.5">${atTag}</td>
<td class="px-4 py-2.5">${rtTag}</td>
<td class="px-4 py-2.5">${statusHtml}</td>
<td class="px-4 py-2.5 text-right">
<button onclick="refreshAccount(${a._idx})" class="text-xs px-2 py-1 rounded border border-border hover:bg-secondary transition-colors">刷新</button>
<button onclick="removeAccount(${a._idx})" class="text-xs px-2 py-1 rounded border border-red-200 text-red-600 hover:bg-red-50 transition-colors ml-1">删除</button>
</td>
</tr>`;
}).join('');
}
const activeCount = _accounts.filter(a => a.active === true).length;
const selCount = _selected.size;
const selText = selCount ? `已选 ${selCount} | ` : '';
// pagination
let pageHtml = '';
if (totalPages > 1) {
pageHtml = `<button onclick="changePage(-1)" class="px-2 py-0.5 rounded border border-border hover:bg-secondary text-xs" ${_currentPage <= 1 ? 'disabled' : ''}>&lt;</button>
<span class="mx-1">${_currentPage}/${totalPages}</span>
<button onclick="changePage(1)" class="px-2 py-0.5 rounded border border-border hover:bg-secondary text-xs" ${_currentPage >= totalPages ? 'disabled' : ''}>&gt;</button>`;
}
document.getElementById('accountFooter').innerHTML = `<div class="flex items-center justify-between">
<span>${selText}显示 ${filtered.length} / ${_accounts.length} 个账号(活跃 ${activeCount}</span>
<div class="flex items-center gap-2">
${pageHtml}
<select onchange="changePageSize(this.value)" class="text-xs h-6 rounded border border-input bg-background px-1">
${[10,20,50,100,200,500,1000].map(n => `<option value="${n}" ${n===_pageSize?'selected':''}>${n}条/页</option>`).join('')}
</select>
</div>
</div>`;
document.getElementById('selectAll').checked = paged.length > 0 && paged.every(a => _selected.has(a._idx));
updateCountdowns();
}
let _selected = new Set();
function toggleSelect(idx) {
_selected.has(idx) ? _selected.delete(idx) : _selected.add(idx);
renderAccounts();
}
function toggleSelectAll() {
const all = document.getElementById('selectAll').checked;
const filter = document.getElementById('accountFilter').value;
const filtered = _accounts.map((a, i) => ({ ...a, _idx: i })).filter(a => {
if (filter === 'active') return a.active === true;
if (filter === 'expired') return a.active !== true;
return true;
});
const start = (_currentPage - 1) * _pageSize;
const paged = filtered.slice(start, start + _pageSize);
paged.forEach(a => all ? _selected.add(a._idx) : _selected.delete(a._idx));
renderAccounts();
}
function getSelectedIndices() { return [..._selected]; }
function changePageSize(v) { _pageSize = parseInt(v); _currentPage = 1; renderAccounts(); }
function changePage(delta) { _currentPage += delta; renderAccounts(); }
function updateCountdowns() {
document.querySelectorAll('[data-expires]').forEach(el => {
const exp = parseInt(el.dataset.expires);
const diff = exp - Date.now();
if (diff <= 0) { el.textContent = '已过期'; el.className = 'text-red-500'; return; }
const d = Math.floor(diff / 86400000);
const h = Math.floor((diff % 86400000) / 3600000);
const m = Math.floor((diff % 3600000) / 60000);
let text = '';
if (d > 0) text += d + '天';
text += h + 'h ' + m + 'm';
el.textContent = text;
if (d < 1) el.className = 'text-orange-500';
});
}
if (!window._countdownTimer) window._countdownTimer = setInterval(updateCountdowns, 1000);
function refreshAccount(idx) {
api(`/admin/accounts/${idx}/refresh`, { method: 'POST' }).then(d => {
d.ok ? showToast('刷新成功', 'success') : showToast(d.error || '刷新失败', 'error');
loadAccounts();
});
}
function removeAccount(idx) {
if (!confirm('确定删除该账号?')) return;
api(`/admin/accounts/${idx}`, { method: 'DELETE' }).then(() => { showToast('已删除', 'success'); loadAccounts(); });
}
function refreshAllAccounts() {
api('/admin/refresh', { method: 'POST' }).then(d => {
d.ok ? showToast('全部刷新完成', 'success') : showToast('刷新失败', 'error');
loadAccounts();
});
}
function batchDeleteAccounts() {
if (!confirm('确定删除所有账号?')) return;
const indices = _accounts.map((_, i) => i);
api('/admin/accounts/batch-delete', { method: 'POST', body: JSON.stringify({ indices }) }).then(d => {
showToast(`已删除 ${d.removed} 个账号`, 'success'); loadAccounts();
});
}
function exportAccounts() {
api('/admin/accounts/export', { method: 'POST' }).then(d => {
const blob = new Blob([JSON.stringify(d.accounts, null, 2)], { type: 'application/json' });
const a = document.createElement('a');
a.href = URL.createObjectURL(blob); a.download = 'ob1_accounts.json'; a.click();
showToast('导出成功', 'success');
});
}
function importAccounts() {
const input = document.createElement('input');
input.type = 'file'; input.accept = '.json';
input.onchange = e => {
const file = e.target.files[0]; if (!file) return;
const reader = new FileReader();
reader.onload = ev => {
try {
const accounts = JSON.parse(ev.target.result);
api('/admin/accounts/import', { method: 'POST', body: JSON.stringify({ accounts: Array.isArray(accounts) ? accounts : [accounts] }) })
.then(d => { showToast(`导入 ${d.imported} 个账号`, 'success'); loadAccounts(); });
} catch { showToast('JSON 格式错误', 'error'); }
};
reader.readAsText(file);
};
input.click();
}
/* ===== Device Auth (Add Account) ===== */
let _pollTimer = null;
function openDeviceAuth() {
document.getElementById('deviceAuthModal').classList.remove('hidden');
document.getElementById('deviceAuthContent').classList.remove('hidden');
document.getElementById('deviceAuthPending').classList.add('hidden');
}
function startDeviceAuth() {
document.getElementById('deviceAuthContent').classList.add('hidden');
document.getElementById('deviceAuthPending').classList.remove('hidden');
api('/admin/device-auth', { method: 'POST' }).then(d => {
if (d.error) {
document.getElementById('deviceAuthContent').classList.remove('hidden');
document.getElementById('deviceAuthPending').classList.add('hidden');
showToast(d.error, 'error');
return;
}
const link = document.getElementById('deviceAuthLink');
link.href = d.verification_uri_complete || d.verification_uri;
link.textContent = d.verification_uri_complete || d.verification_uri;
document.getElementById('deviceAuthCode').textContent = d.user_code || '';
pollDeviceAuth(d.device_code, d.interval || 5);
}).catch(() => {
document.getElementById('deviceAuthContent').classList.remove('hidden');
document.getElementById('deviceAuthPending').classList.add('hidden');
showToast('获取授权失败', 'error');
});
}
function pollDeviceAuth(code, interval) {
clearInterval(_pollTimer);
_pollTimer = setInterval(() => {
api('/admin/device-auth/poll', { method: 'POST', body: JSON.stringify({ device_code: code }) }).then(d => {
if (d.status === 'complete') {
clearInterval(_pollTimer);
closeDeviceAuth();
showToast(`已添加账号: ${d.email}`, 'success');
loadAccounts();
} else if (d.status === 'expired' || d.status === 'error') {
clearInterval(_pollTimer);
showToast(d.message || '授权失败', 'error');
}
});
}, interval * 1000);
}
function closeDeviceAuth() {
clearInterval(_pollTimer);
document.getElementById('deviceAuthModal').classList.add('hidden');
}
/* ===== Settings ===== */
function loadSettings() {
api('/admin/settings').then(d => {
document.getElementById('cfgUsername').value = d.username || '';
document.getElementById('cfgCurrentKey').value = d.api_key || '';
document.getElementById('cfgProxy').value = d.proxy_url || '';
selectRotation(d.rotation_mode || 'cache-first', false);
document.getElementById('cfgDebugLog').checked = (d.log_level || 'INFO') === 'DEBUG';
document.getElementById('cfgRefreshInterval').value = d.refresh_interval || 0;
});
}
function updatePassword() {
const old_password = document.getElementById('cfgOldPwd').value;
const new_password = document.getElementById('cfgNewPwd').value;
if (!old_password || !new_password) { showToast('请填写完整', 'error'); return; }
api('/admin/settings/password', { method: 'POST', body: JSON.stringify({ old_password, new_password }) }).then(d => {
d.ok ? (showToast('密码已更新', 'success'), document.getElementById('cfgOldPwd').value = '', document.getElementById('cfgNewPwd').value = '') : showToast(d.message || '更新失败', 'error');
});
}
function updateUsername() {
const username = document.getElementById('cfgUsername').value.trim();
if (!username) return;
api('/admin/settings/username', { method: 'POST', body: JSON.stringify({ username }) }).then(d => {
d.ok ? showToast('用户名已更新', 'success') : showToast('更新失败', 'error');
});
}
function updateAPIKey() {
const api_key = document.getElementById('cfgNewKey').value.trim();
if (!api_key) return;
api('/admin/settings/api-key', { method: 'POST', body: JSON.stringify({ api_key }) }).then(d => {
d.ok ? showToast('API Key 已更新', 'success') : showToast('更新失败', 'error');
});
}
function updateProxy() {
const url = document.getElementById('cfgProxy').value.trim();
api('/admin/settings/proxy', { method: 'POST', body: JSON.stringify({ url }) }).then(d => {
d.ok ? showToast('代理已更新', 'success') : showToast('更新失败', 'error');
});
}
function testProxy() {
const url = document.getElementById('cfgProxy').value.trim();
if (!url) { showToast('请先填写代理地址', 'error'); return; }
const btn = document.getElementById('btnTestProxy');
btn.disabled = true; btn.textContent = '测试中...';
api('/admin/settings/proxy-test', { method: 'POST', body: JSON.stringify({ url }) }).then(d => {
if (d.ok) showToast('代理可用IP: ' + d.ip, 'success');
else showToast('代理不可用: ' + d.error, 'error');
}).catch(() => showToast('测试请求失败', 'error'))
.finally(() => { btn.disabled = false; btn.textContent = '测试'; });
}
function selectRotation(mode, save = true) {
document.getElementById('cfgRotationMode').value = mode;
if (save) {
api('/admin/settings/rotation-mode', { method: 'POST', body: JSON.stringify({ mode }) }).then(d => {
d.ok ? showToast('调度模式已更新', 'success') : showToast(d.message || '更新失败', 'error');
});
}
}
function toggleDebugLog() {
const level = document.getElementById('cfgDebugLog').checked ? 'DEBUG' : 'INFO';
api('/admin/settings/log-level', { method: 'POST', body: JSON.stringify({ level }) }).then(d => {
d.ok ? showToast(level === 'DEBUG' ? '调试日志已开启' : '调试日志已关闭', 'success') : showToast(d.message || '更新失败', 'error');
});
}
function updateRefreshInterval() {
const interval = parseInt(document.getElementById('cfgRefreshInterval').value) || 0;
api('/admin/settings/refresh-interval', { method: 'POST', body: JSON.stringify({ interval }) }).then(d => {
d.ok ? showToast(interval > 0 ? `自动续期检查已设置为 ${interval} 分钟` : '自动续期已关闭', 'success') : showToast(d.message || '更新失败', 'error');
});
}
/* ===== Chat ===== */
let _chatMessages = [];
const TOP_MODELS = [
'anthropic/claude-opus-4.6',
'anthropic/claude-sonnet-4.6',
'openai/gpt-5.4-pro',
'google/gemini-3.1-flash-image-preview',
'openai/gpt-5.3-codex',
'x-ai/grok-4.1-fast',
'qwen/qwen-3.5-397b',
];
function _shortName(id) { return id.includes('/') ? id.split('/').pop() : id; }
function loadChatModels() {
const sel = document.getElementById('chatModel');
const prev = sel.value;
fetch('/v1/models', { headers: { 'Authorization': 'Bearer ' + TOKEN } })
.then(r => r.json())
.then(d => {
const apiIds = (d.data || []).map(m => m.id);
_fillModelSelect(sel, apiIds, prev);
})
.catch(() => _fillModelSelect(sel, [], prev));
}
function _fillModelSelect(sel, apiIds, prev) {
const all = new Set([...TOP_MODELS, ...apiIds]);
const topSet = new Set(TOP_MODELS);
const rest = [...all].filter(id => !topSet.has(id)).sort();
let html = '<optgroup label="常用">';
html += TOP_MODELS.map(id => `<option value="${id}">${_shortName(id)}</option>`).join('');
html += '</optgroup>';
if (rest.length) {
html += '<optgroup label="全部">';
html += rest.map(id => `<option value="${id}">${_shortName(id)}</option>`).join('');
html += '</optgroup>';
}
sel.innerHTML = html;
sel.value = prev && all.has(prev) ? prev : TOP_MODELS[0];
}
function _parseAssistantMsg(msg) {
const content = msg.content;
const result = { role: 'assistant', content: '', images: [] };
if (typeof content === 'string') {
result.content = content || '';
} else if (Array.isArray(content)) {
for (const part of content) {
if (part.type === 'text') result.content += part.text || '';
else if (part.type === 'image_url') result.images.push(part.image_url?.url || '');
}
}
// OB1/OpenRouter puts images in message.images
if (Array.isArray(msg.images)) {
for (const img of msg.images) {
if (img.image_url?.url) result.images.push(img.image_url.url);
else if (typeof img === 'string') result.images.push(img);
}
}
if (!result.content && !result.images.length) result.content = 'No response';
return result;
}
function sendChat() {
const input = document.getElementById('chatInput');
const msg = input.value.trim();
if (!msg) return;
input.value = '';
_chatMessages.push({ role: 'user', content: msg });
renderChat();
const model = document.getElementById('chatModel').value;
const stream = document.getElementById('chatStream').checked;
if (stream) {
streamChat(model, msg);
} else {
api('/v1/chat/completions', {
method: 'POST',
body: JSON.stringify({ model, messages: _chatMessages, stream: false })
}).then(d => {
const msg = d.choices?.[0]?.message || {};
const parsed = _parseAssistantMsg(msg);
_chatMessages.push(parsed);
renderChat();
}).catch(() => {
_chatMessages.push({ role: 'assistant', content: '请求失败' });
renderChat();
});
}
}
function streamChat(model, msg) {
const assistantMsg = { role: 'assistant', content: '' };
_chatMessages.push(assistantMsg);
renderChat();
fetch('/v1/chat/completions', {
method: 'POST',
headers: { 'Authorization': 'Bearer ' + TOKEN, 'Content-Type': 'application/json' },
body: JSON.stringify({ model, messages: _chatMessages.slice(0, -1), stream: true })
}).then(resp => {
const reader = resp.body.getReader();
const decoder = new TextDecoder();
let buf = '';
function read() {
reader.read().then(({ done, value }) => {
if (done) { renderChat(); return; }
buf += decoder.decode(value, { stream: true });
const lines = buf.split('\n');
buf = lines.pop();
for (const line of lines) {
if (!line.startsWith('data: ') || line === 'data: [DONE]') continue;
try {
const j = JSON.parse(line.slice(6));
const delta = j.choices?.[0]?.delta?.content;
if (delta) { assistantMsg.content += delta; renderChat(); }
} catch {}
}
read();
});
}
read();
}).catch(() => { assistantMsg.content = '流式请求失败'; renderChat(); });
}
function renderChat() {
const box = document.getElementById('chatMessages');
box.innerHTML = _chatMessages.map(m => {
const isUser = m.role === 'user';
let rendered = typeof marked !== 'undefined' ? marked.parse(m.content || '') : (m.content || '');
if (m.images && m.images.length) {
rendered += m.images.map(url => `<img src="${url}" class="mt-2 max-w-full rounded-lg cursor-pointer" style="max-height:400px" onclick="window.open(this.src,'_blank')" alt="生成图片">`).join('');
}
return `<div class="flex ${isUser ? 'justify-end' : 'justify-start'} mb-3">
<div class="chat-msg max-w-[80%] rounded-lg px-4 py-2 text-sm ${isUser ? 'bg-primary text-primary-foreground' : 'bg-secondary'}">
${rendered}
</div>
</div>`;
}).join('');
box.scrollTop = box.scrollHeight;
document.querySelectorAll('.chat-msg pre code').forEach(el => hljs.highlightElement(el));
}
function clearChat() {
_chatMessages = [];
document.getElementById('chatMessages').innerHTML = '';
}
/* ===== Init ===== */
window.addEventListener('DOMContentLoaded', () => {
checkAuth();
loadAccounts();
document.getElementById('chatInput').addEventListener('keydown', e => {
if (e.key === 'Enter' && !e.shiftKey) { e.preventDefault(); sendChat(); }
});
});