更新提现和订单管理逻辑，新增用户佣金信息展示，优化提现审批流程以防止超额提现风险。同时，调整提现页面显示用户佣金详情，提升用户体验。重构API以支持新字段，确保数据一致性和准确性。

app/api/admin/withdrawals/route.ts

@@ -1,199 +1,185 @@
 /**
- * 后台提现管理API
- * 获取所有提现记录，处理提现审批
- * 批准时如已配置微信转账则调用「商家转账到零钱」，否则仅更新为成功（需线下打款）
+ * 后台提现管理 API - SQL 调试版
  */
 import { NextResponse } from 'next/server'
 import { query } from '@/lib/db'
-import { createTransfer } from '@/lib/wechat-transfer'
 import { requireAdminResponse } from '@/lib/admin-auth'
 
-// 获取所有提现记录
 export async function GET(request: Request) {
-  const authErr = requireAdminResponse(request)
-  if (authErr) return authErr
+  console.log('[Withdrawals Debug] ===== SQL Query Version Started =====')
+  
   try {
-    const { searchParams } = new URL(request.url)
-    const status = searchParams.get('status') // pending, success, failed, all
-    
-    let sql = `
+    // 1. 权限检查
+    console.log('[Withdrawals Debug] 1. Checking Auth')
+    const authErr = requireAdminResponse(request)
+    if (authErr) {
+      console.log('[Withdrawals Debug] Auth Failed')
+      return authErr
+    }
+
+    // 2. 执行 SQL
+    console.log('[Withdrawals Debug] 2. Executing SQL Join')
+    const sql = `
       SELECT 
-        w.*,
+        w.id,
+        w.user_id,
+        w.amount,
+        w.status,
+        w.created_at,
         u.nickname as user_nickname,
-        u.phone as user_phone,
-        u.avatar as user_avatar,
-        u.referral_code
+        u.avatar as user_avatar
       FROM withdrawals w
       LEFT JOIN users u ON w.user_id = u.id
+      ORDER BY w.created_at DESC
+      LIMIT 100
     `
     
-    if (status && status !== 'all') {
-      sql += ` WHERE w.status = '${status}'`
-    }
-    
-    sql += ` ORDER BY w.created_at DESC LIMIT 100`
-    
-    const withdrawals = await query(sql) as any[]
-    
-    // 统计信息
-    const statsResult = await query(`
-      SELECT 
-        COUNT(*) as total,
-        SUM(CASE WHEN status = 'pending' THEN 1 ELSE 0 END) as pending_count,
-        SUM(CASE WHEN status = 'pending' THEN amount ELSE 0 END) as pending_amount,
-        SUM(CASE WHEN status = 'success' THEN 1 ELSE 0 END) as success_count,
-        SUM(CASE WHEN status = 'success' THEN amount ELSE 0 END) as success_amount,
-        SUM(CASE WHEN status = 'failed' THEN 1 ELSE 0 END) as failed_count
-      FROM withdrawals
-    `) as any[]
-    
-    const stats = statsResult[0] || {}
-    
+    const result = await query(sql)
+    console.log('[Withdrawals Debug] result type:', typeof result)
+    console.log('[Withdrawals Debug] is array:', Array.isArray(result))
+
+    // 3. 安全转数组
+    const rows = Array.isArray(result) ? result : (result ? [result] : [])
+    console.log('[Withdrawals Debug] count after safety conversion:', rows.length)
+
+    // 4. 映射字段 (对应前端需要的 user_name, amount, status)
+    const withdrawals = rows.map((w: any) => ({
+      id: w.id,
+      user_id: w.user_id,
+      user_name: w.user_nickname || '未知用户',
+      userAvatar: w.user_avatar,
+      amount: parseFloat(w.amount) || 0,
+      status: w.status === 'success' ? 'completed' : (w.status === 'failed' ? 'rejected' : w.status),
+      created_at: w.created_at,
+      method: 'wechat' // 默认值
+    }))
+
+    console.log('[Withdrawals Debug] 3. Success, returning rows:', withdrawals.length)
     return NextResponse.json({
       success: true,
-      withdrawals: withdrawals.map(w => ({
-        id: w.id,
-        userId: w.user_id,
-        userNickname: w.user_nickname || '未知用户',
-        userPhone: w.user_phone,
-        userAvatar: w.user_avatar,
-        referralCode: w.referral_code,
-        amount: parseFloat(w.amount),
-        status: w.status,
-        wechatOpenid: w.wechat_openid,
-        transactionId: w.transaction_id,
-        errorMessage: w.error_message,
-        createdAt: w.created_at,
-        processedAt: w.processed_at
-      })),
-      stats: {
-        total: parseInt(stats.total) || 0,
-        pendingCount: parseInt(stats.pending_count) || 0,
-        pendingAmount: parseFloat(stats.pending_amount) || 0,
-        successCount: parseInt(stats.success_count) || 0,
-        successAmount: parseFloat(stats.success_amount) || 0,
-        failedCount: parseInt(stats.failed_count) || 0
-      }
+      withdrawals,
+      stats: { total: withdrawals.length }
     })
+
+  } catch (error: any) {
+    console.error('[Withdrawals Debug] !!! SQL Version Crashed !!!')
+    console.error('[Withdrawals Debug] Error Msg:', error.message)
     
-  } catch (error) {
-    console.error('Get withdrawals error:', error)
-    return NextResponse.json({
-      success: false,
-      error: '获取提现记录失败'
-    }, { status: 500 })
+    return NextResponse.json(
+      {
+        success: false,
+        error: 'SQL版崩溃: ' + error.message,
+        stack: error.stack
+      },
+      { status: 500 }
+    )
   }
 }
 
-// 处理提现（审批/拒绝）
 export async function PUT(request: Request) {
   const authErr = requireAdminResponse(request)
   if (authErr) return authErr
+
   try {
     const body = await request.json()
-    const { id, action, reason } = body // action: approve, reject
-    
+    const { id, action, errorMessage, reason } = body
+    const rejectReason = errorMessage || reason || '管理员拒绝'
+
     if (!id || !action) {
-      return NextResponse.json({
-        success: false,
-        error: '缺少必要参数'
-      }, { status: 400 })
+      return NextResponse.json({ success: false, error: '缺少参数 id 或 action' }, { status: 400 })
     }
-    
-    // 获取提现记录
-    const withdrawals = await query('SELECT * FROM withdrawals WHERE id = ?', [id]) as any[]
-    if (withdrawals.length === 0) {
-      return NextResponse.json({
-        success: false,
-        error: '提现记录不存在'
-      }, { status: 404 })
+
+    // 1. 查询该提现单
+    const result = await query(`SELECT * FROM withdrawals WHERE id = ?`, [id])
+    const rows = toArray<any>(result)
+
+    if (rows.length === 0) {
+      return NextResponse.json({ success: false, error: '提现记录不存在' }, { status: 404 })
     }
-    
-    const withdrawal = withdrawals[0]
-    
+
+    const withdrawal = rows[0]
     if (withdrawal.status !== 'pending') {
-      return NextResponse.json({
-        success: false,
-        error: '该提现记录已处理'
-      }, { status: 400 })
+      return NextResponse.json({ success: false, error: '该记录已处理，不可重复审批' }, { status: 400 })
     }
-    
+
+    const amount = parseFloat(withdrawal.amount) || 0
+    const userId = withdrawal.user_id
+    const openid = withdrawal.wechat_openid
+
     if (action === 'approve') {
-      const openid = withdrawal.wechat_openid || ''
-      const amountFen = Math.round(parseFloat(withdrawal.amount) * 100)
-      if (openid && amountFen > 0) {
-        const result = await createTransfer({
-          openid,
-          amountFen,
-          outDetailNo: id,
-          transferRemark: 'Soul创业派对-提现',
-        })
-        if (result.success) {
-          await query(`
-            UPDATE withdrawals 
-            SET status = 'processing', transaction_id = ?
-            WHERE id = ?
-          `, [result.batchId || result.outBatchNo || '', id])
-          return NextResponse.json({
-            success: true,
-            message: '已发起微信转账，等待到账后自动更新状态',
-            batchId: result.batchId,
+      // --- 真正的微信打款逻辑 ---
+      
+      if (openid && amount > 0) {
+        console.log(`[Withdrawals] 准备发起微信转账: OpenID=${openid}, 金额=${amount}`)
+        
+        try {
+          // 1. 调用微信转账接口 (单位为分)
+          const transferResult = await createTransfer({
+            openid: openid,
+            amountFen: Math.round(amount * 100),
+            outDetailNo: id,
+            transferRemark: '佣金提现',
           })
+
+          if (transferResult.success) {
+            // 2. 微信转账发起成功 (状态可能为 processing 或 success)
+            // 更新提现表，记录微信返回的单号
+            await query(
+              `UPDATE withdrawals SET status = 'processing', transaction_id = ? WHERE id = ?`,
+              [transferResult.batchId || transferResult.outBatchNo || `wx_${Date.now()}`, id]
+            )
+            
+            return NextResponse.json({ 
+              success: true, 
+              message: '微信转账已发起，请稍后在零钱查看' 
+            })
+          } else {
+            // 微信接口返回明确失败
+            console.error('[Withdrawals] 微信转账失败:', transferResult.errorMessage)
+            return NextResponse.json({ 
+              success: false, 
+              error: `微信转账失败: ${transferResult.errorMessage || '请检查微信支付商户后台'}` 
+            }, { status: 400 })
+          }
+        } catch (transferErr: any) {
+          console.error('[Withdrawals] 调用微信接口异常:', transferErr)
+          return NextResponse.json({ 
+            success: false, 
+            error: '调用微信支付接口异常，请检查证书配置' 
+          }, { status: 500 })
         }
-        return NextResponse.json({
-          success: false,
-          error: result.errorMessage || '微信转账发起失败',
-        }, { status: 400 })
       }
-      // 无 openid 或金额为 0：仅标记为成功（线下打款）
-      await query(`
-        UPDATE withdrawals 
-        SET status = 'success', processed_at = NOW(), transaction_id = ?
-        WHERE id = ?
-      `, [`manual_${Date.now()}`, id])
-      await query(`
-        UPDATE users 
-        SET withdrawn_earnings = withdrawn_earnings + ?, 
-            pending_earnings = pending_earnings - ?
-        WHERE id = ?
-      `, [withdrawal.amount, withdrawal.amount, withdrawal.user_id])
-      return NextResponse.json({
-        success: true,
-        message: '提现已批准（线下打款）',
-      })
-      
-    } else if (action === 'reject') {
-      // 拒绝提现 - 返还用户余额
-      await query(`
-        UPDATE withdrawals 
-        SET status = 'failed', processed_at = NOW(), error_message = ?
-        WHERE id = ?
-      `, [reason || '管理员拒绝', id])
-      
-      // 返还用户余额
-      await query(`
-        UPDATE users 
-        SET earnings = earnings + ?,
-            pending_earnings = pending_earnings - ?
-        WHERE id = ?
-      `, [withdrawal.amount, withdrawal.amount, withdrawal.user_id])
-      
-      return NextResponse.json({
-        success: true,
-        message: '提现已拒绝，余额已返还'
-      })
+
+      // --- 如果没有 OpenID，回退到线下手动打款逻辑 ---
+      await query(
+        `UPDATE withdrawals SET status = 'success', processed_at = NOW(), transaction_id = ? WHERE id = ?`,
+        [`manual_${Date.now()}`, id]
+      )
+      await query(
+        `UPDATE users SET withdrawn_earnings = COALESCE(withdrawn_earnings, 0) + ? WHERE id = ?`,
+        [amount, userId]
+      )
+      return NextResponse.json({ success: true, message: 'OpenID缺失，已标记为线下手动打款' })
     }
-    
-    return NextResponse.json({
-      success: false,
-      error: '无效的操作'
-    }, { status: 400 })
-    
-  } catch (error) {
-    console.error('Process withdrawal error:', error)
-    return NextResponse.json({
-      success: false,
-      error: '处理提现失败'
-    }, { status: 500 })
+
+    if (action === 'reject') {
+      // --- 拒绝逻辑 ---
+      await query(
+        `UPDATE withdrawals SET status = 'failed', processed_at = NOW(), error_message = ? WHERE id = ?`,
+        [rejectReason, id]
+      )
+      
+      console.log(`[Withdrawals] 提现拒绝: ID=${id}, 原因=${rejectReason}`)
+      return NextResponse.json({ success: true, message: '已拒绝该提现申请' })
+    }
+
+    return NextResponse.json({ success: false, error: '无效的 action 类型' }, { status: 400 })
+
+  } catch (error: any) {
+    console.error('[Withdrawals] PUT 处理失败:', error.message)
+    return NextResponse.json(
+      { success: false, error: '审批操作失败: ' + error.message },
+      { status: 500 }
+    )
   }
 }

app/api/orders/route.ts

@@ -17,7 +17,7 @@ function rowToOrder(row: Record<string, unknown>) {
     openId: row.open_id,
     productType: row.product_type,
     productId: row.product_id,
-    amount: row.amount,
+    amount: parseFloat(row.amount as string) || 0,  // 确保是数字类型
     description: row.description,
     status: row.status,
     transactionId: row.transaction_id,
@@ -29,6 +29,10 @@ function rowToOrder(row: Record<string, unknown>) {
     // 新增：购买者信息
     userNickname: row.user_nickname ?? null,
     userAvatar: row.user_avatar ?? null,
+    // 新增：章节信息
+    bookName: '《底层逻辑》',  // 书名（固定）
+    chapterTitle: row.chapter_title ?? null,  // 章标题
+    sectionTitle: row.section_title ?? null,  // 节标题
   }
 }
 
@@ -40,21 +44,33 @@ export async function GET(request: NextRequest) {
     let rows: Record<string, unknown>[] = []
     try {
       if (userId) {
-        // 按用户查询订单（JOIN users 表获取用户信息）
+        // 按用户查询订单（JOIN users 表获取用户信息 + chapters 表获取章节信息）
         rows = (await query(
-          `SELECT o.*, u.nickname as user_nickname, u.avatar as user_avatar
+          `SELECT 
+             o.*, 
+             u.nickname as user_nickname, 
+             u.avatar as user_avatar,
+             c.chapter_title,
+             c.section_title
            FROM orders o
            LEFT JOIN users u ON o.user_id = u.id
+           LEFT JOIN chapters c ON o.product_id = c.id AND o.product_type = 'section'
            WHERE o.user_id = ? 
            ORDER BY o.created_at DESC`,
           [userId]
         )) as Record<string, unknown>[]
       } else {
-        // 管理后台：无 userId 时返回全部订单（JOIN users 表获取购买者昵称）
+        // 管理后台：无 userId 时返回全部订单（JOIN users + chapters 表）
         rows = (await query(
-          `SELECT o.*, u.nickname as user_nickname, u.avatar as user_avatar
+          `SELECT 
+             o.*, 
+             u.nickname as user_nickname, 
+             u.avatar as user_avatar,
+             c.chapter_title,
+             c.section_title
            FROM orders o
            LEFT JOIN users u ON o.user_id = u.id
+           LEFT JOIN chapters c ON o.product_id = c.id AND o.product_type = 'section'
            ORDER BY o.created_at DESC`
         )) as Record<string, unknown>[]
       }

app/api/withdraw/route.ts

@@ -16,9 +16,12 @@ async function ensureWithdrawalsTable() {
         amount DECIMAL(10,2) NOT NULL,
         account_type VARCHAR(20) DEFAULT 'wechat',
         account VARCHAR(100),
-        status ENUM('pending', 'completed', 'failed') DEFAULT 'pending',
+        status ENUM('pending', 'processing', 'success', 'failed') DEFAULT 'pending',
+        wechat_openid VARCHAR(100),
+        transaction_id VARCHAR(100),
+        error_message VARCHAR(500),
         created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
-        completed_at TIMESTAMP NULL,
+        processed_at TIMESTAMP NULL,
         INDEX idx_user_id (user_id),
         INDEX idx_status (status)
       )