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

clearing-service http://jira.mfd.msk:8088/browse/CLS-508 Sdf04 / Sdf13 ожидание полностью готовой группы в SessionMonitor

Browse source
This commit is contained in:
AKurakin 2023-08-30 17:59:16 +03:00
parent f5d5c8acfb
commit 835f9932d9
3 changed files with 3 additions and 3 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

@ -287,7 +287,7 @@ public class StatementService extends QueueConsumer implements InitializingBean
NotificationNewRequest nRequest = new NotificationNewRequest();
nRequest.setObjectType(ObjectType.rgst.getKey());
nRequest.setPriority(Priority.HIGH.getKey());
nRequest.setComment("Поручения из клиринговой системы имеют неисполненный статус в ответе ДФ-13 из расчетной организации");
nRequest.setComment("Поручения из клиринговой системы имеют неисполненный статус в ответе ДФ-13 из расчетного депозитария");
kafkaSender.sendRequestToQueue(Consts.NOTIFICATION_NEW, nRequest);
} else {
kafkaSender.sendRequestToQueue(Consts.CONTINUE_SESSION_BN_FIRST_PART, continueSessionBn);

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

@ -71,7 +71,7 @@ public class Sdf04Executor extends AbstractExecutor<SDf04> {
public Result execute(Collection<SDf04> sdf, StatementRequest statementRequest) {
Result result = new Result();
for (SDf04 sdf04 : sdf) {
if (!StringUtils.startsWith(sdf04.getImp_result(), "OK")) {
if (!StringUtils.contains(sdf04.getImp_result(), "OK")) {
log.warn("groupId={} stop execute, cause: sdf04[{}].Imp_result=\"{}\" was not ok.", statementRequest.getGroupId(),
sdf04.getId(), sdf04.getImp_result());
result.setAnyHasError(true);

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

@ -65,7 +65,7 @@ public class Sdf13Executor extends AbstractExecutor<SDf13> {
result.setChildGenerationId(generationIdForGroup);
result.setAnyHasError(false);
for (SDf13 sdf13 : sdf) {
if (!StringUtils.startsWith(sdf13.getResult(), "OK")) {
if (!StringUtils.contains(sdf13.getResult(), "OK")) {
log.warn("groupId={} stop execute cause: sdf13[{}].result=\"{}\" was not ok.", statementRequest.getGroupId(), sdf13.getId(), sdf13.getResult());
result.setAnyHasError(true);
return result;