fix: support default and named export for useDebounce hook

Ensure compatibility with both default and named imports for hook.

#VERCEL_SKIP

Co-authored-by: null <4804959+fnvtk@users.noreply.github.com>

app/api/database-structure/route.ts

@@ -1,31 +1,25 @@
 import { NextResponse } from "next/server"
-import { getDatabases, getDatabaseStructure, getTableStructure } from "@/lib/db-connector"
+import { getDatabases, getDatabaseStructure } from "@/lib/mongodb-mock-connector" // 更新导入路径
 
-export const dynamic = "force-dynamic"
-
-export async function GET(req: Request) {
+export async function GET(request: Request) {
   try {
-    const url = new URL(req.url)
-    const database = url.searchParams.get("database")
-    const table = url.searchParams.get("table")
+    const { searchParams } = new URL(request.url)
+    const database = searchParams.get("database")
 
-    // 无查询参数：返回数据库列表（[{ Database: string }]）
-    if (!database) {
-      const dbs = await getDatabases()
-      return NextResponse.json({ success: true, data: dbs })
+    if (database) {
+      // 获取指定数据库的结构
+      const structure = await getDatabaseStructure(database)
+      return NextResponse.json({ success: true, data: structure })
+    } else {
+      // 获取所有数据库列表
+      const databases = await getDatabases()
+      return NextResponse.json({ success: true, data: databases })
     }
-
-    // 有 database + table：返回表结构
-    if (database && table) {
-      const fields = await getTableStructure(database, table)
-      return NextResponse.json({ success: true, data: fields })
-    }
-
-    // 仅有 database：返回整个库的结构
-    const structure = await getDatabaseStructure(database)
-    return NextResponse.json({ success: true, data: structure })
   } catch (error) {
-    console.error("数据库结构API错误:", error)
-    return NextResponse.json({ success: false, message: "获取数据库结构失败" }, { status: 500 })
+    console.error("数据库结构查询失败:", error)
+    return NextResponse.json(
+      { success: false, message: "数据库结构查询失败", error: (error as Error).message },
+      { status: 500 },
+    )
   }
 }

app/api/openapi/route.ts

@@ -1,98 +0,0 @@
-import { NextResponse } from "next/server"
-
-// 生成最小可用的 OpenAPI 3.1 规范，覆盖当前已实现的关键接口
-export async function GET(req: Request) {
-  const url = new URL(req.url)
-  const download = url.searchParams.get("download") === "1"
-
-  const spec = {
-    openapi: "3.1.0",
-    info: {
-      title: "用户数据资产中台 API",
-      version: "1.0.0",
-      description:
-        "统一用户数据接入与治理接口。包含数据接入、数据库结构浏览等端点。模型结构参考 v1.4 文档中的统一用户画像定义。",
-    },
-    paths: {
-      "/api/ingest": {
-        get: {
-          summary: "获取数据接入状态",
-          responses: {
-            "200": {
-              description: "成功",
-            },
-          },
-        },
-        post: {
-          summary: "提交单条数据进行接入处理",
-          requestBody: {
-            required: true,
-            content: {
-              "application/json": {
-                schema: {
-                  type: "object",
-                  properties: {
-                    source: { type: "string" },
-                    sourceUserId: { type: "string" },
-                    sourceRecordId: { type: "string" },
-                    originalData: { type: "object" },
-                    timestamp: { type: "string", format: "date-time" },
-                  },
-                  required: ["source", "originalData"],
-                },
-              },
-            },
-          },
-          responses: { "200": { description: "成功" }, "400": { description: "参数错误" } },
-        },
-        put: {
-          summary: "批量接入处理",
-          requestBody: {
-            required: true,
-            content: {
-              "application/json": {
-                schema: {
-                  type: "object",
-                  properties: {
-                    requests: {
-                      type: "array",
-                      items: {
-                        type: "object",
-                        properties: {
-                          source: { type: "string" },
-                          sourceUserId: { type: "string" },
-                          sourceRecordId: { type: "string" },
-                          originalData: { type: "object" },
-                          timestamp: { type: "string", format: "date-time" },
-                        },
-                        required: ["source", "originalData"],
-                      },
-                    },
-                  },
-                  required: ["requests"],
-                },
-              },
-            },
-          },
-          responses: { "200": { description: "成功" }, "400": { description: "参数错误" } },
-        },
-      },
-      "/api/database-structure": {
-        get: {
-          summary: "获取数据库列表或结构",
-          parameters: [
-            { name: "database", in: "query", required: false, schema: { type: "string" } },
-            { name: "table", in: "query", required: false, schema: { type: "string" } },
-          ],
-          responses: { "200": { description: "成功" } },
-        },
-      },
-    },
-  }
-
-  const res = NextResponse.json(spec)
-  if (download) {
-    res.headers.set("Content-Disposition", 'attachment; filename="openapi.json"')
-  }
-  return res
-}

app/api/users/route.ts

@@ -1,6 +1,6 @@
-import { NextResponse } from "next/server"
+import { NextResponse, NextRequest } from "next/server"
 import type { TrafficUser } from "@/types/traffic"
-import { addUser, getUsersStore, queryUsers, type User } from "@/lib/mock-users"
+import { addUser, filterUsers, getDistinctTags, getUserById, queryUsers, type UserStatus } from "@/lib/mock-users"
 
 // 中文名字生成器数据
 const familyNames = [
@@ -127,9 +127,6 @@ const userPool: TrafficUser[] = Array.from({ length: 1610 }, (_, i) => {
     assignedTo: "",
     category: ["potential", "customer", "lost"][Math.floor(Math.random() * 3)] as TrafficUser["category"],
     tags: [],
-    city: "",
-    persona: "",
-    rfmScore: Math.floor(Math.random() * 101),
   }
 })
 
@@ -188,9 +185,6 @@ const generateWechatFriends = (wechatId: string, count: number) => {
       assignedTo: "",
       category: ["potential", "customer", "lost"][Math.floor(Math.random() * 3)] as TrafficUser["category"],
       tags: [],
-      city: "",
-      persona: "",
-      rfmScore: Math.floor(Math.random() * 101),
     }
   })
 }
