PICA

<canigo.integration.pica.version>[2.3.0,2.4.0)</canigo.integration.pica.version>

<dependency>
    <groupId>cat.gencat.ctti</groupId>
    <artifactId>canigo.integration.pica</artifactId>
    <version>${canigo.integration.pica.version}</version>
</dependency>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd">


	<bean id="picaCanigoService" parent="abstractPicaService">
		<property name="modalitats">
			<map>
				<entry key="PADRO_MUNICIPI_RESIDENCIA">
					<bean parent="producteModalitatBase">
						<property name="signat" value="false"/>
						<property name="urlPICA" value="${pica.url}" />
						<property name="codCertificado" value="${pica.codCertificado}"/>
						<property name="codProducto" value="${pica.codProducto}"/>
						<property name="finalidad" value="${pica.finalidad}"/>
						<property name="nifEmisor" value="${pica.nifEmissor}"/>
						<property name="nombreEmisor" value="${pica.nombreEmisor}"/>
					</bean>
				</entry>
			</map>
		</property>
	</bean>
</beans>

import java.io.IOException;
import java.io.StringReader;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Lazy;
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 com.generalitat.mp.ws.CridaSincronaResponseDocument;

import cat.gencat.ctti.canigo.arch.integration.pica.IPicaServiceWrapper;
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;

@Service("picaAplicacioService")
@Lazy
public class PicaAplicacioService {

	private static final Logger log = LoggerFactory.getLogger(PicaAplicacioService.class);

	@Qualifier("picaService")
	@Autowired
    private IPicaServiceWrapper serviceWrapper;
    
	private static final int TIPO_DOC_TITULAR_NIF = 2;

	public String testPica(){
		
		String message;

		 try{
	            IPICAServiceSincron service = serviceWrapper.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 = serviceWrapper.ferPeticioAlServei(service);
	            //extreure resultat
	            List<DadesEspecifiques> resposta= serviceWrapper.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());
	            }
	        }
	    }
	}
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import cat.gencat.plantilla32.service.PicaAplicacioService;

@RestController
@RequestMapping("/pica")
public class PicaServiceController {

	@Autowired
	PicaAplicacioService picaAplicacioService;


	@PostMapping(produces = { MediaType.APPLICATION_JSON_VALUE })
	public String testPica() throws Exception {
		return picaAplicacioService.testPica();
	}
}