HttpHelper.cs 87 KB

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