Merge branch 'dev/dev_xp' into dev/dev
This commit is contained in:
@@ -461,6 +461,11 @@ public class GenerateServiceImpl extends ServiceImpl<GenerateMapper, Generate> i
|
|||||||
Double maxScore = redisUtil.getMaxScore(consumptionOrderKey);
|
Double maxScore = redisUtil.getMaxScore(consumptionOrderKey);
|
||||||
redisUtil.addToZSet(consumptionOrderKey, temp, maxScore);
|
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消息队列
|
// 4、将消息发布到MQ消息队列
|
||||||
rabbitMQService.publishMessageToGenerate(jsonString);
|
rabbitMQService.publishMessageToGenerate(jsonString);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user