mes-sdai-server-api/application/api/controller/Facility.php

<?php
namespace app\api\controller;
use app\common\controller\Api;
use think\Db;
use think\Request;

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

    public function packImagess()
    {
        try {
            $params = $this->request->post();
            $paths = $params['paths'] ?? [];

            if (empty($paths) || !is_array($paths)) {
                return json(['code' => 1, 'msg' => '路径参数不能为空或格式不正确']);
            }

            // 设置基础路径和压缩目录路径
            $basePath = ROOT_PATH . 'public/';
            $zipDir = $basePath . 'uploads/operate/ai/zip/';

            if (!is_dir($zipDir)) {
                mkdir($zipDir, 0755, true);
            }

            // 压缩包文件名及完整路径
            $fileName = 'images_' . date('Ymd_His') . '.zip';
            $zipPath = $zipDir . $fileName;

            // 创建 Zip 文件
            $zip = new \ZipArchive();
            if ($zip->open($zipPath, \ZipArchive::CREATE) !== TRUE) {
                return json(['code' => 1, 'msg' => '无法创建压缩包']);
            }

            // 添加文件到压缩包
            $addCount = 0;
            foreach ($paths as $relativePath) {
                $relativePath = ltrim($relativePath, '/');
                $fullPath = $basePath . $relativePath;

                if (file_exists($fullPath)) {
                    $zip->addFile($fullPath, basename($fullPath)); // 仅保存文件名
                    $addCount++;
                }
            }

            $zip->close();

            if ($addCount === 0) {
                return json(['code' => 1, 'msg' => '未找到有效图片，未生成压缩包']);
            }

            // 返回下载地址（注意路径与保存路径一致）
            $downloadUrl = request()->domain() . '/uploads/operate/ai/zip/' . $fileName;

            return json([
                'code' => 0,
                'msg' => '打包成功',
                'download_url' => $downloadUrl
            ]);
        } catch (\Exception $e) {
            return json([
                'code' => 1,
                'msg' => '异常错误：' . $e->getMessage()
            ]);
        }
    }


    public function getlsit()
    {
        // 获取前端传入的图片路径参数
        $params = $this->request->param('path', '');
        // 查询数据库
        $res = Db::name('text_to_image')->alias('b')
            ->field('b.chinese_description,b.english_description,b.new_image_url,b.custom_image_url,b.size,b.old_image_url,b.img_name')
            ->where('old_image_url', $params)
            ->where('img_name', '<>', '')
            ->where('custom_image_url', '<>', '')
            ->where('status', 1)
            ->order('b.id desc')
            ->select();
        return json(['code' => 0, 'msg' => '查询成功', 'data' => $res,'count'=>count($res)]);
    }


    //获取指定目录所有图片
    public function getPreviewimg()
    {
        $page = (int)$this->request->param('page', 1);
        $limit = (int)$this->request->param('limit', 50);
        $status = $this->request->param('status', '');

        $relativePath = $this->request->param('path', '');
        $basePath = ROOT_PATH . 'public/';
        $fullPath = $basePath . $relativePath;

        if (!is_dir($fullPath)) {
            return json(['code' => 1, 'msg' => '目录不存在']);
        }

        // 1. 获取所有图片路径（不再全部加载到内存）
        $allImages = glob($fullPath . '/*.{jpg,jpeg,png}', GLOB_BRACE);
        if (empty($allImages)) {
            return json(['code' => 0, 'msg' => '暂无图片', 'data' => [], 'total' => 0]);
        }
        // ✅ 加入排序：按照创建时间从新到旧
        usort($allImages, function ($a, $b) {
            return filectime($b) - filectime($a);
        });
        // 构建相对路径数组
        $relativeImages = array_map(function ($imgPath) use ($basePath) {
            return str_replace($basePath, '', $imgPath);
        }, $allImages);

        // 2. 提前构建是否已出图map
        $dbRecords = Db::name('text_to_image')
            ->whereIn('old_image_url', $relativeImages)
            ->where('img_name', '<>', '')
            ->where('custom_image_url', '<>', '')
            ->where('status',1)
            ->field('old_image_url,new_image_url,custom_image_url,chinese_description,english_description,img_name')
            ->select();

        $processedMap = [];
        foreach ($dbRecords as $item) {
            $processedMap[$item['old_image_url']] = $item;
        }

        // 3. 提前获取 same_count 的统计
        $sameCountMap = Db::name('text_to_image')
            ->whereIn('old_image_url', $relativeImages)
            ->where('img_name', '<>', '')
            ->where('custom_image_url', '<>', '')
            ->group('old_image_url')
            ->where('status',1)
            ->column('count(*) as cnt', 'old_image_url');

        // 4. 构造最终筛选数据（分页前进行状态筛选）
        $filtered = [];
        foreach ($allImages as $imgPath) {
            $relative = str_replace($basePath, '', $imgPath);
            $processed = $processedMap[$relative] ?? null;
            $isProcessed = $processed ? 1 : 0;

            // 状态过滤
            if ($status === 'processed' && !$isProcessed) continue;
            if ($status === 'unprocessed' && $isProcessed) continue;

            $info = @getimagesize($imgPath); // 加@防止报错
            $sizeKB = round(filesize($imgPath) / 1024, 2);
            $ctime = date('Y-m-d H:i:s', filectime($imgPath));

            $filtered[] = [
                'path' => $relative,
                'width' => $info[0] ?? 0,
                'height' => $info[1] ?? 0,
                'size_kb' => $sizeKB,
                'created_time' => $ctime,
                'img_name' => $processed['img_name'] ?? '',
                'is_processed' => $isProcessed,
                'new_image_url' => $processed['new_image_url'] ?? '',
                'custom_image_url' => $processed['custom_image_url'] ?? '',
                'chinese_description' => ($processed['chinese_description'] ?? '') . ($processed['english_description'] ?? ''),
                'same_count' => $sameCountMap[$relative] ?? 0
            ];
        }

        // 5. 手动分页（对少量已筛选后的数据）
        $total = count($filtered);
        $pagedData = array_slice($filtered, ($page - 1) * $limit, $limit);
        foreach ($pagedData as $index => &$item) {
            $item['id'] = ($page - 1) * $limit + $index + 1;
        }

        return json([
            'code' => 0,
            'msg' => '获取成功',
            'data' => $pagedData,
            'total' => $total,
            'page' => $page,
            'limit' => $limit
        ]);
    }

    /**
     * 获取原图目录及每个目录下的图片数量
     */
    public function getPreviewSubDirs()
    {
        $baseDir = rtrim(str_replace('\\', '/', ROOT_PATH), '/') . '/public/uploads/operate/ai/Preview';
        $baseRelativePath = 'uploads/operate/ai/Preview';

        if (!is_dir($baseDir)) {
            return json(['code' => 1, 'msg' => '目录不存在']);
        }

        $dirs = [];
        $index = 1;

        /**
         * 递归扫描目录，提取含图片的子目录信息
         */
        $scanDir = function ($dirPath, $relativePath) use (&$scanDir, &$dirs, &$index) {
            $items = scandir($dirPath);
            foreach ($items as $item) {
                if ($item === '.' || $item === '..') continue;

                $fullPath = $dirPath . '/' . $item;
                $relPath = $relativePath . '/' . $item;

                if (is_dir($fullPath)) {
                    // 递归子目录
                    $scanDir($fullPath, $relPath);
                } else {
                    // 匹配图片文件
                    if (preg_match('/\.(jpg|jpeg|png)$/i', $item)) {
                        $parentDir = dirname($fullPath);
                        $relativeDir = dirname($relPath);
                        $key = md5($parentDir);

                        if (!isset($dirs[$key])) {
                            $ctime = filectime($parentDir);

                            // 数据库统计：已处理图片数量
                            $hasData = Db::name('text_to_image')
                                ->where('custom_image_url', '<>', '')
                                ->where('img_name', '<>', '')
                                ->whereLike('old_image_url', $relativeDir . '/%')
                                ->where('status',1)
                                ->whereNotNull('custom_image_url')
                                ->count();

                            // 当前目录下图片数量
                            $imageFiles = glob($parentDir . '/*.{jpg,jpeg,png}', GLOB_BRACE);
                            $imageCount = is_array($imageFiles) ? count($imageFiles) : 0;

                            $dirs[$key] = [
                                'id' => $index++,
                                'name' => basename($parentDir),
                                'count' => $hasData,
                                'ctime' => $ctime, // 时间戳，用于排序
                                'ctime_text' => date('Y-m-d H:i:s', $ctime), // 格式化日期，用于显示
                                'image_count' => $imageCount,
                                'new_image_url' => "/uploads/operate/ai/dall-e/",
                                'old_image_url' => $relativeDir
                            ];
                        }
                    }
                }
            }
        };

        // 执行目录扫描
        $scanDir($baseDir, $baseRelativePath);

        // 排序：按照创建时间（从新到旧）
        $dirList = array_values($dirs);
        usort($dirList, function ($a, $b) {
            return $b['ctime'] - $a['ctime'];
        });

        return json([
            'code' => 0,
            'msg' => '获取成功',
            'data' => $dirList
        ]);
    }






    /**
     * 图片上传
     * @return void
     */
