shudao-main/shudao-chat-go/tests/api_test.go.backup

package tests

import (
	"bufio"
	"bytes"
	"encoding/base64"
	"encoding/json"
	"fmt"
	"image"
	"image/color"
	"image/draw"
	"image/jpeg"
	"io"
	"net"
	"net/http"
	"net/url"
	"os"
	"strings"
	"testing"
	"time"
)

// Qwen3ChatRequest 定义Qwen3聊天请求结构
type Qwen3ChatRequest struct {
	Model       string        `json:"model"`
	Messages    []ChatMessage `json:"messages"`
	Stream      bool          `json:"stream"`
	Temperature float64       `json:"temperature,omitempty"`
}

// ChatMessage 定义聊天消息结构
type ChatMessage struct {
	Role    string `json:"role"`
	Content string `json:"content"`
}

// Qwen3ChatResponse 定义Qwen3聊天响应结构（非流式）
type Qwen3ChatResponse struct {
	ID      string `json:"id"`
	Object  string `json:"object"`
	Created int64  `json:"created"`
	Model   string `json:"model"`
	Choices []struct {
		Index   int `json:"index"`
		Message struct {
			Role             string        `json:"role"`
			Content          string        `json:"content"`
			Refusal          *string       `json:"refusal"`
			Annotations      *string       `json:"annotations"`
			Audio            *string       `json:"audio"`
			FunctionCall     *string       `json:"function_call"`
			ToolCalls        []interface{} `json:"tool_calls"`
			ReasoningContent *string       `json:"reasoning_content"`
		} `json:"message"`
		Logprobs     *string `json:"logprobs"`
		FinishReason string  `json:"finish_reason"`
		StopReason   *string `json:"stop_reason"`
	} `json:"choices"`
	ServiceTier       *string `json:"service_tier"`
	SystemFingerprint *string `json:"system_fingerprint"`
	Usage             struct {
		PromptTokens        int     `json:"prompt_tokens"`
		TotalTokens         int     `json:"total_tokens"`
		CompletionTokens    int     `json:"completion_tokens"`
		PromptTokensDetails *string `json:"prompt_tokens_details"`
	} `json:"usage"`
	PromptLogprobs   *string `json:"prompt_logprobs"`
	KvTransferParams *string `json:"kv_transfer_params"`
}

// Qwen3StreamResponse 定义Qwen3流式响应结构
type Qwen3StreamResponse struct {
	ID                string `json:"id"`
	Object            string `json:"object"`
	Created           int64  `json:"created"`
	Model             string `json:"model"`
	SystemFingerprint string `json:"system_fingerprint,omitempty"`
	Choices           []struct {
		Index int `json:"index"`
		Delta struct {
			Role      string `json:"role,omitempty"`
			Content   string `json:"content,omitempty"`
			ToolCalls []struct {
				Index    int    `json:"index"`
				ID       string `json:"id"`
				Type     string `json:"type"`
				Function struct {
					Name      string `json:"name"`
					Arguments string `json:"arguments"`
				} `json:"function"`
			} `json:"tool_calls,omitempty"`
		} `json:"delta"`
		Logprobs     interface{} `json:"logprobs"`
		FinishReason *string     `json:"finish_reason"`
		StopReason   *string     `json:"stop_reason,omitempty"`
	} `json:"choices"`
}

// TestQwen3ChatAPI 测试Qwen3聊天接口
func TestQwen3ChatAPI(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.Qwen3BaseURL
	model := config.Qwen3Model

	testCases := []struct {
		name    string
		message string
	}{
		{
			name:    "基础问候测试",
			message: "你好，请介绍一下你自己。",
		},
		{
			name:    "技术问题测试",
			message: "请解释一下什么是编程？",
		},
	}

	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			// 构建非流式请求
			request := Qwen3ChatRequest{
				Model:  model,
				Stream: false,
				Messages: []ChatMessage{
					{
						Role:    "system",
						Content: "你是一个乐于助人的助手。",
					},
					{
						Role:    "user",
						Content: tc.message,
					},
				},
			}

			jsonData, err := json.Marshal(request)
			if err != nil {
				t.Fatalf("序列化请求失败: %v", err)
			}

			t.Logf("发送的请求: %s", string(jsonData))

			// 发送POST请求
			resp, err := http.Post(
				fmt.Sprintf("%s/v1/chat/completions", baseURL),
				"application/json",
				bytes.NewBuffer(jsonData),
			)
			if err != nil {
				t.Fatalf("发送请求失败: %v", err)
			}
			defer resp.Body.Close()

			t.Logf("响应状态码: %d", resp.StatusCode)
			t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))

			if resp.StatusCode != http.StatusOK {
				body, _ := io.ReadAll(resp.Body)
				t.Fatalf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
			}

			// 读取完整的响应内容
			body, err := io.ReadAll(resp.Body)
			if err != nil {
				t.Fatalf("读取响应失败: %v", err)
			}

			t.Logf("响应长度: %d", len(body))

			// 解析JSON响应
			var response Qwen3ChatResponse
			if err := json.Unmarshal(body, &response); err != nil {
				t.Fatalf("解析JSON响应失败: %v", err)
			}

			// 验证响应
			if response.ID == "" {
				t.Error("响应ID为空")
			}
			if len(response.Choices) == 0 {
				t.Error("响应中没有选择项")
			}

			t.Logf("✅ 非流式响应成功！")
			t.Logf("请求: %s", tc.message)
			t.Logf("响应ID: %s", response.ID)
			t.Logf("模型: %s", response.Model)
			t.Logf("完整响应: %s", response.Choices[0].Message.Content)
		})
	}
}

// TestQwen3StreamAPI 测试Qwen3流式聊天接口
func TestQwen3StreamAPI(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.Qwen3BaseURL
	model := config.Qwen3Model

	testCases := []struct {
		name    string
		message string
	}{
		{
			name:    "流式基础问候测试",
			message: "你好，请介绍一下你自己。",
		},
		{
			name:    "流式技术问题测试",
			message: "请解释一下什么是编程？",
		},
	}

	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			// 构建流式请求
			request := Qwen3ChatRequest{
				Model:       model,
				Stream:      false,
				Temperature: 0.7,
				Messages: []ChatMessage{
					{
						Role:    "system",
						Content: "你是一个乐于助人的助手。",
					},
					{
						Role:    "user",
						Content: tc.message,
					},
				},
			}

			jsonData, err := json.Marshal(request)
			if err != nil {
				t.Fatalf("序列化请求失败: %v", err)
			}

			// 发送POST请求
			resp, err := http.Post(
				fmt.Sprintf("%s/v1/chat/completions", baseURL),
				"application/json",
				bytes.NewBuffer(jsonData),
			)
			if err != nil {
				t.Fatalf("发送请求失败: %v", err)
			}
			defer resp.Body.Close()

			t.Logf("响应状态码: %d", resp.StatusCode)
			t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))

			if resp.StatusCode != http.StatusOK {
				body, _ := io.ReadAll(resp.Body)
				t.Fatalf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
			}

			t.Logf("响应长度: %d", resp.ContentLength)

			if request.Stream {
				// 处理流式响应
				scanner := bufio.NewScanner(resp.Body)
				var fullContent strings.Builder
				var responseID string
				var firstChunk = true

				t.Logf("开始接收流式响应...")
				chunkCount := 0

				for scanner.Scan() {
					line := scanner.Text()
					chunkCount++

					// 跳过空行和data:前缀
					if line == "" || !strings.HasPrefix(line, "data: ") {
						continue
					}

					// 移除"data: "前缀
					data := strings.TrimPrefix(line, "data: ")

					// 检查是否是结束标记
					if data == "[DONE]" {
						t.Logf("收到结束标记")
						break
					}

					// 解析JSON数据
					var streamResp Qwen3StreamResponse
					if err := json.Unmarshal([]byte(data), &streamResp); err != nil {
						t.Logf("解析流式响应失败: %v, 数据: %s", err, data)
						continue
					}

					// 记录第一个块的ID
					if firstChunk {
						responseID = streamResp.ID
						t.Logf("响应ID: %s", responseID)
						t.Logf("模型: %s", streamResp.Model)
						firstChunk = false
					}

					// 处理choices中的内容
					if len(streamResp.Choices) > 0 {
						choice := streamResp.Choices[0]
						if choice.Delta.Content != "" {
							fullContent.WriteString(choice.Delta.Content)
							t.Logf("收到内容块: %s", choice.Delta.Content)
						}

						// 检查是否完成
						if choice.FinishReason != nil {
							t.Logf("完成原因: %s", *choice.FinishReason)
							break
						}
					}
				}

				if err := scanner.Err(); err != nil {
					t.Fatalf("读取流式响应失败: %v", err)
				}

				// 验证结果
				finalContent := fullContent.String()
				if finalContent == "" {
					t.Error("流式响应内容为空")
				} else {
					t.Logf("✅ 流式响应成功！")
					t.Logf("请求: %s", tc.message)
					t.Logf("响应ID: %s", responseID)
					t.Logf("总块数: %d", chunkCount)
					t.Logf("完整响应: %s", finalContent)
				}
			} else {
				// 处理非流式响应
				body, err := io.ReadAll(resp.Body)
				if err != nil {
					t.Fatalf("读取响应失败: %v", err)
				}

				t.Logf("开始解析非流式响应...")

				// 解析JSON响应
				var response Qwen3ChatResponse
				if err := json.Unmarshal(body, &response); err != nil {
					t.Fatalf("解析JSON响应失败: %v", err)
				}

				// 验证响应
				if response.ID == "" {
					t.Error("响应ID为空")
				}
				if len(response.Choices) == 0 {
					t.Error("响应中没有选择项")
				}

				t.Logf("✅ 非流式响应成功！")
				t.Logf("请求: %s", tc.message)
				t.Logf("响应ID: %s", response.ID)
				t.Logf("模型: %s", response.Model)
				t.Logf("完整响应: %s", response.Choices[0].Message.Content)
			}
		})
	}
}

// TestYOLOPredictAPI 测试YOLO图像识别接口
func TestYOLOPredictAPI(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.YOLOBaseURL

	testCase := struct {
		modeltype      string
		image          string
		conf_threshold float32
	}{
		modeltype:      "gas_station",
		image:          "test_images/1.jpg",
		conf_threshold: 0.5,
	}

	// 使用单个测试用例，不需要循环
	tc := testCase

	// 检查图像文件是否存在
	if _, err := os.Stat(tc.image); os.IsNotExist(err) {
		t.Skipf("测试图像文件不存在: %s", tc.image)
	}

	// 读取图像文件并转换为base64
	imageData, err := os.ReadFile(tc.image)
	if err != nil {
		t.Fatalf("读取图像文件失败: %v", err)
	}

	// 解码图像用于后续处理
	img, _, err := image.Decode(bytes.NewReader(imageData))
	if err != nil {
		t.Fatalf("解码图像失败: %v", err)
	}

	// 将图像数据转换为base64
	imageBase64 := base64.StdEncoding.EncodeToString(imageData)

	// 构建JSON请求体
	requestBody := map[string]interface{}{
		"modeltype":      tc.modeltype,
		"image":          imageBase64,
		"conf_threshold": tc.conf_threshold,
	}

	jsonData, err := json.Marshal(requestBody)
	if err != nil {
		t.Fatalf("序列化请求体失败: %v", err)
	}

	resp, err := http.Post(
		fmt.Sprintf("%s/predict", baseURL),
		"application/json",
		bytes.NewBuffer(jsonData),
	)
	if err != nil {
		t.Fatalf("发送请求失败: %v", err)
	}
	defer resp.Body.Close()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		t.Fatalf("读取响应失败: %v", err)
	}

	if resp.StatusCode != http.StatusOK {
		t.Errorf("请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
	}

	if len(body) == 0 {
		t.Error("响应内容为空")
	}

	t.Logf("响应状态码: %d", resp.StatusCode)
	t.Logf("响应内容: %s", string(body))

	// 解析YOLO响应
	var yoloResp YOLOResponse
	if err := json.Unmarshal(body, &yoloResp); err != nil {
		t.Fatalf("解析YOLO响应失败: %v", err)
	}

	t.Logf("解析成功: 检测到 %d 个对象", len(yoloResp.Labels))

	t.Logf("开始绘制边界框...")
	// 在原始图像上绘制边界框
	annotatedImg := drawBoundingBox(img, yoloResp.Boxes, yoloResp.Labels, yoloResp.Scores)
	t.Logf("边界框绘制完成")

	t.Logf("开始保存图像...")
	// 保存标注后的图像
	outputPath := "test_images/annotated_1.jpg"
	outputFile, err := os.Create(outputPath)
	if err != nil {
		t.Fatalf("创建输出文件失败: %v", err)
	}
	defer outputFile.Close()

	if err := jpeg.Encode(outputFile, annotatedImg, &jpeg.Options{Quality: 95}); err != nil {
		t.Fatalf("保存图像失败: %v", err)
	}

	t.Logf("✅ 已保存标注后的图像到: %s", outputPath)
	t.Logf("识别结果: 检测到 %d 个对象", len(yoloResp.Labels))
	for i, label := range yoloResp.Labels {
		if i < len(yoloResp.Scores) {
			t.Logf("  - %s: 置信度 %.2f%%", label, yoloResp.Scores[i]*100)
		}
	}

	// 强制输出日志
	t.Logf("测试完成，图像已保存")
}

// TestAPIEndpoints 测试API端点连通性
func TestAPIEndpoints(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	endpoints := []struct {
		name string
		url  string
	}{
		{"Qwen3聊天接口", config.GetQwen3ChatURL()},
		{"YOLO预测接口", config.GetYOLOPredictURL()},
		{"TTS流式接口", config.GetTTSStreamURL()},
	}

	for _, endpoint := range endpoints {
		t.Run(endpoint.name, func(t *testing.T) {
			client := &http.Client{
				Timeout: 10 * time.Second,
			}

			resp, err := client.Head(endpoint.url)
			if err != nil {
				t.Logf("端点 %s 不可达: %v", endpoint.name, err)
				return
			}
			defer resp.Body.Close()

			t.Logf("端点 %s 可达，状态码: %d", endpoint.name, resp.StatusCode)
		})
	}
}

// BenchmarkQwen3ChatAPI 性能测试Qwen3聊天接口
func BenchmarkQwen3ChatAPI(b *testing.B) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.Qwen3BaseURL
	model := config.Qwen3Model

	request := Qwen3ChatRequest{
		Model: model,
		Messages: []ChatMessage{
			{
				Role:    "user",
				Content: "你好",
			},
		},
	}

	jsonData, _ := json.Marshal(request)

	b.ResetTimer()
	for i := 0; i < b.N; i++ {
		resp, err := http.Post(
			fmt.Sprintf("%s/v1/chat/completions", baseURL),
			"application/json",
			bytes.NewBuffer(jsonData),
		)
		if err != nil {
			b.Fatalf("请求失败: %v", err)
		}
		resp.Body.Close()
	}
}

