/*
|
* 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.queries.metadata;
|
|
import com.megatim.fdxcommons.model.enumeration.TypeDonnee;
|
import com.megatim.fdxcommons.model.integration.json.JsonStructure;
|
import com.megatim.fdxcommons.model.pojo.JsonColumnDefinition;
|
import com.megatim.fdxcommons.tools.database.exceptions.BadDataValueException;
|
import com.megatim.fdxcommons.tools.database.exceptions.ColumnNotFoundException;
|
import com.megatim.fdxcommons.tools.database.exceptions.LocalDateTimeValueParseError;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.HashSet;
|
import java.util.LinkedHashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
import org.apache.commons.validator.GenericValidator;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
public class JsonFdxParsedDataRow {
|
|
private final Map<String, Object> data;
|
private final Map<String, Object> row = new LinkedHashMap<>();
|
private final Map<String, JsonColumnDefinition> columnNameToColumnDefinition = new HashMap<>();
|
|
public JsonFdxParsedDataRow(Map<String, Object> data, JsonStructure jsonStructure) {
|
this.data = data;
|
columnNameToJsonColumnDefinition(jsonStructure);
|
}
|
|
public Map<String, Object> dataRow() throws ColumnNotFoundException, BadDataValueException, LocalDateTimeValueParseError {
|
Set<String> foundColumns = new HashSet<>();
|
|
if (row.isEmpty()) {
|
|
for (Map.Entry<String, Object> entry : data.entrySet()) {
|
|
String key = entry.getKey();
|
Object value = entry.getValue();
|
|
JsonColumnDefinition jsonColumnDefinition = columnNameToColumnDefinition.get(key.trim().toLowerCase());
|
|
if (jsonColumnDefinition == null) {
|
throw new ColumnNotFoundException("La colonne " + key + " n'est pas une colonne de ce type de fichier");
|
}
|
foundColumns.add(key.toLowerCase());
|
|
if (value == null) {
|
|
if (jsonColumnDefinition.isRequired()) {
|
throw new BadDataValueException("La valeur de la colonne " + jsonColumnDefinition.getName() + " est obligatoire");
|
}
|
return row;
|
}
|
if (jsonColumnDefinition.getTypeDonnee().equals(TypeDonnee.OBJET)) {
|
if (jsonColumnDefinition.isCollection()) {
|
if (value instanceof List) {
|
List<Object> objectsList = (List<Object>) value;
|
List<Object> parsedValues = new ArrayList<>();
|
int i = 0;
|
|
for (Object obj : objectsList) {
|
parsedValues.add(dataRow((Map<String, Object>) obj, jsonColumnDefinition.getColumnNameToColumnDefinition(), jsonColumnDefinition.getName(), i + 1));
|
i++;
|
}
|
row.put(key.trim(), parsedValues);
|
} else {
|
throw new BadDataValueException("La valeur de la colonne " + jsonColumnDefinition.getName() + " doit être une liste de données");
|
}
|
} else {
|
row.put(key.trim(), dataRow((Map<String, Object>) value, jsonColumnDefinition.getColumnNameToColumnDefinition(), jsonColumnDefinition.getName(), 0));
|
}
|
} else {
|
if (jsonColumnDefinition.isCollection()) {
|
if (value instanceof List) {
|
List<Object> objectsList = (List<Object>) value;
|
List<Object> parsedValues = new ArrayList<>();
|
int i = 0;
|
|
for (Object obj : objectsList) {
|
parsedValues.add(parse(jsonColumnDefinition, obj, "", i + 1));
|
i++;
|
}
|
row.put(key.trim(), parsedValues);
|
} else {
|
throw new BadDataValueException("La valeur de la colonne " + jsonColumnDefinition.getName() + " doit être un tableau de données");
|
}
|
} else {
|
row.put(key.trim(), parse(jsonColumnDefinition, value, "", 0));
|
}
|
}
|
}
|
//Cherche les colonnes obligatoires qui sont absentes
|
stopIfRequiredColumnIsAbsent(foundColumns, columnNameToColumnDefinition, "");
|
}
|
return row;
|
}
|
|
private void columnNameToJsonColumnDefinition(JsonStructure jsonStructure) {
|
for (JsonStructure j : jsonStructure.getFields()) {
|
if (j.getTypeDonnee().equals(TypeDonnee.OBJET)) {
|
JsonColumnDefinition jsonCol = new JsonColumnDefinition(j.getTypeDonnee(), j.getName(), j.getLengthh(), j.getFormatDate(), j.isRequired(), j.isCollection());
|
|
for (JsonStructure field : j.getFields()) {
|
jsonCol.getColumnNameToColumnDefinition().put(field.getName().toLowerCase(), jsonColumnDefinition(field));
|
}
|
columnNameToColumnDefinition.put(j.getName().toLowerCase(), jsonCol);
|
} else {
|
columnNameToColumnDefinition.put(j.getName().toLowerCase(), new JsonColumnDefinition(j.getTypeDonnee(), j.getName(), j.getLengthh(), j.getFormatDate(), j.isRequired(), j.isCollection()));
|
}
|
}
|
}
|
|
private JsonColumnDefinition jsonColumnDefinition(JsonStructure jsonStruct) {
|
JsonColumnDefinition jsonCol = new JsonColumnDefinition(jsonStruct.getTypeDonnee(), jsonStruct.getName(), jsonStruct.getLengthh(), jsonStruct.getFormatDate(), jsonStruct.isRequired(), jsonStruct.isCollection());
|
|
if (jsonStruct.getTypeDonnee().equals(TypeDonnee.OBJET)) {
|
for (JsonStructure j : jsonStruct.getFields()) {
|
jsonCol.getColumnNameToColumnDefinition().put(j.getName().toLowerCase(), jsonColumnDefinition(j));
|
}
|
}
|
return jsonCol;
|
}
|
|
private Map<String, Object> dataRow(Map<String, Object> subData, Map<String, JsonColumnDefinition> subColumnNameToColumnDefinition, String parentName, int rangElement) throws ColumnNotFoundException, BadDataValueException, LocalDateTimeValueParseError {
|
Map<String, Object> subRow = new LinkedHashMap<>();
|
Set<String> foundColumns = new HashSet<>();
|
|
for (Map.Entry<String, Object> entry : subData.entrySet()) {
|
|
String key = entry.getKey();
|
Object value = entry.getValue();
|
|
JsonColumnDefinition jsonColumnDefinition = subColumnNameToColumnDefinition.get(key.trim().toLowerCase());
|
|
if (jsonColumnDefinition == null) {
|
throw new ColumnNotFoundException("La colonne " + key + " n'est pas présente pour ce fichier");
|
}
|
foundColumns.add(key.toLowerCase());
|
|
if (value == null) {
|
|
if (jsonColumnDefinition.isRequired()) {
|
throw new BadDataValueException("La valeur de la colonne " + jsonColumnDefinition.getName() + " est obligatoire");
|
}
|
return subRow;
|
}
|
|
if (jsonColumnDefinition.getTypeDonnee().equals(TypeDonnee.OBJET)) {
|
parentName += "." + jsonColumnDefinition.getName();
|
|
if (jsonColumnDefinition.isCollection()) {
|
if (value instanceof List) {
|
List<Object> objectsList = (List<Object>) value;
|
List<Object> parsedValues = new ArrayList<>();
|
int i = 0;
|
|
for (Object obj : objectsList) {
|
parsedValues.add(dataRow((Map<String, Object>) obj, jsonColumnDefinition.getColumnNameToColumnDefinition(), parentName, rangElement));
|
i++;
|
}
|
subRow.put(key.trim(), parsedValues);
|
} else {
|
throw new BadDataValueException("La valeur de la colonne " + jsonColumnDefinition.getName() + " doit être une liste de données");
|
}
|
} else {
|
subRow.put(key.trim(), dataRow((Map<String, Object>) value, jsonColumnDefinition.getColumnNameToColumnDefinition(), parentName, rangElement));
|
}
|
} else {
|
if (jsonColumnDefinition.isCollection()) {
|
if (value instanceof List) {
|
List<Object> objectsList = (List<Object>) value;
|
List<Object> parsedValues = new ArrayList<>();
|
int i = 0;
|
|
for (Object obj : objectsList) {
|
parsedValues.add(parse(jsonColumnDefinition, obj, "", i + 1));
|
i++;
|
}
|
subRow.put(key.trim(), parsedValues);
|
} else {
|
throw new BadDataValueException("La valeur de la colonne " + jsonColumnDefinition.getName() + " doit être un tableau de données");
|
}
|
} else {
|
subRow.put(key.trim(), parse(jsonColumnDefinition, value, parentName, rangElement));
|
}
|
}
|
}
|
//Cherche les colonnes obligatoires qui sont absentes
|
stopIfRequiredColumnIsAbsent(foundColumns, subColumnNameToColumnDefinition, parentName);
|
|
return subRow;
|
}
|
|
private Object parse(JsonColumnDefinition columnDefinition, Object value, String parentName, int rangElement) throws BadDataValueException, LocalDateTimeValueParseError {
|
|
TypeDonnee typeDonnee = columnDefinition.getTypeDonnee();
|
|
if (typeDonnee.equals(TypeDonnee.ALPHANUMERIQUE) && (value == null
|
|| (value instanceof String && lengthLowerOrEquals((String) value, columnDefinition.getLengthh())))) {
|
|
return value != null ? value.toString().trim() : value;
|
|
} else if (typeDonnee.equals(TypeDonnee.NUMERIQUE)) {
|
|
if (value == null) {
|
return 0L;
|
}
|
|
String stringValue = value.toString();
|
if (lengthLowerOrEquals(stringValue, columnDefinition.getLengthh()) && GenericValidator.isLong(stringValue)) {
|
return Long.valueOf(stringValue);
|
}
|
|
} else if (typeDonnee.equals(TypeDonnee.DECIMAL)) {
|
|
if (value == null) {
|
return 0.0;
|
}
|
|
String stringValue = value.toString();
|
if (lengthLowerOrEquals(stringValue, columnDefinition.getLengthh()) && GenericValidator.isDouble(stringValue)) {
|
return Double.valueOf(stringValue);
|
}
|
|
} else if (typeDonnee.equals(TypeDonnee.DATE)) {
|
|
if (value == null) {
|
return null;
|
}
|
String stringValue = value.toString();
|
|
if (lengthEquals(stringValue, columnDefinition.getLengthh()) && GenericValidator.isDate(stringValue, columnDefinition.getFormatDate(), true)) {
|
return new InsertionLocalDateTimeValue(columnDefinition.getFormatDate(), value).value();
|
}
|
}
|
String rangDescription = rangElement == 0 ? "" : "le " + rangElement + "ème élément de ";
|
String fullQualifiedNameOfColumn = parentName == null || parentName.isEmpty() ? columnDefinition.getName() : parentName + "." + columnDefinition.getName();
|
|
throw new BadDataValueException("La valeur " + value + " ne correspond pas au format attendu pour " + rangDescription + " la colonne " + fullQualifiedNameOfColumn);
|
}
|
|
private boolean lengthEquals(String value, int columnMaxLength) {
|
return value.trim().length() == columnMaxLength;
|
}
|
|
private boolean lengthLowerOrEquals(String value, int columnMaxLength) {
|
return value.trim().length() <= columnMaxLength;
|
}
|
|
private void stopIfRequiredColumnIsAbsent(Set<String> foundColumns, Map<String, JsonColumnDefinition> allColumns, String parentName) throws BadDataValueException {
|
|
for (String columnName : allColumns.keySet()) {
|
String fullQualifiedName = parentName.isEmpty() ? columnName : parentName + "." + columnName;
|
|
if (allColumns.get(columnName).isRequired() && !foundColumns.contains(columnName.toLowerCase())) {
|
throw new BadDataValueException("La valeur de la colonne " + fullQualifiedName + " est obligatoire");
|
}
|
}
|
}
|
}
|
