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

clearing-service Sdf04 ожидание полностью готовой группы в SessionMonitor

Browse source
This commit is contained in:
AKurakin 2023-08-30 16:58:25 +03:00
parent 960ed3f0c8
commit 546359752b
2 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java
View file

@ -243,7 +243,7 @@ public class StatementService extends QueueConsumer implements InitializingBean
NotificationNewRequest nRequest = new NotificationNewRequest(); NotificationNewRequest nRequest = new NotificationNewRequest();
nRequest.setObjectType(ObjectType.rgst.getKey()); nRequest.setObjectType(ObjectType.rgst.getKey());
nRequest.setPriority(Priority.HIGH.getKey()); nRequest.setPriority(Priority.HIGH.getKey());
nRequest.setComment(String.format("Ошибка : некоторые из новых SDF_04 имеют неправильный статус")); nRequest.setComment("Поручения из клиринговой системы имеют неисполненный статус в ответе ДФ-04 из расчетной организации");
kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, nRequest); kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, nRequest);
} else { // отправить в SessionMonitor } else { // отправить в SessionMonitor
kafkaSender.sendRequestToQueue(Consts.CONTINUE_SESSION_BN_FIRST_PART, continueSessionBn); kafkaSender.sendRequestToQueue(Consts.CONTINUE_SESSION_BN_FIRST_PART, continueSessionBn);

11
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf04Executor.java
View file

@ -69,14 +69,17 @@ public class Sdf04Executor extends AbstractExecutor<SDf04> {
public Result execute(Collection<SDf04> sdf, StatementRequest statementRequest) { public Result execute(Collection<SDf04> sdf, StatementRequest statementRequest) {
Result result = new Result(); Result result = new Result();
Long generationIdForGroup = imdgProvider.getImdgIdGenerator().nextId();
result.setChildGenerationId(generationIdForGroup);
result.setAnyHasError(false);
for (SDf04 sdf04 : sdf) { for (SDf04 sdf04 : sdf) {
if (!("OK!".equals(sdf04.getImp_result()))) { if (!("OK!".equals(sdf04.getImp_result()))) {
log.trace("sdf04[{}].Imp_result=\"{}\" was not ok.", sdf04.getId(), sdf04.getImp_result()); log.warn("groupId={} stop execute, cause: sdf04[{}].Imp_result=\"{}\" was not ok.", statementRequest.getGroupId(),
sdf04.getId(), sdf04.getImp_result());
result.setAnyHasError(true); result.setAnyHasError(true);
return result;
} }
}
Long generationIdForGroup = imdgProvider.getImdgIdGenerator().nextId();
result.setChildGenerationId(generationIdForGroup);
for (SDf04 sdf04 : sdf) {
//обычно мы ищем по группу sdf04, здесь как будто всегда только одна запись, todo нужно прочекать этот момент //обычно мы ищем по группу sdf04, здесь как будто всегда только одна запись, todo нужно прочекать этот момент
log.debug("Process sdf04 record; sdf04.id: {}", sdf04.getId()); log.debug("Process sdf04 record; sdf04.id: {}", sdf04.getId());
Collection<Registry> registries; Collection<Registry> registries;