package com.megatim.apifdxweb.service.impl.camel.processors;
|
|
import com.megatim.fdxcommons.core.ifaces.db.ImportReferentielHelper;
|
import com.megatim.fdxcommons.core.ifaces.helper.ReferentielConsumptionHelper;
|
import com.megatim.fdxcommons.model.pojo.ReferentielToImportData;
|
import java.io.File;
|
import javax.inject.Inject;
|
import org.apache.camel.Exchange;
|
import org.apache.camel.Processor;
|
import org.apache.camel.cdi.CdiCamelContext;
|
|
/**
|
*
|
* @author lenovo
|
*/
|
public class ReferentielProcessor implements Processor {
|
|
@Inject
|
private ReferentielConsumptionHelper referentielConsumptionHelper;
|
|
@Inject
|
private ImportReferentielHelper importReferentielHelper;
|
|
@Inject
|
private CdiCamelContext camelContext;
|
|
@Override
|
public void process(Exchange exchange) throws Exception {
|
|
File file = exchange.getIn().getBody(File.class);
|
|
ReferentielToImportData referentielToImportData = importReferentielHelper.extractData(file);
|
|
//On enregistre les données de référentiel trouvées
|
referentielConsumptionHelper.consume(referentielToImportData);
|
|
//Envoie des données du ref vers une file
|
exchange.getIn().setBody(referentielToImportData);
|
}
|
|
}
|
