125 lines
4.6 KiB
Plaintext
Executable File
125 lines
4.6 KiB
Plaintext
Executable File
/*
|
||
* To change this template, choose Tools | Templates
|
||
* and open the template in the editor.
|
||
*/
|
||
package com.fp.bpmlib.query.rules;
|
||
|
||
import java.util.ArrayList;
|
||
import java.util.HashMap;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
|
||
import javax.persistence.EntityManager;
|
||
import javax.persistence.Query;
|
||
|
||
import com.fp.dto.Response;
|
||
import com.fp.dto.query.QueryBean;
|
||
import com.fp.dto.query.QueryCriteria;
|
||
import com.fp.dto.query.QueryRequest;
|
||
import com.fp.dto.rules.QueryRule;
|
||
import com.fp.persistence.commondb.PersistenceHelper;
|
||
|
||
// TODO: Auto-generated Javadoc
|
||
/**
|
||
* Clase que realiza la consulta las reglas BPM.
|
||
*
|
||
* @author BPTWPA
|
||
*/
|
||
public class Rules extends QueryRule {
|
||
|
||
/** Constante serialVersionUID. */
|
||
private static final long serialVersionUID = 1L;
|
||
|
||
/** Constante JPQL_RULES. */
|
||
private static final String JPQL_RULES = "select r.pk.rulecode, r.pk.companycode, r.description, r.packagename, "
|
||
+ "r.snapshot, r.active, r.refresh, r.parametertype, r.messagecode , m.description " + "from TbpmRules r, TgeneMessageTemplates m "
|
||
+ "where r.messagecode=m.pk ";
|
||
|
||
/**
|
||
* Process.
|
||
*
|
||
* @param pQueryRequest the query request
|
||
* @return query request
|
||
* @throws Exception la exception
|
||
*/
|
||
@Override
|
||
public QueryRequest process(QueryRequest pQueryRequest) throws Exception {
|
||
StringBuilder jpql = new StringBuilder();
|
||
List<Map<String, Object>> listResp = new ArrayList<Map<String, Object>>();
|
||
Response response = pQueryRequest.getResponse();
|
||
QueryBean qb = (QueryBean) pQueryRequest.get("TBPMRULES");
|
||
List<QueryCriteria> lcriteria = qb.getCriteria();
|
||
EntityManager em = PersistenceHelper.getEntityManager();
|
||
jpql.append(Rules.JPQL_RULES);
|
||
Query qry = em.createQuery(this.addSimpleCriteriaJPQL(jpql, lcriteria, qb));
|
||
this.setSimpleParametersJPQL(qry, lcriteria);
|
||
qry.setFirstResult((qb.getPage() - 1) * qb.getPageSize());
|
||
qry.setMaxResults(qb.getPageSize());
|
||
@SuppressWarnings("unchecked")
|
||
List<Object> list = qry.getResultList();
|
||
if (!list.isEmpty()) {
|
||
for (Object oj : list) {
|
||
Map<String, Object> mapResp = new HashMap<String, Object>();
|
||
Object[] obj = (Object[]) oj;
|
||
mapResp.put("pk_rulecode", obj[0]);
|
||
mapResp.put("pk_companycode", obj[1]);
|
||
mapResp.put("description", obj[2]);
|
||
mapResp.put("packagename", obj[3]);
|
||
mapResp.put("snapshot", obj[4]);
|
||
mapResp.put("active", obj[5]);
|
||
mapResp.put("refresh", obj[6]);
|
||
mapResp.put("parametertype", obj[7]);
|
||
mapResp.put("messagecode", obj[8]);
|
||
mapResp.put("descmessage", obj[9]);
|
||
listResp.add(mapResp);
|
||
}
|
||
}
|
||
response.put("TBPMRULES", listResp);
|
||
return pQueryRequest;
|
||
}
|
||
|
||
/**
|
||
* M<>todo que agrega los parametros de una consulta jpql.
|
||
*
|
||
* @param jpql Creado
|
||
* @param lcriteria Criterios de consulta
|
||
* @param qb the qb
|
||
* @return String del jpql
|
||
*/
|
||
private String addSimpleCriteriaJPQL(StringBuilder jpql, List<QueryCriteria> lcriteria, QueryBean qb) {
|
||
for (QueryCriteria obj : lcriteria) {
|
||
if (obj.getValue() != null) {
|
||
jpql.append(" and ").append(obj.getProperty()).append(" ").append(obj.getOperation()).append(" :")
|
||
.append(obj.getProperty().replace(".", ""));
|
||
}
|
||
}
|
||
boolean first = true;
|
||
for (QueryCriteria order : qb.getOrder(true)) {
|
||
if (first) {
|
||
jpql.append(" ORDER BY ");
|
||
} else {
|
||
jpql.append(" asc, ");
|
||
}
|
||
jpql.append(order.getProperty());
|
||
first = false;
|
||
}
|
||
return String.valueOf(jpql);
|
||
}
|
||
|
||
/**
|
||
* M<>todo que setea los parametros para la consulta.
|
||
*
|
||
* @param qry Query
|
||
* @param lcriteria Criterios de consluta
|
||
*/
|
||
private void setSimpleParametersJPQL(Query qry, List<QueryCriteria> lcriteria) {
|
||
for (QueryCriteria obj : lcriteria) {
|
||
if (obj.getValue() != null) {
|
||
qry.setParameter(obj.getProperty().replace(".", ""),
|
||
((obj.getProperty().replace(".", "").compareTo("rpkcompanycode") == 0) ? Integer.valueOf(String.valueOf(obj.getValue()))
|
||
: obj.getValue()));
|
||
}
|
||
}
|
||
}
|
||
}
|