0707 - 增加消息推送

start/src/main/resources/sdk.yml

@@ -63,6 +63,14 @@ openapi:
       apiCode: test:01
       #多个可以逗号隔开，可以为空
       tenantIds: 1838408702262321152
+archives:
+  async:
+    pool:
+      maxPoolSize: 2
+      corePoolSize: 1
+      queueCapacity: 60
+      namePrefix: async-task-
+      keepAliveSeconds: 60
 # 大华平台配置
 dahua:
   oauth:

web-app/pom.xml

@@ -38,6 +38,9 @@
             <version>1.12.23</version>
             <scope>test</scope>
         </dependency>
-
+        <dependency>
+            <groupId>com.alibaba.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
+        </dependency>
     </dependencies>
 </project>

web-client/src/main/java/com/zcloud/primeport/config/ThreadPoolAsyncConfig.java

@@ -0,0 +1,76 @@
+package com.zcloud.primeport.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.ThreadPoolExecutor;
+
+/**
+ * @author zhangyue
+ * @date 2026/2/2 17:24
+ */
+
+@Configuration
+public class ThreadPoolAsyncConfig {
+
+
+    public static Integer maxPoolSize;
+    public static Integer corePoolSize;
+    public static Integer queueCapacity;
+    public static String namePrefix;
+    public static Integer keepAliveSeconds;
+
+    @Value("${archives.async.pool.maxPoolSize}")
+    public void setMaxPoolSize(Integer maxPoolSizeProperties) {
+        maxPoolSize = maxPoolSizeProperties;
+    }
+
+    @Value("${archives.async.pool.corePoolSize}")
+    public void setCorePoolSize(Integer corePoolSizeProperties) {
+        corePoolSize = corePoolSizeProperties;
+    }
+
+    @Value("${archives.async.pool.queueCapacity}")
+    public void setQueueCapacity(Integer queueCapacityProperties) {
+        queueCapacity = queueCapacityProperties;
+    }
+
+    @Value("${archives.async.pool.namePrefix}")
+    public void setNamePrefix(String namePrefixProperties) {
+        namePrefix = namePrefixProperties;
+    }
+
+    @Value("${archives.async.pool.keepAliveSeconds}")
+    public void setKeepAliveSeconds(Integer keepAliveSecondsProperties) {
+        keepAliveSeconds = keepAliveSecondsProperties;
+    }
+
+    @Bean()
+    public Executor asyncExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        //最大线程数
+        executor.setMaxPoolSize(maxPoolSize);
+        //核心线程数
+        executor.setCorePoolSize(corePoolSize);
+        //任务队列的大小
+        executor.setQueueCapacity(queueCapacity);
+        //线程前缀名
+        executor.setThreadNamePrefix(namePrefix);
+        //线程存活时间
+        executor.setKeepAliveSeconds(keepAliveSeconds);
+        /**
+         * 拒绝处理策略
+         * CallerRunsPolicy()：交由调用方线程运行，比如 main 线程。
+         * AbortPolicy()：直接抛出异常。
+         * DiscardPolicy()：直接丢弃。
+         * DiscardOldestPolicy()：丢弃队列中最老的任务。
+         */
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());
+        // 初始化
+        executor.initialize();
+        return executor;
+    }
+}

web-domain/src/main/java/com/zcloud/primeport/domain/model/VehicleAuditE.java

@@ -46,19 +46,5 @@ public class VehicleAuditE extends BaseE {
     //变更前信息
     private String changeBefore;
 
-    public TodoListAddEvent getSendEventObj() {
-        // 发送待办
-        TodoListAddEvent event = new TodoListAddEvent();
-        event.setTitle("测试消息");
-        event.setContent("测试消息内容");
-        event.setForeignKey(this.id); // 业务表ID
-        event.setForeignSubsidiaryKey(this.id); // 业务附表ID 没有附表时为foreignKey的值
-        event.setReceiveUser(getAuditUserId());// user表ID
-        event.setPcFlag(1); // 是否PC端待办 1是 0否
-        event.setAppFlag(1); // 是否APP端待办 1是 0否
-        event.setOtherParams(new JSONObject());
-       return event;
-    }
-
 }