From 0c9d5404c60b26cc8c094c34723d07ef6d14b732 Mon Sep 17 00:00:00 2001 From: litianxiang Date: Tue, 24 Mar 2026 14:05:27 +0800 Subject: [PATCH] =?UTF-8?q?flux2=E5=A4=B1=E8=B4=A5=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E5=88=A4=E6=96=AD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/ai/da/python/PythonService.java | 10 +++++++++- .../com/ai/da/service/impl/GenerateServiceImpl.java | 2 +- 2 files changed, 10 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/ai/da/python/PythonService.java b/src/main/java/com/ai/da/python/PythonService.java index 9645f62f..f20b0ae2 100644 --- a/src/main/java/com/ai/da/python/PythonService.java +++ b/src/main/java/com/ai/da/python/PythonService.java @@ -3417,7 +3417,6 @@ public class PythonService { mqMessage.put("message", "success"); mqMessage.put("image_url", outputPath); mqMessage.put("category", ""); - String mqMessageBody = JSON.toJSONString(mqMessage); rabbitMQService.publishMessageToGenerateResult(mqMessageBody); } @@ -3425,8 +3424,17 @@ public class PythonService { } else { log.info("generateSketchOrPrintPrint失败###{}", jsonObject); log.info("Generate Exception! Code : " + jsonObject.get("code")); + Map mqMessage = new HashMap<>(); + mqMessage.put("tasks_id", taskId); + mqMessage.put("status", "ERROR"); + mqMessage.put("message", ""); + mqMessage.put("image_url", ""); + mqMessage.put("category", ""); + String mqMessageBody = JSON.toJSONString(mqMessage); + rabbitMQService.publishMessageToGenerateResult(mqMessageBody); return Boolean.FALSE; } + } public Response sendPostToModel(String content, String portAndRoute, String functionName) { diff --git a/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java b/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java index 91ef6282..daed7a7d 100644 --- a/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java +++ b/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java @@ -250,7 +250,7 @@ public class GenerateServiceImpl extends ServiceImpl i .object_name(objectName) .bucket_name(userBucket) .prompt(text).build(); - jsonString = JSON.toJSONString(imageProcessRequest, SerializerFeature.WriteMapNullValue); + jsonString = JSON.toJSONString(imageProcessRequest); } Boolean requestResult = pythonService.generateSketchOrPrint(jsonString, port, path,generateThroughImageTextDTO.getUniqueId());