From f61f28eb7b7f64441c643d7137d8b2b96409324b Mon Sep 17 00:00:00 2001 From: AKurakin Date: Mon, 16 Jan 2023 18:23:05 +0300 Subject: [PATCH] =?UTF-8?q?dbf-importer=20=D0=BF=D0=BE=D1=87=D0=B8=D1=81?= =?UTF-8?q?=D1=82=D0=B8=D0=BB=20enum=20Task=20(98028949b52c7be4a832)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dbf/importer/services/LauncherCommandReceiver.java | 9 ++++----- .../main/java/ru/spcex/platform/enumeration/Task.java | 4 ---- 2 files changed, 4 insertions(+), 9 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 d79c3a9b9..70dee0b97 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,7 +10,6 @@ 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 { @@ -31,16 +30,16 @@ public class LauncherCommandReceiver extends QueueConsumer implements Initializi .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 + .forDestination(Task.accrualOfBalance.topic(), callbacks::put); // GBAL callback(LauncherCommandRequest.class) .setConsumer(action -> importer.run(ETable.DF_12)) - .forDestination(Task.dbf_ABLK.topic(), callbacks::put); // ABLK + .forDestination(Task.accountBlock.topic(), callbacks::put); // ABLK callback(LauncherCommandRequest.class) .setConsumer(action -> importer.run(ETable.DF_09)) - .forDestination(Task.dbf_GBLD.topic(), callbacks::put); // GBLD + .forDestination(Task.getBalance.topic(), callbacks::put); // GBLD callback(LauncherCommandRequest.class) .setConsumer(action -> importer.run(ETable.DF_16)) - .forDestination(Task.dbf_ADBL.topic(), callbacks::put); // ADBL + .forDestination(Task.additionOrDeleteOfBalance.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 edc28722a..eb74613d8 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,10 +13,6 @@ 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