Function executeWPSFileUpload

api/controller/wps.go:708–923

executeWPSFileUpload 执行WPS文件上传

(c *gin.Context)

// executeWPSFileUpload 执行WPS文件上传
func executeWPSFileUpload(c *gin.Context) (any, error) {
	// 记录请求开始
	logger.Infof(c, "开始处理WPS文件上传请求，文件ID: %s", c.Param("file_id"))

	// 获取文件信息
	fileIDStr := c.Param("file_id")
	// 转换成 int64
	fileID, err := strconv.ParseInt(fileIDStr, 10, 64)
	if err != nil {
		return nil, weboffice.ErrInvalidArguments.WithMessage("无效的文件ID")
	}

	// 获取上传许可
	uploadToken := c.GetHeader("X-Upload-Token")
	if uploadToken == "" {
		logger.Error(c, "缺少上传许可")
		return nil, weboffice.ErrPermissionDenied.WithMessage("缺少上传许可")
	}

	logger.Infof(c, "获取到上传许可: %s", uploadToken)

	// 从 Redis 验证上传许可
	redisKey := fmt.Sprintf("wps_upload_token_%s", uploadToken)
	uploadTokenRaw, err := common.RedisGet(redisKey)
	if err != nil {
		logger.Errorf(c, "从Redis验证上传许可失败: %v", err)
		return nil, weboffice.ErrPermissionDenied.WithMessage("上传许可无效或已过期")
	}

	if uploadTokenRaw == "" {
		logger.Errorf(c, "上传许可不存在，Redis Key: %s", redisKey)
		return nil, weboffice.ErrPermissionDenied.WithMessage("上传许可不存在")
	}

	// 从uploadTokenRaw中提取文件ID并验证
	// uploadTokenRaw格式: "wps_upload_%d_%d_%d"，第一个%d是文件ID
	parts := strings.Split(uploadTokenRaw, "_")
	if len(parts) < 4 {
		logger.Errorf(c, "上传许可格式无效: %s", uploadTokenRaw)
		return nil, weboffice.ErrPermissionDenied.WithMessage("上传许可格式无效")
	}

	tokenFileID, err := strconv.ParseInt(parts[2], 10, 64)
	if err != nil {
		logger.Errorf(c, "解析上传许可中的文件ID失败: %v", err)
		return nil, weboffice.ErrPermissionDenied.WithMessage("上传许可中的文件ID无效")
	}

	// 验证文件ID是否匹配
	if tokenFileID != fileID {
		logger.Errorf(c, "文件ID不匹配，上传许可中的文件ID: %d，请求的文件ID: %d", tokenFileID, fileID)
		return nil, weboffice.ErrPermissionDenied.WithMessage("文件ID不匹配")
	}

	logger.Infof(c, "文件ID验证成功，文件ID: %d", fileID)

	file, wpsErr := model.GetFileByIDOlny(fileID)
	if wpsErr != nil {