/*
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
*/
|
package com.megatim.fdxconvert.service;
|
|
import com.megatimfx.common.service.GenericCrudService;
|
import com.megatim.fdxconvert.dao.AbstractDAO;
|
import com.megatim.fdxconvert.dao.TypeFichierDAO;
|
import com.megatim.fdxconvert.pojo.ImportFile;
|
import com.megatim.fdxconvert.model.TypeFichier;
|
import com.megatim.fdxconvert.pojo.DataToImport;
|
import com.megatim.fdxconvert.util.ImportData;
|
import com.megatim.fdxconvert.service.pojo.PaginationElts;
|
import java.io.File;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Optional;
|
|
/**
|
* structLigne : id, code,format_date, position, taille, type_donnee,
|
* validateur_fichier_id ValidateurFichier : id, nombre_position,
|
* type_fichier_code
|
*
|
* @author STEPHANIE
|
*/
|
public class ImportFileService implements GenericCrudService<ImportFile> {
|
|
private static ImportFileService importFileService;
|
private PaginationElts<TypeFichier> pagination;
|
|
private ImportFileService() {
|
|
}
|
|
public static synchronized ImportFileService getInstance() {
|
if (importFileService == null) {
|
importFileService = new ImportFileService();
|
}
|
return importFileService;
|
}
|
|
@Override
|
public ImportFile add(ImportFile t) throws Exception {
|
importDataFromFile(t);
|
return t;
|
}
|
|
@Override
|
public ImportFile edit(ImportFile t) throws Exception {
|
throw new UnsupportedOperationException("Not supported yet.");
|
}
|
|
@Override
|
public List<ImportFile> getAll() throws Exception {
|
throw new UnsupportedOperationException("Not supported yet.");
|
}
|
|
@Override
|
public void delete(ImportFile t) throws Exception {
|
throw new UnsupportedOperationException("Not supported yet.");
|
}
|
|
private void importDataFromFile(ImportFile im) throws Exception{
|
List<String> fields = new ArrayList<>();
|
|
if (im != null && im.getType() != null) {
|
if (im.getType().equals(TypeFichier.class)) {
|
fields.add("code");
|
fields.add("libelle");
|
fields.add("codeParticipant");
|
}
|
}
|
DataToImport datIm = new DataToImport(new File(im.getFilePath()), im.getDelimiteurLigne().getCode(), im.getDelimiteurColonne().getCode(), im.getType(), fields);
|
List<Object> datas = ImportData.importDataFromCsvFile(datIm);
|
if (im.getType().equals(TypeFichier.class)) {
|
AbstractDAO<TypeFichier> dao = new AbstractDAO<>(TypeFichier.class);
|
|
datas.forEach(d -> {
|
TypeFichier t = (TypeFichier) d;
|
Optional<TypeFichier> opt = TypeFichierDAO.findByCode(t);
|
if(!opt.isPresent())
|
dao.add(t);
|
});
|
}
|
}
|
}
|
//{}
|
