fnvtk/soul-yongping
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 分销规则完善 + 微信支付修复

Browse Source 
1. 分销规则：
   - 链接带ID绑定推荐关系
   - 一级分销 + 30天有效期
   - 客户抢夺机制（过期可被抢走）
   - 90%收益归分发者

2. 新增统计数据：
   - 绑定用户数
   - 链接进入人数
   - 带来付款人数

3. 微信支付：
   - 添加点击反馈
   - 优化支付流程日志
   - 改善错误提示

4. 分销中心UI优化
This commit is contained in:
卡若
2026-01-29 09:47:04 +08:00
parent 612b23c6c0
commit 6989ade3e2
8 changed files with 598 additions and 184 deletions
Download Patch File Download Diff File Expand all files Collapse all files

136
app/api/miniprogram/pay/notify/route.ts
View File

@@ -1,10 +1,15 @@
/**
* 小程序支付回调通知处理
* 微信支付成功后会调用此接口
*
* 分销规则：
* - 约90%给分发者（可在system_config配置）
* - 一级分销，只算直接推荐人
*/
import { NextResponse } from 'next/server'
import crypto from 'crypto'
import { query, getConfig } from '@/lib/db'
const WECHAT_PAY_CONFIG = {
appId: 'wxb8bbb2b10dec74aa',
@@ -12,6 +17,9 @@ const WECHAT_PAY_CONFIG = {
mchKey: 'wx3e31b068be59ddc131b068be59ddc2',
}
// 默认分成比例（90%给推广者）
const DEFAULT_DISTRIBUTOR_SHARE = 0.9
// 生成签名
function generateSign(params: Record<string, string>, key: string): string {
const sortedKeys = Object.keys(params).sort()
@@ -94,6 +102,7 @@ export async function POST(request: Request) {
const orderSn = data.out_trade_no
const transactionId = data.transaction_id
const totalFee = parseInt(data.total_fee || '0', 10)
const totalAmount = totalFee / 100 // 转为元
const openId = data.openid
console.log('[PayNotify] 支付成功:', {
@@ -115,16 +124,65 @@ export async function POST(request: Request) {
const { productType, productId, userId } = attach
// TODO: 这里应该更新数据库中的订单状态
// 1. 更新订单状态为已支付
// 2. 如果是章节购买，将章节添加到用户已购列表
// 3. 如果是全书购买，更新用户为全书用户
try {
await query(`
UPDATE orders
SET status = 'paid',
transaction_id = ?,
pay_time = CURRENT_TIMESTAMP
WHERE order_sn = ? AND status = 'pending'
`, [transactionId, orderSn])
console.log('[PayNotify] 订单状态已更新:', orderSn)
} catch (e) {
console.error('[PayNotify] 更新订单状态失败:', e)
}
// 2. 获取用户信息
let buyerUserId = userId
if (!buyerUserId && openId) {
try {
const users = await query('SELECT id FROM users WHERE open_id = ?', [openId]) as any[]
if (users.length > 0) {
buyerUserId = users[0].id
}
} catch (e) {
console.error('[PayNotify] 获取用户信息失败:', e)
}
}
// 3. 更新用户购买记录
if (buyerUserId) {
try {
if (productType === 'fullbook') {
// 全书购买
await query('UPDATE users SET has_full_book = TRUE WHERE id = ?', [buyerUserId])
console.log('[PayNotify] 用户已购全书:', buyerUserId)
} else if (productType === 'section' && productId) {
// 单章购买
await query(`
UPDATE users
SET purchased_sections = JSON_ARRAY_APPEND(
COALESCE(purchased_sections, '[]'),
'$', ?
)
WHERE id = ? AND NOT JSON_CONTAINS(COALESCE(purchased_sections, '[]'), ?)
`, [productId, buyerUserId, JSON.stringify(productId)])
console.log('[PayNotify] 用户已购章节:', buyerUserId, productId)
}
} catch (e) {
console.error('[PayNotify] 更新用户购买记录失败:', e)
}
// 4. 处理分销佣金（90%给推广者）
await processReferralCommission(buyerUserId, totalAmount, orderSn)
}
console.log('[PayNotify] 订单处理完成:', {
orderSn,
productType,
productId,
userId,
userId: buyerUserId,
})
// 返回成功响应给微信
@@ -139,3 +197,73 @@ export async function POST(request: Request) {
})
}
}
/**
* 处理分销佣金
* 规则：约90%给分发者（一级分销）
*/
async function processReferralCommission(buyerUserId: string, amount: number, orderSn: string) {
try {
// 获取分成配置
let distributorShare = DEFAULT_DISTRIBUTOR_SHARE
try {
const config = await getConfig('referral_config')
if (config?.distributorShare) {
distributorShare = config.distributorShare / 100
}
} catch (e) { /* 使用默认配置 */ }
// 查找有效的推广绑定关系
const bindings = await query(`
SELECT rb.id, rb.referrer_id, rb.referee_id, rb.expiry_date, rb.status
FROM referral_bindings rb
WHERE rb.referee_id = ?
AND rb.status = 'active'
AND rb.expiry_date > NOW()
ORDER BY rb.binding_date DESC
LIMIT 1
`, [buyerUserId]) as any[]
if (bindings.length === 0) {
console.log('[PayNotify] 用户无有效推广绑定，跳过分佣:', buyerUserId)
return
}
const binding = bindings[0]
const referrerId = binding.referrer_id
// 计算佣金（90%）
const commission = Math.round(amount * distributorShare * 100) / 100
console.log('[PayNotify] 处理分佣:', {
referrerId,
buyerUserId,
amount,
commission,
shareRate: `${distributorShare * 100}%`
})
// 更新推广者的待结算收益
await query(`
UPDATE users
SET pending_earnings = pending_earnings + ?
WHERE id = ?
`, [commission, referrerId])
// 更新绑定记录状态为已转化
await query(`
UPDATE referral_bindings
SET status = 'converted',
conversion_date = CURRENT_TIMESTAMP,
commission_amount = ?,
order_id = (SELECT id FROM orders WHERE order_sn = ? LIMIT 1)
WHERE id = ?
`, [commission, orderSn, binding.id])
console.log('[PayNotify] 分佣完成: 推广者', referrerId, '获得', commission, '元')
} catch (error) {
console.error('[PayNotify] 处理分佣失败:', error)
// 分佣失败不影响主流程
}
}

148
app/api/referral/bind/route.ts
View File

@@ -1,18 +1,27 @@
/**
* 推荐码绑定API
* 用于处理分享带来的推荐关系绑定
* 推荐码绑定API - 增强版
*
* 核心规则：
* 1. 链接带ID：谁发的链接，进的人就绑谁
* 2. 一级、一月：只有一级分销；绑定有效期一个月
* 3. 长期不发：别人发得多，客户会被「抢走」
* 4. 每天发：持续发的人绑定一直有效，收益越来越高
* 5. 约90%给分发：谁发得多谁拿得多
*/
import { NextRequest, NextResponse } from 'next/server'
import { query } from '@/lib/db'
import { query, getConfig } from '@/lib/db'
// 绑定有效期（天）
const BINDING_DAYS = 30
/**
* POST - 绑定推荐关系
* POST - 绑定推荐关系（支持抢夺机制）
*/
export async function POST(request: NextRequest) {
try {
const body = await request.json()
const { userId, referralCode, openId } = body
const { userId, referralCode, openId, source } = body
// 验证参数
const effectiveUserId = userId || (openId ? `user_${openId.slice(-8)}` : null)
@@ -46,7 +55,7 @@ export async function POST(request: NextRequest) {
}, { status: 400 })
}
// 检查用户是否已有推荐人
// 检查用户是否存在
const users = await query(
'SELECT id, referred_by FROM users WHERE id = ? OR open_id = ?',
[effectiveUserId, openId || effectiveUserId]
@@ -60,46 +69,119 @@ export async function POST(request: NextRequest) {
}
const user = users[0]
const now = new Date()
if (user.referred_by) {
return NextResponse.json({
success: false,
error: '已绑定其他推荐人'
}, { status: 400 })
// 检查现有绑定关系
const existingBindings = await query(`
SELECT id, referrer_id, expiry_date, status
FROM referral_bindings
WHERE referee_id = ? AND status = 'active'
ORDER BY binding_date DESC LIMIT 1
`, [user.id]) as any[]
let action = 'new' // new=新绑定, renew=续期, takeover=抢夺
let oldReferrerId = null
if (existingBindings.length > 0) {
const existing = existingBindings[0]
const expiryDate = new Date(existing.expiry_date)
// 同一个推荐人 - 续期
if (existing.referrer_id === referrer.id) {
action = 'renew'
}
// 不同推荐人 - 检查是否可以抢夺
else if (expiryDate < now) {
// 已过期，可以被抢夺
action = 'takeover'
oldReferrerId = existing.referrer_id
// 将旧绑定标记为过期
await query(
"UPDATE referral_bindings SET status = 'expired' WHERE id = ?",
[existing.id]
)
} else {
// 未过期，不能被抢夺
return NextResponse.json({
success: false,
error: '用户已绑定其他推荐人，绑定有效期内无法更换',
expiryDate: expiryDate.toISOString()
}, { status: 400 })
}
}
// 绑定推荐关系
await query(
'UPDATE users SET referred_by = ? WHERE id = ?',
[referrer.id, user.id]
)
// 更新推荐人的推广数量
await query(
'UPDATE users SET referral_count = referral_count + 1 WHERE id = ?',
[referrer.id]
)
// 创建推荐绑定记录
const bindingId = 'bind_' + Date.now().toString(36) + Math.random().toString(36).substr(2, 6)
// 计算新的过期时间（30天）
const expiryDate = new Date()
expiryDate.setDate(expiryDate.getDate() + 30) // 30天有效期
expiryDate.setDate(expiryDate.getDate() + BINDING_DAYS)
try {
// 创建或更新绑定记录
const bindingId = 'bind_' + Date.now().toString(36) + Math.random().toString(36).substr(2, 6)
if (action === 'renew') {
// 续期：更新过期时间
await query(`
UPDATE referral_bindings
SET expiry_date = ?, binding_date = CURRENT_TIMESTAMP
WHERE referee_id = ? AND referrer_id = ? AND status = 'active'
`, [expiryDate, user.id, referrer.id])
console.log(`[Referral Bind] 续期: ${user.id} -> ${referrer.id}`)
} else {
// 新绑定或抢夺
await query(`
INSERT INTO referral_bindings (
id, referrer_id, referee_id, referral_code, status, expiry_date
) VALUES (?, ?, ?, ?, 'active', ?)
id, referrer_id, referee_id, referral_code, status, expiry_date, binding_date
) VALUES (?, ?, ?, ?, 'active', ?, CURRENT_TIMESTAMP)
ON DUPLICATE KEY UPDATE
referrer_id = VALUES(referrer_id),
referral_code = VALUES(referral_code),
expiry_date = VALUES(expiry_date),
binding_date = CURRENT_TIMESTAMP,
status = 'active'
`, [bindingId, referrer.id, user.id, referralCode, expiryDate])
} catch (e) {
console.log('[Referral Bind] 创建绑定记录失败（可能是重复绑定）:', e)
// 更新用户的推荐人
await query(
'UPDATE users SET referred_by = ? WHERE id = ?',
[referrer.id, user.id]
)
// 更新推荐人的推广数量（仅新绑定时）
if (action === 'new') {
await query(
'UPDATE users SET referral_count = referral_count + 1 WHERE id = ?',
[referrer.id]
)
}
// 如果是抢夺，减少原推荐人的推广数量
if (action === 'takeover' && oldReferrerId) {
await query(
'UPDATE users SET referral_count = GREATEST(referral_count - 1, 0) WHERE id = ?',
[oldReferrerId]
)
console.log(`[Referral Bind] 抢夺: ${user.id}: ${oldReferrerId} -> ${referrer.id}`)
} else {
console.log(`[Referral Bind] 新绑定: ${user.id} -> ${referrer.id}`)
}
}
console.log(`[Referral Bind] 成功: ${user.id} -> ${referrer.id} (${referralCode})`)
// 记录访问日志（用于统计「通过链接进的人数」）
try {
await query(`
INSERT INTO referral_visits (referrer_id, visitor_id, source, created_at)
VALUES (?, ?, ?, CURRENT_TIMESTAMP)
`, [referrer.id, user.id, source || 'miniprogram'])
} catch (e) {
// 访问日志表可能不存在，忽略错误
}
return NextResponse.json({
success: true,
message: '绑定成功',
message: action === 'renew' ? '绑定已续期' : (action === 'takeover' ? '绑定已更新' : '绑定成功'),
action,
expiryDate: expiryDate.toISOString(),
referrer: {
id: referrer.id,
nickname: referrer.nickname

229
app/api/referral/data/route.ts
View File

@@ -1,10 +1,18 @@
/**
* 分销数据API
* 获取用户的推广数据、绑定用户列表、收益统计
* 分销数据API - 增强版
*
* 可见数据：
* - 绑定用户数（当前有效绑定）
* - 通过链接进的人数（总访问量）
* - 带来的付款人数（已转化购买）
* - 收益统计（90%归分发者）
*/
import { NextRequest, NextResponse } from 'next/server'
import { query } from '@/lib/db'
import { query, getConfig } from '@/lib/db'
// 分成比例（默认90%给推广者）
const DISTRIBUTOR_SHARE = 0.9
/**
* GET - 获取分销数据
@@ -21,6 +29,15 @@ export async function GET(request: NextRequest) {
}
try {
// 获取分销配置
let distributorShare = DISTRIBUTOR_SHARE
try {
const config = await getConfig('referral_config')
if (config?.distributorShare) {
distributorShare = config.distributorShare / 100
}
} catch (e) { /* 使用默认配置 */ }
// 1. 获取用户基本信息
const users = await query(`
SELECT id, nickname, referral_code, earnings, pending_earnings,
@@ -37,97 +54,173 @@ export async function GET(request: NextRequest) {
const user = users[0]
// 2. 获取推荐的用户列表
const referees = await query(`
SELECT id, nickname, avatar, phone, wechat_id,
has_full_book, created_at,
DATEDIFF(DATE_ADD(created_at, INTERVAL 30 DAY), NOW()) as days_remaining
FROM users
WHERE referred_by = ?
ORDER BY created_at DESC
`, [userId]) as any[]
// 3. 分类绑定用户
const now = new Date()
const activeBindings: any[] = []
const convertedBindings: any[] = []
const expiredBindings: any[] = []
for (const referee of referees) {
const binding = {
id: referee.id,
nickname: referee.nickname || '用户' + referee.id.slice(-4),
avatar: referee.avatar || `https://picsum.photos/100/100?random=${referee.id.slice(-2)}`,
phone: referee.phone ? referee.phone.slice(0, 3) + '****' + referee.phone.slice(-4) : null,
hasFullBook: referee.has_full_book,
daysRemaining: Math.max(0, referee.days_remaining || 0),
createdAt: referee.created_at
}
// 2. 获取绑定关系统计（从referral_bindings表）
let bindingStats = { total: 0, active: 0, converted: 0, expired: 0 }
try {
const bindings = await query(`
SELECT
COUNT(*) as total,
SUM(CASE WHEN status = 'active' AND expiry_date > NOW() THEN 1 ELSE 0 END) as active,
SUM(CASE WHEN status = 'converted' THEN 1 ELSE 0 END) as converted,
SUM(CASE WHEN status = 'expired' OR (status = 'active' AND expiry_date <= NOW()) THEN 1 ELSE 0 END) as expired
FROM referral_bindings
WHERE referrer_id = ?
`, [userId]) as any[]
if (referee.has_full_book) {
// 已转化（已购买）
convertedBindings.push(binding)
} else if (binding.daysRemaining <= 0) {
// 已过期
expiredBindings.push(binding)
} else {
// 活跃中
activeBindings.push(binding)
if (bindings.length > 0) {
bindingStats = {
total: parseInt(bindings[0].total) || 0,
active: parseInt(bindings[0].active) || 0,
converted: parseInt(bindings[0].converted) || 0,
expired: parseInt(bindings[0].expired) || 0
}
}
} catch (e) { /* 忽略 */ }
// 3. 获取通过链接进入的总人数（访问日志）
let totalVisits = 0
try {
const visits = await query(`
SELECT COUNT(DISTINCT visitor_id) as count
FROM referral_visits
WHERE referrer_id = ?
`, [userId]) as any[]
totalVisits = parseInt(visits[0]?.count) || 0
} catch (e) { /* 访问记录表可能不存在 */ }
// 如果没有访问记录表，用绑定总数替代
if (totalVisits === 0) {
totalVisits = bindingStats.total
}
// 4. 获取收益明细（最近的订单）
// 4. 获取带来的付款人数和金额
let paymentStats = { paidCount: 0, totalAmount: 0 }
try {
const payments = await query(`
SELECT
COUNT(DISTINCT o.user_id) as paid_count,
COALESCE(SUM(o.amount), 0) as total_amount
FROM orders o
JOIN referral_bindings rb ON o.user_id = rb.referee_id
WHERE rb.referrer_id = ? AND o.status = 'paid'
`, [userId]) as any[]
if (payments.length > 0) {
paymentStats = {
paidCount: parseInt(payments[0].paid_count) || 0,
totalAmount: parseFloat(payments[0].total_amount) || 0
}
}
} catch (e) { /* 忽略 */ }
// 5. 获取活跃绑定用户列表
const activeBindings = await query(`
SELECT rb.id, rb.referee_id, rb.expiry_date, rb.binding_date,
u.nickname, u.avatar, u.has_full_book,
DATEDIFF(rb.expiry_date, NOW()) as days_remaining
FROM referral_bindings rb
JOIN users u ON rb.referee_id = u.id
WHERE rb.referrer_id = ? AND rb.status = 'active' AND rb.expiry_date > NOW()
ORDER BY rb.binding_date DESC
LIMIT 50
`, [userId]) as any[]
// 6. 获取已转化用户列表
const convertedBindings = await query(`
SELECT rb.id, rb.referee_id, rb.conversion_date, rb.commission_amount,
u.nickname, u.avatar
FROM referral_bindings rb
JOIN users u ON rb.referee_id = u.id
WHERE rb.referrer_id = ? AND rb.status = 'converted'
ORDER BY rb.conversion_date DESC
LIMIT 50
`, [userId]) as any[]
// 7. 获取收益明细
let earningsDetails: any[] = []
try {
earningsDetails = await query(`
SELECT o.id, o.amount, o.product_type, o.created_at,
u.nickname as buyer_nickname
SELECT o.id, o.order_sn, o.amount, o.product_type, o.pay_time,
u.nickname as buyer_nickname,
rb.commission_amount
FROM orders o
JOIN users u ON o.user_id = u.id
WHERE u.referred_by = ? AND o.status = 'paid'
ORDER BY o.created_at DESC
LIMIT 20
JOIN referral_bindings rb ON o.user_id = rb.referee_id AND rb.referrer_id = ?
WHERE o.status = 'paid'
ORDER BY o.pay_time DESC
LIMIT 30
`, [userId]) as any[]
} catch (e) {
// 订单表可能不存在，忽略
}
} catch (e) { /* 忽略 */ }
// 5. 统计数据
const stats = {
totalReferrals: referees.length,
activeCount: activeBindings.length,
convertedCount: convertedBindings.length,
expiredCount: expiredBindings.length,
expiringCount: activeBindings.filter(b => b.daysRemaining <= 7).length
}
// 8. 计算预估收益
const estimatedEarnings = paymentStats.totalAmount * distributorShare
return NextResponse.json({
success: true,
data: {
// 收益数据
// === 核心可见数据 ===
// 绑定用户数（当前有效绑定）
bindingCount: bindingStats.active,
// 通过链接进的人数
visitCount: totalVisits,
// 带来的付款人数
paidCount: paymentStats.paidCount,
// === 收益数据 ===
// 已结算收益
earnings: parseFloat(user.earnings) || 0,
// 待结算收益
pendingEarnings: parseFloat(user.pending_earnings) || 0,
// 已提现金额
withdrawnEarnings: parseFloat(user.withdrawn_earnings) || 0,
// 预估总收益
estimatedEarnings: Math.round(estimatedEarnings * 100) / 100,
// 分成比例
shareRate: Math.round(distributorShare * 100),
// 推荐码
// === 推荐码 ===
referralCode: user.referral_code,
referralCount: user.referral_count || referees.length,
referralCount: user.referral_count || bindingStats.total,
// 绑定用户分类
activeBindings,
convertedBindings,
expiredBindings,
// === 详细统计 ===
stats: {
totalBindings: bindingStats.total,
activeBindings: bindingStats.active,
convertedBindings: bindingStats.converted,
expiredBindings: bindingStats.expired,
// 即将过期（7天内）
expiringCount: activeBindings.filter((b: any) => b.days_remaining <= 7 && b.days_remaining > 0).length,
// 总支付金额
totalPaymentAmount: paymentStats.totalAmount
},
// 统计
stats,
// === 用户列表 ===
activeUsers: activeBindings.map((b: any) => ({
id: b.referee_id,
nickname: b.nickname || '用户' + b.referee_id.slice(-4),
avatar: b.avatar,
daysRemaining: Math.max(0, b.days_remaining),
hasFullBook: b.has_full_book,
bindingDate: b.binding_date
})),
// 收益明细
earningsDetails: earningsDetails.map(e => ({
convertedUsers: convertedBindings.map((b: any) => ({
id: b.referee_id,
nickname: b.nickname || '用户' + b.referee_id.slice(-4),
avatar: b.avatar,
commission: parseFloat(b.commission_amount) || 0,
conversionDate: b.conversion_date
})),
// === 收益明细 ===
earningsDetails: earningsDetails.map((e: any) => ({
id: e.id,
amount: parseFloat(e.amount) * 0.9, // 90%佣金
orderSn: e.order_sn,
amount: parseFloat(e.amount),
commission: parseFloat(e.commission_amount) || parseFloat(e.amount) * distributorShare,
productType: e.product_type,
buyerNickname: e.buyer_nickname,
createdAt: e.created_at
payTime: e.pay_time
}))
}
})