diff --git a/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/services/CommandService.java b/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/services/CommandService.java index c80b9ec07..be0261798 100644 --- a/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/services/CommandService.java +++ b/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/services/CommandService.java @@ -11,7 +11,6 @@ import ru.spcex.clearing.dbf.exporter.logic.data.enums.Table; import ru.spcex.clearing.platform.messaging.domain.BaseRequest; import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.cud.balance.ExportToFileRequest; -import ru.spcex.clearing.platform.messaging.domain.cud.clearing.Sdf56And51Request; import ru.spcex.clearing.platform.messaging.domain.cud.clearing.SdfClearingRequest; import ru.spcex.clearing.platform.messaging.service.QueueConsumer; import ru.spcex.platform.imdg.api.ImdgProvider; @@ -60,9 +59,9 @@ public class CommandService extends QueueConsumer implements InitializingBean { callback(SdfClearingRequest.class) .setConsumer(r -> processSpecial(Table.S_DF54, r)) .forDestination(Consts.SDF54_PROCESS, callbacks::put); - callback(Sdf56And51Request.class) - .setConsumer(r -> revise(r)) - .forDestination(Consts.REVISE_PROCESS, callbacks::put); + callback(SdfClearingRequest.class) + .setConsumer(r -> processSpecial(Table.S_DF56, r)) + .forDestination(Consts.SDF56_PROCESS, callbacks::put); init(); } @@ -84,20 +83,4 @@ public class CommandService extends QueueConsumer implements InitializingBean { resultContainer.setGroupId(request.getGroupId()); processor.process(resultContainer); } - - private void revise(BaseRequest systemRequest) { - Sdf56And51Request sdf56And51Request = systemRequest.getRequestPayload(); - log.debug("Not implemented sdf56 and sdf51 request"); - { - ResultContainer resultContainer = ResultContainer.createNewTask(Table.S_DF56); - resultContainer.setGroupId(null); - processor.process(resultContainer); - } - - { - ResultContainer resultContainer = ResultContainer.createNewTask(Table.S_DF51); - resultContainer.setGroupId(null); - processor.process(resultContainer); - } - } }