217 行
8.1 KiB
PHP
217 行
8.1 KiB
PHP
<?php
|
||
|
||
namespace app\api\controller;
|
||
|
||
use app\common\library\WithdrawText;
|
||
use think\Db;
|
||
|
||
/**
|
||
* 后台管理端 · 分销管理（Module-ADM-DIST）
|
||
* 路由：
|
||
* GET /api/v1/admin/dist/setting AD1 分销设置读取
|
||
* POST /api/v1/admin/dist/setting AD2 分销设置保存
|
||
* GET /api/v1/admin/dist/withdraws AD3 提现申请列表
|
||
* POST /api/v1/admin/dist/withdraw/:id/pay AD4 提现审核（打款/驳回）
|
||
*/
|
||
class AdminDist extends V1
|
||
{
|
||
/** 管理端接口必须校验管理员身份（V1 默认关闭了 URI 权限校验） */
|
||
public function _initialize()
|
||
{
|
||
parent::_initialize();
|
||
$this->adminOnly();
|
||
}
|
||
|
||
/**
|
||
* AD1 分销设置读取
|
||
* GET /api/v1/admin/dist/setting → {enabled,level,level1Rate,level2Rate,settleCycle,minWithdraw}
|
||
*/
|
||
public function setting()
|
||
{
|
||
if ($this->request->isPost()) {
|
||
$this->saveSetting();
|
||
}
|
||
$this->ok($this->distConfig());
|
||
}
|
||
|
||
/**
|
||
* AD2 分销设置保存
|
||
* POST /api/v1/admin/dist/setting 入参 {enabled,level,level1Rate,level2Rate,settleCycle,minWithdraw}
|
||
* 规则 BR-08：一级+二级分佣比例不能超过 100%
|
||
*/
|
||
public function saveSetting()
|
||
{
|
||
$enabled = $this->input('enabled', $this->cfg('dist.enabled', 1));
|
||
$level = (int)$this->input('level', $this->cfg('dist.level', 2));
|
||
$level1Rate = (float)$this->input('level1Rate', $this->cfg('dist.level1Rate', 20));
|
||
$level2Rate = (float)$this->input('level2Rate', $this->cfg('dist.level2Rate', 10));
|
||
$settleCycle = (string)$this->input('settleCycle', $this->cfg('dist.settleCycle', 'T+7'));
|
||
$minWithdraw = (float)$this->input('minWithdraw', $this->cfg('dist.minWithdraw', 50));
|
||
|
||
if ($level1Rate + $level2Rate > 100) {
|
||
$this->fail('一级+二级分佣比例不能超过 100%');
|
||
}
|
||
|
||
$this->setCfg('dist.enabled', $enabled ? 1 : 0);
|
||
$this->setCfg('dist.level', $level);
|
||
$this->setCfg('dist.level1Rate', $level1Rate);
|
||
$this->setCfg('dist.level2Rate', $level2Rate);
|
||
$this->setCfg('dist.settleCycle', $settleCycle);
|
||
$this->setCfg('dist.minWithdraw', $minWithdraw);
|
||
|
||
$this->adminLog('修改分销设置');
|
||
|
||
$this->ok($this->distConfig());
|
||
}
|
||
|
||
/**
|
||
* AD3 提现申请列表
|
||
* GET /api/v1/admin/dist/withdraws → 数组 [{id,withdrawNo,user,amount,status,channel,createdAt}]
|
||
*/
|
||
public function withdraws()
|
||
{
|
||
$rows = Db::name('fc_withdraw')->alias('w')
|
||
->join('user u', 'u.id = w.user_id', 'LEFT')
|
||
->field('w.*, u.nickname AS nickname')
|
||
->order('w.createtime desc')
|
||
->select();
|
||
|
||
// 兜底同步：转账中的单据主动查一次微信（回调丢失/本地无 HTTPS 回调时）
|
||
$synced = 0;
|
||
foreach ($rows as $row) {
|
||
if ((string)$row['status'] === 'paying' && $synced < 5) {
|
||
$synced++;
|
||
try {
|
||
\app\common\library\WxTransfer::sync((int)$row['id']);
|
||
} catch (\Throwable $e) {
|
||
// 同步失败不影响列表展示
|
||
}
|
||
}
|
||
}
|
||
if ($synced > 0) {
|
||
$rows = Db::name('fc_withdraw')->alias('w')
|
||
->join('user u', 'u.id = w.user_id', 'LEFT')
|
||
->field('w.*, u.nickname AS nickname')
|
||
->order('w.createtime desc')
|
||
->select();
|
||
}
|
||
|
||
$list = [];
|
||
foreach ($rows as $row) {
|
||
$list[] = [
|
||
'id' => (int)$row['id'],
|
||
'withdrawNo' => (string)$row['withdraw_no'],
|
||
'user' => (string)$row['nickname'],
|
||
'amount' => (float)$row['amount'],
|
||
'status' => (string)$row['status'],
|
||
'channel' => (string)$row['channel'],
|
||
'transferStatus' => (string)(isset($row['transfer_status']) ? $row['transfer_status'] : ''),
|
||
'failReason' => WithdrawText::fail(isset($row['fail_reason']) ? $row['fail_reason'] : ''),
|
||
'createdAt' => $this->iso($row['createtime']),
|
||
];
|
||
}
|
||
|
||
$this->ok($list);
|
||
}
|
||
|
||
/**
|
||
* AD4 提现审核
|
||
* POST /api/v1/admin/dist/withdraw/:id/pay 入参 {op,reason?} → {id,status}
|
||
* 规则 BR-09：op=reject 时 reason 必填
|
||
*/
|
||
public function handleWithdraw()
|
||
{
|
||
$id = (int)$this->request->param('id', 0);
|
||
$op = (string)$this->input('op', '');
|
||
$reason = trim((string)$this->input('reason', ''));
|
||
|
||
if ($op === 'reject' && $reason === '') {
|
||
$this->fail('驳回需填写原因');
|
||
}
|
||
|
||
$withdraw = Db::name('fc_withdraw')->where('id', $id)->find();
|
||
if (!$withdraw) {
|
||
$this->fail('提现记录不存在', 404);
|
||
}
|
||
if ((string)$withdraw['status'] !== 'auditing') {
|
||
$this->fail('该提现记录已处理（当前状态：' . $withdraw['status'] . '），请勿重复操作');
|
||
}
|
||
|
||
if ($op === 'reject') {
|
||
try {
|
||
Db::transaction(function () use ($id, $reason) {
|
||
$locked = Db::name('fc_withdraw')->where('id', $id)->lock(true)->find();
|
||
if (!$locked || (string)$locked['status'] !== 'auditing') {
|
||
throw new \RuntimeException('该提现记录已处理，请刷新后重试');
|
||
}
|
||
Db::name('fc_withdraw')->where('id', $id)->update([
|
||
'status' => 'rejected',
|
||
'reason' => $reason,
|
||
'updatetime' => time(),
|
||
]);
|
||
$this->notify($locked['user_id'], 'system', '提现被驳回', '您的提现申请被驳回：' . $reason);
|
||
});
|
||
} catch (\Throwable $e) {
|
||
$this->fail($e->getMessage() ?: '操作失败，请重试');
|
||
}
|
||
|
||
$this->adminLog('驳回提现 #' . $id);
|
||
$this->ok(['id' => (int)$id, 'status' => 'rejected']);
|
||
}
|
||
|
||
// 审核通过 → 自动发起微信商家转账（用户需在微信确认收款）
|
||
try {
|
||
$res = \app\common\library\WxTransfer::approve($id);
|
||
} catch (\Throwable $e) {
|
||
$this->fail('转账失败：' . $e->getMessage());
|
||
}
|
||
|
||
$this->adminLog('提现转账 #' . $id . ' 结果' . $res['state']);
|
||
|
||
$message = $res['withdrawState'] === 'paid'
|
||
? '转账成功，已到账'
|
||
: ($res['withdrawState'] === 'failed' ? '转账失败，请查看失败原因' : '已提交转账，等待用户确认收款');
|
||
|
||
$this->ok([
|
||
'id' => (int)$id,
|
||
'status' => $res['withdrawState'],
|
||
'transferState' => $res['state'],
|
||
], $message);
|
||
}
|
||
|
||
/**
|
||
* 撤销「转账中」的提现单（用户长期不确认收款时使用）
|
||
* POST /api/v1/admin/dist/withdraw/:id/cancel
|
||
*/
|
||
public function cancelWithdraw()
|
||
{
|
||
$id = (int)$this->request->param('id', 0);
|
||
|
||
try {
|
||
$state = \app\common\library\WxTransfer::cancel($id);
|
||
} catch (\Throwable $e) {
|
||
$this->fail('撤销失败：' . $e->getMessage());
|
||
}
|
||
|
||
$this->adminLog('撤销提现转账 #' . $id);
|
||
$this->ok([
|
||
'id' => $id,
|
||
'status' => (string)Db::name('fc_withdraw')->where('id', $id)->value('status'),
|
||
'transferState' => $state,
|
||
]);
|
||
}
|
||
|
||
/** 组装分销设置结构 */
|
||
protected function distConfig()
|
||
{
|
||
return [
|
||
'enabled' => (bool)$this->cfg('dist.enabled', 1),
|
||
'level' => (int)$this->cfg('dist.level', 2),
|
||
'level1Rate' => (float)$this->cfg('dist.level1Rate', 20),
|
||
'level2Rate' => (float)$this->cfg('dist.level2Rate', 10),
|
||
'settleCycle' => (string)$this->cfg('dist.settleCycle', 'T+7'),
|
||
'minWithdraw' => (float)$this->cfg('dist.minWithdraw', 50),
|
||
];
|
||
}
|
||
}
|