leonardo 2015-05-14 18:13:15 +00:00
parent b5464a23e6
commit a20409819b
1 changed files with 3 additions and 77 deletions

View File

@ -802,15 +802,8 @@ public class EditarPuntoVentaController extends MyGenericForwardComposer {
public void onClick$btnIntegracao(Event ev) throws InterruptedException { public void onClick$btnIntegracao(Event ev) throws InterruptedException {
Connection myConn = null; Connection myConn = null;
Integer countTitulos = 0;
StringBuilder logr = new StringBuilder();
try { try {
myConn = dataSource.getConnection(); myConn = dataSource.getConnection();
myConn.setAutoCommit(false);
Date dateInicio = fecIntegracion.getValue(); Date dateInicio = fecIntegracion.getValue();
dateInicio = DateUtil.inicioFecha(dateInicio); dateInicio = DateUtil.inicioFecha(dateInicio);
@ -818,75 +811,9 @@ public class EditarPuntoVentaController extends MyGenericForwardComposer {
log.info("puntoVentaId=" + puntoVenta.getPuntoventaId() + ";fecInicio=" + dateInicio + ";fecFin=" + dateFim); log.info("puntoVentaId=" + puntoVenta.getPuntoventaId() + ";fecInicio=" + dateInicio + ";fecFin=" + dateFim);
StringBuilder sb = null; StringBuilder sb = TotvsService.integraTitulosPagarReceber(puntoVenta.getPuntoventaId(), myConn, dateInicio, dateFim,checkTodosPuntosVenta.isChecked(), checkSimulaIntegracion.isChecked());
logResult.setText("");
TotvsService.setSimulacao(checkSimulaIntegracion.isChecked()); logResult.setText(sb.toString());
if (checkSimulaIntegracion.isChecked()) {
sb= new StringBuilder();
TotvsService.setSb(sb);
}
DAO.getInstance().setDBConnection(myConn);
String strEmpresas = DAO.getInstance().obterConstante("EMPRESAS_INTEGRACAO");
log.info("Empresa Integra Totvs:"+strEmpresas);
if (checkTodosPuntosVenta.isChecked()){
for (Integer puntoventaId : DAO.getInstance().obterListaPuntoVenta()){
for (String empresaId : strEmpresas.split(",")){
try{
countTitulos += TotvsService.cadastrarTituloAReceber(puntoventaId, dateInicio, dateFim, myConn, Integer.parseInt(empresaId));
if (!checkSimulaIntegracion.isChecked()) {
myConn.commit();
} else {
logr.append(sb);
sb= new StringBuilder();
TotvsService.setSb(sb);
myConn.rollback();
}
}catch (Exception e){
log.error("Erro ao integrar Empresa " + empresaId + " - Ponto de venda " + puntoventaId,e);
if (myConn != null) {
try {
myConn.rollback();
} catch (SQLException e1) {
log.error("Erro rollback", e1);
}
}
}
}
}
} else {
for (String empresaId : strEmpresas.split(",")){
try{
countTitulos += TotvsService.cadastrarTituloAReceber(puntoVenta.getPuntoventaId(), dateInicio, dateFim, myConn, Integer.parseInt(empresaId));
if (!checkSimulaIntegracion.isChecked()) {
myConn.commit();
} else {
logr.append(sb);
sb= new StringBuilder();
TotvsService.setSb(sb);
myConn.rollback();
}
}catch (Exception e){
log.error("Erro ao integrar Empresa " + empresaId + " - Ponto de venda " + puntoVenta.getPuntoventaId(),e);
if (myConn != null) {
try {
myConn.rollback();
} catch (SQLException e1) {
log.error("Erro rollback", e1);
}
}
}
}
}
logResult.setText(logr.toString());
log.info("Total de títulos enviados: " + countTitulos);
} catch (Exception e) { } catch (Exception e) {
log.error("Erro ao integrar",e); log.error("Erro ao integrar",e);
@ -910,7 +837,6 @@ public class EditarPuntoVentaController extends MyGenericForwardComposer {
log.error("Erro ao fechar a conexão", e); log.error("Erro ao fechar a conexão", e);
} }
} }
log.info("Total de títulos enviados: " + countTitulos);
} }
} }