import openassemblee.domain.enumeration.TypeIdentiteInternet;
import openassemblee.publicdata.*;
import openassemblee.repository.*;
-import org.elasticsearch.common.base.Strings;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
List<MembreDto> m1 = data.getMembres().stream()
.filter(m -> m.getType().equals("Commissions"))
.filter(m -> m.getUidEnsemble().equals(cp))
- .filter(m -> m.getFonction() == null || Strings.isNullOrEmpty(m.getFonction().trim()))
+ .filter(m -> trimToNull(m.getFonction()) == null)
.collect(Collectors.toList());
uidsTraites.addAll(m1.stream().map(MembreDto::getUidMembre).collect(Collectors.toList()));
long nbCp = m1.stream()
List<MembreDto> m3bis = data.getMembres().stream()
.filter(m -> m.getType().equals("Commissions"))
.filter(m -> m.getUidEnsemble().equals(cp))
- .filter(m -> !Strings.isNullOrEmpty(m.getFonction()))
- .filter(m -> !Strings.isNullOrEmpty(m.getFonction().trim()))
+ .filter(m -> trimToNull(m.getFonction()) != null)
.collect(Collectors.toList());
uidsTraites.addAll(m3bis.stream().map(MembreDto::getUidMembre).collect(Collectors.toList()));
long nbFcpBis = m3bis.stream()
// appartenances groupe politique
List<MembreDto> m4 = data.getMembres().stream()
.filter(m -> m.getType().equals("Groupe politique"))
- .filter(m -> m.getFonction() == null || Strings.isNullOrEmpty(m.getFonction().trim()))
+ .filter(m -> trimToNull(m.getFonction()) == null)
.collect(Collectors.toList());
uidsTraites.addAll(m4.stream().map(MembreDto::getUidMembre).collect(Collectors.toList()));
long nbAgp = m4.stream()
// fonctions groupe politique
List<MembreDto> m5 = data.getMembres().stream()
.filter(m -> m.getType().equals("Groupe politique"))
- .filter(m -> !Strings.isNullOrEmpty(m.getFonction()))
- .filter(m -> !Strings.isNullOrEmpty(m.getFonction().trim()))
+ .filter(m -> trimToNull(m.getFonction()) != null)
.collect(Collectors.toList());
uidsTraites.addAll(m5.stream().map(MembreDto::getUidMembre).collect(Collectors.toList()));
long nbFgp = m5.stream()
List<MembreDto> m6 = data.getMembres().stream()
.filter(m -> m.getType().equals("Commissions"))
.filter(m -> cts.containsKey(m.getUidEnsemble()))
- .filter(m -> m.getFonction() == null || Strings.isNullOrEmpty(m.getFonction().trim()))
+ .filter(m -> trimToNull(m.getFonction()) == null)
.collect(Collectors.toList());
uidsTraites.addAll(m6.stream().map(MembreDto::getUidMembre).collect(Collectors.toList()));
long nbAct = m6.stream()
List<MembreDto> m7 = data.getMembres().stream()
.filter(m -> m.getType().equals("Commissions"))
.filter(m -> cts.containsKey(m.getUidEnsemble()))
- .filter(m -> !Strings.isNullOrEmpty(m.getFonction()))
- .filter(m -> !Strings.isNullOrEmpty(m.getFonction().trim()))
+ .filter(m -> trimToNull(m.getFonction()) != null)
.collect(Collectors.toList());
uidsTraites.addAll(m7.stream().map(MembreDto::getUidMembre).collect(Collectors.toList()));
long nbFct = m7.stream()
elu.setCivilite(c.getCivilite().equals("M.") ? Civilite.MONSIEUR : Civilite.MADAME);
elu.setNom(c.getNom());
elu.setPrenom(c.getPrenom());
- elu.setNomJeuneFille(c.getNomJeuneFille());
- elu.setProfession(c.getProfession());
+ elu.setNomJeuneFille(trimOrNull(c.getNomJeuneFille()));
+ elu.setProfession(trimOrNull(c.getProfession()));
elu.setDateNaissance(parseDate(c.getDateNaissance()));
elu.setLieuNaissance(trimOrNull(c.getVilleNaissance()));
- elu.setListeCourt(c.getListeCourt());
- elu.setListeElectorale(c.getListeElectorale());
- elu.setDepartement(c.getDepElection());
- elu.setCodeDepartement(c.getCodeDepElection());
+ elu.setListeCourt(trimOrNull(c.getListeCourt()));
+ elu.setListeElectorale(trimOrNull(c.getListeElectorale()));
+ elu.setDepartement(trimOrNull(c.getDepElection()));
+ elu.setCodeDepartement(trimOrNull(c.getCodeDepElection()));
AdressePostale ap = new AdressePostale();
- ap.setVoie(c.getAdresse());
- ap.setCodePostal(c.getCodePostal());
- ap.setVille(c.getVille());
+ ap.setVoie(trimOrNull(c.getAdresse()));
+ ap.setCodePostal(trimOrNull(c.getCodePostal()));
+ ap.setVille(trimOrNull(c.getVille()));
ap.setNiveauConfidentialite(PUBLIABLE);
ap.setAdresseDeCorrespondance(true);
ap.setPublicationAnnuaire(true);
elu.getAdressesPostales().add(ap);
NumeroTelephone nt = new NumeroTelephone();
- nt.setNumero(c.getTelephone());
+ nt.setNumero(trimOrNull(c.getTelephone()));
nt.setNiveauConfidentialite(PUBLIABLE);
nt.setPublicationAnnuaire(true);
numeroTelephoneRepository.save(nt);
elu.getNumerosTelephones().add(nt);
NumeroFax nf = new NumeroFax();
- nf.setNumero(c.getFax());
+ nf.setNumero(trimOrNull(c.getFax()));
nf.setNiveauConfidentialite(PUBLIABLE);
nf.setPublicationAnnuaire(true);
numeroFaxRepository.save(nf);
am.setPublicationAnnuaire(true);
adresseMailRepository.save(am);
elu.getAdressesMail().add(am);
- if (!Strings.isNullOrEmpty(c.getTwitter())) {
+ if (trimToNull(c.getTwitter()) != null) {
IdentiteInternet ii = new IdentiteInternet();
ii.setTypeIdentiteInternet(TypeIdentiteInternet.Twitter);
- ii.setUrl(c.getTwitter());
+ ii.setUrl(trimOrNull(c.getTwitter()));
identiteInternetRepository.save(ii);
elu.getIdentitesInternet().add(ii);
}
- if (!Strings.isNullOrEmpty(c.getFacebook())) {
+ if (trimToNull(c.getFacebook()) != null) {
IdentiteInternet ii = new IdentiteInternet();
ii.setTypeIdentiteInternet(TypeIdentiteInternet.Facebook);
- ii.setUrl(c.getFacebook());
+ ii.setUrl(trimOrNull(c.getFacebook()));
identiteInternetRepository.save(ii);
elu.getIdentitesInternet().add(ii);
}
- if (!Strings.isNullOrEmpty(c.getSiteInternet())) {
+ if (trimToNull(c.getSiteInternet()) != null) {
IdentiteInternet ii = new IdentiteInternet();
ii.setTypeIdentiteInternet(TypeIdentiteInternet.SiteInternet);
- ii.setUrl(c.getSiteInternet());
+ ii.setUrl(trimOrNull(c.getSiteInternet()));
identiteInternetRepository.save(ii);
elu.getIdentitesInternet().add(ii);
}
- if (!Strings.isNullOrEmpty(c.getBlog())) {
+ if (trimToNull(c.getBlog()) != null) {
IdentiteInternet ii = new IdentiteInternet();
ii.setTypeIdentiteInternet(TypeIdentiteInternet.Blog);
- ii.setUrl(c.getBlog());
+ ii.setUrl(trimOrNull(c.getBlog()));
identiteInternetRepository.save(ii);
elu.getIdentitesInternet().add(ii);
}
- if (!Strings.isNullOrEmpty(c.getAutre())) {
+ if (trimToNull(c.getAutre()) != null) {
IdentiteInternet ii = new IdentiteInternet();
ii.setTypeIdentiteInternet(TypeIdentiteInternet.Autre);
- ii.setUrl(c.getAutre());
+ ii.setUrl(trimOrNull(c.getAutre()));
identiteInternetRepository.save(ii);
elu.getIdentitesInternet().add(ii);
}
}
private LocalDate parseDate(String date) {
- if (!Strings.isNullOrEmpty(date) && !date.equals(" ")) {
+ if (trimToNull(date) != null) {
return LocalDate.parse(date, DATE_FORMATTER);
} else {
return null;
private GroupePolitique buildGroupePolitique(EnsembleDto e) {
GroupePolitique gp = new GroupePolitique();
- gp.setNom(e.getLibLong());
- gp.setNomCourt(e.getLibCourt());
+ gp.setNom(trimOrNull(e.getLibLong()));
+ gp.setNomCourt(trimOrNull(e.getLibCourt()));
gp.setDateDebut(parseDate(e.getDateCreation()));
gp.setDateFin(parseDate(e.getDateFin()));
gp.setMotifFin(trimOrNull(e.getMotifFin()));
AdressePostale ap = new AdressePostale();
- ap.setVoie(e.getAdresse());
- ap.setCodePostal(e.getCodePostal());
- ap.setVille(e.getVille());
+ ap.setVoie(trimOrNull(e.getAdresse()));
+ ap.setCodePostal(trimOrNull(e.getCodePostal()));
+ ap.setVille(trimOrNull(e.getVille()));
ap.setNiveauConfidentialite(PUBLIABLE);
ap.setAdresseDeCorrespondance(true);
ap.setPublicationAnnuaire(true);
adressePostaleRepository.save(ap);
gp.setAdressePostale(ap);
- gp.setFax(e.getFax());
- gp.setMail(e.getMail());
- gp.setPhone(e.getTelephone());
+ gp.setFax(trimOrNull(e.getFax()));
+ gp.setMail(trimOrNull(e.getMail()));
+ gp.setPhone(trimOrNull(e.getTelephone()));
gp.setImportUid(e.getUidEnsemble());
// TODO faire les audit trails
Organisme o = new Organisme();
o.setCodeRNE(trimOrNull(e.getCodeRne()));
// TODO Solveig ?
- o.setSigle(e.getLibCourt());
- o.setNom(e.getLibLong());
- o.setSecteur(e.getSecteur());
+ o.setSigle(trimOrNull(e.getLibCourt()));
+ o.setNom(trimOrNull(e.getLibLong()));
+ o.setSecteur(trimOrNull(e.getSecteur()));
o.setDateDebut(parseDate(e.getDateCreation()));
o.setDateFin(parseDate(e.getDateFin()));
o.setMotifFin(trimOrNull(e.getMotifFin()));
- o.setTelephone(e.getTelephone());
- o.setFax(e.getFax());
- o.setPhonetique(e.getPhonetique());
- o.setDepartement(e.getDepartement());
+ o.setTelephone(trimOrNull(e.getTelephone()));
+ o.setFax(trimOrNull(e.getFax()));
+ o.setPhonetique(trimOrNull(e.getPhonetique()));
+ o.setDepartement(trimOrNull(e.getDepartement()));
o.setDescription(trimOrNull(e.getDescription()));
- o.setStatus(e.getStatus());
+ o.setStatus(trimOrNull(e.getStatus()));
AdressePostale ap = new AdressePostale();
- ap.setVoie(e.getAdresse());
- ap.setCodePostal(e.getCodePostal());
- ap.setVille(e.getVille());
+ ap.setVoie(trimOrNull(e.getAdresse()));
+ ap.setCodePostal(trimOrNull(e.getCodePostal()));
+ ap.setVille(trimOrNull(e.getVille()));
ap.setNiveauConfidentialite(PUBLIABLE);
ap.setAdresseDeCorrespondance(true);
ap.setPublicationAnnuaire(true);
Organisme o = organismes.get(m.getUidEnsemble());
AppartenanceOrganisme ao = new AppartenanceOrganisme();
ao.setElu(elus.get(m.getUidConseiller()));
- ao.setCodeRNE(o.getCodeRNE());
- ao.setOrganisme(o.getNom());
+ ao.setCodeRNE(trimOrNull(o.getCodeRNE()));
+ ao.setOrganisme(trimOrNull(o.getNom()));
ao.setDateNomination(parseDate(m.getDateNomination()));
ao.setDateDebut(parseDate(m.getDateDebut()));
ao.setDateFin(parseDate(m.getDateFin()));
ao.setFonction(trimOrNull(m.getFonction()));
// TODO Solveig reference == numero nomination ?
- ao.setReference(m.getNumeroNomination());
- ao.setStatut(m.getStatus());
+ ao.setReference(trimOrNull(m.getNumeroNomination()));
+ ao.setStatut(trimOrNull(m.getStatus()));
// TODO Solveig type == nomination ?
- ao.setType(m.getNomination());
+ ao.setType(trimOrNull(m.getNomination()));
ao.setDateNomination(parseDate(m.getDateNomination()));
return appartenanceOrganismeRepository.save(ao);
}
private String trimOrNull(String label) {
return label != null && !label.trim().equals("") ? label : null;
}
+
+ private String trimToNull(String label) {
+ if (label == null) {
+ return null;
+ }
+ String trim = label.trim();
+ if (trim.equals("")) {
+ return null;
+ }
+ return trim;
+ }
}
public static final String EXECUTIF = "COM003";
public static final String DELEGUES_SPECIAUX = "COM004";
+ public static final boolean USE_SPACE = true;
+ public static final String SPACE = USE_SPACE ? " " : "";
+ // TODO PDE say j'ai aussi viré les ""
+ public static final boolean USE_EMPTY_STRING = true;
+ public static final String EMPTY_STRING = USE_EMPTY_STRING ? "" : null;
+
@Autowired
private EluRepository eluRepository;
d.setMandature(MANDATURE);
d.setNom(e.getNom());
d.setActiviteProf(stringOrSpace(null));
- d.setProfession(e.getProfession());
+ d.setProfession(stringOrSpace(e.getProfession()));
getPublishable(e.getAdressesPostales()).ifPresent(ap -> {
- d.setAdresse(ap.getVoie());
- d.setVille(ap.getVille());
- d.setCodePostal(ap.getCodePostal());
+ d.setAdresse(stringOrSpace(ap.getVoie()));
+ d.setVille(stringOrSpace(ap.getVille()));
+ d.setCodePostal(stringOrSpace(ap.getCodePostal()));
});
d.setDateNaissance(formatDate(e.getDateNaissance()));
Optional<AppartenanceGroupePolitique> agp = e.getAppartenancesGroupePolitique().stream()
.filter(a -> a.getDateFin() == null)
.findFirst();
// first set to empty
- d.setGroupeCourt("");
- d.setGroupePolitique("");
+ d.setGroupeCourt(SPACE);
+ d.setGroupePolitique(SPACE);
agp.ifPresent(g -> {
GroupePolitique gp = agp.get().getGroupePolitique();
d.setGroupeCourt(gp.getNomCourt());
}
d.setListeCourt(e.getListeCourt());
d.setListeElectorale(e.getListeElectorale());
- d.setNbEnfants("");
- d.setNomJeuneFille("");
- d.setAutresMandats("");
- d.setSituationFamiliale("");
- d.setTelephone(getPublishable(e.getNumerosTelephones()).map(NumeroTelephone::getNumero).orElse(""));
- d.setFax(getPublishable(e.getNumerosFax()).map(NumeroFax::getNumero).orElse(""));
- d.setMail(getPublishable(e.getAdressesMail()).map(AdresseMail::getMail).orElse(""));
+ d.setNbEnfants(EMPTY_STRING);
+ d.setNomJeuneFille(EMPTY_STRING);
+ d.setAutresMandats(EMPTY_STRING);
+ d.setSituationFamiliale(EMPTY_STRING);
+ d.setTelephone(getPublishable(e.getNumerosTelephones()).map(NumeroTelephone::getNumero).orElse(SPACE));
+ d.setFax(getPublishable(e.getNumerosFax()).map(NumeroFax::getNumero).orElse(SPACE));
+ d.setMail(getPublishable(e.getAdressesMail()).map(AdresseMail::getMail).orElse(SPACE));
d.setValid('1');
// TODO le naming de notre cote a ptet une lacune
d.setDepElection(e.getDepartement());
// .filter(a -> a.getDateFin() == null)
// .sorted(Comparator.comparing(AppartenanceCommissionThematique::getImportUid))
// .forEach(a -> commissionsStringBuilder.append("|").append(a.getCommissionThematique().getImportUid()));
- d.setCommissions("");
+ d.setCommissions(EMPTY_STRING);
// d.setCommissions(commissionsStringBuilder.toString());
- d.setDistinctions("");
- d.setDesignations("");
+ d.setDistinctions(EMPTY_STRING);
+ d.setDesignations(EMPTY_STRING);
Optional<FonctionExecutive> fe = e.getFonctionsExecutives().stream()
.filter(f -> f.getDateFin() == null)
.findFirst();
cp.setLibLong("Commission permanente");
cp.setSt(1f);
cp.setValid('1');
- cp.setDescription(NON_RENSEIGNE);
cp.setStatus(stringOrSpace(null));
cp.setDescription(NON_RENSEIGNE);
deleg.setLibLong("Délégués spéciaux");
deleg.setSt(3f);
deleg.setValid('1');
- deleg.setDescription(NON_RENSEIGNE);
deleg.setDescription(NON_RENSEIGNE);
deleg.setStatus(stringOrSpace(null));
e.setDescription(NON_RENSEIGNE);
if (e.getLibLong().equals("Non Inscrits")) {
- e.setDescription(stringOrSpace(null));
+ e.setDescription(NON_RENSEIGNE);
}
e.setCodeRne(stringOrSpace(null));
e.setDepartement(stringOrSpace(null));
e.setAdresse(stringOrSpace(null));
e.setCodePostal(stringOrSpace(null));
e.setVille(stringOrSpace(null));
- e.setMail(stringOrSpace(null));
e.setPhonetique(stringOrSpace(null));
if (gp.getAdressePostale() != null) {
- e.setAdresse(gp.getAdressePostale().getVoie());
- e.setCodePostal(gp.getAdressePostale().getCodePostal());
- e.setVille(gp.getAdressePostale().getVille());
+ e.setAdresse(stringOrSpace(gp.getAdressePostale().getVoie()));
+ e.setCodePostal(stringOrSpace(gp.getAdressePostale().getCodePostal()));
+ e.setVille(stringOrSpace(gp.getAdressePostale().getVille()));
}
e.setStatus(stringOrSpace(null));
- e.setMail(gp.getMail());
+ e.setMail(stringOrSpace(gp.getMail()));
return e;
}).collect(Collectors.toList());
}
e.setUidEnsemble(o.getImportUid());
e.setMandature(MANDATURE);
// TODO Solveig
- e.setLibCourt(o.getSigle());
+ e.setLibCourt(stringOrSpace(o.getSigle()));
e.setDateCreation(formatDate(o.getDateDebut()));
e.setType("organisme");
e.setTypeCommission(stringOrSpace(null));
// TODO Solveig
e.setSecteur(stringOrSpace(o.getSecteur()));
e.setMotifFin(stringOrSpace(o.getMotifFin()));
- e.setSecteur(o.getSecteur());
- e.setTelephone(o.getTelephone());
- e.setFax(o.getFax());
+ e.setSecteur(stringOrSpace(o.getSecteur()));
+ e.setTelephone(stringOrSpace(o.getTelephone()));
+ e.setFax(stringOrSpace(o.getFax()));
e.setPhonetique(o.getPhonetique());
e.setDepartement(stringOrSpace(o.getDepartement()));
e.setMail(stringOrSpace(null));
e.setPhonetique(stringOrSpace(o.getPhonetique()));
+ e.setAdresse(stringOrSpace(null));
+ e.setCodePostal(stringOrSpace(null));
+ e.setVille(stringOrSpace(null));
if (o.getAdressePostale() != null) {
- e.setAdresse(o.getAdressePostale().getVoie());
- e.setCodePostal(o.getAdressePostale().getCodePostal());
- e.setVille(o.getAdressePostale().getVille());
+ e.setAdresse(stringOrSpace(o.getAdressePostale().getVoie()));
+ e.setCodePostal(stringOrSpace(o.getAdressePostale().getCodePostal()));
+ e.setVille(stringOrSpace(o.getAdressePostale().getVille()));
}
// TODO PDE Solveig ? suppression
// non cohérence
- e.setStatus(o.getStatus());
+ e.setStatus(stringOrSpace(o.getStatus()));
// TODO remove ?
// if(e.getUidEnsemble().equals("ORG2156")) {
// e.setStatus("O");
if (ct.getDateFin() != null) {
e.setStatus("F");
} else {
- e.setStatus(" ");
+ e.setStatus(SPACE);
}
return e;
}).collect(Collectors.toList());
m.setType("Organisme");
m.setDateDebut(formatDate(ao.getDateDebut()));
m.setDateFin(formatDate(ao.getDateFin()));
- m.setNumeroNomination(ao.getReference());
- m.setStatus(ao.getStatut());
- m.setNomination(ao.getType());
+ m.setNumeroNomination(stringOrSpace(ao.getReference()));
+ m.setStatus(stringOrSpace(ao.getStatut()));
+ m.setNomination(stringOrSpace(ao.getType()));
m.setSt(0f);
m.setFonction(stringOrSpace(ao.getFonction()));
m.setBureau(bureau(ao.getFonction()));
.filter(i -> i.getTypeIdentiteInternet() == typeIdentiteInternet)
.findFirst();
// TODO PDE wtf cet espace
- return ii.map(IdentiteInternet::getUrl).orElse(" ");
+ return ii.map(IdentiteInternet::getUrl).orElse(SPACE);
}
private String formatDate(LocalDate date) {
if (date != null) {
return date.format(InjectDataWebservice.DATE_FORMATTER);
} else {
- return " ";
+ return SPACE;
}
}
// TODO ici checker qu'il n'y a pas d'espace au départ
private String stringOrSpace(String label) {
- return label != null ? label : " ";
+ return label != null ? label : SPACE;
}
private char bureau(String fonction) {