Skip to content

Commit

Permalink
#1351 Refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
bolsson committed Oct 26, 2023
1 parent 9c9b3d3 commit 623ce54
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions Assessments.Transformation/PublishDynamicProperties.cs
Original file line number Diff line number Diff line change
Expand Up @@ -110,16 +110,16 @@ public static async Task UploadDynamicPropertiesToTaxonApi(IConfigurationRoot co

//// GET dynamicProperties from RavenDb pertaining alien species 2023 assessments
//var queryAlienSpecies2023 = ravenSession.Advanced.DocumentQuery<DynamicProperty>("Raven/DocumentsByEntityName")
// .WhereStartsWith("__document_id", "DynamicProperty/FremmedArt2023-");
// .WhereStartsWith("__document_id", "DynamicProperty/FremmedArt2023-").ToList();

//var queryRedlistedSpecies2021 = ravenSession.Advanced.DocumentQuery<DynamicProperty>("Raven/DocumentsByEntityName")
// .WhereStartsWith("__document_id", "DynamicProperty/Rodliste2021-");
// .WhereStartsWith("__document_id", "DynamicProperty/Rodliste2021-").ToList();

//var existingDynamicProperties = queryAlienSpecies2023.Union(queryRedlistedSpecies2021).ToList(); // = 0
//var existingDynamicProperties = queryAlienSpecies2023.Union(queryRedlistedSpecies2021).ToList();

////TODO: Delete this list of dynamicProperties from RavenDb
//var obsoleteDynamicProperties = newDynamicProperties.Except(existingDynamicProperties).ToList();


//Store DynamicProperties in RavenDb
foreach (var dynamicProperty in newDynamicProperties)
Expand All @@ -138,12 +138,12 @@ private static void DeleteDocumentsById(string[] toDeleteDocumentIds, IDocumentS
var errorcount = 0;
while (true)
{
var batch = toDeleteDocumentIds.Skip(pointer).Take(Batchsize).Distinct().ToArray();
if (!batch.Any()) break;
var batchIdsToDelete = toDeleteDocumentIds.Skip(pointer).Take(Batchsize).Distinct().ToArray();
if (!batchIdsToDelete.Any()) break;
try
{
//var ses = this.DocumentCacheStore.Session;
var commandlist = batch.Select(deletedRecordId => new DeleteCommandData { Key = deletedRecordId })
var commandlist = batchIdsToDelete.Select(deletedRecordId => new DeleteCommandData { Key = deletedRecordId })
.Cast<ICommandData>().ToList();
using (var session = documentstore.OpenSession())
{
Expand Down

0 comments on commit 623ce54

Please sign in to comment.