package com.rjconsultores.ventaboletos.service.impl;

import java.io.BufferedReader;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.IOException;
import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.TimeUnit;

import javax.sql.DataSource;

import org.apache.log4j.Logger;
import org.apache.poi.hssf.usermodel.HSSFRow;
import org.apache.poi.hssf.usermodel.HSSFSheet;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.rjconsultores.ventaboletos.dao.FiscalDAO;
import com.rjconsultores.ventaboletos.entidad.Aidf;
import com.rjconsultores.ventaboletos.entidad.Empresa;
import com.rjconsultores.ventaboletos.entidad.EsquemaCorrida;
import com.rjconsultores.ventaboletos.entidad.Estado;
import com.rjconsultores.ventaboletos.entidad.TipoEventoExtra;
import com.rjconsultores.ventaboletos.service.FiscalService;
import com.rjconsultores.ventaboletos.service.TipoEventoExtraService;
import com.rjconsultores.ventaboletos.utilerias.BigDecimalUtil;
import com.rjconsultores.ventaboletos.utilerias.LocaleUtil;
import com.rjconsultores.ventaboletos.utilerias.archivointegracion.ArchivoIntegracionECF;
import com.rjconsultores.ventaboletos.utilerias.archivointegracion.ArchivoIntegracionECFManual;
import com.rjconsultores.ventaboletos.utilerias.archivointegracion.ArchivoIntegracionECFReducaoZ;
import com.rjconsultores.ventaboletos.utilerias.archivointegracion.ArchivoIntegracionNaoFiscal;
import com.rjconsultores.ventaboletos.utilerias.archivointegracion.ArchivoIntegracionReducaoZ;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.ExportacaoFiscal;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoECFTipoCCF;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoECFTipoCFC;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoECFTipoICF;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoECFTipoPRC;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoRMDTipoBPS;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoRMDTipoDBP;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoRMDTipoPAR;
import com.rjconsultores.ventaboletos.utilerias.exportacaofiscal.vo.ExportacaoRMDTipoRMD;
import com.rjconsultores.ventaboletos.utilerias.impressaormd.vo.ImpressaoRMD;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.ImportacionFiscalReducaoZVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.ImportacionFiscalVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.ImportacionManualFiscalVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.ImportacionNaoFiscalVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.LeitorFiscalReducaoZVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.LeitorFiscalVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.LeitorManualFiscalVO;
import com.rjconsultores.ventaboletos.vo.impressaofiscal.LeitorNaoFiscalVO;

@Service("fiscalService")
public class FiscalServiceImpl implements FiscalService {
	private static Logger log = Logger.getLogger(FiscalServiceImpl.class);

	public static final String DATE_FORMAT_FISCAL = "yyyyMMdd";
	public static final BigDecimal CEM = BigDecimal.valueOf(100);
	public static final String QUEBRA_LINHA = "\r\n";

	private List<TipoEventoExtra> lsTipoEventoExtra;

	@Autowired
	private TipoEventoExtraService tipoEventoExtraService;

	@Autowired
	private FiscalDAO fiscalDAO;

	@Autowired
	private DataSource dataSourceRead;

	@Autowired
	private ExportacaoFiscal exportacaoFiscal;

	@Override
	@Transactional
	public int gerarRegistroP2_F2(List<EsquemaCorrida> lsEsquemaCorrida, Date dataDe, Date dataAte) throws SQLException {
		return fiscalDAO.gerarRegistroP2_F2(lsEsquemaCorrida, dataDe, dataAte);
	}

	@Override
	public void gravarRMDBoleto(Connection connection, List<ImpressaoRMD> rmds, Aidf aidf, String folio) {
		fiscalDAO.gravarRMDBoleto(connection, rmds, aidf, folio);
	}

