using Application.Domain.Entities;
using Application.Models;
using Infrastructure.Data;
using Infrastructure.Extensions;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;

namespace IoTNode.DeviceServices.SerialPortManager
{
    public class SerialPortService : BaseDeviceService
    {
        private const string _productNumber = "serialport";
        private static readonly object lockObject = new object();

        public SerialPortService(IServiceProvider applicationServices)
            : base(applicationServices)
        {
        }

        public override void Execute()
        {
            this.Notify();
        }

        public void Exec(string deviceNumber, string name)
        {
            using var scope = _applicationServices.CreateScope();
            var repo = scope.ServiceProvider.GetService<IRepository<Device>>();
            var device = repo.ReadOnlyTable().Include(o => o.Data).FirstOrDefault(o => o.Number == deviceNumber);
            var buttons = device.Data.FirstOrDefault(o => o.Key == "Buttons")?.Value.FromJson<List<SPCommandModel>>(); ;
            var button = buttons.FirstOrDefault(o => o.Name == name);
            ExecInternal(button.PortName, button.BaudRate, button.DataBits, button.Parity, button.StopBits, button.Message);
        }

#pragma warning disable CA1822 // Mark members as static

        public void Test(string port, int baud, int dataBits, int partity, int stopBits, string message)
#pragma warning restore CA1822 // Mark members as static
        {
            ExecInternal(port, baud, dataBits, partity, stopBits, message);
        }

        internal void UpdateButtons(string number, string buttons)
        {
            using var scope = _applicationServices.CreateScope();
            var deviceRepo = scope.ServiceProvider.GetService<IRepository<Device>>();
            var device = deviceRepo.Table().Include(o => o.Data).FirstOrDefault(o => o.Number == number);
            if (device != null)
            {
                var data = device.Data.FirstOrDefault(o => o.Key == "Buttons");
                if (data != null)
                {
                    data.Value = buttons.FromJson<List<SPCommandModel>>().ToJson(true);
                    deviceRepo.SaveChanges();
                }
            }
        }

        public static void ExecInternal(string port, int baud, int dataBits, int partity, int stopBits, string message)
        {
            try
            {
                lock (lockObject)
                {
                    using var sp = new SerialPort(port, baud, (Parity)partity, dataBits, (StopBits)stopBits);
                    sp.Open();
                    var bytes = message.HexToBytes();
                    sp.Write(bytes, 0, bytes.Length);
                    sp.Close();
                }
            }
            catch (Exception ex)
            {
                ex.PrintStack();
            }
        }

        public void Notify()
        {
            this.UpdateProduct("串口控制器", _productNumber, "/SerialPort/", "20", "serialport");
            using var scope = _applicationServices.CreateScope();
            var repo = scope.ServiceProvider.GetService<IRepository<Device>>();
            var deviceNumber = $"serialporton{Helper.Instance.GetMacAddress()}";
            var device = repo.ReadOnlyTable().Include(o => o.Data).FirstOrDefault(o => o.Number == deviceNumber);
            if (device == null)
            {
                var productRepo = scope.ServiceProvider.GetService<IRepository<Product>>();
                var nodeRepo = scope.ServiceProvider.GetService<IRepository<Node>>();
                var node = nodeRepo.ReadOnlyTable().FirstOrDefault();
                var product = productRepo.ReadOnlyTable().FirstOrDefault(o => o.Number == _productNumber);
                var name = "串口控制器";
                device = new Device
                {
                    Id = deviceNumber.ToGuid(),
                    Number = deviceNumber,
                    Name = name,
                    DisplayName = name,
                    ProductId = product.Id,
                    NodeId = node.Id,
                    IsOnline = true,
                    Icon = "serialport"
                };
                repo.Add(device);
                repo.SaveChanges();
                var buttons = new List<SPCommandModel>() { new SPCommandModel { Name = "测试", PortName = "/dev/ttyS0", BaudRate = 9600, Parity = 0, DataBits = 8, StopBits = 1, Message = "0123456789ABCDEF" } }.ToJson(true);
                this.UpdateData(repo, device, device.CreateData("Buttons", buttons, DeviceDataType.String, "指令", timestamp: DateTimeOffset.Now.ToUnixTimeMilliseconds()));
            }
        }
    }
}