HttpHelper.cs 81 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Generic;
  4. using System.IO;
  5. using System.Threading.Tasks;
  6. using UnityAsync;
  7. using Best.HTTP;
  8. using Best.HTTP.JSON;
  9. using Newtonsoft.Json;
  10. using Newtonsoft.Json.Serialization;
  11. using Newtonsoft.Json.Linq;
  12. using UnityEngine;
  13. using UnityEngine.Networking;
  14. using Unity.VisualScripting;
  15. using static System.Net.WebRequestMethods;
  16. public class HttpHelper : MonoBehaviour
  17. {
  18. public Action OnSWYJRefresh;
  19. public static bool useAes = false;
  20. public static HttpHelper _Instance;
  21. public static Dictionary<string, DevicesId_Data> _devicesIdDatas = new Dictionary<string, DevicesId_Data>();
  22. public const int timeOut = 3;
  23. class DYServerAddress
  24. {
  25. public string YZTServerAddress;
  26. public string YZTServerPYAddress;
  27. public string Server_UploadPath;
  28. public string ModbusSeverAddress;
  29. public string ObsSeverAddress;
  30. public string ObsSeverM3U8Address;
  31. }
  32. void ChangeServerAddress()
  33. {
  34. //if (System.IO.File.Exists(Application.streamingAssetsPath + "/serverPath.json"))
  35. //{
  36. // string serverAddressContent = System.IO.File.ReadAllText(Application.streamingAssetsPath + "/serverPath.json");
  37. // Debug.Log(serverAddressContent);
  38. // DYServerAddress address = JsonConvert.DeserializeObject<DYServerAddress>(serverAddressContent);
  39. // ServerAddress.YZTServerAddress = address.YZTServerAddress;
  40. // ServerAddress.YZTServerPYAddress = address.YZTServerPYAddress;
  41. // ServerAddress.Server_UploadPath = address.Server_UploadPath;
  42. // ServerAddress.ModbusSeverAddress = address.ModbusSeverAddress;
  43. // ServerAddress.ObsSeverAddress = address.ObsSeverAddress;
  44. // Debug.Log(ServerAddress.ObsSeverAddress);
  45. // ServerAddress.ObsSeverM3U8Address = address.ObsSeverM3U8Address;
  46. //}
  47. }
  48. private async void Awake()
  49. {
  50. _Instance = this;
  51. ChangeServerAddress();
  52. if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2 ||
  53. GlobalData.pageIndex == PageIndex.Page3)
  54. {
  55. Debug.Log("HttpInitYZTData");
  56. //可以并行,无需等待
  57. InitYZTData();
  58. }
  59. if (_devicesIdDatas.Count < 1)
  60. {
  61. await GetSensorList();
  62. }
  63. if (GlobalData.pageIndex == PageIndex.Page1)
  64. {
  65. SendBuYuan_GetSensorData();
  66. SendTaoKou_GetSensorData();
  67. GetBuYuanDevicesGroupInfo();
  68. GetTaoKouDevicesGroupInfo();
  69. }
  70. if (GlobalData.pageIndex == PageIndex.Page2)
  71. {
  72. SendBuYuan_GetSensorData();
  73. SendTaoKou_GetSensorData();
  74. }
  75. if (GlobalData.pageIndex == PageIndex.Page1)
  76. {
  77. Debug.Log("InitXHGKData");
  78. //可以并行,无需等待
  79. InitXHGKData(); //已完成迁移
  80. }
  81. if (GlobalData.pageIndex == PageIndex.Page1)
  82. {
  83. Debug.Log("HttpInitGCJKData");
  84. //可以并行,无需等待
  85. InitGCJKData();
  86. }
  87. if (GlobalData.pageIndex == PageIndex.Page1)
  88. {
  89. Debug.Log("HttpInitXHDDData");
  90. //可以并行,无需等待
  91. InitXHDDData();
  92. }
  93. if (GlobalData.pageIndex == PageIndex.Page1)
  94. {
  95. Debug.Log("HttpInitRKZYData");
  96. //可以并行,无需等待
  97. InitRKZYData();
  98. }
  99. if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2)
  100. {
  101. Debug.Log("HttpInitSWYJData");
  102. //可以并行,无需等待
  103. InitSWYJData();
  104. }
  105. if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2)
  106. {
  107. Debug.Log("HttpInitGCYWData1");
  108. //可以并行,无需等待
  109. InitGCYWData1(0);
  110. }
  111. if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2 ||
  112. GlobalData.pageIndex == PageIndex.Page3)
  113. {
  114. Debug.Log("HttpInitFloorGateData");
  115. InitFloorGateData();
  116. }
  117. if (GlobalData.pageIndex == PageIndex.Page2)
  118. {
  119. Debug.Log("HttpInitDPSWData");
  120. InitDPSWData();
  121. }
  122. if (GlobalData.pageIndex == PageIndex.Page2)
  123. {
  124. Debug.Log("HttpInitGCYWData2");
  125. InitGCYWData2();
  126. }
  127. if (GlobalData.pageIndex == PageIndex.Page2)
  128. {
  129. Debug.Log("HttpInitYJSJData2");
  130. InitYJSJData2();
  131. }
  132. }
  133. private async Task InitGCYWData2()
  134. {
  135. bool successInternet = true;
  136. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetInspectionStatistics);
  137. requestData.timeout = timeOut;
  138. await requestData.SendWebRequest();
  139. try
  140. {
  141. if (requestData.result != UnityWebRequest.Result.Success)
  142. {
  143. Debug.LogWarning("大屏运维数据联网不成功,读本地缓存数据,原因:返request不成功");
  144. successInternet = false;
  145. }
  146. else
  147. {
  148. string postResult = requestData.downloadHandler.text;
  149. if (useAes)
  150. {
  151. postResult = AESCrypto.Decrypt(postResult);
  152. }
  153. JObject jsonObject = JObject.Parse(postResult);
  154. // 提取data字段的值
  155. JToken dataToken = jsonObject["data"];
  156. JToken codeToken = jsonObject["code"];
  157. if (codeToken.ToString() == "200")
  158. {
  159. GlobalData.InspectionStat =
  160. JsonConvert.DeserializeObject<List<StationInspection>>(dataToken.ToString());
  161. }
  162. else
  163. {
  164. Debug.LogWarning("大屏运维数据联网不成功,读本地缓存数据,原因:返序列化失败");
  165. successInternet = false;
  166. }
  167. }
  168. }
  169. catch (Exception e)
  170. {
  171. successInternet = false;
  172. Debug.LogWarning("大屏运维数据联网不成功,读本地缓存数据,原因:" + e.ToString());
  173. }
  174. requestData.Dispose();
  175. if (!successInternet)
  176. {
  177. WWW www = new WWW(Application.streamingAssetsPath + "/inspectionStatistics.json");
  178. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  179. GlobalData.InspectionStat = JsonConvert.DeserializeObject<List<StationInspection>>(www.text);
  180. www.Dispose();
  181. }
  182. }
  183. private async Task InitYJSJData2()
  184. {
  185. bool successInternet = true;
  186. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetAlertData);
  187. requestData.timeout = timeOut;
  188. await requestData.SendWebRequest();
  189. try
  190. {
  191. if (requestData.result != UnityWebRequest.Result.Success)
  192. {
  193. Debug.LogWarning("大屏预警数据联网不成功,读本地缓存数据,原因:返request不成功");
  194. successInternet = false;
  195. }
  196. else
  197. {
  198. string postResult = requestData.downloadHandler.text;
  199. if (useAes)
  200. {
  201. postResult = AESCrypto.Decrypt(postResult);
  202. }
  203. JObject jsonObject = JObject.Parse(postResult);
  204. // 提取data字段的值
  205. JToken dataToken = jsonObject["data"];
  206. JToken codeToken = jsonObject["code"];
  207. if (codeToken.ToString() == "200")
  208. {
  209. GlobalData.alertData = JsonConvert.DeserializeObject<AlertData>(dataToken.ToString());
  210. GlobalData.alertData.success = true;
  211. }
  212. else
  213. {
  214. Debug.LogWarning("大屏预警数据联网不成功,读本地缓存数据,原因:返序列化失败");
  215. successInternet = false;
  216. }
  217. }
  218. }
  219. catch (Exception e)
  220. {
  221. successInternet = false;
  222. Debug.LogWarning("大屏预警数据联网不成功,读本地缓存数据,原因:" + e.ToString());
  223. }
  224. requestData.Dispose();
  225. if (!successInternet)
  226. {
  227. WWW www = new WWW(Application.streamingAssetsPath + "/alertData.json");
  228. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  229. Debug.Log(www.text);
  230. GlobalData.alertData = JsonConvert.DeserializeObject<AlertData>(www.text.ToString());
  231. GlobalData.alertData.success = true;
  232. Debug.Log(GlobalData.alertData.alerts.threeLineWarnings[0].title);
  233. www.Dispose();
  234. }
  235. }
  236. private async Task InitFloorGateData()
  237. {
  238. bool successInternet = true;
  239. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetFloodGateData);
  240. requestData.timeout = timeOut;
  241. await requestData.SendWebRequest();
  242. try
  243. {
  244. if (requestData.result != UnityWebRequest.Result.Success)
  245. {
  246. Debug.LogWarning("大屏闸口数据联网不成功,读本地缓存数据,原因:返request不成功");
  247. successInternet = false;
  248. }
  249. else
  250. {
  251. string postResult = requestData.downloadHandler.text;
  252. if (useAes)
  253. {
  254. postResult = AESCrypto.Decrypt(postResult);
  255. }
  256. JObject jsonObject = JObject.Parse(postResult);
  257. // 提取data字段的值
  258. JToken dataToken = jsonObject["data"];
  259. JToken codeToken = jsonObject["code"];
  260. if (codeToken.ToString() == "200")
  261. {
  262. GlobalData.floorGateData = JsonConvert.DeserializeObject<FloodGateStatusData>(dataToken.ToString());
  263. GlobalData.floorGateData.success = true;
  264. }
  265. else
  266. {
  267. Debug.LogWarning("大屏闸口数据联网不成功,读本地缓存数据,原因:返序列化失败");
  268. successInternet = false;
  269. }
  270. }
  271. }
  272. catch (Exception e)
  273. {
  274. successInternet = false;
  275. Debug.LogWarning("大屏闸口数据联网不成功,读本地缓存数据,原因:" + e.ToString());
  276. }
  277. requestData.Dispose();
  278. if (!successInternet)
  279. {
  280. WWW www = new WWW(Application.streamingAssetsPath + "/floodGateStatusData.json");
  281. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  282. Debug.Log(www.text);
  283. GlobalData.floorGateData = JsonConvert.DeserializeObject<FloodGateStatusData>(www.text.ToString());
  284. GlobalData.floorGateData.success = true;
  285. www.Dispose();
  286. }
  287. }
  288. private async Task InitDPSWData()
  289. {
  290. GlobalData.locationWeatherData = new List<LocationWeatherData>();
  291. bool successInternet = true;
  292. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetHydrologicalData + "?projectType=1");
  293. requestData.timeout = timeOut;
  294. await requestData.SendWebRequest();
  295. try
  296. {
  297. if (requestData.result != UnityWebRequest.Result.Success)
  298. {
  299. Debug.LogWarning("大屏水文数据联网不成功,读本地缓存数据,原因:返request不成功");
  300. successInternet = false;
  301. }
  302. else
  303. {
  304. string postResult = requestData.downloadHandler.text;
  305. if (useAes)
  306. {
  307. postResult = AESCrypto.Decrypt(postResult);
  308. }
  309. JObject jsonObject = JObject.Parse(postResult);
  310. // 提取data字段的值
  311. JToken dataToken = jsonObject["data"];
  312. JToken codeToken = jsonObject["code"];
  313. if (codeToken.ToString() == "200")
  314. {
  315. LocationWeatherData data1 =
  316. JsonConvert.DeserializeObject<LocationWeatherData>(dataToken.ToString());
  317. GlobalData.locationWeatherData.Add(data1);
  318. }
  319. else
  320. {
  321. Debug.LogWarning("大屏水文数据联网不成功,读本地缓存数据,原因:返序列化失败");
  322. successInternet = false;
  323. }
  324. }
  325. }
  326. catch (Exception e)
  327. {
  328. successInternet = false;
  329. Debug.LogWarning("大屏水文数据联网不成功,读本地缓存数据,原因:" + e.ToString());
  330. }
  331. UnityWebRequest requestData1 = UnityWebRequest.Get(ServerAddress.APIGetHydrologicalData + "?projectType=2");
  332. requestData1.timeout = timeOut;
  333. await requestData1.SendWebRequest();
  334. try
  335. {
  336. if (requestData1.result != UnityWebRequest.Result.Success)
  337. {
  338. Debug.LogWarning("大屏水文数据联网不成功,读本地缓存数据,原因:返request不成功");
  339. successInternet = false;
  340. }
  341. else
  342. {
  343. JObject jsonObject = JObject.Parse(requestData1.downloadHandler.text);
  344. // 提取data字段的值
  345. JToken dataToken = jsonObject["data"];
  346. JToken codeToken = jsonObject["code"];
  347. if (codeToken.ToString() == "200")
  348. {
  349. LocationWeatherData data2 =
  350. JsonConvert.DeserializeObject<LocationWeatherData>(dataToken.ToString());
  351. GlobalData.locationWeatherData.Add(data2);
  352. }
  353. else
  354. {
  355. Debug.LogWarning("大屏水文数据联网不成功,读本地缓存数据,原因:返序列化失败");
  356. successInternet = false;
  357. }
  358. }
  359. }
  360. catch (Exception e)
  361. {
  362. successInternet = false;
  363. Debug.LogWarning("大屏水文数据联网不成功,读本地缓存数据,原因:" + e.ToString());
  364. }
  365. requestData.Dispose();
  366. if (!successInternet)
  367. {
  368. WWW www = new WWW(Application.streamingAssetsPath + "/hydrologicalData.json");
  369. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  370. Debug.Log(www.text);
  371. GlobalData.locationWeatherData =
  372. JsonConvert.DeserializeObject<List<LocationWeatherData>>(www.text.ToString());
  373. www.Dispose();
  374. }
  375. }
  376. public async void InitYZTData()
  377. {
  378. await InitYZTData1(); //已完成迁移
  379. InitYZTData_BY_Obs(); //已完成迁移
  380. InitYZTData_TK_Obs(); //新增
  381. InitYZTData3(); //已完成迁移
  382. InitGCGKData();
  383. InitJKYJData();
  384. }
  385. public async Task InitYZTData1()
  386. {
  387. bool successInternet = true;
  388. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterManagerProject);
  389. requestData.timeout = timeOut;
  390. await requestData.SendWebRequest();
  391. try
  392. {
  393. if (true)
  394. {
  395. Debug.LogWarning("YZTLayer联网不成功,读本地缓存数据,原因:返request不成功");
  396. successInternet = false;
  397. }
  398. else
  399. {
  400. string postResult = requestData.downloadHandler.text;
  401. if (useAes)
  402. {
  403. postResult = AESCrypto.Decrypt(postResult);
  404. }
  405. JObject jsonObject = JObject.Parse(postResult);
  406. // 提取data字段的值
  407. JToken dataToken = jsonObject["data"];
  408. JToken codeToken = jsonObject["code"];
  409. if (codeToken.ToString() == "200")
  410. {
  411. GlobalData.layerUnitDatas =
  412. JsonConvert.DeserializeObject<List<LayerUnitData>>(dataToken.ToString());
  413. }
  414. else
  415. {
  416. Debug.LogWarning("YZTLayer联网不成功,读本地缓存数据,原因:返序列化失败");
  417. successInternet = false;
  418. }
  419. }
  420. }
  421. catch (Exception e)
  422. {
  423. successInternet = false;
  424. Debug.LogWarning("YZTLayer联网不成功,读本地缓存数据,原因:" + e.ToString());
  425. }
  426. requestData.Dispose();
  427. if (!successInternet)
  428. {
  429. WWW www = new WWW(Application.streamingAssetsPath + "/layerUnitDatas.json");
  430. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  431. GlobalData.layerUnitDatas = JsonConvert.DeserializeObject<List<LayerUnitData>>(www.text);
  432. www.Dispose();
  433. }
  434. for (int i = 0; i < GlobalData.layerUnitDatas.Count; i++)
  435. {
  436. if (GlobalData.layerUnitDatas[i].type == LayerUnitType.JK)
  437. {
  438. if (!GlobalData.obsCameraLib.ContainsKey(GlobalData.layerUnitDatas[i].name))
  439. GlobalData.obsCameraLib.Add(GlobalData.layerUnitDatas[i].name, GlobalData.layerUnitDatas[i].namePri);
  440. }
  441. }
  442. }
  443. public async Task InitYZTData_BY_Obs()
  444. {
  445. bool successInternet = true;
  446. string sendUrl = ServerAddress.API_GetDevicesInfo;
  447. Debug.Log(ServerAddress.ObsSeverAddress);
  448. sendUrl += "/34020000001180000001/channels?page=1&count=100";
  449. Debug.Log(sendUrl);
  450. UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
  451. requestData.timeout = timeOut;
  452. await requestData.SendWebRequest();
  453. try
  454. {
  455. if (requestData.result != UnityWebRequest.Result.Success)
  456. {
  457. Debug.LogWarning("补元监控数据联网不成功,原因:返request不成功:" + requestData.error);
  458. successInternet = false;
  459. }
  460. else
  461. {
  462. Debug.Log("补元监控数据返回:" + requestData.downloadHandler.text);
  463. string postResult = requestData.downloadHandler.text;
  464. if (useAes)
  465. {
  466. postResult = AESCrypto.Decrypt(postResult);
  467. }
  468. JObject jsonObject = JObject.Parse(postResult);
  469. // 提取data字段的值
  470. JToken dataToken = jsonObject["data"];
  471. JToken codeToken = jsonObject["code"];
  472. if (codeToken.ToString() == "0")
  473. {
  474. GlobalData.obsDatas_by = new List<ObsData>();
  475. ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
  476. for (int i = 0; i < serverObsDatas.list.Count; i++)
  477. {
  478. ObsData obsData = new ObsData();
  479. string originName = serverObsDatas.list[i].name;
  480. obsData.name = "补元-" + serverObsDatas.list[i].name;
  481. //Debug.Log("111" + obsData.name);
  482. if (GlobalData.obsCameraLib.TryGetValue(originName, out var value))
  483. {
  484. obsData.targetName = value;
  485. }
  486. // if (i > 0)
  487. // {
  488. // obsData.url =
  489. // "http://www.chatgpt918.top:9080/rtp/34020000001180000001_34020000001310000001/hls.m3u8";
  490. // }
  491. // else
  492. // {
  493. //obsData.url = await GetObsUrl(serverObsDatas.list[i].deviceId,serverObsDatas.list[i].channelId);
  494. //Debug.Log("!!!:"+obsData.url);
  495. //obsData.url = ServerAddress.ObsSeverM3U8Address + string.Format("/rtp/{0}_{1}/hls.m3u8", serverObsDatas.list[i].deviceId, serverObsDatas.list[i].channelId);
  496. //}
  497. obsData.type = obsType.BuYuanObs;
  498. obsData.deviceId = serverObsDatas.list[i].deviceId;
  499. obsData.channelId = serverObsDatas.list[i].channelId;
  500. obsData.status = serverObsDatas.list[i].status;
  501. GlobalData.obsDatas_by.Add(obsData);
  502. }
  503. }
  504. else
  505. {
  506. Debug.LogWarning("补元监控数据联网不成功,原因:返序列化失败");
  507. successInternet = false;
  508. }
  509. }
  510. }
  511. catch (Exception e)
  512. {
  513. successInternet = false;
  514. Debug.LogWarning("补元监控数据联网不成功,原因:" + e.ToString());
  515. }
  516. requestData.Dispose();
  517. if (!successInternet)
  518. {
  519. WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas_BY.json");
  520. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  521. Debug.Log($"缓存数据:{www.text}");
  522. GlobalData.obsDatas_by = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
  523. www.Dispose();
  524. }
  525. }
  526. public async Task InitYZTData_TK_Obs()
  527. {
  528. bool successInternet = true;
  529. string sendUrl = ServerAddress.API_GetDevicesInfo;
  530. sendUrl += "/34020000001180000002/channels?page=1&count=100";
  531. Debug.Log(sendUrl);
  532. UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
  533. requestData.timeout = timeOut;
  534. await requestData.SendWebRequest();
  535. try
  536. {
  537. if (requestData.result != UnityWebRequest.Result.Success)
  538. {
  539. Debug.LogWarning("套口监控数据联网不成功,原因:返request不成功:" + requestData.error);
  540. successInternet = false;
  541. }
  542. else
  543. {
  544. Debug.Log("套口监控数据返回:" + requestData.downloadHandler.text);
  545. string postResult = requestData.downloadHandler.text;
  546. if (useAes)
  547. {
  548. postResult = AESCrypto.Decrypt(postResult);
  549. }
  550. JObject jsonObject = JObject.Parse(postResult);
  551. // 提取data字段的值
  552. JToken dataToken = jsonObject["data"];
  553. JToken codeToken = jsonObject["code"];
  554. if (codeToken.ToString() == "0")
  555. {
  556. GlobalData.obsDatas_tk = new List<ObsData>();
  557. ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
  558. for (int i = 0; i < serverObsDatas.list.Count; i++)
  559. {
  560. ObsData obsData = new ObsData();
  561. string originName = serverObsDatas.list[i].name;
  562. //Debug.Log("111111111111111:" + originName);
  563. obsData.name = "套口-" + serverObsDatas.list[i].name;
  564. if (GlobalData.obsCameraLib.TryGetValue(obsData.name, out var value))
  565. {
  566. obsData.targetName = value;
  567. }
  568. //obsData.url = await GetObsUrl(serverObsDatas.list[i].deviceId,serverObsDatas.list[i].channelId);
  569. //ServerAddress.ObsSeverM3U8Address + string.Format("/rtp/{0}_{1}/hls.m3u8", serverObsDatas.list[i].deviceId, serverObsDatas.list[i].channelId);
  570. //}
  571. obsData.type = obsType.TaoKouObs;
  572. obsData.deviceId = serverObsDatas.list[i].deviceId;
  573. obsData.channelId = serverObsDatas.list[i].channelId;
  574. obsData.status = serverObsDatas.list[i].status;
  575. GlobalData.obsDatas_tk.Add(obsData);
  576. }
  577. }
  578. else
  579. {
  580. Debug.LogWarning("套口监控数据联网不成功,原因:返序列化失败");
  581. successInternet = false;
  582. }
  583. }
  584. }
  585. catch (Exception e)
  586. {
  587. successInternet = false;
  588. Debug.LogWarning("套口监控数据联网不成功,原因:" + e.ToString());
  589. }
  590. requestData.Dispose();
  591. if (!successInternet)
  592. {
  593. WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas_TK.json");
  594. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  595. Debug.Log($"缓存数据:{www.text}");
  596. GlobalData.obsDatas_tk = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
  597. www.Dispose();
  598. }
  599. }
  600. public async Task<string> GetObsUrl(string deviceId, string channelId)
  601. {
  602. string result = "";
  603. string cmdUrl = ServerAddress.API_PlayStart;
  604. cmdUrl += $"/{deviceId}/{channelId}";
  605. Debug.Log($"send:{cmdUrl}");
  606. UnityWebRequest requestData = UnityWebRequest.Get(cmdUrl);
  607. await requestData.SendWebRequest();
  608. if (requestData.result != UnityWebRequest.Result.Success)
  609. {
  610. Debug.LogWarning($"获取监控播放地址不成功,原因:返request不成功:" + requestData.downloadHandler.text);
  611. }
  612. else
  613. {
  614. Debug.Log(requestData.downloadHandler.text);
  615. string postResult = requestData.downloadHandler.text;
  616. if (useAes)
  617. {
  618. postResult = AESCrypto.Decrypt(postResult);
  619. }
  620. JObject jsonObject = JObject.Parse(postResult);
  621. // 提取data字段的值
  622. JToken dataToken = jsonObject["data"];
  623. ObsPlayUrlData urlData = JsonConvert.DeserializeObject<ObsPlayUrlData>(dataToken.ToString());
  624. result = urlData.hls;
  625. Debug.Log("获取到监控播放路径:" + result);
  626. }
  627. requestData.Dispose();
  628. return result;
  629. }
  630. public async Task InitYZTData3()
  631. {
  632. bool successInternet = true;
  633. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterHotPoint);
  634. requestData.timeout = timeOut;
  635. await requestData.SendWebRequest();
  636. try
  637. {
  638. if (requestData.result != UnityWebRequest.Result.Success)
  639. {
  640. Debug.LogWarning("YZTLayer联网不成功,读本地缓存数据,原因:返request不成功");
  641. successInternet = false;
  642. }
  643. else
  644. {
  645. string postResult = requestData.downloadHandler.text;
  646. if (useAes)
  647. {
  648. postResult = AESCrypto.Decrypt(postResult);
  649. }
  650. JObject jsonObject = JObject.Parse(postResult);
  651. // 提取data字段的值
  652. JToken dataToken = jsonObject["data"];
  653. JToken codeToken = jsonObject["code"];
  654. if (codeToken.ToString() == "200")
  655. {
  656. GlobalData.hotPointDatas = JsonConvert.DeserializeObject<List<HotPointData>>(dataToken.ToString());
  657. }
  658. else
  659. {
  660. Debug.LogWarning("YZTLayer联网不成功,读本地缓存数据,原因:返序列化失败");
  661. successInternet = false;
  662. }
  663. }
  664. }
  665. catch (Exception e)
  666. {
  667. successInternet = false;
  668. Debug.LogWarning("YZTLayer联网不成功,读本地缓存数据,原因:" + e.ToString());
  669. }
  670. requestData.Dispose();
  671. if (!successInternet)
  672. {
  673. WWW www = new WWW(Application.streamingAssetsPath + "/hotPoints.json");
  674. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  675. GlobalData.hotPointDatas = JsonConvert.DeserializeObject<List<HotPointData>>(www.text);
  676. Debug.Log(GlobalData.hotPointDatas.Count);
  677. www.Dispose();
  678. }
  679. }
  680. public async Task InitXHGKData()
  681. {
  682. bool successInternet = true;
  683. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGetProjectMilestones);
  684. requestData.timeout = timeOut;
  685. await requestData.SendWebRequest();
  686. try
  687. {
  688. if (requestData.result != UnityWebRequest.Result.Success)
  689. {
  690. Debug.LogWarning("XHGKLayer联网不成功,读本地缓存数据,原因:返request不成功");
  691. successInternet = false;
  692. }
  693. else
  694. {
  695. string postResult = requestData.downloadHandler.text;
  696. if (useAes)
  697. {
  698. postResult = AESCrypto.Decrypt(postResult);
  699. }
  700. JObject jsonObject = JObject.Parse(postResult);
  701. // ȡdata ֶε ֵ
  702. JToken dataToken = jsonObject["data"];
  703. //Debug.Log(dataToken.ToString());
  704. JToken codeToken = jsonObject["code"];
  705. if (codeToken.ToString() == "200")
  706. {
  707. GlobalData.dsjContents = JsonConvert.DeserializeObject<List<DSJData>>(dataToken.ToString());
  708. }
  709. else
  710. {
  711. Debug.LogWarning("XHGKLayer联网不成功,读本地缓存数据,原因:返序列化失败");
  712. successInternet = false;
  713. }
  714. }
  715. }
  716. catch (Exception e)
  717. {
  718. successInternet = false;
  719. Debug.LogWarning("XHGKLayer联网不成功,读本地缓存数据,原因:" + e.ToString());
  720. }
  721. requestData.Dispose();
  722. if (!successInternet)
  723. {
  724. WWW www = new WWW(Application.streamingAssetsPath + "/dsj.json");
  725. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  726. GlobalData.dsjContents = JsonConvert.DeserializeObject<List<DSJData>>(www.text);
  727. www.Dispose();
  728. }
  729. }
  730. /// <summary>
  731. /// 一张图首页工程概况
  732. /// </summary>
  733. /// <returns></returns>
  734. public async Task InitGCGKData()
  735. {
  736. bool successInternet = true;
  737. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterGaiKuang);
  738. requestData.timeout = timeOut;
  739. await requestData.SendWebRequest();
  740. try
  741. {
  742. if (requestData.result != UnityWebRequest.Result.Success)
  743. {
  744. Debug.LogWarning("GCGK联网不成功,读本地缓存数据,原因:返request不成功");
  745. successInternet = false;
  746. }
  747. else
  748. {
  749. string postResult = requestData.downloadHandler.text;
  750. if (useAes)
  751. {
  752. postResult = AESCrypto.Decrypt(postResult);
  753. }
  754. JObject jsonObject = JObject.Parse(postResult);
  755. JToken dataToken = jsonObject["data"];
  756. //Debug.Log(dataToken.ToString());
  757. JToken codeToken = jsonObject["code"];
  758. if (codeToken.ToString() == "200")
  759. {
  760. //Debug.Log("1111111111:" + dataToken.ToString());
  761. GlobalData.gcgkContents = JsonConvert.DeserializeObject<List<GCGKData>>(dataToken.ToString());
  762. }
  763. else
  764. {
  765. Debug.LogWarning("GCGK联网不成功,读本地缓存数据,原因:返序列化失败");
  766. successInternet = false;
  767. }
  768. }
  769. }
  770. catch (Exception e)
  771. {
  772. successInternet = false;
  773. Debug.LogWarning("GCGK联网不成功,读本地缓存数据,原因:" + e.ToString());
  774. }
  775. requestData.Dispose();
  776. }
  777. /// <summary>
  778. /// 一张图首页监控预警
  779. /// </summary>
  780. /// <returns></returns>
  781. public async Task InitJKYJData()
  782. {
  783. bool successInternet = true;
  784. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetJKYJ + "buyuan");
  785. requestData.timeout = timeOut;
  786. await requestData.SendWebRequest();
  787. try
  788. {
  789. if (requestData.result != UnityWebRequest.Result.Success)
  790. {
  791. Debug.LogWarning("JKYJ-buyuan联网不成功,读本地缓存数据,原因:返request不成功");
  792. successInternet = false;
  793. }
  794. else
  795. {
  796. string postResult = requestData.downloadHandler.text;
  797. if (useAes)
  798. {
  799. postResult = AESCrypto.Decrypt(postResult);
  800. }
  801. JObject jsonObject = JObject.Parse(postResult);
  802. JToken dataToken = jsonObject["data"];
  803. //Debug.Log(dataToken.ToString());
  804. JToken codeToken = jsonObject["code"];
  805. if (codeToken.ToString() == "200")
  806. {
  807. //Debug.Log("1111111111:" + dataToken.ToString());
  808. GlobalData.byJKYJContents = JsonConvert.DeserializeObject<JKYJData>(dataToken.ToString());
  809. }
  810. else
  811. {
  812. Debug.LogWarning("JKYJ-buyuan联网不成功,读本地缓存数据,原因:返序列化失败");
  813. successInternet = false;
  814. }
  815. }
  816. }
  817. catch (Exception e)
  818. {
  819. successInternet = false;
  820. Debug.LogWarning("JKYJ-buyuan联网不成功,读本地缓存数据,原因:" + e.ToString());
  821. }
  822. requestData.Dispose();
  823. successInternet = true;
  824. UnityWebRequest requestData1 = UnityWebRequest.Get(ServerAddress.APIGetJKYJ + "taokou");
  825. requestData1.timeout = timeOut;
  826. await requestData1.SendWebRequest();
  827. try
  828. {
  829. if (requestData1.result != UnityWebRequest.Result.Success)
  830. {
  831. Debug.LogWarning("JKYJ-TAOKOU联网不成功,读本地缓存数据,原因:返request不成功");
  832. successInternet = false;
  833. }
  834. else
  835. {
  836. string postResult = requestData1.downloadHandler.text;
  837. Debug.Log(postResult);
  838. if (useAes)
  839. {
  840. postResult = AESCrypto.Decrypt(postResult);
  841. }
  842. JObject jsonObject = JObject.Parse(postResult);
  843. JToken dataToken = jsonObject["data"];
  844. //Debug.Log(dataToken.ToString());
  845. JToken codeToken = jsonObject["code"];
  846. if (codeToken.ToString() == "200")
  847. {
  848. //Debug.Log("1111111111:" + dataToken.ToString());
  849. GlobalData.tkJKYJContents = JsonConvert.DeserializeObject<JKYJData>(dataToken.ToString());
  850. }
  851. else
  852. {
  853. Debug.LogWarning("JKYJ-TAOKOU联网不成功,读本地缓存数据,原因:返序列化失败");
  854. successInternet = false;
  855. }
  856. }
  857. }
  858. catch (Exception e)
  859. {
  860. successInternet = false;
  861. Debug.LogWarning("JKYJ-TAOKOU联网不成功,读本地缓存数据,原因:" + e.ToString());
  862. }
  863. requestData1.Dispose();
  864. }
  865. public async Task InitGCJKData()
  866. {
  867. bool successInternet = true;
  868. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGeQXZData);
  869. requestData.timeout = timeOut;
  870. await requestData.SendWebRequest();
  871. try
  872. {
  873. if (requestData.result != UnityWebRequest.Result.Success)
  874. {
  875. Debug.LogWarning("水文站联网不成功,原因:返request不成功");
  876. successInternet = false;
  877. }
  878. else
  879. {
  880. string postResult = requestData.downloadHandler.text;
  881. if (useAes)
  882. {
  883. postResult = AESCrypto.Decrypt(postResult);
  884. }
  885. JObject jsonObject = JObject.Parse(postResult);
  886. // 提取data字段的值
  887. JToken dataToken = jsonObject["data"];
  888. JToken codeToken = jsonObject["code"];
  889. if (codeToken.ToString() == "200")
  890. {
  891. GlobalData.qXZDatas = JsonConvert.DeserializeObject<List<QXZData>>(dataToken.ToString());
  892. }
  893. else
  894. {
  895. Debug.LogWarning("水文站联网不成功,原因:返序列化失败");
  896. successInternet = false;
  897. }
  898. }
  899. }
  900. catch (Exception e)
  901. {
  902. successInternet = false;
  903. Debug.LogWarning("水文站联网不成功,原因:" + e.ToString());
  904. }
  905. requestData.Dispose();
  906. successInternet = true;
  907. UnityWebRequest requestData1 = UnityWebRequest.Get(ServerAddress.APIGetGeSWZData);
  908. await requestData1.SendWebRequest();
  909. try
  910. {
  911. if (requestData1.result != UnityWebRequest.Result.Success)
  912. {
  913. Debug.LogWarning("水文站联网不成功,原因:返request不成功");
  914. successInternet = false;
  915. }
  916. else
  917. {
  918. JObject jsonObject = JObject.Parse(requestData1.downloadHandler.text);
  919. // 提取data字段的值
  920. JToken dataToken = jsonObject["data"];
  921. JToken codeToken = jsonObject["code"];
  922. if (codeToken.ToString() == "200")
  923. {
  924. GlobalData.sWZDatas = JsonConvert.DeserializeObject<List<SWZData>>(dataToken.ToString());
  925. }
  926. else
  927. {
  928. Debug.LogWarning("水文站联网不成功,原因:返序列化失败");
  929. successInternet = false;
  930. }
  931. }
  932. }
  933. catch (Exception e)
  934. {
  935. successInternet = false;
  936. Debug.LogWarning("水文站联网不成功,原因:" + e.ToString());
  937. }
  938. requestData1.Dispose();
  939. }
  940. public async Task InitXHDDData()
  941. {
  942. WWW www = new WWW(Application.streamingAssetsPath + "/scheduling.json");
  943. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  944. GlobalData.schedulingData = JsonConvert.DeserializeObject<SchedulingData>(www.text);
  945. www.Dispose();
  946. }
  947. public async Task InitRKZYData()
  948. {
  949. bool successInternet = true;
  950. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGetMovePlans);
  951. requestData.timeout = timeOut;
  952. await requestData.SendWebRequest();
  953. try
  954. {
  955. if (true)
  956. {
  957. Debug.LogWarning("RKZYLayer联网不成功,读本地缓存数据,原因:返request不成功");
  958. successInternet = false;
  959. }
  960. else
  961. {
  962. string postResult = requestData.downloadHandler.text;
  963. if (useAes)
  964. {
  965. postResult = AESCrypto.Decrypt(postResult);
  966. }
  967. JObject jsonObject = JObject.Parse(postResult);
  968. // 提取data字段的值
  969. JToken dataToken = jsonObject["data"];
  970. JToken codeToken = jsonObject["code"];
  971. if (codeToken.ToString() == "200")
  972. {
  973. GlobalData.allServerMovePlans =
  974. JsonConvert.DeserializeObject<List<ServerMovePlan>>(dataToken.ToString());
  975. }
  976. else
  977. {
  978. successInternet = false;
  979. Debug.LogWarning("XHGKLayer联网不成功,读本地缓存数据,原因:返序列化失败");
  980. }
  981. }
  982. }
  983. catch (Exception e)
  984. {
  985. successInternet = false;
  986. Debug.LogWarning("RKZYLayer联网不成功,读本地缓存数据,原因:" + e.ToString());
  987. }
  988. if (!successInternet)
  989. {
  990. WWW www = new WWW(Application.streamingAssetsPath + "/moveplan.json");
  991. await new UnityAsync.WaitUntil(() => { return www.isDone; });
  992. GlobalData.allServerMovePlans = JsonConvert.DeserializeObject<List<ServerMovePlan>>(www.text);
  993. www.Dispose();
  994. }
  995. }
  996. public async Task InitSWYJData()
  997. {
  998. InitSWYJData0();
  999. await InitSWYJData1();
  1000. await InitSWYJData2();
  1001. await InitSWYJData3();
  1002. OnSWYJRefresh?.Invoke();
  1003. }
  1004. /// <summary>
  1005. /// 获取补元的水位
  1006. /// </summary>
  1007. /// <returns></returns>
  1008. public async Task InitSWYJData1()
  1009. {
  1010. var devicesInfo = _devicesIdDatas["上游水位计"];
  1011. string sw1Result = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1012. "d", 10000);
  1013. //Debug.Log("sw1Resultsw1Resultsw1Result上游水位计:" + sw1Result);
  1014. try
  1015. {
  1016. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw1Result);
  1017. if (tempData != null)
  1018. {
  1019. bool findData = false;
  1020. foreach (var VARIABLE in GlobalData.BuYuanShuiWeiDataList)
  1021. {
  1022. if (VARIABLE.name.Equals("补元上游水位"))
  1023. {
  1024. VARIABLE.value = float.Parse(tempData.data[0].avgS1);
  1025. VARIABLE.datas = tempData.data.ToArray();
  1026. findData = true;
  1027. }
  1028. }
  1029. if (!findData)
  1030. {
  1031. GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
  1032. {
  1033. name = "补元上游水位",
  1034. targetName = "BY_ShuiWei_Up",
  1035. value = float.Parse(tempData.data[0].avgS1),
  1036. type = shuiWeiType.BuYuanShuiWei,
  1037. datas = tempData.data.ToArray(),
  1038. sid = devicesInfo.dataSid.ToString(),
  1039. gid = devicesInfo.dataGid.ToString()
  1040. });
  1041. }
  1042. }
  1043. }
  1044. catch (Exception e)
  1045. {
  1046. Debug.LogWarning("补元上游水位不成功,原因:" + e.ToString());
  1047. }
  1048. var devicesInfo1 = _devicesIdDatas["下游水位计"];
  1049. string sw2Result = await GetSingleDevicesInfo(2, devicesInfo1.dataGid.ToString(), devicesInfo1.dataSid.ToString(),
  1050. "d", 100000);
  1051. Debug.Log("sw1Resultsw1Resultsw1Result下游水位计:" + sw2Result);
  1052. try
  1053. {
  1054. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw2Result);
  1055. if (tempData != null)
  1056. {
  1057. bool findData = false;
  1058. foreach (var VARIABLE in GlobalData.BuYuanShuiWeiDataList)
  1059. {
  1060. if (VARIABLE.name.Equals("补元下游水位"))
  1061. {
  1062. VARIABLE.value = float.Parse(tempData.data[0].avgS1);
  1063. VARIABLE.datas = tempData.data.ToArray();
  1064. findData = true;
  1065. }
  1066. }
  1067. if (!findData)
  1068. {
  1069. GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
  1070. {
  1071. name = "补元下游水位",
  1072. targetName = "BY_ShuiWei_Down",
  1073. value = float.Parse(tempData.data[0].avgS1),
  1074. type = shuiWeiType.BuYuanShuiWei,
  1075. datas = tempData.data.ToArray(),
  1076. sid = devicesInfo.dataSid.ToString(),
  1077. gid = devicesInfo.dataGid.ToString()
  1078. });
  1079. }
  1080. }
  1081. }
  1082. catch (Exception e)
  1083. {
  1084. Debug.LogWarning("补元下游水位不成功,原因:" + e.ToString());
  1085. }
  1086. string dayResult = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1087. "d", 6);
  1088. try
  1089. {
  1090. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(dayResult);
  1091. GlobalData.buYuanShuiWei_day = new ShuiWeiBianHuaData();
  1092. GlobalData.buYuanShuiWei_day.name = new string[tempData.data.Count];
  1093. GlobalData.buYuanShuiWei_day.value = new double[tempData.data.Count];
  1094. for (int i = 0; i < tempData.data.Count; i++)
  1095. {
  1096. GlobalData.buYuanShuiWei_day.name[i] = tempData.data[i].timeGroup;
  1097. GlobalData.buYuanShuiWei_day.value[i] = double.Parse(tempData.data[i].avgS1);
  1098. }
  1099. }
  1100. catch (Exception e)
  1101. {
  1102. Debug.LogWarning("获取6天平均数据不成功,原因:" + e.ToString());
  1103. }
  1104. string monthResult = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1105. "d", 90);
  1106. try
  1107. {
  1108. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(monthResult);
  1109. GlobalData.buYuanShuiWei_month = new ShuiWeiBianHuaData();
  1110. GlobalData.buYuanShuiWei_month.name = new string[tempData.data.Count];
  1111. GlobalData.buYuanShuiWei_month.value = new double[tempData.data.Count];
  1112. for (int i = 0; i < tempData.data.Count; i++)
  1113. {
  1114. GlobalData.buYuanShuiWei_month.name[i] = tempData.data[i].timeGroup;
  1115. GlobalData.buYuanShuiWei_month.value[i] = double.Parse(tempData.data[i].avgS1);
  1116. }
  1117. }
  1118. catch (Exception e)
  1119. {
  1120. Debug.LogWarning("获取6月平均数据不成功,原因:" + e.ToString());
  1121. }
  1122. string hourResult = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1123. "h", 6);
  1124. try
  1125. {
  1126. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(hourResult);
  1127. GlobalData.buYuanShuiWei_hour = new ShuiWeiBianHuaData();
  1128. GlobalData.buYuanShuiWei_hour.name = new string[tempData.data.Count];
  1129. GlobalData.buYuanShuiWei_hour.value = new double[tempData.data.Count];
  1130. for (int i = 0; i < tempData.data.Count; i++)
  1131. {
  1132. GlobalData.buYuanShuiWei_hour.name[i] = tempData.data[i].timeGroup;
  1133. GlobalData.buYuanShuiWei_hour.value[i] = double.Parse(tempData.data[i].avgS1);
  1134. }
  1135. }
  1136. catch (Exception e)
  1137. {
  1138. Debug.LogWarning("获取6小时平均数据不成功,原因:" + e.ToString());
  1139. }
  1140. }
  1141. public async Task InitSWYJData2()
  1142. {
  1143. var devicesInfo = _devicesIdDatas["SWJ01YQ"];
  1144. Debug.Log(devicesInfo.dataGid);
  1145. Debug.Log(devicesInfo.dataSid);
  1146. string sw1Result = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(), "d", 10000);
  1147. try
  1148. {
  1149. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw1Result);
  1150. if (tempData != null)
  1151. {
  1152. bool findData = false;
  1153. foreach (var VARIABLE in GlobalData.TaoKouShuiWeiDataList)
  1154. {
  1155. if (VARIABLE.name.Equals("套口上游水位"))
  1156. {
  1157. VARIABLE.value = float.Parse(tempData.data[0].avgS1);
  1158. VARIABLE.datas = tempData.data.ToArray();
  1159. findData = true;
  1160. }
  1161. }
  1162. if (!findData)
  1163. {
  1164. GlobalData.TaoKouShuiWeiDataList.Add(new ShuiWeiData()
  1165. {
  1166. name = "套口上游水位",
  1167. targetName = "TK_ShuiWei_Up",
  1168. value = float.Parse(tempData.data[0].avgS1),
  1169. type = shuiWeiType.TaoKouShuiWei,
  1170. datas = tempData.data.ToArray(),
  1171. sid = devicesInfo.dataSid.ToString(),
  1172. gid = devicesInfo.dataGid.ToString()
  1173. });
  1174. }
  1175. }
  1176. }
  1177. catch (Exception e)
  1178. {
  1179. Debug.LogWarning("套口上游水位不成功,原因:" + e.ToString());
  1180. }
  1181. var devicesInfo1 = _devicesIdDatas["SWJ02YQ"];
  1182. string sw2Result = await GetSingleDevicesInfo(1, devicesInfo1.dataGid.ToString(), devicesInfo1.dataSid.ToString(),
  1183. "d", 100000);
  1184. //Debug.Log("sw1Resultsw1Resultsw1Result下游水位计:" + sw2Result);
  1185. try
  1186. {
  1187. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw2Result);
  1188. if (tempData != null)
  1189. {
  1190. bool findData = false;
  1191. foreach (var VARIABLE in GlobalData.TaoKouShuiWeiDataList)
  1192. {
  1193. if (VARIABLE.name.Equals("套口下游水位"))
  1194. {
  1195. VARIABLE.value = float.Parse(tempData.data[0].avgS1);
  1196. VARIABLE.datas = tempData.data.ToArray();
  1197. findData = true;
  1198. }
  1199. }
  1200. if (!findData)
  1201. {
  1202. GlobalData.TaoKouShuiWeiDataList.Add(new ShuiWeiData()
  1203. {
  1204. name = "套口下游水位",
  1205. targetName = "TK_ShuiWei_Down",
  1206. value = float.Parse(tempData.data[0].avgS1),
  1207. type = shuiWeiType.TaoKouShuiWei,
  1208. datas = tempData.data.ToArray(),
  1209. sid = devicesInfo.dataSid.ToString(),
  1210. gid = devicesInfo.dataGid.ToString()
  1211. });
  1212. }
  1213. }
  1214. }
  1215. catch (Exception e)
  1216. {
  1217. Debug.LogWarning("套口下游水位不成功,原因:" + e.ToString());
  1218. }
  1219. string dayResult = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1220. "d", 6);
  1221. try
  1222. {
  1223. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(dayResult);
  1224. GlobalData.taoKouShuiWei_day = new ShuiWeiBianHuaData();
  1225. GlobalData.taoKouShuiWei_day.name = new string[tempData.data.Count];
  1226. GlobalData.taoKouShuiWei_day.value = new double[tempData.data.Count];
  1227. for (int i = 0; i < tempData.data.Count; i++)
  1228. {
  1229. GlobalData.taoKouShuiWei_day.name[i] = tempData.data[i].timeGroup;
  1230. GlobalData.taoKouShuiWei_day.value[i] = double.Parse(tempData.data[i].avgS1);
  1231. }
  1232. }
  1233. catch (Exception e)
  1234. {
  1235. Debug.LogWarning("获取6天平均数据不成功,原因:" + e.ToString());
  1236. }
  1237. string monthResult = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1238. "d", 90);
  1239. try
  1240. {
  1241. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(monthResult);
  1242. GlobalData.taoKouShuiWei_month = new ShuiWeiBianHuaData();
  1243. GlobalData.taoKouShuiWei_month.name = new string[tempData.data.Count];
  1244. GlobalData.taoKouShuiWei_month.value = new double[tempData.data.Count];
  1245. for (int i = 0; i < tempData.data.Count; i++)
  1246. {
  1247. GlobalData.taoKouShuiWei_month.name[i] = tempData.data[i].timeGroup;
  1248. GlobalData.taoKouShuiWei_month.value[i] = double.Parse(tempData.data[i].avgS1);
  1249. }
  1250. }
  1251. catch (Exception e)
  1252. {
  1253. Debug.LogWarning("获取6月平均数据不成功,原因:" + e.ToString());
  1254. }
  1255. string hourResult = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
  1256. "h", 6);
  1257. try
  1258. {
  1259. GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(hourResult);
  1260. GlobalData.taoKouShuiWei_hour = new ShuiWeiBianHuaData();
  1261. GlobalData.taoKouShuiWei_hour.name = new string[tempData.data.Count];
  1262. GlobalData.taoKouShuiWei_hour.value = new double[tempData.data.Count];
  1263. for (int i = 0; i < tempData.data.Count; i++)
  1264. {
  1265. GlobalData.taoKouShuiWei_hour.name[i] = tempData.data[i].timeGroup;
  1266. GlobalData.taoKouShuiWei_hour.value[i] = double.Parse(tempData.data[i].avgS1);
  1267. }
  1268. }
  1269. catch (Exception e)
  1270. {
  1271. Debug.LogWarning("获取6小时平均数据不成功,原因:" + e.ToString());
  1272. }
  1273. }
  1274. public async Task InitSWYJData3()
  1275. {
  1276. bool successInternet = true;
  1277. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGeSWData);
  1278. requestData.timeout = timeOut;
  1279. await requestData.SendWebRequest();
  1280. try
  1281. {
  1282. if (requestData.result != UnityWebRequest.Result.Success)
  1283. {
  1284. Debug.LogWarning("水位高度联网不成功,原因:返request不成功");
  1285. successInternet = false;
  1286. }
  1287. else
  1288. {
  1289. string postResult = requestData.downloadHandler.text;
  1290. if (useAes)
  1291. {
  1292. postResult = AESCrypto.Decrypt(postResult);
  1293. }
  1294. JObject jsonObject = JObject.Parse(postResult);
  1295. // 提取data字段的值
  1296. JToken dataToken = jsonObject["data"];
  1297. JToken codeToken = jsonObject["code"];
  1298. if (codeToken.ToString() == "200")
  1299. {
  1300. GlobalData.swDatas = JsonConvert.DeserializeObject<List<StationData>>(dataToken.ToString());
  1301. }
  1302. else
  1303. {
  1304. Debug.LogWarning("水位高度联网不成功,原因:返序列化失败");
  1305. successInternet = false;
  1306. }
  1307. for (int i = 0; i < GlobalData.BuYuanShuiWeiDataList.Count; i++)
  1308. {
  1309. StationData stationData = new StationData();
  1310. stationData.LGTD = 113.910187f;
  1311. stationData.LTTD = 30.1765823f;
  1312. stationData.STNM = GlobalData.BuYuanShuiWeiDataList[i].name;
  1313. stationData.upz = GlobalData.BuYuanShuiWeiDataList[i].name.Contains("上")
  1314. ? GlobalData.BuYuanShuiWeiDataList[i].value
  1315. : -1;
  1316. stationData.dwz = GlobalData.BuYuanShuiWeiDataList[i].name.Contains("下")
  1317. ? GlobalData.BuYuanShuiWeiDataList[i].value
  1318. : -1;
  1319. GlobalData.swDatas.Add(stationData);
  1320. }
  1321. }
  1322. }
  1323. catch (Exception e)
  1324. {
  1325. successInternet = false;
  1326. Debug.LogWarning("水位高度联网不成功,原因:" + e.ToString());
  1327. }
  1328. }
  1329. public async Task InitSWYJData0()
  1330. {
  1331. bool successInternet = true;
  1332. UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetThreeLevel);
  1333. requestData.timeout = timeOut;
  1334. await requestData.SendWebRequest();
  1335. try
  1336. {
  1337. if (requestData.result != UnityWebRequest.Result.Success)
  1338. {
  1339. Debug.LogWarning("三线水位联网不成功,原因:返request不成功");
  1340. successInternet = false;
  1341. }
  1342. else
  1343. {
  1344. string postResult = requestData.downloadHandler.text;
  1345. if (useAes)
  1346. {
  1347. postResult = AESCrypto.Decrypt(postResult);
  1348. }
  1349. JObject jsonObject = JObject.Parse(postResult);
  1350. // 提取data字段的值
  1351. JToken dataToken = jsonObject["data"];
  1352. JToken codeToken = jsonObject["code"];
  1353. if (codeToken.ToString() == "200")
  1354. {
  1355. GlobalData.threeLevelShuiWeiDatas =
  1356. JsonConvert.DeserializeObject<List<ThreeLevelShuiWeiData>>(dataToken.ToString());
  1357. }
  1358. else
  1359. {
  1360. Debug.LogWarning("三线水位联网不成功,原因:返序列化失败");
  1361. successInternet = false;
  1362. }
  1363. }
  1364. }
  1365. catch (Exception e)
  1366. {
  1367. successInternet = false;
  1368. Debug.LogWarning("三线水位联网不成功,原因:" + e.ToString());
  1369. }
  1370. }
  1371. public async Task SendBuYuan_GetSensorData()
  1372. {
  1373. UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_BuYuan_GetSensorData);
  1374. await www.SendWebRequest();
  1375. try
  1376. {
  1377. if (www.result != UnityWebRequest.Result.Success)
  1378. {
  1379. Debug.LogWarning("获取补元闸门设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1380. }
  1381. else
  1382. {
  1383. GlobalData.buYuanSensorData = JsonUtility.FromJson<SensorDataResult>(www.downloadHandler.text);
  1384. }
  1385. }
  1386. catch (Exception e)
  1387. {
  1388. Debug.LogWarning("获取补元闸门设备数据不成功,原因:" + e.ToString());
  1389. }
  1390. www.Dispose();
  1391. }
  1392. public async void GetBuYuanDevicesGroupInfo()
  1393. {
  1394. Debug.Log("获取补元所有渗压记");
  1395. Debug.Log(_devicesIdDatas.Count);
  1396. //获取所有渗压记
  1397. //GetDevicesData tempData = new GetDevicesData();
  1398. //tempData.idsList = new List<DevicesMessage>();
  1399. foreach (var device in _devicesIdDatas.Values)
  1400. {
  1401. if (device.stationName.Equals("补元") && device.sensorType.Equals("渗压计"))
  1402. {
  1403. GlobalData.BuYuanShuiYaDataList.Add(new ShuiYaData()
  1404. {
  1405. name = device.sensorName,
  1406. value = device.realtimeValue1,
  1407. type = shuiYaType.BuYuanShuiYa,
  1408. targetName = $"BY_{device.sensorName}",
  1409. gid = device.dataGid.ToString(),
  1410. sid = device.dataSid.ToString()
  1411. });
  1412. }
  1413. }
  1414. Debug.Log("添加补元渗压记:" + GlobalData.BuYuanShuiYaDataList.Count);
  1415. Debug.Log("获取补元所有位移记");
  1416. //获取所有位移记
  1417. foreach (var device in _devicesIdDatas.Values)
  1418. {
  1419. if (device.stationName.Equals("补元") && device.sensorType.Equals("静力水准仪"))
  1420. {
  1421. GlobalData.BuYuanWeiYiDataList.Add(new WeiYiData()
  1422. {
  1423. name = device.sensorName,
  1424. value = device.realtimeValue1,
  1425. type = weiYiType.BuYuanWeiYi,
  1426. targetName = $"BY_{device.sensorName}",
  1427. gid = device.dataGid.ToString(),
  1428. sid = device.dataSid.ToString()
  1429. });
  1430. }
  1431. }
  1432. Debug.Log("添加补元位移记:" + GlobalData.BuYuanWeiYiDataList.Count);
  1433. }
  1434. public async void GetTaoKouDevicesGroupInfo()
  1435. {
  1436. Debug.Log("获取套口所有渗压记");
  1437. //获取所有渗压记
  1438. foreach (var device in _devicesIdDatas.Values)
  1439. {
  1440. if (device.stationName.Equals("套口") && device.sensorType.Equals("渗压计"))
  1441. {
  1442. GlobalData.TaoKouShuiYaDataList.Add(new ShuiYaData()
  1443. {
  1444. name = device.sensorName,
  1445. value = device.realtimeValue1,
  1446. type = shuiYaType.TaoKouShuiYa,
  1447. targetName = $"TK_{device.sensorName}",
  1448. gid = device.dataGid.ToString(),
  1449. sid = device.dataSid.ToString()
  1450. });
  1451. }
  1452. }
  1453. Debug.Log("添加套口渗压记:" + GlobalData.TaoKouShuiYaDataList.Count);
  1454. Debug.Log("获取套口所有位移记");
  1455. //获取所有位移记
  1456. foreach (var device in _devicesIdDatas.Values)
  1457. {
  1458. if (device.stationName.Equals("补元") && device.sensorType.Equals("静力水准仪"))
  1459. {
  1460. GlobalData.TaoKouWeiYiDataList.Add(new WeiYiData()
  1461. {
  1462. name = device.sensorName,
  1463. value = device.realtimeValue1,
  1464. type = weiYiType.TaoKouWeiYi,
  1465. targetName = $"TK_{device.sensorName}",
  1466. gid = device.dataGid.ToString(),
  1467. sid = device.dataSid.ToString()
  1468. });
  1469. }
  1470. }
  1471. Debug.Log("添加套口位移记:" + GlobalData.TaoKouWeiYiDataList.Count);
  1472. }
  1473. public async Task SendTaoKou_GetSensorData()
  1474. {
  1475. UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_TaoKou_GetSensorData);
  1476. await www.SendWebRequest();
  1477. try
  1478. {
  1479. if (www.result != UnityWebRequest.Result.Success)
  1480. {
  1481. Debug.LogWarning("获取套口闸门设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1482. }
  1483. else
  1484. {
  1485. GlobalData.taoKouSensorData = JsonUtility.FromJson<SensorDataResult>(www.downloadHandler.text);
  1486. Debug.Log($"获取套口闸门设备数据:{GlobalData.taoKouSensorData.data.Count}");
  1487. }
  1488. }
  1489. catch (Exception e)
  1490. {
  1491. Debug.LogWarning("获取套口闸门设备数据不成功,原因:" + e.ToString());
  1492. }
  1493. www.Dispose();
  1494. }
  1495. /// <summary>
  1496. /// 获取设备趋势数据
  1497. /// </summary>
  1498. /// <param name="type">0:补元 1:套口</param>
  1499. /// <param name="gid">=devicesID 套口都传一样=sid</param>
  1500. /// <param name="sid">=ChannelID 套口都传一样=sid</param>
  1501. /// <param name="beginTime">yyyy-MM-dd 最大183天</param>
  1502. /// <param name="endTime"></param>
  1503. /// <returns></returns>
  1504. public async Task<string> GetDeviceTrend(int type, string gid, string sid, string beginTime, string endTime)
  1505. {
  1506. string cmdUrl = ServerAddress.APIGetDeviceTrend;
  1507. cmdUrl += $"/{(type==0?"buyuan":"taokou")}/{gid}/{sid}?beginTime={beginTime}&endTime={endTime}";
  1508. UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
  1509. www.downloadHandler = new DownloadHandlerBuffer();
  1510. www.SetRequestHeader("Content-Type", "application/json");
  1511. Debug.Log("send:"+cmdUrl);
  1512. await www.SendWebRequest();
  1513. if (www.result != UnityWebRequest.Result.Success)
  1514. {
  1515. Debug.LogWarning("获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1516. }
  1517. string result = www.downloadHandler.text;
  1518. www.Dispose();
  1519. return result;
  1520. }
  1521. // /// <summary>
  1522. // /// 获取补元硬件组数据
  1523. // /// </summary>
  1524. // /// <param name="sendData"></param>
  1525. // /// <returns></returns>
  1526. // public async Task<string> Devices(GetDevicesData sendData)
  1527. // {
  1528. // string cmdUrl = ServerAddress.API_BuYuan_GetDevicesGroupInfo;
  1529. // string tempStr = JsonConvert.SerializeObject(sendData);
  1530. // var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
  1531. // UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
  1532. // www.uploadHandler = new UploadHandlerRaw(sendByte);
  1533. // www.downloadHandler = new DownloadHandlerBuffer();
  1534. // www.SetRequestHeader("Content-Type", "application/json");
  1535. // await www.SendWebRequest();
  1536. // if (www.result != UnityWebRequest.Result.Success)
  1537. // {
  1538. // Debug.LogWarning($"获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1539. // }
  1540. // string result = www.downloadHandler.text;
  1541. // www.Dispose();
  1542. // return result;
  1543. // }
  1544. /// <summary>
  1545. /// 获取设备的最近N条记录
  1546. /// </summary>
  1547. /// <param name="channelId=gid"></param>
  1548. /// <param name="deviceId=sid"></param>
  1549. /// <param name="count"></param>
  1550. /// <returns></returns>
  1551. public async Task<string> GetSingleDevicesInfo(int type, string gid, string sid, string timeUnit, int count)
  1552. {
  1553. string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo;
  1554. cmdUrl += $"?dataFrom={type}&dataSid={sid}&dataGid={gid}&timeUnit={timeUnit}&number={count}";
  1555. UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
  1556. www.downloadHandler = new DownloadHandlerBuffer();
  1557. www.SetRequestHeader("Content-Type", "application/json");
  1558. await www.SendWebRequest();
  1559. if (www.result != UnityWebRequest.Result.Success)
  1560. {
  1561. Debug.LogWarning("获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1562. }
  1563. string result = www.downloadHandler.text;
  1564. www.Dispose();
  1565. return result;
  1566. }
  1567. /// <summary>
  1568. /// 获取设备最近几天的平均数据
  1569. /// </summary>
  1570. /// <param name="channelId"></param>
  1571. /// <param name="deviceId"></param>
  1572. /// <param name="count"></param>
  1573. /// <returns></returns>
  1574. public async Task<string> GetSingleDevicesInfo_day(int channelId, int deviceId, int count)
  1575. {
  1576. string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo_avg;
  1577. GetSingleDeviceData_AvgType sendData = new GetSingleDeviceData_AvgType();
  1578. sendData.ChannelID = channelId;
  1579. sendData.DeviceID = deviceId;
  1580. sendData.AvgType = "day";
  1581. sendData.N = count;
  1582. string tempStr = JsonConvert.SerializeObject(sendData);
  1583. var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
  1584. UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
  1585. www.uploadHandler = new UploadHandlerRaw(sendByte);
  1586. www.downloadHandler = new DownloadHandlerBuffer();
  1587. www.SetRequestHeader("Content-Type", "application/json");
  1588. await www.SendWebRequest();
  1589. if (www.result != UnityWebRequest.Result.Success)
  1590. {
  1591. Debug.LogWarning("获取设备天平均数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1592. }
  1593. string result = www.downloadHandler.text;
  1594. www.Dispose();
  1595. return result;
  1596. }
  1597. /// <summary>
  1598. /// 获取设备最近几小时的平均数据
  1599. /// </summary>
  1600. /// <param name="channelId"></param>
  1601. /// <param name="deviceId"></param>
  1602. /// <param name="count"></param>
  1603. /// <returns></returns>
  1604. public async Task<string> GetSingleDevicesInfo_hour(int channelId, int deviceId, int count)
  1605. {
  1606. string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo_avg;
  1607. GetSingleDeviceData_AvgType sendData = new GetSingleDeviceData_AvgType();
  1608. sendData.ChannelID = channelId;
  1609. sendData.DeviceID = deviceId;
  1610. sendData.AvgType = "hour";
  1611. sendData.N = count;
  1612. string tempStr = JsonConvert.SerializeObject(sendData);
  1613. var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
  1614. UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
  1615. www.uploadHandler = new UploadHandlerRaw(sendByte);
  1616. www.downloadHandler = new DownloadHandlerBuffer();
  1617. www.SetRequestHeader("Content-Type", "application/json");
  1618. await www.SendWebRequest();
  1619. if (www.result != UnityWebRequest.Result.Success)
  1620. {
  1621. Debug.LogWarning("获取设备小时平均数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1622. }
  1623. string result = www.downloadHandler.text;
  1624. www.Dispose();
  1625. return result;
  1626. }
  1627. /// <summary>
  1628. /// 获取设备最近几个月的平均数据
  1629. /// </summary>
  1630. /// <param name="channelId"></param>
  1631. /// <param name="deviceId"></param>
  1632. /// <param name="count"></param>
  1633. /// <returns></returns>
  1634. public async Task<string> GetSingleDevicesInfo_month(int channelId, int deviceId, int count)
  1635. {
  1636. string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo_avg;
  1637. GetSingleDeviceData_AvgType sendData = new GetSingleDeviceData_AvgType();
  1638. sendData.ChannelID = channelId;
  1639. sendData.DeviceID = deviceId;
  1640. sendData.AvgType = "month";
  1641. sendData.N = count;
  1642. string tempStr = JsonConvert.SerializeObject(sendData);
  1643. var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
  1644. UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
  1645. www.uploadHandler = new UploadHandlerRaw(sendByte);
  1646. www.downloadHandler = new DownloadHandlerBuffer();
  1647. www.SetRequestHeader("Content-Type", "application/json");
  1648. await www.SendWebRequest();
  1649. if (www.result != UnityWebRequest.Result.Success)
  1650. {
  1651. Debug.LogWarning("获取设备月平均数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1652. }
  1653. string result = www.downloadHandler.text;
  1654. www.Dispose();
  1655. return result;
  1656. }
  1657. /// <summary>
  1658. /// 0 补元 1套口
  1659. /// </summary>
  1660. /// <param name="type"></param>
  1661. public async Task InitGCYWData1(int type)
  1662. {
  1663. Debug.Log($"获取B08GCYW 数据:{(type == 0 ? "补元" : "套口")}");
  1664. GlobalData.B08_Type = type;
  1665. string jsonStr;
  1666. try
  1667. {
  1668. jsonStr = await B08_API_data(ServerAddress.API_B08_dataStatis, type);
  1669. Debug.Log("API_B08_dataStatis" + jsonStr);
  1670. GlobalData.B08DataStatis = JsonConvert.DeserializeObject<B08_dataStatis>(jsonStr);
  1671. }
  1672. catch (Exception e)
  1673. {
  1674. Debug.LogWarning("获取API_B08_dataStatis数据不成功,原因:" + e.ToString());
  1675. }
  1676. try
  1677. {
  1678. jsonStr = await B08_API_data(ServerAddress.API_B08_inspectResult, type);
  1679. Debug.Log("API_B08_inspectResult" + jsonStr);
  1680. GlobalData.B08InspectResult = JsonConvert.DeserializeObject<B08_inspectResult>(jsonStr);
  1681. }
  1682. catch (Exception e)
  1683. {
  1684. Debug.LogWarning("获取API_B08_inspectResult数据不成功,原因:" + e.ToString());
  1685. }
  1686. try
  1687. {
  1688. jsonStr = await B08_API_data(ServerAddress.API_B08_projectExamine, type);
  1689. Debug.Log("API_B08_projectExamine" + jsonStr);
  1690. GlobalData.B08ProjectExamine = JsonConvert.DeserializeObject<B08_projectExamine>(jsonStr);
  1691. }
  1692. catch (Exception e)
  1693. {
  1694. Debug.LogWarning("获取API_B08_projectExamine数据不成功,原因:" + e.ToString());
  1695. }
  1696. try
  1697. {
  1698. jsonStr = await B08_API_data(ServerAddress.API_B08_event, type);
  1699. Debug.Log("API_B08_event" + jsonStr);
  1700. GlobalData.B08Event = JsonConvert.DeserializeObject<B08_event>(jsonStr);
  1701. }
  1702. catch (Exception e)
  1703. {
  1704. Debug.LogWarning("获取API_B08_event数据不成功,原因:" + e.ToString());
  1705. }
  1706. try
  1707. {
  1708. jsonStr = await B08_API_data(ServerAddress.API_B08_questionStatis, type);
  1709. Debug.Log("API_B08_questionStatis" + jsonStr);
  1710. GlobalData.B08QuestionStatis = JsonConvert.DeserializeObject<B08_questionStatis>(jsonStr);
  1711. }
  1712. catch (Exception e)
  1713. {
  1714. Debug.LogWarning("获取API_B08_questionStatis数据不成功,原因:" + e.ToString());
  1715. }
  1716. try
  1717. {
  1718. jsonStr = await B08_API_data(ServerAddress.API_B08_inspectType, type);
  1719. Debug.Log("API_B08_inspectType" + jsonStr);
  1720. GlobalData.B08InspectType = JsonConvert.DeserializeObject<B08_inspectType>(jsonStr);
  1721. GlobalData.B08TaskListInfos = new B08_TaskListInfoData[GlobalData.B08InspectType.data.Length];
  1722. for (int i = 0; i < GlobalData.B08InspectType.data.Length; i++)
  1723. {
  1724. string tempResult = await B08_API_TaskInfo(type, i);
  1725. Debug.Log($"B08_API_TaskInfo type={i}:" + tempResult);
  1726. GlobalData.B08TaskListInfos[i] = JsonConvert.DeserializeObject<B08_TaskListInfoData>(tempResult);
  1727. }
  1728. }
  1729. catch (Exception e)
  1730. {
  1731. Debug.LogWarning("获取API_B08_inspectType数据不成功,原因:" + e.ToString());
  1732. }
  1733. }
  1734. public async Task<string> B08_API_data(string cmdUrl, int type)
  1735. {
  1736. if (type == 0)
  1737. {
  1738. cmdUrl += "1794245918999351298";
  1739. }
  1740. else if (type == 1)
  1741. {
  1742. cmdUrl += "1798366756789653505";
  1743. }
  1744. UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
  1745. www.downloadHandler = new DownloadHandlerBuffer();
  1746. www.SetRequestHeader("Content-Type", "application/json");
  1747. await www.SendWebRequest();
  1748. if (www.result != UnityWebRequest.Result.Success)
  1749. {
  1750. Debug.LogWarning($"获取{cmdUrl}数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1751. }
  1752. string result = www.downloadHandler.text;
  1753. www.Dispose();
  1754. return result;
  1755. }
  1756. public async Task<string> B08_API_TaskInfo(int type, int xunjian_type)
  1757. {
  1758. string cmdUrl = ServerAddress.API_B08_taskInfo;
  1759. if (type == 0)
  1760. {
  1761. cmdUrl += "1794245918999351298";
  1762. }
  1763. else if (type == 1)
  1764. {
  1765. cmdUrl += "1798366756789653505";
  1766. }
  1767. cmdUrl += "&xunjian_type=" + xunjian_type;
  1768. Debug.Log("!!!:" + cmdUrl);
  1769. UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
  1770. www.downloadHandler = new DownloadHandlerBuffer();
  1771. www.SetRequestHeader("Content-Type", "application/json");
  1772. await www.SendWebRequest();
  1773. if (www.result != UnityWebRequest.Result.Success)
  1774. {
  1775. Debug.LogWarning($"获取B08_API_TaskInfo type={type} 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1776. }
  1777. string result = www.downloadHandler.text;
  1778. www.Dispose();
  1779. return result;
  1780. }
  1781. /// <summary>
  1782. /// 获取站点水位信息
  1783. /// </summary>
  1784. /// <param name="stcd"></param>
  1785. /// <returns></returns>
  1786. public async Task<string> GetWaterTrend_Chart(string stcd)
  1787. {
  1788. UnityWebRequest www = new UnityWebRequest(ServerAddress.API_GetWaterTrend_chart + stcd, "Get");
  1789. www.downloadHandler = new DownloadHandlerBuffer();
  1790. www.SetRequestHeader("Content-Type", "application/json");
  1791. await www.SendWebRequest();
  1792. if (www.result != UnityWebRequest.Result.Success)
  1793. {
  1794. Debug.LogWarning($"获取stcd:{stcd},水位统计信息数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1795. }
  1796. string result = www.downloadHandler.text;
  1797. www.Dispose();
  1798. return result;
  1799. }
  1800. public async Task<string> GetWaterTrend_List(string stcd)
  1801. {
  1802. UnityWebRequest www = new UnityWebRequest(ServerAddress.API_GetWaterTrend_list + stcd, "Get");
  1803. www.downloadHandler = new DownloadHandlerBuffer();
  1804. www.SetRequestHeader("Content-Type", "application/json");
  1805. await www.SendWebRequest();
  1806. if (www.result != UnityWebRequest.Result.Success)
  1807. {
  1808. Debug.LogWarning($"获取stcd:{stcd},水位统计信息数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1809. }
  1810. string result = www.downloadHandler.text;
  1811. www.Dispose();
  1812. return result;
  1813. }
  1814. public void SaveFirstFrame(byte[] uploadData, string fileName, string _targetName)
  1815. {
  1816. StartCoroutine(SendSaveFirstFrame(uploadData, fileName, _targetName));
  1817. }
  1818. IEnumerator SendSaveFirstFrame(byte[] uploadData, string fileName, string _targetName)
  1819. {
  1820. Debug.Log(fileName);
  1821. WWWForm form = new WWWForm();
  1822. form.AddBinaryData("file", uploadData, fileName);
  1823. UnityWebRequest www = UnityWebRequest.Post(ServerAddress.API_TextureUploadPath, form);
  1824. yield return www.SendWebRequest();
  1825. if (www.result == UnityWebRequest.Result.Success)
  1826. {
  1827. ActionInstance._Instance.obsFmUpdata?.Invoke(_targetName);
  1828. }
  1829. Debug.Log(www.downloadHandler.text);
  1830. www.Dispose();
  1831. }
  1832. #region 摄像头远程控制
  1833. public void GetDeviceChannelId(string deviceId, Action<string> callBack)
  1834. {
  1835. StartCoroutine(SendGetDevicesChannel(deviceId, 1, 1, callBack));
  1836. }
  1837. IEnumerator SendGetDevicesChannel(string deviceId, int page, int count, Action<string> call)
  1838. {
  1839. string sendUrl = ServerAddress.API_GetDevicesInfo;
  1840. sendUrl += $"/{deviceId}/channels?page={page}&count={count}&query&online&channelType&catalogUnderDevice";
  1841. UnityWebRequest www = UnityWebRequest.Get(sendUrl);
  1842. yield return www.SendWebRequest();
  1843. ObsHttpRequestData tempData = JsonConvert.DeserializeObject<ObsHttpRequestData>(www.downloadHandler.text);
  1844. GetObsChannelRequestData channelData = tempData.data.ToObject<GetObsChannelRequestData>();
  1845. call?.Invoke(channelData.list[0].channelId);
  1846. www.Dispose();
  1847. }
  1848. IEnumerator SendStartRTSP(string deviceId, string channelId)
  1849. {
  1850. string sendUrl = ServerAddress.API_PlayStart;
  1851. sendUrl += $"/{deviceId}/{channelId}";
  1852. UnityWebRequest www = UnityWebRequest.Get(sendUrl);
  1853. yield return www.SendWebRequest();
  1854. Debug.Log(www.downloadHandler.text);
  1855. www.Dispose();
  1856. }
  1857. public void SendObsCameraCtrlCmd(string deviceId, string channelId, ObsCtrlType type)
  1858. {
  1859. StartCoroutine(SendCameraCtrl(deviceId, channelId, type.ToString()));
  1860. }
  1861. IEnumerator SendCameraCtrl(string deviceId, string channelId, string command)
  1862. {
  1863. string sendUrl = ServerAddress.API_CameraCtrl;
  1864. sendUrl += $"/{deviceId}/{channelId}?command={command}&horizonSpeed=10&verticalSpeed=10&zoomSpeed=10";
  1865. UnityWebRequest www = UnityWebRequest.Post(sendUrl, "");
  1866. Debug.Log("send:" + sendUrl);
  1867. yield return www.SendWebRequest();
  1868. Debug.Log(www.downloadHandler.text);
  1869. www.Dispose();
  1870. }
  1871. #endregion
  1872. // /// <summary>
  1873. // /// 所有硬件设备的获取信息
  1874. // /// </summary>
  1875. public async Task GetSensorList()
  1876. {
  1877. bool successInternet = true;
  1878. UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_GetAllSensorList);
  1879. www.timeout = timeOut;
  1880. await www.SendWebRequest();
  1881. try
  1882. {
  1883. if (www.result != UnityWebRequest.Result.Success)
  1884. {
  1885. successInternet = false;
  1886. Debug.LogWarning("获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
  1887. }
  1888. else
  1889. {
  1890. SensorListResult tempData = JsonUtility.FromJson<SensorListResult>(www.downloadHandler.text);
  1891. _devicesIdDatas = new Dictionary<string, DevicesId_Data>();
  1892. for (int i = 0; i < tempData.rows.Count; i++)
  1893. {
  1894. _devicesIdDatas.Add(tempData.rows[i].sensorName, tempData.rows[i]);
  1895. }
  1896. Debug.Log($"初始化设备列表成功!!! count:{tempData.total}");
  1897. }
  1898. }
  1899. catch (Exception e)
  1900. {
  1901. successInternet = false;
  1902. Debug.LogWarning("获取设备数据不成功,原因:" + e.ToString());
  1903. }
  1904. www.Dispose();
  1905. if (!successInternet)
  1906. {
  1907. WWW localWWW = new WWW(Application.streamingAssetsPath + "/SensorList.json");
  1908. await new UnityAsync.WaitUntil(() => { return localWWW.isDone; });
  1909. SensorListResult tempData = JsonUtility.FromJson<SensorListResult>(localWWW.text);
  1910. _devicesIdDatas = new Dictionary<string, DevicesId_Data>();
  1911. for (int i = 0; i < tempData.rows.Count; i++)
  1912. {
  1913. _devicesIdDatas.Add(tempData.rows[i].sensorName, tempData.rows[i]);
  1914. }
  1915. Debug.Log($"读取本地初始化设备列表成功!!! count:{tempData.total}");
  1916. www.Dispose();
  1917. }
  1918. // var devicesInfo = _devicesIdDatas["上游水位计"];
  1919. // GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
  1920. // {
  1921. // name = "补元上游水位",
  1922. // targetName = "BY_ShuiWei_Up",
  1923. // value = devicesInfo.realtimeValue1,
  1924. // type = shuiWeiType.BuYuanShuiWei,
  1925. // datas = new []{new SingleDevicesRequestData()
  1926. // {
  1927. // avgS1 = devicesInfo.realtimeValue1.ToString(),
  1928. // timeGroup = devicesInfo.dataUpdateTime
  1929. // }}
  1930. // });
  1931. // var devicesInfo1 = _devicesIdDatas["下游水位计"];
  1932. // GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
  1933. // {
  1934. // name = "补元下游水位",
  1935. // targetName = "BY_ShuiWei_Down",
  1936. // value = devicesInfo1.realtimeValue1,
  1937. // type = shuiWeiType.BuYuanShuiWei,
  1938. // datas = new []{new SingleDevicesRequestData()
  1939. // {
  1940. // avgS1 = devicesInfo1.realtimeValue1.ToString(),
  1941. // timeGroup = devicesInfo1.dataUpdateTime
  1942. // }}
  1943. // });
  1944. }
  1945. }