From 942b5eb19bf8880d2135a5f7df07a5c12cae82d6 Mon Sep 17 00:00:00 2001 From: shahaibo <1023316923@qq.com> Date: Fri, 13 Jun 2025 11:48:08 +0800 Subject: [PATCH] BUGFIX: cloud; --- .../da/common/RabbitMQ/GenerateConsumer.java | 36 +++++++++---------- 1 file changed, 18 insertions(+), 18 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 c12a6d33..b8c83e88 100644 --- a/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java +++ b/src/main/java/com/ai/da/common/RabbitMQ/GenerateConsumer.java @@ -380,7 +380,7 @@ public class GenerateConsumer { String progress = generateResult.getString("progress"); JSONObject result = generateResult.getJSONObject("result"); String url = null; - if (!StringUtils.isEmpty(result)) { + if (!progress.equals("OK") && !StringUtils.isEmpty(result)) { url = result.getString("product_img"); String taskId = generateResult.getString("task_id"); userLikeGroupService.toProductBatch(taskId, url, progress); @@ -604,21 +604,21 @@ public class GenerateConsumer { public void getDesignBatchResult(Message msg, Channel channel) { processDesignBatchResult(msg, channel); } - @RabbitListener(queues = "#{rabbitMQProperties.queues.toProductImageBatch}") - @RabbitHandler - public void getToProductImageBatchResult(Message msg, Channel channel) { - processToProductImageBatchResult(msg, channel); - } - - @RabbitListener(queues = "#{rabbitMQProperties.queues.relightBatch}") - @RabbitHandler - public void getRelightBatchResult(Message msg, Channel channel) { - processRelightBatchResult(msg, channel); - } - - @RabbitListener(queues = "#{rabbitMQProperties.queues.poseTransformBatch}") - @RabbitHandler - public void getPoseTransformBatchResult(Message msg, Channel channel) { - processPoseTransformBatchResult(msg, channel); - } +// @RabbitListener(queues = "#{rabbitMQProperties.queues.toProductImageBatch}") +// @RabbitHandler +// public void getToProductImageBatchResult(Message msg, Channel channel) { +// processToProductImageBatchResult(msg, channel); +// } +// +// @RabbitListener(queues = "#{rabbitMQProperties.queues.relightBatch}") +// @RabbitHandler +// public void getRelightBatchResult(Message msg, Channel channel) { +// processRelightBatchResult(msg, channel); +// } +// +// @RabbitListener(queues = "#{rabbitMQProperties.queues.poseTransformBatch}") +// @RabbitHandler +// public void getPoseTransformBatchResult(Message msg, Channel channel) { +// processPoseTransformBatchResult(msg, channel); +// } }