打手列表新增VIP等级筛选

apps/backend/src/repositories/worker-platform/types.ts

@@ -420,6 +420,8 @@ export type ListInput = {
   workerType?: string
   /** 后台打手列表按主键精确定位。 */
   workerId?: number
+  /** 后台打手列表按 VIP 等级筛选。 */
+  levelId?: number
   /** 后台待验收筛选：普通单按接单人，拼单按参与打手等级。 */
   workerLevelIds?: number[]
   categoryId?: number

apps/backend/src/repositories/worker-platform/worker-repo.ts

@@ -236,8 +236,15 @@ export async function listWorkerUsers({
   keyword = '',
   workerType = '',
   workerId = 0,
+  levelId = 0,
 }: ListInput = {}): Promise<{ items: WorkerUserRow[]; total: number }> {
-  const { whereClause, params } = buildWorkerUserWhere({ status, keyword, workerType, workerId })
+  const { whereClause, params } = buildWorkerUserWhere({
+    status,
+    keyword,
+    workerType,
+    workerId,
+    levelId,
+  })
   const totalResult = await query<{ total: number }>(
     `SELECT COUNT(*)::int AS total FROM worker_users wu ${whereClause}`,
     params,
@@ -299,7 +306,8 @@ function buildWorkerUserWhere({
   keyword = '',
   workerType = '',
   workerId = 0,
-}: Pick<ListInput, 'status' | 'keyword' | 'workerType' | 'workerId'>) {
+  levelId = 0,
+}: Pick<ListInput, 'status' | 'keyword' | 'workerType' | 'workerId' | 'levelId'>) {
   const filters: string[] = []
   const params: unknown[] = []
   if (status) {
@@ -320,6 +328,10 @@ function buildWorkerUserWhere({
     params.push(workerId)
     filters.push(`wu.id = $${params.length}`)
   }
+  if (levelId) {
+    params.push(levelId)
+    filters.push(`wu.level_id = $${params.length}`)
+  }
   return {
     whereClause: filters.length > 0 ? `WHERE ${filters.join(' AND ')}` : '',
     params,

apps/backend/src/services/worker-platform/admin-worker-user-service.ts

@@ -27,10 +27,12 @@ export async function listAdminWorkerUsers(query: JsonObject = {}) {
   const page = normalizePage(query.page)
   const pageSize = normalizePageSize(query.pageSize)
   const workerId = normalizeOptionalId(query.workerId ?? query.worker_id) || 0
+  const levelId = normalizeOptionalId(query.levelId ?? query.level_id) || 0
   const { items, total } = await listWorkerUsers({
     page,
     pageSize,
     workerId,
+    levelId,
     status: String(query.status || '').trim(),
     keyword: String(query.keyword || '').trim(),
     workerType: String(query.workerType || query.worker_type || '').trim(),