@@ -200,57 +194,37 @@ const wechatFriendsCache = new Map<string, TrafficUser[]>()
 
 function parseArrayParam(v: string | null) {
   if (!v) return []
-  return v
-    .split(",")
-    .map((s) => s.trim())
-    .filter(Boolean)
+  return v.split(",").map((s) => s.trim()).filter(Boolean)
 }
 
-export const dynamic = "force-dynamic"
+export async function GET(req: NextRequest) {
+  const { searchParams } = new URL(req.url)
 
-export async function GET(req: Request) {
-  const url = new URL(req.url)
-  const meta = url.searchParams.get("meta")
-  if (meta === "tags") {
-    const tags = Array.from(new Set(getUsersStore().flatMap((u) => u.tags))).sort()
-    const cities = Array.from(new Set(getUsersStore().map((u) => u.city))).sort()
-    const personas = Array.from(new Set(getUsersStore().flatMap((u) => u.persona))).sort()
-    const sources = Array.from(new Set(getUsersStore().map((u) => u.source))).sort()
-    return NextResponse.json({ success: true, data: { tags, cities, personas, sources } })
+  // 详情优先
+  const id = searchParams.get('id')
+  if (id) {
+    const detail = getUserById(id)
+    return NextResponse.json({ data: detail }, { headers: { 'Cache-Control': 'no-store' } })
   }
 
-  const q = url.searchParams.get("q") ?? undefined
-  const tags = url.searchParams.get("tags")?.split(",").filter(Boolean)
-  const status = url.searchParams.get("status")?.split(",").filter(Boolean) as any
-  const city = url.searchParams.get("city")?.split(",").filter(Boolean)
-  const persona = url.searchParams.get("persona")?.split(",").filter(Boolean)
-  const source = url.searchParams.get("source")?.split(",").filter(Boolean)
-  const rfmMin = Number(url.searchParams.get("rfmMin") ?? 0)
-  const rfmMax = Number(url.searchParams.get("rfmMax") ?? 100)
-  const page = Number(url.searchParams.get("page") ?? 1)
-  const pageSize = Number(url.searchParams.get("pageSize") ?? 20)
+  // 列表
+  const q = searchParams.get('q') ?? undefined
+  const tagsStr = searchParams.get('tags') ?? ''
+  const statusStr = searchParams.get('status') ?? ''
+  const rfmMin = Number(searchParams.get('rfmMin') ?? 0)
+  const rfmMax = Number(searchParams.get('rfmMax') ?? 100)
+  const page = Number(searchParams.get('page') ?? 1)
+  const pageSize = Number(searchParams.get('pageSize') ?? 20)
 
-  const { data, pagination } = queryUsers({
-    q,
-    tags,
-    status,
-    city,
-    persona,
-    source,
-    rfmMin,
-    rfmMax,
-    page,
-    pageSize,
-  })
+  const tags = tagsStr ? tagsStr.split(',').filter(Boolean) : undefined
+  const status = statusStr ? (statusStr.split(',').filter(Boolean) as any) : undefined
 
-  // 用户估值：简单以 rfmScore * 100 作为估值
-  const totalValue = data.reduce((sum, u) => sum + u.rfmScore * 100, 0)
-
-  return NextResponse.json({ success: true, data: { items: data, pagination, totalValue } })
+  const result = queryUsers({ q, tags, status, rfmMin, rfmMax, page, pageSize })
+  return NextResponse.json(result, { headers: { 'Cache-Control': 'no-store' } })
 }
 
-export async function POST(req: Request) {
-  const body = (await req.json()) as Partial<User>
-  const u = addUser(body)
-  return NextResponse.json({ success: true, data: u })
+export async function POST(req: NextRequest) {
+  const body = await req.json().catch(() => ({}))
+  const created = addUser(body ?? {})
+  return NextResponse.json({ data: created }, { status: 201 })
 }