update dependencies and add notification events setting

.env.development.example

@@ -1,3 +1,5 @@
 CLOUDFLARE_ACCOUNT_ID=
 CLOUDFLARE_DATABASE_ID=
-CLOUDFLARE_TOKEN=
+CLOUDFLARE_TOKEN=
+# 本地开发时取消下面的注释
+# CLOUDFLARE_ENV=development

app/api/settings/account/route.ts

@@ -1,69 +1,38 @@
-/**
- * 账户设置 API 路由
- *
- * 该模块提供用户账户设置的获取和更新功能，包括：
- * - 时区设置
- * - 通知时间设置（每天哪些小时发送通知）
- *
- * @module api/settings/account
- */
-
 import { NextRequest, NextResponse } from "next/server";
 import { getDb } from "@/db";
 import { userSettings } from "@/db/schema";
 import { requireApiAuth } from "@/lib/session";
 import { eq } from "drizzle-orm";
 import { z } from "zod";
 
-/**
- * 更新设置的验证模式
- *
- * - timezone: 用户所在时区，非空字符串
- * - notifyHours: 通知小时数组，值为 0-23 的整数，至少包含一个值
- */
 const updateSchema = z.object({
   timezone: z.string().min(1).optional(),
   notifyHours: z.array(z.number().int().min(0).max(23)).min(1).optional(),
   notifyDeliveryMode: z.enum(["every_slot", "once_per_day"]).optional(),
 });
 
-/**
- * GET /api/settings/account
- *
- * 获取当前用户的账户设置
- *
- * @returns {Promise<NextResponse>} 返回包含以下字段的 JSON 响应：
- *   - timezone: 用户时区（默认 "UTC"）
- *   - notifyHours: 通知小时数组（默认 [0]）
- *
- * @throws {Error} 如果用户未认证, 会抛出错误
- *
- * @example
- * // 响应示例
- * { "timezone": "Asia/Shanghai", "notifyHours": [9, 18] }
- */
 export async function GET() {
-  // 验证用户身份
   const session = await requireApiAuth();
   const db = await getDb();
 
-  // 查询用户的设置记录
   const [settings] = await db
     .select()
     .from(userSettings)
     .where(eq(userSettings.userId, session.userId))
     .limit(1);
 
-  // 如果用户没有设置记录，返回默认值
   if (!settings) {
-    return NextResponse.json({ timezone: "UTC", notifyHours: [0], notifyDeliveryMode: "every_slot" });
+    return NextResponse.json({
+      timezone: "UTC",
+      notifyHours: [0],
+      notifyDeliveryMode: "every_slot",
+    });
   }
 
-  // 解析通知小时 JSON 字符串
   let notifyHours: number[] = [0];
   try {
     notifyHours = JSON.parse(settings.notifyHoursJson) as number[];
-  } catch { /* 解析失败时使用默认值 */ }
+  } catch {}
 
   return NextResponse.json({
     timezone: settings.timezone,
@@ -72,58 +41,31 @@ export async function GET() {
   });
 }
 
