Notes

Write a note in this area. It's really easy to share with others. Click here ...public async Task StoreEmpDataToDB(EmployeeAssignmentResponseModel obj)
{
using (var transaction = dbContext.Database.BeginTransaction())
{
try
{
Int64 employeeId = 0;
// Store and Update Candidate Data
var candidateDataToStore = mapper.Map<List<Candidate>>(obj.data?.CANDIDATE);
if (candidateDataToStore.Count > 0)
{
employeeId = Convert.ToInt64(candidateDataToStore[0].id);
}
foreach (var candidate in candidateDataToStore)
{
var existingCandidate = await dbContext.Candidate.AsNoTracking()
.Where(c => c.id == candidate.id && c.Email == candidate.Email)
.FirstOrDefaultAsync();
if (existingCandidate == null)
{
await dbContext.Candidate.AddAsync(candidate);
}
else
{
dbContext.Entry(existingCandidate).State = EntityState.Detached; // Detach the existing entity
candidate.TableId = existingCandidate.TableId;
candidate.ModifiedDate = DateTime.Now; // Set the ModifiedDate explicitly
dbContext.Entry(candidate).State = EntityState.Modified; // Attach and mark the new entity as modified
}
}

// Store and Update Job Data
var jobDataToStore = mapper.Map<List<Job>>(obj.data?.JOB);
foreach (var job in jobDataToStore)
{
var existingJob = await dbContext.Job.AsNoTracking()
.FirstOrDefaultAsync(j => j.JobId == job.JobId && j.CompanyId == job.CompanyId
&& j.CustomerId == job.CustomerId && j.EmployeeId == Convert.ToString(employeeId));
if (existingJob == null)
{
job.EmployeeId = Convert.ToString(employeeId);
await dbContext.Job.AddAsync(job);
}
else
{
dbContext.Entry(existingJob).State = EntityState.Detached; // Detach the existing entity
job.TableId = existingJob.TableId;
job.EmployeeId = Convert.ToString(employeeId);
dbContext.Entry(job).State = EntityState.Modified; // Attach and mark the new entity as modified
}
}

// Store and Update Salary Data
for (var i = 0; i < obj.data?.SALARY?.Count; i++)
{
obj.data.SALARY[i].EndDate = obj.data.SALARY[i].END_DATE?.ToString();
}
var salaryDataToStore = mapper.Map<List<Salaries>>(obj.data?.SALARY);
foreach (var salary in salaryDataToStore)
{
var existingSalary = await dbContext.Salaries.AsNoTracking()
.FirstOrDefaultAsync(s => s.EmployeeId == salary.EmployeeId && s.RecId == salary.RecId);
if (existingSalary == null)
{
await dbContext.Salaries.AddAsync(salary);
}
else
{
dbContext.Entry(existingSalary).State = EntityState.Detached; // Detach the existing entity
salary.Id = existingSalary.Id;
dbContext.Entry(salary).State = EntityState.Modified; // Attach and mark the new entity as modified
}
}

// Store and Update Billing Data
var billingDataToStore = mapper.Map<List<Billings>>(obj.data?.BILLING);
foreach (var billing in billingDataToStore)
{
var existingBilling = await dbContext.Billings.AsNoTracking()
.FirstOrDefaultAsync(b => b.EmployeeId == billing.EmployeeId && b.RecId == billing.RecId);
if (existingBilling == null)
{
await dbContext.Billings.AddAsync(billing);
}
else
{
dbContext.Entry(existingBilling).State = EntityState.Detached; // Detach the existing entity
billing.Id = existingBilling.Id;
dbContext.Entry(billing).State = EntityState.Modified; // Attach and mark the new entity as modified
}
}
await dbContext.SaveChangesAsync();
transaction.Commit();
}
catch (Exception ex)
{
transaction.Rollback();
logExceptionService.WriteToFile("Exception Error in StoreEmpDataToDB Method", ex.Message);
throw new Exception(AppConstants.ErrorSavingDataToTheDatabase + ex.Message);
}
}
}