This commit is contained in:
parent
96885fa9d6
commit
333603c937
4 changed files with 7 additions and 12 deletions
|
|
@ -120,7 +120,7 @@ public class PrecSessionStateMachineConfig extends EnumStateMachineConfigurerAda
|
|||
);
|
||||
this.obligationAdmissionContinueAction.setDataEnum(DataEnum.obligationAdmissionStashedRgs);
|
||||
this.inspectionObligationsV2Action.setClearingMemberCategoryFilter(
|
||||
category -> !ClearingCategory.P.equalsByKey(category)
|
||||
category -> category == null || !ClearingCategory.P.equalsByKey(category)
|
||||
);
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -120,7 +120,7 @@ public class PrpcSessionStateMachineConfig extends EnumStateMachineConfigurerAda
|
|||
);
|
||||
this.obligationAdmissionContinueAction.setDataEnum(DataEnum.obligationAdmissionStashedRgs);
|
||||
this.inspectionObligationsV2Action.setClearingMemberCategoryFilter(
|
||||
ClearingCategory.P::equalsByKey
|
||||
ctgr -> ctgr != null && ClearingCategory.P.equalsByKey(ctgr)
|
||||
);
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -53,7 +53,6 @@ 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.text.TextUtil;
|
||||
import ru.spcex.platform.utils.time.TimeUtil;
|
||||
|
||||
@Service
|
||||
|
|
@ -176,15 +175,9 @@ public class InspectionObligationsPrecAction extends ReviseStage1Action {
|
|||
rgs.getCompanyId()
|
||||
).cashed(cmcImdg.predicateBuilder(), cmcCash);
|
||||
ClearingMemberCategory cmc = cmcImdg.getSingleObjectByPredicate(cmcPrdct);
|
||||
if (cmc == null || TextUtil.isEmpty(cmc.getClearingMemberCategory())) {
|
||||
log.error("couldn't find ClearingMemberCategory for group.id={}, rgs.id={}, company.id={}",
|
||||
entry.getKey().groupId(), rgs.getId(), rgs.getCompanyId());
|
||||
setGroupStatusError.accept(group);
|
||||
continue GROUP;
|
||||
}
|
||||
if (!cmcFilter.apply(cmc.getClearingMemberCategory())) {
|
||||
if (!cmcFilter.apply(cmc != null ? cmc.getClearingMemberCategory() : null)) {
|
||||
log.debug("group.id={}, rgs.id={}, company.id={}: category {}, skipping",
|
||||
entry.getKey().groupId(), rgs.getId(), rgs.getCompanyId(),cmc.getClearingMemberCategory());
|
||||
entry.getKey().groupId(), rgs.getId(), rgs.getCompanyId(), cmc != null ? cmc.getClearingMemberCategory() : "null");
|
||||
continue;
|
||||
}
|
||||
ImdgPredicate am_bPrdct = AssetByTcrCompanyAccountCashedPredicate
|
||||
|
|
|
|||
|
|
@ -3,7 +3,9 @@ package ru.spcex.clearing.dflt.management.error;
|
|||
import ru.spcex.platform.utils.enumeration.IErrorEnumId;
|
||||
|
||||
public enum DefaultManagementErrors implements IErrorEnumId {
|
||||
|
||||
//DictionaryNotFound(5003L),
|
||||
//RecordNotFoundInDictionary(5423L),
|
||||
//RecordNotFound(5406L),
|
||||
GeneralError(11000L),
|
||||
RecordNotFound(11001L),
|
||||
RecordAlreadyPresent(11002L),
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue