fix: 修复标签创建重复和流式响应解析问题

修复标签创建时未检查重复名称的问题，增加冲突错误返回。
优化流式响应中对引用数据的处理，支持序列化后的数据结构解析。

Author: lyingbug

internal/application/service/tag.go

@@ -110,6 +110,16 @@ func (s *knowledgeTagService) CreateTag(
 	if err != nil {
 		return nil, err
 	}
+
+	// Check if tag with same name already exists
+	existingTag, err := s.repo.GetByName(ctx, kb.TenantID, kbID, name)
+	if err == nil && existingTag != nil {
+		return nil, werrors.NewConflictError("标签名称已存在")
+	}
+	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
+		return nil, err
+	}
+
 	now := time.Now()
 	tag := &types.KnowledgeTag{
 		ID:              uuid.New().String(),

internal/handler/session/helpers.go

@@ -60,18 +60,35 @@ func buildStreamResponse(evt interfaces.StreamEvent, requestID string) *types.St
 	// Special handling for references event
 	if evt.Type == types.ResponseTypeReferences {
 		refsData := evt.Data["references"]
-		logger.GetLogger(context.Background()).Info("buildStreamResponse references event",
-			"refsData_type", fmt.Sprintf("%T", refsData),
-			"refsData", refsData)
 		if refs, ok := refsData.(types.References); ok {
-			logger.GetLogger(context.Background()).Info("buildStreamResponse: matched types.References")
 			response.KnowledgeReferences = refs
 		} else if refs, ok := refsData.([]*types.SearchResult); ok {
-			logger.GetLogger(context.Background()).Info("buildStreamResponse: matched []*types.SearchResult")
 			response.KnowledgeReferences = types.References(refs)
-		} else {
-			logger.GetLogger(context.Background()).Warn("buildStreamResponse: references type assertion failed",
-				"actual_type", fmt.Sprintf("%T", refsData))
+		} else if refs, ok := refsData.([]interface{}); ok {
+			// Handle case where data was serialized/deserialized (e.g., from Redis)
+			searchResults := make([]*types.SearchResult, 0, len(refs))
+			for _, ref := range refs {
+				if refMap, ok := ref.(map[string]interface{}); ok {
+					sr := &types.SearchResult{
+						ID:                getString(refMap, "id"),
+						Content:           getString(refMap, "content"),
+						KnowledgeID:       getString(refMap, "knowledge_id"),
+						ChunkIndex:        int(getFloat64(refMap, "chunk_index")),
+						KnowledgeTitle:    getString(refMap, "knowledge_title"),
+						StartAt:           int(getFloat64(refMap, "start_at")),
+						EndAt:             int(getFloat64(refMap, "end_at")),
+						Seq:               int(getFloat64(refMap, "seq")),
+						Score:             getFloat64(refMap, "score"),
+						ChunkType:         getString(refMap, "chunk_type"),
+						ParentChunkID:     getString(refMap, "parent_chunk_id"),
+						ImageInfo:         getString(refMap, "image_info"),
+						KnowledgeFilename: getString(refMap, "knowledge_filename"),
+						KnowledgeSource:   getString(refMap, "knowledge_source"),
+					}
+					searchResults = append(searchResults, sr)
+				}
+			}
+			response.KnowledgeReferences = types.References(searchResults)
 		}
 	}