OrderController.php 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Requests\Admin\OrderAssign;
  4. use App\Http\Requests\Admin\OrderUpdate;
  5. use App\Http\Requests\Admin\OrderFetch;
  6. use App\Models\CommissionLog;
  7. use App\Services\OrderService;
  8. use App\Services\UserService;
  9. use App\Utils\Helper;
  10. use Illuminate\Http\Request;
  11. use App\Http\Controllers\Controller;
  12. use App\Models\Order;
  13. use App\Models\User;
  14. use App\Models\Plan;
  15. use Illuminate\Support\Facades\DB;
  16. class OrderController extends Controller
  17. {
  18. private function filter(Request $request, &$builder)
  19. {
  20. if ($request->input('filter')) {
  21. foreach ($request->input('filter') as $filter) {
  22. if ($filter['key'] === 'email') {
  23. $user = User::where('email', "%{$filter['value']}%")->first();
  24. if (!$user) continue;
  25. $builder->where('user_id', $user->id);
  26. continue;
  27. }
  28. if ($filter['condition'] === '模糊') {
  29. $filter['condition'] = 'like';
  30. $filter['value'] = "%{$filter['value']}%";
  31. }
  32. $builder->where($filter['key'], $filter['condition'], $filter['value']);
  33. }
  34. }
  35. }
  36. public function detail(Request $request)
  37. {
  38. $order = Order::find($request->input('id'));
  39. if (!$order) abort(500, '订单不存在');
  40. $order['commission_log'] = CommissionLog::where('trade_no', $order->trade_no)->get();
  41. if ($order->surplus_order_ids) {
  42. $order['surplus_orders'] = Order::whereIn('id', $order->surplus_order_ids)->get();
  43. }
  44. return response([
  45. 'data' => $order
  46. ]);
  47. }
  48. public function fetch(OrderFetch $request)
  49. {
  50. $current = $request->input('current') ? $request->input('current') : 1;
  51. $pageSize = $request->input('pageSize') >= 10 ? $request->input('pageSize') : 10;
  52. $orderModel = Order::orderBy('created_at', 'DESC');
  53. if ($request->input('is_commission')) {
  54. $orderModel->where('invite_user_id', '!=', NULL);
  55. $orderModel->whereNotIn('status', [0, 2]);
  56. $orderModel->where('commission_balance', '>', 0);
  57. }
  58. $this->filter($request, $orderModel);
  59. $total = $orderModel->count();
  60. $res = $orderModel->forPage($current, $pageSize)
  61. ->get();
  62. $plan = Plan::get();
  63. for ($i = 0; $i < count($res); $i++) {
  64. for ($k = 0; $k < count($plan); $k++) {
  65. if ($plan[$k]['id'] == $res[$i]['plan_id']) {
  66. $res[$i]['plan_name'] = $plan[$k]['name'];
  67. }
  68. }
  69. }
  70. return response([
  71. 'data' => $res,
  72. 'total' => $total
  73. ]);
  74. }
  75. public function paid(Request $request)
  76. {
  77. $order = Order::where('trade_no', $request->input('trade_no'))
  78. ->first();
  79. if (!$order) {
  80. abort(500, '订单不存在');
  81. }
  82. if ($order->status !== 0) abort(500, '只能对待支付的订单进行操作');
  83. $orderService = new OrderService($order);
  84. if (!$orderService->paid('manual_operation')) {
  85. abort(500, '更新失败');
  86. }
  87. return response([
  88. 'data' => true
  89. ]);
  90. }
  91. public function cancel(Request $request)
  92. {
  93. $order = Order::where('trade_no', $request->input('trade_no'))
  94. ->first();
  95. if (!$order) {
  96. abort(500, '订单不存在');
  97. }
  98. if ($order->status !== 0) abort(500, '只能对待支付的订单进行操作');
  99. $orderService = new OrderService($order);
  100. if (!$orderService->cancel()) {
  101. abort(500, '更新失败');
  102. }
  103. return response([
  104. 'data' => true
  105. ]);
  106. }
  107. public function update(OrderUpdate $request)
  108. {
  109. $params = $request->only([
  110. 'commission_status'
  111. ]);
  112. $order = Order::where('trade_no', $request->input('trade_no'))
  113. ->first();
  114. if (!$order) {
  115. abort(500, '订单不存在');
  116. }
  117. try {
  118. $order->update($params);
  119. } catch (\Exception $e) {
  120. abort(500, '更新失败');
  121. }
  122. return response([
  123. 'data' => true
  124. ]);
  125. }
  126. public function assign(OrderAssign $request)
  127. {
  128. $plan = Plan::find($request->input('plan_id'));
  129. $user = User::where('email', $request->input('email'))->first();
  130. if (!$user) {
  131. abort(500, '该用户不存在');
  132. }
  133. if (!$plan) {
  134. abort(500, '该订阅不存在');
  135. }
  136. $userService = new UserService();
  137. if ($userService->isNotCompleteOrderByUserId($user->id)) {
  138. abort(500, '该用户还有待支付的订单,无法分配');
  139. }
  140. DB::beginTransaction();
  141. $order = new Order();
  142. $orderService = new OrderService($order);
  143. $order->user_id = $user->id;
  144. $order->plan_id = $plan->id;
  145. $order->period = $request->input('period');
  146. $order->trade_no = Helper::guid();
  147. $order->total_amount = $request->input('total_amount');
  148. if ($order->period === 'reset_price') {
  149. $order->type = 4;
  150. } else if ($user->plan_id !== NULL && $order->plan_id !== $user->plan_id) {
  151. $order->type = 3;
  152. } else if ($user->expired_at > time() && $order->plan_id == $user->plan_id) {
  153. $order->type = 2;
  154. } else {
  155. $order->type = 1;
  156. }
  157. $orderService->setInvite($user);
  158. if (!$order->save()) {
  159. DB::rollback();
  160. abort(500, '订单创建失败');
  161. }
  162. DB::commit();
  163. return response([
  164. 'data' => $order->trade_no
  165. ]);
  166. }
  167. }