This commit is contained in:
parent
0db5cb0a28
commit
2781b29664
2 changed files with 3 additions and 0 deletions
|
|
@ -5,6 +5,7 @@ import ru.clearing.classes.statics.data.misc.OrderCurrency;
|
||||||
import ru.spcex.clearing.dflt.management.error.DefaultManagementErrors;
|
import ru.spcex.clearing.dflt.management.error.DefaultManagementErrors;
|
||||||
import ru.spcex.clearing.imdg.IMDGDistributedNames;
|
import ru.spcex.clearing.imdg.IMDGDistributedNames;
|
||||||
import ru.spcex.clearing.platform.messaging.domain.cud.order.OrderCurrencyUpdateRequest;
|
import ru.spcex.clearing.platform.messaging.domain.cud.order.OrderCurrencyUpdateRequest;
|
||||||
|
import ru.spcex.platform.enumeration.OrderStatus;
|
||||||
import ru.spcex.platform.enumeration.OvernightType;
|
import ru.spcex.platform.enumeration.OvernightType;
|
||||||
import ru.spcex.platform.imdg.api.Imdg;
|
import ru.spcex.platform.imdg.api.Imdg;
|
||||||
import ru.spcex.platform.imdg.api.predicate.ImdgPredicateBuilder;
|
import ru.spcex.platform.imdg.api.predicate.ImdgPredicateBuilder;
|
||||||
|
|
@ -30,6 +31,7 @@ public class SpotPairPresent implements IValidationRule<ImdgValidationContext<Or
|
||||||
pb.equals("companyId", oc.getCompanyId()),
|
pb.equals("companyId", oc.getCompanyId()),
|
||||||
pb.equals("tradingClearingRegistryId", oc.getTradingClearingRegistryId()),
|
pb.equals("tradingClearingRegistryId", oc.getTradingClearingRegistryId()),
|
||||||
pb.equals("counterPartyId", oc.getCounterPartyId()),
|
pb.equals("counterPartyId", oc.getCounterPartyId()),
|
||||||
|
pb.equals("status", OrderStatus.CREATED.getKey()),
|
||||||
pb.not(
|
pb.not(
|
||||||
pb.equals("id", oc.getId())
|
pb.equals("id", oc.getId())
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -69,6 +69,7 @@ public class UpdateMapService extends AbstractUpdateMapService {
|
||||||
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ExecutionCurrency).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_ExecutionCurrency).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
||||||
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_SettlementHouseProperties).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_SettlementHouseProperties).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
||||||
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_TradingClearingRegistryList).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_TradingClearingRegistryList).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
||||||
|
hazelcastServerInstance.getMap(IMDGDistributedNames.Map_OrderCurrency).addLocalEntryListener(this, Predicates.alwaysTrue(), true);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue