update

src/main/java/com/free/controller/ChatRecordController.java

@@ -74,6 +74,7 @@ public class ChatRecordController {
     data.setApply_id(body.getApply_id());
     data.setSpeaker(body.getSpeaker());
     data.setContent(body.getContent());
+    data.setContent_type(body.getContent_type());
     this.service.save(data);
     QueryWrapper qw = new QueryWrapper<>();
     qw.eq("id", data.getId());

src/main/java/com/free/dto/ChatRecordCreateDTO.java

@@ -12,4 +12,5 @@ public class ChatRecordCreateDTO {
   private Long speaker;
   @NotBlank(message = "请输入发言内容")
   private String content;
+  private String content_type;
 }

src/main/java/com/free/entity/ChatRecord.java

@@ -44,4 +44,9 @@ public class ChatRecord extends BaseEntity {
   @ApiModelProperty("发言内容")
   private String content;
 
+  @Column(comment = "内容类型")
+  @TableField(value = "content_type")
+  @ApiModelProperty("内容类型")
+  private String content_type;
+
 }

src/main/java/com/free/mq/MqListeners.java

@@ -5,11 +5,18 @@ import org.springframework.amqp.core.FanoutExchange;
 import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.Queue;
 import org.springframework.amqp.core.TopicExchange;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
+import org.springframework.amqp.rabbit.core.RabbitAdmin;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Lazy;
 
 @Configuration
 public class MqListeners {
+  @Lazy
+  @Autowired
+  RabbitAdmin rabbitAdmin;
   /** 管理用的队列和交换机,主要是平台统一监控: 1.用户进入智能客服;2.用户使用智能客服;3.用户需要转人工; */
   /** 管理用 - 交换机 */
   public final static String adminExName = "adminEx";
@@ -91,4 +98,24 @@ public class MqListeners {
     return BindingBuilder.bind(chatQueue()).to(exchange()).with(routerMatch);
   }
 
+  // 创建初始化RabbitAdmin对象
+  @Bean
+  public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
+    RabbitAdmin rabbitAdmin = new RabbitAdmin(connectionFactory);
+    // 只有设置为 true，spring 才会加载 RabbitAdmin 这个类
+    rabbitAdmin.setAutoStartup(true);
+    return rabbitAdmin;
+  }
+
+  // 创建交换机和对列
+  @Bean
+  public void createExchangeQueue() {
+    rabbitAdmin.declareExchange(admiExchange());
+    rabbitAdmin.declareExchange(userExchange());
+    rabbitAdmin.declareExchange(exchange());
+
+    rabbitAdmin.declareQueue(adminQueue());
+    rabbitAdmin.declareQueue(userQueue());
+    rabbitAdmin.declareQueue(chatQueue());
+  }
 }

src/main/resources/application.yml

@@ -25,6 +25,9 @@ spring:
     username: free
     password: free1977
     virtual-host: customer
+    listener:
+      simple:
+        acknowledge-mode: auto
   devtools:
     restart:
       enabled: true