sileya-ai
/
vr-shopxo-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

账户充值

feat/task1-c-wallet
devil_gong 2019-05-07 18:01:49 +08:00
parent 8d6109d80d
commit 9f0c4cca20
4 changed files with 34 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
application/plugins/wallet/Common.php
View File

@ -56,20 +56,19 @@ class Common extends Controller
// 发起支付 - 支付方式 // 发起支付 - 支付方式
$this->assign('buy_payment_list', PaymentService::BuyPaymentList(['is_enable'=>1, 'is_open_user'=>1])); $this->assign('buy_payment_list', PaymentService::BuyPaymentList(['is_enable'=>1, 'is_open_user'=>1]));
// 用户钱包信息 // 用户钱包
$this->user_wallet = WalletService::UserWallet(['user'=>$this->user]); $user_wallet = WalletService::UserWallet(['user'=>$this->user]);
$this->assign('user_wallet', $this->user_wallet['data']);
// 用户钱包状态 // 用户钱包状态
$wallet_error = ''; $wallet_error = '';
if(isset($this->user_wallet['code']) and $this->user_wallet['code'] == 0) if(isset($user_wallet['code']) and $user_wallet['code'] == 0)
{ {
if(!isset($this->user_wallet['data']['status']) || $this->user_wallet['data']['status'] != 0) if(!isset($user_wallet['data']['status']) || $user_wallet['data']['status'] != 0)
{ {
$wallet_error = array_key_exists($this->user_wallet['data']['status'], WalletService::$wallet_status_list) ? '用户钱包[ '.WalletService::$wallet_status_list[$this->user_wallet['data']['status']]['name'].' ]' : '用户钱包状态异常错误'; $wallet_error = array_key_exists($user_wallet['data']['status'], WalletService::$wallet_status_list) ? '用户钱包[ '.WalletService::$wallet_status_list[$user_wallet['data']['status']]['name'].' ]' : '用户钱包状态异常错误';
} }
} else { } else {
$wallet_error = isset($this->user_wallet['msg']) ? $this->user_wallet['msg'] : '用户钱包异常错误'; $wallet_error = isset($user_wallet['msg']) ? $user_wallet['msg'] : '用户钱包异常错误';
} }
$this->assign('wallet_error', $wallet_error); $this->assign('wallet_error', $wallet_error);
@ -78,6 +77,10 @@ class Common extends Controller
{ {
exit(json_encode(DataReturn($wallet_error, -50))); exit(json_encode(DataReturn($wallet_error, -50)));
} }
// 用户钱包信息
$this->user_wallet = $user_wallet['data'];
$this->assign('user_wallet', $user_wallet['data']);
} }
} }
?> ?>

1
application/plugins/wallet/Recharge.php
View File

@ -101,6 +101,7 @@ class Recharge extends Common
// 用户 // 用户
$params['user'] = $this->user; $params['user'] = $this->user;
$params['user_wallet'] = $this->user_wallet;
return BaseService::RechargeCreate($params); return BaseService::RechargeCreate($params);
} }

6
application/plugins/wallet/service/BaseService.php
View File

@ -133,6 +133,11 @@ class BaseService
'key_name' => 'user', 'key_name' => 'user',
'error_msg' => '用户信息有误', 'error_msg' => '用户信息有误',
], ],
[
'checked_type' => 'empty',
'key_name' => 'user_wallet',
'error_msg' => '用户钱包有误',
],
[ [
'checked_type' => 'fun', 'checked_type' => 'fun',
'key_name' => 'money', 'key_name' => 'money',
@ -155,6 +160,7 @@ class BaseService
// 添加 // 添加
$data = [ $data = [
'recharge_no' => date('YmdHis').GetNumberCode(6), 'recharge_no' => date('YmdHis').GetNumberCode(6),
'wallet_id' => $params['user_wallet']['id'],
'user_id' => $params['user']['id'], 'user_id' => $params['user']['id'],
'money' => PriceNumberFormat($params['money']), 'money' => PriceNumberFormat($params['money']),
'status' => 0, 'status' => 0,

17
application/plugins/wallet/service/PayService.php
View File

@ -14,6 +14,7 @@ use think\Db;
use app\service\PaymentService; use app\service\PaymentService;
use app\service\PayLogService; use app\service\PayLogService;
use app\service\MessageService; use app\service\MessageService;
use app\plugins\wallet\service\WalletService;
/** /**
* 支付服务层 * 支付服务层
@ -344,6 +345,22 @@ class PayService
); );
if(Db::name('PluginsWalletRecharge')->where(['id'=>$params['recharge']['id']])->update($upd_data)) if(Db::name('PluginsWalletRecharge')->where(['id'=>$params['recharge']['id']])->update($upd_data))
{ {
$log_data = [
'user_id' => $wallet['user_id'],
'wallet_id' => $wallet['id'],
'business_type' => 0,
'operation_type' => ($wallet[$v['field']] < $data[$v['field']]) ? 1 : 0,
'money_type' => $v['money_type'],
'operation_money' => ($wallet[$v['field']] < $data[$v['field']]) ? PriceNumberFormat($data[$v['field']]-$wallet[$v['field']]) : PriceNumberFormat($wallet[$v['field']]-$data[$v['field']]),
'original_money' => $wallet[$v['field']],
'latest_money' => $data[$v['field']],
'msg' => '管理员操作'.$operation_msg,
];
if(!self::WalletLogInsert($log_data))
{
Db::rollback();
return DataReturn('日志添加失败', -101);
}
// 提交事务 // 提交事务
Db::commit(); Db::commit();
return DataReturn('支付成功', 0); return DataReturn('支付成功', 0);