daniel.zauli 2017-01-18 20:50:27 +00:00
parent aa51e6902e
commit 300e9de79e
2 changed files with 37 additions and 8 deletions

View File

@ -142,9 +142,15 @@ public class CalcularPeajeHibernateDAO extends GenericHibernateDAO<String, Strin
// pra cada ruta obter as combinacoes de tramos, cada tramo com sua lista de casetaPeaje
public int[] gerarSQLInserirPeajes(List<Ruta> lsRuta, OrgaoConcedente orgao, boolean usaICMS) {
boolean isOrgaoNull = orgao == null;
List<String> updates = new ArrayList<String>();
List<PeajeVO> peajes = new ArrayList<PeajeVO>();
List<ClasseIndicePeaje> classeIndicePeajes = new ArrayList<ClasseIndicePeaje>();
if(orgao != null){
orgao = orgaoConcedenteService.obtenerID(orgao.getOrgaoConcedenteId());
List<ClasseIndicePeaje> classeIndicePeajes = orgao.getClassesIndicePeaje();
classeIndicePeajes = orgao.getClassesIndicePeaje();
}
log.debug("****** INICIO DO PROCESSO DE CALCULO DE PEDAGIO ******");
log.debug("****** QTD DE LINHAS = "+lsRuta.size()+"******");
int z = 0;
@ -154,6 +160,14 @@ public class CalcularPeajeHibernateDAO extends GenericHibernateDAO<String, Strin
List<Object> lsObj = buscarCasetasPeajeWithinTramo(ruta);
log.debug("****** QTD COMBINAÇÕES DE TRECHOS x QTD PEDAGIOS POR TRECHO: "+lsObj.size()+" ******");
if(isOrgaoNull){
orgao = orgaoConcedenteService.obtenerID(ruta.getOrgaoConcedente().getOrgaoConcedenteId());
classeIndicePeajes = orgao.getClassesIndicePeaje();
String update = " update peaje set activo = 0 where ruta_id ="+ruta.getRutaId();
updates.add(update);
}
if (null != lsObj) {
for (Object arrObj : lsObj) {
BigDecimal bigKm = new BigDecimal(((Object[]) arrObj)[11].toString()) ;
@ -163,16 +177,27 @@ public class CalcularPeajeHibernateDAO extends GenericHibernateDAO<String, Strin
log.debug("****** FIM LINHA : "+ruta.toString()+" . INSTRUCOES DE INSERT NO BANCO PRONTAS ******");
}
StringBuilder updateSql = new StringBuilder()
StringBuilder updateSql = new StringBuilder();
if(isOrgaoNull == false){
updateSql = new StringBuilder()
.append("update peaje set activo = 0 ")
.append("where orgaoconcedente_id = ")
.append(orgao.getOrgaoConcedenteId());
}
int[] result = {};
Connection con = getSession().connection();
try {
Statement stmt = con.createStatement();
con.setAutoCommit(false);
if(!isOrgaoNull){
stmt.addBatch(updateSql.toString());
}else{
for(String up : updates){
stmt.addBatch(up);
}
}
for(int i = 0 ; i < peajes.size(); i++){
stmt.addBatch(peajes.get(i).toInsertQuery());
stmt.addBatch(peajes.get(i).toUpdateExcepcionPeajeQuery());

View File

@ -68,7 +68,11 @@ public class RutaHibernateDAO extends GenericHibernateDAO<Ruta, Integer> impleme
c.addOrder(Order.asc("descruta"));
return c.list();
List<Ruta> l =c.list();
for(Ruta r : l){
r.getLsRutaEmpresa();
}
return l;
}
public List<Ruta> buscarPorClaseServicio(ClaseServicio claseServicio) {