[ '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 "
";
// print_r($prompt);
// echo "
";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}");
    }
}