Merge pull request #4 from dexcoder6/feat/admin-dashboard
fix: 数据看板时区统一为 Asia/Shanghai + 订单列表支付方式显示修复
This commit is contained in:
@@ -1,14 +1,24 @@
|
|||||||
import { NextRequest, NextResponse } from 'next/server';
|
import { NextRequest, NextResponse } from 'next/server';
|
||||||
|
import { Prisma } from '@prisma/client';
|
||||||
import { prisma } from '@/lib/db';
|
import { prisma } from '@/lib/db';
|
||||||
import { verifyAdminToken, unauthorizedResponse } from '@/lib/admin-auth';
|
import { verifyAdminToken, unauthorizedResponse } from '@/lib/admin-auth';
|
||||||
import { OrderStatus } from '@prisma/client';
|
import { OrderStatus } from '@prisma/client';
|
||||||
|
|
||||||
/** 格式化 Date 为 YYYY-MM-DD(使用本地时区,与 PostgreSQL DATE() 一致) */
|
/** 业务时区偏移(东八区,+8 小时) */
|
||||||
function toDateStr(d: Date): string {
|
const BIZ_TZ_OFFSET_MS = 8 * 60 * 60 * 1000;
|
||||||
const y = d.getFullYear();
|
const BIZ_TZ_NAME = 'Asia/Shanghai';
|
||||||
const m = String(d.getMonth() + 1).padStart(2, '0');
|
|
||||||
const day = String(d.getDate()).padStart(2, '0');
|
/** 获取业务时区下的 YYYY-MM-DD */
|
||||||
return `${y}-${m}-${day}`;
|
function toBizDateStr(d: Date): string {
|
||||||
|
const local = new Date(d.getTime() + BIZ_TZ_OFFSET_MS);
|
||||||
|
return local.toISOString().split('T')[0];
|
||||||
|
}
|
||||||
|
|
||||||
|
/** 获取业务时区下"今天 00:00"对应的 UTC 时间 */
|
||||||
|
function getBizDayStartUTC(d: Date): Date {
|
||||||
|
const bizDateStr = toBizDateStr(d);
|
||||||
|
// bizDateStr 00:00 在业务时区 = bizDateStr 00:00 - offset 在 UTC
|
||||||
|
return new Date(`${bizDateStr}T00:00:00+08:00`);
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function GET(request: NextRequest) {
|
export async function GET(request: NextRequest) {
|
||||||
@@ -18,12 +28,8 @@ export async function GET(request: NextRequest) {
|
|||||||
const days = Math.min(365, Math.max(1, Number(searchParams.get('days') || '30')));
|
const days = Math.min(365, Math.max(1, Number(searchParams.get('days') || '30')));
|
||||||
|
|
||||||
const now = new Date();
|
const now = new Date();
|
||||||
const startDate = new Date(now);
|
const todayStart = getBizDayStartUTC(now);
|
||||||
startDate.setDate(startDate.getDate() - days);
|
const startDate = new Date(todayStart.getTime() - days * 24 * 60 * 60 * 1000);
|
||||||
startDate.setHours(0, 0, 0, 0);
|
|
||||||
|
|
||||||
const todayStart = new Date(now);
|
|
||||||
todayStart.setHours(0, 0, 0, 0);
|
|
||||||
|
|
||||||
const paidStatuses: OrderStatus[] = [
|
const paidStatuses: OrderStatus[] = [
|
||||||
OrderStatus.PAID,
|
OrderStatus.PAID,
|
||||||
@@ -52,16 +58,18 @@ export async function GET(request: NextRequest) {
|
|||||||
prisma.order.count({ where: { createdAt: { gte: todayStart } } }),
|
prisma.order.count({ where: { createdAt: { gte: todayStart } } }),
|
||||||
// Total orders
|
// Total orders
|
||||||
prisma.order.count(),
|
prisma.order.count(),
|
||||||
// Daily series (raw query for DATE truncation)
|
// Daily series: use AT TIME ZONE to group by business timezone date
|
||||||
|
// Prisma.raw() inlines the timezone name to avoid parameterization mismatch between SELECT and GROUP BY
|
||||||
prisma.$queryRaw<{ date: string; amount: string; count: bigint }[]>`
|
prisma.$queryRaw<{ date: string; amount: string; count: bigint }[]>`
|
||||||
SELECT DATE(paid_at) as date, SUM(amount)::text as amount, COUNT(*) as count
|
SELECT (paid_at AT TIME ZONE 'UTC' AT TIME ZONE ${Prisma.raw(`'${BIZ_TZ_NAME}'`)})::date::text as date,
|
||||||
|
SUM(amount)::text as amount, COUNT(*) as count
|
||||||
FROM orders
|
FROM orders
|
||||||
WHERE status IN ('PAID', 'RECHARGING', 'COMPLETED', 'REFUNDING', 'REFUNDED', 'REFUND_FAILED')
|
WHERE status IN ('PAID', 'RECHARGING', 'COMPLETED', 'REFUNDING', 'REFUNDED', 'REFUND_FAILED')
|
||||||
AND paid_at >= ${startDate}
|
AND paid_at >= ${startDate}
|
||||||
GROUP BY DATE(paid_at)
|
GROUP BY (paid_at AT TIME ZONE 'UTC' AT TIME ZONE ${Prisma.raw(`'${BIZ_TZ_NAME}'`)})::date
|
||||||
ORDER BY date
|
ORDER BY date
|
||||||
`,
|
`,
|
||||||
// Leaderboard: GROUP BY user_id only, MAX() for name/email to avoid splitting rows on name changes
|
// Leaderboard: GROUP BY user_id only, MAX() for name/email
|
||||||
prisma.$queryRaw<
|
prisma.$queryRaw<
|
||||||
{ user_id: number; user_name: string | null; user_email: string | null; total_amount: string; order_count: bigint }[]
|
{ user_id: number; user_name: string | null; user_email: string | null; total_amount: string; order_count: bigint }[]
|
||||||
>`
|
>`
|
||||||
@@ -83,22 +91,29 @@ export async function GET(request: NextRequest) {
|
|||||||
}),
|
}),
|
||||||
]);
|
]);
|
||||||
|
|
||||||
// Fill missing dates for continuous line chart (use local timezone consistently)
|
// Fill missing dates for continuous line chart
|
||||||
const dailyMap = new Map<string, { amount: number; count: number }>();
|
const dailyMap = new Map<string, { amount: number; count: number }>();
|
||||||
for (const row of dailyRaw) {
|
for (const row of dailyRaw) {
|
||||||
const dateStr = typeof row.date === 'string' ? row.date : toDateStr(new Date(row.date));
|
dailyMap.set(row.date, { amount: Number(row.amount), count: Number(row.count) });
|
||||||
dailyMap.set(dateStr, { amount: Number(row.amount), count: Number(row.count) });
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const dailySeries: { date: string; amount: number; count: number }[] = [];
|
const dailySeries: { date: string; amount: number; count: number }[] = [];
|
||||||
const cursor = new Date(startDate);
|
const cursor = new Date(startDate);
|
||||||
while (cursor <= now) {
|
while (cursor <= now) {
|
||||||
const dateStr = toDateStr(cursor);
|
const dateStr = toBizDateStr(cursor);
|
||||||
const entry = dailyMap.get(dateStr);
|
const entry = dailyMap.get(dateStr);
|
||||||
dailySeries.push({ date: dateStr, amount: entry?.amount ?? 0, count: entry?.count ?? 0 });
|
dailySeries.push({ date: dateStr, amount: entry?.amount ?? 0, count: entry?.count ?? 0 });
|
||||||
cursor.setDate(cursor.getDate() + 1);
|
cursor.setTime(cursor.getTime() + 24 * 60 * 60 * 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Deduplicate: toBizDateStr on consecutive UTC days near midnight can produce the same biz date
|
||||||
|
const seen = new Set<string>();
|
||||||
|
const deduped = dailySeries.filter((d) => {
|
||||||
|
if (seen.has(d.date)) return false;
|
||||||
|
seen.add(d.date);
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
|
||||||
// Calculate summary
|
// Calculate summary
|
||||||
const todayPaidAmount = Number(todayStats._sum?.amount || 0);
|
const todayPaidAmount = Number(todayStats._sum?.amount || 0);
|
||||||
const todayPaidCount = todayStats._count._all;
|
const todayPaidCount = todayStats._count._all;
|
||||||
@@ -117,7 +132,7 @@ export async function GET(request: NextRequest) {
|
|||||||
successRate: Math.round(successRate * 10) / 10,
|
successRate: Math.round(successRate * 10) / 10,
|
||||||
avgAmount: Math.round(avgAmount * 100) / 100,
|
avgAmount: Math.round(avgAmount * 100) / 100,
|
||||||
},
|
},
|
||||||
dailySeries,
|
dailySeries: deduped,
|
||||||
leaderboard: leaderboardRaw.map((row) => ({
|
leaderboard: leaderboardRaw.map((row) => ({
|
||||||
userId: row.user_id,
|
userId: row.user_id,
|
||||||
userName: row.user_name,
|
userName: row.user_name,
|
||||||
|
|||||||
@@ -86,7 +86,7 @@ export default function OrderTable({ orders, onRetry, onCancel, onViewDetail, da
|
|||||||
</span>
|
</span>
|
||||||
</td>
|
</td>
|
||||||
<td className={tdMuted}>
|
<td className={tdMuted}>
|
||||||
{order.paymentType === 'alipay' ? '支付宝' : '微信支付'}
|
{order.paymentType === 'alipay' ? '支付宝' : order.paymentType === 'wechat' ? '微信支付' : order.paymentType === 'stripe' ? 'Stripe' : order.paymentType}
|
||||||
</td>
|
</td>
|
||||||
<td className={tdMuted}>
|
<td className={tdMuted}>
|
||||||
{order.srcHost || '-'}
|
{order.srcHost || '-'}
|
||||||
|
|||||||
Reference in New Issue
Block a user