5

我在哪里可以找到展示如何使用 C# 连接到 Magento REST API 的示例？

我发现是一个 php，除了一点点我也想不通。

使用我在网上找到的 Dropbox OAuth 示例，我尝试使其适用于 Magento：

private void button1_Click(object sender, RoutedEventArgs e) 
{ 
    var consumerKey = “xxxxxxxxxxxxx”; 
    var consumerSecret = “xxxxxxxxxxxxxxxx”;

    var uri = new Uri("http://www.MagentoWebsite.com/oauth/token");

    // Generate a signature 
    OAuthBase oAuth = new OAuthBase(); 
    string nonce = oAuth.GenerateNonce(); 
    string timeStamp = oAuth.GenerateTimeStamp(); 
    string parameters; 
    string normalizedUrl; 
    string signature = oAuth.GenerateSignature(uri, consumerKey, consumerSecret, 
    String.Empty, String.Empty, “GET”, timeStamp, nonce, OAuthBase.SignatureTypes.HMACSHA1, 
    out normalizedUrl, out parameters);

    signature = HttpUtility.UrlEncode(signature);

    StringBuilder requestUri = new StringBuilder(uri.ToString()); 
    requestUri.AppendFormat("?oauth_consumer_key={0}&", consumerKey); 
    requestUri.AppendFormat("oauth_nonce={0}&", nonce); 
    requestUri.AppendFormat("oauth_timestamp={0}&", timeStamp); 
    requestUri.AppendFormat("oauth_signature_method={0}&", “HMAC-SHA1"); 
    requestUri.AppendFormat("oauth_version={0}&", “1.0"); 
    requestUri.AppendFormat("oauth_signature={0}", signature);

    var request = (HttpWebRequest)WebRequest.Create(new Uri(requestUri.ToString())); 
    request.Method = WebRequestMethods.Http.Get;

    var response = request.GetResponse();

    var queryString = new StreamReader(response.GetResponseStream()).ReadToEnd();

    var parts = queryString.Split(’&’); 
    var token = parts[1].Substring(parts[1].IndexOf(’=’) + 1); 
    var tokenSecret = parts[0].Substring(parts[0].IndexOf(’=’) + 1);

    queryString = String.Format("oauth_token={0}", token); 
    var authorizeUrl = “http://www.MagentoWebsite.com/admin/oauth_authorize?”+queryString; 
    Process.Start(authorizeUrl); 
}

不幸的是，这会返回BAD REQUEST响应。

4

4 回答 4

7

我最近为 Magento 启动了一个 C# REST API 客户端项目，可能会对您有所帮助：

https://github.com/nickvane/Magento-RestApi

它还没有完成功能，但是实现了 oauth 身份验证。该代码使用支持 oauth 身份验证的restsharp 。

于 2013-05-10T18:01:42.350 回答
3

我有同样的问题，但找不到答案，因此我花了一天时间让它工作。我在这里分享我的代码，我希望它能帮助该功能的其他人。

在 aspx 页面中使用以下代码获取 oAuth 访问权限

        protected void Page_Load(object sender, EventArgs e)
    {
        string oauth_token = Request.QueryString["oauth_token"];
        string oauth_verifier = Request.QueryString["oauth_verifier"];

        if (string.IsNullOrEmpty(oauth_token) || string.IsNullOrEmpty(oauth_verifier))
        {
            BeginAuthorization();
        }
        else
        {
            Authorize(oauth_token,oauth_verifier);
        }
    }

    private void Authorize(string oauth_token, string oauth_verifier)
    {
        var uri = new Uri(MagentoServer + "/oauth/token");
        string oauth_token_secret = (string)Session["oauth_token_secret"];

        OAuthBase oAuth = new OAuthBase();
        string nonce = oAuth.GenerateNonce();
        string timeStamp = oAuth.GenerateTimeStamp();
        string parameters;
        string normalizedUrl;
        string signature = oAuth.GenerateSignature(uri, ConsumerKey, ConsumerSecret,
        oauth_token,oauth_token_secret, "GET", timeStamp, nonce, OAuthBase.SignatureTypes.PLAINTEXT,
        out normalizedUrl, out parameters);

        StringBuilder sb = new StringBuilder("OAuth ");
        sb.AppendFormat("oauth_verifier=\"{0}\",", oauth_verifier);
        sb.AppendFormat("oauth_token=\"{0}\",", oauth_token);
        sb.AppendFormat("oauth_version=\"{0}\",", "1.0");
        sb.AppendFormat("oauth_signature_method=\"{0}\",", "PLAINTEXT");
        sb.AppendFormat("oauth_nonce=\"{0}\",", nonce);
        sb.AppendFormat("oauth_timestamp=\"{0}\",", timeStamp);
        sb.AppendFormat("oauth_consumer_key=\"{0}\",", ConsumerKey);
        sb.AppendFormat("oauth_signature=\"{0}\"", signature);

        var request = (HttpWebRequest)WebRequest.Create(uri);
        request.Headers[HttpRequestHeader.Authorization] = sb.ToString();
        request.ContentType = "text/xml";
        request.Accept = "text/xml";
        request.KeepAlive = true;
        request.Method = "POST";

        try
        {
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            if (response.StatusCode == HttpStatusCode.OK)
            {

                Stream responseStream = response.GetResponseStream();
                StreamReader responseReader = new StreamReader(responseStream);
                string text = responseReader.ReadToEnd();
                try
                {
                    Dictionary<String, string> responseDic = GetDictionaryFromQueryString(text);

                    string token = responseDic.First(q => q.Key == "oauth_token").Value;
                    string secret = responseDic.First(q => q.Key == "oauth_token_secret").Value;

                    Configuration objConfig = System.Web.Configuration.WebConfigurationManager.OpenWebConfiguration("~");
                    AppSettingsSection objAppsettings = (AppSettingsSection)objConfig.GetSection("appSettings");
                    //Edit
                    if (objAppsettings != null)
                    {
                        objAppsettings.Settings["Magento.Token"].Value = token;
                        objAppsettings.Settings["Magento.TokenSecret"].Value = secret;
                        objConfig.Save();
                    }

                    errorLabel.Text = "Done";
                    errorLabel.ForeColor = System.Drawing.Color.Green;

                }
                catch (Exception ex)
                {
                    errorLabel.Text = "Exchanging token failed.<br>Response text = " + text + "<br>Exception = " + ex.Message;
                }
            }
        }
        catch (WebException ex)
        {
            var responseStream = ex.Response.GetResponseStream();
            StreamReader responseReader = new StreamReader(responseStream);
            string resp = responseReader.ReadToEnd();
            errorLabel.Text = resp;
        }

    }

    private void BeginAuthorization()
    {
        string CallbackUrl = Server.UrlEncode(Request.Url.AbsoluteUri);
        var uri = new Uri(MagentoServer + "/oauth/initiate?oauth_callback=" + CallbackUrl);

        OAuthBase oAuth = new OAuthBase();
        string nonce = oAuth.GenerateNonce();
        string timeStamp = oAuth.GenerateTimeStamp();
        string parameters;
        string normalizedUrl;
        string signature = oAuth.GenerateSignature(uri, ConsumerKey, ConsumerSecret,
        String.Empty, String.Empty, "GET", timeStamp, nonce, OAuthBase.SignatureTypes.PLAINTEXT,
        out normalizedUrl, out parameters);

        StringBuilder sb = new StringBuilder("OAuth ");
        sb.AppendFormat("oauth_callback=\"{0}\",", CallbackUrl);
        sb.AppendFormat("oauth_version=\"{0}\",", "1.0");
        sb.AppendFormat("oauth_signature_method=\"{0}\",", "PLAINTEXT");
        sb.AppendFormat("oauth_nonce=\"{0}\",", nonce);
        sb.AppendFormat("oauth_timestamp=\"{0}\",", timeStamp);
        sb.AppendFormat("oauth_consumer_key=\"{0}\",", ConsumerKey);
        sb.AppendFormat("oauth_signature=\"{0}\"", signature);

        var request = (HttpWebRequest)WebRequest.Create(uri);
        request.Headers[HttpRequestHeader.Authorization] = sb.ToString();
        request.ContentType = "text/xml";
        request.Accept = "text/xml";
        request.KeepAlive = true;
        request.Method = "GET";

        try
        {
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            if (response.StatusCode == HttpStatusCode.OK)
            {

                Stream responseStream = response.GetResponseStream();
                StreamReader responseReader = new StreamReader(responseStream);
                string text = responseReader.ReadToEnd();
                try
                {
                    Dictionary<String, string> dic = GetDictionaryFromQueryString(text);

                    string oauth_token = dic.First(q => q.Key == "oauth_token").Value;
                    string oauth_token_secret = dic.First(q => q.Key == "oauth_token_secret").Value;
                    Session["oauth_token_secret"] = oauth_token_secret;
                    string redirectUrl = MagentoServer + "/index.php/admin/oauth_authorize?oauth_token=" + oauth_token + "&oauth_verifier=" +
                        oauth_token_secret;
                    Response.Redirect(redirectUrl);

                }
                catch (Exception ex)
                {
                    errorLabel.Text = "Parsing request token failed.<br>Response text = " + text + "<br>Exception = " + ex.Message;
                }

            }
        }
        catch (WebException ex)
        {
            var responseStream = ex.Response.GetResponseStream();
            StreamReader responseReader = new StreamReader(responseStream);
            string resp = responseReader.ReadToEnd();
            errorLabel.Text = resp;
        }
    }

    private static Dictionary<string, string> GetDictionaryFromQueryString(string queryString)
    {
        string[] parts = queryString.Split('&');
        Dictionary<String, string> dic = new Dictionary<string, string>();
        foreach (var part in parts)
        {
            dic.Add(part.Split('=')[0], part.Split('=')[1]);
        }
        return dic;
    }

    #region Settings

    string MagentoServer
    {
        get
        {
            return ConfigurationManager.AppSettings["Magento.Server"];
        }
    }

    string ConsumerKey
    {
        get
        {
            return ConfigurationManager.AppSettings["Magento.ConsumerKey"];
        }
    }

    string ConsumerSecret
    {
        get
        {
            return ConfigurationManager.AppSettings["Magento.ConsumerSecret"];
        }
    }

    #endregion
}

在类文件中添加以下代码

public class ApiClient
{

    public ApiClient(string magentoServer, string consumerKey, string consumerSecret, string accessToken, string accessTokenSeccret)
    {
        MagentoServer = magentoServer;
        ConsumerKey = consumerKey;
        ConsumerSecret = consumerSecret;
        AccessToken = accessToken;
        AccessTokenSecret = accessTokenSeccret;
    }

    #region Request

    HttpWebRequest CreateAuthorizedRequest(string url, string requestMethod,ApiFilter filter)
    {
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url + "?" + filter.ToString());

        OAuthBase oAuth = new OAuthBase();
        string nonce = oAuth.GenerateNonce();
        string timeStamp = oAuth.GenerateTimeStamp();
        string parameters;
        string normalizedUrl;
        string signature = oAuth.GenerateSignature(new Uri(url), ConsumerKey, ConsumerSecret,
        AccessToken, AccessTokenSecret, requestMethod, timeStamp, nonce, OAuthBase.SignatureTypes.PLAINTEXT,
        out normalizedUrl, out parameters);

        StringBuilder sb = new StringBuilder("OAuth ");
        sb.AppendFormat("oauth_token=\"{0}\",", AccessToken);
        sb.AppendFormat("oauth_version=\"{0}\",", "1.0");
        sb.AppendFormat("oauth_signature_method=\"{0}\",", "PLAINTEXT");
        sb.AppendFormat("oauth_nonce=\"{0}\",", nonce);
        sb.AppendFormat("oauth_timestamp=\"{0}\",", timeStamp);
        sb.AppendFormat("oauth_consumer_key=\"{0}\",", ConsumerKey);
        sb.AppendFormat("oauth_signature=\"{0}\"", signature);

        request.Headers[HttpRequestHeader.Authorization] = sb.ToString();
        request.Method = requestMethod;

        //request.ContentType = "application/json";
        request.Accept = "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8";//application/json,
        request.KeepAlive = true;

        return request;
    }

    string FetchRequest(HttpWebRequest request)
    {
        try
        {
            string responseText = string.Empty;
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            if (response.StatusCode == HttpStatusCode.OK)
            {
                using (Stream responseStream = response.GetResponseStream())
                {
                    using (StreamReader responseReader = new StreamReader(responseStream))
                    {
                        responseText = responseReader.ReadToEnd();
                        return responseText;
                    }
                }
            }

            return responseText;
        }
        catch (WebException ex)
        {
            var responseStream = ex.Response.GetResponseStream();
            StreamReader responseReader = new StreamReader(responseStream);
            string responseText = responseReader.ReadToEnd();
            throw new MagentoApiException(responseText,ex.Status);
        }
    }

    #endregion

    #region Public properties

    string MagentoServer { get; set; }

    string ConsumerKey { get; set; }

    string ConsumerSecret { get; set; }

    string AccessToken { get; set; }

    string AccessTokenSecret { get; set; }

    #endregion

}


