Changeset 8392 for mauRepo/MolesManager

Timestamp:

25/06/12 13:28:21 (7 years ago)

Author:

mnagni

Message:

Incomplete - # 22488: CEDA Observation Collection - Geographical Extent
 http://team.ceda.ac.uk/trac/ceda/ticket/22488

Location:

mauRepo/MolesManager/trunk/src

Files:

• MolesManager/moles3epb.py (modified) (2 diffs)
• libs/migration/processor/dataEntity.py (modified) (2 diffs)
• libs/postgisutil.py (added)

mauRepo/MolesManager/trunk/src/MolesManager/moles3epb.py

@@ -45 +45 @@
 from ea_model.moles3_4.utilities.mo_rolevalue import MO_RoleValue
 from sqlalchemy.orm.collections import InstrumentedList
+from ea_model.iso_19115_2006_metadata_corrigendum.extent_information.ex_geographicboundingbox import EX_GeographicBoundingBox
+from libs.postgisutil import unifyGeometries, create_st_setSRID
 
 
@@ -148 +150 @@
         return coll                                      
 
+    def getGeograpicExtentGeometry(self, ge):
+        '''
+            Creates the appropriate postgis geometry from a EX_GeographicExtent
+            @param ge: an EX_GeographicExtent instance
+            @return: a postgix text geometry
+        '''
+        if isinstance(ge, EX_GeographicBoundingBox):
+            return create_st_setSRID(ge.westBoundLongitude, ge.southBoundLatitude, \
+                           ge.eastBoundLongitude, ge.northBoundLatitude)
+        return None
+    
+    
+    
+    def getUnifyObservationCollectionGE(self, collection):
+        """
+            Returns the union of the collections.member'a  GeographicExtension(s)
+            @param collection: an CEDA_ObservationColleciton instance  
+        """
+        bboxes = []
+        for member in collection.member:
+            for ge in member.geographicExtent:
+                bboxes.append(self.getGeograpicExtentGeometry(ge))
+        
+        return unifyGeometries(bboxes, self)  
+
     def retrieveGUIDFromInstance(self, instance):
         """

mauRepo/MolesManager/trunk/src/libs/migration/processor/dataEntity.py

@@ -68 +68 @@
         self._dataEntityHasSameHash = hasMOSameHash(self._dataEntityMigration)       
         self.epbRepo = epbRepo
+
+    def _checkGeographicExtent(self, ceda_observationCollection):
+        union = self.moles3epb.getUnifyObservationCollectionGE(ceda_observationCollection)
     
     def _processTitle(self, ceda_observationCollection):
@@ -206 +209 @@
                                       
             except Exception as ex:
-                exs.append(ex)  
+                exs.append(ex)
+                
+        self._checkGeographicExtent(obsColl)
+          
         return exs