daoadresseservice/admin/CsvUdtraek.java

package dk.daoas.daoadresseservice;

import java.io.IOException;
import java.sql.SQLException;
import java.util.List;

import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import dk.daoas.daoadresseservice.beans.Address;
import dk.daoas.daoadresseservice.beans.LoggedAddress;
import dk.daoas.daoadresseservice.beans.SearchResult;
import dk.daoas.daoadresseservice.beans.SearchResult.Status;
import dk.daoas.daoadresseservice.db.DatabaseLayer;

/**
 * Servlet implementation class CsvUdtraek
 */
@WebServlet("/CsvUdtraek")
public class CsvUdtraek extends HttpServlet {
        private static final long serialVersionUID = 1L;

        
        protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
                String type = request.getParameter("type");             
                String str = null;
                
                if (type != null) {
                        switch( type ) {
                        case "ikkedaekket":
                                str = udtraekIkkeDaekket();
                                break;
                        case "sammenlign":
                                str = udtraekSammenligning(request);
                                break;
                        default:
                                str = null; 
                                break;
                        }
                }
                
                if (str != null) {
                        response.setContentType("text/csv");
                        response.setHeader("Content-Disposition", "filename=" + type + ".csv");
                        response.getWriter().print(str);
                } else {
                        response.setContentType("text/plain");
                        response.getWriter().print("Type parameter is blank or invalid value");
                }
        }
        
        /* *******************************************
         * 
         */
        private String udtraekIkkeDaekket() {
                AdressSearch search = (AdressSearch) getServletContext().getAttribute("search");
                if (search == null) {
                        return "data struktur ikke indlæst";
                }
                
                StringBuilder sb = new StringBuilder();
                sb.append("gadeid;postnr;vejnavn;husnr;husnrbogstav;distributor\r\n");
                
                for (Address addr : search.getNonCoveredAddresses() ) {
                        sb.append( addr.gadeid ).append(";")
                                .append( addr.postnr ).append(";")
                                .append( addr.vejnavn ).append(";")
                                .append( addr.husnr ).append(";")
                                .append( addr.husnrbogstav ).append(";")
                                .append( addr.distributor != null ? addr.distributor : "" )                             
                                .append( "\n" );
                }
                
                return sb.toString();
        }
        
        /* *******************************************
         * 
         */

        protected String udtraekSammenligning(HttpServletRequest request) throws IOException {
                
                AdressSearch search = (AdressSearch) getServletContext().getAttribute("search");
                if (search == null) {
                        return "data struktur ikke indlæst";
                }
                
                int antal_dage = 2;
                
                if (request.getParameter("antaldage") != null ) {
                        antal_dage = Integer.parseInt( request.getParameter("antaldage") );
                }

                
                try {
                        StringBuilder sb = new StringBuilder();
                        sb.append("besked;postnr;adresse;gl status;ny status\n");
                
                        List<LoggedAddress> addrList = DatabaseLayer.getLoggedAdresses(antal_dage);                     
                        
                        for(LoggedAddress addr : addrList) {
                                SearchResult res = search.search("" + addr.postnr, addr.adresse);
                                
                                if (res.status != Status.STATUS_OK) { //Ny service fandt ikke adressen) {
                                        
                                        if (addr.status != 10 ) {//Hvis gl service kunne finde adressen så er vi ude i en regression

                                                appendLogLine("ny fejler, gl ok", sb, addr, res);
                                                
                                        } else {
                                                appendLogLine("ny fejler, gl fejler !!!", sb, addr, res);
                                        }

                                } else {
                                        if (addr.status == 10) {
                                                appendLogLine("ny OK, gl fejler", sb, addr, res);

                                        } else if (addr.status == 12 ) {
                                                
                                                if (res.google == false && res.osm == false) {
                                                        
                                                        appendLogLine("ny Direkte, gl Google", sb, addr, res);                                                  
                                                }                                               
                                        }
                                }
                                
                                if (res.osm || res.google) {
                                        try {
                                                Thread.sleep(50);//Back-off external services
                                        } catch(InterruptedException e) {
                                                //
                                        }
                                }
                        }
                        sb.append("Antal adresser testet: ;").append(addrList.size()).append(";;;\n");
                        

                        return sb.toString();
                        
                } catch(SQLException e) {
                        throw new IOException(e);
                }
        }
        
    private void appendLogLine(String msg, StringBuilder sb, LoggedAddress addr, SearchResult res) {
        
                sb.append(msg).append(";").append(addr.postnr).append(";")
                        .append(addr.adresse).append(";")
                        .append(addr.status).append(";").append(res.status).append("\n");
        
    }

}
1	torben	2332	package dk.daoas.daoadresseservice;
2
3			import java.io.IOException;
4	torben	2384	import java.sql.SQLException;
5			import java.util.List;
6	torben	2332
7			import javax.servlet.ServletException;
8			import javax.servlet.annotation.WebServlet;
9			import javax.servlet.http.HttpServlet;
10			import javax.servlet.http.HttpServletRequest;
11			import javax.servlet.http.HttpServletResponse;
12
13			import dk.daoas.daoadresseservice.beans.Address;
14	torben	2384	import dk.daoas.daoadresseservice.beans.LoggedAddress;
15			import dk.daoas.daoadresseservice.beans.SearchResult;
16			import dk.daoas.daoadresseservice.beans.SearchResult.Status;
17			import dk.daoas.daoadresseservice.db.DatabaseLayer;
18	torben	2332
19			/**
20			* Servlet implementation class CsvUdtraek
21			*/
22			@WebServlet("/CsvUdtraek")
23			public class CsvUdtraek extends HttpServlet {
24			private static final long serialVersionUID = 1L;
25
26
27			protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
28	torben	2384	String type = request.getParameter("type");
29			String str = null;
30	torben	2332
31	torben	2384	if (type != null) {
32			switch( type ) {
33			case "ikkedaekket":
34			str = udtraekIkkeDaekket();
35			break;
36			case "sammenlign":
37			str = udtraekSammenligning(request);
38			break;
39			default:
40			str = null;
41			break;
42			}
43	torben	2332	}
44
45	torben	2384	if (str != null) {
46			response.setContentType("text/csv");
47			response.setHeader("Content-Disposition", "filename=" + type + ".csv");
48			response.getWriter().print(str);
49			} else {
50			response.setContentType("text/plain");
51			response.getWriter().print("Type parameter is blank or invalid value");
52			}
53	torben	2332	}
54
55	torben	2384	/* *******************************************
56			*
57			*/
58	torben	2332	private String udtraekIkkeDaekket() {
59			AdressSearch search = (AdressSearch) getServletContext().getAttribute("search");
60			if (search == null) {
61			return "data struktur ikke indlæst";
62			}
63
64			StringBuilder sb = new StringBuilder();
65	torben	2335	sb.append("gadeid;postnr;vejnavn;husnr;husnrbogstav;distributor\r\n");
66	torben	2332
67			for (Address addr : search.getNonCoveredAddresses() ) {
68	torben	2335	sb.append( addr.gadeid ).append(";")
69	torben	2332	.append( addr.postnr ).append(";")
70			.append( addr.vejnavn ).append(";")
71			.append( addr.husnr ).append(";")
72			.append( addr.husnrbogstav ).append(";")
73			.append( addr.distributor != null ? addr.distributor : "" )
74			.append( "\n" );
75			}
76
77			return sb.toString();
78			}
79	torben	2384
80			/* *******************************************
81			*
82			*/
83	torben	2332
84	torben	2384	protected String udtraekSammenligning(HttpServletRequest request) throws IOException {
85
86			AdressSearch search = (AdressSearch) getServletContext().getAttribute("search");
87			if (search == null) {
88			return "data struktur ikke indlæst";
89			}
90
91			int antal_dage = 2;
92
93			if (request.getParameter("antaldage") != null ) {
94	torben	2385	antal_dage = Integer.parseInt( request.getParameter("antaldage") );
95	torben	2384	}
96
97
98			try {
99			StringBuilder sb = new StringBuilder();
100			sb.append("besked;postnr;adresse;gl status;ny status\n");
101
102			List<LoggedAddress> addrList = DatabaseLayer.getLoggedAdresses(antal_dage);
103
104			for(LoggedAddress addr : addrList) {
105			SearchResult res = search.search("" + addr.postnr, addr.adresse);
106
107			if (res.status != Status.STATUS_OK) { //Ny service fandt ikke adressen) {
108
109			if (addr.status != 10 ) {//Hvis gl service kunne finde adressen så er vi ude i en regression
110
111			appendLogLine("ny fejler, gl ok", sb, addr, res);
112
113			} else {
114			appendLogLine("ny fejler, gl fejler !!!", sb, addr, res);
115			}
116
117			} else {
118			if (addr.status == 10) {
119			appendLogLine("ny OK, gl fejler", sb, addr, res);
120
121			} else if (addr.status == 12 ) {
122
123			if (res.google == false && res.osm == false) {
124
125			appendLogLine("ny Direkte, gl Google", sb, addr, res);
126			}
127			}
128			}
129
130			if (res.osm \|\| res.google) {
131			try {
132			Thread.sleep(50);//Back-off external services
133			} catch(InterruptedException e) {
134			//
135			}
136			}
137			}
138			sb.append("Antal adresser testet: ;").append(addrList.size()).append(";;;\n");
139
140
141			return sb.toString();
142
143			} catch(SQLException e) {
144			throw new IOException(e);
145			}
146			}
147
148			private void appendLogLine(String msg, StringBuilder sb, LoggedAddress addr, SearchResult res) {
149
150			sb.append(msg).append(";").append(addr.postnr).append(";")
151			.append(addr.adresse).append(";")
152			.append(addr.status).append(";").append(res.status).append("\n");
153
154			}
155
156	torben	2332	}