using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.IO;
using System.Threading;
using System.Net.NetworkInformation;
using System.Data.OracleClient;
using System.Diagnostics;
using MySql.Data.MySqlClient;


namespace ZktecoAttendenceService
{
    public partial class DevicePolling : Form
    {
        static MySqlConnection connection;

        static ConnectionClass ObjConnectionClass = new ConnectionClass();
        AttendanceDAO attendanceDAO = new AttendanceDAO();
        AttendanceMachineUserDAO attendanceMachineUserDAO = new AttendanceMachineUserDAO();
        WriteToTxtFile WriteFile_obj = new WriteToTxtFile();


        public zkemkeeper.CZKEMClass axCZKEM1 = new zkemkeeper.CZKEMClass();
        private bool bIsConnected = false;//the boolean value identifies whether the device is connected
        private int iMachineNumber = 0;//the serial number of the device.After connecting the device ,this value will be changed.
        DataTable dtMachines = new DataTable();
        DataTable dtPAth = new DataTable();

        List<string> empList = new List<string>();

        public DevicePolling()
        {
            InitializeComponent();
        }

        private void DevicePolling_Load(object sender, EventArgs e)
        {


            //timer1.Enabled = true;
            //timer1.Interval = 100;
            //timer1.Start();
            WriteFile_obj.WriteToFile("--Service is started at " + DateTime.Now, "ZKTECOAttendance");

            List<string> responses = StartPooling();
            foreach (var response in responses)
            {
                WriteFile_obj.WriteToFile(response, "ZKTECOAttendance");
            }
            WriteFile_obj.WriteToFile("--Service is stopped at " + DateTime.Now, "ZKTECOAttendance");

            Application.Exit();
        }



        public List<string> StartPooling()
        {
            List<string> responses = new List<string>();

            try
            {
                //timer1.Enabled = false;

                Ping ping = new Ping();
                string mIp = string.Empty;
                Int16 mMacID = 0;
                string mInOut = string.Empty;

                connection = ObjConnectionClass.Connection();
                if (ObjConnectionClass.OpenConnection(connection) == true)
                {
                    AttendanceMachineDAO attendanceMachineDAO = new AttendanceMachineDAO();
                    List<AttendanceMachine> machines = attendanceMachineDAO.getAttendanceMachines(connection, "0");

                    foreach (var machine in machines)
                    {

                       if (machine.MachineIp == "192.168.52.17")
                        {


                            bool Bconnect = false;

                            Bconnect = axCZKEM1.Connect_Net(machine.MachineIp, Convert.ToInt32(machine.PortNumber));
                            axCZKEM1.EnableDevice(Convert.ToInt32(machine.MachineId), false);//disable the device


                            if (Bconnect == true)
                            {

                                if (machine.MachineId != "100")
                                {

                                    machine.Status = "SYNCING";
                                    attendanceMachineDAO.update(machine, connection);

                                    responses.AddRange(poolMachineData(machine.MachineIp, machine.PortNumber, Convert.ToInt16(machine.MachineId)));
                                    machine.Status = "IDLE";

                                    DateTime now = DateTime.Now.AddMinutes(-5);
                                    machine.LastSyncDate = now;
                                    Console.WriteLine(machine.MachineId + " => " + machine.LastSyncDate);
                                    attendanceMachineDAO.update(machine, connection);


                                    List<string> Newresponses = new List<string>();
                                    GetAllFaceInfo(machine);

                                    //Delete from machine and db
                                    attendanceMachineUserDAO.UpdateTotalEmpInMachines(machine.MachineId, empList.Count, connection);

                                    Newresponses = (attendanceMachineUserDAO.DeleteFromDbAndMachine(empList, machine, connection));
                                    if (Newresponses.Count != 0)
                                    {
                                        responses.AddRange(Newresponses);

                                    }
                                    empList = new List<string>();
                                    axCZKEM1.EnableDevice(Convert.ToInt32(machine.MachineId), true);
                                    Cursor = Cursors.Default;
                                    axCZKEM1.Disconnect();

                                }

                                //for colony attendance
                                else
                                {
                                    machine.Status = "SYNCING";
                                    attendanceMachineDAO.updateColony(machine, connection);
                                    responses.AddRange(poolMachineDataColony(machine.MachineIp, machine.PortNumber, Convert.ToInt16(machine.MachineId)));
                                    machine.Status = "IDLE";

                                    DateTime now = DateTime.Now.AddMinutes(-5);
                                    machine.LastSyncDate = now;
                                    Console.WriteLine(machine.MachineId + " => " + machine.LastSyncDate);
                                    attendanceMachineDAO.updateColony(machine, connection);
                                    axCZKEM1.EnableDevice(Convert.ToInt32(machine.MachineId), true);
                                    Cursor = Cursors.Default;
                                    axCZKEM1.Disconnect();
                                }
                            }

                            else
                            {
                                responses.Add("MACHINE : " + machine.MachineIp + " : NOT CONNECTED");
                                // return responses;
                                machine.Status = "NOT CONNECTED";
                                attendanceMachineDAO.update(machine, connection);

                            }


                        }
                       
                    }
                    ObjConnectionClass.CloseConnection(connection);
                }

                return responses;

            }
            catch (Exception ex)
            {
                return responses;
            }
            finally
            {
                ObjConnectionClass.CloseConnection(connection);
            }


        }

