tabular-data-manager/src/main/java/org/gcube/portlets/user/td/client/TabularDataController.java

576 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.sdmximportwizardtd.shared.TRId;
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.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.extjs.gxt.ui.client.event.ResizeEvent;
import com.google.gwt.core.client.GWT;
import com.google.gwt.core.client.RunAsyncCallback;
import com.google.gwt.event.shared.GwtEvent;
import com.google.gwt.user.client.ui.Label;
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.core.client.util.Margins;
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;
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 BorderLayoutContainer centerContainer;
protected ContentPanel functionalityPanel;
protected TabPanel functionalityTab;
protected int indexFunctionalityTab = 0;
protected boolean functionalityOpen;
protected Label propertiesLabel;
protected BorderLayoutData eastData;
/**
* Table Open
*/
protected boolean tableOpen=false;
/**
* 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 BorderLayoutContainer getCenterContainer() {
return centerContainer;
}
public void setCenterContainer(BorderLayoutContainer centerContainer) {
this.centerContainer = centerContainer;
}
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);
Info.display("Open Functionality", "open: " + 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(propertiesLabel==null){
propertiesLabel = new Label("Tabular Resources Properties");
propertiesLabel.addStyleName("pad-text");
TabItemConfig propertiesItemConf=new TabItemConfig("Properties", true);
org.gcube.portlets.user.td.information.shared.TRId trId=new org.gcube.portlets.user.td.information.shared.TRId("0","1");
TabularResourceProperties 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();
functionalityOpen=false;
propertiesLabel=null;
}
}
}
);
Label taskLabel = new Label("Task Properties");
taskLabel.addStyleName("pad-text");
functionalityTab.add(taskLabel, new TabItemConfig("Task", true));
//Last is functionalityTab.getWidgetCount() - 1)
functionalityTab.setActiveWidget(functionalityTab
.getWidget(0));
centerContainer.onResize();
}
if(functionalityOpen){
functionalityPanel.collapse();
functionalityOpen=false;
} else {
functionalityPanel.enable();
functionalityPanel.expand();
functionalityOpen=true;
}
centerContainer.onResize();
};
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);
tableOpen=true;
}
@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(
org.gcube.portlets.user.sdmxexportwizardtd.shared.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(tableOpen) tabularData.closeTable();
}
/**
*
*/
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(
org.gcube.portlets.user.td.open.shared.TRId tabularResourceId) {
trId= new TRId(tabularResourceId.getId(),tabularResourceId.getTableId());
tableOpening=new TableId(Constants.TD_DATASOURCE_FACTORY_ID,trId.getTableId());
tabularData.openTable(tableOpening);
tableOpen=true;
}
});
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);
}
*/
}