forked from ddrilling/AsbCloudServer
194 lines
11 KiB
C#
194 lines
11 KiB
C#
using AsbCloudApp.Data;
|
|
using AsbCloudApp.Data.SAUB;
|
|
using AsbCloudApp.Data.Subsystems;
|
|
using AsbCloudApp.Services;
|
|
using AsbCloudApp.Services.Subsystems;
|
|
using AsbCloudDb.Model;
|
|
using AsbCloudDb.Model.Subsystems;
|
|
using AsbCloudInfrastructure.Repository;
|
|
using AsbCloudInfrastructure.Services;
|
|
using AsbCloudInfrastructure.Services.Cache;
|
|
using AsbCloudInfrastructure.Services.DailyReport;
|
|
using AsbCloudInfrastructure.Services.DetectOperations;
|
|
using AsbCloudInfrastructure.Services.DrillingProgram;
|
|
using AsbCloudInfrastructure.Services.SAUB;
|
|
using AsbCloudInfrastructure.Services.Subsystems;
|
|
using AsbCloudInfrastructure.Services.WellOperationService;
|
|
using AsbCloudInfrastructure.Validators;
|
|
using FluentValidation.AspNetCore;
|
|
using Mapster;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.Extensions.Configuration;
|
|
using Microsoft.Extensions.DependencyInjection;
|
|
using System;
|
|
|
|
namespace AsbCloudInfrastructure
|
|
{
|
|
public static class DependencyInjection
|
|
{
|
|
public static IAsbCloudDbContext MakeContext(string connectionString)
|
|
{
|
|
var options = new DbContextOptionsBuilder<AsbCloudDbContext>()
|
|
.UseNpgsql(connectionString)
|
|
.Options;
|
|
var context = new AsbCloudDbContext(options);
|
|
return context;
|
|
}
|
|
|
|
public static void MapsterSetup()
|
|
{
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<DateTimeOffset, DateTime>()
|
|
.MapWith((source) => source.DateTime);
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<DateTime, DateTimeOffset>()
|
|
.MapWith((source) => source == default ? new DateTime(0, DateTimeKind.Utc) : source);
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<TimeDto, TimeOnly>()
|
|
.MapWith((source) => source == default ? default : source.MakeTimeOnly());
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<TimeOnly, TimeDto>()
|
|
.MapWith((source) => new(source));
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<TimeOnly, TimeDto>()
|
|
.MapWith((source) => new(source));
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<WellDto, Well>()
|
|
.Ignore(dst => dst.Cluster,
|
|
dst => dst.RelationCompaniesWells,
|
|
dst => dst.Telemetry,
|
|
dst => dst.WellComposites,
|
|
dst => dst.WellCompositeSrcs,
|
|
dst => dst.WellOperations,
|
|
dst => dst.WellType);
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<ClusterDto, Cluster>()
|
|
.Ignore(dst => dst.Deposit,
|
|
dst => dst.Wells);
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<FileCategoryDto, FileCategory>();
|
|
|
|
TypeAdapterConfig.GlobalSettings.Default.Config
|
|
.ForType<WellFinalDocumentDto, WellFinalDocument>();
|
|
}
|
|
|
|
public static IServiceCollection AddInfrastructure(this IServiceCollection services, IConfiguration configuration)
|
|
{
|
|
MapsterSetup();
|
|
services.AddDbContext<AsbCloudDbContext>(options =>
|
|
options.UseNpgsql(configuration.GetConnectionString("DefaultConnection")));
|
|
|
|
services.AddFluentValidation();
|
|
|
|
services.AddScoped<IAsbCloudDbContext>(provider => provider.GetService<AsbCloudDbContext>());
|
|
services.AddScoped<IEmailService, EmailService>();
|
|
|
|
services.AddHostedService<OperationDetectionBackgroundService>();
|
|
services.AddHostedService<SubsystemOperationTimeBackgroundService>();
|
|
services.AddSingleton(new WitsInfoService());
|
|
services.AddSingleton(new CacheDb());
|
|
services.AddSingleton(new InstantDataRepository());
|
|
services.AddSingleton<ITelemetryTracker, TelemetryTracker>();
|
|
services.AddSingleton<IRequerstTrackerService, RequestTrackerService>();
|
|
services.AddSingleton<IBackgroundWorkerService, BackgroundWorkerService>();
|
|
|
|
services.AddTransient<IAuthService, AuthService>();
|
|
services.AddTransient<IClusterService, ClusterService>();
|
|
services.AddTransient<IDrillFlowChartRepository, DrillFlowChartRepository>();
|
|
services.AddTransient<IDrillingProgramService, DrillingProgramService>();
|
|
services.AddTransient<IDrillParamsService, DrillParamsService>();
|
|
services.AddTransient<IEventService, EventService>();
|
|
services.AddTransient<IFileService, FileService>();
|
|
services.AddTransient<IMeasureService, MeasureService>();
|
|
services.AddTransient<IMessageService, MessageService>();
|
|
services.AddTransient<IOperationsStatService, OperationsStatService>();
|
|
services.AddTransient<IReportService, ReportService>();
|
|
services.AddTransient<ISetpointsService, SetpointsService>();
|
|
services.AddTransient<ITelemetryService, TelemetryService>();
|
|
services.AddTransient<ITelemetryUserService, TelemetryUserService>();
|
|
services.AddTransient<ITimezoneService, TimezoneService>();
|
|
services.AddTransient<IUserService, UserService>();
|
|
services.AddTransient<IUserRoleService, UserRoleService>();
|
|
services.AddTransient<IWellService, WellService>();
|
|
services.AddTransient<IWellCompositeService, WellCompositeService>();
|
|
services.AddTransient<IWellOperationImportService, WellOperationImportService>();
|
|
services.AddTransient<IWellOperationService, WellOperationService>();
|
|
services.AddTransient<IScheduleReportService, ScheduleReportService>();
|
|
services.AddTransient<IDailyReportService, DailyReportService>();
|
|
services.AddTransient<IDetectedOperationService, DetectedOperationService>();
|
|
services.AddTransient<IDrillerService, DrillerService>();
|
|
|
|
services.AddTransient<ISubsystemOperationTimeService, SubsystemOperationTimeService>();
|
|
services.AddTransient<IScheduleRepository, ScheduleRepository>();
|
|
services.AddTransient<IRepositoryWellRelated<OperationValueDto>, CrudWellRelatedServiceBase<OperationValueDto, OperationValue>>();
|
|
services.AddTransient<IUserSettingsRepository, UserSettingsRepository>();
|
|
services.AddTransient<IWellFinalDocumentsService, WellFinalDocumentsService>();
|
|
services.AddTransient<IFileCategoryService, FileCategoryService>();
|
|
|
|
// admin crud services:
|
|
services.AddTransient<ICrudService<TelemetryDto>, CrudServiceBase<TelemetryDto, Telemetry>>(s =>
|
|
new CrudCacheServiceBase<TelemetryDto, Telemetry>(
|
|
s.GetService<IAsbCloudDbContext>(),
|
|
dbSet => dbSet.Include(t => t.Well))); // может быть включен в сервис TelemetryService
|
|
services.AddTransient<ICrudService<DrillParamsDto>, DrillParamsService>();
|
|
services.AddTransient<ICrudService<DepositDto>, CrudCacheServiceBase<DepositDto, Deposit>>(s =>
|
|
new CrudCacheServiceBase<DepositDto, Deposit>(
|
|
s.GetService<IAsbCloudDbContext>(),
|
|
dbSet => dbSet.Include(d => d.Clusters)));
|
|
services.AddTransient<ICrudService<CompanyDto>, CrudCacheServiceBase<CompanyDto, Company>>(s =>
|
|
new CrudCacheServiceBase<CompanyDto, Company>(
|
|
s.GetService<IAsbCloudDbContext>(),
|
|
dbSet => dbSet.Include(c => c.CompanyType)));
|
|
|
|
services.AddTransient<ICrudService<CompanyTypeDto>, CrudCacheServiceBase<CompanyTypeDto, CompanyType>>();
|
|
services.AddTransient<ICrudService<ClusterDto>, CrudCacheServiceBase<ClusterDto, Cluster>>(s =>
|
|
new CrudCacheServiceBase<ClusterDto, Cluster>(
|
|
s.GetService<IAsbCloudDbContext>(),
|
|
dbSet => dbSet
|
|
.Include(c => c.Wells)
|
|
.Include(c => c.Deposit))); // может быть включен в сервис ClusterService
|
|
// Subsystem service
|
|
services.AddTransient<ICrudService<SubsystemDto>, CrudCacheServiceBase<SubsystemDto, Subsystem>>();
|
|
services.AddTransient<ISubsystemService, SubsystemService>();
|
|
|
|
services.AddTransient<ICrudService<PermissionDto>, CrudCacheServiceBase<PermissionDto, Permission>>();
|
|
|
|
// TelemetryData services
|
|
services.AddTransient<ITelemetryDataService<TelemetryDataSaubDto>, TelemetryDataSaubService>();
|
|
services.AddTransient<ITelemetryDataService<TelemetryDataSpinDto>, TelemetryDataSpinService>();
|
|
|
|
// Wits
|
|
services.AddTransient<IWitsRecordRepository<AsbCloudApp.Data.WITS.Record1Dto>, WitsRecordRepository<AsbCloudApp.Data.WITS.Record1Dto, AsbCloudDb.Model.WITS.Record1>>();
|
|
services.AddTransient<IWitsRecordRepository<AsbCloudApp.Data.WITS.Record7Dto>, WitsRecordRepository<AsbCloudApp.Data.WITS.Record7Dto, AsbCloudDb.Model.WITS.Record7>>();
|
|
services.AddTransient<IWitsRecordRepository<AsbCloudApp.Data.WITS.Record8Dto>, WitsRecordRepository<AsbCloudApp.Data.WITS.Record8Dto, AsbCloudDb.Model.WITS.Record8>>();
|
|
services.AddTransient<IWitsRecordRepository<AsbCloudApp.Data.WITS.Record50Dto>, WitsRecordRepository<AsbCloudApp.Data.WITS.Record50Dto, AsbCloudDb.Model.WITS.Record50>>();
|
|
services.AddTransient<IWitsRecordRepository<AsbCloudApp.Data.WITS.Record60Dto>, WitsRecordRepository<AsbCloudApp.Data.WITS.Record60Dto, AsbCloudDb.Model.WITS.Record60>>();
|
|
services.AddTransient<IWitsRecordRepository<AsbCloudApp.Data.WITS.Record61Dto>, WitsRecordRepository<AsbCloudApp.Data.WITS.Record61Dto, AsbCloudDb.Model.WITS.Record61>>();
|
|
|
|
services.AddValidators();
|
|
|
|
return services;
|
|
}
|
|
|
|
public static IServiceCollection AddTransientLazy<TService, TImplementation>(this IServiceCollection services)
|
|
where TService : class
|
|
where TImplementation : class, TService
|
|
=> services.AddTransient<TService, TImplementation>()
|
|
.AddTransient(provider => new Lazy<TService>(provider.GetService<TService>));
|
|
|
|
public static IServiceCollection AddTransientLazy<TService, TImplementation>(this IServiceCollection services, Func<IServiceProvider, TImplementation> implementationFactory)
|
|
where TService : class
|
|
where TImplementation : class, TService
|
|
=> services.AddTransient<TService, TImplementation>(implementationFactory)
|
|
.AddTransient(provider => new Lazy<TService>(() => implementationFactory(provider)));
|
|
|
|
}
|
|
}
|