WaterFlush/Assets/Scripts/HttpHelper.cs

using System;

using System.Collections;
using System.Collections.Generic;
using System.IO;
using System.Threading.Tasks;
using UnityAsync;
using Best.HTTP;
using Best.HTTP.JSON;
using Newtonsoft.Json;
using Newtonsoft.Json.Serialization;
using Newtonsoft.Json.Linq;
using UnityEngine;
using UnityEngine.Networking;
using Unity.VisualScripting;
using static System.Net.WebRequestMethods;
using System.Linq;
using UniTask = Cysharp.Threading.Tasks.UniTask;
using UniTaskVoid = Cysharp.Threading.Tasks.UniTaskVoid;

public class HttpHelper : MonoBehaviour
{
    public Action OnSWYJRefresh;

    public static bool useAes = false;

    public static HttpHelper _Instance;


    public const int timeOut = 3;

    class DYServerAddress
    {

        public string YZTServerAddress;
        public string YZTServerPYAddress;
        public string Server_UploadPath;
        public string ModbusSeverAddress;
        public string ObsSeverAddress;
        public string ObsSeverM3U8Address;
    }

    void ChangeServerAddress()
    {
        //if (System.IO.File.Exists(Application.streamingAssetsPath + "/serverPath.json"))
        //{
        //    string serverAddressContent = System.IO.File.ReadAllText(Application.streamingAssetsPath + "/serverPath.json");
        //    Debug.Log(serverAddressContent);
        //    DYServerAddress address = JsonConvert.DeserializeObject<DYServerAddress>(serverAddressContent);
        //    ServerAddress.YZTServerAddress = address.YZTServerAddress;
        //    ServerAddress.YZTServerPYAddress = address.YZTServerPYAddress;
        //    ServerAddress.Server_UploadPath = address.Server_UploadPath;
        //    ServerAddress.ModbusSeverAddress = address.ModbusSeverAddress;
        //    ServerAddress.ObsSeverAddress = address.ObsSeverAddress;
        //    Debug.Log(ServerAddress.ObsSeverAddress);
        //    ServerAddress.ObsSeverM3U8Address = address.ObsSeverM3U8Address;
        //}
    }

    private async UniTaskVoid Awake()
    {
        _Instance = this;

        ChangeServerAddress();
        
        try
        {
            var tokenJson = await B08_API_GetToken();
            GetToken tokenResult= JsonConvert.DeserializeObject<GetToken>(tokenJson);
            //Debug.Log("GetToken:" + tokenResult.data.token);
            token = tokenResult.data.token;
        }
        catch (Exception e)
        {
            Debug.LogWarning("GetToken不成功,原因:" + e.ToString());
        }


        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2 ||
            GlobalData.pageIndex == PageIndex.Page3)
        {
            Debug.Log("HttpInitYZTData");
            //可以并行，无需等待
            InitYZTData();
        }

        if (GlobalData._devicesIdDatas.Count < 1)
        {
            await GetSensorList();
        }

        if (GlobalData.pageIndex == PageIndex.Page1)
        {

            SendBuYuan_GetSensorData();
            SendTaoKou_GetSensorData();
            GetBuYuanDevicesGroupInfo();
            GetTaoKouDevicesGroupInfo();
        }

        if (GlobalData.pageIndex == PageIndex.Page2)
        {
            SendBuYuan_GetSensorData();
            SendTaoKou_GetSensorData();
        }

