using Newtonsoft.Json.Linq;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Text;
using System.Threading.Tasks;
using UnityEngine;
using UnityEngine.Networking;

/// <summary>
///整合JSON
/// </summary>
public static class CombineJSON
{
    //public static List<string> jsons = new List<string>();
    public static Dictionary<string, string> jsonsDic = new Dictionary<string, string>();

    #region 直连
    /// <summary>
    /// 获取所有设备API
    /// </summary>
    /// <returns></returns>
    public static string GetCombineJSON()
    {
        //创建一个JArray对象，用于存储多个JSON 对象
        JArray jsonArray = new JArray();

        // 解析JSON字符串，并添加到JArray
        foreach (var item in jsonsDic.Values)
        {
            var jsonObj = JObject.Parse(item);
            jsonArray.Add(jsonObj);
        }

        //创建一个包含JArray的JObject对象
        JObject resultObj = new JObject();
        resultObj["data"] = jsonArray;

        //将整合后的JSON输出成字符串
        string resultJson = resultObj.ToString();
        return resultJson;
    }

    /// <summary>
    /// POST修改数据的请求
    /// </summary>
    /// <param name="apiUrl"></param>
    /// <param name="newData"></param>
    /// <returns></returns>
    /// <exception cref="Exception"></exception>
    public static async Task<string> UpdateJson_POST(string apiUrl, string token, string newData)
    {
        var client = new HttpClient();
        var request = new HttpRequestMessage
        {
            Method = HttpMethod.Post,
            RequestUri = new Uri(apiUrl),
            Headers =
    {
        { "X-Token", token },
    },
            Content = new StringContent(newData)
            {
                Headers =
        {
            ContentType = new MediaTypeHeaderValue("application/json")
        }
            }
        };
        using (var response = await client.SendAsync(request))
        {
            response.EnsureSuccessStatusCode();
            var body = await response.Content.ReadAsStringAsync();
            return body;
        }
    }

    /// <summary>
    /// POST获取数据的请求
    /// </summary>
    /// <param name="apiUrl"></param>
    /// <param name="token"></param>
    /// <returns></returns>
    public static async Task<string> GetJson_POST(string apiUrl, string token)
    {
        using (HttpClient httpClient = new HttpClient())
        {
            Debug.Log(apiUrl + "=aaaaaa=");
            var client = new HttpClient();
            var request = new HttpRequestMessage
            {
                Method = HttpMethod.Post,
                RequestUri = new Uri(apiUrl),
                Headers =
    {
        { "X-Token", token },
    },
            };
            using (var response = await client.SendAsync(request))
            {
                Debug.Log(apiUrl + "=bbbbbbb=");

                response.EnsureSuccessStatusCode();
                var body = await response.Content.ReadAsStringAsync();
                Debug.Log(body);
                return (body);
            }
        }
    }

    /// <summary>
    /// 获取GET接口
    /// </summary>
    /// <param name="apiUrl"></param>
    /// <returns></returns>
    public static async Task<string> GetJson_GET(string apiUrl)
    {
        using (var httpClient = new HttpClient())
        {
            using (var response = await httpClient.GetAsync(apiUrl))
            {
                if (response.IsSuccessStatusCode)
                {
                    string jsonResult = await response.Content.ReadAsStringAsync();
                    // 处理返回的JSON数据
                    Debug.Log(jsonResult);
                    return jsonResult;
                }
                else
                {
                    Debug.Log("请求GET接口失败: " + response.StatusCode);
                    return null;
                }
            }
        }
    }
    #endregion


    #region 协程调用接口


    /// <summary>
    /// POST获取数据的请求
    /// </summary>
    /// <param name="apiUrl"></param>
    /// <param name="token"></param>
    /// <param name="callback"></param>
    /// <returns></returns>
    public static IEnumerator GetJson_POST(string apiUrl, string token, Action<string> callback)
    {
        //using (UnityWebRequest request = UnityWebRequest.Post(apiUrl, ""))
        UnityWebRequest request = new UnityWebRequest(apiUrl, "POST");
        {
            request.SetRequestHeader("X-Token", token);
            request.SetRequestHeader("Content-Type", "application/json");
            DownloadHandlerBuffer dH = new DownloadHandlerBuffer();
            request.downloadHandler = dH;
            //request.timeout = 15;
            yield return request.SendWebRequest();

            if (!request.isNetworkError && !request.isHttpError)
            {
                // 等待一帧
                yield return null;

                // 检查请求是否已完成
                while (!request.isDone)
                {
                    yield return null;
                }
                //if (request.downloadHandler.text != null)
                if (!string.IsNullOrEmpty(request.downloadHandler.text))
                //byte[] responseData = request.downloadHandler.data;
                //if (responseData != null && responseData.Length > 0)
                {
                    string responseText = request.downloadHandler.text;
                    //Debug.Log(responseText);
                    //string responseText = Encoding.UTF8.GetString(responseData);
                    callback(responseText);
                }
                else
                {
                    Debug.Log(apiUrl + " request.downloadHandler.text为null");
                    callback.Invoke(null);
                }
            }
            else
            {
                Debug.Log(apiUrl + " 请求POST接口失败: " + request.error + "\nURL: " + apiUrl + "\nrequest.downloadHandler:" + request.downloadHandler.text);
                callback.Invoke(null);
            }
        }
    }