//    public function getUploadPath()
//    {
//        // 处理 CORS OPTIONS 预检请求
//        if ($_SERVER['REQUEST_METHOD'] == 'OPTIONS') {
//            header('Access-Control-Allow-Origin: *');
//            header('Access-Control-Allow-Methods: POST, OPTIONS');
//            header('Access-Control-Allow-Headers: Content-Type, Authorization');
//            header('Access-Control-Max-Age: 86400');
//            exit(204);
//        }
//
//// 实际请求必须返回 CORS 头
//        header('Access-Control-Allow-Origin: *');
//        $today = date('Ymd');
//        $basePath = 'uploads/operate/ai/Preview/' . $today;
//        $rootBasePath = ROOT_PATH . 'public/' . $basePath;
//
//        // 创建当天目录
//        if (!is_dir($rootBasePath)) {
//            mkdir($rootBasePath, 0755, true);
//        }
//
//        // 获取子目录索引
//        $dirs = array_filter(glob($rootBasePath . '/*'), 'is_dir');
//        $usedIndexes = [];
//
//        foreach ($dirs as $dirPath) {
//            $dirName = basename($dirPath);
//            if (preg_match('/^\d{2}$/', $dirName)) {
//                $usedIndexes[] = intval($dirName);
//            }
//        }
//
//        $nextIndex = empty($usedIndexes) ? 1 : max($usedIndexes) + 1;
//        $subDir = str_pad($nextIndex, 2, '0', STR_PAD_LEFT);
//        $relativePath = $basePath . '/' . $subDir;
//        $targetPath = ROOT_PATH . 'public/' . $relativePath;
//
//        // 创建该批次目录
//        if (!is_dir($targetPath)) {
//            mkdir($targetPath, 0755, true);
//        }
//
//        return json([
//            'code' => 0,
//            'msg' => '获取上传路径成功',
//            'data' => [
//                'upload_path' => $relativePath
//            ]
//        ]);
//    }
//    public function ImgUpload()
//    {
//        if ($_SERVER['REQUEST_METHOD'] == 'OPTIONS') {
//            header('Access-Control-Allow-Origin: *');
//            header('Access-Control-Allow-Methods: POST, OPTIONS');
//            header('Access-Control-Allow-Headers: Content-Type, Authorization');
//            header('Access-Control-Max-Age: 86400');
//            exit(204);
//        }
//        header('Access-Control-Allow-Origin: *');
//
//        $file = request()->file('image');
//        $relativePath = input('post.upload_path');
//
//        if (!$file || !$relativePath) {
//            return json(['code' => 1, 'msg' => '缺少上传文件或路径参数']);
//        }
//
//        $targetPath = ROOT_PATH . 'public/' . $relativePath;
//
//        if (!is_dir($targetPath)) {
//            mkdir($targetPath, 0755, true);
//        }
//
//        $tmpFilePath = $file->getPathname();
//        $extension = pathinfo($file->getInfo('name'), PATHINFO_EXTENSION);
//        $hashName = hash_file('md5', $tmpFilePath);
//        $newFileName = $hashName . '.' . $extension;
//
//        $info = $file->validate(['size' => 10 * 1024 * 1024, 'ext' => 'jpg,jpeg,png'])
//            ->move($targetPath, $newFileName);
//
//        if ($info) {
//            $imageUrl = $relativePath . '/' . str_replace('\\', '/', $newFileName);
//            return json(['code' => 0, 'msg' => '上传成功', 'data' => ['url' => $imageUrl]]);
//        } else {
//            return json(['code' => 1, 'msg' => '上传失败', 'data' => $file->getError()]);
//        }
//    }

    public function ImgUpload()
    {
        // 处理 CORS OPTIONS 预检请求
        if ($_SERVER['REQUEST_METHOD'] == 'OPTIONS') {
            header('Access-Control-Allow-Origin: *');
            header('Access-Control-Allow-Methods: POST, OPTIONS');
            header('Access-Control-Allow-Headers: Content-Type, Authorization');
            header('Access-Control-Max-Age: 86400');
            exit(204);
        }

// 实际请求必须返回 CORS 头
        header('Access-Control-Allow-Origin: *');

// 获取上传的文件
        $file = request()->file('image');

        if ($file) {
            // 指定目标目录（你想上传到的目录）
            $targetPath = ROOT_PATH . 'public' . DS . 'uploads' . DS . 'operate' . DS . 'ai' . DS . 'Preview';

            // 若目录不存在则创建
            if (!is_dir($targetPath)) {
                mkdir($targetPath, 0755, true);
            }

            // 移动文件到指定目录，并验证大小/格式
            $info = $file->validate([
                'size' => 10485760, // 最大10MB
                'ext' => 'jpg,png'
            ])->move($targetPath);

            if ($info) {
                $fileName = $info->getSaveName();
                $imageUrl = '/uploads/operate/ai/Preview/' . str_replace('\\', '/', $fileName);
                return json(['code' => 0, 'msg' => '成功', 'data' => ['url' => $imageUrl]]);
            } else {
                $res = $file->getError();
                return json(['code' => 1, 'msg' => '失败', 'data' => $res]);
            }
        }

        return json(['code' => 1, 'msg' => '没有文件上传', 'data' => null]);
    }


    /**
     * 模版
    */
    public function Template(){
        $Template = Db::name("template")->find();
        return json([
            'code' => 0,
            'msg' => '模版',
            'data' => $Template
        ]);
    }
    /**
     * 更新模版
     */
    public function updatetemplate(){
        if (Request::instance()->isPost() == false){
            $this->error('非法请求');
        }

        $params = Request::instance()->post();


        // 验证传入的参数是否存在，避免空值
        if (empty($params['textareaContent']) || empty($params['width']) || empty($params['height'])) {
            return json(['code' => 1, 'msg' => '参数缺失']);
        }

        // 更新模板数据
        $Template = Db::name("template")
            ->where('id', 1) // 假设模板 ID 是 1，需根据实际情况修改
            ->update([
                'content' => $params['textareaContent'],  // 更新图生文模版内容
                'width' => $params['width'],  // 更新宽度
                'height' => $params['height'],  // 更新宽度
            ]);

        // 判断数据库更新是否成功
        if ($Template){
            return json(['code' => 0, 'msg' => '成功']);
        }else{
            return json(['code' => 1, 'msg' => '失败']);
        }
    }

}