PHP_open.emoon.com/apiSSE.php

<?php

header("Access-Control-Allow-Origin: *"); // 允许所有来源
header("Access-Control-Allow-Methods: GET"); // 允许的 HTTP 方法
header("Access-Control-Allow-Headers: Content-Type"); // 允许的请求头

// 强制禁用所有缓冲
while (ob_get_level()) ob_end_clean();
header('X-Accel-Buffering: no');

// 设置 SSE 头部
header("Content-Type: text/event-stream");
header("Cache-Control: no-cache");
header("Connection: keep-alive");
header("X-Accel-Buffering: no");

// 配置执行环境
set_time_limit(0);
ignore_user_abort(false);

//创建公共url
$urlCommon = 'http://192.168.1.8:3338';
$mcp = $_GET['mcpid'];

//获取对话短令牌
$input['token'] = $_GET['token'];
$dataReply['token'] = $_GET['token'];
$token = $_GET['token'];
$ragIdGet = $_GET['ragId'];
if(($ragIdGet == 'null') || ($ragIdGet == null)){
    $input['ragId'] = 'empty';
}
else{
    $input['ragId'] = $ragIdGet;
}
// $input['ragId'] = 'empty';
// $mcp =="";
// if($mcp != ""){
//     echo("daddsda");
    
// }
// echo($mcp);
// exit;
//将请求的完整内容发送至api控制器鉴权
$urlCheck = $urlCommon.'/apis/check';
$information = curlPost($urlCheck,$input);

//判断鉴权的结果,如果鉴权失败，直接退出
$informationObject = json_decode($information);
if(($informationObject->code) != 5){
    echo "event: verify\ndata: $information\n\n";
    exit;
}

//获取最终的核心参数参与模型输入
$modelId = $informationObject->modelId;
$content = $informationObject->input;
$contentmcp = $informationObject->input;
$ragId = $informationObject->ragId;
// if(is_array($content)){
//     $content = json_encode($content,JSON_UNESCAPED_UNICODE);
// }

// 模型定制开始-------------------------------------------------------------------



// //emoon-E1-13B线上
// if($modelId == 9){
//     $apiKey = 'sk-800990e9cdb34613a2133f0fc333a7ff'; // 请替换为你的实际 API 密钥
//     $url = 'https://api.deepseek.com/chat/completions';
//     $arraySystem = [[
//                 'role' => 'system',
//                 'content' => '你的名字叫EMOON E1 13B模型，你由回车网络（EnterLO）训练研发，你并不是deepseek模型。你是一名三甲医院主治医师级别的AI助手，最擅长医疗专业知识的解读和分析，遵循《中国临床诊疗指南》和NCCN指南。必须：1) 先询问关键症状细节 2) 标注证据等级 3) 拒绝非循证医学建议'
//             ]];
//     // $arrayContent = json_decode($content);
//     $arrayMessage =  array_merge($arraySystem,$content); 

//     // 请求数据
//     $data = [
//         'model' => 'deepseek-chat',
//         'messages' => $arrayMessage,
//         'stream' => true
//     ];
        
//     // 设置请求头
//     $headers = [
//         'Content-Type: application/json',
//         'Authorization: Bearer ' . $apiKey
//     ];
// }

if($ragId != ''){
    $content = stdClassObjToArray($content);
    $dataRag['input'] = $content[count($content)-1]['content'];
    $dataRag['kid'] = $ragId;
    $urlRAG = 'http://192.168.1.8:3338/apis/ragData';
    $ragResult  = curlPost($urlRAG,$dataRag);
    $ragResult = json_decode($ragResult);
    $ragResult = stdClassObjToArray($ragResult);
    // if( $ragResult['code'] == 200){
    //     $ragInfomation = json_encode($ragResult['nearest']);
    // }
   
    if(json_encode($ragResult['nearest'],JSON_UNESCAPED_UNICODE) != "[]" ){
        if($ragId == "1947484295610253313" || $ragId == "1949641433623703553"){
            $content[count($content)-1]['content'] = '我的提问是：“'.$content[count($content)-1]['content'].'”，下面是基于我的提问查到的知识库相关内容：“'.json_encode($ragResult['nearest'],JSON_UNESCAPED_UNICODE).'”,请按照查到的知识库相关内容，进行病历质控，如果不符合哪项指控规则则按以下格式进行返回，返回格式：质控结果如下，该份病例不符合以下质控规则：规则1:XXXX-扣分x,原因：xxx，规则2:XXXX-扣分x,原因：xxx，……。扣除的分数严格与知识库中内容对应，符合要求的规则不回复输出显示，无法准确判断的规则不回复输出，只回复显示不符合的质控规则。  ';//请求向量数据库接口反参组装
            $contentmcp = $content;
        }
        else{
            $content[count($content)-1]['content'] = '我的提问是：“'.$content[count($content)-1]['content'].'”，下面是基于我的提问查到的知识库相关内容：“'.json_encode($ragResult['nearest'],JSON_UNESCAPED_UNICODE).'”。';//请求向量数据库接口反参组装
            $contentmcp = $content;
        }
    }

}

