mes-ai-server-api/application/job/ImageToImageJob.php

<?php
namespace app\job;
use app\service\AIGatewayService;
use think\Db;
use think\queue\Job;
use think\Queue;
//图生图
class ImageToImageJob{
    public function fire(Job $job, $data)
    {
        //产品图+模板图） 时走此分支
        if (isset($data['status_val']) && $data['status_val'] == '图生图') {
            $taskId = $data['task_id'];
            // 幂等：若任务已完成则跳过，避免超时重试导致重复执行
            $redis = getTaskRedis();
            $existing = $redis->get("img_to_img_task:{$taskId}");
            if ($existing) {
                $info = json_decode($existing, true);
                if (isset($info['status']) && $info['status'] === 'completed') {
                    echo "任务 {$taskId} 已完成，跳过重复执行\n";
                    $job->delete();
                    return;
                }
            }
            try {
                echo " 开始处理图生图".date('Y-m-d H:i:s')."\n";

                $result = $this->get_img_to_img($data);
                // get_img_to_img 内部已写入 img_to_img_task，此处无需重复写入
                if (is_array($result) && isset($result['code']) && $result['code'] !== 0) {
                    throw new \Exception($result['msg'] ?? '图生图失败');
                }

                echo "🎉 任务 {$taskId} 执行完成，图片生成成功！\n";
                echo "结束时间：" . date('Y-m-d H:i:s') . "\n";
                $job->delete();

            } catch (\Exception $e) {
                echo "图生图失败: " . $e->getMessage() . "\n";
                $job->delete();
            }
            $job->delete();
        } else {
            $logId = $data['log_id'] ?? null;

            try {
                // 任务类型校验（必须是图生图）
                if (!isset($data['type']) || $data['type'] !== '图生图') {
                    $job->delete();
                    return;
                }

                $startTime = date('Y-m-d H:i:s');
                echo "━━━━━━━━━━ ▶ 图生图任务开始处理━━━━━━━━━━\n";
                echo "处理时间：{$startTime}\n";

                // 更新日志状态：处理中
                if ($logId) {
                    Db::name('image_task_log')->where('id', $logId)->update([
                        'status' => 1,
                        'log' => '图生图处理中',
                        'update_time' => $startTime
                    ]);
                }

                //拼接原图文件路径 + 图片名称
                $old_image_url = rtrim($data['sourceDir'], '/') . '/' . ltrim($data['file_name'], '/');

                $list = Db::name("text_to_image")
                    ->where('old_image_url', $old_image_url)
                    ->where('img_name', '<>', '')
                    // ->where('status', 1)
                    ->select();

                if (!empty($list)) {
                    $total = count($list);
                    echo "📊 共需处理：{$total} 条记录\n\n";

                    foreach ($list as $index => $row) {
                        $currentIndex = $index + 1;
                        $begin = date('Y-m-d H:i:s');
                        echo "处理时间：{$begin}\n";
                        echo "👉 正在处理第 {$currentIndex} 条，ID: {$row['id']}\n";

                        // 调用生成图像方法
                        $result = $this->ImageToImage(
                            $data["file_name"],
                            $data["outputDir"],
                            $row["new_image_url"],
                            $row["img_name"],
                            1024,
                            1303
                        );

                        $resultText = ($result === true || $result === 1 || $result === '成功') ? '成功' : '失败或无返回';
                        echo "✅ 处理结果：{$resultText}\n";

                        $end = date('Y-m-d H:i:s');
                        echo "完成时间：{$end}\n";
                        echo "Processed: " . static::class . "\n";
                        echo "图生图已处理完成\n\n";
                    }

                    // 更新日志状态：成功
                    if ($logId) {
                        Db::name('image_task_log')->where('id', $logId)->update([
                            'status' => 2,
                            'log' => '图生图处理成功',
                            'update_time' => date('Y-m-d H:i:s')
                        ]);
                    }

                    echo date('Y-m-d H:i:s') . " 图生图任务全部完成\n";
                } else {

                    echo "未找到可处理的数据，跳过执行\n";
                    if ($logId) {
                        Db::name('image_task_log')->where('id', $logId)->update([
                            'status' => 2,
                            'log' => '无数据可处理，已跳过'.$old_image_url,
                            'update_time' => date('Y-m-d H:i:s')
                        ]);
                    }
                }

                // 如果还有链式任务，继续推送
                if (!empty($data['chain_next'])) {
                    $nextType = array_shift($data['chain_next']);
                    $data['type'] = $nextType;

                    Queue::push('app\job\ImageArrJob', [
                        'task_id' => $data['task_id'],
                        'data' => [$data]
                    ], 'arrimage');
                }

                $job->delete();

            }  catch (\Exception $e) {
                //异常处理，记录失败日志
                echo "错误信息: " . $e->getMessage() . "\n";
                echo "文件: " . $e->getFile() . "\n";
                echo "行号: " . $e->getLine() . "\n";

                // 删除当前任务
                $job->delete();
            }
        }


    }

