Function deleteFileWithCascade

api/model/file.go:1045–1090

deleteFileWithCascade 级联删除文件及其所有相关数据

(eid int64, fileID int64)

// deleteFileWithCascade 级联删除文件及其所有相关数据
func deleteFileWithCascade(eid int64, fileID int64) error {
	// 获取文件信息
	file, err := GetFileByID(eid, fileID)
	if err != nil {
		return fmt.Errorf("获取文件信息失败: %v", err)
	}

	// 检查是否为目录类型，目录删除逻辑不变
	if file.Type == FILE_TYPE_DIR {
		tx := DB.Begin()
		defer func() {
			if r := recover(); r != nil {
				tx.Rollback()
			}
		}()

		var entityIDs []int64
		if err := tx.Model(&EntityChunkRelation{}).
			Distinct("entity_id").
			Where("eid = ? AND file_id = ?", eid, fileID).
			Pluck("entity_id", &entityIDs).Error; err != nil {
			tx.Rollback()
			return fmt.Errorf("查询实体关联失败: %v", err)
		}

		if err := tx.Where("eid = ? AND file_id = ?", eid, fileID).Delete(&EntityChunkRelation{}).Error; err != nil {
			tx.Rollback()
			return fmt.Errorf("删除实体关联失败: %v", err)
		}

		if err := tx.Where("eid = ? AND id = ?", eid, fileID).Delete(&File{}).Error; err != nil {
			tx.Rollback()
			return err
		}

		if err := DeleteOrphanEntitiesByIDsWithDB(tx, eid, entityIDs); err != nil {
			tx.Rollback()
			return fmt.Errorf("清理孤儿实体失败: %v", err)
		}

		return tx.Commit().Error
	}

	// 对于文件类型，执行级联删除
	return cascadeDeleteFileData(eid, fileID)
}

// cascadeDeleteFileData 级联删除文件相关数据
func cascadeDeleteFileData(eid int64, fileID int64) error {