fastadmin_tailored/application/admin/controller/shop/Order.php

<?php

namespace app\admin\controller\shop;

use addons\shop\model\TemplateMsg;
use app\common\controller\Backend;
use app\admin\model\shop\OrderGoods;
use app\admin\model\shop\OrderAftersales;
use app\admin\model\shop\OrderAction;
use app\admin\model\shop\OrderElectronics;
use app\common\Enum\OrderEnum;
use app\common\Enum\GoodsEnum;
use app\common\Enum\PayEnum;
use app\common\Enum\ChannelEnum;
use think\Db;

/**
 * 订单管理
 *
 * @icon fa fa-circle-o
 */
class Order extends Backend
{

    /**
     * Order模型对象
     * @var \app\admin\model\shop\Order
     */
    protected $model = null;
    protected $relationSearch = true;
    protected $searchFields = 'id,order_sn';

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new \app\admin\model\shop\Order;
        
        // 视图赋值
        $this->view->assign("orderStatusList", OrderEnum::getOrderStatusList());
        $this->view->assign("statusList", $this->model->getStatusList());
        $this->view->assign("payModeList", OrderEnum::getPayModeList());
        $this->view->assign("payTypeList", PayEnum::getPayMethodList());
        $this->view->assign("orderTypeList", OrderEnum::getOrderTypeList());
        $this->view->assign("deliveryTypeList", OrderEnum::getDeliveryTypeList());
        $this->view->assign("invoiceStatusList", OrderEnum::getInvoiceStatusList());
        $this->view->assign("activityTypeList", OrderEnum::getActivityTypeList());
        $this->view->assign("actionTypeList", OrderEnum::getActionTypeList());
        $this->view->assign("saleStatusList", GoodsEnum::getSaleStatusMap());
        
