chore: 初始化东安动力MES采集程序
This commit is contained in:
yexingqiang
448
Common/02WebApiCall/WebApiCall/CallWebApi.cs
Normal file
448
Common/02WebApiCall/WebApiCall/CallWebApi.cs
Normal file
@@ -0,0 +1,448 @@
|
||||
using DoWhatPlc;
|
||||
using Newtonsoft.Json;
|
||||
using System;
|
||||
using System.Collections.Concurrent;
|
||||
using System.Collections.Generic;
|
||||
using System.Data;
|
||||
using System.Data.SqlClient;
|
||||
using System.IO;
|
||||
using System.Linq;
|
||||
using System.Net;
|
||||
using System.Net.Http;
|
||||
using System.Text;
|
||||
using System.Threading.Tasks;
|
||||
|
||||
namespace DtWebApi
|
||||
{
|
||||
public class OutGUID
|
||||
{
|
||||
/// <summary>
|
||||
/// 2021.10.25.LLX
|
||||
/// </summary>
|
||||
/// <returns></returns>
|
||||
public static string Get_CS_GUID()
|
||||
{
|
||||
return Guid.NewGuid().ToString().ToUpper();
|
||||
}
|
||||
|
||||
}
|
||||
public partial class CallWebApi
|
||||
{
|
||||
public string InvokeWebapiString(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
string result = task.Result;
|
||||
return result;
|
||||
}
|
||||
public DataTable InvokeWebapiDataTable(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
var result = task.Result;
|
||||
//反序列化Json
|
||||
DataTable dt = new DataTable();
|
||||
dt = JsonConvert.DeserializeObject<DataTable>(task.Result);
|
||||
return dt;
|
||||
}
|
||||
public DataSet InvokeWebapiDataSet(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
DataSet ds = new DataSet();
|
||||
try
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
var result = task.Result;
|
||||
//反序列化Json
|
||||
ds = JsonConvert.DeserializeObject<DataSet>(task.Result);
|
||||
}
|
||||
catch
|
||||
{
|
||||
|
||||
}
|
||||
return ds;
|
||||
|
||||
|
||||
}
|
||||
|
||||
public SqlDataReader InvokeWebapiSqlDataReader(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
var result = task.Result;
|
||||
//反序列化Json
|
||||
SqlDataReader dr;
|
||||
dr = JsonConvert.DeserializeObject<SqlDataReader>(task.Result);
|
||||
return dr;
|
||||
}
|
||||
|
||||
public bool InvokeWebapiBool(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
string result = task.Result;
|
||||
return Convert.ToBoolean(result);
|
||||
}
|
||||
public int InvokeWebapiInt(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
string result = task.Result;
|
||||
return Convert.ToInt32(result);
|
||||
}
|
||||
#region WinFrom调用webapi接口通用方法
|
||||
public EngineValue InvokeWebapiEngineValue(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rt = JsonConvert.DeserializeObject<EngineValue>(task.Result);
|
||||
return rt;
|
||||
}
|
||||
public ReturnValueObject InvokeWebapiReturnValueObject(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rs = JsonConvert.DeserializeObject<ReturnValueString>(task.Result);
|
||||
if (rs == null) return null;
|
||||
var ro = rs.ReturnValueToObject();
|
||||
return ro;
|
||||
}
|
||||
public List<ReturnValueObject> InvokeWebapiReturnValueObjectList(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rsList = JsonConvert.DeserializeObject< List < ReturnValueString > >(task.Result);
|
||||
List<ReturnValueObject> roList = new List<ReturnValueObject>();
|
||||
foreach(var rs in rsList)
|
||||
{
|
||||
var ro = rs.ReturnValueToObject();
|
||||
roList.Add(ro);
|
||||
}
|
||||
|
||||
return roList;
|
||||
}
|
||||
public void InvokeWebapiWritePLC(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
|
||||
}
|
||||
//public List<ReturnValueObject> InvokeWebapiReturnValueObjectList(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics)
|
||||
//{
|
||||
// string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
// Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
// //反序列化Json
|
||||
// var rtList = JsonConvert.DeserializeObject<List<ReturnValueString>>(task.Result);
|
||||
|
||||
// List<ReturnValueObject> roList = new List<ReturnValueObject>();
|
||||
// foreach(var rt in rtList)
|
||||
// {
|
||||
// var ro = rt.ReturnValueToObject();
|
||||
// roList.Add(ro);
|
||||
// }
|
||||
// return roList;
|
||||
//}
|
||||
|
||||
public HashtableList InvokeWebapiHashtableList(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics = null)
|
||||
{
|
||||
try
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rtList = JsonConvert.DeserializeObject<HashtableList>(task.Result);
|
||||
|
||||
return rtList;
|
||||
}
|
||||
catch
|
||||
{
|
||||
return new HashtableList();
|
||||
}
|
||||
|
||||
}
|
||||
public List<TagIDTagFormat> InvokeWebapiListTagFormat(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics=null)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rtList = JsonConvert.DeserializeObject<List<TagIDTagFormat>>(task.Result);
|
||||
|
||||
return rtList;
|
||||
}
|
||||
public QualityDataSaveList InvokeWebapiQualityDataSaveList(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics = null)
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rtList = JsonConvert.DeserializeObject<QualityDataSaveList>(task.Result);
|
||||
|
||||
return rtList;
|
||||
}
|
||||
public List<string> InvokeWebapiListString(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics = null)
|
||||
{
|
||||
try
|
||||
{
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rtList = JsonConvert.DeserializeObject<List<string>>(task.Result);
|
||||
|
||||
return rtList;
|
||||
}
|
||||
catch(Exception err)
|
||||
{
|
||||
return new List<string>();
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public ConcurrentDictionary<string, TagFormat> InvokeWebapiConcurrentDictionaryTagFormat(string controlStr, string actionStr, string api, string type, Dictionary<string, string> dics = null)
|
||||
{
|
||||
|
||||
string url = GetUrlWebApi(controlStr, actionStr, dics);
|
||||
Task<string> task = InvokeWebapi(url, api, type, dics);
|
||||
//反序列化Json
|
||||
var rtList = JsonConvert.DeserializeObject<ConcurrentDictionary<string, TagFormat>>(task.Result);
|
||||
|
||||
return rtList;
|
||||
}
|
||||
|
||||
private async Task<string> InvokeWebapi(string url, string api, string type, Dictionary<string, string> dics)
|
||||
{
|
||||
string result = string.Empty;
|
||||
HttpClient client = new HttpClient();
|
||||
client.DefaultRequestHeaders.Add("authorization", "Basic YWRtaW46cGFzc3dvcmRAcmljZW50LmNvbQ==");//basic编码后授权码
|
||||
client.BaseAddress = new Uri(url);
|
||||
|
||||
client.Timeout = TimeSpan.FromSeconds(510);
|
||||
|
||||
if (type.ToLower() == "put")
|
||||
{
|
||||
HttpResponseMessage response;
|
||||
//包含复杂类型
|
||||
if (dics.Keys.Contains("input"))
|
||||
{
|
||||
if (dics != null)
|
||||
{
|
||||
foreach (var item in dics.Keys)
|
||||
{
|
||||
api = api.Replace(item, dics[item]).Replace("{", "").Replace("}", "");
|
||||
}
|
||||
}
|
||||
var contents = new StringContent(dics["input"], Encoding.UTF8, "application/json");
|
||||
response = client.PutAsync(api, contents).Result;
|
||||
if (response.IsSuccessStatusCode)
|
||||
{
|
||||
result = await response.Content.ReadAsStringAsync();
|
||||
return result;
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
var content = new FormUrlEncodedContent(dics);
|
||||
response = client.PutAsync(api, content).Result;
|
||||
if (response.IsSuccessStatusCode)
|
||||
{
|
||||
result = await response.Content.ReadAsStringAsync();
|
||||
return result;
|
||||
}
|
||||
}
|
||||
else if (type.ToLower() == "post")
|
||||
{
|
||||
var content = new FormUrlEncodedContent(dics);
|
||||
|
||||
HttpResponseMessage response = client.PostAsync(api, content).Result;
|
||||
if (response.IsSuccessStatusCode)
|
||||
{
|
||||
result = await response.Content.ReadAsStringAsync();
|
||||
return result;
|
||||
}
|
||||
}
|
||||
else if (type.ToLower() == "get")
|
||||
{
|
||||
HttpResponseMessage response = client.GetAsync(api).Result;
|
||||
|
||||
if (response.IsSuccessStatusCode)
|
||||
{
|
||||
result = await response.Content.ReadAsStringAsync();
|
||||
return result;
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
return result;
|
||||
}
|
||||
return result;
|
||||
}
|
||||
#endregion
|
||||
public static string Url_WebApi = System.Configuration.ConfigurationManager.AppSettings["Url_WebApi"];
|
||||
private string GetUrlWebApi(string controlStr,string actionStr,Dictionary<string,string> dic=null)
|
||||
{
|
||||
string url = Url_WebApi + "//api//" + controlStr + "//"+actionStr;
|
||||
//string url = Url_WebApi + "//api//" + controlStr+"1" + "//"+actionStr;
|
||||
StringBuilder builder = new StringBuilder();
|
||||
int i = 0;
|
||||
if(dic!=null)
|
||||
{
|
||||
foreach (var item in dic)
|
||||
{
|
||||
string item_Value = Utils.UrlEncode(item.Value);
|
||||
|
||||
if (i > 0)
|
||||
builder.Append("&");
|
||||
builder.AppendFormat("{0}={1}", item.Key, item_Value);
|
||||
i++;
|
||||
}
|
||||
if (i > 0)
|
||||
{
|
||||
url = url + "//?" + builder.ToString();
|
||||
}
|
||||
}
|
||||
|
||||
return url;
|
||||
}
|
||||
private string GetUrlWebApi(string controlStr, string actionStr)
|
||||
{
|
||||
string url = Url_WebApi + "//api//" + controlStr + "//" + actionStr;
|
||||
|
||||
return url;
|
||||
}
|
||||
|
||||
|
||||
#region 获取APP升级版本信息
|
||||
//public List<Versions> GetVersList()
|
||||
//{
|
||||
// string api = "";
|
||||
// List<Versions> list = new List<Versions>();
|
||||
// string url = "http://域名/api/Config/GetVersionList?ClientType=android";
|
||||
// Dictionary<string, string> dics = new Dictionary<string, string>();
|
||||
// Task<string> task = InvokeWebapi(url, api, "GET", dics);
|
||||
// string result = task.Result;
|
||||
// #region 解析结果集
|
||||
// if (result != null)
|
||||
// {
|
||||
// JObject jsonObj = null;
|
||||
// jsonObj = JObject.Parse(result);
|
||||
// DataInfo info = new DataInfo();
|
||||
// info.statusCode = Convert.ToInt32(jsonObj["statusCode"]);
|
||||
// info.message = jsonObj["message"].ToString();
|
||||
// if (info.statusCode == 1)
|
||||
// {
|
||||
// JArray jlist = JArray.Parse(jsonObj["data"].ToString());
|
||||
// for (int i = 0; i < jlist.Count; ++i) //遍历JArray
|
||||
// {
|
||||
// Versions ver = new Versions();
|
||||
// JObject tempo = JObject.Parse(jlist[i].ToString());
|
||||
// ver.VersionId = Convert.ToInt32(tempo["versionId"]);
|
||||
// ver.VersionNumber = tempo["versionNumber"].ToString();
|
||||
// ver.Description = tempo["description"].ToString();
|
||||
// ver.FilePath = tempo["filePath"].ToString();
|
||||
// ver.ClientType = tempo["clientType"].ToString();
|
||||
// ver.IsForce = Convert.ToInt32(tempo["isForce"]);
|
||||
// list.Add(ver);
|
||||
// }
|
||||
// }
|
||||
// }
|
||||
// #endregion
|
||||
// return list;
|
||||
//}
|
||||
|
||||
#endregion
|
||||
}
|
||||
|
||||
public class Post
|
||||
{
|
||||
public static string Postring(string url, Dictionary<string, string> dic)
|
||||
{
|
||||
string result = "";
|
||||
//url = "http://172.16.22.15:8000/" + url;
|
||||
HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
|
||||
req.Method = "POST";
|
||||
req.ContentType = "application/x-www-form-urlencoded";
|
||||
req.Proxy = null;
|
||||
|
||||
req.KeepAlive = false;
|
||||
|
||||
#region 添加Post 参数
|
||||
StringBuilder builder = new StringBuilder();
|
||||
int i = 0;
|
||||
foreach (var item in dic)
|
||||
{
|
||||
if (i > 0)
|
||||
builder.Append("&");
|
||||
builder.AppendFormat("{0}={1}", item.Key, item.Value);
|
||||
i++;
|
||||
}
|
||||
byte[] data = Encoding.UTF8.GetBytes(builder.ToString());
|
||||
req.ContentLength = data.Length;
|
||||
using (Stream reqStream = req.GetRequestStream())
|
||||
{
|
||||
reqStream.Write(data, 0, data.Length);
|
||||
reqStream.Close();
|
||||
}
|
||||
#endregion
|
||||
HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
|
||||
Stream stream = resp.GetResponseStream();
|
||||
|
||||
//获取响应内容
|
||||
using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
|
||||
{
|
||||
result = reader.ReadToEnd();
|
||||
}
|
||||
return result;
|
||||
}
|
||||
|
||||
public static string Postring1(string url, string token, Dictionary<string, string> dic)
|
||||
{
|
||||
string results = "";
|
||||
//url = "http://172.16.22.15:8000/" + url;
|
||||
|
||||
HttpWebRequest req = (HttpWebRequest)WebRequest.Create(url);
|
||||
req.Method = "POST";
|
||||
req.ContentType = "application/x-www-form-urlencoded";
|
||||
req.Headers.Add("Authorization", "Bearer " + token);
|
||||
#region 添加Post 参数
|
||||
StringBuilder builder = new StringBuilder();
|
||||
int i = 0;
|
||||
foreach (var item in dic)
|
||||
{
|
||||
if (i > 0)
|
||||
builder.Append("&");
|
||||
builder.AppendFormat("{0}={1}", item.Key, item.Value);
|
||||
i++;
|
||||
}
|
||||
byte[] data = Encoding.UTF8.GetBytes(builder.ToString());
|
||||
req.ContentLength = data.Length;
|
||||
try
|
||||
{
|
||||
using (Stream reqStream = req.GetRequestStream())
|
||||
{
|
||||
reqStream.Write(data, 0, data.Length);
|
||||
reqStream.Close();
|
||||
}
|
||||
#endregion
|
||||
HttpWebResponse resp = (HttpWebResponse)req.GetResponse();
|
||||
Stream stream = resp.GetResponseStream();
|
||||
//获取响应内容
|
||||
using (StreamReader reader = new StreamReader(stream, Encoding.UTF8))
|
||||
{
|
||||
results = reader.ReadToEnd();
|
||||
}
|
||||
return results;
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
Console.WriteLine(e.Message);
|
||||
return e.Message;
|
||||
throw;
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user