Change in BulkInsert (add ignore duplicate)

main
muhammad.faique 2025-06-26 13:13:17 +05:00
parent 6b03af550f
commit 24145f5215
10 changed files with 19 additions and 23 deletions

Binary file not shown.

View File

@ -54,7 +54,7 @@ namespace ZktecoAttendenceService
// Start building the INSERT statement
StringBuilder queryBuilder = new StringBuilder("INSERT INTO attendance_log (ac_no, checktime, processed, machine_id, in_out_type_id, machine_ip, date) VALUES ");
StringBuilder queryBuilder = new StringBuilder("INSERT IGNORE INTO attendance_log (ac_no, checktime, processed, machine_id, in_out_type_id, machine_ip, date) VALUES ");
// Add each record as a value
List<string> rows = new List<string>();

View File

@ -112,7 +112,7 @@ namespace ZktecoAttendenceService
return responses;
}
bool Bconnect = false;
// bool Bconnect = false;
public void DeleteFaceTemplate(zkemkeeper.CZKEMClass axCZKEM1, AttendanceMachine machine, int Emp_ID, List<string> responses)
{
//Bconnect = axCZKEM1.Connect_Net(machine.MachineIp, machine.PortNumber);
@ -120,8 +120,7 @@ namespace ZktecoAttendenceService
try
{
if (Bconnect == true)
{
axCZKEM1.SSR_DeleteEnrollData(Convert.ToInt32(machine.MachineId), Emp_ID.ToString(), 12);
Console.WriteLine(Emp_ID + " removed from " + machine.MachineId);
@ -131,11 +130,7 @@ namespace ZktecoAttendenceService
//axCZKEM1.EnableDevice(Convert.ToInt32(machine.MachineId), true);
//axCZKEM1.Disconnect();
}
else
{
}
}

View File

@ -65,8 +65,7 @@ namespace ZktecoAttendenceService
{
try
{
List<string> responses = new List<string>();
AttendanceMachineDAO attendanceMachineDAO = new AttendanceMachineDAO();
AttendanceMachineUserDAO attendanceMachineUserDAO = new AttendanceMachineUserDAO();
@ -78,9 +77,11 @@ namespace ZktecoAttendenceService
var machines = attendanceMachineDAO.getAttendanceMachines(connection, "0");
foreach (var machine in machines)
{
{
// if ((machine.MachineIp == "172.16.53.4") || (machine.MachineIp == "172.16.53.9")) // For lahore warehouse
if (machine.MachineIp == "192.168.50.8")
// if (machine.MachineIp == "192.168.90.191") // For lahore warehouse
{
bool isConnected = axCZKEM1.Connect_Net(machine.MachineIp, Convert.ToInt32(machine.PortNumber));
if (isConnected)
@ -139,7 +140,7 @@ namespace ZktecoAttendenceService
}
else
{
responses.Add("MACHINE : " + machine.MachineIp + " : NOT CONNECTED");
responses.Add("MACHINE : " + machine.MachineIp + " : NOT CONNECTED");
machine.Status = "NOT CONNECTED";
attendanceMachineDAO.update(machine, connection);
}
@ -273,9 +274,9 @@ namespace ZktecoAttendenceService
//if(axCZKEM1.ReadGeneralLogData(machineId))
if(axCZKEM1.ReadGeneralLogData(machineId))
if (axCZKEM1.ReadAllGLogData(machineId))
// if (axCZKEM1.ReadAllGLogData(machineId))
// Connect and read attendance records
//if (axCZKEM1.ReadTimeGLogData(machineId, startTimeFormatted, endTimeFormatted)) // read all the attendance records into memory

View File

@ -1,17 +1,13 @@
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.DevicePolling.resources
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\DevicePolling.Properties.Resources.resources
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.GenerateResource.cache
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.CoreCompileInputs.cache
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\DevicePolling.exe.config
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\DevicePolling.exe
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\DevicePolling.pdb
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\MySql.Data.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\DevicePolling.exe.config
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\BouncyCastle.Cryptography.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\Google.Protobuf.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\K4os.Compression.LZ4.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\K4os.Compression.LZ4.Streams.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\K4os.Hash.xxHash.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\Microsoft.Bcl.AsyncInterfaces.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\MySql.Data.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Buffers.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Configuration.ConfigurationManager.dll
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Diagnostics.DiagnosticSource.dll
@ -36,7 +32,11 @@ D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Memory.xml
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Numerics.Vectors.xml
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Runtime.CompilerServices.Unsafe.xml
D:\Projects\ZktecoAttendenceService\DevicePolling\bin\Debug\System.Threading.Tasks.Extensions.xml
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.AssemblyReference.cache
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.DevicePolling.resources
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\DevicePolling.Properties.Resources.resources
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.GenerateResource.cache
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.CoreCompileInputs.cache
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.CopyComplete
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\DevicePolling.exe
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\DevicePolling.pdb
D:\Projects\ZktecoAttendenceService\DevicePolling\obj\Debug\ZktecoAttendenceService.csproj.AssemblyReference.cache