Changeset 8362


Ignore:
Timestamp:
20/06/12 11:40:21 (7 years ago)
Author:
mnagni
Message:

Fixes a bug in geographicalExtension migration

Location:
mauRepo/MolesManager/trunk/src/libs/migration
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • mauRepo/MolesManager/trunk/src/libs/migration/processor/deployment.py

    r8358 r8362  
    433433        if not ge: 
    434434            ge = extractGeographicExtentInMigrationDocument(self._dataEntityMigration) 
    435         geographicExtent = createEX_GeographicBoundingBox(ge['east'], ge['north'], ge['west'], ge['south']) 
    436          
    437         if not self._deploymentHasBeenProcessed: 
    438             observation.geographicExtent.append(geographicExtent) 
     435            if ge: 
     436                geographicExtent = createEX_GeographicBoundingBox(ge['east'], ge['north'], ge['west'], ge['south']) 
     437                if not self._deploymentHasBeenProcessed: 
     438                    observation.geographicExtent.append(geographicExtent) 
    439439            return           
    440440        #Still have to update observation.geographicExtent 
  • mauRepo/MolesManager/trunk/src/libs/migration/tests/migrationprocess.py

    r8358 r8362  
    3636from libs.migration.processor.loadResources import LoadResources 
    3737from libs.migration.db.classes import MigrationObject 
    38 from libs.migration.processor.commons import DO_BADC, DS_pUBLISHED, DS_PUBLISHED 
     38from libs.migration.processor.commons import DO_BADC, DS_pUBLISHED, DS_PUBLISHED,\ 
     39    DO_NEODC 
    3940from MolesManager.moles3epb import Moles3EPBFactory 
    4041from libs.migration.processor.migrationProcess import MigrationProcess 
     
    7576            for e in ex: 
    7677                print e 
     78                 
     79        self.mp = MigrationProcess(self.epbRepo) 
    7780 
    78     def testMigrationProcess(self):         
    79         mp = MigrationProcess(self.epbRepo) 
    80  
    81         dataEntity = MigrationObject() 
    82         dataEntity.doc_owner = DO_BADC 
    83                  
     81    def testMigrationProcess(self):                         
    8482        #dataEntity.doc_status = DS_pUBLISHED 
    8583        #dataEntity.doc_name = 'dataent_csip.atom' 
     
    9088         
    9189        #Has 3 DOI 
    92         dataEntity.doc_status = DS_pUBLISHED 
    93         dataEntity.doc_name = 'dataent_chobs.atom'         
    94                  
     90        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_chobs.atom') 
    9591         
    96         ex = mp.process(dataEntity) 
    97         #ex = [] 
    98         #ex = mp.process() 
     92        #IASI 
     93        self.processDataEntity(DO_NEODC, DS_pUBLISHED, 'dataent_12417810458627666.atom') 
     94        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_VIRTEM.atom') 
     95        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_12162569915925921.atom') 
     96               
     97        #ECMWF 
     98        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-ERA.atom') 
     99        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-OP.atom') 
     100        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_12458543158227759.atom')                 
     101        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-E40.atom') 
     102        self.processDataEntity(DO_BADC, DS_pUBLISHED, 'dataent_ECMWF-TRJ.atom')                 
     103 
     104         
     105    def processDataEntity(self, doc_owner, doc_status, doc_name): 
     106        dataEntity = MigrationObject() 
     107        dataEntity.doc_owner = doc_owner         
     108        dataEntity.doc_status = doc_status 
     109        dataEntity.doc_name = doc_name 
     110        ex = self.mp.process(dataEntity) 
    99111        for e in ex: 
    100112            print e 
    101         #self._dropAllTables() 
     113         
    102114 
    103     """         
    104     def _dropAllTables(self): 
    105         session = Moles3EPB.getNewMolesSession() 
    106         f = open('dropAllTables.sql', 'r') 
    107         for line in f.readlines(): 
    108             stripped = line.strip() 
    109             if len(stripped) > 0: 
    110                 Moles3EPB.executeNative(line.strip(), session) 
    111         session.commit() 
    112         session.close()         
    113     """     
    114          
    115          
Note: See TracChangeset for help on using the changeset viewer.