mes-sdai-server-api/application/job/TextToImageJob.php

<?php

namespace app\job;

use think\Db;
use think\Queue;
use think\queue\Job;

class TextToImageJob
{
    protected $config = [
        'gpt' => [
            'api_key' => 'sk-Bhos1lXTRpZiAAmN06624a219a874eCd91Dc068b902a3e73',
            'api_url' => 'https://one.opengptgod.com/v1/chat/completions'
        ],
        'dalle' => [
            'api_key' => 'sk-e0JuPjMntkbgi1BoMjrqyyzMKzAxILkQzyGMSy3xiMupuoWY',
            'api_url' => 'https://niubi.zeabur.app/v1/images/generations'
        ]
    ];

    public function fire(Job $job, $data)
    {
        echo date('Y-m-d H:i:s') . " 任务开始执行\n";

        try {
            if (isset($data['type']) && $data['type'] === '文生图') {
                echo date('Y-m-d H:i:s') . " [文生图 - 数据库模式] 阶段开始\n";

                $list = Db::name("text_to_image")
                    ->where('old_image_url', $data['sourceDir'] . '/' . $data['file_name'])
                    ->where('img_name', '<>', '')
                    ->where('status', 0)
                    ->select();

                if (!empty($list)) {
                    foreach ($list as $index => $row) {
                        echo "处理第 " . ($index + 1) . " 条数据，处理ID：" . $row['id'] . "\n";

                        // 调用 textToImage 方法
                        $result = $this->textToImage(
                            $data["file_name"],          // 文件名
                            $data["outputDir"],          // 输出目录
                            $data["width"],              // 宽度
                            $data["height"],             // 高度
                            $row["english_description"], // 英文描述
                            $row["img_name"]             // 图片名
                        );

                        echo "处理结果：" . $result . "\n";

                    }

                    echo date('Y-m-d H:i:s') . " 文生图任务全部执行完成\n";
                } else {
                    echo "未找到 status=0 的数据，跳过执行\n";
                }

                $job->delete(); // 删除队列任务

            } else {
                echo date('Y-m-d H:i:s') . " [文生图 - 单条传参模式] 开始执行\n";

                $result = $this->textToImage(
                    $data["fileName"],
                    $data["outputDir"],
                    $data["width"],
                    $data["height"],
                    $data["englishDesc"],
                    $data["img_name"]
                );

                echo "返回结果：" . $result . "\n";
                echo date('Y-m-d H:i:s') . " 单条文生图执行结束\n";

                $job->delete();
            }

        } catch (\Exception $e) {
            echo "异常信息: " . $e->getMessage() . "\n";
            echo "文件: " . $e->getFile() . "\n";
            echo "行号: " . $e->getLine() . "\n";
            echo date('Y-m-d H:i:s') . " 任务执行失败\n";
            $job->delete();
        }
    }

    /**
     * 任务失败时的处理
     */
    public function failed($data)
    {
        // 记录失败日志或发送通知
        echo "ImageJob failed: " . json_encode($data);
    }

