using System.Data;
using System.Text;
using System.Text.Json;
using System.Text.Json.Serialization;
using Common;
using CommonEntity;
using LogCap.Common;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Mvc.Diagnostics;
using NLog;
using RestSharp;
using RestSharp.Authenticators;
using ViewModels;

namespace EMQX_HttpAuth.Controllers
{
    [Route("api/[controller]/[action]")]
    [ApiController]
    public class SocketTcpController : ControllerBase
    {
        private readonly Logger _logger = LogManager.GetCurrentClassLogger();
        public static string tcp_server = "http://localhost:8086";
        public static string mqtt_server = "http://43.138.217.154:18083";
        public IList<char> HexSet = new List<char>() { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'A', 'B', 'C', 'D', 'E', 'F', 'a', 'b', 'c', 'd', 'e', 'f' };
        public IConfiguration Configuration { get; set; }
        public SocketTcpController(IConfiguration config)
        {
            this.Configuration = config;
        }
        /// <summary>
        /// 获取所有在线的 下位机 客户端，返回的数据是 IP:端口的形式
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        [HttpPost()]
        async public Task<string> Get_all_TCPClients([FromBody] Data data)
        {
            RestClient client1 = new RestClient(tcp_server);
            //Console.WriteLine("发送MQTT的数据为：" + str);
            var request1 = new RestRequest("/blw/tcphandle", Method.Post);

            //注意方法是POST
            //Console.WriteLine("Topic: " + debug_log_report_mqtt_topic);
            request1.AddParameter("cmd", "get_tcp_info");
            request1.AddParameter("parameterlist", "");

            var Q = await client1.ExecuteAsync(request1);
            return Q.Content;
        }

        /// <summary>
        /// 获取所有在线的MQTTClient
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        [HttpPost()]
        async public Task<object> Get_all_MQTTClients([FromBody] QueryData data)
        {
            string? Key = Configuration["Key"];
            string? Security = Configuration["Security"];
            var option = new RestClientOptions()
            {
                BaseUrl = new Uri(mqtt_server),
                Authenticator = new HttpBasicAuthenticator(Key, Security)

            };
            RestClient client1 = new RestClient(option);

            //Console.WriteLine("发送MQTT的数据为：" + str);
            var request1 = new RestRequest("/api/v5/clients", Method.Get);

            //注意方法是POST
            //Console.WriteLine("Topic: " + debug_log_report_mqtt_topic);
            request1.AddQueryParameter("limit", data.Limit);
            request1.AddQueryParameter("page", data.Page);
            request1.AddQueryParameter("isTrusted", true);

            var Q = await client1.ExecuteAsync(request1);


            //返回的数据是
            //{
            //  "data": [
            //    {
            //      "recv_oct": 147525,
            //      "send_msg.dropped.expired": 0,
            //      "recv_msg.qos0": 0,
            //      "inflight_max": 32,
            //      "recv_msg.qos1": 3320,
            //      "send_msg.qos0": 0,
            //      "recv_msg.qos2": 0,
            //      "expiry_interval": 0,
            //      "send_msg.dropped": 0,
            //      "mqueue_len": 0,
            //      "proto_ver": 5,
            //      "keepalive": 60,
            //      "inflight_cnt": 0,
            //      "node": "emqx@127.0.0.1",
            //      "created_at": "2025-06-09T16:08:38.394+08:00",
            //      "send_cnt": 9436,
            //      "ip_address": "43.138.217.154",
            //      "clean_start": true,
            //      "proto_name": "MQTT",
            //      "enable_authn": true,
            //      "mountpoint": null,
            //      "is_persistent": false,
            //      "send_msg.qos1": 6113,
            //      "send_msg.dropped.too_large": 0,
            //      "send_oct": 331649,
            //      "recv_msg": 3320,
            //      "heap_size": 6772,
            //      "username": "admin",
            //      "send_msg.dropped.queue_full": 0,
            //      "send_msg": 6113,
            //      "clientid": "newemqttclient",
            //      "subscriptions_max": "infinity",
            //      "mqueue_max": 1000,
            //      "recv_pkt": 9436,
            //      "user_property": {},
            //      "port": 36036,
            //      "connected_at": "2025-06-09T16:08:38.394+08:00",
            //      "mailbox_len": 0,
            //      "recv_msg.dropped": 0,
            //      "subscriptions_cnt": 1,
            //      "is_bridge": false,
            //      "awaiting_rel_max": 100,
            //      "awaiting_rel_cnt": 0,
            //      "mqueue_dropped": 0,
            //      "send_pkt": 9436,
            //      "send_msg.qos2": 0,
            //      "recv_msg.dropped.await_pubrel_timeout": 0,
            //      "connected": true,
            //      "reductions": 130011309,
            //      "recv_cnt": 9436,
            //      "listener": "tcp:default"
            //    }
            //      ],
            //  "meta": {
            //    "count": 3,
            //    "limit": 20,
            //    "page": 1,
            //    "hasnext": false
            //  }
            //}

            var DDD = System.Text.Json.JsonSerializer.Deserialize<MQTTData>(Q.Content);

            var DDD1 = DDD.data.Select(A => new NiMingOO
            {
                Listener = A["listener"].ToString(),
                UserName = A["username"].ToString(),
                WWWWIP = A["ip_address"].ToString(),
                WWWWPort = A["port"].ToString(),
                ClientId = A["clientid"].ToString(),
                Connected = A["connected"].ToString(),
                connected_DateTime = A["connected_at"].ToString()
            }).ToList();
            return DDD1;
        }


