jude-user-recharge/app/admin/controller/product/Product.php

<?php
/**
 * 产品管理控制器
 */

namespace app\admin\controller\product;

use app\common\controller\Backend;
use think\facade\Db;
use think\facade\Validate;

class Product extends Backend
{

    protected array $noNeedLogin = ['*'];
    /**
     * 产品列表
     * @return void
     */
    public function index():void
    {
        $where = [];

        // 产品名称搜索
        if (!empty($this->request->get('name'))) {
            $name = $this->request->get('name');
            $where[] = ['p.name', 'like', '%' . $name . '%'];
        }

        // 产品编码搜索
        if (!empty($this->request->get('code'))) {
            $code = $this->request->get('code');
            $where[] = ['p.code', 'like', '%' . $code . '%'];
        }

        // 分类筛选
        if (!empty($this->request->get('category_id'))) {
            $categoryId = $this->request->get('category_id');
            $where['p.category_id'] = $categoryId;
        }

        // 库存状态筛选
        if (!empty($this->request->get('stock_status'))) {
            $stockStatus = $this->request->get('stock_status');
            $where['p.stock_status'] = $stockStatus;
        }

        // 产品状态筛选
        if (!empty($this->request->get('status'))) {
            $status = $this->request->get('status');
            $where['p.status'] = $status;
        }

        // 排序
        $order = [];
        if (!empty($this->request->get('order'))) {
            $order_a = $this->request->get('order');
            $order_a = explode(',', $order_a);
            $order[$order_a[0]] = $order_a[1];
        } else {
            $order['p.sort'] = 'asc';
            $order['p.id'] = 'desc';
        }

        // 分页
        $page = $this->request->get('page', 1);
        $limit = $this->request->get('limit', 20);

        // 查询数据
        $productList = Db::name('product')
            ->alias('p')
            ->leftJoin('product_category pc', 'p.category_id = pc.id')
            ->field('p.*, pc.name as category_name')
            ->where($where)
            ->order($order)
            ->paginate([
                'list_rows' => $limit,
                'page' => $page
            ]);

        // 转换图片字段
        $list = $productList->items();
        foreach ($list as &$item) {
            if (!empty($item['image'])) {
                $item['image'] = json_decode($item['image'], true);
            } else {
                $item['image'] = [];
            }

            if (!empty($item['key_attributes'])) {
                $item['key_attributes'] = json_decode($item['key_attributes'], true);
            } else {
                $item['key_attributes'] = [];
            }
        }

        $this->success('查询成功', [
            'list' => $list,
            'total' => $productList->total()
        ]);
    }

    /**
     * 新增/编辑产品
     * @return void
     */
    public function edit():void
    {
        $id = $this->request->post('id');
        $name = $this->request->post('name');
        $code = $this->request->post('code');
        $categoryId = $this->request->post('category_id');
        $description = $this->request->post('description', '');
        $detail = $this->request->post('detail', '');
        $keyAttributes = $this->request->post('key_attributes', []);
        $image = $this->request->post('image');
        $stockStatus = $this->request->post('stock_status', 1);
        $status = $this->request->post('status', 1);
        $sort = $this->request->post('sort', 0);

        if (empty($name)) {
            $this->error(__('产品名称不能为空'));
        }

        if (empty($code)) {
            $this->error(__('产品编码不能为空'));
        }

        // 验证产品编码是否已存在（编辑时排除自己）
        $checkCode = Db::name('product')
            ->where('code', $code);

        if (!empty($id)) {
            $checkCode->where('id', '<>', $id);
        }

        if ($checkCode->find()) {
            $this->error(__('产品编码已存在'));
        }

        // 处理图片和属性字段
        if (empty($image)) {
            $image = "";
        }

        if (!is_array($keyAttributes)) {
            $keyAttributes = [];
        }

        $data = [
            'name' => $name,
            'code' => $code,
            'category_id' => $categoryId ?: null,
            'description' => $description,
            'detail' => $detail,
            'key_attributes' => json_encode($keyAttributes, JSON_UNESCAPED_UNICODE),
            'image' => $image,
            'stock_status' => $stockStatus,
            'status' => $status,
            'sort' => $sort,
            'update_time' => date('Y-m-d H:i:s')
        ];
        try {
            if (!empty($id)) {
                // 编辑
                $productInfo = Db::name('product')
                    ->where('id', $id)
                    ->find();

                if (!$productInfo) {
                    $this->error(__('产品不存在'));
                }

                $result = Db::name('product')
                    ->where('id', $id)
                    ->update($data);
                $message = '编辑成功';
            } else {
                // 新增
                $data['create_time'] = date('Y-m-d H:i:s');
                $result = Db::name('product')
                    ->insert($data);
                $id = Db::name('product')->getLastInsID();
                $message = '新增成功';
            }

        } catch (\Exception $e) {
            $this->error('操作失败: ' . $e->getMessage());
        }
        if ($result) {
            $this->success($message, ['id' => $id]);
        } else {
            $this->error(__('操作失败'));
        }
    }

