using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using IStation.Untity;
using IStation.Model;
using SuperSocket.Server;
using SuperSocket;
using IStation.DataDockingSocket;

namespace IStation.Server 
{
    /// <summary>
    /// 接收信息辅助类
    /// </summary>
    internal class RequestReceivedHelper
    {
        //接收数据
        public static async ValueTask Receive(IAppSession session, PackageInfo packageInfo)
        {
            await Task.Run(async () =>
            {
                if (packageInfo == null)
                {
                    SZJTKTLogHelper.Error(" packageInfo is null");
                    return;
                } 
                var bytes = packageInfo.Body;
                if (!Valid(bytes))
                {
                    SZJTKTLogHelper.Error(" bytes Validation failed!");
                    return;
                }
                var appParas = AppParasHelper.Get();
                if (appParas == null || appParas.RuleItems == null)
                {
                    SZJTKTLogHelper.Error(" json is null");
                    return;
                }

                var byte4 = new byte[4];
                //数据读取日期
                Array.Copy(bytes, 13, byte4, 0, 4);
                var date = Bytes2Int4(byte4); 
                //数据读取时间 
                Array.Copy(bytes, 17, byte4, 0, 4);
                var time = Bytes2Int4(byte4);

                var hmsStr = time.ToString();
                if (hmsStr.Length < 6)
                    hmsStr = "0" + hmsStr;
                var hms = hmsStr.Substring(0, 2) + ":" + hmsStr.Substring(2, 2) + ":" + hmsStr.Substring(4, 2);
                var strTime = $"{date} {hms}";
                DateTime dataTime = DateTime.ParseExact(strTime.ToString(), "yyyyMMdd hh:mm:ss", System.Globalization.CultureInfo.CurrentCulture);

                var list = new List<Model.MonitorDataDockingSrcRecord>();
                foreach (var x in appParas.RuleItems)
                {
                    var record = new Model.MonitorDataDockingSrcRecord();
                    record.SignId = x.SignId;
                    record.RecordType = Model.eMonitorType.General;
                    record.SrcTime = dataTime;
                    record.SrcValue = null;
                    switch (x.Rule)
                    {
                        case eRule.Double:
                            {
                                var btValue = bytes.Skip((x.Index - 1)).Take(x.Size).ToArray();
                                record.SrcValue = Bytes2Double(btValue).ToString();
                            }
                            break;
                        case eRule.Int4:
                            {
                                var btValue = bytes.Skip((x.Index - 1)).Take(x.Size).ToArray();
                                record.SrcValue = Bytes2Int4(btValue).ToString();
                            }
                            break;
                        case eRule.Int32:
                            {
                                var btValue = bytes.Skip((x.Index - 1)).Take(x.Size).ToArray();
                                record.SrcValue = Bytes2Int32(btValue).ToString();
                            }
                            break;
                        default: break;
                    }
                    list.Add(record);
                }

            });

        }

        //验证
        private static bool Valid(byte[] bytes)
        {
            SZJTKTLogHelper.Info($"字节长度:{bytes.Count()}");
            if (bytes == null || bytes.Count() < 1)
                return false;
            var bytePrefix = new byte[8];
            Array.Copy(bytes, 0, bytePrefix, 0, 8);
            var prefix = Encoding.ASCII.GetString(bytePrefix);
            SZJTKTLogHelper.Info($"前缀:{prefix}");
            if (prefix != Settings.Transfer.SZJTKT.Prefix)
                return false;

            byte[] byteProductID = new byte[4];
            Array.Copy(bytes, 9, byteProductID, 0, 4);
            var productId = Bytes2Int4(byteProductID);
            SZJTKTLogHelper.Info($"设备编号:{productId}");
            if (productId.ToString() != Settings.Transfer.SZJTKT.ProductId)
                return false;
            return true;
        }


