PlanController.php 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Requests\Admin\PlanSave;
  4. use App\Http\Requests\Admin\PlanSort;
  5. use App\Http\Requests\Admin\PlanUpdate;
  6. use Illuminate\Http\Request;
  7. use App\Http\Controllers\Controller;
  8. use App\Models\Plan;
  9. use App\Models\Order;
  10. use App\Models\User;
  11. use Illuminate\Support\Facades\DB;
  12. class PlanController extends Controller
  13. {
  14. public function fetch(Request $request)
  15. {
  16. $counts = User::select(
  17. DB::raw("plan_id"),
  18. DB::raw("count(*) as count")
  19. )
  20. ->where('plan_id', '!=', NULL)
  21. ->where(function ($query) {
  22. $query->where('expired_at', '>=', time())
  23. ->orWhere('expired_at', NULL);
  24. })
  25. ->groupBy("plan_id")
  26. ->get();
  27. $plans = Plan::orderBy('sort', 'ASC')->get();
  28. foreach ($plans as $k => $v) {
  29. $plans[$k]->count = 0;
  30. foreach ($counts as $kk => $vv) {
  31. if ($plans[$k]->id === $counts[$kk]->plan_id) $plans[$k]->count = $counts[$kk]->count;
  32. }
  33. }
  34. return response([
  35. 'data' => $plans
  36. ]);
  37. }
  38. public function save(PlanSave $request)
  39. {
  40. $params = $request->validated();
  41. if ($request->input('id')) {
  42. $plan = Plan::find($request->input('id'));
  43. if (!$plan) {
  44. abort(500, '该订阅不存在');
  45. }
  46. DB::beginTransaction();
  47. // update user group id and transfer
  48. try {
  49. User::where('plan_id', $plan->id)->update([
  50. 'group_id' => $params['group_id'],
  51. 'transfer_enable' => $params['transfer_enable'] * 1073741824
  52. ]);
  53. $plan->update($params);
  54. } catch (\Exception $e) {
  55. DB::rollBack();
  56. abort(500, '保存失败');
  57. }
  58. DB::commit();
  59. return response([
  60. 'data' => true
  61. ]);
  62. }
  63. if (!Plan::create($params)) {
  64. abort(500, '创建失败');
  65. }
  66. return response([
  67. 'data' => true
  68. ]);
  69. }
  70. public function drop(Request $request)
  71. {
  72. if (Order::where('plan_id', $request->input('id'))->first()) {
  73. abort(500, '该订阅下存在订单无法删除');
  74. }
  75. if (User::where('plan_id', $request->input('id'))->first()) {
  76. abort(500, '该订阅下存在用户无法删除');
  77. }
  78. if ($request->input('id')) {
  79. $plan = Plan::find($request->input('id'));
  80. if (!$plan) {
  81. abort(500, '该订阅ID不存在');
  82. }
  83. }
  84. return response([
  85. 'data' => $plan->delete()
  86. ]);
  87. }
  88. public function update(PlanUpdate $request)
  89. {
  90. $updateData = $request->only([
  91. 'show',
  92. 'renew'
  93. ]);
  94. $plan = Plan::find($request->input('id'));
  95. if (!$plan) {
  96. abort(500, '该订阅不存在');
  97. }
  98. try {
  99. $plan->update($updateData);
  100. } catch (\Exception $e) {
  101. abort(500, '保存失败');
  102. }
  103. return response([
  104. 'data' => true
  105. ]);
  106. }
  107. public function sort(PlanSort $request)
  108. {
  109. DB::beginTransaction();
  110. foreach ($request->input('plan_ids') as $k => $v) {
  111. if (!Plan::find($v)->update(['sort' => $k + 1])) {
  112. DB::rollBack();
  113. abort(500, '保存失败');
  114. }
  115. }
  116. DB::commit();
  117. return response([
  118. 'data' => true
  119. ]);
  120. }
  121. }