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

http://jira.mfd.msk:8088/browse/CLS-1054

Browse source
This commit is contained in:
ialbert 2026-06-23 13:07:05 +03:00
parent abc2076fbd
commit bfba880629
2 changed files with 6 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/InspectionObligationsPrecAction.java
View file

@ -53,7 +53,6 @@ import ru.spcex.platform.imdg.api.predicate.specific.RegistryCodeSqlBuilder;
import ru.spcex.platform.imdg.iml.hazelcast.adapter.CashV2; import ru.spcex.platform.imdg.iml.hazelcast.adapter.CashV2;
import static ru.spcex.platform.utils.enumeration.IEnumKey.getEnumByKey; import static ru.spcex.platform.utils.enumeration.IEnumKey.getEnumByKey;
import ru.spcex.platform.utils.enumeration.IMessageResolver; import ru.spcex.platform.utils.enumeration.IMessageResolver;
import ru.spcex.platform.utils.enumeration.SimpleMessageResolver;
import ru.spcex.platform.utils.number.BigDecimalUtil; import ru.spcex.platform.utils.number.BigDecimalUtil;
import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD; import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD;
import ru.spcex.platform.utils.time.TimeUtil; import ru.spcex.platform.utils.time.TimeUtil;
@ -66,15 +65,16 @@ public class InspectionObligationsPrecAction extends ReviseStage1Action {
private final Imdg<ClearingMemberCategory> cmcImdg; private final Imdg<ClearingMemberCategory> cmcImdg;
private final Imdg<SessionTypeDictionary> ssnTypeImdg; private final Imdg<SessionTypeDictionary> ssnTypeImdg;
private final ImdgId idGen; private final ImdgId idGen;
private final IMessageResolver msgResolver = new SimpleMessageResolver(); private final IMessageResolver msgResolver;
private Function<List<String>, Boolean> cmcFilter; private Function<List<String>, Boolean> cmcFilter;
private SessionType sessionType; private SessionType sessionType;
private String ssnName; private String ssnName;
private Long sessionId; private Long sessionId;
@Autowired @Autowired
public InspectionObligationsPrecAction(ImdgProvider imdgProvider) { public InspectionObligationsPrecAction(ImdgProvider imdgProvider, IMessageResolver messageResolver) {
super(imdgProvider); super(imdgProvider);
this.msgResolver = messageResolver;
this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null); this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null);
this.cmcImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_ClearingMemberCategory, ClearingMemberCategory.class, null); this.cmcImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_ClearingMemberCategory, ClearingMemberCategory.class, null);
this.ssnTypeImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SessionTypeDictionary, SessionTypeDictionary.class); this.ssnTypeImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SessionTypeDictionary, SessionTypeDictionary.class);

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

@ -58,7 +58,6 @@ import ru.spcex.platform.utils.collection.Pair;
import ru.spcex.platform.utils.enumeration.EnumMessage; import ru.spcex.platform.utils.enumeration.EnumMessage;
import ru.spcex.platform.utils.enumeration.IEnumKey; import ru.spcex.platform.utils.enumeration.IEnumKey;
import ru.spcex.platform.utils.enumeration.IMessageResolver; import ru.spcex.platform.utils.enumeration.IMessageResolver;
import ru.spcex.platform.utils.enumeration.SimpleMessageResolver;
import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD; import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD;
@Service @Service
@ -67,7 +66,7 @@ public class InspectionObligationsV2Action extends ReviseStage1Action {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
private final Imdg<Registry> registryImdg; private final Imdg<Registry> registryImdg;
private final ImdgId idGen; private final ImdgId idGen;
private final IMessageResolver msgResolver = new SimpleMessageResolver(); private final IMessageResolver msgResolver;
private SessionType sessionType; private SessionType sessionType;
private final AssetTBFProcessingCashing assetsCashing; private final AssetTBFProcessingCashing assetsCashing;
private final GatewayRequester gateway; private final GatewayRequester gateway;
@ -76,10 +75,12 @@ public class InspectionObligationsV2Action extends ReviseStage1Action {
@Autowired @Autowired
public InspectionObligationsV2Action(ImdgProvider imdgProvider, public InspectionObligationsV2Action(ImdgProvider imdgProvider,
IMessageResolver messageResolver,
GatewayRequester gateway, GatewayRequester gateway,
PlanBalanceCalc planBalanceCalc PlanBalanceCalc planBalanceCalc
) { ) {
super(imdgProvider); super(imdgProvider);
this.msgResolver = messageResolver;
this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null); this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null);
this.idGen = imdgProvider.getImdgIdGenerator(); this.idGen = imdgProvider.getImdgIdGenerator();
this.gateway = gateway; this.gateway = gateway;