From 007ee7bc1b63aa381b3a414952bbf41aeebed60e Mon Sep 17 00:00:00 2001
From: Administrator <XS@163.COM>
Date: 星期一, 27 四月 2026 16:32:19 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/ai/service/PythonService.java | 60 ++++++++++++++++++++++++++++++------------------------------
1 files changed, 30 insertions(+), 30 deletions(-)
diff --git a/src/main/java/com/zy/ai/service/PythonService.java b/src/main/java/com/zy/ai/service/PythonService.java
index adc712b..82b77a9 100644
--- a/src/main/java/com/zy/ai/service/PythonService.java
+++ b/src/main/java/com/zy/ai/service/PythonService.java
@@ -12,36 +12,36 @@
@Autowired
private LlmChatService llmChatService;
- public boolean runPython(String prompt, String chatId, SseEmitter emitter) {
- try {
- llmChatService.chatStreamRunPython(prompt, chatId, s -> {
- try {
- String safe = s == null ? "" : s.replace("\r", "").replace("\n", "\\n");
- if (!safe.isEmpty()) {
- sse(emitter, safe);
- }
- } catch (Exception ignore) {
- }
- }, () -> {
- try {
- sse(emitter, "\\n\\n銆怉I銆戣繍琛屽凡鍋滄锛堟甯哥粨鏉燂級\\n\\n");
- log.info("AI MCP diagnose stopped: final end");
- emitter.complete();
- } catch (Exception ignore) {
- }
- }, e -> {
- sse(emitter, "\\n\\n銆怉I銆戝垎鏋愬嚭閿欙紝姝ｅ湪鍥為��...\\n\\n");
- });
- return true;
- } catch (Exception e) {
- try {
- sse(emitter, "\\n\\n銆怉I銆戣繍琛屽凡鍋滄锛堝紓甯革級\\n\\n");
- log.error("AI MCP diagnose stopped: error", e);
- emitter.completeWithError(e);
- } catch (Exception ignore) {}
- return true;
- }
- }
+// public boolean runPython(String prompt, String chatId, SseEmitter emitter) {
+// try {
+// llmChatService.chatStreamRunPython(prompt, chatId, s -> {
+// try {
+// String safe = s == null ? "" : s.replace("\r", "").replace("\n", "\\n");
+// if (!safe.isEmpty()) {
+// sse(emitter, safe);
+// }
+// } catch (Exception ignore) {
+// }
+// }, () -> {
+// try {
+// sse(emitter, "\\n\\n銆怉I銆戣繍琛屽凡鍋滄锛堟甯哥粨鏉燂級\\n\\n");
+// log.info("AI MCP diagnose stopped: final end");
+// emitter.complete();
+// } catch (Exception ignore) {
+// }
+// }, e -> {
+// sse(emitter, "\\n\\n銆怉I銆戝垎鏋愬嚭閿欙紝姝ｅ湪鍥為��...\\n\\n");
+// });
+// return true;
+// } catch (Exception e) {
+// try {
+// sse(emitter, "\\n\\n銆怉I銆戣繍琛屽凡鍋滄锛堝紓甯革級\\n\\n");
+// log.error("AI MCP diagnose stopped: error", e);
+// emitter.completeWithError(e);
+// } catch (Exception ignore) {}
+// return true;
+// }
+// }
private void sse(SseEmitter emitter, String data) {
if (data == null) return;
--
Gitblit v1.9.1