/[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 3008 by torben, Tue Apr 19 19:55:19 2016 UTC revision 3029 by torben, Fri Apr 29 11:23:06 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 24  import dk.daoas.adressevedligehold.util. Line 23  import dk.daoas.adressevedligehold.util.
23    
24  public class DawaTask extends Task {  public class DawaTask extends Task {
25                    
26          final String kommentarTemplate = "Oprettet via DAWA";          final static String KOMMENTAR_TEMPLATE = "Oprettet via DAWA";
27                    
28          private TaskLogger logger = TaskLogger.getInstance();          private TaskLogger logger = TaskLogger.getInstance();
29                    
30          private short regionCode;          private short regionCode;
31          private String regionName;          private String regionName;
32                    
33            int antalBehandlede = 0;
34            int antalKommuner = 0;
35            
36                    
37                    
38          DatabaseCoverageUpdate db = new DatabaseCoverageUpdate();          DatabaseCoverageUpdate db = new DatabaseCoverageUpdate();
# Line 82  public class DawaTask extends Task { Line 84  public class DawaTask extends Task {
84                  int totalAntalUkendt = 0;                  int totalAntalUkendt = 0;
85                  int totalAntalDobbelt = 0;                  int totalAntalDobbelt = 0;
86                                    
87                    antalKommuner = kommuner.size();
88                    
89                                    
90                  StringBuilder sb = new StringBuilder();                  StringBuilder sb = new StringBuilder();
91                                    
# Line 94  public class DawaTask extends Task { Line 98  public class DawaTask extends Task {
98                                                    
99                          List<Address> dawaListe = dawa.adresserIKommune(kommunekode);                          List<Address> dawaListe = dawa.adresserIKommune(kommunekode);
100                          // stage 3 søg                                  // stage 3 søg        
101                          Set<String> ukendteDAV = new TreeSet<>();                          CountMap ukendteDAV = new CountMap();
102                          Set<String> dobbeltGadeidDAV = new TreeSet<>();                          CountMap dobbeltGadeidDAV = new CountMap();
103                          List<Address> nyeAdresser = new ArrayList<>();                          List<Address> nyeAdresser = new ArrayList<>();
104                                                    
105                          for (Address dawaAddr : dawaListe) {                          for (Address dawaAddr : dawaListe) {
106                                  String dav = getDAVid(dawaAddr);                                  String dav = getDAVid(dawaAddr);
107                                  DawaGade gade = search.get(dav);                                  DawaGade gade = search.get(dav);
108                                  if (gade == null) {                                  if (gade == null) {
109                                          ukendteDAV.add(dav + " " + dawaAddr.vejnavn);                                          String key = dav + " " + dawaAddr.vejnavn;
110                                            ukendteDAV.increment(key);
111                                          continue;                                          continue;
112                                  }                                  }
113                                                                    
114                                  if (gade.gadeids.size() != 1) {                                  if (gade.gadeids.size() != 1) {
115                                          dobbeltGadeidDAV.add(dav + " " + dawaAddr.vejnavn);                                          String key = dav + " " + dawaAddr.vejnavn;
116                                            dobbeltGadeidDAV.increment(key);
117                                            continue;
118                                  }                                  }
119                                                                    
120                                  boolean fundet = false;                                  boolean fundet = false;
# Line 121  public class DawaTask extends Task { Line 128  public class DawaTask extends Task {
128                                  if (fundet == false) {                                  if (fundet == false) {
129                                          dawaAddr.gadeid = gade.gadeids.iterator().next();                                          dawaAddr.gadeid = gade.gadeids.iterator().next();
130                                          dawaAddr.state = AddressState.CREATED;                                          dawaAddr.state = AddressState.CREATED;
131                                          dawaAddr.kommentar = kommentarTemplate;                                          dawaAddr.kommentar = KOMMENTAR_TEMPLATE;
132                                          nyeAdresser.add(dawaAddr);                                          nyeAdresser.add(dawaAddr);
133                                  }                                                        }                      
134                          }                          }
# Line 129  public class DawaTask extends Task { Line 136  public class DawaTask extends Task {
136                                                    
137                          db.saveNewAddresses(nyeAdresser);                          db.saveNewAddresses(nyeAdresser);
138                                                    
139                          logger.info("Save to db done - sending report mail");                          logger.info("Save to db done - adding to report mail");
140                                                    
141                          List<Address> saveOK = new ArrayList<>();                          List<Address> saveOK = new ArrayList<>();
142                          List<Address> saveFail = new ArrayList<>();                          List<Address> saveFail = new ArrayList<>();
# Line 145  public class DawaTask extends Task { Line 152  public class DawaTask extends Task {
152                          totalAntalFejl += saveFail.size();                          totalAntalFejl += saveFail.size();
153                          totalAntalUkendt += ukendteDAV.size();                          totalAntalUkendt += ukendteDAV.size();
154                          totalAntalDobbelt += dobbeltGadeidDAV.size();                          totalAntalDobbelt += dobbeltGadeidDAV.size();
155                            
156                            
157                            antalBehandlede++;
158                    
159                                                    
160                          sb.append("<h2>Kommune: " + kommunenavn + "</h2>\n");                          sb.append("<h2>Kommune: " + kommunenavn + "</h2>\n");
161                            
162                            sb.append("Kommunekode: " + kommunekode + "<br>\n");
163                          sb.append("Antal Inserts: " + saveOK.size() + "<br>\n");                          sb.append("Antal Inserts: " + saveOK.size() + "<br>\n");
164                          sb.append("Antal insert fails: " + saveFail.size() + "<br>\n");                          sb.append("Antal insert fails: " + saveFail.size() + "<br>\n");
165                          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 172  public class DawaTask extends Task {
172                          addressTable(sb, saveFail);                          addressTable(sb, saveFail);
173                                                    
174                          sb.append("<h3>Ukendte DAV:</h3>\n");                          sb.append("<h3>Ukendte DAV:</h3>\n");
175                          for (String dav : ukendteDAV) {                          for (Map.Entry<String, Integer> dav : ukendteDAV.entrySet()) {                          
176                                  sb.append(dav + "<br>\n");                                  sb.append(dav.getKey() + " : " + dav.getValue() + "<br>\n");
177                          }                          }
178                                                    
179                          sb.append("<h3>Dobbelt gadeid DAV:</h3>\n");                          sb.append("<h3>Dobbelt gadeid DAV:</h3>\n");
180                          for (String dav : dobbeltGadeidDAV) {                          for (Map.Entry<String, Integer> dav : dobbeltGadeidDAV.entrySet()) {                            
181                                  sb.append(dav + "<br>\n");                                  sb.append(dav.getKey() + " : " + dav.getValue() + "<br>\n");
182                          }                          }                                              
                           
183                  }                  }
184                    logger.info("Sendingreport mail");
185                                    
186                  headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n");                  headerSB.append("Antal Inserts: " + totalAntalNye + "<br>\n");
187                  headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n");                  headerSB.append("Antal insert fails: " + totalAntalFejl + "<br>\n");
# Line 216  public class DawaTask extends Task { Line 228  public class DawaTask extends Task {
228    
229          @Override          @Override
230          public double getPercentCompleted() {          public double getPercentCompleted() {
231                  return 0;                  if (antalKommuner == 0) {
232                            return 0;      
233                    }
234                    
235                    return  (antalBehandlede / ((double)antalKommuner) ) * 100.0;
236                    
237          }          }
238                    
239    
Legend:
Removed from v.3008  
changed lines
  Added in v.3029
  ViewVC Help
Powered by ViewVC 1.1.20