mes-server-api/application/api/controller/Product.php

<?php


namespace app\api\controller;

use app\common\controller\Api;
use think\Db;

class Product extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 本地文件同步到 OSS（配置齐全时）；失败不影响主流程
     */
    protected function maybeUploadToOss($localFullPath, $objectKey)
    {
        return Common::uploadLocalFileToOss((string)$localFullPath, (string)$objectKey);
    }

    /**
     * 商户菜单
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function merchantGetab()
    {
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }
        $list  = \db('product_merchant')
            ->where([
                'status' => 1,
                'deleteTime' => null,
            ])
            ->field('merchant_code,merchant_name')
            ->select();
        foreach ($list as $k => $v) {
            $list[$k]['tab'] = $v['merchant_name'].'('.$v['merchant_code'].')';
        }
        if (empty($list)) {
            $this->error('未找到商户数据');
        }else{
            $this->success('成功', $list);
        }
    }

    /**
     * 产品列表
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function productList()
    {
        // 1. 请求方法验证优化
        if (!$this->request->isGet()) {
            $this->error('请求方法错误');
        }

        $param = $this->request->param();

        // 2. 参数验证优化
        if (empty($param['code']) || !is_string($param['code'])) {
            $this->error('商户编码参数错误');
        }

        // 3. 参数安全处理
        $merchantCode = trim($param['code']);
        $searchKeyword = isset($param['search']) ? trim($param['search']) : '';

        // 4. 分页参数处理
        $page = isset($param['page']) ? intval($param['page']) : 1;
        $pageSize = isset($param['pageSize']) ? intval($param['pageSize']) : 15;

        // 验证分页参数
        if ($page < 1) $page = 1;
        if ($pageSize < 1 || $pageSize > 100) $pageSize = 15; // 限制最大每页100条

        // 5. 构建查询条件
        $where = [
            'b.merchant_code' => $merchantCode
        ];

        if (!empty($searchKeyword)) {
            // 使用更安全的查询方式
            $where['a.product_name|a.product_code'] = ['like', '%' . addslashes($searchKeyword) . '%'];
        }

        // 6. 查询数据（带分页）
        try {
            // 首先获取总记录数
            $total = \db('product')
                ->alias('a')
                ->join('product_merchant b', 'a.merchant_id = b.id')
                ->where('a.deleteTime', null)
                ->where($where)
                ->count();

            // 分页查询
            $list = \db('product')
                ->alias('a')
                ->join('product_merchant b', 'a.merchant_id = b.id')
                ->where($where)
                ->field([
                    'a.product_name as 产品名称',
                    'a.product_code as 产品编码',
                    'a.product_img',
                    'a.deleteTime',
                    'a.product_new_img',
                    'a.createTime as 创建时间',
                    'a.create_name as 创建人',
                    'b.merchant_code as 商户编码',
                    'a.id'
                ])
                ->where('a.deleteTime', null)
                ->order('a.createTime', 'desc')
                ->page($page, $pageSize)
                ->select();
        } catch (\Exception $e) {
            $this->error('查询数据失败：' . $e->getMessage());
        }

        // 7. 优化数据处理逻辑
        if (!empty($list)) {
            foreach ($list as &$item) {
                // 产品图片
                if (!empty($item['product_img'])) {
                    $item['产品图片'] = ltrim($item['product_img'], '/');
                    unset($item['product_img']); // 移除原始字段
                } else {
                    $item['产品图片'] = ''; // 设置默认值
                }

                // 产品效果图
                if (!empty($item['product_new_img'])) {
                    $item['产品效果图'] = ltrim($item['product_new_img'], '/');
                    unset($item['product_new_img']); // 移除原始字段
                } else {
                    $item['产品效果图'] = ''; // 设置默认值
                }
            }
            unset($item); // 解除引用
        }

        foreach ($list as &$item) {
                $item['产品图片'] = Common::ossFullUrl((string)$item['产品图片']);
                $item['产品效果图'] = Common::ossFullUrl((string)$item['产品效果图']);
        }
        unset($item);
        $result = [
            'list' => $list,
            'total' => $total,
        ];

        // 10. 统一返回格式
        $this->success('查询成功', $result);
    }

    /**
     * 产品详情
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function productDetail()
    {
        if (!$this->request->isGet()) {
            $this->error('只支持GET请求');
        }
        $param = $this->request->param();
        if (empty($param['id']) || !is_numeric($param['id'])) {
            $this->error('产品ID参数错误');
        }
        $productId = intval($param['id']);
        if ($productId <= 0) {
            $this->error('产品ID必须为正整数');
        }
        try {
            $product = \db('product')
                ->field([
                    'id',
                    'product_name as 产品名称',
                    'product_code as 产品编码',
                    'product_img',
                    'product_new_img',
                    'createTime as 创建时间',
                    'create_name as 创建人',
                ])
                ->where('id', $productId)
                ->whereNull('deleteTime')
                ->order('id desc')
                ->find();
        } catch (\Exception $e) {
            $this->error('查询产品详情失败：' . $e->getMessage());
        }
        if (empty($product)) {
            $this->error('产品不存在或已被删除');
        }

        // 6. 优化图片路径处理
        // 产品图片
        if (!empty($product['product_img'])) {
            $product['产品图片'] = ltrim($product['product_img']);
        } else {
            $product['产品图片'] = '';  // 设置默认空值
        }

        // 产品效果图 - 修复变量名错误（原代码中使用了$v）
        if (!empty($product['product_new_img'])) {
            $product['产品效果图'] = ltrim($product['product_new_img']);
        } else {
            $product['产品效果图'] = '';  // 设置默认空值
        }

        $newImg = \db('product_new_img')
            ->where('product_id', $productId)
            ->whereNull('deleteTime')
            ->column('img_address');

        $product['newImg'] = $newImg;

        // 7. 移除原始图片字段，保持返回数据整洁
        unset($product['product_img'], $product['product_new_img']);

        $product_image = \db('product_image')->alias('a')
            ->field('
                a.id,
                a.product_id,
                a.template_id,
                a.product_new_img,
                a.product_content,
                a.createTime,
                b.thumbnail_image,
                b.template_name
            ')
            ->join('product_template b', 'a.template_id = b.id', 'LEFT')
            ->where('a.product_id', $productId)
            ->whereNull('a.mod_rq')
            ->order('a.id desc')
            ->select();

        foreach ($product_image as &$item) {
            if (!empty($item['product_new_img']) || !empty($item['thumbnail_image'])) {
                $item['product_new_img'] = Common::ossFullUrl((string)$item['product_new_img']);
                $item['thumbnail_image'] = Common::ossFullUrl((string)$item['thumbnail_image']);
            }
        }
        unset($item);

        // $product 是单条记录，不是列表，直接处理
        if (!empty($product['产品图片'])) {
            $product['产品图片'] = Common::ossFullUrl((string)$product['产品图片']);
        }
        if (!empty($product['产品效果图'])) {
            $product['产品效果图'] = Common::ossFullUrl((string)$product['产品效果图']);
        }

        return json([
            'code' => 0,
            'msg' => '获取产品详情成功',
            'image' => $product_image,//历史图片
            'data' => $product
        ]);
    }

    /**
     * 获取单条产品数据信息
    */
    public function GetProductFind(){
        if (!$this->request->isGet()) {
            $this->error('只支持GET请求');
        }
        $param = $this->request->param();
        if (empty($param['id']) || !is_numeric($param['id'])) {
            $this->error('产品ID参数错误');
        }
        $product = Db::name('product')->where('id', $param['id'])->find();
        if (empty($product)) {
            return json([
                'code' => 1,
                'msg' => '产品不存在',
                'data' => null
            ]);
        }
        $this->success('获取成功', $product);
    }


    /**
     * 新增产品
     * @return void
     */
    public function productAdd()
    {

        // 请求方法验证（可提取为公共方法）
        if (!$this->request->isPost()) {
            throw new \Exception('非法请求');
        }

        // 获取并验证参数
        $param = $this->request->post();
        $this->validateProductParams($param, ['product_name', 'product_code']);

        //处理产品图片 base64 -> 保存到 uploads/merchant/{product_code前段}/{product_code}/{product_name}.png
        $productImgPath = '';
        if (!empty($param['product_img'])) {
            $base64Data = $param['product_img'];
            if (preg_match('/data:image\/(png|jpg|jpeg);base64,([A-Za-z0-9+\/=]+)/i', $base64Data, $m)) {
                $imageType = strtolower($m[1]);
                $imageData = base64_decode($m[2]);
                if ($imageData !== false && strlen($imageData) >= 100) {
                    $productCode = $param['product_code'];
                    $prefix = strlen($productCode) >= 4 ? substr($productCode, 0, -4) : $productCode; // 后四位前面的数值
                    $safeName = preg_replace('/[\\\\\/:*?"<>|]/u', '_', $param['product_name']);
                    $ext = ($imageType === 'jpeg') ? 'jpg' : $imageType;
                    $fileName = $safeName . '.' . $ext;
                    $saveDir = str_replace('\\', '/', ROOT_PATH . 'public/uploads/merchant/' . $prefix . '/' . $productCode . '/'. 'oldimg/');
                    if (!is_dir($saveDir)) {
                        mkdir($saveDir, 0755, true);
                    }
                    if (file_put_contents($saveDir . $fileName, $imageData)) {
                        $productImgPath = 'uploads/merchant/' . $prefix . '/' . $productCode . '/' . 'oldimg/'. $fileName;
                        // 本地保存成功后，尝试同步 OSS（失败不阻塞新增）
                        $this->maybeUploadToOss($saveDir . $fileName, $productImgPath);
                    }
                }
            }
        }

        $data = [
            'product_name' => $param['product_name'],
            'product_code' => $param['product_code'],
            'createTime'   => date('Y-m-d H:i:s', time()),
            'create_name'  => isset($param['create_name']) ? $param['create_name'] : '',
            'merchant_id'  => isset($param['merchant_id']) ? intval($param['merchant_id']) : 0,
            'product_img'  => $productImgPath,
        ];

        //验证产品编码唯一性
        if (Db::name('product')->where('product_code', $data['product_code'])->count() > 0) {
            $this->error('产品编码已存在');
        }

        $result = Db::name('product')->insert($data);

        if ($result) {

            $this->success('新增成功');
        } else {

            $this->error('新增失败');
        }

    }

    /**
     * 修改产品数据
     * @return void
     */
    public function productEdit()
    {

        // 1. 请求方法验证
        if (!$this->request->isPost()) {
            throw new \Exception('非法请求');
        }

        // 2. 获取并验证参数
        $param = $this->request->post();
        $this->validateProductParams($param, ['id', 'product_name', 'product_code']);

        // 3. 检查产品是否存在
        $product = Db::name('product')->where('id', intval($param['id']))->find();
        if (!$product) {
            $this->error('产品不存在');
        }

        // 4. 准备更新数据
        $updateData = [
            'product_name' => $param['product_name'],
            'product_code' => $param['product_code'],
        ];

        // 5. 可选字段更新
        $optionalFields = ['create_name', 'merchant_id', 'product_img', 'product_new_img'];
        foreach ($optionalFields as $field) {
            if (isset($param[$field])) {
                $updateData[$field] = $param[$field];
            }
        }

        // 6. 验证产品编码唯一性（排除自身）
        $codeExists = Db::name('product')
            ->where('product_code', $updateData['product_code'])
            ->where('id', '<>', intval($param['id']))
            ->count();

        if ($codeExists > 0) {
            $this->error('产品编码已被其他产品使用');
        }

        // 7. 使用事务更新

        $result = Db::name('product')
            ->where('id', intval($param['id']))
            ->update($updateData);

        if ($result !== false) {

            $this->success('更新成功');
        } else {

            $this->error('更新失败');
        }

    }

    /**
     * 验证产品参数（私有方法，供内部使用）
     * @param array $param 参数数组
     * @param array $requiredFields 必要字段
     * @throws \Exception
     */
    private function validateProductParams($param, $requiredFields)
    {
        foreach ($requiredFields as $field) {
            if (!isset($param[$field]) || trim($param[$field]) === '') {
                throw new \Exception("缺少必要参数：{$field}");
            }
        }
    }

    /**
     * 获取商户ID
     * @return void
     */
    public function getMerchantId()
    {
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['merchant_code'])) {
            $this->error('参数错误');
        }
        $id = \db('product_merchant')
            ->where('merchant_code', $param['merchant_code'])
            ->value('id');
        if (!empty($id)) {
            $this->success('成功', $id);
        }else{
            $this->error('失败');
        }
    }

    /**
     * 产品删除
     */
    public function Product_Del()
    {
        $params = $this->request->param();

        $record['deleteTime'] = date('Y-m-d H:i:s');
        $res = Db::name('product')->where('id', $params['id'])->update($record);
        if (!$res) {
            return json([
                'code' => 1,
                'msg'  => '删除失败',
                'data' => ''
            ]);
        }
        return json([
            'code' => 0,
            'msg'  => '删除成功'
        ]);
    }

}