PICA v1.1.0

  <dependency>
		<groupId>cat.gencat.ctti</groupId>
		<artifactId>interop.connectors.pica</artifactId>
		<version>1.1.0</version>
  </dependency>

pica:
  axis-definition: classpath:axis2client/
  modalitats:
    PADRO_MUNICIPI_RESIDENCIA:
      signat: false
      url-pica: http://preproduccio.pica.intranet.gencat.cat/pica_cataleg/AppJava/services/PADRO_MUNICIPI_RESIDENCIA
      cod-certificado: PADRO_MUNICIPI_RESIDENCIA
      cod-producto: PADRO
      finalidad: PROVES
      nif-emisor: Q0801175A
      nombre-emisor: CONSORCI AOC
      password-type: PasswordText

  requeridor:
    fitxer-signatura: classpath:config/cert/pica.signature.properties
    id-solicitante: ID_SOLICITANTE
    id-transmision: ID_TRANSMISION
    nombre-solicitante: NOM_SOLICITANTE
    password: USER_PASSWORD
    user: PASSWORD

  requeridor-error:
    password: PICAERROR
    user: USER_ERROR

  modes:
    passwordType: PasswordText
  requirer:
    password: REQUIRER_PASSWORD
    petitionerId: PETITIONER_ID
    petitionerName: PETITIONER_NAME
    signatureFile: classpath:config/cert/pica.signature.properties
    transmitionId: TRANSMITION_ID
    user: USER
  trustStore:
    location: classpath:config/cert/certificats.jks
    password: PASSWORD_DE_LA_TRUSTSTORE
    type: JKS

import cat.gencat.ctti.interop.connectors.pica.PicaServiceWrapperImpl;
import cat.gencat.pica.api.peticio.beans.DadesEspecifiques;
import cat.gencat.pica.api.peticio.beans.Funcionari;
import cat.gencat.pica.api.peticio.beans.Titular;
import cat.gencat.pica.api.peticio.core.IPICAServiceSincron;
import com.generalitat.mp.ws.CridaSincronaResponseDocument;
import org.apache.logging.log4j.Logger;
import org.springframework.stereotype.Service;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import java.io.IOException;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

@Service
public class PicaService {
    private static final Logger log = org.apache.logging.log4j.LogManager.getLogger(PicaService.class);

    private final PicaServiceWrapperImpl picaServiceWrapperImpl;

    private static final int TIPO_DOC_TITULAR_NIF = 2;

    public PicaService(PicaServiceWrapperImpl picaServiceWrapperImpl) {
        this.picaServiceWrapperImpl = picaServiceWrapperImpl;
    }

    public String testPica() throws Exception {
        log.info("Executing Pica test...");
        String message;
        try {
            IPICAServiceSincron service = picaServiceWrapperImpl.getPicaWebServiceSincronInstance("PADRO_MUNICIPI_RESIDENCIA");
            Funcionari func = getFuncionari();
            Titular tit = creaTitular();
            List<DadesEspecifiques> datosEspecificosXML = createDadesEspecifiques();
            service.setFuncionari(func);
            service.setTitular(tit);
            service.setDadesEspecifiques(datosEspecificosXML);
            // Identificador únic de petició
            service.crearPeticio("PROVA_OTCANIGO_" + System.currentTimeMillis());
            // fer peticio
            CridaSincronaResponseDocument resp = picaServiceWrapperImpl.ferPeticioAlServei(service);
            // extreure resultat
            List<DadesEspecifiques> resposta = picaServiceWrapperImpl.extreuDadesEspecifiques(service, resp);
            Iterator<DadesEspecifiques> it = resposta.iterator();
            while (it.hasNext()) {
                DadesEspecifiques object = it.next();
                String dadesXML = object.getDadesXML();
                // Parsejar resposta
                parseXML(dadesXML);
            }
            message = "Test correcte";
        } catch (Exception e) {
            message = "Test amb errors: " + e.getMessage();
            log.error(e.getMessage(), e);
        }
        return message;
    }

    /**
     * Crea un objecte funcionari return funcionari
     **/
    private Funcionari getFuncionari() {
        Funcionari funcionari = new Funcionari();
        funcionari.setNombreFuncionario("Nom Funcionari");
        funcionari.setNifFuncionario("55555555A");
        funcionari.setEmailFuncionario("prova@gencat.com");
        return funcionari;
    }

    /**
     * Crea un objecte titular return titular
     **/
    private Titular creaTitular() {
        Titular tit = new Titular();
        tit.setTitularTipoDocumentacion(TIPO_DOC_TITULAR_NIF);
        tit.setTitularDocumentacion("NIF_TITULAR"); // Es posa el NIF real
        tit.setTitularNombreCompleto("NOM_COMPLET_TITULAR"); // Es posa el nom
        // real
        return tit;
    }

    /**
     * Crea un objecte dades específiques return DadesEspecifiques
     **/
    private List<DadesEspecifiques> createDadesEspecifiques() {
        List<DadesEspecifiques> dadesEspecifiquesXML = new ArrayList<DadesEspecifiques>();
        StringBuffer sb = new StringBuffer("<ns1:request xmlns:ns1=\"http://www.gencat.net/tfn\">");
        sb.append("<ns1:simpleparam name=\"NUMTIT\">83746573</ns1:simpleparam>");
        sb.append("<ns1:simpleparam name=\"NUMNIF\">111111111H</ns1:simpleparam>");
        sb.append("</ns1:request>");
        DadesEspecifiques dades = new DadesEspecifiques();
        dades.setIdSolicitud("1");
        dades.setDadesXML(sb.toString());
        dadesEspecifiquesXML.add(dades);
        return dadesEspecifiquesXML;
    }

    /**
     * Parsejar la resposta deixant constància en format de traces si la crida
     * ha finalitzat o no correctament
     **/
    private void parseXML(String dadesXML) throws ParserConfigurationException, SAXException, IOException {
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        DocumentBuilder builder = factory.newDocumentBuilder();
        InputSource inStream = new InputSource();
        boolean error = false;

        inStream.setCharacterStream(new StringReader(dadesXML));
        Document doc = builder.parse(inStream);
        NodeList nodes = doc.getElementsByTagName("error");
        if (nodes.getLength() == 0) {
            nodes = doc.getElementsByTagName("sol:SolicitudError");
            error = true;
        }

        for (int i = 0; i < nodes.getLength(); i++) {
            Node node = nodes.item(i);
            if (node.getNodeType() == Node.ELEMENT_NODE) {
                Element element = (Element) node;
                if (!error) {
                    log.info(dadesXML);
                } else {
                    log.info(element.getTextContent());
                }
            }
        }
    }
}