generate 将还未处理的请求置为Waiting状态

This commit is contained in:
2024-04-30 11:39:04 +08:00
parent 5f0546c6cf
commit 988fe89576

View File

@@ -461,6 +461,11 @@ public class GenerateServiceImpl extends ServiceImpl<GenerateMapper, Generate> 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);
}