Changeset 5009 for main/waeup.sirp/trunk/src/waeup/sirp/utils

Timestamp:

4 Feb 2010, 13:48:45 (15 years ago)

Author:

uli

Message:

Move academics-specific components from utils.batching to university.batching.

File:

• main/waeup.sirp/trunk/src/waeup/sirp/utils/batching.py (modified) (4 diffs)

main/waeup.sirp/trunk/src/waeup/sirp/utils/batching.py

@@ -14 +14 @@
 from zope.interface import Interface
 from zope.schema import getFields
-from zope.schema.interfaces import IText
 from waeup.sirp.interfaces import (
     IBatchProcessor, ISchemaTypeConverter, FatalCSVError)
-from waeup.sirp.university.interfaces import (
-    IFacultyContainer, IFaculty, ICourse, IDepartment, ICertificate,
-    ICertificateCourse)
 
 class BatchProcessor(grok.GlobalUtility):
@@ -31 +27 @@
 
     # Name used in pages and forms...
-    name = u'Department importer'
+    name = u'Non-registered base importer'
     
     # Internal name...
-    util_name = 'departmentimporter'
+    util_name = 'baseimporter'
     
     # Items for this processor need an interface with zope.schema fields.
-    iface = IDepartment
+    iface = Interface
     
     # The name must be the same as the util_name attribute in order to
@@ -168 +164 @@
 
     def getParent(self, row, site):
+        """Get the parent object for the entry in ``row``.
+        """
+        raise NotImplementedError('method not implemented')
+    
+    def getEntry(self, row, site):
         """Get the parent object for the entry in ``row``.
         """
@@ -315 +316 @@
         return (num, num_warns,
                 os.path.abspath(finished_path), failed_path)
