Function wrapHandlerFunc

api/controller/wps.go:34–97

wrapHandlerFunc 封装返回处理函数

(f func(*gin.Context) (any, error))

// wrapHandlerFunc 封装返回处理函数
func wrapHandlerFunc(f func(*gin.Context) (any, error)) gin.HandlerFunc {
	return func(c *gin.Context) {
		begin := time.Now()
		data, err := f(c)
		cost := time.Since(begin)

		if err != nil {
			var respErr *weboffice.Error
			if e, ok := err.(*weboffice.Error); ok {
				respErr = e
			} else {
				respErr = weboffice.ErrInternalError.WithMessage(err.Error())
			}

			// 记录详细的错误信息
			logger.SysErrorf("WPS接口调用失败: %s %s 错误码=%d 错误消息=%s 耗时=%s",
				c.Request.Method, c.Request.RequestURI, respErr.Code(), respErr.Message(), cost.String())

			// 记录请求头信息（排除敏感信息）
			headers := make(map[string]string)
			for key, values := range c.Request.Header {
				if key != "Authorization" && key != "X-Upload-Token" {
					headers[key] = strings.Join(values, ",")
				}
			}
			logger.SysErrorf("请求头信息: %+v", headers)

			// 记录请求参数（如果是POST/PUT请求，记录请求体的一部分）
			if c.Request.Method == "POST" || c.Request.Method == "PUT" {
				body, _ := io.ReadAll(c.Request.Body)
				if len(body) > 0 {
					// 限制日志大小，避免记录过大的请求体
					bodyStr := string(body)
					if len(bodyStr) > 500 {
						bodyStr = bodyStr[:500] + "..."
					}
					logger.SysErrorf("请求体内容: %s", bodyStr)
					// 恢复请求体，以便后续处理
					c.Request.Body = io.NopCloser(strings.NewReader(bodyStr))
				}
			}

			c.JSON(respErr.StatusCode(), &weboffice.Reply{Code: respErr.Code(), Message: respErr.Message()})
		} else {
			// 记录成功的调用信息
			logger.SysLogf("WPS接口调用成功: %s %s 耗时=%s",
				c.Request.Method, c.Request.RequestURI, cost.String())

			// 记录响应数据的摘要信息
			if data != nil {
				// 将响应数据转换为JSON字符串，限制长度
				if jsonStr, err := json.Marshal(data); err == nil {
					jsonStrStr := string(jsonStr)
					if len(jsonStrStr) > 500 {
						jsonStrStr = jsonStrStr[:500] + "..."
					}
					logger.SysLogf("响应数据摘要: %s", jsonStrStr)
				}