infantServiceApi/app/api/controller/Shop.php

<?php
declare (strict_types=1);

namespace app\api\controller;

use app\BaseController;
use app\model\api\StoreOrder;
use app\model\api\StoreOrderCartInfo;
use app\model\api\StoreCart;
use app\model\api\PayTrade;
use app\model\api\UserAddress;
use app\model\api\StoreProductAttrValue;
use app\model\api\UserScoreDetail;
use app\Request;
use library\services\UtilService;
use think\facade\Db;
use think\db\exception\DbException;

class Shop extends BaseController
{
    /**
     * 创建订单
     * @param Request $request
     */
    public function createOrder(Request $request)
    {
        $post = UtilService::getMore([
            ['cart_ids', '', 'empty', '参数错误'],
            ['address_id', 0],
        ], $request);

        // 获取购物车商品
        $cartIds = explode(',', (string)$post['cart_ids']);
        $cartList = Db::name('store_cart')
            ->whereIn('id', $cartIds)
            ->where('uid', $request->user['uid'])
            ->select()
            ->toArray();

        if (empty($cartList)) {
            return app('json')->fail('购物车商品不存在');
        }

        // 获取收货地址
        $address = null;
        if ($post['address_id'] > 0) {
            $address = Db::name('user_address')->where('id', $post['address_id'])->find();
        }

        if (!$address) {
            $address = (new UserAddress())->getDefaultAddress($request->user['uid']);
        }

        if (!$address) {
            return app('json')->fail('请先添加收货地址');
        }

        // 计算订单金额
        $totalMoney = 0;
        $payMoney = 0;
        $cartInfo = [];
        $totalNum = 0;  // 总商品数量

        foreach ($cartList as $cart) {
            $product = Db::name('store_product')->where('id', $cart['product_id'])->find();
            if (!$product) {
                continue;
            }

            $price = $product['price'];
            $skuPrice = null;

            // 如果有SKU，获取SKU价格
            if (!empty($cart['product_attr_unique'])) {
                $sku = (new StoreProductAttrValue())->getSkuBySuk($cart['product_id'], $cart['product_attr_unique']);
                if ($sku) {
                    $price = $sku['price'];
                }
            }

            $cartNum = (int)($cart['cart_num'] ?? 1);
            $productMoney = $price * $cartNum;
            $totalMoney += $productMoney;
            $totalNum += $cartNum;  // 累加总数量

            $cartInfo[] = [
                'cart_id' => $cart['id'],
                'product_id' => $cart['product_id'],
                'product_name' => $product['store_name'] ?? '',
                'cart_info' => json_encode([
                    'cart_num' => $cartNum,
                    'product_attr_unique' => $cart['product_attr_unique'] ?? '',
                    'image' => $product['image'] ?? '',
                    'price' => $price,
                    'total_price' => $productMoney,
                ], JSON_UNESCAPED_UNICODE),
                'unique' => $cart['product_attr_unique'] ?: uniqid('cart_', true),
            ];
        }

        // 运费（暂时设置为0，后续可以根据运费模板计算）
        $postage = 0;
        $payMoney = $totalMoney + $postage;

        // 生成订单号
        $orderId = makeOrderId($request->user['uid'], 'SO');

        // 检查用户积分是否足够
        $userScore = Db::name('user')->where('uid', $request->user['uid'])->value('score') ?? 0;
        if ($userScore < $payMoney) {
            return app('json')->fail('积分不足，当前积分：' . $userScore . '，需要：' . $payMoney);
        }

        // 开启事务
        Db::startTrans();
        try {
            // 创建订单
            $orderData = [
                'order_id' => $orderId,
                'uid' => $request->user['uid'],
                'real_name' => $address['real_name'],
                'user_phone' => $address['phone'],
                'user_address' => $address['detail'],
                'total_price' => $totalMoney,
                'total_num' => $totalNum,
                'total_postage' => $postage,
                'pay_price' => $payMoney,
                'pay_postage' => $postage,
                'paid' => 0,
                'status' => 0,
                'create_time' => time(),
            ];

            $orderIdDb = Db::name('store_order')->insertGetId($orderData);

            // 创建订单商品
            foreach ($cartInfo as &$item) {
                $item['oid'] = $orderIdDb;
                $item['order_id'] = $orderId;
            }
            Db::name('store_order_cart_info')->insertAll($cartInfo);

            // 扣除用户积分
            $scoreDetail = new UserScoreDetail();
            $scoreResult = $scoreDetail->payScore(
                $request->user['uid'],
                $payMoney,
                'outcome_score',
                '商城订单：' . $orderId,
                ['o_id' => $orderIdDb],
                '',
                '商城购买积分抵扣支出，支出' . $payMoney . '积分'
            );

            if (!$scoreResult) {
                Db::rollback();
                return app('json')->fail('积分扣除失败');
            }

            // 创建支付流水
            $payTrade = new PayTrade();
            $payTrade->credentials(
                'score',
                $request->user['uid'],
                'shop_order',
                $payMoney,
                '商城订单积分支付',
                $orderId,
                ['order_id' => $orderId],
                0,
                'shop_score',
                $orderIdDb
            );

            // 更新订单为已支付状态（积分支付直接完成）
            Db::name('store_order')->where('id', $orderIdDb)->update([
                'paid' => 1,
                'pay_time' => time()
            ]);

            // 清除购物车
            Db::name('store_cart')->whereIn('id', $cartIds)->delete();

            Db::commit();

            return app('json')->success('订单创建成功', [
                'order_id' => $orderId,
                'pay_money' => $payMoney,
            ]);

        } catch (DbException $e) {
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [createOrder Error] ' . $e->getMessage() . ' File: ' . $e->getFile() . ' Line: ' . $e->getLine() . "创建订单报错\r\n", 8);

            Db::rollback();
            return app('json')->fail('订单创建失败');
        }
    }

