c#中利用Tu Share获取股票交易信息

三、Http API说明

Tushare HTTP数据获取的方式，采用了post的机制，通过提交JSON body参数，就可以获得您想要的数据。具体参数说明如下：

输入参数

api_name：接口名称，比如stock_basic

token ：用户唯一标识，可通过登录pro网站获取

params：接口参数，如daily接口中start_date和end_date

fields：字段列表，用于接口获取指定的字段，以逗号分隔，如"open,high,low,close"

输出参数

code： 接口返回码，2002表示权限问题。

msg：错误信息，比如“系统内部错误”，“没有权限”等

data：数据，data里包含fields和items字段，分别为字段和数据内容

四、c#(.net core)实现

1、在Visual Studio中安装下面几个包：Microsoft.Extensions.Http、Newtonsoft.Json

2、封装方法，实现对REST web service的调用

public interface IHttpClientUtility
{
 string HttpClientPost(string url, object datajson);
}

public class HttpClientUtility : IHttpClientUtility
 {
 

 public HttpClientUtility()
 {
 
 }
 public string HttpClientPost(string url, object datajson)
 {
 using (HttpClient httpClient = new HttpClient()) //http对象
 {
 httpClient.DefaultRequestHeaders.Accept.Clear();
 httpClient.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
 httpClient.Timeout = new TimeSpan(0, 0, 5);
 //转为链接需要的格式
 HttpContent httpContent = new JsonContent(datajson);
 //请求
 HttpResponseMessage response = httpClient.PostAsync(url, httpContent).Result;
 if (response.IsSuccessStatusCode)
 {
  Task<string> t = response.Content.ReadAsStringAsync();
  return t.Result;
 }
 throw new Exception("调用失败");
 }
     
 }
 }

public class JsonContent : StringContent
 {
 public JsonContent(object value)
 : base(JsonConvert.SerializeObject(value), Encoding.UTF8,
 "application/json")
 {
 }

 public JsonContent(object value, string mediaType)
 : base(JsonConvert.SerializeObject(value), Encoding.UTF8, mediaType)
 {
 }
 }

3、封装对Tu Share API的调用

public class TuShareUtility 
 {
 private IHttpClientUtility _httpClientUtility;
 private string _url = "http://api.waditu.com/";
 
 public TuShareUtility(IHttpClientUtility httpClientUtility)
 {
 _httpClientUtility = httpClientUtility;
 }

 /// <summary>
 /// 调用TuShare API
 /// </summary>
 /// <param name="apiName"></param>
 /// <param name="parmaMap"></param>
 /// <param name="fields"></param>
 /// <returns></returns>
 public DataTable GetData(string apiName,Dictionary<string,string> parmaMap,params string[] fields)
 {
 var tuShareParamObj=new TuShareParamObj(){ ApiName = apiName ,Params = parmaMap,Fields = string.Join(",",fields)};
 //做Http调用
 var result=_httpClientUtility.HttpClientPost(_url, tuShareParamObj);
 //将返回结果序列化成对象
 var desResult=JsonConvert.DeserializeObject<TuShareResult>(result);
 //如果调用失败，抛出异常
 if(!string.IsNullOrEmpty(desResult.Msg))
 throw new Exception(desResult.Msg);
 //返回结果分成两部分，一部分是列头信息，另一部分是数据本身，用这两部分数据可以构建DataTable
 DataTable dt = new DataTable();
 foreach (var dataField in desResult.Data.Fields)
 {
 dt.Columns.Add(dataField);
 }

 foreach (var dataItemRow in desResult.Data.Items)
 {
 var newdr=dt.NewRow();
 for (int i=0;i< dataItemRow.Length;i++)
 {
  newdr[i] = dataItemRow[i];
 }

 dt.Rows.Add(newdr);
 }
 return dt;
 }

 private class TuShareParamObj
 {
 [JsonProperty("api_name")]
 public string ApiName { get; set; }

 [JsonProperty("token")]
 public string Token { get; } = "****************";//你的Token

 [JsonProperty("params")]
 public Dictionary<string, string> Params { get; set; }

 [JsonProperty("fields")]
 public string Fields { get; set; }
 }

 private class TuShareData
 {
 [JsonProperty("fields")]
 public string[] Fields { get; set; }

 [JsonProperty("items")]
 public string[][] Items { get; set; }
 }

 private class TuShareResult
 {
 [JsonProperty("code")]
 public string Code { get; set; }

 [JsonProperty("msg")]
 public string Msg { get; set; }

 [JsonProperty("data")]
 public TuShareData Data { get; set; }
 }
 }

4、调用示例

获得日线行情，整个过程1秒左右，返回6月24日，股票相关交易信息，代码如下，(该网站的其它接口定义可以到https://tushare.pro/document/2查看)

var tuShareUtility=new TuShareUtility();
Dictionary<string, string> p = new Dictionary<string, string>();
p["trade_date"] = "20200624";
var table = tuShareUtility.GetData("daily", p, "");

返回如下结果

返回字段说明