Release/v1.0.0第一个正式版本

.github/workflows/depoly.yml

@@ -58,14 +58,17 @@ jobs:
           script: |
             set -e
             cd ./refine
+            
             echo "pulling latest code..."
-            git pull
-            git checkout develop
+            git fetch --all
+            BRANCH_NAME="${{ github.ref_name }}"
+            echo "Detected branch: $BRANCH_NAME"
+            git checkout $BRANCH_NAME
+            git pull origin $BRANCH_NAME
             echo "pull completed."
+            
             echo "Deploying..."
-            sh build.sh stop
-            sh build.sh rm && sh build.sh rmi
+            echo "Pulling latest Docker image..."
+            docker pull docker.cnb.cool/hamster-yhz/refine:latest
             sh build.sh base && sh build.sh services
             echo "Deployment completed."
-
-

README.md

@@ -5,4 +5,5 @@ AchoBeta Refine 琢玉系统-2025年-J组-复试项目
 一个面向学生的AI学习助手项目后端，通过上传错题，系统自动识题目内容、分错误原因、讲解知识点并生成个性化练习，帮助学生快速查漏补缺
 
 > 快速了解项目结构 请阅读: `docs/PROJECT_GUIDE.md`
+>
 > 快速了解贡献指南 请阅读: `docs/CONTRIBUTING_GUIDE.md`

docs/dev-ops/docker-compose-app.yml

@@ -6,6 +6,7 @@ services:
   refine:
     image: docker.cnb.cool/hamster-yhz/refine:latest
     container_name: refine
+    pull_policy: always
     restart: on-failure
     ports:
       - "8091:8091"

pom.xml

@@ -46,7 +46,8 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.source>21</maven.compiler.source>
         <maven.compiler.target>21</maven.compiler.target>
-        <langchain4j.version>1.1.0-beta7</langchain4j.version>
+        <langchain4j.version>1.6.0-beta12</langchain4j.version>
+        <jackson.version>2.19.0</jackson.version>
     </properties>
 
     <licenses>
@@ -64,11 +65,11 @@
 
     <dependencyManagement>
         <dependencies>
-            <dependency>
-                <groupId>dev.langchain4j</groupId>
-                <artifactId>langchain4j-core</artifactId>
-                <version>1.1.0</version>
-            </dependency>
+<!--            <dependency>-->
+<!--                <groupId>dev.langchain4j</groupId>-->
+<!--                <artifactId>langchain4j-core</artifactId>-->
+<!--                <version>1.1.0</version>-->
+<!--            </dependency>-->
             <!-- PostgreSQL驱动 -->
             <dependency>
                 <groupId>org.postgresql</groupId>
@@ -85,7 +86,7 @@
             <dependency>
                 <groupId>dev.langchain4j</groupId>
                 <artifactId>langchain4j-embeddings-all-minilm-l6-v2</artifactId>
-                <version>1.1.0-beta6</version>
+                <version>1.0.1-beta6</version>
             </dependency>
             <!-- 使用OpenAI的嵌入模型 -->
             <dependency>
@@ -97,7 +98,12 @@
             <dependency>
                 <groupId>com.fasterxml.jackson.core</groupId>
                 <artifactId>jackson-databind</artifactId>