    /**
     * 订单列表
     * @param Request $request
     */
    public function orderList(Request $request)
    {
        $post = UtilService::getMore([
            ['page', 1],
            ['pageSize', 20],
            ['status', ''],
        ], $request);

        $where = [
            ['uid', '=', $request->user['uid']]
        ];

        if ($post['status'] !== '' && in_array((string)$post['status'], ["0", "1", "2", "3", "-1"])) {
            $where[] = ['status', '=', (int)$post['status']];
        }

        $result = (new StoreOrder())->getList($where, $post['page'], $post['pageSize']);

        return app('json')->success($result);
    }

    /**
     * 订单详情
     * @param Request $request
     */
    public function orderDetail(Request $request)
    {
        $post = UtilService::getMore([
            ['order_id', '', 'empty', '参数错误'],
        ], $request);

        $order = Db::name('store_order')
            ->where('order_id', $post['order_id'])
            ->where('uid', $request->user['uid'])
            ->find();

        if (!$order) {
            return app('json')->fail('订单不存在');
        }

        // 获取订单商品
        $cartInfo = Db::name('store_order_cart_info')
            ->where('oid', $order['id'])
            ->select()
            ->toArray();

        $order['cart_info'] = $cartInfo;

        return app('json')->success($order);
    }

    /**
     * 取消订单
     * @param Request $request
     */
    public function cancelOrder(Request $request)
    {
        $post = UtilService::getMore([
            ['order_id', '', 'empty', '参数错误'],
        ], $request);

        $order = Db::name('store_order')
            ->where('order_id', $post['order_id'])
            ->where('uid', $request->user['uid'])
            ->where('status', 0)
            ->find();

        if (!$order) {
            return app('json')->fail('订单不存在或已取消');
        }

        Db::startTrans();
        try {
            // 退还用户积分（如果是积分支付且已支付）
            if ($order['paid'] == 1) {
                $userScore = new UserScoreDetail();
                $result = $userScore->incomeScore(
                    $request->user['uid'],
                    $order['pay_price'],
                    $order['order_id'],
                    'score_refund',
                    [],
                    $order['id'],
                    '积分退款',
                    '商城订单取消退还积分：' . $order['order_id']
                );

                if (!$result) {
                    Db::rollback();
                    return app('json')->fail('积分退还失败');
                }
            }

            Db::name('store_order')->where('id', $order['id'])->update(['status' => -1]);
            Db::commit();

            return app('json')->success('订单已取消，积分已退还');
        } catch (\Exception $e) {
            Db::rollback();
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [cancelOrder Error] ' . $e->getMessage() . "\r\n", 8);
            return app('json')->fail('取消订单失败');
        }
    }

    /**
     * 确认收货
     * @param Request $request
     */
    public function confirmOrder(Request $request)
    {
        $post = UtilService::getMore([
            ['order_id', '', 'empty', '参数错误'],
        ], $request);

        $order = Db::name('store_order')
            ->where('order_id', $post['order_id'])
            ->where('uid', $request->user['uid'])
            ->where('status', 2)
            ->find();

        if (!$order) {
            return app('json')->fail('订单不存在或状态错误');
        }

        Db::name('store_order')->where('id', $order['id'])->update([
            'status' => 3,
            'confirm_time' => time()
        ]);

        return app('json')->success('确认收货成功');
    }
}