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\model\api\User as UserModel;
use app\Request;
use app\services\AliyunExpressService;
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'] ?? '',
            ];
        }

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

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

        // 开启事务
        Db::startTrans();
        try {
            // 创建订单
            $orderData = [
                'order_id' => $orderId,
                'uid' => $request->user['uid'],
                'real_name' => $address['real_name'],
                'user_phone' => $address['phone'],
//                'province' => $address['province'],
//                'city' => $address['city'],
//                'district' => $address['district'],
                'user_address' => $address['detail'],
                'address_id' => $post['address_id'],
                '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);

            // 创建支付流水
            $mtime = microtime(true) * 10000;
            $payOn = "T" . date("Ymd") . $mtime . rand(100, 999) . $request->user['uid'];
            $trade = [
                'uid' => $request->user['uid'],
                'o_id' => $orderIdDb,
                'order_id' => $orderId,
                'pay_no' => $payOn,
                'out_trade_no' => '',
                'pay_type' => 'score',
                'money' => $payMoney,
                'type' => 'shop_order',
                'd_json' => serialize(['order_id' => $orderId]),
                'time' => time(),
                'status' => 0,
            ];
            Db::name('pay_trade')->insert($trade);

            // 清除购物车
            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);

        $post['page'] = (int)$post['page'];
        $post['pageSize'] = (int)$post['pageSize'];

        $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();

        // 解析 cart_info JSON 字段并合并到外层
        foreach ($cartInfo as &$item) {
            if (!empty($item['cart_info'])) {
                $innerCartInfo = json_decode($item['cart_info'], true);
                unset($item['cart_info']);
                $item = array_merge($item, $innerCartInfo);
            } else {
                unset($item['cart_info']);
            }
        }

        $order['cart_info'] = $cartInfo;
        $order['address_info'] = Db::name('user_address')->where('id', $order['address_id'])->find();
        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::name('store_order')->where('id', $order['id'])->update(['status' => -1]);

        return app('json')->success('订单已取消');
    }

    /**
     * 确认收货
     * @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('确认收货成功');
    }

    /**
     * 积分支付
     * @param Request $request
     */
    public function scorePay(Request $request)
    {
        $post = UtilService::getMore([
            ['order_id', '', 'empty', '参数错误'],
        ], $request);

        // 查询订单
        $orderData = Db::name('store_order')
            ->where('order_id', $post['order_id'])
            ->where('uid', $request->user['uid'])
            ->find();

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

        if ($orderData['status'] != 0) {
            return app('json')->fail('订单状态错误');
        }

        if ($orderData['paid'] == 1) {
            return app('json')->fail('订单已支付');
        }

        // 检查用户积分
        $userData = (new UserModel)->where('uid', $request->user['uid'])->find();
        if (empty($userData)) {
            return app('json')->fail('用户不存在');
        }

        if ($userData['score'] < $orderData['pay_price']) {
            return app('json')->fail('积分不足，当前积分：' . $userData['score'] . '，需要：' . $orderData['pay_price']);
        }

        // 开启事务
        Db::startTrans();
        try {
            // 扣除积分
            $scoreResult = (new UserScoreDetail)->payScore(
                $request->user['uid'],
                floatval($orderData['pay_price']),
                'outcome_score',
                '订单支付：' . $orderData['order_id'],
                ['o_id' => $orderData['id']],
                '积分支付',
                '商城订单积分支付，支出' . $orderData['pay_price'] . '积分'
            );

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

            // 更新订单状态
            Db::name('store_order')->where('id', $orderData['id'])->update([
                'paid' => 1,
                'status' => 1,
                'pay_time' => time()
            ]);

            Db::commit();
            return app('json')->success('积分支付成功');
        } catch (DbException $e) {
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [scorePay Error] ' . $e->getMessage() . ' File: ' . $e->getFile() . ' Line: ' . $e->getLine() . "\r\n", 8);

            Db::rollback();
            return app('json')->fail('支付失败');
        }
    }

    /**
     * 查询物流信息
     * @param Request $request
     */
    public function express(Request $request)
    {
        try {
            $post = UtilService::getMore([
                ['order_id', '', 'empty', '参数错误'],
            ], $request);

            // 断点1：记录请求参数
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [express] 请求参数: ' . json_encode($post, JSON_UNESCAPED_UNICODE) . "\r\n", 8);

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

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

            // 断点2：记录订单物流字段
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [express] 订单物流信息: express_num=' . ($order['express_num'] ?? '') . ', express_code=' . ($order['express_code'] ?? '') . ', express_type=' . ($order['express_type'] ?? '') . "\r\n", 8);

            if (empty($order['express_num'])) {
                return app('json')->fail('暂无物流信息');
            }

            $service = new AliyunExpressService();

            $result = $service->query($order['express_num'], $order['express_code'] ?? '');

            // 断点4：记录阿里云接口原始返回
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [express] 阿里云返回: ' . json_encode($result, JSON_UNESCAPED_UNICODE) . "\r\n", 8);

            if ($result === false) {
                return app('json')->fail('物流查询失败，请检查阿里云物流AppCode配置');
            }

            $data = [
                'express_type' => $order['express_type'] ?? '',
                'express_code' => $order['express_code'] ?? '',
                'express_num'  => $order['express_num'],
                'list'         => $result['result']['list'] ?? [],
                'status'       => $result['result']['deliverystatus'] ?? -1,
                'status_text'  => $service->getStatusText((int)($result['result']['deliverystatus'] ?? -1)),
            ];

            return app('json')->success('查询成功', $data);
        } catch (\Exception $e) {
            @file_put_contents('quanju.txt', date('Y-m-d H:i:s') . ' [express Error] ' . $e->getMessage() . ' File: ' . $e->getFile() . ' Line: ' . $e->getLine() . "\r\n", 8);
            return app('json')->fail('物流查询异常：' . $e->getMessage());
        }
    }
}