UNIT session fix: adjust value/5 step returns/inclusion conditions

This commit is contained in:
ialbert 2024-06-20 19:22:38 +03:00
parent 1b0672bba3
commit ae87df9e86
3 changed files with 4 additions and 2 deletions

View file

@ -227,8 +227,8 @@ public class UnitedSession extends AbstractSession implements InitializingBean {
InspectionPoolPayload companyIdPayload = new InspectionPoolPayload();
companyIdPayload.setSessionId(currSession.getId());
companyIdPayload.setProcessedCompanyId(currSession.getCompanyId());
//fixme checks inside the stages
runStage(TaskType.InspectionObligations, companyIdPayload, inspectionObligationsReturn);
//fixme checks inside the stages
//runStage(TaskType.InspectionObligations, companyIdPayload, inspectionObligationsReturn);
runStage(TaskType.InspectionObligations, companyIdPayload, inspectionObligations);
}

View file

@ -356,6 +356,7 @@ public class FormingPaymentInstructionAssets implements ISessionStage {
}
private BigDecimal adjustAmountByReturns(Registry amb, Long sessionId) {//companyid, tcr/account, sessionId, RUB
if (SessionType.UNIT.equals(sessionType)) return BigDecimal.ZERO;
Long companyId = amb.getCompanyId();
Long tradingClearingRegistryId = amb.getTradingClearingRegistryId();
ImdgPredicateBuilder pb = registryImdg.predicateBuilder();

View file

@ -117,6 +117,7 @@ public class InclusionObligations implements ISessionStage {
} else {
registryPredicate = prdctBuilder.and(
defaultCondition,
SessionType.UNIT.equals(sessionType) ? prdctBuilder.equals("sessionId", sessionId) : prdctBuilder.alwaysTrue(),
prdctBuilder.equals("registryStatus", RegistryStatus.PROC.getKey())
);
}