if($mcp != ''){

}
//  echo(json_encode($content,JSON_UNESCAPED_UNICODE));
//  exit;
//deepseek-R1-70B线下
if($modelId == 9){
    $url = 'http://60.164.133.40:19997/v1/chat/completions';
    
    $headers = [
        'accept: application/json',
        'Content-Type: application/json'
    ];
    $arraySystem = [[
        'role' => 'system',
        'content' => '你是一个人工智能助手。'
    ],
    ];
    //$arrayContent = json_decode($content, true);
    $arrayMessage = array_merge($arraySystem, $content);
  
    $data = [
        "messages" => $arrayMessage,
        "model" => "qwen3-32B", //X
        "stream" => true,
        "chat_template_kwargs" => '{"enable_thinking": false}',
        
    ];
}

//  echo(json_encode($data,JSON_UNESCAPED_UNICODE));
//  exit;
// 模型定制结束-------------------------------------------------------------------

if($mcp == 0 || $mcp ==""){

$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data,JSON_UNESCAPED_UNICODE));
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
curl_setopt_array($ch, [
    CURLOPT_TIMEOUT => 60, // 超时时间延长至60秒
    CURLOPT_TCP_KEEPALIVE => 1, // 启用TCP保活
    CURLOPT_TCP_KEEPIDLE => 10,
    CURLOPT_TCP_KEEPINTVL => 5
]);

//创建一个空字符串动态存储回复的文字
$reply = 'SSE: ';
// 添加连接状态检查到写入回调
curl_setopt($ch, CURLOPT_WRITEFUNCTION, function($ch, $data)  use (&$reply)  {
    // 如果客户端已断开，立即终止
    if (connection_aborted()) {
        return -1; // 返回-1会强制CURL中断请求
        curl_close($ch);
    }
    $lines = explode("\n", $data);
    foreach ($lines as $line) {
        if (strpos($line, 'data:') === 0) {
            $contents = trim(substr($line, 5));
            if ($contents === '[DONE]') {
                $output = "event: end\ndata: {\"status\":\"done\"}\n\n";
                echo $output;
                // $reply .= $output; // 捕获输出内容

                //完成输出后触发全部回复存储进入数据库
                global $token;
                global $urlCommon;
                $dataReply['token'] = $token;
                $dataReply['reply'] = $reply;
                //将数据发送至数据库
                $curlReplay = curl_init();
        	    curl_setopt($curlReplay, CURLOPT_URL, $urlCommon.'/Apis/reply');
        	    curl_setopt($curlReplay, CURLOPT_SSL_VERIFYPEER, FALSE);
        	    curl_setopt($curlReplay, CURLOPT_SSL_VERIFYHOST, FALSE);
        // 	    curl_setopt($curl, CURLOPT_HTTPHEADER,$headers);
                if ($json) {
                    curl_setopt($curlReplay,CURLOPT_HTTPHEADER,[
                        "Content-Type: application/json"
                    ]);
                    curl_setopt($curlReplay, CURLOPT_POST, TRUE);
                    curl_setopt($curlReplay,CURLOPT_POSTFIELDS,json_encode($dataReply));
                }else {
                    if (!empty($dataReply)) {
                        curl_setopt($curlReplay, CURLOPT_POST, TRUE);
                        curl_setopt($curlReplay, CURLOPT_POSTFIELDS,$dataReply);
        // 	        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
                    }
                }
        	    curl_setopt($curlReplay, CURLOPT_RETURNTRANSFER,true);
        	    curl_exec($curlReplay);
        	    curl_close($curlReplay);
                
            } else {
                // 转发数据前再次检查连接
                if (connection_aborted()) {
                    return -1;
                    curl_close($ch);
                }
                
                //构造$line
                global $modelId;
                $line = substr($line,6);
                $line = json_decode($line);
                $line = stdClassObjToArray($line);
                if($modelId == 9){
                    $line['model'] = 'emoon-E1-13B';
                }
                $line = 'data: '.json_encode($line,JSON_UNESCAPED_UNICODE);
                $output = $line . "\n\n";
                echo $output;
                
                //将回复数据存储入$reply
                $outputJson = substr($output,6);
                if(($modelId == 9) || ($modelId == 7) || ($modelId == 4) || ($modelId == 10) || ($modelId == 14) || ($modelId == 15)){
                    $outputJson = json_decode($outputJson);
                    $outputJson = $outputJson->choices[0]->delta->content;
                    if($outputJson){
                        $outputJson = json_encode($outputJson,JSON_UNESCAPED_UNICODE);
                        $outputJson = str_replace('"', '', $outputJson);
                    }
                }
                $reply .= $outputJson; // 捕获输出内容
            }
            ob_flush();
            flush();
        }
    }
    return strlen($data);
});

