UserExtract.php 7.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213
  1. <?php
  2. /**
  3. *
  4. * @author: xaboy<365615158@qq.com>
  5. * @day: 2018/3/3
  6. */
  7. namespace app\models\user;
  8. use crmeb\basic\BaseModel;
  9. use crmeb\services\workerman\ChannelService;
  10. use crmeb\traits\ModelTrait;
  11. use crmeb\services\SystemConfigService;
  12. /**
  13. * TODO 用户提现
  14. * Class UserExtract
  15. * @package app\models\user
  16. */
  17. class UserExtract extends BaseModel
  18. {
  19. /**
  20. * 数据表主键
  21. * @var string
  22. */
  23. protected $pk = 'id';
  24. /**
  25. * 模型名称
  26. * @var string
  27. */
  28. protected $name = 'user_extract';
  29. use ModelTrait;
  30. //审核中
  31. const AUDIT_STATUS = 0;
  32. //未通过
  33. const FAIL_STATUS = -1;
  34. //已提现
  35. const SUCCESS_STATUS = 1;
  36. protected static $extractType = ['alipay','bank','weixin'];
  37. protected static $extractTypeMsg = ['alipay'=>'支付宝','bank'=>'银行卡','weixin'=>'微信'];
  38. protected static $status = array(
  39. -1=>'未通过',
  40. 0 =>'审核中',
  41. 1 =>'已提现'
  42. );
  43. /**
  44. * 用户自主提现记录提现记录,后台执行审核
  45. * @param array $userInfo 用户个人信息
  46. * @param array $data 提现详细信息
  47. * @return bool
  48. */
  49. public static function userExtract($userInfo,$data){
  50. if(!in_array($data['extract_type'],self::$extractType))
  51. return self::setErrorInfo('提现方式不存在');
  52. $userInfo = User::get($userInfo['uid']);
  53. $sxf = 0;
  54. $js = '';
  55. $bl = '';
  56. if ($data['type'] == 1){
  57. if ($data['money'] > $userInfo['white_integral']) return self::setErrorInfo('肥料不足');
  58. $extractPrice = $userInfo['white_integral'];
  59. $js = '肥料';
  60. $bl = 'white_integral';
  61. }elseif ($data['type'] == 2){
  62. if ($userInfo['is_merchant'] == 0) return self::setErrorInfo('你不是商户,无法提现');
  63. if ($data['money'] > $userInfo['business_integral']) return self::setErrorInfo('商家积分不足');
  64. $extractPrice = $userInfo['business_integral'];
  65. $js = '商家积分';
  66. $bl = 'business_integral';
  67. }
  68. // $extractPrice = $userInfo['brokerage_price'];
  69. if($extractPrice < 0) return self::setErrorInfo('提现积分不足'.$data['money']);
  70. if($data['money'] > $extractPrice) return self::setErrorInfo('提现肥料不足'.$data['money']);
  71. if($data['money'] <= 0) return self::setErrorInfo('提现积分大于0');
  72. $balance = bcsub($extractPrice,$data['money'],2);
  73. if($balance < 0) $balance=0;
  74. if ($userInfo['integral'] > 0){
  75. $tx = SystemConfigService::get('deduction_tx');
  76. $sxf = ($data['money'] - (($data['money']*0.95) - 5));
  77. $dk = $userInfo['integral']/$tx;
  78. if($dk > $sxf){
  79. $ydk = ($dk - $sxf) * $tx;
  80. $money = $data['money'];
  81. }else{
  82. $ydk = 0;
  83. $money = $data['money'] - ($sxf - $dk);
  84. }
  85. }else{
  86. $money = ($data['money']*0.95) - 5;
  87. }
  88. $insertData = [
  89. 'uid' => $userInfo['uid'],
  90. 'extract_type' => $data['extract_type'],
  91. 'extract_price' => $money,
  92. 'add_time' => time(),
  93. 'balance' => $balance,
  94. 'status' => self::AUDIT_STATUS
  95. ];
  96. if(isset($data['name']) && strlen(trim($data['name']))) $insertData['real_name'] = $data['name'];
  97. else $insertData['real_name'] = $userInfo['nickname'];
  98. if(isset($data['cardnum'])) $insertData['bank_code'] = $data['cardnum'];
  99. else $insertData['bank_code'] = '';
  100. if(isset($data['bankname'])) $insertData['bank_address']=$data['bankname'];
  101. else $insertData['bank_address']='';
  102. if(isset($data['weixin'])) $insertData['wechat'] = $data['weixin'];
  103. else $insertData['wechat'] = $userInfo['nickname'];
  104. if($data['extract_type'] == 'alipay'){
  105. if(!$data['alipay_code']) return self::setErrorInfo('请输入支付宝账号');
  106. $insertData['alipay_code'] = $data['alipay_code'];
  107. $mark = '提现'.$js.',使用支付宝提现'.$insertData['extract_price'].'元';
  108. }else if($data['extract_type'] == 'bank'){
  109. if(!$data['cardnum']) return self::setErrorInfo('请输入银行卡账号');
  110. if(!$data['bankname']) return self::setErrorInfo('请输入开户行信息');
  111. $mark = '提现'.$js.',使用银联卡'.$insertData['bank_code'].'提现'.$insertData['extract_price'].'元';
  112. }else if($data['extract_type'] == 'weixin'){
  113. if(!$data['weixin']) return self::setErrorInfo('请输入微信账号');
  114. $mark = '提现'.$js.',使用微信提现'.$insertData['extract_price'].'元';
  115. }
  116. self::beginTrans();
  117. try{
  118. $res1 = self::create($insertData);
  119. if(!$res1) return self::setErrorInfo('提现失败');
  120. if ($userInfo['purple_integral'] > 0){
  121. if($dk > $sxf){
  122. $res2 = User::edit([$bl => $balance, 'purple_integral' => $ydk],$userInfo['uid'],'uid');
  123. UserBill::expend('提现抵扣',$userInfo['uid'],'integral','extract',($sxf*$tx),$res1['id'],$ydk,'提现使用'.($sxf*$tx).'阳光抵扣'.$sxf.'手续费');
  124. }else{
  125. $res2 = User::edit([$bl => $balance, 'purple_integral' => $ydk],$userInfo['uid'],'uid');
  126. UserBill::expend('提现抵扣',$userInfo['uid'],'integral','extract',(($sxf - $dk)*$tx),$res1['id'],$ydk,'提现使用'.(($sxf - $dk)*$tx).'阳光抵扣'.($sxf - $dk).'手续费');
  127. }
  128. }else{
  129. $res2 = User::edit([$bl => $balance],$userInfo['uid'],'uid');
  130. }
  131. $res3 = UserBill::expend('提现',$userInfo['uid'],'now_money','extract',$data['money'],$res1['id'],$balance,$mark);
  132. $res = $res2 && $res3;
  133. if($res){
  134. self::commitTrans();
  135. try{
  136. ChannelService::instance()->send('WITHDRAW', ['id'=>$res1->id]);
  137. }catch (\Exception $e){}
  138. event('AdminNewPush');
  139. //发送模板消息
  140. return true;
  141. }else return self::setErrorInfo('提现失败!');
  142. }catch (\Exception $e){
  143. self::rollbackTrans();
  144. return self::setErrorInfo('提现失败!');
  145. }
  146. }
  147. /**
  148. * 获得用户最后一次提现信息
  149. * @param $openid
  150. * @return mixed
  151. */
  152. public static function userLastInfo($uid)
  153. {
  154. return self::where(compact('uid'))->order('add_time DESC')->find();
  155. }
  156. /**
  157. * 获得用户提现总金额
  158. * @param $uid
  159. * @return mixed
  160. */
  161. public static function userExtractTotalPrice($uid,$status=self::SUCCESS_STATUS)
  162. {
  163. return self::where('uid',$uid)->where('status',$status)->value('SUM(extract_price)')?:0;
  164. }
  165. /**
  166. * 用户提现记录列表
  167. * @param int $uid 用户uid
  168. * @param int $first 截取行数
  169. * @param int $limit 截取数
  170. * @return \think\Collection
  171. * @throws \think\db\exception\DataNotFoundException
  172. * @throws \think\db\exception\ModelNotFoundException
  173. * @throws \think\exception\DbException
  174. */
  175. public static function extractList($uid,$first = 0,$limit = 8)
  176. {
  177. $list=UserExtract::where('uid',$uid)->order('add_time desc')->limit($first,$limit)->select();
  178. foreach($list as &$v){
  179. $v['add_time']=date('Y/m/d',$v['add_time']);
  180. }
  181. return $list;
  182. }
  183. /**
  184. * 获取累计已提现佣金
  185. * @param $uid
  186. * @return float
  187. */
  188. public static function extractSum($uid)
  189. {
  190. return self::where('uid',$uid)->where('status',1)->sum('extract_price');
  191. }
  192. }