/*
 * 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.controller;

import com.megatimfx.common.abstracts.AbstractEditDialogController;
import com.megatimfx.common.enums.Operateur;
import com.megatimfx.common.pojo.SearchCriteria;
import com.megatimfx.common.utils.ViewLoaderUtil;
import com.megatimfx.components.customdialogs.AlertMessageUtil;
import com.megatimfx.components.customdialogs.LoadinIndicatorDialogUtil;
import com.megatimfx.components.dialogs.NotificationDialog;
import com.megatimfx.components.dialogs.NotificationType;
import com.megatim.fdxconvert.enums.DataType;
import com.megatim.fdxconvert.exceptions.ConfigException;
import com.megatim.fdxconvert.exceptions.ValidatorException;
import com.megatim.fdxconvert.forms.DataFileToJsonFormController;
import com.megatim.fdxconvert.model.Configuration;
import com.megatim.fdxconvert.model.Validateur;
import com.megatim.fdxconvert.pojo.ColumnDefinition;
import com.megatim.fdxconvert.pojo.DataFileToJson;
import com.megatim.fdxconvert.service.ConfigurationService;
import com.megatim.fdxconvert.util.ExportToJson;
import com.megatim.fdxconvert.pojo.FileToValidateDescription;
import com.megatim.fdxconvert.service.ValidateurService;
import com.megatim.typefichier.validator.utilities.ParserUtils;
import com.megatim.fdxconvert.util.ValidateurParser;
import java.io.File;
import java.io.IOException;
import java.net.URL;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.ResourceBundle;
import javafx.concurrent.Task;
import javafx.event.ActionEvent;
import javafx.scene.Node;
import javafx.scene.layout.Pane;
import javafx.stage.Stage;

/**
 *
 * @author ASUS
 */
public class DataFileToJsonEditDialogController extends AbstractEditDialogController<DataFileToJson> {

    org.apache.log4j.Logger logger = org.apache.log4j.Logger.getLogger(DataFileToJsonEditDialogController.class);
    private DataFileToJsonFormController txtFileToJsonFormController;

    @Override
    public void initialize(URL url, ResourceBundle rb) {
        txtFileToJsonFormController = new DataFileToJsonFormController();
        super.initialize(url, rb);

    }

    @Override
    public String getTitle() {
        getEditButton().setText("Convertir");
        return "Conversion d'un fichier de données en JSON";
    }

    @Override
    public Pane getContentFormPane() throws IOException {
        return ViewLoaderUtil.getPaneFromFxmlFile(txtFileToJsonFormController.getClass().getResource("DataFileToJsonEditForm.fxml"), txtFileToJsonFormController);

    }

    @Override
    public Object getContentFormController() {
        return txtFileToJsonFormController;
    }

    @Override
    public void afterSave(ActionEvent event) {
        List<Validateur> validateurs = ValidateurService.getInstance().getAll(Arrays.asList(validateurCriterion(getCurrentObject().getTypeFichier().getCode())));
        boolean proceed = !validateurs.isEmpty() || getCurrentObject().getValidateurPath() != null;
        Task<Void> task = new Task<Void>() {

            @Override
            protected Void call() throws Exception {
                parseFile();
                return null;
            }
        };
        task.setOnRunning(e -> LoadinIndicatorDialogUtil.getLoadingIndicatorDialog().show());
        task.setOnSucceeded(e -> {

            LoadinIndicatorDialogUtil.getLoadingIndicatorDialog().hide();
            Node source = (Node) event.getSource();
            Stage parentStage = (Stage) source.getScene().getWindow();

            NotificationDialog notificationDialog = new NotificationDialog("Conversion en JSON reussie", NotificationType.SUCCESS, parentStage);
            notificationDialog.showNotification();
        });

        task.setOnFailed(e -> {
            LoadinIndicatorDialogUtil.getLoadingIndicatorDialog().hide();
            Throwable th = task.getException();

            if (th instanceof ConfigException || th instanceof ValidatorException) {
                Node source = (Node) event.getSource();
                Stage parentStage = (Stage) source.getScene().getWindow();
                NotificationDialog notificationDialog = new NotificationDialog(th.getMessage(), NotificationType.WARNING, parentStage);
                logger.warn(th.getMessage());
                notificationDialog.showNotification();

            } else {
                logger.error(th);
                AlertMessageUtil.showAlertException(th, "Une exception s'est produite pendant la validation du fichier", "Erreur");
            }
        });
        if (proceed) {
            new Thread(task).start();
        } else {
            AlertMessageUtil.showAlertException(new Exception(""), "Validateur de " + getCurrentObject().getTypeFichier().getCode() + " introuvable", "Erreur");
        }
    }

    private SearchCriteria validateurCriterion(String codeTypeFichier) {
        SearchCriteria criterion = new SearchCriteria();
        criterion.setFieldName("codeTypeFichier");
        criterion.setFieldType(String.class);
        criterion.setFieldValue(codeTypeFichier);
        criterion.setOperateur(Operateur.EQUALS);

        return criterion;
    }

    private void parseFile() throws Exception {
        Configuration config = ConfigurationService.getInstance().getCurrentConfig();
        List<ColumnDefinition> colDefs = new ArrayList<>();

        if (getCurrentObject().getValidateurPath()!= null) {
            colDefs = ValidateurParser.retrieveFieldsFromValidator(new File(getCurrentObject().getValidateurPath()), getCurrentObject().getTypeFichier().getCode());
        } else {
            ParserUtils.getValidateurElements(getCurrentObject().getValidateurBytes());
        }
        parseFile(getCurrentObject(), config, colDefs);
    }

    private void parseFile(DataFileToJson txtFileToJson, Configuration config, List<ColumnDefinition> colDefs) throws Exception {
        String fileName = (new File(txtFileToJson.getFileToConvertPath())).getName();
        int index = fileName.lastIndexOf(".");
        fileName = fileName.substring(0, index);
        File outputFile = new File(config.getDatasDir(), fileName + ".json");
        FileToValidateDescription fileDesc = null;

        if (!txtFileToJson.getDataType().equals(DataType.TXT)) {
            fileDesc = new FileToValidateDescription(new File(txtFileToJson.getFileToConvertPath()),
                    txtFileToJson.getDelimiteurLigne().getCode(),
                    txtFileToJson.getDelimiteurColonne().getCode());
        }

        switch (txtFileToJson.getDataType()) {
            case CSV:
                ExportToJson.parseCsvFile(fileDesc, outputFile, colDefs, txtFileToJson.isHeaderPresent());
                break;
            case TXT:
                ExportToJson.parseFileByColumnLength(
                        new FileToValidateDescription(new File(txtFileToJson.getFileToConvertPath()), "", ""),
                        outputFile, colDefs);
                break;
            case XLS:
                ExportToJson.parseXlsFile(fileDesc, outputFile, colDefs, txtFileToJson.isHeaderPresent());
                break;
            case XLSX:
                ExportToJson.parseXlsxFile(fileDesc, outputFile, colDefs, txtFileToJson.isHeaderPresent());
                break;
            default:
                throw new Exception("Type de données non supporté");
        }
    }

}