|
@@ -314,7 +314,8 @@ public class HttpHelper : MonoBehaviour
|
|
|
public async Task InitYZTData()
|
|
|
{
|
|
|
InitYZTData1();//已完成迁移
|
|
|
- InitYZTData2();//未完成迁移
|
|
|
+ InitYZTData_BY_Obs();//已完成迁移
|
|
|
+ InitYZTData_TK_Obs();//新增
|
|
|
InitYZTData3();//已完成迁移
|
|
|
|
|
|
}
|
|
@@ -375,12 +376,11 @@ public class HttpHelper : MonoBehaviour
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public async Task InitYZTData2()
|
|
|
+ public async Task InitYZTData_BY_Obs()
|
|
|
{
|
|
|
- Debug.Log("!!!!!");
|
|
|
bool successInternet = true;
|
|
|
string sendUrl = ServerAddress.API_GetDevicesInfo;
|
|
|
- sendUrl += "/34020000001180000001/channels?page=1&count=40";
|
|
|
+ sendUrl += "/34020000001180000001/channels?page=1&count=100";
|
|
|
Debug.Log(sendUrl);
|
|
|
UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
|
|
|
requestData.timeout = timeOut;
|
|
@@ -402,7 +402,7 @@ public class HttpHelper : MonoBehaviour
|
|
|
JToken codeToken = jsonObject["code"];
|
|
|
if (codeToken.ToString() == "0")
|
|
|
{
|
|
|
- GlobalData.obsDatas = new List<ObsData>();
|
|
|
+ GlobalData.obsDatas_by = new List<ObsData>();
|
|
|
ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
|
|
|
for (int i = 0; i < serverObsDatas.list.Count; i++)
|
|
|
{
|
|
@@ -422,7 +422,7 @@ public class HttpHelper : MonoBehaviour
|
|
|
obsData.deviceId = serverObsDatas.list[i].deviceId;
|
|
|
obsData.channelId = serverObsDatas.list[i].channelId;
|
|
|
obsData.status = serverObsDatas.list[i].status;
|
|
|
- GlobalData.obsDatas.Add(obsData);
|
|
|
+ GlobalData.obsDatas_by.Add(obsData);
|
|
|
}
|
|
|
}
|
|
|
else
|
|
@@ -441,14 +441,91 @@ public class HttpHelper : MonoBehaviour
|
|
|
|
|
|
if (!successInternet)
|
|
|
{
|
|
|
- WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas.json");
|
|
|
+ WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas_BY.json");
|
|
|
await new UnityAsync.WaitUntil(() =>
|
|
|
{
|
|
|
return www.isDone;
|
|
|
});
|
|
|
|
|
|
Debug.Log($"缓存数据:{www.text}");
|
|
|
- GlobalData.obsDatas = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
|
|
|
+ GlobalData.obsDatas_by = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
|
|
|
+ www.Dispose();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public async Task InitYZTData_TK_Obs()
|
|
|
+ {
|
|
|
+ bool successInternet = true;
|
|
|
+ string sendUrl = ServerAddress.API_GetDevicesInfo;
|
|
|
+ sendUrl += "/34020000001180000002/channels?page=1&count=100";
|
|
|
+ Debug.Log(sendUrl);
|
|
|
+ UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
|
|
|
+ requestData.timeout = timeOut;
|
|
|
+ await requestData.SendWebRequest();
|
|
|
+ try
|
|
|
+ {
|
|
|
+ if (requestData.result != UnityWebRequest.Result.Success)
|
|
|
+ {
|
|
|
+ Debug.LogWarning("监控数据联网不成功,原因:返request不成功:" + requestData.error);
|
|
|
+ successInternet = false;
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Debug.Log(requestData.downloadHandler.text);
|
|
|
+ JObject jsonObject = JObject.Parse(requestData.downloadHandler.text);
|
|
|
+
|
|
|
+ // 提取data字段的值
|
|
|
+ JToken dataToken = jsonObject["data"];
|
|
|
+ JToken codeToken = jsonObject["code"];
|
|
|
+ if (codeToken.ToString() == "0")
|
|
|
+ {
|
|
|
+ GlobalData.obsDatas_tk = new List<ObsData>();
|
|
|
+ ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
|
|
|
+ for (int i = 0; i < serverObsDatas.list.Count; i++)
|
|
|
+ {
|
|
|
+ ObsData obsData = new ObsData();
|
|
|
+ obsData.name = serverObsDatas.list[i].name;
|
|
|
+ obsData.targetName = GlobalData.obsCameraLib[obsData.name];
|
|
|
+ // if (i > 0)
|
|
|
+ // {
|
|
|
+ // obsData.url =
|
|
|
+ // "http://www.chatgpt918.top:9080/rtp/34020000001180000001_34020000001310000001/hls.m3u8";
|
|
|
+ // }
|
|
|
+ // else
|
|
|
+ // {
|
|
|
+ obsData.url = ServerAddress.ObsSeverM3U8Address + string.Format("/rtp/{0}_{1}/hls.m3u8", serverObsDatas.list[i].deviceId, serverObsDatas.list[i].channelId);
|
|
|
+ //}
|
|
|
+ obsData.type = obsType.TaoKouObs;
|
|
|
+ obsData.deviceId = serverObsDatas.list[i].deviceId;
|
|
|
+ obsData.channelId = serverObsDatas.list[i].channelId;
|
|
|
+ obsData.status = serverObsDatas.list[i].status;
|
|
|
+ GlobalData.obsDatas_tk.Add(obsData);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ Debug.LogWarning("监控数据联网不成功,原因:返序列化失败");
|
|
|
+ successInternet = false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ catch (Exception e)
|
|
|
+ {
|
|
|
+ successInternet = false;
|
|
|
+ Debug.LogWarning("监控数据联网不成功,原因:" + e.ToString());
|
|
|
+ }
|
|
|
+ requestData.Dispose();
|
|
|
+
|
|
|
+ if (!successInternet)
|
|
|
+ {
|
|
|
+ WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas_TK.json");
|
|
|
+ await new UnityAsync.WaitUntil(() =>
|
|
|
+ {
|
|
|
+ return www.isDone;
|
|
|
+ });
|
|
|
+
|
|
|
+ Debug.Log($"缓存数据:{www.text}");
|
|
|
+ GlobalData.obsDatas_tk = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
|
|
|
www.Dispose();
|
|
|
}
|
|
|
}
|
|
@@ -920,15 +997,26 @@ public class HttpHelper : MonoBehaviour
|
|
|
//获取所有渗压记
|
|
|
GetDevicesData tempData = new GetDevicesData();
|
|
|
tempData.idsList = new List<DevicesMessage>();
|
|
|
- for (int i = 0; i < 13; i++)
|
|
|
+ foreach (var device in _devicesIdDatas.Values)
|
|
|
{
|
|
|
- var devicesInfo = _devicesIdDatas[$"P{i + 1}"];
|
|
|
- tempData.idsList.Add(new DevicesMessage()
|
|
|
+ if (device.stationName.Equals("补元") && device.sensorType.Equals("渗压计"))
|
|
|
{
|
|
|
- DeviceID = devicesInfo.dataSid,
|
|
|
- ChannelID = devicesInfo.dataGid
|
|
|
- });
|
|
|
+ tempData.idsList.Add(new DevicesMessage()
|
|
|
+ {
|
|
|
+ DeviceID = device.dataSid,
|
|
|
+ ChannelID = device.dataGid
|
|
|
+ });
|
|
|
+ }
|
|
|
}
|
|
|
+ // for (int i = 0; i < 13; i++)
|
|
|
+ // {
|
|
|
+ // var devicesInfo = _devicesIdDatas[$"P{i + 1}"];
|
|
|
+ // tempData.idsList.Add(new DevicesMessage()
|
|
|
+ // {
|
|
|
+ // DeviceID = devicesInfo.dataSid,
|
|
|
+ // ChannelID = devicesInfo.dataGid
|
|
|
+ // });
|
|
|
+ // }
|
|
|
string jsonStr;
|
|
|
try
|
|
|
{
|
|
@@ -957,15 +1045,26 @@ public class HttpHelper : MonoBehaviour
|
|
|
//获取所有位移记
|
|
|
tempData = new GetDevicesData();
|
|
|
tempData.idsList = new List<DevicesMessage>();
|
|
|
- for (int i = 0; i < 8; i++)
|
|
|
+ foreach (var device in _devicesIdDatas.Values)
|
|
|
{
|
|
|
- var devicesInfo = _devicesIdDatas[$"M{i + 1}"];
|
|
|
- tempData.idsList.Add(new DevicesMessage()
|
|
|
+ if (device.stationName.Equals("补元") && device.sensorType.Equals("静力水准仪"))
|
|
|
{
|
|
|
- DeviceID = devicesInfo.dataSid,
|
|
|
- ChannelID = devicesInfo.dataGid
|
|
|
- });
|
|
|
+ tempData.idsList.Add(new DevicesMessage()
|
|
|
+ {
|
|
|
+ DeviceID = device.dataSid,
|
|
|
+ ChannelID = device.dataGid
|
|
|
+ });
|
|
|
+ }
|
|
|
}
|
|
|
+ // for (int i = 0; i < 8; i++)
|
|
|
+ // {
|
|
|
+ // var devicesInfo = _devicesIdDatas[$"M{i + 1}"];
|
|
|
+ // tempData.idsList.Add(new DevicesMessage()
|
|
|
+ // {
|
|
|
+ // DeviceID = devicesInfo.dataSid,
|
|
|
+ // ChannelID = devicesInfo.dataGid
|
|
|
+ // });
|
|
|
+ // }
|
|
|
try
|
|
|
{
|
|
|
jsonStr = await Devices(tempData);
|