        /// <summary>
        /// 处理数据
        /// </summary>
        public static List<Model.MonitorDataDockingSrcRecord> HandleData
            (
                byte[] bts
            )
        {

            var list = new List<Model.MonitorDataDockingSrcRecord>();

            //将指令转化为字节数组
            var instrution_bts = bts;
            var byte4 = new byte[4];
            var byte2 = new byte[2];
            var byte1 = new byte[1];

            //数据读取日期
            Array.Copy(instrution_bts, 13, byte4, 0, 4);
            var date = Bytes2Int4(byte4);

            //数据读取时间 
            Array.Copy(instrution_bts, 17, byte4, 0, 4);
            var time = Bytes2Int4(byte4);

            var hms = time.ToString();
            if (hms.Length < 6)
                hms = "0" + hms;
            var ttt = hms.Substring(0, 2) + ":" + hms.Substring(2, 2) + ":" + hms.Substring(4, 2);
            var strTime = $"{date} {ttt}";
            DateTime dataTime = DateTime.ParseExact(strTime.ToString(), "yyyyMMdd hh:mm:ss", System.Globalization.CultureInfo.CurrentCulture);


            //瞬时流量，m3/h 
            Array.Copy(instrution_bts, 21, byte4, 0, 4); 
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1590274355240243200",
                SrcValue = Bytes2Double(byte4).ToString()
            });

            //瞬时压力，Mpa 
            Array.Copy(instrution_bts, 25, byte4, 0, 4);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589903942416994304",
                SrcValue = Bytes2Double(byte4).ToString()
            });

            //瞬时流速，m3/h 
            Array.Copy(instrution_bts, 29, byte4, 0, 4);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589904380742733824",
                SrcValue = Bytes2Double(byte4).ToString()
            });

            //正向累计整数 
            Array.Copy(instrution_bts, 33, byte4, 0, 4);
            var ForwardCumulativeFlowInteger = Bytes2Int4(byte4);
            //正向累计的小数/1000 
            Array.Copy(instrution_bts, 41, byte2, 0, 2);
            var ForwardCumulativeFlowDecimal = Bytes2Int32(byte2);
            //正向累积流量 
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589903863446638592",
                SrcValue = (ForwardCumulativeFlowInteger + ForwardCumulativeFlowDecimal * 0.001).ToString()
            });

            //反向累计整数 
            Array.Copy(instrution_bts, 37, byte4, 0, 4);
            var ReverseCumulativeFlowInteger = Bytes2Int4(byte4);
            //反向累计的小数 /1000 
            Array.Copy(instrution_bts, 43, byte2, 0, 2);
            var ReverseCumulativeFlowDecimal = Bytes2Int32(byte2);
            //反向累积流量 
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589904635718668288",
                SrcValue = (ReverseCumulativeFlowInteger + ReverseCumulativeFlowDecimal * 0.001).ToString()
            });

            //水表电池电量 
            Array.Copy(instrution_bts, 45, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589906693322575872",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //GPRS电池电量 
            Array.Copy(instrution_bts, 46, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589906830698614784",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //系统报警 
            Array.Copy(instrution_bts, 47, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589905499946618880",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //水表空管报警 
            Array.Copy(instrution_bts, 48, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589905855032201216",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //断励磁报警 
            Array.Copy(instrution_bts, 49, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589905963715006464",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //流量上线报警 
            Array.Copy(instrution_bts, 50, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589906172004143104",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //流量下线报警 
            Array.Copy(instrution_bts, 51, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589906236487372800",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //压力上限报警 
            Array.Copy(instrution_bts, 52, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589906299754254336",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            //压力下限报警 
            Array.Copy(instrution_bts, 53, byte1, 0, 1);
            list.Add(new Model.MonitorDataDockingSrcRecord()
            {
                SignId = "1589906389663354880",
                SrcValue = Bytes2Int32(byte1).ToString()
            });

            return list;
        }
        

        public static int Bytes2Int4(byte[] src, int offset = 0)
        {
            src = src.Reverse().ToArray();
            int value;
            value = (int)(((src[offset] & 0xFF) << 24)
                    | ((src[offset + 1] & 0xFF) << 16)
                    | ((src[offset + 2] & 0xFF) << 8)
                    | (src[offset + 3] & 0xFF));
            return value;
        } 
        public static double Bytes2Double(byte[] value, int offset = 0)
        {
            return BitConverter.ToSingle(value.Reverse().ToArray(), 0);//采用了IEEE-754二进制浮点数算术标准
        } 
        public static int Bytes2Int32(byte[] bytes)
        {
            return Convert.ToInt32(Byte2HexStr(bytes.Reverse().ToArray()), 16); ;
        }
        

        /// <summary>
        /// byte[]转为16进制字符串
        /// </summary> 
        public static string Byte2HexStr(byte[] bytes)
        {
            string returnStr = "";
            if (bytes != null)
            {
                for (int i = 0; i < bytes.Length; i++)
                {
                    returnStr += bytes[i].ToString("X2");
                }
            }
            return returnStr;
        }
    }
}