Method GetProgress

api/controller/batch_upload.go:218–250

GetProgress 获取上传进度（轮询方式） @Summary 获取上传进度 @Description 获取批量上传的进度信息 @Tags 批量上传 @Accept json @Produce json @Security BearerAuth @Param batch_id path string true "批次ID" @Param detail query bool false "是否返回详细信息" @Param file_upload_id query string false "查询特定文件" @Param since query int false "增量查询时间戳" @Suc

(c *gin.Context)

// @Failure 500 {object} model.CommonResponse "服务器内部错误"
// @Router /api/files/upload/batch/{batch_id}/progress [get]
func (ctrl *BatchUploadController) GetProgress(c *gin.Context) {
	batchID := c.Param("batch_id")

	var params service.ProgressQueryParams
	if err := c.ShouldBindQuery(&params); err != nil {
		c.JSON(http.StatusBadRequest, model.ParamError.ToResponse(err))
		return
	}

	// 验证权限
	batch, err := ctrl.manager.GetBatch(batchID)
	if err != nil {
		c.JSON(http.StatusNotFound, model.NotFound.ToResponse(err))
		return
	}

	eid := config.GetEID(c)
	userID := config.GetUserId(c)

	if batch.GetEID() != eid || batch.GetUserID() != userID {
		c.JSON(http.StatusForbidden, model.AuthFailed.ToResponse(errors.New("无权限查看此批次")))
		return
	}

	// 获取进度信息
	progress, err := ctrl.progressStorage.GetBatchProgress(batchID, &params)
	if err != nil {
		c.JSON(http.StatusInternalServerError, model.SystemError.ToResponse(err))
		return
	}

	c.JSON(http.StatusOK, model.Success.ToResponse(progress))
}

// CancelBatch 取消批量上传
// @Summary 取消批量上传