public class ApiFilter
{
    public ApiFilter()
    {
        filterDescriptions = new List<FilterDescription>();
    }

    public int? Page { get; set; }
    public int? Limit { get; set; }
    public List<FilterDescription> filterDescriptions;

    public const string Type = "rest";

    public void AddFilter(string column, FilterType filterType, string value)
    {
        filterDescriptions.Add(new FilterDescription()
        {
            Column = column,
            FilterType = filterType,
            Value = value
        });
    }

    public override string ToString()
    {
        StringBuilder sb = new StringBuilder();
        sb.AppendFormat("type={0}", Type);

        if (Page.HasValue)
            sb.AppendFormat("&page={0}", Page.Value);
        if (Limit.HasValue)
            sb.AppendFormat("&limit={0}", Limit.Value);

        int counter = 1;
        foreach (var filter in filterDescriptions)
        {

            sb.AppendFormat("&filter[{0}][attribute]={1}&filter[{2}][{3}]={4}", counter, filter.Column, counter, filter.FilterType, filter.Value);
            counter++;
        }

        return sb.ToString();
    }
}

public class FilterDescription
{
    public string Column { get; set; }
    public FilterType FilterType { get; set; }
    public string Value { get; set; }
}

public enum FilterType
{
    /// <summary>
    /// Not Equal To
    /// </summary>
    neq,
    /// <summary>
    /// equals any of
    /// </summary>
    @in,
    /// <summary>
    /// not equals any of
    /// </summary>
    nin,
    /// <summary>
    /// greater than
    /// </summary>
    gt,
    /// <summary>
    /// less than
    /// </summary>
    lt

}

