From 98028949b52c7be4a832546351cb3796e5b2f481 Mon Sep 17 00:00:00 2001 From: AKurakin Date: Fri, 13 Jan 2023 14:29:34 +0300 Subject: [PATCH] =?UTF-8?q?dbf-importer=20=D0=B4=D0=BE=D0=B1=D0=B0=D0=B2?= =?UTF-8?q?=D0=B8=D0=BB=20=D1=81=D0=BB=D1=83=D1=88=D0=B0=D1=82=D0=B5=D0=BB?= =?UTF-8?q?=D0=B5=D0=B9=20=D0=BD=D0=B0=20=D0=BD=D0=BE=D0=B2=D1=8B=D0=B5=20?= =?UTF-8?q?Task?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../services/LauncherCommandReceiver.java | 16 +++++++++++++++- .../java/ru/spcex/platform/enumeration/Task.java | 5 ++++- 2 files changed, 19 insertions(+), 2 deletions(-) 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) {