四川日报压缩包推送

src/main/java/com/fdkankan/external/entity/SceneEditControls.java

@@ -1,6 +1,7 @@
 package com.fdkankan.external.entity;
 
 import com.baomidou.mybatisplus.annotation.*;
+import com.mybatisflex.annotation.Table;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -17,7 +18,7 @@ import java.util.Date;
  */
 @Getter
 @Setter
-@TableName("t_scene_edit_controls")
+@Table("t_scene_edit_controls")
 public class SceneEditControls implements Serializable {
 
     private static final long serialVersionUID = 1L;

src/main/java/com/fdkankan/external/entity/SceneEditInfo.java

@@ -1,6 +1,7 @@
 package com.fdkankan.external.entity;
 
 import com.baomidou.mybatisplus.annotation.*;
+import com.mybatisflex.annotation.Table;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -17,7 +18,7 @@ import java.util.Date;
  */
 @Getter
 @Setter
-@TableName("t_scene_edit_info")
+@Table("t_scene_edit_info")
 public class SceneEditInfo implements Serializable {
 
     private static final long serialVersionUID = 1L;

src/main/java/com/fdkankan/external/entity/SceneEditInfoExt.java

@@ -1,6 +1,7 @@
 package com.fdkankan.external.entity;
 
 import com.baomidou.mybatisplus.annotation.*;
+import com.mybatisflex.annotation.Table;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -16,7 +17,7 @@ import java.util.Date;
  */
 @Getter
 @Setter
-@TableName("t_scene_edit_info_ext")
+@Table("t_scene_edit_info_ext")
 public class SceneEditInfoExt {
 
     private static final long serialVersionUID = 1L;

src/main/java/com/fdkankan/external/entity/ScenePlus.java

@@ -1,6 +1,7 @@
 package com.fdkankan.external.entity;
 
 import com.baomidou.mybatisplus.annotation.*;
+import com.mybatisflex.annotation.Table;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -17,7 +18,7 @@ import java.util.Date;
  */
 @Getter
 @Setter
-@TableName("t_scene_plus")
+@Table("t_scene_plus")
 public class ScenePlus implements Serializable {
 
     private static final long serialVersionUID = 1L;

src/main/java/com/fdkankan/external/entity/ScenePlusExt.java

@@ -1,6 +1,7 @@
 package com.fdkankan.external.entity;
 
 import com.baomidou.mybatisplus.annotation.*;
+import com.mybatisflex.annotation.Table;
 import lombok.Getter;
 import lombok.Setter;
 
@@ -17,7 +18,7 @@ import java.util.Date;
  */
 @Getter
 @Setter
-@TableName("t_scene_plus_ext")
+@Table("t_scene_plus_ext")
 public class ScenePlusExt implements Serializable {
 
     private static final long serialVersionUID = 1L;

src/main/resources/application.yml

@@ -16,6 +16,20 @@ spring:
         max-wait: -1 # 连接池最大阻塞等待时间（使用负值表示没有限制）
     lettuce:
       shutdown-timeout: 0ms
+  rabbitmq:
+    host: 120.24.144.164
+    port: 5672
+    username: admin
+    password: adminv41234
+    virtual-host: 4dkankan
+    connection-timeout: 0
+    listener:
+      simple:
+        prefetch: 5
+        max-concurrency: 10
+        acknowledge-mode: manual #开启消费者手动确认
+    #开启消息投递确认机制
+    publisher-confirm-type: correlated
 account:
   username: super-admin
   password: Aa123456