Morska plugins refactor

This commit is contained in:
2025-12-02 21:24:37 +01:00
parent 3f8e62fbb8
commit 445c07a8d8
21 changed files with 56 additions and 53 deletions

View File

@@ -2,9 +2,9 @@
DECLARE @JustForDebug TINYINT = 0; DECLARE @JustForDebug TINYINT = 0;
-- SETUP VARIABLES -- SETUP VARIABLES
DECLARE @Number INT = (SELECT COUNT(id) + 1 FROM [diunabi-morska].[dbo].[Layers]); DECLARE @Number INT = (SELECT COUNT(id) + 1 FROM [DiunaBI-PedrolloPL].[dbo].[Layers]);
DECLARE @Name NVARCHAR(50) = CONCAT( DECLARE @Name NVARCHAR(50) = CONCAT(
'L', @Number, '-D-D6-SELL-CODES' 'L', @Number, 'D-P2-CODES'
); );
DECLARE @LayerId UNIQUEIDENTIFIER = NEWID(); DECLARE @LayerId UNIQUEIDENTIFIER = NEWID();
@@ -16,7 +16,7 @@ BEGIN
RETURN; RETURN;
END; END;
INSERT INTO [diunabi-morska].[dbo].[Layers] INSERT INTO [DiunaBI-PedrolloPL].[dbo].[Layers]
([Id], [Number], [Name], [CreatedAt], [ModifiedAt], [IsDeleted], [CreatedById], [ModifiedById], [Type]) ([Id], [Number], [Name], [CreatedAt], [ModifiedAt], [IsDeleted], [CreatedById], [ModifiedById], [Type])
VALUES (@LayerId, @Number, @Name, GETDATE(), GETDATE(), 0, '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 3); VALUES (@LayerId, @Number, @Name, GETDATE(), GETDATE(), 0, '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 3);
@@ -27,16 +27,23 @@ DECLARE @Array TABLE (
INSERT INTO @Array (Code, Desc1) INSERT INTO @Array (Code, Desc1)
VALUES VALUES
('1002', '1102'), ('01','<nieznany>'),
('1003','1202'), ('02','DOLNOŚLĄSKIE'),
('1008','1302'), ('03','KUJAWSKO-POMORSKIE'),
('1009','1302'), ('04','LUBELSKIE'),
('9085','1203'), ('05','LUBUSKIE'),
('1010','1304'), ('06','ŁÓDZKIE'),
('9086','1005'), ('07','MAŁOPOLSKIE'),
('1021','1206'), ('08','MAZOWIECKIE'),
('9089','1207'), ('09','OPOLSKIE'),
('9091','1208') ('10','PODKARPACKIE'),
('11','PODLASKIE'),
('12','POMORSKIE'),
('13','ŚLĄSKIE'),
('14','ŚWIĘTOKRZYSKIE'),
('15','WARMIŃSKO-MAZURSKIE'),
('16','WIELKOPOLSKIE'),
('17','ZACHODNIOPOMORSKIE');
-- Loop through the array and insert into the target table -- Loop through the array and insert into the target table
DECLARE @Code NVARCHAR(50); DECLARE @Code NVARCHAR(50);
@@ -51,7 +58,7 @@ FETCH NEXT FROM CursorArray INTO @Code, @Desc1;
WHILE @@FETCH_STATUS = 0 WHILE @@FETCH_STATUS = 0
BEGIN BEGIN
INSERT INTO [diunabi-morska].[dbo].[Records] INSERT INTO [DiunaBI-PedrolloPL].[dbo].[Records]
([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId]) ([Id], [Code], [Desc1], [CreatedAt], [ModifiedAt], [CreatedById], [ModifiedById], [IsDeleted], [LayerId])
VALUES (NEWID(), @Code, @Desc1, GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, @LayerId); VALUES (NEWID(), @Code, @Desc1, GETDATE(), GETDATE(), '117be4f0-b5d1-41a1-a962-39dc30cce368', '117be4f0-b5d1-41a1-a962-39dc30cce368', 0, @LayerId);

View File

@@ -1,7 +0,0 @@
using DiunaBI.Infrastructure.Plugins;
namespace DiunaBI.Plugins.Morska.Exporters;
public abstract class MorskaBaseExporter : BaseDataExporter
{
}

View File

@@ -1,5 +1,6 @@
using System.Globalization; using System.Globalization;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Google.Apis.Sheets.v4.Data; using Google.Apis.Sheets.v4.Data;
@@ -7,7 +8,7 @@ using Microsoft.Extensions.Configuration;
namespace DiunaBI.Plugins.Morska.Exporters; namespace DiunaBI.Plugins.Morska.Exporters;
public class GoogleSheetExport : MorskaBaseExporter public class GoogleSheetExport : BaseDataExporter
{ {
public override string ExporterType => "GoogleSheet"; public override string ExporterType => "GoogleSheet";
private readonly GoogleDriveHelper _googleDriveHelper; private readonly GoogleDriveHelper _googleDriveHelper;

View File

@@ -1,7 +0,0 @@
using DiunaBI.Infrastructure.Plugins;
namespace DiunaBI.Plugins.Morska.Importers;
public abstract class MorskaBaseImporter : BaseDataImporter
{
}

View File

@@ -1,6 +1,7 @@
using System.Globalization; using System.Globalization;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
@@ -8,7 +9,7 @@ using Microsoft.EntityFrameworkCore;
namespace DiunaBI.Plugins.Morska.Importers; namespace DiunaBI.Plugins.Morska.Importers;
public class MorskaD1Importer : MorskaBaseImporter public class MorskaD1Importer : BaseDataImporter
{ {
public override string ImporterType => "Morska.Import.D1"; public override string ImporterType => "Morska.Import.D1";

View File

@@ -3,6 +3,7 @@ using System.Text;
using System.Text.Json; using System.Text.Json;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
@@ -11,7 +12,7 @@ using Google.Apis.Sheets.v4.Data;
namespace DiunaBI.Plugins.Morska.Importers; namespace DiunaBI.Plugins.Morska.Importers;
public class MorskaD3Importer : MorskaBaseImporter public class MorskaD3Importer : BaseDataImporter
{ {
public override string ImporterType => "Morska.Import.D3"; public override string ImporterType => "Morska.Import.D3";

View File

@@ -1,13 +1,14 @@
using System.Globalization; using System.Globalization;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
namespace DiunaBI.Plugins.Morska.Importers; namespace DiunaBI.Plugins.Morska.Importers;
public class MorskaFk2Importer : MorskaBaseImporter public class MorskaFk2Importer : BaseDataImporter
{ {
public override string ImporterType => "Morska.Import.FK2"; public override string ImporterType => "Morska.Import.FK2";

View File

@@ -1,6 +1,7 @@
using System.Globalization; using System.Globalization;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
@@ -8,7 +9,7 @@ using Microsoft.EntityFrameworkCore;
namespace DiunaBI.Plugins.Morska.Importers; namespace DiunaBI.Plugins.Morska.Importers;
public class MorskaStandardImporter : MorskaBaseImporter public class MorskaStandardImporter : BaseDataImporter
{ {
public override string ImporterType => "Morska.Import.Standard"; public override string ImporterType => "Morska.Import.Standard";

View File

@@ -1,7 +0,0 @@
using DiunaBI.Infrastructure.Plugins;
namespace DiunaBI.Plugins.Morska.Processors;
public abstract class MorskaBaseProcessor : BaseDataProcessor
{
}

View File

@@ -2,6 +2,7 @@
using System.Text.RegularExpressions; using System.Text.RegularExpressions;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services.Calculations; using DiunaBI.Infrastructure.Services.Calculations;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Google.Apis.Sheets.v4.Data; using Google.Apis.Sheets.v4.Data;
@@ -10,7 +11,7 @@ using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaD6Processor : MorskaBaseProcessor public class MorskaD6Processor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.D6"; public override string ProcessorType => "Morska.Process.D6";

View File

@@ -1,6 +1,7 @@
using System.Globalization; using System.Globalization;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using DiunaBI.Infrastructure.Services.Calculations; using DiunaBI.Infrastructure.Services.Calculations;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
@@ -10,7 +11,7 @@ using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT1R1Processor : MorskaBaseProcessor public class MorskaT1R1Processor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T1.R1"; public override string ProcessorType => "Morska.Process.T1.R1";

View File

@@ -2,6 +2,7 @@
using System.Text.RegularExpressions; using System.Text.RegularExpressions;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Google.Apis.Sheets.v4.Data; using Google.Apis.Sheets.v4.Data;
@@ -10,7 +11,7 @@ using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT1R3Processor : MorskaBaseProcessor public class MorskaT1R3Processor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T1.R3"; public override string ProcessorType => "Morska.Process.T1.R3";

View File

@@ -1,12 +1,13 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT3MultiSourceCopySelectedCodesProcessor : MorskaBaseProcessor public class MorskaT3MultiSourceCopySelectedCodesProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "T3.MultiSourceCopySelectedCodes"; public override string ProcessorType => "T3.MultiSourceCopySelectedCodes";

View File

@@ -1,12 +1,13 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT3MultiSourceCopySelectedCodesYearSummaryProcessor : MorskaBaseProcessor public class MorskaT3MultiSourceCopySelectedCodesYearSummaryProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "T3.MultiSourceCopySelectedCodesYearSummary"; public override string ProcessorType => "T3.MultiSourceCopySelectedCodesYearSummary";

View File

@@ -1,5 +1,6 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using DiunaBI.Infrastructure.Services.Calculations; using DiunaBI.Infrastructure.Services.Calculations;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
@@ -7,7 +8,7 @@ using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT3MultiSourceSummaryProcessor : MorskaBaseProcessor public class MorskaT3MultiSourceSummaryProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T3.MultiSourceSummary"; public override string ProcessorType => "Morska.Process.T3.MultiSourceSummary";

View File

@@ -1,5 +1,6 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using DiunaBI.Infrastructure.Services.Calculations; using DiunaBI.Infrastructure.Services.Calculations;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
@@ -7,7 +8,7 @@ using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT3MultiSourceYearSummaryProcessor : MorskaBaseProcessor public class MorskaT3MultiSourceYearSummaryProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T3.MultiSourceYearSummary"; public override string ProcessorType => "Morska.Process.T3.MultiSourceYearSummary";

View File

@@ -1,13 +1,14 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT3SingleSourceProcessor : MorskaBaseProcessor public class MorskaT3SingleSourceProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T3.SingleSource"; public override string ProcessorType => "Morska.Process.T3.SingleSource";

View File

@@ -1,5 +1,6 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
@@ -7,7 +8,7 @@ using Google.Apis.Sheets.v4;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT3SourceYearSummaryProcessor : MorskaBaseProcessor public class MorskaT3SourceYearSummaryProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T3.SourceYearSummary"; public override string ProcessorType => "Morska.Process.T3.SourceYearSummary";

View File

@@ -1,6 +1,7 @@
using System.Globalization; using System.Globalization;
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
using Google.Apis.Sheets.v4.Data; using Google.Apis.Sheets.v4.Data;
@@ -9,7 +10,7 @@ using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT4R2Processor : MorskaBaseProcessor public class MorskaT4R2Processor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T4.R2"; public override string ProcessorType => "Morska.Process.T4.R2";

View File

@@ -1,12 +1,13 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using Google.Apis.Sheets.v4; using Google.Apis.Sheets.v4;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT4SingleSourceProcessor : MorskaBaseProcessor public class MorskaT4SingleSourceProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T4.SingleSource"; public override string ProcessorType => "Morska.Process.T4.SingleSource";

View File

@@ -1,12 +1,13 @@
using DiunaBI.Domain.Entities; using DiunaBI.Domain.Entities;
using DiunaBI.Infrastructure.Data; using DiunaBI.Infrastructure.Data;
using DiunaBI.Infrastructure.Plugins;
using DiunaBI.Infrastructure.Services; using DiunaBI.Infrastructure.Services;
using Microsoft.EntityFrameworkCore; using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
namespace DiunaBI.Plugins.Morska.Processors; namespace DiunaBI.Plugins.Morska.Processors;
public class MorskaT5LastValuesProcessor : MorskaBaseProcessor public class MorskaT5LastValuesProcessor : BaseDataProcessor
{ {
public override string ProcessorType => "Morska.Process.T5.LastValues"; public override string ProcessorType => "Morska.Process.T5.LastValues";