mikhail/parr_api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Подготовка расписания для автоматического запуска заданий

Browse Source
This commit is contained in:
Mikhail Kuznetsov
2023-06-21 11:09:40 +10:00
parent 8747fea111
commit 3ebc077b27
5 changed files with 86 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

89
PARR.API/Controllers/V1/JobController.cs
View File

@@ -75,6 +75,15 @@ namespace PARR.API.Controllers.V1
[HttpGet(ApiRoutes.Jobs.GetByIp)]
public async Task<IActionResult> GetByClientIP([FromQuery] JobGetByIpQuery requestQuery)
{
var d1 = DateTimeOffset.Now;
var d2 = DateTimeOffset.Now.Date;
if (d1.Date == d2) { }
var ip = requestQuery.Ip ?? clientService.GetClientIp()?.ToString();
if (string.IsNullOrEmpty(ip))
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = "Client IP address is null." } }));
@@ -83,6 +92,7 @@ namespace PARR.API.Controllers.V1
// С одним IP может быть несколько информационных систем, соответственного а таблице храниться несколько записей хостов с одинаковым IP
var hosts = await hostService.Get().Where(h => h.IP == ip).ToListAsync();
var hostJobsDict = new Dictionary<DAL.Models.Host, List<Job>>();
foreach (var host in hosts)
{
@@ -100,44 +110,42 @@ namespace PARR.API.Controllers.V1
}
var jobsList = new List<Job>();
var response = new Dictionary<string, string>();
var jobsToResponse = new List<Job>();
foreach (var hostAndJobs in hostJobsDict)
{
hostAndJobs.Value.ForEach(async item =>
foreach (var item in hostAndJobs.Value)
{
if (!jobsList.Contains(item))
{
jobsList.Add(item);
var plannedJobs = await GetListJobsAsync(item, hostAndJobs.Key, date);
//todo:!!! эти списки склеивать в один, отсортировать по дате и перегнать в дикт
//var baseTime = new DateTimeOffset(date.Year, date.Year, 01, 0, 0, 0, new TimeSpan(0));
////если более суток то идём в JobJournal и получаем дату последнегно запуска. Если нет то приравниваем к StartAt
//var freq = item.Frequency;
//if (true)
//{
//}
//var curTimeCreation = baseTime;
//while(curTimeCreation <= curTimeCreation.EndOfDay())
//{
// curTimeCreation=curTimeCreation.DateTime.AddMinutes(freq);
//}
//kaskjdhaskjkjasklhd
jobsToResponse.AddRange(plannedJobs);
}
});
}
}
jobsToResponse = jobsToResponse.OrderBy(t => t.StartAt).ToList();
if (!jobsToResponse.Any())
return NoContent();
if (requestQuery.IsFullResponse == true)
{
var jobResponse = mapper.Map<List<JobGetAllResponse>>(jobsToResponse);
return Ok(new Response<List<JobGetAllResponse>>(jobResponse, true));
}
//var responseDict = new Dictionary<string, string>();
//foreach ()
//{
//}
// var jobListForResponse = new
@@ -184,8 +192,10 @@ namespace PARR.API.Controllers.V1
// если в истории нет записей, то запускаем сегодня в стартЭт
// берем квери дэйт и ем задаем время из Джобс СтартЭт
var startDateTimeNext = new DateTimeOffset(queryDate.Year, queryDate.Month, queryDate.Day, job.StartAt.Hour, job.StartAt.Minute, job.StartAt.Second, new TimeSpan(0));
//todo:
var jobToAdded = new Job { StartAt = startDateTimeNext };
//todo: check
var jobToAdded = mapper.Map<Job>(job);//new Job { StartAt = startDateTimeNext };
jobToAdded.StartAt = startDateTimeNext;
jobs.Add(jobToAdded);
}
else
@@ -196,8 +206,9 @@ namespace PARR.API.Controllers.V1
// если берем прошлую последнюю операцию из журнала, и к ней прибавить фрекунси, то время следующего старта сдвинется на время выполнения прошлого задания
// чтобы это избежать, берем квери дэйт и ем задаем время из Джобс СтартЭт
var startDateTimeNext = new DateTimeOffset(queryDate.Year, queryDate.Month, queryDate.Day, job.StartAt.Hour, job.StartAt.Minute, job.StartAt.Second, new TimeSpan(0));
//todo:
var jobToAdded = new Job { StartAt = startDateTimeNext };
//todo: check
var jobToAdded = mapper.Map<Job>(job);
jobToAdded.StartAt = startDateTimeNext;
jobs.Add(jobToAdded);
}
}
@@ -214,8 +225,10 @@ namespace PARR.API.Controllers.V1
var min = startAtMinutes;
while (min > 0)
{
//TODO
var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
//var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
//todo: check
var jobToAdded = mapper.Map<Job>(job);
jobToAdded.StartAt = queryDate.StartOfDay().AddMinutes(min);
jobs.Add(jobToAdded);
min = min - job.Frequency;
}
@@ -223,8 +236,10 @@ namespace PARR.API.Controllers.V1
// прибавляем пока не наступят след сутки
while (min <= allDayMinutes)
{
//TODO
var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
//TODO: check
//var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
var jobToAdded = mapper.Map<Job>(job);
jobToAdded.StartAt = queryDate.StartOfDay().AddMinutes(min);
jobs.Add(jobToAdded);
min = min + job.Frequency;
}
@@ -237,7 +252,9 @@ namespace PARR.API.Controllers.V1
while (min <= allDayMinutes)
{
//TODO
var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
//var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
var jobToAdded = mapper.Map<Job>(job);
jobToAdded.StartAt = queryDate.StartOfDay().AddMinutes(min);
jobs.Add(jobToAdded);
min = min + job.Frequency;
}