    /// <summary>
    /// POST修改数据的请求
    /// </summary>
    /// <param name="apiUrl"></param>
    /// <param name="token"></param>
    /// <param name="newData"></param>
    /// <param name="onComplete"></param>
    /// <returns></returns>
    public static IEnumerator UpdateJson_POST(string apiUrl, string token, string newData, Action<string> callback)
    {
        //using (UnityWebRequest request = new UnityWebRequest(apiUrl, "POST"))
        UnityWebRequest request = new UnityWebRequest(apiUrl, "POST");
        {
            request.SetRequestHeader("X-Token", token);
            request.SetRequestHeader("Content-Type", "application/json");
            byte[] bodyRaw = System.Text.Encoding.UTF8.GetBytes(newData);
            DownloadHandlerBuffer dH = new DownloadHandlerBuffer();
            request.uploadHandler = new UploadHandlerRaw(bodyRaw);
            request.downloadHandler = new DownloadHandlerBuffer();
            request.downloadHandler = dH;
            //request.timeout = 15;
            yield return request.SendWebRequest();

            if (request.result == UnityWebRequest.Result.Success)
            {
                // 等待一帧
                yield return null;

                // 检查请求是否已完成
                while (!request.isDone)
                {
                    yield return null;
                }
                //if (request.downloadHandler.text != null)
                if (!string.IsNullOrEmpty(request.downloadHandler.text))
                //byte[] responseData = request.downloadHandler.data;
                //if (responseData != null && responseData.Length > 0)
                {
                    string responseText = request.downloadHandler.text;
                    //string responseText = Encoding.UTF8.GetString(responseData);
                    callback?.Invoke(responseText);
                }
                else
                {
                    Debug.Log(apiUrl + " request.downloadHandler.text为空");
                    callback.Invoke(null);
                }
            }
            else
            {
                Debug.Log(apiUrl + " 请求POST接口失败: " + request.error + "\nURL: " + apiUrl);
                callback.Invoke(null);
            }
        }
    }

    /// <summary>
    /// 获取GET接口
    /// </summary>
    /// <param name="apiUrl"></param>
    /// <returns></returns>
    public static IEnumerator GetJson_GET(string apiUrl, Action<string> callback)
    {
        using (UnityWebRequest request = UnityWebRequest.Get(apiUrl))
        {
            yield return request.SendWebRequest();

            if (!request.isNetworkError && !request.isHttpError)
            {
                if (request.downloadHandler.text != null)
                {
                    string jsonResult = request.downloadHandler.text;
                    //Debug.Log(jsonResult);
                    callback?.Invoke(jsonResult);
                }
                else
                {
                    Debug.Log("request.downloadHandler.text为null");
                    callback.Invoke(null);
                }
            }
            else
            {
                Debug.Log("请求GET接口失败: " + request.error);
                callback.Invoke(null);
            }
        }
    }

    public static IEnumerator GetJson_GET(string apiUrl, string token, Action<string> callback)
    {
        //using (UnityWebRequest request = UnityWebRequest.Get(apiUrl))
        UnityWebRequest request = UnityWebRequest.Get(apiUrl);
        {
            request.SetRequestHeader("X-Token", token);
            DownloadHandlerBuffer dH = new DownloadHandlerBuffer();
            request.downloadHandler = dH;
            //request.timeout = 15;
            yield return request.SendWebRequest();

            if (request.result == UnityWebRequest.Result.Success)
            {
                // 等待一帧
                yield return null;

                // 检查请求是否已完成
                while (!request.isDone)
                {
                    yield return null;
                }
                //string responseBody = request.downloadHandler.text;
                //if (request.downloadHandler.text != null)
                if (!string.IsNullOrEmpty(request.downloadHandler.text))
                //    byte[] responseData = request.downloadHandler.data;
                //if (responseData != null && responseData.Length > 0)
                {
                    string responseText = request.downloadHandler.text;
                    //string responseText = Encoding.UTF8.GetString(responseData);
                    callback?.Invoke(responseText);
                }
                else
                {
                    Debug.Log(apiUrl + " request.downloadHandler.text为空");
                    callback.Invoke(null);
                }
            }
            else
            {
                Debug.Log(apiUrl + " 请求Get接口失败: " + request.error + "\nURL: " + apiUrl);
                callback.Invoke(null);
            }
        }
    }


    public static IEnumerator GetJson_POST(string apiUrl, string token, int looptime, Action<string> callback)
    {
        while (true)
        {
            //if (CabinetUIManager.Instance.SomeMethod() && GameManager.Inst.isLoading)
            //{
            //    yield return new WaitForSeconds(looptime);
            //}
            //else
            //{
            //    yield return null;
            //}

            //using (UnityWebRequest request = UnityWebRequest.Post(apiUrl, ""))
            UnityWebRequest request = new UnityWebRequest(apiUrl, "POST");
            {
                request.SetRequestHeader("X-Token", token);
                request.SetRequestHeader("Content-Type", "application/json");
                DownloadHandlerBuffer dH = new DownloadHandlerBuffer();
                request.downloadHandler = dH;
                request.timeout = 15;
                yield return request.SendWebRequest();

                if (!request.isNetworkError && !request.isHttpError)
                {
                    // 等待一帧
                    yield return null;

                    // 检查请求是否已完成
                    while (!request.isDone)
                    {
                        yield return null;
                    }
                    //if (request.downloadHandler.text != null)
                    if (!string.IsNullOrEmpty(request.downloadHandler.text))
                    //    byte[] responseData = request.downloadHandler.data;
                    //if (responseData != null && responseData.Length > 0)
                    {
                        string responseText = request.downloadHandler.text;
                        //Debug.Log(responseText);
                        //string responseText = Encoding.UTF8.GetString(responseData);
                        callback(responseText);
                    }
                    else
                    {
                        Debug.Log("request.downloadHandler.text为null");
                    }
                }
                else
                {
                    Debug.Log("请求POST接口失败: " + request.error + "\nURL: " + apiUrl);
                }
            }
            yield return new WaitForSeconds(looptime);
        }
    }

    #endregion
}