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

inspection obligation: set plan balance before the step.

Browse source
This commit is contained in:
ialbert 2025-07-16 17:40:42 +03:00
parent 4351fc9ca3
commit 3e804be783
3 changed files with 9 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsDepositReturnAction.java
View file

@ -50,7 +50,7 @@ import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD;
@Service
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public class InspectionObligationsDepositReturnAction extends AbstractSessionActionForOkErrorHandling {
public class InspectionObligationsDepositReturnAction extends ReviseStage1Action {
private final Logger log = LoggerFactory.getLogger(getClass());
private final Imdg<Registry> registryImdg;
private final Imdg<ClearingMemberCategory> categoryImdg;
@ -64,6 +64,7 @@ public class InspectionObligationsDepositReturnAction extends AbstractSessionAct
@Autowired
public InspectionObligationsDepositReturnAction(ImdgProvider imdgProvider, RegistryManager rgsMng, AssetTBFProcessing assets, TradingTimeService tradingTimeService, GatewayRequester gateway, PlanBalanceCalc planBalanceCalc) {
super(imdgProvider);
this.registryImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_Registry, Registry.class);
this.categoryImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_ClearingMemberCategory, ClearingMemberCategory.class);
this.rgsMng = rgsMng;
@ -75,7 +76,8 @@ public class InspectionObligationsDepositReturnAction extends AbstractSessionAct
}
@Override
protected void actualExecute(StateContext<TaskType, SsnEvent> ctx) {
public void actualExecute(StateContext<TaskType, SsnEvent> ctx) {
super.actualExecute(ctx);
Long sessionId = ctx.getExtendedState().get(DataEnum.sessionId, Long.class);
this.sessionType = ctx.getExtendedState().get(DataEnum.sessionType, SessionType.class);
String sqlCondition = String.format("(%s) and registryStatus = '%s'",

6
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsV2Action.java
View file

@ -62,7 +62,7 @@ import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD;
@Service
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public class InspectionObligationsV2Action extends AbstractSessionActionForOkErrorHandling {
public class InspectionObligationsV2Action extends ReviseStage1Action {
private final Logger log = LoggerFactory.getLogger(getClass());
private final Imdg<Registry> registryImdg;
private final ImdgId idGen;
@ -78,6 +78,7 @@ public class InspectionObligationsV2Action extends AbstractSessionActionForOkErr
GatewayRequester gateway,
PlanBalanceCalc planBalanceCalc
) {
super(imdgProvider);
this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null);
this.idGen = imdgProvider.getImdgIdGenerator();
this.gateway = gateway;
@ -93,8 +94,9 @@ public class InspectionObligationsV2Action extends AbstractSessionActionForOkErr
@Override
protected void actualExecute(StateContext<TaskType, SsnEvent> ctx) {
public void actualExecute(StateContext<TaskType, SsnEvent> ctx) {
try {
super.actualExecute(ctx);
Long sessionId = ctx.getExtendedState().get(DataEnum.sessionId, Long.class);
this.sessionType = ctx.getExtendedState().get(DataEnum.sessionType, SessionType.class);
inspectionObligations(sessionId, ctx);

2
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/ReviseStage1Action.java
View file

@ -23,7 +23,7 @@ import ru.spcex.platform.imdg.api.predicate.specific.RegistryCodeSqlBuilder;
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
public class ReviseStage1Action extends AbstractSessionActionForOkErrorHandling {
private final Logger log = LoggerFactory.getLogger(getClass());
private Imdg<Registry> registryImdg;
private final Imdg<Registry> registryImdg;
@Autowired
public ReviseStage1Action(ImdgProvider imdgProvider) {