jiqu-library-server/app/Endpoint/Api/Http/Controllers/Order/OrderController.php

<?php

namespace App\Endpoint\Api\Http\Controllers\Order;

use App\Endpoint\Api\Http\Controllers\Controller;
use App\Endpoint\Api\Http\Resources\OrderPackageResource;
use App\Endpoint\Api\Http\Resources\OrderResource;
use App\Endpoint\Api\Http\Resources\OrderResourceCollection;
use App\Events\OrderPaid;
use App\Exceptions\BizException;
use App\Helpers\Paginator as PaginatorHelper;
use App\Models\KuaidiLog;
use App\Services\OrderService;
use Illuminate\Database\QueryException;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

class OrderController extends Controller
{
    /**
     * 订单列表
     *
     * @param \Illuminate\Http\Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function index(Request $request)
    {
        $perPage = PaginatorHelper::resolvePerPage('per_page', 20, 50);

        $orders = $request->user()->orders()
                        ->with('products')
                        ->filter($request->all())
                        ->latest('id')
                        ->simplePaginate($perPage);

        return OrderResourceCollection::make($orders);
    }

    /**
     * 创建订单
     *
     * @param \Illuminate\Http\Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function store(Request $request)
    {
        $isQuick = $request->filled('product');

        $rules = $isQuick ? [
            'product.sku_id' => ['bail', 'required', 'int'],
            'product.quantity' => ['bail', 'required', 'int', 'min:1'],
            'shipping_address_id' => ['bail', 'required', 'int'],
            'coupon_id' => ['bail', 'nullable', 'int'],
            'note' => ['bail', 'nullable', 'string', 'max:255'],
        ] : [
            'shopping_cart' => ['bail', 'required', 'array'],
            'shipping_address_id' => ['bail', 'required', 'int'],
            'coupon_id' => ['bail', 'nullable', 'int'],
            'note' => ['bail', 'nullable', 'string', 'max:255'],
        ];

        $input = $request->validate($rules, [], [
            'product.sku_id' => '商品',
            'product.quantity' => '数量',
            'shopping_cart' => '购物车商品',
            'shipping_address_id' => '收货地址',
            'coupon_id' => '优惠券',
            'note' => '订单备注',
        ]);

        $user = $request->user();

        try {
            $order = DB::transaction(function () use ($isQuick, $user, $input) {
                $orderService = new OrderService();

                if ($isQuick) {
                    return $orderService->createQuickOrder(
                        $user,
                        $input['product']['sku_id'],
                        $input['product']['quantity'],
                        $input['shipping_address_id'],
                        $input['coupon_id'] ?? null,
                        $input['note'] ?? null,
                    );
                }

                return $orderService->createShoppingCartOrder(
                    $user,
                    $input['shopping_cart'],
                    $input['shipping_address_id'],
                    $input['coupon_id'] ?? null,
                    $input['note'] ?? null,
                );
            });
        } catch (QueryException $e) {
            if (strpos($e->getMessage(), 'Numeric value out of range') !== false) {
                $e = new BizException('商品库存不足');
            }

            throw $e;
        }

        OrderPaid::dispatchIf($order->isPaid(), $order);

        return OrderResource::make($order);
    }

    /**
     * 查看订单
     *
     * @param int $id
     * @param \Illuminate\Http\Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function show($id, Request $request)
    {
        $order = $request->user()->orders()->findOrFail($id);
        $order->load('products');
<<<<<<< Updated upstream
        $order->load('lastPackage');
=======
        $order->load('packages');
>>>>>>> Stashed changes

        return OrderResource::make($order);
    }

    /**
     * 确认收货/完成订单
     *
     * @param int $id
     * @param \Illuminate\Http\Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function confirm($id, Request $request)
    {
        $user = $request->user();

        DB::transaction(function () use ($id, $user) {
            $order = $user->orders()->lockForUpdate()->findOrFail($id);

            (new OrderService())->confirm($order);
        });

        return response()->noContent();
    }

    /**
     * 取消订单
     *
     * @param int $id
     * @param \Illuminate\Http\Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function cancel($id, Request $request)
    {
        $user = $request->user();

        DB::transaction(function () use ($id, $user) {
            $order = $user->orders()->lockForUpdate()->findOrFail($id);

            (new OrderService())->cancel($order);
        });

        return response()->noContent();
    }

    /**
     * 支付订单
     *
     * @param int $id
     * @param \Illuminate\Http\Request $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function pay($id, Request $request)
    {
        $input = $request->validate([
            'pay_way' => ['bail', 'required'],
        ]);

        $user = $request->user();

        return DB::transaction(function () use ($id, $user, $input) {
            $order = $user->orders()->findOrFail($id);

            return (new OrderService())->pay($order, $input['pay_way']);
        });
    }

    /**
     * 订单包裹列表
     */
    public function orderPackages($id, Request $request)
    {
        $order = $request->user()->orders()->findOrFail($id);
        return OrderPackageResource::collection($order->packages()->where('is_failed', false)->orderBy('updated_at', 'desc')->get());
    }

    /**
     * 物流包裹的明细
     *
     * @return void
     */
    public function shippingInfo($id, Request $request)
    {
        $package = $request->user()->orderPackages()->where('is_failed', false)->findOrFail($id);
        return response()->json(array_merge(OrderPackageResource::make($package)->resolve(), [
            'shipping_info'=> KuaidiLog::where(['number'=>$package->shipping_number, 'code'=>$package->shipping_code])->first()?->info,
        ]));
    }

    /**
     * 订单包裹列表
     */
    public function orderPackages($id, Request $request)
    {
        $order = $request->user()->orders()->findOrFail($id);
        return OrderPackageResource::collection($order->packages()->where('is_failed', false)->orderBy('updated_at', 'desc')->get());
    }

    /**
     * 物流包裹的明细
     *
     * @return void
     */
    public function shippingInfo($id, Request $request)
    {
        $package = $request->user()->orderPackages()->where('is_failed', false)->findOrFail($id);
        return response()->json(array_merge(OrderPackageResource::make($package)->resolve(), [
            'shipping_info'=> KuaidiLog::where(['number'=>$package->shipping_number, 'code'=>$package->shipping_code])->first()?->info,
        ]));
    }
}