daoas/daoadresseservice/OSMStreetnameHelper.java

package dk.daoas.daoadresseservice;

import java.net.URLEncoder;

import com.google.gson.Gson;

import dk.daoas.daoadresseservice.admin.ServiceConfig;
import dk.daoas.daoadresseservice.beans.OSMAddress;
import dk.daoas.daoadresseservice.beans.SearchResult;
import dk.daoas.daoadresseservice.util.HttpUtil;
import dk.thoerup.circuitbreaker.CircuitBreaker;
import dk.thoerup.circuitbreaker.CircuitBreakerManager;
import dk.thoerup.circuitbreaker.CircuitInvocation;

public class OSMStreetnameHelper implements StreetnameHelper {
        
        ServiceConfig conf;
        
        public OSMStreetnameHelper(ServiceConfig conf) {
                this.conf = conf;
        }

        @Override
        public String proposeStreetName(SearchResult result, int postnr, String vejnavn) {
                if (conf.useOpenStreetMaps == false)
                        return null;
                
                result.osm = true;
                
                try {

                        OSMInvocation wrapper = new OSMInvocation( conf, postnr, vejnavn );
                        CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("osm");

                        result.osmVej = (String) breaker.invoke(wrapper);
                        return result.osmVej;
                        
                } catch (Exception e) {
                        System.out.println( "OSMError: " + e.getClass().getName() +" / "+ e.getMessage() );
                }                                                               
                return null;
        }

        static class OSMInvocation implements CircuitInvocation {
                int postnr;
                String vejnavn;
                ServiceConfig conf;
                
                public OSMInvocation(ServiceConfig conf, int postnr, String vejnavn) {
                        this.conf = conf;
                        this.postnr= postnr;
                        this.vejnavn = vejnavn;                 
                }
                
                @Override
                public String proceed() throws Exception {
                        //TimingHelper timer = new TimingHelper();
                        String encVej = URLEncoder.encode(vejnavn, "UTF-8");
                        
                        
                        String url = conf.nominatimBase + "/search?country=DK&street=" + encVej + "&postalcode=" + postnr + "&format=json&addressdetails=1";
                        
                        //String url = "http://nominatim.openstreetmap.org/search?country=DK&street=" + encVej + "&format=json&addressdetails=1";
                        //System.out.println (url);
                        
                        String json = HttpUtil.getContentString(url, conf.osmTimeout);
                        //System.out.println(json);
                        
                        Gson gson = new Gson();
                        OSMAddress adrList[] = gson.fromJson(json, OSMAddress[].class);
                        
                        //timer.printElapsed("OSM elapsed");
                        
                        //System.out.println("Count: " + adrList.length);
                        if (adrList.length != 1)
                                return null;
                                
                        if (adrList[0].address != null) {
                                return adrList[0].address.road;
                        }

                        return null;
                }
        }

        
}
1	package dk.daoas.daoadresseservice;
2
3	import java.net.URLEncoder;
4
5	import com.google.gson.Gson;
6
7	import dk.daoas.daoadresseservice.admin.ServiceConfig;
8	import dk.daoas.daoadresseservice.beans.OSMAddress;
9	import dk.daoas.daoadresseservice.beans.SearchResult;
10	import dk.daoas.daoadresseservice.util.HttpUtil;
11	import dk.thoerup.circuitbreaker.CircuitBreaker;
12	import dk.thoerup.circuitbreaker.CircuitBreakerManager;
13	import dk.thoerup.circuitbreaker.CircuitInvocation;
14
15	public class OSMStreetnameHelper implements StreetnameHelper {
16
17	ServiceConfig conf;
18
19	public OSMStreetnameHelper(ServiceConfig conf) {
20	this.conf = conf;
21	}
22
23	@Override
24	public String proposeStreetName(SearchResult result, int postnr, String vejnavn) {
25	if (conf.useOpenStreetMaps == false)
26	return null;
27
28	result.osm = true;
29
30	try {
31
32	OSMInvocation wrapper = new OSMInvocation( conf, postnr, vejnavn );
33	CircuitBreaker breaker = CircuitBreakerManager.getManager().getCircuitBreaker("osm");
34
35	result.osmVej = (String) breaker.invoke(wrapper);
36	return result.osmVej;
37
38	} catch (Exception e) {
39	System.out.println( "OSMError: " + e.getClass().getName() +" / "+ e.getMessage() );
40	}
41	return null;
42	}
43
44	static class OSMInvocation implements CircuitInvocation {
45	int postnr;
46	String vejnavn;
47	ServiceConfig conf;
48
49	public OSMInvocation(ServiceConfig conf, int postnr, String vejnavn) {
50	this.conf = conf;
51	this.postnr= postnr;
52	this.vejnavn = vejnavn;
53	}
54
55	@Override
56	public String proceed() throws Exception {
57	//TimingHelper timer = new TimingHelper();
58	String encVej = URLEncoder.encode(vejnavn, "UTF-8");
59
60
61	String url = conf.nominatimBase + "/search?country=DK&street=" + encVej + "&postalcode=" + postnr + "&format=json&addressdetails=1";
62
63	//String url = "http://nominatim.openstreetmap.org/search?country=DK&street=" + encVej + "&format=json&addressdetails=1";
64	//System.out.println (url);
65
66	String json = HttpUtil.getContentString(url, conf.osmTimeout);
67	//System.out.println(json);
68
69	Gson gson = new Gson();
70	OSMAddress adrList[] = gson.fromJson(json, OSMAddress[].class);
71
72	//timer.printElapsed("OSM elapsed");
73
74	//System.out.println("Count: " + adrList.length);
75	if (adrList.length != 1)
76	return null;
77
78	if (adrList[0].address != null) {
79	return adrList[0].address.road;
80	}
81
82	return null;
83	}
84	}
85
86
87	}