Method multiLibraryVectorSearchLegacy

api/service/rag/search.go:3537–3619

multiLibraryVectorSearchLegacy 原来的多库搜索流程（用于测试 mock 场景）

(eid int64, req *SearchRequest, configService *ChunkConfigService)

// multiLibraryVectorSearchLegacy 原来的多库搜索流程（用于测试 mock 场景）
func (s *SearchService) multiLibraryVectorSearchLegacy(eid int64, req *SearchRequest, configService *ChunkConfigService) ([]SearchResultItem, error) {
	logger.SysDebugf("🔍 开始多知识库向量搜索-Legacy (eid=%d, libraries=%v)", eid, req.LibraryIDs)

	// 并发搜索各个知识库
	type libraryResult struct {
		libraryID int64
		results   []SearchResultItem
		err       error
	}

	resultChan := make(chan libraryResult, len(req.LibraryIDs))
	maxConcurrentSearches := multiLibrarySearchConcurrencyLimit()
	sem := make(chan struct{}, maxConcurrentSearches)

	// 为每个知识库启动独立的搜索
	for _, libraryID := range req.LibraryIDs {
		sem <- struct{}{}
		go func(libID int64) {
			defer func() {
				<-sem
			}()

			// 创建单知识库搜索请求
			singleReq := &SearchRequest{
				Query:        req.Query,
				SearchType:   req.SearchType,
				TopK:         req.TopK,
				LibraryIDs:   []int64{libID},
				FileIDs:      req.FileIDs,
				ChunkTypes:   req.ChunkTypes,
				SearchConfig: normalizeSearchConfigForExecution(req.SearchConfig),
				trace:        req.trace,
			}

			results, err := singleVectorSearchFn(s, eid, singleReq, configService)
			resultChan <- libraryResult{
				libraryID: libID,
				results:   results,
				err:       err,
			}
		}(libraryID)
	}

	// 收集所有结果
	var allResults []SearchResultItem
	var errors []error

	for i := 0; i < len(req.LibraryIDs); i++ {
		result := <-resultChan
		if result.err != nil {
			logger.SysLogf("❌ 知识库%d搜索失败: %v", result.libraryID, result.err)
			errors = append(errors, fmt.Errorf("知识库%d: %v", result.libraryID, result.err))
		} else {
			logger.SysLogf("✅ 知识库%d搜索成功，返回%d个结果", result.libraryID, len(result.results))
			allResults = append(allResults, result.results...)
		}
	}