123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168 |
- <?php
- namespace app\models\user;
- use crmeb\basic\BaseModel;
- use crmeb\services\workerman\ChannelService;
- use crmeb\traits\ModelTrait;
- class UserExtract extends BaseModel
- {
-
- protected $pk = 'id';
-
- protected $name = 'user_extract';
- use ModelTrait;
-
- const AUDIT_STATUS = 0;
-
- const FAIL_STATUS = -1;
-
- const SUCCESS_STATUS = 1;
- protected static $extractType = ['alipay','bank','weixin'];
- protected static $extractTypeMsg = ['alipay'=>'支付宝','bank'=>'银行卡','weixin'=>'微信'];
- protected static $status = array(
- -1=>'未通过',
- 0 =>'审核中',
- 1 =>'已提现'
- );
-
- public static function userExtract($userInfo,$data){
- if(!in_array($data['extract_type'],self::$extractType))
- return self::setErrorInfo('提现方式不存在');
- $userInfo = User::get($userInfo['uid']);
- $extractPrice = $userInfo['brokerage_price'];
- if($extractPrice < 0) return self::setErrorInfo('提现佣金不足'.$data['money']);
- if($data['money'] > $extractPrice) return self::setErrorInfo('提现佣金不足'.$data['money']);
- if($data['money'] <= 0) return self::setErrorInfo('提现佣金大于0');
- $balance = bcsub($userInfo['brokerage_price'],$data['money'],2);
- if($balance < 0) $balance=0;
- $insertData = [
- 'uid' => $userInfo['uid'],
- 'extract_type' => $data['extract_type'],
- 'extract_price' => $data['money'],
- 'add_time' => time(),
- 'balance' => $balance,
- 'status' => self::AUDIT_STATUS
- ];
- if(isset($data['name']) && strlen(trim($data['name']))) $insertData['real_name'] = $data['name'];
- else $insertData['real_name'] = $userInfo['nickname'];
- if(isset($data['cardnum'])) $insertData['bank_code'] = $data['cardnum'];
- else $insertData['bank_code'] = '';
- if(isset($data['bankname'])) $insertData['bank_address']=$data['bankname'];
- else $insertData['bank_address']='';
- if(isset($data['weixin'])) $insertData['wechat'] = $data['weixin'];
- else $insertData['wechat'] = $userInfo['nickname'];
- if($data['extract_type'] == 'alipay'){
- if(!$data['alipay_code']) return self::setErrorInfo('请输入支付宝账号');
- $insertData['alipay_code'] = $data['alipay_code'];
- $mark = '使用支付宝提现'.$insertData['extract_price'].'元';
- }else if($data['extract_type'] == 'bank'){
- if(!$data['cardnum']) return self::setErrorInfo('请输入银行卡账号');
- if(!$data['bankname']) return self::setErrorInfo('请输入开户行信息');
- $mark = '使用银联卡'.$insertData['bank_code'].'提现'.$insertData['extract_price'].'元';
- }else if($data['extract_type'] == 'weixin'){
- $mark = '使用微信提现'.$insertData['extract_price'].'元';
- }
- self::beginTrans();
- try{
- $res1 = self::create($insertData);
- if(!$res1) return self::setErrorInfo('提现失败');
- $res2 = User::edit(['brokerage_price'=>$balance],$userInfo['uid'],'uid');
- $res3 = UserBill::expend('余额提现',$userInfo['uid'],'now_money','extract',$data['money'],$res1['id'],$balance,$mark);
- $res = $res2 && $res3;
- if($res){
- self::commitTrans();
- try{
- ChannelService::instance()->send('WITHDRAW', ['id'=>$res1->id]);
- }catch (\Exception $e){}
- event('AdminNewPush');
-
- return true;
- }else return self::setErrorInfo('提现失败!');
- }catch (\Exception $e){
- self::rollbackTrans();
- return self::setErrorInfo('提现失败!');
- }
- }
-
- public static function userLastInfo($uid)
- {
- return self::where(compact('uid'))->order('add_time DESC')->find();
- }
-
- public static function userExtractTotalPrice($uid,$status=self::SUCCESS_STATUS)
- {
- return self::where('uid',$uid)->where('status',$status)->value('SUM(extract_price)')?:0;
- }
-
- public static function extractList($uid,$first = 0,$limit = 8)
- {
- $list=UserExtract::where('uid',$uid)->order('add_time desc')->limit($first,$limit)->select();
- foreach($list as &$v){
- $v['add_time']=date('Y/m/d',$v['add_time']);
- }
- return $list;
- }
-
- public static function extractSum($uid)
- {
- return self::where('uid',$uid)->where('status',1)->sum('extract_price');
- }
- }
|