using System;
using System.Collections.Generic;
using System.IO;
using System.Net;
using System.Text; 
using IStation.Model;

namespace IStation.WinFrmUI.River
{
    /// <summary>
    ///  潮汐接口
    /// </summary>
    public class TideFromWebHelper
    { 
        private static readonly string _urlPrefix = "https://global-tide.nmdis.org.cn/Api/Service.ashx";
            //"http://global-tide.nmdis.org.cn/Api/Service.ashx";//主体Url


        /// <summary>
        /// 获取潮汐数据
        /// </summary>
        static public List<Model.TileLevel> GetByDay1(
            DateTime startday,  
            out string error)
        {
            string benchmark;
            var list = ReadList(startday, out benchmark);
            if(list == null)
            {
                list = GetByDayApi(startday, out benchmark, out error);
                if (list == null)
                {
                    return null;
                }

                SaveList(startday, benchmark, list);
            }
            else
            {
                 error = null;
            } 
            return list;
        }
        /// <summary>
        /// 
        /// </summary>
        /// <param name="startday"></param>
        /// <param name="error"></param>
        /// <returns></returns>
        static public List<Model.TimeWaterLevel> GetByDay2(DateTime startday, out string error)
        {
            var waterLevels长江 = new List<TimeWaterLevel>();
         
            var list = GetByDay1(startday,   out error);
            if (list != null)
            {
                foreach (var h in list)
                {
                    waterLevels长江.Add(
                       new TimeWaterLevel(
                       new DateTime(startday.Year, startday.Month, startday.Day, h.Hour, 0, 0), h.Level));
                }
            }
            else
            {
                error = null;
            }
            return waterLevels长江;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="startday"></param>
        /// <param name="endday"></param>
        /// <param name="benchmark"></param>
        /// <param name="error"></param>
        /// <returns></returns>
        static public List<Model.TimeWaterLevel> GetByDayRange(
            DateTime startday, DateTime endday, 
            out string error)
        {
   
            error = null;

            var waterLevels长江 = new List<TimeWaterLevel>(); 
            for (DateTime currentDate = startday; currentDate <= endday; currentDate = currentDate.AddDays(1))
            {
                if (endday.Date > DateTime.Now.Date.AddDays(2))
                {
                    break ;
                }

                var list1 = GetByDay1(startday.Date,  out error);
                if (list1 != null && list1.Count > 0)
                {
                    for (int h = startday.Hour; h < 24; h++)
                    {
                        waterLevels长江.Add(
                           new TimeWaterLevel(
                           new DateTime(startday.Year, startday.Month, startday.Day, h, 0, 0),
                           list1[h].Level));
                    }
                }
            }

   
            return waterLevels长江;
        }
       
        /// <summary>
        /// 
        /// </summary>
        /// <param name="day"></param>
        /// <param name="benchmark"></param>
        /// <param name="error"></param>
        /// <returns></returns>
        static private List<Model.TileLevel> GetByDayApi(
            DateTime day,
            out string benchmark,
            out string error)
        {
            if (day > DateTime.Today.AddDays(1))
            {
                error = "不能查询后天的数据";
                benchmark = "";
                return null;
            }
            IStation.LogHelper.Info("read tide from web  day: " + day + " start");

            benchmark = "";
            error = "";
            IStation.CalcModel.Tide.PostParas paras = new CalcModel.Tide.PostParas();
            paras.Data = new CalcModel.Tide.DateParas();
            paras.Data.code = "NT1170";//static string 石洞口 = "NT1170";
            paras.Data.date = day.ToString();
            var url = $"{_urlPrefix}?ApiRequest={paras.ToJson()}";
            try
            {
                var responseText = HttpRequest(url, "GET");
                var result = JsonHelper.Json2Object<IStation.CalcModel.Tide.Result>(responseText);
                if (result == null)
                {
                    IStation.LogHelper.Error("read tide from web 1 长江水位请求失败 "   );
                    error = "长江水位请求失败";
                    return null;
                }

                if (Convert.ToBoolean(result.State) && !string.IsNullOrEmpty(result.Message))
                {
                    IStation.LogHelper.Error("read tide from web 2 长江水位请求失败 "+ result.Message);
                    error = result.Message;
                    return null;
                }
                if (result.Data == null)
                {
                    IStation.LogHelper.Error("read tide from web 3 长江水位请求失败 "  );
                    error = "长江水位请求失败";
                    return null;
                }

                benchmark = result.Data.Data.Benchmark;//= "在平均海面下213cm"
                List<Model.TileLevel> list = new List<Model.TileLevel>(24);
                list.Add(new Model.TileLevel()
                { Hour =   0 , Level = result.Data.SubData.a0 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 1, Level = result.Data.SubData.a1 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 2, Level = result.Data.SubData.a2 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 3, Level = result.Data.SubData.a3 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 4, Level = result.Data.SubData.a4 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 5, Level = result.Data.SubData.a5 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 6, Level = result.Data.SubData.a6 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 7, Level = result.Data.SubData.a7 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 8, Level = result.Data.SubData.a8 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 9, Level = result.Data.SubData.a9 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 10, Level = result.Data.SubData.a10 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 11, Level = result.Data.SubData.a11 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 12, Level = result.Data.SubData.a12 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 13, Level = result.Data.SubData.a13 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 14, Level = result.Data.SubData.a14 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 15, Level = result.Data.SubData.a15 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 16, Level = result.Data.SubData.a16 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 17, Level = result.Data.SubData.a17 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 18, Level = result.Data.SubData.a18 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 19, Level = result.Data.SubData.a19 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 20, Level = result.Data.SubData.a20 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 21, Level = result.Data.SubData.a21 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 22, Level = result.Data.SubData.a22 / 100 });
                list.Add(new Model.TileLevel()
                { Hour = 23, Level = result.Data.SubData.a23 / 100 });
                IStation.LogHelper.Info("read tide from web  day: " + day +" success");
                return list;
            }
            catch (Exception ex)
            {
                IStation.LogHelper.Error("read tide from web error:"+ ex);
                error = ex.Message;
                //IStation.Log
            }
            return null;
        }

        static private void SaveList(DateTime day, string benchmark, List<Model.TileLevel> list)
        {
            if (list == null)
                return;
            try
            {
                var folder = System.IO.Path.Combine(IStation.DataFolderHelper.GetRootPath(),
                "Tide", "FromWeb",
                day.Year.ToString(),
                day.ToString("yyyy-MM"));
                if (!System.IO.Directory.Exists(folder))
                {
                    System.IO.Directory.CreateDirectory(folder);

                }
                var fileName = System.IO.Path.Combine(folder,
                    string.Format("{0}.csv", day.ToString("yyyy-MM-dd")));


                StreamWriter streamWriter = new StreamWriter(fileName, false, System.Text.Encoding.GetEncoding("gb2312"));

                StringBuilder StringBuilder = new StringBuilder();
                // 写出表头
                StringBuilder.Append("总流量,长江水位差值");
                //
                StringBuilder.AppendLine(); StringBuilder.Append("benchmark,"); StringBuilder.Append(benchmark);

                // 写出数据
                foreach (var m in list)
                {
                    StringBuilder.AppendLine(); StringBuilder.AppendFormat("{0},{1}", m.Hour, m.Level);
                }
                streamWriter.Write(StringBuilder.ToString());

                streamWriter.Flush();
                streamWriter.Close();
            }
            catch(Exception ex)
            {
               IStation.LogHelper.WriteError("write tide file error:"+ex.Message, ex);
                return;
            }
        }

        static private List<Model.TileLevel> ReadList(DateTime day,out string benchmark)
        {
            var list = new List<Model.TileLevel>();
            benchmark = null;
            var folder = System.IO.Path.Combine(IStation.DataFolderHelper.GetRootPath(),
                "Tide", "FromWeb",
                day.Year.ToString(),
                day.ToString("yyyy-MM"));
            if (!System.IO.Directory.Exists(folder))
            {
                System.IO.Directory.CreateDirectory(folder);
                return null;
            }
            var fileName = System.IO.Path.Combine(folder,
                string.Format("{0}.csv", day.ToString("yyyy-MM-dd")));
            if (!System.IO.File.Exists(fileName))
            {
                return null;
            }
            //文件流读取
            System.IO.FileStream fs = new System.IO.FileStream(fileName, System.IO.FileMode.Open);
            System.IO.StreamReader sr = new System.IO.StreamReader(fs, Encoding.GetEncoding("gb2312"));

            string tempText  ;
            int line = 0;
            while ((tempText = sr.ReadLine()) != null)
            {
                line++;
                string[] arr = tempText.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);

                //一般第一行为标题，所以取出来作为标头
                if (line == 1)
                {

                }
                else if (line == 2)
                {
                    benchmark = arr[1];
                }
                else
                {
                     list.Add(new Model.TileLevel(Convert.ToInt32(arr[0]), Convert.ToDouble(arr[1])));
                }
            }

            //关闭流
            sr.Close(); fs.Close();

            return list;
        }

