From 4f4135187f711f48672d610fabd048bf9e3171bc Mon Sep 17 00:00:00 2001
From: zhaoxiaohao <279049017@qq.com>
Date: Thu, 22 Apr 2021 11:18:16 +0800
Subject: [PATCH] 添加报告页面的以充值列表一个大的分页

---
 kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java |  100 +++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 99 insertions(+), 1 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 02fda0d..3aa3d0a 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
@@ -13,6 +13,9 @@
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * 石家庄喜高科技有限责任公司 版权所有 © Copyright 2020<br>
  *
@@ -60,9 +63,29 @@
      */
     private String routingKeyName;
 
+    /**
+     * AI返回结果队列
+     */
+    private String AIEvaluationResults;
+
+    /**
+     * 骨龄评价统计
+     */
+    private String BoneAgeEvaluationData;
+
+    /**
+     * 档案统计
+     */
+    private String ChildRecordData;
+
+    /**
+     * 报告统计
+     */
+    private String ReportData;
+
     @Bean
     public ConnectionFactory connectionFactory() {
-        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port);
+        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host, port);
         connectionFactory.setUsername(username);
         connectionFactory.setPassword(password);
         connectionFactory.setVirtualHost(virtualHost);
@@ -137,6 +160,28 @@
     }
 
     @Bean
+    public Queue AIEvaluationResults() {
+        return new Queue(AIEvaluationResults);
+    }
+
+    @Bean
+    public Queue BoneAgeEvaluationData() {
+        return new Queue(BoneAgeEvaluationData);
+    }
+
+    @Bean
+    public Queue ChildRecordData() {
+        return new Queue(ChildRecordData);
+    }
+
+
+    @Bean
+    public Queue ReportData() {
+        return new Queue(ReportData);
+    }
+
+
+    @Bean
     Binding bindingExchangeAIEvaluation(TopicExchange exchange) {
         return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName);
     }
@@ -150,4 +195,57 @@
     Binding bindingExchangeAdvancedEvaluation(TopicExchange exchange) {
         return BindingBuilder.bind(AdvancedEvaluation()).to(exchange).with(routingKeyName);
     }
+
+    /**
+     * 可爱高咨询延时队列交换机
+     * @return
+     */
+    @Bean
+    public CustomExchange delayExchange(){
+        Map<String, Object> args = new HashMap<>(16);
+        args.put("x-delayed-type", "direct");
+        //属性参数 交换机名称 交换机类型 是否持久化 是否自动删除 配置参数
+        return new CustomExchange("kagDelayExchange", "x-delayed-message", true, false, args);
+    }
+
+    /**
+     * 可爱高咨询延时队列D
+     * @return
+     */
+    @Bean
+    public Queue delayQueue(){
+        //属性参数 队列名称 是否持久化
+        return new Queue("kagMessageDelayQueue", true);
+    }
+
+    /**
+     * 可爱高咨询
+     * 延时队列绑定交换机
+     * @return
+     */
+    @Bean
+    public Binding cfgDelayBinding(){
+        return BindingBuilder.bind(delayQueue()).to(delayExchange()).with("kagMessageDelayKey").noargs();
+    }
+
+
+    /**
+     * 可爱高咨询延时队列--更改待完成状态
+     * @return
+     */
+    @Bean
+    public Queue delayUncompletedQueue(){
+        //属性参数 队列名称 是否持久化
+        return new Queue("kagAdvisoryNncompletedDelayQueue", true);
+    }
+
+    /**
+     * 可爱高咨询
+     * 给延时队列绑定交换机
+     * @return
+     */
+    @Bean
+    public Binding delayBinding(){
+        return BindingBuilder.bind(delayQueue()).to(delayExchange()).with("kagAdvisoryUncompletedDelayKey").noargs();
+    }
 }

--
Gitblit v1.8.0