diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsPrecAction.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsPrecAction.java index d5983e02a..ecbb4fdab 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsPrecAction.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsPrecAction.java @@ -53,7 +53,6 @@ import ru.spcex.platform.imdg.api.predicate.specific.RegistryCodeSqlBuilder; import ru.spcex.platform.imdg.iml.hazelcast.adapter.CashV2; import static ru.spcex.platform.utils.enumeration.IEnumKey.getEnumByKey; import ru.spcex.platform.utils.enumeration.IMessageResolver; -import ru.spcex.platform.utils.enumeration.SimpleMessageResolver; import ru.spcex.platform.utils.number.BigDecimalUtil; import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD; import ru.spcex.platform.utils.time.TimeUtil; @@ -66,15 +65,16 @@ public class InspectionObligationsPrecAction extends ReviseStage1Action { private final Imdg cmcImdg; private final Imdg ssnTypeImdg; private final ImdgId idGen; - private final IMessageResolver msgResolver = new SimpleMessageResolver(); + private final IMessageResolver msgResolver; private Function, Boolean> cmcFilter; private SessionType sessionType; private String ssnName; private Long sessionId; @Autowired - public InspectionObligationsPrecAction(ImdgProvider imdgProvider) { + public InspectionObligationsPrecAction(ImdgProvider imdgProvider, IMessageResolver messageResolver) { super(imdgProvider); + this.msgResolver = messageResolver; this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null); this.cmcImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_ClearingMemberCategory, ClearingMemberCategory.class, null); this.ssnTypeImdg = imdgProvider.getImdg(IMDGDistributedNames.Map_SessionTypeDictionary, SessionTypeDictionary.class); diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsV2Action.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsV2Action.java index 86f22963f..5b098ec38 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsV2Action.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/session/state/action/InspectionObligationsV2Action.java @@ -58,7 +58,6 @@ import ru.spcex.platform.utils.collection.Pair; import ru.spcex.platform.utils.enumeration.EnumMessage; import ru.spcex.platform.utils.enumeration.IEnumKey; import ru.spcex.platform.utils.enumeration.IMessageResolver; -import ru.spcex.platform.utils.enumeration.SimpleMessageResolver; import static ru.spcex.platform.utils.number.BigDecimalUtil.safeBD; @Service @@ -67,7 +66,7 @@ public class InspectionObligationsV2Action extends ReviseStage1Action { private final Logger log = LoggerFactory.getLogger(getClass()); private final Imdg registryImdg; private final ImdgId idGen; - private final IMessageResolver msgResolver = new SimpleMessageResolver(); + private final IMessageResolver msgResolver; private SessionType sessionType; private final AssetTBFProcessingCashing assetsCashing; private final GatewayRequester gateway; @@ -76,10 +75,12 @@ public class InspectionObligationsV2Action extends ReviseStage1Action { @Autowired public InspectionObligationsV2Action(ImdgProvider imdgProvider, + IMessageResolver messageResolver, GatewayRequester gateway, PlanBalanceCalc planBalanceCalc ) { super(imdgProvider); + this.msgResolver = messageResolver; this.registryImdg = imdgProvider.getCashingImdg(IMDGDistributedNames.Map_Registry, Registry.class, null); this.idGen = imdgProvider.getImdgIdGenerator(); this.gateway = gateway;