package dk.daoas.adressevedligehold.dawa;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.TreeMap;
import java.util.TreeSet;

import dk.daoas.adressevedligehold.MailSender;
import dk.daoas.adressevedligehold.beans.Address;
import dk.daoas.adressevedligehold.beans.Address.AddressState;
import dk.daoas.adressevedligehold.db.DatabaseCoverageUpdate;
import dk.daoas.adressevedligehold.tasks.Task;
import dk.daoas.adressevedligehold.tasks.TaskLogger;
import dk.daoas.adressevedligehold.util.DeduplicateHelper;
import dk.daoas.adressevedligehold.util.TimingHelper;

/*
 * Alle regioner: http://dawa.aws.dk/regioner/
 * Enkelt region: http://dawa.aws.dk/regioner/{region}
 */


public class DawaTask extends Task {
	
	final String kommentarTemplate = "Oprettet via DAWA";
	
	private TaskLogger logger = TaskLogger.getInstance(); 
	
	private short regionCode;
	private String regionName;
	
	
	
	DatabaseCoverageUpdate db = new DatabaseCoverageUpdate();
	
	DeduplicateHelper<String> dedup = new DeduplicateHelper<>(); 
	
	public DawaTask(short regionCode, String regionName){
		this.regionCode = regionCode;		
		this.regionName = regionName;
		
	}

	@Override
	protected void taskRun() throws Exception {
		TimingHelper timer = new TimingHelper();
			
		DawaWebservice dawa = new DawaWebservice();
		TreeMap<String, DawaGade> search = new TreeMap<>();
		
		// stage 1 - hent alle data			
		List<Address> adresser = db.getAllAdresses();
		
		
		// stage 2 opbyg søge struktur		
		logger.info("Building search structure");

		
		for (Address addr : adresser) {
			String dav = getDAVid(addr);
			DawaGade gade = search.get(dav);
			if (gade == null) {
				gade = new DawaGade();
				search.put(dav, gade);
			}
			gade.gadeids.add( addr.gadeid );
			gade.adresser.add(addr);			
		}
		logger.info("Build search structure done");
		
		Map<String,Integer> kommuner = dawa.kommunerIRegion(regionCode);
		
		String subject = "DAWA indlæsning done";
		
		StringBuilder headerSB = new StringBuilder();
		headerSB.append("<h1>Indlæsnings rapport for " + regionName + " / " + regionCode + " </h1><br>");
		
		int totalAntalNye = 0;
		int totalAntalFejl = 0;
		int totalAntalUkendt = 0;
		int totalAntalDobbelt = 0;
		
		
		StringBuilder sb = new StringBuilder();
		
		for (Map.Entry<String, Integer> entry : kommuner.entrySet()) {
			int kommunekode = entry.getValue();
			String kommunenavn = entry.getKey();
			
			logger.info("Behandler: " + kommunekode + " " + kommunenavn);
		
			
			List<Address> dawaListe = dawa.adresserIKommune(kommunekode);
			// stage 3 søg		
			Set<String> ukendteDAV = new TreeSet<>();
			Set<String> dobbeltGadeidDAV = new TreeSet<>();
			List<Address> nyeAdresser = new ArrayList<>();
			
			for (Address dawaAddr : dawaListe) {
				String dav = getDAVid(dawaAddr);
				DawaGade gade = search.get(dav);
				if (gade == null) {
					ukendteDAV.add(dav + " " + dawaAddr.vejnavn);
					continue;
				}
				
				if (gade.gadeids.size() != 1) {
					dobbeltGadeidDAV.add(dav + " " + dawaAddr.vejnavn);
				}
				
				boolean fundet = false;
				for (Address target : gade.adresser) {
					if ( target.husnr == dawaAddr.husnr && target.husnrbogstav.equals(dawaAddr.husnrbogstav) ) {
						fundet = true;
						break;
					}	
				}
				
				if (fundet == false) {
					dawaAddr.gadeid = gade.gadeids.iterator().next();
					dawaAddr.state = AddressState.CREATED;
					dawaAddr.kommentar = kommentarTemplate;
					nyeAdresser.add(dawaAddr);
				}			
			}
			logger.info("Address Search done - starting save to DB");
			
			db.saveNewAddresses(nyeAdresser);
			
			logger.info("Save to db done - sending report mail");
			
			List<Address> saveOK = new ArrayList<>();
			List<Address> saveFail = new ArrayList<>();
			for (Address a : nyeAdresser) {
				if (a.state == AddressState.CREATE_FAIL) {
					saveFail.add(a);
				} else {
					saveOK.add(a);
				}
			}
			
			totalAntalNye += saveOK.size();
			totalAntalFejl += saveFail.size();
			totalAntalUkendt += ukendteDAV.size();
			totalAntalDobbelt += dobbeltGadeidDAV.size();
	
			
			sb.append("<h2>Kommune: " + kommunenavn + " / " + kommunekode + "</h2><br>\n");
			sb.append("Antal Inserts: " + saveOK.size() + "<br>\n");
			sb.append("Antal insert fails: " + saveFail.size() + "<br>\n");
			sb.append("Antal ukendte dav: " + ukendteDAV.size() + "<br>\n");
			sb.append("Antal dobbelt gadeid dav: " + dobbeltGadeidDAV.size() + "<br>\n");
			
			sb.append("<h3>Adresser ok:</h3>\n");
			addressTable(sb, saveOK);
			
			sb.append("<h3>SQL INSERT fejl:</h3>\n");
			addressTable(sb, saveFail);
			
			sb.append("<h3>Ukendte DAV:</h3>\n");
			for (String dav : ukendteDAV) {
				sb.append(dav + "<br>\n");
			}
			
			sb.append("<h3>Dobbelt gadeid DAV:</h3>\n");
			for (String dav : dobbeltGadeidDAV) {
				sb.append(dav + "<br>\n");
			}
			
		}
		
		headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n");
		headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n");
		headerSB.append("Antal ukendte dav: " + totalAntalUkendt + "<br>\n");
		headerSB.append("Antal dobbelt gadeid dav: " + totalAntalDobbelt + "<br>\n");
		headerSB.append("Elapsed: " + timer.getElapsed() + " ms.<br>\n");
		
		MailSender.sendMail(subject, headerSB.toString() + sb.toString() );

	}
	