        public List<string> poolMachineDataColony(string ip, int port, int machineId)
        {
            List<string> responses = new List<string>();


            string mPath = string.Empty;

            string sdwEnrollNumber = "";
            int idwVerifyMode = 0;
            int idwInOutMode = 0;
            int idwYear = 0;
            int idwMonth = 0;
            int idwDay = 0;
            int idwHour = 0;
            int idwMinute = 0;
            int idwSecond = 0;
            int idwWorkcode = 0;
            int CountAttendance = 0;

            //Cursor = Cursors.WaitCursor;
            //Bconnect = axCZKEM1.Connect_Net(ip, Convert.ToInt32(port));
            //axCZKEM1.EnableDevice(machineId, false);//disable the device

            try
            {

                //axCZKEM1.RegEvent(Convert.ToInt32(machineId), 65535);//Here you can register the realtime events that you want to be triggered(the parameters 65535 means registering all)
                if (axCZKEM1.ReadAllGLogData(machineId))//read all the attendance records to the memory
                {
                    while (axCZKEM1.SSR_GetGeneralLogData(machineId, out sdwEnrollNumber, out idwVerifyMode,
                               out idwInOutMode, out idwYear, out idwMonth, out idwDay, out idwHour, out idwMinute, out idwSecond, ref idwWorkcode))//get records from the memory
                    {
                        DateTime date = new DateTime(idwYear, idwMonth, idwDay, idwHour, idwMinute, idwSecond);
                        try
                        {

                            Attendance log = new Attendance(sdwEnrollNumber, date, false, machineId.ToString(), "1", ip, DateTime.Now);
                            attendanceDAO.AddColony(log, connection);
                            CountAttendance++;
                            responses.Add("MACHINE : " + ip + " : , EMP NO : " + sdwEnrollNumber + " , TIME : " + date + "");

                            //return response;

                        }
                        catch (Exception ex)
                        {
                            responses.Add(ex.Message.ToString());
                        }
                    }


                    // responses.Add(GetTotalFromMachine(machineId));
                    axCZKEM1.ClearGLog(machineId);
                    //axCZKEM1.EnableDevice(machineId, true);

                    // axCZKEM1.Disconnect();

                }
                else
                {
                    responses.Add("MACHINE : " + ip + " : NO DATA");
                    return responses;
                }
                return responses;
            }
            catch (Exception ex)
            {

                responses.Add(ex.Message.ToString());
                return responses;

            }
        }
        public List<string> poolMachineData(string ip, int port, int machineId)
        {
            List<string> responses = new List<string>();
            List<Attendance> attendanceLogs = new List<Attendance>();
            string sdwEnrollNumber = "";
            int idwVerifyMode = 0;
            int idwInOutMode = 0;
            int idwYear = 0;
            int idwMonth = 0;
            int idwDay = 0;
            int idwHour = 0;
            int idwMinute = 0;
            int idwSecond = 0;
            int idwWorkcode = 0;

            try
            {
                // Connect and read attendance records
                if (axCZKEM1.ReadAllGLogData(machineId)) // read all the attendance records into memory
                {
                    while (axCZKEM1.SSR_GetGeneralLogData(machineId, out sdwEnrollNumber, out idwVerifyMode,
                           out idwInOutMode, out idwYear, out idwMonth, out idwDay, out idwHour, out idwMinute, out idwSecond, ref idwWorkcode)) // get records from memory
                    {
                        DateTime date = new DateTime(idwYear, idwMonth, idwDay, idwHour, idwMinute, idwSecond);
                        Attendance log = new Attendance(sdwEnrollNumber, date, false, machineId.ToString(), "1", ip, DateTime.Now);
                        attendanceLogs.Add(log); // Add to the bulk insert list

                        // Optionally log the retrieved record
                        responses.Add($"MACHINE: {ip}, EMP NO: {sdwEnrollNumber}, TIME: {date}");
                    }

                    // Perform bulk insert for all records
                    try
                    {
                        if (attendanceLogs.Count > 0)
                        {
                            attendanceDAO.BulkInsert(attendanceLogs, connection); // Bulk insert method
                            responses.Add($"Successfully inserted {attendanceLogs.Count} records for MACHINE: {ip}");
                        }
                        else
                        {
                            responses.Add($"MACHINE: {ip} - No attendance logs found.");
                        }
                    }
                    catch (Exception ex)
                    {
                        responses.Add($"Error during bulk insert: {ex.Message}");
                    }

                    // Clear logs from the machine
                    axCZKEM1.ClearGLog(machineId);
                }
                else
                {
                    responses.Add($"MACHINE: {ip} - No data available.");
                }

                return responses;
            }
            catch (Exception ex)
            {
                responses.Add($"Error: {ex.Message}");
                return responses;
            }
        }


