using Hanhe.iWCS.Common;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Hanhe.iWCS.IndonesiaGLMProtocol
{
    public class OITcpHelper
    {
        private static string url = Settings.OITcpSeverUrl;
        private static string token = "";
        private static WebApiHelper apiHelper = new WebApiHelper();
        public static string readip = "";
        public static string writeip = "";
        public static string writeAllIP = "";


        #region 1.	中转请求操作
        /// <summary>
        /// 1.1.	请求 json内容
        /// </summary>
        public static void JsonTransit() {
            var req = JsonConvert.SerializeObject(new JsonTransitData());
            var feedback = apiHelper.WebPost($"{url}/api/transit/json?access_token={token}", req);
            if (feedback != "") {
                var result = JsonConvert.DeserializeObject<JsonTransitResult>(feedback);
            }
        }
        /// <summary>
        /// 1.2.	请求 ascii内容
        /// </summary>
        public static StrTransitResult AsciiTransit(StrTransitData model) {
            StrTransitResult result = null;
            var req = JsonConvert.SerializeObject(model);
            var feedback = apiHelper.WebPost($"{url}/api/transit/ascii?access_token={token}", req);
            if (feedback != "") {
                result = JsonConvert.DeserializeObject<StrTransitResult>(feedback);
            }
            return result;
        }
        /// <summary>
        /// 1.3.	请求 hex内容
        /// </summary>
        public static void HexTransit() {
            var req = JsonConvert.SerializeObject(new StrTransitData());
            var feedback = apiHelper.WebPost($"{url}/api/transit/hex?access_token={token}", req);
            if (feedback != "") {
                var result = JsonConvert.DeserializeObject<StrTransitResult>(feedback);
            }
        }
        public class BaseTransitData
        {
            public string host { get; set; }
            public int port { get; set; }
            public int timeout { get; set; }

        }
        public class JsonTransitData : BaseTransitData
        {
            public object data { get; set; }
        }
        public class JsonTransitResult : BaseResponseModel
        {
            public object result { get; set; }
        }
        public class StrTransitData : BaseTransitData
        {
            public string data { get; set; }
        }
        public class StrTransitResult : BaseResponseModel
        {
            public string result { get; set; }
        }
        #endregion

        #region 2.	Modbus处理操作
        #region 2.1.	读取输出线圈状态 01 功能
        /// <summary>
        /// 2.1.	读取输出线圈状态 01 功能
        /// </summary>
        public static RelayReadOutResult RelayReadOutPut(RelayReadOutPutModel model) {
            RelayReadOutResult result = null;
            var req = JsonConvert.SerializeObject(model);
            var feedback = apiHelper.WebPost($"{url}/api/modbus/relay/readoutput?access_token={token}", req);
            //Console.WriteLine($"读取输出线圈状态 modbus/relay/readoutput req={req} res={feedback}");
            CMMLog.Info($"读取输出线圈状态 modbus/relay/readoutput req={req} res={feedback}");
            if (feedback != "") {
                result = JsonConvert.DeserializeObject<RelayReadOutResult>(feedback);
            }
            return result;
        }
        public class RelayReadOutPutModel : BaseRequestModel
        {
            public int bitNum { get; set; }
            //public object tcpModel { get; set; }
            //public int msgNo { get; set; }
        }
        public class RelayReadOutResult : BaseResponseModel
        {
            public int[] result { get; set; }
        }
        #endregion

        #region 2.2.	读取输入离散量 02 功能
        /// <summary>
        /// 2.2.	读取输入离散量 02 功能
        /// </summary>
        public static void RelayReadInPut(BaseRequestModel model) {
            var req = JsonConvert.SerializeObject(model);
            var feedback = apiHelper.WebPost($"{url}/api/modbus/relay/readinput?access_token={token}", req);
            if (feedback != "") {
                var result = JsonConvert.DeserializeObject<RelayReadInPutResult>(feedback);
            }
        }
        public class RelayReadInPutResult : BaseRequestModel
        {
            public int result { get; set; }
        }
        #endregion

        #region 2.3.	读取输出寄存器数据 03 功能
        /// <summary>
        /// 2.3.	读取输出寄存器数据 03 功能
        /// </summary>
        public static RegisterReadOutPutResult RegisterReadOutPut(RegisterReadOutPutModel model) {
            RegisterReadOutPutResult result = null;
            //Settings.PlcInfo pmInfo = Settings.GetPlcInfo().Where(a => a.ip == model.host).FirstOrDefault();
            //model.port = pmInfo.port;
            var req = JsonConvert.SerializeObject(model);
            #region   拦截相同IP延迟一秒发送
            if (model.host == readip)
            {
                DateTime dateTime = DateTime.Now;
                int z = 1;
                while (z == 1)
                {
                    if (DateTime.Now.Subtract(dateTime).TotalSeconds > 2)
                    {
                        z = 2;
                        readip = model.host;
                    }
                }
            }
            else
            {
                readip = model.host;
            }
            #endregion
            CMMLog.Debug($"读取输出寄存器数据03功能:IP:{readip},URL：{url}/api/modbus/register/readoutput?access_token={token},写入数据：{req}");
            var feedback = apiHelper.WebPost($"{url}/api/modbus/register/readoutput?access_token={token}", req);
            if (feedback != "") {
                result = JsonConvert.DeserializeObject<RegisterReadOutPutResult>(feedback);
                CMMLog.Debug($"返回值:ip:{readip}" + JsonConvert.SerializeObject(result));
            }
            else
            {
                CMMLog.Error($"读取输出寄存器数据03功能：IP:{readip},返回值feedback为空！返回值：{feedback}");
            }
            try
            {
                if (result != null)
                {
                    if (result.errCode == 0)
                    {
                        var packNo = Settings.GetPlcInfo().Where(a => a.ip == model.host && a.deviceType == "1").FirstOrDefault();
                        if (packNo != null)
                        {
                            CMMLog.Debug($"读取输出寄存器数据 03 功能MODBUS参数:IP:{readip},包装机号：{packNo.location},通道地址为{model.addr},端口为{model.port},返回值{result.result[0]}");
                            //Console.WriteLine($"读取输出寄存器数据 03 功能MODBUS参数:IP:{readip},包装机号：{packNo.location},通道地址为{model.addr},端口为{model.port},返回值{result.result[0]}");
                        }
                        else
                        {
                            packNo = Settings.GetPlcInfo().Where(a => a.ip == model.host && a.deviceType == "22").FirstOrDefault();
                            if (packNo != null)
                            {
                                CMMLog.Debug($"读取输出寄存器数据 03 功能MODBUS参数:IP:{readip},包装机号：{packNo.location},通道地址为{model.addr},端口为{model.port},返回值{result.result[0]}");
                                //Console.WriteLine($"读取输出寄存器数据 03 功能MODBUS参数:IP:{readip},包装机号：{packNo.location},通道地址为{model.addr},端口为{model.port},返回值{result.result[0]}");
                            }
                        }
                    }
                    else if (result.errCode == 1025)
                    {
                        var packNo = Settings.GetPlcInfo().Where(a => a.ip == model.host && a.deviceType == "1").FirstOrDefault();
                        if (packNo != null)
                        {
                            CMMLog.Debug($"【1025异常】读取输出寄存器数据 03 功能MODBUS参数:IP:{readip},包装机号：{packNo.location}，通道地址为{model.addr},端口为{model.port},发送值{req}");
                            //Console.WriteLine($"【1025异常】读取输出寄存器数据 03 功能MODBUS参数:通道地址为{model.addr},端口为{model.port},发送值{req}");
                        }
                    }
                }
                else
                {
                    CMMLog.Debug($"读取输出寄存器数据 03 功能MODBUS参数为空:IP:{readip},通道地址为{model.addr},端口为{model.port},发送值{req}");
                    //Console.WriteLine($"读取输出寄存器数据 03 功能MODBUS参数为空:IP:{readip},通道地址为{model.addr},端口为{model.port},发送值{req}");
                }
                #region   重发机制
                //else if(result.errCode == 1125)
                //{
                //    int err = 0;
                //    while (err == 0)
                //    {
                //        var req1 = JsonConvert.SerializeObject(model);
                //        DateTime dateTime1 = DateTime.Now;
                //        if (DateTime.Now.Subtract(dateTime1).TotalSeconds > 1)
                //        {
                //            var feedbackReset = apiHelper.WebPost($"{url}/api/modbus/register/readoutput?access_token={token}", req1);
                //            CMMLog.Debug($"重新读取输出寄存器03功能输入数据:req:{req1},ip:{readip}");
                //            CMMLog.Debug($"重新读取输出寄存器数据03功能请求URL:readUrl:{url}/api/modbus/register/readoutput?access_token={token}");
                //            if (feedbackReset != "")
                //            {
                //                result = JsonConvert.DeserializeObject<RegisterReadOutPutResult>(feedbackReset);
                //                if(result.errCode == 0)
                //                {
                //                    err = 1;
                //                    CMMLog.Debug($"读取输出寄存器数据 03 功能MODBUS参数:通道地址为{model.addr},端口为{model.port},发送值{req},返回值{result.result[0]}");
                //                    Console.WriteLine($"读取输出寄存器数据 03 功能MODBUS参数:通道地址为{model.addr},端口为{model.port},发送值{req},返回值{result.result[0]}");
                //                    readip = model.host;
                //                }
                //            }
                //        }
                //    }
                //}
                #endregion
            }
            catch (Exception ex)
            {
                CMMLog.Error($"读取输出寄存器数据03功能抛出异常,IP:{readip},通道为:{model.addr},读取数量为：{model.dataNum},异常信息：{ex.Message}");
            }
            //CMMLog.Debug($"读取输出寄存器数据03功能返回结果:{feedback}");
            //Console.WriteLine($"读取输出寄存器数据03功能返回结果:{feedback}");
            
            return result;
        }
        public class RegisterReadOutPutModel : BaseRequestModel
        {

            public int dataNum { get; set; }
            //public int msgNo { get; set; }
        }
        public class RegisterReadOutPutResult : BaseResponseModel
        {
            public int[] result { get; set; }
        }
        #endregion

        #region  2.4.	读取输入寄存器数据 04 功能
        /// <summary>
        /// 2.4.	读取输入寄存器数据 04 功能
        /// </summary>
        public static RegisterReadOutPutResult RegisterReadInPut(RegisterReadOutPutModel model) {
            RegisterReadOutPutResult result = null;
            var req = JsonConvert.SerializeObject(model);
            var feedback = apiHelper.WebPost($"{url}/api/modbus/register/readinput?access_token={token}", req);
            if (feedback != "") {
                result = JsonConvert.DeserializeObject<RegisterReadOutPutResult>(feedback);
            }
            //CMMLog.Debug($"读取输入寄存器数据 04 功能MODBUS参数返回值为：{result},发送值{req}");
            ////Console.WriteLine($"读取输入寄存器数据 04 功能MODBUS参数返回值为：{result},发送值{req}");
            return result;
        }
       
        #endregion

        #region 2.5.	写单个输出线圈 05 功能
        /// <summary>
        /// 2.5.	写单个输出线圈 05 功能
        /// </summary>
        public static BaseResponseModel RelayWriteOutPut(RelayWriteOutPutModel model) {
            BaseResponseModel result = null;
            var req = JsonConvert.SerializeObject(model);
            var feedback = apiHelper.WebPost($"{url}/api/modbus/relay/writeoutput?access_token={token}", req);
            //Console.WriteLine($"写单个输出线圈 modbus/relay/writeoutput req={req} res={feedback}");
            CMMLog.Info($"写单个输出线圈 modbus/relay/writeoutput req={req} res={feedback}");
            if (feedback != "") {
                result = JsonConvert.DeserializeObject<BaseResponseModel>(feedback);
            }
            return result;
        }
        public class RelayWriteOutPutModel : BaseRequestModel
        {
            public bool status { get; set; }
        }
        #endregion

        #region 2.6.	写单个输出寄存器 06 功能
        public static BaseResponseModel RegisterWriteOutPut(RegisterWriteOutPutModel model) {
            BaseResponseModel result = null;
            //Settings.PlcInfo pmInfo = Settings.GetPlcInfo().Where(a => a.ip == model.host).FirstOrDefault();
            //model.port = pmInfo.port;
            var req = JsonConvert.SerializeObject(model);
            #region   拦截相同IP延迟一秒发送
            if (model.host == readip)
            {
                DateTime dateTime = DateTime.Now;
                int z = 1;
                while (z == 1)
                {
                    if (DateTime.Now.Subtract(dateTime).TotalSeconds > 1)
                    {
                        z = 2;
                        readip = model.host;
                    }
                }
            }
            else
            {
                readip = model.host;
            }
            #endregion
            CMMLog.Debug($"写单个输出寄存器06功能写入值：IP:{readip},URL：{url}/api/modbus/register/writeoutput?access_token={token},写入数据：{req}");
            var feedback = apiHelper.WebPost($"{url}/api/modbus/register/writeoutput?access_token={token}", req);
            if (feedback != "") result = JsonConvert.DeserializeObject<BaseResponseModel>(feedback);
            else CMMLog.Error($"写单个输出寄存器06功能写入值：异常：IP:{readip},返回值feedback为空！返回值：{feedback}");
            try
            {
                if (result != null && result.errCode == 0)
                {
                    CMMLog.Debug($"写单个输出寄存器 06 功能MODBUS参数：IP:{readip},通道地址为{model.addr},端口为：{model.port},错误码：{result.errCode},返回信息：{result.errMsg}");
                    ////Console.WriteLine($"写单个输出寄存器 06 功能MODBUS参数：通道地址为{model.addr},端口为：{model.port},错误码：{result.errCode},返回信息：{result.errMsg}");
                }
                else if (result.errCode == 1025)
                {
                    var packNo = Settings.GetPlcInfo().Where(a => a.ip == model.host && a.deviceType == "1").FirstOrDefault();
                    if (packNo != null)
                    {
                        CMMLog.Error($"【1025异常】读取输出寄存器数据 03 功能MODBUS参数:IP:{readip},当前包装机号：{packNo.location},通道地址为{model.addr},端口为{model.port},发送值{req}");
                        ////Console.WriteLine($"【1025异常】读取输出寄存器数据 03 功能MODBUS参数:当前包装机号：{packNo.location}通道地址为{model.addr},端口为{model.port},发送值{req}");
                    }
                }
                else if (result.errCode == 1125 || result.errCode != 0)
                {
                    DateTime dateTime = DateTime.Now;
                    int err = 3;
                    int num = 0;

                    while (err > 0)
                    {
                        if(DateTime.Now.Subtract(dateTime).TotalMilliseconds >= 300)
                        {
                            var feedbackReset = apiHelper.WebPost($"{url}/api/modbus/register/writeoutput?access_token={token}", req);
                            CMMLog.Debug($"【1125异常】重新读取写入寄存器数据06:IP:{readip},写入数据：{req}，Url:{url}/api/modbus/register/readoutput?access_token={token}");
                            if (feedbackReset != "")
                            {
                                result = JsonConvert.DeserializeObject<RegisterReadOutPutResult>(feedbackReset);
                                if (result.errCode == 0)
                                {
                                    err = err - 1;
                                    num = num + 1;
                                    CMMLog.Debug($"【1125异常】写单个输出寄存器 06 功能MODBUS参数:IP:{readip},通道地址为{model.addr},端口为{model.port},发送值{req},错误码：{result.errCode},返回信息：{result.errMsg}");
                                    readip = model.host;
                                }
                            }
                        }
                    }
                }
            }
            catch (Exception ex)
            {
                CMMLog.Error($"写单个输出寄存器06功能功能抛出异常:IP:{readip},通道为:{model.addr},写入值为：{model.data},异常信息：{ex.Message}");
            }
            return result;
        }
        public class RegisterWriteOutPutModel : BaseRequestModel
        {
            public int data { get; set; }
        }
        #endregion

        #region 2.7.	写多个输出线圈 15 功能
        public static void RelayWriteOutPutMulti() {
            var req = JsonConvert.SerializeObject(new RelayWriteOutPutModelMulti());
            var feedback = apiHelper.WebPost($"{url}/api/modbus/relay/writeoutputmulti?access_token={token}", req);
            if (feedback != "") {
                var result = JsonConvert.DeserializeObject<BaseResponseModel>(feedback);
            }
        }
        public class RelayWriteOutPutModelMulti : BaseRequestModel
        {
            public int bitNum { get; set; }
            public int[] data { get; set; }
        }
        #endregion

        #region 2.8.	写多个输出寄存器 16 功能
        public static void RegisterWriteOutPutMulti() {
            var req = JsonConvert.SerializeObject(new RegisterWriteOutPutModelMulti());
            var feedback = apiHelper.WebPost($"{url}/api/modbus/register/writeoutputmulti?access_token={token}", req);
            if (feedback != "") {
                var result = JsonConvert.DeserializeObject<BaseResponseModel>(feedback);
            }
        }
        public static BaseResponseModel RegisterWriteOutPutMulti(RegisterWriteOutPutModelMulti model)
        {
            BaseResponseModel result = null;
            //Settings.PlcInfo pmInfo = Settings.GetPlcInfo().Where(a => a.ip == model.host).FirstOrDefault();
            //model.port = pmInfo.port;
            var req = JsonConvert.SerializeObject(model);
            #region   拦截相同IP延迟一秒发送
            if (model.host == readip)
            {
                DateTime dateTime = DateTime.Now;
                int z = 1;
                while (z == 1)
                {
                    if (DateTime.Now.Subtract(dateTime).TotalSeconds > 1)
                    {
                        z = 2;
                        readip = model.host;
                    }
                }
                readip = model.host;
            }
            else
            {
                readip = model.host;
            }
            #endregion
            CMMLog.Debug($"写多个输出寄存器16功能：IP:{readip},URL:{url}/api/modbus/register/writeoutputmulti?access_token={token},写入数据：{req}");
            var feedback = apiHelper.WebPost($"{url}/api/modbus/register/writeoutputmulti?access_token={token}", req);
            if (feedback != "")
            {
                result = JsonConvert.DeserializeObject<BaseResponseModel>(feedback);
            }
            else
            {
                CMMLog.Error($"写多个输出寄存器16功能：异常：IP:{readip},返回值feedback为空！");
            }
            try
            {
                if (result != null && result.errCode == 0)
                {
                    CMMLog.Debug($"写多个输出寄存器16功能：IP:{readip},通道地址为{model.addr},端口为{model.port},发送值{req},错误码：{result.errCode},错误信息：{result.errMsg}");
                    ////Console.WriteLine($"写多个输出寄存器 16 功能MODBUS参数,通道地址为{model.addr},端口为{model.port},发送值{req},返回值{result.errCode},{result.errMsg}");
                }
                else if (result.errCode == 1025)
                {
                    var packNo = Settings.GetPlcInfo().Where(a => a.ip == model.host && a.deviceType == "1").FirstOrDefault();
                    if (packNo != null)
                    {
                        CMMLog.Error($"【1025异常】写多个输出寄存器16功能:IP:{readip},包装机号：{packNo.location}，通道地址为{model.addr},端口为{model.port},发送值{req}");
                        ////Console.WriteLine($"【1025异常】读取输出寄存器数据 03 功能MODBUS参数:通道地址为{model.addr},端口为{model.port},发送值{req}");
                    }
                }
                #region   重发机制
                //else if (result.errCode == 1125)
                //{
                //    int err = 0;
                //    while (err == 0)
                //    {
                //        var req1 = JsonConvert.SerializeObject(model);
                //        DateTime dateTime1 = DateTime.Now;
                //        if (DateTime.Now.Subtract(dateTime1).TotalSeconds > 1)
                //        {
                //            var feedbackReset = apiHelper.WebPost($"{url}/api/modbus/register/writeoutputmulti?access_token={token}", req);
                //            CMMLog.Debug($"重新读取写入多个寄存器16功能输入数据:req:{req1},ip:{readip}");
                //            CMMLog.Debug($"重新读取写入多个寄存器数据16功能请求URL:readUrl:{url}/api/modbus/register/readoutput?access_token={token}");
                //            if (feedbackReset != "")
                //            {
                //                result = JsonConvert.DeserializeObject<RegisterReadOutPutResult>(feedbackReset);
                //                if (result.errCode == 0)
                //                {
                //                    err = 1;
                //                    CMMLog.Debug($"写多个输出寄存器 16 功能MODBUS参数,通道地址为{model.addr},端口为{model.port},发送值{req},返回值{result.errCode},{result.errMsg}");
                //                    //Console.WriteLine($"写多个输出寄存器 16 功能MODBUS参数,通道地址为{model.addr},端口为{model.port},发送值{req},返回值{result.errCode},{result.errMsg}");
                //                    readip = model.host;
                //                }
                //            }
                //        }
                //    }
                //}
                #endregion
            }
            catch (Exception ex)
            {
                CMMLog.Error($"写多个输出寄存器16功能:异常：IP:{readip},通道为:{model.addr},写入值为：{model.data}，异常信息：{ex.Message}");
            }
            //CMMLog.Debug($"写多个输出寄存器16功能:{feedback}");
            ////Console.WriteLine($"写多个输出寄存器16功能:{feedback}");
            return result;
        }
        public class RegisterWriteOutPutModelMulti : BaseRequestModel
        {
            public int[] data { get; set; }
        }
        #endregion

        #endregion


        public class ReadInPutResult : BaseResponseModel
        {
            public int result { get; set; }
        }
        public class BaseResponseModel
        {
            public int errCode { get; set; }
            public string errMsg { get; set; }
        }
        public class BaseRequestModel
        {
            public string host { get; set; }
            public int port { get; set; } = 502;
            public int timeout { get; set; } = 1000;
            public int deviceNo { get; set; } = 1;
            public int addr { get; set; }
            public object tcpModel { get; set; } = new { msgNo = 1 };
        }
    }
}