Services/shop-platform
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

test(addon/aikefu): 还原原先的kefu.app 方便测试

Browse Source
This commit is contained in:
ZF Sun
2025-12-06 16:42:45 +08:00
parent fe73fdd5bd
commit 42aa934493
1 changed files with 124 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

127
src/app/api/controller/Kefu.php
View File

@@ -10,6 +10,127 @@ use think\facade\Event;
*/
class Kefu extends BaseApi
{
/**
* 系统健康检查, 用来检测当前的AI服务是否正常
* @return \think\response\Json | bool
*/
public function health()
{
$start_time = microtime(true);
// (必选) 获取站点ID和会员ID，可以通过事件数据传递
$site_id = $this->params['uniacid'] ?? $this->site_id; // 使用 uniacid, 方便以后迁移，而且uniacid 是唯一的, site_id 不是，同时被params给过滤了
// 检查site_id 如果 < 1, 则返回错误
if ($site_id < 1) {
return $this->response($this->error('缺少关键参数站点ID'));
}
// 准备事件数据
$event_data = [
'check_id' => uniqid('health_', true),
'timestamp' => date('Y-m-d H:i:s'),
'site_id' => $site_id,
'check_type' => $this->params['check_type'] ?? 'full' // full, basic, ai_service
];
$health_summary = null;
$event_data = [
'check_id' => uniqid('health_', true),
'timestamp' => date('Y-m-d H:i:s'),
'site_id' => $site_id,
'check_type' => $this->params['check_type'] ?? 'full' // full, basic, ai_service
];
try {
// 触发健康检查事件
$result = Event::trigger('KefuHealthCheck', $event_data);
// 汇总检查结果
$health_summary = [
'status' => 'healthy',
'check_id' => $event_data['check_id'],
'timestamp' => $event_data['timestamp'],
'total_checks' => 0,
'passed_checks' => 0,
'failed_checks' => 0,
'response_time_ms' => 0,
'components' => [],
'warnings' => [],
'errors' => []
];
if (is_array($result) && !empty($result)) {
foreach ($result as $check_result) {
if (isset($check_result['component'])) {
$health_summary['components'][$check_result['component']] = $check_result;
$health_summary['total_checks']++;
if ($check_result['status'] === 'healthy') {
$health_summary['passed_checks']++;
} else {
$health_summary['failed_checks']++;
if ($check_result['status'] === 'error') {
$health_summary['errors'][] = $check_result['message'] ?? 'Unknown error';
$health_summary['status'] = 'unhealthy';
} elseif ($check_result['status'] === 'warning') {
$health_summary['warnings'][] = $check_result['message'] ?? 'Unknown warning';
if ($health_summary['status'] === 'healthy') {
$health_summary['status'] = 'warning';
}
}
}
}
}
}
// 计算总体响应时间
$health_summary['response_time_ms'] = round((microtime(true) - $start_time) * 1000, 2);
// 如果没有任何检查结果，进行基础检查
if ($health_summary['total_checks'] === 0) {
$health_summary['components']['basic'] = [
'status' => 'healthy',
'message' => '基础服务正常',
'response_time_ms' => 0,
'details' => [
'php_version' => PHP_VERSION,
'memory_usage' => round(memory_get_usage() / 1024 / 1024, 2) . ' MB',
'time_limit' => ini_get('max_execution_time') . 's'
]
];
$health_summary['total_checks'] = 1;
$health_summary['passed_checks'] = 1;
}
// 根据检查结果确定HTTP状态码
$http_code = 200;
if ($health_summary['status'] === 'unhealthy') {
$http_code = 503; // Service Unavailable
} elseif ($health_summary['status'] === 'warning') {
$http_code = 200; // Still OK but with warnings
}
return $this->response([
'code' => 0,
'message' => $health_summary['status'],
'data' => $health_summary
], $http_code);
} catch (\Exception $e) {
return $this->response([
'code' => -1,
'message' => '健康检查失败',
'data' => [
'status' => 'error',
'check_id' => $event_data['check_id'] ?? '',
'timestamp' => $event_data['timestamp'] ?? date('Y-m-d H:i:s'),
'error' => $e->getMessage(),
'response_time_ms' => round((microtime(true) - $start_time) * 1000, 2)
]
], 500);
}
}
/**
* 智能客服聊天接口
* @return \think\response\Json
@@ -140,9 +261,9 @@ class Kefu extends BaseApi
$member_id = $this->params['member_id'] ?? $this->member_id;
$token = $this->params['token'] ?? $this->token;
// 验证参数
if (empty($conversation_id)) {
return $this->response($this->error('会话ID不能为空'));
// 验证参数（conversation_id 和 user_id 至少需要一个）
if (empty($conversation_id) && empty($user_id)) {
return $this->response($this->error('会话ID或用户ID不能为空'));
}
try {