MQ配置文件修改

custom-server-app/pom.xml

@@ -49,5 +49,14 @@
             <groupId>org.springframework.security</groupId>
             <artifactId>spring-security-crypto</artifactId>
         </dependency>
+        <!-- RabbitMQ -->
+        <dependency>
+            <groupId>org.springframework.amqp</groupId>
+            <artifactId>spring-rabbit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
     </dependencies>
 </project>

custom-server-app/src/main/java/com/jomalls/custom/app/dto/warehouse/CustomWarehouseInfoUpdateDTO.java

@@ -111,4 +111,10 @@ public class CustomWarehouseInfoUpdateDTO implements Serializable {
 
     @Schema(description = "是否为正式仓库")
     private Boolean formal;
+
+    /**
+     * 1已上线，10待上线，20已下线，30待下线
+     */
+    @Schema(description = "1已上线，10待上线，20已下线，30待下线")
+    private Integer status;
 }

custom-server-core/pom.xml

@@ -63,10 +63,6 @@
             <artifactId>transmittable-thread-local</artifactId>
         </dependency>
         <dependency>
-            <groupId>org.springframework.amqp</groupId>
-            <artifactId>spring-rabbit</artifactId>
-        </dependency>
-        <dependency>
             <groupId>org.dromara.x-file-storage</groupId>
             <artifactId>x-file-storage-spring</artifactId>
         </dependency>

custom-server-starter/pom.xml

@@ -79,6 +79,15 @@
             <groupId>org.springframework.security</groupId>
             <artifactId>spring-security-crypto</artifactId>
         </dependency>
+        <!-- RabbitMQ -->
+        <dependency>
+            <groupId>org.springframework.amqp</groupId>
+            <artifactId>spring-rabbit</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-amqp</artifactId>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

custom-server-starter/src/main/java/com/jomalls/custom/config/RabbitMqApplicationRunner.java

+package com.jomalls.custom.config;
+
+import com.jomalls.custom.app.mq.MqTool;
+import com.jomalls.custom.enums.MqRoute;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.ApplicationArguments;
+import org.springframework.boot.ApplicationRunner;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+
+@Component  //被 spring 容器管理
+@Order(1)   //如果多个自定义的 ApplicationRunner  ，用来标明执行的顺序
+public class RabbitMqApplicationRunner implements ApplicationRunner {
+
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
+
+    @Override
+    public void run(ApplicationArguments args) throws Exception {
+        MqTool.init(rabbitTemplate, MqRoute.geList());
+    }
+}
\ No newline at end of file

custom-server-starter/src/main/java/com/jomalls/custom/config/WebMvcConfiguration.java

@@ -37,7 +37,8 @@ public class WebMvcConfiguration implements WebMvcConfigurer {
                         "/api/v3/actuator/*",
                         "/.well-known/**",
                         "/favicon.ico",
-                        "/static/**");
+                        "/static/**",
+                        "/rest/**");
     }
 
     /**

custom-server-starter/src/main/resources/application-dev.yml

@@ -12,6 +12,17 @@ spring:
       port: 6379
       password: joshine.dev
       database: 7
+  # RabbitMQ配置
+  rabbitmq:
+    host: 172.16.19.99 #测试
+    port: 5672 # AMQP协议端口
+    username: admin
+    password: joshine_mq$ #测试
+    virtual-host: / #rabbitmq 的虚拟机
+    # 发送方确认回调
+    publisher-confirm-type: correlated
+    # 发送方返回
+    publisher-returns: true
 # 令牌配置
 token:
   header: Authorization

custom-server-starter/src/main/resources/application-prod.yml

@@ -12,6 +12,17 @@ spring:
       port: 6379
       password: joshine.dev
       database: 7
+  # RabbitMQ配置
+  rabbitmq:
+    host: 47.122.114.252 #这里改为你自己的IP地址
+    port: 5672 # AMQP协议端口
+    username: admin
+    password: joshine_mq$
+    virtual-host: / # rabbitmq 的虚拟机
+    # 发送方确认回调
+    publisher-confirm-type: correlated
+    # 发送方返回
+    publisher-returns: true
 # 令牌配置
 token:
   header: Authorization
@@ -45,4 +56,4 @@ dromara:
         end-point: oss-cn-hangzhou.aliyuncs.com
         bucket-name: jomalls-psd
         domain: https://jomalls-psd.oss-cn-hangzhou.aliyuncs.com/ # 访问域名，注意“/”结尾，例如：https://abc.oss-cn-shanghai.aliyuncs.com/
-        base-path: custom/ # 基础路径
\ No newline at end of file
+        base-path: custom/ # 基础路径

custom-server-starter/src/main/resources/application-test.yml

@@ -12,6 +12,17 @@ spring:
       port: 6379
       password: joshine.dev
       database: 7
+  # RabbitMQ配置
+  rabbitmq:
+    host: 172.16.19.100 #这里改为你自己的IP地址
+    port: 5672 # AMQP协议端口
+    username: admin
+    password: joshine_mq$@
+    virtual-host: /test-env # rabbitmq 的虚拟机
+    # 发送方确认回调
+    publisher-confirm-type: correlated
+    # 发送方返回
+    publisher-returns: true
 # 令牌配置
 token:
   header: Authorization

pom.xml

@@ -27,7 +27,6 @@
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <x-file.version>2.3.0</x-file.version>
         <aliyun-oss.version>3.16.1</aliyun-oss.version>
-        <spring-boot-starter-amqp.version>2.5.15</spring-boot-starter-amqp.version>
     </properties>
     <dependencies>
         <dependency>
@@ -135,12 +134,6 @@
                 <artifactId>x-file-storage-spring</artifactId>
                 <version>${x-file.version}</version>
             </dependency>
-            <!-- RabbitMQ -->
-            <dependency>
-                <groupId>org.springframework.boot</groupId>
-                <artifactId>spring-boot-starter-amqp</artifactId>
-                <version>${spring-boot-starter-amqp.version}</version>
-            </dependency>
             <dependency>
                 <groupId>com.aliyun.oss</groupId>
                 <artifactId>aliyun-sdk-oss</artifactId>