    /**
     * 失败回调（可用于后续通知或重试机制）
     */
    public function failed($data)
    {
        echo "ImageJob failed: " . json_encode($data);
    }

    /**
     * Gemini 图生图：产品图 + 模板图 + 提示词 → 生成新图
     */
    public function get_img_to_img($data)
    {

        $prompt = trim($data['prompt'] ?? '');
        $size = trim($data['size'] ?? '');
        $status_val = trim($data['status_val'] ?? '');
        $product_img = trim($data['product_img'] ?? '');
        $template_img = trim($data['template_img'] ?? '');
        $model = trim($data['model']);
        $sys_id = trim($data['sys_id']);
        $date = date('Y-m-d H:i:s');

        $setTaskError = function ($msg) use ($data) {
            if (!empty($data['task_id'])) {
                try {
                    $redis = getTaskRedis();
                    $redis->set("img_to_img_task:" . $data['task_id'], json_encode([
                        'status' => 'failed',
                        'msg' => $msg,
                        'error' => $msg,
                        'completed_at' => date('Y-m-d H:i:s')
                    ], JSON_UNESCAPED_UNICODE), ['EX' => 300]);
                } catch (\Exception $e) {
                }
            }
        };

        $product_base64Data = null;
        $product_mimeType = 'image/png';
        $template_base64Data = null;
        $template_mimeType = 'image/png';
        if ($data['status_type'] == 'ProductImageGeneration') {
            //产品图创作页面参数配置
            // 前端传 base64，先解析用于调接口，成功后再存文件与数据库
            preg_match('/data:image\/(png|jpg|jpeg);base64,([^"]+)/', $product_img, $pm);
            if (empty($pm)) {
                $setTaskError('产品图未找到图片数据');
                return ['code' => 1, 'msg' => '产品图未找到图片数据'];
            }
            $product_base64Data = preg_replace('/\s+/', '', $pm[2]);
            $product_mimeType = ($pm[1] == 'jpg' ? 'image/jpeg' : 'image/' . $pm[1]);
            $product_img_ext = $pm[1];

            preg_match('/data:image\/(png|jpg|jpeg);base64,([^"]+)/', $template_img, $tm);
            if (empty($tm)) {
                $setTaskError('模板图未找到图片数据');
                return ['code' => 1, 'msg' => '模板图未找到图片数据'];
            }
            $template_base64Data = preg_replace('/\s+/', '', $tm[2]);
            $template_mimeType = ($tm[1] == 'jpg' ? 'image/jpeg' : 'image/' . $tm[1]);
            $template_img_ext = $tm[1];
        } else if($data['status_type'] == 'ProductTemplateReplace'){
            //产品替换页面参数配置
            $productImgRaw = AIGatewayService::file_get_contents($product_img);
            $product_base64Data = $productImgRaw['base64Data'];
            $product_mimeType = $productImgRaw['mimeType'];
            $templateImgRaw = AIGatewayService::file_get_contents($template_img);
            $template_base64Data = $templateImgRaw['base64Data'];
            $template_mimeType = $templateImgRaw['mimeType'];
        }else {
            return ['code' => 1, 'msg' => '当前页面未进行配置，请联系管理员开通权限'];
        }

        $defaultPrompt = '请完成产品模板替换：
                            1. 从产品图提取产品主体、品牌名称、核心文案；
                            2. 从模板图继承版式布局、文字排版、色彩风格、背景元素；
                            3. 将模板图中的产品和文字替换为产品图的内容；
                            4. 最终生成的图片与模板图视觉风格100%统一，仅替换产品和文字。';
        $promptContent = $prompt ? $prompt . "\n\n" . $defaultPrompt : $defaultPrompt;
        $aiGateway = new AIGatewayService();
        $res = $aiGateway->buildRequestData($status_val,$model,$promptContent,$size,$product_base64Data,$product_mimeType,$template_base64Data,$template_mimeType);

        $base64Data = null;
        if (isset($res['candidates'][0]['content']['parts'][0]['inlineData']['data'])) {
            $base64Data = $res['candidates'][0]['content']['parts'][0]['inlineData']['data'];
        } elseif (isset($res['candidates'][0]['content']['parts'][0]['text'])) {
            $text = $res['candidates'][0]['content']['parts'][0]['text'];
            // text 格式多为 ![image](data:image/png;base64,XXX)，支持换行
            if (preg_match('/data:image\/(png|jpg|jpeg|webp);base64,([^\)]+)/i', $text, $m)) {
                $base64Data = preg_replace('/\s+/', '', $m[2]);
            }
        }
        if (!$base64Data) {
            $errMsg = isset($res['error']['message']) ? $res['error']['message'] : '未获取到图片数据';
            $setTaskError($errMsg);
            return ['code' => 1, 'msg' => $errMsg];
        }
        $imageData = base64_decode($base64Data);

        if ($imageData === false || strlen($imageData) < 100) {
            $setTaskError('图片Base64解码失败');
            return ['code' => 1, 'msg' => '图片Base64解码失败'];
        }

        if ($data['status_type'] == 'ProductImageGeneration') {
            // 接口成功后再存文件与数据库
            $rootPath = str_replace('\\', '/', ROOT_PATH);
            $saveDir = rtrim($rootPath, '/') . '/public/uploads/Product/' . date('Y-m-d') . '/';
            if (!is_dir($saveDir)) {
                mkdir($saveDir, 0755, true);
            }

            $product_file = 'product-' . uniqid() . '.' . $product_img_ext;
            $product_image_data = base64_decode($product_base64Data);
            if ($product_image_data === false || !file_put_contents($saveDir . $product_file, $product_image_data)) {
                $setTaskError('产品图保存失败');
                return ['code' => 1, 'msg' => '产品图保存失败'];
            }
            $product_db_path = '/uploads/Product/' . date('Y-m-d') . '/' . $product_file;

            $template_file = 'template-' . uniqid() . '.' . $template_img_ext;
            $template_image_data = base64_decode($template_base64Data);
            if ($template_image_data === false || !file_put_contents($saveDir . $template_file, $template_image_data)) {
                $setTaskError('模板图保存失败');
                return ['code' => 1, 'msg' => '模板图保存失败'];
            }
            $template_db_path = '/uploads/Product/' . date('Y-m-d') . '/' . $template_file;

            $fileName = uniqid() . '.png';
            if (!file_put_contents($saveDir . $fileName, $imageData)) {
                $setTaskError('生成图保存失败');
                return ['code' => 1, 'msg' => '生成图保存失败'];
            }
            $db_img_path = '/uploads/Product/' . date('Y-m-d') . '/' . $fileName;

            Db::name('product_image_generate')->insert([
                'prompt' => $prompt,
                'model' => $model,
                'product_img' => $product_db_path,
                'reference_image' => $template_db_path,
                'generated_image' => $db_img_path,
                'status_val' => $status_val,
                'size' => $size,
                'sys_id' => $sys_id,
                'createTime' => $date,
            ]);

            if (!empty($data['task_id'])) {
                try {
                    $redis = getTaskRedis();
                    $redis->set("img_to_img_task:" . $data['task_id'], json_encode([
                        'status' => 'completed',
                        'image' => $db_img_path,
                        'image_url' => $db_img_path,
                        'completed_at' => date('Y-m-d H:i:s')
                    ], JSON_UNESCAPED_UNICODE), ['EX' => 300]);
                } catch (\Exception $e) {
                    // 忽略 Redis 错误
                }
            }
            return $db_img_path;
        } else if($data['status_type'] == 'ProductTemplateReplace'){
            $record = [];
            // 获取产品信息
            $product = Db::name('product')->where('id', $data['id'])->find();
            if (empty($product)) {
                $setTaskError('产品不存在');
                return '产品不存在';
            }
            $product_code = $product['product_code'];
            $product_code_prefix = substr($product_code, 0, 9); // 前九位

            $rootPath = str_replace('\\', '/', ROOT_PATH);
            // $saveDir = rtrim($rootPath, '/') . '/public/uploads/ceshi/';
            $saveDir = rtrim($rootPath, '/') . '/public/uploads/merchant/'. '/' . $product_code_prefix . '/' . $product_code . '/' . 'newimg' . '/';

            if (!is_dir($saveDir)) {
                mkdir($saveDir, 0755, true);
            }
            $fileName = 'img2img-' . date('YmdHis') . '-' . uniqid() . '.png';
            $fullPath = $saveDir . $fileName;
            if (!file_put_contents($fullPath, $imageData)) {
                $setTaskError('图片保存失败');
                return ['code' => 1, 'msg' => '图片保存失败'];
            }

            // $db_img_path = '/uploads/ceshi/'. $fileName;
            $db_img_path = '/uploads/merchant/'. '/' . $product_code_prefix . '/' . $product_code . '/' . 'newimg' . '/' . $fileName;

            Db::name('product')->where('id',  $data['id'])->update
            (
                [
                    'createTime' => date('Y-m-d H:i:s'),
                    'content' => $data['prompt'],
                    'product_new_img' => $db_img_path
                ]
            );
            //生成新图后保存到记录 存留历史图片
            $record['product_id'] = $data['id'];
            $record['product_new_img'] = $db_img_path;
            $record['product_content'] = $data['prompt'];
            $record['template_id'] = $data['template_id'];
            $record['createTime'] = date('Y-m-d H:i:s');
            Db::name('product_image')->insert($record);

            if (!empty($data['task_id'])) {
                try {
                    $redis = getTaskRedis();
                    $redis->set("img_to_img_task:" . $data['task_id'], json_encode([
                        'status' => 'completed',
                        'image' => $db_img_path,
                        'image_url' => $db_img_path,
                        'completed_at' => date('Y-m-d H:i:s')
                    ], JSON_UNESCAPED_UNICODE), ['EX' => 300]);
                } catch (\Exception $e) {
                    // 忽略 Redis 错误
                }
            }

            return $db_img_path;
        }else{
            return ['code' => 1, 'msg' => '当前页面未进行配置，请联系管理员开通权限'];
        }
    }