	@Override
	public void cancelarRMDBoleto(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, Aidf aidf, String folio) {
		fiscalDAO.cancelarRMDBoleto(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), aidf, folio);
	}

	@Override
	public List<ImpressaoRMD> getRegistroImpressaoRMDTipoDVB(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio) {
		return fiscalDAO.getRegistroImpressaoRMDTipoDVB(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio);
	}

	@Override
	public List<ImpressaoRMD> getRegistroImpressaoRMDTipoECF(Connection connection, Date inicio, Date fim, Empresa empresa, Estado estado, String rmd, String folio) {
		return fiscalDAO.getRegistroImpressaoRMDTipoECF(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado(), rmd, folio);
	}

	@Override
	public File importacionFiscalECFManual(Date inicio, Date fim, Empresa empresa, Estado estado) {

		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionManualFiscalVO> list = fiscalDAO.buscaDatosFiscaisECFManual(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), connection);
			return new ArchivoIntegracionECFManual().importacionFiscalECFManual(inicio, fim, empresa, list);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	@Override
	public File importacionFiscalReducaoZPendencia(Date inicio, Date fim, Empresa empresa, Estado estado) {

		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionFiscalReducaoZVO> list = fiscalDAO.buscaDatosFiscaisReducaoZ(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), true, connection);
			return new ArchivoIntegracionReducaoZ().importacionReducaoZ(inicio, fim, empresa, true, list);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	@Override
	public File importacionFiscalReducaoZ(Date inicio, Date fim, Empresa empresa, Estado estado) {

		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionFiscalReducaoZVO> list = fiscalDAO.buscaDatosFiscaisReducaoZ(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), false, connection);
			return new ArchivoIntegracionReducaoZ().importacionReducaoZ(inicio, fim, empresa, false, list);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	@Override
	public File importacionFiscalECFPendencias(Date inicio, Date fim, Empresa empresa, Estado estado) {
		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionFiscalVO> list = fiscalDAO.buscaDatosFiscaisECF(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), false, false, true, connection);
			return new ArchivoIntegracionECF().importacionFiscalECFGenerico(inicio, fim, empresa, false, false, true, list);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	@Override
	public File importacionFiscalECFCancelados(Date inicio, Date fim, Empresa empresa, Estado estado) {
		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionFiscalVO> list = fiscalDAO.buscaDatosFiscaisECF(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), false, true, false, connection);
			return new ArchivoIntegracionECF().importacionFiscalECFGenerico(inicio, fim, empresa, false, true, false, list);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	@Override
	public HashMap<String, Object> importacionFiscalECFValidaReducaoZ(Date inicio, Date fim, Empresa empresa, Estado estado) {

		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionFiscalVO> listEcf = fiscalDAO.buscaDatosFiscaisECF(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), true, false, false, connection);

			List<ImportacionFiscalReducaoZVO> listRedZ = fiscalDAO.buscaDatosFiscaisReducaoZ(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), false, connection);

			ArchivoIntegracionECFReducaoZ ecfRedZ = new ArchivoIntegracionECFReducaoZ();
			ecfRedZ.importacionFiscalECFValidaReducaoZ(listEcf, listRedZ);

			List<File> files = new ArrayList<File>();
			files.add(new ArchivoIntegracionECF().importacionFiscalECFGenerico(inicio, fim, empresa, true, false, false, ecfRedZ.getListEcfValidos()));
			files.add(new ArchivoIntegracionReducaoZ().importacionReducaoZ(inicio, fim, empresa, false, ecfRedZ.getListRedZValidos()));

			files.add(new ArchivoIntegracionECF().importacionFiscalECFGenerico(inicio, fim, empresa, false, false, true, ecfRedZ.getListEcfInvalidos()));
			files.add(new ArchivoIntegracionReducaoZ().importacionReducaoZ(inicio, fim, empresa, true, ecfRedZ.getListRedZInvalidos()));

			HashMap<String, Object> result = new HashMap<String, Object>();
			result.put("arquivos", files);
			result.put("ecfInvalidos", ecfRedZ.getListEcfInvalidos());
			result.put("redZInvalido", ecfRedZ.getListRedZInvalidos());

			return result;

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}

		return null;
	}

	@Override
	public File importacionFiscalECF(Date inicio, Date fim, Empresa empresa, Estado estado) {
		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionFiscalVO> list = fiscalDAO.buscaDatosFiscaisECF(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), true, false, false, connection);
			return new ArchivoIntegracionECF().importacionFiscalECFGenerico(inicio, fim, empresa, true, false, false, list);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	@Override
	public File importacionNaoFiscal(Date inicio, Date fim, Empresa empresa, Estado estado) {
		Connection connection = null;
		try {
			connection = getConnection();

			List<ImportacionNaoFiscalVO> importacionNaoFiscalVOs = fiscalDAO.buscaDatosNaoFiscais(inicio, fim, empresa.getEmpresaId(), estado.getEstadoId(), connection);

			return new ArchivoIntegracionNaoFiscal().gerarArquivo(empresa.getCnpj(), importacionNaoFiscalVOs);

		} catch (Exception e) {
			log.error(e.getMessage(), e);
		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);
				throw new RuntimeException(e);
			}
		}
		return null;
	}

	private Connection getConnection() {
		return DataSourceUtils.getConnection(dataSourceRead);
	}

	@Override
	public File importacionFiscalECFXls(Empresa empresa, File arquivoTxt) {
		return gerarArquivoEcfXlsGenerico(empresa, arquivoTxt);
	}

	@Override
	public File importacionFiscalReducaoZXls(Empresa empresa, File arquivoTxt) {
		try {
			List<LeitorFiscalReducaoZVO> registros = carregarRegistrosReducaoZ(empresa, arquivoTxt);
			return gerarArquivoReducaoZXls(registros, arquivoTxt.getName());
		} catch (Exception e) {
			log.error(e.getMessage(), e);
		}
		return null;
	}

	private List<LeitorFiscalReducaoZVO> carregarRegistrosReducaoZ(Empresa empresa, File arquivoTxt) throws Exception {
		List<LeitorFiscalReducaoZVO> registros = new ArrayList<LeitorFiscalReducaoZVO>();
		BufferedReader br = new BufferedReader(new FileReader(arquivoTxt));
		String linha = br.readLine();
		while (linha != null) {
			LeitorFiscalReducaoZVO leitorFiscalReducaoZ = null;
			int indice = -1;
			if (linha.startsWith("1")) {
				leitorFiscalReducaoZ = new LeitorFiscalReducaoZVO();
				leitorFiscalReducaoZ.setEmpresaId(empresa.getEmpresaId());
				leitorFiscalReducaoZ.setNombempresa(empresa.getNombempresa());
				leitorFiscalReducaoZ.setDatamov(linha.substring(1, 9).trim());
				leitorFiscalReducaoZ.setCnpj(linha.substring(9, 23).trim());
				leitorFiscalReducaoZ.setAliquota(BigDecimalUtil.getStringToBigDecimal(linha.substring(196, 210).trim(), 2, LocaleUtil.getLocale()));

				if (registros.contains(leitorFiscalReducaoZ)) {
					indice = registros.indexOf(leitorFiscalReducaoZ);
					leitorFiscalReducaoZ = registros.get(indice);
				}

				leitorFiscalReducaoZ.setImposto(leitorFiscalReducaoZ.getImposto().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(272, 285).trim(), 2, LocaleUtil.getLocale())));
				leitorFiscalReducaoZ.setValorNaoTributado(leitorFiscalReducaoZ.getValorNaoTributado().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(182, 196).trim(), 2, LocaleUtil.getLocale())));
				leitorFiscalReducaoZ.setVendabrutadiaria(leitorFiscalReducaoZ.getVendabrutadiaria().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(126, 140).trim(), 2, LocaleUtil.getLocale())));

				linha = br.readLine();
			} else {
				linha = br.readLine();
			}

			if (leitorFiscalReducaoZ != null && indice > -1) {
				registros.set(indice, leitorFiscalReducaoZ);
			} else if (leitorFiscalReducaoZ != null) {
				registros.add(leitorFiscalReducaoZ);
			}
		}

		br.close();

		Collections.sort(registros);

		return registros;
	}

	private File gerarArquivoReducaoZXls(List<LeitorFiscalReducaoZVO> registros, String nomeArquivo) throws IOException {
		HSSFWorkbook workbook = new HSSFWorkbook();
		HSSFSheet firstSheet = workbook.createSheet();

		int linha = 0;

		// Cabecalho
		HSSFRow row = firstSheet.createRow(linha++);
		row.createCell(0).setCellValue("DATA_MOVIMENTO");
		row.createCell(1).setCellValue("EMPRESA");
		row.createCell(2).setCellValue("CNPJ");
		row.createCell(3).setCellValue("VENDA_BRUTA_DIARIA");
		row.createCell(4).setCellValue("VALOR_NAO_TRIBUTADO");
		row.createCell(5).setCellValue("ALIQUOTA");
		row.createCell(6).setCellValue("VALOR_ICMS");

		for (LeitorFiscalReducaoZVO leitorFiscal : registros) {
			row = firstSheet.createRow(linha++);
			row.createCell(0).setCellValue(leitorFiscal.getDatamov());
			row.createCell(1).setCellValue(leitorFiscal.getNombempresa());
			row.createCell(2).setCellValue(leitorFiscal.getCnpj());
			row.createCell(3).setCellValue(leitorFiscal.getVendabrutadiaria().doubleValue());
			row.createCell(4).setCellValue(leitorFiscal.getValorNaoTributado().doubleValue());
			row.createCell(5).setCellValue(leitorFiscal.getAliquota().doubleValue());
			row.createCell(6).setCellValue(leitorFiscal.getImposto().doubleValue());
		}

		ByteArrayOutputStream bos = new ByteArrayOutputStream();
		workbook.write(bos);

		nomeArquivo = "consolidado_" + nomeArquivo.split("\\.")[0];
		File arquivo = File.createTempFile(nomeArquivo, ".xls");

		FileOutputStream fos = new FileOutputStream(arquivo);
		fos.write(bos.toByteArray());
		fos.close();

		return arquivo;
	}

	@Override
	public File importacionFiscalECFManualXls(Empresa empresa, File arquivoTxt) {
		try {
			List<LeitorManualFiscalVO> registros = carregarRegistrosManualFiscal(empresa, arquivoTxt);
			return gerarArquivoEcfManualXls(registros, arquivoTxt.getName());
		} catch (Exception e) {
			log.error(e.getMessage(), e);
		}
		return null;
	}

	private File gerarArquivoEcfManualXls(List<LeitorManualFiscalVO> registros, String nomeArquivo) throws Exception {
		HSSFWorkbook workbook = new HSSFWorkbook();
		HSSFSheet firstSheet = workbook.createSheet();

		int linha = 0;

		// Cabecalho
		HSSFRow row = firstSheet.createRow(linha++);
		row.createCell(0).setCellValue("DATA_EMISSAO");
		row.createCell(1).setCellValue("EMPRESA");
		row.createCell(2).setCellValue("UF_ORIGEM");
		row.createCell(3).setCellValue("UF_DESTINO");
		row.createCell(4).setCellValue("CLASSE");
		row.createCell(5).setCellValue("STATUS");
		row.createCell(6).setCellValue("TARIFA");
		row.createCell(7).setCellValue("TX_EMBARQUE");
		row.createCell(8).setCellValue("PEDAGIO");
		row.createCell(9).setCellValue("SEGURO");
		row.createCell(10).setCellValue("TOTAL");
		row.createCell(11).setCellValue("ALIQUOTA");
		row.createCell(12).setCellValue("VALOR_ICMS");
		row.createCell(13).setCellValue("QTDE");

		for (LeitorManualFiscalVO leitorFiscal : registros) {
			row = firstSheet.createRow(linha++);
			row.createCell(0).setCellValue(leitorFiscal.getDataEmissao());
			row.createCell(1).setCellValue(leitorFiscal.getNombempresa());
			row.createCell(2).setCellValue(leitorFiscal.getOrigenUf());
			row.createCell(3).setCellValue(leitorFiscal.getDestinoUf());
			row.createCell(4).setCellValue(leitorFiscal.getClaseServicio());
			row.createCell(5).setCellValue(leitorFiscal.getStatus());
			row.createCell(6).setCellValue(leitorFiscal.getValorItem().doubleValue());
			row.createCell(7).setCellValue(leitorFiscal.getImportetaxaembarque().doubleValue());
			row.createCell(8).setCellValue(leitorFiscal.getImportepedagio().doubleValue());
			row.createCell(9).setCellValue(leitorFiscal.getImporteseguro().doubleValue());
			row.createCell(10).setCellValue(leitorFiscal.getValorTotal().doubleValue());
			row.createCell(11).setCellValue(leitorFiscal.getIcms().doubleValue());
			row.createCell(12).setCellValue(leitorFiscal.getValorIcms().doubleValue());
			row.createCell(13).setCellValue(leitorFiscal.getQtdeItens());
		}

		ByteArrayOutputStream bos = new ByteArrayOutputStream();
		workbook.write(bos);

		nomeArquivo = "consolidado_" + nomeArquivo.split("\\.")[0];
		File arquivo = File.createTempFile(nomeArquivo, ".xls");

		FileOutputStream fos = new FileOutputStream(arquivo);
		fos.write(bos.toByteArray());
		fos.close();

		return arquivo;
	}

	@Override
	public File importacionNaoFiscalXls(Empresa empresa, File arquivoTxt) {
		return gerarArquivoNaoFiscalXls(empresa, arquivoTxt);
	}

	@Override
	public File importacionFiscalECFCanceladosXls(Empresa empresa, File arquivoTxt) {
		return gerarArquivoEcfXlsGenerico(empresa, arquivoTxt);
	}

	private File gerarArquivoNaoFiscalXls(Empresa empresa, File arquivoTxt) {
		try {
			List<LeitorNaoFiscalVO> registros = carregarRegistrosNaoFiscais(empresa, arquivoTxt);
			return gerarArquivoNaoFiscaisXls(registros, arquivoTxt.getName());
		} catch (Exception e) {
			log.error(e.getMessage(), e);
		}
		return null;
	}

	private File gerarArquivoEcfXlsGenerico(Empresa empresa, File arquivoTxt) {
		try {
			List<LeitorFiscalVO> registros = carregarRegistrosEcf(empresa, arquivoTxt);
			return gerarArquivoEcfXls(registros, arquivoTxt.getName());
		} catch (Exception e) {
			log.error(e.getMessage(), e);
		}
		return null;
	}

	private File gerarArquivoEcfXls(List<LeitorFiscalVO> registros, String nomeArquivo) throws IOException {
		HSSFWorkbook workbook = new HSSFWorkbook();
		HSSFSheet firstSheet = workbook.createSheet();

		int linha = 0;

		// Cabecalho
		HSSFRow row = firstSheet.createRow(linha++);
		row.createCell(0).setCellValue("DATA_EMISSAO");
		row.createCell(1).setCellValue("EMPRESA");
		row.createCell(2).setCellValue("UF_ORIGEM");
		row.createCell(3).setCellValue("UF_DESTINO");
		row.createCell(4).setCellValue("CLASSE");
		row.createCell(5).setCellValue("MOTIVO_CANCELAMENTO");
		row.createCell(6).setCellValue("TARIFA");
		row.createCell(7).setCellValue("TX_EMBARQUE");
		row.createCell(8).setCellValue("PEDAGIO");
		row.createCell(9).setCellValue("SEGURO");
		row.createCell(10).setCellValue("MULTA");
		row.createCell(11).setCellValue("TOTAL");
		row.createCell(12).setCellValue("ALIQUOTA_ICMS");
		row.createCell(13).setCellValue("VALOR_ICMS");
		row.createCell(14).setCellValue("QTDE");

		for (LeitorFiscalVO leitorFiscal : registros) {
			row = firstSheet.createRow(linha++);
			row.createCell(0).setCellValue(leitorFiscal.getDataEmissao());
			row.createCell(1).setCellValue(leitorFiscal.getNombempresa());
			row.createCell(2).setCellValue(leitorFiscal.getOrigenUf());
			row.createCell(3).setCellValue(leitorFiscal.getDestinoUf());
			row.createCell(4).setCellValue(leitorFiscal.getClaseServicio());
			row.createCell(5).setCellValue(leitorFiscal.getDescmotivocancelamento());
			row.createCell(6).setCellValue(leitorFiscal.getValorTarifa().doubleValue());
			row.createCell(7).setCellValue(leitorFiscal.getValorEmbarque().doubleValue());
			row.createCell(8).setCellValue(leitorFiscal.getValorPedagio().doubleValue());
			row.createCell(9).setCellValue(leitorFiscal.getValorSeguro().doubleValue());
			row.createCell(10).setCellValue(leitorFiscal.getValorMulta().doubleValue());
			row.createCell(11).setCellValue(leitorFiscal.getTotal().doubleValue());
			row.createCell(12).setCellValue(leitorFiscal.getAliquota().doubleValue());
			row.createCell(13).setCellValue(leitorFiscal.getValorIcms().doubleValue());
			row.createCell(14).setCellValue(leitorFiscal.getQtdeItens());
		}

		ByteArrayOutputStream bos = new ByteArrayOutputStream();
		workbook.write(bos);

		nomeArquivo = "consolidado_" + nomeArquivo.split("\\.")[0];
		File arquivo = File.createTempFile(nomeArquivo, ".xls");

		FileOutputStream fos = new FileOutputStream(arquivo);
		fos.write(bos.toByteArray());
		fos.close();

		return arquivo;

	}

	private List<LeitorFiscalVO> carregarRegistrosEcf(Empresa empresa, File arquivoTxt) throws Exception {
		List<LeitorFiscalVO> registros = new ArrayList<LeitorFiscalVO>();
		BufferedReader br = new BufferedReader(new FileReader(arquivoTxt));
		String linha = br.readLine();
		while (linha != null) {
			LeitorFiscalVO leitorFiscal = null;
			int indice = -1;
			if (linha.startsWith("1")) {
				leitorFiscal = new LeitorFiscalVO();
				leitorFiscal.setEmpresaId(empresa.getEmpresaId());
				leitorFiscal.setNombempresa(empresa.getNombempresa());
				leitorFiscal.setDataEmissao(linha.substring(1, 9).trim());
				leitorFiscal.setOrigenUf(linha.substring(177, 179).trim());
				leitorFiscal.setDestinoUf(linha.substring(184, 186).trim());
				leitorFiscal.setClaseServicio(linha.substring(226, 256).trim());
				leitorFiscal.setDescmotivocancelamento(linha.substring(192, 212).trim());
				leitorFiscal.setAliquota(BigDecimalUtil.getStringToBigDecimal(linha.substring(79, 93).trim(), 2, LocaleUtil.getLocale()));

				if (registros.contains(leitorFiscal)) {
					indice = registros.indexOf(leitorFiscal);
					leitorFiscal = registros.get(indice);
				}

				leitorFiscal.setQtdeItens(leitorFiscal.getQtdeItens() + 1);
				linha = br.readLine();
				while (linha != null && linha.startsWith("2")) {
					if (linha.indexOf("TA") >= 0) {
						leitorFiscal.setValorTarifa(leitorFiscal.getValorTarifa().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					if (linha.indexOf("TX") >= 0) {
						leitorFiscal.setValorEmbarque(leitorFiscal.getValorEmbarque().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					if (linha.indexOf("PE") >= 0) {
						leitorFiscal.setValorPedagio(leitorFiscal.getValorPedagio().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					if (linha.indexOf("SE") >= 0) {
						leitorFiscal.setValorSeguro(leitorFiscal.getValorSeguro().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					linha = br.readLine();
				}
			} else {
				linha = br.readLine();
			}

			if (leitorFiscal != null && indice > -1) {
				registros.set(indice, leitorFiscal);
			} else if (leitorFiscal != null) {
				registros.add(leitorFiscal);
			}
		}

		br.close();

		Collections.sort(registros);

		return registros;
	}

	private List<LeitorManualFiscalVO> carregarRegistrosManualFiscal(Empresa empresa, File arquivoTxt) throws Exception {
		List<LeitorManualFiscalVO> registros = new ArrayList<LeitorManualFiscalVO>();
		BufferedReader br = new BufferedReader(new FileReader(arquivoTxt));
		String linha = br.readLine();
		while (linha != null) {
			LeitorManualFiscalVO leitorManualFiscal = null;
			int indice = -1;
			if (linha.startsWith("1")) {
				leitorManualFiscal = new LeitorManualFiscalVO();
				leitorManualFiscal.setEmpresaId(empresa.getEmpresaId());
				leitorManualFiscal.setNombempresa(empresa.getNombempresa());
				leitorManualFiscal.setDataEmissao(linha.substring(1, 9).trim());
				leitorManualFiscal.setOrigenUf(linha.substring(177, 179).trim());
				leitorManualFiscal.setDestinoUf(linha.substring(184, 186).trim());
				leitorManualFiscal.setClaseServicio(linha.substring(226, 256).trim());
				leitorManualFiscal.setStatus(linha.substring(223, 224).trim());
				leitorManualFiscal.setIcms(BigDecimalUtil.getStringToBigDecimal(linha.substring(79, 93).trim(), 2, LocaleUtil.getLocale()));

				if (registros.contains(leitorManualFiscal)) {
					indice = registros.indexOf(leitorManualFiscal);
					leitorManualFiscal = registros.get(indice);
				}

				leitorManualFiscal.setValorIcms(leitorManualFiscal.getValorIcms().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(93, 107).trim(), 2, LocaleUtil.getLocale())));
				leitorManualFiscal.setValorTotal(leitorManualFiscal.getValorTotal().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(51, 65).trim(), 2, LocaleUtil.getLocale())));

				leitorManualFiscal.setQtdeItens(leitorManualFiscal.getQtdeItens() + 1);
				linha = br.readLine();
				while (linha != null && linha.startsWith("2")) {
					if (linha.indexOf("TA") >= 0) {
						leitorManualFiscal.setValorItem(leitorManualFiscal.getValorItem().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					if (linha.indexOf("TX") >= 0) {
						leitorManualFiscal.setImportetaxaembarque(leitorManualFiscal.getImportetaxaembarque().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					if (linha.indexOf("PE") >= 0) {
						leitorManualFiscal.setImportepedagio(leitorManualFiscal.getImportepedagio().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					if (linha.indexOf("SE") >= 0) {
						leitorManualFiscal.setImporteseguro(leitorManualFiscal.getImporteseguro().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(47, 62).trim(), 2, LocaleUtil.getLocale())));
					}

					linha = br.readLine();
				}
			} else {
				linha = br.readLine();
			}

			if (leitorManualFiscal != null && indice > -1) {
				registros.set(indice, leitorManualFiscal);
			} else if (leitorManualFiscal != null) {
				registros.add(leitorManualFiscal);
			}
		}

		br.close();

		Collections.sort(registros);

		return registros;
	}

	private List<LeitorNaoFiscalVO> carregarRegistrosNaoFiscais(Empresa empresa, File arquivoTxt) throws Exception {
		List<LeitorNaoFiscalVO> registros = new ArrayList<LeitorNaoFiscalVO>();
		BufferedReader br = new BufferedReader(new FileReader(arquivoTxt));
		String linha = br.readLine();
		while (linha != null) {
			LeitorNaoFiscalVO naoFiscais = null;
			int indice = -1;
			if (linha.startsWith("1")) {
				naoFiscais = new LeitorNaoFiscalVO();
				naoFiscais.setEmpresaId(empresa.getEmpresaId());
				naoFiscais.setNombempresa(empresa.getNombempresa());
				naoFiscais.setDatamov(linha.substring(1, 9).trim());

				Integer tipoEventoExtraId = Integer.valueOf(linha.substring(69, 78).trim());
				TipoEventoExtra tipoEvento = getTipoEventoExtra(tipoEventoExtraId);

				naoFiscais.setTipoeventoextraId(tipoEvento.getTipoeventoextraId());
				naoFiscais.setDesctipoevento(tipoEvento.getDescTipoEvento());

				if (registros.contains(naoFiscais)) {
					indice = registros.indexOf(naoFiscais);
					naoFiscais = registros.get(indice);
				}

				naoFiscais.setValorTotal(naoFiscais.getValorTotal().add(BigDecimalUtil.getStringToBigDecimal(linha.substring(52, 65).trim(), 2, LocaleUtil.getLocale())));

				linha = br.readLine();
			} else {
				linha = br.readLine();
			}

			if (naoFiscais != null && indice > -1) {
				registros.set(indice, naoFiscais);
			} else if (naoFiscais != null) {
				registros.add(naoFiscais);
			}
		}

		br.close();

		Collections.sort(registros);

		return registros;
	}

	private File gerarArquivoNaoFiscaisXls(List<LeitorNaoFiscalVO> registros, String nomeArquivo) throws IOException {
		HSSFWorkbook workbook = new HSSFWorkbook();
		HSSFSheet firstSheet = workbook.createSheet();

		int linha = 0;

		// Cabecalho
		HSSFRow row = firstSheet.createRow(linha++);
		row.createCell(0).setCellValue("DATA_EMISSAO");
		row.createCell(1).setCellValue("EMPRESA");
		row.createCell(2).setCellValue("CODIGO_NATUREZA");
		row.createCell(3).setCellValue("DESCRICAO_NATUREZA");
		row.createCell(4).setCellValue("VALOR_TOTAL");

		for (LeitorNaoFiscalVO leitorNaoFiscal : registros) {
			row = firstSheet.createRow(linha++);
			row.createCell(0).setCellValue(leitorNaoFiscal.getDatamov());
			row.createCell(1).setCellValue(leitorNaoFiscal.getNombempresa());
			row.createCell(2).setCellValue(leitorNaoFiscal.getTipoeventoextraId());
			row.createCell(3).setCellValue(leitorNaoFiscal.getDesctipoevento());
			row.createCell(4).setCellValue(leitorNaoFiscal.getValorTotal().doubleValue());
		}

		ByteArrayOutputStream bos = new ByteArrayOutputStream();
		workbook.write(bos);

		nomeArquivo = "consolidado_" + nomeArquivo.split("\\.")[0];
		File arquivo = File.createTempFile(nomeArquivo, ".xls");

		FileOutputStream fos = new FileOutputStream(arquivo);
		fos.write(bos.toByteArray());
		fos.close();

		return arquivo;

	}

	private TipoEventoExtra getTipoEventoExtra(Integer tipoEventoExtraId) {
		for (TipoEventoExtra tipoEvento : getListTipoEventoExtra()) {
			if (tipoEventoExtraId.equals(tipoEvento.getTipoeventoextraId()))
				return tipoEvento;
		}
		return null;
	}

	private List<TipoEventoExtra> getListTipoEventoExtra() {
		if (lsTipoEventoExtra == null) {
			lsTipoEventoExtra = tipoEventoExtraService.obtenerTodos();
		}
		return lsTipoEventoExtra;
	}

	@Override
	public File buscarArquivoExportacaoECF(Date inicio, Date fim, Empresa empresa, Estado estado, String nomeArquivo) {
		Connection connection = null;

		try {
			connection = getConnection();

			List<String> tempos = new ArrayList<String>(0);
			Long begin = 0L;

			begin = Calendar.getInstance().getTimeInMillis();
			List<ExportacaoECFTipoCFC> listaRegistroECFTipoCFC = fiscalDAO.buscarRegistroECFTipoCFC(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			tempos.add(infoTempo("CFC", begin));

			begin = Calendar.getInstance().getTimeInMillis();
			List<ExportacaoECFTipoCCF> listaRegistroECFTipoCCF = fiscalDAO.buscarRegistroECFTipoCCF(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			tempos.add(infoTempo("CCF", begin));

			begin = Calendar.getInstance().getTimeInMillis();
			List<ExportacaoECFTipoICF> listaRegistroECFTipoICF = fiscalDAO.buscarRegistroECFTipoICF(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			tempos.add(infoTempo("ICF", begin));

			begin = Calendar.getInstance().getTimeInMillis();
			List<ExportacaoECFTipoPRC> listaRegistroECFTipoPRC = fiscalDAO.buscarRegistroECFTipoPRC(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			tempos.add(infoTempo("PRC", begin));

			return exportacaoFiscal.gerarArquivoECF(tempos, nomeArquivo, inicio, fim, estado.getCveestado(), empresa.getNombempresa(), listaRegistroECFTipoCFC, listaRegistroECFTipoCCF, listaRegistroECFTipoICF,
					listaRegistroECFTipoPRC);

		} catch (Exception e) {
			log.error(e.getMessage(), e);

		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);

				throw new RuntimeException(e);
			}
		}

		return null;
	}

	private String infoTempo(final String descricao, final Long inicio) {
		final Long termino = Calendar.getInstance().getTimeInMillis();
		final Long tempo = termino - inicio;

		return descricao + ": " + String.format("%dm %ds", TimeUnit.MILLISECONDS.toMinutes(tempo), TimeUnit.MILLISECONDS.toSeconds(tempo) - TimeUnit.MINUTES.toSeconds(TimeUnit.MILLISECONDS.toMinutes(tempo)));
	}

	@Override
	public File buscarArquivoExportacaoRMD(Date inicio, Date fim, Empresa empresa, Estado estado, String nomeArquivo) {
		Connection connection = null;

		try {
			connection = getConnection();

			List<ExportacaoRMDTipoPAR> listaRegistroRMDTipoPAR = fiscalDAO.buscarRegistroRMDTipoPAR(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			List<ExportacaoRMDTipoRMD> listaRegistroRMDTipoRMD = fiscalDAO.buscarRegistroRMDTipoRMD(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			List<ExportacaoRMDTipoBPS> listaRegistroRMDTipoBPS = fiscalDAO.buscarRegistroRMDTipoBPS(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());
			List<ExportacaoRMDTipoDBP> listaRegistroRMDTipoDBP = fiscalDAO.buscarRegistroRMDTipoDBP(connection, inicio, fim, empresa.getEmpresaId(), estado.getCveestado());

			return exportacaoFiscal.gerarArquivoRMD(inicio, fim, nomeArquivo, empresa.getNombempresa(), listaRegistroRMDTipoPAR, listaRegistroRMDTipoRMD, listaRegistroRMDTipoBPS,
					listaRegistroRMDTipoDBP);

		} catch (Exception e) {
			log.error(e.getMessage(), e);

		} finally {
			try {
				if (connection != null && !connection.isClosed()) {
					connection.close();
				}
			} catch (SQLException e) {
				log.error("error fechar conexão", e);

				throw new RuntimeException(e);
			}
		}

		return null;
	}
}