-/**
- * PUT /api/settings/account
- *
- * 更新当前用户的账户设置
- *
- * @param {NextRequest} request - 请求对象，包含 JSON 格式的设置数据
- * @returns {Promise<NextResponse>} 返回更新结果：
- *   - 成功: { success: true }
- *   - 验证失败: { error: ZodError } (状态码 400)
- *
- * @throws {Error} 如果用户未认证, 会抛出错误
- *
- * @example
- * // 请求体示例
- * { "timezone": "Asia/Shanghai", "notifyHours": [9, 12, 18] }
- *
- * // 成功响应
- * { "success": true }
- */
 export async function PUT(request: NextRequest) {
-  // 验证用户身份
   const session = await requireApiAuth();
   const db = await getDb();
 
-  // 解析并验证请求体
   const body = await request.json() as unknown;
   const parsed = updateSchema.safeParse(body);
 
-  // 验证失败时返回错误详情
   if (!parsed.success) {
     return NextResponse.json({ error: parsed.error.flatten() }, { status: 400 });
   }
 
-  // 检查用户是否已有设置记录
   const [existing] = await db
     .select({ id: userSettings.id })
     .from(userSettings)
     .where(eq(userSettings.userId, session.userId))
     .limit(1);
 
-  // 构建更新值对象
   const values: Record<string, unknown> = { updatedAt: new Date() };
   if (parsed.data.timezone) values.timezone = parsed.data.timezone;
   if (parsed.data.notifyHours) values.notifyHoursJson = JSON.stringify(parsed.data.notifyHours);
   if (parsed.data.notifyDeliveryMode) values.notifyDeliveryMode = parsed.data.notifyDeliveryMode;
 
-  // 根据是否存在记录执行更新或插入操作
   if (existing) {
-    // 更新现有记录
     await db.update(userSettings).set(values).where(eq(userSettings.userId, session.userId));
   } else {
-    // 创建新记录，使用传入值或默认值
     await db.insert(userSettings).values({
       userId: session.userId,
       ...values,

app/api/settings/notification-events/route.ts

@@ -0,0 +1,73 @@
+import { NextRequest, NextResponse } from "next/server";
+import { and, desc, eq, inArray, lt } from "drizzle-orm";
+import { getDb } from "@/db";
+import { notificationChannels, notificationEvents, subscriptions } from "@/db/schema";
+import { requireApiAuth } from "@/lib/session";
+import { z } from "zod";
+
+const cleanupSchema = z.object({
+  months: z.number().int().min(1),
+});
+
+export async function GET() {
+  const session = await requireApiAuth();
+  const db = await getDb();
+
+  const items = await db
+    .select({
+      id: notificationEvents.id,
+      createdAt: notificationEvents.createdAt,
+      sentAt: notificationEvents.sentAt,
+      subscriptionName: subscriptions.name,
+      channelName: notificationChannels.name,
+      status: notificationEvents.status,
+      offsetDays: notificationEvents.offsetDays,
+      error: notificationEvents.error,
+    })
+    .from(notificationEvents)
+    .innerJoin(subscriptions, eq(notificationEvents.subscriptionId, subscriptions.id))
+    .innerJoin(notificationChannels, eq(notificationEvents.channelId, notificationChannels.id))
+    .where(eq(subscriptions.userId, session.userId))
+    .orderBy(desc(notificationEvents.createdAt))
+    .limit(50);
+
+  return NextResponse.json({ items });
+}
+
+export async function DELETE(request: NextRequest) {
+  const session = await requireApiAuth();
+  const db = await getDb();
+
+  const body = await request.json() as unknown;
+  const parsed = cleanupSchema.safeParse(body);
+
+  if (!parsed.success) {
+    return NextResponse.json({ error: parsed.error.flatten() }, { status: 400 });
+  }
+
+  const cutoff = new Date();
+  cutoff.setMonth(cutoff.getMonth() - parsed.data.months);
+
+  const ids = await db
+    .select({ id: notificationEvents.id })
+    .from(notificationEvents)
+    .innerJoin(subscriptions, eq(notificationEvents.subscriptionId, subscriptions.id))
+    .where(eq(subscriptions.userId, session.userId));
+
+  const deletableIds = ids.map((item) => item.id);
+  if (deletableIds.length === 0) {
+    return NextResponse.json({ success: true, deletedCount: 0 });
+  }
+
+  const deleted = await db
+    .delete(notificationEvents)
+    .where(
+      and(
+        inArray(notificationEvents.id, deletableIds),
+        lt(notificationEvents.createdAt, cutoff)
+      )
+    )
+    .returning({ id: notificationEvents.id });
+
+  return NextResponse.json({ success: true, deletedCount: deleted.length });
+}

components/dashboard-client.tsx

@@ -375,7 +375,7 @@ export default function DashboardClient({ initialData, initialExchangeRates }: D
                 >
                   <XAxis type="number" tick={{ fontSize: 11 }} tickFormatter={(v: number) => `${sym}${v.toFixed(0)}`} />
                   <YAxis type="category" dataKey="category" tick={{ fontSize: 11 }} width={52} />
-                  <Tooltip formatter={(v: number) => [`${sym}${v.toFixed(2)}`, "支出"]} />
+                  <Tooltip formatter={(value) => [typeof value === "number" ? `${sym}${value.toFixed(2)}` : `${sym}${value ?? ""}`, "支出"]} />
                   <Bar dataKey="value" radius={[0, 4, 4, 0]}>
                     {categoryChartData.map((_, i) => (
                       <Cell key={i} fill={CATEGORY_COLORS[i % CATEGORY_COLORS.length]} />