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['提现资产']) && in_array($info['提现资产'], ['钱包余额', '商城余额'], true)); 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['提现资产']) && in_array($info['提现资产'], ['钱包余额', '商城余额'], true)); 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; } }