        public static string FrameNoKey = "FrameNoKey";



        [HttpPost()]
        async public Task<RMsg> send_data_to_target([FromBody] Data data)
        {
            RMsg r = new RMsg();
            try
            {

                RestClient client1 = new RestClient(tcp_server);
                var request1 = new RestRequest("/blw/tcphandle", Method.Post);
                request1.AddParameter("cmd", data.Cmd);

                var VData = data.Parameterlist;
                string? HHH1 = VData.data;
                string? HHH2 = HHH1.Replace(" ", "");
                if (IsIllegalHexadecimal(HHH2) == false)
                {
                    request1.AddParameter("parameterlist", JsonSerializer.Serialize(VData));
                    var Q = await client1.ExecuteAsync(request1);
                    r.isok = true;
                    r.message = "success";
                }
                else
                {
                    r.isok = false;
                    r.message = "错误，发送的数据必须是 16进制";
                }
            }
            catch (Exception ex)
            {
                r.message = ex.Message;
                r.isok = false;
            }
            return r;

        }

        /// <summary>
        /// 发送控制数据
        /// 也可以 发送控制指令通过clientid
        /// 接口加好了。发送控制指令接口 地址：
        ///http://iot-manage.uts-data.com:5001/api/sockettcp/send_data_to_targetnew
        ///
        ///发送数据如下：
        ///{
        ///    "Cmd": "tcp_send_data_clientid",
        ///    "Parameterlist": {
        ///        "device_clientid": "71",
        ///        "command_word":"04",
        ///        "data": "AA BB CC DD EE FF AA FF AA"
        ///    }
        ///}
        ///command_word 是命令字，device_clientid是CID。data 是要发送的 控制数据
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        [HttpPost()]
        async public Task<RMsg> send_data_to_targetnew([FromBody] Data data)
        {
            RMsg r = new RMsg();
            try
            {
                var KKK = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
                if (KKK == 0)
                {
                    CSRedisCacheHelper.Forever(FrameNoKey, 0);
                }
                else
                {
                    CSRedisCacheHelper.GenericSerNo(FrameNoKey);
                }

                ushort Xuhao = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
                ushort NewXuHao = 0;
                if (Xuhao == ushort.MaxValue)
                {
                    NewXuHao = 0;
                }
                else
                {
                    NewXuHao = (ushort)(Xuhao + 1);
                }

                CSRedisCacheHelper.Forever<ushort>(FrameNoKey, NewXuHao);

                RestClient client1 = new RestClient(tcp_server);
                var request1 = new RestRequest("/blw/tcphandle", Method.Post);

                //cmd 是 tcp_send_data
                request1.AddParameter("cmd", data.Cmd);

                var VData = data.Parameterlist;


                //组装命令
                List<byte> lll = new List<byte>();
                //包头
                lll.Add(0xAA);

                //整包长度
                lll.Add(0x00);
                lll.Add(0x00);

                //包序号
                byte[] XXX = BitConverter.GetBytes(NewXuHao);
                lll.AddRange(XXX);

                //重发次数
                lll.Add(0x00);

                string SSS = VData.device_clientid;
                int SXSX = int.Parse(SSS);
                //设备序列号
                byte[] SXBy = BitConverter.GetBytes(SXSX);
                lll.AddRange(SXBy);


                // 要加密的数据
                List<byte> 加密数据表 = new List<byte>();

                //命令字
                var UUU = VData.command_word;
                ushort III = ushort.Parse(UUU);
                byte[] CCC = BitConverter.GetBytes(III);

                加密数据表.AddRange(CCC);

                string? HHH1 = VData.data;
                string? HHH2 = HHH1.Replace(" ", "");

                byte[] finally_data = Tools.HEXString2ByteArray(HHH2);
                加密数据表.AddRange(finally_data);

                //将数据头复制一份
                //List<byte> jisuan = new List<byte>(lll);
                //加上数据段部分
                //jisuan.AddRange(加密数据表);
                //jisuan.Add(0x00);
                //jisuan.Add(0x00);
                //var dainfo = jisuan.ToArray();
                //byte[] CRCList = BitConverter.GetBytes(crc);
                //加密数据表.AddRange(CRCList);


                byte[] key = new byte[] { };
                var TST = CSRedisCacheHelper.HMGet<string>(0, CacheKey.DeviceInfo, VData.device_clientid);
                if (TST != null)
                {
                    if (TST[0] != null)
                    {
                        key = Encoding.ASCII.GetBytes(TST[0]);
                    }
                    else
                    {
                        key = Encoding.ASCII.GetBytes("abcdefg123456");
                    }
                }
                byte[] decryptedContent = Tools.IHIOT_Message_Content_Encrypt(NewXuHao, key, 加密数据表.ToArray());

                lll.AddRange(decryptedContent);


                var dainfo = lll.ToArray();

                int changdu = dainfo.Length;

                changdu = changdu + 2 + 6;

                ushort sss1 = (ushort)changdu;
                byte[] bas = BitConverter.GetBytes(sss1);

                dainfo[1] = bas[0];
                dainfo[2] = bas[1];

                //CRC
                ushort crc = Tools.CRC16(dainfo, dainfo.Length);//最后两个字节，加CRC16校验
                //dainfo[dainfo.Length - 2] = Convert.ToByte(crc & 0xff);
                //dainfo[dainfo.Length - 1] = Convert.ToByte((crc >> 8) & 0xff);


                var USB = dainfo.ToList();
                byte[] CRCList = BitConverter.GetBytes(crc);

                USB.AddRange(CRCList);
                USB.AddRange(new byte[] { 0x2D, 0x2D, 0x0D, 0x0A, 0x2D, 0x2D });

                var CMDdata = USB.ToArray();
                VData.data = Tools.ByteToString(CMDdata);

                if (IsIllegalHexadecimal(HHH2) == false)
                {
                    request1.AddParameter("parameterlist", JsonSerializer.Serialize(VData));
                    var Q = await client1.ExecuteAsync(request1);
                    r.isok = true;
                    r.message = "success";
                }
                else
                {
                    r.isok = false;
                    r.message = "错误，发送的数据必须是 16进制";
                }
            }
            catch (Exception ex)
            {
                r.message = ex.Message + ex.StackTrace;
                r.isok = false;
            }
            return r;

        }


