http://jira.mfd.msk:8088/browse/CLS-497 change predicate
This commit is contained in:
parent
f35e4bce23
commit
317b24748c
3 changed files with 3 additions and 11 deletions
|
|
@ -9,7 +9,6 @@ import ru.spcex.platform.imdg.api.predicate.ImdgPredicateBuilder;
|
||||||
|
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
public class ExecutedDealReportBuilder_INFTYPE_1 extends ExecutedDealReportBuilderCommon<SessionIdParam> {
|
public class ExecutedDealReportBuilder_INFTYPE_1 extends ExecutedDealReportBuilderCommon<SessionIdParam> {
|
||||||
|
|
@ -31,11 +30,9 @@ public class ExecutedDealReportBuilder_INFTYPE_1 extends ExecutedDealReportBuild
|
||||||
@Override
|
@Override
|
||||||
protected Collection<ExecutionFond> getExecutionFondsForReport(SessionIdParam params) {
|
protected Collection<ExecutionFond> getExecutionFondsForReport(SessionIdParam params) {
|
||||||
ImdgPredicateBuilder pb = executionFondImdg.predicateBuilder();
|
ImdgPredicateBuilder pb = executionFondImdg.predicateBuilder();
|
||||||
List<Long> sessionIds = params.getSessionId();
|
|
||||||
if (sessionIds == null || sessionIds.isEmpty()) sessionIds = getSessionIdsForCurrentDate(sessionImdg);
|
|
||||||
return executionFondImdg.getCollectionObjectsByPredicate(
|
return executionFondImdg.getCollectionObjectsByPredicate(
|
||||||
pb.and(
|
pb.and(
|
||||||
pb.in("sessionId", sessionIds.toArray(new Long[0])),
|
pb.notNull("sessionId"),
|
||||||
pb.less("tradingDate", LocalDate.now()),
|
pb.less("tradingDate", LocalDate.now()),
|
||||||
pb.equals("settlementDate", LocalDate.now())
|
pb.equals("settlementDate", LocalDate.now())
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -9,7 +9,6 @@ import ru.spcex.platform.imdg.api.predicate.ImdgPredicateBuilder;
|
||||||
|
|
||||||
import java.time.LocalDate;
|
import java.time.LocalDate;
|
||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
public class ExecutedDealReportBuilder_INFTYPE_2 extends ExecutedDealReportBuilderCommon<SessionIdParam> {
|
public class ExecutedDealReportBuilder_INFTYPE_2 extends ExecutedDealReportBuilderCommon<SessionIdParam> {
|
||||||
|
|
@ -31,11 +30,9 @@ public class ExecutedDealReportBuilder_INFTYPE_2 extends ExecutedDealReportBuild
|
||||||
@Override
|
@Override
|
||||||
protected Collection<ExecutionFond> getExecutionFondsForReport(SessionIdParam params) {
|
protected Collection<ExecutionFond> getExecutionFondsForReport(SessionIdParam params) {
|
||||||
ImdgPredicateBuilder pb = executionFondImdg.predicateBuilder();
|
ImdgPredicateBuilder pb = executionFondImdg.predicateBuilder();
|
||||||
List<Long> sessionIds = params.getSessionId();
|
|
||||||
if (sessionIds == null || sessionIds.isEmpty()) sessionIds = getSessionIdsForCurrentDate(sessionImdg);
|
|
||||||
return executionFondImdg.getCollectionObjectsByPredicate(
|
return executionFondImdg.getCollectionObjectsByPredicate(
|
||||||
pb.and(
|
pb.and(
|
||||||
pb.in("sessionId",sessionIds.toArray(new Long[0])),
|
pb.notNull("sessionId"),
|
||||||
pb.equals("tradingDate", LocalDate.now()),
|
pb.equals("tradingDate", LocalDate.now()),
|
||||||
pb.equals("settlementDate", LocalDate.now())
|
pb.equals("settlementDate", LocalDate.now())
|
||||||
)
|
)
|
||||||
|
|
|
||||||
|
|
@ -66,10 +66,8 @@ public class UnfulfilledDealReportBuilder extends CSVReportBuilder<SessionIdPara
|
||||||
@Override
|
@Override
|
||||||
protected void collect(SessionIdParam params) {
|
protected void collect(SessionIdParam params) {
|
||||||
ImdgPredicateBuilder pb = executionFondImdg.predicateBuilder();
|
ImdgPredicateBuilder pb = executionFondImdg.predicateBuilder();
|
||||||
List<Long> sessionIds = params.getSessionId();
|
|
||||||
if (sessionIds == null || sessionIds.isEmpty()) sessionIds = getSessionIdsForCurrentDate(sessionImdg);
|
|
||||||
ImdgPredicate predicate = pb.and(
|
ImdgPredicate predicate = pb.and(
|
||||||
pb.in("sessionId", sessionIds.toArray(new Long[0])),
|
pb.notNull("sessionId"),
|
||||||
pb.equals("coverageStatus", Allowed.DENIED.getKey())
|
pb.equals("coverageStatus", Allowed.DENIED.getKey())
|
||||||
);
|
);
|
||||||
Collection<ExecutionFond> executionFonds = executionFondImdg.getCollectionObjectsByPredicate(predicate);
|
Collection<ExecutionFond> executionFonds = executionFondImdg.getCollectionObjectsByPredicate(predicate);
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue