From 988fe8957642a01f512623e4d54dbcc12d6836da Mon Sep 17 00:00:00 2001 From: xupei Date: Tue, 30 Apr 2024 11:39:04 +0800 Subject: [PATCH] =?UTF-8?q?generate=20=E5=B0=86=E8=BF=98=E6=9C=AA=E5=A4=84?= =?UTF-8?q?=E7=90=86=E7=9A=84=E8=AF=B7=E6=B1=82=E7=BD=AE=E4=B8=BAWaiting?= =?UTF-8?q?=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ai/da/service/impl/GenerateServiceImpl.java | 5 +++++ 1 file changed, 5 insertions(+) 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 1678b3b9..1755eb60 100644 --- a/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java +++ b/src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java @@ -461,6 +461,11 @@ public class GenerateServiceImpl extends ServiceImpl i Double maxScore = redisUtil.getMaxScore(consumptionOrderKey); redisUtil.addToZSet(consumptionOrderKey, temp, maxScore); + // 加入resultMap + String key = generateResultKey + ":" + temp; + GenerateResultVO generateResultVO = new GenerateResultVO(generateThroughImageTextDTO.getUniqueId(), null, null, "Waiting"); + redisUtil.addToString(key, new Gson().toJson(generateResultVO), CommonConstant.GENERATE_RESULT_EXPIRE_TIME); + // 4、将消息发布到MQ消息队列 rabbitMQService.publishMessageToGenerate(jsonString); }