321 lines
13 KiB
C#
321 lines
13 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Net.Http;
|
||
using System.Text.Json;
|
||
using System.Threading.Tasks;
|
||
using BootstrapBlazor.Components;
|
||
using Microsoft.JSInterop;
|
||
using WalkingTec.Mvvm.Core;
|
||
using WalkingTec.Mvvm.Core.Extensions;
|
||
|
||
namespace WtmBlazorUtils
|
||
{
|
||
public class ApiClient
|
||
{
|
||
public HttpClient Client { get; }
|
||
private IJSRuntime js { get; }
|
||
public ApiClient(HttpClient client, IJSRuntime jsr)
|
||
{
|
||
Client = client;
|
||
js = jsr;
|
||
}
|
||
|
||
public void SetToken(string token)
|
||
{
|
||
Client.DefaultRequestHeaders.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", token);
|
||
}
|
||
|
||
#region CallApi
|
||
public async Task<ApiResult<T>> CallAPI<T>(string url, HttpMethodEnum method, HttpContent content, int? timeout = null, string proxy = null) where T : class
|
||
{
|
||
var token = await js.InvokeAsync<string>("localStorageFuncs.get", "wtmtoken");
|
||
Client.DefaultRequestHeaders.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Bearer", token);
|
||
ApiResult<T> rv = new ApiResult<T>();
|
||
try
|
||
{
|
||
if (string.IsNullOrEmpty(url))
|
||
{
|
||
return rv;
|
||
}
|
||
url = url.AppendQuery("culture=" + System.Threading.Thread.CurrentThread.CurrentUICulture.Name);
|
||
//如果配置了代理，则使用代理
|
||
//设置超时
|
||
if (timeout.HasValue)
|
||
{
|
||
Client.Timeout = new TimeSpan(0, 0, 0, timeout.Value, 0);
|
||
}
|
||
//填充表单数据
|
||
HttpResponseMessage res = null;
|
||
switch (method)
|
||
{
|
||
case HttpMethodEnum.GET:
|
||
res = await Client.GetAsync(url);
|
||
break;
|
||
case HttpMethodEnum.POST:
|
||
res = await Client.PostAsync(url, content);
|
||
break;
|
||
case HttpMethodEnum.PUT:
|
||
res = await Client.PutAsync(url, content);
|
||
break;
|
||
case HttpMethodEnum.DELETE:
|
||
res = await Client.DeleteAsync(url);
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
if (res == null)
|
||
{
|
||
return rv;
|
||
}
|
||
rv.StatusCode = res.StatusCode;
|
||
if (res.IsSuccessStatusCode == true)
|
||
{
|
||
Type dt = typeof(T);
|
||
if (dt == typeof(byte[]))
|
||
{
|
||
rv.Data = await res.Content.ReadAsByteArrayAsync() as T;
|
||
}
|
||
else
|
||
{
|
||
string responseTxt = await res.Content.ReadAsStringAsync();
|
||
if (dt == typeof(string))
|
||
{
|
||
rv.Data = responseTxt as T;
|
||
}
|
||
else
|
||
{
|
||
rv.Data = JsonSerializer.Deserialize<T>(responseTxt, CoreProgram.DefaultJsonOption);
|
||
}
|
||
}
|
||
}
|
||
else
|
||
{
|
||
if (res.StatusCode == System.Net.HttpStatusCode.Unauthorized)
|
||
{
|
||
await js.InvokeVoidAsync("localStorageFuncs.remove", "wtmtoken");
|
||
await js.InvokeVoidAsync("urlFuncs.redirect","/login");
|
||
}
|
||
string responseTxt = await res.Content.ReadAsStringAsync();
|
||
if (res.StatusCode == System.Net.HttpStatusCode.BadRequest)
|
||
{
|
||
try
|
||
{
|
||
rv.Errors = JsonSerializer.Deserialize<ErrorObj>(responseTxt, CoreProgram.DefaultJsonOption);
|
||
}
|
||
catch { }
|
||
}
|
||
rv.ErrorMsg = responseTxt;
|
||
}
|
||
|
||
return rv;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
rv.ErrorMsg = ex.ToString();
|
||
return rv;
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 使用Get方法调用api
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="domainName">Appsettings中配置的Domain key</param>
|
||
/// <param name="url">调用地址</param>
|
||
/// <param name="timeout">超时时间，单位秒</param>
|
||
/// <param name="proxy">代理地址</param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult<T>> CallAPI<T>(string url, int? timeout = null, string proxy = null) where T : class
|
||
{
|
||
HttpContent content = null;
|
||
//填充表单数据
|
||
return await CallAPI<T>(url, HttpMethodEnum.GET, content, timeout, proxy);
|
||
}
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="domainName">Appsettings中配置的Domain key</param>
|
||
/// <param name="url">调用地址</param>
|
||
/// <param name="method">调用方式</param>
|
||
/// <param name="postdata">提交字段</param>
|
||
/// <param name="timeout">超时时间，单位秒</param>
|
||
/// <param name="proxy">代理地址</param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult<T>> CallAPI<T>(string url, HttpMethodEnum method, IDictionary<string, string> postdata, int? timeout = null, string proxy = null) where T : class
|
||
{
|
||
HttpContent content = null;
|
||
//填充表单数据
|
||
if (!(postdata == null || postdata.Count == 0))
|
||
{
|
||
List<KeyValuePair<string, string>> paras = new List<KeyValuePair<string, string>>();
|
||
foreach (string key in postdata.Keys)
|
||
{
|
||
paras.Add(new KeyValuePair<string, string>(key, postdata[key]));
|
||
}
|
||
if (paras.Any())
|
||
{
|
||
url = url.AppendQuery(paras);
|
||
}
|
||
content = new FormUrlEncodedContent(paras);
|
||
}
|
||
return await CallAPI<T>(url, method, content, timeout, proxy);
|
||
}
|
||
|
||
public async Task<ApiResult<T>> CallAPI<T>(string url, HttpMethodEnum method, IDictionary<string, string> postdata, byte[] filedata, string filename, int? timeout = null, string proxy = null) where T : class
|
||
{
|
||
MultipartFormDataContent content = new MultipartFormDataContent();
|
||
//填充表单数据
|
||
if (!(postdata == null || postdata.Count == 0))
|
||
{
|
||
List<KeyValuePair<string, string>> paras = new List<KeyValuePair<string, string>>();
|
||
foreach (string key in postdata.Keys)
|
||
{
|
||
if (postdata[key] != null)
|
||
{
|
||
content.Add(new StringContent(postdata[key]), key);
|
||
}
|
||
}
|
||
}
|
||
content.Add(new ByteArrayContent(filedata), "File", filename);
|
||
|
||
return await CallAPI<T>(url, method, content, timeout, proxy);
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
/// <typeparam name="T"></typeparam>
|
||
/// <param name="domainName">Appsettings中配置的Domain key</param>
|
||
/// <param name="url">调用地址</param>
|
||
/// <param name="method">调用方式</param>
|
||
/// <param name="postdata">提交的object，会被转成json提交</param>
|
||
/// <param name="timeout">超时时间，单位秒</param>
|
||
/// <param name="proxy">代理地址</param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult<T>> CallAPI<T>(string url, HttpMethodEnum method, object postdata, int? timeout = null, string proxy = null) where T : class
|
||
{
|
||
HttpContent content = new StringContent(JsonSerializer.Serialize(postdata, CoreProgram.DefaultPostJsonOption), System.Text.Encoding.UTF8, "application/json");
|
||
return await CallAPI<T>(url, method, content, timeout, proxy);
|
||
}
|
||
|
||
public async Task<ApiResult<string>> CallAPI(string url, HttpMethodEnum method, HttpContent content, int? timeout = null, string proxy = null)
|
||
{
|
||
return await CallAPI<string>(url, method, content, timeout, proxy);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 使用Get方法调用api
|
||
/// </summary>
|
||
/// <param name="domainName">Appsettings中配置的Domain key</param>
|
||
/// <param name="url">调用地址</param>
|
||
/// <param name="timeout">超时时间，单位秒</param>
|
||
/// <param name="proxy">代理地址</param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult<string>> CallAPI(string url, int? timeout = null, string proxy = null)
|
||
{
|
||
return await CallAPI<string>(url, timeout, proxy);
|
||
}
|
||
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
/// <param name="domainName">Appsettings中配置的Domain key</param>
|
||
/// <param name="url">调用地址</param>
|
||
/// <param name="method">调用方式</param>
|
||
/// <param name="postdata">提交字段</param>
|
||
/// <param name="timeout">超时时间，单位秒</param>
|
||
/// <param name="proxy">代理地址</param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult<string>> CallAPI(string url, HttpMethodEnum method, IDictionary<string, string> postdata, int? timeout = null, string proxy = null)
|
||
{
|
||
return await CallAPI<string>(url, method, postdata, timeout, proxy);
|
||
|
||
}
|
||
|
||
/// <summary>
|
||
///
|
||
/// </summary>
|
||
/// <param name="domainName">Appsettings中配置的Domain key</param>
|
||
/// <param name="url">调用地址</param>
|
||
/// <param name="method">调用方式</param>
|
||
/// <param name="postdata">提交的object，会被转成json提交</param>
|
||
/// <param name="timeout">超时时间，单位秒</param>
|
||
/// <param name="proxy">代理地址</param>
|
||
/// <returns></returns>
|
||
public async Task<ApiResult<string>> CallAPI(string url, HttpMethodEnum method, object postdata, int? timeout = null, string proxy = null)
|
||
{
|
||
return await CallAPI<string>(url, method, postdata, timeout, proxy);
|
||
}
|
||
|
||
#endregion
|
||
|
||
public async Task<ApiResult<WtmApiResult<T>>> CallSearchApi<T>(string url, BaseSearcher searcher, QueryPageOptions options) where T : class, new()
|
||
{
|
||
searcher.Page = options.PageIndex;
|
||
searcher.Limit = options.PageItems;
|
||
if (string.IsNullOrEmpty(options.SortName) == false && options.SortOrder != SortOrder.Unset)
|
||
{
|
||
searcher.SortInfo = new SortInfo
|
||
{
|
||
Property = options.SortName,
|
||
Direction = options.SortOrder == SortOrder.Desc ? SortDir.Desc : SortDir.Asc
|
||
};
|
||
}
|
||
else
|
||
{
|
||
searcher.SortInfo = null;
|
||
}
|
||
var rv = await CallAPI<WtmApiResult<T>>(url, HttpMethodEnum.POST, searcher);
|
||
return rv;
|
||
}
|
||
|
||
public async Task<List<SelectedItem>> CallItemsApi(string url, HttpMethodEnum method = HttpMethodEnum.GET, object postdata = null, int? timeout = null, string proxy = null, string placeholder = null,List<string> values = null)
|
||
{
|
||
var result = await CallAPI<List<ComboSelectListItem>>(url, method, postdata, timeout, proxy);
|
||
List<SelectedItem> rv = new List<SelectedItem>();
|
||
if(values == null)
|
||
{
|
||
values = new List<string>();
|
||
}
|
||
if (result.StatusCode == System.Net.HttpStatusCode.OK)
|
||
{
|
||
if (result.Data != null)
|
||
{
|
||
foreach (var item in result.Data)
|
||
{
|
||
rv.Add(new SelectedItem
|
||
{
|
||
Text = item.Text,
|
||
Value = item.Value.ToString(),
|
||
Active = values.Any(x=>x.Contains(item.Value.ToString()))
|
||
});
|
||
}
|
||
}
|
||
if(string.IsNullOrEmpty(placeholder) == false)
|
||
{
|
||
rv.Insert(0, new SelectedItem
|
||
{
|
||
Text = placeholder,
|
||
Value = ""
|
||
});
|
||
}
|
||
}
|
||
return rv;
|
||
}
|
||
|
||
}
|
||
|
||
public class WtmApiResult<T>
|
||
{
|
||
public List<T> Data { get; set; }
|
||
public int Count { get; set; }
|
||
public int Page { get; set; }
|
||
public int PageCount { get; set; }
|
||
public string Msg { get; set; }
|
||
public int Code { get; set; }
|
||
}
|
||
}
|