Changeset 8210
- Timestamp:
- 03/04/12 08:16:48 (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
r8209 r8210 33 33 from ea_model.iso_19108_2006_temporal_schema.temporal_reference_system.tm_position import TM_Position 34 34 from ea_model.iso_19108_2006_temporal_schema.temporal_objects.tm_instant import TM_Instant 35 from ea_model.moles3_4.utilities.mo_organization import MO_Organization36 35 from ea_model.iso_19115_2006_metadata_corrigendum.citation_and_responsible_party_information.ci_contact import CI_Contact 37 36 from ea_model.iso_19115_2006_metadata_corrigendum.citation_and_responsible_party_information.ci_address import CI_Address … … 324 323 return linksDict 325 324 325 326 326 327 def findDownloadLinksInMigrationDocument(migrationObject): 327 328 """ … … 344 345 return linksDict['ACCESS'] 345 346 347 def findDocumentationInMigrationDocument(migrationObject): 348 """ 349 Return a list of dictionaries describing a <link rel="...DOCUMENT..."> tag type 350 Each dictionary has two keys: 'href' and 'title' 351 @param migrationObject: the migration instance to retrieve and parse 352 @return: a list of dictionaries 353 """ 354 linksDict = findLinksInMigrationDocument(migrationObject) 355 return linksDict['DOCUMENT'] 356 346 357 def findDOIInMigrationDocument(migrationObject): 347 358 """ … … 351 362 @return: a dictionary relative to the DOI, None otherwise 352 363 """ 353 linksDict = findLinksInMigrationDocument(migrationObject) 354 for link in linksDict['DOCUMENTATION']: 364 for link in findDocumentationInMigrationDocument(migrationObject): 355 365 if link['href'].startswith('doi:'): 356 366 return link … … 828 838 return ceda_acquisition 829 839 830 def createCEDA_Project(abstract = None, publication_state = None ):840 def createCEDA_Project(abstract = None, publication_state = None, documentation = None, project_resource=None): 831 841 ceda_project = CEDA_Project() 832 842 if abstract: … … 834 844 if publication_state: 835 845 ceda_project.publicationState = publication_state 846 if documentation and type(documentation) == list: 847 ceda_project.documentation = documentation 848 if project_resource and type(project_resource) == list: 849 ceda_project.projectResource = project_resource 836 850 return ceda_project -
mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment_data.py
r8209 r8210 4 4 @author: mnagni 5 5 ''' 6 from libs.migration.processor.commons import findLinksInDeployment,\ 7 findSubTypeInDPT, hasAtomDocumentSameHash, getAtomDocumentHashByMO,\ 6 from libs.migration.processor.commons import findSubTypeInDPT,\ 8 7 createCEDA_Processing, createCEDA_Instrument, createCEDA_Project,\ 9 findSummary 8 findSummary, findDocumentationInMigrationDocument, createCI_Citation,\ 9 createMO_OnlineResource 10 10 from libs.migration.MigrationEPB import MigrationEPB 11 11 from MolesManager.moles3epb import Moles3EPB … … 27 27 if links.has_key('ACTIVITY'): 28 28 for link in links['ACTIVITY']: 29 activity = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, link + '.atom', self._migrationSessions.migrationSession) 29 activity = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, link + '.atom', \ 30 self._migrationSessions.migrationSession) 30 31 i_abstract = findSummary(activity) 31 project = createCEDA_Project(abstract=i_abstract, publication_state=MO_PublicationStateValue.cl_working) 32 doc_link = findDocumentationInMigrationDocument(activity) 33 i_documentation = None 34 i_resource = None 35 if doc_link and len(doc_link) == 1: 36 i_documentation = createCI_Citation("Documentation resource") 37 i_resource = createMO_OnlineResource(doc_link[0]['href']) 38 project = createCEDA_Project(abstract=i_abstract, publication_state=MO_PublicationStateValue.cl_working, \ 39 documentation=i_documentation, project_resource=i_resource) 32 40 self._commitDeploymentMigration(project, activity, 'ceda_project_id') 33 41 return project … … 39 47 hasCedaAcquisition = False 40 48 for dpt in links['DPT']: 41 dataProductionTool = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, dpt + '.atom', self._migrationSessions.migrationSession) 49 dataProductionTool = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, dpt + \ 50 '.atom', self._migrationSessions.migrationSession) 42 51 43 52 #has the document changed? … … 62 71 #if not a DPT.subType == 'model' then.... 63 72 for obs in links['OBS']: 64 observationStation = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, obs + '.atom', self._migrationSessions.migrationSession) 73 observationStation = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, obs + \ 74 '.atom', self._migrationSessions.migrationSession) 65 75 66 76 #has the document changed?
Note: See TracChangeset
for help on using the changeset viewer.