using System;
using System.Collections.Generic;
using System.IO.Ports;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Channels;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Xml.Serialization;
using System.Windows.Threading;
using System.Diagnostics;
using System.Collections.ObjectModel;
using SafeBagDE70.Model;
using HandyControl.Tools;
using System.Drawing.Printing;
using System.Drawing;
using static HandyControl.Tools.Interop.InteropValues;
using SafeBagDE70.API;
using Newtonsoft.Json;
using System.IO;
using System.Reflection;
using DE70_CMDv2;
using System.Configuration;


namespace SafeBagDE70
{   //Summary
   

    public partial class MainUserWindow : HandyControl.Controls.Window
    {
        SerialPort serialPortDE70 = new SerialPort();
        SerialPort serialPortSensor= new SerialPort();

        List<CountSession> sessions = new List<CountSession>();
        ObservableCollection<LvCountItem> lvCountItems = new ObservableCollection<LvCountItem>();
        private DispatcherTimer timer;
        private DispatcherTimer sensorTimer;
        int countTimer = 0;
        CCmdRsp cCmdRsp = null;
        bool bInitialized = false;

        public MainUserWindow()
        {
            //Need to update: auto detect COM Port
            try
            {
                InitializeComponent();
                //string queuePath = ConfigurationManager.AppSettings["SensorPort"].ToString();
                AppData.Init();
                //this.gridMain.IsEnabled = false;
               

                InitApp();


            }
            catch (Exception ex)
            {
                ShowError("LỖI CỔNG KẾT NỐI, VUI LÒNG KIỂM TRA LẠI CỔNG KẾT NỐI");
                //MessageBox.Show("Cổng đang mở, kiểm tra lại cổng kết nối");
                //this.Close();
            }
        }
        public void InitApp()
        {
            LoginUsingQRCode();
            panelError.Visibility = Visibility.Collapsed;

            serialPortDE70.ReadBufferSize = 4096;
            serialPortDE70.WriteBufferSize = 4096;
            cCmdRsp = new CCmdRsp(serialPortDE70);

            serialPortDE70.PortName = AppData.CDMPort;
            serialPortDE70.BaudRate = 9600;
            serialPortDE70.Parity = Parity.Even;
            serialPortDE70.DataBits = 8;
            serialPortDE70.StopBits = StopBits.One;

            serialPortSensor.PortName = AppData.SensorPort;
            serialPortSensor.BaudRate = 9600;
            serialPortSensor.Parity = Parity.None;
            serialPortSensor.DataBits = 8;
            serialPortSensor.StopBits = StopBits.One;

            //Subscrible to the DataReveied event

            serialPortDE70.Open();
            serialPortSensor.Open();

            bInitialized = InitSession();

            timer = new DispatcherTimer();
            timer.Interval = new TimeSpan(0, 0, 10);  //10 seconds
            timer.Tick += Timer_Tick;
            timer.Start();

            sensorTimer = new DispatcherTimer();
            sensorTimer.Interval = new TimeSpan(0, 0, 1);  //10 seconds
            sensorTimer.Tick += SensorTimer_Tick;
            sensorTimer.Start();
        }

