60 lines
2.0 KiB
Java
60 lines
2.0 KiB
Java
package org.gcube.portlets.admin.accountingmanager.server.amservice.query;
|
|
|
|
import java.util.ArrayList;
|
|
|
|
import org.gcube.accounting.aggregation.AggregatedStorageUsageRecord;
|
|
import org.gcube.accounting.analytics.Filter;
|
|
import org.gcube.accounting.analytics.TemporalConstraint;
|
|
import org.gcube.portlets.admin.accountingmanager.server.amservice.PeriodModeMap;
|
|
import org.gcube.portlets.admin.accountingmanager.shared.data.AccountingFilter;
|
|
import org.gcube.portlets.admin.accountingmanager.shared.data.query.SeriesRequest;
|
|
import org.gcube.portlets.admin.accountingmanager.shared.exception.AccountingManagerServiceException;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
/**
|
|
* Accounting Query 4 Storage
|
|
*
|
|
* @author "Giancarlo Panichi" email: <a
|
|
* href="mailto:g.panichi@isti.cnr.it">g.panichi@isti.cnr.it</a>
|
|
*
|
|
*/
|
|
public class AccountingQuery4Storage extends AccountingQueryBuilder {
|
|
protected static Logger logger = LoggerFactory
|
|
.getLogger(AccountingQuery4Storage.class);
|
|
private SeriesRequest seriesRequest;
|
|
|
|
public AccountingQuery4Storage(SeriesRequest seriesRequest) {
|
|
this.seriesRequest = seriesRequest;
|
|
}
|
|
|
|
@Override
|
|
public void buildOpEx() throws AccountingManagerServiceException {
|
|
|
|
TemporalConstraint temporalConstraint = new TemporalConstraint(
|
|
seriesRequest.getAccountingPeriod().getStartDate().getTime(),
|
|
seriesRequest.getAccountingPeriod().getEndDate().getTime(),
|
|
PeriodModeMap.getMode(seriesRequest.getAccountingPeriod()
|
|
.getPeriod()));
|
|
|
|
ArrayList<AccountingFilter> accountingFilters = seriesRequest
|
|
.getFilters();
|
|
|
|
ArrayList<Filter> filters=null;
|
|
if (accountingFilters != null) {
|
|
filters = new ArrayList<Filter>();
|
|
for (AccountingFilter accountigFilters : accountingFilters) {
|
|
Filter filter = new Filter(accountigFilters.getFilterKey()
|
|
.getKey(), accountigFilters.getValue());
|
|
filters.add(filter);
|
|
}
|
|
}
|
|
|
|
AccountingQuery invocation = new AccountingQuery(
|
|
AggregatedStorageUsageRecord.class, temporalConstraint, filters);
|
|
|
|
accountingQuerySpec.setOp(invocation);
|
|
|
|
}
|
|
}
|