Balance.php 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. <?php
  2. namespace App\Http\Controllers\admin;
  3. use App\Constants\HttpStatus;
  4. use App\Http\Controllers\Controller;
  5. use App\Models\BalanceLog;
  6. use App\Services\BalanceLogService;
  7. use Carbon\Carbon;
  8. use Illuminate\Validation\ValidationException;
  9. use Exception;
  10. class Balance extends Controller
  11. {
  12. public function log()
  13. {
  14. try {
  15. $params = request()->validate([
  16. 'page' => ['nullable', 'integer', 'min:1'],
  17. 'limit' => ['nullable', 'integer', 'min:1'],
  18. 'type' => ['nullable', 'integer'],
  19. 'member_id' => ['nullable', 'string', 'min:1'],
  20. 'related_id' => ['nullable', 'string', 'min:1'],
  21. 'change_type' => ['nullable', 'string', 'in:' . implode(',', BalanceLogService::$RW)],
  22. 'start_time' => ['nullable', 'date', 'date_format:Y-m-d', 'required_with:end_time'],
  23. 'end_time' => ['nullable', 'date', 'date_format:Y-m-d', 'required_with:start_time'],
  24. 'first_name' => ['nullable'],
  25. 'is_fancai' => ['nullable', 'integer','in:0,1'],
  26. // 用户类型/注册来源:-1 tg用户,0 后台客服账号,1 真实用户,2 虚拟用户
  27. 'from' => ['nullable'],
  28. ]);
  29. $page = request()->input('page', 1);
  30. $limit = request()->input('limit', 10);
  31. $query = BalanceLog::join('users', 'users.member_id', '=', 'balance_logs.member_id')
  32. ->where(BalanceLogService::getWhere($params));
  33. if (!empty($params['is_fancai'])) {
  34. $data['change_types'] = ['即充即送','老用户回归','余额宝利息'];
  35. $query = $query->whereIn('balance_logs.change_type', $data['change_types'])
  36. ->where('balance_logs.type', 2);
  37. } else {
  38. $data['change_types'] = BalanceLogService::$RW;
  39. }
  40. // 统计与列表共用筛选条件;clone 避免 count/sum 影响后续分页查询
  41. $data['total'] = (clone $query)->count();
  42. $data['total_amount'] = bcadd((clone $query)->sum('balance_logs.amount'), 0, 2);
  43. $data['data'] = $query->select("balance_logs.*", "users.first_name", "users.admin_note as user_admin_note", "users.from as user_from")
  44. ->orderByDesc('balance_logs.id')
  45. ->forPage($page, $limit)
  46. ->with(['member'])
  47. ->get()
  48. ->toArray();
  49. } catch (ValidationException $e) {
  50. return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
  51. } catch (Exception $e) {
  52. return $this->error($e->getCode(),$e->getMessage());
  53. }
  54. return $this->success($data);
  55. }
  56. }