// YOLOResponse 定义YOLO响应结构
type YOLOResponse struct {
	Boxes     [][]float64 `json:"boxes"`
	Labels    []string    `json:"labels"`
	Scores    []float64   `json:"scores"`
	ModelType string      `json:"model_type"`
}

// drawBoundingBox 在图像上绘制边界框和标签
func drawBoundingBox(img image.Image, boxes [][]float64, labels []string, scores []float64) image.Image {
	// 创建可绘制的图像副本
	bounds := img.Bounds()
	drawableImg := image.NewRGBA(bounds)
	draw.Draw(drawableImg, bounds, img, image.Point{}, draw.Src)

	// 红色边界框
	red := image.NewUniform(color.RGBA{255, 0, 0, 255})

	fmt.Printf("图像边界: %v\n", bounds)

	for i, box := range boxes {
		if len(box) >= 4 {
			x1, y1, x2, y2 := int(box[0]), int(box[1]), int(box[2]), int(box[3])
			fmt.Printf("边界框 %d: [%d, %d, %d, %d]\n", i, x1, y1, x2, y2)

			// 绘制边界框
			drawRect(drawableImg, x1, y1, x2, y2, red)

			// 绘制标签和置信度（暂时注释掉，避免白色区域）
			// if i < len(labels) && i < len(scores) {
			// 	label := fmt.Sprintf("%s: %.2f", labels[i], scores[i])
			// 	drawLabel(drawableImg, x1, y1-20, label)
			// }
		}
	}

	return drawableImg
}

// drawRect 绘制矩形
func drawRect(img *image.RGBA, x1, y1, x2, y2 int, color *image.Uniform) {
	bounds := img.Bounds()
	fmt.Printf("绘制矩形: [%d, %d, %d, %d], 图像边界: %v\n", x1, y1, x2, y2, bounds)

	// 确保坐标在图像边界内
	if x1 < bounds.Min.X {
		x1 = bounds.Min.X
	}
	if y1 < bounds.Min.Y {
		y1 = bounds.Min.Y
	}
	if x2 >= bounds.Max.X {
		x2 = bounds.Max.X - 1
	}
	if y2 >= bounds.Max.Y {
		y2 = bounds.Max.Y - 1
	}

	fmt.Printf("调整后坐标: [%d, %d, %d, %d]\n", x1, y1, x2, y2)

	// 绘制四条边
	for x := x1; x <= x2; x++ {
		img.Set(x, y1, color)
		img.Set(x, y2, color)
	}
	for y := y1; y <= y2; y++ {
		img.Set(x1, y, color)
		img.Set(x2, y, color)
	}

	fmt.Printf("矩形绘制完成\n")
}

// drawLabel 绘制标签文本（简化版本，只绘制背景矩形）
func drawLabel(img *image.RGBA, x, y int, text string) {
	fmt.Printf("绘制标签: '%s' 在位置 [%d, %d]\n", text, x, y)

	// 绘制白色背景矩形
	white := image.NewUniform(color.RGBA{255, 255, 255, 255})
	labelWidth := len(text) * 8 // 估算文本宽度
	labelHeight := 16

	// 确保标签在图像边界内
	bounds := img.Bounds()
	if x < bounds.Min.X {
		x = bounds.Min.X
	}
	if y < bounds.Min.Y {
		y = bounds.Min.Y
	}
	if x+labelWidth >= bounds.Max.X {
		labelWidth = bounds.Max.X - x - 1
	}
	if y+labelHeight >= bounds.Max.Y {
		labelHeight = bounds.Max.Y - y - 1
	}

	fmt.Printf("标签尺寸: %dx%d\n", labelWidth, labelHeight)

	// 绘制背景矩形
	for dx := 0; dx < labelWidth; dx++ {
		for dy := 0; dy < labelHeight; dy++ {
			if x+dx < bounds.Max.X && y+dy < bounds.Max.Y && x+dx >= bounds.Min.X && y+dy >= bounds.Min.Y {
				img.Set(x+dx, y+dy, white)
			}
		}
	}

	fmt.Printf("标签绘制完成\n")
}

// TestHealthCheck 测试健康检查接口
func TestHealthCheck(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.HealthBaseURL

	t.Run("健康检查测试", func(t *testing.T) {
		client := &http.Client{
			Timeout: 10 * time.Second,
		}

		// 发送POST请求到健康检查端点
		t.Logf("请求URL: %s/health", baseURL)
		resp, err := client.Post(fmt.Sprintf("%s/health", baseURL), "application/json", nil)
		if err != nil {
			t.Logf("❌ 健康检查请求失败: %v", err)
			t.Logf("错误类型: %T", err)

			// 检查是否是网络相关错误
			if netErr, ok := err.(interface{ Timeout() bool }); ok && netErr.Timeout() {
				t.Logf("⚠️ 这是超时错误")
			}

			// 尝试更详细的错误信息
			if urlErr, ok := err.(*url.Error); ok {
				t.Logf("URL错误详情: %+v", urlErr)
				if urlErr.Err != nil {
					t.Logf("底层错误: %v", urlErr.Err)
				}
			}

			t.Fatalf("健康检查请求失败: %v", err)
		}
		defer resp.Body.Close()

		// 读取响应内容
		body, err := io.ReadAll(resp.Body)
		if err != nil {
			t.Logf("读取响应失败: %v", err)
		}

		t.Logf("健康检查响应状态码: %d", resp.StatusCode)
		t.Logf("响应头: %+v", resp.Header)
		t.Logf("响应内容: %s", string(body))

		// 验证响应状态码
		if resp.StatusCode != http.StatusOK {
			t.Errorf("健康检查失败，期望状态码200，实际状态码: %d", resp.StatusCode)
		}

		// 验证响应内容（通常健康检查返回简单的状态信息）
		if len(body) == 0 {
			t.Error("健康检查响应内容为空")
		}

		// 尝试解析JSON响应（如果返回的是JSON格式）
		var healthResponse map[string]interface{}
		if err := json.Unmarshal(body, &healthResponse); err == nil {
			t.Logf("✅ 健康检查返回JSON格式响应: %+v", healthResponse)
		} else {
			t.Logf("健康检查返回非JSON格式响应: %s", string(body))
		}
	})
}

// ShudaoWorkflowRequest 定义蜀道集团工作流请求结构
type ShudaoWorkflowRequest struct {
	WorkflowID   string                 `json:"workflow_id"`
	Inputs       map[string]interface{} `json:"inputs"`
	ResponseMode string                 `json:"response_mode"`
	User         string                 `json:"user"`
}

// ShudaoWorkflowResponse 定义蜀道集团工作流响应结构
type ShudaoWorkflowResponse struct {
	TaskID         string `json:"task_id"`
	WorkflowRunID  string `json:"workflow_run_id"`
	Data           struct {
		ID          string `json:"id"`
		WorkflowID  string `json:"workflow_id"`
		Status      string `json:"status"`
		Outputs     struct {
			JSON []struct {
				Answer            *string `json:"answer"`
				FollowUpQuestions *string `json:"follow_up_questions"`
				Images            []string `json:"images"`
				Query             string  `json:"query"`
				RequestID         string  `json:"request_id"`
				ResponseTime      float64 `json:"response_time"`
				Results           []struct {
					Content     string  `json:"content"`
					RawContent  *string `json:"raw_content"`
					Score       float64 `json:"score"`
					Title       string  `json:"title"`
					URL         string  `json:"url"`
				} `json:"results"`
			} `json:"json"`
		} `json:"outputs"`
		Error        string  `json:"error"`
		ElapsedTime  float64 `json:"elapsed_time"`
		TotalTokens  int     `json:"total_tokens"`
		TotalSteps   int     `json:"total_steps"`
		CreatedAt    int64   `json:"created_at"`
		FinishedAt   int64   `json:"finished_at"`
	} `json:"data"`
}