        if (GlobalData.pageIndex == PageIndex.Page1)
        {
            Debug.Log("InitXHGKData");
            //可以并行，无需等待
            InitXHGKData(); //已完成迁移
        }

        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2)
        {
            Debug.Log("HttpInitGCJKData");
            //可以并行，无需等待
            InitGCJKData();
            InitGCJKData2();
            InitGCJKData1h();
        }

        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page3)
        {
            Debug.Log("HttpInitXHDDData");
            //可以并行，无需等待
            InitXHDDData0();
            InitXHDDData1();
            InitXHDDData2();
            InitXHDDData3();
        }

        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page3)
        {
            Debug.Log("HttpInitRKZYData");
            //可以并行，无需等待
            InitRKZYData();
        }

        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2 || GlobalData.pageIndex == PageIndex.Page3)
        {
            Debug.Log("HttpInitSWYJData");
            //可以并行，无需等待
            InitSWYJData();
        }

        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2)
        {
            
            GetGCYW_Station().Forget();
        }

        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2 ||
            GlobalData.pageIndex == PageIndex.Page3)
        {
            Debug.Log("HttpInitFloorGateData");
            InitFloorGateData();
        }

        if (GlobalData.pageIndex == PageIndex.Page2)
        {
            Debug.Log("HttpInitDPSWData");
            //InitDPSWData();
            InitDPXHQData();
        }

        if (GlobalData.pageIndex == PageIndex.Page2)
        {
            Debug.Log("HttpInitGCYWData2");
            InitGCYWData2();
        }

        if (GlobalData.pageIndex == PageIndex.Page2)
        {
            Debug.Log("HttpInitYJSJData2");
            InitYJSJData2();
        }
    }

    private async Task InitGCYWData2()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetInspectionStatistics);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("大屏运维数据联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.InspectionStat =
                        JsonConvert.DeserializeObject<List<StationInspection>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("大屏运维数据联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("大屏运维数据联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/inspectionStatistics.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            GlobalData.InspectionStat = JsonConvert.DeserializeObject<List<StationInspection>>(www.text);
            www.Dispose();
        }
    }

    private async Task InitYJSJData2()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetAlertData);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("大屏预警数据联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.alertData = JsonConvert.DeserializeObject<AlertData>(dataToken.ToString());
                    GlobalData.alertData.success = true;
                }
                else
                {
                    Debug.LogWarning("大屏预警数据联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("大屏预警数据联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/alertData.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            Debug.Log(www.text);
            GlobalData.alertData = JsonConvert.DeserializeObject<AlertData>(www.text.ToString());
            GlobalData.alertData.success = true;
            Debug.Log(GlobalData.alertData.alerts.threeLineWarnings[0].title);
            www.Dispose();
        }
    }

    private async Task InitFloorGateData()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetFloodGateData);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("大屏闸口数据联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                Debug.Log("大屏闸口数据:" + postResult);
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    Debug.Log(dataToken);
                    GlobalData.floorGateData = JsonConvert.DeserializeObject<FloodGateStatusData>(dataToken.ToString());
                    GlobalData.floorGateData.success = true;
                    //Debug.Log("GlobalData.floorGateData.success:" + GlobalData.floorGateData.success);
                }
                else
                {
                    Debug.LogWarning("大屏闸口数据联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("大屏闸口数据联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/floodGateStatusData.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            Debug.Log(www.text);
            GlobalData.floorGateData = JsonConvert.DeserializeObject<FloodGateStatusData>(www.text.ToString());
            GlobalData.floorGateData.success = true;
            www.Dispose();
        }
    }

    public async Task InitDPXHQData()
    {
        GlobalData.floodStorageArea = new FloodStorageArea();
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetDPXHQData);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("大屏蓄洪区数据联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    //LocationWeatherData data1 =
                    //    JsonConvert.DeserializeObject<LocationWeatherData>(dataToken.ToString());
                    //GlobalData.locationWeatherData.Add(data1);
                }
                else
                {
                    Debug.LogWarning("大屏蓄洪区数据联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("大屏蓄洪区数据联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/xhq.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            // Debug.Log(www.text);
            GlobalData.floodStorageArea =
                JsonConvert.DeserializeObject<FloodStorageArea>(www.text.ToString());
            GlobalData.floodStorageArea.done = true;
            www.Dispose();
            //Debug.Log(GlobalData.floodStorageArea.pumpStations.value);
        }
        requestData.Dispose();
    }

    private async Task InitDPSWData()
    {
        GlobalData.locationWeatherData = new List<LocationWeatherData>();
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetHydrologicalData + "?projectType=1");
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("大屏水文数据联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    LocationWeatherData data1 =
                        JsonConvert.DeserializeObject<LocationWeatherData>(dataToken.ToString());
                    GlobalData.locationWeatherData.Add(data1);
                }
                else
                {
                    Debug.LogWarning("大屏水文数据联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("大屏水文数据联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        UnityWebRequest requestData1 = UnityWebRequest.Get(ServerAddress.APIGetHydrologicalData + "?projectType=2");
        requestData1.timeout = timeOut;
        await requestData1.SendWebRequest();
        try
        {
            if (requestData1.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("大屏水文数据联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData1.downloadHandler.text);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    LocationWeatherData data2 =
                        JsonConvert.DeserializeObject<LocationWeatherData>(dataToken.ToString());
                    GlobalData.locationWeatherData.Add(data2);
                }
                else
                {
                    Debug.LogWarning("大屏水文数据联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("大屏水文数据联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/hydrologicalData.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            Debug.Log(www.text);
            GlobalData.locationWeatherData =
                JsonConvert.DeserializeObject<List<LocationWeatherData>>(www.text.ToString());
            www.Dispose();
        }
    }


    public async void InitYZTData()
    {
        await InitYZTData1(); //已完成迁移
        InitYZTData_BY_Obs(); //已完成迁移
        InitYZTData_TK_Obs(); //新增
        InitYZTData3(); //已完成迁移
        InitGCGKData();
        InitJKYJData();
    }

    public async Task InitYZTData1()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterManagerProject);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (true)
            {
                Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.layerUnitDatas =
                        JsonConvert.DeserializeObject<List<LayerUnitData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/layerUnitDatas.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            GlobalData.layerUnitDatas = JsonConvert.DeserializeObject<List<LayerUnitData>>(www.text);
            www.Dispose();
        }

        for (int i = 0; i < GlobalData.layerUnitDatas.Count; i++)
        {
            if (GlobalData.layerUnitDatas[i].type == LayerUnitType.JK)
            {
                if (!GlobalData.obsCameraLib.ContainsKey(GlobalData.layerUnitDatas[i].name))
                    GlobalData.obsCameraLib.Add(GlobalData.layerUnitDatas[i].name, GlobalData.layerUnitDatas[i].namePri);
            }
        }
    }

    public async Task InitYZTData_BY_Obs()
    {
        bool successInternet = true;
        string sendUrl = ServerAddress.API_GetDevicesInfo;
        Debug.Log(ServerAddress.ObsSeverAddress);
        sendUrl += "/34020000001180000001/channels?page=1&count=100";
        Debug.Log(sendUrl);
        UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("补元监控数据联网不成功,原因:返request不成功:" + requestData.error);
                successInternet = false;
            }
            else
            {
                Debug.Log("补元监控数据返回:" + requestData.downloadHandler.text);
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);


                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "0")
                {
                    GlobalData.obsDatas_by = new List<ObsData>();
                    ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
                    for (int i = 0; i < serverObsDatas.list.Count; i++)
                    {
                        ObsData obsData = new ObsData();
                        string originName = serverObsDatas.list[i].name;
                        obsData.name = "BY_" + serverObsDatas.list[i].name;
                        //Debug.Log("111" + obsData.name);
                        if (GlobalData.obsCameraLib.TryGetValue(obsData.name, out var value))
                        {
                            obsData.targetName = value;
                        }

                        obsData.type = obsType.BuYuanObs;
                        obsData.deviceId = serverObsDatas.list[i].deviceId;
                        obsData.channelId = serverObsDatas.list[i].channelId;
                        GlobalData.obsDeviceIDLib.Add(obsData.name, obsData.channelId);
                        obsData.status = serverObsDatas.list[i].status;
                        GlobalData.obsDatas_by.Add(obsData);
                    }
                }
                else
                {
                    Debug.LogWarning("补元监控数据联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("补元监控数据联网不成功,原因:" + e.ToString());
        }

        requestData.Dispose();

        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas_BY.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });

            Debug.Log($"缓存数据:{www.text}");
            GlobalData.obsDatas_by = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
            www.Dispose();
        }
    }

    public async Task InitYZTData_TK_Obs()
    {
        bool successInternet = true;
        string sendUrl = ServerAddress.API_GetDevicesInfo;
        sendUrl += "/34020000001180000002/channels?page=1&count=100";
        Debug.Log(sendUrl);
        UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("套口监控数据联网不成功,原因:返request不成功:" + requestData.error);
                successInternet = false;
            }
            else
            {

                Debug.Log("套口监控数据返回:" + requestData.downloadHandler.text);
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);


                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "0")
                {
                    GlobalData.obsDatas_tk = new List<ObsData>();
                    ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
                    for (int i = 0; i < serverObsDatas.list.Count; i++)
                    {
                        ObsData obsData = new ObsData();
                        string originName = serverObsDatas.list[i].name;
                        //Debug.Log("111111111111111:" + originName);
                        obsData.name = "TK_" + serverObsDatas.list[i].name;
                        if (GlobalData.obsCameraLib.TryGetValue(obsData.name, out var value))
                        {
                            obsData.targetName = value;
                        }

                        //obsData.url = await GetObsUrl(serverObsDatas.list[i].deviceId,serverObsDatas.list[i].channelId);
                        //ServerAddress.ObsSeverM3U8Address + string.Format("/rtp/{0}_{1}/hls.m3u8", serverObsDatas.list[i].deviceId, serverObsDatas.list[i].channelId);
                        //}
                        obsData.type = obsType.TaoKouObs;
                        
                        obsData.deviceId = serverObsDatas.list[i].deviceId;
                        obsData.channelId = serverObsDatas.list[i].channelId;
                        GlobalData.obsDeviceIDLib.Add(obsData.name, obsData.channelId);
                        obsData.status = serverObsDatas.list[i].status;
                        GlobalData.obsDatas_tk.Add(obsData);
                    }
                }
                else
                {
                    Debug.LogWarning("套口监控数据联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("套口监控数据联网不成功,原因:" + e.ToString());
        }

        requestData.Dispose();

        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/ObsDatas_TK.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });

            Debug.Log($"缓存数据:{www.text}");
            GlobalData.obsDatas_tk = JsonConvert.DeserializeObject<List<ObsData>>(www.text);
            www.Dispose();
        }
    }


    public async Task<string> GetObsUrl(string deviceId, string channelId)
    {
        string result = "";
        string cmdUrl = ServerAddress.API_PlayStart;
        cmdUrl += $"/{deviceId}/{channelId}?token=12345678";
        Debug.Log($"send:{cmdUrl}");
        UnityWebRequest requestData = UnityWebRequest.Get(cmdUrl);
        await requestData.SendWebRequest();
        if (requestData.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取监控播放地址不成功,原因:返request不成功:" + requestData.downloadHandler.text);
        }
        else
        {
            Debug.Log(requestData.downloadHandler.text);
            string postResult = requestData.downloadHandler.text;
            if (useAes)
            {
                postResult = AESCrypto.Decrypt(postResult);

            }
            JObject jsonObject = JObject.Parse(postResult);
            // 提取data字段的值
            JToken dataToken = jsonObject["data"];
            ObsPlayUrlData urlData = JsonConvert.DeserializeObject<ObsPlayUrlData>(dataToken.ToString());
            if (urlData != null)
            {
                result = urlData.hls;
                Debug.Log("获取到监控播放路径:" + result);
            }
        }
        requestData.Dispose();
        return result;
    }

    public async Task InitYZTData3()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterHotPoint);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try

        {
            if (true)
            //if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.hotPointDatas = JsonConvert.DeserializeObject<List<HotPointData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/hotPoints.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            GlobalData.hotPointDatas = JsonConvert.DeserializeObject<List<HotPointData>>(www.text);
            Debug.Log(GlobalData.hotPointDatas.Count);
            www.Dispose();
        }
    }

    public async Task InitXHGKData()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGetProjectMilestones);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (true)
            {
                Debug.LogWarning("XHGKLayer联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                //   ȡdata ֶε ֵ
                JToken dataToken = jsonObject["data"];
                //Debug.Log(dataToken.ToString());
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.dsjContents = JsonConvert.DeserializeObject<List<DSJData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("XHGKLayer联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("XHGKLayer联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/dsj.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            GlobalData.dsjContents = JsonConvert.DeserializeObject<List<DSJData>>(www.text);
            www.Dispose();
        }
    }

    /// <summary>
    /// 一张图首页工程概况
    /// </summary>
    /// <returns></returns>
    public async Task InitGCGKData()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterGaiKuang);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("GCGK联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);


                JToken dataToken = jsonObject["data"];
                //Debug.Log(dataToken.ToString());
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    //Debug.Log("1111111111:" + dataToken.ToString());
                    GlobalData.gcgkContents = JsonConvert.DeserializeObject<List<GCGKData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("GCGK联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("GCGK联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();
    }


    /// <summary>
    /// 一张图首页监控预警
    /// </summary>
    /// <returns></returns>
    public async Task InitJKYJData()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetJKYJ + "buyuan");
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("JKYJ-buyuan联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);


                JToken dataToken = jsonObject["data"];
                //Debug.Log(dataToken.ToString());
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    //Debug.Log("1111111111:" + dataToken.ToString());
                    GlobalData.byJKYJContents = JsonConvert.DeserializeObject<JKYJData>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("JKYJ-buyuan联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("JKYJ-buyuan联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData.Dispose();

        successInternet = true;
        UnityWebRequest requestData1 = UnityWebRequest.Get(ServerAddress.APIGetJKYJ + "taokou");
        requestData1.timeout = timeOut;
        await requestData1.SendWebRequest();
        try
        {
            if (requestData1.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("JKYJ-TAOKOU联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData1.downloadHandler.text;
                Debug.Log(postResult);
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);


                JToken dataToken = jsonObject["data"];
                //Debug.Log(dataToken.ToString());
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    //Debug.Log("1111111111:" + dataToken.ToString());
                    GlobalData.tkJKYJContents = JsonConvert.DeserializeObject<JKYJData>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("JKYJ-TAOKOU联网不成功，读本地缓存数据,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("JKYJ-TAOKOU联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        requestData1.Dispose();
    }

    public async Task InitGCJKData()
    {
        bool successInternet = true;
        //UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGeQXZData);
        //requestData.timeout = timeOut;
        //await requestData.SendWebRequest();
        //try
        //{
        //    if (requestData.result != UnityWebRequest.Result.Success)
        //    {
        //        Debug.LogWarning("水文站联网不成功,原因:返request不成功");
        //        successInternet = false;
        //    }
        //    else
        //    {
        //        string postResult = requestData.downloadHandler.text;
        //        if (useAes)
        //        {
        //            postResult = AESCrypto.Decrypt(postResult);

        //        }
        //        JObject jsonObject = JObject.Parse(postResult);

        //        // 提取data字段的值
        //        JToken dataToken = jsonObject["data"];
        //        JToken codeToken = jsonObject["code"];
        //        if (codeToken.ToString() == "200")
        //        {
        //            GlobalData.qXZDatas = JsonConvert.DeserializeObject<List<QXZData>>(dataToken.ToString());
        //        }
        //        else
        //        {
        //            Debug.LogWarning("水文站联网不成功,原因:返序列化失败");
        //            successInternet = false;
        //        }
        //    }
        //}
        //catch (Exception e)
        //{
        //    successInternet = false;
        //    Debug.LogWarning("水文站联网不成功,原因:" + e.ToString());
        //}

        //requestData.Dispose();

        successInternet = true;
        UnityWebRequest requestData1 = UnityWebRequest.Get(ServerAddress.APIGetGeSWZData);
        await requestData1.SendWebRequest();
        try
        {
            if (requestData1.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("水文站联网不成功,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData1.downloadHandler.text);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.sWZDatas = JsonConvert.DeserializeObject<List<SWZData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("水文站联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("水文站联网不成功,原因:" + e.ToString());
        }

        requestData1.Dispose();


        successInternet = true;
        UnityWebRequest requestData2 = UnityWebRequest.Get(ServerAddress.APIGetGeSWZData6H);
        await requestData2.SendWebRequest();
        try
        {
            if (requestData2.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("水文站联网不成功,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData2.downloadHandler.text);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.sWZDatas6H = JsonConvert.DeserializeObject<List<SWZData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("水文站联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("水文站联网不成功,原因:" + e.ToString());
        }

        requestData2.Dispose();
    }


    public async Task InitGCJKData1h()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGeQXZOneHourData);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("水文站联网不成功,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.qXZDatas1h = JsonConvert.DeserializeObject<List<QXZData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("水文站联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("水文站联网不成功,原因:" + e.ToString());
        }

        requestData.Dispose();

    }

    public async Task InitGCJKData2()
    {
        GlobalData.sensorAlertDone = false;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetSensorAlerts);
        requestData.timeout = 2;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("工程告警联网不成功,原因:返request不成功");
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);
                Debug.LogError(postResult.ToString());
                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    
                    GlobalData.sensorAlert = JsonConvert.DeserializeObject<SensorAlert>(dataToken.ToString());
                    GlobalData.sensorAlertDone = true;
                }
                else
                {
                    Debug.LogWarning("工程告警联网不成功,原因:返序列化失败");
                }
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("工程告警联网不成功,原因:" + e.ToString());
        }
    }


    public async Task InitXHDDData0()
    {
        WWW www = new WWW(Application.streamingAssetsPath + "/scheduling.json");
        await new UnityAsync.WaitUntil(() => { return www.isDone; });
        GlobalData.schedulingData = JsonConvert.DeserializeObject<SchedulingData>(www.text);
        www.Dispose();
    }


    public async Task InitXHDDData1()
    {
        WWW www = new WWW(Application.streamingAssetsPath + "/allAlert.json");
        await new UnityAsync.WaitUntil(() => { return www.isDone; });
        GlobalData.xHDDAlertData = JsonConvert.DeserializeObject<XHDDAlertData>(www.text);
        www.Dispose();
    }

    public async Task InitXHDDData2()
    {
        WWW www = new WWW(Application.streamingAssetsPath + "/rkzyld.json");
        await new UnityAsync.WaitUntil(() => { return www.isDone; });
        GlobalData.emergencyResponseData = JsonConvert.DeserializeObject<EmergencyResponseData>(www.text);
        www.Dispose();
    }

    public async Task InitXHDDData3()
    {
        WWW www = new WWW(Application.streamingAssetsPath + "/rkzygb.json");
        await new UnityAsync.WaitUntil(() => { return www.isDone; });
        GlobalData.allRegionData = JsonConvert.DeserializeObject<AllRegionData>(www.text);
        www.Dispose();
    }

    public async Task InitRKZYData()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGetMovePlans);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (true)
            {
                Debug.LogWarning("RKZYLayer联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.allServerMovePlans =
                        JsonConvert.DeserializeObject<List<ServerMovePlan>>(dataToken.ToString());
                }
                else
                {
                    successInternet = false;
                    Debug.LogWarning("XHGKLayer联网不成功，读本地缓存数据,原因:返序列化失败");
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("RKZYLayer联网不成功，读本地缓存数据,原因:" + e.ToString());
        }

        if (!successInternet)
        {
            WWW www = new WWW(Application.streamingAssetsPath + "/moveplan.json");
            await new UnityAsync.WaitUntil(() => { return www.isDone; });
            GlobalData.allServerMovePlans = JsonConvert.DeserializeObject<List<ServerMovePlan>>(www.text);
            www.Dispose();
        }
    }


    public async Task InitSWYJData()
    {
        InitSWYJData0();

        await InitSWYJData1();
        await InitSWYJData2();
        await InitSWYJData3();
        await InitSWYJData4();
        OnSWYJRefresh?.Invoke();
    }

    /// <summary>
    /// 获取补元的水位
    /// </summary>
    /// <returns></returns>
    public async Task InitSWYJData1()
    {
        var devicesInfo = GlobalData._devicesIdDatas["上游水位计"];
        string sw1Result = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "d", 10000);
        //Debug.Log("sw1Resultsw1Resultsw1Result上游水位计:" + sw1Result);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw1Result);
            if (tempData != null)
            {
                bool findData = false;
                foreach (var VARIABLE in GlobalData.BuYuanShuiWeiDataList)
                {
                    if (VARIABLE.name.Equals("补元上游水位"))
                    {
                        VARIABLE.value = float.Parse(tempData.data[0].avgS1);
                        VARIABLE.datas = tempData.data.ToArray();
                        findData = true;
                    }
                }
                if (!findData)
                {
                    GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
                    {
                        name = "补元上游水位",
                        targetName = "BY_ShuiWei_Up",
                        value = float.Parse(tempData.data[0].avgS1),
                        type = shuiWeiType.BuYuanShuiWei,
                        datas = tempData.data.ToArray(),
                        sid = devicesInfo.dataSid.ToString(),
                        gid = devicesInfo.dataGid.ToString()
                    });
                }
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("补元上游水位不成功,原因:" + e.ToString());
        }

        var devicesInfo1 = GlobalData._devicesIdDatas["下游水位计"];
        string sw2Result = await GetSingleDevicesInfo(2, devicesInfo1.dataGid.ToString(), devicesInfo1.dataSid.ToString(),
            "d", 100000);
        Debug.Log("sw1Resultsw1Resultsw1Result下游水位计:" + sw2Result);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw2Result);
            if (tempData != null)
            {
                bool findData = false;
                foreach (var VARIABLE in GlobalData.BuYuanShuiWeiDataList)
                {
                    if (VARIABLE.name.Equals("补元下游水位"))
                    {
                        VARIABLE.value = float.Parse(tempData.data[0].avgS1);
                        VARIABLE.datas = tempData.data.ToArray();
                        findData = true;
                    }
                }
                if (!findData)
                {
                    GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
                    {
                        name = "补元下游水位",
                        targetName = "BY_ShuiWei_Down",
                        value = float.Parse(tempData.data[0].avgS1),
                        type = shuiWeiType.BuYuanShuiWei,
                        datas = tempData.data.ToArray(),
                        sid = devicesInfo.dataSid.ToString(),
                        gid = devicesInfo.dataGid.ToString()
                    });
                }
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("补元下游水位不成功,原因:" + e.ToString());
        }
        string dayResult = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "d", 6);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(dayResult);
            GlobalData.buYuanShuiWei_day = new ShuiWeiBianHuaData();
            GlobalData.buYuanShuiWei_day.name = new string[tempData.data.Count];
            GlobalData.buYuanShuiWei_day.value = new double[tempData.data.Count];
            for (int i = 0; i < tempData.data.Count; i++)
            {
                GlobalData.buYuanShuiWei_day.name[i] = tempData.data[i].timeGroup;
                GlobalData.buYuanShuiWei_day.value[i] = double.Parse(tempData.data[i].avgS1);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6天平均数据不成功,原因:" + e.ToString());
        }

        string monthResult = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "d", 90);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(monthResult);
            GlobalData.buYuanShuiWei_month = new ShuiWeiBianHuaData();
            GlobalData.buYuanShuiWei_month.name = new string[tempData.data.Count];
            GlobalData.buYuanShuiWei_month.value = new double[tempData.data.Count];
            for (int i = 0; i < tempData.data.Count; i++)
            {
                GlobalData.buYuanShuiWei_month.name[i] = tempData.data[i].timeGroup;
                GlobalData.buYuanShuiWei_month.value[i] = double.Parse(tempData.data[i].avgS1);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6月平均数据不成功,原因:" + e.ToString());
        }

        string hourResult = await GetSingleDevicesInfo(2, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "h", 6);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(hourResult);
            GlobalData.buYuanShuiWei_hour = new ShuiWeiBianHuaData();
            GlobalData.buYuanShuiWei_hour.name = new string[tempData.data.Count];
            GlobalData.buYuanShuiWei_hour.value = new double[tempData.data.Count];
            for (int i = 0; i < tempData.data.Count; i++)
            {
                GlobalData.buYuanShuiWei_hour.name[i] = tempData.data[i].timeGroup;
                GlobalData.buYuanShuiWei_hour.value[i] = double.Parse(tempData.data[i].avgS1);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6小时平均数据不成功,原因:" + e.ToString());
        }
    }

    public async Task InitSWYJData2()
    {
        var devicesInfo = GlobalData._devicesIdDatas["SWJ01YQ"];
        Debug.Log(devicesInfo.dataGid);
        Debug.Log(devicesInfo.dataSid);
        string sw1Result = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(), "d", 10000);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw1Result);
            if (tempData != null)
            {
                bool findData = false;
                foreach (var VARIABLE in GlobalData.TaoKouShuiWeiDataList)
                {
                    if (VARIABLE.name.Equals("套口上游水位"))
                    {
                        VARIABLE.value = float.Parse(tempData.data[0].avgS1);
                        VARIABLE.datas = tempData.data.ToArray();
                        findData = true;
                    }
                }
                if (!findData)
                {
                    GlobalData.TaoKouShuiWeiDataList.Add(new ShuiWeiData()
                    {
                        name = "套口上游水位",
                        targetName = "TK_ShuiWei_Up",
                        value = float.Parse(tempData.data[0].avgS1),
                        type = shuiWeiType.TaoKouShuiWei,
                        datas = tempData.data.ToArray(),
                        sid = devicesInfo.dataSid.ToString(),
                        gid = devicesInfo.dataGid.ToString()
                    });
                }
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("套口上游水位不成功,原因:" + e.ToString());
        }

        var devicesInfo1 = GlobalData._devicesIdDatas["SWJ02YQ"];
        string sw2Result = await GetSingleDevicesInfo(1, devicesInfo1.dataGid.ToString(), devicesInfo1.dataSid.ToString(),
            "d", 100000);
        //Debug.Log("sw1Resultsw1Resultsw1Result下游水位计:" + sw2Result);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(sw2Result);
            if (tempData != null)
            {
                bool findData = false;
                foreach (var VARIABLE in GlobalData.TaoKouShuiWeiDataList)
                {
                    if (VARIABLE.name.Equals("套口下游水位"))
                    {
                        VARIABLE.value = float.Parse(tempData.data[0].avgS1);
                        VARIABLE.datas = tempData.data.ToArray();
                        findData = true;
                    }
                }
                if (!findData)
                {
                    GlobalData.TaoKouShuiWeiDataList.Add(new ShuiWeiData()
                    {
                        name = "套口下游水位",
                        targetName = "TK_ShuiWei_Down",
                        value = float.Parse(tempData.data[0].avgS1),
                        type = shuiWeiType.TaoKouShuiWei,
                        datas = tempData.data.ToArray(),
                        sid = devicesInfo.dataSid.ToString(),
                        gid = devicesInfo.dataGid.ToString()
                    });
                }
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("套口下游水位不成功,原因:" + e.ToString());
        }

        string dayResult = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "d", 6);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(dayResult);
            GlobalData.taoKouShuiWei_day = new ShuiWeiBianHuaData();
            GlobalData.taoKouShuiWei_day.name = new string[tempData.data.Count];
            GlobalData.taoKouShuiWei_day.value = new double[tempData.data.Count];
            for (int i = 0; i < tempData.data.Count; i++)
            {
                GlobalData.taoKouShuiWei_day.name[i] = tempData.data[i].timeGroup;
                GlobalData.taoKouShuiWei_day.value[i] = double.Parse(tempData.data[i].avgS1);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6天平均数据不成功,原因:" + e.ToString());
        }

        string monthResult = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "d", 90);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(monthResult);
            GlobalData.taoKouShuiWei_month = new ShuiWeiBianHuaData();
            GlobalData.taoKouShuiWei_month.name = new string[tempData.data.Count];
            GlobalData.taoKouShuiWei_month.value = new double[tempData.data.Count];
            for (int i = 0; i < tempData.data.Count; i++)
            {
                GlobalData.taoKouShuiWei_month.name[i] = tempData.data[i].timeGroup;
                GlobalData.taoKouShuiWei_month.value[i] = double.Parse(tempData.data[i].avgS1);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6月平均数据不成功,原因:" + e.ToString());
        }

        string hourResult = await GetSingleDevicesInfo(1, devicesInfo.dataGid.ToString(), devicesInfo.dataSid.ToString(),
            "h", 6);
        try
        {
            GetSingleDevicesRequest tempData = JsonConvert.DeserializeObject<GetSingleDevicesRequest>(hourResult);
            GlobalData.taoKouShuiWei_hour = new ShuiWeiBianHuaData();
            GlobalData.taoKouShuiWei_hour.name = new string[tempData.data.Count];
            GlobalData.taoKouShuiWei_hour.value = new double[tempData.data.Count];
            for (int i = 0; i < tempData.data.Count; i++)
            {
                GlobalData.taoKouShuiWei_hour.name[i] = tempData.data[i].timeGroup;
                GlobalData.taoKouShuiWei_hour.value[i] = double.Parse(tempData.data[i].avgS1);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6小时平均数据不成功,原因:" + e.ToString());
        }
    }

    public async Task InitSWYJData3()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGeSWData);
        requestData.timeout = 6;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("水位高度联网不成功,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                //Debug.LogError(dataToken);
                if (codeToken.ToString() == "200")
                {
                    //Debug.LogError(200);
                    GlobalData.swDatas = JsonConvert.DeserializeObject<List<StationData>>(dataToken.ToString());
                    //Debug.LogError(GlobalData.swDatas.Count);
                    for (int i = 0; i < GlobalData.swDatas.Count; i++)
                    {
                        GlobalData.swDatas[i].stnm = GlobalData.swDatas[i].stnm.Replace("（", "(").Replace("）", ")");
                    }
                }
                else
                {
                    Debug.LogWarning("水位高度联网不成功,原因:返序列化失败");
                    successInternet = false;
                }

                //for (int i = 0; i < GlobalData.BuYuanShuiWeiDataList.Count; i++)
                //{
                //    StationData stationData = new StationData();
                //    stationData.LGTD = 113.910187f;
                //    stationData.LTTD = 30.1765823f;
                //    stationData.STNM = GlobalData.BuYuanShuiWeiDataList[i].name;
                //    stationData.upz = GlobalData.BuYuanShuiWeiDataList[i].name.Contains("上")
                //        ? GlobalData.BuYuanShuiWeiDataList[i].value
                //        : -1;
                //    stationData.dwz = GlobalData.BuYuanShuiWeiDataList[i].name.Contains("下")
                //        ? GlobalData.BuYuanShuiWeiDataList[i].value
                //        : -1;
                //    GlobalData.swDatas.Add(stationData);
                //}
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("水位高度联网不成功,原因:" + e.ToString());
        }
    }


    public async Task InitSWYJData4()
    {
        GlobalData.sWAlertDone = false;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetAlerts);
        requestData.timeout = 2;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("水位告警联网不成功,原因:返request不成功");
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["rows"];

                GlobalData.sWAlerts = JsonConvert.DeserializeObject<List<SWAlert>>(dataToken.ToString());
                GlobalData.sWAlertDone = true;
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("水位告警联网不成功,原因:" + e.ToString());
        }
    }

    public async Task InitSWYJData0()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetThreeLevel);
        requestData.timeout = timeOut;
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("三线水位联网不成功,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                string postResult = requestData.downloadHandler.text;
                if (useAes)
                {
                    postResult = AESCrypto.Decrypt(postResult);

                }
                JObject jsonObject = JObject.Parse(postResult);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.threeLevelShuiWeiDatas =
                        JsonConvert.DeserializeObject<List<ThreeLevelShuiWeiData>>(dataToken.ToString());
                }
                else
                {
                    Debug.LogWarning("三线水位联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("三线水位联网不成功,原因:" + e.ToString());
        }

    }

    public async Task SendBuYuan_GetSensorData()
    {
        UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_BuYuan_GetSensorData);
        await www.SendWebRequest();
        try
        {
            if (www.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("获取补元闸门设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
            }
            else
            {
               // Debug.Log("11111111111111111111:" + www.downloadHandler.text);
                GlobalData.buYuanSensorData = JsonUtility.FromJson<SensorDataResult>(www.downloadHandler.text);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取补元闸门设备数据不成功,原因:" + e.ToString());
        }

        www.Dispose();
    }

    public async void GetBuYuanDevicesGroupInfo()
    {
        Debug.Log("获取补元所有渗压记");
        //获取所有渗压记
        //GetDevicesData tempData = new GetDevicesData();
        //tempData.idsList = new List<DevicesMessage>();
        foreach (var device in GlobalData._devicesIdDatas.Values)
        {

            if (device.stationName.Contains("补元") && device.sensorType.Equals("渗压计"))
            {
                GlobalData.BuYuanShuiYaDataList.Add(new ShuiYaData()
                {
                    name = device.sensorName,
                    value = device.realtimeValue1,
                    type = shuiYaType.BuYuanShuiYa,
                    targetName = $"BY_{device.sensorName}",
                    gid = device.dataGid.ToString(),
                    sid = device.dataSid.ToString()
                });
            }
        }
        Debug.Log("添加补元渗压记：" + GlobalData.BuYuanShuiYaDataList.Count);

        Debug.Log("获取补元所有位移记");
        //获取所有位移记
        foreach (var device in GlobalData._devicesIdDatas.Values)
        {
            if (device.stationName.Contains("补元") && device.sensorType.Equals("静力水准仪"))
            {
                GlobalData.BuYuanWeiYiDataList.Add(new WeiYiData()
                {
                    name = device.sensorName,
                    value = device.realtimeValue1,
                    type = weiYiType.BuYuanWeiYi,
                    targetName = $"BY_{device.sensorName}",
                    gid = device.dataGid.ToString(),
                    sid = device.dataSid.ToString()
                });
            }
        }
        Debug.Log("添加补元位移记：" + GlobalData.BuYuanWeiYiDataList.Count);
    }

    public async void GetTaoKouDevicesGroupInfo()
    {
        Debug.Log("获取套口所有渗压记");
        //获取所有渗压记
        foreach (var device in GlobalData._devicesIdDatas.Values)
        {
            if (device.stationName.Contains("套口") && device.sensorType.Equals("渗压计"))
            {
                GlobalData.TaoKouShuiYaDataList.Add(new ShuiYaData()
                {
                    name = device.sensorName,
                    value = device.realtimeValue1,
                    type = shuiYaType.TaoKouShuiYa,
                    targetName = $"TK_{device.sensorName}",
                    gid = device.dataGid.ToString(),
                    sid = device.dataSid.ToString()
                });
            }
        }
        Debug.Log("添加套口渗压记：" + GlobalData.TaoKouShuiYaDataList.Count);

        Debug.Log("获取套口所有位移记");
        //获取所有位移记
        foreach (var device in GlobalData._devicesIdDatas.Values)
        {
            if (device.stationName.Contains("补元") && device.sensorType.Equals("静力水准仪"))
            {
                GlobalData.TaoKouWeiYiDataList.Add(new WeiYiData()
                {
                    name = device.sensorName,
                    value = device.realtimeValue1,
                    type = weiYiType.TaoKouWeiYi,
                    targetName = $"TK_{device.sensorName}",
                    gid = device.dataGid.ToString(),
                    sid = device.dataSid.ToString()
                });
            }
        }
        Debug.Log("添加套口位移记：" + GlobalData.TaoKouWeiYiDataList.Count);
    }

    public async Task SendTaoKou_GetSensorData()
    {
        UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_TaoKou_GetSensorData);
        await www.SendWebRequest();
        try
        {
            if (www.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("获取套口闸门设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
            }
            else
            {
                GlobalData.taoKouSensorData = JsonUtility.FromJson<SensorDataResult>(www.downloadHandler.text);
                Debug.Log($"获取套口闸门设备数据:{GlobalData.taoKouSensorData.data.Count}");
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取套口闸门设备数据不成功,原因:" + e.ToString());
        }

        www.Dispose();
    }

    /// <summary>
    /// 获取设备趋势数据
    /// </summary>
    /// <param name="type">0:补元 1：套口</param>
    /// <param name="gid">=devicesID 套口都传一样=sid</param>
    /// <param name="sid">=ChannelID 套口都传一样=sid</param>
    /// <param name="beginTime">yyyy-MM-dd 最大183天</param>
    /// <param name="endTime"></param>
    /// <returns></returns>
    public async Task<string> GetDeviceTrend(int type, string gid, string sid, string beginTime, string endTime)
    {
        string cmdUrl = ServerAddress.APIGetDeviceTrend;
        cmdUrl += $"/{(type == 0 ? "buyuan" : "taokou")}/{gid}/{sid}?beginTime={beginTime}&endTime={endTime}";
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        Debug.Log("send:" + cmdUrl);
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning("获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    // /// <summary>
    // /// 获取补元硬件组数据
    // /// </summary>
    // /// <param name="sendData"></param>
    // /// <returns></returns>
    // public async Task<string> Devices(GetDevicesData sendData)
    // {
    //     string cmdUrl = ServerAddress.API_BuYuan_GetDevicesGroupInfo;
    //     string tempStr = JsonConvert.SerializeObject(sendData);
    //     var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
    //     UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
    //     www.uploadHandler = new UploadHandlerRaw(sendByte);
    //     www.downloadHandler = new DownloadHandlerBuffer();
    //     www.SetRequestHeader("Content-Type", "application/json");
    //     await www.SendWebRequest();
    //     if (www.result != UnityWebRequest.Result.Success)
    //     {
    //         Debug.LogWarning($"获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
    //     }
    //     string result = www.downloadHandler.text;
    //     www.Dispose();
    //     return result;
    // }


    /// <summary>
    /// 获取设备的最近N条记录
    /// </summary>
    /// <param name="channelId=gid"></param>
    /// <param name="deviceId=sid"></param>
    /// <param name="count"></param>
    /// <returns></returns>
    public async Task<string> GetSingleDevicesInfo(int type, string gid, string sid, string timeUnit, int count)
    {
        string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo;
        cmdUrl += $"?dataFrom={type}&dataSid={sid}&dataGid={gid}&timeUnit={timeUnit}&number={count}";
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning("获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }


    /// <summary>
    /// 获取设备最近几天的平均数据
    /// </summary>
    /// <param name="channelId"></param>
    /// <param name="deviceId"></param>
    /// <param name="count"></param>
    /// <returns></returns>
    public async Task<string> GetSingleDevicesInfo_day(int channelId, int deviceId, int count)
    {
        string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo_avg;
        GetSingleDeviceData_AvgType sendData = new GetSingleDeviceData_AvgType();
        sendData.ChannelID = channelId;
        sendData.DeviceID = deviceId;
        sendData.AvgType = "day";
        sendData.N = count;
        string tempStr = JsonConvert.SerializeObject(sendData);
        var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
        www.uploadHandler = new UploadHandlerRaw(sendByte);
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning("获取设备天平均数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    /// <summary>
    /// 获取设备最近几小时的平均数据
    /// </summary>
    /// <param name="channelId"></param>
    /// <param name="deviceId"></param>
    /// <param name="count"></param>
    /// <returns></returns>
    public async Task<string> GetSingleDevicesInfo_hour(int channelId, int deviceId, int count)
    {
        string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo_avg;
        GetSingleDeviceData_AvgType sendData = new GetSingleDeviceData_AvgType();
        sendData.ChannelID = channelId;
        sendData.DeviceID = deviceId;
        sendData.AvgType = "hour";
        sendData.N = count;
        string tempStr = JsonConvert.SerializeObject(sendData);
        var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
        www.uploadHandler = new UploadHandlerRaw(sendByte);
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning("获取设备小时平均数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    /// <summary>
    /// 获取设备最近几个月的平均数据
    /// </summary>
    /// <param name="channelId"></param>
    /// <param name="deviceId"></param>
    /// <param name="count"></param>
    /// <returns></returns>
    public async Task<string> GetSingleDevicesInfo_month(int channelId, int deviceId, int count)
    {
        string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo_avg;
        GetSingleDeviceData_AvgType sendData = new GetSingleDeviceData_AvgType();
        sendData.ChannelID = channelId;
        sendData.DeviceID = deviceId;
        sendData.AvgType = "month";
        sendData.N = count;
        string tempStr = JsonConvert.SerializeObject(sendData);
        var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "POST");
        www.uploadHandler = new UploadHandlerRaw(sendByte);
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning("获取设备月平均数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    public async UniTaskVoid GetGCYW_Station()
    {
        Debug.Log("获取B08GCYW 站点列表");
        using UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_B08_getStationList);
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取{ServerAddress.API_B08_getStationList}数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        var jsonStr = www.downloadHandler.text;
        www.Dispose();
        Debug.Log(jsonStr);
        var datas = JsonConvert.DeserializeObject<B08_StationListData>(jsonStr);
        foreach (var data in datas.data)
        {
            GlobalData.B08StationList.TryAdd(data.name, data.id);
            foreach (var chiles in data.children)
            {
                GlobalData.B08StationList.TryAdd(chiles.name, chiles.id);
                foreach (var chilesChile in chiles.children)
                {
                    GlobalData.B08StationList.TryAdd(chilesChile.name, chilesChile.id);
                    foreach (var chilesChilesChild in chiles.children)
                    {
                        GlobalData.B08StationList.TryAdd(chilesChilesChild.name, chilesChilesChild.id);
                        //三层应该没有儿子了吧 拉屎谁不会呢
                    }
                }
            }
        }
        //懒得搞直接获取所有属性
        foreach (var key in GlobalData.B08StationList.Keys)
        {
            var StatisticsStr = await GetStatistics(GlobalData.B08StationList[key]);
            B08_StatisticsInfo saveInfo = new B08_StatisticsInfo();
            saveInfo.dates = new List<string>();
            saveInfo.valueOfDates = new List<int>();
            JObject jsonObject = JObject.Parse(StatisticsStr);
            // 提取data字段的值
            JToken dataToken = jsonObject["data"];
            JToken statusCount = dataToken["statusCount"];
            saveInfo.waitDispatch = statusCount?["0"] != null ? statusCount["0"].ToString() : "0";
            saveInfo.waitPatrol = statusCount?["1"] != null ? statusCount["1"].ToString() : "0";
            saveInfo.onPatrol = statusCount?["2"] != null ? statusCount["2"].ToString() : "0";
            saveInfo.patrolCompleted = statusCount?["3"] != null ? statusCount["3"].ToString() : "0";

            JObject dailyCountObj=(JObject)dataToken["dailyCount"];
            foreach (var property in dailyCountObj.Properties())
            {
                saveInfo.dates.Add(property.Name);
                saveInfo.valueOfDates.Add((int)property.Value);
            }
            GlobalData.B08StatisticsInfo.TryAdd(key, saveInfo);
        }
        Debug.Log("获取站点信息完毕");
    }
    
    public async Cysharp.Threading.Tasks.UniTask<string> GetStatistics(string stationId)
    {
        var result="";

        string startTime = DateTime.Now.AddDays(-7).ToString("yyyy-M-d");
        string endTime =DateTime.Now.ToString("yyyy-M-d");
        
        var sendData = new PostStatisticsData
        {
            timeRange = new string[]
            {
                $"{startTime}", $"{endTime}"
            },
            startTime = $"{startTime} 00:00:00",
            endTime = $"{endTime} 23:59:59",
            ids = stationId
        };
        string tempStr = JsonConvert.SerializeObject(sendData);
        var sendByte = System.Text.Encoding.UTF8.GetBytes(tempStr);
        using UnityWebRequest www = new UnityWebRequest("http://58.19.230.46:9180/prod-api/project/workOrder/statistics","POST");
        www.uploadHandler = new UploadHandlerRaw(sendByte);
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }
    
    public async UniTask InitGCYWData1(string ids)
    {
        GlobalData.B08_Type = ids;
        string TFSJ_cmd =
            $"http://58.19.230.46:9180/prod-api/project/workOrder/list?pageNum=1&pageSize=999&type=2&stationId={ids}&isAsc=desc";
        
        UnityWebRequest TFSJ_www = new UnityWebRequest(TFSJ_cmd, "Get");
        TFSJ_www.downloadHandler = new DownloadHandlerBuffer();
        TFSJ_www.SetRequestHeader("Content-Type", "application/json");
        TFSJ_www.SetRequestHeader("Authorization", "Bearer "+token);
        await TFSJ_www.SendWebRequest();
        if (TFSJ_www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取{TFSJ_cmd}数据不成功,原因:返request不成功:" + TFSJ_www.downloadHandler.text);
        }
        string TFSJ_result = TFSJ_www.downloadHandler.text;
        GlobalData.B08Event = JsonConvert.DeserializeObject<B08_event>(TFSJ_result);
        foreach (var eventItems in GlobalData.B08Event.rows)
        {
            if (eventItems.status == null)
            {
                GlobalData.B08Event.waitHandle++;
                continue;
            }
            switch (eventItems.status)
            {
                case 0:
                case 1:
                    GlobalData.B08Event.waitHandle++;
                    break;
                case 2:
                    GlobalData.B08Event.waitAccept++;
                    break;
                case 3:
                    GlobalData.B08Event.hasHandle++;
                    break;
            }
        }
        Debug.Log(TFSJ_result);
        Debug.Log("!!!!!!!!!!!!!!!!!!!!");

        string XJRW_cmd = $"http://58.19.230.46:9180/prod-api/project/workOrder/list?pageNum=1&pageSize=999&type=3&stationId={ids}&isAsc=desc";
        UnityWebRequest XJRW_www = new UnityWebRequest(XJRW_cmd, "Get");
        XJRW_www.downloadHandler = new DownloadHandlerBuffer();
        XJRW_www.SetRequestHeader("Content-Type", "application/json");
        XJRW_www.SetRequestHeader("Authorization", "Bearer "+token);
        await XJRW_www.SendWebRequest();
        if (XJRW_www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取{XJRW_cmd}数据不成功,原因:返request不成功:" + XJRW_www.downloadHandler.text);
        }
        string XJRW_result = XJRW_www.downloadHandler.text;
        Debug.Log(XJRW_result);
        Debug.Log("!!!!!!!!!!!!!!!!!!!!");
        // try
        // {
        //     jsonStr = await B08_API_data(ServerAddress.API_B08_dataStatis, type);
        //     Debug.Log("API_B08_dataStatis" + jsonStr);
        //     GlobalData.B08DataStatis = JsonConvert.DeserializeObject<B08_dataStatis>(jsonStr);
        // }
        // catch (Exception e)
        // {
        //     Debug.LogWarning("获取API_B08_dataStatis数据不成功,原因:" + e.ToString());
        // }
        //
        // try
        // {
        //     jsonStr = await B08_API_data(ServerAddress.API_B08_inspectResult, type);
        //     Debug.Log("API_B08_inspectResult" + jsonStr);
        //     GlobalData.B08InspectResult = JsonConvert.DeserializeObject<B08_inspectResult>(jsonStr);
        // }
        // catch (Exception e)
        // {
        //     Debug.LogWarning("获取API_B08_inspectResult数据不成功,原因:" + e.ToString());
        // }
        //
        // try
        // {
        //     jsonStr = await B08_API_data(ServerAddress.API_B08_projectExamine, type);
        //     Debug.Log("API_B08_projectExamine" + jsonStr);
        //     GlobalData.B08ProjectExamine = JsonConvert.DeserializeObject<B08_projectExamine>(jsonStr);
        // }
        // catch (Exception e)
        // {
        //     Debug.LogWarning("获取API_B08_projectExamine数据不成功,原因:" + e.ToString());
        // }
        //
        // try
        // {
        //     jsonStr = await B08_API_data(ServerAddress.API_B08_event, type);
        //     Debug.Log("API_B08_event" + jsonStr);
        //     GlobalData.B08Event = JsonConvert.DeserializeObject<B08_event>(jsonStr);
        // }
        // catch (Exception e)
        // {
        //     Debug.LogWarning("获取API_B08_event数据不成功,原因:" + e.ToString());
        // }

        // try
        // {
        //     jsonStr = await B08_API_data(ServerAddress.API_B08_questionStatis, type);
        //     Debug.Log("API_B08_questionStatis" + jsonStr);
        //     GlobalData.B08QuestionStatis = JsonConvert.DeserializeObject<B08_questionStatis>(jsonStr);
        // }
        // catch (Exception e)
        // {
        //     Debug.LogWarning("获取API_B08_questionStatis数据不成功,原因:" + e.ToString());
        // }
    }

    public async Task B08_GetTaskList()
    {
        string jsonStr;
     
        try
        {
            jsonStr = await B08_API_TaskInfoList(1,999);
            //Debug.Log("B08_API_TaskInfoList" + jsonStr);
            GlobalData.B08TaskListData = JsonConvert.DeserializeObject<B08_TaskListInfoData>(jsonStr);
            //Debug.Log("GlobalData.B08TaskListData: "+GlobalData.B08TaskListData.rows.Length);
            // GlobalData.B08TaskListInfos = new B08_TaskListInfoData[GlobalData.B08InspectType.data.Length];
            for (int i = 0; i < GlobalData.B08TaskListData.rows.Length; i++)
            {
                string tempResult = await B08_API_TaskInfo(GlobalData.B08TaskListData.rows[i].id);
                //Debug.Log($"B08_API_TaskInfo id={GlobalData.B08TaskListData.rows[i].id}:" + tempResult);
                var tempInfo= JsonConvert.DeserializeObject<B08_TaskInfo>(tempResult);
                if (tempInfo != null)
                {
                    GlobalData.B08TaskListData.rows[i].infoData = tempInfo.Data;
                }
                else
                {
                    Debug.Log("tempInfo null! :"+tempResult);
                }
                string taskLocationResult = await B08_API_TaskLocation(GlobalData.B08TaskListData.rows[i].id);
                Debug.Log($"taskLocationResult id={GlobalData.B08TaskListData.rows[i].id}:" + taskLocationResult);
                GlobalData.B08TaskListData.rows[i].infoData.Locations = JsonConvert.DeserializeObject<B08_TaskLocationData>(taskLocationResult).data.locations;

            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取B08_API_TaskInfo数据不成功,原因:" + e.ToString());
        }
    }

    public string token;
    
    public async Task<string> B08_API_data(string cmdUrl, int type)
    {
        if (type == 0)
        {
            cmdUrl += "1794245918999351298";
        }
        else if (type == 1)
        {
            cmdUrl += "1798366756789653505";
        }

        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取{cmdUrl}数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }
    // public async Task<string> B08_API_TaskInfo(int type, int xunjian_type)
    // {
    //     string cmdUrl = ServerAddress.API_B08_taskInfo;
    //     if (type == 0)
    //     {
    //         cmdUrl += "1794245918999351298";
    //     }
    //     else if (type == 1)
    //     {
    //         cmdUrl += "1798366756789653505";
    //     }
    //
    //     cmdUrl += "&xunjian_type=" + xunjian_type;
    //     Debug.Log("!!!:" + cmdUrl);
    //     UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
    //     www.downloadHandler = new DownloadHandlerBuffer();
    //     www.SetRequestHeader("Content-Type", "application/json");
    //     await www.SendWebRequest();
    //     if (www.result != UnityWebRequest.Result.Success)
    //     {
    //         Debug.LogWarning($"获取B08_API_TaskInfo type={type} 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
    //     }
    //     string result = www.downloadHandler.text;
    //     www.Dispose();
    //     return result;
    // }
    
    public async Task<string> B08_API_GetToken()
    {
        string cmdUrl = ServerAddress.API_GetToken;
        //Debug.Log("!!!:" + cmdUrl);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Post");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取API_GetToken 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    
    public async Task<string> B08_API_TaskInfoList(int page,int pageSize)
    {
        string cmdUrl = ServerAddress.API_B08_taskInfoList;
        cmdUrl += $"?pageNum={page}&pageSize={pageSize}";
        Debug.Log("!!!:" + cmdUrl +" token:"+token);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        www.SetRequestHeader("Authorization", "Bearer "+token);
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取B08_API_TaskInfoList page={page} pageSize={pageSize} 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }
    
    public async Task<string> B08_API_TaskInfo(string id)
    {
        string cmdUrl = ServerAddress.API_B08_taskInfo;
        cmdUrl += $"/{id}";
        Debug.Log("!!!:" + cmdUrl +" token:"+token);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        www.SetRequestHeader("Authorization", "Bearer "+token);
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取API_B08_taskInfo id={id} 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }
    
    public async Task<string> B08_API_TaskInfoItems(string id)
    {
        string cmdUrl = ServerAddress.API_B08_taskItems;
        cmdUrl += $"/{id}/taskItems";
        //Debug.Log("!!!:" + cmdUrl +" token:"+token);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        www.SetRequestHeader("Authorization", "Bearer "+token);
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取B08_API_TaskInfoItems id={id} 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }
    
    public async Task<string> B08_API_TaskLocation(string id)
    {
        string cmdUrl = ServerAddress.API_B08_taskLocation;
        cmdUrl += $"/{id}?useOptimized=true&includeWorkOrderInfo=true&limit=100";
        Debug.Log("!!!:" + cmdUrl +" token:"+token);
        UnityWebRequest www = new UnityWebRequest(cmdUrl, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        www.SetRequestHeader("Authorization", "Bearer "+token);
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取API_B08_taskLocation id={id} 数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }
        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }


    /// <summary>
    /// 获取站点水位图表
    /// </summary>
    /// <param name="stcd"></param>
    /// <returns></returns>
    public async Task<string> GetWaterTrend_Chart(string stcd,string startDate,string endDate)
    {
        UnityWebRequest www = new UnityWebRequest(ServerAddress.API_GetWaterTrend_chart + stcd + "&startDate=" + startDate + "&endDate=" + endDate, "Get");
        Debug.Log(ServerAddress.API_GetWaterTrend_chart + stcd + "&startDate=" + startDate + "&endDate=" + endDate);
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取stcd:{stcd},水位统计信息数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    public async Task<string> GetDropTrend_Chart(string stcd, string startDate, string endDate)
    {
        UnityWebRequest www = new UnityWebRequest(ServerAddress.API_GetDropTrend_chart + stcd + "&startDate=" + startDate + "&endDate=" + endDate, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取stcd:{stcd},水位统计信息数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    public async Task<string> GetWaterTrend_Info(string stcd)
    {
        UnityWebRequest www = new UnityWebRequest(ServerAddress.API_GetWaterTrend_info + stcd, "Get");
        www.downloadHandler = new DownloadHandlerBuffer();
        www.SetRequestHeader("Content-Type", "application/json");
        await www.SendWebRequest();
        if (www.result != UnityWebRequest.Result.Success)
        {
            Debug.LogWarning($"获取stcd:{stcd},水位统计信息数据不成功,原因:返request不成功:" + www.downloadHandler.text);
        }

        string result = www.downloadHandler.text;
        www.Dispose();
        return result;
    }

    public void SaveFirstFrame(byte[] uploadData, string fileName, string _targetName)
    {
        StartCoroutine(SendSaveFirstFrame(uploadData, fileName, _targetName));
    }

    IEnumerator SendSaveFirstFrame(byte[] uploadData, string fileName, string _targetName)
    {
        //fileName = "1.jpg";
        WWWForm form = new WWWForm();
        form.AddBinaryData("file", uploadData, fileName);
        UnityWebRequest www = UnityWebRequest.Post(ServerAddress.API_TextureUploadPath, form);
        yield return www.SendWebRequest();
        if (www.result == UnityWebRequest.Result.Success)
        {
            ActionInstance._Instance.obsFmUpdata?.Invoke(_targetName);
        }

        Debug.Log(www.downloadHandler.text);
        www.Dispose();
    }


    #region 摄像头远程控制

    public void GetDeviceChannelId(string deviceId, Action<string> callBack)
    {
        StartCoroutine(SendGetDevicesChannel(deviceId, 1, 1, callBack));
    }

    IEnumerator SendGetDevicesChannel(string deviceId, int page, int count, Action<string> call)
    {
        string sendUrl = ServerAddress.API_GetDevicesInfo;
        sendUrl += $"/{deviceId}/channels?page={page}&count={count}&query&online&channelType&catalogUnderDevice";
        UnityWebRequest www = UnityWebRequest.Get(sendUrl);
        yield return www.SendWebRequest();
        ObsHttpRequestData tempData = JsonConvert.DeserializeObject<ObsHttpRequestData>(www.downloadHandler.text);
        GetObsChannelRequestData channelData = tempData.data.ToObject<GetObsChannelRequestData>();
        call?.Invoke(channelData.list[0].channelId);
        www.Dispose();
    }

    IEnumerator SendStartRTSP(string deviceId, string channelId)
    {
        string sendUrl = ServerAddress.API_PlayStart;
        sendUrl += $"/{deviceId}/{channelId}";
        UnityWebRequest www = UnityWebRequest.Get(sendUrl);
        yield return www.SendWebRequest();
        Debug.Log(www.downloadHandler.text);
        www.Dispose();
    }

    public void SendObsCameraCtrlCmd(string deviceId, string channelId, ObsCtrlType type)
    {
        StartCoroutine(SendCameraCtrl(deviceId, channelId, type.ToString()));
    }

    IEnumerator SendCameraCtrl(string deviceId, string channelId, string command)
    {
        string sendUrl = ServerAddress.API_CameraCtrl;
        sendUrl += $"/{deviceId}/{channelId}?command={command}&horizonSpeed=10&verticalSpeed=10&zoomSpeed=10";
        UnityWebRequest www = UnityWebRequest.Post(sendUrl, "");
        Debug.Log("send:" + sendUrl);
        yield return www.SendWebRequest();
        Debug.Log(www.downloadHandler.text);
        www.Dispose();
    }

    #endregion

    // /// <summary>
    // /// 所有硬件设备的获取信息
    // /// </summary>
    public async Task GetSensorList()
    {
        bool successInternet = true;
        UnityWebRequest www = UnityWebRequest.Get(ServerAddress.API_GetAllSensorList);
        www.timeout = timeOut;
        await www.SendWebRequest();
        try
        {
            if (www.result != UnityWebRequest.Result.Success)
            {
                successInternet = false;
                Debug.LogWarning("获取设备数据不成功,原因:返request不成功:" + www.downloadHandler.text);
            }
            else
            {
                Debug.Log($"设备列表json :{www.downloadHandler.text}");
                SensorListResult tempData = JsonUtility.FromJson<SensorListResult>(www.downloadHandler.text);
                GlobalData._devicesIdDatas = new Dictionary<string, DevicesId_Data>();

                for (int i = 0; i < tempData.rows.Count; i++)
                {
                    GlobalData._devicesIdDatas.Add(tempData.rows[i].sensorName, tempData.rows[i]);
                }
                Debug.Log($"初始化设备列表成功！！！ count:{tempData.total}");
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("获取设备数据不成功,原因:" + e.ToString());
        }

        www.Dispose();

        if (!successInternet)
        {
            WWW localWWW = new WWW(Application.streamingAssetsPath + "/SensorList.json");
            await new UnityAsync.WaitUntil(() => { return localWWW.isDone; });
            SensorListResult tempData = JsonUtility.FromJson<SensorListResult>(localWWW.text);
            GlobalData._devicesIdDatas = new Dictionary<string, DevicesId_Data>();
            for (int i = 0; i < tempData.rows.Count; i++)
            {
                GlobalData._devicesIdDatas.Add(tempData.rows[i].sensorName, tempData.rows[i]);
            }

            Debug.Log($"读取本地初始化设备列表成功！！！ count:{tempData.total}");
            www.Dispose();
        }
    }
}