infantServiceApi/app/system/controller/Shop.php

<?php
declare (strict_types = 1);

namespace app\system\controller;

use app\BaseController;
use app\model\api\StoreOrder;
use app\model\api\StoreOrderCartInfo;
use app\Request;
use app\services\AliyunExpressService;
use library\services\UtilService;
use think\facade\Db;

class Shop extends BaseController
{
    /**
     * 商城订单统计
     * @param Request $request
     */
    public function total(Request $request)
    {
        $post = UtilService::getMore([
            ['status', ''],
        ], $request);

        $order = Db::name('store_order');
        $totalWhere = [];

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

        //全部
        $orderCount = $order->where($totalWhere)->count();
        //待支付
        $waitPayWhere = $totalWhere;
        $waitPayWhere[] = ['status', '=', 0];
        $waitPayCount = $order->where($waitPayWhere)->count();
        //待发货
        $waitSendWhere = $totalWhere;
        $waitSendWhere[] = ['status', '=', 1];
        $waitSendCount = $order->where($waitSendWhere)->count();
        //待收货
        $waitAcceptWhere = $totalWhere;
        $waitAcceptWhere[] = ['status', '=', 2];
        $waitAcceptCount = $order->where($waitAcceptWhere)->count();
        //已完成
        $okWhere = $totalWhere;
        $okWhere[] = ['status', '=', 3];
        $okCount = $order->where($okWhere)->count();
        //已取消
        $closeWhere = $totalWhere;
        $closeWhere[] = ['status', '=', -1];
        $closeCount = $order->where($closeWhere)->count();

        return app('json')->success([
            'orderCount' => $orderCount,
            'waitPayCount' => $waitPayCount,
            'waitSendCount' => $waitSendCount,
            'waitAcceptCount' => $waitAcceptCount,
            'okCount' => $okCount,
            'closeCount' => $closeCount,
        ]);
    }

    /**
     * 商城订单列表
     * @param Request $request
     */
    public function list(Request $request)
    {
        $pageSize = 50;
        $post = UtilService::getMore([
            ['page', 1],
            ['uid', 0],
            ['mobile', ''],
            ['order_id', ''],
            ['status', ''],
            ['time', []],
        ], $request);

        $where = [];
        if (!empty($post['uid'])) {
            $where[] = ['o.uid', '=', $post['uid']];
        } else if (!empty($post['mobile'])) {
            $m = Db::name('user')->where('mobile', $post['mobile'])->find();
            if (!empty($m)) {
                $where[] = ['o.uid', '=', $m['uid']];
            }
        }
        if (!empty($post['order_id'])) {
            $where[] = ['o.order_id', '=', $post['order_id']];
        }
        if ($post['status'] !== '' && in_array((string)$post['status'], ["0", "1", "2", "3", "-1"])) {
            $where[] = ['o.status', '=', (int)$post['status']];
        }

        //创建时间
        $startTime = '';
        $endTime = '';
        if (!empty($post['time'][0]) && !empty($post['time'][1])) {
            $startTime = strtotime($post['time'][0]);
            $endTime = strtotime($post['time'][1]);
            $where[] = ['o.time', 'between', "{$startTime},{$endTime}"];
        }

//        $order = Db::name('store_order');
        $order = Db::name('store_order')
            ->alias('o')
            ->field('o.*,u.mobile,u.nickname')
            ->leftJoin('user u', 'u.uid = o.uid')
            ->where($where)
            ->page((int)$post['page'], $pageSize)
            ->order('o.id', 'desc')
            ->select()
            ->toArray();

        // 关联订单商品信息
        foreach ($order as &$item) {
            $cartInfo = Db::name('store_order_cart_info')
                ->where('oid', $item['id'])
                ->select()
                ->toArray();
            foreach ($cartInfo as &$cart) {
                if (!empty($cart['cart_info'])) {
                    $innerCartInfo = json_decode($cart['cart_info'], true);
                    unset($cart['cart_info']);
                    $cart = array_merge($cart, $innerCartInfo);
                }
            }
            $item['cart_info'] = $cartInfo;

            // 关联收货地址信息
            if (!empty($item['address_id'])) {
                $address = Db::name('user_address')->where('id', $item['address_id'])->find();
                $item['address'] = $address ?: [];
            } else {
                $item['address'] = [];
            }
//            $item['address_info'] = Db::name('user_address')->where('id', $item['address_id'])->find();

        }

        $pageCount = Db::name('store_order')
            ->alias('o')
            ->leftJoin('user u', 'u.uid = o.uid')
            ->where($where)
            ->count();

        $result = UtilService::getParam([
            'id',
            'order_id',
            'uid',
            'user_phone',
            'address_id',
            'user_address',
//            'mobile',
//            'nickname',
//            'real_name',
//            'tel',
//            'province',
//            'city',
//            'district',
//            'detail',
             'address',
            'cart_info',
            'total_price',
            'pay_price',
            'total_postage',
            'pay_postage',
            'paid',
            'status',
            ['create_time', 'create_time', 'date("Y-m-d H:i:s",$1)'],
            ['pay_time', 'pay_time', function ($item) {
                return empty($item) ? "-" : date('Y-m-d H:i:s', $item);
            }],
            ['confirm_time', 'confirm_time', function ($item) {
                return empty($item) ? "-" : date('Y-m-d H:i:s', $item);
            }],
        ], $order);

        return app('json')->success([
            'list' => $result,
            'pageCount' => $pageCount,
            'pageSize' => $pageSize,
            'page' => $post['page'],
        ]);
    }

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

