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

Add some fields into dtos to make possible assign telemetry to well.

Browse Source
This commit is contained in:
Фролов 2021-12-17 13:07:45 +05:00
parent 31b671a0c7
commit 9bb1cc5abc
3 changed files with 2 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
AsbCloudApp/Data/TelemetryDto.cs
View File

@ -5,5 +5,6 @@
public int Id { get; set; }
public string RemoteUid { get; set; }
public TelemetryInfoDto Info { get; set; }
public WellDto Well { get; set; }
}
}

1
AsbCloudApp/Data/WellDto.cs
View File

@ -20,6 +20,7 @@ namespace AsbCloudApp.Data
/// </summary>
public int IdState { get; set; }
public DateTime LastTelemetryDate { get; set; }
public int? IdTelemetry { get; set; }
public TelemetryDto Telemetry { get; set; }
}
}

25
AsbCloudInfrastructure/Services/TelemetryService.cs
View File

@ -377,30 +377,5 @@ namespace AsbCloudInfrastructure.Services
return affected;
}
//todo: delete this
private async Task<int> MergeDataAsync_old<TEntity>(int from, int to, CancellationToken token)
where TEntity : class, AsbCloudDb.Model.ITelemetryData
{
var dbSet = db.Set<TEntity>();
var entitiesFromQuery = dbSet.Where(d => d.IdTelemetry == from);
var entitiesFrom = await entitiesFromQuery
.AsNoTracking()
.ToListAsync(token)
.ConfigureAwait(false);
dbSet.RemoveRange(entitiesFromQuery);
var affected = await db.SaveChangesAsync(token)
.ConfigureAwait(false);
entitiesFrom.ForEach(d => d.IdTelemetry = to);
dbSet.AddRange(entitiesFrom);
affected += await db.SaveChangesAsync(token)
.ConfigureAwait(false);
return affected;
}
}
}