        public void ShutdownApp()
        {
            try
            {
                if (serialPortDE70.IsOpen)
                    serialPortDE70.Close();
                if (serialPortSensor.IsOpen)
                    serialPortSensor.Close();

                if (timer != null)
                {
                    timer.Tick -= Timer_Tick;
                    timer.Stop();
                }
                if (sensorTimer != null)
                {
                    sensorTimer.Tick -= SensorTimer_Tick;
                    sensorTimer.Stop();
                }
            }
            catch (Exception ex)
            {
            }
        }
        public void SetStep(int step)
        {
            switch(step)
            {
                case 0:
                    btnStart.IsEnabled = true;
                    btnCheck.IsEnabled = false;
                    btnCountStart.IsEnabled = false;
                    btnStoreStart.IsEnabled = false;
                    btnEnd.IsEnabled = false;
                    break;
                case 1:
                    btnStart.IsEnabled = false;
                    btnCheck.IsEnabled = false;
                    btnCountStart.IsEnabled = true;
                    btnStoreStart.IsEnabled = false;
                    btnEnd.IsEnabled =false;
                    break;
                case 2:
                    btnStart.IsEnabled = false;
                    btnCheck.IsEnabled = true;
                    btnCountStart.IsEnabled = true;
                    btnStoreStart.IsEnabled = true;
                    btnEnd.IsEnabled = false;
                    break;
                case 3:
                    btnStart.IsEnabled = false;
                    btnCheck.IsEnabled = true;
                    btnCountStart.IsEnabled = true;
                    btnStoreStart.IsEnabled = true;
                    btnEnd.IsEnabled = true;
                    break;
            }    
        }

