From 6cfff15c6290c7ec35750faa0962edabe6a87073 Mon Sep 17 00:00:00 2001
From: ZF sun <34314687@qq.com>
Date: Sat, 6 Dec 2025 14:55:10 +0800
Subject: [PATCH] =?UTF-8?q?fix(addon/aikefu):=20=E4=BD=BF=E7=94=A8curl?=
 =?UTF-8?q?=E6=9D=A5=E5=8F=91=E9=80=81=E8=AF=B7=E6=B1=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/addon/aikefu/api/controller/Kefu.php | 61 ++++++++++++++++++++++--
 1 file changed, 56 insertions(+), 5 deletions(-)

diff --git a/src/addon/aikefu/api/controller/Kefu.php b/src/addon/aikefu/api/controller/Kefu.php
index c16a4b30c..26fa47e08 100644
--- a/src/addon/aikefu/api/controller/Kefu.php
+++ b/src/addon/aikefu/api/controller/Kefu.php
@@ -6,10 +6,61 @@ use addon\aikefu\model\Config as KefuConfigModel;
 use addon\aikefu\model\Conversation as KefuConversationModel;
 use addon\aikefu\model\Message as KefuMessageModel;
 use app\api\controller\BaseApi;
-use extend\api\HttpClient;
+
 
 class Kefu extends BaseApi
 {
+    /**
+     * 封装curl请求方法
+     * @param string $url 请求URL
+     * @param string $method 请求方法
+     * @param array $data 请求数据
+     * @param array $headers 请求头
+     * @return string 响应内容
+     */
+    private function curlRequest($url, $method = 'GET', $data = [], $headers = [])
+    {
+        $ch = curl_init();
+        
+        // 设置URL
+        curl_setopt($ch, CURLOPT_URL, $url);
+        
+        // 设置请求方法
+        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
+        
+        // 设置POST数据
+        if ($method === 'POST' && !empty($data)) {
+            curl_setopt($ch, CURLOPT_POSTFIELDS, is_array($data) ? json_encode($data) : $data);
+        }
+        
+        // 设置请求头
+        if (!empty($headers)) {
+            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
+        }
+        
+        // 设置返回值
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
+        
+        // 执行请求
+        $response = curl_exec($ch);
+        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
+        
+        // 关闭连接
+        curl_close($ch);
+        
+        if ($response === false) {
+            throw new \Exception('Curl请求失败');
+        }
+        
+        if ($httpCode >= 400) {
+            throw new \Exception('HTTP请求失败，状态码：' . $httpCode);
+        }
+        
+        return $response;
+    }
     /**
      * 为事件调用初始化属性
      * @param array $data 事件数据
@@ -62,7 +113,7 @@ class Kefu extends BaseApi
                 return $this->response($this->error('智能客服暂未启用'));
             }
 
-            $config = $config_info['data']['value'];
+            $config = $config_info;
             $apiKey = $config['api_key'];
             $baseUrl = $config['base_url'];
             $chatEndpoint = $config['chat_endpoint'];
@@ -88,7 +139,7 @@ class Kefu extends BaseApi
 
             // 发送请求到Dify API
             $url = $baseUrl . $chatEndpoint;
-            $response = HttpClient::http($url, 'POST', json_encode($requestData), $headers);
+            $response = $this->curlRequest($url, 'POST', $requestData, $headers);
 
             // 解析响应
             $result = json_decode($response, true);
@@ -213,7 +264,7 @@ class Kefu extends BaseApi
                 return $this->response($this->error('智能客服暂未启用'));
             }
 
-            $config = $config_info['data']['value'];
+            $config = $config_info;
             $apiKey = $config['api_key'];
             $baseUrl = $config['base_url'];
 
@@ -231,7 +282,7 @@ class Kefu extends BaseApi
 
             // 发送请求到Dify API
             $url = $baseUrl . '/conversations';
-            $response = HttpClient::http($url, 'POST', json_encode($requestData), $headers);
+            $response = $this->curlRequest($url, 'POST', $requestData, $headers);
 
             // 解析响应
             $result = json_decode($response, true);