// TestShudaoWorkflowConnectivity 测试蜀道集团工作流接口连通性
func TestShudaoWorkflowConnectivity(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.GetShudaoWorkflowURL()
	authToken := config.ShuDaoAuthToken
	workflowID := config.ShuDaoWorkflowID

	t.Run("蜀道集团工作流接口连通性测试", func(t *testing.T) {
		client := &http.Client{
			Timeout: 60 * time.Second, // 工作流可能需要更长时间
		}

		t.Logf("测试蜀道集团工作流接口连通性: %s", baseURL)
		t.Logf("使用工作流ID: %s", workflowID)
		t.Logf("使用认证令牌: %s", authToken)

		// 构建测试请求
		request := ShudaoWorkflowRequest{
			WorkflowID: workflowID,
			Inputs: map[string]interface{}{
				"keywords": "蜀道集团",
				"num":      5, // 减少结果数量以加快测试
			},
			ResponseMode: "blocking",
			User:         "test_user_001",
		}

		jsonData, err := json.Marshal(request)
		if err != nil {
			t.Fatalf("序列化测试请求失败: %v", err)
		}

		// 创建HTTP请求
		req, err := http.NewRequest("POST", baseURL, bytes.NewBuffer(jsonData))
		if err != nil {
			t.Fatalf("创建HTTP请求失败: %v", err)
		}

		// 设置请求头
		req.Header.Set("Authorization", "Bearer "+authToken)
		req.Header.Set("Content-Type", "application/json")

		// 发送请求
		resp, err := client.Do(req)
		if err != nil {
			t.Logf("❌ 蜀道集团工作流接口连接失败: %v", err)
			t.Logf("可能的原因:")
			t.Logf("  - 工作流服务未启动")
			t.Logf("  - 网络不可达")
			t.Logf("  - 端口不正确")
			t.Logf("  - 防火墙阻止")
			t.Logf("  - 认证令牌无效")
			t.Fatalf("蜀道集团工作流接口连通性测试失败: %v", err)
		}
		defer resp.Body.Close()

		t.Logf("✅ 蜀道集团工作流接口HTTP连接成功")
		t.Logf("响应状态码: %d", resp.StatusCode)
		t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))

		// 读取响应体
		body, err := io.ReadAll(resp.Body)
		if err != nil {
			t.Fatalf("读取响应体失败: %v", err)
		}

		// 验证响应状态码
		if resp.StatusCode != http.StatusOK {
			t.Logf("⚠️ 蜀道集团工作流服务返回非200状态码: %d", resp.StatusCode)
			t.Logf("响应内容: %s", string(body))
			t.Fatalf("蜀道集团工作流接口返回错误状态码: %d", resp.StatusCode)
		}

		// 解析响应JSON
		var response ShudaoWorkflowResponse
		if err := json.Unmarshal(body, &response); err != nil {
			t.Logf("⚠️ 响应JSON解析失败: %v", err)
			t.Logf("原始响应: %s", string(body))
			t.Fatalf("无法解析蜀道集团工作流响应: %v", err)
		}

		t.Logf("✅ 蜀道集团工作流服务响应正常")
		t.Logf("任务ID: %s", response.TaskID)
		t.Logf("工作流运行ID: %s", response.WorkflowRunID)
		t.Logf("工作流状态: %s", response.Data.Status)
		t.Logf("执行耗时: %.3f秒", response.Data.ElapsedTime)

		// 验证工作流执行状态
		if response.Data.Status != "succeeded" {
			t.Logf("⚠️ 工作流执行状态异常: %s", response.Data.Status)
			if response.Data.Error != "" {
				t.Logf("错误信息: %s", response.Data.Error)
			}
			t.Fatalf("工作流执行失败，状态: %s", response.Data.Status)
		}

		// 验证返回结果
		if len(response.Data.Outputs.JSON) == 0 {
			t.Fatalf("工作流未返回任何结果")
		}

		jsonResult := response.Data.Outputs.JSON[0]
		t.Logf("查询关键词: %s", jsonResult.Query)
		t.Logf("检索耗时: %.3f秒", jsonResult.ResponseTime)
		t.Logf("返回结果数量: %d", len(jsonResult.Results))

		// 验证结果质量
		if len(jsonResult.Results) == 0 {
			t.Fatalf("未返回任何检索结果")
		}

		// 显示前3个结果的基本信息
		for i, result := range jsonResult.Results {
			if i >= 3 {
				break
			}
			t.Logf("结果 %d:", i+1)
			t.Logf("  标题: %s", result.Title)
			t.Logf("  相关性得分: %.4f", result.Score)
			t.Logf("  URL: %s", result.URL)
			t.Logf("  内容摘要: %s...", truncateString(result.Content, 100))
		}

		// 验证结果质量（相关性得分）
		highScoreCount := 0
		for _, result := range jsonResult.Results {
			if result.Score > 0.7 {
				highScoreCount++
			}
		}

		t.Logf("高质量结果数量 (得分>0.7): %d/%d", highScoreCount, len(jsonResult.Results))

		if highScoreCount == 0 {
			t.Logf("⚠️ 警告: 没有高质量结果 (得分>0.7)")
		}

		t.Logf("✅ 蜀道集团工作流接口测试完成")
	})
}

// truncateString 截断字符串到指定长度
func truncateString(s string, maxLen int) string {
	if len(s) <= maxLen {
		return s
	}
	return s[:maxLen]
}

// SearchRequest 定义搜索请求结构
type SearchRequest struct {
	Query    string `json:"query"`
	NResults int    `json:"n_results"`
}

// SearchResponse 定义搜索响应结构
type SearchResponse struct {
	Results []SearchResult `json:"results"`
	Total   int            `json:"total"`
	Query   string         `json:"query"`
}

// SearchResult 定义搜索结果结构
type SearchResult struct {
	ID       string                 `json:"id"`
	Title    string                 `json:"title"`
	Content  string                 `json:"content"`
	Score    float64                `json:"score"`
	Metadata map[string]interface{} `json:"metadata,omitempty"`
}

