diff --git a/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ColaImpresion.java b/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ColaImpresion.java index 34dd834..acee188 100644 --- a/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ColaImpresion.java +++ b/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ColaImpresion.java @@ -20,84 +20,87 @@ import com.fp.persistence.parmas.param.TarmCentroControl; import com.fp.persistence.pgeneral.safe.TsafeUserDetail; /** - * Componente que realiza la búsquedas de los datos de impresión de un usuario + * Componente que realiza la búsquedas de los datos de impresión + * de un usuario + * * @author dcruz * */ -public class ColaImpresion extends QueryRule{ +public class ColaImpresion extends QueryRule { - private static final long serialVersionUID = -3993166768741911054L; - private static final String QUERY_USUARIO_ID = "SELECT o FROM TsafeUserDetail o WHERE o.pk.usercode=:usercode AND o.pk.dateto=:dateto"; - private static final String QUERY_COLA_IMPRESION = "SELECT o.* FROM TarmColadeImpresion o " - + "left join tarmdocumentohabilitante i on o.cdocumento = i.cdocumento " - + "left join tarmsolicitud k on i.csolicitud = k.csolicitud " - + "WHERE o.estadoimpresion=:estado and i.ccentrocontrol = :ccentrocontrol and coalesce(k.estado,'APB') IN ('APB','FIN')"; + private static final long serialVersionUID = -3993166768741911054L; + private static final String QUERY_USUARIO_ID = "SELECT o FROM TsafeUserDetail o WHERE o.pk.usercode=:usercode AND o.pk.dateto=:dateto"; + private static final String QUERY_COLA_IMPRESION = "SELECT o.* FROM TarmColadeImpresion o " + + "left join tarmdocumentohabilitante i on o.cdocumento = i.cdocumento " + + "left join tarmsolicitud k on i.csolicitud = k.csolicitud " + + "WHERE o.estadoimpresion=:estado and i.ccentrocontrol = :ccentrocontrol and coalesce(k.estado,'APB') IN ('APB','FIN')"; - @SuppressWarnings("unchecked") - @Override - public QueryRequest process(QueryRequest pRequest) throws Exception { - Query query; - List lcolaImpresion = null; - try { - String estado = (String) pRequest.get("estado"); - String usercode = (String) pRequest.get("usercode"); - System.out.println("estado..."+estado); - System.out.println("usercode..."+usercode); - query = PersistenceHelper.getEntityManager().createQuery(QUERY_USUARIO_ID); - query.setParameter("usercode", usercode); - query.setParameter("dateto", FormatDates.getDefaultExpiryTimestamp()); - List ltsafeUserDetails = query.getResultList(); - TsafeUserDetail tsafeUserDetail; - if(ltsafeUserDetails != null && !ltsafeUserDetails.isEmpty()){ - tsafeUserDetail = ltsafeUserDetails.iterator().next(); - }else{ - return pRequest; - } - //centro control - query=PersistenceHelper.getEntityManager().createQuery("select o from TarmCentroControl o" - + " where o.pk=(select p.ccentrocontrol from TarmCentroControlJur p " - + " where p.provincecode=(select pr.provincecode from TcustPersonAddress pr " - + " where pr.pk.personcode=:personcode and" - + " pr.pk.dateto=:dateto and" - + " pr.principal='Y' and" - + " pr.pk.addressnumber=(select max(q.pk.addressnumber) from TcustPersonAddress q " - + " where q.pk.personcode=:personcode and" - + " q.pk.dateto=:dateto and" - + " q.principal='Y')))"); - query.setParameter("personcode", tsafeUserDetail.getPk().getPersoncode()); - query.setParameter("dateto", FormatDates.getDefaultExpiryTimestamp()); - List tarmCentroControls = query.getResultList(); - TarmCentroControl tarmCentroControl; - if(tarmCentroControls != null && !tarmCentroControls.isEmpty()){ - tarmCentroControl = tarmCentroControls.iterator().next(); - }else{ - return pRequest; - } - System.out.println("QUERY COLA IMPRESION: "+QUERY_COLA_IMPRESION); - query = PersistenceHelper.getEntityManager().createNativeQuery(QUERY_COLA_IMPRESION); - query.setParameter("estado", estado); - query.setParameter("ccentrocontrol", tarmCentroControl.getPk()); + @SuppressWarnings("unchecked") + @Override + public QueryRequest process(QueryRequest pRequest) throws Exception { + Query query; + List lcolaImpresion = null; + try { + String estado = (String) pRequest.get("estado"); + String usercode = (String) pRequest.get("usercode"); + System.out.println("estado..." + estado); + System.out.println("usercode..." + usercode); + query = PersistenceHelper.getEntityManager().createQuery(QUERY_USUARIO_ID); + query.setParameter("usercode", usercode); + query.setParameter("dateto", FormatDates.getDefaultExpiryTimestamp()); + List ltsafeUserDetails = query.getResultList(); + TsafeUserDetail tsafeUserDetail; + if (ltsafeUserDetails != null && !ltsafeUserDetails.isEmpty()) { + tsafeUserDetail = ltsafeUserDetails.iterator().next(); + } else { + return pRequest; + } + //centro control + query = PersistenceHelper.getEntityManager().createQuery("select o from TarmCentroControl o" + + " where o.pk=(select p.ccentrocontrol from TarmCentroControlJur p " + + " where p.provincecode=(select pr.provincecode from TcustPersonAddress pr " + + " where pr.pk.personcode=:personcode and" + + " pr.pk.dateto=:dateto and" + + " pr.principal='Y' and" + + " pr.pk.addressnumber=(select max(q.pk.addressnumber) from TcustPersonAddress q " + + " where q.pk.personcode=:personcode and" + + " q.pk.dateto=:dateto and" + + " q.principal='Y')))"); + query.setParameter("personcode", tsafeUserDetail.getPk().getPersoncode()); + query.setParameter("dateto", FormatDates.getDefaultExpiryTimestamp()); + List tarmCentroControls = query.getResultList(); + TarmCentroControl tarmCentroControl; + if (tarmCentroControls != null && !tarmCentroControls.isEmpty()) { + tarmCentroControl = tarmCentroControls.iterator().next(); + } else { + return pRequest; + } + System.out.println("QUERY COLA IMPRESION: " + QUERY_COLA_IMPRESION); + query = PersistenceHelper.getEntityManager().createNativeQuery(QUERY_COLA_IMPRESION); + query.setParameter("estado", estado); + query.setParameter("ccentrocontrol", tarmCentroControl.getPk()); + + List coladeImpresionList = new ArrayList(); + List ltarmColadeImpresionsTMP = query.getResultList(); + for (Object[] tmp : ltarmColadeImpresionsTMP) { + TarmColadeImpresion colaImpresionObj = new TarmColadeImpresion(); + colaImpresionObj.setPk(tmp[3].toString()); + colaImpresionObj.setEstadoimpresion(tmp[1].toString()); + colaImpresionObj.setFechaimpresion((Timestamp) tmp[4]); + colaImpresionObj.setEstadoimpresioncode(tmp[2].toString()); + colaImpresionObj.setCdocumento((new BigDecimal(tmp[0].toString())).longValue()); + colaImpresionObj.setFecharegistro(new Date(((Timestamp) tmp[5]).getTime())); + if (tmp[6] != null) { + colaImpresionObj.setCodigotarjeta(tmp[6].toString()); + } + coladeImpresionList.add(colaImpresionObj); + } + lcolaImpresion = ColaImpresionUtil.getInstancia().completaColaImpresion(coladeImpresionList, tsafeUserDetail.getPk().getPersoncode(), tsafeUserDetail.getPk().getUsercode()); + pRequest.getResponse().put("COLAIMPRESION", lcolaImpresion); + } catch (Throwable e) { + APPLogger.getLogger().error(e.getMessage(), e); + } + return pRequest; + } - List coladeImpresionList = new ArrayList(); - List ltarmColadeImpresionsTMP = query.getResultList(); - for(Object[]tmp:ltarmColadeImpresionsTMP){ - TarmColadeImpresion colaImpresionObj = new TarmColadeImpresion(); - colaImpresionObj.setPk(tmp[3].toString()); - colaImpresionObj.setEstadoimpresion(tmp[1].toString()); - colaImpresionObj.setFechaimpresion((Timestamp) tmp[4]); - colaImpresionObj.setEstadoimpresioncode(tmp[2].toString()); - colaImpresionObj.setCdocumento((new BigDecimal(tmp[0].toString())).longValue()); - colaImpresionObj.setFecharegistro(new Date(((Timestamp) tmp[5]).getTime())); - if (tmp[6] != null) - colaImpresionObj.setCodigotarjeta(tmp[6].toString()); - coladeImpresionList.add(colaImpresionObj); - } - lcolaImpresion = ColaImpresionUtil.getInstancia().completaColaImpresion(coladeImpresionList, tsafeUserDetail.getPk().getPersoncode(), tsafeUserDetail.getPk().getUsercode()); - pRequest.getResponse().put("COLAIMPRESION", lcolaImpresion); - } catch (Throwable e) { - APPLogger.getLogger().error(e.getMessage(), e); - } - return pRequest; - } - } diff --git a/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ConsultaImpresionProceso.java b/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ConsultaImpresionProceso.java index 7ab3cc0..3a8cad5 100644 --- a/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ConsultaImpresionProceso.java +++ b/base/business/armas/src/main/java/com/fp/armas/rules/query/webservices/ConsultaImpresionProceso.java @@ -20,53 +20,55 @@ import com.fp.persistence.parmas.inte.TarmColadeImpresion; /** * Consulta los datos de impresión del proceso + * * @author dcruz * */ public class ConsultaImpresionProceso extends QueryRule { - private static final long serialVersionUID = -7675701723545274414L; - public static final String QUERY_COLA_SOLICITUD = "SELECT o.* FROM TarmColadeImpresion o WHERE o.estadoimpresion='PIMPR' and o.cdocumento " - + "IN ((SELECT i.cdocumento FROM TarmDocumentoHabilitante i WHERE i.csolicitud IN (SELECT c.CSOLICITUD FROM TarmSolicitud c " - + "WHERE c.estado IN ('APB','FIN') and c.numerosolicitud=:numerosolicitud)) UNION (SELECT SD.cdocumento FROM tarmsolicituddocumento SD WHERE sd.csolicitud " - + "IN (SELECT c.CSOLICITUD FROM TarmSolicitud c WHERE c.estado IN ('APB','FIN') and c.numerosolicitud=:numerosolicitud)))"; + private static final long serialVersionUID = -7675701723545274414L; + public static final String QUERY_COLA_SOLICITUD = "SELECT cdocumento, estadoimpresion, estadoimpresioncode, cimpresion, fechaimpresion, " + + "fecharegistro, codigotarjeta FROM TarmColadeImpresion o WHERE o.estadoimpresion='PIMPR' and o.cdocumento " + + "IN ((SELECT i.cdocumento FROM TarmDocumentoHabilitante i WHERE i.csolicitud IN (SELECT c.CSOLICITUD FROM TarmSolicitud c " + + "WHERE c.estado IN ('APB','FIN') and c.numerosolicitud=:numerosolicitud)) UNION (SELECT SD.cdocumento FROM tarmsolicituddocumento SD " + + "WHERE sd.csolicitud IN (SELECT c.CSOLICITUD FROM TarmSolicitud c WHERE c.estado IN ('APB','FIN') and c.numerosolicitud=:numerosolicitud)))"; - @SuppressWarnings("unchecked") - @Override - public QueryRequest process(QueryRequest pRequest) throws Exception { - // TODO Auto-generated method stub - List lcolaImpresion = null; - try { - - String codigosolicitud = (String) pRequest.get("CODIGOSOLICITUD"); - System.out.println("codigosolicitud.."+codigosolicitud); - System.out.println(QUERY_COLA_SOLICITUD); - Query query = PersistenceHelper.getEntityManager().createNativeQuery(QUERY_COLA_SOLICITUD); - query.setParameter("numerosolicitud", codigosolicitud); + @SuppressWarnings("unchecked") + @Override + public QueryRequest process(QueryRequest pRequest) throws Exception { + // TODO Auto-generated method stub + List lcolaImpresion = null; + try { - List ltarmColadeImpresions = new ArrayList(); - List ltarmColadeImpresionsTMP = query.getResultList(); - - for(Object[]tmp:ltarmColadeImpresionsTMP){ - TarmColadeImpresion colaImpresionObj = new TarmColadeImpresion(); - colaImpresionObj.setPk(tmp[3].toString()); - colaImpresionObj.setEstadoimpresion(tmp[1].toString()); - colaImpresionObj.setFechaimpresion((Timestamp) tmp[4]); - colaImpresionObj.setEstadoimpresioncode(tmp[2].toString()); - colaImpresionObj.setCdocumento(((BigDecimal) tmp[0]).longValue()); - colaImpresionObj.setFecharegistro(new Date(((Timestamp) tmp[5]).getTime())); - if (tmp[6] != null) - colaImpresionObj.setCodigotarjeta(tmp[6].toString()); - ltarmColadeImpresions.add(colaImpresionObj); - } - - lcolaImpresion = ColaImpresionUtil.getInstancia().completaColaImpresion(ltarmColadeImpresions); - pRequest.getResponse().put("COLAIMPRESION", lcolaImpresion); - pRequest.getResponse().put("COLAIMPRESION", lcolaImpresion); - } catch (Throwable e) { - APPLogger.getLogger().error(e.getMessage(), e); - } - return pRequest; - } + String codigosolicitud = (String) pRequest.get("CODIGOSOLICITUD"); + System.out.println("codigosolicitud.." + codigosolicitud); + System.out.println(QUERY_COLA_SOLICITUD); + Query query = PersistenceHelper.getEntityManager().createNativeQuery(QUERY_COLA_SOLICITUD); + query.setParameter("numerosolicitud", codigosolicitud); + + List ltarmColadeImpresions = new ArrayList<>(); + List ltarmColadeImpresionsTMP = query.getResultList(); + + for (Object[] tmp : ltarmColadeImpresionsTMP) { + TarmColadeImpresion colaImpresionObj = new TarmColadeImpresion(); + colaImpresionObj.setCdocumento(((BigDecimal) tmp[0]).longValue()); + colaImpresionObj.setEstadoimpresion(tmp[1].toString()); + colaImpresionObj.setEstadoimpresioncode(tmp[2].toString()); + colaImpresionObj.setPk(tmp[3].toString()); + colaImpresionObj.setFechaimpresion(tmp[4] == null ? null : new Timestamp(((Date) tmp[4]).getTime())); + colaImpresionObj.setFecharegistro(tmp[5] == null ? null : (Date) tmp[5]); + if (tmp[6] != null) { + colaImpresionObj.setCodigotarjeta(tmp[6].toString()); + } + ltarmColadeImpresions.add(colaImpresionObj); + } + lcolaImpresion = ColaImpresionUtil.getInstancia().completaColaImpresion(ltarmColadeImpresions); + pRequest.getResponse().put("COLAIMPRESION", lcolaImpresion); +// pRequest.getResponse().put("COLAIMPRESION", lcolaImpresion); + } catch (Throwable e) { + APPLogger.getLogger().error(e.getMessage(), e); + } + return pRequest; + } }