From cc8f2e07782958be2e9930eb1eec3367ea45ae65 Mon Sep 17 00:00:00 2001 From: shahaibo <1023316923@qq.com> Date: Mon, 21 Apr 2025 23:44:55 +0800 Subject: [PATCH] =?UTF-8?q?TASK:=E6=A8=A1=E5=9D=97=E5=8C=96=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ai/da/common/RabbitMQ/GenerateConsumer.java | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 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 546de399..9324ef97 100644 --- a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java +++ b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java @@ -382,7 +382,11 @@ public class GenerateConsumer { log.info("task_id : {} start ", generateResult.get("task_id")); if (generateResult.get("status").equals("SUCCESS")) { String progress = generateResult.getString("progress"); - String url = generateResult.getJSONArray("result").getString(0); + JSONArray result = generateResult.getJSONArray("result"); + String url = null; + if (!StringUtils.isEmpty(result)) { + url = result.getString(0); + } String taskId = generateResult.getString("task_id"); userLikeGroupService.relightBatch(taskId, url, progress); } else { @@ -506,9 +510,9 @@ public class GenerateConsumer { processToProductImageBatchResult(msg, channel); } -// @RabbitListener(queues = "#{rabbitMQProperties.queues.relightBatch}") -// @RabbitHandler -// public void getRelightBatchResult(Message msg, Channel channel) { -// processRelightBatchResult(msg, channel); -// } + @RabbitListener(queues = "#{rabbitMQProperties.queues.relightBatch}") + @RabbitHandler + public void getRelightBatchResult(Message msg, Channel channel) { + processRelightBatchResult(msg, channel); + } }