Subversion Repositories Integrator Subversion

package nfe;

import java.rmi.RemoteException;
import java.util.Iterator;

import javax.xml.bind.JAXBException;
import javax.xml.stream.XMLStreamException;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMText;
import org.apache.axiom.om.util.AXIOMUtil;
import org.apache.axis2.transport.http.HTTPConstants;

import br.inf.portalfiscal.nfe.schema_4.enviNFe.TEnviNFe;
import br.inf.portalfiscal.nfe.schema_4.enviNFe.TRetEnviNFe;
import br.inf.portalfiscal.www.nfe_400.wsdl.NFeAutorizacao.NFeAutorizacao4Stub;
import nfe.dom.ConfiguracoesIniciaisNfe;
import nfe.exception.NfeException;
import nfe.exception.NfeValidacaoException;
import nfe.util.CertificadoUtil;
import nfe.util.ConstantesUtil;
import nfe.util.ObjetoUtil;
import nfe.util.WebServiceUtil;
import nfe.util.XmlUtil;

/**
 * Classe Responsavel por Enviar o XML.
 *
 * @author Samuel Oliveira - samuk.exe@hotmail.com - www.samuelweb.com.br
 */
class Enviar {

    /**
     * Metodo para Montar a NFE
     *
     * @param enviNFe
     * @param valida
     * @return
     * @throws NfeException
     */
    static TEnviNFe montaNfe(TEnviNFe enviNFe, boolean valida) throws NfeException {

        try {

            /**
             * Cria o xml
             */
            String xml = XmlUtil.objectToXml(enviNFe);

            /**
             * Assina o Xml
             */
            xml = Assinar.assinaNfe(xml, "NFe");

            /**
             * Valida o Xml caso sejá selecionado True
             */
            if(valida){
                String erros = Validar.validaXml(xml, Validar.ENVIO);
                if (!ObjetoUtil.isEmpty(erros)) {
                    throw new NfeValidacaoException("Erro Na Validação do Xml: " + erros);
                }
            }

            if (ConfiguracoesIniciaisNfe.getInstance().isLog()) {
                System.out.println("Xml Assinado: " + xml);
            }

            return XmlUtil.xmlToObject(xml, TEnviNFe.class);

        } catch (JAXBException e) {
            throw new NfeException(e.getMessage());
        }

    }

    /**
     * Metodo para Enviar a NFE.
     *
     * @param enviNFe
     * @param tipo
     * @return
     * @throws NfeException
     */
    static TRetEnviNFe enviaNfe(TEnviNFe enviNFe, String tipo) throws NfeException {

        /**
         * Informacoes do Certificado Digital.
         */
        ConfiguracoesIniciaisNfe config = CertificadoUtil.iniciaConfiguracoes();

        boolean nfce = tipo.equals(ConstantesUtil.NFCE);
        String qrCode = "";

        try {
            if (nfce) {
                qrCode = enviNFe.getNFe().get(0).getInfNFeSupl().getQrCode();
                enviNFe.getNFe().get(0).getInfNFeSupl().setQrCode("");
            }

            String xml = XmlUtil.objectToXml(enviNFe);

            if (nfce) {
                enviNFe.getNFe().get(0).getInfNFeSupl().setQrCode(qrCode);
            }

            OMElement ome = AXIOMUtil.stringToOM(xml);

            Iterator<?> children = ome.getChildrenWithLocalName("NFe");
            while (children.hasNext()) {
                OMElement omElementNFe = (OMElement) children.next();
                if ((omElementNFe != null) && ("NFe".equals(omElementNFe.getLocalName()))) {
                    omElementNFe.addAttribute("xmlns", "http://www.portalfiscal.inf.br/nfe", null);
                    if (nfce) {

                        OMFactory f = OMAbstractFactory.getOMFactory();
                        OMText omt = f.createOMText(qrCode, OMElement.CDATA_SECTION_NODE);

                        Iterator<?> itInfSupl = omElementNFe.getChildrenWithLocalName("infNFeSupl");
                        while (itInfSupl.hasNext()) {
                            Object elementInfSupl = itInfSupl.next();
                            if (elementInfSupl instanceof OMElement) {
                                OMElement omElementInfSupl = (OMElement) elementInfSupl;
                                Iterator<?> itqrCode = omElementInfSupl.getChildrenWithLocalName("qrCode");
                                while (itqrCode.hasNext()) {
                                    Object elementQrCode = itqrCode.next();
                                    if (elementQrCode instanceof OMElement) {
                                        OMElement omElementQrCode = (OMElement) elementQrCode;
                                        omElementQrCode.addChild(omt);
                                    }
                                }
                            }
                        }
                    }
                }
            }

            //Adicionado CDATA após OM
            if (nfce) {
                enviNFe.getNFe().get(0).getInfNFeSupl().setQrCode("<![CDATA["+qrCode +"]]>");
            }

            if (config.isLog()) {
                System.out.println("Xml para Envio: " + ome.toString());
            }

            NFeAutorizacao4Stub.NfeDadosMsg dadosMsg = new NFeAutorizacao4Stub.NfeDadosMsg();
            dadosMsg.setExtraElement(ome);

            NFeAutorizacao4Stub stub = new NFeAutorizacao4Stub(nfce ? WebServiceUtil.getUrl(ConstantesUtil.NFCE, ConstantesUtil.SERVICOS.ENVIO) : WebServiceUtil.getUrl(ConstantesUtil.NFE, ConstantesUtil.SERVICOS.ENVIO));
            //Timeout
            if (!ObjetoUtil.isEmpty(config.getTimeout())) {
                stub._getServiceClient().getOptions().setProperty(
                        HTTPConstants.SO_TIMEOUT, config.getTimeout());
                stub._getServiceClient().getOptions().setProperty(
                        HTTPConstants.CONNECTION_TIMEOUT, config.getTimeout());
            }
            NFeAutorizacao4Stub.NfeResultMsg result = stub.nfeAutorizacaoLote(dadosMsg);

            return XmlUtil.xmlToObject(result.getExtraElement().toString(), TRetEnviNFe.class);

        } catch (RemoteException | XMLStreamException | JAXBException e) {
            throw new NfeException(e.getMessage());
        }

    }

}