http://jira.mfd.msk:8088/browse/BKI-3488

src/main/java/ru/nbch/credit_tracker/config/task/PipelineStarterConfig.java

@@ -30,7 +30,7 @@ public class PipelineStarterConfig {
                                                                                          PackageRecordsService packageRecordsService,
                                                                                          PhonesMapMapper phonesMapMapper) {
         return (setupParam) -> switch (setupParam.mode()) {
-            case DEFAULT ->
+            case DEFAULT, RESEND ->
                 new KickPipeLineDefaultImpl(setupParam, userPackageMapper, packageRecordsService, creditTrackerSettings);
             case RESTORE ->
                 new KickPipeLineDefaultImpl(setupParam, userPackageMapper, packageRecordsService, creditTrackerSettings);

src/main/java/ru/nbch/credit_tracker/model/impl/PackageVariable.java

@@ -3,5 +3,6 @@ package ru.nbch.credit_tracker.model.impl;
 public enum PackageVariable {
     packageId,
     cacheMisses,
-    cacheHits
+    cacheHits,
+    mode
 }

src/main/java/ru/nbch/credit_tracker/service/mode/common/UpdatingFidAndPdService.java

@@ -62,7 +62,7 @@ public class UpdatingFidAndPdService {
                     List<UserPackage> packagesRepeated = userPackageMapper.findForRepeatedPackages();
                     packagesRepeated.forEach(userPackage -> {
                         Long packageId = userPackage.getId();
-                        SetupParam setupParam = new SetupParam(packageId, null, PipelineMode.DEFAULT);
+                        SetupParam setupParam = new SetupParam(packageId, null, PipelineMode.RESEND);
                         try {
                             Pipeline makeXmlByCache = pipelinePackageManager.build(setupParam);
                             pipelinePackageOrchestrator.startOrDelay(makeXmlByCache, packageId);

src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageOrchestrator.java

@@ -16,6 +16,7 @@ import ru.nbch.credit_tracker.model.impl.PackageVariable;
 import ru.nbch.credit_tracker.model.impl.SignalXmlFilePayload;
 import ru.nbch.credit_tracker.service.MonitoringErrorProcesingService;
 import ru.nbch.credit_tracker.service.signal.SignalRestService;
+import ru.nbch.credit_tracker.service.task.impl.PipelineMode;
 import ru.nbch.credit_tracker.service.task.impl.XmlMergeCoordinator;
 import ru.nbch.credit_tracker.utils.error.ExceptionUtils;
 
@@ -125,7 +126,12 @@ public class PipelinePackageOrchestrator {
                     log.trace("Signal file by path: {} is completed", res.signalXmlFilePath());
                     boolean success = signalRestService.setupMonitoring(res.signalXmlFilePath());
                     if (success) {
+                        PipelineMode mode = ctx.get(PackageVariable.mode);
+                        if (mode != null && mode.equals(PipelineMode.DEFAULT)) {
                             userPackageMapper.updatePackageOnMonitoringSuccess(packageId, LocalDateTime.now());
+                        } else {
+                            userPackageMapper.updatePackageOnMonitoringSuccess(packageId, null);
+                        }
                         monitoringErrorProcesingService.findErrors(packageId);
                     } else {
                         userPackageMapper.setRejectedStatus(packageId, RejectedStatus.ERROR.getKey());

src/main/java/ru/nbch/credit_tracker/service/task/impl/KickPipeLine.java

@@ -23,6 +23,7 @@ import ru.nbch.credit_tracker.utils.error.ExceptionUtils;
 public abstract class KickPipeLine implements IPipeLineStarter<SubjectPayload> {
     private final Logger log = LoggerFactory.getLogger(getClass());
     protected final Long packageId;
+    protected final PipelineMode mode;
     protected final UserPackageMapper userPackageMapper;
     protected final PackageRecordsService packageRecordsService;
     protected final CreditTrackerSettings creditTrackerSettings;
@@ -41,6 +42,7 @@ public abstract class KickPipeLine implements IPipeLineStarter<SubjectPayload> {
         this.packageRecordsService = packageRecordsService;
         this.creditTrackerSettings = creditTrackerSettings;
         this.BATCH_SIZE = creditTrackerSettings.getPipeline().subjectBatchSize();
+        this.mode = setupParam.mode();
     }
 
     private static class PipelineStarterException extends SignalClientException {
@@ -62,6 +64,7 @@ public abstract class KickPipeLine implements IPipeLineStarter<SubjectPayload> {
             context.store(PackageVariable.packageId, packageId);
             context.store(PackageVariable.cacheMisses, new AtomicInteger());
             context.store(PackageVariable.cacheHits, new AtomicInteger());
+            context.store(PackageVariable.mode, mode);
             int limit = BATCH_SIZE;
             UserPackage userPackage = userPackageMapper.findPackage(packageId);
             List<PackagesRecordsMap> page = nextPage(limit);

src/main/java/ru/nbch/credit_tracker/service/task/impl/PipelineMode.java

@@ -7,6 +7,7 @@ package ru.nbch.credit_tracker.service.task.impl;
  */
 public enum PipelineMode {
     DEFAULT,
+    RESEND,
     RESTORE,
     REPEATED_RESTORE,
     RECALC_PERSONAL_DATA,

src/main/resources/mybatis/mapper/signal/UserPackageMapper.xml

@@ -91,7 +91,12 @@
 
     <update id="updatePackageOnMonitoringSuccess">
         UPDATE signals_user_packages
-        SET monitoring_at = #{monitoringAt}, status = 'ON_MONITORING', fid_changed = null
+        SET
+            <if test="monitoringAt != null">
+                monitoring_at = #{monitoringAt},
+            </if>
+            status = 'ON_MONITORING',
+            fid_changed = null
         WHERE id = #{id}
     </update>