Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| b2cf602602 |
@@ -73,40 +73,43 @@ public class SalaryBusinessLogicContract(ISalaryStorageContract salaryStorageCon
|
||||
|
||||
private double CalculateSalaryForBartender(List<SaleDataModel> sales, DateTime startDate, DateTime finishDate, BartenderPostConfiguration config)
|
||||
{
|
||||
var tasks = new List<Task>();
|
||||
var calcPercent = 0.0;
|
||||
for (var date = startDate; date < finishDate; date = date.AddDays(1))
|
||||
var days = (finishDate - startDate).Days;
|
||||
var dates = Enumerable.Range(0, days)
|
||||
.Select(offset => startDate.AddDays(offset))
|
||||
.ToList();
|
||||
|
||||
var parallelOptions = new ParallelOptions
|
||||
{
|
||||
tasks.Add(Task.Factory.StartNew((object? obj) =>
|
||||
MaxDegreeOfParallelism = _salaryConfiguration.MaxConcurrentThreads
|
||||
};
|
||||
|
||||
Parallel.ForEach(dates, parallelOptions, date =>
|
||||
{
|
||||
var salesInDay = sales.Where(x => x.SaleDate.Date == date.Date).ToArray();
|
||||
if (salesInDay.Length == 0) return;
|
||||
|
||||
double dailySum = salesInDay.Sum(x => x.Sum);
|
||||
double averageSale = dailySum / salesInDay.Length;
|
||||
|
||||
lock (_lockObject)
|
||||
{
|
||||
var dateInTask = (DateTime)obj!;
|
||||
var salesInDay = sales.Where(x => x.SaleDate >= dateInTask && x.SaleDate <= dateInTask.AddDays(1)).ToArray();
|
||||
if (salesInDay.Length > 0)
|
||||
{
|
||||
lock (_lockObject)
|
||||
{
|
||||
calcPercent += (salesInDay.Sum(x => x.Sum) / salesInDay.Length) * config.SalePercent;
|
||||
}
|
||||
}
|
||||
}, date));
|
||||
}
|
||||
var calcBonusTask = Task.Run(() =>
|
||||
{
|
||||
return sales.Where(x => x.Sum > _salaryConfiguration.ExtraSaleSum).Sum(x => x.Sum) * config.BonusForExtraSales;
|
||||
calcPercent += averageSale * config.SalePercent;
|
||||
}
|
||||
});
|
||||
|
||||
double bonus = 0;
|
||||
try
|
||||
{
|
||||
Task.WaitAll([Task.WhenAll(tasks), calcBonusTask]);
|
||||
bonus = sales.Where(x => x.Sum > _salaryConfiguration.ExtraSaleSum)
|
||||
.Sum(x => x.Sum) * config.BonusForExtraSales;
|
||||
}
|
||||
catch (AggregateException agEx)
|
||||
catch (Exception ex)
|
||||
{
|
||||
foreach (var ex in agEx.InnerExceptions)
|
||||
{
|
||||
_logger.LogError(ex, "Error in the cashier payroll process");
|
||||
}
|
||||
return 0;
|
||||
_logger.LogError(ex, "Error in bonus calculation");
|
||||
}
|
||||
return config.Rate + calcPercent + calcBonusTask.Result;
|
||||
|
||||
return config.Rate + calcPercent + bonus;
|
||||
}
|
||||
private double CalculateSalaryForManager(DateTime startDate, DateTime finishDate, ManagerPostConfiguration config)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user