From 91e8eb21da3cce30430a8007c9a1c62586315f32 Mon Sep 17 00:00:00 2001 From: luogw <3132758203@qq.com> Date: Fri, 6 Feb 2026 16:54:21 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E6=B1=A0=E6=95=B0=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/project/ding/utils/DingUtil.java | 2 +- .../KnowledgePointApplicationServiceImpl.java | 2 +- .../config/InformationAsyncConfig.java | 41 ------------------- .../mapper/KnowledgePointMapper.java | 6 +-- .../OperationLogApplicationServiceImpl.java | 2 +- .../project/operation/config/AsyncConfig.java | 37 ++++------------- 6 files changed, 13 insertions(+), 77 deletions(-) delete mode 100644 src/main/java/com/project/information/config/InformationAsyncConfig.java diff --git a/src/main/java/com/project/ding/utils/DingUtil.java b/src/main/java/com/project/ding/utils/DingUtil.java index 1653575..275446c 100644 --- a/src/main/java/com/project/ding/utils/DingUtil.java +++ b/src/main/java/com/project/ding/utils/DingUtil.java @@ -141,7 +141,7 @@ public class DingUtil { /** * 发送工作通知 */ - @Async("dingNoticeExecutor") + @Async("asycExecutor") public void sendWorkNotice(AppealDTO appealDTO) throws DtErrorException { DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); String nowTime = LocalDateTime.now().format(formatter); diff --git a/src/main/java/com/project/information/application/KnowledgePointApplicationServiceImpl.java b/src/main/java/com/project/information/application/KnowledgePointApplicationServiceImpl.java index 89c0c4d..94916e0 100644 --- a/src/main/java/com/project/information/application/KnowledgePointApplicationServiceImpl.java +++ b/src/main/java/com/project/information/application/KnowledgePointApplicationServiceImpl.java @@ -51,7 +51,7 @@ public class KnowledgePointApplicationServiceImpl implements KnowledgePointAppli } @Override - @Async("parseExecutor") + @Async("asycExecutor") public void parse(Map fileMap) { for (Long id : fileMap.keySet()) { try { diff --git a/src/main/java/com/project/information/config/InformationAsyncConfig.java b/src/main/java/com/project/information/config/InformationAsyncConfig.java deleted file mode 100644 index 17e76ba..0000000 --- a/src/main/java/com/project/information/config/InformationAsyncConfig.java +++ /dev/null @@ -1,41 +0,0 @@ -package com.project.information.config; - -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; -import org.springframework.scheduling.annotation.EnableAsync; -import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; - -import java.util.concurrent.Executor; -import java.util.concurrent.ThreadPoolExecutor; - -/** - * 异步配置类：开启异步支持 - */ -@Configuration -@EnableAsync -public class InformationAsyncConfig { - - /** - * 自定义发生通知异步线程池 - */ - @Bean(name = "parseExecutor") - public Executor parseExecutor() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); - // 核心线程数（根据业务量调整） - executor.setCorePoolSize(5); - // 最大线程数 - executor.setMaxPoolSize(10); - // 队列容量 - executor.setQueueCapacity(100); - // 线程前缀名（便于日志排查） - executor.setThreadNamePrefix("parse-file-"); - // 线程空闲超时时间 - executor.setKeepAliveSeconds(60); - // 拒绝策略：队列满时由调用线程执行 - executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); - // 初始化线程池 - executor.initialize(); - return executor; - } - -} diff --git a/src/main/java/com/project/information/mapper/KnowledgePointMapper.java b/src/main/java/com/project/information/mapper/KnowledgePointMapper.java index c974d9a..645a456 100644 --- a/src/main/java/com/project/information/mapper/KnowledgePointMapper.java +++ b/src/main/java/com/project/information/mapper/KnowledgePointMapper.java @@ -19,9 +19,9 @@ public interface KnowledgePointMapper extends BaseMapper { */ @Select({ "SELECT", - " SUM(CASE WHEN p.knowledgeType = 0 THEN 1 ELSE 0 END) AS preciseSum,", - " SUM(CASE WHEN p.knowledgeType = 1 THEN 1 ELSE 0 END) AS blurSum", - "FROM evaluator_knowledge_point e", + " SUM(CASE WHEN p.knowledge_type = 0 THEN 1 ELSE 0 END) AS preciseSum,", + " SUM(CASE WHEN p.knowledge_type = 1 THEN 1 ELSE 0 END) AS blurSum", + "FROM evaluator_information e", "INNER JOIN evaluator_knowledge_point p ON p.information_id = e.id", "WHERE e.sub_line_id = #{subLineId}" }) diff --git a/src/main/java/com/project/operation/application/OperationLogApplicationServiceImpl.java b/src/main/java/com/project/operation/application/OperationLogApplicationServiceImpl.java index 6113d6f..26b915a 100644 --- a/src/main/java/com/project/operation/application/OperationLogApplicationServiceImpl.java +++ b/src/main/java/com/project/operation/application/OperationLogApplicationServiceImpl.java @@ -36,7 +36,7 @@ public class OperationLogApplicationServiceImpl implements OperationLogApplicati } @Override - @Async("operationLogExecutor") + @Async("asycExecutor") public void saveOperationLogAsync(OperationLogDTO operationLogDTO) { this.saveOperationLog(operationLogDTO); } diff --git a/src/main/java/com/project/operation/config/AsyncConfig.java b/src/main/java/com/project/operation/config/AsyncConfig.java index 39e327c..c4a6332 100644 --- a/src/main/java/com/project/operation/config/AsyncConfig.java +++ b/src/main/java/com/project/operation/config/AsyncConfig.java @@ -16,19 +16,19 @@ import java.util.concurrent.ThreadPoolExecutor; public class AsyncConfig { /** - * 自定义日志异步线程池 + * 自定义异步线程池 */ - @Bean(name = "operationLogExecutor") - public Executor operationLogExecutor() { + @Bean(name = "asycExecutor") + public Executor asycExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); - // 核心线程数（根据业务量调整） - executor.setCorePoolSize(5); + // 核心线程数 + executor.setCorePoolSize(2); // 最大线程数 - executor.setMaxPoolSize(20); + executor.setMaxPoolSize(5); // 队列容量 executor.setQueueCapacity(100); // 线程前缀名（便于日志排查） - executor.setThreadNamePrefix("operation-log-"); + executor.setThreadNamePrefix("asyc-log-"); // 线程空闲超时时间 executor.setKeepAliveSeconds(60); // 拒绝策略：队列满时由调用线程执行（避免日志丢失） @@ -37,27 +37,4 @@ public class AsyncConfig { executor.initialize(); return executor; } - - /** - * 自定义日志异步线程池 - */ - @Bean(name = "dingNoticeExecutor") - public Executor dingNoticeExecutor() { - ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); - // 核心线程数（根据业务量调整） - executor.setCorePoolSize(5); - // 最大线程数 - executor.setMaxPoolSize(20); - // 队列容量 - executor.setQueueCapacity(100); - // 线程前缀名（便于日志排查） - executor.setThreadNamePrefix("ding-notice-"); - // 线程空闲超时时间 - executor.setKeepAliveSeconds(60); - // 拒绝策略：队列满时由调用线程执行 - executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); - // 初始化线程池 - executor.initialize(); - return executor; - } }