using System.Text;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using MySQLAccess.PGModels;
using Newtonsoft.Json;
using NLog;
using ViewModels;

namespace IotManager.Controllers
{
    [Route("api/[controller]/[action]")]
    [ApiController]
    public class MQTTReceiveAPIController : ControllerBase
    {
        private readonly Logger _logger = LogManager.GetCurrentClassLogger();
        private readonly IConfiguration? config;
        private PostgresContext IotServerContext { get; set; }

        public MQTTReceiveAPIController(IConfiguration config, PostgresContext context)
        {
            this.config = config;
            this.IotServerContext = context;
        }
        [HttpPost()]
        public void ReceiveData()
        {
            try
            {
                var readResult = Request.BodyReader.ReadAsync().Result;
                Request.BodyReader.AdvanceTo(readResult.Buffer.Start, readResult.Buffer.End);
                string body = Encoding.UTF8.GetString(readResult.Buffer.FirstSpan);

                if (!string.IsNullOrEmpty(body))
                {
                    Task.Factory.StartNew((state) =>
                    {
                        string BodyString = state.ToString();
                        _logger.Error(body);
                        var QQQ = System.Text.Json.JsonSerializer.Deserialize<RawPayload>(body);
                        string topic = QQQ.topic;
                        string payload = QQQ.payload;

                        //传递过来的数据就是base64的，没有必要再转
                        byte[] bbb = Convert.FromBase64String(payload);
                        string bbb1 = Tools.ByteToString(bbb);

                        this._logger.Info("Topic: " + topic);
                        this._logger.Info("PayLoad: " + bbb1);


                        byte[] NNN1 = Tools.HEXString2ByteArray(bbb1.Replace(" ", ""));
                        //AA 13 00 44 0B 00 FF FF FF FF 61 67 EF 6B E8 2D 2D 0D 0A 2D 2D

                        byte Header = NNN1[0];
                        //从1到3之间的元素，不包括3
                        byte[] Len = NNN1[1..3];
                        //byte[] Len = NNN1.AsSpan(1,2);
                        byte[] Pack_SN = NNN1[3..5];

                        //重发次数
                        byte RetryCount = NNN1[5];

                        //设备编号
                        byte[] DeviceOnlyNo = NNN1[6..10];

                        //命令字
                        byte[] Command = NNN1[10..12];


                        //校验CRC16，小端模式(低地址在前)
                        //校验内容：Pack_Head + Pack_LEN + Pack_SN + Retry_Num + Client_ID + CMD + PARA
                        byte[] CRCCode = NNN1[^8..^6];

                        //结尾标志符
                        //// 获取从倒数第三个元素到数组末尾的所有元素
                        byte[] Tail = NNN1[^6..];

                    }, body);
                }
            }
            catch (Exception)
            {

            }
        }
    }
    public class RawPayload
    {
        public string topic { get; set; }
        public string payload { get; set; }
    }
}