-                <version>2.19.0</version>
+                <version>${jackson.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.fasterxml.jackson.core</groupId>
+                <artifactId>jackson-annotations</artifactId>
+                <version>${jackson.version}</version>
             </dependency>
             <!-- spring ai alibaba -->
             <dependency>
@@ -202,11 +208,6 @@
                 <artifactId>java-jwt</artifactId>
                 <version>4.4.0</version>
             </dependency>
-            <dependency>
-                <groupId>commons-codec</groupId>
-                <artifactId>commons-codec</artifactId>
-                <version>1.15</version>
-            </dependency>
             <dependency>
                 <groupId>org.projectlombok</groupId>
                 <artifactId>lombok</artifactId>
@@ -227,7 +228,7 @@
             <dependency>
                 <groupId>dev.langchain4j</groupId>
                 <artifactId>langchain4j</artifactId>
-                <version>1.1.0</version>
+                <version>1.6.0</version>
             </dependency>
             <dependency>
                 <groupId>dev.langchain4j</groupId>

refine-api/src/main/java/com/achobeta/api/dto/AiSolveRequestDTO.java

@@ -1,22 +1,30 @@
 package com.achobeta.api.dto;
 
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
+import lombok.AllArgsConstructor;
 import lombok.Builder;
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 import java.io.Serializable;
 
 /**
  * @Auth : Malog
- * @Desc :
+ * @Desc : AI解题请求DTO
  * @Time : 2025/11/7 11:17
  */
 @Data
 @Builder
+@NoArgsConstructor
+@AllArgsConstructor
 public class AiSolveRequestDTO implements Serializable {
 
     /**
      * 问题内容
      */
-    private String questionContext;
+    @NotBlank(message = "问题内容不能为空")
+    @Size(max = 10000, message = "问题内容长度不能超过10000字符")
+    private String question;
 
 }

refine-api/src/main/java/com/achobeta/api/dto/KeyPointsDTO.java

@@ -11,7 +11,7 @@ public class KeyPointsDTO {
     /**
      * 知识点id
      */
-    private int id;
+    private String id;
     /**
      * 知识点内容
      */

refine-api/src/main/java/com/achobeta/api/dto/MistakeReasonToggleRequestDTO.java

@@ -0,0 +1,32 @@
+package com.achobeta.api.dto;
+
+import com.achobeta.types.annotation.FieldDesc;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import jakarta.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Auth : Malog
+ * @Desc : 简化错因切换请求DTO
+ * @Time : 2025/11/10
+ */
+@Getter
+@Setter
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class MistakeReasonToggleRequestDTO implements Serializable {
+
+    @NotBlank(message = "题目ID不能为空")
+    @FieldDesc(name = "题目ID")
+    private String questionId;
+
+    @NotBlank(message = "错因参数名不能为空")
+    @FieldDesc(name = "错因参数名")
+    private String reasonName;
+}

refine-api/src/main/java/com/achobeta/api/dto/StudyNoteRequestDTO.java

@@ -14,12 +14,6 @@
 @Data
 public class StudyNoteRequestDTO implements Serializable {
 
-    /**
-     * 用户ID
-     */
-    @NotBlank(message = "用户ID不能为空")
-    private String userId;
-
     /**
      * 题目ID
      */

refine-api/src/main/java/com/achobeta/api/dto/UpdateOtherReasonRequestDTO.java

@@ -0,0 +1,32 @@
+package com.achobeta.api.dto;
+
+import com.achobeta.types.annotation.FieldDesc;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+import jakarta.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Auth : Malog
+ * @Desc : 更新其他原因文本请求DTO
+ * @Time : 2025/11/10
+ */
+@Getter
+@Setter
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class UpdateOtherReasonRequestDTO implements Serializable {
+
+    @NotBlank(message = "题目ID不能为空")
+    @FieldDesc(name = "题目ID")
+    private String questionId;
+
+    @NotBlank(message = "其他原因描述不能为空")
+    @FieldDesc(name = "其他原因描述")
+    private String otherReasonText;
+}

refine-app/src/main/java/com/achobeta/aop/GlobalOperationAspect.java

@@ -43,10 +43,10 @@ public void interceptorDo(JoinPoint point) {
             checkLogin();
         } catch (UnauthorizedException e) {
             log.error("登录验证失败：{}", e.getMessage());
-            throw new AppException(e.getCode(),e.getMessage());
+            throw new AppException(e.getCode(), e.getMessage());
         } catch (AppException e) {
             log.error("全局拦截异常", e);
-            throw new AppException(e.getMessage());
+            throw new AppException(e.getCode(), e.getMessage());
         } catch (Throwable e) {
             log.error("全局拦截异常", e);
             throw new AppException(GlobalServiceStatusCode.PARAM_FAILED_VALIDATE);
@@ -74,7 +74,7 @@ private void checkLogin() {
         // 从请求头获取token
         String token = request.getHeader("access-token");
         if (StringTools.isEmpty(token)) {
-            throw new AppException(GlobalServiceStatusCode.UNAUTHORIZED); // token为空，未登录
+            throw new AppException(401, "token为空"); // token为空，未登录
         }
 
         // 先JWT技术验证，验签名、过期时间

refine-app/src/main/java/com/achobeta/config/AiThreadPoolConfig.java

@@ -1,48 +1,71 @@
 package com.achobeta.config;
 
+import lombok.extern.slf4j.Slf4j;
 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.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
+/**
+ * AI 专属线程池配置（用于 AI 流式调用、API 请求等业务逻辑）
+ * 核心优化：配置容错、参数合理性校验、资源占用控制、生产环境监控
+ */
 @Configuration
+@Slf4j
 public class AiThreadPoolConfig {
 
-    // 最大并发数
-    @Value("${ai.dashscope.max-concurrency}")
+    /**
+     * AI 最大并发数（从配置文件读取，默认值 10，避免配置缺失导致启动失败）
+     * 用途：限制 AI 调用的最大并发量，避免触发第三方 API（如 DashScope）限流
+     */
+    @Value("${ai.dashscope.max-concurrency:10}")
     private int aiMaxConcurrency;
 
-    @Bean
+    /**
+     * AI 专属线程池（业务层面：执行 AI 流式调用、模型推理等耗时操作）
+     */
+    @Bean(name = "aiExclusiveThreadPool") // 明确 bean 名称，避免注入冲突
     public ThreadPoolTaskExecutor aiExclusiveThreadPool() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        // 1. 基础参数计算（CPU 核心数）
         int cpuCore = Runtime.getRuntime().availableProcessors();
+        log.info("系统 CPU 核心数：{}，配置的 AI 最大并发数：{}", cpuCore, aiMaxConcurrency);
 
-        int baseCoreSize = cpuCore * 2 + 1;
+        // 2. 配置容错校验（避免无效配置）
+        if (aiMaxConcurrency < 1) {
+            log.warn("AI 最大并发数配置无效（{}），使用默认值 10", aiMaxConcurrency);
+            aiMaxConcurrency = 10;
+        }
 
-        int corePoolSize = Math.max(baseCoreSize, aiMaxConcurrency);
+        // 3. 线程池参数优化（核心逻辑）
+        // 核心线程数：取「CPU核心数*2 +1」和「AI最大并发数的1/2」的较小值（避免空闲线程浪费）
+        int corePoolSize = Math.min(cpuCore * 2 + 1, aiMaxConcurrency / 2);
+        // 最大线程数：不超过配置的 AI 最大并发数（避免超预期并发导致限流/资源耗尽）
+        int maxPoolSize = Math.min(cpuCore * 4 + 1, aiMaxConcurrency);
+        // 队列容量：核心线程数*3（上限 50），平衡缓冲和内存占用（避免队列过大导致任务堆积）
+        int queueCapacity = Math.min(corePoolSize * 3, 50);
 
+        // 4. 初始化线程池
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(corePoolSize);
+        executor.setMaxPoolSize(maxPoolSize);
+        executor.setQueueCapacity(queueCapacity);
+        executor.setKeepAliveSeconds(120); // 空闲线程存活时间（120秒，适配 AI 长耗时调用）
+        executor.setThreadNamePrefix("ai-exclusive-thread-"); // 线程名前缀（日志排查）
+        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); // 拒绝策略
 
-        // 最大线程数：从配置文件读取，确保不超过系统承受能力
-        // 若配置值小于核心线程数，则强制使用核心线程数作为上限
-        executor.setMaxPoolSize(corePoolSize * 2);
-
-        // 设置缓冲队列大小，避免任务瞬间涌入导致OOM
-        executor.setQueueCapacity(corePoolSize * 5);
+        // 5. 线程池销毁时的优雅关闭（等待任务执行完成，避免任务丢失）
+        executor.setWaitForTasksToCompleteOnShutdown(true);
+        executor.setAwaitTerminationSeconds(30); // 等待 30 秒后强制关闭（适配 AI 长耗时任务）
+        executor.setAwaitTerminationMillis(30 * 1000L); // 兼容低版本 Spring（可选）
 
-        // 超过核心线程数的线程，空闲120秒后销毁，
-        executor.setKeepAliveSeconds(120);
+        // 6. 初始化并打印配置（生产环境监控关键）
+        executor.initialize();
+        log.info("AI 专属线程池初始化完成：核心线程数={}，最大线程数={}，队列容量={}，拒绝策略={}",
+                corePoolSize, maxPoolSize, queueCapacity, executor.getThreadPoolExecutor().getRejectedExecutionHandler().getClass().getSimpleName());
 
-        // 线程名称前缀，便于日志排查
-        executor.setThreadNamePrefix("ai-exclusive-thread-");
-
-        // 当线程池和队列都满时，让提交任务的线程自己执行，避免任务丢失
-        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
-
-        executor.initialize();//初始化
         return executor;
     }
-
-}
+}

refine-app/src/main/java/com/achobeta/config/ChatModelListenerConfig.java

@@ -28,7 +28,7 @@ public void onResponse(ChatModelResponseContext responseContext) {
 
             @Override
             public void onError(ChatModelErrorContext errorContext) {
-                log.info("onError(): {}", errorContext.error().getMessage());
+                log.warn("onError(): {}", errorContext.error().getMessage());
             }
         };
     }