treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

LP: added dummy LpPipelinePackageFabric

Browse source
This commit is contained in:
Mikhail Trofimov 2026-06-30 15:43:07 +03:00
parent ef5aaf418a
commit 05ae297474
3 changed files with 34 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/ru/nbch/credit_tracker/config/settings/CreditTrackerSettings.java
View file

@ -26,6 +26,8 @@ public class CreditTrackerSettings {
@NestedConfigurationProperty @NestedConfigurationProperty
private PipelineSettings pipeline; private PipelineSettings pipeline;
@NestedConfigurationProperty @NestedConfigurationProperty
private PipelineSettings lpPipeline;
@NestedConfigurationProperty
private FlagUpdaterSettings flagUpdater; private FlagUpdaterSettings flagUpdater;
@NestedConfigurationProperty @NestedConfigurationProperty
private KafkaConsumerSettings kafkaConsumerSettings; private KafkaConsumerSettings kafkaConsumerSettings;

6
src/main/java/ru/nbch/credit_tracker/facade/SignalFacade.java
View file

@ -30,6 +30,7 @@ import ru.nbch.credit_tracker.model.ValidationResult;
import ru.nbch.credit_tracker.service.UserPackageService; import ru.nbch.credit_tracker.service.UserPackageService;
import ru.nbch.credit_tracker.service.scoring.AuthorizationService; import ru.nbch.credit_tracker.service.scoring.AuthorizationService;
import ru.nbch.credit_tracker.service.signal.SignalRestService; 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.NpPipelinePackageFabric;
import ru.nbch.credit_tracker.service.task.PipelinePackageOrchestrator; import ru.nbch.credit_tracker.service.task.PipelinePackageOrchestrator;
import ru.nbch.credit_tracker.service.task.SetupParam; import ru.nbch.credit_tracker.service.task.SetupParam;
@ -65,6 +66,7 @@ public class SignalFacade {
private final UserPackageService userPackageService; private final UserPackageService userPackageService;
private final AuthorizationService authorizationService; private final AuthorizationService authorizationService;
private final NpPipelinePackageFabric npPipelinePackageFabric; private final NpPipelinePackageFabric npPipelinePackageFabric;
private final LpPipelinePackageFabric lpPipelinePackageFabric;
private final SignalRestService signalRestService; private final SignalRestService signalRestService;
private final Saver saver; private final Saver saver;
private final PipelinePackageOrchestrator pipelineOrchestrator; private final PipelinePackageOrchestrator pipelineOrchestrator;
@ -75,6 +77,7 @@ public class SignalFacade {
UserPackageService userPackageService, UserPackageService userPackageService,
AuthorizationService authorizationService, AuthorizationService authorizationService,
NpPipelinePackageFabric npPipelinePackageManager, NpPipelinePackageFabric npPipelinePackageManager,
LpPipelinePackageFabric lpPipelinePackageFabric,
SignalRestService signalRestService, SignalRestService signalRestService,
Saver saver, PipelinePackageOrchestrator pipelineOrchestrator) { Saver saver, PipelinePackageOrchestrator pipelineOrchestrator) {
this.monitoringRequestValidator = monitoringRequestValidator; this.monitoringRequestValidator = monitoringRequestValidator;
@ -82,6 +85,7 @@ public class SignalFacade {
this.userPackageService = userPackageService; this.userPackageService = userPackageService;
this.authorizationService = authorizationService; this.authorizationService = authorizationService;
this.npPipelinePackageFabric = npPipelinePackageManager; this.npPipelinePackageFabric = npPipelinePackageManager;
this.lpPipelinePackageFabric = lpPipelinePackageFabric;
this.signalRestService = signalRestService; this.signalRestService = signalRestService;
this.saver = saver; this.saver = saver;
this.pipelineOrchestrator = pipelineOrchestrator; this.pipelineOrchestrator = pipelineOrchestrator;
@ -159,7 +163,7 @@ public class SignalFacade {
CtFileUtils.deleteQuietly(parsedFilePath); CtFileUtils.deleteQuietly(parsedFilePath);
}, pipeline, packageId); }, pipeline, packageId);
} else { } else {
Pipeline pipeline = npPipelinePackageFabric.build(new SetupParam(packageId, parsedFilePath, PipelineMode.DEFAULT)); Pipeline pipeline = lpPipelinePackageFabric.build(new SetupParam(packageId, parsedFilePath, PipelineMode.DEFAULT));
pipelineOrchestrator.startOrDelay(() -> { pipelineOrchestrator.startOrDelay(() -> {
saver.readAndSaveLpPackage(packageId, parsedFilePath); saver.readAndSaveLpPackage(packageId, parsedFilePath);
CtFileUtils.deleteQuietly(parsedFilePath); CtFileUtils.deleteQuietly(parsedFilePath);

27
src/main/java/ru/nbch/credit_tracker/service/task/LpPipelinePackageFabric.java Normal file
View file

@ -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());
}
}