PlanController.php 3.5 KB

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