/*
 * 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.fdxcommons.tools.database.contrat;

import com.megatim.fdxcommons.model.pojo.JsonTableDefinition;
import com.megatim.fdxcommons.model.enumeration.TypeDonnee;
import com.megatim.fdxcommons.model.integration.ColumnDefinition;
import com.megatim.fdxcommons.model.integration.json.JsonStructure;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

/**
 *
 * @author ASUS
 */
public class JsonStructureIterator {

    private final JsonStructure jsonStructure;
    private final String tableName;

    public JsonStructureIterator(String tableName, JsonStructure jsonStructure) {
        this.jsonStructure = jsonStructure;
        this.tableName = tableName;
    }

    /**
     * ColumnDefinition mais avec le nom complet de la colonne (exples :
     * adresse.ville, cpteBanque.rib pour les colonnes de niveau 2)
     *
     * @return
     */
    public List<ColumnDefinition> columnsDefinitionWithFullQualifiedName() {
        List<ColumnDefinition> columnsDefinition = new ArrayList<>();

        List<JsonStructure> fields = jsonStructure.getFields();
        List<JsonStructure> fieldsWithoutParent = fields.stream().filter(f -> !f.getTypeDonnee().equals(TypeDonnee.OBJET)).collect(Collectors.toList());
        List<JsonStructure> fieldsWithParent = fields.stream().filter(f -> f.getTypeDonnee().equals(TypeDonnee.OBJET)).collect(Collectors.toList());

        columnsDefinition.addAll(columnsDefinitionWithFullQualifiedName(fieldsWithoutParent, ""));
        fieldsWithParent.stream().forEach(j -> columnsDefinition.addAll(columnsDefinitionWithFullQualifiedName(j, "")));

        return columnsDefinition;
    }

    public JsonTableDefinition tableDefinition() throws SQLException {
        List<JsonStructure> fields = jsonStructure.getFields();

        List<JsonStructure> simpleFields = fields.stream().filter(f -> !f.isCollection() && !f.getTypeDonnee().equals(TypeDonnee.OBJET)).collect(Collectors.toList());
        JsonTableDefinition tableDefinition = new JsonTableDefinition(tableName.toLowerCase(), columnsDefinition(simpleFields), null, "");

        List<JsonStructure> objectFields = fields.stream().filter(f -> f.isCollection() || f.getTypeDonnee().equals(TypeDonnee.OBJET)).collect(Collectors.toList());

        for (JsonStructure j : objectFields) {
            tableDefinition.getTablesDefinition().add(tableDefinition(j, tableName, j.getName()));
        }
        return tableDefinition;
    }

    private List<ColumnDefinition> columnsDefinitionWithFullQualifiedName(JsonStructure jsonStructure, String parentFullQualifiedName) {
        List<ColumnDefinition> columnsDefinition = new ArrayList<>();

        for (JsonStructure j : jsonStructure.getFields()) {
            if (j.getTypeDonnee().equals(TypeDonnee.OBJET)) {
                if (parentFullQualifiedName.isEmpty()) {
                    columnsDefinition.addAll(columnsDefinitionWithFullQualifiedName(j, jsonStructure.getName()));
                } else {
                    columnsDefinition.addAll(columnsDefinitionWithFullQualifiedName(j, parentFullQualifiedName + "." + jsonStructure.getName()));
                }
            } else {
                if (parentFullQualifiedName.isEmpty()) {
                    columnsDefinition.add(columnDefinitionWithFullQualifiedName(j, jsonStructure.getName()));
                } else {
                    columnsDefinition.add(columnDefinitionWithFullQualifiedName(j, parentFullQualifiedName + "." + jsonStructure.getName()));
                }

            }
        }
        return columnsDefinition;
    }

    private JsonTableDefinition tableDefinition(JsonStructure jsonStruct, String parentTableName, String parentFieldName) {
        JsonTableDefinition tableDef = null;

        if (jsonStruct.getTypeDonnee().equals(TypeDonnee.OBJET)) {
            List<JsonStructure> simpleFields = jsonStruct.getFields().stream().filter(f -> !f.isCollection() && !f.getTypeDonnee().equals(TypeDonnee.OBJET)).collect(Collectors.toList());
            tableDef = new JsonTableDefinition((parentTableName + "_" + jsonStruct.getName()).toLowerCase(), columnsDefinition(simpleFields), parentTableName.toLowerCase(), parentFieldName);

            List<JsonStructure> objectFields = jsonStruct.getFields().stream().filter(f -> f.isCollection() || f.getTypeDonnee().equals(TypeDonnee.OBJET)).collect(Collectors.toList());

            for (JsonStructure j : objectFields) {
                String newParentTableName = parentTableName.isEmpty() ? jsonStruct.getName() : parentTableName + "_" + jsonStruct.getName();
                String newParentFieldName = parentFieldName.isEmpty() ? jsonStruct.getName() : parentFieldName + "." + j.getName();
                tableDef.getTablesDefinition().add(tableDefinition(j, newParentTableName, newParentFieldName));
            }
        } else if (jsonStruct.isCollection()) {
            tableDef = new JsonTableDefinition((parentTableName + "_" + jsonStruct.getName()).toLowerCase(), columnsDefinition(Arrays.asList(jsonStruct)), parentTableName.toLowerCase(), parentFieldName);
        }
        return tableDef;
    }

    private List<ColumnDefinition> columnsDefinition(List<JsonStructure> fields) {
        List<ColumnDefinition> columnsDefinition = new ArrayList<>();
        fields.stream().forEach(f -> columnsDefinition.add(new ColumnDefinition(f.getName(), f.getTypeDonnee().name(), f.getLengthh(), f.isRequired(), f.isCollection())));

        return columnsDefinition;
    }

    private List<ColumnDefinition> columnsDefinitionWithFullQualifiedName(List<JsonStructure> fields, String parentFullQualifiedName) {
        List<ColumnDefinition> columnsDefinition = new ArrayList<>();
        fields.stream().forEach(f -> {
            if (parentFullQualifiedName.isEmpty()) {
                columnsDefinition.add(new ColumnDefinition(f.getName(), f.getTypeDonnee().name(), f.getLengthh(), f.isRequired(), f.isCollection()));
            } else {
                columnsDefinition.add(new ColumnDefinition(parentFullQualifiedName + "." + f.getName(), f.getTypeDonnee().name(), f.getLengthh(), f.isRequired(), f.isCollection()));
            }
        }
        );

        return columnsDefinition;
    }

    private ColumnDefinition columnDefinitionWithFullQualifiedName(JsonStructure f, String parentFullQualifiedName) {
        if (parentFullQualifiedName.isEmpty()) {
            return new ColumnDefinition(f.getName(), f.getTypeDonnee().name(), f.getLengthh(), f.isRequired(), f.isCollection());
        } else {
            return new ColumnDefinition(parentFullQualifiedName + "." + f.getName(), f.getTypeDonnee().name(), f.getLengthh(), f.isRequired(), f.isCollection());
        }

    }
}