HttpHelper.cs 83 KB

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