package com.megatim.fdxconvert.viewmodel;
|
|
import com.megatim.dynamicjsonparser.enums.TypeDonnee;
|
import com.megatim.fdxconvert.App;
|
import com.megatim.fdxconvert.dao.JsonStructureDAO;
|
import com.megatim.fdxconvert.model.JsonStructure;
|
import com.megatim.fdxconvert.model.TypeFichierJson;
|
import com.megatim.fdxconvert.service.TypeFichierJsonService;
|
import javafx.application.Platform;
|
import javafx.beans.binding.Bindings;
|
import javafx.beans.binding.StringBinding;
|
import javafx.beans.property.*;
|
import javafx.collections.FXCollections;
|
import javafx.collections.ObservableList;
|
import javafx.concurrent.Task;
|
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.function.Consumer;
|
|
public class JsonStructureTableViewModel {
|
|
private final ObservableList<TypeFichierJson> data = FXCollections.observableArrayList();
|
private final ObjectProperty<TypeFichierJson> selectedItem = new SimpleObjectProperty<>(null);
|
|
private final BooleanProperty loading = new SimpleBooleanProperty(false);
|
private final IntegerProperty pageNumber = new SimpleIntegerProperty(0);
|
private final LongProperty totalElements = new SimpleLongProperty(0);
|
private final LongProperty numberPerPage = new SimpleLongProperty(0);
|
private final BooleanProperty last = new SimpleBooleanProperty(false);
|
private final BooleanProperty first = new SimpleBooleanProperty(false);
|
|
private final StringBinding paginationNumberInfo = Bindings.createStringBinding(() -> evalString(), pageNumber, numberPerPage, totalElements);
|
|
public void init() {
|
loadData(pageNumber.get());
|
pageNumber.addListener((observable, oldValue, newValue) -> {
|
loadData(newValue.intValue());
|
});
|
}
|
|
public void reloadData() {
|
loadData(pageNumber.get());
|
}
|
|
public void loadSelectedItemChildren(Consumer<TypeFichierJson> consumer) {
|
Task<JsonStructure> task = new Task<JsonStructure>() {
|
@Override
|
protected JsonStructure call() throws Exception {
|
loading.set(true);
|
JsonStructure jsonStructure = JsonStructureDAO.loadSubJsonStructure(selectedItem.get().getJsonStructure());
|
setDelimiteurDate(jsonStructure.getFields());
|
return jsonStructure;
|
}
|
};
|
task.setOnSucceeded(e -> {
|
loading.set(false);
|
selectedItem.get().setJsonStructure(task.getValue());
|
consumer.accept(selectedItem.get());
|
});
|
task.setOnFailed(e -> loading.set(false));
|
task.setOnCancelled(e -> loading.set(false));
|
Thread thread = new Thread(task);
|
thread.setDaemon(true);
|
thread.start();
|
}
|
|
public void deleteSelectedItem() {
|
Task<Void> task = new Task<Void>() {
|
@Override
|
protected Void call() throws Exception {
|
loading.set(true);
|
TypeFichierJsonService.getInstance().delete(selectedItem.get());
|
return null;
|
}
|
};
|
task.setOnSucceeded(e -> {
|
loading.set(false);
|
pageNumber.set(0);
|
loadData(pageNumber.get());
|
});
|
task.setOnFailed(e -> loading.set(false));
|
task.setOnCancelled(e -> loading.set(false));
|
Thread thread = new Thread(task);
|
thread.setDaemon(true);
|
thread.start();
|
}
|
|
public void nextPage() {
|
if (!last.get()) {
|
pageNumber.set(pageNumber.get() + 1);
|
}
|
}
|
|
public void previousPage() {
|
if (!first.get()) {
|
pageNumber.set(pageNumber.get() - 1);
|
}
|
}
|
|
private void setDelimiteurDate(List<JsonStructure> jsonStructures) {
|
jsonStructures.stream().forEach(j -> {
|
if (j.getTypeDonnee().equals(TypeDonnee.OBJET)) {
|
setDelimiteurDate(j.getFields());
|
} else if (j.getTypeDonnee().equals(TypeDonnee.DATE) && j.getCodeDelimiteurDate() != null) {
|
j.setDelimiteurDate(App.SEPARATEURS_DATE.get(j.getCodeDelimiteurDate()));
|
}
|
});
|
}
|
|
private void loadData(int page) {
|
|
Task<Void> task = new Task<Void>() {
|
@Override
|
protected Void call() throws Exception {
|
|
loading.set(true);
|
|
List<TypeFichierJson> typeFichierJsons = TypeFichierJsonService.getInstance().getAllByPage(page, Arrays.asList());
|
|
Platform.runLater(() -> {
|
data.clear();
|
data.addAll(typeFichierJsons);
|
totalElements.set(TypeFichierJsonService.getInstance().getTotalElements());
|
numberPerPage.set(TypeFichierJsonService.getInstance().getNumberPerPage());
|
last.set(TypeFichierJsonService.getInstance().isLast());
|
first.set(TypeFichierJsonService.getInstance().isFirst());
|
});
|
|
return null;
|
}
|
};
|
|
task.setOnSucceeded(e -> loading.set(false));
|
task.setOnFailed(e -> loading.set(false));
|
task.setOnCancelled(e -> loading.set(false));
|
Thread thread = new Thread(task);
|
thread.setDaemon(true);
|
thread.start();
|
|
}
|
|
public ObservableList<TypeFichierJson> getData() {
|
return data;
|
}
|
|
public BooleanProperty getLoadingProperty() {
|
return loading;
|
}
|
|
public StringBinding getPaginationNumberInfo() {
|
return paginationNumberInfo;
|
}
|
|
public BooleanProperty getLastProperty() {
|
return last;
|
}
|
|
public BooleanProperty getFirstProperty() {
|
return first;
|
}
|
|
public ObjectProperty<TypeFichierJson> selectedItemProperty() {
|
return selectedItem;
|
}
|
|
private String evalString() {
|
long currentNumber = (pageNumber.get() + 1) * numberPerPage.get();
|
return (currentNumber < totalElements.get() ? currentNumber : totalElements.get()) + "/" + totalElements.get();
|
}
|
}
|