	private void addressTable(StringBuilder sb, List<Address> addr) {
		sb.append("<table border=0>\n");
		sb.append("<tr><th>GadeID</th><th>Postnr</th><th>Kom.kode</th><th>Vejkode</th><th>Vejnavn</th><th>Husnr<th><th>Litra</th></tr>");
		for (Address a: addr) {
			sb.append("<tr>");
			sb.append("<td>&nbsp;").append(a.gadeid).append(" </td>");
			sb.append("<td>&nbsp;").append(a.postnr).append(" </td>");
			sb.append("<td>&nbsp;").append(a.kommunekode).append(" </td>");
			sb.append("<td>&nbsp;").append(a.vejkode).append(" </td>");
			sb.append("<td>&nbsp;").append(a.vejnavn).append(" </td>");
			sb.append("<td>&nbsp;").append(a.husnr).append(" </td>");
			sb.append("<td>&nbsp;").append(a.husnrbogstav).append(" </td>");
		}
		sb.append("</table><br>\n");
		
	}
	
	String getDAVid(Address addr) {
		String dav = String.format("%04d%03d%04d", addr.postnr, addr.kommunekode, addr.vejkode);
		
		return dedup.getInstance(dav);
	}

	@Override
	public String getDescription() {
		return "DawaTask";
	}

	@Override
	public String getDetail() {
		return "Region: " + regionCode + "/" + regionName;
	}

	@Override
	public double getPercentCompleted() {
		return 0;
	}
	


}