714 lines
28 KiB
PHP
714 lines
28 KiB
PHP
<?php
|
||
/**
|
||
* Created by PhpStorm.
|
||
*
|
||
* User: king/QQ：995265288
|
||
* Date: 2018/5/31 下午2:40
|
||
* Email: livsyitian@163.com
|
||
*/
|
||
|
||
namespace app\frontend\modules\withdraw\controllers;
|
||
|
||
|
||
use app\common\components\ApiController;
|
||
use app\common\events\withdraw\WithdrawAppliedEvent;
|
||
use app\common\events\withdraw\WithdrawApplyEvent;
|
||
use app\common\events\withdraw\WithdrawApplyingEvent;
|
||
use app\common\exceptions\AppException;
|
||
use app\common\facades\Setting;
|
||
use app\common\listeners\income\WithdrawPayedListener;
|
||
use app\common\models\Income;
|
||
use app\common\models\income\WithdrawIncomeApply;
|
||
use app\common\models\IncomeFreezeSet;
|
||
use app\common\services\income\IncomeService;
|
||
use app\common\services\income\WithdrawIncomeApplyService;
|
||
use app\common\services\income\WithdrawIncomeDeductionService;
|
||
use app\frontend\modules\withdraw\models\Withdraw;
|
||
use app\frontend\modules\withdraw\services\WithdrawConfig;
|
||
use Illuminate\Support\Facades\DB;
|
||
use Illuminate\Support\Facades\Log;
|
||
use app\frontend\modules\withdraw\services\StatisticalPresentationService;
|
||
use app\common\helpers\Url;
|
||
use Yunshop\Commission\models\Agents;
|
||
use app\common\models\WithdrawMergeServicetaxRate;
|
||
use Yunshop\Love\Common\Services\CommonService;
|
||
use Yunshop\ShareholderDividend\models\ShareholderDividendModel;
|
||
use Yunshop\WithdrawalLimit\Common\models\MemberWithdrawalLimit;
|
||
use app\common\services\finance\Withdraw as WithdrawService;
|
||
|
||
class ApplyController extends ApiController
|
||
{
|
||
private $withdraw_set;
|
||
|
||
/**
|
||
* @var static
|
||
*/
|
||
private $pay_way;
|
||
|
||
/**
|
||
* @var double
|
||
*/
|
||
private $amount;
|
||
|
||
/**
|
||
* @var double
|
||
*/
|
||
private $poundage;
|
||
|
||
|
||
/**
|
||
* @var array
|
||
*/
|
||
private $withdraw_data;
|
||
|
||
private $withdraw_config;
|
||
|
||
private $need_deduction_love_data;//需要扣除爱心值的参数
|
||
|
||
|
||
public function __construct()
|
||
{
|
||
parent::__construct();
|
||
|
||
$this->withdraw_set = $this->getWithdrawSet();
|
||
}
|
||
|
||
//提现接口
|
||
public function index()
|
||
{
|
||
$this->withdrawLimitation();
|
||
[$amount, $pay_way, $poundage, $withdraw_data] = $this->getPostValue();
|
||
$this->amount = $amount;
|
||
$this->pay_way = $pay_way;
|
||
$this->poundage = $poundage;
|
||
$this->withdraw_data = $withdraw_data;
|
||
$this->validatePayWay();
|
||
//提现数据验证
|
||
$this->validateData();
|
||
//提现限额判断
|
||
$this->cashLimitation();
|
||
//提现额度插件判断
|
||
$this->withdrawalLimitation();
|
||
//提现扣除爱心值验证
|
||
$this->validateWithdrawDeductionLove();
|
||
//插入提现
|
||
$result = $this->withdrawStart();
|
||
|
||
|
||
if ($result === true) {
|
||
return $this->successJson($this->successMessage());
|
||
}
|
||
return $this->errorJson($result ?: $this->withdrawalName() . '申请失败');
|
||
}
|
||
|
||
public function validatePayWay()
|
||
{
|
||
$types = array_unique(array_column($this->withdraw_data,'type'));
|
||
if (!$types) {
|
||
return $this->errorJson('提现类型错误!');
|
||
}
|
||
foreach ($types as $type) {
|
||
$withdrawConfig = $this->withdrawConfig($type);
|
||
if (!$withdrawConfig || !$withdrawConfig->checkPayWay($this->pay_way)) {
|
||
return $this->errorJson('该提现方式已关闭!');
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @param $type
|
||
* @return mixed
|
||
*/
|
||
private function withdrawConfig($type)
|
||
{
|
||
if (!isset($this->withdraw_config)) {
|
||
$this->withdraw_config = collect(WithdrawConfig::current()->get('withdraw_apply') ? : []);
|
||
}
|
||
$config = $this->withdraw_config->where('income_type',$type)->first();
|
||
if (!$config) {
|
||
$config = $this->withdraw_config->where('income_type','common')->first();
|
||
}
|
||
return call_user_func($config['class']);
|
||
}
|
||
|
||
//如果设置赠送说明，优先使用赠送说明
|
||
private function successMessage()
|
||
{
|
||
if ($explain = $this->withdrawalExplain()) {
|
||
return str_replace('[奖励余额]', $this->awardBalance(), $explain);
|
||
}
|
||
return $this->withdrawalName() . '申请成功，预计到账时间T+2';
|
||
}
|
||
|
||
private function validateWithdrawDeductionLove()
|
||
{
|
||
$this->need_deduction_love_data = [];
|
||
if (app('plugins')->isEnabled('love') && \Setting::get('love.withdraw_deduction_status')) {
|
||
$withdraw_deduction_type = \Setting::get('love.withdraw_deduction_type');
|
||
if ($withdraw_deduction_type == 2) {
|
||
$loveName = \Setting::get('love.unable_name') ?: '冻结爱心值';
|
||
$loveValue = CommonService::getMemberFrozeLove(\YunShop::app()->getMemberId());//冻结爱心值
|
||
$loveSign = 'froze';
|
||
} else {
|
||
$loveName = \Setting::get('love.usable_name') ?: '可用爱心值';
|
||
$loveValue = CommonService::getMemberUsableLove(\YunShop::app()->getMemberId());//可用爱心值
|
||
$loveSign = 'usable';
|
||
}
|
||
|
||
$withdraw_deduction_love_rate = \Setting::get('love.withdraw_deduction_love_rate');
|
||
$deductionLove = proportionMath($this->amount,$withdraw_deduction_love_rate);//需要扣除的爱心值
|
||
if (bccomp($deductionLove,$loveValue,2) == 1) {
|
||
return $this->errorJson('提现需扣除' . $deductionLove . $loveName . ',您的' . $loveName . '不足');
|
||
}
|
||
|
||
if (!empty($withdraw_deduction_love_rate)) {
|
||
$this->need_deduction_love_data = [
|
||
'rate' => $withdraw_deduction_love_rate,
|
||
'love_sign' => $loveSign,
|
||
];
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 奖励余额
|
||
*
|
||
* @return string
|
||
*/
|
||
private function awardBalance()
|
||
{
|
||
return (new WithdrawPayedListener())->awardValue($this->pay_way, $this->amount);
|
||
}
|
||
|
||
/**
|
||
* 余额设置-》收入提现赠送说明
|
||
*
|
||
* @return string
|
||
*/
|
||
private function withdrawalExplain()
|
||
{
|
||
return Setting::get('finance.balance.income_withdraw_award_explain');
|
||
}
|
||
|
||
/**
|
||
* "提现" 字样自定名称
|
||
*
|
||
* @return string
|
||
*/
|
||
private function withdrawalName()
|
||
{
|
||
$setting = Setting::get('shop.lang.zh_cn.income');
|
||
|
||
return $setting['name_of_withdrawal'] ? $setting['name_of_withdrawal'] : '提现';
|
||
}
|
||
|
||
private function cashLimitation()
|
||
{
|
||
$set = Setting::get('withdraw.income');
|
||
|
||
//提交提现的次数
|
||
$number_of_submissions = count($this->withdraw_data);
|
||
|
||
if ($this->pay_way == 'wechat') {
|
||
$wechat_frequency = floor($set['wechat_frequency'] ?: 10);
|
||
//统计用户今天提现的次数
|
||
$statisticalPresentationService = new StatisticalPresentationService;
|
||
$today_withdraw_count = $statisticalPresentationService->statisticalPresentation('wechat');
|
||
|
||
if (($number_of_submissions + $today_withdraw_count) > $wechat_frequency) {
|
||
\Log::debug('提现到微信失败', ['今天提现次数', $today_withdraw_count, '本次提现次数', $number_of_submissions, '每日限制次数', $wechat_frequency]);
|
||
return $this->errorJson('提现失败,每日提现到微信次数不能超过' . $wechat_frequency . '次');
|
||
}
|
||
} elseif ($this->pay_way == 'alipay') {
|
||
$alipay_frequency = floor($set['alipay_frequency'] ?: 10);
|
||
//统计用户今天提现的次数 + 供应商提现的次数
|
||
$statisticalPresentationService = new StatisticalPresentationService;
|
||
$today_withdraw_count = $statisticalPresentationService->statisticalPresentation('alipay');
|
||
if (($number_of_submissions + $today_withdraw_count) > $alipay_frequency) {
|
||
\Log::debug('提现到支付宝失败', ['今天提现次数', $today_withdraw_count, '本次提现次数', $number_of_submissions, '每日限制次数', $alipay_frequency]);
|
||
return $this->errorJson('提现失败,每日提现到支付宝次数不能超过' . $alipay_frequency . '次');
|
||
|
||
}
|
||
} elseif ($this->pay_way == 'converge_pay') {
|
||
$converge_frequency = floor($set['converge_pay_frequency'] ?: 0);
|
||
if ($converge_frequency){
|
||
//统计用户今天提现的次数 + 供应商提现的次数
|
||
$statisticalPresentationService = new StatisticalPresentationService;
|
||
$today_withdraw_count = $statisticalPresentationService->statisticalPresentation('converge_pay');
|
||
if (($number_of_submissions + $today_withdraw_count) > $converge_frequency) {
|
||
\Log::debug('提现到汇聚失败', ['今天提现次数', $today_withdraw_count, '本次提现次数', $number_of_submissions, '每日限制次数', $converge_frequency]);
|
||
return $this->errorJson('提现失败,每日提现到汇聚次数不能超过' . $converge_frequency . '次');
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
private function withdrawalLimitation()
|
||
{
|
||
if (app('plugins')->isEnabled('withdrawal-limit')) {
|
||
$set = \Setting::get('withdrawal-limit.is_open');
|
||
if ($set != 1 || !in_array($this->pay_way, MemberWithdrawalLimit::$payWays)) {
|
||
return;
|
||
}
|
||
$ways = json_decode(\Setting::get('withdrawal-limit.way'), true);
|
||
$mark = false;
|
||
switch ($this->pay_way) {
|
||
case Withdraw::WITHDRAW_WITH_ALIPAY:
|
||
if ($ways['alipay'] == 1) {
|
||
$mark = true;
|
||
}
|
||
break;
|
||
case Withdraw::WITHDRAW_WITH_WECHAT:
|
||
if ($ways['wechat'] == 1) {
|
||
$mark = true;
|
||
}
|
||
break;
|
||
case Withdraw::WITHDRAW_WITH_MANUAL:
|
||
if ($ways['bankcard'] == 1) {
|
||
$mark = true;
|
||
}
|
||
break;
|
||
}
|
||
if ($mark) {
|
||
$memberModel = MemberWithdrawalLimit::uniacid()->where('member_id', \YunShop::app()->getMemberId())->first();
|
||
if ($memberModel) {
|
||
$limit = $memberModel->total_amount;
|
||
} else {
|
||
$limit = 0;
|
||
}
|
||
if ($this->amount > $limit) {
|
||
return $this->errorJson('当前提现额度不足，暂不能提现');
|
||
}
|
||
}
|
||
}
|
||
if (app('plugins')->isEnabled('high-light') && in_array($this->pay_way, [
|
||
Withdraw::WITHDRAW_WITH_HIGH_LIGHT_WECHAT,
|
||
Withdraw::WITHDRAW_WITH_HIGH_LIGHT_ALIPAY,
|
||
Withdraw::WITHDRAW_WITH_HIGH_LIGHT_BANK
|
||
])) {
|
||
try {
|
||
if ($this->amount < 1) {
|
||
throw new \Exception('高灯提现金额必须大于等于1元');
|
||
}
|
||
switch ($this->pay_way) {
|
||
case Withdraw::WITHDRAW_WITH_HIGH_LIGHT_WECHAT:
|
||
if ($this->amount > 100000) {
|
||
throw new \Exception('高灯微信单笔提现不得大于10万元！');
|
||
}
|
||
break;
|
||
case Withdraw::WITHDRAW_WITH_HIGH_LIGHT_ALIPAY:
|
||
if ($this->amount > 400000) {
|
||
throw new \Exception('高灯微信单笔提现不得大于40万元！');
|
||
}
|
||
break;
|
||
case Withdraw::WITHDRAW_WITH_HIGH_LIGHT_BANK:
|
||
if ($this->amount > 100000) {
|
||
throw new \Exception('高灯银行卡单笔提现不得大于10万元！');
|
||
}
|
||
break;
|
||
}
|
||
} catch (\Exception $e) {
|
||
return $this->errorJson($e->getMessage());
|
||
}
|
||
}
|
||
}
|
||
|
||
private function withdrawLimitation()
|
||
{
|
||
if (app('plugins')->isEnabled('commission')) {
|
||
$set = \Setting::get('plugin.commission');
|
||
$agent = Agents::uniacid()->where('member_id', \YunShop::app()->getMemberId())->with('agentLevel')->first();
|
||
if (!$agent->agent_level_id) {
|
||
if ($set['no_withdraw']) {
|
||
return $this->errorJson('不满足分销商等级，不可提现', ['status' => 0]);
|
||
}
|
||
} else {
|
||
if ($agent->agentLevel->no_withdraw) {
|
||
return $this->errorJson('不满足分销商等级，不可提现', ['status' => 0]);
|
||
}
|
||
}
|
||
}
|
||
$this->validateWithdrawDate();
|
||
}
|
||
|
||
private function withdrawStart()
|
||
{
|
||
try {
|
||
|
||
DB::transaction(function () {
|
||
$this->_withdrawStart();
|
||
});
|
||
return true;
|
||
|
||
} catch (\Exception $exception) {
|
||
throw $exception;
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* @return bool
|
||
* @throws AppException|
|
||
*/
|
||
private function _withdrawStart()
|
||
{
|
||
$amount = '0';
|
||
|
||
if (count($this->withdraw_data) > 1) { // 如果同时提现几种类型的收入并且后台设置了劳务税金额梯度比例，劳务税按金额总和计算
|
||
if ($this->withdraw_set['servicetax']) {
|
||
$merge_servicetax_withdraw_id = []; //劳务税id
|
||
$merge_servicetax_amount = 0; //劳务税计算金额
|
||
}
|
||
}
|
||
$uid = \YunShop::app()->getMemberId();
|
||
$incomeFreezeSet = IncomeFreezeSet::getInfo($uid);
|
||
$totalFreezeMoney = 0;// 总冻结金额
|
||
foreach ($this->withdraw_data as $key => $item) {
|
||
// 冻结金额处理
|
||
$currentFreezeSet = $incomeFreezeSet[$item['key_name']]['set_info'] ?? [];
|
||
if($currentFreezeSet['freeze_type'] == 1){
|
||
// 独立设置
|
||
$levelList = $currentFreezeSet['level_list'] ?? [];
|
||
$lvAmountList = ShareholderDividendModel::getIncome((int)$uid,(int)0,'undrawn')
|
||
->select([
|
||
'yz_shareholder_dividend.team_level',
|
||
DB::raw("sum(ims_yz_member_income.amount) as lv_sum_amount,GROUP_CONCAT(ims_yz_member_income.id) AS ids")
|
||
])
|
||
->groupBy('yz_shareholder_dividend.team_level')
|
||
->get()
|
||
->toArray();
|
||
$item['freeze_money'] = 0;
|
||
$typeId = explode(',',$item['type_id']);
|
||
foreach($lvAmountList as $lvAmountInfo){
|
||
// 当前等级设置的冻结金额
|
||
$lvSetFreezeMoney = $levelList[$lvAmountInfo['team_level']]['freeze_money'] ?? 0;
|
||
// 判断：当前等级存在冻结金额 且该等级提现佣金小于等于冻结金额，冻结金额为0且不提现该等级佣金
|
||
if($lvSetFreezeMoney > 0 && $lvAmountInfo['lv_sum_amount'] <= $lvSetFreezeMoney){
|
||
// 当前等级佣金不提现
|
||
$item['income'] = (float)$item['income'] - (float)$lvAmountInfo['lv_sum_amount'];// 减少当前提现金额
|
||
$this->amount = $this->amount - (float)$lvAmountInfo['lv_sum_amount'];// 减少当前总提现金额
|
||
$typeId = array_diff($typeId,explode(',',$lvAmountInfo['ids']));
|
||
}else{
|
||
$item['freeze_money'] += $lvSetFreezeMoney;
|
||
}
|
||
}
|
||
|
||
$item['type_id'] = implode(',',$typeId);
|
||
}else{
|
||
// 统一设置
|
||
$item['freeze_money'] = $currentFreezeSet['total'];
|
||
}
|
||
|
||
// 提交金额处理
|
||
$withdrawModel = new Withdraw();
|
||
$withdrawModel->mark = $item['key_name'];
|
||
$withdrawModel->withdraw_set = $this->withdraw_set;
|
||
$withdrawModel->income_set = $this->getIncomeSet($item['key_name']);
|
||
$withdrawModel->fill($this->getWithdrawData($item));
|
||
event(new WithdrawApplyEvent($withdrawModel));
|
||
$validator = $withdrawModel->validator();
|
||
if ($validator->fails()) throw new AppException("ERROR:Data anomaly -- {$item['key_name']}::{$validator->messages()->first()}");
|
||
event(new WithdrawApplyingEvent($withdrawModel));
|
||
if (!$withdrawModel->save()) {
|
||
throw new AppException("ERROR:Data storage exception -- {$item['key_name']}");
|
||
}
|
||
//判断收入是否已提现
|
||
$apply_count = WithdrawIncomeApply::whereIn('income_id', array_filter(explode(',', $item['type_id'])))->whereIn('status', [0, 1, -1])->lockForUpdate()->count();
|
||
if ($apply_count > 0) {
|
||
throw new AppException("ERROR:Data storage exception repeat-- {$item['key_name']}");
|
||
}
|
||
//插入提现收入申请表
|
||
if (!WithdrawIncomeApplyService::insert($withdrawModel)) {
|
||
throw new AppException("ERROR:Data storage exception -- {$item['key_name']}");
|
||
}
|
||
//插入提现收入扣除爱心值记录
|
||
if (!empty($this->need_deduction_love_data) && !WithdrawIncomeDeductionService::insert($withdrawModel,$this->need_deduction_love_data,proportionMath($withdrawModel->amounts,$this->need_deduction_love_data['rate']))) {
|
||
throw new AppException("ERROR:Data2 storage exception -- {$item['key_name']}");
|
||
}
|
||
|
||
app('plugins')->isEnabled('converge_pay') && $this->withdraw_set['free_audit'] == 1 && $this->pay_way == 'converge_pay' ? \Setting::set('plugin.convergePay_set.notifyWithdrawUrl', Url::shopSchemeUrl('payment/convergepay/notifyUrlWithdraw.php')) : null;
|
||
event(new WithdrawAppliedEvent($withdrawModel));
|
||
|
||
$amount = bcadd($amount, $withdrawModel->amounts, 2);
|
||
|
||
if (isset($merge_servicetax_withdraw_id)
|
||
&& !in_array($item['key_name'], ['StoreCashier', 'StoreWithdraw', 'StoreBossWithdraw'])
|
||
&& ($withdrawModel->pay_way != 'balance' || !$this->withdraw_set['balance_special'])) { //统计需要劳务税的基本计算金额
|
||
|
||
$merge_servicetax_withdraw_id[] = $withdrawModel->id;
|
||
$this_servicetax_amount = !$this->withdraw_set['service_tax_calculation'] ? bcsub($withdrawModel->amounts, $withdrawModel->poundage, 2) : $withdrawModel->amounts;
|
||
if (bccomp($this_servicetax_amount, 0, 2) != 1) $this_servicetax_amount = 0;
|
||
$merge_servicetax_amount = bcadd($merge_servicetax_amount, $this_servicetax_amount, 2);
|
||
}
|
||
|
||
|
||
$totalFreezeMoney += $withdrawModel->freeze_money;
|
||
}
|
||
|
||
if (!empty($merge_servicetax_withdraw_id)) {
|
||
$service_tax_data = WithdrawService::getWithdrawServicetaxPercent($merge_servicetax_amount, $withdrawModel);
|
||
if (bccomp($service_tax_data['servicetax_percent'], 0, 2) == 1) {
|
||
$time = time();
|
||
foreach ($merge_servicetax_withdraw_id as $v) {
|
||
$service_tax_insert_data[] = [
|
||
'uniacid' => \YunShop::app()->uniacid,
|
||
'withdraw_id' => $v,
|
||
'servicetax_rate' => $service_tax_data['servicetax_percent'],
|
||
'created_at' => $time,
|
||
'updated_at' => $time
|
||
];
|
||
}
|
||
WithdrawMergeServicetaxRate::insert($service_tax_insert_data);
|
||
}
|
||
}
|
||
|
||
$realMoney = bcadd($amount, $totalFreezeMoney, 2);
|
||
if (bccomp($realMoney, $this->amount, 2) != 0) {
|
||
throw new AppException('提现失败：提现金额错误');
|
||
}
|
||
return true;
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
|
||
/**
|
||
* @param $withdraw_item
|
||
* @return array
|
||
* @throws AppException
|
||
*/
|
||
private function getWithdrawData($withdraw_item)
|
||
{
|
||
// 判断：如果存在冻结金额 减少冻结金额
|
||
$freezeMoney = $withdraw_item['freeze_money'] ?? 0;
|
||
$withdraw_item['income'] = (float)$withdraw_item['income'] - (float)$freezeMoney;
|
||
|
||
|
||
|
||
$set = Setting::get('withdraw.commission');
|
||
if ($set['max_roll_out_limit'] && $set['max_roll_out_limit'] > 0) {
|
||
$amounts = isset($withdraw_item['can_amount']) ? $withdraw_item['can_amount'] : $withdraw_item['income'];
|
||
}else {
|
||
$amounts = $withdraw_item['income'];
|
||
}
|
||
return [
|
||
'withdraw_sn' => Withdraw::createOrderSn('WS', 'withdraw_sn'),
|
||
'uniacid' => \YunShop::app()->uniacid,
|
||
'member_id' => $this->getMemberId(),
|
||
'key_name' => $withdraw_item['key_name'],
|
||
'type' => $withdraw_item['type'],
|
||
'type_name' => $withdraw_item['type_name'],
|
||
'type_id' => $withdraw_item['type_id'],
|
||
'amounts' => $amounts,
|
||
'poundage' => '0.00',
|
||
'poundage_rate' => '0.00',
|
||
'poundage_type' => $withdraw_item['poundage_type'] ?: 0,
|
||
'actual_poundage' => '0.00',
|
||
'actual_amounts' => '0.00',
|
||
'servicetax' => '0.00',
|
||
'servicetax_rate' => '0.00',
|
||
'actual_servicetax' => '0.00',
|
||
'pay_way' => $this->pay_way,
|
||
'manual_type' => !empty($this->withdraw_set['manual_type']) ? $this->withdraw_set['manual_type'] : 1,
|
||
'status' => Withdraw::STATUS_INITIAL,
|
||
'audit_at' => null,
|
||
'pay_at' => null,
|
||
'arrival_at' => null,
|
||
'created_at' => time(),
|
||
'updated_at' => time(),
|
||
'freeze_money' => $freezeMoney,
|
||
];
|
||
}
|
||
|
||
|
||
/**
|
||
* 提现对应收入设置
|
||
*
|
||
* @param $mark
|
||
* @return array
|
||
*/
|
||
private function getIncomeSet($mark)
|
||
{
|
||
return Setting::get('withdraw.' . $mark);
|
||
}
|
||
|
||
|
||
/**
|
||
* 提现设置
|
||
*
|
||
* @return array
|
||
*/
|
||
private function getWithdrawSet()
|
||
{
|
||
return Setting::get('withdraw.income');
|
||
}
|
||
|
||
|
||
/**
|
||
* @return array
|
||
* @throws AppException
|
||
*/
|
||
private function getPostValue()
|
||
{
|
||
$post_data = \YunShop::request()->data;
|
||
Log::info('收入提现提交数据：', [$post_data]);
|
||
//$post_data = $this->testData();
|
||
|
||
!is_array($post_data) && $post_data = json_decode($post_data, true);
|
||
|
||
if (!$post_data) {
|
||
throw new AppException('Undetected submission of data');
|
||
}
|
||
// 12月20号修改 提现原代码是提现金额不能小于1元
|
||
if ($post_data['total']['amounts'] < 0) {
|
||
throw new AppException('提现金额不能小于0元');
|
||
}
|
||
|
||
$amount = $post_data['total']['amounts'];
|
||
$pay_way = $post_data['total']['pay_way'];
|
||
$poundage = $post_data['total']['poundage'];
|
||
$withdraw_data = $post_data['withdrawal'];
|
||
|
||
return [$amount, $pay_way, $poundage, $withdraw_data];
|
||
}
|
||
|
||
|
||
/**
|
||
* @return int
|
||
* @throws AppException
|
||
*/
|
||
private function getMemberId()
|
||
{
|
||
$member_id = \YunShop::app()->getMemberId();
|
||
|
||
if (!$member_id) {
|
||
throw new AppException('Please log in');
|
||
}
|
||
return $member_id;
|
||
}
|
||
|
||
|
||
private function testData()
|
||
{
|
||
$data = [
|
||
'total' => [
|
||
'amounts' => 1816.01,
|
||
'poundage' => 181.6,
|
||
'pay_way' => 'balance',
|
||
],
|
||
'withdrawal' => [
|
||
[
|
||
'type' => 'Yunshop\ConsumeReturn\common\models\Log',
|
||
'key_name' => 'consumeReturn',
|
||
'type_name' => '消费返现',
|
||
'type_id' => '7223,7319,7408,7477,7605,7680,7808,7881,7973,8048,8137,8205,8274,8401,8535,8670,8721,8805,8877,9030,9145,9237,9325,9403,9477,9554,9755,9837,9919,10012,10101,10184,10374,10528,10650,10760,10858',
|
||
'income' => '12032.92',
|
||
'poundage' => '12.03',
|
||
'poundage_rate' => '0.1',
|
||
'servicetax' => '1202.08',
|
||
'servicetax_rate' => '10',
|
||
'can' => '1',
|
||
'roll_out_limit' => '0',
|
||
'selected' => 1,
|
||
],
|
||
[
|
||
'type' => 'Yunshop\LevelReturn\models\LevelReturnModel',
|
||
'key_name' => 'levelReturn',
|
||
'type_name' => '等级返现',
|
||
'type_id' => '7426,7481,7556,7883,7884,7885,7886,8222,8223,8224,8281,8360,8552,8895,8954,8955,8956,8957,9107,9621,10598,10599,10784,10785,10786,10989',
|
||
'income' => '20241.59',
|
||
'poundage' => '20.24',
|
||
'poundage_rate' => '0.1',
|
||
'servicetax' => '2022.13',
|
||
'servicetax_rate' => '10',
|
||
'can' => '1',
|
||
'roll_out_limit' => '10',
|
||
'selected' => 1,
|
||
]
|
||
]
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
private function validateData()
|
||
{
|
||
$member_id = $this->getMemberId();
|
||
//对比提现的收入记录是否属于该会员
|
||
foreach ($this->withdraw_data as &$withdraw) {
|
||
$income_ids = array_filter(explode(',', $withdraw['type_id']));
|
||
if ($withdraw['type'] == 'Yunshop\Commission\models\CommissionOrder') {
|
||
$set = Setting::get('withdraw.commission');
|
||
if ($set['max_roll_out_limit'] && $set['max_roll_out_limit'] > 0) {
|
||
$incomes = Income::where('member_id', $member_id)->whereIn('id', $income_ids)->orderBy('amount', 'desc')->get()->toArray();
|
||
$amount = $this->getToDayAmount();
|
||
$amount_c = $this->getToDayAmount();
|
||
$income_ids = [];
|
||
foreach ($incomes as $item) {
|
||
if ($amount > $set['max_roll_out_limit']) {
|
||
break;
|
||
}
|
||
$amount_c = bcadd($item['amount'], $amount_c, 2);;
|
||
if ($amount_c > $set['max_roll_out_limit']) {
|
||
$amount_c = $amount;
|
||
continue;
|
||
}
|
||
$amount = $amount_c;
|
||
$income_ids[] = $item['id'];
|
||
}
|
||
if (count($income_ids) < 1) {
|
||
return $this->errorJson('无满足提现要求的收入');
|
||
}
|
||
$withdraw['type_id'] = implode(',', $income_ids);
|
||
}
|
||
}
|
||
$income_count = Income::where('member_id', $member_id)->whereIn('id', $income_ids)->count();
|
||
//判断收入是否已提现
|
||
$apply_count = WithdrawIncomeApply::whereIn('income_id', $income_ids)->whereIn('status', [0, 1, -1])->count();
|
||
if ($income_count != count($income_ids) || $apply_count > 0) {
|
||
return $this->errorJson('提现数据错误');
|
||
}
|
||
}
|
||
}
|
||
|
||
private function validateWithdrawDate()
|
||
{
|
||
$income_set = \Setting::get('withdraw.income');
|
||
$disable = 0;
|
||
$day_msg = '无提现限制';
|
||
if (is_array($income_set['withdraw_date'])) {
|
||
$day = date('d');
|
||
$day_msg = '可提现日期为：' . implode(',', $income_set['withdraw_date']) . '号';
|
||
$disable = 1;
|
||
foreach ($income_set['withdraw_date'] as $date) {
|
||
if ($day == $date) {
|
||
$disable = 0;
|
||
break;
|
||
}
|
||
if ($day < $date) {
|
||
$disable = 1;
|
||
}
|
||
|
||
|
||
}
|
||
}
|
||
if ($disable == 1) {
|
||
return $this->errorJson($day_msg, ['status' => 0]);
|
||
}
|
||
}
|
||
|
||
private function getToDayAmount() {
|
||
$before_dawn = mktime(0, 0, 0, date("m"), date("d"), date("Y"));
|
||
$now = time();
|
||
$max_amount = Withdraw::where('type', 'Yunshop\Commission\models\CommissionOrder')
|
||
->where('member_id', \YunShop::app()->getMemberId())
|
||
->whereBetween('created_at', [$before_dawn, $now])
|
||
->whereIn('status', [0, 1, 2, 4])
|
||
->sum('amounts');
|
||
|
||
return $max_amount ?: 0;
|
||
}
|
||
}
|