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

feat(api): Обновил логику получения шаблона по статусу, согласоно статусам отработки робота. TemplateRobotStatusController - управление статусами робота в шаблоне

Browse Source
This commit is contained in:
Mikhail Trubnikov
2023-10-04 12:00:43 +10:00
parent 49a04752bb
commit d0b75b7f58
10 changed files with 225 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
PARR.API.sln
View File

@@ -15,6 +15,7 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PARR.AIHIT", "PARR.AIHIT\AI
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{C170A32C-5A9D-4F1C-B6FF-FAE12736ED17}"
ProjectSection(SolutionItems) = preProject
.gitignore = .gitignore
.gitlab-ci.yml = .gitlab-ci.yml
NuGet.config = NuGet.config
README.md = README.md
@@ -30,9 +31,9 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PARR.EsppTemplateSync", "PA
EndProject
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PARR.MockData", "PARR.MockData\PARR.MockData.csproj", "{B02E5B16-59BD-4F02-9CC4-6873409DBD84}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "PARR.GeneratorTemplates", "PARR.GeneratorTemplates\PARR.GeneratorTemplates.csproj", "{79EC7AD8-9A16-4806-881A-E5632C48C461}"
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PARR.GeneratorTemplates", "PARR.GeneratorTemplates\PARR.GeneratorTemplates.csproj", "{79EC7AD8-9A16-4806-881A-E5632C48C461}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "PARR.GeneratorTemplatesWorker", "PARR.GeneratorTemplatesWorker\PARR.GeneratorTemplatesWorker.csproj", "{BE11D005-D3FE-4F29-93A2-7379E729C78D}"
Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "PARR.GeneratorTemplatesWorker", "PARR.GeneratorTemplatesWorker\PARR.GeneratorTemplatesWorker.csproj", "{BE11D005-D3FE-4F29-93A2-7379E729C78D}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution

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

