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

http://jira.mfd.msk:8088/browse/CLS-732 sdf54 & DM*I hotfix

Browse source
This commit is contained in:
ialbert 2024-08-14 12:23:25 +03:00
parent 7652e28ae9
commit a4febcafb1
1 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java
View file

@ -187,13 +187,6 @@ public class PaymentInstructionOutboundService {
SDf54 sDf54 = sdf54Creator.create(pmt); SDf54 sDf54 = sdf54Creator.create(pmt);
sDf54.setId(idGenerator.nextId()); sDf54.setId(idGenerator.nextId());
sDf54.setGenerationId(pmt.getId()); sDf54.setGenerationId(pmt.getId());
sdf54Imdg.insert(sDf54);
log.debug("new sdf54.id: {}", sDf54.getId());
dmiService.setProcComment(tcr.getId(),
curr,
safeBD(amount).negate(),
sDf54.getDocnm_ref());
assetsMng.process(assets.get().a__b(), assets.get().a__t(), assets.get().a__f(), BigDecimal.ZERO);
if (time.isTradingTime()) { if (time.isTradingTime()) {
Supplier<AssetOperationRequest> builder = () -> GatewayRequestCreator.from(pmt, Supplier<AssetOperationRequest> builder = () -> GatewayRequestCreator.from(pmt,
assets.get().a__b().getTradingCode(), assets.get().a__b().getTradingCode(),
@ -213,6 +206,13 @@ public class PaymentInstructionOutboundService {
return error(req.getId(), ClearingError.GeneralError); return error(req.getId(), ClearingError.GeneralError);
} }
} }
sdf54Imdg.insert(sDf54);
log.debug("new sdf54.id: {}", sDf54.getId());
dmiService.setProcComment(tcr.getId(),
curr,
safeBD(amount).negate(),
sDf54.getDocnm_ref());
assetsMng.process(assets.get().a__b(), assets.get().a__t(), assets.get().a__f(), BigDecimal.ZERO);
SdfClearingRequest exp = new SdfClearingRequest(); SdfClearingRequest exp = new SdfClearingRequest();
exp.setGroupId(sDf54.getGenerationId()); exp.setGroupId(sDf54.getGenerationId());
kafkaSender.sendRequestToQueue(Consts.SDF54_PROCESS, exp); kafkaSender.sendRequestToQueue(Consts.SDF54_PROCESS, exp);