etreschenkov 2025-05-27 15:08:18 +03:00
parent edd9c7c08d
commit 7f81e47fb6
2 changed files with 13 additions and 3 deletions

View file

@ -158,6 +158,12 @@ public class GatewayService extends QueueConsumer implements InitializingBean {
.clearingSystem(clearingSystemValue)
.build();
OutboundRequest outboundDigitalFondRequest = OutboundRequestBuilder.builder()
.section(Section.FOND_DC.getKey())
.type(OutboundRequestType.ON_DEMAND.getKey())
.clearingSystem(clearingSystemValue)
.build();
OutboundRequest outboundMkrRequest = OutboundRequestBuilder.builder()
.section(Section.MKR.getKey())
.type(OutboundRequestType.ON_DEMAND.getKey())
@ -171,15 +177,18 @@ public class GatewayService extends QueueConsumer implements InitializingBean {
.build();
outboundRequestByUuid.put(outboundFondRequest.getId(), outboundFondRequest);
outboundRequestByUuid.put(outboundDigitalFondRequest.getId(), outboundDigitalFondRequest);
outboundRequestByUuid.put(outboundMkrRequest.getId(), outboundMkrRequest);
outboundRequestByUuid.put(outboundCurrRequest.getId(), outboundCurrRequest);
sendRequest(outboundFondRequest);
log.debug("LOSC task 1/3 complete (FOND section)");
log.debug("LOSC task 1/4 complete (FOND section)");
sendRequest(outboundDigitalFondRequest);
log.debug("LOSC task 2/4 complete (FOND_DC section)");
sendRequest(outboundMkrRequest);
log.debug("LOSC task 2/3 complete (MKR section)");
log.debug("LOSC task 3/4 complete (MKR section)");
sendRequest(outboundCurrRequest);
log.debug("LOSC task 3/3 complete (CURR section)");
log.debug("LOSC task 4/4 complete (CURR section)");
}
public void requestOnAsset(BaseRequest<AssetOperationListRequest> request) {

View file

@ -5,6 +5,7 @@ import ru.spcex.platform.utils.enumeration.IEnumKey;
public enum Section implements IEnumKey {
MKR("MKR"),
FOND("FOND"),
FOND_DC("FOND_DC"),
CURR("CURR"),
MULT("MULT");