process fix
This commit is contained in:
@@ -255,8 +255,8 @@ namespace WebAPI.Controllers
|
|||||||
cp.process(sourceLayer, processWorker?.Id);
|
cp.process(sourceLayer, processWorker?.Id);
|
||||||
break;
|
break;
|
||||||
case "Deaggregation":
|
case "Deaggregation":
|
||||||
DeaggregationProcessor dp = new DeaggregationProcessor(db, googleSheetValues, this);
|
//DeaggregationProcessor dp = new DeaggregationProcessor(db, googleSheetValues, this);
|
||||||
dp.process(sourceLayer, processWorker?.Id);
|
//dp.process(sourceLayer, processWorker?.Id);
|
||||||
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -114,6 +114,7 @@ namespace WebAPI.dataProcessors
|
|||||||
});
|
});
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
List<Record> newRecords = new List<Record>();
|
||||||
foreach (Record source in dataSource.Records!)
|
foreach (Record source in dataSource.Records!)
|
||||||
{
|
{
|
||||||
Record record = new Record
|
Record record = new Record
|
||||||
@@ -124,7 +125,7 @@ namespace WebAPI.dataProcessors
|
|||||||
CreatedAt = DateTime.UtcNow,
|
CreatedAt = DateTime.UtcNow,
|
||||||
ModifiedAt = DateTime.UtcNow
|
ModifiedAt = DateTime.UtcNow
|
||||||
};
|
};
|
||||||
processedLayer.Records.Add(record);
|
newRecords.Add(record);
|
||||||
}
|
}
|
||||||
if (isNew)
|
if (isNew)
|
||||||
{
|
{
|
||||||
@@ -133,7 +134,7 @@ namespace WebAPI.dataProcessors
|
|||||||
{
|
{
|
||||||
db.Layers.Update(processedLayer);
|
db.Layers.Update(processedLayer);
|
||||||
}
|
}
|
||||||
controller.SaveRecords(processedLayer.Id, processedLayer.Records, Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"));
|
controller.SaveRecords(processedLayer.Id, newRecords, Guid.Parse("F392209E-123E-4651-A5A4-0B1D6CF9FF9D"));
|
||||||
db.SaveChanges();
|
db.SaveChanges();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user