Package com.opengamma.master.position

Examples of com.opengamma.master.position.PositionSearchResult

303
304
305
306
307
308
309
310
311
312
313
314
    searchReq.setMinQuantity(position.getQuantity());
    searchReq.setMaxQuantity(position.getQuantity());

    // TODO Compare position attributes

    PositionSearchResult searchResult = _positionMaster.search(searchReq);
    for (ManageablePosition existingPosition : searchResult.getPositions()) {
      ManageablePosition chosenPosition = null;
      if (writtenSecurities.get(0).getUniqueId().getObjectId().equals(existingPosition.getSecurityLink().getObjectId())) {
        chosenPosition = existingPosition;
      } else {
        for (ExternalId id : existingPosition.getSecurityLink().getExternalIds()) {
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
61
    final int pages = (total / PAGE_SIZE) + 1;
    for (int page = 1; page <= pages; page++) {
      request.setPagingRequest(PagingRequest.ofPage(page, PAGE_SIZE));
      System.out.println("Checking position master, page " + request.getPagingRequest());
      try {
        final PositionSearchResult result = getPositionMaster().search(request);
        for (final PositionDocument doc : result.getDocuments()) {
          assertNotNull(doc);
          assertNotNull(doc.getUniqueId());
          assertNotNull(doc.getPosition());
        }
      } catch (final RuntimeException ex) {
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
    ArgumentChecker.notNull(request.getPagingRequest(), "request.pagingRequest");
    ArgumentChecker.notNull(request.getVersionCorrection(), "request.versionCorrection");
    s_logger.debug("search {}", request);

    final VersionCorrection vc = request.getVersionCorrection().withLatestFixed(now());
    final PositionSearchResult result = new PositionSearchResult(vc);

    final ExternalIdSearch securityIdSearch = request.getSecurityIdSearch();
    final Collection<ObjectId> positionObjectIds = request.getPositionObjectIds();
    final Collection<ObjectId> tradeObjectIds = request.getTradeObjectIds();
    if ((positionObjectIds != null && positionObjectIds.size() == 0) ||
        (tradeObjectIds != null && tradeObjectIds.size() == 0) ||
        (ExternalIdSearch.canMatch(securityIdSearch) == false)) {
      result.setPaging(Paging.of(request.getPagingRequest(), 0));
      return result;
    }

    final DbMapSqlParameterSource args = new DbMapSqlParameterSource().addTimestamp("version_as_of_instant", vc.getVersionAsOf()).addTimestamp("corrected_to_instant", vc.getCorrectedTo())
        .addValueNullIgnored("min_quantity", request.getMinQuantity()).addValueNullIgnored("max_quantity", request.getMaxQuantity())
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
64
65
  private FlexiBean createPortfolioNodeData() {
    ManageablePortfolioNode node = data().getNode();
    PositionSearchRequest positionSearch = new PositionSearchRequest();
    positionSearch.setPositionObjectIds(node.getPositionIds());
    PositionSearchResult positionsResult = data().getPositionMaster().search(positionSearch);
    resolveSecurities(positionsResult.getPositions());

    FlexiBean out = createRootData();
    out.put("positionsResult", positionsResult);
    out.put("positions", positionsResult.getPositions());
    return out;
  }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
      searchRequest.addPositionObjectId(ObjectId.parse(tradeIdStr));
    }
    out.put("searchRequest", searchRequest);
   
    if (data().getUriInfo().getQueryParameters().size() > 0) {
      PositionSearchResult searchResult = data().getPositionMaster().search(searchRequest);
      out.put("searchResult", searchResult);
      out.put("paging", new WebPaging(searchResult.getPaging(), data().getUriInfo()));
    }
    return out;
  }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
62
63
  private FlexiBean createPortfolioData() {
    PortfolioDocument doc = data().getVersioned();
    PositionSearchRequest positionSearch = new PositionSearchRequest();
    positionSearch.setPositionObjectIds(doc.getPortfolio().getRootNode().getPositionIds());
    PositionSearchResult positionsResult = data().getPositionMaster().search(positionSearch);
    resolveSecurities(positionsResult.getPositions());

    FlexiBean out = createRootData();
    out.put("positionsResult", positionsResult);
    out.put("positions", positionsResult.getPositions());
    return out;
  }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
81
82
  private FlexiBean createPortfolioNodeData() {
    ManageablePortfolioNode node = data().getNode();
    PositionSearchRequest positionSearch = new PositionSearchRequest();
    positionSearch.setPositionObjectIds(node.getPositionIds());
    PositionSearchResult positionsResult = data().getPositionMaster().search(positionSearch);
    resolveSecurities(positionsResult.getPositions());
   
    FlexiBean out = createRootData();
    out.put("positionsResult", positionsResult);
    out.put("positions", positionsResult.getPositions());
    return out;
  }
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
70
71
  private FlexiBean createPortfolioData() {
    PortfolioDocument doc = data().getPortfolio();
    PositionSearchRequest positionSearch = new PositionSearchRequest();
    positionSearch.setPositionObjectIds(doc.getPortfolio().getRootNode().getPositionIds());
    PositionSearchResult positionsResult = data().getPositionMaster().search(positionSearch);
    resolveSecurities(positionsResult.getPositions());
       
    FlexiBean out = createRootData();
    out.put("positionsResult", positionsResult);
    out.put("positions", positionsResult.getPositions());
    return out;
  }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
    throw new UnsupportedOperationException();
  }

  @Override
  public PositionSearchResult search(final PositionSearchRequest overallRequest) {
    final PositionSearchResult overallResult = new PositionSearchResult();
   
    pagedSearch(new PositionSearchStrategy() {
     
      @Override
      public AbstractDocumentsResult<PositionDocument> search(PositionMaster master, PositionSearchRequest searchRequest) {
        PositionSearchResult masterResult = master.search(searchRequest);
        overallResult.setVersionCorrection(masterResult.getVersionCorrection());
        return masterResult;
      }
    }, overallResult, overallRequest);
   
   
View Full Code Here
237
238
239
240
241
242
243
244
245
246
    for (final PositionDocument doc : _store.values()) {
      if (request.matches(doc)) {
        list.add(clonePositionDocument(doc));
      }
    }
    final PositionSearchResult result = new PositionSearchResult();
    result.setPaging(Paging.of(request.getPagingRequest(), list));
    result.getDocuments().addAll(request.getPagingRequest().select(list));
    return result;
  }
View Full Code Here
TOP

Related Classes of com.opengamma.master.position.PositionSearchResult

  • com.opengamma.financial.portfolio.save.SavePortfolio
  • com.opengamma.integration.copier.portfolio.writer.MasterPortfolioWriter
  • com.opengamma.integration.masterdb.AbstractIntegrationDbPositionMasterTest
  • com.opengamma.master.position.impl.CombinedPositionMaster
  • com.opengamma.master.position.impl.DataPositionMasterResource
  • com.opengamma.master.position.impl.EHCachingPositionMaster
  • com.opengamma.master.position.impl.InMemoryPositionMaster
  • com.opengamma.master.position.impl.MasterPositionSource
  • com.opengamma.master.position.impl.MasterPositionSourceTest
  • com.opengamma.masterdb.position.DbPositionMaster
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.