Changeset 8181
- Timestamp:
- 22/03/12 13:32:38 (9 years ago)
- Location:
- mauRepo/MolesManager/trunk/src/libs/migration/processor
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
mauRepo/MolesManager/trunk/src/libs/migration/processor/commons.py
r8180 r8181 7 7 from ea_model.iso_19115_2006_metadata_corrigendum.reference_system_information.md_identifier import MD_Identifier 8 8 from httplib import HTTPConnection 9 from xml.etree.ElementTree import XML, ElementTree, fromstring, dump,tostring9 from xml.etree.ElementTree import XML, tostring 10 10 import time, datetime 11 11 from ea_model.upcomingiso.ci_organisation import CI_Organisation 12 12 from ea_model.upcomingiso.ci_party import CI_Party 13 13 from ea_model.upcomingiso.ci_individual import CI_Individual 14 from libs.migration.exception.exceptions import NoDataLineage,\ 15 NoAssociatedAuthor 14 from libs.migration.exception.exceptions import NoDataLineage 16 15 from ea_model.iso_19115_2006_metadata_corrigendum.citation_and_responsible_party_information.ci_citation import CI_Citation 17 16 from ea_model.iso_19115_2006_metadata_corrigendum.data_quality_information.dq_element import DQ_Element … … 20 19 from xml.sax.saxutils import unescape, escape 21 20 import html5lib 22 from html5lib import sanitizer, treebuilders 23 from libs.migration.authors import authors 21 from html5lib import treebuilders 24 22 from ea_model.ceda_metadatamodel.ceda_result.ceda_result import CEDA_Result 25 23 from ea_model.moles3_4.result.mo_onlineresource import MO_OnlineResource 26 24 from ea_model.iso_19115_2006_metadata_corrigendum.citation_and_responsible_party_information.url import URL 27 from ea_model.iso_19115_2006_metadata_corrigendum.extent_information.ex_geographicextent import EX_GeographicExtent28 25 from ea_model.iso_19115_2006_metadata_corrigendum.extent_information.ex_geographicboundingbox import EX_GeographicBoundingBox 29 from ea_model.iso_19115_2006_metadata_corrigendum.citation_and_responsible_party_information.ci_onlinefunctioncode import CI_OnLineFunctionCode 26 from ea_model.ceda_metadatamodel.ceda_computation.ceda_processing import CEDA_Processing 27 from ea_model.ceda_metadatamodel.ceda_acquisition.ceda_instrument import CEDA_Instrument 28 from ea_model.ceda_metadatamodel.ceda_observationprocess.ceda_compositeprocess import CEDA_CompositeProcess 29 from ea_model.ceda_metadatamodel.ceda_acquisition.ceda_acquisition import CEDA_Acquisition 30 30 31 31 base = '/exist/rest/atoms' … … 496 496 return ex_geographic_bb 497 497 498 499 500 501 498 def createCEDA_Processing(): 499 ceda_processing = CEDA_Processing() 500 return ceda_processing 501 502 503 def createCEDA_Instrument(): 504 ceda_instrument = CEDA_Instrument() 505 return ceda_instrument 506 507 def createCEDA_CompositeProcess(): 508 ceda_cp = CEDA_CompositeProcess() 509 return ceda_cp 510 511 def createCEDA_Acquisition(): 512 ceda_acquisition = CEDA_Acquisition() 513 return ceda_acquisition 514 -
mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment_data.py
r8091 r8181 5 5 ''' 6 6 from libs.migration.processor.commons import findLinksInDeployment,\ 7 findSubTypeInDPT, hasAtomDocumentSameHash, getAtomDocumentHashByMO 7 findSubTypeInDPT, hasAtomDocumentSameHash, getAtomDocumentHashByMO,\ 8 createCEDA_Processing, createCEDA_Instrument 8 9 from libs.migration.MigrationEPB import MigrationEPB 9 from ea_model.ceda_metadatamodel.ceda_computation.ceda_processing import CEDA_Processing10 from ea_model.ceda_metadatamodel.ceda_acquisition.ceda_instrument import CEDA_Instrument11 from ea_model.ceda_metadatamodel.ceda_observationprocess.ceda_compositeprocess import CEDA_CompositeProcess12 from ea_model.ceda_metadatamodel.ceda_acquisition.ceda_acquisition import CEDA_Acquisition13 from libs.epb import EPB14 10 from MolesManager.moles3epb import Moles3EPB 15 11 … … 20 16 self._deploymentMigration = deploymentMigration 21 17 22 def _processCEDA_Processing(self, dataProductionTool): 23 if dataProductionTool and hasattr(dataProductionTool, 'ceda_processing_id'): 24 return EPB.searchOrCreate(CEDA_Processing, self._migrationSessions.molesSession, dataProductionTool.ceda_processing_id) 25 26 def _processCEDA_Instrument(self, dataProductionTool): 27 if dataProductionTool and hasattr(dataProductionTool, 'ceda_instrument_id'): 28 return EPB.searchOrCreate(CEDA_Instrument, self._migrationSessions.molesSession, dataProductionTool.ceda_instrument_id) 29 30 def _processCEDA_CompositeProcess(self, observationStation): 31 if observationStation and hasattr(observationStation, 'ceda_compositeprocess_id'): 32 return EPB.searchOrCreate(CEDA_CompositeProcess, self._migrationSessions.molesSession, observationStation.ceda_compositeprocess_id) 33 34 def _processCEDA_Acquisition(self, observationStation): 35 if observationStation and hasattr(observationStation, 'ceda_acquisition_id'): 36 return EPB.searchOrCreate(CEDA_Acquisition, self._migrationSessions.molesSession, observationStation.ceda_acquisition_id) 18 def _commitDeploymentMigration(self, associateWithCedaObservation, dataProductionTool, dataProductionToolField): 19 Moles3EPB.addCedaObject(associateWithCedaObservation, self._migrationSessions.molesSession, True) 20 setattr(dataProductionTool, dataProductionToolField, associateWithCedaObservation.id) 21 self._migrationSessions.migrationSession.commit() 37 22 38 23 def _assignProcess(self): … … 53 38 subType = findSubTypeInDPT(dataProductionTool) 54 39 if subType == 'model': 55 ret = self._processCEDA_Processing(dataProductionTool) 56 Moles3EPB.addCedaObject(ret, self._migrationSessions.molesSession, True) 57 dataProductionTool.ceda_processing_id = ret.id 58 self._migrationSessions.migrationSession.commit() 40 associateWithCedaObservation = createCEDA_Processing() 41 self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_processing_id') 59 42 if not (hasCedaComposite or hasCedaProcessing): 60 associateWithCedaObservation = ret61 43 hasCedaProcessing = True 62 44 hasCedaComposite = False 63 45 hasCedaAcquisition = False 64 46 else: 65 ret = self._processCEDA_Instrument(dataProductionTool) 66 Moles3EPB.addCedaObject(ret, self._migrationSessions.molesSession, True) 67 dataProductionTool.ceda_instrument_id = ret.id 68 self._migrationSessions.migrationSession.commit() 47 associateWithCedaObservation = createCEDA_Instrument() 48 self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_instrument_id') 69 49 70 50 … … 81 61 subType = findSubTypeInDPT(observationStation) 82 62 if subType == 'satellite': 83 ret = self._processCEDA_CompositeProcess(observationStation) 84 Moles3EPB.addCedaObject(ret, self._migrationSessions.molesSession, True) 85 observationStation.ceda_compositeprocess_id = ret.id 86 self._migrationSessions.migrationSession.commit() 87 if not hasCedaComposite: 88 associateWithCedaObservation = ret 89 hasCedaProcessing = True 90 hasCedaComposite = False 91 hasCedaAcquisition = False 63 associateWithCedaObservation = createCEDA_Processing() 64 self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_compositeprocess_id') 65 if not hasCedaComposite: 66 hasCedaProcessing = True 67 hasCedaComposite = False 68 hasCedaAcquisition = False 92 69 else: 93 ret = self._processCEDA_Acquisition(observationStation) 94 Moles3EPB.addCedaObject(ret, self._migrationSessions.molesSession, True) 95 observationStation.ceda_acquisition_id = ret.id 96 self._migrationSessions.migrationSession.commit() 70 pass 71 ''' 72 associateWithCedaObservation = createCEDA_Acquisition() 73 self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_acquisition_id') 74 ''' 97 75 if not (hasCedaComposite or hasCedaProcessing or hasCedaAcquisition): 98 associateWithCedaObservation = ret99 76 hasCedaProcessing = True 100 77 hasCedaComposite = False 101 78 hasCedaAcquisition = True 79 102 80 103 81 return associateWithCedaObservation
Note: See TracChangeset
for help on using the changeset viewer.