feat(chat): 集成 FastGPT 聊天模型- 在 ChatModeType 枚举中添加 FASTGPT 选项- 新增 FastGPT 相关的实体类和请求响应类

- 实现 FastGPT聊天服务接口
- 添加 FastGPT SSE 事件监听器

ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/enums/ChatModeType.java

@@ -17,7 +17,9 @@ public enum ChatModeType {
 
     VECTOR("vector", "知识库向量模型"),
 
-    IMAGE("image", "图片识别模型");
+    IMAGE("image", "图片识别模型"),
+
+    FASTGPT("fastgpt", "FASTGPT");
 
     private final String code;
     private final String description;

ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/listener/FastGPTSSEEventSourceListener.java

@@ -0,0 +1,70 @@
+package org.ruoyi.chat.listener;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.Response;
+import okhttp3.ResponseBody;
+import okhttp3.sse.EventSource;
+import okhttp3.sse.EventSourceListener;
+import org.jetbrains.annotations.NotNull;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import java.util.Objects;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class FastGPTSSEEventSourceListener extends EventSourceListener {
+
+    private SseEmitter emitter;
+
+    @Autowired(required = false)
+    public FastGPTSSEEventSourceListener(SseEmitter emitter) {
+        this.emitter = emitter;
+    }
+
+    @Override
+    public void onOpen(EventSource eventSource, Response response) {
+        log.info("FastGPT  sse连接成功");
+    }
+
+    @Override
+    public void onEvent(@NotNull EventSource eventSource, String id, String type, @NotNull String data) {
+        try {
+            log.debug("事件类型为: {}", type);
+            log.debug("事件数据为: {}", data);
+            if ("flowResponses".equals(type)){
+                emitter.send(data);
+                emitter.complete();
+            } else {
+                emitter.send(data);
+            }
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
+    @Override
+    public void onClosed(EventSource eventSource) {
+        log.info("FastGPT  sse连接关闭");
+    }
+
+    @Override
+    @SneakyThrows
+    public void onFailure(EventSource eventSource, Throwable t, Response response) {
+        if (Objects.isNull(response)) {
+            return;
+        }
+        ResponseBody body = response.body();
+        if (Objects.nonNull(body)) {
+            log.error("FastGPT  sse连接异常data：{}，异常：{}", body.string(), t);
+        } else {
+            log.error("FastGPT sse连接异常data：{}，异常：{}", response, t);
+        }
+        eventSource.cancel();
+    }
+}

ruoyi-modules/ruoyi-chat/src/main/java/org/ruoyi/chat/service/chat/impl/FastGPTServiceImpl.java

@@ -0,0 +1,52 @@
+package org.ruoyi.chat.service.chat.impl;
+
+import org.ruoyi.chat.config.ChatConfig;
+import org.ruoyi.chat.enums.ChatModeType;
+import org.ruoyi.chat.listener.FastGPTSSEEventSourceListener;
+import org.ruoyi.chat.service.chat.IChatService;
+import org.ruoyi.common.chat.entity.chat.FastGPTChatCompletion;
+import org.ruoyi.common.chat.entity.chat.Message;
+import org.ruoyi.common.chat.openai.OpenAiStreamClient;
+import org.ruoyi.common.chat.request.ChatRequest;
+import org.ruoyi.domain.vo.ChatModelVo;
+import org.ruoyi.service.IChatModelService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
+
+import java.util.List;
+
+/**
+ * FastGpt 聊天管理
+ * 项目整体沿用Openai接口范式，根据FastGPT文档增加相应的参数
+ *
+ * @author yzm
+ */
+@Service
+public class FastGPTServiceImpl implements IChatService {
+
+    @Autowired
+    private IChatModelService chatModelService;
+
+    @Override
+    public SseEmitter chat(ChatRequest chatRequest, SseEmitter emitter) {
+        ChatModelVo chatModelVo = chatModelService.selectModelByName(chatRequest.getModel());
+        OpenAiStreamClient openAiStreamClient = ChatConfig.createOpenAiStreamClient(chatModelVo.getApiHost(), chatModelVo.getApiKey());
+        List<Message> messages = chatRequest.getMessages();
+        FastGPTSSEEventSourceListener listener = new FastGPTSSEEventSourceListener(emitter);
+        FastGPTChatCompletion completion = FastGPTChatCompletion
+                .builder()
+                .messages(messages)
+                // 开启后sse会返回event值
+                .detail(true)
+                .stream(true)
+                .build();
+        openAiStreamClient.streamChatCompletion(completion, listener);
+        return emitter;
+    }
+
+    @Override
+    public String getCategory() {
+        return ChatModeType.FASTGPT.getCode();
+    }
+}