        public List<string> GetAllFaceInfo(AttendanceMachine machine)
        {
            bool Bconnect = false;
            string sdwEnrollNumber = string.Empty, sName = string.Empty, sPassword = string.Empty;
            int iPrivilege = 0, iFaceIndex = 0, iFlag = 0, iTmpLength = 0;
            bool bEnabled = false;
            Bconnect = axCZKEM1.Connect_Net(machine.MachineIp, Convert.ToInt32(machine.PortNumber));
            axCZKEM1.EnableDevice(Convert.ToInt16(machine.MachineId), false);//disable the device


            if (Bconnect == true)
            {
                //objZkeeper.ReadAllUserID(machineNumber);
                axCZKEM1.ReadAllTemplate(Convert.ToInt16(machine.MachineId));
                while (axCZKEM1.SSR_GetAllUserInfo(Convert.ToInt16(machine.MachineId), out sdwEnrollNumber, out sName, out sPassword, out iPrivilege, out bEnabled))
                {
                    empList.Add(sdwEnrollNumber);
                }

            }
            return empList;
        }
        public string GetTotalFromMachine(int MachineID)
        {
            string response = "";

            string sdwEnrollNumber = string.Empty, sName = string.Empty, sPassword = string.Empty;
            int iPrivilege = 0, iFaceIndex = 0, iFlag = 0, iTmpLength = 0;
            bool bEnabled = false;

            axCZKEM1.ReadAllUserID(MachineID);
            //axCZKEM1.ReadAllTemplate(MachineID);

            int totalCount = 0;
            while (axCZKEM1.SSR_GetAllUserInfo(MachineID, out sdwEnrollNumber, out sName, out sPassword, out iPrivilege, out bEnabled))
            {

                totalCount++;
            }
            attendanceMachineUserDAO.UpdateTotalEmpInMachines(MachineID.ToString(), totalCount, connection);
            response = "MACHINE : " + MachineID + ", TOTAL EMP : " + totalCount + "";
            return response;
        }

        static string GetMonthName(int monthNum)
        {
            return GetMonthName(monthNum, false);
        }
        static string GetMonthName(int monthNum, bool abbreviate)
        {
            if (monthNum < 1 || monthNum > 12)
                throw new ArgumentOutOfRangeException("monthNum");
            DateTime date = new DateTime(1, monthNum, 1);
            if (abbreviate)
                return date.ToString("MMM");
            else
                return date.ToString("MMMM");
        }


        private void timer1_Tick(object sender, EventArgs e)
        {
            StartPooling();
        }


    }
}