        //请求
        private static string HttpRequest(string url, string type, string data = null )
        {
            ServicePointManager.Expect100Continue = true;
            ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12 | SecurityProtocolType.Tls11 | SecurityProtocolType.Tls;
            ServicePointManager.ServerCertificateValidationCallback = (sender, certificate, chain, errors) => true;

            var request = (HttpWebRequest)WebRequest.Create(url);
            request.Method = type;
            request.ContentType = "application/json";
            request.KeepAlive = false;
             
            //if (version != null)
            //{
            //    //默认是HttpVersion.Version11
            //    request.ProtocolVersion = version;
            //}

            #region 注释
            /*request.Timeout = 10 * 1000;//请求超时时间
            if (!string.IsNullOrEmpty(data))
            {
                request.ContentLength = Encoding.UTF8.GetBytes(data).Length;
            }*/
            #endregion

            if (!string.IsNullOrEmpty(data))
            {
                using (var streamWriter = new StreamWriter(request.GetRequestStream()))
                {
                    streamWriter.Write(data);
                    streamWriter.Flush();
                }
            }

            string responseText;
            using (var response = (HttpWebResponse)request.GetResponse())
            using (var reader = new StreamReader(response.GetResponseStream()))
            {
                responseText = reader.ReadToEnd();
            }
            return responseText;
        }


    }
}