public class MagentoApiException : Exception
{

    public MagentoApiException(string responseText, WebExceptionStatus status)
    {
        ResponseText = responseText;
        Status = status;
    }

    public string ResponseText { get; set; }
    public WebExceptionStatus Status { get; set; }
}

也不要忘记将https://oauth.googlecode.com/svn/code/csharp/OAuthBase.cs添加到项目中

可以使用了。从 api 读取：

var request = CreateAuthorizedRequest(MagentoServer + "/api/rest/products", "get", new ApiFilter() {Page = 1 });
            var responseText = FetchRequest(request);

Magento REST Api 文档可以在这里找到

于 2014-07-13T10:43:21.330 回答
0

您可以使用 Spring.NET Social 快速创建客户端 REST API： http ://www.springframework.net/social/

Magento 使用类似于 Twitter 的 OAuth 1.0a 身份验证。您可以在这里查看 Twitter 实现： http ://www.springframework.net/social-twitter/

以及带有分步说明的相关文档： http ://www.springframework.net/social/refdoc/implementing.html

于 2012-07-18T15:17:32.217 回答
0

我不确定这是否有帮助，但是一旦我能够从 Magento 获取 oauth_token 和 oauth_token_secret（我使用 PHP Magento 示例来获取它），我就能够通过将所有内容放入 requestUri 中来查询 REST API标题。