        public void InitSessionCount()
        {
            lvCountItems.Clear();
            lvCountItems.Add(new LvCountItem
            {
                Name = "500",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "1000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "2000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "5000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "10000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "20000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "50000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "100000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "200000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "500000",
                Quantity = "0"
            });
            lvCountItems.Add(new LvCountItem
            {
                Name = "Tổng",
                Quantity = "0"
            });
            lvCountItems[10].Quantity = "0";
            lvCountItems[10].Value = "0";

            lvCount.ItemsSource = lvCountItems;

            //lvCountItems[0].Quantity = "10";
        }
        public long maxQuantitySheet = 10000;
        public int quantityStored = 0;
        public int totalAllDenominations = 0;
        public int posDenomi;
        public bool printerFlag = false;
        public static string? recvDataString;
        public int[] TempQuantity = new int[10] { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
        public int[] TempNote = new int[5] { 0, 0, 0, 0, 0 };
        public int[] Notes = new int[5] { 0, 0, 0, 0, 0 };

        private void SensorTimer_Tick(object? sender, EventArgs e)
        {
            timer.IsEnabled = false;
            int state = 0;
            if (serialPortSensor.IsOpen==true)
            {
                serialPortSensor.Write(new byte[] { (byte)'S', 13, 10 }, 0, 3);
                var buffer = new byte[16];
              
                int n = serialPortSensor.Read(buffer, 0, buffer.Length);
                
                for (int i = 1; i < n - 1; i++)
                {
                    if ((buffer[i] == 13) && (buffer[i + 1] == 10))
                    {
                        state = buffer[i - 1]-48;
                        if(bInitialized)
                        {
                            if (state != 0)
                                gridMain.IsEnabled = false;
                            else
                                gridMain.IsEnabled = true;
                        }
                        switch (state)
                        {
                            case 0:
                                lblStatus.Content = "Két: đóng, Túi: đóng";
                                break;
                            case 1:
                                lblStatus.Content = "Két: đóng, Túi: đã bị lấy ra";
                                break;
                            case 2:
                                lblStatus.Content = "Két: mở, Túi: đóng";
                                break;
                            case 3:
                                lblStatus.Content = "Két: mở, Túi: đã bị lấy ra";
                                break;
                        }
                        break;
                    }
                }
              
            }
          
            timer.IsEnabled = true;
        }
        private void Timer_Tick(object? sender, EventArgs e)
        {
            timer.IsEnabled = false;

            APIModels.SendHealthCheck();

            timer.IsEnabled = true;
        }
        public int UpdateTotalQuantity()
        {
            int total = 0;
            foreach (var item in lvCountItems)
            {
                if (item.Name != "Tổng")
                {
                    int quantity = 0;
                    if (int.TryParse(item.Quantity, out quantity))
                    {
                        total += quantity;
                    }
                }
            }
            return total;
        }

        public int AutoSerialGet(SerialPort serialPort)
        {
            int ret;
            ushort seri_num = 0;
            ushort get_num = 0;
            bool endflg = false;

            while (true)
            {
                ret = cCmdRsp.SendSerialSense();
                if (ret == Constants.E_OK)
                {
                    ret = cCmdRsp.GetSerialNum(out seri_num);
                    if (ret == Constants.E_OK)
                    {
                        // Serial number acquisition

                        if (cCmdRsp.ChkCntEnd())
                        {
                            endflg = true;
                            Debug.WriteLine("END FLAG: "+cCmdRsp.recv_dat.dat[1]);
                        }
                        Debug.WriteLine("START");
                        Debug.WriteLine($"Num Serial: {seri_num}");
                   
                        while (get_num < seri_num)
                        {
                            get_num++;
                            ret = cCmdRsp.SendGetSerial(get_num);


                            switch (cCmdRsp.recv_dat.dat[18])
                            {
                                case 0x00: TempNote[0] ++; Notes[0] += TempNote[0]; break;
                                case 0x02:
                                    //TempNote[1] ++;
                                    switch (cCmdRsp.recv_dat.dat[17])
                                    {
                                        case 0x00: TempQuantity[0]++; break;
                                        case 0x01: TempQuantity[1]++; break;
                                        case 0x02: TempQuantity[2]++; break;
                                        case 0x03: TempQuantity[3]++; break;
                                        case 0x04: TempQuantity[4]++; break;
                                        case 0x05: TempQuantity[5]++; break;
                                        case 0x06: TempQuantity[6]++; break;
                                        case 0x07: TempQuantity[7]++; break;
                                        case 0x08: TempQuantity[8]++; break;
                                        case 0x09: TempQuantity[9]++; break;

                                    }
                                    break;
                                case 0x03: TempNote[2] ++; Notes[2] += TempNote[2]; break;
                                case 0x0b: TempNote[3] ++; Notes[3] += TempNote[3]; break;
                                case 0x0c: TempNote[4] ++; Notes[4] += TempNote[4]; break;
                            }
                        }

                        Debug.WriteLine("END");
                        //Debug.WriteLine("Ellapsed Time: " + timeSpan.TotalSeconds);
                        if (endflg)
                        {
                          
                            break;
                        }
                    }
                    else
                    {
                        Debug.WriteLine("END GET SERIAL: "+ret);
                        break;
                    }
                }
                else
                {
                    Debug.WriteLine("END SEND SERIAL: "+ret);
                    break;
                }
            }
            return 0;
        }

        public void btnCountStart_Click(object sender, RoutedEventArgs e)
        {
            printerFlag = false;

            string currentMethod = MethodBase.GetCurrentMethod().Name;
            try
            {

                serialPortDE70.DiscardInBuffer();
                serialPortDE70.DiscardOutBuffer();
                LogAction(currentMethod, null);

                cCmdRsp.SendXXCmd((byte)Command.CMD_DE_CNTSTART);
                //var recvData = DE70_CMD.SendxxCmd((byte)CMD_BYTE.CMD_DE_CNTSTART, serialPort);

                //Thread.Sleep(20000);
                if (cCmdRsp.recv_dat != null && cCmdRsp.recv_dat.dat[2] != 43) { }
                do
                {
                    serialPortDE70.DiscardInBuffer();
                    serialPortDE70.DiscardOutBuffer();
                    cCmdRsp.SendXXCmd((byte)Command.CMD_SENSE);
                }
                while (cCmdRsp.recv_dat != null && cCmdRsp.recv_dat.dat[1] == 0x09); //SR2 = 0x09 : Counting Status

                //SR3 = 0x43 : Stacker full
             
                AutoSerialGet(serialPortDE70);

                if (sessions == null || sessions.Count == 0)
                {
                    double tempSum = 0;
                    for (int i = 0; i < 10; i++)
                    {
                        lvCountItems[i].Quantity = TempQuantity[9 - i].ToString();
                        tempSum += lvCountItems[i].getValue();
                    }

                    lvCountItems[10].Quantity = UpdateTotalQuantity().ToString();
                    lvCountItems[10].Value = tempSum.ToString();

                }
                else
                {
                    InitSessionCount();
                    double sum = 0;

                    for (int i = 0; i < 10; i++)
                    {
                        int a = 0;
                        for (int j = 0; j < sessions.Count; j++)
                        {

                            a += sessions[j].QuantityDenomi[9 - i];

                        }

                        a += TempQuantity[9 - i];

                        lvCountItems[i].Quantity = a.ToString();
                        sum += lvCountItems[i].getValue();

                    }
                    //Update amount of money
                    lvCountItems[10].Quantity = UpdateTotalQuantity().ToString();
                    lvCountItems[10].Value = sum.ToString();

                }
                SetStep(2);
            }
            catch (Exception ex)
            {
                LogException(currentMethod, ex.ToString());
            }
        }

        private void btnCheck_Click(object sender, RoutedEventArgs e)
        {
            string currentMethod = MethodBase.GetCurrentMethod().Name;
 
            try
            {
                serialPortDE70.DiscardInBuffer();
                serialPortDE70.DiscardOutBuffer();
                LogAction(currentMethod, null);
                Array.Clear(TempQuantity, 0, TempQuantity.Length);

                cCmdRsp.SendXXCmd((byte)Command.CMD_DE_CANCEL);

                double sumStored;

                //TempNote[1] = 0;

                if (sessions != null)
                {
                    sumStored = 0;

                    for (int i = 0; i < 10; i++)
                    {
                        int a = 0;
                        for (int j = 0; j < sessions.Count; j++)
                        {

                            a += sessions[j].QuantityDenomi[9 - i];
                            //quantityStored += lvCountItems[i].getQuantity();
                        }
                        lvCountItems[i].Quantity = a.ToString();
                        sumStored += lvCountItems[i].getValue();
                    }
                    lvCountItems[10].Quantity = UpdateTotalQuantity().ToString();
                    lvCountItems[10].Value = sumStored.ToString();
                }
                else
                {
                    InitSessionCount();
                }
            }
            catch (Exception ex)
            {
                LogException(currentMethod, ex.ToString());
            }
        }
        private void btnStoreStart_Click(object sender, RoutedEventArgs e)
        {
            printerFlag = true;
 
            string currentMethod = MethodBase.GetCurrentMethod().Name;
           
            try
            {
                serialPortDE70.DiscardInBuffer();
                serialPortDE70.DiscardOutBuffer();
                LogAction(currentMethod, null);
                sessions.Add(new CountSession());

                sessions[sessions.Count - 1].QuantityDenomi = (int[])TempQuantity.Clone();
                quantityStored = UpdateTotalQuantity();

                Debug.WriteLine(quantityStored);

                Array.Clear(TempQuantity, 0, TempQuantity.Length);

                cCmdRsp.SendXXCmd((byte)Command.CMD_DE_STORESTART);
                SetStep(3);
            }
            catch (Exception ex)
            {
                LogException(currentMethod, ex.ToString());
            }
        }

        private void btnStart_Click(object sender, RoutedEventArgs e)
        {
            string currentMethod = MethodBase.GetCurrentMethod().Name;
            InitSession();
            try
            {
                serialPortDE70.DiscardInBuffer();
                serialPortDE70.DiscardOutBuffer();

                LogAction(currentMethod, null);

                cCmdRsp.SendXXCmd((byte)Command.CMD_DE_SENSE);

                var recvData = cCmdRsp.recv_dat;

                if (recvData.dat[14] == recvData.dat[16])
                {
                    cCmdRsp.SendLock();
                }
                else
                {
                    cCmdRsp.SendEventFix(recvData.dat[16]);
                    cCmdRsp.SendLock();
                }
                SetStep(1);
            }
            catch (Exception ex)
            {
                LogException(currentMethod, ex.ToString());
            }
        }

        private void btnEnd_Click(object sender, RoutedEventArgs e)
        {
          
            string currentMethod = MethodBase.GetCurrentMethod().Name;
          
            try
            {
                LogAction(currentMethod, null);
                serialPortDE70.DiscardInBuffer();
                serialPortDE70.DiscardOutBuffer();

                //SendData2Server  
                var data2Send = new CountingData2Send
                {
                    Sessions = sessions,
                    MachineId = null,
                    UserId = AppData.CurrentCustomerAccount.CustomerId,
                    MachineTime = DateTime.Now.ToString("yyyyMMddHHmmss"),
                    RejectNotes = Notes[0],
                    GenuineNotes = quantityStored,
                    UnfitNotes = Notes[2],
                    CounterfeitNotes = Notes[3],
                    SuspendNotes = Notes[4]

                };
                var str = JsonConvert.SerializeObject(data2Send);

                APIModels.SendCountingData(data2Send);
                //Reset all and ready to next session

                if(printerFlag == true)
                {
                    PrintReceipt();
                    printerFlag = false;
                    
                }
                InitSession();
                //Debug.WriteLine("Reject Note: " + Notes[0] );
                //Debug.WriteLine("Genuine note stored: " + quantityStored);
                //Debug.WriteLine("Unfit note: " + Notes[2]);
                //Debug.WriteLine("Counterfeit: " + Notes[3]);
                //Debug.WriteLine("Suspend: " + Notes[4]);

            }
            catch (Exception ex)
            {
                LogException(currentMethod, ex.ToString());
            }
            LoginUsingQRCode();

        }
        private void ShowError(string strError)
        {
            gridMain.IsEnabled = false;
            btnCollect2.Visibility=Visibility.Collapsed;
            panelError.Visibility = Visibility.Visible;
            lblError.Text = strError;
        }

        private bool InitSession()
        {
            try
            {
                //Check status
                cCmdRsp.SendDeSense();
                var data = cCmdRsp.recv_dat.dat;
                int IsCassetteFull=data[17] & 0x08;
                if(IsCassetteFull != 0)
                {
                    ShowError("TÚI ĐẦY, ĐỀ NGHỊ LẤY TÚI TRƯỚC KHI TIẾP TỤC THAO TÁC");
                    btnCollect2.Visibility=Visibility.Visible;
                    return false;
                }
                else
                {
                    InitSessionCount();
                    sessions.Clear();
                    Array.Clear(TempNote, 0, TempNote.Length);
                    Array.Clear(Notes, 0, Notes.Length);
                    quantityStored = 0;
                    maxQuantitySheet = 0;
                    cCmdRsp.SendXXCmd((byte)Command.CMD_DE_UNLOCK);
                    SetStep(0);
                    return true;
                }    
               
            }
            catch(Exception ex)
            {
                LogException("InitSession", ex.ToString());
            }
            return false;
        }

        private void PrintReceipt()
        {
            var shopName = AppData.CurrentCustomerAccount.Name;
            var shopCode = AppData.CurrentCustomerAccount.CustomerId;
            var tradingCode = "TRA04052024CDM";
            var storeAccountNumber = 686868686688;
            var currentTime = DateTime.Now;
            var printDocument = new PrintDocument();
            printDocument.PrinterSettings.PrinterName = "CUSTOM K80";
            printDocument.PrintPage += (sender, e) =>
            {
                e.Graphics.DrawString("Biên nhận nộp tiền", new Font("Arial", 15), System.Drawing.Brushes.Black, new PointF(80, 10));
                e.Graphics.DrawString("Mã máy CDM: ", new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 60));
                e.Graphics.DrawString("Batch no: ", new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 90));
                e.Graphics.DrawString("Thời gian GD: " + currentTime.ToString("dd/MM/yyyy HH:mm:ss"), new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 120));
                e.Graphics.DrawString("Mã GD: " + tradingCode, new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 150));
                e.Graphics.DrawString("Mã gian hàng: " + shopCode, new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 180));
                e.Graphics.DrawString("Tên gian hàng: " + shopName, new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 210));
                e.Graphics.DrawString("STK gian hàng: " + storeAccountNumber, new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 240));
                e.Graphics.DrawString("Số tiền nộp: " + lvCountItems[10].Value, new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(50, 270));
                e.Graphics.DrawString("*****Xin cám ơn******", new Font("Arial", 9), System.Drawing.Brushes.Black, new PointF(100, 300));
                // To send raw ESC/POS commands, you'd typically use e.Graphics.DrawString() with the command string,
                // or for more complex scenarios, directly manipulate the byte stream sent to the printer.
            };
            printDocument.Print();

        
        }

        public void LogAction(string strAction, string? strData)
        {
            if (strData != null) strData = "Data: " + strData;
            File.AppendAllText("log.txt", "\r\n" + DateTime.Now.ToString("yyyyMMddHHmmss: ") +
                "Action: " + strAction + " " + strData);
        }

        public void LogException(string strAction, string? strData)
        {
            if (strData != null) strData = "Data: " + strData;
            File.AppendAllText("logException.txt", "\r\n" + DateTime.Now.ToString("yyyyMMddHHmmss: ") +
                "Action: " + strAction + " " + strData);
        }

        private void LoginUsingQRCode()
        {
            var wnd = new WelcomeWindow();
            wnd.ShowDialog();

            lblUser.Content = "";
            //var wnd = new QRCodeZebraWindow();
            //wnd.ShowDialog();
            if (wnd.DialogResult == true)
            {
                var strQR = wnd.QRCodeContent;
                var strPincode = wnd.PinCode;
                if (AppData.customerAccounts!=null)
                {
                    CustomerAccount? cca = null;
                    if(strQR!=null)
                    {
                        cca = AppData.customerAccounts.Where(x => x.QRCode == strQR).FirstOrDefault();
                    }
                    else if(strPincode!=null)
                    {
                        strPincode = strPincode.ToUpper();
                        cca = AppData.customerAccounts.Where(x => x.PINCode == strPincode).FirstOrDefault();
                    }
                    
                    if (cca != null)
                    {
                        AppData.CurrentCustomerAccount = cca;
                        lblUser.Content = $"Xin chào khách hàng: {cca.Name} (Gian hàng {cca.CustomerId})";
                    }
                    else
                    {
                        MessageBox.Show("QRCode không đúng, vui lòng thử lại");
                        LoginUsingQRCode();
                    }
                }    
            }
        }

        private void btnLoginByPINCode_Click(object sender, RoutedEventArgs e)
        {
            var wnd = new PinCodeWindow();
            wnd.ShowDialog();
        }

        private void btnCollect_Click(object sender, RoutedEventArgs e)
        {
            cCmdRsp.SendDeSense();
            Thread.Sleep(1000);
            cCmdRsp.SendXXCmd((byte)Command.CMD_DE_UNLOCK);
            Thread.Sleep(1000);
            cCmdRsp.SendDeSense();
            Thread.Sleep(1000);
            //Event fix
            var recvData = cCmdRsp.recv_dat;

            if (recvData.dat[14] == recvData.dat[16])
            {
                cCmdRsp.SendLock();
            }
            else
            {
                cCmdRsp.SendEventFix(recvData.dat[16]);
                cCmdRsp.SendLock();
            }

            var currentMode = cCmdRsp.GetLockParam().mode;
            cCmdRsp.GetLockParam().mode = Mode.MODE_COLLECTION;  
            cCmdRsp.SendLock();
            Thread.Sleep(10000);
            cCmdRsp.SendDeSense();
            Thread.Sleep(1000);
            recvData = cCmdRsp.recv_dat;

            if (recvData.dat[14] != recvData.dat[16])
            {
                ShowError("Khởi tạo bộ đếm thành công");
                ShutdownApp();
                InitApp();
            }    
            //Thread.Sleep(5000);
            //cCmdRsp.GetLockParam().mode = currentMode;
            //cCmdRsp.SendLock();
        }
    }
}