DuplicatesModel.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2022 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.contacts.duplicates;
 
import java.util.List;
import java.util.TreeSet;
import org.turro.string.Phrases;
import org.turro.contacts.Address;
import org.turro.contacts.Connector;
import org.turro.contacts.Contact;
import org.turro.contacts.db.ContactsPU;
import org.turro.i18n.I_;
import org.turro.jpa.Dao;
import org.turro.plugin.contacts.IContact;
import org.turro.sql.SqlClause;
import org.turro.string.Strings;
import org.turro.util.Cached;
 
public class DuplicatesModel extends TreeSet<Duplicated> {
  
  private final Contact contact;
 
  public DuplicatesModel(Contact contact) {
    this.contact = contact;
    if(contact != null) performChecks();
  }
 
  public boolean hasStoppers() {
    return stream().anyMatch(dup -> dup.getType().equals(Duplicated.DuplicatedType.STOPPER));
  }
  
  private void performChecks() {
    checkGlobalID();
    checkName();
    checkConnectors();
    checkAddreses();
  }
 
  private void checkGlobalID() {
    if(Strings.isBlank(contact.getGlobalIdentifier())) return;
    List<String> contacts = SqlClause.select("c.name").from("Contact c")
            .where().notEqual("c.globalIdentifier", null)
            .and().equal("c.globalIdentifier", contact.getGlobalIdentifier())
            .startIf(!contact.isNew())
            .and().notEqual("c", contact)
            .endIf()
            .dao(dao.get())
            .resultList(String.class);
    if(!contacts.isEmpty()) {
      Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.STOPPER, 
              I_.get("Global identifier"), contact.getGlobalIdentifier());
      duplicated.setContacts(contacts);
      add(duplicated);
    }
  }
  
  private void checkName() {
    List<String> contacts = SqlClause.select("c.name").from("Contact c")
            .where().equal("c.name", contact.getName())
            .startIf(!contact.isNew())
            .and().notEqual("c", contact)
            .endIf()
            .dao(dao.get())
            .resultList(String.class);
    if(!contacts.isEmpty()) {
      Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.WARNING, 
              I_.get("Name"), contact.getName());
      duplicated.setConsequence(I_.get("These users will be difficult to spot"));
      duplicated.setContacts(contacts);
      add(duplicated);
    }
  }
  
  private void checkConnectors() {
    for(Connector connector : contact.getConnectors()) {
      if(connector != null) {
        List<String> contacts = SqlClause.select("c.contact.name").from("Connector c")
                .where().equal("c.description", connector.getDescription())
                .and().equal("c.value", connector.getValue())
                .startIf(!contact.isNew())
                .and().notEqual("c.contact", contact)
                .endIf()
                .dao(dao.get())
                .resultList(String.class);
        if(!contacts.isEmpty()) {
          if(connector.getDescription().equals(IContact.CONNECTOR_EMAIL)) {
            Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.WARNING, 
                    Phrases.start(I_.get("Connector"), ":", connector.getDescription()).toString(), 
                    connector.getValue());
            duplicated.setConsequence(I_.get("These users wont be able to authenticate"));
            duplicated.setContacts(contacts);
            add(duplicated);
          } else if(connector.getDescription().equals(IContact.CONNECTOR_TRADE)) {
            Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.WARNING, 
                    Phrases.start(I_.get("Connector"), ":", connector.getDescription()).toString(), 
                    connector.getValue());
            duplicated.setConsequence(I_.get("These users have the same trademark"));
            duplicated.setContacts(contacts);
            add(duplicated);
          } else if(connector.getDescription().equals(IContact.CONNECTOR_FISCAL)) {
            Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.WARNING, 
                    Phrases.start(I_.get("Connector"), ":", connector.getDescription()).toString(), 
                    connector.getValue());
            duplicated.setConsequence(I_.get("These users have the same fiscal name"));
            duplicated.setContacts(contacts);
            add(duplicated);
          } else {
            Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.SAFE, 
                    Phrases.start(I_.get("Connector"), ":", connector.getDescription()).toString(), 
                    connector.getValue());
            duplicated.setContacts(contacts);
            add(duplicated);
          }
        }
      }
    }
  }
  
  private void checkAddreses() {
    for(Address address : contact.getAddresses()) {
      if(address != null) {
        List<String> contacts = SqlClause.select("c.contact.name").from("Address c")
                .where().equal("c.street", address.getStreet())
                .and().equal("c.zipCode", address.getZipCode())
                .and().equal("c.city", address.getCity())
                .startIf(!contact.isNew())
                .and().notEqual("c.contact", contact)
                .endIf()
                .dao(dao.get())
                .resultList(String.class);
        if(!contacts.isEmpty()) {
          if(address.getDescription().equals(IContact.ADDRESS_FISCAL)) {
            Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.WARNING, 
                    Phrases.start(I_.get("Address"), ":", address.getDescription()).toString(), 
                    address.getAddressString());
            duplicated.setConsequence(I_.get("These users have the same fiscal address"));
            duplicated.setContacts(contacts);
            add(duplicated);
          } else {
            Duplicated duplicated = new Duplicated(Duplicated.DuplicatedType.SAFE, 
                    Phrases.start(I_.get("Address"), ":", address.getDescription()).toString(), 
                    address.getAddressString());
            duplicated.setContacts(contacts);
            add(duplicated);
          }
        }
      }
    }
  }
 
  private final Cached<Dao> dao = Cached.instance(() -> new ContactsPU());
 
}