@@ -63,6 +63,14 @@
public const string getParam = "{id}";
}
public static class TemplateRobotStatus
{
public const string Get = Base + "/templates/" + templateId + "/robot-statuses";
public const string Update = Base + "/templates/" + templateId + "/robot-statuses";
public const string templateId = "{templateId}";
}
public static class StatusTemplate
{
public const string GetAll = Base + "/template-statuses/";

7
PARR.API/Contracts/V1/Requests/TemplateRobotStatusRequest.cs Normal file
View File

@@ -0,0 +1,7 @@
namespace PARR.API.Contracts.V1.Requests
{
public class TemplateRobotStatusRequest
{
public int Code { get; set; }
}
}

8
PARR.API/Contracts/V1/Responses/TemplateRobotStatusResponse.cs Normal file
View File

@@ -0,0 +1,8 @@
namespace PARR.API.Contracts.V1.Responses
{
public class TemplateRobotStatusResponse : RobotStatusResponse
{
public int RobotAttemptsNumber { get; set; }
public DateTimeOffset? RobotLastStatusUpdated { get; set; }
}
}

47
PARR.API/Controllers/V1/TemplateController.cs
View File

@@ -19,14 +19,17 @@ namespace PARR.API.Controllers.V1
{
private readonly IMapper mapper;
private readonly ITemplateService templateService;
private readonly SettingsFromDb settingsFromDb;
public TemplateController(
IMapper mapper,
ITemplateService templateService
ITemplateService templateService,
SettingsFromDb settingsFromDb
)
{
this.mapper = mapper;
this.templateService = templateService;
this.settingsFromDb = settingsFromDb;
}
@@ -106,33 +109,37 @@ namespace PARR.API.Controllers.V1
{
Template? template = null;
//1.Поиск шаблонов со `StatusCode` 10 или 20 и `RobotStatusCode` = 11.Находим, **выбрали эту запись, конец**.
//2.Поиск шаблонов со `StatusCode` 10 или 20 и `RobotStatusCode` = 22
//3.Далее проверяется `RobotLastStatusUpdated`, что время последнего смены статуса не превышает допустимого(берется из настроек, поле `RobotWaitTime`) и что текущая попытка не больше разрешенной(берется из настроек, поле `RobotAttemptsNumber`) - если это так, берется эта запись.
//4.Если `RobotStatusCode` = 22 и `RobotLastStatusUpdated` истекло и `RobotAttemptsNumber` >= допустимому, то ставим `RobotStatusCode`= 33
//1.Ищем `RobotStatusCode` = 22 и `RobotLastStatusUpdated` истекло и `RobotAttemptsNumber` >= допустимого значения из настроек,
//ставим всем этим записям `RobotStatusCode`= 33
//2.Поиск шаблонов со `StatusCode` 10 или 20 и `RobotStatusCode` = 11.Находим, **выбрали эту запись, конец**.
//3.Поиск шаблонов со `StatusCode` 10 или 20 и `RobotStatusCode` = 22.
//Далее проверяется `RobotLastStatusUpdated`, что время последнего смены статуса не превышает допустимого(берется из настроек, поле `RobotWaitTime`)
//и что текущая попытка не больше разрешенной(берется из настроек, поле `RobotAttemptsNumber`) - если это так, берется эта запись.
//1.
await templateService.CheckAndSetErrorRobotStatusAsync(settingsFromDb.RobotAttemptsNumber, settingsFromDb.RobotWaitTime);
//2.
template = await templateService.GetWithIncludes()
.AsSplitQuery()
.FirstOrDefaultAsync(t => t.StatusCode == statusCode && t.RobotStatusCode == (int)RobotStatusEnum.Wait);
//if (template == null)
//{
// // переходим к шагам 2,3
// template = await templateService.GetWithIncludes()
// .AsSplitQuery()
// //todo
// .FirstOrDefaultAsync(t => t.StatusCode == statusCode && t.RobotStatusCode == (int)RobotStatusEnum.InProgress);
//}
//3.
if (template == null)
{
var endDate = DateTimeOffset.UtcNow.Add(-settingsFromDb.RobotWaitTime);
template = await templateService.GetWithIncludes()
.AsSplitQuery()
.FirstOrDefaultAsync(t =>
t.StatusCode == statusCode
&& t.RobotStatusCode == (int)RobotStatusEnum.InProgress
&& t.RobotAttemptsNumber < settingsFromDb.RobotAttemptsNumber
&& t.RobotLastStatusUpdated < endDate
);
}
////Тут узкое место, так как возвращается первый, если будет много роботов, то будет возвращаться им один и тот же элемент.
////нужно вводить статус, что эл уже занят
// template = await templateService.GetWithIncludes()
// .AsSplitQuery()
// .FirstOrDefaultAsync(t => t.StatusCode == statusCode);
if (template == null)
return NotFound();

109
PARR.API/Controllers/V1/TemplateRobotStatusController.cs Normal file
View File

@@ -0,0 +1,109 @@
using AutoMapper;
using FluentValidation;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using PARR.API.Contracts.V1;
using PARR.API.Contracts.V1.Requests;
using PARR.API.Contracts.V1.Responses;
using PARR.API.Contracts.V1.Responses.Base;
using PARR.API.Controllers.V1.Base;
using PARR.DAL.Contracts;
using PARR.DAL.Services.Interfaces;
namespace PARR.API.Controllers.V1
{
public class TemplateRobotStatusController : BaseApiController
{
private readonly IMapper mapper;
private readonly ITemplateService templateService;
private readonly IValidator<TemplateRobotStatusRequest> validator;
public TemplateRobotStatusController(
IMapper mapper,
ITemplateService templateService,
IValidator<TemplateRobotStatusRequest> validator
)
{
this.mapper = mapper;
this.templateService = templateService;
this.validator = validator;
}
/// <summary>
/// Получить статус робота по Id шаблона
/// </summary>
/// <param name="templateId"></param>
/// <returns></returns>
[HttpGet(ApiRoutes.TemplateRobotStatus.Get)]
public async Task<IActionResult> Get([FromRoute] Guid templateId)
{
var template = await templateService.Get()
.Include(t => t.RobotStatus)
.FirstOrDefaultAsync(t => t.Id == templateId);
if (template == null)
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = $"Не найден шаблон с id: {templateId}" } }));
var response = mapper.Map<TemplateRobotStatusResponse>(template);
return Ok(new Response<TemplateRobotStatusResponse>(response, true));
}
/// <summary>
/// Обновить статус робота по Id шаблона
/// </summary>
/// <param name="templateId"></param>
/// <returns></returns>
[HttpPut(ApiRoutes.TemplateRobotStatus.Update)]
public async Task<IActionResult> UpdateStatus([FromRoute] Guid templateId, [FromBody] TemplateRobotStatusRequest request)
{
var resultValidate = await validator.ValidateAsync(request);
if (!resultValidate.IsValid)
return BadRequest(new Response(resultValidate.Errors));
var template = await templateService.Get()
.FirstOrDefaultAsync(t => t.Id == templateId);
if (template == null)
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = $"Не найден шаблон с id: {templateId}" } }));
switch (request.Code)
{
case (int)RobotStatusEnum.InProgress:
template.RobotAttemptsNumber++;
template.RobotStatusCode = request.Code;
template.RobotLastStatusUpdated = DateTimeOffset.UtcNow;
break;
case (int)RobotStatusEnum.Error:
template.RobotStatusCode = request.Code;
break;
case (int)RobotStatusEnum.Complete:
template.RobotStatusCode = request.Code;
template.RobotLastStatusUpdated = DateTimeOffset.UtcNow;
break;
case (int)RobotStatusEnum.Wait:
template.RobotStatusCode = request.Code;
template.RobotLastStatusUpdated = null;
template.RobotAttemptsNumber = 0;
break;
default:
break;
}
if (!await templateService.CommitAsync())
return BadRequest(new Response(false, new List<ErrorModel> { new ErrorModel { Message = $"Ошибка при изменении статуса шаблону {templateId}" } }));
var templateToResponse = await templateService.Get()
.Include(t => t.RobotStatus)
.FirstOrDefaultAsync(t => t.Id == templateId);
var response = mapper.Map<TemplateRobotStatusResponse>(templateToResponse);
return Ok(new Response<TemplateRobotStatusResponse>(response, true));
}
}
}

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