// TestSearchAPI 测试搜索功能接口
func TestSearchAPI(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.SearchBaseURL

	testCases := []struct {
		name     string
		query    string
		nResults int
	}{
		{
			name:     "技术搜索测试",
			query:    "技术",
			nResults: 3,
		},
		{
			name:     "编程搜索测试",
			query:    "编程",
			nResults: 5,
		},
		{
			name:     "AI搜索测试",
			query:    "人工智能",
			nResults: 2,
		},
	}

	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			// 构建搜索请求
			request := SearchRequest{
				Query:    tc.query,
				NResults: tc.nResults,
			}

			jsonData, err := json.Marshal(request)
			if err != nil {
				t.Fatalf("序列化搜索请求失败: %v", err)
			}

			// 发送POST请求到搜索端点
			resp, err := http.Post(
				fmt.Sprintf("%s/search", baseURL),
				"application/json",
				bytes.NewBuffer(jsonData),
			)
			if err != nil {
				t.Fatalf("搜索请求失败: %v", err)
			}
			defer resp.Body.Close()

			// 读取响应内容
			body, err := io.ReadAll(resp.Body)
			if err != nil {
				t.Fatalf("读取搜索响应失败: %v", err)
			}

			t.Logf("搜索响应状态码: %d", resp.StatusCode)
			t.Logf("搜索查询: %s", tc.query)
			t.Logf("请求结果数量: %d", tc.nResults)

			// 验证响应状态码
			if resp.StatusCode != http.StatusOK {
				t.Errorf("搜索请求失败，期望状态码200，实际状态码: %d", resp.StatusCode)
				if len(body) < 500 {
					t.Logf("错误响应内容: %s", string(body))
				}
				return
			}

			// 验证响应内容不为空
			if len(body) == 0 {
				t.Error("搜索响应内容为空")
				return
			}

			// 尝试解析JSON响应
			var searchResponse SearchResponse
			if err := json.Unmarshal(body, &searchResponse); err != nil {
				t.Logf("⚠️ 搜索响应不是标准JSON格式: %v", err)
				t.Logf("响应内容: %s", string(body))

				// 尝试解析为简单的map结构
				var simpleResponse map[string]interface{}
				if err := json.Unmarshal(body, &simpleResponse); err == nil {
					t.Logf("✅ 搜索返回简单JSON格式: %+v", simpleResponse)
				} else {
					t.Logf("搜索返回非JSON格式响应")
				}
				return
			}

			// 验证搜索结果
			t.Logf("✅ 搜索成功！")
			t.Logf("查询: %s", searchResponse.Query)
			t.Logf("总结果数: %d", searchResponse.Total)
			t.Logf("返回结果数: %d", len(searchResponse.Results))

			// 验证结果数量
			if len(searchResponse.Results) > tc.nResults {
				t.Logf("⚠️ 返回结果数量(%d)超过请求数量(%d)", len(searchResponse.Results), tc.nResults)
			}

			// 显示搜索结果详情
			for i, result := range searchResponse.Results {
				t.Logf("结果 %d:", i+1)
				t.Logf("  ID: %s", result.ID)
				t.Logf("  标题: %s", result.Title)
				t.Logf("  内容: %s", truncateString(result.Content, 100))
				t.Logf("  评分: %.4f", result.Score)
				if len(result.Metadata) > 0 {
					t.Logf("  元数据: %+v", result.Metadata)
				}
			}
		})
	}
}

// truncateString 截断字符串到指定长度
func truncateString(s string, maxLen int) string {
	if len(s) <= maxLen {
		return s
	}
	return s[:maxLen] + "..."
}

// TTSRequest 定义TTS请求结构
type TTSRequest struct {
	Text string `json:"text"`
}

// TestTTSStreamAPI 测试TTS流式接口
func TestTTSStreamAPI(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.TTSBaseURL

	testCases := []struct {
		name string
		text string
	}{
		{
			name: "短文本测试",
			text: "你好，这是一个语音合成测试。",
		},
		{
			name: "中等长度文本测试",
			text: "答案依据：《汽车加油站雷电防护装置检测报告综述表》委托单位随检人员在雷电防护装置检测过程中承担着关键的协同与监督职责。",
		},
		{
			name: "长文本测试",
			text: "答案依据：《汽车加油站雷电防护装置检测报告综述表》委托单位随检人员在雷电防护装置检测过程中承担着关键的协同与监督职责，其参与过程对检测报告的完整性与合规性具有直接影响。作为检测工作的现场对接方和责任主体之一，委托单位随检人员需全程参与检测实施，确保检测工作在真实、可控的现场环境下开展，有效保障检测数据的真实性与代表性。",
		},
	}

	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			// 构建TTS请求
			request := TTSRequest{
				Text: tc.text,
			}

			jsonData, err := json.Marshal(request)
			if err != nil {
				t.Fatalf("序列化TTS请求失败: %v", err)
			}

			t.Logf("发送的TTS请求: %s", string(jsonData))
			t.Logf("请求URL: %s/tts/voice", baseURL)

			// 创建HTTP客户端，设置较长的超时时间（TTS可能需要较长时间）
			client := &http.Client{
				Timeout: 60 * time.Second,
			}

			// 发送POST请求
			resp, err := client.Post(
				fmt.Sprintf("%s/tts/voice", baseURL),
				"application/json",
				bytes.NewBuffer(jsonData),
			)
			if err != nil {
				t.Fatalf("发送TTS请求失败: %v", err)
			}
			defer resp.Body.Close()

			t.Logf("TTS响应状态码: %d", resp.StatusCode)
			t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))
			t.Logf("Content-Length: %s", resp.Header.Get("Content-Length"))

			// 验证响应状态码
			if resp.StatusCode != http.StatusOK {
				body, _ := io.ReadAll(resp.Body)
				t.Fatalf("TTS请求失败，状态码: %d, 响应: %s", resp.StatusCode, string(body))
			}

			// 检查Content-Type是否为音频格式
			contentType := resp.Header.Get("Content-Type")
			if contentType != "" {
				t.Logf("响应Content-Type: %s", contentType)
				// WAV格式通常为 "audio/wav" 或 "audio/wave"
				if !strings.Contains(contentType, "audio") && !strings.Contains(contentType, "wav") {
					t.Logf("⚠️ 警告: Content-Type不是预期的音频格式")
				}
			}

			// 读取流式音频数据
			t.Logf("开始接收流式音频数据...")
			var audioData bytes.Buffer
			totalBytes := 0
			chunkCount := 0

			// 分块读取数据
			buffer := make([]byte, 4096) // 4KB缓冲区
			for {
				n, err := resp.Body.Read(buffer)
				if n > 0 {
					audioData.Write(buffer[:n])
					totalBytes += n
					chunkCount++

					// 每读取10个块输出一次进度
					if chunkCount%10 == 0 {
						t.Logf("已接收 %d 字节音频数据 (块数: %d)", totalBytes, chunkCount)
					}
				}

				if err == io.EOF {
					t.Logf("音频数据接收完成")
					break
				}
				if err != nil {
					t.Fatalf("读取音频数据失败: %v", err)
				}
			}

			t.Logf("✅ TTS流式响应成功！")
			t.Logf("请求文本: %s", tc.text)
			t.Logf("文本长度: %d 字符", len(tc.text))
			t.Logf("音频数据总大小: %d 字节", totalBytes)
			t.Logf("接收块数: %d", chunkCount)

			// 验证音频数据不为空
			if totalBytes == 0 {
				t.Error("音频数据为空")
				return
			}

			// 验证音频数据大小合理性（至少应该有WAV文件头）
			if totalBytes < 44 {
				t.Errorf("音频数据太小，可能不是有效的WAV文件: %d 字节", totalBytes)
			}

			// 验证WAV文件头（RIFF格式）
			audioBytes := audioData.Bytes()
			if len(audioBytes) >= 12 {
				// 检查RIFF头
				if string(audioBytes[0:4]) == "RIFF" {
					t.Logf("✅ 检测到有效的RIFF格式音频文件")
					if len(audioBytes) >= 8 {
						fileSize := int(audioBytes[4]) | int(audioBytes[5])<<8 | int(audioBytes[6])<<16 | int(audioBytes[7])<<24
						t.Logf("WAV文件大小字段: %d 字节", fileSize)
					}
					if len(audioBytes) >= 12 && string(audioBytes[8:12]) == "WAVE" {
						t.Logf("✅ 检测到WAVE格式")
					}
				} else {
					t.Logf("⚠️ 警告: 音频数据不是标准的RIFF格式")
					t.Logf("文件头: %x", audioBytes[:min(16, len(audioBytes))])
				}
			}

			// 保存音频文件到本地进行验证
			outputFilename := fmt.Sprintf("tts_test_%s.wav", strings.ReplaceAll(tc.name, " ", "_"))
			outputFile, err := os.Create(outputFilename)
			if err != nil {
				t.Fatalf("创建音频输出文件失败: %v", err)
			}
			defer outputFile.Close()

			_, err = outputFile.Write(audioBytes)
			if err != nil {
				t.Fatalf("写入音频文件失败: %v", err)
			}

			t.Logf("✅ 音频文件已保存: %s", outputFilename)
			t.Logf("文件大小: %d 字节", totalBytes)

			// 验证文件是否成功创建
			if stat, err := os.Stat(outputFilename); err == nil {
				t.Logf("✅ 文件验证成功，实际大小: %d 字节", stat.Size())
				if stat.Size() != int64(totalBytes) {
					t.Errorf("文件大小不匹配: 期望 %d, 实际 %d", totalBytes, stat.Size())
				}
			} else {
				t.Errorf("文件验证失败: %v", err)
			}
		})
	}
}