    /**
     * 删除产品
     * @return void
     */
    public function delete():void
    {
        $id = $this->request->post('id');

        if (empty($id)) {
            $this->error(__('参数错误'));
        }

        // 检查是否有套餐关联
        $hasPackage = Db::name('package')
            ->where('product_id', $id)
            ->count();

        if ($hasPackage > 0) {
            $this->error(__('该产品下有关联的套餐，请先删除套餐'));
        }

        // 检查是否有订单关联
        $hasOrder = Db::name('order_item')
            ->where('product_id', $id)
            ->count();

        if ($hasOrder > 0) {
            $this->error(__('该产品已有订单记录，不能删除'));
        }

        try {
            Db::startTrans();

            // 删除产品
            $result = Db::name('product')
                ->where('id', $id)
                ->delete();

            // 删除产品规格
            Db::name('product_spec')
                ->where('product_id', $id)
                ->delete();

            Db::commit();

        } catch (\Exception $e) {
            Db::rollback();
            $this->error('删除失败: ' . $e->getMessage());
        }
        if ($result) {
            $this->success('删除成功');
        } else {
            $this->error(__('删除失败'));
        }
    }

    /**
     * 产品详情
     * @return void
     */
    public function detail():void
    {
        $id = $this->request->get('id');

        if (empty($id)) {
            $this->error(__('参数错误'));
        }

        // 获取产品基础信息
        $productInfo = Db::name('product')
            ->alias('p')
            ->leftJoin('product_category pc', 'p.category_id = pc.id')
            ->where('p.id', $id)
            ->field('p.*, pc.name as category_name')
            ->find();

        if (!$productInfo) {
            $this->error(__('产品不存在'));
        }

        if (empty($productInfo['image'])) {
            $productInfo['image'] = [];
        }

        if (!empty($productInfo['key_attributes'])) {
            $productInfo['key_attributes'] = json_decode($productInfo['key_attributes'], true);
        } else {
            $productInfo['key_attributes'] = [];
        }

        // 获取产品规格
        $specList = Db::name('product_spec')
            ->where('product_id', $id)
            ->order('sort', 'asc')
            ->select()
            ->toArray();

        foreach ($specList as &$spec) {
            if (!empty($spec['value'])) {
                $spec['value'] = json_decode($spec['value'], true);
            } else {
                $spec['value'] = [];
            }
        }

        // 获取关联套餐数量
        $packageCount = Db::name('package')
            ->where('product_id', $id)
            ->count();

        // 获取订单数量
        $orderCount = Db::name('order_item')
            ->where('product_id', $id)
            ->count();

        $result = [
            'product_info' => $productInfo,
            'spec_list' => $specList,
            'package_count' => $packageCount,
            'order_count' => $orderCount
        ];

        $this->success('查询成功', $result);
    }

    /**
     * 批量更新产品状态
     * @return void
     */
    public function batchStatus():void
    {
        $ids = $this->request->post('ids');
        $status = $this->request->post('status');

        if (empty($ids) || empty($status)) {
            $this->error(__('参数错误'));
        }

        if (!is_array($ids)) {
            $ids = explode(',', $ids);
        }

        try {
            $result = Db::name('product')
                ->whereIn('id', $ids)
                ->update([
                    'status' => $status,
                    'update_time' => date('Y-m-d H:i:s')
                ]);

        } catch (\Exception $e) {
            $this->error('操作失败: ' . $e->getMessage());
        }

        if ($result) {
            $statusText = $status == 1 ? '上架' : '下架';
            $this->success("成功{$statusText}{$result}个产品");
        } else {
            $this->error(__('操作失败'));
        }
    }

    /**
     * 批量更新库存状态
     * @return void
     */
    public function batchStockStatus():void
    {
        $ids = $this->request->post('ids');
        $stockStatus = $this->request->post('stock_status');

        if (empty($ids) || empty($stockStatus)) {
            $this->error(__('参数错误'));
        }

        if (!is_array($ids)) {
            $ids = explode(',', $ids);
        }

        try {
            $result = Db::name('product')
                ->whereIn('id', $ids)
                ->update([
                    'stock_status' => $stockStatus,
                    'update_time' => date('Y-m-d H:i:s')
                ]);

        } catch (\Exception $e) {
            $this->error('操作失败: ' . $e->getMessage());
        }

        if ($result) {
            $statusText = [
                1 => '充足',
                2 => '缺货',
                3 => '下架'
            ][$stockStatus] ?? '未知';
            $this->success("成功更新{$result}个产品的库存状态为{$statusText}");
        } else {
            $this->error(__('操作失败'));
        }

    }

