Changeset 7262 for main/waeup.sirp/trunk/src/waeup/sirp/applicants/batching.py

Timestamp:

4 Dec 2011, 08:36:14 (13 years ago)

Author:

Henrik Bettermann

Message:

Add Applicant Importer (tests will follow).

File:

• main/waeup.sirp/trunk/src/waeup/sirp/applicants/batching.py (modified) (2 diffs)

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

@@ -22 +22 @@
 from waeup.sirp.interfaces import IBatchProcessor
 from waeup.sirp.utils.batching import BatchProcessor
-from waeup.sirp.applicants.interfaces import IApplicantsContainer
+from waeup.sirp.applicants.interfaces import (
+    IApplicantsContainer, IApplicant)
 
 class ApplicantsContainerImporter(BatchProcessor):
@@ -64 +65 @@
         del parent[row['code']]
         return
+
+class ApplicantProcessor(BatchProcessor):
+    """A batch processor for IApplicant objects.
+    """
+    grok.implements(IBatchProcessor)
+    grok.provides(IBatchProcessor)
+    grok.context(Interface)
+    util_name = 'applicantimporter'
+    grok.name(util_name)
+    name = u'Applicant Importer'
+    iface = IApplicant
+    location_fields = []
+    factory_name = 'waeup.Applicant'
+    location_fields = ['container_code', 'application_number']
+
+    mode = None
+
+    @property
+    def req(self):
+        result = dict(
+            create = ['container_code'] + self.required_fields,
+            update = self.location_fields,
+            remove = self.location_fields,
+        )
+        return result
+
+    def parentsExist(self, row, site):
+        if not 'applicants' in site.keys():
+            return False
+        return row['container_code'] in site['applicants'].keys()
+
+    def entryExists(self, row, site):
+        if not self.parentsExist(row, site):
+            return None
+        parent = self.getParent(row, site)
+        if 'application_number' in row.keys() and row['application_number']:
+            if row['application_number'] in parent.keys():
+                return parent[row['application_number']]
+        return None
+
+    def getParent(self, row, site):
+        return site['applicants'][row['container_code']]
+
+    def getEntry(self, row, site):
+        return self.entryExists(row, site)
+
+    def addEntry(self, obj, row, site):
+        parent = self.getParent(row, site)
+        parent.addApplicant(obj)
+        return
+
+    def delEntry(self, row, site):
+        applicant = self.entryExists(row, site)
+        if applicant:
+            parent = self.getParent(row, site)
+            del parent[row['application_number']]
+        pass