RelationUtil.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2012 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.util;
 
import java.util.Collection;
import java.util.List;
import java.util.stream.Stream;
import org.turro.string.Strings;
import org.turro.contacts.BusinessRelation;
import org.turro.contacts.Contact;
import org.turro.contacts.db.ContactsPU;
import org.turro.elephant.db.WhereClause;
import org.turro.jpa.Dao;
 
@Deprecated
public class RelationUtil {
  
  public static void addRelation(Contact business, Contact contact, String relation) {
    if(business != null && contact != null && !Strings.isBlank(relation)) {
      Dao dao = new ContactsPU();
      WhereClause wc = new WhereClause();
      wc.addClause("select r from BusinessRelation as r");
      wc.addClause("where r.contact = :c1");
      wc.addNamedValue("c1", contact);
      wc.addClause("and r.business = :c2");
      wc.addNamedValue("c2", business);
      wc.addClause("and r.relationType = :pr");
      wc.addNamedValue("pr", relation);
      List<BusinessRelation> relations = dao.getResultList(wc);
      if(relations.isEmpty()) {
        BusinessRelation r = new BusinessRelation();
        r.setContact(contact);
        r.setBusiness(business);
        r.setRelationType(relation);
        dao.saveObject(r);
      }
    }
  }
  
  public static void addRelation(String business, String contact, String relation) {
    if(business != null && contact != null && !Strings.isBlank(relation)) {
      Dao dao = new ContactsPU();
      WhereClause wc = new WhereClause();
      wc.addClause("select r from BusinessRelation as r");
      wc.addClause("where r.contact.id = :c1");
      wc.addNamedValue("c1", contact);
      wc.addClause("and r.business.id = :c2");
      wc.addNamedValue("c2", business);
      wc.addClause("and r.relationType = :pr");
      wc.addNamedValue("pr", relation);
      List<BusinessRelation> relations = dao.getResultList(wc);
      if(relations.isEmpty()) {
        BusinessRelation r = new BusinessRelation();
        r.setContact(dao.find(Contact.class, contact));
        r.setBusiness(dao.find(Contact.class, business));
        r.setRelationType(relation);
        if(r.getContact() != null && r.getBusiness()!= null) {
          dao.saveObject(r);
        }
      }
    }
  }
  
  public static void addRelations(Collection<BusinessRelation> relations) {
    Dao dao = new ContactsPU();
    dao.saveCollection(relations);
  }
  
  public static void killRelation(Contact business, Contact contact, String relation) {
    if(business != null && contact != null && !Strings.isBlank(relation)) {
      Dao dao = new ContactsPU();
      WhereClause wc = new WhereClause();
      wc.addClause("delete from BusinessRelation as r");
      wc.addClause("where r.contact = :c1");
      wc.addNamedValue("c1", contact);
      wc.addClause("and r.business = :c2");
      wc.addNamedValue("c2", business);
      wc.addClause("and r.relationType = :pr");
      wc.addNamedValue("pr", relation);
      dao.executeUpdate(wc);
    }
  }
  
  public static void killRelation(String business, String contact, String relation) {
    if(business != null && contact != null && !Strings.isBlank(relation)) {
      Dao dao = new ContactsPU();
      WhereClause wc = new WhereClause();
      wc.addClause("delete from BusinessRelation as r");
      wc.addClause("where r.contact.id = :c1");
      wc.addNamedValue("c1", contact);
      wc.addClause("and r.business.id = :c2");
      wc.addNamedValue("c2", business);
      wc.addClause("and r.relationType = :pr");
      wc.addNamedValue("pr", relation);
      dao.executeUpdate(wc);
    }
  }
  
  public static void killRelations(String like) {
    if(!Strings.isBlank(like)) {
      Dao dao = new ContactsPU();
      WhereClause wc = new WhereClause();
      wc.addClause("delete from BusinessRelation as r");
      wc.addClause("where r.relationType like :pr");
      wc.addNamedValue("pr", like);
      dao.executeUpdate(wc);
    }
  }
 
  public static void setPreferentialRelation() {
    try(Stream<Contact> contacts = new ContactsPU().stream(Contact.class, "select c from Contact c")) {
      contacts.forEach((contact) -> {
        if(contact.getBusiness() == null) {
          for(BusinessRelation relation : contact.getBusinessRelations()) {
            if(!Strings.isBlank(relation.getRelationType()) && relation.getRelationType().startsWith("$REL_")) {
              new ContactsPU().executeUpdate(
                      "update BusinessRelation set preferential = TRUE where identifier = ?", 
                      new Object[] { relation.getId() }
                      );
              break;
            }
          }
        }
      });
    }
  }
 
  private RelationUtil() {
  }
  
}