using Lskj.Business.Impl;
using Lskj.Control;
using Lskj.Control.Model;
using Lskj.Core;
using ReaderApi;
using ReaderApi.Data;
using System;
using System.Collections.Generic;
using System.Data;
using System.Drawing;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading;
using System.Windows.Forms;
using static ReaderApi.DeviceManagement;

namespace RFIDManagement
{
    public partial class FrmMain : BaseForm
    {
        public FrmMain()
        {
            InitializeComponent();
            this.Load += OnFormLoad;
            this.FormClosing += OnFrmMainFormClosing;
        }
        /// <summary>
        /// 连接驱动
        /// </summary>
        public DeviceManagement Device;
        /// <summary>
        /// 连接数
        /// </summary>
        public List<Reader> Readers;
        /// <summary>
        /// 消息
        /// </summary>
        public List<Tag> Tags;
        /// <summary>
        /// 标记
        /// </summary>
        public bool StartFlag;
        /// <summary>
        /// 更新数据Timer
        /// </summary>
        public System.Windows.Forms.Timer UpdateTagTimer;
        /// <summary>
        /// 展示视频Timer
        /// </summary>
        public System.Windows.Forms.Timer ShowTimer;
        /// <summary>
        /// 界面上下文
        /// </summary>
        public SynchronizationContext SyncContext;
        /// <summary>
        /// 当前连接
        /// </summary>
        public Reader SelectReader;
        /// <summary>
        /// 数据源
        /// </summary>
        public DataTable SourceTable;
        /// <summary>
        /// 写入数据窗口
        /// </summary>
        FrmDataWrite DataWriteForm;
        /// <summary>
        /// 初始化界面
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnFormLoad(object sender, EventArgs e)
        {
            this.startLinkBtn.Enabled = true;
            this.stopLinkBtn.Enabled = true;
            this.startReadBtn.Enabled = false;
            this.stopReadBtn.Enabled = false;
            this.writeBtn.Enabled = false;
            if (!DBConfig.Instance.CreateConnection())
            {
                MessageUtil.Show("网络连接失败");
                Close();
            }
            StringBuilder sqlBuilder = new StringBuilder();
            sqlBuilder.AppendLine($"if not exists(select top 1 * from sysObjects where Id = object_id(N'P_RfidInfoTab') and xtype = 'U')");
            sqlBuilder.AppendLine($"begin");
            sqlBuilder.AppendLine($"create table P_RfidInfoTab(id int IDENTITY(1, 1) NOT NULL,epc varchar(100) NULL,url varchar(200) NULL,fileType int NULL,nextTime int NULL,orderId int NULL,nowCount int NULL,allCount int NULL)");
            sqlBuilder.AppendLine($"end");
            sqlBuilder.AppendLine($"else begin");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'epc')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add epc varchar(100) end");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'url')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add url varchar(200) end");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'fileType')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add fileType int end");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'nextTime')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add nextTime int end");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'orderId')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add orderId int end");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'nowCount')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add nowCount int end");
            sqlBuilder.AppendLine($"if not exists(select top 1 * from syscolumns where id = object_id(N'P_RfidInfoTab') and name = 'allCount')");
            sqlBuilder.AppendLine($"begin alter table P_RfidInfoTab add allCount int end");
            sqlBuilder.AppendLine($"end");
            SqlHelper.ExecuteNonQuery(sqlBuilder.ToString());
            SqlHelper.ExecuteNonQuery("update P_RfidInfoTab set nowCount = '0'");
            UpdateTagTimer = new System.Windows.Forms.Timer();
            UpdateTagTimer.Interval = 200;
            UpdateTagTimer.Tick += OnUpdateTagTimerTick;
            UpdateTagTimer.Enabled = true;
            ShowTimer = new System.Windows.Forms.Timer();
            ShowTimer.Interval = 100;
            ShowTimer.Tick += OnShowTimerTick;
            ShowTimer.Enabled = true;
            SyncContext = SynchronizationContext.Current;
            Device = new DeviceManagement();
            Tags = new List<Tag>();
            Readers = new List<Reader>();
            Device.OnDeviceState += new DeviceEventHandle(OnDeviceEventHandle);
            Device.OnRecvMessage += new MessageReceivedEventHandle(OnRecvMessageEventHandle);
            this.startLinkBtn.Click += OnStartLinkBtnClick;
            this.stopLinkBtn.Click += OnStopLinkBtnClick;
            this.startReadBtn.Click += OnStartReadBtnClick;
            this.stopReadBtn.Click += OnStopReadBtnClick;
            this.writeBtn.Click += OnWriteBtnClick;
            this.refushBtn.Click += OnRefushBtnClick; ;
            this.com_LinkType.SelectedIndexChanged += OnComLinkTypeSelectedIndexChanged;
            string linkType = IniHelper.Read("LinkType");
            int selectIndex = com_LinkType.Properties.Items.IndexOf(linkType);
            com_LinkType.SelectedIndex = selectIndex;
            InitSourceTable();
        }
        /// <summary>
        /// 开始连接按钮点击时
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnStartLinkBtnClick(object sender, EventArgs e)
        {
            string connectMode = com_LinkType.Text;
            string connectStr = com_LinkPms.Text;
            try
            {
                ConnectDevice(connectMode, connectStr, 1);
            }
            catch (Exception ex)
            {
                MessageUtil.Show(ex.Message);
            }
        }
        /// <summary>
        /// 断开连接
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnStopLinkBtnClick(object sender, EventArgs e)
        {
            ConnectClose();
            lb_LinkTips.Text = "未连接";
            lb_LinkTips.ForeColor = Color.Gray;
            startLinkBtn.Enabled = true;
            stopLinkBtn.Enabled = true;
            startReadBtn.Enabled = false;
            stopReadBtn.Enabled = false;
            writeBtn.Enabled = false;
        }
        /// <summary>
        /// 开始读取
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnStartReadBtnClick(object sender, EventArgs e)
        {
            if (lb_LinkTips.Text.Equals("已连接"))
            {
                Tags.Clear();
                var result = SelectReader?.Send(new InventoryPara(InventoryMode.EPC));
                if (result != null)
                {
                    GlobalPara.tagDisplayArea = TagDisplayArea.main;
                }
                startLinkBtn.Enabled = false;
                stopLinkBtn.Enabled = true;
                startReadBtn.Enabled = false;
                stopReadBtn.Enabled = true;
                writeBtn.Enabled = false;
            }
            else
            {
                MessageUtil.Show("未连接");
            }
        }
        /// <summary>
        /// 停止读取
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnStopReadBtnClick(object sender, EventArgs e)
        {
            SelectReader?.Send(new InventoryStopPara());
            startLinkBtn.Enabled = false;
            stopLinkBtn.Enabled = true;
            startReadBtn.Enabled = true;
            stopReadBtn.Enabled = false;
            writeBtn.Enabled = true;
        }
        /// <summary>
        /// 标签写入按钮点击
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnWriteBtnClick(object sender, EventArgs e)
        {
            if (!StartFlag)
            {
                try
                {
                    DataWriteForm = new FrmDataWrite();
                    DataWriteForm.SelectReader = SelectReader;
                    DataWriteForm.ShowDialog();
                    DataWriteForm.Dispose();
                }
                catch (Exception ex)
                {
                    MessageUtil.Show(ex.Message);
                }
            }
            else
            {
                MessageUtil.Show("请先停止读取数据");
            }
        }
        /// <summary>
        /// 重置按钮点击
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnRefushBtnClick(object sender, EventArgs e)
        {
            SqlHelper.ExecuteNonQuery("update P_RfidInfoTab set nowCount = '0'");
        }
        /// <summary>
        /// 切换连接模式
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnComLinkTypeSelectedIndexChanged(object sender, EventArgs e)
        {
            if (com_LinkType.Text.Equals("RS232"))
            {
                InitRS232();
            }
            else if (com_LinkType.Text.Equals("UDP"))
            {
                InitUDP();
            }
        }
        /// <summary>
        /// RFID设备状态改变事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnDeviceEventHandle(object sender, DeviceEventArgs e)
        {
            if (e.cmd == ReaderApi.DeviceState.Connected)
            {
                foreach (Reader re in Readers)
                {
                    var result = re?.Send(new InventoryStopPara());
                }
                AddReader(e.reader);
                SyncContext.Post(AddReaderUI, e.reader);
            }
            else if (e.cmd == ReaderApi.DeviceState.Disconnected)
            {
                RemoveReader(e.reader);
                SyncContext.Post(RemoveReaderUI, e.reader);
            }
            else if (e.cmd == ReaderApi.DeviceState.ConnectError)
            {
                SelectReader = null;
                MessageUtil.Show($"连接错误!\r\n{e.reader.connectStr}");
            }
        }
        /// <summary>
        /// 接收RFID数据事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnRecvMessageEventHandle(object sender, MessageReceivedEventArgs e)
        {
            if (e.data != null)
            {
                if (e.cmd == CmdType.cmd_tag || e.cmd == CmdType.cmd_write_tag || e.cmd == CmdType.cmd_lock_tag || e.cmd == CmdType.cmd_kill_tag)    //标签数据
                {
                    if (GlobalPara.tagDisplayArea == TagDisplayArea.main)
                    {
                        GlobalMethod.AddTag(e.data as Tag, Tags);
                    }
                    else if (GlobalPara.tagDisplayArea == TagDisplayArea.writeTag || GlobalPara.tagDisplayArea == TagDisplayArea.writeTagRead || GlobalPara.tagDisplayArea == TagDisplayArea.writeTagReadListBox2)
                    {
                        SyncContext.Post(DataWriteFormAddTag, e.data);
                    }
                }
                else
                {
                    if (e.cmd == CmdType.cmd_tag_epc || e.cmd == CmdType.cmd_tag_tid || e.cmd == CmdType.cmd_tag_epc_tid || e.cmd == CmdType.cmd_tag_epc_user)   //开始读取标签成功
                    {
                        StartFlag = (e.data as Result).isSuccess;
                    }
                    else if (e.cmd == CmdType.cmd_inventory_stop)//停止读标签成功
                    {
                        if ((e.data as Result).isSuccess)
                        {
                            StartFlag = false;
                        }
                    }
                    if (e.cmd == CmdType.cmd_485_address)//485地址设置
                    {
                        if ((e.data as Result).isSuccess)
                        {
                            MessageUtil.Show("485地址已经改变");
                        }
                    }
                }
            }
        }
        /// <summary>
        /// 创建数据源
        /// </summary>
        private void InitSourceTable()
        {
            SourceTable = new DataTable();
            SourceTable.Columns.Add("EpcColumn");
            SourceTable.Columns.Add("PCColumn");
            SourceTable.Columns.Add("AntColumn");
            SourceTable.Columns.Add("RSSIColumn");
            SourceTable.Columns.Add("CountColumn");
            SourceTable.Columns.Add("FrequencyColumn");
            this.gcMain.DataSource = SourceTable;
        }
        /// <summary>
        /// 加载串口
        /// </summary>
        private void InitRS232()
        {
            string comPort = IniHelper.Read("RS232");
            com_LinkPms.Properties.Items.Clear();
            string[] ports = SerialPort.GetPortNames();
            foreach (string port in ports)
            {
                com_LinkPms.Properties.Items.Add(port);
            }
            int selectIndex = com_LinkPms.Properties.Items.IndexOf(comPort);
            if (selectIndex > 0)
            {
                com_LinkPms.SelectedIndex = selectIndex;
            }
        }
        /// <summary>
        /// 加载UDP
        /// </summary>
        private void InitUDP()
        {
            string udpServer = IniHelper.Read("UDP");
            com_LinkPms.Properties.Items.Clear();
            if (!string.IsNullOrEmpty(udpServer))
            {
                com_LinkPms.Text = udpServer;
            }
            else
            {
                com_LinkPms.Text = "192.168.0.188:4001";
            }
        }
        /// <summary>
        /// 保存连接信息
        /// </summary>
        private void SaveLink()
        {
            IniHelper.Write("LinkType", com_LinkType.Text);
            if (com_LinkType.Text.Equals("RS232"))
            {
                IniHelper.Write("RS232", com_LinkPms.Text);
            }
            else if (com_LinkType.Text.Equals("UDP"))
            {
                IniHelper.Write("UDP", com_LinkPms.Text);
            }
        }
        /// <summary>
        /// 创建连接
        /// </summary>
        /// <param name="connectMode"></param>
        /// <param name="connectStr"></param>
        /// <param name="rs485add"></param>
        private void ConnectDevice(string connectMode, string connectStr, int rs485add)
        {
            Device.Open(connectMode, connectStr, rs485add);
        }
        /// <summary>
        /// 添加Readers
        /// </summary>
        /// <param name="state"></param>
        private void AddReaderUI(object state)
        {
            if (Readers.Count == 1)
            {
                WaitForm.ShowForm("连接中...");
                SelectReader = Readers.First();
                InventoryStopPara stopPara = new InventoryStopPara();
                var resultStop = SelectReader?.SendSyn(stopPara);
                SyncContext.Post(UpdateConnectState, resultStop);
                if (resultStop.isSuccess)
                {
                    GetVersionPara para = new GetVersionPara();
                    var result = SelectReader?.SendSyn(para);
                    SyncContext.Post(UpdateVersion, result);
                }
                WaitForm.HideForm();
            }
        }
        /// <summary>
        /// 添加Reader
        /// </summary>
        /// <param name="reader"></param>
        public void AddReader(Reader reader)
        {
            lock (Readers)
            {
                var newReaderFlag = false;
                foreach (var re in Readers)
                {
                    if (re.connectStr == reader.connectStr)
                    {
                        newReaderFlag = true;
                    }
                }
                if (!newReaderFlag)
                {
                    Readers.Add(reader);
                }
            }
        }
        /// <summary>
        /// 移除Readers
        /// </summary>
        /// <param name="state"></param>
        private void RemoveReaderUI(object state)
        {
            if (Readers.Count == 1)
            {
                SelectReader = Readers.First();
            }
        }
        /// <summary>
        /// 移除Readers
        /// </summary>
        /// <param name="reader"></param>
        private void RemoveReader(Reader reader)
        {
            lock (Readers)
            {
                foreach (var re in Readers)
                {
                    if (re.connectStr == reader.connectStr)
                    {
                        Readers.Remove(reader);
                        break;
                    }
                }
            }
        }
        /// <summary>
        /// 更新连接信息
        /// </summary>
        /// <param name="state"></param>
        private void UpdateConnectState(object state)
        {
            var result = state as Result;
            if (!result.isSuccess)
            {
                MessageUtil.Show(result.errorMsg);
                lb_LinkTips.Text = "连接失败";
                lb_LinkTips.ForeColor = Color.Red;
                ConnectClose();
            }
        }
        private void UpdateVersion(object state)
        {
            var result = state as Result;
            if (result.isSuccess)
            {
                lb_LinkTips.Text = "已连接";
                lb_LinkTips.ForeColor = Color.Green;
                startLinkBtn.Enabled = false;
                stopLinkBtn.Enabled = true;
                startReadBtn.Enabled = true;
                stopReadBtn.Enabled = false;
                writeBtn.Enabled = true;
                SaveLink();
            }
            else
            {
                lb_LinkTips.Text = "连接失败";
                lb_LinkTips.ForeColor = Color.Red;
                ConnectClose();
                startLinkBtn.Enabled = true;
                stopLinkBtn.Enabled = true;
                startReadBtn.Enabled = false;
                stopReadBtn.Enabled = false;
                writeBtn.Enabled = false;
            }
        }
        /// <summary>
        /// 关闭连接
        /// </summary>
        private void ConnectClose()
        {
            Device?.Close();
            Readers?.Clear();
            Tags?.Clear();
            gridView?.BeginUpdate();
            SourceTable?.Rows.Clear();
            gridView?.EndUpdate();
            SelectReader = null;
        }
        /// <summary>
        /// 更新数据事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnUpdateTagTimerTick(object sender, EventArgs e)
        {
            gridView.BeginUpdate();
            lock (Tags)
            {
                foreach (Tag tag in Tags)
                {
                    DataRow row = SourceTable.AsEnumerable().Where(n => (n["EpcColumn"] + "").Equals(tag.epc)).FirstOrDefault();
                    if (row != null)
                    {
                        row["PCColumn"] = tag.pc.ToString();
                        row["AntColumn"] = tag.ant.ToString();
                        row["RSSIColumn"] = tag.rssi.ToString();
                        row["CountColumn"] = tag.count.ToString();
                        if (tag.frequency >= 0xC9)
                        {
                            row["FrequencyColumn"] = tag.frequency.ToString("X2");
                        }
                        else
                        {
                            if (Frequency.frequency.ContainsKey(tag.frequency))
                            {
                                row["FrequencyColumn"] = Frequency.frequency[tag.frequency];
                            }
                            else
                            {
                                row["FrequencyColumn"] = tag.frequency.ToString("X2");
                            }
                        }
                    }
                    else
                    {
                        DataRow newRow = SourceTable.NewRow();
                        newRow["EpcColumn"] = tag.epc.ToString();
                        newRow["PCColumn"] = tag.pc.ToString();
                        newRow["AntColumn"] = tag.ant.ToString();
                        newRow["RSSIColumn"] = tag.rssi.ToString();
                        newRow["CountColumn"] = tag.count.ToString();
                        newRow["FrequencyColumn"] = tag.frequency.ToString();
                        SourceTable.Rows.Add(newRow);
                    }
                }
                List<DataRow> deleteRows = new List<DataRow>();
                foreach (DataRow row in SourceTable.Rows)
                {
                    Tag tag = Tags.Where(n => n.epc.Equals(row["EpcColumn"] + "")).FirstOrDefault();
                    if (tag == null)
                    {
                        deleteRows.Add(row);
                    }
                }
                foreach (DataRow deleteRow in deleteRows)
                {
                    SourceTable.Rows.Remove(deleteRow);
                }
            }
            gridView.EndUpdate();
            Tags.Clear();
        }
        /// <summary>
        /// 更新数据事件
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnShowTimerTick(object sender, EventArgs e)
        {
            ShowTimer.Enabled = false;
            try
            {
                List<DataRow> dataRowsList = SourceTable.AsEnumerable().OrderByDescending(n => Convert.ToDecimal(n["RSSIColumn"])).ToList();
                if (dataRowsList != null)
                {
                    foreach (DataRow dataRow in dataRowsList)
                    {
                        string epcValue = dataRow["EpcColumn"] + "";
                        DataTable selectTable = BaseImpl.GetDataTableResult($"select * from P_RfidInfoTab where epc = '{epcValue}' order by orderId");
                        foreach (DataRow selectRow in selectTable.Rows)
                        {
                            try
                            {
                                int.TryParse(selectRow["id"] + "", out int id);
                                int.TryParse(selectRow["nextTime"] + "", out int nextTime);
                                string url = selectRow["url"] + "";
                                int.TryParse(selectRow["fileType"] + "", out int fileType);
                                int.TryParse(selectRow["nowCount"] + "", out int nowCount);
                                int.TryParse(selectRow["allCount"] + "", out int allCount);
                                int intervalTime = nextTime != 0 ? nextTime * 1000 : 1000;
                                if (nowCount < allCount)
                                {
                                    using (FrmVlcPlayer frmVlcPlayer = new FrmVlcPlayer())
                                    {
                                        frmVlcPlayer.PlayVideo(url);
                                        if (fileType.Equals(0))
                                        {
                                            frmVlcPlayer.Opacity = 1;
                                            frmVlcPlayer.WindowState = FormWindowState.Maximized;
                                        }
                                        else
                                        {
                                            frmVlcPlayer.Opacity = 0;
                                            frmVlcPlayer.WindowState = FormWindowState.Minimized;
                                        }
                                        frmVlcPlayer.TopMost = true;
                                        frmVlcPlayer.ShowDialog();
                                    }
                                    SqlHelper.ExecuteNonQuery($"update P_RfidInfoTab set nowCount = '{nowCount + 1}' where id = '{id}'");
                                    Thread.Sleep(intervalTime);
                                }
                            }
                            catch (Exception)
                            {
                            }
                        }
                        break;
                    }
                }
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            ShowTimer.Enabled = true;
        }
        /// <summary>
        /// 写入数据
        /// </summary>
        private void DataWriteFormAddTag(object state)
        {
            DataWriteForm?.AddTag(state as Tag);
        }
        /// <summary>
        /// 窗体关闭时
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private void OnFrmMainFormClosing(object sender, System.Windows.Forms.FormClosingEventArgs e)
        {
            if (stopReadBtn.Enabled)
            {
                OnStopReadBtnClick(null, null);
            }
            if (stopLinkBtn.Enabled)
            {
                OnStopLinkBtnClick(null, null);
            }
        }
    }
}