on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

fix telemetry user id mapping

Browse Source
This commit is contained in:
Фролов 2021-09-03 11:35:49 +05:00
parent 187c83a7b1
commit 16bd6749fd
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
AsbCloudInfrastructure/Services/DataService.cs
View File

@ -18,6 +18,7 @@ namespace AsbCloudInfrastructure.Services
private readonly ITelemetryService telemetryService; private readonly ITelemetryService telemetryService;
private readonly ITelemetryAnalyticsService analyticsService; private readonly ITelemetryAnalyticsService analyticsService;
private readonly CacheTable<Telemetry> cacheTelemetry; private readonly CacheTable<Telemetry> cacheTelemetry;
private readonly CacheTable<TelemetryUser> cacheTelemetryUsers;
private readonly CacheTable<Well> cacheWells; private readonly CacheTable<Well> cacheWells;
public DataService(IAsbCloudDbContext db, ITelemetryService telemetryService, public DataService(IAsbCloudDbContext db, ITelemetryService telemetryService,
@ -27,6 +28,7 @@ namespace AsbCloudInfrastructure.Services
this.telemetryService = telemetryService; this.telemetryService = telemetryService;
this.analyticsService = analyticsService; this.analyticsService = analyticsService;
cacheTelemetry = cacheDb.GetCachedTable<Telemetry>((AsbCloudDbContext)db); cacheTelemetry = cacheDb.GetCachedTable<Telemetry>((AsbCloudDbContext)db);
cacheTelemetryUsers = cacheDb.GetCachedTable<TelemetryUser>((AsbCloudDbContext)db);
cacheWells = cacheDb.GetCachedTable<Well>((AsbCloudDbContext)db); cacheWells = cacheDb.GetCachedTable<Well>((AsbCloudDbContext)db);
} }
@ -94,10 +96,13 @@ namespace AsbCloudInfrastructure.Services
if (oldDataSaubBase.Any()) if (oldDataSaubBase.Any())
db.DataSaubBases.RemoveRange(oldDataSaubBase); db.DataSaubBases.RemoveRange(oldDataSaubBase);
foreach (var dto in dtos) foreach (var dto in dtos)
{ {
var dataSaub = dto.Adapt<DataSaubBase>(); var dataSaub = dto.Adapt<DataSaubBase>();
var telemetryUser = await cacheTelemetryUsers
.FirstOrDefaultAsync(u => u.IdTelemetry == telemetryId && (u.Name == dto.User || u.Surname == dto.User), token)
.ConfigureAwait(false);
dataSaub.IdUser = telemetryUser?.IdUser;
dataSaub.IdTelemetry = telemetryId; dataSaub.IdTelemetry = telemetryId;
db.DataSaubBases.Add(dataSaub); db.DataSaubBases.Add(dataSaub);