/[projects]/dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/dawa/DawaTask.java
ViewVC logotype

Diff of /dao/DaoAdresseVedligehold/src/main/java/dk/daoas/adressevedligehold/dawa/DawaTask.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 3006 by torben, Tue Apr 19 15:49:14 2016 UTC revision 3013 by torben, Wed Apr 20 14:15:02 2016 UTC
# Line 3  package dk.daoas.adressevedligehold.dawa Line 3  package dk.daoas.adressevedligehold.dawa
3  import java.util.ArrayList;  import java.util.ArrayList;
4  import java.util.List;  import java.util.List;
5  import java.util.Map;  import java.util.Map;
 import java.util.Set;  
6  import java.util.TreeMap;  import java.util.TreeMap;
 import java.util.TreeSet;  
7    
8  import dk.daoas.adressevedligehold.MailSender;  import dk.daoas.adressevedligehold.MailSender;
9  import dk.daoas.adressevedligehold.beans.Address;  import dk.daoas.adressevedligehold.beans.Address;
# Line 13  import dk.daoas.adressevedligehold.beans Line 11  import dk.daoas.adressevedligehold.beans
11  import dk.daoas.adressevedligehold.db.DatabaseCoverageUpdate;  import dk.daoas.adressevedligehold.db.DatabaseCoverageUpdate;
12  import dk.daoas.adressevedligehold.tasks.Task;  import dk.daoas.adressevedligehold.tasks.Task;
13  import dk.daoas.adressevedligehold.tasks.TaskLogger;  import dk.daoas.adressevedligehold.tasks.TaskLogger;
14    import dk.daoas.adressevedligehold.util.CountMap;
15  import dk.daoas.adressevedligehold.util.DeduplicateHelper;  import dk.daoas.adressevedligehold.util.DeduplicateHelper;
16  import dk.daoas.adressevedligehold.util.TimingHelper;  import dk.daoas.adressevedligehold.util.TimingHelper;
17    
# Line 72  public class DawaTask extends Task { Line 71  public class DawaTask extends Task {
71                                    
72                  Map<String,Integer> kommuner = dawa.kommunerIRegion(regionCode);                  Map<String,Integer> kommuner = dawa.kommunerIRegion(regionCode);
73                                    
74                  String subject = "DAWA indlæsning done";                  String subject = "DAWA indlæsning - " + regionName;
75                                    
76                  StringBuilder headerSB = new StringBuilder();                  StringBuilder headerSB = new StringBuilder();
77                  headerSB.append("<h1>Indlæsnings rapport for " + regionName + " / " + regionCode + " </h1><br>");                  headerSB.append("<h1>Indlæsnings rapport for " + regionName + " </h1><br>");
78                                    
79                  int totalAntalNye = 0;                  int totalAntalNye = 0;
80                  int totalAntalFejl = 0;                  int totalAntalFejl = 0;
# Line 94  public class DawaTask extends Task { Line 93  public class DawaTask extends Task {
93                                                    
94                          List<Address> dawaListe = dawa.adresserIKommune(kommunekode);                          List<Address> dawaListe = dawa.adresserIKommune(kommunekode);
95                          // stage 3 søg                                  // stage 3 søg        
96                          Set<String> ukendteDAV = new TreeSet<>();                          CountMap ukendteDAV = new CountMap();
97                          Set<String> dobbeltGadeidDAV = new TreeSet<>();                          CountMap dobbeltGadeidDAV = new CountMap();
98                          List<Address> nyeAdresser = new ArrayList<>();                          List<Address> nyeAdresser = new ArrayList<>();
99                                                    
100                          for (Address dawaAddr : dawaListe) {                          for (Address dawaAddr : dawaListe) {
101                                  String dav = getDAVid(dawaAddr);                                  String dav = getDAVid(dawaAddr);
102                                  DawaGade gade = search.get(dav);                                  DawaGade gade = search.get(dav);
103                                  if (gade == null) {                                  if (gade == null) {
104                                          ukendteDAV.add(dav + " " + dawaAddr.vejnavn);                                          String key = dav + " " + dawaAddr.vejnavn;
105                                            ukendteDAV.increment(key);
106                                          continue;                                          continue;
107                                  }                                  }
108                                                                    
109                                  if (gade.gadeids.size() != 1) {                                  if (gade.gadeids.size() != 1) {
110                                          dobbeltGadeidDAV.add(dav + " " + dawaAddr.vejnavn);                                          String key = dav + " " + dawaAddr.vejnavn;
111                                            dobbeltGadeidDAV.increment(key);
112                                            continue;
113                                  }                                  }
114                                                                    
115                                  boolean fundet = false;                                  boolean fundet = false;
# Line 129  public class DawaTask extends Task { Line 131  public class DawaTask extends Task {
131                                                    
132                          db.saveNewAddresses(nyeAdresser);                          db.saveNewAddresses(nyeAdresser);
133                                                    
134                          logger.info("Save to db done - sending report mail");                          logger.info("Save to db done - adding to report mail");
135                                                    
136                          List<Address> saveOK = new ArrayList<>();                          List<Address> saveOK = new ArrayList<>();
137                          List<Address> saveFail = new ArrayList<>();                          List<Address> saveFail = new ArrayList<>();
# Line 147  public class DawaTask extends Task { Line 149  public class DawaTask extends Task {
149                          totalAntalDobbelt += dobbeltGadeidDAV.size();                          totalAntalDobbelt += dobbeltGadeidDAV.size();
150                    
151                                                    
152                          sb.append("<h2>Kommune: " + kommunenavn + " / " + kommunekode + "</h2><br>\n");                          sb.append("<h2>Kommune: " + kommunenavn + "</h2>\n");
153                            
154                            sb.append("Kommunekode: " + kommunekode + "<br>\n");
155                          sb.append("Antal Inserts: " + saveOK.size() + "<br>\n");                          sb.append("Antal Inserts: " + saveOK.size() + "<br>\n");
156                          sb.append("Antal insert fails: " + saveFail.size() + "<br>\n");                          sb.append("Antal insert fails: " + saveFail.size() + "<br>\n");
157                          sb.append("Antal ukendte dav: " + ukendteDAV.size() + "<br>\n");                          sb.append("Antal ukendte dav: " + ukendteDAV.size() + "<br>\n");
# Line 160  public class DawaTask extends Task { Line 164  public class DawaTask extends Task {
164                          addressTable(sb, saveFail);                          addressTable(sb, saveFail);
165                                                    
166                          sb.append("<h3>Ukendte DAV:</h3>\n");                          sb.append("<h3>Ukendte DAV:</h3>\n");
167                          for (String dav : ukendteDAV) {                          for (Map.Entry<String, Integer> dav : ukendteDAV.entrySet()) {                          
168                                  sb.append(dav + "<br>\n");                                  sb.append(dav.getKey() + " : " + dav.getValue() + "<br>\n");
169                          }                          }
170                                                    
171                          sb.append("<h3>Dobbelt gadeid DAV:</h3>\n");                          sb.append("<h3>Dobbelt gadeid DAV:</h3>\n");
172                          for (String dav : dobbeltGadeidDAV) {                          for (Map.Entry<String, Integer> dav : dobbeltGadeidDAV.entrySet()) {                            
173                                  sb.append(dav + "<br>\n");                                  sb.append(dav.getKey() + " : " + dav.getValue() + "<br>\n");
174                          }                          }                                              
                           
175                  }                  }
176                    logger.info("Sendingreport mail");
177                                    
178                  headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n");                  headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n");
179                  headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n");                  headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n");
Legend:
Removed from v.3006  
changed lines
  Added in v.3013
  ViewVC Help
Powered by ViewVC 1.1.20