shumengya/cwd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(admin): 简化统计查询逻辑，移除域名提取

Browse Source 
移除 extractDomain 函数，直接使用 site_id 字段进行分组统计。
简化 SQL 查询，不再获取 post_slug 和 post_url 字段。
This commit is contained in:
anghunk
2026-02-09 15:58:31 +08:00
parent fea594af0d
commit 67a2777ea8
1 changed files with 5 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
cwd-api/src/api/admin/getStats.ts
View File

@@ -12,31 +12,12 @@ type DomainCounts = StatusCounts & {
domain: string;
};
function extractDomain(source: string | null | undefined): string | null {
if (!source) {
return null;
}
const value = source.trim();
if (!value) {
return null;
}
if (!/^https?:\/\//i.test(value)) {
return null;
}
try {
const url = new URL(value);
return url.hostname.toLowerCase();
} catch {
return null;
}
}
export const getStats = async (c: Context<{ Bindings: Bindings }>) => {
try {
const rawSiteId = c.req.query('siteId');
const siteId = rawSiteId && rawSiteId !== 'default' ? rawSiteId : null;
let sql = 'SELECT created, post_slug, post_url, status FROM Comment';
let sql = 'SELECT created, status, site_id FROM Comment';
const params: any[] = [];
if (siteId) {
@@ -46,9 +27,8 @@ export const getStats = async (c: Context<{ Bindings: Bindings }>) => {
const { results } = await c.env.CWD_DB.prepare(sql).bind(...params).all<{
created: number;
post_slug: string;
post_url: string | null;
status: string;
site_id: string | null;
}>();
const summary: StatusCounts = {
@@ -65,10 +45,9 @@ export const getStats = async (c: Context<{ Bindings: Bindings }>) => {
const thirtyDaysAgo = now - 29 * 24 * 60 * 60 * 1000;
for (const row of results) {
const domain =
extractDomain(row.post_url) || extractDomain(row.post_slug) || 'unknown';
const domainKey = row.site_id && row.site_id.trim() ? row.site_id.trim() : 'default';
let counts = domainMap.get(domain);
let counts = domainMap.get(domainKey);
if (!counts) {
counts = {
total: 0,
@@ -76,7 +55,7 @@ export const getStats = async (c: Context<{ Bindings: Bindings }>) => {
pending: 0,
rejected: 0
};
domainMap.set(domain, counts);
domainMap.set(domainKey, counts);
}
counts.total += 1;
if (row.status === 'approved') {