Function cleanupVectorDataAsync

api/model/file.go:1222–1255

cleanupVectorDataAsync 异步清理向量数据

(eid int64, fileID int64, vectorIDs []string)

// cleanupVectorDataAsync 异步清理向量数据
func cleanupVectorDataAsync(eid int64, fileID int64, vectorIDs []string) {
	log.Printf("开始异步清理向量数据 - EID: %d, FileID: %d, 向量数量: %d", eid, fileID, len(vectorIDs))

	// 使用defer确保错误也会被记录
	defer func() {
		if r := recover(); r != nil {
			log.Printf("向量数据清理过程中发生panic - EID: %d, FileID: %d, Error: %v", eid, fileID, r)
		}
	}()

	if len(vectorIDs) == 0 {
		log.Printf("文件没有向量数据需要清理 - EID: %d, FileID: %d", eid, fileID)
		return
	}

	log.Printf("开始清理 %d 个向量 - EID: %d, FileID: %d", len(vectorIDs), eid, fileID)

	// 1. 从向量数据库中删除向量
	err := deleteVectorsFromDB(eid, fileID, vectorIDs)
	if err != nil {
		log.Printf("从向量数据库删除向量失败 - EID: %d, FileID: %d, Error: %v", eid, fileID, err)
		// 即使删除失败，也继续执行后续清理步骤
	} else {
		log.Printf("成功从向量数据库删除 %d 个向量 - EID: %d, FileID: %d", len(vectorIDs), eid, fileID)
	}

	// 2. 记录清理操作日志
	err = recordVectorCleanupLog(eid, fileID, len(vectorIDs))
	if err != nil {
		log.Printf("记录向量清理日志失败 - EID: %d, FileID: %d, Error: %v", eid, fileID, err)
	}

	log.Printf("向量数据清理完成 - EID: %d, FileID: %d, 清理向量数: %d", eid, fileID, len(vectorIDs))
}

func GetChildrenByPathPrefix(eid int64, pathPrefix string) ([]File, error) {
	var files []File