Changeset 8290 for main/waeup.kofa/trunk/src/waeup/kofa/applicants/batching.py

Timestamp:

26 Apr 2012, 17:01:32 (13 years ago)

Author:

Henrik Bettermann

Message:

Enable import of password and state. When application_number is given in create mode, construct applicant_id accordingly (do not use id generator) and store applicant with this application_number in the respective container. Attention: application_number can be any string.

More tests will follow.

File:

• main/waeup.kofa/trunk/src/waeup/kofa/applicants/batching.py (modified) (5 diffs)

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

@@ -23 +23 @@
 from zope.interface import Interface
 from zope.component import queryUtility
+from hurry.workflow.interfaces import IWorkflowState
 from zope.catalog.interfaces import ICatalog
 from waeup.kofa.interfaces import (
-    IBatchProcessor, IObjectConverter, FatalCSVError, IGNORE_MARKER)
+    IBatchProcessor, IObjectConverter, FatalCSVError, IGNORE_MARKER,
+    IObjectHistory, IUserAccount)
+from waeup.kofa.interfaces import MessageFactory as _
 from waeup.kofa.utils.batching import BatchProcessor
 from waeup.kofa.applicants.interfaces import (
     IApplicantsContainer, IApplicant, IApplicantUpdateByRegNo)
+from waeup.kofa.applicants.workflow import  IMPORTABLE_STATES
 
 class ApplicantsContainerProcessor(BatchProcessor):
@@ -89 +93 @@
     def available_fields(self):
         return sorted(list(set(
-            ['application_number','reg_number','container_code'] + getFields(
+            ['application_number','reg_number',
+            'container_code','state','password'] + getFields(
                 self.iface).keys())))
 
@@ -150 +155 @@
         parent = self.getParent(row, site)
         parent.addApplicant(obj)
+        # We have to log this if state is provided. If not,
+        # logging is done by the event handler handle_applicant_added
+        if row.has_key('state'):
+            parent.__parent__.logger.info(
+            '%s - Application initialized' % obj.applicant_id)
+        history = IObjectHistory(obj)
+        history.addMessage(_('Application initialized'))
         return
 
@@ -158 +170 @@
             del parent[applicant.application_number]
         pass
+
+    def updateEntry(self, obj, row, site):
+        """Update obj to the values given in row.
+        """
+        items_changed = ''
+
+        # Remove application_number from row if empty
+        if row.has_key('application_number') and row['application_number'] in (
+            None, IGNORE_MARKER):
+            row.pop('application_number')
+
+        # Update applicant_id fom application_number and container code
+        # if application_number is given
+        if row.has_key('application_number'):
+            obj.applicant_id = u'%s_%s' % (
+                row['container_code'], row['application_number'])
+            row.pop('application_number')
+
+        # Update password
+        passwd = row.get('password', IGNORE_MARKER)
+        if passwd not in ('', IGNORE_MARKER):
+            IUserAccount(obj).setPassword(passwd)
+            row.pop('password')
+
+        # Update registration state
+        state = row.get('state', IGNORE_MARKER)
+        if state not in (IGNORE_MARKER, ''):
+            value = row['state']
+            IWorkflowState(obj).setState(value)
+            msg = _("State '${a}' set", mapping = {'a':value})
+            history = IObjectHistory(obj)
+            history.addMessage(msg)
+            row.pop('state')
+
+        # apply other values...
+        items_changed = super(ApplicantProcessor, self).updateEntry(
+            obj, row, site)
+
+        # Log actions...
+        parent = self.getParent(row, site)
+        if hasattr(obj,'application_number'):
+            # Update mode: the applicant exists and we can get the applicant_id
+            parent.__parent__.logger.info(
+                '%s - Application record updated: %s'
+                % (obj.applicant_id, items_changed))
+        else:
+            # Create mode: the applicant does not yet exist
+            parent.logger.info('Application record imported: %s' % items_changed)
+        return items_changed
 
     def getMapping(self, path, headerfields, mode):
@@ -186 +247 @@
         errs, inv_errs, conv_dict =  converter.fromStringDict(
             row, self.factory_name, mode=mode)
+        if row.has_key('state') and \
+            not row['state'] in IMPORTABLE_STATES:
+            if row['state'] not in (IGNORE_MARKER, ''):
+                errs.append(('state','not allowed'))
+            else:
+                # state is an attribute of Applicant and must not
+                # be changed if empty
+                conv_dict['state'] = IGNORE_MARKER
+        application_number = row.get('application_number', IGNORE_MARKER)
+        if application_number in (IGNORE_MARKER, ''):
+                conv_dict['application_number'] = IGNORE_MARKER
         return errs, inv_errs, conv_dict