D1 Process worker fix

This commit is contained in:
Michał Zieliński
2025-06-10 18:37:11 +02:00
parent 80072dca59
commit 0c7ea660e8
5 changed files with 16 additions and 31 deletions

View File

@@ -261,6 +261,8 @@ public class MorskaT5LastValuesProcessor : MorskaBaseProcessor
ProcessHelper.SetValue(processedRecord, i, value);
}
}
processedRecord.Desc1 = lastRecord.Desc1;
return processedRecord;
}

View File

@@ -277,7 +277,6 @@ public class LayersController : Controller
x.Name != null && x.Name.Contains(nameFilter) &&
x.Records!.Any(y => y.Code == "Type" && y.Desc1 == "ImportWorker") &&
x.Records!.Any(y => y.Code == "IsEnabled" && y.Desc1 == "True"
&& x.Number == 5375
)
)
.OrderByDescending(x => x.CreatedAt)
@@ -330,12 +329,12 @@ public class LayersController : Controller
switch (type)
{
case "D1":
var d1importer = _pluginManager.GetImporter(plugin);
if (d1importer == null)
var d1Importer = _pluginManager.GetImporter(plugin);
if (d1Importer == null)
{
throw new Exception("MorskaD1 importer not found");
}
d1importer.Import(importWorker);
d1Importer.Import(importWorker);
Thread.Sleep(5000); // be aware of GSheet API quota
_logger.LogInformation("AutoImport: Successfully processed D1 import for {LayerName} ({LayerId})",
@@ -343,12 +342,12 @@ public class LayersController : Controller
break;
case "FK2":
var fk2importer = _pluginManager.GetImporter(plugin);
if (fk2importer == null)
var fk2Importer = _pluginManager.GetImporter(plugin);
if (fk2Importer == null)
{
throw new Exception("MorskaFK2 importer not found");
}
fk2importer.Import(importWorker);
fk2Importer.Import(importWorker);
Thread.Sleep(5000); // be aware of GSheet API quota
_logger.LogInformation("AutoImport: Successfully processed FK2 import for {LayerName} ({LayerId})",

View File

@@ -31,10 +31,6 @@
</Content>
</ItemGroup>
<ItemGroup>
<Folder Include="plugins\" />
</ItemGroup>
<Target Name="CopyPlugins" AfterTargets="Build">
<MSBuild Projects="../DiunaBI.Plugins.Morska/DiunaBI.Plugins.Morska.csproj" Properties="Configuration=$(Configuration);TargetFramework=$(TargetFramework)" />