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

refactor(all): Удалены из БД таблицы V1

Browse Source
This commit is contained in:
Mikhail Trubnikov
2023-10-18 09:40:13 +10:00
parent d720b70c4c
commit 0c688f7089
52 changed files with 2813 additions and 1980 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
PARR.API/Contracts/V1/ApiRoutes.cs
View File

@@ -27,20 +27,6 @@
public const string Metrics = Base + "/metrics";
}
public static class Jobs
{
public const string GetAll = Base + "/jobs/";
public const string GetByIp = Base + "/jobs/ip/";
//public const string Get = Base + "/schedulers/" + getParam;
//public const string GetAreas = Base + "/schedulers/" + getParam + "/areas";
//public const string GetPlaces = Base + "/schedulers/" + getParam + "/places";
//public const string GetTemplates = Base + "/schedulers/" + getParam + "/templates";
public const string getParam = "{id}";
}
public static class AgentTask
{
public const string GetByIp = Base + "/agent-tasks/ip";

4
PARR.API/Contracts/V1/Requests/Queries/AgentTaskGetByIpQuery.cs
View File

@@ -3,12 +3,12 @@
public class AgentTaskGetByIpQuery
{
/// <summary>
/// По-умолчанию берётся IP-клиента
/// По умолчанию берётся IP-клиента
/// </summary>
public string? Ip { get; set; }
/// <summary>
/// По-умолчанию расписание на сегодня
/// По умолчанию расписание на сегодня
/// </summary>
public DateTimeOffset? Date { get; set; }
}

15
PARR.API/Contracts/V1/Requests/Queries/JobGetAllQuery.cs
View File

@@ -1,15 +0,0 @@
namespace PARR.API.Contracts.V1.Requests.Queries
{
public class JobGetAllQuery
{
/// <summary>
/// true - вкл задания, false - выкл задания, null - все задания
/// </summary>
public bool? IsEnabled { get; set; }
/// <summary>
/// Список запланированных заданий на указанную дату
/// </summary>
public DateTimeOffset? StartDatePlanned { get; set; }
}
}

20
PARR.API/Contracts/V1/Requests/Queries/JobGetByIpQuery.cs
View File

@@ -1,20 +0,0 @@
namespace PARR.API.Contracts.V1.Requests.Queries
{
public class JobGetByIpQuery
{
/// <summary>
/// По-умолчанию берётся IP-клиента или указанный вручную
/// </summary>
public string? Ip { get; set; }
/// <summary>
/// По-умолчанию расписание на сегодня или указанную дату
/// </summary>
public DateTimeOffset? Date { get; set; }
/// <summary>
/// Вернуть полностью объект Job в json формате или вернуть краткий список со временем
/// </summary>
public bool? IsFullResponse { get; set; }
}
}

8
PARR.API/Contracts/V1/Responses/JobModeResponse.cs
View File

@@ -1,8 +0,0 @@
namespace PARR.API.Contracts.V1.Responses
{
public class JobModeResponse
{
public Guid Id { get; set; }
public required string Name { get; set; }
}
}

36
PARR.API/Contracts/V1/Responses/JobResponse.cs
View File

@@ -1,36 +0,0 @@
namespace PARR.API.Contracts.V1.Responses
{
public class JobBaseResponse
{
public required string Name { get; set; }
public DateTimeOffset StartAt { get; set; }
public int FrequencyMinute { get; set; }
public required JobModeResponse JobMode { get; set; }
public required string Script { get; set; }
}
public class JobGetAllResponse : JobBaseResponse
{
public Guid Id { get; set; }
public bool IsEnabled { get; set; }
}
public class JobResponse
{
}
public class JobMinResponse
{
public List<JobMinScheduleResponse> Scheduled { get; set; } = new List<JobMinScheduleResponse>();
}
public class JobMinScheduleResponse
{
public DateTimeOffset StartAt { get; set; }
public required string Script { get; set; }
public required string Name { get; set; }
}
}

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

@@ -1,254 +0,0 @@
using AutoMapper;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using PARR.API.Contracts.V1;
using PARR.API.Contracts.V1.Requests.Queries;
using PARR.API.Contracts.V1.Responses;
using PARR.API.Contracts.V1.Responses.Base;
using PARR.API.Controllers.V1.Base;
using PARR.API.Extensions;
using PARR.API.Services.Interfaces;
using PARR.DAL.DomainModels;
using PARR.DAL.Models.V1;
using PARR.DAL.Services.Interfaces.V1;
namespace PARR.API.Controllers.V1
{
public class JobController : BaseApiController
{
private readonly IMapper mapper;
private readonly V1_IJobService jobService;
//private readonly ISchedulerService schedulerService;
private readonly IClientService clientService;
private readonly V1_IHostService v1_hostService;
private readonly V1_IJobJournalService jobJournalService;
public JobController(
IMapper mapper,
V1_IJobService jobService,
IClientService clientService,
V1_IHostService v1_hostService,
V1_IJobJournalService jobJournalService
)
{
this.mapper = mapper;
this.jobService = jobService;
//this.schedulerService = schedulerService;
this.clientService = clientService;
this.v1_hostService = v1_hostService;
this.jobJournalService = jobJournalService;
}
/// <summary>
/// (НЕ РАБОТАЕТ. АДАПТАЦИЯ ПОД НОВУЮ ВЕРСИЮ) Список всех jobов постранично в соотвествии с фильтрами
/// </summary>
/// <param name="paginationQuery"></param>
/// <returns></returns>
[HttpGet(ApiRoutes.Jobs.GetAll)]
public async Task<IActionResult> GetAll([FromQuery] PaginationQuery paginationQuery, [FromQuery] JobGetAllQuery filter)
{
var paginationFilter = mapper.Map<PaginationFilter>(paginationQuery);
IQueryable<V1_Job> query = jobService.Get().Include(t => t.JobMode).OrderBy(s => s.StartAt);
if (filter.IsEnabled.HasValue)
query = query.Where(t => t.IsEnabled == filter.IsEnabled);
if (filter.StartDatePlanned.HasValue)
query = query.Where(t => t.StartAt.DateTime.Date <= filter.StartDatePlanned.Value.DateTime.Date); ;
var jobs = await jobService.GetPage(query, paginationFilter).ToListAsync();
if (!jobs.Any())
return NoContent();
var jobResponse = mapper.Map<List<JobGetAllResponse>>(jobs);
var paginationResponse = new PagedResponse<JobGetAllResponse>(jobResponse, true).GetPaginatedProps(paginationFilter, query);
return Ok(paginationResponse);
}
/// <summary>
/// (НЕ РАБОТАЕТ. АДАПТАЦИЯ ПОД НОВУЮ ВЕРСИЮ) Список заданий на запуск по IP-адресу клиента исполнения
/// </summary>
/// <param name="requestQuery"></param>
/// <returns></returns>
[HttpGet(ApiRoutes.Jobs.GetByIp)]
public async Task<IActionResult> GetByClientIP([FromQuery] JobGetByIpQuery requestQuery)
{
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." } }));
var date = requestQuery.Date ?? DateTimeOffset.UtcNow;
// С одним IP может быть несколько информационных систем, соответственного а таблице храниться несколько записей хостов с одинаковым IP
var hosts = await v1_hostService.Get().Where(h => h.IP == ip).ToListAsync();
var hostJobsDict = new Dictionary<V1_Host, List<V1_Job>>();
foreach (var host in hosts)
{
var jobsHost = await jobService.Get()
.Include(a => a.Application).ThenInclude(ah => ah.ApplicationsInHosts)/*.ThenInclude(h => h.Host)*/
.Include(jm => jm.JobMode)
.AsSplitQuery()
.Where(j => j.Application != null && j.Application.ApplicationsInHosts.Any(ah => ah.HostId == host.Id) && j.IsEnabled && j.StartAt <= date)
.ToListAsync();
if (jobsHost.Any())
{
hostJobsDict.Add(host, jobsHost);
}
}
var jobsList = new List<V1_Job>();
var jobsToResponse = new List<V1_Job>();
foreach (var hostAndJobs in hostJobsDict)
{
foreach (var item in hostAndJobs.Value)
{
if (!jobsList.Contains(item))
{
jobsList.Add(item);
var plannedJobs = await GetListJobsAsync(item, hostAndJobs.Key, date);
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));
}
// возврат минимального ответа
return Ok(mapper.Map<JobMinResponse>(jobsToResponse));
//try
//{
// return Ok(jobsToResponse.ToDictionary(t => t.ScriptName, d => d.StartAt));
//}
//catch (ArgumentException ex)
//{
// return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = $"Не могу создать json объект с одинаковым значением ключа (ScriptName). {ex.Message}" } }));
//}
}
private async Task<List<V1_Job>> GetListJobsAsync(V1_Job job, V1_Host host, DateTimeOffset queryDate)
{
var jobs = new List<V1_Job>();
#region description
// freaq > суток или нет?
//-----------
// меньше суток
//фрек=10 мин
// старт эт = 17:00 и != сегодня
//цикл 17:00 -10мин пока не начнется вчерашний день
//цикл 17:00 +10мин пока не начентся завтрашний день
// елси страт эт == сегодня
//цикл 17:00 +10мин пока не начентся завтрашний день
//-----------
// ------freaq больше суток--------
// журнал берем последнее событие (че там со статусами? не надо пока), к нему пребавляем фрек, и смотрим == сегодня или нет, если сегодня то добавляем
// --------------
#endregion
var allDayMinutes = 1440;
if (job.Frequency >= allDayMinutes)
{
//больше или = суток
var lastJournalItem = await jobJournalService.GetLastAsync(job.Id, host.Id, queryDate);
if (lastJournalItem == null)
{
// если в истории нет записей, то запускаем сегодня в стартЭт
// берем квери дэйт и ем задаем время из Джобс СтартЭт
var startDateTimeNext = new DateTimeOffset(queryDate.Year, queryDate.Month, queryDate.Day, job.StartAt.Hour, job.StartAt.Minute, job.StartAt.Second, new TimeSpan(0));
var jobToAdded = mapper.Map<V1_Job>(job);//new Job { StartAt = startDateTimeNext };
jobToAdded.StartAt = startDateTimeNext;
jobs.Add(jobToAdded);
}
else
{
var startDateNext = lastJournalItem.DateOper.DateTime.AddMinutes(job.Frequency);
if (startDateNext.Date == queryDate.DateTime.Date)
{
// если берем прошлую последнюю операцию из журнала, и к ней прибавить фрекунси, то время следующего старта сдвинется на время выполнения прошлого задания
// чтобы это избежать, берем квери дэйт и ем задаем время из Джобс СтартЭт
var startDateTimeNext = new DateTimeOffset(queryDate.Year, queryDate.Month, queryDate.Day, job.StartAt.Hour, job.StartAt.Minute, job.StartAt.Second, new TimeSpan(0));
var jobToAdded = mapper.Map<V1_Job>(job);
jobToAdded.StartAt = startDateTimeNext;
jobs.Add(jobToAdded);
}
}
}
else
{
//меньше суток
var startAtMinutes = (job.StartAt - job.StartAt.StartOfDay()).TotalMinutes;
// если дата старта != queryDate
if (job.StartAt.DateTime.Date != queryDate.DateTime.Date)
{
// отнимаем пока не наступили прошлые стуки
var min = startAtMinutes;
while (min >= 0)
{
//var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
var jobToAdded = mapper.Map<V1_Job>(job);
jobToAdded.StartAt = queryDate.StartOfDay().AddMinutes(min);
jobs.Add(jobToAdded);
min = min - job.Frequency;
}
// прибавляем пока не наступят след сутки
min = startAtMinutes + job.Frequency;
while (min < allDayMinutes)
{
//var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
var jobToAdded = mapper.Map<V1_Job>(job);
jobToAdded.StartAt = queryDate.StartOfDay().AddMinutes(min);
jobs.Add(jobToAdded);
min = min + job.Frequency;
}
}
else
{
// = queryDate
// прибавляем пока не наступят след сутки
var min = startAtMinutes;
while (min < allDayMinutes)
{
//var jobToAdded = new Job { StartAt = queryDate.StartOfDay().AddMinutes(min) };
var jobToAdded = mapper.Map<V1_Job>(job);
jobToAdded.StartAt = queryDate.StartOfDay().AddMinutes(min);
jobs.Add(jobToAdded);
min = min + job.Frequency;
}
}
}
return jobs;
}
}
}

3
PARR.API/MappingProfiles/DomainToDomainProfile.cs
View File

@@ -1,5 +1,4 @@
using AutoMapper;
using PARR.DAL.Models.V1;
namespace PARR.API.MappingProfiles
{
@@ -7,7 +6,7 @@ namespace PARR.API.MappingProfiles
{
public DomainToDomainProfile()
{
CreateMap<V1_Job, V1_Job>();
//CreateMap<V1_Job, V1_Job>();
}
}
}

18
PARR.API/MappingProfiles/DomainToResponseProfile.cs
View File

@@ -4,7 +4,6 @@ using PARR.API.MappingProfiles.Resolvers;
using PARR.BLL.Helpers;
using PARR.DAL.DomainModels;
using PARR.DAL.Models;
using PARR.DAL.Models.V1;
namespace PARR.API.MappingProfiles
{
@@ -12,23 +11,6 @@ namespace PARR.API.MappingProfiles
{
public DomainToResponseProfile()
{
// --- Job ---
CreateMap<V1_Job, JobBaseResponse>()
.Include<V1_Job, JobGetAllResponse>()
.ForMember(d => d.FrequencyMinute, o => o.MapFrom(s => s.Frequency))
.ForMember(d => d.Script, o => o.MapFrom(s => s.ScriptName));
CreateMap<V1_Job, JobGetAllResponse>();
CreateMap<List<V1_Job>, JobMinResponse>()
.ForMember(d => d.Scheduled, o => o.MapFrom(s => s));
CreateMap<V1_Job, JobMinScheduleResponse>()
.ForMember(d => d.Script, o => o.MapFrom(s => s.ScriptName));
// === Job ===
CreateMap<V1_JobMode, JobModeResponse>();
// --- Template ---
CreateMap<Template, TemplateResponse>()
.ForMember(d => d.Work, o => o.MapFrom(s => s.ApplicationsInWork!.Work))