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.Linq;
using UnityEngine;
using UnityEngine.Networking;
using Unity.VisualScripting;
using static System.Net.WebRequestMethods;

public class HttpHelper : MonoBehaviour
{
    public Action OnSWYJRefresh;

    public static HttpHelper _Instance;
    
    public static Dictionary<string, DevicesId_Data> _devicesIdDatas_BuYuan =new Dictionary<string, DevicesId_Data>();


    private async void Awake()
    {
        _Instance = this;
        InItBuYuanDevicesList();
        await SendBuYuan_GetSensorData();
        await GetBuYuanDevicesGroupInfo();


        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2 || GlobalData.pageIndex == PageIndex.Page3)
        {
            //可以并行，无需等待
            InitYZTData();
        }
        if (GlobalData.pageIndex == PageIndex.Page1)
        {
            //可以并行，无需等待
            InitXHGKData();
        }
        if (GlobalData.pageIndex == PageIndex.Page1)
        {
            //可以并行，无需等待
            InitGCJKData();
        }
        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2)
        {
            //可以并行，无需等待
            InitSWYJData();
        }
        if (GlobalData.pageIndex == PageIndex.Page1 || GlobalData.pageIndex == PageIndex.Page2)
        {
            //可以并行，无需等待
            InitGCYWData();
        }
    }
    public async Task InitYZTData() {
        await InitYZTData1();
        InitYZTData2();

    }
    public async Task InitYZTData1()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetWaterManagerProject);
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("YZTLayer联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData.downloadHandler.text);

                // 提取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) {
                GlobalData.obsCameraLib.Add(GlobalData.layerUnitDatas[i].name, GlobalData.layerUnitDatas[i].name_pri);
            }
        }
    }

    public async Task InitYZTData2()
    {

        bool successInternet = true;
        string sendUrl = ServerAddress.API_GetDevicesInfo;
        sendUrl += "/34020000001180000001/channels?page=1&count=40";
        Debug.Log(sendUrl);
        UnityWebRequest requestData = UnityWebRequest.Get(sendUrl);
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("监控数据联网不成功,原因:返request不成功:" + requestData.downloadHandler.text.ToString());
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData.downloadHandler.text);

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "0")
                {
                    GlobalData.obsDatas = new List<ObsData>();
                    ServerObsDatas serverObsDatas = JsonConvert.DeserializeObject<ServerObsDatas>(dataToken.ToString());
                    for (int i = 0; i < serverObsDatas.list.Count; i++)
                    {
                        ObsData obsData = new ObsData();
                        obsData.name = serverObsDatas.list[i].name;
                        obsData.targetName = GlobalData.obsCameraLib[obsData.name];
                        // if (i > 0)
                        // {
                        //     obsData.url =
                        //         "http://www.chatgpt918.top:9080/rtp/34020000001180000001_34020000001310000001/hls.m3u8";
                        // }
                        // else
                        // {
                        obsData.url = ServerAddress.ObsSeverM3U8Address + string.Format("/rtp/{0}_{1}/hls.m3u8", serverObsDatas.list[i].deviceId, serverObsDatas.list[i].channelId);
                        //}
                        obsData.type = obsType.BuYuanObs;
                        obsData.deviceId = serverObsDatas.list[i].deviceId;
                        obsData.channelId = serverObsDatas.list[i].channelId;
                        obsData.status = serverObsDatas.list[i].status;
                        GlobalData.obsDatas.Add(obsData);
                    }
                }
                else
                {
                    Debug.LogWarning("监控数据联网不成功,原因:返序列化失败");
                    successInternet = false;
                }
            }
        }
        catch (Exception e)
        {
            successInternet = false;
            Debug.LogWarning("监控数据联网不成功,原因:" + e.ToString());
        }
        requestData.Dispose();

    }

    public async Task InitXHGKData()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetGetProjectMilestones);
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("XHGKLayer联网不成功，读本地缓存数据,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData.downloadHandler.text);

                //   ȡ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();
        }
    }

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

                // 提取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();
    }

    public async Task InitSWYJData() {
        InitSWYJData0();
        await InitSWYJData1();
        await InitSWYJData2();
        OnSWYJRefresh?.Invoke();
    }



    public async Task InitSWYJData1()
    {
        GlobalData.BuYuanShuiWeiDataList = new List<ShuiWeiData>();
        var devicesInfo = _devicesIdDatas_BuYuan["上游水位计"];
        string sw1Result = await GetSingleDevicesInfo(devicesInfo.ChannelID, devicesInfo.DeviceID, 24);
        try
        {
            GetDevicesRequestData tempData =JsonConvert.DeserializeObject<GetDevicesRequestData>(sw1Result);
            if (tempData != null)
            {
                GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
                {
                    name = "补元上游水位",
                    targetName = "BY_ShuiWei_Up",
                    value = tempData.datas[0].NodeValue,
                    type = shuiWeiType.BuYuanShuiWei,
                    datas = tempData.datas.ToArray()
                });
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("补元上游水位不成功,原因:" + e.ToString());
        }

        var devicesInfo1 = _devicesIdDatas_BuYuan["下游水位计"];
        string sw2Result = await GetSingleDevicesInfo(devicesInfo1.ChannelID, devicesInfo1.DeviceID, 24);
        try
        {
            GetDevicesRequestData tempData = JsonConvert.DeserializeObject<GetDevicesRequestData>(sw2Result);
            if (tempData != null)
            {
                GlobalData.BuYuanShuiWeiDataList.Add(new ShuiWeiData()
                {
                    name = "补元下游水位",
                    targetName = "BY_ShuiWei_Down",
                    value = tempData.datas[0].NodeValue,
                    type = shuiWeiType.BuYuanShuiWei,
                    datas = tempData.datas.ToArray()
                });
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("补元下游水位不成功,原因:" + e.ToString());
        }

        string dayResult = await GetSingleDevicesInfo_day(devicesInfo.ChannelID, devicesInfo.DeviceID, 6);
        try
        {
            GetDevicesRequestData tempData = JsonConvert.DeserializeObject<GetDevicesRequestData>(dayResult);
            GlobalData.buYuanShuiWei_day = new ShuiWeiBianHuaData();
            GlobalData.buYuanShuiWei_day.name = new string[6];
            GlobalData.buYuanShuiWei_day.value = new double[6];
            for (int i = 0; i < tempData.datas.Count; i++)
            {
                GlobalData.buYuanShuiWei_day.name[i] = tempData.datas[i].RecvTime;
                GlobalData.buYuanShuiWei_day.value[i] = tempData.datas[i].NodeValue;
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6天平均数据不成功,原因:" + e.ToString());
        }

        string monthResult = await GetSingleDevicesInfo_month(devicesInfo.ChannelID, devicesInfo.DeviceID, 6);
        try
        {
            GetDevicesRequestData tempData = JsonConvert.DeserializeObject<GetDevicesRequestData>(monthResult);
            GlobalData.buYuanShuiWei_month = new ShuiWeiBianHuaData();
            GlobalData.buYuanShuiWei_month.name = new string[6];
            GlobalData.buYuanShuiWei_month.value = new double[6];
            for (int i = 0; i < tempData.datas.Count; i++)
            {
                GlobalData.buYuanShuiWei_month.name[i] = tempData.datas[i].RecvTime;
                GlobalData.buYuanShuiWei_month.value[i] = tempData.datas[i].NodeValue;
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6月平均数据不成功,原因:" + e.ToString());
        }

        string hourResult = await GetSingleDevicesInfo_hour(devicesInfo.ChannelID, devicesInfo.DeviceID, 6);
        try
        {
            GetDevicesRequestData tempData = JsonConvert.DeserializeObject<GetDevicesRequestData>(hourResult);
            GlobalData.buYuanShuiWei_hour = new ShuiWeiBianHuaData();
            GlobalData.buYuanShuiWei_hour.name = new string[6];
            GlobalData.buYuanShuiWei_hour.value = new double[6];
            for (int i = 0; i < tempData.datas.Count; i++)
            {
                GlobalData.buYuanShuiWei_hour.name[i] = tempData.datas[i].RecvTime;
                GlobalData.buYuanShuiWei_hour.value[i] = tempData.datas[i].NodeValue;
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取6小时平均数据不成功,原因:" + e.ToString());
        }
    }

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

                // 提取data字段的值
                JToken dataToken = jsonObject["data"];
                JToken codeToken = jsonObject["code"];
                if (codeToken.ToString() == "200")
                {
                    GlobalData.swDatas = JsonConvert.DeserializeObject<List<StationData>>(dataToken.ToString());
                }
                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 InitSWYJData0()
    {
        bool successInternet = true;
        UnityWebRequest requestData = UnityWebRequest.Get(ServerAddress.APIGetThreeLevel);
        await requestData.SendWebRequest();
        try
        {
            if (requestData.result != UnityWebRequest.Result.Success)
            {
                Debug.LogWarning("三线水位联网不成功,原因:返request不成功");
                successInternet = false;
            }
            else
            {
                JObject jsonObject = JObject.Parse(requestData.downloadHandler.text);

                // 提取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
            {
               GlobalData.buYuanSensorData= JsonUtility.FromJson<SensorDataResult>(www.downloadHandler.text);
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取补元闸门设备数据不成功,原因:" +e.ToString());
        }
        www.Dispose();
    }

    public async Task GetBuYuanDevicesGroupInfo()
    {
        //获取所有渗压记
        GetDevicesData tempData = new GetDevicesData();
        tempData.idsList = new List<DevicesMessage>();
        for (int i = 0; i < 13; i++)
        {
            var devicesInfo = _devicesIdDatas_BuYuan[$"P{i+1}"];
            tempData.idsList.Add(new DevicesMessage()
            {
                DeviceID = devicesInfo.DeviceID,
                ChannelID = devicesInfo.ChannelID
            });
        }
        string jsonStr;
        try
        {
            jsonStr = await Devices(tempData);
            jsonStr = "{\"datas\":" + jsonStr+"}";
            GetDevicesRequestData resultData= JsonUtility.FromJson<GetDevicesRequestData>(jsonStr);
            GlobalData.BuYuanShuiYaDataList = new List<ShuiYaData>();
            for (int i = 0; i < resultData.datas.Count; i++)
            {
                GlobalData.BuYuanShuiYaDataList.Add(new ShuiYaData()
                {
                    name = resultData.datas[i].NodeName,
                    value = resultData.datas[i].NodeValue,
                    type = shuiYaType.BuYuanShuiYa,
                    targetName = $"BY_{resultData.datas[i].NodeName}"
                });
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取补元水压计设备数据不成功,原因:" +e.ToString());
            throw;
        }
        
        //获取所有位移记
        tempData = new GetDevicesData();
        tempData.idsList = new List<DevicesMessage>();
        for (int i = 0; i < 8; i++)
        {
            var devicesInfo = _devicesIdDatas_BuYuan[$"M{i+1}"];
            tempData.idsList.Add(new DevicesMessage()
            {
                DeviceID = devicesInfo.DeviceID,
                ChannelID = devicesInfo.ChannelID
            });
        }
        try
        {
            jsonStr = await Devices(tempData);
            jsonStr = "{\"datas\":" + jsonStr+"}";
            GetDevicesRequestData resultData= JsonUtility.FromJson<GetDevicesRequestData>(jsonStr);
            GlobalData.BuYuanWeiYiDataList = new List<WeiYiData>();
            for (int i = 0; i < resultData.datas.Count; i++)
            {
                GlobalData.BuYuanWeiYiDataList.Add(new WeiYiData()
                {
                    name = resultData.datas[i].NodeName,
                    value = resultData.datas[i].NodeValue,
                    type = weiYiType.BuYuanWeiYi,
                    targetName = $"BY_{resultData.datas[i].NodeName}"
                });
            }
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取补元位移计设备数据不成功,原因:" +e.ToString());
            throw;
        }
    }
    
    /// <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"></param>
    /// <param name="deviceId"></param>
    /// <param name="count"></param>
    /// <returns></returns>
    public async Task<string> GetSingleDevicesInfo(int channelId, int deviceId, int count) {
        string cmdUrl = ServerAddress.API_BuYuan_GetSingleDevicesInfo;
        GetSingleDeviceData sendData = new GetSingleDeviceData();
        sendData.ChannelID = channelId;
        sendData.DeviceID = deviceId;
        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_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 Task InitGCYWData()
    {
        string jsonStr;
        try
        { 
            jsonStr = await B08_API_data(ServerAddress.API_B08_dataStatis);
           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);
            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);
            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);
            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);
            GlobalData.B08QuestionStatis=JsonConvert.DeserializeObject<B08_questionStatis>(jsonStr);
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取API_B08_questionStatis数据不成功,原因:" + e.ToString());
        }
        
        try
        {
            jsonStr = await B08_API_data(ServerAddress.API_B08_inspectType);
            GlobalData.B08InspectType=JsonConvert.DeserializeObject<B08_inspectType>(jsonStr);
        }
        catch (Exception e)
        {
            Debug.LogWarning("获取API_B08_inspectType数据不成功,原因:" + e.ToString());
        }
    }
    
    public async Task<string> B08_API_data(string 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($"获取{cmdUrl}数据不成功,原因:返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)
    {
        Debug.Log(fileName);
        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 void InItBuYuanDevicesList()
    {
        _devicesIdDatas_BuYuan = new Dictionary<string, DevicesId_Data>();

        _devicesIdDatas_BuYuan.Add("上游水位计", new DevicesId_Data()
        {
            ChannelID = 7,
            DeviceID = 4,
            name = "上游水位计",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("下游水位计", new DevicesId_Data()
        {
            ChannelID = 8,
            DeviceID = 4,
            name = "上游水位计",
            showName = "",
            value = -1
        });

        #region P

        _devicesIdDatas_BuYuan.Add("P1", new DevicesId_Data()
        {
            ChannelID = 1,
            DeviceID = 2,
            name = "P1/UP1",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P2", new DevicesId_Data()
        {
            ChannelID = 2,
            DeviceID = 2,
            name = "P2/UP2",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P3", new DevicesId_Data()
        {
            ChannelID = 3,
            DeviceID = 2,
            name = "P3",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P4", new DevicesId_Data()
        {
            ChannelID = 4,
            DeviceID = 2,
            name = "P4/UP3",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P5", new DevicesId_Data()
        {
            ChannelID = 1,
            DeviceID = 3,
            name = "P5/UP5",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P6", new DevicesId_Data()
        {
            ChannelID = 2,
            DeviceID = 3,
            name = "P6/",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P7", new DevicesId_Data()
        {
            ChannelID = 3,
            DeviceID = 3,
            name = "P7/UP5",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P8", new DevicesId_Data()
        {
            ChannelID = 4,
            DeviceID = 3,
            name = "P8/UP6",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P5温度", new DevicesId_Data()
        {
            ChannelID = 9,
            DeviceID = 3,
            name = "P5温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P6温度", new DevicesId_Data()
        {
            ChannelID = 10,
            DeviceID = 3,
            name = "P6温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P7温度", new DevicesId_Data()
        {
            ChannelID = 11,
            DeviceID = 3,
            name = "P7温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P8温度", new DevicesId_Data()
        {
            ChannelID = 12,
            DeviceID = 3,
            name = "P8温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P9温度", new DevicesId_Data()
        {
            ChannelID = 9,
            DeviceID = 4,
            name = "P9温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P10温度", new DevicesId_Data()
        {
            ChannelID = 10,
            DeviceID = 4,
            name = "P10温度",
            showName = "",
            value = -1
        });

        _devicesIdDatas_BuYuan.Add("P12温度", new DevicesId_Data()
        {
            ChannelID = 11,
            DeviceID = 4,
            name = "P12温度",
            showName = "",
            value = -1
        });

        _devicesIdDatas_BuYuan.Add("P9", new DevicesId_Data()
        {
            ChannelID = 3,
            DeviceID = 4,
            name = "P9",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P10", new DevicesId_Data()
        {
            ChannelID = 4,
            DeviceID = 4,
            name = "P10/UP7",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P11", new DevicesId_Data()
        {
            ChannelID = 5,
            DeviceID = 4,
            name = "P11/UP8",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add("P12", new DevicesId_Data()
        {
            ChannelID = 1,
            DeviceID = 4,
            name = "P12/UP9",
            showName = "",
            value = -1
        });

        _devicesIdDatas_BuYuan.Add("P13", new DevicesId_Data()
        {
            ChannelID = 2,
            DeviceID = 4,
            name = "P13/UP10",
            showName = "",
            value = -1
        });

        #endregion

        #region M

        //M1-8
        int m_cid = 1;
        int m_did = 5;
        for (int i = 0; i < 8; i++)
        {
            _devicesIdDatas_BuYuan.Add($"M{i + 1}", new DevicesId_Data()
            {
                ChannelID = m_cid + i,
                DeviceID = m_did,
                name = $"M{i + 1}",
                showName = "",
                value = -1
            });
        }

        //M温度
        _devicesIdDatas_BuYuan.Add($"M2温度", new DevicesId_Data()
        {
            ChannelID = 10,
            DeviceID = 5,
            name = $"M2温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add($"M5温度", new DevicesId_Data()
        {
            ChannelID = 13,
            DeviceID = 5,
            name = $"M5温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add($"M6温度", new DevicesId_Data()
        {
            ChannelID = 14,
            DeviceID = 5,
            name = $"M6温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add($"M7温度", new DevicesId_Data()
        {
            ChannelID = 15,
            DeviceID = 5,
            name = $"M7温度",
            showName = "",
            value = -1
        });
        _devicesIdDatas_BuYuan.Add($"M8温度", new DevicesId_Data()
        {
            ChannelID = 16,
            DeviceID = 5,
            name = $"M8温度",
            showName = "",
            value = -1
        });

        #endregion
    }
    
    
}