diff --git a/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java b/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java index da48710..9045599 100644 --- a/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java +++ b/src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java @@ -26,6 +26,8 @@ public class CreditTrackerSettings { @NestedConfigurationProperty private PipelineSettings pipeline; @NestedConfigurationProperty + private PipelineSettings lpPipeline; + @NestedConfigurationProperty private FlagUpdaterSettings flagUpdater; @NestedConfigurationProperty private KafkaConsumerSettings kafkaConsumerSettings; diff --git a/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java b/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java index b413f1e..bbd26dc 100644 --- a/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java +++ b/src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java @@ -30,6 +30,7 @@ import ru.nbch.credit_tracker.model.ValidationResult; import ru.nbch.credit_tracker.service.UserPackageService; import ru.nbch.credit_tracker.service.scoring.AuthorizationService; import ru.nbch.credit_tracker.service.signal.SignalRestService; +import ru.nbch.credit_tracker.service.task.LpPipelinePackageFabric; import ru.nbch.credit_tracker.service.task.NpPipelinePackageFabric; import ru.nbch.credit_tracker.service.task.PipelinePackageOrchestrator; import ru.nbch.credit_tracker.service.task.SetupParam; @@ -65,6 +66,7 @@ public class SignalFacade { private final UserPackageService userPackageService; private final AuthorizationService authorizationService; private final NpPipelinePackageFabric npPipelinePackageFabric; + private final LpPipelinePackageFabric lpPipelinePackageFabric; private final SignalRestService signalRestService; private final Saver saver; private final PipelinePackageOrchestrator pipelineOrchestrator; @@ -75,6 +77,7 @@ public class SignalFacade { UserPackageService userPackageService, AuthorizationService authorizationService, NpPipelinePackageFabric npPipelinePackageManager, + LpPipelinePackageFabric lpPipelinePackageFabric, SignalRestService signalRestService, Saver saver, PipelinePackageOrchestrator pipelineOrchestrator) { this.monitoringRequestValidator = monitoringRequestValidator; @@ -82,6 +85,7 @@ public class SignalFacade { this.userPackageService = userPackageService; this.authorizationService = authorizationService; this.npPipelinePackageFabric = npPipelinePackageManager; + this.lpPipelinePackageFabric = lpPipelinePackageFabric; this.signalRestService = signalRestService; this.saver = saver; this.pipelineOrchestrator = pipelineOrchestrator; @@ -159,7 +163,7 @@ public class SignalFacade { CtFileUtils.deleteQuietly(parsedFilePath); }, pipeline, packageId); } else { - Pipeline pipeline = npPipelinePackageFabric.build(new SetupParam(packageId, parsedFilePath, PipelineMode.DEFAULT)); + Pipeline pipeline = lpPipelinePackageFabric.build(new SetupParam(packageId, parsedFilePath, PipelineMode.DEFAULT)); pipelineOrchestrator.startOrDelay(() -> { saver.readAndSaveLpPackage(packageId, parsedFilePath); CtFileUtils.deleteQuietly(parsedFilePath); diff --git a/src/main/java/ru/nbch/credit_tracker/service/task/LpPipelinePackageFabric.java b/src/main/java/ru/nbch/credit_tracker/service/task/LpPipelinePackageFabric.java new file mode 100644 index 0000000..004f3ca --- /dev/null +++ b/src/main/java/ru/nbch/credit_tracker/service/task/LpPipelinePackageFabric.java @@ -0,0 +1,27 @@ +package ru.nbch.credit_tracker.service.task; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.InitializingBean; +import org.springframework.stereotype.Component; +import ru.nbch.credit_tracker.config.settings.CreditTrackerSettings; +import ru.nbch.pipeline.engine.core.Pipeline; + +@Slf4j +@Component +public class LpPipelinePackageFabric implements InitializingBean { + + private final CreditTrackerSettings creditTrackerSettings; + + public LpPipelinePackageFabric(CreditTrackerSettings creditTrackerSettings) { + this.creditTrackerSettings = creditTrackerSettings; + } + + public Pipeline build(SetupParam setupParam) throws Exception { + return null; + } + + @Override + public void afterPropertiesSet() throws Exception { + log.info("pipeline settings: {}", creditTrackerSettings.getLpPipeline()); + } +}