From 2166c1a14f9629aa49a5f3bb849ce878df4c4892 Mon Sep 17 00:00:00 2001
From: yangbin <yangbin@qq.com>
Date: 星期三, 28 八月 2024 17:23:25 +0800
Subject: [PATCH] 2
---
lxzn-module-ai/src/main/java/org/jeecg/modules/ai/service/imp/WebSocketAiService.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/lxzn-module-ai/src/main/java/org/jeecg/modules/ai/service/imp/WebSocketAiService.java b/lxzn-module-ai/src/main/java/org/jeecg/modules/ai/service/imp/WebSocketAiService.java
new file mode 100644
index 0000000..f9629a9
--- /dev/null
+++ b/lxzn-module-ai/src/main/java/org/jeecg/modules/ai/service/imp/WebSocketAiService.java
@@ -0,0 +1,28 @@
+package org.jeecg.modules.ai.service.imp;
+
+import org.jeecg.modules.ai.service.IWebSocketAiService;
+import org.jeecg.modules.ai.websocket.AiWebSocket;
+import org.jeecg.modules.utils.AiTestUils;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author clown
+ * * @date 2024/8/8
+ */
+@Service
+public class WebSocketAiService implements IWebSocketAiService {
+
+
+ @Override
+ /*@Scheduled(cron = "0/10 * * * * ?")*/
+ public void selectChatIA() {
+ String name = "{\"id\":\"683a65fd-8feb-4446-ad32-714c4785f667\",\"messages\":[{\"role\":\"user\",\"content\":\"缁欐垜璁蹭釜鏁呬簨锛焅"}],\"stream\":true,\"max_tokens\":500}"; // JSON鏁版嵁
+ String url = "https://836u458t54.vicp.fun/chat/test_chat";
+ String aiPost = AiTestUils.sendJsonToHttpsPost(url, name);
+ /*System.out.println(aiPost);*/
+ for (String s : AiWebSocket.getSessionPoolAi().keySet()) {
+ AiWebSocket.pushMessage(s,aiPost);
+ }
+ }
+}
--
Gitblit v1.9.3