        [HttpPost()]
        async public Task<RMsg> send_data_to_lowermachine([FromBody] Data data)
        {
            RMsg r = new RMsg();
            try
            {
                var KKK = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);
                if (KKK == 0)
                {
                    CSRedisCacheHelper.Forever(FrameNoKey, 0);
                }
                else
                {
                    CSRedisCacheHelper.GenericSerNo(FrameNoKey);
                }

                var Xuhao = CSRedisCacheHelper.ForeverGet<ushort>(FrameNoKey);

                RestClient client1 = new RestClient(tcp_server);
                var request1 = new RestRequest("/blw/tcphandle", Method.Post);

                //cmd 是 tcp_send_data
                request1.AddParameter("cmd", data.Cmd);

                var VData = data.Parameterlist;
                //var HHH = JsonSerializer.Deserialize<SendData>(VData);
                List<byte> lll = new List<byte>();
                //包头
                lll.Add(0xAA);

                //整包长度
                lll.Add(0x00);
                lll.Add(0x00);

                //包序号
                byte[] XXX = BitConverter.GetBytes(Xuhao);
                lll.AddRange(XXX);

                //重发次数
                lll.Add(0x00);

                string SSS = VData.device_clientid;
                int SXSX = int.Parse(SSS);
                //设备序列号
                byte[] SXBy = BitConverter.GetBytes(SXSX);
                lll.AddRange(SXBy);


                List<byte> lll_new = new List<byte>(lll.ToArray());
                //命令字
                List<byte> jia_mi_bytes = new List<byte>();
                var UUU = VData.command_word;
                ushort III = ushort.Parse(UUU);
                byte[] CCC = BitConverter.GetBytes(III);
                lll.AddRange(CCC);

                jia_mi_bytes.AddRange(CCC);


                string? HHH1 = VData.data;
                string? HHH2 = HHH1.Replace(" ", "");

                byte[] finally_data = Tools.HEXString2ByteArray(HHH2);

                lll.AddRange(finally_data);
                jia_mi_bytes.AddRange(finally_data);

                lll.Add(0x00);
                lll.Add(0x00);

                var dainfo = lll.ToArray();

                //CRC
                ushort crc = Tools.CRC16(dainfo, dainfo.Length - 2);//最后两个字节，加CRC16校验
                dainfo[dainfo.Length - 2] = Convert.ToByte(crc & 0xff);
                dainfo[dainfo.Length - 1] = Convert.ToByte((crc >> 8) & 0xff);

                var dataF = dainfo.ToList();
                byte[] CRCList = BitConverter.GetBytes(crc);

                jia_mi_bytes.AddRange(CRCList);

                byte[] key = new byte[] { };
                var TST = CSRedisCacheHelper.HMGet<DeviceCacheInfo>(0, CacheKey.DeviceInfo, VData.device_clientid);
                if (TST != null)
                {
                    key = Encoding.ASCII.GetBytes(TST[0].SecretKey);
                }
                byte[] decryptedContent = Tools.IHIOT_Message_Content_Encrypt(Xuhao, key, jia_mi_bytes.ToArray());

                dataF.AddRange(new byte[] { 0x2D, 0x2D, 0x0D, 0x0A, 0x2D, 0x2D });
                var CMDdata = dataF.ToArray();
                int len = CMDdata.Length;
                ushort sss1 = (ushort)len;
                byte[] bas = BitConverter.GetBytes(sss1);

                CMDdata[1] = bas[0];
                CMDdata[2] = bas[1];

                VData.data = Tools.ByteToString(CMDdata);

                if (IsIllegalHexadecimal(HHH2) == false)
                {
                    request1.AddParameter("parameterlist", JsonSerializer.Serialize(VData));
                    var Q = await client1.ExecuteAsync(request1);
                    r.isok = true;
                    r.message = "success";
                }
                else
                {
                    r.isok = false;
                    r.message = "错误，发送的数据必须是 16进制";
                }
            }
            catch (Exception ex)
            {
                _logger.Error("错误:" + ex.Message);
                r.message = ex.Message;
                r.isok = false;
            }
            return r;

        }

