|
@@ -1,12 +1,10 @@
|
|
|
-using System;
|
|
|
|
|
|
|
+using Newtonsoft.Json;
|
|
|
|
|
+using Newtonsoft.Json.Linq;
|
|
|
|
|
+using System;
|
|
|
using System.Collections.Generic;
|
|
using System.Collections.Generic;
|
|
|
using System.Drawing;
|
|
using System.Drawing;
|
|
|
-using System.IO;
|
|
|
|
|
-using System.Linq;
|
|
|
|
|
using System.Net.Http;
|
|
using System.Net.Http;
|
|
|
-using System.Runtime.InteropServices.ComTypes;
|
|
|
|
|
using System.Text;
|
|
using System.Text;
|
|
|
-using System.Text.Json;
|
|
|
|
|
using System.Threading.Tasks;
|
|
using System.Threading.Tasks;
|
|
|
using System.Windows.Forms;
|
|
using System.Windows.Forms;
|
|
|
using UAS_MES_NEW.CustomControl.RichText;
|
|
using UAS_MES_NEW.CustomControl.RichText;
|
|
@@ -87,103 +85,117 @@ namespace UAS_MES_NEW.Make
|
|
|
secret = secret
|
|
secret = secret
|
|
|
};
|
|
};
|
|
|
string result = await HttpHelper.PostAsync(apiUrl, dataObject);
|
|
string result = await HttpHelper.PostAsync(apiUrl, dataObject);
|
|
|
- JsonDocument doc = JsonDocument.Parse(result);
|
|
|
|
|
- JsonElement root = doc.RootElement;
|
|
|
|
|
|
|
+ JObject root = JObject.Parse(result);
|
|
|
|
|
+ JArray dataArr = (JArray)root["data"];
|
|
|
|
|
|
|
|
- JsonElement dataArr = root.GetProperty("data");
|
|
|
|
|
- if (dataArr.ValueKind == JsonValueKind.Array)
|
|
|
|
|
|
|
+ foreach (JToken item in dataArr)
|
|
|
{
|
|
{
|
|
|
- foreach (JsonElement item in dataArr.EnumerateArray())
|
|
|
|
|
- {
|
|
|
|
|
- clientId.Add(item.GetProperty("clientid").ToString());
|
|
|
|
|
- clientName.Add(item.GetProperty("clientname").ToString());
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ clientId.Add(item["clientid"].ToString());
|
|
|
|
|
+ clientName.Add(item["clientname"].ToString());
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- JsonElement nameElement = root.GetProperty("status");
|
|
|
|
|
- if (nameElement.ToString() == "200")
|
|
|
|
|
|
|
+ if (root["status"].ToString() == "200")
|
|
|
{
|
|
{
|
|
|
- ShowMsg(Msg1, 1, $"获取温湿度设备成功,已获取到{dataArr.GetArrayLength()}个");
|
|
|
|
|
|
|
+ ShowMsg(Msg1, 1, $"获取温湿度设备成功,已获取到{dataArr.Count}个");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
string basrUrl = IpPortUrlVal.Text.Trim() + "getEquipDetails";
|
|
string basrUrl = IpPortUrlVal.Text.Trim() + "getEquipDetails";
|
|
|
- for(int i = 0;i < clientId.Count;i++)
|
|
|
|
|
|
|
+ for (int i = 0; i < clientId.Count; i++)
|
|
|
{
|
|
{
|
|
|
- var paramsObj = new
|
|
|
|
|
- {
|
|
|
|
|
- secret = secret,
|
|
|
|
|
- clientId = clientId[i]
|
|
|
|
|
- };
|
|
|
|
|
- string result = await HttpHelper.PostAsync(basrUrl, paramsObj);
|
|
|
|
|
- JsonDocument doc = JsonDocument.Parse(result);
|
|
|
|
|
- JsonElement root = doc.RootElement;
|
|
|
|
|
-
|
|
|
|
|
- JsonElement nameElement = root.GetProperty("status");
|
|
|
|
|
- if (nameElement.ToString() == "200")
|
|
|
|
|
|
|
+ try
|
|
|
{
|
|
{
|
|
|
- switch (i)
|
|
|
|
|
|
|
+ var paramsObj = new
|
|
|
{
|
|
{
|
|
|
- case 1:
|
|
|
|
|
- ShowMsg(Msg2, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
- break;
|
|
|
|
|
- case 2:
|
|
|
|
|
- ShowMsg(Msg3, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
- break;
|
|
|
|
|
- case 3:
|
|
|
|
|
- ShowMsg(Msg4, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
- break;
|
|
|
|
|
- default:
|
|
|
|
|
- ShowMsg(Msg1, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
- break;
|
|
|
|
|
|
|
+ secret = secret,
|
|
|
|
|
+ clientId = clientId[i]
|
|
|
|
|
+ };
|
|
|
|
|
+ string result = await HttpHelper.PostAsync(basrUrl, paramsObj);
|
|
|
|
|
+ JObject root = JObject.Parse(result);
|
|
|
|
|
+ string status = root["status"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ if (status == "200")
|
|
|
|
|
+ {
|
|
|
|
|
+ switch (i)
|
|
|
|
|
+ {
|
|
|
|
|
+ case 1:
|
|
|
|
|
+ ShowMsg(Msg2, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
+ break;
|
|
|
|
|
+ case 2:
|
|
|
|
|
+ ShowMsg(Msg3, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
+ break;
|
|
|
|
|
+ case 3:
|
|
|
|
|
+ ShowMsg(Msg4, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
+ break;
|
|
|
|
|
+ default:
|
|
|
|
|
+ ShowMsg(Msg1, 1, $"温湿度设备:{clientName[i]},已获取并记录运行信息");
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ else
|
|
|
|
|
+ {
|
|
|
|
|
+ switch (i)
|
|
|
|
|
+ {
|
|
|
|
|
+ case 1:
|
|
|
|
|
+ ShowMsg(Msg2, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
+ break;
|
|
|
|
|
+ case 2:
|
|
|
|
|
+ ShowMsg(Msg3, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
+ break;
|
|
|
|
|
+ case 3:
|
|
|
|
|
+ ShowMsg(Msg4, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
+ break;
|
|
|
|
|
+ default:
|
|
|
|
|
+ ShowMsg(Msg1, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
+ break;
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|
|
|
|
|
+ JToken chart = root["data"]["equip"]["chart"];
|
|
|
|
|
+
|
|
|
|
|
+ string checkPoint1_T = chart["检测点01"]["当前温度"].ToString();
|
|
|
|
|
+ string checkPoint1_H = chart["检测点01"]["当前湿度"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ string checkPoint2_T = chart["检测点02"]["当前温度"].ToString();
|
|
|
|
|
+ string checkPoint2_H = chart["检测点02"]["当前湿度"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ string checkPoint3_T = chart["检测点03"]["当前温度"].ToString();
|
|
|
|
|
+ string checkPoint3_H = chart["检测点03"]["当前湿度"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ string checkPoint4_T = chart["检测点04"]["当前温度"].ToString();
|
|
|
|
|
+ string checkPoint4_H = chart["检测点04"]["当前湿度"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ string checkPoint5_T = chart["检测点05"]["当前温度"].ToString();
|
|
|
|
|
+ string checkPoint5_H = chart["检测点05"]["当前湿度"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ string average = chart["环境平均湿度"].ToString();
|
|
|
|
|
+
|
|
|
|
|
+ dh.ExecuteSql($@"INSERT INTO HUMITURE (HU_ID,HU_INDATE,CHECKPOINT1_T,CHECKPOINT1_H,CHECKPOINT2_T,CHECKPOINT2_H,CHECKPOINT3_T,CHECKPOINT3_H,
|
|
|
|
|
+ CHECKPOINT4_T,CHECKPOINT4_H,CHECKPOINT5_T,CHECKPOINT5_H,AVERAGE,EQUITYPE,EQUIID) VALUES
|
|
|
|
|
+ (HUMITURE_SEQ.NEXTVAL,sysdate,'{checkPoint1_T}','{checkPoint1_H}','{checkPoint2_T}','{checkPoint2_H}','{checkPoint3_T}','{checkPoint3_H}',
|
|
|
|
|
+ '{checkPoint4_T}','{checkPoint4_H}','{checkPoint5_T}','{checkPoint5_H}','{average}','{clientName[i]}','{clientId[i]}')", "insert");
|
|
|
}
|
|
}
|
|
|
- else
|
|
|
|
|
|
|
+ catch(Exception ex)
|
|
|
{
|
|
{
|
|
|
switch (i)
|
|
switch (i)
|
|
|
{
|
|
{
|
|
|
case 1:
|
|
case 1:
|
|
|
- ShowMsg(Msg2, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
|
|
+ ShowMsg(Msg2, 0, $"获取设备:{clientName[i]}数据时发生错误: {ex.Message}");
|
|
|
break;
|
|
break;
|
|
|
case 2:
|
|
case 2:
|
|
|
- ShowMsg(Msg3, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
|
|
+ ShowMsg(Msg3, 0, $"获取设备:{clientName[i]}数据时发生错误: {ex.Message}");
|
|
|
break;
|
|
break;
|
|
|
case 3:
|
|
case 3:
|
|
|
- ShowMsg(Msg4, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
|
|
+ ShowMsg(Msg4, 0, $"获取设备:{clientName[i]}数据时发生错误: {ex.Message}");
|
|
|
break;
|
|
break;
|
|
|
default:
|
|
default:
|
|
|
- ShowMsg(Msg1, 0, $"温湿度设备:{clientName[i]},获取运行数据异常,请检查设备");
|
|
|
|
|
|
|
+ ShowMsg(Msg1, 0, $"获取设备:{clientName[i]}数据时发生错误: {ex.Message}");
|
|
|
break;
|
|
break;
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- JsonElement chart = root.GetProperty("data").GetProperty("equip").GetProperty("chart");
|
|
|
|
|
-
|
|
|
|
|
- JsonElement checkPoint1_T = chart.GetProperty("检测点01").GetProperty("当前温度");
|
|
|
|
|
- JsonElement checkPoint1_H = chart.GetProperty("检测点01").GetProperty("当前湿度");
|
|
|
|
|
-
|
|
|
|
|
- JsonElement checkPoint2_T = chart.GetProperty("检测点02").GetProperty("当前温度");
|
|
|
|
|
- JsonElement checkPoint2_H = chart.GetProperty("检测点02").GetProperty("当前湿度");
|
|
|
|
|
-
|
|
|
|
|
- JsonElement checkPoint3_T = chart.GetProperty("检测点03").GetProperty("当前温度");
|
|
|
|
|
- JsonElement checkPoint3_H = chart.GetProperty("检测点03").GetProperty("当前湿度");
|
|
|
|
|
-
|
|
|
|
|
- JsonElement checkPoint4_T = chart.GetProperty("检测点04").GetProperty("当前温度");
|
|
|
|
|
- JsonElement checkPoint4_H = chart.GetProperty("检测点04").GetProperty("当前湿度");
|
|
|
|
|
-
|
|
|
|
|
- JsonElement checkPoint5_T = chart.GetProperty("检测点05").GetProperty("当前温度");
|
|
|
|
|
- JsonElement checkPoint5_H = chart.GetProperty("检测点05").GetProperty("当前湿度");
|
|
|
|
|
-
|
|
|
|
|
- JsonElement average = chart.GetProperty("环境平均湿度");
|
|
|
|
|
-
|
|
|
|
|
- dh.ExecuteSql($@"INSERT INTO HUMITURE (HU_ID,HU_INDATE,CHECKPOINT1_T,CHECKPOINT1_H,CHECKPOINT2_T,CHECKPOINT2_H,CHECKPOINT3_T,CHECKPOINT3_H,
|
|
|
|
|
- CHECKPOINT4_T,CHECKPOINT4_H,CHECKPOINT5_T,CHECKPOINT5_H,AVERAGE,EQUITYPE,EQUIID) VALUES
|
|
|
|
|
- (HUMITURE_SEQ.NEXTVAL,sysdate,'{checkPoint1_T.ToString()}','{checkPoint1_H.ToString()}','{checkPoint2_T.ToString()}','{checkPoint2_H.ToString()}','{checkPoint3_T.ToString()}','{checkPoint3_H.ToString()}',
|
|
|
|
|
- '{checkPoint4_T.ToString()}','{checkPoint4_H.ToString()}','{checkPoint5_T.ToString()}','{checkPoint5_H.ToString()}','{average.ToString()}','{clientName[i]}','{clientId[i]}')", "insert");
|
|
|
|
|
-
|
|
|
|
|
|
|
+
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
- catch(Exception ex)
|
|
|
|
|
|
|
+ catch (Exception ex)
|
|
|
{
|
|
{
|
|
|
ShowMsg(Msg1, 0, $"获取数据时发生错误: {ex.Message}");
|
|
ShowMsg(Msg1, 0, $"获取数据时发生错误: {ex.Message}");
|
|
|
}
|
|
}
|
|
@@ -228,7 +240,7 @@ namespace UAS_MES_NEW.Make
|
|
|
public static async Task<string> PostAsync<T>(string url, T data)
|
|
public static async Task<string> PostAsync<T>(string url, T data)
|
|
|
{
|
|
{
|
|
|
var client = new HttpClient();
|
|
var client = new HttpClient();
|
|
|
- string json = JsonSerializer.Serialize(data);
|
|
|
|
|
|
|
+ string json = JsonConvert.SerializeObject(data);
|
|
|
var content = new StringContent(json, Encoding.UTF8, "application/json");
|
|
var content = new StringContent(json, Encoding.UTF8, "application/json");
|
|
|
var response = await client.PostAsync(url, content);
|
|
var response = await client.PostAsync(url, content);
|
|
|
response.EnsureSuccessStatusCode();
|
|
response.EnsureSuccessStatusCode();
|