org.turro.indicator.ContactIndicator Class Reference

Inheritance diagram for org.turro.indicator.ContactIndicator:

Collaboration diagram for org.turro.indicator.ContactIndicator:

Public Member Functions
	ContactIndicator ()
void	generateSiblings ()
double	getValue (IndicatorVariable variable, Object entity)
double	getValue (IndicatorVariable variable, Object entity, String relatedPath)
Public Member Functions inherited from org.turro.indicator.AbstractIndicator
void	initIndicator ()
void	prepareIndicator ()
String	getRoot ()
List< IndicatorVariable >	getVariables ()
List< IndicatorVariable >	getAllVariables ()
IndicatorVariable	getVariable (String name)
List< IndicatorVariable >	getAllRankingVariables (String root)
List< IndicatorVariable >	getAllMatchingVariables (String root)
IndicatorResult	readIndicator (String storeClass, String indicator)
void	preprocess (IndicatorVariable variable, IPreprocessor preprocessor, String entityRoot, String relatedRoot)
void	postprocess (IndicatorVariable variable, IPreprocessor postprocessor, String entityRoot, String relatedRoot)
Stream< String >	getEntityPaths (String root)
Stream< GenericSiblings >	getSiblingPaths (String entityPath)
Dao	getDao ()
boolean	itsMine (String root)
boolean	itsMine (IndicatorVariable variable)

Protected Member Functions
void	initVariables ()
void	initExternalVariables ()
Dao	createDao ()
void	processRankingVariable (Dao dao, IPreprocessor preprocessor, IndicatorVariable variable, String entityRoot)
void	processMatchingVariable (Dao dao, IPreprocessor preprocessor, IndicatorVariable variable, String entityRoot, String relatedRoot)
void	postprocessRankingVariable (Dao dao, IPreprocessor preprocessor, IndicatorVariable variable, String entityRoot)
Protected Member Functions inherited from org.turro.indicator.AbstractIndicator
void	addVariable (String name, VariableType type)
void	addVariable (String name, VariableType type, boolean reversed)
void	addVariable (String name, VariableType type, String avoid)
void	addVariable (String name, boolean preprocess, VariableType type)
void	addVariable (String name, boolean preprocess, VariableType type, boolean reversed)
void	addVariable (String name, boolean preprocess, VariableType type, String avoid)
void	addExternalVariable (String root, String name)
String	getPath (Object entity)
void	postprocessMatchingVariable (Dao dao, IPreprocessor postprocessor, IndicatorVariable variable, String entityRoot, String relatedRoot)

Additional Inherited Members
Protected Attributes inherited from org.turro.indicator.AbstractIndicator
List< IndicatorVariable >	variables = new ArrayList<>()
String	root

Detailed Description

Author

Lluis Turró Cutiller lluis.nosp@m.@tur.nosp@m.ro.or.nosp@m.g

Definition at line 49 of file ContactIndicator.java.

Constructor & Destructor Documentation

ContactIndicator()

org.turro.indicator.ContactIndicator.ContactIndicator

(

)

Definition at line 51 of file ContactIndicator.java.

                            {
    root = "contact";
  }

Member Function Documentation

createDao()

Dao org.turro.indicator.ContactIndicator.createDao ( )

protected

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 110 of file ContactIndicator.java.

                            {
    return new ContactsPU();
  }

Here is the caller graph for this function:

generateSiblings()

void org.turro.indicator.ContactIndicator.generateSiblings

(

)

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 82 of file ContactIndicator.java.

                                 {
    List<LogCount> genact = Logs.getGeneratorActivityCount(new CheckDate().addYears(-2).getDate());
    SqlClause.update("Contact").set("inactive", true)
            .dao(getDao()).execute();
    try(Stream<Contact> stream = createDao().stream(Contact.class, "select c from Contact c")) {
      stream.forEach(contact -> {
        if(genact.contains(new LogCount("/contact/" + contact.getId(), 0))) {
          SqlClause.update("Contact").set("inactive", false)
                  .where().equal("id", contact.getId())
                  .dao(getDao()).execute();
        }
      });
    }
    try(Stream<Contact> stream = SqlClause.select("distinct c").from("Contact c")
            .where().in("c.type", List.copyOf(ContactType.juridicals()))
            .and().exists(SqlClause.select("r").from("BusinessRelation r")
                    .where("r.business.id = c.id")
                    .and().equal("r.contact.inactive", false))            
            .dao(createDao()).stream(Contact.class)) {
      stream.forEach(contact -> {
        SqlClause.update("Contact").set("inactive", false)
                .where().equal("id", contact.getId())
                .dao(getDao()).execute();
      });
    }
  }

Here is the call graph for this function:

getValue() [1/2]

double org.turro.indicator.ContactIndicator.getValue	(	IndicatorVariable	variable,
		Object	entity
	)

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 115 of file ContactIndicator.java.

                                                                    {
    if((entity instanceof Contact) && itsMine(variable)) {
      Contact contact = (Contact) entity;
      switch(variable.getName()) {
        case "profile":
          return contact.getProfile().getCompletion().getPercent();
      }
    }
    return 0.0;
  }

Here is the call graph for this function:

getValue() [2/2]