    /**
     * 文生图接口
     */
    public function textToImage($fileName, $outputDirRaw, $width, $height, $prompt, $img_name)
    {
        $rootPath = str_replace('\\', '/', ROOT_PATH);
        $outputDir = rtrim($rootPath . 'public/' . $outputDirRaw, '/') . '/';
        $dateDir = date('Y-m-d') . '/';
        $fullBaseDir = $outputDir . $dateDir;

        // 创建输出目录结构
        foreach ([$fullBaseDir, $fullBaseDir . '1024x1024/', $fullBaseDir . "{$width}x{$height}/"] as $dir) {
            if (!is_dir($dir)) {
                mkdir($dir, 0755, true);
            }
        }

        // 清理 prompt 的换行
        $prompt = preg_replace('/[\r\n\t]+/', ' ', $prompt);

        // 查询数据库记录
        $record = Db::name('text_to_image')
            ->where('old_image_url', 'like', "%{$fileName}")
            ->order('id desc')
            ->find();

        if (!$record) {
            return '没有找到匹配的图像记录';
        }

        // 写入 prompt 日志
        $logDir = $rootPath . 'runtime/logs/';
        if (!is_dir($logDir)) mkdir($logDir, 0755, true);
//        echo 2345;
        // 调用文生图模型接口生成图像
        $startTime = microtime(true);
//         echo "<pre>";
// print_r($prompt);
// echo "<pre>";die;
        $dalle1024 = $this->callDalleApi($prompt);
        // $dalle1024 = json_decode('{"created":1747932746,"data":[{"revised_prompt":"**First paragraph:**   A geometric abstract design with a central motif consisting of curved and angular shapes in a symmetrical arrangement. The color scheme predominantly features shades of blue, with hints of white and black creating a contrast. The design incorporates smooth, flowing lines mixed with sharp angles. The overall style has a modern, minimalist aesthetic, with a focus on balance and clean shapes.","url":"https:\/\/filesystem.site\/cdn\/20250523\/3NVcCUaZDkLimWjtgOwJYniGezDX8d.png"}],"usage":{"total_tokens":4250,"input_tokens":75,"output_tokens":4175,"input_tokens_details":{"text_tokens":75}}}',true);

        $endTime = microtime(true);
        $executionTime = $endTime - $startTime;
        echo "API调用耗时: " . round($executionTime, 3) . " 秒\n";

        // 检查 URL 返回是否成功
        if (!isset($dalle1024['data'][0]['url']) || empty($dalle1024['data'][0]['url'])) {
            $errorText = $dalle1024['error']['message'] ?? '未知错误';
            echo '生成失败：' . $errorText;
        }
//        echo 342342;
        // 下载图像
        $imgUrl1024 = $dalle1024['data'][0]['url'];
        $imgData1024 = @file_get_contents($imgUrl1024);
        if (!$imgData1024 || strlen($imgData1024) < 1000) {
            return "下载图像失败或内容异常";
        }
//        echo 3423424444;
        // file_put_contents(
        //     $logDir . 'img_name.txt',
        //     "\n====图片 " . date('Y-m-d H:i:s') . " ====\n" . $img_name . "\n\n",
        //     FILE_APPEND
        // );

        // 保存原图（1024x1024）
//        $img_name = $this->limitStringLength($img_name);
        $img_name = preg_replace('/[^\x{4e00}-\x{9fa5}A-Za-z0-9_\- ]/u', '', $img_name);
        $img_name = mb_substr($img_name, 0, 30); // 限制为前30个字符（避免路径过长）

        $filename1024 = $img_name . '.png';
        $savePath1024 = $fullBaseDir . '1024x1024/' . $filename1024;
        file_put_contents($savePath1024, $imgData1024);
//        echo 342344543532;
        // 处理缩略图
        $im = @imagecreatefromstring($imgData1024);
        if (!$im) return "图像格式不受支持或已损坏";

        $srcWidth = imagesx($im);
        $srcHeight = imagesy($im);
        $srcRatio = $srcWidth / $srcHeight;
        $dstRatio = $width / $height;

        // 居中裁剪逻辑
        if ($srcRatio > $dstRatio) {
            $cropHeight = $srcHeight;
            $cropWidth = intval($srcHeight * $dstRatio);
            $srcX = intval(($srcWidth - $cropWidth) / 2);
            $srcY = 0;
        } else {
            $cropWidth = $srcWidth;
            $cropHeight = intval($srcWidth / $dstRatio);
            $srcX = 0;
            $srcY = intval(($srcHeight - $cropHeight) / 2);
        }
//        echo 789;
        $dstImg = imagecreatetruecolor($width, $height);
        imagecopyresampled($dstImg, $im, 0, 0, $srcX, $srcY, $width, $height, $cropWidth, $cropHeight);

        // 保存裁剪后图像
        $filenameCustom = $img_name . ".png";
        $savePathCustom = $fullBaseDir . "{$width}x{$height}/" . $filenameCustom;
        imagepng($dstImg, $savePathCustom);
        imagedestroy($im);
        imagedestroy($dstImg);


        // file_put_contents(
        //     $logDir . 'image_url.txt',
        //     "\n====图片路径 " . date('Y-m-d H:i:s') . " ====\n" . str_replace($rootPath . 'public/', '', $savePath1024) . "\n\n",
        //     "\n====图片路径 " . date('Y-m-d H:i:s') . " ====\n" . str_replace($rootPath . 'public/', '', $savePathCustom) . "\n\n",
        //     FILE_APPEND
        // );
        $status = trim($img_name) === '' ? 0 : 1;
        // 更新数据库记录
        $updateRes = Db::name('text_to_image')->where('id', $record['id'])->update([
            'new_image_url' => str_replace($rootPath . 'public/', '', $savePath1024),
            'custom_image_url' => str_replace($rootPath . 'public/', '', $savePathCustom),
            'img_name' => $img_name,
            'error_msg' => '',
            'size' => "{$width}x{$height}",
            'updated_time' => date('Y-m-d H:i:s'),
            'status' => $status
        ]);
        return 0;
    }

