WithdrawService.php 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | Laravel框架 [ Laravel ]
  4. // +----------------------------------------------------------------------
  5. // | 版权所有 2017~2021 Laravel研发中心
  6. // +----------------------------------------------------------------------
  7. // | 官方网站: http://www.laravel.cn
  8. // +----------------------------------------------------------------------
  9. // | Author: wesmiler <12345678@qq.com>
  10. // +----------------------------------------------------------------------
  11. namespace App\Services;
  12. use App\Models\MemberModel;
  13. use App\Models\RechargeModel;
  14. use App\Models\WithdrawModel;
  15. /**
  16. * 提现记录管理-服务类
  17. * @author wesmiler
  18. * @since 2020/11/11
  19. * Class WithdrawService
  20. * @package App\Services
  21. */
  22. class WithdrawService extends BaseService
  23. {
  24. /**
  25. * 构造函数
  26. * @author wesmiler
  27. * @since 2020/11/11
  28. * WithdrawService constructor.
  29. */
  30. public function __construct()
  31. {
  32. $this->model = new WithdrawModel();
  33. }
  34. /**
  35. * 获取列表
  36. * @return array
  37. * @since 2020/11/11
  38. * @author wesmiler
  39. */
  40. public function getList()
  41. {
  42. $params = request()->all();
  43. $page = isset($params['pageSize']) ? intval($params['pageSize']) : PAGE;
  44. $pageSize = isset($params['pageSize']) ? intval($params['pageSize']) : PERPAGE;
  45. $dataList = $this->model::from('withdraw_logs as a')
  46. ->leftJoin('member as m', 'm.id', '=', 'a.user_id')
  47. ->where(function ($query) use ($params) {
  48. $query->where('a.mark', 1);
  49. $payType = isset($params['pay_type']) ? $params['pay_type'] : 0;
  50. if ($payType > 0) {
  51. $query->where('a.pay_type', $payType);
  52. }
  53. $userId = isset($params['user_id']) ? $params['user_id'] : 0;
  54. if ($userId > 0) {
  55. $query->where('a.user_id', $userId);
  56. }
  57. $datetime = isset($params['datetime'])? $params['datetime'] : [];
  58. $dateStart = $datetime && isset($datetime[0])? $datetime[0] : '';
  59. $dateEnd = isset($datetime[1])? $datetime[1] : '';
  60. if($dateStart && $dateEnd && $dateEnd> $dateStart){
  61. $query->where('a.create_time', '>', strtotime($dateStart))->where('a.create_time','<=', strtotime($dateEnd)+86399);
  62. }else if($dateStart && $dateStart == $dateEnd){
  63. $query->where('a.create_time', '>=', strtotime($dateStart))->where('a.create_time','<=', strtotime($dateStart)+86399);
  64. }else if ($dateStart){
  65. $query->where('a.create_time', '<=', strtotime($dateStart)+86399);
  66. }
  67. $status = isset($params['status']) ? $params['status'] : 0;
  68. if ($status > 0) {
  69. $query->where('a.status', $status);
  70. } else {
  71. $query->whereIn('a.status', [1, 2]);
  72. }
  73. })
  74. ->where(function ($query) use ($params) {
  75. $keyword = isset($params['keyword']) ? trim($params['keyword']) : '';
  76. if (!empty($keyword)) {
  77. $query->where('m.nickname','like',"%{$keyword}%")
  78. ->orWhere('a.order_sn','like',"%{$keyword}%");
  79. }
  80. })
  81. ->select(['a.id', 'a.user_id','a.order_sn','a.trade_no','a.pay_at', 'm.nickname','a.realname','a.account','a.qrcode','a.pay_type','a.money', 'a.balance','a.reason', 'a.status', 'a.create_time', 'a.update_time','a.remark'])
  82. ->orderBy('a.create_time', 'desc')
  83. ->paginate($pageSize);
  84. $dataList = $dataList ? $dataList->toArray() : [];
  85. if ($dataList) {
  86. foreach ($dataList['data'] as &$item) {
  87. $item['qrcode'] = $item['qrcode']? get_image_url($item['qrcode']) : '';
  88. $item['create_time'] = $item['create_time'] ? datetime($item['create_time'],'Y-m-d H:i:s') : '';
  89. }
  90. unset($item);
  91. }
  92. return [
  93. 'code' => 0,
  94. 'success'=> true,
  95. 'msg' => '操作成功',
  96. 'count' => isset($dataList['total']) ? $dataList['total'] : 0,
  97. 'data' => isset($dataList['data']) ? $dataList['data'] : 0,
  98. ];
  99. }
  100. /**
  101. * 添加或编辑
  102. * @return array
  103. * @since 2020/11/11
  104. * @author wesmiler
  105. */
  106. public function edit()
  107. {
  108. $data = request()->all();
  109. $data['update_time'] = time();
  110. return parent::edit($data); // TODO: Change the autogenerated stub
  111. }
  112. /**
  113. * 用户工资提现
  114. * @param $userId
  115. * @return array
  116. */
  117. public function withdraw($userId){
  118. $params = request()->all();
  119. $money = isset($params['money'])? $params['money'] : 0;
  120. if($money<=0){
  121. return message('提现金额错误', false);
  122. }
  123. // 验证提现限制
  124. $limitMin = ConfigService::make()->getConfigByCode('withdraw_min');
  125. if($money < $limitMin){
  126. return message('最低提现金额为:'.$limitMin.'元', false);
  127. }
  128. // 验证账户
  129. $memberInfo = MemberModel::where(['id'=> $userId,'mark'=> 1,'status'=> 1])
  130. ->select(['id','openid','nickname','salary'])
  131. ->first();
  132. if(!$memberInfo){
  133. return message('账户不可操作或已冻结,请联系客服', false);
  134. }
  135. if($memberInfo->salary < $money){
  136. return message('可提现金额不足', false);
  137. }
  138. // 处理
  139. $data = [
  140. 'order_sn'=> get_order_num('T'),
  141. 'user_id'=> $userId,
  142. 'pay_type'=> isset($params['pay_type'])? $params['pay_type'] : 1,
  143. 'money'=> $money,
  144. 'balance'=> $memberInfo->salary,
  145. 'realname'=> isset($params['realname'])? $params['realname'] : '',
  146. 'account'=> isset($params['account'])? $params['account'] : '',
  147. 'qrcode'=> isset($params['qrcode'])? $params['qrcode'] : '',
  148. 'remark'=> isset($params['remark'])? $params['remark'] : '',
  149. 'status'=> 2,
  150. ];
  151. \DB::beginTransaction();
  152. if(!MemberModel::where(['id'=> $userId,'mark'=> 1])->decrement('salary', $money)){
  153. \DB::rollBack();
  154. return message('更新账户失败,请刷新后重试',false);
  155. }
  156. if(!$this->model::insertGetId($data)){
  157. \DB::rollBack();
  158. return message('提现处理失败,请刷新后重试',false);
  159. }
  160. \DB::commit();
  161. return message('提现申请成功,请耐心等候审核打款',true);
  162. }
  163. }