        // 前端配置
        $this->assignconfig('orderStatusList', json_encode(OrderEnum::getOrderStatusList()));
        $this->assignconfig('payModeList', json_encode(OrderEnum::getPayModeList()));
        $this->assignconfig('payTypeList', json_encode(PayEnum::getPayMethodList()));
        $this->assignconfig('statusList', json_encode($this->model->getStatusList()));
        $this->assignconfig('orderTypeList', json_encode(OrderEnum::getOrderTypeList()));
        $this->assignconfig('deliveryTypeList', json_encode(OrderEnum::getDeliveryTypeList()));
        $this->assignconfig('invoiceStatusList', json_encode(OrderEnum::getInvoiceStatusList()));
        $this->assignconfig('activityTypeList', json_encode(OrderEnum::getActivityTypeList()));
        $this->assignconfig('actionTypeList', json_encode(OrderEnum::getActionTypeList()));
        $this->assignconfig('saleStatusList', json_encode(GoodsEnum::getSaleStatusMap()));
    }

    /**
     * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
     * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
     * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
     */

    /**
     * 查看
     */
    public function index()
    {
        //设置过滤方法
        $this->request->filter(['strip_tags', 'trim']);
        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }
            list($where, $sort, $order, $offset, $limit, , $alias) = $this->buildparams();
            $a = reset($alias);
            $list = $this->model
                ->with(['OrderAddress','OrderGoods','User'])
                ->order('createtime desc')
                ->where($where)
                ->paginate($limit);



            $result = array("total" => $list->total(), "rows" => $list->items());

            return json($result);
        }
        $config = get_addon_config('shop');
        $this->assignconfig('shop', $config);
        return $this->view->fetch();
    }

    //发货单列表
    public function orderList()
    {
        $ids = $this->request->post('ids/a');
        if (empty($ids)) {
            $this->error('参数错误');
        }
        $orderList = $this->model->with(['User', 'OrderGoods'])->order('createtime desc')->where('id', 'IN', $ids)->select();

        foreach ($orderList as $index => $item) {
            if ($item->user) {
                $item->user->visible(['id', 'nickname', 'avatar']);
            }
        }

        $orderList = collection($orderList)->toArray();
        foreach ($orderList as $index => $item) {
            $nums = 0;
            foreach ($item['order_goods'] as $key => $goods) {
                if ($goods['salestate'] == 4 || $goods['salestate'] == 5) {
                    unset($orderList[$index]['order_goods'][$key]);
                } else {
                    $nums += $goods['nums'];
                }
            }
            $orderList[$index]['nums'] = $nums;
        }
        $this->success('获取成功', '', ['orderList' => $orderList]);
    }

    //订单详情
    public function detail()
    {
        $id = $this->request->param('ids');
        if (!$id) {
            $this->error('参数错误');
        }
        
        // 查询订单信息，包括关联的用户、商品、操作记录、收货地址
        $row = $this->model
            ->field('o.*,sum(s.refund) refund')
            ->with([
                'User' => function($query) {
                    $query->field('id,username,nickname,avatar,email,mobile');
                },
                'OrderGoods' => function($query) {
                    $query->field('*');
                },
                'OrderAddress' => function($query) {
                    $query->field('*');
                }
            ])
            ->where('o.id', $id)
            ->alias('o')
            ->join('shop_order_aftersales s', 'o.id=s.order_id and s.status=2 and s.type <> 3', 'LEFT')
            ->find();

        if (!$row) {
            $this->error('记录未找到');
        }

        // 添加枚举文本转换
        $row['order_status_text'] = OrderEnum::getOrderStatusText($row['order_status']);
        $row['source_text'] = $this->getSourceText($row['source']);
        $row['type_text'] = $this->getTypeText($row['type']);
        $row['pay_type_text'] = $this->getPayTypeText($row['pay_type']);
        $row['pay_mode_text'] = $this->getPayModeText($row['pay_mode']);
        $row['delivery_type_text'] = $this->getDeliveryTypeText($row['delivery_type']);
        $row['invoice_status_text'] = $this->getInvoiceStatusText($row['invoice_status']);
        $row['activity_type_text'] = $this->getActivityTypeText($row['activity_type']);
        
        // 处理订单商品的规格信息和售后状态文本
        if ($row->order_goods) {
            $orderGoods = [];
            foreach ($row->order_goods as $index => $item) {
                $itemData = $item->toArray();
                // 格式化商品规格属性
                $itemData['goods_sku_attr_formatted'] = $this->formatGoodsSkuAttr($itemData['goods_sku_attr']);
                // 处理售后状态文本
                $itemData['sale_status_text'] = $this->getSaleStatusText($itemData['sale_status']);
                $orderGoods[] = $itemData;
            }
            $row['order_goods'] = $orderGoods;
        }
        
        // 单独查询订单操作记录（因为使用order_sn关联）
        $orderActionResult = Db::name('shop_order_action')
            ->where('order_sn', $row['order_sn'])
            ->order('createtime desc')
            ->select();
        
        // 转换为数组并处理操作记录文本
        $orderActions = [];
        if ($orderActionResult) {
            $orderActions = collection($orderActionResult)->toArray();
            foreach ($orderActions as &$action) {
                $action['action_type_text'] = $this->getActionTypeText($action['action_type'] ?? '');
            }
        }
        
        // 将操作记录添加到订单数据中
        $row['order_action'] = $orderActions;

        // 重新计算商品折扣价格（基于新字段）
        // $this->calculateGoodsDiscountPrice($row);

        $config = get_addon_config('shop');
        $this->assignconfig('shop', $config);

        $this->view->assign('row', $row);
        return $this->view->fetch();
    }

    /**
     * 计算商品折扣后的价格
     */
    private function calculateGoodsDiscountPrice(&$row)
    {
        if (!isset($row['order_goods']) || empty($row['order_goods'])) {
            return;
        }

        // 使用新的字段名进行计算
        $orderAmount = bcsub($row['order_amount'], $row['express_fee'], 2);
        $goodsPrice = $row['goods_price'];
        $discountRatio = $goodsPrice > 0 ? bcdiv($orderAmount, $goodsPrice, 10) : 1;
        $remainingAmount = $orderAmount;
        
        $orderGoods = $row['order_goods'];
        $goodsCount = count($orderGoods);
        foreach ($orderGoods as $index => $item) {
            if ($index == $goodsCount - 1) {
                // 最后一个商品，使用剩余金额
                $discountPrice = $remainingAmount;
            } else {
                // 计算折扣后价格
                $originalPrice = bcmul($item['goods_original_price'], $item['nums'], 2);
                $discountPrice = $row['discount_fee'] == 0 ? $originalPrice : bcmul($originalPrice, $discountRatio, 2);
            }
            $remainingAmount = bcsub($remainingAmount, $discountPrice, 2);
            $row['order_goods'][$index]['discount_price'] = $discountPrice;
        }
    }

    /**
     * 获取订单来源文本
     */
    private function getSourceText($source)
    {
        // 映射数据库中的source字段到ChannelEnum
        $sourceMapping = [
            'H5' => ChannelEnum::CHANNEL_H5,
            'WechatOfficialAccount' => ChannelEnum::CHANNEL_WECHAT_OFFICIAL_ACCOUNT,
            'WechatMiniProgram' => ChannelEnum::CHANNEL_WECHAT_MINI_PROGRAM,
            'App' => ChannelEnum::CHANNEL_IOS_APP, // 默认使用iOS
            'PC' => ChannelEnum::CHANNEL_PC,
            'Admin' => ChannelEnum::CHANNEL_PC, // 后台创建归为PC
        ];
        
        $channelType = $sourceMapping[$source] ?? $source;
        return ChannelEnum::getChannelText($channelType);
    }

    /**
     * 获取订单类型文本
     */
    private function getTypeText($type)
    {
        return OrderEnum::getOrderTypeText($type);
    }

    /**
     * 获取支付方式文本
     */
    private function getPayTypeText($payType)
    {
        // 直接使用PayEnum获取支付方式文本
        return PayEnum::getPayMethodText($payType);
    }

    /**
     * 获取支付模式文本
     */
    private function getPayModeText($payMode)
    {
        // 直接使用OrderEnum的支付模式枚举
        return OrderEnum::getPayModeText($payMode);
    }

    /**
     * 获取发货方式文本
     */
    private function getDeliveryTypeText($deliveryType)
    {
        return OrderEnum::getDeliveryTypeText($deliveryType);
    }

    /**
     * 获取发票状态文本
     */
    private function getInvoiceStatusText($invoiceStatus)
    {
        return OrderEnum::getInvoiceStatusText($invoiceStatus);
    }

    /**
     * 获取活动类型文本
     */
    private function getActivityTypeText($activityType)
    {
        return OrderEnum::getActivityTypeText($activityType);
    }

    /**
     * 获取操作类型文本
     */
    private function getActionTypeText($actionType)
    {
        return OrderEnum::getActionTypeText($actionType);
    }

    /**
     * 获取售后状态文本
     */
    private function getSaleStatusText($saleStatus)
    {
        return GoodsEnum::getSaleStatusText($saleStatus);
    }

    /**
     * 格式化商品规格属性
     */
    private function formatGoodsSkuAttr($goodsSkuAttr)
    {
        if (empty($goodsSkuAttr)) {
            return [];
        }

        // 尝试解析JSON格式的规格信息
        $decoded = json_decode($goodsSkuAttr, true);
        if (json_last_error() === JSON_ERROR_NONE && is_array($decoded)) {
            return $decoded;
        }

        // 如果不是JSON格式，直接返回原始字符串（兼容旧格式）
        return [
            [
                'name' => '规格',
                'value' => $goodsSkuAttr
            ]
        ];
    }

    //订单状态操作
    public function edit_status()
    {
        $order_status = $this->request->post('order_status');
        $pay_time = $this->request->post('pay_time');
        $order_id = $this->request->post('order_id');

        $order = $this->model->where('id', $order_id)->find();
        if (!$order) {
            $this->error('未找到订单记录');
        }
        //取消
        if ($order_status == OrderEnum::STATUS_CANCEL && $order->order_status == OrderEnum::STATUS_CREATE && !$order->pay_time) {
            $order->order_status = OrderEnum::STATUS_CANCEL;
            $order->cancel_time = time();
            $order->save();
            $this->success('取消成功');
        }
        // 支付
        if ($pay_time && $order->order_status == OrderEnum::STATUS_CREATE && !$order->pay_time) {
            $order->order_status = OrderEnum::STATUS_PAY;
            $order->pay_type = 'system';
            $order->pay_amount = $order->amount;
            $order->pay_time = time();
            $order->save();

            //发送通知
            //TemplateMsg::sendTempMsg(0, $order->order_sn);
            $this->success('操作成功');
        }
        //已完成
        if ($order_status == OrderEnum::STATUS_CONFIRM && $order->order_status == OrderEnum::STATUS_PAY && $order->pay_time) {
            $order->order_status = OrderEnum::STATUS_CONFIRM;
            $order->save();
            OrderAction::push($order->order_sn, '更改订单为已完成', '管理员');
            $this->success('操作成功');
        } elseif ($order->order_status == OrderEnum::STATUS_REFUND) {
            $this->error("请完成售后后再进行操作");
        }

        $this->error('没有权限操作');
    }


    //编辑订单信息【备注等】
    public function edit_info()
    {
        $id = $this->request->post('id');
        $field = $this->request->post('field');
        $value = $this->request->post('value');
        if (!in_array($field, ['memo'])) {
            $this->error('没有权限编辑');
        }
        $row = $this->model->with(['User'])->where('id', $id)->find();
        if (!$row) {
            $this->error('记录未找到');
        }
        $row->$field = $value;
        $row->save();
        $this->success('保存成功');
    }

    //发货
    public function deliver()
    {
        $expressname = $this->request->post('expressname');
        $expressno = $this->request->post('expressno');
        $order_id = $this->request->post('order_id');
        $type = $this->request->post('type');
        $order = $this->model->where('id', $order_id)->find();
        if (!$order) {
            $this->error('未找到订单记录');
        }
        //发货 / 修改快递信息
        if ($order->order_status == OrderEnum::STATUS_PAY && $type == 0) {
            $order->express_name = $expressname;
            $order->express_no = $expressno;
            $order->order_status = OrderEnum::STATUS_SHIP;
            $order->shipping_time = time();
            $order->save();
            $this->success('发货成功');
        } elseif ($type == 1) {
            $order->express_name = $expressname;
            $order->express_no = $expressno;
            $order->save();
            $this->success('修改成功');
        } elseif ($order->order_status == OrderEnum::STATUS_REFUND) {
            $this->error("请完成售后后再进行操作");
        }
        $this->error('没有权限操作');
    }

    //电子面单【单独】
    public function electronics()
    {
        $order_id = $this->request->param('order_id');
        $row = $this->model->field('o.id,oe.print_template')
            ->where('o.id', $order_id)
            ->alias('o')
            ->join('shop_order_electronics oe', 'oe.order_sn=o.order_sn and oe.status=0', 'LEFT')
            ->find();

        if ($row && !empty($row['print_template'])) {
            $this->success('获取成功', '', ['PrintTemplate' => $row->print_template]);
        }
        $res = [];
        $electronics_id = $this->request->param('electronics_id');
        try {
            $res = \addons\shop\library\KdApiExpOrder::create($order_id, $electronics_id);
        } catch (\Exception $e) {
            $this->error($e->getMessage());
        }
        if (!isset($res['Success']) || !$res['Success']) {
            $msg = isset($res['Reason']) ? $res['Reason'] : '请求失败';
            $this->error($msg);
        }
        //成功
        $this->success('开始打印', '', $res);
    }

    //批量打印
    public function prints()
    {
        $ids = $this->request->param('ids');
        if (empty($ids)) {
            $this->error('打印参数错误');
        }
        $order_ids = explode('_', $ids);
        if ($this->request->isPost()) {
            $electronics_id = $this->request->post('electronics_id');
            $param = [];
            //是否已获取
            $list = $this->model->field('o.id,oe.print_template')
                ->where('o.id', 'IN', $order_ids)
                ->alias('o')
                ->join('shop_order_electronics oe', 'oe.order_sn=o.order_sn and oe.status=0', 'LEFT')
                ->select();
            $has_ids = [];
            //获取过的
            if ($list) {
                foreach ($list as $item) {
                    if (!empty($item['print_template'])) {
                        $param[] = [
                            'PrintTemplate' => $item['print_template'],
                            'Success'       => true
                        ];
                        $has_ids[] = $item['id'];
                    }
                }
            }
            //剩余未获取的
            try {
                foreach (array_diff($order_ids, $has_ids) as $order_id) {
                    $res = \addons\shop\library\KdApiExpOrder::create($order_id, $electronics_id);
                    if ($res) {
                        $param[] = $res;
                    }
                }
            } catch (\Exception $e) {
                $this->error($e->getMessage());
            }
            $this->success('操作成功', '', $param);
        }
        $config = get_addon_config('shop');
        $this->assignconfig('shop', $config);
        $this->assignconfig('order_ids', $order_ids);
        $order = $this->model->with(['OrderGoods', 'OrderAddress'])->where('id', 'IN', $order_ids)->select();
        
        // 处理规格信息格式化
        $processedOrder = [];
        foreach ($order as $orderItem) {
            $orderData = $orderItem->toArray();
            if (isset($orderData['order_goods']) && $orderData['order_goods']) {
                foreach ($orderData['order_goods'] as $index => $goodsItem) {
                    $orderData['order_goods'][$index]['goods_sku_attr_formatted'] = $this->formatGoodsSkuAttr($goodsItem['goods_sku_attr']);
                }
            }
            $processedOrder[] = $orderData;
        }
        $order = $processedOrder;
        
        $this->view->assign('order', $order);
        return $this->view->fetch();
    }

    //取消电子面单
    public function cancel_electronics()
    {
        $oe_id = $this->request->param('oe_id');
        $row = OrderElectronics::get($oe_id);
        if ($row['status'] == 1) {
            $this->error('电子面单已取消');
        }
        $res = \app\common\library\KdApiExpOrder::cancel($row);
        if (isset($res['Success']) && $res['Success']) {
            $row->status = 1;
            $row->save();
            $this->success('取消成功', '', $res);
        }
        $msg = isset($res['Reason']) ? $res['Reason'] : '取消失败';
        $this->error($msg);
    }

 
}