上传备份

src/main/java/xyz/wbsite/achat/OpenAiController.java

@@ -9,8 +9,8 @@ import org.springframework.web.bind.annotation.RestController;
 import xyz.wbsite.achat.core.chat.ChatCompletionRequest;
 import xyz.wbsite.achat.core.chat.CompletionRequest;
 import xyz.wbsite.achat.core.chat.CompletionResponse;
-import xyz.wbsite.achat.core.chat.EmbeddingsRequest;
+import xyz.wbsite.achat.core.embed.EmbeddingsRequest;
-import xyz.wbsite.achat.core.chat.EmbeddingsResponse;
+import xyz.wbsite.achat.core.embed.EmbeddingsResponse;
 import xyz.wbsite.achat.core.model.ModelListResponse;
 import xyz.wbsite.achat.core.chat.ChatService;
 

src/main/java/xyz/wbsite/achat/config/ChatConfig.java

@@ -5,6 +5,8 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 import xyz.wbsite.achat.core.chat.ChatService;
 import xyz.wbsite.achat.core.chat.ChatServiceSampleImpl;
+import xyz.wbsite.achat.core.session.SessionService;
+import xyz.wbsite.achat.core.session.SessionServiceMemoryImpl;
 
 /**
  * 对话配置
@@ -20,4 +22,9 @@ public class ChatConfig implements WebMvcConfigurer {
     public ChatService chatService() {
         return new ChatServiceSampleImpl();
     }
+
+    @Bean
+    public SessionService sessionService() {
+        return new SessionServiceMemoryImpl();
+    }
 }

src/main/java/xyz/wbsite/achat/config/ThreadConfig.java

@@ -16,7 +16,7 @@ import java.util.concurrent.ThreadPoolExecutor;
  * @since 1.8
  */
 @Configuration
-public class ThreadPoolConfig {
+public class ThreadConfig {
 
     // 获取CPU核心数
     private final int cpuCount = Runtime.getRuntime().availableProcessors();

src/main/java/xyz/wbsite/achat/config/WebConfig.java

@@ -12,7 +12,7 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
  * @since 1.8
  */
 @Configuration
-public class WebMvcConfig implements WebMvcConfigurer {
+public class WebConfig implements WebMvcConfigurer {
 
     /**
      * 跨域配置

src/main/java/xyz/wbsite/achat/core/chat/ChatService.java

@@ -1,13 +1,8 @@
 package xyz.wbsite.achat.core.chat;
 
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
-import xyz.wbsite.achat.core.chat.ChatCompletionRequest;
+import xyz.wbsite.achat.core.embed.EmbeddingsRequest;
-import xyz.wbsite.achat.core.chat.ChatCompletionResponse;
+import xyz.wbsite.achat.core.embed.EmbeddingsResponse;
-import xyz.wbsite.achat.core.chat.CompletionRequest;
-import xyz.wbsite.achat.core.chat.CompletionResponse;
-import xyz.wbsite.achat.core.chat.EmbeddingsRequest;
-import xyz.wbsite.achat.core.chat.EmbeddingsResponse;
-import xyz.wbsite.achat.core.chat.StreamEmitter;
 
 public interface ChatService {
 

src/main/java/xyz/wbsite/achat/core/chat/ChatServiceSampleImpl.java

@@ -2,16 +2,8 @@ package xyz.wbsite.achat.core.chat;
 
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
-import xyz.wbsite.achat.core.chat.ChatCompletionRequest;
+import xyz.wbsite.achat.core.embed.EmbeddingsRequest;
-import xyz.wbsite.achat.core.chat.ChatCompletionResponse;
+import xyz.wbsite.achat.core.embed.EmbeddingsResponse;
-import xyz.wbsite.achat.core.chat.CompletionRequest;
-import xyz.wbsite.achat.core.chat.CompletionResponse;
-import xyz.wbsite.achat.core.chat.EmbeddingsRequest;
-import xyz.wbsite.achat.core.chat.EmbeddingsResponse;
-import xyz.wbsite.achat.core.chat.Role;
-import xyz.wbsite.achat.core.chat.StreamEmitter;
-import xyz.wbsite.achat.core.chat.Usage;
-import xyz.wbsite.achat.core.chat.ChatService;
 
 import javax.annotation.Resource;
 import java.util.Collections;

src/main/java/xyz/wbsite/achat/core/embed/EmbeddingsRequest.java

@@ -1,4 +1,4 @@
-package xyz.wbsite.achat.core.chat;
+package xyz.wbsite.achat.core.embed;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -15,18 +15,15 @@ public class EmbeddingsRequest {
     private List<String> input;
     private String user;
 
-    // 无参构造函数
     public EmbeddingsRequest() {
     }
 
-    // 私有构造函数，用于Builder模式
     private EmbeddingsRequest(Builder builder) {
         this.model = builder.model;
         this.input = builder.input;
         this.user = builder.user;
     }
 
-    // 静态builder方法，返回Builder实例
     public static Builder builder() {
         return new Builder();
     }
@@ -55,7 +52,6 @@ public class EmbeddingsRequest {
         this.user = user;
     }
 
-    // Builder内部类
     public static class Builder {
         private String model;
         private List<String> input = new ArrayList<>();
@@ -81,7 +77,6 @@ public class EmbeddingsRequest {
             return this;
         }
 
-        // 构建EmbeddingsRequest对象
         public EmbeddingsRequest build() {
             return new EmbeddingsRequest(this);
         }

src/main/java/xyz/wbsite/achat/core/embed/EmbeddingsResponse.java

@@ -1,4 +1,6 @@
-package xyz.wbsite.achat.core.chat;
+package xyz.wbsite.achat.core.embed;
+
+import xyz.wbsite.achat.core.chat.Usage;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -23,6 +25,7 @@ public class EmbeddingsResponse {
      * 无参构造函数
      */
     public EmbeddingsResponse() {
+
     }
 
     /**

src/main/java/xyz/wbsite/achat/core/session/SessionServiceMemoryImpl.java

@@ -1,7 +1,5 @@
 package xyz.wbsite.achat.core.session;
 
-import org.springframework.stereotype.Service;
-
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
@@ -15,7 +13,6 @@ import java.util.stream.Collectors;
  * @version 0.0.1
  * @since 1.8
  */
-@Service
 public class SessionServiceMemoryImpl implements SessionService {
 
     /**