// min 返回两个整数中的较小值
func min(a, b int) int {
	if a < b {
		return a
	}
	return b
}

// TestTTSConnectivity 测试TTS接口连通性
func TestTTSConnectivity(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.TTSBaseURL

	t.Run("TTS接口连通性测试", func(t *testing.T) {
		client := &http.Client{
			Timeout: 30 * time.Second,
		}

		t.Logf("测试TTS接口连通性: %s/tts/voice", baseURL)

		// 构建简单的测试请求
		request := TTSRequest{
			Text: "测试",
		}

		jsonData, err := json.Marshal(request)
		if err != nil {
			t.Fatalf("序列化测试请求失败: %v", err)
		}

		// 发送POST请求
		resp, err := client.Post(
			fmt.Sprintf("%s/tts/voice", baseURL),
			"application/json",
			bytes.NewBuffer(jsonData),
		)
		if err != nil {
			t.Logf("❌ TTS接口连接失败: %v", err)
			t.Logf("可能的原因:")
			t.Logf("  - TTS服务未启动")
			t.Logf("  - 网络不可达")
			t.Logf("  - 端口不正确")
			t.Logf("  - 防火墙阻止")
			t.Fatalf("TTS接口连通性测试失败: %v", err)
		}
		defer resp.Body.Close()

		t.Logf("✅ TTS接口HTTP连接成功")
		t.Logf("响应状态码: %d", resp.StatusCode)
		t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))

		// 验证响应状态码
		if resp.StatusCode != http.StatusOK {
			body, _ := io.ReadAll(resp.Body)
			t.Logf("⚠️ TTS服务不可用，状态码: %d", resp.StatusCode)
			t.Logf("响应内容: %s", string(body))

			// 根据状态码提供具体的错误信息
			switch resp.StatusCode {
			case 502:
				t.Logf("❌ 502 Bad Gateway - TTS后端服务可能未启动或配置错误")
			case 503:
				t.Logf("❌ 503 Service Unavailable - TTS服务暂时不可用")
			case 404:
				t.Logf("❌ 404 Not Found - TTS接口路径不存在")
			case 500:
				t.Logf("❌ 500 Internal Server Error - TTS服务内部错误")
			default:
				t.Logf("❌ 未知错误状态码: %d", resp.StatusCode)
			}
		} else {
			t.Logf("✅ TTS服务响应正常")

			// 读取少量数据验证是否为音频格式
			buffer := make([]byte, 1024)
			n, err := resp.Body.Read(buffer)
			if err != nil && err != io.EOF {
				t.Logf("读取响应数据失败: %v", err)
			} else if n > 0 {
				t.Logf("✅ 成功接收 %d 字节数据", n)

				// 检查是否为WAV格式
				if n >= 12 {
					if string(buffer[0:4]) == "RIFF" {
						t.Logf("✅ 检测到WAV格式音频数据")
					} else {
						t.Logf("⚠️ 数据格式可能不是WAV: %x", buffer[:min(16, n)])
					}
				}
			}
		}
	})
}

// ShudaoWorkflowRequest 定义蜀道集团工作流请求结构
type ShudaoWorkflowRequest struct {
	WorkflowID   string                 `json:"workflow_id"`
	Inputs       map[string]interface{} `json:"inputs"`
	ResponseMode string                 `json:"response_mode"`
	User         string                 `json:"user"`
}

// ShudaoWorkflowResponse 定义蜀道集团工作流响应结构
type ShudaoWorkflowResponse struct {
	TaskID         string `json:"task_id"`
	WorkflowRunID  string `json:"workflow_run_id"`
	Data           struct {
		ID          string `json:"id"`
		WorkflowID  string `json:"workflow_id"`
		Status      string `json:"status"`
		Outputs     struct {
			JSON []struct {
				Answer            *string `json:"answer"`
				FollowUpQuestions *string `json:"follow_up_questions"`
				Images            []string `json:"images"`
				Query             string  `json:"query"`
				RequestID         string  `json:"request_id"`
				ResponseTime      float64 `json:"response_time"`
				Results           []struct {
					Content     string  `json:"content"`
					RawContent  *string `json:"raw_content"`
					Score       float64 `json:"score"`
					Title       string  `json:"title"`
					URL         string  `json:"url"`
				} `json:"results"`
			} `json:"json"`
		} `json:"outputs"`
		Error        string  `json:"error"`
		ElapsedTime  float64 `json:"elapsed_time"`
		TotalTokens  int     `json:"total_tokens"`
		TotalSteps   int     `json:"total_steps"`
		CreatedAt    int64   `json:"created_at"`
		FinishedAt   int64   `json:"finished_at"`
	} `json:"data"`
}

