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");