PlanController.php 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  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. User::where('plan_id', $plan->id)->update([
  41. 'group_id' => $params['group_id'],
  42. 'transfer_enable' => $params['transfer_enable'] * 1073741824
  43. ]);
  44. $plan->update($params);
  45. } catch (\Exception $e) {
  46. DB::rollBack();
  47. abort(500, '保存失败');
  48. }
  49. DB::commit();
  50. return response([
  51. 'data' => true
  52. ]);
  53. }
  54. if (!Plan::create($params)) {
  55. abort(500, '创建失败');
  56. }
  57. return response([
  58. 'data' => true
  59. ]);
  60. }
  61. public function drop(Request $request)
  62. {
  63. if (Order::where('plan_id', $request->input('id'))->first()) {
  64. abort(500, '该订阅下存在订单无法删除');
  65. }
  66. if (User::where('plan_id', $request->input('id'))->first()) {
  67. abort(500, '该订阅下存在用户无法删除');
  68. }
  69. if ($request->input('id')) {
  70. $plan = Plan::find($request->input('id'));
  71. if (!$plan) {
  72. abort(500, '该订阅ID不存在');
  73. }
  74. }
  75. return response([
  76. 'data' => $plan->delete()
  77. ]);
  78. }
  79. public function update(PlanUpdate $request)
  80. {
  81. $updateData = $request->only([
  82. 'show',
  83. 'renew'
  84. ]);
  85. $plan = Plan::find($request->input('id'));
  86. if (!$plan) {
  87. abort(500, '该订阅不存在');
  88. }
  89. try {
  90. $plan->update($updateData);
  91. } catch (\Exception $e) {
  92. abort(500, '保存失败');
  93. }
  94. return response([
  95. 'data' => true
  96. ]);
  97. }
  98. public function sort(PlanSort $request)
  99. {
  100. DB::beginTransaction();
  101. foreach ($request->input('plan_ids') as $k => $v) {
  102. if (!Plan::find($v)->update(['sort' => $k + 1])) {
  103. DB::rollBack();
  104. abort(500, '保存失败');
  105. }
  106. }
  107. DB::commit();
  108. return response([
  109. 'data' => true
  110. ]);
  111. }
  112. }