// TestShudaoWorkflowConnectivity 测试蜀道集团工作流接口连通性
func TestShudaoWorkflowConnectivity(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.GetShudaoWorkflowURL()
	authToken := config.ShuDaoAuthToken
	workflowID := config.ShuDaoWorkflowID

	t.Run("蜀道集团工作流接口连通性测试", func(t *testing.T) {
		client := &http.Client{
			Timeout: 60 * time.Second, // 工作流可能需要更长时间
		}

		t.Logf("测试蜀道集团工作流接口连通性: %s", baseURL)
		t.Logf("使用工作流ID: %s", workflowID)
		t.Logf("使用认证令牌: %s", authToken)

		// 构建测试请求
		request := ShudaoWorkflowRequest{
			WorkflowID: workflowID,
			Inputs: map[string]interface{}{
				"keywords": "蜀道集团",
				"num":      5, // 减少结果数量以加快测试
			},
			ResponseMode: "blocking",
			User:         "test_user_001",
		}

		jsonData, err := json.Marshal(request)
		if err != nil {
			t.Fatalf("序列化测试请求失败: %v", err)
		}

		// 创建HTTP请求
		req, err := http.NewRequest("POST", baseURL, bytes.NewBuffer(jsonData))
		if err != nil {
			t.Fatalf("创建HTTP请求失败: %v", err)
		}

		// 设置请求头
		req.Header.Set("Authorization", "Bearer "+authToken)
		req.Header.Set("Content-Type", "application/json")

		// 发送请求
		resp, err := client.Do(req)
		if err != nil {
			t.Logf("❌ 蜀道集团工作流接口连接失败: %v", err)
			t.Logf("可能的原因:")
			t.Logf("  - 工作流服务未启动")
			t.Logf("  - 网络不可达")
			t.Logf("  - 端口不正确")
			t.Logf("  - 防火墙阻止")
			t.Logf("  - 认证令牌无效")
			t.Fatalf("蜀道集团工作流接口连通性测试失败: %v", err)
		}
		defer resp.Body.Close()

		t.Logf("✅ 蜀道集团工作流接口HTTP连接成功")
		t.Logf("响应状态码: %d", resp.StatusCode)
		t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))

		// 读取响应体
		body, err := io.ReadAll(resp.Body)
		if err != nil {
			t.Fatalf("读取响应体失败: %v", err)
		}

		// 验证响应状态码
		if resp.StatusCode != http.StatusOK {
			t.Logf("⚠️ 蜀道集团工作流服务返回非200状态码: %d", resp.StatusCode)
			t.Logf("响应内容: %s", string(body))
			t.Fatalf("蜀道集团工作流接口返回错误状态码: %d", resp.StatusCode)
		}

		// 解析响应JSON
		var response ShudaoWorkflowResponse
		if err := json.Unmarshal(body, &response); err != nil {
			t.Logf("⚠️ 响应JSON解析失败: %v", err)
			t.Logf("原始响应: %s", string(body))
			t.Fatalf("无法解析蜀道集团工作流响应: %v", err)
		}

		t.Logf("✅ 蜀道集团工作流服务响应正常")
		t.Logf("任务ID: %s", response.TaskID)
		t.Logf("工作流运行ID: %s", response.WorkflowRunID)
		t.Logf("工作流状态: %s", response.Data.Status)
		t.Logf("执行耗时: %.3f秒", response.Data.ElapsedTime)

		// 验证工作流执行状态
		if response.Data.Status != "succeeded" {
			t.Logf("⚠️ 工作流执行状态异常: %s", response.Data.Status)
			if response.Data.Error != "" {
				t.Logf("错误信息: %s", response.Data.Error)
			}
			t.Fatalf("工作流执行失败，状态: %s", response.Data.Status)
		}

		// 验证返回结果
		if len(response.Data.Outputs.JSON) == 0 {
			t.Fatalf("工作流未返回任何结果")
		}

		jsonResult := response.Data.Outputs.JSON[0]
		t.Logf("查询关键词: %s", jsonResult.Query)
		t.Logf("检索耗时: %.3f秒", jsonResult.ResponseTime)
		t.Logf("返回结果数量: %d", len(jsonResult.Results))

		// 验证结果质量
		if len(jsonResult.Results) == 0 {
			t.Fatalf("未返回任何检索结果")
		}

		// 显示前3个结果的基本信息
		for i, result := range jsonResult.Results {
			if i >= 3 {
				break
			}
			t.Logf("结果 %d:", i+1)
			t.Logf("  标题: %s", result.Title)
			t.Logf("  相关性得分: %.4f", result.Score)
			t.Logf("  URL: %s", result.URL)
			t.Logf("  内容摘要: %s...", truncateString(result.Content, 100))
		}

		// 验证结果质量（相关性得分）
		highScoreCount := 0
		for _, result := range jsonResult.Results {
			if result.Score > 0.7 {
				highScoreCount++
			}
		}

		t.Logf("高质量结果数量 (得分>0.7): %d/%d", highScoreCount, len(jsonResult.Results))

		if highScoreCount == 0 {
			t.Logf("⚠️ 警告: 没有高质量结果 (得分>0.7)")
		}

		t.Logf("✅ 蜀道集团工作流接口测试完成")
	})
}

// truncateString 截断字符串到指定长度
func truncateString(s string, maxLen int) string {
	if len(s) <= maxLen {
		return s
	}
	return s[:maxLen]
}

// TestHealthAndSearchIntegration 集成测试：先检查健康状态，再进行搜索
func TestHealthAndSearchIntegration(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.HealthBaseURL

	t.Run("健康检查和搜索集成测试", func(t *testing.T) {
		client := &http.Client{
			Timeout: 15 * time.Second,
		}

		// 第一步：健康检查
		t.Logf("步骤1: 执行健康检查...")
		t.Logf("请求URL: %s/health", baseURL)

		healthResp, err := client.Post(fmt.Sprintf("%s/health", baseURL), "application/json", nil)
		if err != nil {
			t.Logf("❌ 健康检查请求失败: %v", err)
			t.Logf("错误类型: %T", err)

			// 检查是否是网络相关错误
			if netErr, ok := err.(interface{ Timeout() bool }); ok && netErr.Timeout() {
				t.Logf("⚠️ 这是超时错误")
			}

			// 尝试更详细的错误信息
			if urlErr, ok := err.(*url.Error); ok {
				t.Logf("URL错误详情: %+v", urlErr)
				if urlErr.Err != nil {
					t.Logf("底层错误: %v", urlErr.Err)
				}
			}

			t.Fatalf("健康检查失败: %v", err)
		}
		defer healthResp.Body.Close()

		// 读取响应内容
		healthBody, err := io.ReadAll(healthResp.Body)
		if err != nil {
			t.Logf("读取健康检查响应失败: %v", err)
		}

		t.Logf("健康检查响应状态码: %d", healthResp.StatusCode)
		t.Logf("响应头: %+v", healthResp.Header)
		if len(healthBody) > 0 {
			t.Logf("响应内容: %s", string(healthBody))
		}

		if healthResp.StatusCode != http.StatusOK {
			t.Fatalf("健康检查失败，状态码: %d", healthResp.StatusCode)
		}
		t.Logf("✅ 健康检查通过")

		// 第二步：执行搜索
		t.Logf("步骤2: 执行搜索测试...")
		searchRequest := SearchRequest{
			Query:    "技术",
			NResults: 3,
		}

		jsonData, err := json.Marshal(searchRequest)
		if err != nil {
			t.Fatalf("序列化搜索请求失败: %v", err)
		}

		searchResp, err := client.Post(
			fmt.Sprintf("%s/search", baseURL),
			"application/json",
			bytes.NewBuffer(jsonData),
		)
		if err != nil {
			t.Fatalf("搜索请求失败: %v", err)
		}
		defer searchResp.Body.Close()

		body, err := io.ReadAll(searchResp.Body)
		if err != nil {
			t.Fatalf("读取搜索响应失败: %v", err)
		}

		if searchResp.StatusCode != http.StatusOK {
			t.Errorf("搜索失败，状态码: %d", searchResp.StatusCode)
			if len(body) < 200 {
				t.Logf("错误响应: %s", string(body))
			}
		} else {
			t.Logf("✅ 搜索功能正常")
			t.Logf("响应长度: %d 字节", len(body))
		}

		t.Logf("✅ 集成测试完成")
	})
}

// TestNetworkConnectivity 测试网络连通性
func TestNetworkConnectivity(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.HealthBaseURL

	t.Run("网络连通性测试", func(t *testing.T) {
		// 解析URL
		parsedURL, err := url.Parse(baseURL)
		if err != nil {
			t.Fatalf("解析URL失败: %v", err)
		}

		t.Logf("测试目标: %s", baseURL)
		t.Logf("协议: %s", parsedURL.Scheme)
		t.Logf("主机: %s", parsedURL.Host)
		t.Logf("端口: %s", parsedURL.Port())

		// 测试TCP连接
		conn, err := net.DialTimeout("tcp", parsedURL.Host, 5*time.Second)
		if err != nil {
			t.Logf("❌ TCP连接失败: %v", err)
			t.Logf("可能的原因:")
			t.Logf("  - 服务器未启动")
			t.Logf("  - 防火墙阻止")
			t.Logf("  - 网络不可达")
			t.Logf("  - 端口不正确")
		} else {
			t.Logf("✅ TCP连接成功")
			conn.Close()
		}

		// 测试HTTP连接
		client := &http.Client{
			Timeout: 10 * time.Second,
		}

		// 尝试简单的HEAD请求
		resp, err := client.Head(baseURL)
		if err != nil {
			t.Logf("❌ HTTP HEAD请求失败: %v", err)
		} else {
			t.Logf("✅ HTTP连接成功，状态码: %d", resp.StatusCode)
			resp.Body.Close()
		}

		// 尝试POST请求到根路径
		resp, err = client.Post(baseURL, "application/json", nil)
		if err != nil {
			t.Logf("❌ HTTP POST请求失败: %v", err)
		} else {
			t.Logf("✅ HTTP POST连接成功，状态码: %d", resp.StatusCode)
			resp.Body.Close()
		}
	})
}

