AdmMono/src/com/rjconsultores/ventaboletos/dao/hibernate/SapHibernateDAO.java

package com.rjconsultores.ventaboletos.dao.hibernate;

import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import javax.sql.DataSource;

import org.hibernate.Query;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;

import com.rjconsultores.ventaboletos.dao.SapDAO;
import com.rjconsultores.ventaboletos.entidad.Empresa;
import com.rjconsultores.ventaboletos.entidad.FechamentoCntcorrente;
import com.rjconsultores.ventaboletos.entidad.PuntoVenta;
import com.rjconsultores.ventaboletos.enums.StatusIntegracaoSap;
import com.rjconsultores.ventaboletos.utilerias.DateUtil;
import com.rjconsultores.ventaboletos.vo.integracao.FechamentoCntCorrenteVO;

@Repository("sapDAO")
public class SapHibernateDAO extends GenericHibernateDAO<FechamentoCntcorrente, Long> implements SapDAO {
	
	@Autowired
    public SapHibernateDAO(@Qualifier("sessionFactory") SessionFactory factory) {
        setSessionFactory(factory);
    }
	
	@Autowired
	@Qualifier("dataSourceWrite")
	DataSource scoDs;
	
	@Override
	@Transactional
	public List<FechamentoCntCorrenteVO> obtenerTodosParaRemessa(Empresa empresa, Date dataDe, Date dataAte, String status) {
		return obtenerTodosParaRemessa(empresa, dataDe, dataAte, status, null);
	}

