using IStation.Common;
using IStation.Dto;
using IStation.Untity; 
using IStation.ZyModel; 
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Http;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Web;
using System.Web.Http; 

namespace IStation.WebApi.Controllers
{
    /// <summary>
    /// 取水总量
    /// </summary>
    [RoutePrefix("TotalWaterIn")]
    public class TotalWaterInController : ApiController
    {
        /// <summary>
        ///
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
        [Route("Test1")]
        [HttpGet]
        public async Task<IStation.Dto.ApiResult> Test1()
        {
            var sum = await ZyConnectHelper.async_debug();
            return new IStation.Dto.ApiResult<double>(sum);
        }

        /// <summary>
        ///
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
        [Route("Test2")]
        [HttpGet]
        public IStation.Dto.ApiResult Test2()
        {
            var sum = ZyConnectHelper.async_debug().GetAwaiter().GetResult();
            return new IStation.Dto.ApiResult<double>(sum);
        }

        /// <summary>
        ///
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
        [Route("GetByDayDebug")]
        [HttpGet]
        public IStation.Dto.ApiResult GetByDayDebug(string day)
        {
            if (ZyConnectHelper.isDebug)
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "Debug is Unacess " };
            if (day == null)
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day null" };
            }
            if (!DateTime.TryParse(day, out DateTime dayD))
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day 格式不正确" };
            }
            if (dayD > DateTime.Today)
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "不能查询今日的数据" };
            }

            var sum = ZyConnectHelper.GetTotalWaterByDay_In(dayD).Result;
            return new IStation.Dto.ApiResult<double>(sum);
        }

        /// <summary>
        /// 获取某日的取水总量
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
        [Route("GetByDay")]
        [HttpGet]
        public async Task<IStation.Dto.ApiResult> GetByDay(string day)
        {
            if (ZyConnectHelper.isDebug)
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "Debug is Unacess " };
            if (day == null)
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day null" };
            }
            if (!DateTime.TryParse(day, out DateTime dayD))
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "day 格式不正确" };
            }
            if (dayD > DateTime.Today)
            {
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "不能查询今日的数据" };
            }
            double sum = -1;
            if (dayD < DateTime.Today)
            {
                sum = TotalWaterInHelper.Read(dayD);
            }

            if (sum < 0)
            {
                var tagDict = new Dictionary<string, string>
                {
                  { "1#", "二取水1号主水泵.累计流量" },
                  { "2#", "二取水2号主水泵.累计流量" },
                  { "3#", "二取水3号主水泵.累计流量" },
                  { "4#", "二取水4号主水泵.累计流量" },
                  { "5#", "二取水5号主水泵.累计流量" },
                };
                var starttime = new DateTime(dayD.Year, dayD.Month, dayD.Day, 0, 0, 0).ToString("G");
                var endtime = new DateTime(dayD.Year, dayD.Month, dayD.Day, 23, 59, 59).ToString("G");
                if (dayD == DateTime.Today)
                {
                    endtime = DateTime.Now.AddMinutes(-5).ToString("G");
                }
                sum = 0;
                string joinedValues = string.Join(",", tagDict.Values);
                var result = HttpClientHelper.Get<List<DataPoint>>(ZyConnectHelper.ZyApiUrl, starttime, endtime, "first", "300s", joinedValues);
                var realScadaDataList = ZyConnectHelper.GetScadaData(result);
                if (realScadaDataList != null && realScadaDataList.Any())
                {
                    foreach (var r in realScadaDataList)
                    {
                        if (r.MonitorRecords == null || !r.MonitorRecords.Any())
                            continue;
                        var rrr = r.MonitorRecords.Where(x => x.Value != null).Select(x => x.Value.Value).ToList();
                        if (rrr == null || !rrr.Any())
                            continue;
                        if (double.IsNaN(rrr.Last()) || double.IsNaN(rrr.First()))
                        {
                            return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "获取监控数据失败" };
                        }
                        sum += (rrr.Last() - rrr.First());
                    }
                }
            }
            if (dayD < DateTime.Today)
            {
                TotalWaterInHelper.Save(dayD, sum);
            }
            return new IStation.Dto.ApiResult<double>(sum / 10000);
        }

        /// <summary>
        /// 获取最近三天的取水总量
        /// </summary>
        /// <param name="day"></param>
        /// <returns></returns>
        [Route("GetLastDay3")]
        [HttpGet]
        public async Task<IStation.Dto.ApiResult> GetLastDay3()
        {
            if (ZyConnectHelper.isDebug)
                return new IStation.Dto.ApiResult() { Code = ApiResultCode.Error, Message = "Debug is Unacess " };
            DateTime yest1 = DateTime.Today.AddDays(-1);
            var sum1 = TotalWaterInHelper.Read(yest1);
            if (sum1 < 0)
            {
                sum1 = await ZyConnectHelper.GetTotalWaterByDay_In(yest1);//.GetAwaiter().GetResult();
                TotalWaterInHelper.Save(yest1, sum1);
            }

            DateTime yest2 = DateTime.Today.AddDays(-2);
            var sum2 = TotalWaterInHelper.Read(yest2);
            if (sum2 < 0)
            {
                sum2 = await ZyConnectHelper.GetTotalWaterByDay_In(yest2);//.GetAwaiter().GetResult();
                TotalWaterInHelper.Save(yest2, sum2);
            }

            DateTime yest3 = DateTime.Today.AddDays(-3);
            var sum3 = TotalWaterInHelper.Read(yest3);
            if (sum3 < 0)
            {
                sum3 = await ZyConnectHelper.GetTotalWaterByDay_In(yest3);//.GetAwaiter().GetResult();

                TotalWaterInHelper.Save(yest3, sum3);
            }

            return new IStation.Dto.ApiResult<List<double>>(new List<double> { sum1 / 10000, sum2 / 10000, sum3 / 10000 });
        }

        /// <summary>
        /// 获取web客户端ip
        /// </summary>
        /// <returns></returns>
        public static string GetWebClientIp()
        {
            string userIP = "";

            try
            {
                if (System.Web.HttpContext.Current == null
                 || System.Web.HttpContext.Current.Request == null
                 || System.Web.HttpContext.Current.Request.ServerVariables == null)
                {
                    return "";
                }

                string CustomerIP = "";

                //CDN加速后取到的IP simone 090805
                CustomerIP = System.Web.HttpContext.Current.Request.Headers["Cdn-Src-Ip"];
                if (!string.IsNullOrEmpty(CustomerIP))
                {
                    return CustomerIP;
                }

                CustomerIP = System.Web.HttpContext.Current.Request.ServerVariables["HTTP_X_FORWARDED_FOR"];

                if (!String.IsNullOrEmpty(CustomerIP))
                {
                    return CustomerIP;
                }

                if (System.Web.HttpContext.Current.Request.ServerVariables["HTTP_VIA"] != null)
                {
                    CustomerIP = System.Web.HttpContext.Current.Request.ServerVariables["HTTP_X_FORWARDED_FOR"];

                    if (CustomerIP == null)
                    {
                        CustomerIP = System.Web.HttpContext.Current.Request.ServerVariables["REMOTE_ADDR"];
                    }
                }
                else
                {
                    CustomerIP = System.Web.HttpContext.Current.Request.ServerVariables["REMOTE_ADDR"];
                }

                if (string.Compare(CustomerIP, "unknown", true) == 0 || String.IsNullOrEmpty(CustomerIP))
                {
                    return System.Web.HttpContext.Current.Request.UserHostAddress;
                }
                return CustomerIP;
            }
            catch { }

            return userIP;
        }

        private string _url = "ws://192.168.201.17:40001";

        private async Task<List<ZyModel.RealScadaData>> Get(string inputJson)
        {
            if (string.IsNullOrEmpty(inputJson))
                return default;
            var ws = new ClientWebSocket();
            IStation.LogHelper.Info(" var ws = new ClientWebSocket();");
            await ws.ConnectAsync(new Uri(_url), CancellationToken.None);
            IStation.LogHelper.Info(" ws.ConnectAsync(new Uri(_url_root), CancellationToken.None);");
            if (ws.State != WebSocketState.Open)
            {
                return default;
            }
            IStation.LogHelper.Info("ws.ConnectAsync");
            var realScadaDataList = new List<ZyModel.RealScadaData>();
            var inputBytes = Encoding.UTF8.GetBytes(inputJson);
            await ws.SendAsync(new ArraySegment<byte>(inputBytes), WebSocketMessageType.Text, true, CancellationToken.None);
            try
            {
                IStation.LogHelper.Info("ws.SendAsync");
                List<byte> outputBytes = new List<byte>();//全部消息容器
                var buffer = new byte[1024 * 4];//缓冲区
                var result = ws.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None).Result; //监听Socket信息
                while (!result.CloseStatus.HasValue)  //是否关闭
                {
                    if (result.MessageType == WebSocketMessageType.Text)//文本消息
                    {
                        outputBytes.AddRange(buffer.Take(result.Count));
                        if (result.EndOfMessage)//消息是否已接收完全
                        {
                            IStation.LogHelper.Info("result.EndOfMessage");
                            //发送过来的消息
                            string outputJson = Encoding.UTF8.GetString(outputBytes.ToArray(), 0, outputBytes.Count);
                            var scadaDict = JsonHelper.Json2Object<Dictionary<string, Dictionary<DateTime, string>>>(outputJson);
                            if (scadaDict != null && scadaDict.Any())
                            {
                                foreach (var dict in scadaDict)
                                {
                                    var data = new ZyModel.RealScadaData();
                                    data.TagName = dict.Key;
                                    data.MonitorRecords = new List<IStation.ZyModel.MonitorRecord>();
                                    foreach (var item in dict.Value)
                                    {
                                        var record = new IStation.ZyModel.MonitorRecord();
                                        record.Time = item.Key;
                                        if (double.TryParse(item.Value, out double value))
                                        {
                                            record.Value = value;
                                        }
                                        data.MonitorRecords.Add(record);
                                    }
                                    realScadaDataList.Add(data);
                                }
                                IStation.LogHelper.Info("scadaDict != null && scadaDict.Any()");
                            }
                            break;
                        }
                    }

                    result = ws.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None).Result;//继续监听Socket信息
                                                                                                            // IStation.LogHelper.Info("ws.ReceiveAsync");
                }
            }
            catch (Exception ex)
            {
                IStation.LogHelper.Info(ex.Message);
                throw ex;
            }
            finally
            {
                try
                {   //关闭WebSocket
                    await ws.CloseOutputAsync(WebSocketCloseStatus.NormalClosure, "AcknowledgeCloseframe", CancellationToken.None);
                    IStation.LogHelper.Info("ws.CloseOutputAsync");
                }
                catch (Exception ex)
                {
                    IStation.LogHelper.Info(ex.Message);
                    throw ex;
                }
                ws.Abort();
                ws.Dispose();
            }
            return realScadaDataList;
        }
    }
}