    public function ImageToImage($fileName, $outputDirRaw, $new_image_url, $width, $height)
    {
        $rootPath = str_replace('\\', '/', ROOT_PATH);
        $outputDir = rtrim($rootPath . 'public/' . ltrim($outputDirRaw, '/'), '/') . '/';
        $dateDir = date('Y-m-d') . '/';
        $fullBaseDir = $outputDir . $dateDir;

        // 创建主目录和 imgtoimg 子目录
        if (!is_dir($fullBaseDir)) {
            mkdir($fullBaseDir, 0755, true);
        }

        $imgtoimgDir = $fullBaseDir . '1024x1303/';
        if (!is_dir($imgtoimgDir)) {
            mkdir($imgtoimgDir, 0755, true);
        }

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

        if (!$record) {
            return json(['code' => 1, 'msg' => '没有找到匹配的图像记录']);
        }

        // 调用 AI 图生图 API
        $ai = new AIGatewayService();
        $res = $ai->txt2imgWithControlNet('', $new_image_url);
        if (!isset($res['code']) || $res['code'] !== 0) {
            return json(['code' => 1, 'msg' => $res['msg'] ?? '图像生成失败']);
        }

        // 生成保存文件路径
        $originalBaseName = pathinfo($new_image_url, PATHINFO_FILENAME);
        $finalFileName = $originalBaseName . '.png';
        $savePath = $imgtoimgDir . $finalFileName;

        // 写入图像文件
        if (!file_put_contents($savePath, base64_decode($res['data']['base64']))) {
            return json(['code' => 1, 'msg' => '图像保存失败，请检查目录权限']);
        }

        // 构造相对路径用于数据库
        $relativeImgPath = rtrim($outputDirRaw, '/') . '/' . $dateDir . '1024x1303/' . $finalFileName;

        // 更新数据库记录
        Db::name('text_to_image')->where('id', $record['id'])->update([
            'imgtoimg_url' => $relativeImgPath,
            'status_name' => '图生图',
            'error_msg' => '',
            'update_time' => date('Y-m-d H:i:s')
        ]);

        // 返回成功响应
        return "成功";
    }
}