muaazh / zkteco_pullsdk_wrapper Goto Github PK

public void btn_conectar_Click(object sender, EventArgs e)
{
    if (btn_Connect.Text == "Connect")
    {
        foreach (var item in _currentSettings)
        {
            item.AccessPanelData = new AccessPanel();
            // connect
            if (!item.AccessPanelData.Connect(item.IP, item.Port.Value, 0, item.TimeOuts.Value))
            {
                logger.Information("Cannot connect:" + item.IP);
                MessageBox.Show("Cannot connect this ip " + item.IP + ". Error", "Infomation", MessageBoxButtons.OK, MessageBoxIcon.Error);
            }
            else
            {
                logger.Information("Start with IP:" + item.IP);
               //call function run backgroud
                Task.Run(() => BackgroundTask(item));
            }
        }
        btn_Connect.Text = "Disconnect";
    }
    else
    {
        foreach (var item in _currentSettings)
        {
            item.AccessPanelData.Disconnect();
        }
        listBoxActive.Items.Clear();
        btn_Connect.Text = "Connect";
    }
}

//Create thread run backgroud
async Task BackgroundTask(Settings setting)
{
    while (setting.IsActive)
    {
        await Task.Delay(1000);
        var listLog = csetting.AccessPanelData.GetEventLog();
        if (listLog != null && listLog.Events != null)
        {
            var list = listLog.Events;
            foreach (var item in list)
            {
                if (list_log1.Items.Count > 20)
                {
                    list_log1.Invoke(new MethodInvoker(() => list_log1.Items.Clear()));
                }

                list_log1.Invoke(new MethodInvoker(() =>
                {
                    list_log1.Items.Add(setting.IP);
                    var index = list_log1.Items.Count - 1;
                    list_log1.Items[index].SubItems.Add(item.Time);
                    list_log1.Items[index].SubItems.Add(item.Pin);
                    list_log1.Items[index].SubItems.Add(item.inputString);
                    list_log1.Items[index].SubItems.Add(item.Door);
                    list_log1.Items[index].SubItems.Add(item.EventType.ToString());
                    list_log1.Items[index].SubItems.Add(item.InOrOut.ToString());
                    list_log1.Items[index].SubItems.Add("");
                    list_log1.Items[index].SubItems.Add("");
                }));
               //item.inputString is code I will check to access open door
                if (item.inputString.Length > 5 && setting.intPtr != IntPtr.Zero)
                {
                  // call function check true false can access open door
                    var ticket = await ServiceConnection.CheckTicketAsync(item.inputString, setting.IP);
                    if (CheckCong(item.inputString, setting.IP) && ticket.ActiveID != null)
                    {
                            //create another thread to open Door
                           var task = Task.Run(async () =>
                            {
                              //NumberOfOpenDoor > 1 Open the door multiple times, each time 3 seconds apart 
                                for (int k = 0; k < ticket.NumberOfOpenDoor; k++)
                                {
                                    setting.AccessPanelData.OpenDoor(1, 1);
                                   //wait 3s
                                    await Task.Delay(3000);
                                }
                            });
                            await task;
                    }
                }
            }
        }
    }
}