diff --git a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/services/LauncherCommandReceiver.java b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/services/LauncherCommandReceiver.java index eec3f4f88..d79c3a9b9 100644 --- a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/services/LauncherCommandReceiver.java +++ b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/services/LauncherCommandReceiver.java @@ -10,6 +10,7 @@ import ru.spcex.clearing.dbf.importer.logic.data.enums.ETable; import ru.spcex.clearing.platform.messaging.domain.cud.schedule.LauncherCommandRequest; import ru.spcex.clearing.platform.messaging.service.QueueConsumer; import ru.spcex.platform.enumeration.Task; +import ru.spcex.platform.utils.log.ExceptionUtils; @Service public class LauncherCommandReceiver extends QueueConsumer implements InitializingBean { @@ -27,7 +28,20 @@ public class LauncherCommandReceiver extends QueueConsumer implements Initializi public void afterPropertiesSet() { callback(LauncherCommandRequest.class) .setConsumer(action -> importer.run(ETable.DF_04)) - .forDestination(Task.createOrderConfirm.topic(), callbacks::put); + .forDestination(Task.createOrderConfirm.topic(), callbacks::put); // CORC + callback(LauncherCommandRequest.class) + .setConsumer(action -> importer.run(ETable.DF_01)) + .forDestination(Task.dbf_GBAL.topic(), callbacks::put); // GBAL + callback(LauncherCommandRequest.class) + .setConsumer(action -> importer.run(ETable.DF_12)) + .forDestination(Task.dbf_ABLK.topic(), callbacks::put); // ABLK + callback(LauncherCommandRequest.class) + .setConsumer(action -> importer.run(ETable.DF_09)) + .forDestination(Task.dbf_GBLD.topic(), callbacks::put); // GBLD + callback(LauncherCommandRequest.class) + .setConsumer(action -> importer.run(ETable.DF_16)) + .forDestination(Task.dbf_ADBL.topic(), callbacks::put); // ADBL + init(); } } diff --git a/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/Task.java b/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/Task.java index 792cdbe0c..edc28722a 100644 --- a/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/Task.java +++ b/platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/Task.java @@ -13,11 +13,14 @@ public enum Task implements IEnumKey { startOfPreClearing("SPRC"),// Запуск преклиринга startPostClearing("SPOC"),// Запуск постклиринга createOrder("CORD"), + dbf_GBAL("GBAL"), + dbf_ABLK("ABLK"), + dbf_GBLD("GBLD"), + dbf_ADBL("ADBL"), createOrderConfirm("CORC"), getAllBalance("GALB"), createReport_GREP("GREP");// Создание отчёта (report-service) RPRT нескольких видов, этот GREP - private final String key; Task(String key) {