source: mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment_data.py @ 8210

'''
Created on 13 Feb 2012

@author: mnagni
'''
from libs.migration.processor.commons import findSubTypeInDPT,\
    createCEDA_Processing, createCEDA_Instrument, createCEDA_Project,\
    findSummary, findDocumentationInMigrationDocument, createCI_Citation,\
    createMO_OnlineResource
from libs.migration.MigrationEPB import MigrationEPB
from MolesManager.moles3epb import Moles3EPB
from ea_model.moles3_4.utilities.mo_publicationstatevalue import MO_PublicationStateValue

class DeploymentDataProcessor(object):
    
    def __init__(self, deploymentMigration, migrationSessions):
        self._migrationSessions = migrationSessions
        self._deploymentMigration = deploymentMigration
        
    def _commitDeploymentMigration(self, associateWithCedaObservation, dataProductionTool, dataProductionToolField):
        Moles3EPB.addCedaObject(associateWithCedaObservation, self._migrationSessions.molesSession, True)
        setattr(dataProductionTool, dataProductionToolField, associateWithCedaObservation.id)                                  
        self._migrationSessions.migrationSession.commit() 
        
    def createProject(self, links):
        project = None
        if links.has_key('ACTIVITY'):
            for link in links['ACTIVITY']:
                activity = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, link + '.atom', \
                                                                         self._migrationSessions.migrationSession)
                i_abstract = findSummary(activity)
                doc_link = findDocumentationInMigrationDocument(activity)
                i_documentation = None
                i_resource = None
                if doc_link and len(doc_link) == 1:
                    i_documentation = createCI_Citation("Documentation resource")
                    i_resource = createMO_OnlineResource(doc_link[0]['href'])
                project = createCEDA_Project(abstract=i_abstract, publication_state=MO_PublicationStateValue.cl_working, \
                                             documentation=i_documentation, project_resource=i_resource)
                self._commitDeploymentMigration(project, activity, 'ceda_project_id')
        return project
        
    def createProcess(self, links):
        associateWithCedaObservation = None
        hasCedaProcessing = False
        hasCedaComposite = False
        hasCedaAcquisition = False
        for dpt in links['DPT']:
            dataProductionTool = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, dpt + \
                                                                               '.atom', self._migrationSessions.migrationSession)
            
            #has the document changed?            
            #if hasAtomDocumentSameHash(dataProductionTool):
            #    dataProductionTool.doc_hash = getAtomDocumentHashByMO(self._deploymentMigration)
            #    self._migrationSessions.migrationSession.commit()
            #    continue
            
            subType = findSubTypeInDPT(dataProductionTool)
            if subType == 'model':
                associateWithCedaObservation = createCEDA_Processing()
                self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_processing_id')
                if not (hasCedaComposite or hasCedaProcessing):
                    hasCedaProcessing = True
                    hasCedaComposite = False
                    hasCedaAcquisition = False 
            else:
                associateWithCedaObservation = createCEDA_Instrument()
                self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_instrument_id')
                
                
        #if not a DPT.subType == 'model' then....
        for obs in links['OBS']:
            observationStation = MigrationEPB.getDeploymentDataMigrationByName(self._deploymentMigration, obs + \
                                                                               '.atom', self._migrationSessions.migrationSession)
 
            #has the document changed?            
            #if hasAtomDocumentSameHash(observationStation):
            #    observationStation.doc_hash = getAtomDocumentHashByMO(self._deploymentMigration)
            #    self._migrationSessions.migrationSession.commit()
            #    continue                       
            
            subType = findSubTypeInDPT(observationStation)
            if subType == 'satellite':
                    associateWithCedaObservation = createCEDA_Processing()
                    self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_compositeprocess_id')   
                    if not hasCedaComposite:
                        hasCedaProcessing = True
                        hasCedaComposite = False
                        hasCedaAcquisition = False               
            else:
                pass
                '''
                associateWithCedaObservation = createCEDA_Acquisition()
                self._commitDeploymentMigration(associateWithCedaObservation, dataProductionTool, 'ceda_acquisition_id')
                '''                
                if not (hasCedaComposite or hasCedaProcessing or hasCedaAcquisition):
                    hasCedaProcessing = True
                    hasCedaComposite = False
                    hasCedaAcquisition = True                            
        return associateWithCedaObservation