-
-class FacultyProcessor(BatchProcessor):
-    """A batch processor for IFaculty objects.
-    """
-    grok.provides(IBatchProcessor)
-    grok.context(Interface)
-    util_name = 'facultyimporter'
-    grok.name(util_name)
-
-    name = u'Faculty importer'
-    iface = IFaculty
-
-    location_fields = ['code',]
-    factory_name = 'waeup.Faculty'
-
-    def parentsExist(self, row, site):
-        return 'faculties' in site.keys()
-
-    def entryExists(self, row, site):
-        return row['code'] in site['faculties'].keys()
-
-    def getParent(self, row, site):
-        return site['faculties']
-
-    def getEntry(self, row, site):
-        if not self.entryExists(row, site):
-            return None
-        parent = self.getParent(row, site)
-        return parent.get(row['code'])
-    
-    def addEntry(self, obj, row, site):
-        parent = self.getParent(row, site)
-        parent.addFaculty(obj)
-        return
-
-    def delEntry(self, row, site):
-        parent = self.getParent(row, site)
-        del parent[row['code']]
-        pass
-
-class DepartmentProcessor(BatchProcessor):
-    """A batch processor for IDepartment objects.
-    """
-    grok.provides(IBatchProcessor)
-    grok.context(Interface)
-    util_name = 'departmentimporter'
-    grok.name(util_name)
-
-    name = u'Department importer'
-    iface = IDepartment
-
-    location_fields = ['code', 'faculty_code']
-    factory_name = 'waeup.Department'
-
-    def parentsExist(self, row, site):
-        if not 'faculties' in site.keys():
-            return False
-        return row['faculty_code'] in site['faculties']
-
-    def entryExists(self, row, site):
-        if not self.parentsExist(row, site):
-            return False
-        parent = self.getParent(row, site)
-        return row['code'] in parent.keys()
-
-    def getParent(self, row, site):
-        return site['faculties'][row['faculty_code']]
-
-    def getEntry(self, row, site):
-        if not self.entryExists(row, site):
-            return None
-        parent = self.getParent(row, site)
-        return parent.get(row['code'])
-    
-    def addEntry(self, obj, row, site):
-        parent = self.getParent(row, site)
-        parent.addDepartment(obj)
-        return
-
-    def delEntry(self, row, site):
-        parent = self.getParent(row, site)
-        del parent[row['code']]
-        return
-
-class CourseProcessor(BatchProcessor):
-    """A batch processor for ICourse objects.
-    """
-    grok.provides(IBatchProcessor)
-    grok.context(Interface)
-    util_name = 'courseimporter'
-    grok.name(util_name)
-
-    name = u'Course importer'
-    iface = ICourse
-
-    location_fields = ['code', 'faculty_code', 'department_code']
-    factory_name = 'waeup.Course'
-
-    def parentsExist(self, row, site):
-        if not 'faculties' in site.keys():
-            return False
-        if not row['faculty_code'] in site['faculties'].keys():
-            return False
-        faculty = site['faculties'][row['faculty_code']]
-        return row['department_code'] in faculty.keys()
-
-    def entryExists(self, row, site):
-        if not self.parentsExist(row, site):
-            return False
-        parent = self.getParent(row, site)
-        return row['code'] in parent.keys()
-
-    def getParent(self, row, site):
-        dept = site['faculties'][row['faculty_code']][row['department_code']]
-        return dept.courses
-
-    def getEntry(self, row, site):
-        if not self.entryExists(row, site):
-            return None
-        parent = self.getParent(row, site)
-        return parent.get(row['code'])
-    
-    def addEntry(self, obj, row, site):
-        parent = self.getParent(row, site)
-        parent.addCourse(obj)
-        return
-
-    def delEntry(self, row, site):
-        parent = self.getParent(row, site)
-        del parent[row['code']]
-        return
-
-class CertificateProcessor(BatchProcessor):
-    """A batch processor for ICertificate objects.
-    """
-    grok.provides(IBatchProcessor)
-    grok.context(Interface)
-    util_name = 'certificateimporter'
-    grok.name(util_name)
-
-    name = u'Certificate importer'
-    iface = ICertificate
-
-    location_fields = ['code', 'faculty_code', 'department_code']
-    factory_name = 'waeup.Certificate'
-
-    def parentsExist(self, row, site):
-        if not 'faculties' in site.keys():
-            return False
-        if not row['faculty_code'] in site['faculties'].keys():
-            return False
-        faculty = site['faculties'][row['faculty_code']]
-        return row['department_code'] in faculty.keys()
-
-    def entryExists(self, row, site):
-        if not self.parentsExist(row, site):
-            return False
-        parent = self.getParent(row, site)
-        return row['code'] in parent.keys()
-
-    def getParent(self, row, site):
-        dept = site['faculties'][row['faculty_code']][row['department_code']]
-        return dept.certificates
-
-    def getEntry(self, row, site):
-        if not self.entryExists(row, site):
-            return None
-        parent = self.getParent(row, site)
-        return parent.get(row['code'])
-
-    def addEntry(self, obj, row, site):
-        parent = self.getParent(row, site)
-        parent.addCertificate(obj)
-        return
-
-    def delEntry(self, row, site):
-        parent = self.getParent(row, site)
-        del parent[row['code']]
-        return
-
-class CertificateCourseProcessor(BatchProcessor):
-    """A batch processor for ICertificateCourse objects.
-    """
-    grok.provides(IBatchProcessor)
-    grok.context(Interface)
-    util_name = 'certificatecourseimporter'
-    grok.name(util_name)
-
-    name = u'CertificateCourse importer'
-    iface = ICertificateCourse
-
-    location_fields = ['course', 'level', 'faculty_code', 'department_code',
-                       'certificate_code',]
-    factory_name = 'waeup.CertificateCourse'
-
-    def parentsExist(self, row, site):
-        if not 'faculties' in site.keys():
-            return False
-        if not row['faculty_code'] in site['faculties'].keys():
-            return False
-        faculty = site['faculties'][row['faculty_code']]
-        if not row['department_code'] in faculty.keys():
-            return False
-        dept = faculty[row['department_code']]
-        return row['certificate_code'] in dept.certificates.keys()
-
-    def entryExists(self, row, site):
-        if not self.parentsExist(row, site):
-            return False
-        parent = self.getParent(row, site)
-        code = "%s_%s" % (row['course'].code, row['level'])
-        return code in parent.keys()
-
-    def getParent(self, row, site):
-        dept = site['faculties'][row['faculty_code']][row['department_code']]
-        return dept.certificates[row['certificate_code']]
-
-    def getEntry(self, row, site):
-        if not self.entryExists(row, site):
-            return None
-        parent = self.getParent(row, site)
-        return parent.get(row['course'])
-
-    def addEntry(self, obj, row, site):
-        parent = self.getParent(row, site)
-        parent.addCourseRef(row['course'],
-                            row['level'], row['core_or_elective'])
-        return
-
-    def delEntry(self, row, site):
-        parent = self.getParent(row, site)
-        parent.delCourseRef(row['course'].code, row['level'])
-        return