diudiuu

if resp.StatusCode < 200 || resp.StatusCode >= 300 {

if wrapped.C != 0 {

// exchangeToken 用 code 换 access_token
func (s *OAuthService) exchangeToken(p *entity.OAuthProvider, code, redirectURI string) (*tokenResponse, error) {
	params := url.Values{}
	params.Set("grant_type", "authorization_code")
	params.Set("code", code)
	params.Set("redirect_uri", redirectURI)
	params.Set("client_id", p.ClientID)
	params.Set("client_secret", p.ClientSecret)

	resp, err := http.PostForm(p.TokenURL, params)
	if err != nil {
		global.Logger.WithFields(map[string]interface{}{
			"provider": p.Name,
		}).Errorf("oauth: 请求 token 接口失败: %v", err)
		return nil, err
	}
	defer resp.Body.Close()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		return nil, err
	}
	if resp.StatusCode < 200 || resp.StatusCode >= 300 {
		global.Logger.WithFields(map[string]interface{}{
			"provider": p.Name,
			"status": resp.StatusCode,
			"body": string(body),
		}).Errorf("oauth: token 接口返回异常")
		return nil, fmt.Errorf("token 接口返回 %d", resp.StatusCode)
	}

	// 支持 wrapped 格式：{"c":0,"m":"...","d":{...}}
	if p.ResponseFormat == "wrapped" {
		var wrapped struct {
			C int `json:"c"`
			M string `json:"m"`
			D json.RawMessage `json:"d"`
		}
		if err := json.Unmarshal(body, &wrapped); err != nil {
			global.Logger.WithFields(map[string]interface{}{
				"provider": p.Name,
			}).Errorf("oauth: 解析 wrapped token 响应失败: %v", err)
			return nil, err
		}
		if wrapped.C != 0 {
			global.Logger.WithFields(map[string]interface{}{
				"provider": p.Name,
				"code": wrapped.C,
				"message": wrapped.M,
			}).Errorf("oauth: token 接口业务错误")
			return nil, fmt.Errorf("token 接口业务错误: code=%d", wrapped.C)
		}
		body = wrapped.D
	}

	var result tokenResponse
	if err := json.Unmarshal(body, &result); err != nil {
		global.Logger.WithFields(map[string]interface{}{
			"provider": p.Name,
		}).Errorf("oauth: 解析 token 响应失败: %v", err)
		return nil, err
	}
	return &result, nil
}