Function NewEntityVectorService

api/service/rag/entity_vector.go:20–39

(db *gorm.DB)

}

func NewEntityVectorService(db *gorm.DB) *EntityVectorService {
	config := vectorstore.LoadFromEnv()
	store, err := vectorstore.NewVectorStore(config)
	if err != nil {
		logger.SysLogf("创建向量存储失败: %v", err)
		store = nil
	}
	if store != nil {
		ctx := context.Background()
		if err := store.Connect(ctx); err != nil {
			logger.SysLogf("连接向量存储失败: %v", err)
			store = nil
		}
	}
	return &EntityVectorService{
		db:        db,
		vectorDB:  store,
		embedding: NewEmbeddingService(db),
	}
}

func (s *EntityVectorService) IndexEntity(eid int64, entity *model.Entity) error {
	if entity == nil || entity.ID <= 0 {