123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190 |
- <?php
- namespace App\Http\Controllers\Admin;
- use App\Http\Requests\Admin\OrderAssign;
- use App\Http\Requests\Admin\OrderUpdate;
- use App\Http\Requests\Admin\OrderFetch;
- use App\Models\CommissionLog;
- use App\Services\OrderService;
- use App\Services\UserService;
- use App\Utils\Helper;
- use Illuminate\Http\Request;
- use App\Http\Controllers\Controller;
- use App\Models\Order;
- use App\Models\User;
- use App\Models\Plan;
- use Illuminate\Support\Facades\DB;
- class OrderController extends Controller
- {
- private function filter(Request $request, &$builder)
- {
- if ($request->input('filter')) {
- foreach ($request->input('filter') as $filter) {
- if ($filter['key'] === 'email') {
- $user = User::where('email', "%{$filter['value']}%")->first();
- if (!$user) continue;
- $builder->where('user_id', $user->id);
- continue;
- }
- if ($filter['condition'] === '模糊') {
- $filter['condition'] = 'like';
- $filter['value'] = "%{$filter['value']}%";
- }
- $builder->where($filter['key'], $filter['condition'], $filter['value']);
- }
- }
- }
- public function detail(Request $request)
- {
- $order = Order::find($request->input('id'));
- if (!$order) abort(500, '订单不存在');
- $order['commission_log'] = CommissionLog::where('trade_no', $order->trade_no)->get();
- if ($order->surplus_order_ids) {
- $order['surplus_orders'] = Order::whereIn('id', $order->surplus_order_ids)->get();
- }
- return response([
- 'data' => $order
- ]);
- }
- public function fetch(OrderFetch $request)
- {
- $current = $request->input('current') ? $request->input('current') : 1;
- $pageSize = $request->input('pageSize') >= 10 ? $request->input('pageSize') : 10;
- $orderModel = Order::orderBy('created_at', 'DESC');
- if ($request->input('is_commission')) {
- $orderModel->where('invite_user_id', '!=', NULL);
- $orderModel->whereNotIn('status', [0, 2]);
- $orderModel->where('commission_balance', '>', 0);
- }
- $this->filter($request, $orderModel);
- $total = $orderModel->count();
- $res = $orderModel->forPage($current, $pageSize)
- ->get();
- $plan = Plan::get();
- for ($i = 0; $i < count($res); $i++) {
- for ($k = 0; $k < count($plan); $k++) {
- if ($plan[$k]['id'] == $res[$i]['plan_id']) {
- $res[$i]['plan_name'] = $plan[$k]['name'];
- }
- }
- }
- return response([
- 'data' => $res,
- 'total' => $total
- ]);
- }
- public function paid(Request $request)
- {
- $order = Order::where('trade_no', $request->input('trade_no'))
- ->first();
- if (!$order) {
- abort(500, '订单不存在');
- }
- if ($order->status !== 0) abort(500, '只能对待支付的订单进行操作');
- $orderService = new OrderService($order);
- if (!$orderService->paid('manual_operation')) {
- abort(500, '更新失败');
- }
- return response([
- 'data' => true
- ]);
- }
- public function cancel(Request $request)
- {
- $order = Order::where('trade_no', $request->input('trade_no'))
- ->first();
- if (!$order) {
- abort(500, '订单不存在');
- }
- if ($order->status !== 0) abort(500, '只能对待支付的订单进行操作');
- $orderService = new OrderService($order);
- if (!$orderService->cancel()) {
- abort(500, '更新失败');
- }
- return response([
- 'data' => true
- ]);
- }
- public function update(OrderUpdate $request)
- {
- $params = $request->only([
- 'commission_status'
- ]);
- $order = Order::where('trade_no', $request->input('trade_no'))
- ->first();
- if (!$order) {
- abort(500, '订单不存在');
- }
- try {
- $order->update($params);
- } catch (\Exception $e) {
- abort(500, '更新失败');
- }
- return response([
- 'data' => true
- ]);
- }
- public function assign(OrderAssign $request)
- {
- $plan = Plan::find($request->input('plan_id'));
- $user = User::where('email', $request->input('email'))->first();
- if (!$user) {
- abort(500, '该用户不存在');
- }
- if (!$plan) {
- abort(500, '该订阅不存在');
- }
- $userService = new UserService();
- if ($userService->isNotCompleteOrderByUserId($user->id)) {
- abort(500, '该用户还有待支付的订单,无法分配');
- }
- DB::beginTransaction();
- $order = new Order();
- $orderService = new OrderService($order);
- $order->user_id = $user->id;
- $order->plan_id = $plan->id;
- $order->period = $request->input('period');
- $order->trade_no = Helper::guid();
- $order->total_amount = $request->input('total_amount');
- if ($order->period === 'reset_price') {
- $order->type = 4;
- } else if ($user->plan_id !== NULL && $order->plan_id !== $user->plan_id) {
- $order->type = 3;
- } else if ($user->expired_at > time() && $order->plan_id == $user->plan_id) {
- $order->type = 2;
- } else {
- $order->type = 1;
- }
- $orderService->setInvite($user);
- if (!$order->save()) {
- DB::rollback();
- abort(500, '订单创建失败');
- }
- DB::commit();
- return response([
- 'data' => $order->trade_no
- ]);
- }
- }
|