    /**
     * 添加/编辑产品规格
     * @return void
     */
    public function editSpec():void
    {
        $id = $this->request->post('id');
        $productId = $this->request->post('product_id');
        $name = $this->request->post('name');
        $value = $this->request->post('value', []);
        $sort = $this->request->post('sort', 0);

        if (empty($productId) || empty($name)) {
            $this->error(__('参数不完整'));
        }

        // 检查产品是否存在
        $productInfo = Db::name('product')
            ->where('id', $productId)
            ->find();

        if (!$productInfo) {
            $this->error(__('产品不存在'));
        }

        // 处理规格值
        if (!is_array($value)) {
            $value = [];
        }

        $data = [
            'product_id' => $productId,
            'name' => $name,
            'value' => json_encode($value, JSON_UNESCAPED_UNICODE),
            'sort' => $sort
        ];

        try {
            if (!empty($id)) {
                // 编辑
                $result = Db::name('product_spec')
                    ->where('id', $id)
                    ->update($data);
                $message = '编辑成功';
            } else {
                // 新增
                $data['create_time'] = date('Y-m-d H:i:s');
                $result = Db::name('product_spec')
                    ->insert($data);
                $id = Db::name('product_spec')->getLastInsID();
                $message = '新增成功';
            }

        } catch (\Exception $e) {
            $this->error('操作失败: ' . $e->getMessage());
        }
        if ($result) {
            $this->success($message, ['id' => $id]);
        } else {
            $this->error(__('操作失败'));
        }
    }

    /**
     * 删除产品规格
     * @return void
     */
    public function deleteSpec():void
    {
        $id = $this->request->post('id');

        if (empty($id)) {
            $this->error(__('参数错误'));
        }

        try {
            $result = Db::name('product_spec')
                ->where('id', $id)
                ->delete();

        } catch (\Exception $e) {
            $this->error('删除失败: ' . $e->getMessage());
        }

        if ($result) {
            $this->success('删除成功');
        } else {
            $this->error(__('删除失败'));
        }
    }

    /**
     * 获取产品规格列表
     * @return void
     */
    public function specList():void
    {
        $productId = $this->request->get('product_id');

        if (empty($productId)) {
            $this->error(__('参数错误'));
        }

        $specList = Db::name('product_spec')
            ->where('product_id', $productId)
            ->order('sort', 'asc')
            ->select()
            ->toArray();

        foreach ($specList as &$spec) {
            if (!empty($spec['value'])) {
                $spec['value'] = json_decode($spec['value'], true);
            } else {
                $spec['value'] = [];
            }
        }

        $this->success('查询成功', $specList);
    }

    /**
     * 获取产品状态选项
     * @return void
     */
    public function statusOptions():void
    {
        $options = [
            ['value' => 1, 'label' => '上架'],
            ['value' => 2, 'label' => '下架']
        ];

        $this->success('获取成功', $options);
    }

    /**
     * 获取库存状态选项
     * @return void
     */
    public function stockStatusOptions():void
    {
        $options = [
            ['value' => 1, 'label' => '充足'],
            ['value' => 2, 'label' => '缺货'],
            ['value' => 3, 'label' => '下架']
        ];

        $this->success('获取成功', $options);
    }

    /**
     * 导出产品列表
     * @return void
     */
    public function export():void
    {
        $where = [];

        // 根据筛选条件构建查询条件
        if (!empty($this->request->get('name'))) {
            $name = $this->request->get('name');
            $where[] = ['p.name', 'like', '%' . $name . '%'];
        }

        if (!empty($this->request->get('status'))) {
            $status = $this->request->get('status');
            $where['p.status'] = $status;
        }

        // 查询数据
        $productList = Db::name('product')
            ->alias('p')
            ->leftJoin('product_category pc', 'p.category_id = pc.id')
            ->field('p.id, p.name, p.code, pc.name as category_name, 
                     p.stock_status, p.status, p.sort, p.create_time')
            ->where($where)
            ->order('p.sort', 'asc')
            ->order('p.id', 'desc')
            ->select()
            ->toArray();

        // 状态映射
        $stockStatusMap = [1 => '充足', 2 => '缺货', 3 => '下架'];
        $statusMap = [1 => '上架', 2 => '下架'];

        foreach ($productList as &$item) {
            $item['stock_status'] = $stockStatusMap[$item['stock_status']] ?? '未知';
            $item['status'] = $statusMap[$item['status']] ?? '未知';
        }

        $this->success('查询成功', $productList);
    }
}