Function DeleteFileAsync

api/controller/file.go:1124–1191

DeleteFileAsync godoc @Summary 异步删除文件 @Description 异步删除文件接口，支持级联删除相关数据 @Tags 文件管理 @Accept json @Produce json @Security BearerAuth @Param file_id path int true "文件ID" @Param async query bool false "是否异步删除" default(false) @Success 200 {object} model.CommonResponse @Router /api/files/{file_id}/delete-a

(c *gin.Context)

// @Success 200 {object} model.CommonResponse
// @Router /api/files/{file_id}/delete-async [delete]
func DeleteFileAsync(c *gin.Context) {
	eid := config.GetEID(c)
	userID := config.GetUserId(c)

	id := c.Param("file_id")
	if id == "" {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(errors.New("文件ID不能为空")))
		return
	}

	fileID, err := parseMCPStyleID(id)
	if err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(errors.New("无效的文件ID")))
		return
	}

	// 获取文件信息以检查权限和记录日志
	file, err := model.GetFileByID(eid, fileID)
	if err != nil {
		c.JSON(http.StatusNotFound, model.NotFound.ToResponse(err))
		return
	}

	// 获取知识库和空间信息用于日志
	library, _ := model.GetLibraryByID(eid, file.LibraryID)
	space, _ := model.GetSpaceByID(eid, library.SpaceID)

	permisson, err := service.GetUserPermission(eid, model.RESOURCE_TYPE_FILE, fileID, userID)
	if err != nil || permisson < model.PERMISSION_MANAGE {
		c.JSON(http.StatusForbidden, model.AuthFailed.ToResponse(err))
		return
	}

	// 检查是否异步删除
	async := c.DefaultQuery("async", "false") == "true"

	// 执行删除（现在都是级联删除）
	if err := model.DeleteFile(eid, fileID); err != nil {
		c.JSON(http.StatusInternalServerError, model.FileError.ToResponse(err))
		return
	}

	// 记录系统日志
	fileName := filepath.Base(file.Path)
	log := model.SystemLog{
		Eid:      eid,
		UserID:   config.GetUserId(c),
		Nickname: config.GetUserNickname(c),
		Module:   model.SystemLogModuleFile,
		Action:   model.SystemLogActionDelete,
		Content:  fmt.Sprintf("从【%s】知识库【%s】删除了《%s》", space.Name, library.Name, fileName),
		IP:       utils.GetClientIP(c),
	}
	model.CreateSystemLog(&log)

	// 从 Elasticsearch 移除索引
	elasticsearch.SyncFileToES(file, "delete")