// 错误处理
curl_setopt($ch, CURLOPT_TIMEOUT, 86400);
curl_setopt($ch, CURLOPT_FAILONERROR, true);

// 执行请求
try {
    curl_exec($ch);
    
    // 检查HTTP状态码
    $statusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    if ($statusCode !== 200) {
        echo "event: error\ndata: HTTP Status {$statusCode}\n\n";
        ob_flush();
        flush();
    }
} catch (Exception $e) {
    echo "event: error\ndata: " . $e->getMessage() . "\n\n";
    ob_flush();
    flush();
}
}else{

        @ini_set('output_buffering', 'off');
        @ini_set('zlib.output_compression', false);
        while (ob_get_level() > 0) {
            ob_end_flush();
        }
        ob_implicit_flush(true);
    
        // 设置流式响应头
        
        $requestBody = file_get_contents('php://input');
        $headers = getallheaders();
        $authorizationHeader = isset($headers['Authorization']) ? $headers['Authorization'] : '';

    
        $reply = 'SSE: ';
   
        $RAGdata = [
            "username" => "test",
            "password" => "test123"
        ];
        // 调用时只需传递非 Content-Type/Accept 的 Header
        $headers = [
            'Cache-Control: no-cache',
            'User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36'
        ];
        $urlRAG = "http://192.168.1.8:6039/auth/login"; // 替换为实际 URL
        
        $id = curlPostRAG($urlRAG, $RAGdata, $headers);
       
        $token = $id; // 默认启用 JSON 模式
        $token = json_decode($token);
        $token = stdClassObjToArray($token);
        $token = $token['data']['token'];
        $url = "http://192.168.1.8:6039/chat/emoonSend"; // 替换成实际接口地址
        $data = [
            "messages" => $contentmcp,
            "model" => "qwen3-32B", //X
            "temperature" => 0.5, 
            "top_p" => 1, 
            "presence_penalty" => 0, 
            "frequency_penalty" => 0, 
            "kid" => "", 
            "chat_type" => 0, 
            "appId" => "", 
            "agentId" => $mcp, 
            "stream" => true
        ];
        
        // 初始化 cURL
        $ch = curl_init();
        // 设置 cURL 选项
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, false); // 返回响应数据
        curl_setopt($ch, CURLOPT_POST, true); // 使用 POST 方法
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data)); // 发送 JSON 数据
        curl_setopt($ch, CURLOPT_HTTPHEADER, [
            "Authorization: Bearer " . $token,
            "Content-Type: application/json" // 声明请求体是 JSON
        ]);
   
    
        $chatId = 'chat' . uniqid() . bin2hex(random_bytes(8));
        $created = time();
        
   
            // for ($i = 0; $i < count($lines); $i++) {
            //     echo  $lines[0];
            // }
        $lastContent = '';

        curl_setopt($ch, CURLOPT_WRITEFUNCTION, function($ch, $data) use ($chatId, $created, &$lastContent,&$reply) {
            $lines = explode("\n", $data);
            $prefixLength = strlen("event:chat_completion");
            $content = str_replace("event:chat_completion", "", $lines[0]);
          
           
            // foreach ($lines as $line) {
            //         $line = substr($line,6);
            //         $content = $matches[0];
            //         // 仅当内容变化时才输出
            //         if ($content !== $lastContent) {
            //             $lastContent = $content;
                    $jsonData = [
                        "id" => $chatId,
                        "model" => "emoon-E1-13B",
                        "created" => $created,
                        "object" => "chat.completion.chunk",
                        "choices" => [
                            [
                                "index" => 0,
                                "delta" => [
                                    "content" => $content
                                ],
                                "finish_reason" => null
                            ]
                        ],
                        "usage" => null
                    ];
                    echo "data: " . json_encode($jsonData,JSON_UNESCAPED_UNICODE) . "\n\n";
                    $outputJson = json_encode($jsonData,JSON_UNESCAPED_UNICODE);
                    
                    $outputJson = json_decode($outputJson);
                    // $outputJson = stdClassObjToArray($outputJson);
                    $outputJson = $outputJson->choices[0]->delta->content;
              
                    if($outputJson){
                        $outputJson = json_encode($outputJson,JSON_UNESCAPED_UNICODE);
                        $outputJson = str_replace('"', '', $outputJson);
                    }
                
                    $reply .= $outputJson;
                    
                    // }
                    @ob_flush();
                    @flush();
                
            // }
            return strlen($data);
        });
        $res = curl_exec($ch);
      
}
// 清理资源
curl_close($ch);