        /// <summary>
        /// 判断十六进制字符串hex是否正确
        /// </summary>
        /// <param name="hex">十六进制字符串</param>
        /// <returns>true：不正确，false：正确</returns>
        public bool IsIllegalHexadecimal(string hex)
        {
            foreach (char item in hex)
            {
                if (!HexSet.Contains<char>(item))
                    return true;
            }
            return false;
        }

    }

    public class MQTTData
    {
        public List<Dictionary<string, object>> data { get; set; }
        public Dictionary<string, object> meta { get; set; }
    }
    public class NiMingOO
    {
        public string? Listener { get; set; }
        public string? UserName { get; set; }
        public string? WWWWIP { get; set; }
        public string? WWWWPort { get; set; }
        public string? ClientId { get; set; }
        public string? Connected { get; set; }
        public string? connected_DateTime { get; set; }
    }

    public class QueryData
    {
        public int Limit { get; set; }
        public int Page { get; set; }
    }
    public class RMsg
    {
        public string message { get; set; }
        public bool isok { get; set; }
    }
    public class Data
    {
        public string? Cmd { get; set; }
        public SendData? Parameterlist { get; set; }
    }
    public class SendData
    {
        public string? endpoint { get; set; }

        /// <summary>
        /// 设备序号
        /// </summary>
        public string? device_clientid { get; set; }
        public string? command_word { get; set; }
        public string? data { get; set; }
    }
}