sileya-ai
/
vr-shopxo-source
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
vr-shopxo-source/application/plugins/wallet/service/CashService.php

542 lines
19 KiB
PHP
Raw Normal View History

钱包
2019-05-08 10:19:23 +00:00
<?php
// +----------------------------------------------------------------------
// | ShopXO 国内领先企业级B2C免费开源电商系统
// +----------------------------------------------------------------------
// | Copyright (c) 2011~2019 http://shopxo.net All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: Devil
// +----------------------------------------------------------------------
namespace app\plugins\wallet\service;
use think\Db;
use app\service\MessageService;
use app\plugins\wallet\service\WalletService;
/**
* 提现服务层
* @author Devil
* @blog http://gong.gg/
* @version 0.0.1
* @datetime 2016-12-01T21:51:08+0800
*/
class CashService
{
// 提现状态
public static $cash_status_list = [
0 => ['value' => 0, 'name' => '未打款', 'checked' => true],
1 => ['value' => 1, 'name' => '已打款'],
2 => ['value' => 2, 'name' => '打款失败'],
];
/**
* 验证码发送
* @author Devil
* @blog http://gong.gg/
* @version 0.0.1
* @datetime 2017-03-05T19:17:10+0800
* @param [array] $params [输入参数]
*/
public static function VerifySend($params = [])
{
// 数据验证
$p = [
[
'checked_type' => 'empty',
'key_name' => 'account_type',
'error_msg' => '身份认证方式有误',
],
[
'checked_type' => 'empty',
'key_name' => 'user',
'error_msg' => '用户信息有误',
],
];
$ret = ParamsChecked($params, $p);
if($ret !== true)
{
return DataReturn($ret, -1);
}
// 账户
if(empty($params['user'][$params['account_type']]))
{
return DataReturn('当前验证类型账号未绑定', -1);
}
// 验证码基础参数
$img_verify_params = array(
'key_prefix' => 'wallet_cash',
'expire_time' => MyC('common_verify_expire_time'),
'time_interval' => MyC('common_verify_time_interval'),
);
// 是否开启图片验证码
$verify = self::IsImaVerify($params, $img_verify_params);
if($verify['code'] != 0)
{
return $verify;
}
// 当前验证账户
$accounts = $params['user'][$params['account_type']];
// 发送验证码
$verify_params = array(
'key_prefix' => md5('wallet_cash_'.$accounts),
'expire_time' => MyC('common_verify_expire_time'),
'time_interval' => MyC('common_verify_time_interval'),
);
$code = GetNumberCode(6);
if($params['account_type'] == 'mobile')
{
$obj = new \base\Sms($verify_params);
新增短信，邮箱通用模板
2019-05-13 06:27:17 +00:00
$status = $obj->SendCode($accounts, $code, MyC('common_sms_currency_template'));
钱包
2019-05-08 10:19:23 +00:00
} else {
$obj = new \base\Email($verify_params);
$email_params = array(
'email' => $accounts,
新增短信，邮箱通用模板
2019-05-13 06:27:17 +00:00
'content' => MyC('common_email_currency_template'),
钱包
2019-05-08 10:19:23 +00:00
'title' => MyC('home_site_name').' - 账户安全认证',
'code' => $code,
);
$status = $obj->SendHtml($email_params);
}
// 状态
if($status)
{
// 清除验证码
if(isset($verify['data']) && is_object($verify['data']))
{
$verify['data']->Remove();
}
return DataReturn('发送成功', 0);
}
return DataReturn('发送失败'.'['.$obj->error.']', -100);
}
/**
* 是否开启图片验证码校验
* @author Devil
* @blog http://gong.gg/
* @version 0.0.1
* @datetime 2017-03-22T15:48:31+0800
* @param [array] $params [输入参数]
* @param [array] $verify_params [配置参数]
* @return [object] [图片验证码类对象]
*/
private static function IsImaVerify($params, $verify_params)
{
if(MyC('home_img_verify_state') == 1)
{
if(empty($params['verify']))
{
return DataReturn('参数错误', -10);
}
$verify = new \base\Verify($verify_params);
if(!$verify->CheckExpire())
{
return DataReturn('验证码已过期', -11);
}
if(!$verify->CheckCorrect($params['verify']))
{
return DataReturn('验证码错误', -12);
}
return DataReturn('操作成功', 0, $verify);
}
return DataReturn('操作成功', 0);
}
/**
* 验证码校验
* @author Devil
* @blog http://gong.gg/
* @version 0.0.1
* @datetime 2017-03-28T15:57:19+0800
* @param [array] $params [输入参数]
*/
public static function VerifyCheck($params = [])
{
// 数据验证
$p = [
[
'checked_type' => 'empty',
'key_name' => 'account_type',
'error_msg' => '身份认证方式有误',
],
[
'checked_type' => 'empty',
'key_name' => 'verify',
'error_msg' => '验证码不能为空',
],
[
'checked_type' => 'empty',
'key_name' => 'user',
'error_msg' => '用户信息有误',
],
];
$ret = ParamsChecked($params, $p);
if($ret !== true)
{
return DataReturn($ret, -1);
}
// 账户
if(empty($params['user'][$params['account_type']]))
{
return DataReturn('当前验证类型账号未绑定', -1);
}
// 当前验证账户
$accounts = $params['user'][$params['account_type']];
// 验证码校验
$verify_params = array(
'key_prefix' => md5('wallet_cash_'.$accounts),
'expire_time' => MyC('common_verify_expire_time')
);
if($params['account_type'] == 'mobile')
{
$obj = new \base\Sms($verify_params);
} else {
$obj = new \base\Email($verify_params);
}
// 是否已过期
if(!$obj->CheckExpire())
{
return DataReturn('验证码已过期', -10);
}
// 是否正确
if($obj->CheckCorrect($params['verify']))
{
// 校验成功标记
钱包优化，新增上传附件钩子
2019-05-09 09:48:25 +00:00
session('plugins_wallet_cash_check_success', time());
钱包
2019-05-08 10:19:23 +00:00
// 清除验证码
$obj->Remove();
return DataReturn('验证正确', 0);
}
return DataReturn('验证码错误', -11);
}
/**
* 提现创建
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2019-05-08
* @desc description
* @param [array] $params [输入参数]
*/
钱包优化，新增上传附件钩子
2019-05-09 09:48:25 +00:00
public static function CashCreate($params = [])
钱包
2019-05-08 10:19:23 +00:00
{
钱包提现处理
2019-05-10 07:12:08 +00:00
// 参数验证
钱包
2019-05-08 10:19:23 +00:00
$p = [
[
'checked_type' => 'empty',
'key_name' => 'money',
'error_msg' => '提现金额不能为空',
],
[
'checked_type' => 'length',
'key_name' => 'bank_name',
'checked_data' => '1,60',
'error_msg' => '收款银行格式 1~60 个字符之间',
],
[
'checked_type' => 'length',
'key_name' => 'bank_accounts',
'checked_data' => '1,60',
'error_msg' => '收款账号格式 1~60 个字符之间',
],
[
'checked_type' => 'length',
'key_name' => 'bank_username',
'checked_data' => '1,30',
'error_msg' => '开户人姓名格式 1~30 个字符之间',
],
[
'checked_type' => 'empty',
'key_name' => 'user',
'error_msg' => '用户信息有误',
],
];
$ret = ParamsChecked($params, $p);
if($ret !== true)
{
return DataReturn($ret, -1);
}
// 用户钱包
$user_wallet = WalletService::UserWallet($params['user']['id']);
if($user_wallet['code'] != 0)
{
return $user_wallet;
}
// 提现金额
$money = PriceNumberFormat($params['money']);
if($money > $user_wallet['data']['normal_money'])
{
return DataReturn('提现金额不能大于有效金额', -1);
}
// 开始处理
Db::startTrans();
// 添加提现数据
$data = [
'cash_no' => date('YmdHis').GetNumberCode(6),
'user_id' => $user_wallet['data']['user_id'],
'wallet_id' => $user_wallet['data']['id'],
'status' => 0,
'money' => $money,
'bank_name' => $params['bank_name'],
'bank_accounts' => $params['bank_accounts'],
'bank_username' => $params['bank_username'],
'add_time' => time(),
];
$cash_id = Db::name('PluginsWalletCash')->insertGetId($data);
if($cash_id <= 0)
{
Db::rollback();
return DataReturn('提现操作失败', -100);
}
// 钱包更新
$wallet_data = [
'normal_money' => PriceNumberFormat($user_wallet['data']['normal_money']-$money),
细节优化
2019-05-10 16:23:36 +00:00
'frozen_money' => PriceNumberFormat($user_wallet['data']['frozen_money']+$money),
钱包
2019-05-08 10:19:23 +00:00
'upd_time' => time(),
];
if(!Db::name('PluginsWallet')->where(['id'=>$user_wallet['data']['id']])->update($wallet_data))
{
Db::rollback();
return DataReturn('钱包操作失败', -100);
}
// 日志
细节优化
2019-05-10 16:23:36 +00:00
$money_field = [
['field' => 'normal_money', 'money_type' => 0, 'msg' => ' [ 有效金额减少'.$money.'元 ]'],
['field' => 'frozen_money', 'money_type' => 1, 'msg' => ' [ 冻结金额增加'.$money.'元 ]'],
钱包
2019-05-08 10:19:23 +00:00
];
细节优化
2019-05-10 16:23:36 +00:00
foreach($money_field as $v)
钱包
2019-05-08 10:19:23 +00:00
{
细节优化
2019-05-10 16:23:36 +00:00
// 有效金额
if($user_wallet['data'][$v['field']] != $wallet_data[$v['field']])
{
$log_data = [
'user_id' => $user_wallet['data']['user_id'],
'wallet_id' => $user_wallet['data']['id'],
'business_type' => 2,
'operation_type' => ($user_wallet['data'][$v['field']] < $wallet_data[$v['field']]) ? 1 : 0,
'money_type' => $v['money_type'],
'operation_money' => ($user_wallet['data'][$v['field']] < $wallet_data[$v['field']]) ? PriceNumberFormat($wallet_data[$v['field']]-$user_wallet['data'][$v['field']]) : PriceNumberFormat($user_wallet['data'][$v['field']]-$wallet_data[$v['field']]),
'original_money' => $user_wallet['data'][$v['field']],
'latest_money' => $wallet_data[$v['field']],
'msg' => '用户提现申请 '.$v['msg'],
];
if(!WalletService::WalletLogInsert($log_data))
{
Db::rollback();
return DataReturn('日志添加失败', -101);
}
钱包
2019-05-08 10:19:23 +00:00
细节优化
2019-05-10 16:23:36 +00:00
// 消息通知
MessageService::MessageAdd($user_wallet['data']['user_id'], '账户余额变动', $log_data['msg'], 3, $cash_id);
}
}
钱包
2019-05-08 10:19:23 +00:00
// 提交事务
Db::commit();
return DataReturn('操作成功', 0);
}
钱包提现处理
2019-05-10 07:12:08 +00:00
/**
* 提现申请审核
* @author Devil
* @blog http://gong.gg/
* @version 1.0.0
* @date 2019-05-10
* @desc description
* @param [array] $params [输入参数]
*/
public static function CashAudit($params = [])
{
// 参数验证
$p = [
[
'checked_type' => 'empty',
'key_name' => 'id',
'error_msg' => '提现id有误',
],
[
'checked_type' => 'empty',
'key_name' => 'pay_money',
'error_msg' => '打款金额有误',
],
[
'checked_type' => 'fun',
'key_name' => 'pay_money',
'checked_data' => 'CheckPrice',
'error_msg' => '请输入有效的打款金额有误',
],
[
'checked_type' => 'min',
'key_name' => 'pay_money',
'checked_data' => 0.01,
'error_msg' => '打款金额有误，最低0.01元',
],
[
'checked_type' => 'length',
'key_name' => 'msg',
'checked_data' => '180',
'error_msg' => '备注最多 180 个字符',
],
[
'checked_type' => 'in',
'key_name' => 'type',
'checked_data' => ['agree', 'refuse'],
'error_msg' => '操作类型有误，同意或拒绝操作出错',
],
];
$ret = ParamsChecked($params, $p);
if($ret !== true)
{
return DataReturn($ret, -1);
}
// 获取提现数据
$cash = Db::name('PluginsWalletCash')->find(intval($params['id']));
if(empty($cash))
{
return DataReturn('提现数据不存在或已删除', -10);
}
// 状态
if($cash['status'] != 0)
{
return DataReturn('状态不可操作['.self::$cash_status_list[$cash['status']]['name'].']', -11);
}
// 金额处理
$pay_money = PriceNumberFormat($params['pay_money']);
if($pay_money <= 0.00 || $pay_money > $cash['money'])
{
return DataReturn('打款金额有误，最低0.01元，最高'.$cash['money'].'元', -12);
}
// 获取用户钱包
$wallet = Db::name('PluginsWallet')->find(intval($cash['wallet_id']));
if(empty($wallet))
{
return DataReturn('用户钱包不存在或已删除', -20);
}
// 是否发送消息
$is_send_message = (isset($params['is_send_message']) && $params['is_send_message'] == 1) ? 1 : 0;
// 开始处理
Db::startTrans();
// 数据处理
if($params['type'] == 'agree')
{
// 钱包更新数据
$wallet_upd_data = [
'frozen_money' => PriceNumberFormat($wallet['frozen_money']-$cash['money']),
];
// 提现更新数据
$cash_upd_data = [
'status' => 1,
'pay_money' => $pay_money,
'pay_time' => time(),
];
$money_field = [
['field' => 'frozen_money', 'money_type' => 1, 'msg' => ' [ 提现申请成功 , 冻结金额减少'.$cash['money'].'元 ]'],
];
// 打款金额是否小于提现金额
if($pay_money < $cash['money'])
{
$surplus_money = PriceNumberFormat($cash['money']-$pay_money);
$wallet_upd_data['normal_money'] = PriceNumberFormat($wallet['normal_money']+$surplus_money);
$money_field[] = ['field' => 'normal_money', 'money_type' => 0, 'msg' => ' [ 提现申请成功 , 部分金额未打款 , 冻结金额退回至有效金额'.$surplus_money.'元 ]'];
}
} else {
// 钱包更新数据
$wallet_upd_data = [
'frozen_money' => PriceNumberFormat($wallet['frozen_money']-$cash['money']),
'normal_money' => PriceNumberFormat($wallet['normal_money']+$cash['money']),
];
// 提现更新数据
$cash_upd_data = [
'status' => 2,
];
$money_field = [
['field' => 'frozen_money', 'money_type' => 1, 'msg' => ' [ 提现申请失败 , 冻结金额释放 '.$cash['money'].'元 ]'],
['field' => 'normal_money', 'money_type' => 0, 'msg' => ' [ 提现申请失败 , 冻结金额退回至有效金额'.$cash['money'].'元 ]'],
];
}
// 提现更新
$cash_upd_data['msg'] = empty($params['msg']) ? '' : $params['msg'];
$cash_upd_data['upd_time'] = time();
if(!Db::name('PluginsWalletCash')->where(['id'=>$cash['id']])->update($cash_upd_data))
{
Db::rollback();
return DataReturn('提现申请操作失败', -100);
}
// 钱包更新
if(!Db::name('PluginsWallet')->where(['id'=>$wallet['id']])->update($wallet_upd_data))
{
Db::rollback();
return DataReturn('钱包操作失败', -101);
}
foreach($money_field as $v)
{
// 有效金额
if($wallet[$v['field']] != $wallet_upd_data[$v['field']])
{
$log_data = [
'user_id' => $wallet['user_id'],
'wallet_id' => $wallet['id'],
'business_type' => 2,
'operation_type' => ($wallet[$v['field']] < $wallet_upd_data[$v['field']]) ? 1 : 0,
'money_type' => $v['money_type'],
'operation_money' => ($wallet[$v['field']] < $wallet_upd_data[$v['field']]) ? PriceNumberFormat($wallet_upd_data[$v['field']]-$wallet[$v['field']]) : PriceNumberFormat($wallet[$v['field']]-$wallet_upd_data[$v['field']]),
'original_money' => $wallet[$v['field']],
'latest_money' => $wallet_upd_data[$v['field']],
细节优化
2019-05-10 16:23:36 +00:00
'msg' => '管理员审核'.$v['msg'],
钱包提现处理
2019-05-10 07:12:08 +00:00
];
if(!WalletService::WalletLogInsert($log_data))
{
Db::rollback();
return DataReturn('日志添加失败', -101);
}
// 消息通知
if($is_send_message == 1)
{
MessageService::MessageAdd($wallet['user_id'], '账户余额变动', $log_data['msg'], 3, $cash['id']);
}
}
}
// 处理成功
Db::commit();
return DataReturn('操作成功', 0);
}
钱包
2019-05-08 10:19:23 +00:00
}
?>