using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Net;
|
using System.Text;
|
using Jayrock.Json.Conversion;
|
using YouZanSDKStandard.Api.Request;
|
using YouZanSDK.Setting;
|
using CommonUtil.Web;
|
using CommonUtil;
|
|
namespace YouZanSDKStandard.Api
|
{
|
public class YouZanClient
|
{
|
/// <summary>
|
/// 调用接口
|
/// </summary>
|
/// <typeparam name="T"></typeparam>
|
/// <param name="request"></param>
|
/// <returns></returns>
|
public static T Execute<T>(IRequest<T> request) where T : YouZanResponse
|
{
|
return Execute<T>(request, string.Empty);
|
}
|
|
|
/// <summary>
|
/// 调用接口
|
/// </summary>
|
/// <typeparam name="T"></typeparam>
|
/// <param name="request"></param>
|
/// <param name="SessionKey"></param>
|
/// <returns></returns>
|
public static T Execute<T>(IRequest<T> request, string SessionKey) where T : YouZanResponse
|
{
|
T t = null;
|
|
#region 检验参数
|
request.Validate();
|
#endregion
|
|
|
//接口参数
|
IDictionary<string, object> dict = request.GetParameters();
|
//Dictionary<string, object> dict = new Dictionary<string, object>();
|
//foreach (var dic in dictionary)
|
//{
|
// dict.Add(dic.Key, dic.Value);
|
//}
|
string reStr = "";
|
YouZanResponse rspBase = null;
|
try
|
{
|
string apiUrl = YouZanSetting.GetApiUrl(request.GetApiName(), request.GetApiVersion(), SessionKey);
|
//reStr = PostJson(apiUrl, dict);
|
reStr = new WebUtil().DoPostWithJson(apiUrl, dict, null);
|
//if (!reStr.Contains("true"))
|
// LogTextHelper.WriteLine("有赞接口返回错误信息", reStr);
|
|
try
|
{
|
//rspBase = JsonConvert.Import(typeof(YouZanResponse), reStr) as YouZanResponse;
|
rspBase = JSONUtil.JsonToObject<YouZanResponse>(reStr);
|
}
|
catch (Exception e)
|
{
|
LogTextHelper.WriteLine("有赞接口转换错误", reStr);
|
}
|
|
if (rspBase != null)
|
{
|
if (rspBase.success)
|
{
|
try
|
{
|
reStr = request.ResponseJsonPrefix(reStr);
|
// t = JsonConvert.Import(typeof(T), reStr) as T;
|
t= JSONUtil.JsonToObject<T>(reStr);
|
}
|
catch (Exception ex)
|
{
|
LogTextHelper.WriteLine("有赞接口转换错误1", reStr);
|
rspBase = new YouZanResponse
|
{
|
code = 500,
|
success = false,
|
message = "接口调用异常" + ex.ToString() + "接口返回：" + reStr,
|
};
|
|
t = (T)rspBase;
|
}
|
}
|
else
|
{
|
reStr = request.ResponseJsonPrefix(reStr);
|
t = JSONUtil.JsonToObject<T>(reStr);
|
}
|
}
|
else
|
{
|
rspBase = new YouZanResponse
|
{
|
code = 500,
|
success = false,
|
message = "接口调用异常接口返回：" + reStr,
|
};
|
|
t = (T)rspBase;
|
}
|
}
|
catch (Exception ex)
|
{
|
rspBase = new YouZanResponse
|
{
|
code = 500,
|
success = false,
|
message = "接口调用异常" + ex.ToString() + "接口返回：" + reStr,
|
};
|
|
t = (T)rspBase;
|
}
|
if (t == null)
|
{
|
rspBase = new YouZanResponse
|
{
|
code = 500,
|
success = false,
|
message = "接口调用异常接口返回：" + reStr,
|
};
|
|
t = (T)rspBase;
|
}
|
|
return t;
|
#region 旧sdk废弃
|
/*
|
//youzan.items.get 长度16
|
int num = apiName.LastIndexOf(".");//num=12
|
string text = apiName.Substring(0, num);//text="youzan.items"
|
string text2 = apiName.Substring(num + 1, apiName.Length - (num + 1));//text2="get"
|
string postUrl = YouZanSetting.OfficialCallUrl + "/" + text + "/3.1.0/" + text2;
|
string postPar = "?access_token=" + SessionKey;
|
if (dictionary.Count > 0)
|
{
|
foreach (var item in dictionary )
|
{
|
postPar += "&" + item.Key + "=" + item.Value;
|
}
|
}
|
// string reStr = postMethod(postUrl, postPar, false);
|
Auth auth = new Token(SessionKey);
|
YZClient yzClient = new DefaultYZClient(auth);
|
string reStr="" ;
|
switch (apiName)
|
{
|
case "youzan.scrm.customer.search": reStr = yzClient.Invoke(apiName, "3.1.0", "Post", dict, null); ; break;
|
case "youzan.trades.sold.outer.get": reStr = yzClient.Invoke(apiName, "3.0.0", "get", dict, null); ; break;
|
case "youzan.trades.sold.get": reStr = yzClient.Invoke(apiName, "4.0.0", "get", dict, null); ; break;
|
}
|
YouZanResponse rspBase;
|
try
|
{
|
rspBase = JsonConvert.Import(typeof(YouZanResponse), reStr) as YouZanResponse;
|
|
if (rspBase != null)
|
{
|
if (rspBase.error_response != null)
|
{
|
rspBase.IsError = true;
|
}
|
|
|
|
|
#region 返回值处理
|
if (rspBase.IsError)
|
{
|
t = (T) rspBase;
|
}
|
else
|
{
|
#region Response对象处理
|
try
|
{
|
reStr = request.ResponseJsonPrefix(reStr);
|
t = JsonConvert.Import(typeof(T), reStr) as T;
|
}
|
catch(Exception ex)
|
{
|
string exStr = ex.ToString();
|
}
|
#endregion
|
}
|
#endregion
|
|
}
|
else
|
{
|
rspBase = new YouZanResponse
|
{
|
IsError = true,
|
error_response = {msg = "接口调用异常"}
|
};
|
t = (T)rspBase;
|
}
|
}
|
catch (Exception ex)
|
{
|
rspBase = new YouZanResponse
|
{
|
IsError = true,
|
error_response = { msg = "接口调用异常" }
|
};
|
t = (T) rspBase;
|
}
|
return t;
|
*/
|
#endregion
|
}
|
|
|
|
|
|
/// <summary>
|
/// post调用求情
|
/// </summary>
|
/// <param name="postUrl">请求地址</param>
|
/// <param name="pars">请求参数</param>
|
/// <param name="isLogin"></param>
|
/// <returns></returns>
|
private static string postMethod(string postUrl, string pars, bool isLogin = false)
|
{
|
byte[] postData = System.Text.Encoding.UTF8.GetBytes(pars);
|
System.Net.HttpWebRequest request = (System.Net.HttpWebRequest)System.Net.WebRequest.Create(postUrl);
|
request.ContentType = "application/x-www-form-urlencoded";
|
request.Method = "post";
|
request.Timeout = 5000;
|
request.ContentLength = postData.Length;
|
|
System.IO.Stream requestStream = request.GetRequestStream();
|
requestStream.Write(postData, 0, postData.Length);
|
requestStream.Close();
|
|
System.Net.HttpWebResponse response = (System.Net.HttpWebResponse)request.GetResponse();
|
|
var ecoding = isLogin ? Encoding.Default : Encoding.UTF8;
|
|
System.IO.StreamReader sr = new System.IO.StreamReader(response.GetResponseStream(), ecoding);
|
|
string str = sr.ReadToEnd();//读取获取到的参数
|
sr.Close();
|
response.Close();
|
return str;
|
|
}
|
|
/// <summary>
|
/// PostJson请求
|
/// </summary>
|
/// <param name="url"></param>
|
/// <param name="postObj"></param>
|
/// <returns></returns>
|
public static string PostJson(string url, object postObj)
|
{
|
var httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
|
httpWebRequest.ContentType = "application/json";
|
httpWebRequest.Method = "POST";
|
var postData = Jayrock.Json.Conversion.JsonConvert.ExportToString(postObj);
|
using (var streamWriter = new StreamWriter(httpWebRequest.GetRequestStream()))
|
{
|
streamWriter.Write(postData);
|
streamWriter.Flush();
|
streamWriter.Close();
|
}
|
var httpResponse = (HttpWebResponse)httpWebRequest.GetResponse();
|
using (var streamReader = new StreamReader(httpResponse.GetResponseStream()))
|
{
|
var result = streamReader.ReadToEnd();
|
return result;
|
}
|
}
|
|
public static string PostJsonSpecial(string url, string postData)
|
{
|
var httpWebRequest = (HttpWebRequest)WebRequest.Create(url);
|
httpWebRequest.ContentType = "application/json";
|
httpWebRequest.Method = "POST";
|
|
using (var streamWriter = new StreamWriter(httpWebRequest.GetRequestStream()))
|
{
|
streamWriter.Write(postData);
|
streamWriter.Flush();
|
streamWriter.Close();
|
}
|
var httpResponse = (HttpWebResponse)httpWebRequest.GetResponse();
|
using (var streamReader = new StreamReader(httpResponse.GetResponseStream()))
|
{
|
var result = streamReader.ReadToEnd();
|
return result;
|
}
|
}
|
|
}
|
}
|