// ShudaoWorkflowRequest 定义蜀道集团工作流请求结构
type ShudaoWorkflowRequest struct {
	WorkflowID   string                 `json:"workflow_id"`
	Inputs       map[string]interface{} `json:"inputs"`
	ResponseMode string                 `json:"response_mode"`
	User         string                 `json:"user"`
}

// ShudaoWorkflowResponse 定义蜀道集团工作流响应结构
type ShudaoWorkflowResponse struct {
	TaskID         string `json:"task_id"`
	WorkflowRunID  string `json:"workflow_run_id"`
	Data           struct {
		ID          string `json:"id"`
		WorkflowID  string `json:"workflow_id"`
		Status      string `json:"status"`
		Outputs     struct {
			JSON []struct {
				Answer            *string `json:"answer"`
				FollowUpQuestions *string `json:"follow_up_questions"`
				Images            []string `json:"images"`
				Query             string  `json:"query"`
				RequestID         string  `json:"request_id"`
				ResponseTime      float64 `json:"response_time"`
				Results           []struct {
					Content     string  `json:"content"`
					RawContent  *string `json:"raw_content"`
					Score       float64 `json:"score"`
					Title       string  `json:"title"`
					URL         string  `json:"url"`
				} `json:"results"`
			} `json:"json"`
		} `json:"outputs"`
		Error        string  `json:"error"`
		ElapsedTime  float64 `json:"elapsed_time"`
		TotalTokens  int     `json:"total_tokens"`
		TotalSteps   int     `json:"total_steps"`
		CreatedAt    int64   `json:"created_at"`
		FinishedAt   int64   `json:"finished_at"`
	} `json:"data"`
}

// TestShudaoWorkflowConnectivity 测试蜀道集团工作流接口连通性
func TestShudaoWorkflowConnectivity(t *testing.T) {
	// 加载测试配置
	config := LoadConfig()
	baseURL := config.GetShudaoWorkflowURL()
	authToken := config.ShuDaoAuthToken
	workflowID := config.ShuDaoWorkflowID

	t.Run("蜀道集团工作流接口连通性测试", func(t *testing.T) {
		client := &http.Client{
			Timeout: 60 * time.Second, // 工作流可能需要更长时间
		}

		t.Logf("测试蜀道集团工作流接口连通性: %s", baseURL)
		t.Logf("使用工作流ID: %s", workflowID)
		t.Logf("使用认证令牌: %s", authToken)

		// 构建测试请求
		request := ShudaoWorkflowRequest{
			WorkflowID: workflowID,
			Inputs: map[string]interface{}{
				"keywords": "蜀道集团",
				"num":      5, // 减少结果数量以加快测试
			},
			ResponseMode: "blocking",
			User:         "test_user_001",
		}

		jsonData, err := json.Marshal(request)
		if err != nil {
			t.Fatalf("序列化测试请求失败: %v", err)
		}

		// 创建HTTP请求
		req, err := http.NewRequest("POST", baseURL, bytes.NewBuffer(jsonData))
		if err != nil {
			t.Fatalf("创建HTTP请求失败: %v", err)
		}

		// 设置请求头
		req.Header.Set("Authorization", "Bearer "+authToken)
		req.Header.Set("Content-Type", "application/json")

		// 发送请求
		resp, err := client.Do(req)
		if err != nil {
			t.Logf("❌ 蜀道集团工作流接口连接失败: %v", err)
			t.Logf("可能的原因:")
			t.Logf("  - 工作流服务未启动")
			t.Logf("  - 网络不可达")
			t.Logf("  - 端口不正确")
			t.Logf("  - 防火墙阻止")
			t.Logf("  - 认证令牌无效")
			t.Fatalf("蜀道集团工作流接口连通性测试失败: %v", err)
		}
		defer resp.Body.Close()

		t.Logf("✅ 蜀道集团工作流接口HTTP连接成功")
		t.Logf("响应状态码: %d", resp.StatusCode)
		t.Logf("Content-Type: %s", resp.Header.Get("Content-Type"))

		// 读取响应体
		body, err := io.ReadAll(resp.Body)
		if err != nil {
			t.Fatalf("读取响应体失败: %v", err)
		}

		// 验证响应状态码
		if resp.StatusCode != http.StatusOK {
			t.Logf("⚠️ 蜀道集团工作流服务返回非200状态码: %d", resp.StatusCode)
			t.Logf("响应内容: %s", string(body))
			t.Fatalf("蜀道集团工作流接口返回错误状态码: %d", resp.StatusCode)
		}

		// 解析响应JSON
		var response ShudaoWorkflowResponse
		if err := json.Unmarshal(body, &response); err != nil {
			t.Logf("⚠️ 响应JSON解析失败: %v", err)
			t.Logf("原始响应: %s", string(body))
			t.Fatalf("无法解析蜀道集团工作流响应: %v", err)
		}

		t.Logf("✅ 蜀道集团工作流服务响应正常")
		t.Logf("任务ID: %s", response.TaskID)
		t.Logf("工作流运行ID: %s", response.WorkflowRunID)
		t.Logf("工作流状态: %s", response.Data.Status)
		t.Logf("执行耗时: %.3f秒", response.Data.ElapsedTime)

		// 验证工作流执行状态
		if response.Data.Status != "succeeded" {
			t.Logf("⚠️ 工作流执行状态异常: %s", response.Data.Status)
			if response.Data.Error != "" {
				t.Logf("错误信息: %s", response.Data.Error)
			}
			t.Fatalf("工作流执行失败，状态: %s", response.Data.Status)
		}

		// 验证返回结果
		if len(response.Data.Outputs.JSON) == 0 {
			t.Fatalf("工作流未返回任何结果")
		}

		jsonResult := response.Data.Outputs.JSON[0]
		t.Logf("查询关键词: %s", jsonResult.Query)
		t.Logf("检索耗时: %.3f秒", jsonResult.ResponseTime)
		t.Logf("返回结果数量: %d", len(jsonResult.Results))

		// 验证结果质量
		if len(jsonResult.Results) == 0 {
			t.Fatalf("未返回任何检索结果")
		}

		// 显示前3个结果的基本信息
		for i, result := range jsonResult.Results {
			if i >= 3 {
				break
			}
			t.Logf("结果 %d:", i+1)
			t.Logf("  标题: %s", result.Title)
			t.Logf("  相关性得分: %.4f", result.Score)
			t.Logf("  URL: %s", result.URL)
			t.Logf("  内容摘要: %s...", truncateString(result.Content, 100))
		}

		// 验证结果质量（相关性得分）
		highScoreCount := 0
		for _, result := range jsonResult.Results {
			if result.Score > 0.7 {
				highScoreCount++
			}
		}

		t.Logf("高质量结果数量 (得分>0.7): %d/%d", highScoreCount, len(jsonResult.Results))

		if highScoreCount == 0 {
			t.Logf("⚠️ 警告: 没有高质量结果 (得分>0.7)")
		}

		t.Logf("✅ 蜀道集团工作流接口测试完成")
	})
}

// truncateString 截断字符串到指定长度
func truncateString(s string, maxLen int) string {
	if len(s) <= maxLen {
		return s
	}
	return s[:maxLen]
}