447 lines
16 KiB
Java
447 lines
16 KiB
Java
/*
|
||
* To change this template, choose Tools | Templates
|
||
* and open the template in the editor.
|
||
*/
|
||
package com.rjconsultores.ventaboletos.service.impl;
|
||
|
||
import java.util.Calendar;
|
||
import java.util.List;
|
||
|
||
import org.apache.commons.lang.StringUtils;
|
||
import org.slf4j.Logger;
|
||
import org.slf4j.LoggerFactory;
|
||
import org.springframework.beans.factory.annotation.Autowired;
|
||
import org.springframework.stereotype.Service;
|
||
import org.springframework.transaction.annotation.Transactional;
|
||
|
||
import com.rjconsultores.ventaboletos.dao.PuntoVentaDAO;
|
||
import com.rjconsultores.ventaboletos.dao.UsuarioUbicacionDAO;
|
||
import com.rjconsultores.ventaboletos.entidad.Constante;
|
||
import com.rjconsultores.ventaboletos.entidad.Empresa;
|
||
import com.rjconsultores.ventaboletos.entidad.FormaPagoDet;
|
||
import com.rjconsultores.ventaboletos.entidad.Parada;
|
||
import com.rjconsultores.ventaboletos.entidad.PuntoVenta;
|
||
import com.rjconsultores.ventaboletos.entidad.Usuario;
|
||
import com.rjconsultores.ventaboletos.exception.IntegracionException;
|
||
import com.rjconsultores.ventaboletos.exception.ValidacionCampoException;
|
||
import com.rjconsultores.ventaboletos.service.ConstanteService;
|
||
import com.rjconsultores.ventaboletos.service.PuntoVentaService;
|
||
import com.rjconsultores.ventaboletos.utilerias.ApplicationProperties;
|
||
import com.rjconsultores.ventaboletos.utilerias.UsuarioLogado;
|
||
import com.rjconsultores.ws.totvs.service.TotvsService;
|
||
import com.rjconsultores.ws.utileria.Atributos;
|
||
import com.rjconsultores.ws.utileria.Atributos.CodPaisBanco;
|
||
import com.rjconsultores.ws.utileria.Atributos.ContribuinteICMS;
|
||
import com.rjconsultores.ws.utileria.Atributos.ContribuinteSimplesNacional;
|
||
import com.rjconsultores.ws.utileria.Atributos.InscricaoMunicipal;
|
||
import com.rjconsultores.ws.utileria.Atributos.TipoCliente;
|
||
import com.rjconsultores.ws.utileria.Atributos.TipoEntidade;
|
||
import com.rjconsultores.ws.utileria.Atributos.TipoFornecedor;
|
||
import com.rjconsultores.ws.utileria.Atributos.TipoPessoa;
|
||
import com.rjconsultores.ws.utileria.RetornoTotvs;
|
||
import com.rjconsultores.ws.utileria.RetornoTotvs.TipoRetorno;
|
||
|
||
/**
|
||
*
|
||
* @author Administrador
|
||
*/
|
||
@Service("puntoVentaService")
|
||
public class PuntoVentaServiceImpl implements PuntoVentaService {
|
||
|
||
private static Logger log = LoggerFactory.getLogger(PuntoVentaServiceImpl.class);
|
||
|
||
@Autowired
|
||
private PuntoVentaDAO puntoVentaDAO;
|
||
@Autowired
|
||
private ConstanteService constanteService;
|
||
|
||
@Autowired
|
||
private UsuarioUbicacionDAO usuarioUbicacionDAO;
|
||
|
||
// FIXME : Remover esse m<>todo de quem est<73> usando. Esse m<>todo carrega muitos dados
|
||
@Deprecated
|
||
public List<PuntoVenta> obtenerTodos() {
|
||
return puntoVentaDAO.obtenerTodos();
|
||
}
|
||
|
||
public PuntoVenta obtenerID(Integer id) {
|
||
return puntoVentaDAO.obtenerID(id);
|
||
}
|
||
|
||
@Transactional(noRollbackFor = { IntegracionException.class, ValidacionCampoException.class })
|
||
public PuntoVenta suscribir(PuntoVenta entidad) throws IntegracionException, ValidacionCampoException {
|
||
entidad.setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.setActivo(Boolean.TRUE);
|
||
|
||
Exception respEx = null;
|
||
if (ApplicationProperties.getInstance().integracionTotvs()) {
|
||
try {
|
||
if (entidad.getIndIntegracion() == TipoRetorno.PENDENTE.getValor()
|
||
|| entidad.getIndIntegracion() == TipoRetorno.ERRO.getValor()) {
|
||
String resp = integracionTotvs(entidad);
|
||
|
||
TipoRetorno retornoTotvs = RetornoTotvs.validaRetornoTotvs(resp);
|
||
|
||
switch (retornoTotvs) {
|
||
case CONCLUIDA:
|
||
entidad.setIndIntegracion(TipoRetorno.CONCLUIDA.getValor());
|
||
break;
|
||
|
||
case JA_CADASTRADA:
|
||
entidad.setIndIntegracion(TipoRetorno.JA_CADASTRADA.getValor());
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_JA_CADASTRADO);
|
||
break;
|
||
|
||
case ERRO:
|
||
entidad.setIndIntegracion(TipoRetorno.ERRO.getValor());
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_GENERICA + resp);
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
} else {
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_NAO_ENVIO);
|
||
}
|
||
} catch (ValidacionCampoException ev) {
|
||
entidad.setIndIntegracion(TipoRetorno.ERRO.getValor());
|
||
respEx = ev;
|
||
|
||
} catch (Exception e) {
|
||
entidad.setIndIntegracion(TipoRetorno.ERRO.getValor());
|
||
log.error(Atributos.MSG_ERRO_GENERICA, e);
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_GENERICA + e.getMessage());
|
||
}
|
||
}
|
||
entidad = puntoVentaDAO.suscribir(entidad);
|
||
|
||
if (respEx != null) {
|
||
if (respEx instanceof IntegracionException) {
|
||
throw (IntegracionException) respEx;
|
||
} else if (respEx instanceof ValidacionCampoException) {
|
||
throw (ValidacionCampoException) respEx;
|
||
}
|
||
}
|
||
|
||
return entidad;
|
||
}
|
||
|
||
@Transactional(noRollbackFor = { IntegracionException.class, ValidacionCampoException.class })
|
||
public PuntoVenta actualizacion(PuntoVenta entidad) throws IntegracionException, ValidacionCampoException {
|
||
entidad.setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.setActivo(Boolean.TRUE);
|
||
|
||
Exception respEx = null;
|
||
|
||
if (ApplicationProperties.getInstance().integracionTotvs()) {
|
||
|
||
try {
|
||
if (entidad.getIndIntegracion() == TipoRetorno.PENDENTE.getValor()
|
||
|| entidad.getIndIntegracion() == TipoRetorno.ERRO.getValor()) {
|
||
String resp = integracionTotvs(entidad);
|
||
|
||
TipoRetorno retornoTotvs = RetornoTotvs.validaRetornoTotvs(resp);
|
||
|
||
switch (retornoTotvs) {
|
||
case CONCLUIDA:
|
||
entidad.setIndIntegracion(TipoRetorno.CONCLUIDA.getValor());
|
||
break;
|
||
|
||
case JA_CADASTRADA:
|
||
entidad.setIndIntegracion(TipoRetorno.JA_CADASTRADA.getValor());
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_JA_CADASTRADO);
|
||
break;
|
||
|
||
case ERRO:
|
||
entidad.setIndIntegracion(TipoRetorno.ERRO.getValor());
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_GENERICA + resp);
|
||
break;
|
||
|
||
default:
|
||
break;
|
||
}
|
||
} else {
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_NAO_ENVIO);
|
||
}
|
||
} catch (ValidacionCampoException e) {
|
||
entidad.setIndIntegracion(TipoRetorno.ERRO.getValor());
|
||
respEx = e;
|
||
|
||
} catch (Exception e) {
|
||
entidad.setIndIntegracion(TipoRetorno.ERRO.getValor());
|
||
log.error(Atributos.MSG_ERRO_GENERICA, e);
|
||
respEx = new IntegracionException(Atributos.MSG_ERRO_GENERICA + e.getMessage());
|
||
}
|
||
}
|
||
|
||
entidad = puntoVentaDAO.actualizacion(entidad);
|
||
|
||
if (respEx != null) {
|
||
if (respEx instanceof IntegracionException) {
|
||
throw (IntegracionException) respEx;
|
||
} else if (respEx instanceof ValidacionCampoException) {
|
||
throw (ValidacionCampoException) respEx;
|
||
}
|
||
}
|
||
|
||
return entidad;
|
||
}
|
||
|
||
@Transactional
|
||
public void borrar(PuntoVenta entidad) {
|
||
|
||
for (FormaPagoDet forma : entidad.getLsFormaPagoDet()) {
|
||
forma.setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
forma.setFecmodif(Calendar.getInstance().getTime());
|
||
forma.setActivo(Boolean.FALSE);
|
||
}
|
||
|
||
if (entidad.getAgenciaId() != null) {
|
||
|
||
entidad.getAgenciaId().setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.getAgenciaId().setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.getAgenciaId().setActivo(Boolean.FALSE);
|
||
|
||
}
|
||
|
||
if (entidad.getComissaoId() != null) {
|
||
entidad.getComissaoId().setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.getComissaoId().setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.getComissaoId().setActivo(Boolean.FALSE);
|
||
}
|
||
|
||
if (entidad.getDiversosId() != null) {
|
||
entidad.getDiversosId().setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.getDiversosId().setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.getDiversosId().setActivo(Boolean.FALSE);
|
||
}
|
||
|
||
if (entidad.getTitularId() != null) {
|
||
entidad.getTitularId().setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.getTitularId().setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.getTitularId().setActivo(Boolean.FALSE);
|
||
}
|
||
|
||
entidad.setUsuarioId(UsuarioLogado.getUsuarioLogado().getUsuarioId());
|
||
entidad.setFecmodif(Calendar.getInstance().getTime());
|
||
entidad.setActivo(Boolean.FALSE);
|
||
|
||
puntoVentaDAO.actualizacion(entidad);
|
||
}
|
||
|
||
public List<PuntoVenta> buscaLike(String strEstacion) {
|
||
return puntoVentaDAO.buscaLike(strEstacion);
|
||
}
|
||
|
||
public List<PuntoVenta> buscar(String nomPuntoVenta, String numPuntoVenta) {
|
||
return puntoVentaDAO.busca(nomPuntoVenta, numPuntoVenta);
|
||
}
|
||
|
||
public List<PuntoVenta> buscaPuntoVenta(String numPuntoVenta) {
|
||
return puntoVentaDAO.buscaPuntoVenta(numPuntoVenta);
|
||
}
|
||
|
||
public List<PuntoVenta> buscaPuntoVentaParada(Parada paradaId) {
|
||
return puntoVentaDAO.buscaPuntoVentaParada(paradaId);
|
||
}
|
||
|
||
public List<PuntoVenta> buscarPuntoVentaSubordinados(PuntoVenta puntoVenta) {
|
||
List<PuntoVenta> lsPuntoVentaSubordinados = puntoVentaDAO.buscarPuntoVentaSubordinados(puntoVenta);
|
||
|
||
return lsPuntoVentaSubordinados;
|
||
}
|
||
|
||
public List<PuntoVenta> buscarPuntosVentaMovimentacionBilhetes(List<Empresa> empresas) {
|
||
List<PuntoVenta> puntosVenta = puntoVentaDAO.buscarPuntosVentaMovimentacionBilhetes(empresas);
|
||
return puntosVenta;
|
||
}
|
||
|
||
public List<PuntoVenta> buscarPuntosVentaPorUsuario(Usuario usuario) {
|
||
List<PuntoVenta> puntosVenta = usuarioUbicacionDAO.buscarPuntoVentaPorUsuario(usuario);
|
||
return puntosVenta;
|
||
}
|
||
|
||
private void validaCampos(PuntoVenta puntoVenta) throws ValidacionCampoException {
|
||
|
||
if (puntoVenta.getNumDoCPuntoVenta() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.numDoCPuntoVenta");
|
||
}
|
||
|
||
if (puntoVenta.getNumIEPuntoVenta() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.numIEPuntoVenta");
|
||
}
|
||
|
||
if (puntoVenta.getColonia() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.colonia");
|
||
}
|
||
|
||
if (puntoVenta.getAgenciaId() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.agenciaId");
|
||
} else {
|
||
|
||
if (puntoVenta.getAgenciaId().getNumagencia() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.numagencia");
|
||
}
|
||
if (puntoVenta.getAgenciaId().getNumconta() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.numconta");
|
||
}
|
||
if (puntoVenta.getAgenciaId().getDigito() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.digito");
|
||
}
|
||
|
||
if (puntoVenta.getAgenciaId().getInstiFinanceiraId() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.instiFinanceiraId");
|
||
} else {
|
||
if (puntoVenta.getAgenciaId().getInstiFinanceiraId().getCodigo() == null) {
|
||
throw new ValidacionCampoException("editarPuntoVentaController.erro.instiFinanceiraId.codigo");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
private String integracionTotvs(PuntoVenta puntoVenta) throws Exception {
|
||
if (ApplicationProperties.getInstance().integracionTotvs()) {
|
||
|
||
validaCampos(puntoVenta);
|
||
|
||
String endpointFornecedor = getEndpointFornecedor();
|
||
String endpointCliente = getEndpointCliente();
|
||
|
||
String xidsvp = puntoVenta.getNumPuntoVenta();
|
||
|
||
String cnpjEmpresaProtheus = Atributos.CNPJ_EMPRESA_PROTHEUS;
|
||
|
||
String nome = puntoVenta.getNombpuntoventa();
|
||
String cgc = puntoVenta.getNumDoCPuntoVenta();
|
||
|
||
String endereco = puntoVenta.getDireccioncalle() + "," + ((puntoVenta.getDireccionnumero() == null) ? "" : puntoVenta.getDireccionnumero());
|
||
String complemen = puntoVenta.getCompl() == null ? "" : puntoVenta.getCompl();
|
||
String bairro = puntoVenta.getColonia() == null ? null : puntoVenta.getColonia().getDesccolonia();
|
||
|
||
String codmun = puntoVenta.getColonia() == null ? null : puntoVenta.getColonia().getCiudad().getCodmunicipio().toString();
|
||
codmun = (codmun == null) ? "" : StringUtils.leftPad(codmun, 5, '0');
|
||
|
||
String est = puntoVenta.getColonia() == null ? null : puntoVenta.getColonia().getCiudad().getEstado().getCveestado();
|
||
String codpais = CodPaisBanco.BRASIL.getValor();
|
||
|
||
String cep = puntoVenta.getCodpostal() != null?puntoVenta.getCodpostal().toString():null;
|
||
|
||
String tel = puntoVenta.getNumtelefonouno();
|
||
String ddd = null;
|
||
try {
|
||
String[] telefone = tel == null ? null : tel.split("\\)");
|
||
ddd = tel == null ? null : telefone[0].replaceAll("\\(", "");
|
||
tel = tel == null ? null : telefone[1].replaceAll("\\(", "");
|
||
} catch (Exception e) {
|
||
tel = puntoVenta.getNumtelefonouno();
|
||
}
|
||
|
||
String email = puntoVenta.getDescCorreo() == null ? "" : puntoVenta.getDescCorreo();
|
||
String fax = puntoVenta.getNumfax() == null ? "" : puntoVenta.getNumfax();
|
||
String inscr = puntoVenta.getNumIEPuntoVenta();
|
||
String inscrm = InscricaoMunicipal.ISENTO.name();
|
||
|
||
String nreduz = puntoVenta.getRazonSocial() != null ? puntoVenta.getRazonSocial() : puntoVenta.getNombpuntoventa();
|
||
|
||
String simpnac = ContribuinteSimplesNacional.NAO.getValor();
|
||
|
||
String tppessoa = TipoFornecedor.OS.name();
|
||
String tppessoaCliente = TipoCliente.F.name();
|
||
|
||
String tipoPessoa = TipoPessoa.F.name();
|
||
|
||
if (isCNPJ(cgc)) {
|
||
tipoPessoa = TipoPessoa.J.name();
|
||
}
|
||
|
||
String obs = StringUtils.isBlank(puntoVenta.getComentarios()) ? "sem obs." : puntoVenta.getComentarios();
|
||
|
||
String contaFornecedor = Atributos.CONTA_FORNECEDOR_PROTHEUS;
|
||
String contaCliente = Atributos.CONTA_CLIENTE_PROTHEUS;
|
||
|
||
String naturez = "";
|
||
String cnae = "";
|
||
String fator = "";
|
||
|
||
String agencia = puntoVenta.getAgenciaId() == null ? "" : puntoVenta.getAgenciaId().getNumagencia();
|
||
String dgverag = "";
|
||
try {
|
||
String[] agenciaComp = agencia == null ? null : agencia.split("-");
|
||
agencia = agencia == null ? null : agenciaComp[0];
|
||
dgverag = agencia == null ? null : agenciaComp[1];
|
||
} catch (Exception e) {
|
||
agencia = puntoVenta.getAgenciaId() == null ? "" : puntoVenta.getAgenciaId().getNumagencia();
|
||
}
|
||
|
||
String banco = puntoVenta.getAgenciaId().getInstiFinanceiraId() == null ? "" : puntoVenta.getAgenciaId().getInstiFinanceiraId().getCodigo();
|
||
String ctacorr = puntoVenta.getAgenciaId() == null ? "" : puntoVenta.getAgenciaId().getNumconta();
|
||
String dgverct = puntoVenta.getAgenciaId() == null ? "" : puntoVenta.getAgenciaId().getDigito();
|
||
|
||
String resp = null;
|
||
Exception respEx = null;
|
||
|
||
try {
|
||
resp = TotvsService.cadastrarFornecedor(endpointFornecedor, bairro, cep, cgc, cnae, codmun, codpais, complemen, contaFornecedor, ddd, email, endereco,
|
||
est, inscr, inscrm, naturez, nreduz, nome, simpnac, tel, tipoPessoa, tppessoa, cnpjEmpresaProtheus, xidsvp, agencia, banco,
|
||
dgverag, ctacorr, dgverct);
|
||
} catch (Exception e) {
|
||
log.error("", e);
|
||
respEx = e;
|
||
}
|
||
|
||
String contrib = ContribuinteICMS.NAO.getValor();
|
||
String entid = TipoEntidade.TRANSPORTE_PASSAGEIRO.getValor();
|
||
String pais = "";// segundo orienta<74><61>o da TOTVS, passar em branco
|
||
|
||
try {
|
||
resp = TotvsService.cadastrarCliente(endpointCliente, bairro, cep, cgc, codmun, codpais, complemen, contaCliente, contrib, ddd, email, cnpjEmpresaProtheus,
|
||
endereco, entid, fator, fax, inscr, inscrm, naturez, nreduz, nome, obs, pais, tppessoaCliente, tel, tipoPessoa, est, xidsvp);
|
||
} catch (Exception e) {
|
||
log.error("", e);
|
||
respEx = e;
|
||
}
|
||
|
||
if (respEx != null) {
|
||
throw respEx;
|
||
}
|
||
|
||
return resp;
|
||
}
|
||
return null;
|
||
}
|
||
|
||
private String getEndpointFornecedor() {
|
||
Constante constante = constanteService.buscarPorNomeConstante("WS_TOTVS_FORNECEDOR_ENDPOINT");
|
||
if (constante == null) {
|
||
return "";
|
||
}
|
||
return constante.getValorconstante();
|
||
}
|
||
|
||
private String getEndpointCliente() {
|
||
Constante constante = constanteService.buscarPorNomeConstante("WS_TOTVS_CLIENTE_ENDPOINT");
|
||
if (constante == null) {
|
||
return "";
|
||
}
|
||
return constante.getValorconstante();
|
||
}
|
||
|
||
private String somenteNumeros(String s) {
|
||
if (s == null || StringUtils.isBlank(s)) {
|
||
return "";
|
||
}
|
||
|
||
s = StringUtils.trim(s);
|
||
|
||
return s.replaceAll("[^0-9]", "");
|
||
}
|
||
|
||
private boolean isCNPJ(String vlr) {
|
||
vlr = somenteNumeros(vlr);
|
||
return vlr.length() > 11;
|
||
}
|
||
|
||
}
|