From 3fd36846ad612f627c0784587dc6099a322a158e Mon Sep 17 00:00:00 2001 From: houruijun <411269194@kidgrow.com> Date: Wed, 24 Jun 2020 18:55:09 +0800 Subject: [PATCH] 1.编写扣费业务4大接口(AI 调用前,失败退,调用后,人工读) 2.增加写mq消息队列 3.增加扣费业务相关全局静态值 4.调整扣费,套餐,套餐记录services里面的调用关系。 --- kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java | 24 ++++++++++++++++++++++-- 1 files changed, 22 insertions(+), 2 deletions(-) diff --git a/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java b/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java index bcf5d4f..02fda0d 100644 --- a/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java +++ b/kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java @@ -127,7 +127,27 @@ } @Bean - Binding bindingExchangeMessage(Queue kidgrowQueue, TopicExchange exchange) { - return BindingBuilder.bind(kidgrowQueue).to(exchange).with(routingKeyName); + Binding bindingExchangeMessage(TopicExchange exchange) { + return BindingBuilder.bind(KidgrowQueue()).to(exchange).with(routingKeyName); + } + + @Bean + public Queue AIEvaluation() { + return new Queue("AIEvaluation"); + } + + @Bean + Binding bindingExchangeAIEvaluation(TopicExchange exchange) { + return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName); + } + + @Bean + public Queue AdvancedEvaluation() { + return new Queue("AdvancedEvaluation"); + } + + @Bean + Binding bindingExchangeAdvancedEvaluation(TopicExchange exchange) { + return BindingBuilder.bind(AdvancedEvaluation()).to(exchange).with(routingKeyName); } } -- Gitblit v1.8.0