double org.turro.indicator.ContactIndicator.getValue	(	IndicatorVariable	variable,
		Object	entity,
		String	relatedPath
	)

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 127 of file ContactIndicator.java.

                                                                                        {
    if((entity instanceof Contact) && itsMine(variable)) {
      Contact contact = (Contact) entity;
      IElephantEntity related = Entities.getController(relatedPath);
      if("contact".equals(related.getRoot())) {
        switch(variable.getName()) {
          case "distance":
            if(contact.hasLocation()) {
              Contact crelated = (Contact) related.getEntity();
              if(crelated.hasLocation()) {
                return ZipCodeAPI.distanceOrZero(contact.getLatitude(), crelated.getLatitude(), 
                                contact.getLongitude(), crelated.getLongitude());
              }
            }
        }
      }
    }
    return 0.0;
  }

Here is the call graph for this function:

initExternalVariables()

void org.turro.indicator.ContactIndicator.initExternalVariables ( )

protected

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 63 of file ContactIndicator.java.

                                         {
    addExternalVariable("dossier", "participation");
    addExternalVariable("dossier", "categoryParticipation");
    addExternalVariable("dossier", "issueResponsible");
    addExternalVariable("dossier", "issueReporter");
    addExternalVariable("dossier", "issueQA");
    addExternalVariable("dossier", "issueAssistant");
    addExternalVariable("student", "challenges");
    addExternalVariable("student", "responses");
    addExternalVariable("student", "responsesLike");
    addExternalVariable("forum", "topics");
    addExternalVariable("forum", "posts");
    addExternalVariable("commons", "following");
    addExternalVariable("commons", "followed");
    addExternalVariable("commons", "seen");
    addExternalVariable("commons", "like");
  }

Here is the call graph for this function:

initVariables()

void org.turro.indicator.ContactIndicator.initVariables ( )

protected

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 56 of file ContactIndicator.java.

                                 {
    addVariable("available", true, VariableType.RANKING_VARIABLE);
    addVariable("profile", VariableType.RANKING_VARIABLE);
    addVariable("distance", VariableType.MATCHING_VARIABLE, true);
  }

Here is the call graph for this function:

postprocessRankingVariable()

void org.turro.indicator.ContactIndicator.postprocessRankingVariable ( Dao  dao, IPreprocessor  preprocessor, IndicatorVariable  variable, String  entityRoot  )

protected

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 193 of file ContactIndicator.java.

                                                                                                                                {
    if("contact".equals(entityRoot)) {
      try(Stream<Contact> stream = getJuridicals()) {
        stream.forEach(juridical -> {
          List<String> springPaths = getSpringPaths(juridical);
          if(!springPaths.isEmpty()) {
            WhereClause wc = PostprocessClause.load(preprocessor.tableName())
                    .setEntityPath(ContactsPU.getObjectPath(juridical))
                    .setSpringPaths(springPaths)
                    .getRankingClause();
            if(wc != null) {
              try(Stream<GenericRanking> istream = dao.stream(GenericRanking.class, wc, 1000)) {
                istream.forEach(r -> {
                  if(r != null && !Zero.near(r.getRanking(), 2)) {
                    preprocessor.poolInstance(r.copyTo((IRanking) preprocessor.createInstance()));
                  } 
                });
              }
            }
          }
        });
        preprocessor.finishPreprocessor();
      }
    }
  }

Here is the call graph for this function:

processMatchingVariable()

void org.turro.indicator.ContactIndicator.processMatchingVariable ( Dao  dao, IPreprocessor  preprocessor, IndicatorVariable  variable, String  entityRoot, String  relatedRoot  )

protected

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 174 of file ContactIndicator.java.

                                                                                                                                                 {
    WhereClause wc = null;
    if("contact".equals(entityRoot)) {
      if("contact".equals(relatedRoot)) {
        switch(variable.getName()) {
        }
      }
    }
    if(wc != null) {
      try(Stream<GenericMatching> stream = dao.stream(GenericMatching.class, wc, 1000)) {
        stream.forEach(r -> {
          preprocessor.poolInstance(r.copyTo((IMatching) preprocessor.createInstance()));
        });
        preprocessor.finishPreprocessor();
      }
    }
  }

Here is the call graph for this function:

processRankingVariable()

void org.turro.indicator.ContactIndicator.processRankingVariable ( Dao  dao, IPreprocessor  preprocessor, IndicatorVariable  variable, String  entityRoot  )

protected

Reimplemented from org.turro.indicator.AbstractIndicator.

Definition at line 148 of file ContactIndicator.java.

                                                                                                                            {
    WhereClause wc = null;
    if("contact".equals(entityRoot)) {
      switch(variable.getName()) {
        case "available":
          wc = PreprocessClause.load("JobBoard")
                  .addCondition("and available = TRUE")
                  .setRankingRoot(entityRoot)
                  .setRankingField("concat('/contact/',contact.id)")
                  .setVariable(variable)
                  .setAggregate("count(id)")
                  .getClause();
          break;
      }
    }
    if(wc != null) {
      try(Stream<GenericRanking> stream = dao.stream(GenericRanking.class, wc, 1000)) {
        stream.forEach(r -> {
          preprocessor.poolInstance(r.copyTo((IRanking) preprocessor.createInstance()));
        });
        preprocessor.finishPreprocessor();
      }
    }
  }

Here is the call graph for this function:

---

The documentation for this class was generated from the following file:

• ContactIndicator.java