Method updateEmbeddingStatusWithError

api/service/rag/embedding.go:951–957

updateEmbeddingStatusWithError 更新向量化状态为失败

(eid int64, chunkID int64, errorMsg string)

// updateEmbeddingStatusWithError 更新向量化状态为失败
func (s *EmbeddingService) updateEmbeddingStatusWithError(eid int64, chunkID int64, errorMsg string) {
	err := model.UpdateChunkEmbeddingStatus(eid, chunkID, model.DocumentChunkEmbeddingStatusFailed, "")
	if err != nil {
		fmt.Printf("更新向量化失败状态失败: %v\n", err)
	}
	fmt.Printf("分块 %d 向量化失败: %s\n", chunkID, errorMsg)
}

// GetQueryEmbedding 获取查询文本的向量（使用 singleflight 防止并发重复请求）
func (s *EmbeddingService) GetQueryEmbedding(eid int64, query string, channelID int64, config *ChunkConfig) ([]float64, error) {