本文整理了Java中org.sentilo.common.domain.QueryFilterParams.<init>方法的一些代码示例，展示了QueryFilterParams.<init>的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。QueryFilterParams.<init>方法的具体详情如下：
包路径：org.sentilo.common.domain.QueryFilterParams
类名称：QueryFilterParams
方法名：<init>

QueryFilterParams.<init>介绍

暂无

代码示例

代码示例来源：origin: sentilo/sentilo

public OrderInputMessage(final String providerId, final String sensorId, final Date from, final Date to, final Integer limit) {
 this(providerId, sensorId);
 queryFilters = new QueryFilterParams(from, to, limit);
}

代码示例来源：origin: sentilo/sentilo

public DataInputMessage(final String providerId, final String sensorId, final Date from, final Date to, final Integer limit) {
 this(providerId, sensorId);
 queryFilters = new QueryFilterParams(from, to, limit);
}

代码示例来源：origin: sentilo/sentilo

public AlarmInputMessage(final String alertId, final Date from, final Date to, final Integer limit) {
 this(alertId);
 queryFilters = new QueryFilterParams(from, to, limit);
}

代码示例来源：origin: sentilo/sentilo

@Override
public Observation getLastObservation(final Sensor sensor) {
 final QueryFilterParams filterParams = new QueryFilterParams(1);
 return getLastObservation(sensor, filterParams);
}

代码示例来源：origin: sentilo/sentilo

@Override
public SortedEventsList<Observation> getLastObservations(final Sensor sensor, final Date from, final Date to, Integer limit) {
 // limits under 0 are not allowed
 if (limit != null && limit <= 0) {
  limit = null;
 }
 final QueryFilterParams filterParams = new QueryFilterParams(from, to, limit);
 return getFilteredLastObservations(sensor, filterParams);
}

代码示例来源：origin: sentilo/sentilo

@Override
public SortedEventsList<AlarmMessage> getLastAlarmsMessages(final Sensor sensor) {
 // To retrieve the latest alarms associated with the sensor alerts, we must first retrieve the
 // sensor alerts list and then, for each alert, recover their last alarm.
 final List<AlarmMessage> lastAlarmMessages = new ArrayList<AlarmMessage>();
 final List<Alert> sensorAlerts = getSensorAlerts(sensor);
 for (final Alert alert : sensorAlerts) {
  final QueryFilterParams filterParams = new QueryFilterParams(SentiloConstants.NUM_MAXIM_ELEMENTS);
  final AlarmInputMessage message = new AlarmInputMessage(alert.getId(), filterParams);
  final AlarmsOutputMessage outMessage = platformTemplate.getAlarmOps().getLastAlarmMessages(message);
  if (!CollectionUtils.isEmpty(outMessage.getAlarms())) {
   lastAlarmMessages.addAll(outMessage.getAlarms());
  }
 }
 return new SortedEventsList<AlarmMessage>(lastAlarmMessages);
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _07_getEmptyLastObservationsFromSensorInPeriod() throws Exception {
 final QueryFilterParams filterParams =
   new QueryFilterParams(new Date(System.currentTimeMillis() + 1000000), new Date(System.currentTimeMillis() + 2000000));
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, SENSOR1, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && CollectionUtils.isEmpty(response.getObservations()));
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _12_getEmptyLastObservationsFromProviderInPeriod() throws Exception {
 final QueryFilterParams filterParams =
   new QueryFilterParams(new Date(System.currentTimeMillis() + 1000000), new Date(System.currentTimeMillis() + 2000000));
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && CollectionUtils.isEmpty(response.getSensors()));
}

代码示例来源：origin: sentilo/sentilo

StringUtils.hasText(from) ? new QueryFilterParams(DateUtils.stringToDate(from), DateUtils.stringToDate(to), 1) : new QueryFilterParams(1);

代码示例来源：origin: sentilo/sentilo

@Test
public void _08_getLastObservationFromSensorInPeriod() throws Exception {
 final QueryFilterParams filterParams = new QueryFilterParams(new Date(System.currentTimeMillis() - 6000000), new Date());
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, SENSOR1, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getObservations()));
 assertEquals(1, response.getObservations().size());
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _09_getLastObservationsFromSensorInPeriod() throws Exception {
 final int num_observations = 3;
 final QueryFilterParams filterParams = new QueryFilterParams(new Date(System.currentTimeMillis() - 6000000), new Date(), num_observations);
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, SENSOR1, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getObservations()));
 assertEquals(num_observations, response.getObservations().size());
}

代码示例来源：origin: sentilo/sentilo

