|
|
@ -4,6 +4,7 @@ import java.math.BigDecimal;
|
|
|
|
import java.sql.Connection;
|
|
|
|
import java.sql.Connection;
|
|
|
|
import java.sql.PreparedStatement;
|
|
|
|
import java.sql.PreparedStatement;
|
|
|
|
import java.sql.ResultSet;
|
|
|
|
import java.sql.ResultSet;
|
|
|
|
|
|
|
|
import java.sql.ResultSetMetaData;
|
|
|
|
import java.sql.SQLException;
|
|
|
|
import java.sql.SQLException;
|
|
|
|
import java.util.ArrayList;
|
|
|
|
import java.util.ArrayList;
|
|
|
|
import java.util.Date;
|
|
|
|
import java.util.Date;
|
|
|
@ -411,9 +412,9 @@ public class FiscalHibernateDAO implements FiscalDAO {
|
|
|
|
sql.append(" ei.icms as impostoEstado, ");
|
|
|
|
sql.append(" ei.icms as impostoEstado, ");
|
|
|
|
sql.append(" 'N' as status ");
|
|
|
|
sql.append(" 'N' as status ");
|
|
|
|
sql.append(" FROM fiscal_r4 r4 ");
|
|
|
|
sql.append(" FROM fiscal_r4 r4 ");
|
|
|
|
sql.append(" LEFT JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
sql.append(" INNER JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
sql.append(" LEFT JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 ");
|
|
|
|
sql.append(" INNER JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 ");
|
|
|
|
sql.append(" INNER JOIN boleto b ON b.boleto_id = r4.boleto_id ");
|
|
|
|
sql.append(" INNER JOIN boleto b ON b.boleto_id = r4.boleto_id ");
|
|
|
|
sql.append(" INNER JOIN clase_servicio cs ON cs.claseservicio_id = b.claseservicio_id ");
|
|
|
|
sql.append(" INNER JOIN clase_servicio cs ON cs.claseservicio_id = b.claseservicio_id ");
|
|
|
|
sql.append(" LEFT JOIN alias_servico ase ON ase.origen_id = b.origen_id ");
|
|
|
|
sql.append(" LEFT JOIN alias_servico ase ON ase.origen_id = b.origen_id ");
|
|
|
@ -466,7 +467,7 @@ public class FiscalHibernateDAO implements FiscalDAO {
|
|
|
|
return sql.toString();
|
|
|
|
return sql.toString();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public String sqlFiscaisECFPendencias(Date inicio, Date fim, Integer empresaId, Connection connection) throws SQLException {
|
|
|
|
private String sqlFiscaisECFPendenciasDesconto() {
|
|
|
|
|
|
|
|
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
|
sql.append(" SELECT r4.numserie20 as numImpressora, ");
|
|
|
|
sql.append(" SELECT r4.numserie20 as numImpressora, ");
|
|
|
@ -483,8 +484,10 @@ public class FiscalHibernateDAO implements FiscalDAO {
|
|
|
|
sql.append(" r5.codproduto as codProduto, ");
|
|
|
|
sql.append(" r5.codproduto as codProduto, ");
|
|
|
|
sql.append(" fi.modelo as modeloImpressora, ");
|
|
|
|
sql.append(" fi.modelo as modeloImpressora, ");
|
|
|
|
sql.append(" r4.usuario_id as numCaixa, ");
|
|
|
|
sql.append(" r4.usuario_id as numCaixa, ");
|
|
|
|
sql.append(" r5.impdesconto ");
|
|
|
|
sql.append(" r5.impdesconto as desconto, ");
|
|
|
|
|
|
|
|
sql.append(" 'DESCONTO' as status");
|
|
|
|
sql.append(" FROM fiscal_r4 r4 ");
|
|
|
|
sql.append(" FROM fiscal_r4 r4 ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN boleto b ON b.boleto_id = r4.boleto_id ");
|
|
|
|
sql.append(" INNER JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
sql.append(" INNER JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
sql.append(" LEFT JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 AND fi.fiscalimpressora_id = r5.fiscalimpressora_id ");
|
|
|
|
sql.append(" LEFT JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 AND fi.fiscalimpressora_id = r5.fiscalimpressora_id ");
|
|
|
@ -492,73 +495,230 @@ public class FiscalHibernateDAO implements FiscalDAO {
|
|
|
|
sql.append(" AND b.marca_id = ? ");
|
|
|
|
sql.append(" AND b.marca_id = ? ");
|
|
|
|
sql.append(" AND r5.impdesconto <> 0 ");
|
|
|
|
sql.append(" AND r5.impdesconto <> 0 ");
|
|
|
|
sql.append(" GROUP BY r4.numserie20, r4.coo, r4.datainicialemissao, r4.cpfcnpjcliente, ");
|
|
|
|
sql.append(" GROUP BY r4.numserie20, r4.coo, r4.datainicialemissao, r4.cpfcnpjcliente, ");
|
|
|
|
sql.append(" r4.imptotalliquido, fi.numcnpj, fi.numserie, r5.impdesconto, ");
|
|
|
|
sql.append(" r4.imptotalliquido, fi.numcnpj, fi.numserie, r5.impdesconto, ");
|
|
|
|
sql.append(" r5.totparcial, r5.imptotalliquido, r5.tipopassagem, ");
|
|
|
|
sql.append(" r5.totparcial, r5.imptotalliquido, r5.tipopassagem, ");
|
|
|
|
sql.append(" r5.numitem, r5.codproduto, fi.modelo, r4.usuario_id ");
|
|
|
|
sql.append(" r5.numitem, r5.codproduto, fi.modelo, r4.usuario_id ");
|
|
|
|
sql.append(" ORDER BY r4.datainicialemissao, r4.numserie20, r4.coo, r5.numitem ");
|
|
|
|
sql.append(" ORDER BY r4.datainicialemissao, r4.numserie20, r4.coo, r5.numitem ");
|
|
|
|
return sql.toString();
|
|
|
|
return sql.toString();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
private String sqlFiscaisECFPendenciasCancelado() {
|
|
|
|
public List<ImportacionFiscalVO> buscaDatosFiscaisECF(Date inicio, Date fim, Integer empresaId, boolean isCancelados, boolean isPendencias, Connection connection) throws SQLException {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
String sql = sqlFiscaisECF();
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
|
if (isCancelados) {
|
|
|
|
sql.append("SELECT r4.numserie20 as numImpressora, ");
|
|
|
|
sql = sqlFiscaisECFCancelados();
|
|
|
|
sql.append(" r4.coo as coo, ");
|
|
|
|
|
|
|
|
sql.append(" r4.imptotalliquido as valorTotal, ");
|
|
|
|
|
|
|
|
sql.append(" r4.datainicialemissao as dataEmissao, ");
|
|
|
|
|
|
|
|
sql.append(" r4.cpfcnpjcliente as cnpjCliente, ");
|
|
|
|
|
|
|
|
sql.append(" b.boleto_id as boletoId, ");
|
|
|
|
|
|
|
|
sql.append(" b.marca_id as empresaId, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numcnpj as cnpjImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numserie as numpdv, ");
|
|
|
|
|
|
|
|
sql.append(" r5.totparcial as repTributado, ");
|
|
|
|
|
|
|
|
sql.append(" r5.imptotalliquido as valorItem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.tipopassagem as tipoPassagem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.numitem as numItem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.codproduto as codProduto, ");
|
|
|
|
|
|
|
|
sql.append(" fi.modelo as modeloImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" r4.usuario_id as numCaixa, ");
|
|
|
|
|
|
|
|
sql.append(" b.preciopagado as importetarifa, ");
|
|
|
|
|
|
|
|
sql.append(" b.importetaxaembarque as importetaxaembarque, ");
|
|
|
|
|
|
|
|
sql.append(" b.importepedagio as importepedagio, ");
|
|
|
|
|
|
|
|
sql.append(" b.importeseguro as importeseguro, ");
|
|
|
|
|
|
|
|
sql.append(" translate(fi.numcnpj, ' / - . ', ' ') as cnpjEcf, ");
|
|
|
|
|
|
|
|
sql.append(" r4.indcancelamento, ");
|
|
|
|
|
|
|
|
sql.append(" 'CANCELADO' as status ");
|
|
|
|
|
|
|
|
sql.append("FROM fiscal_r4 r4 ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 AND fi.fiscalimpressora_id = r5.fiscalimpressora_id ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN boleto b ON b.boleto_id = r4.boleto_id ");
|
|
|
|
|
|
|
|
sql.append("WHERE r4.datamov BETWEEN ? AND ? ");
|
|
|
|
|
|
|
|
sql.append(" AND b.marca_id = ? ");
|
|
|
|
|
|
|
|
sql.append(" AND r4.indcancelamento = 'S' ");
|
|
|
|
|
|
|
|
sql.append(" AND (SELECT r3.numserie20 FROM fiscal_r3 r3 where r3.numserie20 = r4.numserie20");
|
|
|
|
|
|
|
|
sql.append(" AND r3.datamov = r4.datamov AND r3.totparcial IN ('Can-T')) IS NOT NULL ");
|
|
|
|
|
|
|
|
sql.append("GROUP BY r4.numserie20, r4.coo, r4.datainicialemissao, ");
|
|
|
|
|
|
|
|
sql.append(" r4.cpfcnpjcliente, r4.imptotalliquido, ");
|
|
|
|
|
|
|
|
sql.append(" b.boleto_id, b.marca_id, fi.numcnpj, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numserie, r5.impdesconto, r5.totparcial, ");
|
|
|
|
|
|
|
|
sql.append(" r5.imptotalliquido, r5.tipopassagem, r5.numitem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.codproduto, fi.modelo, r4.usuario_id, ");
|
|
|
|
|
|
|
|
sql.append(" b.preciopagado, b.importetaxaembarque, b.importepedagio, ");
|
|
|
|
|
|
|
|
sql.append(" b.importeseguro, fi.numcnpj, r4.indcancelamento, r4.indcancelamento ");
|
|
|
|
|
|
|
|
sql.append("ORDER BY r4.datainicialemissao, r4.numserie20, r4.coo, r5.numitem ");
|
|
|
|
|
|
|
|
return sql.toString();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private String sqlFiscaisECFPendenciasGratuidade() {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
|
|
|
|
|
sql.append("SELECT r4.numserie20 as numImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" r4.coo as coo, ");
|
|
|
|
|
|
|
|
sql.append(" r4.imptotalliquido as valorTotal, ");
|
|
|
|
|
|
|
|
sql.append(" r4.datainicialemissao as dataEmissao, ");
|
|
|
|
|
|
|
|
sql.append(" r4.cpfcnpjcliente as cnpjCliente, ");
|
|
|
|
|
|
|
|
sql.append(" b.boleto_id as boletoId, ");
|
|
|
|
|
|
|
|
sql.append(" b.marca_id as empresaId, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numcnpj as cnpjImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numserie as numpdv, ");
|
|
|
|
|
|
|
|
sql.append(" r5.totparcial as repTributado, ");
|
|
|
|
|
|
|
|
sql.append(" r5.imptotalliquido as valorItem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.tipopassagem as tipoPassagem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.numitem as numItem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.codproduto as codProduto, ");
|
|
|
|
|
|
|
|
sql.append(" fi.modelo as modeloImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" r4.usuario_id as numCaixa, ");
|
|
|
|
|
|
|
|
sql.append(" b.preciopagado as importetarifa, ");
|
|
|
|
|
|
|
|
sql.append(" b.importetaxaembarque as importetaxaembarque, ");
|
|
|
|
|
|
|
|
sql.append(" b.importepedagio as importepedagio, ");
|
|
|
|
|
|
|
|
sql.append(" b.importeseguro as importeseguro, ");
|
|
|
|
|
|
|
|
sql.append(" translate(fi.numcnpj, ' / - . ', ' ') as cnpjEcf, ");
|
|
|
|
|
|
|
|
sql.append(" r4.indcancelamento, ");
|
|
|
|
|
|
|
|
sql.append(" 'GRATUIDADE' as status ");
|
|
|
|
|
|
|
|
sql.append("FROM fiscal_r4 r4 ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 AND fi.fiscalimpressora_id = r5.fiscalimpressora_id ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN boleto b ON b.boleto_id = r4.boleto_id ");
|
|
|
|
|
|
|
|
sql.append("WHERE r4.datamov BETWEEN ? AND ? ");
|
|
|
|
|
|
|
|
sql.append(" AND b.marca_id = ? ");
|
|
|
|
|
|
|
|
sql.append(" AND r5.imptotalliquido = 1 ");
|
|
|
|
|
|
|
|
sql.append(" AND b.preciopagado = 0 ");
|
|
|
|
|
|
|
|
sql.append("GROUP BY r4.numserie20, r4.coo, r4.datainicialemissao, ");
|
|
|
|
|
|
|
|
sql.append(" r4.cpfcnpjcliente, r4.imptotalliquido, ");
|
|
|
|
|
|
|
|
sql.append(" b.boleto_id, b.marca_id, fi.numcnpj, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numserie, r5.impdesconto, r5.totparcial, ");
|
|
|
|
|
|
|
|
sql.append(" r5.imptotalliquido, r5.tipopassagem, r5.numitem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.codproduto, fi.modelo, r4.usuario_id, ");
|
|
|
|
|
|
|
|
sql.append(" b.preciopagado, b.importetaxaembarque, b.importepedagio, ");
|
|
|
|
|
|
|
|
sql.append(" b.importeseguro, fi.numcnpj, r4.indcancelamento, r4.indcancelamento ");
|
|
|
|
|
|
|
|
sql.append("ORDER BY r4.datainicialemissao, r4.numserie20, r4.coo, r5.numitem ");
|
|
|
|
|
|
|
|
return sql.toString();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private String sqlFiscaisECFPendenciasInconsistente() {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
StringBuilder sql = new StringBuilder();
|
|
|
|
|
|
|
|
sql.append("SELECT r4.numserie20 as numImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" r4.coo as coo, ");
|
|
|
|
|
|
|
|
sql.append(" r4.imptotalliquido as valorTotal, ");
|
|
|
|
|
|
|
|
sql.append(" r4.datainicialemissao as dataEmissao, ");
|
|
|
|
|
|
|
|
sql.append(" r4.cpfcnpjcliente as cnpjCliente, ");
|
|
|
|
|
|
|
|
sql.append(" b.boleto_id as boletoId, ");
|
|
|
|
|
|
|
|
sql.append(" b.marca_id as empresaId, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numcnpj as cnpjImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numserie as numpdv, ");
|
|
|
|
|
|
|
|
sql.append(" r5.totparcial as repTributado, ");
|
|
|
|
|
|
|
|
sql.append(" r5.imptotalliquido as valorItem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.tipopassagem as tipoPassagem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.numitem as numItem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.codproduto as codProduto, ");
|
|
|
|
|
|
|
|
sql.append(" fi.modelo as modeloImpressora, ");
|
|
|
|
|
|
|
|
sql.append(" r4.usuario_id as numCaixa, ");
|
|
|
|
|
|
|
|
sql.append(" b.preciopagado as importetarifa, ");
|
|
|
|
|
|
|
|
sql.append(" b.importetaxaembarque as importetaxaembarque, ");
|
|
|
|
|
|
|
|
sql.append(" b.importepedagio as importepedagio, ");
|
|
|
|
|
|
|
|
sql.append(" b.importeseguro as importeseguro, ");
|
|
|
|
|
|
|
|
sql.append(" translate(fi.numcnpj, ' / - . ', ' ') as cnpjEcf, ");
|
|
|
|
|
|
|
|
sql.append(" r4.indcancelamento, ");
|
|
|
|
|
|
|
|
sql.append(" 'INCONSISTENTE' as status ");
|
|
|
|
|
|
|
|
sql.append("FROM fiscal_r4 r4 ");
|
|
|
|
|
|
|
|
sql.append(" LEFT JOIN fiscal_r5 r5 ON r4.numserie20 = r5.numserie20 AND r4.coo = r5.coo ");
|
|
|
|
|
|
|
|
sql.append(" AND r4.datamov = r5.datamov AND r4.contador = r5.contador ");
|
|
|
|
|
|
|
|
sql.append(" LEFT JOIN fiscal_impressora fi ON fi.numserie20 = r4.numserie20 AND fi.fiscalimpressora_id = r5.fiscalimpressora_id ");
|
|
|
|
|
|
|
|
sql.append(" INNER JOIN boleto b ON b.boleto_id = r4.boleto_id ");
|
|
|
|
|
|
|
|
sql.append("WHERE r4.datamov BETWEEN ? AND ? ");
|
|
|
|
|
|
|
|
sql.append(" AND b.marca_id = ? ");
|
|
|
|
|
|
|
|
sql.append(" AND r4.indcancelamento = 'S' ");
|
|
|
|
|
|
|
|
sql.append(" AND (SELECT MAX(r3.numserie20) FROM fiscal_r3 r3 where r3.numserie20 = r4.numserie20");
|
|
|
|
|
|
|
|
sql.append(" AND r3.datamov = r4.datamov AND r3.totparcial IN ('Can-T', 'DT')) IS NULL ");
|
|
|
|
|
|
|
|
sql.append("GROUP BY r4.numserie20, r4.coo, r4.datainicialemissao, ");
|
|
|
|
|
|
|
|
sql.append(" r4.cpfcnpjcliente, r4.imptotalliquido, ");
|
|
|
|
|
|
|
|
sql.append(" b.boleto_id, b.marca_id, fi.numcnpj, ");
|
|
|
|
|
|
|
|
sql.append(" fi.numserie, r5.impdesconto, r5.totparcial, ");
|
|
|
|
|
|
|
|
sql.append(" r5.imptotalliquido, r5.tipopassagem, r5.numitem, ");
|
|
|
|
|
|
|
|
sql.append(" r5.codproduto, fi.modelo, r4.usuario_id, ");
|
|
|
|
|
|
|
|
sql.append(" b.preciopagado, b.importetaxaembarque, b.importepedagio, ");
|
|
|
|
|
|
|
|
sql.append(" b.importeseguro, fi.numcnpj, r4.indcancelamento, r4.indcancelamento ");
|
|
|
|
|
|
|
|
sql.append("ORDER BY r4.datainicialemissao, r4.numserie20, r4.coo, r5.numitem ");
|
|
|
|
|
|
|
|
return sql.toString();
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
|
|
|
public List<ImportacionFiscalVO> buscaDatosFiscaisECF(Date inicio, Date fim, Integer empresaId, boolean isNormal, boolean isCancelados, boolean isPendencias, Connection connection) throws SQLException {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (isNormal) {
|
|
|
|
|
|
|
|
return montarItensECF(inicio, fim, empresaId, connection, sqlFiscaisECF());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} else if (isCancelados) {
|
|
|
|
|
|
|
|
return montarItensECF(inicio, fim, empresaId, connection, sqlFiscaisECFCancelados());
|
|
|
|
|
|
|
|
|
|
|
|
} else if (isPendencias) {
|
|
|
|
} else if (isPendencias) {
|
|
|
|
sql = sqlFiscaisECFPendencias(inicio, fim, empresaId, connection);
|
|
|
|
|
|
|
|
|
|
|
|
List<ImportacionFiscalVO> list = new ArrayList<ImportacionFiscalVO>();
|
|
|
|
|
|
|
|
list.addAll(montarItensECF(inicio, fim, empresaId, connection, sqlFiscaisECFPendenciasCancelado()));
|
|
|
|
|
|
|
|
list.addAll(montarItensECF(inicio, fim, empresaId, connection, sqlFiscaisECFPendenciasDesconto()));
|
|
|
|
|
|
|
|
list.addAll(montarItensECF(inicio, fim, empresaId, connection, sqlFiscaisECFPendenciasInconsistente()));
|
|
|
|
|
|
|
|
list.addAll(montarItensECF(inicio, fim, empresaId, connection, sqlFiscaisECFPendenciasGratuidade()));
|
|
|
|
|
|
|
|
return list;
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return null;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private List<ImportacionFiscalVO> montarItensECF(Date inicio, Date fim, Integer empresaId, Connection connection, String sql) throws SQLException {
|
|
|
|
|
|
|
|
|
|
|
|
PreparedStatement stmt = connection.prepareStatement(sql);
|
|
|
|
PreparedStatement stmt = connection.prepareStatement(sql);
|
|
|
|
stmt.setFetchSize(100);
|
|
|
|
stmt.setFetchSize(100);
|
|
|
|
if (!isPendencias) {
|
|
|
|
stmt.setString(1, DateUtil.getStringDate(inicio, DATE_FORMAT_FISCAL));
|
|
|
|
stmt.setString(1, DateUtil.getStringDate(inicio, DATE_FORMAT_FISCAL));
|
|
|
|
stmt.setString(2, DateUtil.getStringDate(fim, DATE_FORMAT_FISCAL));
|
|
|
|
stmt.setString(2, DateUtil.getStringDate(fim, DATE_FORMAT_FISCAL));
|
|
|
|
stmt.setInt(3, empresaId);
|
|
|
|
stmt.setInt(3, empresaId);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<ImportacionFiscalVO> list = new ArrayList<ImportacionFiscalVO>();
|
|
|
|
List<ImportacionFiscalVO> list = new ArrayList<ImportacionFiscalVO>();
|
|
|
|
ImportacionFiscalVO fiscal = null;
|
|
|
|
ImportacionFiscalVO fiscal = null;
|
|
|
|
String codProduto = null;
|
|
|
|
String codProduto = null;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<String> columns = new ArrayList<String>();
|
|
|
|
|
|
|
|
ResultSetMetaData rsMetaData = stmt.getMetaData();
|
|
|
|
|
|
|
|
for (int i = 1; i <= rsMetaData.getColumnCount(); i++) {
|
|
|
|
|
|
|
|
columns.add(rsMetaData.getColumnName(i).toLowerCase());
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
ResultSet rset = stmt.executeQuery();
|
|
|
|
ResultSet rset = stmt.executeQuery();
|
|
|
|
while (rset.next()) {
|
|
|
|
while (rset.next()) {
|
|
|
|
|
|
|
|
|
|
|
|
ItemFiscalVO item = new ItemFiscalVO();
|
|
|
|
ItemFiscalVO item = new ItemFiscalVO();
|
|
|
|
item.setNumImpressora(rset.getString("numImpressora"));
|
|
|
|
item.setNumImpressora(columns.contains("numimpressora") ? rset.getString("numImpressora") : null);
|
|
|
|
item.setCoo(rset.getString("coo"));
|
|
|
|
item.setCoo(columns.contains("coo") ? rset.getString("coo") : null);
|
|
|
|
item.setBoletoId(rset.getLong("boletoId"));
|
|
|
|
item.setBoletoId(columns.contains("boletoid") ? rset.getLong("boletoId") : null);
|
|
|
|
item.setEmpresaId(rset.getInt("empresaId"));
|
|
|
|
item.setEmpresaId(columns.contains("empresaid") ? rset.getInt("empresaId") : null);
|
|
|
|
item.setDataEmissao(rset.getString("dataEmissao"));
|
|
|
|
item.setDataEmissao(columns.contains("dataemissao") ? rset.getString("dataEmissao") : null);
|
|
|
|
item.setCnpjCliente(rset.getString("cnpjCliente"));
|
|
|
|
item.setCnpjCliente(columns.contains("cnpjcliente") ? rset.getString("cnpjCliente") : null);
|
|
|
|
item.setCnpjImpressora(rset.getString("cnpjImpressora"));
|
|
|
|
item.setCnpjImpressora(columns.contains("cnpjimpressora") ? rset.getString("cnpjImpressora") : null);
|
|
|
|
item.setOrigenId(rset.getInt("origenId"));
|
|
|
|
item.setOrigenId(columns.contains("origenid") ? rset.getInt("origenId") : null);
|
|
|
|
item.setOrigenUf(rset.getString("origenUf"));
|
|
|
|
item.setOrigenUf(columns.contains("origenuf") ? rset.getString("origenUf") : null);
|
|
|
|
item.setDestinoId(rset.getInt("destinoId"));
|
|
|
|
item.setDestinoId(columns.contains("destinoid") ? rset.getInt("destinoId") : null);
|
|
|
|
item.setDestinoUf(rset.getString("destinoUf"));
|
|
|
|
item.setDestinoUf(columns.contains("destinouf") ? rset.getString("destinoUf") : null);
|
|
|
|
item.setNumpdv(rset.getString("numpdv"));
|
|
|
|
item.setNumpdv(columns.contains("numpdv") ? rset.getString("numpdv") : null);
|
|
|
|
item.setNumItem(rset.getString("numItem"));
|
|
|
|
item.setNumItem(columns.contains("numitem") ? rset.getString("numItem") : null);
|
|
|
|
item.setCodProduto(rset.getString("codProduto"));
|
|
|
|
item.setCodProduto(columns.contains("codproduto") ? rset.getString("codProduto") : null);
|
|
|
|
item.setRepTributado(rset.getString("repTributado"));
|
|
|
|
item.setRepTributado(columns.contains("reptributado") ? rset.getString("repTributado") : null);
|
|
|
|
item.setTipoPassagem(rset.getString("tipoPassagem"));
|
|
|
|
item.setTipoPassagem(columns.contains("tipopassagem") ? rset.getString("tipoPassagem") : null);
|
|
|
|
item.setModeloImpressora(rset.getString("modeloImpressora"));
|
|
|
|
item.setModeloImpressora(columns.contains("modeloimpressora") ? rset.getString("modeloImpressora") : null);
|
|
|
|
item.setNumCaixa(rset.getString("numCaixa"));
|
|
|
|
item.setNumCaixa(columns.contains("numcaixa") ? rset.getString("numCaixa") : null);
|
|
|
|
item.setStatus(rset.getString("status"));
|
|
|
|
item.setStatus(columns.contains("status") ? rset.getString("status") : null);
|
|
|
|
item.setClaseServicio(rset.getString("claseServicio"));
|
|
|
|
item.setClaseServicio(columns.contains("claseservicio") ? rset.getString("claseServicio") : null);
|
|
|
|
|
|
|
|
item.setMotivocancelacion(columns.contains("motivocancelacion") ? rset.getInt("motivocancelacion") : null);
|
|
|
|
if (isCancelados) {
|
|
|
|
item.setValorMulta(columns.contains("valormulta") ? rset.getBigDecimal("valorMulta") : null);
|
|
|
|
item.setMotivocancelacion(rset.getInt("motivocancelacion"));
|
|
|
|
item.setImpostoEstado(columns.contains("impostoestado") ? rset.getBigDecimal("impostoEstado") : null);
|
|
|
|
item.setValorMulta(rset.getBigDecimal("valorMulta"));
|
|
|
|
item.setDesconto(columns.contains("desconto") ? rset.getBigDecimal("desconto") : null);
|
|
|
|
} else {
|
|
|
|
|
|
|
|
item.setImpostoEstado(rset.getBigDecimal("impostoEstado"));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// TODO: Estes atributos foram criados, por motivo de divergencia no valorTotal com o valor unitario na tabela FISCAL_R5
|
|
|
|
// TODO: Estes atributos foram criados, por motivo de divergencia no valorTotal com o valor unitario na tabela FISCAL_R5
|
|
|
|
item.setValorTarifa(rset.getBigDecimal("importetarifa"));
|
|
|
|
item.setValorTarifa(columns.contains("importetarifa") ? rset.getBigDecimal("importetarifa") : null);
|
|
|
|
item.setValorPedagio(rset.getBigDecimal("importepedagio"));
|
|
|
|
item.setValorPedagio(columns.contains("importepedagio") ? rset.getBigDecimal("importepedagio") : null);
|
|
|
|
item.setValorEmbarque(rset.getBigDecimal("importetaxaembarque"));
|
|
|
|
item.setValorEmbarque(columns.contains("importetaxaembarque") ? rset.getBigDecimal("importetaxaembarque") : null);
|
|
|
|
item.setValorSeguro(rset.getBigDecimal("importeseguro"));
|
|
|
|
item.setValorSeguro(columns.contains("importeseguro") ? rset.getBigDecimal("importeseguro") : null);
|
|
|
|
|
|
|
|
|
|
|
|
ImportacionFiscalVO novoFiscal = item;
|
|
|
|
ImportacionFiscalVO novoFiscal = item;
|
|
|
|
|
|
|
|
|
|
|
|