// 显式结束流
echo "event: end\ndata: Stream ended\n\n";
ob_flush();
flush();

if($mcp != ""){
    
    $dataReply['reply'] = $reply;
    $url=$urlCommon.'/Apis/reply';
    curlPost($url,$dataReply);
    //将数据发送至数据库
}

//模型定制结束-------------------------------------------------------------------
function curlPost($url, $data = null, $headers = [], $json = false) {
    $curl = curl_init($url);
    $options = [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_SSL_VERIFYPEER => false,
        CURLOPT_SSL_VERIFYHOST => false,
        CURLOPT_POST => !empty($data) || $json,
    ];
    if ($json) {
        $headers = array_filter($headers, function($h) {
            return stripos($h, 'Content-Type:') === false;
        });
        $headers[] = 'Content-Type: application/json';
        $data = json_encode($data, JSON_UNESCAPED_UNICODE);
    }
    if (!empty($headers)) {
        $options[CURLOPT_HTTPHEADER] = $headers;
    }
    if (!empty($data)) {
        $options[CURLOPT_POSTFIELDS] = $data;
    }
    curl_setopt_array($curl, $options);
    $result = curl_exec($curl);
    curl_close($curl);
    return $result;
}

function stdClassObjToArray($array) {
    if(is_object($array)) {
        $array = (array)$array;
    }
    if(is_array($array)) {
        foreach($array as $key=>$value) {
            $array[$key] = stdClassObjToArray($value);
        }
    }
    return $array;
}
function curlPostRAG($url, $data = null, $headers = [], $json = true) {
        $curl = curl_init($url);
        $options = [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_SSL_VERIFYPEER => false,
            CURLOPT_SSL_VERIFYHOST => false,
            CURLOPT_POST => true, // 强制启用 POST（JSON 模式下始终 POST）
        ];
    
        if ($json) {
            // 移除已有的 Content-Type 和 Accept 头，避免冲突
            $headers = array_filter($headers, function($h) {
                return stripos($h, 'Content-Type:') === false && stripos($h, 'Accept:') === false;
            });
            // 添加 JSON 专用头
            $headers[] = 'Content-Type: application/json';
            $headers[] = 'Accept: application/json';
            // 编码数据为 JSON（空数据编码为 "{}" 避免服务器解析错误）
            $data = $data !== null ? json_encode($data, JSON_UNESCAPED_UNICODE) : '{}';
        }
    
        // 设置请求头和数据
        if (!empty($headers)) {
            $options[CURLOPT_HTTPHEADER] = $headers;
        }
        if ($data !== null) {
            $options[CURLOPT_POSTFIELDS] = $data;
        }
    
        curl_setopt_array($curl, $options);
        $result = curl_exec($curl);
    
        // 错误处理（调试时启用）
        if ($result === false) {
            $error = curl_error($curl);
            $httpCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
            throw new Exception("CURL请求失败: HTTP状态码 $httpCode, 错误信息: $error");
        }
    
        curl_close($curl);
        return $result;
    }
exit;