@Override
public SortedEventsList<OrderMessage> getLastOrderMessages(final Sensor sensor) {
 final QueryFilterParams filterParams = new QueryFilterParams(SentiloConstants.NUM_MAXIM_ELEMENTS);
 final OrderInputMessage message = new OrderInputMessage(sensor.getProviderId(), sensor.getSensorId(), filterParams);
 final OrdersOutputMessage outMessage = platformTemplate.getOrderOps().getLastOrders(message);
 return new SortedEventsList<OrderMessage>(outMessage.getOrders());
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _13_getLastObservationFromProviderInPeriod() throws Exception {
 final QueryFilterParams filterParams = new QueryFilterParams(new Date(System.currentTimeMillis() - 60000000), new Date());
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getSensors()));
 // La lista contiene almenos dos registros, uno para cada sensor del proveedor que hemos
 // utilizado en el test
 assertTrue(response.getSensors().size() >= 2);
 // Y para cada sensor tendremos una observacion
 assertTrue(countObservations(response.getSensors()) == response.getSensors().size());
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _14_getLastObservationsFromProviderInPeriod() throws Exception {
 final int num_observations = 3;
 final QueryFilterParams filterParams = new QueryFilterParams(new Date(System.currentTimeMillis() - 6000000), new Date(), num_observations);
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getSensors()));
 // La lista contiene almenos dos registros, uno para cada sensor del proveedor que hemos
 // utilizado en el test
 assertTrue(response.getSensors().size() >= 2);
 // Y para cada sensor tenemos almenos 2 observaciones que entran dentro del periodo indicado,
 // las utilizadas en este test --> un minimo de 4 observaciones en total
 assertTrue(countObservations(response.getSensors()) > 4);
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _04_getFilteredLastAlarmMessages() throws Exception {
 final QueryFilterParams filterParams = new QueryFilterParams(1);
 final AlarmInputMessage message = new AlarmInputMessage(ALERT_NAME, filterParams);
 final AlarmsOutputMessage response = platformTemplate.getAlarmOps().getLastAlarmMessages(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getAlarms()));
 assertEquals(1, response.getAlarms().size());
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _06_getLastObservationsFromSensor() throws Exception {
 final int num_observations = 3;
 final QueryFilterParams filterParams = new QueryFilterParams(3);
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, SENSOR1, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getObservations()));
 assertEquals(num_observations, response.getObservations().size());
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _15_removeLastObservationsFromSensor() throws Exception {
 final QueryFilterParams filterParams = new QueryFilterParams(SentiloConstants.NUM_MAXIM_ELEMENTS);
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, SENSOR1, filterParams);
 final int countBeforeRemove = platformTemplate.getDataOps().getLastObservations(message).getObservations().size();
 platformTemplate.getDataOps().removeLastObservations(message);
 final int countAfterRemove = platformTemplate.getDataOps().getLastObservations(message).getObservations().size();
 assertTrue(countAfterRemove == SentiloConstants.NUM_MAXIM_ELEMENTS || countAfterRemove == countBeforeRemove - 1);
}

代码示例来源：origin: sentilo/sentilo

@Test
public void _11_getLastObservationsFromProvider() throws Exception {
 final int num_observations = 3;
 final QueryFilterParams filterParams = new QueryFilterParams(num_observations);
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, filterParams);
 final ObservationsOutputMessage response = platformTemplate.getDataOps().getLastObservations(message);
 assertTrue(response != null && !CollectionUtils.isEmpty(response.getSensors()));
 // La lista contiene almenos dos registros, uno para cada sensor del proveedor que hemos
 // utilizado en el test
 assertTrue(response.getSensors().size() >= 2);
 // Y para cada sensor tenemos almenos 2 observaciones, las utilizadas en este test --> un minimo
 // de 4 observaciones en total
 assertTrue(countObservations(response.getSensors()) >= 4);
}

代码示例来源：origin: sentilo/sentilo

final String limitText = Integer.toString(limit);
DataInputMessage message = new DataInputMessage(PROVIDER_ID, SENSOR_ID, new QueryFilterParams(from, to, limit));
RequestParameters parameters = RequestUtils.buildParameters(message);
assertEquals(parameters.size(), 3);
assertEquals(parameters.get(RequestParameters.TO), toText);
message = new DataInputMessage(PROVIDER_ID, SENSOR_ID, new QueryFilterParams(from.getTime(), to.getTime(), limit));
parameters = RequestUtils.buildParameters(message);
assertEquals(parameters.size(), 3);
assertEquals(parameters.get(RequestParameters.TO), toText);
message = new DataInputMessage(PROVIDER_ID, SENSOR_ID, new QueryFilterParams(from, to));
parameters = RequestUtils.buildParameters(message);
assertEquals(parameters.size(), 2);
assertEquals(parameters.get(RequestParameters.TO), toText);
message = new DataInputMessage(PROVIDER_ID, SENSOR_ID, new QueryFilterParams(from, null));
parameters = RequestUtils.buildParameters(message);
assertEquals(parameters.size(), 1);

代码示例来源：origin: sentilo/sentilo

@Test
public void _16_removeLastObservationsFromProvider() throws Exception {
 final QueryFilterParams filterParams = new QueryFilterParams(SentiloConstants.NUM_MAXIM_ELEMENTS);
 final DataInputMessage message = new DataInputMessage(PROVIDER_ID, filterParams);
 final int countBeforeRemove = countObservations(platformTemplate.getDataOps().getLastObservations(message).getSensors());
 platformTemplate.getDataOps().removeLastObservations(message);
 final int countAfterRemove = countObservations(platformTemplate.getDataOps().getLastObservations(message).getSensors());
 assertTrue(countAfterRemove <= countBeforeRemove);
}