import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
private List<RecordSet> createRecordSet(Stream stream, int length) {
	List<RecordSet> records = new ArrayList<>();
	for (int i = 0; i < length; i++) {

		long time = (long) (Instant.now().toEpochMilli() - (i * 1000) - (Math.random() * 100));
		log.debug("Set timestamp to {}", time);

		double posX = 11.45 + (System.currentTimeMillis() % 2 == 0 ? -1 * i : i);
		double posY = 45.11 + (System.currentTimeMillis() % 2 == 0 ? -1 * i : i);

		RecordSet record = new RecordSet(stream).channel("number", i)
				.channel("string", System.currentTimeMillis() % 2 == 0 ? "Hello world" : "See you later")
				.channel("boolean", System.currentTimeMillis() % 2 == 0).location(new GeoJsonPoint(posX, posY))
				.timestamp(new Date(time));

		records.add(record);
	}

	return records;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
@Test
public void searchByDistance() {

	Raptor raptor = Utils.createNewAdminInstance();

	log.debug("Search by distance");

	Device dev = createDevice(raptor);
	Stream s = dev.stream("test");

	int qt = 10;
	pushRecords(raptor, s, qt);

	DataQuery q = new DataQuery();
	q.distance(new GeoJsonPoint(11.45, 45.11), 10000, Metrics.KILOMETERS);
	ResultSet results = raptor.Stream().search(s, q);

	log.debug("Found {} records", results.size());
	Assert.assertEquals(qt, results.size());
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
/**
 * Read JSON data from disk and insert those stores.
 * 
 * @return
 */
public @Bean AbstractRepositoryPopulatorFactoryBean repositoryPopulator() {

	ObjectMapper mapper = new ObjectMapper();
	mapper.addMixIn(GeoJsonPoint.class, GeoJsonPointMixin.class);
	mapper.configure(FAIL_ON_UNKNOWN_PROPERTIES, false);

	Jackson2RepositoryPopulatorFactoryBean factoryBean = new Jackson2RepositoryPopulatorFactoryBean();
	factoryBean.setResources(new Resource[] { new ClassPathResource("starbucks-in-nyc.json") });
	factoryBean.setMapper(mapper);

	return factoryBean;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
@Test
public void searchByBoundingBox() {

	Raptor raptor = Utils.createNewAdminInstance();

	log.debug("Search by bounding box");

	Device dev = createDevice(raptor);
	Stream s = dev.stream("test");

	int qt = 10;
	pushRecords(raptor, s, qt);

	ResultSet results = raptor.Stream().search(s,
			new DataQuery().boundingBox(new GeoJsonPoint(12, 45), new GeoJsonPoint(10, 44)));

	log.debug("Found {} records", results.size());
	Assert.assertTrue(results.size() > 0);
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public DataQuery distance(GeoJsonPoint center, double radius, Metrics unit) {
    this.location.distance(center, radius, unit);
    return this;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public DataQuery boundingBox(GeoJsonPoint nw, GeoJsonPoint sw) {
    this.location.boundingBox(nw, sw);
    return this;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
private GeoJsonPoint getGeoJsonPoint(JsonNode parent, String node) {
    JsonNode centerNode = parent.get(node);
    GeoJsonPoint geo = new GeoJsonPoint(centerNode.get("x").asDouble(), centerNode.get("y").asDouble());

    return geo;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public GeoQuery distance(GeoJsonPoint center, double radius, Metrics unit) {
    distance.center = center;
    distance.radius = radius;
    distance.unit = unit;
    return this;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public GeoQuery boundingBox(GeoJsonPoint nw, GeoJsonPoint sw) {
    this.boundingBox.northWest = nw;
    this.boundingBox.southWest = sw;
    return this;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public GeoJsonPoint location() {
    return location;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public GeoJsonPoint getLocation() {
    return location;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
@Override
public DBObject convert(final GeoJsonPoint source) {
	return new BasicDBObject("type", "Point").append("coordinates", new Double[]{ source.getX(), source.getY() });
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public @Nullable GeoJsonPoint getLocation() {
	return location.orElse(null);
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public void setLocation(final @Nullable GeoJsonPoint location) {
	this.location = ofNullable(location);
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public static ProvGeocoding newGeocoding(final GeoJsonPoint point) {
	return new ProvGeocoding(point, GeocodingHelper.class);
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
public ProvGeocoding(final GeoJsonPoint point, final Class<?> geocoder) {
	this.point = point;
	this.geocoder = geocoder;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
@ApiOperation("Find offices inside box")
@RequestMapping(method = RequestMethod.GET)
public List<Office> findByGeometryWithinBox(@RequestParam GeoJsonPoint first, @RequestParam GeoJsonPoint second) {
	List<Office> result = officeService.findByGeometryWithin(new Box(first, second));
	return result;
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
@ApiOperation("Find offices from region inside box")
@RequestMapping(value = "/{region}", method = RequestMethod.GET)
public List<Office> findByRegionAndGeometryWithinBox(@PathVariable String region, @RequestParam GeoJsonPoint first, @RequestParam GeoJsonPoint second) {
	return officeService.findByRegionAndGeometryWithin(region, new Box(first, second));
}
 

import org.springframework.data.mongodb.core.geo.GeoJsonPoint; //导入依赖的package包/类
@Test
public void pullLastUpdate() {

	Raptor raptor = Utils.createNewAdminInstance();

	log.debug("Pull device last update");

	Device dev = createDevice(raptor);
	Stream s = dev.stream("test");

	String msg = "LastUpdate";

	RecordSet r = new RecordSet(s).channel("number", 1).channel("string", msg).channel("boolean", true)
			.location(new GeoJsonPoint(11.45, 45.11));

	raptor.Stream().push(r);

	RecordSet record = raptor.Stream().lastUpdate(s);
	Assert.assertNotNull(record);

	Long val1 = record.value("number").getNumber().longValue();
	Long val2 = r.value("number").getNumber().longValue();

	Assert.assertTrue(val1.equals(val2));
	Assert.assertEquals(record.value("string").getString(), r.value("string").getString());
	Assert.assertEquals(record.value("boolean").getBoolean(), r.value("boolean").getBoolean());

}