    /**
     * 处理字符串长度，超出限制则截断
     *
     * @param string $str 输入字符串
     * @param int $maxLength 最大长度限制（默认200）
     * @return string 处理后的字符串
     */
    public function limitStringLength($str, $maxLength = 10)
    {
        // 如果字符串长度没有超出限制，直接返回
        if (mb_strlen($str, 'UTF-8') <= $maxLength) {
            return $str;
        }

        // 超出限制则截断
        return mb_substr($str, 0, $maxLength, 'UTF-8');
    }
    public function cleanImageUrl($input) {
        // 去除字符串首尾空格和中文引号替换为英文引号
        $input = trim($input);
        $input = str_replace(['“', '”', '‘', '’'], '"', $input);

        // 判断是否为纯中文文字
        if (preg_match('/^[\x{4e00}-\x{9fa5}]+$/u', $input)) {
            // 纯中文：替换掉不适合用于文件名的字符
            $cleaned = preg_replace('/[\/\\\:\*\?"<>\|，。！￥【】、；‘’“”《》\s]+/u', '', $input);
        } elseif (preg_match('/[a-zA-Z]/', $input) && !preg_match('/[\x{4e00}-\x{9fa5}]/u', $input)) {
            // 如果是纯字母和空格，且没有中文字符：保留空格，去掉其他符号
            $cleaned = preg_replace('/[^a-zA-Z\s]/', '', $input);
        } else {
            // 如果包含中文或是其他混合字符，按照纯中文的规则清理符号
            $cleaned = preg_replace('/[\/\\\:\*\?"<>\|，。！￥【】、；‘’“”《》\s]+/u', '', $input);
        }

        return $cleaned;
    }


    /**
     * 文生图模型
     */
    public function callDalleApi($prompt)
    {
        $data = [
            'prompt' => $prompt,
//            'model'   => 'dall-e-2',
            'model'   => 'gpt-image-1',
            'n'       => 1,
            'size'    => '1024x1024',
            'quality' => 'standard',
            'style'   => 'vivid',
            'response_format' => 'url'
        ];
        return $this->callApi($this->config['dalle']['api_url'], $this->config['dalle']['api_key'], $data);
    }




    /**
     * 通用API调用方法
     */
    public function callApi($url, $apiKey, $data)
    {
        $maxRetries = 2;
        $attempt = 0;
        $lastError = '';

        while ($attempt <= $maxRetries) {
            $ch = curl_init();
            curl_setopt_array($ch, [
                CURLOPT_URL => $url,
                CURLOPT_RETURNTRANSFER => true,
                CURLOPT_POST => true,
                CURLOPT_POSTFIELDS => json_encode($data),
                CURLOPT_HTTPHEADER => [
                    'Content-Type: application/json',
                    'Authorization: Bearer ' . $apiKey
                ],
                CURLOPT_TIMEOUT => 120,
                CURLOPT_SSL_VERIFYPEER => false,
                CURLOPT_SSL_VERIFYHOST => 0,
                CURLOPT_TCP_KEEPALIVE => 1,
                CURLOPT_FORBID_REUSE => false
            ]);

            $response = curl_exec($ch);
            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            $curlError = curl_error($ch);
            curl_close($ch);

            if ($response !== false && $httpCode === 200) {
                $result = json_decode($response, true);
                return $result;
            }

            $lastError = $curlError ?: "HTTP错误：{$httpCode}";
            $attempt++;
            sleep(1);
        }

        throw new \Exception("请求失败（重试{$maxRetries}次）：{$lastError}");
    }
}