3 * Copyright (C) 2013 EDIT
4 * European Distributed Institute of Taxonomy
5 * http://www.e-taxonomy.eu
7 * The contents of this file are subject to the Mozilla Public License Version 1.1
8 * See LICENSE.TXT at the top of this package for the full license terms.
10 package eu
.etaxonomy
.taxeditor
.view
.dataimport
;
12 import java
.io
.IOException
;
13 import java
.io
.InputStream
;
16 import org
.apache
.log4j
.Logger
;
17 import org
.eclipse
.core
.runtime
.IProgressMonitor
;
18 import org
.eclipse
.core
.runtime
.IStatus
;
19 import org
.eclipse
.core
.runtime
.Status
;
20 import org
.eclipse
.core
.runtime
.jobs
.Job
;
21 import org
.eclipse
.jface
.viewers
.IStructuredSelection
;
22 import org
.eclipse
.jface
.wizard
.Wizard
;
23 import org
.eclipse
.swt
.widgets
.Display
;
24 import org
.eclipse
.ui
.IImportWizard
;
25 import org
.eclipse
.ui
.IWorkbench
;
26 import org
.eclipse
.ui
.IWorkbenchPage
;
27 import org
.eclipse
.ui
.IWorkbenchWindow
;
28 import org
.eclipse
.ui
.PartInitException
;
29 import org
.eclipse
.ui
.PlatformUI
;
30 import org
.w3c
.dom
.NodeList
;
32 import eu
.etaxonomy
.cdm
.database
.DbSchemaValidation
;
33 import eu
.etaxonomy
.cdm
.ext
.common
.ServiceWrapperBase
;
34 import eu
.etaxonomy
.cdm
.ext
.occurrence
.OccurenceQuery
;
35 import eu
.etaxonomy
.cdm
.ext
.occurrence
.bioCase
.BioCaseQueryServiceWrapper
;
36 import eu
.etaxonomy
.cdm
.io
.specimen
.abcd206
.in
.Abcd206ImportConfigurator
;
38 import eu
.etaxonomy
.cdm
.io
.specimen
.abcd206
.in
.AbcdParseUtility
;
39 import eu
.etaxonomy
.cdm
.io
.specimen
.abcd206
.in
.SpecimenImportReport
;
40 import eu
.etaxonomy
.cdm
.io
.specimen
.abcd206
.in
.UnitAssociationWrapper
;
41 import eu
.etaxonomy
.taxeditor
.store
.CdmStore
;
44 * Wizard for querying specimen provider.
49 public class SpecimenSearchWizard
extends Wizard
implements IImportWizard
{
50 private static final Logger logger
= Logger
.getLogger(SpecimenSearchWizard
.class);
52 private OccurenceQuery query
= null;
53 private SpecimenProviderSelectionWizardPage providerSelectionPage
;
54 private SpecimenSearchWizardPage searchPage
;
57 * Creates a new SpecimenSearchWizard
59 public SpecimenSearchWizard() {
60 //default constructor needed for RCP extension points
62 //check if connected to a data source. If not this will open an error dialog
63 CdmStore
.getCurrentApplicationConfiguration();
64 this.setWindowTitle("Search Specimens");
69 * @see org.eclipse.jface.wizard.Wizard#performFinish()
72 public boolean performFinish() {
73 searchPage
.getController().saveLastSate();
74 providerSelectionPage
.getController().saveLastState();
75 ServiceWrapperBase serviceWrapper
;
76 DataImportView
<?
> dataImportView
= null;
77 query
= searchPage
.getQuery();
78 Abcd206ImportConfigurator configurator
= CdmStore
.getImportManager().AbcdConfigurator();
79 configurator
.setOccurenceQuery(query
);
80 configurator
.setSourceUri(providerSelectionPage
.getEndPoint());
81 configurator
.setAddMediaAsMediaSpecimen(true);
82 configurator
.setDbSchemaValidation(DbSchemaValidation
.CREATE
);
83 configurator
.setIgnoreAuthorship(true);
85 //Job job = CdmStore.getImportManager().createIOServiceJob(configurator, new File(source), SOURCE_TYPE.INPUTSTREAM);
86 //CdmStore.getImportManager().run(job);
88 serviceWrapper
= providerSelectionPage
.getQueryServiceWrapper();
89 InputStream stream
= null;
91 final IWorkbenchWindow window
= PlatformUI
.getWorkbench().getActiveWorkbenchWindow();
92 IWorkbenchPage activePart
= window
.getActivePage();
93 if (providerSelectionPage
.getQueryType().equals(QueryType
.BIOCASE
)){
94 stream
=((BioCaseQueryServiceWrapper
) serviceWrapper
).query(query
, configurator
.getSourceUri());
95 SpecimenImportReport report
= new SpecimenImportReport();
96 UnitAssociationWrapper unitNodesList
= AbcdParseUtility
.parseUnitsNodeList(stream
, report
);
97 NodeList nodeList
= unitNodesList
.getAssociatedUnits();
98 String prefix
= unitNodesList
.getPrefix();
99 String associationType
= unitNodesList
.getAssociationType();
100 URI uri
=AbcdParseUtility
.parseFirstUri(nodeList
, report
);
101 String content
= AbcdParseUtility
.parseFirstTextContent(nodeList
);
102 System
.out
.println(content
);
105 SpecimenImportView specimenImportView
= new SpecimenImportView();
107 specimenImportView
= (SpecimenImportView
) activePart
.showView(SpecimenImportView
.ID
);
108 specimenImportView
.setEndpoint(providerSelectionPage
.getEndPoint());
109 specimenImportView
.setQuery(query
);
110 dataImportView
= specimenImportView
;
111 } catch (PartInitException e
) {
112 // TODO Auto-generated catch block
120 dataImportView
= (GbifResponseImportView
) activePart
.showView(GbifResponseImportView
.ID
, "query_"+query
.toString().replaceAll(",", ""), IWorkbenchPage
.VIEW_ACTIVATE
);
121 dataImportView
.setQuery(query
);
122 // (GbifResponseImportView) activePart.showView(GbifResponseImportView.ID);getWorkbench().getActiveWorkbenchWindow().getActivePage()
123 // .showView(GbifResponseImportView.ID, "query_"+query.toString().replaceAll(",", ""),IWorkbenchPage.VIEW_ACTIVATE);
125 } catch (PartInitException e
) {
126 // TODO Auto-generated catch block
133 } catch (IOException e
) {
134 // TODO Auto-generated catch block
137 // CdmStore.getImportManager().run(configurator);
140 // switch (providerSelectionPage.getQueryType()) {
142 // SpecimenImportView specimenImportView = (SpecimenImportView) TaxeditorEditorPlugin.getDefault().getWorkbench().getActiveWorkbenchWindow().getActivePage()
143 // .showView(SpecimenImportView.ID, "query_"+query.toString().replaceAll(",", ""),IWorkbenchPage.VIEW_ACTIVATE);
144 // specimenImportView.setEndpoint(providerSelectionPage.getEndPoint());
145 // dataImportView = specimenImportView;
148 // dataImportView = (GbifResponseImportView) TaxeditorEditorPlugin.getDefault().getWorkbench().getActiveWorkbenchWindow().getActivePage()
149 // .showView(GbifResponseImportView.ID, "query_"+query.toString().replaceAll(",", ""),IWorkbenchPage.VIEW_ACTIVATE);
152 // } catch ( PartInitException e ) {
153 // logger.error("Could not open import view for query: " + query.toString(), e);
155 // if(dataImportView!=null){
156 // dataImportView.setQuery(query);
157 //// dataImportView.query();
158 //// Display.getDefault().asyncExec(new Runnable() {
161 //// public void run() {
162 //// CdmStore.getContextManager().notifyContextRefresh();
165 Job queryJob
= new QueryJob("Query specimen provider", dataImportView
);
172 * @see org.eclipse.jface.wizard.Wizard#addPages()
175 public void addPages() {
176 addPage(providerSelectionPage
);
181 * @see org.eclipse.ui.IWorkbenchWizard#init(org.eclipse.ui.IWorkbench, org.eclipse.jface.viewers.IStructuredSelection)
184 public void init(IWorkbench workbench
, IStructuredSelection selection
) {
185 providerSelectionPage
= new SpecimenProviderSelectionWizardPage("Select specimen provider");
186 searchPage
= new SpecimenSearchWizardPage("Specimen Search");
189 private class QueryJob
extends Job
{
191 private final DataImportView
<?
> view
;
196 public QueryJob(String name
, DataImportView
<?
> view
) {
202 * @see org.eclipse.core.runtime.jobs.Job#run(org.eclipse.core.runtime.IProgressMonitor)
205 protected IStatus
run(IProgressMonitor monitor
) {
206 view
.getConversationHolder().bind();
208 Display
.getDefault().asyncExec(new Runnable() {
212 CdmStore
.getContextManager().notifyContextRefresh();
215 return Status
.OK_STATUS
;