treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

exporter

Browse source
This commit is contained in:
etreschenkov 2023-05-24 12:22:19 +03:00
parent 0d0157fef2
commit cd863f209a
1 changed files with 3 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/services/CommandService.java
View file

@ -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<Sdf56And51Request> 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);
}
}
}