DD.WellWorkover.Cloud/AsbCloudInfrastructure/Services/ProcessMaps/ProcessMapPlanService.cs

using AsbCloudApp.Data;
using AsbCloudApp.Data.ProcessMaps;
using AsbCloudApp.Repositories;
using AsbCloudApp.Requests;
using AsbCloudApp.Services;
using System.Collections.Generic;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Threading;
using System.Threading.Tasks;

namespace AsbCloudInfrastructure.Services.ProcessMaps;

public class ProcessMapPlanService<T> : AsbCloudApp.Services.ProcessMaps.IProcessMapPlanService<T>
    where T : AsbCloudApp.Data.ProcessMapPlan.ProcessMapPlanBaseDto
{
    private readonly ICrudRepository<WellSectionTypeDto> wellSectionTypeRepository;
    private readonly IChangeLogRepository<T, ProcessMapPlanBaseRequestWithWell> processMapPlanBaseRepository;
    private readonly IRepositoryWellRelated<WellSectionPlanDto> wellSectionPlanRepository;

    public ProcessMapPlanService(
        ICrudRepository<WellSectionTypeDto> wellSectionTypeRepository,
        IChangeLogRepository<T, ProcessMapPlanBaseRequestWithWell> processMapPlanBaseRepository,
        IRepositoryWellRelated<WellSectionPlanDto> wellSectionPlanRepository)
    {
        this.wellSectionTypeRepository = wellSectionTypeRepository;
        this.processMapPlanBaseRepository = processMapPlanBaseRepository;
        this.wellSectionPlanRepository = wellSectionPlanRepository;
    }

    public async Task<IEnumerable<ValidationResultDto<T>>> GetAsync(int idWell, CancellationToken cancellationToken)
    {
        var wellSectionTypes = await wellSectionTypeRepository.GetAllAsync(cancellationToken);

        var request = new ProcessMapPlanBaseRequestWithWell(idWell);

        var processMapsPlan = await processMapPlanBaseRepository.Get(request, cancellationToken);

        var wellSectionsPlan = await wellSectionPlanRepository.GetByIdWellAsync(idWell, cancellationToken);

        return processMapsPlan.Select(processMapPlan =>
        {
            var wellSectionPlan = wellSectionsPlan.FirstOrDefault(s => s.IdSectionType == processMapPlan.IdWellSectionType);

            var isValid = wellSectionPlan is not null && wellSectionPlan.DepthStart <= processMapPlan.DepthStart &&
                        wellSectionPlan.DepthEnd >= processMapPlan.DepthEnd;

            var validationResult = new ValidationResultDto<T>
            {
                Item = processMapPlan
            };

            if (isValid)
                return validationResult;

            var wellSectionType = wellSectionTypes.FirstOrDefault(s => s.Id == processMapPlan.IdWellSectionType);

            validationResult.Warnings = new ValidationResult[]
            {
                new($"Конструкция секции: {wellSectionType?.Caption}; " +
                    $"Интервал бурения от {processMapPlan.DepthStart} до {processMapPlan.DepthEnd} не совпадает с данными указанными на странице " +
                    $"Конструкция скважины / План", new[] { nameof(processMapPlan.DepthStart), nameof(processMapPlan.DepthEnd) })
            };

            return validationResult;
        });
    }
}