using AlibabaSDK.Setting;
|
using CommonUtil;
|
using CommonUtil.Web;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Net;
|
using System.Security.Cryptography;
|
using System.Text;
|
using CommonUtil;
|
using System.Web;
|
|
|
namespace AlibabaSDK.Api
|
{
|
public class AliabaClient
|
{
|
/// <summary>
|
/// 执行TOP公开API请求
|
/// </summary>
|
/// <typeparam name="T"></typeparam>
|
/// <param name="request"></param>
|
/// <param name="appKey"></param>
|
/// <param name="secretKey"></param>
|
/// <returns></returns>
|
public static T Execute<T>(IAlibabaApiRequest<T> request, string sessionKey) where T : AlibabaApiResponse
|
{
|
T t = null;
|
try
|
{
|
// request.Validate();
|
string Method = request.GetApiName();
|
string PostUrl = AlibabaApiSet.G1OfficialUrl;
|
string appKey = AlibabaApiSet.AppKey;
|
string secretKey = AlibabaApiSet.SecretKey;
|
long timeStamp = ExtendUtil.EncodeUnixMillisecond(DateTime.Now);
|
//系统级参数
|
string baseUrl = $"{Method}/{appKey}";
|
PostUrl += $"{baseUrl}";
|
//获取应用级参数
|
Dictionary<string, object> paramers = request.GetParameters();
|
paramers.Add("access_token", sessionKey);
|
//计算sign
|
string sign = GetSign(baseUrl, paramers);
|
//paramers.Add("_aop_timestamp", timeStamp.ToString());
|
paramers.Add("_aop_signature", sign);
|
string paramStr = string.Empty;
|
foreach (var pa in paramers)
|
{
|
paramStr += paramStr.IsNullOrEmpty() ? $"?" : "&";
|
Type ty = pa.Value.GetType();
|
if ("string,long,int,douber,decimal".Contains(ty.Name.ToLower()))
|
{
|
paramStr += $"{ pa.Key}={ pa.Value}";
|
}
|
else
|
{
|
paramStr += $"{ pa.Key}={ JSONUtil.ObjectToJson(pa.Value).ToUrlEncode()}";
|
}
|
}
|
IDictionary<string, object> postDic = JSONUtil.JsonToObject<IDictionary<string, object>>(JsonConvert.SerializeObject(paramers));
|
//Post请求数据
|
PostUrl += paramStr;
|
|
//string responseStr = new WebUtil().DoPost(PostUrl, text, null);
|
string responseStr = Post(PostUrl);
|
if (responseStr.IsNullOrEmpty())
|
{
|
return null;
|
}
|
t = JsonConvert.DeserializeObject<T>(responseStr);
|
t.Body = responseStr;
|
}
|
catch (Exception exe)
|
{
|
LogUtil.Error(exe.ToString(), "1688sdk错误");
|
t = request.ErrorObj() as T;
|
if (t != null)
|
{
|
t.ErrorMsg = exe.Message;
|
t.ErrorCode = "-32606";
|
}
|
t.Body = "";
|
}
|
return t;
|
}
|
|
//urlPath: 基础url部分，格式为protocol/apiVersion/namespace/apiName/appKey，如 json/1/system/currentTime/1；如果为客户端授权时此参数置为空串""
|
//paramDic: 请求参数，即queryString + request body 中的所有参数
|
private static string GetSign(string urlPath, Dictionary<string, object> paramDic)
|
{
|
if (urlPath.StartsWith("/"))
|
{
|
urlPath = urlPath.Substring(1, urlPath.Length - 1);
|
}
|
byte[] signatureKey = Encoding.UTF8.GetBytes(AlibabaApiSet.SignKey);//此处用自己的签名密钥
|
List<string> list = new List<string>();
|
foreach (KeyValuePair<string, object> kv in paramDic)
|
{
|
|
Type ty = kv.Value.GetType();
|
if ("string,long,int,douber,decimal".Contains(ty.Name.ToLower()))
|
{
|
list.Add(kv.Key + kv.Value.ToString());
|
}
|
else
|
{
|
list.Add(kv.Key + JSONUtil.ObjectToJson(kv.Value));
|
}
|
}
|
list.Sort();
|
string tmp = urlPath;
|
foreach (string kvstr in list)
|
{
|
tmp = tmp + kvstr;
|
}
|
|
//HMAC-SHA1
|
HMACSHA1 hmacsha1 = new HMACSHA1(signatureKey);
|
byte[] hashBytes = hmacsha1.ComputeHash(Encoding.UTF8.GetBytes(tmp));
|
byte[] hash = hmacsha1.Hash;
|
//TO HEX
|
return BitConverter.ToString(hashBytes).Replace("-", "").ToUpper();
|
}
|
|
public static string Post(string Url)
|
{
|
string strURL = Url;
|
//创建一个HTTP请求
|
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(strURL);
|
//Post请求方式
|
request.Method = "POST";
|
//内容类型
|
// request.ContentType = "application/x-www-form-urlencoded";
|
|
//设置参数，并进行URL编码
|
|
// string paraUrlCoded = jsonParas;//System.Web.HttpUtility.UrlEncode(jsonParas);
|
|
byte[] payload;
|
//将Json字符串转化为字节
|
// payload = System.Text.Encoding.UTF8.GetBytes(paraUrlCoded);
|
//设置请求的ContentLength
|
// request.ContentLength = payload.Length;
|
//发送请求，获得请求流
|
|
Stream writer;
|
try
|
{
|
writer = request.GetRequestStream();//获取用于写入请求数据的Stream对象
|
}
|
catch (Exception)
|
{
|
writer = null;
|
Console.Write("连接服务器失败!");
|
}
|
//将请求参数写入流
|
// writer.Write(null, 0, 0);
|
writer.Close();//关闭请求流
|
// String strValue = "";//strValue为http响应所返回的字符流
|
HttpWebResponse response;
|
try
|
{
|
//获得响应流
|
response = (HttpWebResponse)request.GetResponse();
|
}
|
catch (WebException ex)
|
{
|
response = ex.Response as HttpWebResponse;
|
}
|
Stream s = response.GetResponseStream();
|
// Stream postData = Request.InputStream;
|
StreamReader sRead = new StreamReader(s);
|
string postContent = sRead.ReadToEnd();
|
sRead.Close();
|
Console.ForegroundColor = ConsoleColor.Cyan;
|
Console.WriteLine($"服务端返回信息：{postContent},时间：{DateTime.Now.ToString()}");
|
|
|
return postContent;//返回Json数据
|
}
|
}
|
}
|