        $order = Db::name('store_order')
            ->alias('o')
            ->field('o.*,u.mobile,u.nickname')
            ->leftJoin('user u', 'u.uid = o.uid')
            ->where('o.id', $post['id'])
            ->find();

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

        $data = $order;
        //获取订单商品
        $cartInfo = Db::name('store_order_cart_info')
            ->where('oid', $data['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']);
            }
        }
        $data['cart_info'] = $cartInfo;
        $data['address_info'] = Db::name('user_address')->where('id', $data['address_id'])->find();

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

    /**
     * 发货
     * @param Request $request
     */
    public function fahuo(Request $request)
    {
        $post = UtilService::getMore([
            ['id', '', 'empty', '参数错误'],
            ['express_type', ''],
            ['express_code', ''],
            ['express_num', ''],
        ], $request);

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

        if (empty($order)) {
            return app('json')->fail('当前订单不可发货');
        }

        if (empty($post['express_num'])) {
            return app('json')->fail('请输入物流单号');
        }

        $result = Db::name('store_order')->where('id', $post['id'])->update([
            'status' => 2,
            'express_type' => $post['express_type'],
            'express_code' => $post['express_code'],
            'express_num' => $post['express_num'],
            'delivery_time' => time(),
        ]);

        if ($result) {
            return app('json')->success('操作成功');
        } else {
            return app('json')->fail('操作失败');
        }
    }

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

        $order = Db::name('store_order')
            ->where('id', $post['id'])
            ->find();

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

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

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

        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);
    }

    /**
     * 订单备注
     * @param Request $request
     */
    public function mono(Request $request)
    {
        $post = UtilService::getMore([
            ['id', '', 'empty', '参数错误'],
            ['remark', '', 'empty', '请输入备注内容'],
        ], $request);

        $order = Db::name('store_order')->where('id', $post['id'])->find();
        if (empty($order)) {
            return app('json')->fail('订单不存在');
        }

        $result = Db::name('store_order')->where('id', $post['id'])->update([
            'remark' => $post['remark'],
        ]);

        if ($result) {
            return app('json')->success('操作成功');
        } else {
            return app('json')->fail('操作失败');
        }
    }
}