551 lines
14 KiB
Java
551 lines
14 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.portlets.user.td.client;
|
|
|
|
import org.gcube.portlets.user.sdmxexportwizardtd.client.SDMXExportWizardTD;
|
|
import org.gcube.portlets.user.sdmximportwizardtd.client.SDMXImportWizardTD;
|
|
import org.gcube.portlets.user.sdmximportwizardtd.client.general.WizardListener;
|
|
import org.gcube.portlets.user.td.ciw.client.CSVImporterWidget;
|
|
import org.gcube.portlets.user.td.client.event.CloseTabularResourceEvent;
|
|
import org.gcube.portlets.user.td.client.event.CloseTabularResourceType;
|
|
import org.gcube.portlets.user.td.client.event.ExportTableEvent;
|
|
import org.gcube.portlets.user.td.client.event.ExportTableType;
|
|
import org.gcube.portlets.user.td.client.event.ImportTableEvent;
|
|
import org.gcube.portlets.user.td.client.event.ImportTableType;
|
|
import org.gcube.portlets.user.td.client.event.OpenFunctionalityEvent;
|
|
import org.gcube.portlets.user.td.client.event.OpenFunctionalityType;
|
|
import org.gcube.portlets.user.td.client.event.OpenTabularResourceEvent;
|
|
import org.gcube.portlets.user.td.client.event.OpenTabularResourceType;
|
|
import org.gcube.portlets.user.td.gxtservice.shared.TRId;
|
|
import org.gcube.portlets.user.td.importer.client.TabularDataImporterListener;
|
|
import org.gcube.portlets.user.td.information.client.TabularResourceProperties;
|
|
import org.gcube.portlets.user.td.open.client.TDOpen;
|
|
import org.gcube.portlets.user.tdw.client.TabularData;
|
|
import org.gcube.portlets.user.tdw.shared.model.TableId;
|
|
|
|
import com.allen_sauer.gwt.log.client.Log;
|
|
import com.google.gwt.core.client.GWT;
|
|
import com.google.gwt.core.client.RunAsyncCallback;
|
|
import com.google.gwt.user.client.ui.Widget;
|
|
import com.google.web.bindery.event.shared.EventBus;
|
|
import com.google.web.bindery.event.shared.SimpleEventBus;
|
|
import com.sencha.gxt.widget.core.client.ContentPanel;
|
|
import com.sencha.gxt.widget.core.client.TabItemConfig;
|
|
import com.sencha.gxt.widget.core.client.TabPanel;
|
|
import com.sencha.gxt.widget.core.client.container.BorderLayoutContainer.BorderLayoutData;
|
|
import com.sencha.gxt.widget.core.client.event.BeforeCloseEvent;
|
|
import com.sencha.gxt.widget.core.client.event.BeforeCloseEvent.BeforeCloseHandler;
|
|
import com.sencha.gxt.widget.core.client.info.Info;
|
|
|
|
/**
|
|
* @author "Federico De Faveri defaveri@isti.cnr.it"
|
|
*
|
|
*/
|
|
public class TabularDataController {
|
|
// implements HasCloseHandlers<Long>, HasOpenHandlers<Long> {
|
|
|
|
protected SimpleEventBus eventBus;
|
|
protected TabularData tabularData;
|
|
protected UIState uiState = UIState.START;
|
|
protected UIProperties uiProperties = UIProperties.CLOSED;
|
|
|
|
protected ContentPanel functionalityPanel;
|
|
protected TabPanel functionalityTab;
|
|
protected int indexFunctionalityTab = 0;
|
|
protected TabularResourceProperties trProperties;
|
|
protected BorderLayoutData eastData;
|
|
|
|
/**
|
|
* Tabular Resource Id
|
|
*/
|
|
protected TRId trId;
|
|
|
|
/**
|
|
* Grid TableId
|
|
*/
|
|
protected TableId tableOpening;
|
|
|
|
public TabularDataController() {
|
|
eventBus = new SimpleEventBus();
|
|
bindToEvents();
|
|
}
|
|
|
|
/**
|
|
* @return the eventBus
|
|
*/
|
|
public EventBus getEventBus() {
|
|
return eventBus;
|
|
}
|
|
|
|
public void setTabularData(TabularData tabularData) {
|
|
this.tabularData = tabularData;
|
|
}
|
|
|
|
public ContentPanel getFunctionalityPanel() {
|
|
return functionalityPanel;
|
|
}
|
|
|
|
public void setFunctionalityPanel(ContentPanel functionalityPanel) {
|
|
this.functionalityPanel = functionalityPanel;
|
|
}
|
|
|
|
public TabPanel getFunctionalityTab() {
|
|
return functionalityTab;
|
|
}
|
|
|
|
public void setFunctionalityTab(TabPanel functionalityTab) {
|
|
this.functionalityTab = functionalityTab;
|
|
}
|
|
|
|
public BorderLayoutData getEastData() {
|
|
return eastData;
|
|
}
|
|
|
|
public void setEastData(BorderLayoutData eastData) {
|
|
this.eastData = eastData;
|
|
}
|
|
|
|
protected void bindToEvents() {
|
|
eventBus.addHandler(ImportTableEvent.TYPE,
|
|
new ImportTableEvent.ImportTableHandler() {
|
|
|
|
@Override
|
|
public void onImportTable(ImportTableEvent event) {
|
|
doImportTable(event.getImportType());
|
|
}
|
|
});
|
|
eventBus.addHandler(ExportTableEvent.TYPE,
|
|
new ExportTableEvent.ExportTableHandler() {
|
|
|
|
@Override
|
|
public void onExportTable(ExportTableEvent event) {
|
|
doExportTable(event.getExportType());
|
|
}
|
|
});
|
|
eventBus.addHandler(OpenTabularResourceEvent.TYPE,
|
|
new OpenTabularResourceEvent.OpenTabularResourceHandler() {
|
|
|
|
@Override
|
|
public void onOpenTabularResource(
|
|
OpenTabularResourceEvent event) {
|
|
doOpenTabularResource(event.getOpenType());
|
|
}
|
|
});
|
|
eventBus.addHandler(CloseTabularResourceEvent.TYPE,
|
|
new CloseTabularResourceEvent.CloseTabularResourceHandler() {
|
|
|
|
@Override
|
|
public void onCloseTabularResource(
|
|
CloseTabularResourceEvent event) {
|
|
doCloseTabularResource(event.getCloseType());
|
|
}
|
|
});
|
|
eventBus.addHandler(OpenFunctionalityEvent.TYPE,
|
|
new OpenFunctionalityEvent.OpenFunctionalityHandler() {
|
|
|
|
@Override
|
|
public void onOpenFunctionality(OpenFunctionalityEvent event) {
|
|
doOpenFunctionality(event.getOpenFunctionalityType());
|
|
}
|
|
});
|
|
|
|
}
|
|
|
|
public void doImportTable(ImportTableType importType) {
|
|
Log.trace("doImportTable importType: " + importType);
|
|
Info.display("Import Tabular Resource", "type: " + importType);
|
|
try {
|
|
switch (importType) {
|
|
case SDMX:
|
|
openSDMXImportWizard();
|
|
break;
|
|
case CSV:
|
|
openCSVImportWizard();
|
|
break;
|
|
case JSON:
|
|
openCSVImportWizard();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
} catch (Exception e) {
|
|
Log.error("doImportTable Error : " + e.getLocalizedMessage()
|
|
+ " \n " + e.getMessage());
|
|
}
|
|
}
|
|
|
|
public void doExportTable(ExportTableType exportType) {
|
|
Log.trace("doExportTable importType: " + exportType);
|
|
Info.display("Export Tabular Resource", "type: " + exportType);
|
|
try {
|
|
switch (exportType) {
|
|
case SDMX:
|
|
openSDMXExportWizard();
|
|
break;
|
|
case CSV:
|
|
openSDMXExportWizard();
|
|
break;
|
|
case JSON:
|
|
openSDMXExportWizard();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
} catch (Exception e) {
|
|
Log.error("doImportTable Error : " + e.getLocalizedMessage()
|
|
+ " \n " + e.getMessage());
|
|
}
|
|
}
|
|
|
|
public void doOpenTabularResource(OpenTabularResourceType openType) {
|
|
Log.trace("doOpenTabularResource openType: " + openType);
|
|
Info.display("Open Tabular Resource", "open: " + openType);
|
|
try {
|
|
switch (openType) {
|
|
case TABLE:
|
|
openTabularResources();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
} catch (Exception e) {
|
|
Log.error("doOpenTable Error : " + e.getLocalizedMessage() + " \n "
|
|
+ e.getMessage());
|
|
}
|
|
}
|
|
|
|
public void doCloseTabularResource(CloseTabularResourceType closeType) {
|
|
Log.trace("doCloseTabularResource closeType: " + closeType);
|
|
Info.display("Close Tabular Resource", "close: " + closeType);
|
|
try {
|
|
switch (closeType) {
|
|
case TABLE:
|
|
closeTabularResources();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
} catch (Exception e) {
|
|
Log.error("doOpenTable Error : " + e.getLocalizedMessage() + " \n "
|
|
+ e.getMessage());
|
|
}
|
|
}
|
|
|
|
public void doOpenFunctionality(OpenFunctionalityType openType) {
|
|
Log.trace("doOpenFunctionality openType: " + openType);
|
|
try {
|
|
switch (openType) {
|
|
case PROPERTIES:
|
|
openFunctionalityProperties();
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
} catch (Exception e) {
|
|
Log.error("doOpenFunctionality Error : " + e.getLocalizedMessage());
|
|
e.printStackTrace();
|
|
}
|
|
}
|
|
|
|
protected void openFunctionalityProperties() {
|
|
if (uiState == UIState.TR_OPEN) {
|
|
if (uiProperties == UIProperties.OPENED) {
|
|
functionalityPanel.collapse();
|
|
functionalityPanel.disable();
|
|
uiProperties=UIProperties.CLOSED;
|
|
functionalityTab.remove(trProperties);
|
|
Info.display("Properties", "Closed");
|
|
} else {
|
|
TabItemConfig propertiesItemConf = new TabItemConfig(
|
|
"Properties", true);
|
|
|
|
|
|
trProperties = new TabularResourceProperties(
|
|
"TRProperties", eventBus, trId);
|
|
trProperties.setHeaderVisible(false);
|
|
functionalityTab.add(trProperties, propertiesItemConf);
|
|
functionalityTab
|
|
.addBeforeCloseHandler(new BeforeCloseHandler<Widget>() {
|
|
|
|
@Override
|
|
public void onBeforeClose(
|
|
BeforeCloseEvent<Widget> event) {
|
|
if (functionalityTab.getWidgetCount() == 1) {
|
|
functionalityPanel.disable();
|
|
functionalityPanel.collapse();
|
|
uiProperties=UIProperties.CLOSED;
|
|
functionalityTab.remove(trProperties);
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
/*Label taskLabel = new Label("Task Properties");
|
|
taskLabel.addStyleName("pad-text");
|
|
functionalityTab
|
|
.add(taskLabel, new TabItemConfig("Task", true));
|
|
|
|
*/
|
|
functionalityTab.setActiveWidget(functionalityTab.getWidget(0));
|
|
|
|
|
|
|
|
functionalityPanel.enable();
|
|
functionalityPanel.expand();
|
|
uiProperties=UIProperties.OPENED;
|
|
|
|
}
|
|
} else {
|
|
Info.display("Properties", "No table open");
|
|
}
|
|
};
|
|
|
|
protected void openSDMXImportWizard() {
|
|
|
|
GWT.runAsync(new RunAsyncCallback() {
|
|
|
|
@Override
|
|
public void onSuccess() {
|
|
SDMXImportWizardTD importWizard = new SDMXImportWizardTD(
|
|
"SDMX Import");
|
|
|
|
importWizard.addListener(new WizardListener() {
|
|
|
|
@Override
|
|
public void completed(TRId tabularResourceId) {
|
|
trId = tabularResourceId;
|
|
tableOpening = new TableId(
|
|
Constants.TD_DATASOURCE_FACTORY_ID, trId
|
|
.getTableId());
|
|
tabularData.openTable(tableOpening);
|
|
uiState = UIState.TR_OPEN;
|
|
|
|
}
|
|
|
|
@Override
|
|
public void aborted() {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void failed(Throwable throwable, String reason,
|
|
String details) {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
});
|
|
/*
|
|
* importWizard.addWizardSelectionHandler(new
|
|
* WizardSelectionHandler<Dataset>() {
|
|
*
|
|
* @Override public void onSelected(
|
|
* SDMXWizardSelectionEvent<Dataset> event) {
|
|
* doSDMXDatasetImport(event.getSelected()); }
|
|
*
|
|
* @Override public void onClosed(
|
|
* SDMXWizardSelectionEvent<Dataset> event) {
|
|
*
|
|
* } });
|
|
*/
|
|
|
|
importWizard.show();
|
|
}
|
|
|
|
@Override
|
|
public void onFailure(Throwable reason) {
|
|
asyncCodeLoadingFailed(reason);
|
|
}
|
|
});
|
|
|
|
}
|
|
|
|
protected void openSDMXExportWizard() {
|
|
|
|
GWT.runAsync(new RunAsyncCallback() {
|
|
|
|
@Override
|
|
public void onSuccess() {
|
|
SDMXExportWizardTD exportWizard = new SDMXExportWizardTD(
|
|
"SDMX Export");
|
|
|
|
exportWizard
|
|
.addListener(new org.gcube.portlets.user.sdmxexportwizardtd.client.general.WizardListener() {
|
|
|
|
@Override
|
|
public void failed(Throwable throwable,
|
|
String reason, String details) {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void completed(TRId id) {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void aborted() {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
});
|
|
|
|
exportWizard.show();
|
|
}
|
|
|
|
@Override
|
|
public void onFailure(Throwable reason) {
|
|
asyncCodeLoadingFailed(reason);
|
|
}
|
|
});
|
|
|
|
}
|
|
|
|
/**
|
|
*
|
|
*/
|
|
protected void closeTabularResources() {
|
|
if (uiState == UIState.TR_OPEN) {
|
|
tabularData.closeTable();
|
|
uiState = UIState.START;
|
|
if(uiProperties==UIProperties.OPENED){
|
|
functionalityPanel.collapse();
|
|
functionalityPanel.disable();
|
|
uiProperties=UIProperties.CLOSED;
|
|
functionalityTab.remove(trProperties);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
*
|
|
*/
|
|
protected void openTabularResources() {
|
|
|
|
Log.info("Open Tabular Resources");
|
|
|
|
GWT.runAsync(new RunAsyncCallback() {
|
|
|
|
@Override
|
|
public void onSuccess() {
|
|
TDOpen tdOpen = new TDOpen("Tabular Resources Open");
|
|
|
|
tdOpen.addListener(new org.gcube.portlets.user.td.open.client.general.WizardListener() {
|
|
|
|
@Override
|
|
public void aborted() {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void failed(Throwable throwable, String reason,
|
|
String details) {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void completed(TRId tabularResourceId) {
|
|
trId = new TRId(tabularResourceId.getId(),
|
|
tabularResourceId.getTableId());
|
|
tableOpening = new TableId(
|
|
Constants.TD_DATASOURCE_FACTORY_ID, trId
|
|
.getTableId());
|
|
tabularData.openTable(tableOpening);
|
|
uiState = UIState.TR_OPEN;
|
|
|
|
}
|
|
|
|
});
|
|
Log.info("TDOpen add Listener");
|
|
tdOpen.show();
|
|
}
|
|
|
|
@Override
|
|
public void onFailure(Throwable reason) {
|
|
asyncCodeLoadingFailed(reason);
|
|
}
|
|
});
|
|
|
|
}
|
|
|
|
/*
|
|
* protected void doSDMXDatasetImport(List<Dataset> datasets) {
|
|
* Log.info("doSDMXDatasetImport: " + datasets.size()); for (Dataset d :
|
|
* datasets) { Log.info("Dataset: " + d.getId() + d.getName() +
|
|
* d.getAgencyId()); }
|
|
*
|
|
* }
|
|
*/
|
|
|
|
protected void openCSVImportWizard() {
|
|
/*
|
|
* GWT.runAsync(new RunAsyncCallback() {
|
|
*
|
|
* @Override public void onSuccess() {
|
|
*/
|
|
CSVImporterWidget csvImporterWidget = new CSVImporterWidget();
|
|
csvImporterWidget.show(new TabularDataImporterListener() {
|
|
|
|
@Override
|
|
public void failed(Throwable throwable, String reason,
|
|
String details) {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void completed() {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
|
|
@Override
|
|
public void aborted() {
|
|
// TODO Auto-generated method stub
|
|
|
|
}
|
|
});
|
|
|
|
/*
|
|
* }
|
|
*
|
|
* @Override public void onFailure(Throwable reason) {
|
|
* asyncCodeLoadingFailed(reason); } });
|
|
*/
|
|
}
|
|
|
|
protected void asyncCodeLoadingFailed(Throwable reason) {
|
|
Log.error("Async code loading failed", reason);
|
|
Info.display("Async code loading failed",
|
|
"Please retry to lunch the operation");
|
|
}
|
|
|
|
/**
|
|
* {@inheritDoc}
|
|
*
|
|
* @Override public HandlerRegistration addCloseHandler(CloseHandler<Long>
|
|
* handler) { //return eventBus.addHandler(CloseEvent.getType(),
|
|
* handler); }
|
|
*
|
|
* /** {@inheritDoc}
|
|
* @Override public HandlerRegistration addOpenHandler(OpenHandler<Long>
|
|
* handler) { //return eventBus.addHandler(OpenEvent.getType(),
|
|
* handler); }
|
|
*/
|
|
|
|
/**
|
|
* {@inheritDoc}
|
|
*
|
|
* @Override public void fireEvent(GwtEvent<?> event) {
|
|
* eventBus.fireEvent(event); }
|
|
*/
|
|
|
|
}
|