From 4e80493a263d77ed62f392ce39bdcb2462759467 Mon Sep 17 00:00:00 2001 From: shahaibo <1023316923@qq.com> Date: Thu, 5 Jun 2025 14:00:38 +0800 Subject: [PATCH] TASK:batch toProductImage;chatStream; --- .../com/ai/da/common/RabbitMQ/GenerateConsumer.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java index 0c07f718..e02ee7cd 100644 --- a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java +++ b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java @@ -375,16 +375,16 @@ public class GenerateConsumer { log.info("toProductImageBatch response : {}", generateResult); try { - log.info("tasks_id : {} start ", generateResult.get("task_id")); + log.info("tasks_id : {} start ", generateResult.get("tasks_id")); if (!StringUtils.isEmpty(generateResult.getString("progress"))) { String progress = generateResult.getString("progress"); - JSONArray result = generateResult.getJSONArray("result"); + JSONObject result = generateResult.getJSONObject("result_data"); String url = null; if (!StringUtils.isEmpty(result)) { - url = result.getString(0); + url = result.getString("image_url"); + String taskId = generateResult.getString("tasks_id"); + userLikeGroupService.toProductBatch(taskId, url, progress); } - String taskId = generateResult.getString("task_id"); - userLikeGroupService.toProductBatch(taskId, url, progress); } else { // 修改redis中的数据状态为exception String key = toProductImageResultKey + ":" + generateResult.get("task_id");