fastadmin_tailored/application/api/controller/Order.php

<?php

namespace app\api\controller;

use app\common\model\UserCoupon;
use app\common\model\Carts;
use app\common\model\Order as OrderModel;
use app\common\model\Address;
use app\common\model\Third;
use app\common\model\OrderAction;
use app\common\model\OrderGoods;
use app\common\library\KdApiExpOrder;
use think\Db;

/**
 * 订单接口
 */
class Order extends Base
{
    protected $noNeedLogin = [];

    //计算邮费，判断商品 - 支持购物车和商品规格两种模式
    public function calculate()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        $postData = $this->request->post();
        $postData['calculate_data'] = '1'; // 添加触发自定义验证的字段
        if (!$validate->scene('calculate')->check($postData)) {
            $this->error($validate->getError());
        }
        
        $config = get_addon_config('shop');
        $address_id = $this->request->post('address_id/d'); // 地址id
        $user_coupon_id = $this->request->post('user_coupon_id/d'); // 优惠券
        $cart_ids = $this->request->post('cart_ids/a'); // 购物车ID数组
        $goods_list = $this->request->post('goods_list/a'); // 商品列表
        
        $address = Address::get($address_id);
        $area_id = !empty($address) ? $address->area_id : 0;
        
        try {
            // 自动判断数据源类型并获取标准化的商品列表
            if (!empty($cart_ids)) {
                // 购物车模式：先转换为商品列表
                $goods_list = \app\common\Service\Cart::convertCartToGoodsList($cart_ids, $this->auth->id);
            } elseif (empty($goods_list)) {
                throw new \Exception("请提供购物车ID或商品列表");
            }
            
            // 统一调用计算方法
            $result = \app\common\Service\OrderService::calculateOrder($goods_list, $this->auth->id, $area_id, $user_coupon_id);
            $orderItem = $result['orderItem'];
            $goodsList = $result['goodsList'];
            $orderInfo = $result['orderInfo'];
            $userCoupon = $result['userCoupon'];
            
            if (empty($goodsList)) {
                throw new \Exception("未找到商品");
            }
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        
        // 处理商品数据
        foreach ($goodsList as $item) {
            $item->category_id = $item->goods->category_id;
            $item->brand_id = $item->goods->brand_id;
            $item->goods->visible(explode(',', 'id,title,image,price,marketprice'));
        }
        
        // 获取我的可以使用的优惠券
        $goods_ids    = array_column($goodsList, 'goods_id');
        $category_ids = array_column($goodsList, 'category_id');
        $brand_ids    = array_column($goodsList, 'brand_id');

        $this->success('获取成功', [
            'coupons'          => UserCoupon::myGoodsCoupon($this->auth->id, $goods_ids, $category_ids, $brand_ids),
            'goods_list'       => $goodsList,
            'order_info'       => $orderInfo,            
        ]);
    }


    //提交订单 - 统一接口
    public function create()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        if (!$validate->scene('create')->check($this->request->post())) {
            $this->error($validate->getError());
        }
        
        $address_id = $this->request->post('address_id/d'); // 地址id
        $user_coupon_id = $this->request->post('user_coupon_id/d'); // 优惠券id
        $remark = $this->request->post('remark','','trim'); // 备注
        $cart_ids = $this->request->post('cart_ids/a'); // 购物车ID数组
        $goods_list = $this->request->post('goods_list/a'); // 商品列表
        
        $order = null;
        try {
            if (!empty($cart_ids)) {
                // 购物车模式 - 校验购物车id合法性
                $row = (new Carts)->where('id', 'IN', $cart_ids)->where('user_id', '<>', $this->auth->id)->find();
                if ($row) {
                    $this->error('存在不合法购物车数据');
                }
                
                // 先转换购物车为商品列表
                $goods_list = \app\common\Service\CartService::convertCartToGoodsList($cart_ids, $this->auth->id);
                
                // 创建订单
                $order = \app\common\Service\OrderService::createOrder($address_id, $this->auth->id, $goods_list, $user_coupon_id, $remark);
                
                // 购物车订单创建成功后清理购物车
                \app\common\Service\CartService::clear($cart_ids);
            } elseif (!empty($goods_list)) {
                // 商品列表模式 - 直接创建订单
                $order = \app\common\Service\OrderService::createOrder($address_id, $this->auth->id, $goods_list, $user_coupon_id, $remark);
            } else {
                $this->error('请提供购物车ID或商品列表');
            }
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        
        $this->success('下单成功！', array_intersect_key($order->toArray(), array_flip(['order_sn', 'paystate'])));
    }

    //订单详情
    public function detail()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        $params = ['order_sn' => $this->request->param('order_sn')];
        if (!$validate->scene('detail')->check($params)) {
            $this->error($validate->getError());
        }
        