	@Override
	@Transactional
	public List<FechamentoCntCorrenteVO> obtenerTodosParaRemessa(Empresa empresa, Date dataDe, Date dataAte, String status, PuntoVenta puntoVenta) {
		
		StringBuilder sb = new StringBuilder();
		sb.append(" SELECT   ");
		sb.append("     fc.fechamentocntcorrente_id, ");
		sb.append("     to_char(fc.fecfechamento, 'yyyy-mm-DD'), ");
		sb.append("     fc.total, ");
		sb.append("     es.cveestado, ");
		sb.append("     pv.numpuntoventa, ");
		sb.append("     pv.numdocpuntoventa, ");
		sb.append("     pv.nombpuntoventa, ");
		sb.append("     fc.empresa_id, ");
		sb.append("     emp.nombempresa, ");
		sb.append("     fc.indintegradosap, ");
		sb.append("     to_char(fc.fecfechamento, 'yyyy'), ");
		sb.append("     to_char(fc.fecfechamento, 'mm'), ");
		sb.append("     CASE to_char(fc.fecfechamento, 'D') ");
		sb.append("     WHEN '6' THEN to_char(fc.fecfechamento+3, 'yyyy-mm-DD') ");
		sb.append("     WHEN '7' THEN to_char(fc.fecfechamento+2, 'yyyy-mm-DD') ");
		sb.append("     ELSE to_char(fc.fecfechamento+1, 'yyyy-mm-DD') END as feclancamento ");
		sb.append(" FROM ");
		sb.append("     fechamento_cntcorrente  fc  ");
		sb.append("     INNER JOIN punto_venta   		  pv ON pv.puntoventa_id = fc.puntoventa_id AND pv.activo = 1 ");
		sb.append("     INNER JOIN empresa       		  emp ON emp.empresa_id = fc.empresa_id AND emp.activo = 1 ");
		sb.append("     INNER JOIN FECHAMENTO_PARAMPTOVTA fp ON fp.PUNTOVENTA_ID = fc.puntoventa_id AND fp.activo =1 ");
		sb.append("                                          AND fp.empresa_id = fc.empresa_id AND fp.TIPOPAGAMENTO = 'B'" );
		sb.append("     LEFT JOIN ciudad         		  ci ON ci.ciudad_id = emp.ciudad_id AND ci.activo = 1 ");
		sb.append("     LEFT JOIN plaza          	 	  pl ON pl.plaza_id = ci.plaza_id AND pl.activo = 1 ");
		sb.append("     LEFT JOIN estado         		  es ON es.estado_id = ci.estado_id AND es.activo = 1 ");
		sb.append(" WHERE ");
		sb.append("     fc.activo = 1 ");
		sb.append("     AND fc.fecfechamento BETWEEN :dataDe AND :dataAte ");
		
		if( empresa != null ) {
			sb.append("     AND fc.EMPRESA_ID = :empresaId ");
		}
		
		if( puntoVenta != null ) {
			sb.append("     AND pv.puntoventa_id = :puntoVentaId ");
		}
		
		if(status != null && !status.isEmpty()){
			sb.append(" AND fc.indintegradosap in ("+status+")");
		}

		sb.append(" ORDER BY ");
		sb.append("     pv.nombpuntoventa, fc.fecfechamento ");
		
		Query query = getSession().createSQLQuery(sb.toString());
		
		if( empresa != null ) {
			query.setInteger("empresaId", empresa.getEmpresaId());
		}
		
		if( puntoVenta != null ) {
			query.setInteger("puntoVentaId", puntoVenta.getPuntoventaId());
		}
		
		if(dataDe != null && dataAte != null){			
			query.setDate("dataDe", DateUtil.normalizarToFecha(dataDe));
			query.setDate("dataAte", DateUtil.normalizarToFecha(dataAte));
		}		
		
		query.setMaxResults(100);

		List<Object[]> list = query.list();
		List<FechamentoCntCorrenteVO> retorno = new ArrayList<FechamentoCntCorrenteVO>();
		
		for(Object[] tupla : list){
			
			FechamentoCntCorrenteVO fcc = new FechamentoCntCorrenteVO();
			fcc.setFechamentocntcorrenteId( Long.valueOf(tupla[0].toString()));
			fcc.setFecfechamento( tupla[1].toString() );
			fcc.setTotal( (BigDecimal)tupla[2] );
			fcc.setUfEmpresa(tupla[3].toString());
			fcc.setNumPuntoVenta(tupla[4].toString());
			
			try {
				String cnpj = tupla[5].toString().replaceAll("[^0-9]", "");
				fcc.setCnpjPuntoVenta(cnpj);
			}catch (Exception e) {
				throw new RuntimeException( "CNPJ fora do padrao no ponto de venda: "+tupla[6]  );
			}
			fcc.setNombpuntoventa(tupla[6].toString());

			fcc.setEmpresaId( Integer.valueOf( tupla[7].toString() ));
			fcc.setNombEmpresa( tupla[8].toString());
			
			fcc.setIntegradoSap( StatusIntegracaoSap.getStatusIntegracaoSap( tupla[9]==null?0:Integer.valueOf(tupla[9].toString()) ));
			
			fcc.setAnofechamento(tupla[10].toString());
			fcc.setMesfechamento(tupla[11].toString());
			fcc.setFeclancamento(tupla[12].toString());
			
			//empresa enviada nula apenas no processo automatico
			if(empresa == null) {
				fcc.setEnviar(true);
			}
			
			retorno.add(fcc);
		}

		return retorno;
	}

	@Override
	@Transactional
	public synchronized boolean atualizaFechamento(Long fechamentocntcorrenteId, int status) throws Exception {
		
		if(fechamentocntcorrenteId == null ) {
			return false;
		}
		
		//<2F> feito update manualmente porque o hibernate utiliza sco_read e nao tem permissao de escrita no banco
		try(Connection con = scoDs.getConnection();
		    Statement stmt = con.createStatement()){		
			stmt.addBatch("UPDATE FECHAMENTO_CNTCORRENTE SET INDINTEGRADOSAP = "+ status 
				     +" WHERE FECHAMENTOCNTCORRENTE_ID = " + fechamentocntcorrenteId);

			stmt.executeBatch();
		}
		
		return Boolean.TRUE;
	}
	
}