<?php
|
|
namespace app\admin\controller;
|
|
use think\facade\Db;
|
use think\facade\Request;
|
use think\facade\View;
|
use think\Exception;
|
|
class WithdrawalRecord extends Common {
|
/*
|
* 品牌管理
|
*/
|
public function index(): string {
|
$other['title'] = '提现审核';
|
$guide['one']['text'] = '数据审核';
|
$guide['two']['text'] = '提现审核';
|
View::assign('guide', $guide);
|
View::assign('other', $other);
|
return View::fetch('index');
|
}
|
|
/*
|
*/
|
public function getWithdrawalRecordList() {
|
try {
|
if (!Request::isPost()) {
|
throw new Exception(lang('request_method_incorrect'));
|
}
|
$kw = input('kw');
|
// $condition[] = ['SRR.status', '=', 0];
|
$condition[] = ['SWR.payment_account', 'like', '%' . $kw . '%'];
|
$p = input('p', 1);
|
$other['page_size'] = input('page_size', 20);
|
$order = 'SWR.id desc';
|
$count = Db::name('supplier_withdrawal_record')
|
->alias('SWR')
|
->join('payment_tool PT', 'PT.payment_tool_id=SWR.payment_tool_id')
|
->join('supplier_asset SA', 'SA.id=SWR.asset_id')
|
->join('currency C', 'C.id=SA.currency_id')
|
->where($condition)->count();
|
$list = Db::name('supplier_withdrawal_record')
|
->alias('SWR')
|
->field("SWR.*,PT.payment_tool_name,C.currency_name")
|
->join('payment_tool PT', 'PT.payment_tool_id=SWR.payment_tool_id')
|
->join('supplier_asset SA', 'SA.id=SWR.asset_id')
|
->join('currency C', 'C.id=SA.currency_id')
|
->where($condition)->order($order)->page($p, $other['page_size'])->withAttr('add_time', function ($value) {
|
return date('Y-m-d H:i', $value);
|
})
|
->select()->toArray();
|
$other['count'] = $count;
|
$result['other'] = $other;
|
if (!$list) {
|
throw new Exception(lang('no_data_found'));
|
} else {
|
$result['list'] = $list;
|
return $this->successResponse($result);
|
}
|
} catch (\Exception $exc) {
|
return $this->errorResponse($exc->getMessage());
|
}
|
}
|
|
|
/**
|
* 汇款审核
|
*/
|
public function reviewWithdrawalRecord() {
|
// 开始数据库事务
|
Db::startTrans();
|
try {
|
if (!Request::isPost()) {
|
throw new Exception(lang('request_method_incorrect'));
|
}
|
$record_id = input('post.record_id');
|
if (!is_numeric($record_id)) {
|
throw new Exception(lang('parameter_error'));
|
}
|
$status = input('post.status');
|
//更新数据
|
$info = Db::name('supplier_withdrawal_record')->field('id,status,asset_id,payment_amount,supplier_id')->where('id', $record_id)->find();
|
if (!$info) {
|
throw new Exception(lang('no_data_found'));
|
}
|
if ($info['status'] == 1) {
|
throw new Exception('该申请已审核通过，请勿重复审核');
|
}
|
$payment_amount = $info['payment_amount'];
|
if ($status == 1) {
|
$service_charge = input('post.service_charge');
|
if (!is_numeric($service_charge)) {
|
throw new Exception('请输入手续费');
|
}
|
$add_fee = $payment_amount - $service_charge;//实际收款金额：充值金额-手续费
|
$asset_update['mnyusd'] = Db::raw("mnyusd+$payment_amount");//提现总额
|
$asset_update['mnylck'] = Db::raw("mnylck-$payment_amount");//冻结金额
|
Db::name('supplier_asset')->where('id', $info['asset_id'])->update($asset_update);
|
$record_update = [
|
'status' => 1,
|
'service_charge' => $service_charge,
|
'review_time' => time()//审核时间
|
];
|
Db::name('supplier_withdrawal_record')->where('id', $record_id)->update($record_update);//更新状态
|
$LogData = [
|
'amount' => $add_fee,
|
'type' => 2,//1增加，2减少
|
'remark' => '提现确认',
|
'user_id' => $this->admin_id,
|
'supplier_id' => $info['supplier_id'],
|
'target_type' => 2,//提现
|
'target_id' => $info['asset_id'],
|
];
|
event('SupplierBillLog', $LogData);//提现确认日志
|
$message = '操作成功，审核通过';
|
} else {
|
$review_comments = input('post.review_comments');
|
//审核不通过处理
|
$asset_update['mnyavl'] = Db::raw("mnyavl+$payment_amount");//可用余额恢复
|
$asset_update['mnylck'] = Db::raw("mnylck-$payment_amount");//冻结金额恢复
|
Db::name('supplier_asset')->where('id', $info['asset_id'])->update($asset_update);
|
|
$no_record_update = [
|
'status' => 2,
|
'review_comments' => $review_comments,
|
'review_time' => time()//审核时间
|
];
|
Db::name('supplier_withdrawal_record')->where('id', $record_id)->update($no_record_update);
|
$message = '操作成功，审核不通过';
|
}
|
// 提交事务
|
Db::commit();
|
return $this->successResponse($message);
|
|
} catch (Exception $exc) {
|
// 回滚事务
|
Db::rollback();
|
return $this->errorResponse($exc->getMessage());
|
}
|
}
|
|
}
|
