合并分支 'lyh-server' 到 'master'

Lyh server



查看合并请求 !1711

@@ -68,13 +68,12 @@ class ChatLogic extends BaseLogic
         header('Connection: keep-alive');
         header('Connection: keep-alive');
         $aiResponse = '';
         $aiResponse = '';
         while (!$stream->eof()) {
         while (!$stream->eof()) {
-            $chunk = $stream->read(1);
+            $chunk = $stream->read(1024);
             $chunk = str_replace(chr(1), '', $chunk);
             $chunk = str_replace(chr(1), '', $chunk);
             if ($chunk !== false) {
             if ($chunk !== false) {
-                $chunk = json_decode($chunk,true);
-                $aiResponse .= $chunk['text']; // 累积完整的 AI 回复
+                $aiResponse .= $chunk; // 累积完整的 AI 回复
                 // 使用 en_sse_data 格式化流数据
                 // 使用 en_sse_data 格式化流数据
-                echo $gptService->en_sse_data(trim($chunk['text']));
+                echo $gptService->en_sse_data(trim($chunk));
                 ob_flush();
                 ob_flush();
                 flush();
                 flush();
             }
             }
@@ -87,6 +86,31 @@ class ChatLogic extends BaseLogic
     }
     }
 
 
     /**
     /**
+     * @remark :获取一行数据
+     * @name   :getStreamContentLine
+     * @author :lyh
+     * @method :post
+     * @time   :2025/4/2 22:42
+     */
+    public function getStreamContentLine($stream){
+        $text = '';
+        while (!$stream->eof()){
+            // 读取一个字符串
+            $t = $this->stream->read(1);
+            $this->body .= $t;
+            if($t === "\n"){
+                break;
+            }
+            // 结束了
+            if(ord($t)==1){
+                break;
+            }
+            $text .= $t;
+        }
+        return $text;
+    }
+
+    /**
      * @remark :创建一条新会话
      * @remark :创建一条新会话
      * @name   :saveChat
      * @name   :saveChat
      * @author :lyh
      * @author :lyh