850 行
35 KiB
PHP
可执行文件
850 行
35 KiB
PHP
可执行文件
<?php
|
||
|
||
namespace addons\shopro\service;
|
||
|
||
use addons\shopro\exception\ShoproException;
|
||
use think\Db;
|
||
use think\Log;
|
||
use think\exception\HttpResponseException;
|
||
use app\admin\model\shopro\Withdraw as WithdrawModel;
|
||
use app\admin\model\shopro\WithdrawLog as WithdrawLogModel;
|
||
use addons\shopro\library\Operator;
|
||
use app\admin\model\shopro\ThirdOauth;
|
||
use addons\shopro\service\Wallet as WalletService;
|
||
use addons\shopro\library\pay\PayService;
|
||
use app\admin\model\shopro\user\User;
|
||
use addons\shopro\service\partner\PartnerConfig;
|
||
use addons\shopro\service\partner\RateService;
|
||
use addons\shopro\service\partner\PartnerRewardService;
|
||
use app\admin\model\shopro\commission\Agent as AgentModel;
|
||
|
||
class Withdraw
|
||
{
|
||
|
||
protected $user = null;
|
||
|
||
/**
|
||
* @var array
|
||
*/
|
||
public $config = [];
|
||
|
||
public function __construct($user = null)
|
||
{
|
||
if ($user) {
|
||
$this->user = is_numeric($user) ? User::get($user) : $user;
|
||
}
|
||
|
||
// 提现规则
|
||
$config = sheep_config('shop.recharge_withdraw.withdraw');
|
||
|
||
// 提现开关与是否允许提现综合状态
|
||
$config['status'] = isset($config['status']) ? intval($config['status']) : (!empty($config['methods']) ? 1 : 0);
|
||
$config['is_withdraw_open'] = (bool)($config['status'] === 1 && !empty($config['methods']));
|
||
|
||
$config['min_amount'] = $config['min_amount'] == 0 ? $config['min_amount'] : number_format(floatval($config['min_amount']), 2, '.', '');
|
||
$config['max_amount'] = $config['max_amount'] == 0 ? $config['max_amount'] : number_format(floatval($config['max_amount']), 2, '.', '');
|
||
$config['charge_rate_format'] = round(floatval($config['charge_rate']), 1); // 1 位小数
|
||
$config['charge_rate'] = round((floatval($config['charge_rate']) * 0.01), 3);
|
||
|
||
$this->config = $config;
|
||
}
|
||
|
||
|
||
// 发起提现申请
|
||
public function apply($params)
|
||
{
|
||
$walletType = $params['wallet_type'] ?? 'money';
|
||
if (!in_array($walletType, ['money', 'commission', 'madow'])) {
|
||
$walletType = 'money';
|
||
}
|
||
$type = $params['type'] ?? '';
|
||
$money = $params['money'] ?? 0;
|
||
$money = (string)$money;
|
||
|
||
if ($walletType === 'madow') {
|
||
return $this->applyMadow($params, $type, $money);
|
||
}
|
||
|
||
// 手续费
|
||
$charge = bcmul($money, (string)$this->config['charge_rate'], 2);
|
||
|
||
// 检查提现规则
|
||
$this->checkApply($type, $money, $charge, $walletType);
|
||
|
||
// 获取账号信息
|
||
$withdrawInfo = $this->getAccountInfo($type, $params);
|
||
$withdrawInfo['wallet_type'] = $walletType;
|
||
if ($walletType === 'money') {
|
||
$withdrawInfo['提现资产'] = '商城余额';
|
||
} elseif ($walletType === 'commission') {
|
||
$withdrawInfo['提现资产'] = '佣金钱包';
|
||
}
|
||
|
||
// 添加提现记录
|
||
$withdraw = new WithdrawModel();
|
||
$withdraw->user_id = $this->user->id;
|
||
$withdraw->amount = $money;
|
||
$withdraw->charge_fee = $charge;
|
||
$withdraw->charge_rate = $this->config['charge_rate'];
|
||
$withdraw->withdraw_sn = get_sn($this->user->id, 'W');
|
||
$withdraw->withdraw_type = $type;
|
||
$withdraw->withdraw_info = $withdrawInfo;
|
||
$withdraw->status = 0;
|
||
$withdraw->platform = request()->header('platform');
|
||
$this->saveWithdrawSafe($withdraw);
|
||
|
||
// 扣减对应钱包资金（内扣模式：仅扣除提现申请本金，手续费从提现金额中内扣）
|
||
if ($walletType === 'money') {
|
||
WalletService::change($this->user, 'money', -$money, 'withdraw', [
|
||
'withdraw_id' => $withdraw->id,
|
||
'amount' => $withdraw->amount,
|
||
'charge_fee' => $withdraw->charge_fee,
|
||
'charge_rate' => $withdraw->charge_rate,
|
||
'wallet_type' => 'money',
|
||
], '申请提现扣除余额');
|
||
$this->handleLog($withdraw, '用户发起商城余额提现申请', $this->user);
|
||
} else {
|
||
WalletService::change($this->user, 'commission', -$money, 'withdraw', [
|
||
'withdraw_id' => $withdraw->id,
|
||
'amount' => $withdraw->amount,
|
||
'charge_fee' => $withdraw->charge_fee,
|
||
'charge_rate' => $withdraw->charge_rate,
|
||
'wallet_type' => 'commission',
|
||
]);
|
||
$this->handleLog($withdraw, '用户发起佣金提现申请', $this->user);
|
||
}
|
||
|
||
return $withdraw;
|
||
}
|
||
|
||
// 发起 dmepa 提现申请
|
||
protected function applyMadow($params, $type, $money)
|
||
{
|
||
if (!PartnerConfig::isMadowWithdrawEnabled()) {
|
||
throw new ShoproException('dmepa提现功能暂未开启');
|
||
}
|
||
|
||
if ($type !== 'bank') {
|
||
throw new ShoproException('dmepa提现仅支持银行卡转账');
|
||
}
|
||
|
||
if (floatval($money) <= 0) {
|
||
throw new ShoproException('请输入正确的提现金额');
|
||
}
|
||
|
||
$minAmount = PartnerConfig::madowWithdrawMin();
|
||
if ($minAmount > 0 && floatval($money) < $minAmount) {
|
||
throw new ShoproException('提现金额不能少于 ' . $minAmount . '元');
|
||
}
|
||
|
||
$rate = (new RateService())->currentRate();
|
||
if ($rate <= 0) {
|
||
throw new ShoproException('当前dmepa暂无有效市值汇率，无法发起提现');
|
||
}
|
||
|
||
// 计算需扣除的 dmepa = 金额 / 汇率
|
||
$rateStr = number_format($rate, 12, '.', '');
|
||
$deductMadow = function_exists('bcdiv') ? bcdiv($money, $rateStr, 4) : number_format(floatval($money) / $rate, 4, '.', '');
|
||
if (floatval($deductMadow) <= 0) {
|
||
throw new ShoproException('折算dmepa数量不足');
|
||
}
|
||
|
||
// 检查合伙人资产
|
||
$agent = AgentModel::where('user_id', $this->user->id)->lock(true)->find();
|
||
if (!$agent) {
|
||
throw new ShoproException('未找到您的合伙资产账户');
|
||
}
|
||
|
||
$currentMadow = strval($agent->madow ?? 0);
|
||
if (bccomp($currentMadow, $deductMadow, 4) < 0) {
|
||
throw new ShoproException('持仓dmepa不足，无法提现');
|
||
}
|
||
|
||
// 手续费计算 (内扣模式)
|
||
$chargeRatePercent = PartnerConfig::madowWithdrawChargeRate();
|
||
$chargeRate = round($chargeRatePercent * 0.01, 4);
|
||
$chargeFee = function_exists('bcmul') ? bcmul((string)$money, (string)$chargeRate, 2) : number_format(floatval($money) * $chargeRate, 2, '.', '');
|
||
if (floatval($chargeFee) > 0 && floatval($money) <= floatval($chargeFee)) {
|
||
throw new ShoproException('提现金额必须大于手续费');
|
||
}
|
||
$realMoney = bcsub((string)$money, (string)$chargeFee, 2);
|
||
|
||
// 校验银行卡信息
|
||
$withdrawInfo = $this->getAccountInfo($type, $params);
|
||
$rateClean = rtrim(rtrim(number_format((float)$rate, 12, '.', ''), '0'), '.');
|
||
$moneyClean = number_format((float)$money, 2, '.', '');
|
||
$withdrawInfo['提现资产'] = 'DMEPA';
|
||
$withdrawInfo['扣除DMEPA'] = $deductMadow . ' DMEPA';
|
||
$withdrawInfo['市值汇率'] = '1 DMEPA ≈ ' . $rateClean . ' 元';
|
||
$withdrawInfo['换算市值'] = $moneyClean . ' 元';
|
||
if (floatval($chargeFee) > 0 || floatval($chargeRate) > 0) {
|
||
$withdrawInfo['提现手续费'] = number_format(floatval($chargeFee), 2, '.', '') . ' 元 (' . $chargeRatePercent . '%)';
|
||
}
|
||
$withdrawInfo['预计到账'] = number_format(floatval($realMoney), 2, '.', '') . ' 元';
|
||
$withdrawInfo['wallet_type'] = 'madow';
|
||
$withdrawInfo['madow_amount'] = $deductMadow;
|
||
$withdrawInfo['rate'] = $rate;
|
||
$withdrawInfo['charge_fee'] = $chargeFee;
|
||
$withdrawInfo['charge_rate'] = $chargeRate;
|
||
|
||
// 扣减 dmepa
|
||
$agent->setDec('madow', $deductMadow);
|
||
|
||
// 创建提现记录
|
||
$withdraw = new WithdrawModel();
|
||
$withdraw->user_id = $this->user->id;
|
||
$withdraw->amount = $money;
|
||
$withdraw->charge_fee = $chargeFee;
|
||
$withdraw->charge_rate = $chargeRate;
|
||
$withdraw->withdraw_sn = get_sn($this->user->id, 'W');
|
||
$withdraw->withdraw_type = 'bank';
|
||
$withdraw->withdraw_info = $withdrawInfo;
|
||
$withdraw->status = 0;
|
||
$withdraw->platform = request()->header('platform');
|
||
$this->saveWithdrawSafe($withdraw);
|
||
|
||
// 记录合伙人流水
|
||
PartnerRewardService::write([
|
||
'order_id' => -$withdraw->id,
|
||
'buyer_id' => $this->user->id,
|
||
'user_id' => $this->user->id,
|
||
'role' => 'partner',
|
||
'reward_type' => 'madow_withdraw',
|
||
'amount' => -$money,
|
||
'madow' => -$deductMadow,
|
||
'base_amount' => $money,
|
||
'rate' => $rate,
|
||
'ext' => [
|
||
'withdraw_sn' => $withdraw->withdraw_sn,
|
||
'withdraw_id' => $withdraw->id,
|
||
'deduct_madow' => $deductMadow,
|
||
'cny_amount' => $money,
|
||
'rate' => $rate,
|
||
'charge_fee' => $chargeFee,
|
||
'charge_rate' => $chargeRate,
|
||
'real_amount' => $realMoney,
|
||
],
|
||
'settle_date' => null,
|
||
'status' => 1,
|
||
]);
|
||
|
||
$this->handleLog($withdraw, '用户发起dmepa提现申请（扣除 ' . $deductMadow . ' dmepa）', $this->user);
|
||
|
||
return $withdraw;
|
||
}
|
||
|
||
|
||
// 继续提现
|
||
public function retry($params)
|
||
{
|
||
$withdraw = WithdrawModel::where('user_id', $this->user->id)
|
||
->where('withdraw_sn', $params['withdraw_sn'])
|
||
->where('status', 1)
|
||
->where('withdraw_type', 'wechat')
|
||
->find();
|
||
|
||
if (!$withdraw) {
|
||
throw new ShoproException('提现记录不存在');
|
||
}
|
||
if (request()->header('platform') !== $withdraw->platform) {
|
||
throw new ShoproException('请在发起该次提现的平台操作');
|
||
}
|
||
|
||
$this->handleLog($withdraw, '用户重新发起提现申请');
|
||
// 实时检查提现单状态
|
||
return $this->checkWechatTransferResult($withdraw);
|
||
}
|
||
|
||
// 取消提现(适用于微信商家转账)
|
||
public function cancel($params)
|
||
{
|
||
$withdraw = WithdrawModel::where('user_id', $this->user->id)
|
||
->where('withdraw_sn', $params['withdraw_sn'])
|
||
->where('status', 1)
|
||
->where('withdraw_type', 'wechat')
|
||
->find();
|
||
|
||
if (!$withdraw) {
|
||
throw new ShoproException('提现记录不存在');
|
||
}
|
||
|
||
if (request()->header('platform') !== $withdraw->platform) {
|
||
throw new ShoproException('请在发起该次提现的平台操作');
|
||
}
|
||
|
||
// 实时检查提现单状态
|
||
$withdraw = $this->checkWechatTransferResult($withdraw);
|
||
|
||
if ($withdraw->wechat_transfer_state !== 'WAIT_USER_CONFIRM') {
|
||
throw new ShoproException('该提现单暂无法发起取消操作,请联系客服');
|
||
}
|
||
// 提交微信撤销单
|
||
$payService = new PayService($withdraw->withdraw_type, $withdraw->platform);
|
||
|
||
try {
|
||
$result = $payService->cancelTransferOrder([
|
||
'withdraw_sn' => $withdraw->withdraw_sn,
|
||
]);
|
||
} catch (\Exception $e) {
|
||
\think\Log::error('撤销提现失败: ' . ': 行号: ' . $e->getLine() . ': 文件: ' . $e->getFile() . ': 错误信息: ' . $e->getMessage());
|
||
$this->handleLog($withdraw, '撤销微信商家转账失败: ' . $e->getMessage());
|
||
throw new ShoproException($e->getMessage());
|
||
}
|
||
|
||
$withdraw->wechat_transfer_state = $result['state'];
|
||
$withdraw->save();
|
||
$this->handleLog($withdraw, '申请撤销微信商家转账成功，报文信息：' . json_encode($result, JSON_UNESCAPED_UNICODE));
|
||
return $withdraw;
|
||
}
|
||
|
||
|
||
// 新版本微信商家转账
|
||
// https://pay.weixin.qq.com/doc/v3/merchant/4012711988
|
||
public function handleWechatTransfer($withdraw)
|
||
{
|
||
operate_disabled();
|
||
|
||
$payService = new PayService($withdraw->withdraw_type, $withdraw->platform);
|
||
$payload = [
|
||
'_action' => 'mch_transfer', // 新版转账
|
||
'out_bill_no' => $withdraw->withdraw_sn,
|
||
'transfer_scene_id' => '1005',
|
||
'openid' => $withdraw->withdraw_info['微信ID'] ?? '',
|
||
'user_name' => $withdraw->withdraw_info['真实姓名'] ?? '', // 明文传参即可，sdk 会自动加密
|
||
'transfer_amount' => bcsub((string)$withdraw->amount, (string)$withdraw->charge_fee, 2),
|
||
'transfer_remark' => "用户[" . ($withdraw->withdraw_info['微信用户'] ?? '') . "]提现",
|
||
'transfer_scene_report_infos' => [
|
||
['info_type' => '岗位类型', 'info_content' => '推广专员'],
|
||
['info_type' => '报酬说明', 'info_content' => '推广佣金报酬'],
|
||
],
|
||
];
|
||
try {
|
||
list($response, $transferData) = $payService->transfer($payload);
|
||
$withdraw->status = 1; // 提现处理中
|
||
$withdraw->wechat_transfer_state = $response['state'];
|
||
$withdraw->payment_json = json_encode($response, JSON_UNESCAPED_UNICODE);
|
||
$withdraw->save();
|
||
$this->handleLog($withdraw, '用户发起微信商家转账收款，报文信息：' . json_encode($response, JSON_UNESCAPED_UNICODE), $this->user);
|
||
|
||
return $transferData;
|
||
} catch (\Exception $e) {
|
||
\think\Log::error('提现失败: ' . ': 行号: ' . $e->getLine() . ': 文件: ' . $e->getFile() . ': 错误信息: ' . $e->getMessage());
|
||
// $withdraw->wechat_transfer_state = 'NOT_FOUND';
|
||
$withdraw->save();
|
||
$this->handleFail($withdraw, $e->getMessage());
|
||
throw new ShoproException($e->getMessage());
|
||
}
|
||
|
||
// 发起提现失败，自动处理退还佣金
|
||
|
||
}
|
||
|
||
// 支付宝提现
|
||
public function handleAlipayWithdraw($withdraw)
|
||
{
|
||
operate_disabled();
|
||
|
||
Db::startTrans();
|
||
try {
|
||
$withdraw = $this->handleAgree($withdraw, $this->user);
|
||
$withdraw = $this->handleWithdraw($withdraw, $this->user);
|
||
|
||
Db::commit();
|
||
} catch (ShoproException $e) {
|
||
Db::commit(); // 不回滚，记录错误日志
|
||
throw new ShoproException($e->getMessage());
|
||
} catch (HttpResponseException $e) {
|
||
$data = $e->getResponse()->getData();
|
||
$message = $data ? ($data['msg'] ?? '') : $e->getMessage();
|
||
throw new ShoproException($message);
|
||
} catch (\Exception $e) {
|
||
Db::rollback();
|
||
throw new ShoproException($e->getMessage());
|
||
}
|
||
}
|
||
|
||
|
||
|
||
// 同意操作
|
||
public function handleAgree($withdraw, $oper = null)
|
||
{
|
||
if ($withdraw->status != 0) {
|
||
throw new ShoproException('请勿重复操作');
|
||
}
|
||
$withdraw->status = 1;
|
||
$withdraw->save();
|
||
return $this->handleLog($withdraw, '同意提现申请', $oper);
|
||
}
|
||
|
||
// 处理打款
|
||
public function handleWithdraw($withdraw, $oper = null)
|
||
{
|
||
$withDrawStatus = false;
|
||
if ($withdraw->status != 1) {
|
||
throw new ShoproException('请勿重复操作');
|
||
}
|
||
if ($withdraw->withdraw_type !== 'bank') {
|
||
$withDrawStatus = $this->handleTransfer($withdraw);
|
||
} else {
|
||
$withDrawStatus = true;
|
||
}
|
||
if ($withDrawStatus) {
|
||
$withdraw->status = 2;
|
||
$withdraw->paid_fee = bcsub((string)$withdraw->amount, (string)$withdraw->charge_fee, 2);
|
||
$withdraw->save();
|
||
return $this->handleLog($withdraw, '已打款', $oper);
|
||
}
|
||
return $withdraw;
|
||
}
|
||
|
||
// 拒绝操作
|
||
public function handleRefuse($withdraw, $refuse_msg)
|
||
{
|
||
if ($withdraw->status != 0 && $withdraw->status != 1) {
|
||
throw new ShoproException('请勿重复操作');
|
||
}
|
||
$withdraw->status = -1;
|
||
$withdraw->save();
|
||
|
||
if (!$this->user && !empty($withdraw->user_id)) {
|
||
$this->user = User::get($withdraw->user_id);
|
||
}
|
||
$userId = $this->user ? $this->user->id : intval($withdraw->user_id);
|
||
|
||
$info = $withdraw->withdraw_info;
|
||
if (is_string($info)) {
|
||
$info = json_decode($info, true) ?: [];
|
||
}
|
||
$isMadow = (isset($info['wallet_type']) && $info['wallet_type'] === 'madow')
|
||
|| (isset($info['提现资产']) && strcasecmp($info['提现资产'], 'dmepa') === 0);
|
||
|
||
$isMoney = (isset($info['wallet_type']) && $info['wallet_type'] === 'money')
|
||
|| (isset($info['提现资产']) && $info['提现资产'] === '商城余额');
|
||
|
||
if ($isMadow) {
|
||
$madowRefund = $info['madow_amount'] ?? ($info['扣除DMEPA'] ?? ($info['扣除dmepa'] ?? 0));
|
||
if (is_string($madowRefund)) {
|
||
$madowRefund = trim(str_ireplace(['dmepa', ' '], '', $madowRefund));
|
||
}
|
||
if (floatval($madowRefund) > 0) {
|
||
$agent = AgentModel::where('user_id', $userId)->lock(true)->find();
|
||
if ($agent) {
|
||
$agent->setInc('madow', $madowRefund);
|
||
}
|
||
PartnerRewardService::write([
|
||
'order_id' => -$withdraw->id,
|
||
'buyer_id' => $userId,
|
||
'user_id' => $userId,
|
||
'role' => 'partner',
|
||
'reward_type' => 'madow_withdraw_refund',
|
||
'amount' => $withdraw->amount,
|
||
'madow' => $madowRefund,
|
||
'base_amount' => $withdraw->amount,
|
||
'rate' => $info['rate'] ?? 0,
|
||
'ext' => [
|
||
'withdraw_sn' => $withdraw->withdraw_sn,
|
||
'withdraw_id' => $withdraw->id,
|
||
'refund_madow' => $madowRefund,
|
||
'refuse_msg' => $refuse_msg,
|
||
],
|
||
'settle_date' => date('Y-m-d'),
|
||
'status' => 1,
|
||
]);
|
||
}
|
||
return $this->handleLog($withdraw, '拒绝:' . $refuse_msg . '，已退还扣除的 ' . $madowRefund . ' dmepa');
|
||
} elseif (isset($info['wallet_type']) && $info['wallet_type'] === 'commission') {
|
||
// 仅显式标注佣金提现的退回用户佣金
|
||
WalletService::change($this->user, 'commission', $withdraw->amount, 'withdraw_error', [
|
||
'withdraw_id' => $withdraw->id,
|
||
'amount' => $withdraw->amount,
|
||
'charge_fee' => $withdraw->charge_fee,
|
||
'charge_rate' => $withdraw->charge_rate,
|
||
'wallet_type' => 'commission',
|
||
]);
|
||
|
||
return $this->handleLog($withdraw, '拒绝:' . $refuse_msg . '，已退还提现佣金');
|
||
} else {
|
||
// 方案 B 一体化内扣：常规提现默认退回商城可用余额本金
|
||
WalletService::change($this->user, 'money', $withdraw->amount, 'withdraw_error', [
|
||
'withdraw_id' => $withdraw->id,
|
||
'amount' => $withdraw->amount,
|
||
'charge_fee' => $withdraw->charge_fee,
|
||
'charge_rate' => $withdraw->charge_rate,
|
||
'wallet_type' => 'money',
|
||
], '提现驳回退还余额');
|
||
|
||
return $this->handleLog($withdraw, '拒绝:' . $refuse_msg . '，已退还提现商城余额');
|
||
}
|
||
}
|
||
|
||
|
||
// 失败
|
||
public function handleFail($withdraw, $refuse_msg, $status = -2)
|
||
{
|
||
if ($withdraw->status != 0 && $withdraw->status != 1) {
|
||
throw new ShoproException('请勿重复操作');
|
||
}
|
||
$withdraw->status = $status;
|
||
$withdraw->save();
|
||
|
||
if (!$this->user && !empty($withdraw->user_id)) {
|
||
$this->user = User::get($withdraw->user_id);
|
||
}
|
||
$userId = $this->user ? $this->user->id : intval($withdraw->user_id);
|
||
|
||
$info = $withdraw->withdraw_info;
|
||
if (is_string($info)) {
|
||
$info = json_decode($info, true) ?: [];
|
||
}
|
||
$isMadow = (isset($info['wallet_type']) && $info['wallet_type'] === 'madow')
|
||
|| (isset($info['提现资产']) && strcasecmp($info['提现资产'], 'dmepa') === 0);
|
||
|
||
$isMoney = (isset($info['wallet_type']) && $info['wallet_type'] === 'money')
|
||
|| (isset($info['提现资产']) && $info['提现资产'] === '商城余额');
|
||
|
||
if ($isMadow) {
|
||
$madowRefund = $info['madow_amount'] ?? ($info['扣除DMEPA'] ?? ($info['扣除dmepa'] ?? 0));
|
||
if (is_string($madowRefund)) {
|
||
$madowRefund = trim(str_ireplace(['dmepa', ' '], '', $madowRefund));
|
||
}
|
||
if (floatval($madowRefund) > 0) {
|
||
$agent = AgentModel::where('user_id', $userId)->lock(true)->find();
|
||
if ($agent) {
|
||
$agent->setInc('madow', $madowRefund);
|
||
}
|
||
PartnerRewardService::write([
|
||
'order_id' => -$withdraw->id,
|
||
'buyer_id' => $userId,
|
||
'user_id' => $userId,
|
||
'role' => 'partner',
|
||
'reward_type' => 'madow_withdraw_refund',
|
||
'amount' => $withdraw->amount,
|
||
'madow' => $madowRefund,
|
||
'base_amount' => $withdraw->amount,
|
||
'rate' => $info['rate'] ?? 0,
|
||
'ext' => [
|
||
'withdraw_sn' => $withdraw->withdraw_sn,
|
||
'withdraw_id' => $withdraw->id,
|
||
'refund_madow' => $madowRefund,
|
||
'fail_msg' => $refuse_msg,
|
||
],
|
||
'settle_date' => date('Y-m-d'),
|
||
'status' => 1,
|
||
]);
|
||
}
|
||
return $this->handleLog($withdraw, '提现失败，已退还 ' . $madowRefund . ' dmepa:' . $refuse_msg);
|
||
} elseif (isset($info['wallet_type']) && $info['wallet_type'] === 'commission') {
|
||
// 仅显式标注佣金提现的退回用户佣金
|
||
WalletService::change($this->user, 'commission', $withdraw->amount, 'withdraw_error', [
|
||
'withdraw_id' => $withdraw->id,
|
||
'amount' => $withdraw->amount,
|
||
'charge_fee' => $withdraw->charge_fee,
|
||
'charge_rate' => $withdraw->charge_rate,
|
||
'wallet_type' => 'commission',
|
||
]);
|
||
|
||
return $this->handleLog($withdraw, '提现失败，已退还提现佣金:' . $refuse_msg);
|
||
} else {
|
||
// 方案 B 一体化内扣：常规提现默认退回商城可用余额本金
|
||
WalletService::change($this->user, 'money', $withdraw->amount, 'withdraw_error', [
|
||
'withdraw_id' => $withdraw->id,
|
||
'amount' => $withdraw->amount,
|
||
'charge_fee' => $withdraw->charge_fee,
|
||
'charge_rate' => $withdraw->charge_rate,
|
||
'wallet_type' => 'money',
|
||
], '提现失败退还余额');
|
||
|
||
return $this->handleLog($withdraw, '提现失败，已退还提现商城余额:' . $refuse_msg);
|
||
}
|
||
}
|
||
|
||
|
||
// 商家转账回调
|
||
public function handleWechatTransferNotify($action, $withdrawSn, $originData)
|
||
{
|
||
$withdraw = WithdrawModel::where('withdraw_sn', $withdrawSn)->find();
|
||
if (!$withdraw) {
|
||
throw new ShoproException('提现记录不存在');
|
||
}
|
||
|
||
if ($withdraw->status !== 1) {
|
||
throw new ShoproException('提现记录状态不正确');
|
||
}
|
||
|
||
$this->user = User::get($withdraw->user_id);
|
||
|
||
if (!$this->user) {
|
||
throw new ShoproException('用户不存在');
|
||
}
|
||
|
||
$withdraw->wechat_transfer_state = $action;
|
||
|
||
switch ($action) {
|
||
case 'SUCCESS':
|
||
$withdraw->status = 2;
|
||
$this->handleLog($withdraw, '微信商家转账成功，报文信息: ' . json_encode($originData, JSON_UNESCAPED_UNICODE), $this->user);
|
||
$withdraw->save();
|
||
break;
|
||
case 'FAILED':
|
||
$this->handleFail($withdraw, '微信商家转账失败，报文信息: ' . json_encode($originData, JSON_UNESCAPED_UNICODE), -2);
|
||
break;
|
||
case 'CANCELLED': // 撤销完成
|
||
$this->handleFail($withdraw, '微信商家转账撤销成功，报文信息: ' . json_encode($originData, JSON_UNESCAPED_UNICODE), -3);
|
||
break;
|
||
default:
|
||
$this->handleLog($withdraw, '回调结果不是终态，报文信息: ' . json_encode($originData, JSON_UNESCAPED_UNICODE), $this->user);
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
// 检查微信商家转账单结果
|
||
public function checkWechatTransferResult($withdraw)
|
||
{
|
||
if ($withdraw->createtime < strtotime('-30 day')) {
|
||
throw new ShoproException('提现单据已过期，请联系客服解决');
|
||
}
|
||
$payService = new PayService($withdraw->withdraw_type, $withdraw->platform);
|
||
|
||
$result = $payService->queryTransferOrder([
|
||
'withdraw_sn' => $withdraw->withdraw_sn,
|
||
]);
|
||
$withdraw->wechat_transfer_state = $result['state'];
|
||
$withdraw->save();
|
||
$this->handleLog($withdraw, '查询微信商家转账单，报文信息：' . json_encode($result, JSON_UNESCAPED_UNICODE));
|
||
|
||
return $withdraw;
|
||
}
|
||
|
||
|
||
// 企业付款提现
|
||
private function handleTransfer($withdraw)
|
||
{
|
||
operate_disabled();
|
||
$type = $withdraw->withdraw_type;
|
||
$platform = $withdraw->platform;
|
||
|
||
$payService = new PayService($type, $platform);
|
||
|
||
if ($type == 'alipay') {
|
||
$payload = [
|
||
'out_biz_no' => $withdraw->withdraw_sn,
|
||
'trans_amount' => bcsub((string)$withdraw->amount, (string)$withdraw->charge_fee, 2),
|
||
'product_code' => 'TRANS_ACCOUNT_NO_PWD',
|
||
'biz_scene' => 'DIRECT_TRANSFER',
|
||
// 'order_title' => '余额提现到',
|
||
'remark' => '用户提现',
|
||
'payee_info' => [
|
||
'identity' => $withdraw->withdraw_info['支付宝账户'] ?? '',
|
||
'identity_type' => 'ALIPAY_LOGON_ID',
|
||
'name' => $withdraw->withdraw_info['真实姓名'] ?? '',
|
||
]
|
||
];
|
||
}
|
||
|
||
try {
|
||
list($code, $response) = $payService->transfer($payload);
|
||
if ($code === 1) {
|
||
$withdraw->payment_json = json_encode($response, JSON_UNESCAPED_UNICODE);
|
||
$withdraw->save();
|
||
return true;
|
||
}
|
||
throw new ShoproException(json_encode($response, JSON_UNESCAPED_UNICODE));
|
||
} catch (HttpResponseException $e) {
|
||
$data = $e->getResponse()->getData();
|
||
$message = $data ? ($data['msg'] ?? '') : $e->getMessage();
|
||
throw new ShoproException($message);
|
||
} catch (\Exception $e) {
|
||
\think\Log::error('提现失败：' . ' 行号：' . $e->getLine() . '文件：' . $e->getFile() . '错误信息：' . $e->getMessage());
|
||
$this->handleLog($withdraw, '提现失败：' . $e->getMessage());
|
||
throw new ShoproException($e->getMessage()); // 弹出错误信息
|
||
}
|
||
return false;
|
||
}
|
||
|
||
|
||
/**
|
||
* 安全保存提现记录，具备字段溢出与表结构自动修复能力
|
||
*/
|
||
protected function saveWithdrawSafe($withdraw)
|
||
{
|
||
try {
|
||
$withdraw->save();
|
||
} catch (\Exception $e) {
|
||
$msg = $e->getMessage();
|
||
if (stripos($msg, '22001') !== false || stripos($msg, '1406') !== false || stripos($msg, 'too long') !== false) {
|
||
$prefix = config('database.prefix') ?: 'hla_';
|
||
try {
|
||
\think\Db::execute("ALTER TABLE `{$prefix}shopro_withdraw` MODIFY COLUMN `withdraw_info` text NULL COMMENT '提现信息'");
|
||
\think\Db::execute("ALTER TABLE `{$prefix}shopro_withdraw` MODIFY COLUMN `charge_rate` decimal(10, 4) NOT NULL DEFAULT '0.0000' COMMENT '手续费率'");
|
||
\think\Db::execute("ALTER TABLE `{$prefix}shopro_withdraw` MODIFY COLUMN `platform` varchar(50) NULL DEFAULT NULL COMMENT '平台'");
|
||
\think\Db::execute("ALTER TABLE `{$prefix}shopro_withdraw_log` MODIFY COLUMN `content` text NULL COMMENT '日志内容'");
|
||
$withdraw->save();
|
||
return $withdraw;
|
||
} catch (\Exception $subEx) {
|
||
// 若 DDL 无权限或执行失败，执行结构化降级精简以确保提现不中断
|
||
$info = $withdraw->withdraw_info;
|
||
if (is_array($info)) {
|
||
$compact = [
|
||
'real_name' => $info['真实姓名'] ?? ($info['real_name'] ?? ''),
|
||
'bank_name' => $info['开户行'] ?? ($info['bank_name'] ?? ''),
|
||
'card_no' => $info['银行卡号'] ?? ($info['card_no'] ?? ''),
|
||
'wallet_type' => $info['wallet_type'] ?? 'madow',
|
||
'madow_amount' => $info['madow_amount'] ?? '',
|
||
'rate' => $info['rate'] ?? 0,
|
||
'charge_fee' => $info['charge_fee'] ?? 0,
|
||
'charge_rate' => $info['charge_rate'] ?? 0,
|
||
];
|
||
$withdraw->withdraw_info = $compact;
|
||
$withdraw->save();
|
||
return $withdraw;
|
||
}
|
||
throw $e;
|
||
}
|
||
}
|
||
throw $e;
|
||
}
|
||
return $withdraw;
|
||
}
|
||
|
||
// 添加日志
|
||
private function handleLog($withdraw, $oper_info, $oper = null)
|
||
{
|
||
$oper = Operator::get($oper);
|
||
|
||
try {
|
||
WithdrawLogModel::insert([
|
||
'withdraw_id' => $withdraw->id,
|
||
'content' => $oper_info,
|
||
'oper_type' => $oper['type'],
|
||
'oper_id' => $oper['id'],
|
||
'createtime' => time()
|
||
]);
|
||
} catch (\Exception $e) {
|
||
$msg = $e->getMessage();
|
||
if (stripos($msg, '22001') !== false || stripos($msg, '1406') !== false || stripos($msg, 'too long') !== false) {
|
||
$prefix = config('database.prefix') ?: 'hla_';
|
||
try {
|
||
\think\Db::execute("ALTER TABLE `{$prefix}shopro_withdraw_log` MODIFY COLUMN `content` text NULL COMMENT '日志内容'");
|
||
} catch (\Exception $ignored) {}
|
||
WithdrawLogModel::insert([
|
||
'withdraw_id' => $withdraw->id,
|
||
'content' => mb_substr($oper_info, 0, 80, 'UTF-8'),
|
||
'oper_type' => $oper['type'],
|
||
'oper_id' => $oper['id'],
|
||
'createtime' => time()
|
||
]);
|
||
} else {
|
||
throw $e;
|
||
}
|
||
}
|
||
return $withdraw;
|
||
}
|
||
|
||
|
||
// 提现条件检查
|
||
private function checkApply($type, $money, $charge, $walletType = 'money')
|
||
{
|
||
if (isset($this->config['status']) && intval($this->config['status']) === 0) {
|
||
throw new ShoproException('系统提现功能已关闭');
|
||
}
|
||
|
||
if (empty($this->config['methods'])) {
|
||
throw new ShoproException('暂未开启任何提现方式');
|
||
}
|
||
|
||
if (!in_array($type, $this->config['methods'])) {
|
||
throw new ShoproException('暂不支持该提现方式');
|
||
}
|
||
|
||
if (!is_numeric($money) || floatval($money) <= 0) {
|
||
throw new ShoproException('请输入正确的提现金额');
|
||
}
|
||
|
||
$floatMoney = floatval($money);
|
||
// 提现金额必须为整数且为 100 的整数倍（如 100、200、1200 等）
|
||
if (floor($floatMoney) != $floatMoney || (intval($floatMoney) % 100 !== 0)) {
|
||
throw new ShoproException('提现金额必须为100的整数倍');
|
||
}
|
||
|
||
// 检查最小提现金额
|
||
if ($this->config['min_amount'] > 0 && $money < $this->config['min_amount']) {
|
||
throw new ShoproException('提现金额不能少于 ' . $this->config['min_amount'] . '元');
|
||
}
|
||
// 检查最大提现金额
|
||
if ($this->config['max_amount'] > 0 && $money > $this->config['max_amount']) {
|
||
throw new ShoproException('提现金额不能大于 ' . $this->config['max_amount'] . '元');
|
||
}
|
||
|
||
if ($walletType === 'money') {
|
||
if (bccomp((string)($this->user->money ?? 0), (string)$money, 2) < 0) {
|
||
throw new ShoproException('商城可用余额不足');
|
||
}
|
||
} else {
|
||
if (bccomp((string)($this->user->commission ?? 0), (string)$money, 2) < 0) {
|
||
throw new ShoproException('可提现佣金不足');
|
||
}
|
||
}
|
||
|
||
$realAmount = bcsub($money, $charge, 2);
|
||
if (bccomp($realAmount, '0.00', 2) <= 0) {
|
||
throw new ShoproException('扣除手续费后实际到账金额必须大于0元');
|
||
}
|
||
|
||
// 检查最大提现次数
|
||
if (isset($this->config['max_num']) && $this->config['max_num'] > 0) {
|
||
$start_time = $this->config['num_unit'] == 'day' ? strtotime(date('Y-m-d', time())) : strtotime(date('Y-m', time()));
|
||
|
||
$num = WithdrawModel::where('user_id', $this->user->id)->where('createtime', '>=', $start_time)->count();
|
||
|
||
if ($num >= $this->config['max_num']) {
|
||
throw new ShoproException('每' . ($this->config['num_unit'] == 'day' ? '日' : '月') . '提现次数不能大于 ' . $this->config['max_num'] . '次');
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
// 获取提现账户信息
|
||
private function getAccountInfo($type, $params)
|
||
{
|
||
$platform = request()->header('platform');
|
||
|
||
switch ($type) {
|
||
case 'wechat':
|
||
if ($platform == 'App') {
|
||
$platform = 'openPlatform';
|
||
} elseif (in_array($platform, ['WechatOfficialAccount', 'WechatMiniProgram'])) {
|
||
$platform = lcfirst(str_replace('Wechat', '', $platform));
|
||
}
|
||
$thirdOauth = ThirdOauth::where('provider', 'wechat')->where('platform', $platform)->where('user_id', $this->user->id)->find();
|
||
if (!$thirdOauth) {
|
||
throw new ShoproException('请先绑定微信账号', -1);
|
||
}
|
||
$withdrawInfo = [
|
||
'真实姓名' => $params['account_name'],
|
||
'微信用户' => $thirdOauth['nickname'] ?: $this->user['nickname'],
|
||
'微信ID' => $thirdOauth['openid'],
|
||
];
|
||
break;
|
||
case 'alipay':
|
||
$withdrawInfo = [
|
||
'真实姓名' => $params['account_name'],
|
||
'支付宝账户' => $params['account_no']
|
||
];
|
||
break;
|
||
case 'bank':
|
||
$withdrawInfo = [
|
||
'真实姓名' => $params['account_name'],
|
||
'开户行' => $params['account_header'] ?? '',
|
||
'银行卡号' => $params['account_no']
|
||
];
|
||
break;
|
||
}
|
||
if (!isset($withdrawInfo)) {
|
||
throw new ShoproException('您的提现信息有误');
|
||
}
|
||
|
||
return $withdrawInfo;
|
||
}
|
||
}
|