etreshenkov 2023-07-06 19:03:20 +03:00
parent 73e93a4c46
commit b469c162b2
8 changed files with 18 additions and 3 deletions

View file

@ -219,6 +219,7 @@ public class FinalMkrSession extends AbstractSession implements InitializingBean
{ {
FinishingSessionPayload payload = new FinishingSessionPayload(); FinishingSessionPayload payload = new FinishingSessionPayload();
payload.setSessionId(currSession.getId()); payload.setSessionId(currSession.getId());
payload.setPr("3");
runStage(TaskType.FinishingSession, payload, finishingSession); runStage(TaskType.FinishingSession, payload, finishingSession);
} }
//stage 11 //stage 11

View file

@ -189,6 +189,7 @@ public class IntermediateMkrSession extends AbstractSession implements Initializ
{ {
FinishingSessionPayload payload = new FinishingSessionPayload(); FinishingSessionPayload payload = new FinishingSessionPayload();
payload.setSessionId(currSession.getId()); payload.setSessionId(currSession.getId());
payload.setPr("4");
runStage(TaskType.FinishingSession, payload, finishingSession); runStage(TaskType.FinishingSession, payload, finishingSession);
} }
//stage 11 //stage 11

View file

@ -178,6 +178,7 @@ public class PrimaryAuctionB0Session extends AbstractSession implements Initiali
{ {
FinishingSessionPayload payload = new FinishingSessionPayload(); FinishingSessionPayload payload = new FinishingSessionPayload();
payload.setSessionId(currSession.getId()); payload.setSessionId(currSession.getId());
payload.setPr("0");
runStage(TaskType.FinishingSession, payload, finishingSession); runStage(TaskType.FinishingSession, payload, finishingSession);
} }
//stage 11 //stage 11

View file

@ -177,6 +177,7 @@ public class PrimaryAuctionBnSession extends AbstractSession implements Initiali
{ {
FinishingSessionPayload payload = new FinishingSessionPayload(); FinishingSessionPayload payload = new FinishingSessionPayload();
payload.setSessionId(currSession.getId()); payload.setSessionId(currSession.getId());
payload.setPr("0");
runStage(TaskType.FinishingSession, payload, finishingSession); runStage(TaskType.FinishingSession, payload, finishingSession);
} }
//stage 11 //stage 11

View file

@ -177,6 +177,7 @@ public class PrimaryAuctionT0Session extends AbstractSession implements Initiali
{ {
FinishingSessionPayload payload = new FinishingSessionPayload(); FinishingSessionPayload payload = new FinishingSessionPayload();
payload.setSessionId(currSession.getId()); payload.setSessionId(currSession.getId());
payload.setPr("0");
runStage(TaskType.FinishingSession, payload, finishingSession); runStage(TaskType.FinishingSession, payload, finishingSession);
} }
//stage 11 //stage 11

View file

@ -178,6 +178,7 @@ public class SecondaryAuctionT0Session extends AbstractSession implements Initia
{ {
FinishingSessionPayload payload = new FinishingSessionPayload(); FinishingSessionPayload payload = new FinishingSessionPayload();
payload.setSessionId(currSession.getId()); payload.setSessionId(currSession.getId());
payload.setPr("1");
runStage(TaskType.FinishingSession, payload, finishingSession); runStage(TaskType.FinishingSession, payload, finishingSession);
} }
//stage 11 //stage 11

View file

@ -59,7 +59,7 @@ public class FinishingSession implements ISessionStage {
FinishingSessionPayload payload = (FinishingSessionPayload) task.getData(); FinishingSessionPayload payload = (FinishingSessionPayload) task.getData();
switch (task.getTaskType()) { switch (task.getTaskType()) {
case FinishingSession -> { case FinishingSession -> {
return finishingSession(payload.getSessionId()); return finishingSession(payload.getSessionId(), payload.getPr());
} }
default -> { default -> {
throw new IllegalStateException("Unknown task type: " + task.getTaskType()); throw new IllegalStateException("Unknown task type: " + task.getTaskType());
@ -67,7 +67,7 @@ public class FinishingSession implements ISessionStage {
} }
} }
protected StageResult<?> finishingSession(Long sessionId) { protected StageResult<?> finishingSession(Long sessionId, String pr) {
// 2. Отправка сообщений // 2. Отправка сообщений
Collection<Registry> forRegistries = selectRegistry(sessionId); Collection<Registry> forRegistries = selectRegistry(sessionId);
log.debug("Found {} registries for sessionId={}", forRegistries.size(), sessionId); log.debug("Found {} registries for sessionId={}", forRegistries.size(), sessionId);
@ -88,7 +88,7 @@ public class FinishingSession implements ISessionStage {
return sResult; return sResult;
} }
} }
sdf05Sender.sendSdf05("3"); sdf05Sender.sendSdf05(pr);
StageResult<Collection<Registry>> res = new StageResult<>(null, true); StageResult<Collection<Registry>> res = new StageResult<>(null, true);
return res; return res;
} }

View file

@ -2,6 +2,7 @@ package ru.spcex.clearing.session.stage.task;
public class FinishingSessionPayload { public class FinishingSessionPayload {
private Long sessionId; private Long sessionId;
private String pr;
public Long getSessionId() { public Long getSessionId() {
return sessionId; return sessionId;
@ -10,4 +11,12 @@ public class FinishingSessionPayload {
public void setSessionId(Long sessionId) { public void setSessionId(Long sessionId) {
this.sessionId = sessionId; this.sessionId = sessionId;
} }
public String getPr() {
return pr;
}
public void setPr(String pr) {
this.pr = pr;
}
} }