您的示例帮助我使大部分代码正确，并对其进行了一些修改（这里有一个小片段）：

            StringBuilder sb = new StringBuilder("OAuth ");
            sb.AppendFormat("oauth_version={0},", "1.0");
            sb.AppendFormat("oauth_signature_method={0},", "HMAC-SHA1");
            sb.AppendFormat("oauth_nonce={0},", nonce);
            sb.AppendFormat("oauth_timestamp={0},", timeStamp);
            sb.AppendFormat("oauth_consumer_key={0},", consumerKey);
            sb.AppendFormat("oauth_token={0},", oauth_token);
            sb.AppendFormat("oauth_signature={0}", sig);

            Debug.WriteLine(sb.ToString());
            var request = (HttpWebRequest)WebRequest.Create((resourceUrl));
            request.Headers[HttpRequestHeader.Authorization] = sb.ToString();
            request.ContentType = "text/xml";
            request.Accept = "text/xml";
            request.KeepAlive = true;
            //request.Method = WebRequestMethods.Http.Get;
            request.Method = "GET";

            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            Debug.WriteLine(response.StatusCode);
            Debug.WriteLine(response.Server);
            if (response.StatusCode == HttpStatusCode.OK)
            {

                Stream responseStream = response.GetResponseStream();
                StreamReader responseReader = new StreamReader(responseStream);
                XmlDocument xmlDoc = new XmlDocument();
                xmlDoc.Load(response.GetResponseStream());
                Dts.Variables["User::XML_Response"].Value = xmlDoc.OuterXml.ToString();

            }

这有帮助吗？

于 2013-01-18T22:09:38.727 回答