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

http://jira.mfd.msk:8088/browse/CLS-607 поправил комментарии

Browse source
This commit is contained in:
AKurakin 2023-12-28 18:00:40 +03:00
parent 2cbb8a39ef
commit 0f65c05f08
2 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java
View file

@ -217,13 +217,13 @@ public class Sdf06Executor {
asts.ifPresent(a -> assets.process(a.a__b(), a.a__t(), a.a__f(), BigDecimal.ZERO)); asts.ifPresent(a -> assets.process(a.a__b(), a.a__t(), a.a__f(), BigDecimal.ZERO));
} }
} else { } else {
log.trace("statement.id={}, sdf07.id={}, sdf06.id={} rejected (by gateway answer)",
statementId,
sdf06.getGenerationId(),
sdf06.getId());
SDf07 sdf07 = createSdf07(sdf06, now, errorResult3); SDf07 sdf07 = createSdf07(sdf06, now, errorResult3);
sdf07.setGenerationId(sdf07GroupId); sdf07.setGenerationId(sdf07GroupId);
sdf07Imdg.insert(sdf07); sdf07Imdg.insert(sdf07);
log.trace("statement.id={}, sdf07.id={}, sdf06.id={} sdf06.getGenerationId={} rejected (by gateway answer)",
statementId,
sdf07.getId(),
sdf06.getId(), sdf06.getGenerationId());
stmt.setOperationStatus(OperationStatus.Rejected.getKey()); stmt.setOperationStatus(OperationStatus.Rejected.getKey());
stmt.setUpdated(updatedTime); stmt.setUpdated(updatedTime);
stmt.setOutSDfId(sdf07.getId()); stmt.setOutSDfId(sdf07.getId());

1
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf08Executor.java
View file

@ -150,7 +150,6 @@ public class Sdf08Executor extends AbstractExecutor<SDf08> {
} }
if (error.isPresent() && !ClearingError.SecurityNotFound.equals(error.get().getSubject())) { if (error.isPresent() && !ClearingError.SecurityNotFound.equals(error.get().getSubject())) {
log.error("sdf01.id={} error: {}", sdf08.getId(), messageResolver.resolve(error.get())); log.error("sdf01.id={} error: {}", sdf08.getId(), messageResolver.resolve(error.get()));
//fixme инициировать = команда для другого сервиса? sdf02Imdg.insert(createErrorSdf02(sdf01, error.get(), generationIdForGroup));
SDf09 errSdf = createErrorSdf09(sdf08, generationIdForGroup, error.get()); SDf09 errSdf = createErrorSdf09(sdf08, generationIdForGroup, error.get());
sdf09Imdg.insert(errSdf); sdf09Imdg.insert(errSdf);
continue; continue;