        $order_sn = $this->request->param('order_sn');
        $order = OrderModel::getDetail($order_sn, $this->auth->id);
        if (empty($order)) {
            $this->error('未找到订单');
        }
        if (OrderModel::isExpired($order_sn)) {
            $this->error("订单已经失效");
        }
        $order->append(['status_text']);
        $order->hidden(explode(',', 'method,transactionid,updatetime,deletetime'));
        $order->expiretime = $order->expiretime - time();
        $this->success('', $order);
    }

    //订单列表
    public function index()
    {
        $param = $this->request->param();
        $param['user_id'] = $this->auth->id;
        $list = OrderModel::tableList($param);
        foreach ($list as $item) {
            $item->append(['status_text']);
            $field = 'id,order_sn,amount,expressno,expressname,saleamount,shippingfee,paystate,orderstate,shippingstate,order_goods,status,status_text';
            $item->visible(explode(',', $field));
        }
        $this->success('获取成功', $list);
    }

    //取消订单
    public function cancel()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        if (!$validate->scene('cancel')->check($this->request->post())) {
            $this->error($validate->getError());
        }
        
        $order_sn = $this->request->post('order_sn');
        $order = OrderModel::getByOrderSn($order_sn);
        if (empty($order)) {
            $this->error('订单不存在');
        }
        if ($order->user_id != $this->auth->id) {
            $this->error('不能越权操作');
        }
        if ($order->status == 'hidden') {
            $this->error('订单已失效！');
        }
        //可以取消
        if (!$order->paystate && !$order->orderstate) {
            // 启动事务
            Db::startTrans();
            try {
                $order->orderstate = 1;
                $order->canceltime = time();
                $order->save();
                foreach ($order->order_goods as $item) {
                    $sku = $item->sku;
                    $goods = $item->goods;
                    //商品库存恢复
                    if ($sku) {
                        $sku->setInc('stocks', $item->nums);
                    }
                    if ($goods) {
                        $goods->setInc('stocks', $item->nums);
                    }
                }
                //恢复优惠券
                UserCoupon::resetUserCoupon($order->user_coupon_id, $order->order_sn);
                // 提交事务
                Db::commit();
            } catch (\Exception $e) {
                // 回滚事务
                Db::rollback();
                $this->error('订单取消失败');
            }
            //记录操作
            OrderAction::push($order->order_sn, '系统', '订单取消成功');
            $this->success('订单取消成功！', $order['status']);
        } else {
            $this->error('订单不允许取消');
        }
    }

    //订单支付
    public function pay()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        if (!$validate->scene('pay')->check($this->request->post())) {
            $this->error($validate->getError());
        }
        
        $order_sn = $this->request->post('order_sn');
        $paytype = $this->request->post('paytype');
        $method = $this->request->post('method');
        $appid = $this->request->post('appid'); //为APP的应用id
        $returnurl = $this->request->post('returnurl', '', 'trim');
        $openid = $this->request->post('openid', '', null);
        $logincode = $this->request->post('logincode', '', null);

        $orderInfo = OrderModel::getByOrderSn($order_sn);
        if (!$orderInfo) {
            $this->error("未找到指定的订单");
        }
        if ($orderInfo['paystate']) {
            $this->error("订单已经支付，请勿重复支付");
        }
        if (OrderModel::isExpired($order_sn)) {
            $this->error("订单已经失效");
        }

        //如果有传递logincode，则直接使用code换openid
        if (!$openid && $logincode) {
            $json = (new \addons\shop\library\Wechat\Service())->getWechatSession($logincode);
            $openid = $json['openid'] ?? $openid;
        }

        //必须传递openid
        if (in_array($method, ['miniapp', 'mp', 'mini']) && !$openid) {
            $this->error("未找到第三方用户信息", 'bind');
        }

        $response = null;
        try {
            $response = OrderModel::pay($order_sn, $this->auth->id, $paytype, $method, $openid, '', $returnurl);
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        $this->success("请求成功", $response);
    }

    //确认收货
    public function receipt()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        $params = ['order_sn' => $this->request->post('order_sn')];
        if (!$validate->scene('detail')->check($params)) {
            $this->error($validate->getError());
        }
        
        $order_sn = $this->request->post('order_sn');
        $order = OrderModel::getByOrderSn($order_sn);
        if (empty($order)) {
            $this->error('订单不存在');
        }
        if ($order->user_id != $this->auth->id) {
            $this->error('不能越权操作');
        }
        if ($order->status == 'hidden') {
            $this->error('订单已失效！');
        }
        if ($order->paystate == 1 && !$order->orderstate && $order->shippingstate == 1) {
            $order->shippingstate = 2;
            $order->receivetime = time();
            $order->save();
            //记录操作
            OrderAction::push($order->order_sn, '系统', '订单确认收货成功');
            $this->success('确认收货成功');
        }
        $this->error('未可确认收货');
    }

    //查询物流
    public function logistics()
    {
        // 验证请求参数
        $validate = new \app\api\validate\Order();
        $params = ['order_sn' => $this->request->param('order_sn')];
        if (!$validate->scene('detail')->check($params)) {
            $this->error($validate->getError());
        }
        
        $order_sn = $this->request->param('order_sn');
        $order = OrderModel::getDetail($order_sn, $this->auth->id);
        if (empty($order)) {
            $this->error('未找到订单');
        }
        if (!$order->shippingstate) {
            $this->error('订单未发货');
        }
        $electronics = Db::name('shop_order_electronics')->where('order_sn', $order_sn)->where('status', 0)->find();
        if (!$electronics) {
            $this->error('订单未发货');
        }
        $result = KdApiExpOrder::getLogisticsQuery([
            'order_sn'      => $order_sn,
            'logistic_code' => $electronics['logistic_code'],
            'shipper_code'  => $electronics['shipper_code']
        ]);
        if ($result['Success']) {
            $this->success('查询成功', $result['Traces']);
        }
        $this->error('查询失败');
    }
}