e559665a2cae4bcca11cffacd9c2f5f83db14985
[taxeditor.git] / eu.etaxonomy.taxeditor.editor / src / main / java / eu / etaxonomy / taxeditor / editor / view / dataimport / SpecimenImportEditorInput.java
1 // $Id$
2 /**
3 * Copyright (C) 2014 EDIT
4 * European Distributed Institute of Taxonomy
5 * http://www.e-taxonomy.eu
6 *
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.
9 */
10 package eu.etaxonomy.taxeditor.editor.view.dataimport;
11
12 import java.io.IOException;
13 import java.io.InputStream;
14 import java.net.URISyntaxException;
15 import java.util.ArrayList;
16 import java.util.Collection;
17
18 import org.apache.http.client.ClientProtocolException;
19 import org.eclipse.swt.widgets.Display;
20
21 import eu.etaxonomy.cdm.ext.biocase.BioCaseQuery;
22 import eu.etaxonomy.cdm.ext.biocase.BioCaseQueryServiceWrapper;
23 import eu.etaxonomy.cdm.io.common.CdmDefaultImport;
24 import eu.etaxonomy.cdm.io.specimen.abcd206.in.Abcd206ImportConfigurator;
25 import eu.etaxonomy.cdm.model.occurrence.SpecimenOrObservationBase;
26 import eu.etaxonomy.taxeditor.editor.view.dataimport.transientServices.TransientCdmRepository;
27 import eu.etaxonomy.taxeditor.store.CdmStore;
28
29 /**
30 * @author pplitzner
31 * @date 25.02.2014
32 *
33 */
34 public class SpecimenImportEditorInput extends DataImportEditorInput<SpecimenOrObservationBase> {
35
36 private final BioCaseQuery query;
37
38 /**
39 * @param results
40 */
41 public SpecimenImportEditorInput(BioCaseQuery query) {
42 super();
43 this.query = query;
44 }
45
46 public void query(){
47 String errorMessage = "Could not execute query " + SpecimenImportEditorInput.this.query;
48
49 Collection<SpecimenOrObservationBase> results = new ArrayList<SpecimenOrObservationBase>();
50 try {
51 InputStream resultStream = new BioCaseQueryServiceWrapper().query(SpecimenImportEditorInput.this.query);
52 Abcd206ImportConfigurator configurator = Abcd206ImportConfigurator.NewInstance(resultStream, null, false);
53 TransientCdmRepository repo =
54 new TransientCdmRepository(CdmStore.getCurrentApplicationConfiguration());
55 configurator.setCdmAppController(repo);
56
57 CdmDefaultImport<Abcd206ImportConfigurator> importer = new CdmDefaultImport<Abcd206ImportConfigurator>();
58 importer.invoke(configurator);
59 results = repo.getUnits();
60 } catch (ClientProtocolException e) {
61 logger.error(errorMessage, e);
62 } catch (IOException e) {
63 logger.error(errorMessage, e);
64 } catch (URISyntaxException e) {
65 logger.error(errorMessage, e);
66 }
67 setResults(results);
68
69 Display.getDefault().asyncExec(new Runnable() {
70
71 @Override
72 public void run() {
73 CdmStore.getContextManager().notifyContextRefresh();
74 }
75 });
76 }
77
78 /* (non-Javadoc)
79 * @see org.eclipse.ui.IEditorInput#getName()
80 */
81 @Override
82 public String getName() {
83 return query.toString();
84 }
85
86 /* (non-Javadoc)
87 * @see org.eclipse.ui.IEditorInput#getToolTipText()
88 */
89 @Override
90 public String getToolTipText() {
91 return query.toString();
92 }
93
94 /* (non-Javadoc)
95 * @see java.lang.Object#hashCode()
96 */
97 @Override
98 public int hashCode() {
99 final int prime = 31;
100 int result = 1;
101 result = prime * result + ((query == null) ? 0 : query.hashCode());
102 return result;
103 }
104
105 /* (non-Javadoc)
106 * @see java.lang.Object#equals(java.lang.Object)
107 */
108 @Override
109 public boolean equals(Object obj) {
110 if (this == obj) {
111 return true;
112 }
113 if (obj == null) {
114 return false;
115 }
116 if (getClass() != obj.getClass()) {
117 return false;
118 }
119 SpecimenImportEditorInput other = (SpecimenImportEditorInput) obj;
120 if (query == null) {
121 if (other.query != null) {
122 return false;
123 }
124 } else if (!query.equals(other.query)) {
125 return false;
126 }
127 return true;
128 }
129 }