@@ -65,6 +65,11 @@ namespace PARR.API.MappingProfiles
CreateMap<StatusTemplate, StatusTemplateResponse>();
CreateMap<Template, TemplateRobotStatusResponse>()
.ForMember(d => d.Code, o => o.MapFrom(s => s.RobotStatus!.Code))
.ForMember(d => d.Name, o => o.MapFrom(s => s.RobotStatus!.Name))
.ForMember(d => d.Description, o => o.MapFrom(s => s.RobotStatus!.Description));
CreateMap<Process, ProcessResponse>();
CreateMap<Subprocess, SubprocessResponse>();

15
PARR.API/Validators/TemplateRobotStatusRequestValidator.cs Normal file
View File

@@ -0,0 +1,15 @@
using FluentValidation;
using PARR.API.Contracts.V1.Requests;
using PARR.DAL.Contracts;
namespace PARR.API.Validators
{
public class TemplateRobotStatusRequestValidator : AbstractValidator<TemplateRobotStatusRequest>
{
public TemplateRobotStatusRequestValidator()
{
var statuses = new List<int> { (int)RobotStatusEnum.Wait, (int)RobotStatusEnum.InProgress, (int)RobotStatusEnum.Error, (int)RobotStatusEnum.Complete };
RuleFor(t => t.Code).Must(t => statuses.Contains(t)).WithMessage($"Допустимые значения: {string.Join(", ", statuses)}");
}
}
}

33
PARR.DAL/Services/Implementations/TemplateService.cs
View File

@@ -1,6 +1,7 @@
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging;
using PARR.DAL.Context;
using PARR.DAL.Contracts;
using PARR.DAL.Models;
using PARR.DAL.Services.Abstracts;
using PARR.DAL.Services.Interfaces;
@@ -41,5 +42,37 @@ namespace PARR.DAL.Services.Implementations
.ThenInclude(s => s!.Subprocess)
.ThenInclude(p => p!.Process);
}
public async Task CheckAndSetErrorRobotStatusAsync(int robotAttemptsNumber, TimeSpan robotWaitTime)
{
//Ищем `RobotStatusCode` = 22 и `RobotLastStatusUpdated` истекло и `RobotAttemptsNumber` >= допустимого значения из настроек,
//ставим всем этим записям `RobotStatusCode`= 33
var endDate = DateTimeOffset.UtcNow.Add(-robotWaitTime);
var templates = await EntitySet.Where(t =>
t.RobotStatusCode == (int)RobotStatusEnum.InProgress
&& t.RobotAttemptsNumber >= robotAttemptsNumber
&& t.RobotLastStatusUpdated <= endDate
)
.ToListAsync();
if (!templates.Any())
return;
foreach (var template in templates)
{
template.RobotStatusCode = (int)RobotStatusEnum.Error;
template.DateModified = DateTimeOffset.UtcNow;
logger.LogInformation($"Устанавливаю RobotStatus: {RobotStatusEnum.Error} для шаблона {template.Name}");
}
var result = await CommitAsync();
if (!result)
logger.LogError($"Ошибка при сохранении изменений RobotStatus у шаблонов на {RobotStatusEnum.Error}");
}
}
}

8
PARR.DAL/Services/Interfaces/ITemplateService.cs
View File

@@ -5,6 +5,14 @@ namespace PARR.DAL.Services.Interfaces
{
public interface ITemplateService : IBaseService<Template>
{
/// <summary>
/// Поиск шаблонов с просроченным временем выполнения роботом и превышенным кол-вом попыток. Установка им ошибочного статуса
/// </summary>
/// <param name="robotAttemptsNumber">Максимальное кол-во ошибок</param>
/// <param name="robotWaitTime">Максимальное время выполнения</param>
/// <returns></returns>
Task CheckAndSetErrorRobotStatusAsync(int robotAttemptsNumber, TimeSpan robotWaitTime);
Task<Template?> GetTemplateByNameAsync(string name);
IQueryable<Template> GetWithIncludes();