source: WAeUP_SRP/trunk/WAeUPImport.py @ 9964

Last change on this file since 9964 was 9233, checked in by Henrik Bettermann, 12 years ago

We do not need to remove the catalog entry.
  • Property svn:keywords set to Id
File size: 69.6 KB
Line 
1#-*- mode: python; mode: fold -*-
2# (C) Copyright 2005 The WAeUP group  <http://www.waeup.org>
3# Author: Joachim Schmitz (js@aixtraware.de)
4#
5# This program is free software; you can redistribute it and/or modify
6# it under the terms of the GNU General Public License version 2 as published
7# by the Free Software Foundation.
8#
9# This program is distributed in the hope that it will be useful,
10# but WITHOUT ANY WARRANTY; without even the implied warranty of
11# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12# GNU General Public License for more details.
13#
14# You should have received a copy of the GNU General Public License
15# along with this program; if not, write to the Free Software
16# Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
17# 02111-1307, USA.
18#
19# $Id: WAeUPImport.py 9233 2012-09-26 04:11:16Z henrik $
20"""The WAeUP Tool Box.
21"""
22
23#from AccessControl import ClassSecurityInfo
24#from Acquisition import aq_inner
25#from Acquisition import aq_parent
26#from Globals import DTMLFile
27#from Globals import InitializeClass
28from OFS.SimpleItem import SimpleItem
29from zExceptions import BadRequest
30
31#from Products.CMFCore.utils import getToolByName
32#from Products.CPSSchemas.DataStructure import DataStructure
33#from Products.CPSSchemas.DataModel import DataModel
34#from Products.CPSSchemas.StorageAdapter import MappingStorageAdapter
35from Products.CMFCore.ActionProviderBase import ActionProviderBase
36#from Products.CMFCore.permissions import View
37#from Products.ZCatalog.ZCatalog import ZCatalog
38#from Products.CMFCore.permissions import ModifyPortalContent
39#from Products.CMFCore.permissions import ManagePortal
40from Products.CMFCore.utils import UniqueObject
41#from Products.CMFCore.URLTool import URLTool
42from Products.CMFCore.utils import getToolByName
43from Globals import package_home,INSTANCE_HOME
44from Products.AdvancedQuery import Eq, Between, Le,In
45import csv,re,os,sys
46from shutil import copy2
47import DateTime,time
48import logging
49p_home = package_home(globals())
50i_home = INSTANCE_HOME
51from utils import makeDigest
52
53NO_KEY = '----'
54IGNORE = 'ignore'
55class WAeUPImport(UniqueObject, SimpleItem, ActionProviderBase): ###(
56    """ WAeUPImport """
57    required_modes = ('create',)
58
59    def __init__(self,waeup_tool): ###(
60        self.students_folder = waeup_tool.portal_url.getPortalObject().campus.students
61        self.member = member = waeup_tool.portal_membership.getAuthenticatedMember()
62        self.import_date = DateTime.DateTime()
63        self.imported_by = str(member)
64        #self.current = DateTime.DateTime().strftime("%d-%m-%y_%H_%M_%S")
65        self.waeup_tool = waeup_tool
66        self.session = waeup_tool.getSessionId()[0]
67        self.academics_folder = waeup_tool.portal_url.getPortalObject().campus.academics
68        self.schema_tool = getToolByName(waeup_tool, 'portal_schemas')
69        self.layout_tool = getToolByName(waeup_tool, 'portal_layouts')
70        self.types_tool = getToolByName(waeup_tool, 'portal_types')
71        self.portal_workflow = getToolByName(waeup_tool, 'portal_workflow')
72        self.portal_url = getToolByName(waeup_tool, 'portal_url')
73        self.portal_catalog = waeup_tool.portal_catalog
74        self.portal_directories = waeup_tool.portal_directories
75        self.students_catalog = waeup_tool.students_catalog
76        self.courses_catalog = waeup_tool.courses_catalog
77        self.course_results = waeup_tool.course_results
78        self.payments_catalog = waeup_tool.payments_catalog
79        self.applicants_catalog = waeup_tool.applicants_catalog
80        self.removed_student_ids = waeup_tool.removed_student_ids
81        #self.mode = mode
82        # self.import_method = getattr(self, '%s' % mode,None)
83        errors = []
84        # if self.import_method is None:
85        #     errors.append('No importer method %s' % mode)
86        self.pending_path = "%s/import/%s.pending" % (i_home,self.plural_name)
87        self.pending_tmp = "%s/import/%s.pending.tmp" % (i_home,self.plural_name)
88        self.pending_backup = "%s/import/%s.pending.old" % (i_home,self.plural_name)
89        self.pending_fn = os.path.split(self.pending_path)[1]
90        self.imported_path = "%s/import/%s.imported" % (i_home,self.plural_name)
91        self.imported_fn = os.path.split(self.imported_path)[1]
92        iname = "import_%s" % self.name
93        self.logger = logging.getLogger('WAeUPImport.%sImport' % self.plural_name.capitalize())
94        self.schema = self.schema_tool._getOb(iname,None)
95        #self.pending_schema = self.schema_tool._getOb("%s_pending" % iname,None)
96        self.layout = self.layout_tool._getOb(iname,None)
97        while True:
98            if self.schema is None:
99                errors.append('no schema %s' % iname)
100            # if self.pending_schema is None:
101            #     self.pending_schema = self.schema
102            if self.layout is None:
103                errors.append('no such layout %s' % iname)
104            if errors:
105                break
106            self.data_keys = self.schema.keys()
107            self.csv_keys = self.schema.keys()
108            info = {}
109            info['imported_from'] = ''
110            info['import_record_no'] = 0
111            info['imported_by'] = self.imported_by
112            info['import_date'] = self.import_date.strftime("%d/%m/%y %H:%M:%S")
113            info['error'] = ''
114            self.info = info
115            self.csv_keys.extend(self.info)
116            self.validators = {}
117            for widget in self.layout.keys():
118                self.validators[widget] = self.layout[widget].validate
119            self.required_keys = {}
120            for mode in self.required_modes:
121                self.required_keys[mode] = [self.layout.getIdUnprefixed(id)
122                                    for id,widget in self.layout.objectItems()
123                                    if widget.is_required]
124            break
125        self.init_errors = ','.join(errors)
126    ###)
127
128    def findStudent(self,mode,student_id=None, matric_no=None, jamb_reg_no=None): ###(
129        #logger = logging.getLogger('WAeUPImport.findStudent')
130        student_record = None
131        msg = ''
132        key_used = ''
133        while True:
134            if student_id:
135                key_used = 'student_id'
136                res = self.students_catalog(id = student_id)
137                if not res:
138                    msg = "no student with id %s" % student_id
139                    break
140                student_record = res[0]
141                #if matric_no and student_record.matric_no:
142                #    if  matric_no != student_record.matric_no:
143                #        #msg = "old matric_no %s overwritten with %s" % (student_record.matric_no,matric_no)
144                #        logger.info("%s, old matric_no %s overwritten with %s" % (student_record.id,student_record.matric_no,matric_no))
145                #if jamb_reg_no and student_record.jamb_reg_no:
146                #    if jamb_reg_no != student_record.jamb_reg_no:
147                #        #msg = "old reg_no %s overwritten with %s" % (student_record.jamb_reg_no,jamb_reg_no)
148                #        logger.info("%s, old reg_no %s overwritten with %s" % (student_record.id,student_record.jamb_reg_no,jamb_reg_no))
149            elif jamb_reg_no:
150                key_used = 'jamb_reg_no'
151                res = self.students_catalog(jamb_reg_no = jamb_reg_no)
152                if res:
153                    if mode == 'create':
154                        msg = "jamb_reg_no exists"
155                        break
156                else:
157                    if mode == 'edit':
158                        msg = "no student with jamb_reg_no %s" % jamb_reg_no
159                        break
160                student_record = res[0]
161            elif matric_no:
162                key_used = 'matric_no'
163                res = self.students_catalog(matric_no = matric_no)
164                if not res:
165                    msg = "no student with matric_no %s" % matric_no
166                    break
167                student_record = res[0]
168            else:
169                msg = "neither id, matric_no nor reg_no specified"
170            break
171        d = {}
172        d['student_record'] = student_record
173        d['key_used'] = key_used
174        d['msg'] = msg
175        return d
176    ###)
177
178    def makeIdLists(self): ###(
179        pending_digests = []
180        pending = []
181        # pending_student_ids = []
182        # pending_matric_nos = []
183        # pending_reg_ns = []
184        if os.path.exists(self.pending_path):
185            datafile = open(self.pending_path,"r")
186            reader = csv.reader(datafile)
187            old_headline = reader.next()
188            #datafile.seek(0)
189            pending_csv_reader = csv.DictReader(datafile,old_headline,)
190            #pending_csv_reader.next() # skip headline
191            for item in pending_csv_reader:
192                digest = makeDigest(item,self.data_keys)
193                if digest not in pending_digests:
194                    pending_digests += digest,
195                    pending += item,
196            datafile.close()
197            #copy2(self.pending_path,self.pending_backup)
198        return pending, pending_digests
199    ###)
200
201    def checkHeadline(self,headline): ###(
202        """ check the headline of a csv file """
203        import_keys = [k.strip() for k in headline if not (k.strip().startswith('ignore')
204                                                        or k.strip() in self.info.keys())]
205        # import_keys = [k.strip() for k in headline if not (k.strip() in self.info.keys())]
206        diff2schema = set(import_keys).difference(set(self.schema.keys()))
207        diff2layout = set(import_keys).difference(set(self.layout.keys()))
208        #if diff2schema and diff2schema != set(['id',]):
209        if diff2schema:
210            return list(diff2schema)
211        return []
212    ###)
213
214    def getHeadlineFields(self,headline,values): ###(
215        """ check the headline of a csv file """
216        # import_keys = [k.strip() for k in headline if not (k.strip().startswith('ignore')
217        #                                                 or k.strip() in self.info.keys())]
218        import_keys = [k.strip() for k in headline if not (k.strip() in self.info.keys())]
219        info_keys = [k.strip() for k in headline if k.strip() in self.info.keys()]
220        si = set(import_keys)
221        ss = set(self.schema.keys())
222
223        invalid_keys = si - ss
224        keys = []
225        i = 0
226        duplicates = False
227        singels = []
228        msg = ''
229        while True:
230            if len(values) != len(import_keys):
231                if len(values) == len(import_keys) + len(info_keys):
232                    msg += "fields from pending data file in headline"
233                else:
234                    msg += "%d fields in headline but %d values" % (len(import_keys),len(values))
235                break
236            for k in import_keys:
237                if k in singels:
238                    keys += (k,'%s' % k,values[i],'(duplicate)'),
239                    msg += ("duplicate %s," % k)
240                    keys[singels.index(k)] = (k,'%s' % k,values[singels.index(k)],'(duplicate)')
241                elif k in invalid_keys and not k.startswith(IGNORE):
242                    keys += (k,NO_KEY,values[i],'(invalid)'),
243                else:
244                    keys += (k,k,values[i],''),
245                i += 1
246                singels += k,
247            break
248        return msg,keys
249    ###)
250###)
251
252class ApplicationImport(WAeUPImport):###(
253    name = "application"
254    plural_name = "%ss" % name
255    commit_after = 1000
256
257    def create(self,mapping):###(
258        reg_no = mapping.get('reg_no')
259        msg = ''
260        while True:
261            try:
262                self.applicants_catalog.addRecord(**mapping)
263            except ValueError:
264                msg =  "applicant record with reg_no %s already exists" % reg_no
265            break
266        return reg_no,msg,mapping
267    ###)
268   
269    def remove(self,mapping):
270        reg_no = mapping.get('reg_no')
271        msg = ''
272        while True:
273            if self.applicants_catalog.getRecordByKey(reg_no) is None:
274                msg =  "no application record with reg_no %(reg_no)s" % vars()
275                break
276            self.applicants_catalog.deleteRecord(reg_no)
277            break
278        return reg_no,msg,mapping   
279   
280    def edit(self,mapping):###(
281        reg_no = mapping.get('reg_no')
282        status = mapping.get('status')
283        jamb_reg_no = mapping.get('jamb_reg_no')
284        msg = ''
285        while True:
286            if jamb_reg_no:
287                res = self.applicants_catalog(jamb_reg_no = jamb_reg_no.upper())
288                if not len(res):
289                    res = self.applicants_catalog(jamb_reg_no = jamb_reg_no.lower())
290                if not len(res):
291                    msg =  "applicant record with jamb_reg_no %s does not exist" % jamb_reg_no
292                    break
293            else:
294                res = self.applicants_catalog(reg_no = reg_no)
295            if len(res):
296                if res[0].status == 'created' and status != 'created':
297                    msg =  "student object with id %s for %s already created, status cannot be changed" % (res[0].student_id, reg_no)
298                elif status == 'created' and res[0].status != 'created':
299                    msg =  "student object for %s has not yet been created, status cannot be set to 'created'" % (reg_no)
300                else:
301                    self.applicants_catalog.modifyRecord(**mapping)
302            else:
303                msg =  "applicant record with reg_no %s does not exist" % reg_no
304            break
305        return reg_no,msg,mapping
306    ###)
307
308###)
309
310class CertificateImport(WAeUPImport):###(
311    name = "certificate"
312    plural_name = "%ss" % name
313    commit_after = 100000
314
315    def create(self,mapping):###(
316        if getattr(self,'_v_certificate_list',None) is None:
317            self._v_certificate_list = []
318        if getattr(self,'_v_department_certificates',None) is None:
319            departments = self.portal_catalog(portal_type = "Department")
320            self._v_department_certificates = {}
321            for department  in departments:
322                certificates_container = getattr(department.getObject(),"certificates",None)
323                self._v_department_certificates[department.getId] = {'container': certificates_container,
324                                                            'certificates': certificates_container.objectIds(),
325                                                            }
326        department_id = mapping['department_code']
327        msg = ''
328        certificate_id = mapping.get('code')
329        while True:
330            department_certificates = self._v_department_certificates.get(department_id,None)
331            if department_certificates is None:
332                msg =  "No Department with ID: %s" % department_id
333                break
334            certificates_container = department_certificates['container']
335            certificates = department_certificates['certificates']
336            if certificate_id in self._v_certificate_list:
337                msg =  "Duplicate Certificate ID: %s" % department_id
338                break
339            if certificate_id in certificates:
340                msg =  "Duplicate Certificate ID: %s" % department_id
341                break
342            try:
343                certificates_container.invokeFactory('Certificate', certificate_id)
344            except BadRequest,E:
345                msg =  "%s" % E
346                break
347            self._v_certificate_list.append(certificate_id)
348            certificate = getattr(certificates_container,certificate_id)
349            certificate.getContent().edit(mapping=mapping)
350            break
351        return certificate_id,msg,mapping
352    ###)
353
354    def edit(self,mapping):###(
355        certificate_id = mapping.get('code')
356        res = self.portal_catalog(id=certificate_id)
357        msg = ''
358        while True:
359            if not res:
360                msg =  "no certificate with id: %s" % certificate_id
361                break
362            c = res[0].getObject()
363            c.getContent().edit(mapping=mapping)
364            break
365        return certificate_id,msg,mapping
366    ###)
367###)
368
369class CourseImport(WAeUPImport):###(
370    name = "course"
371    plural_name = "%ss" % name
372    commit_after = 1000
373
374    def create(self,mapping):###(
375        if getattr(self,'_v_course_list',None) is None:
376            self._v_course_list = []
377        if getattr(self,'_v_department_courses',None) is None:
378            departments = self.portal_catalog(portal_type = "Department")
379            self._v_department_courses = {}
380            for department in departments:
381                courses_container = getattr(department.getObject(),"courses",None)
382                if courses_container is not None:
383                    self._v_department_courses[department.getId] = {'container': courses_container,
384                                                                    'courses': courses_container.objectIds(),
385                                                                   }
386        department_id = mapping['department_code']
387        course_id = mapping.get('code','')
388        msg = ''
389        while True:
390            department_courses = self._v_department_courses.get(department_id,None)
391            if department_courses is None:
392                msg =  "no department with id: %(department_id)s" % vars()
393                break
394            courses_container = department_courses['container']
395            courses = department_courses['courses']
396            if course_id in self._v_course_list:
397                msg =  "duplicate course id: %(course_id)s" % vars()
398                break
399            if course_id in courses:
400                msg =  "course %(course_id)s already exists in department %(department_id)s" % vars()
401                break
402            try:
403                courses_container.invokeFactory('Course', course_id)
404            except BadRequest,E:
405                msg =  "%s" % E
406                break
407            self._v_course_list.append(course_id)
408            course = getattr(courses_container,course_id)
409            course.getContent().edit(mapping=mapping)
410            break
411        return course_id,msg,mapping
412    ###)
413
414    def edit(self,mapping): ###(
415        course_id = mapping.get('code','')
416        course = self.courses_catalog.getRecordByKey(course_id)
417        msg = ''
418        while True:
419            if course is None:
420                msg =  "no course with id: %s" % course_id
421                break
422            course_object = getattr(getattr(getattr(getattr(self.academics_folder,course.faculty),
423                                    course.department),
424                                    'courses'),
425                                    course_id)
426            course_object.getContent().edit(mapping=mapping)
427            break
428        return course_id,msg,mapping
429    ###)
430
431    def remove(self,mapping): ###(
432        course_id = mapping.get('code','')
433        course = self.courses_catalog.getRecordByKey(course_id)
434        msg = ''
435        while True:
436            if course is None:
437                msg =  "no course with id: %s" % course_id
438                break
439            courses = getattr(getattr(getattr(self.academics_folder,course.faculty),
440                                    course.department),
441                                    'courses')
442            courses.manage_delObjects((course_id),)     
443            break
444        return course_id,msg,mapping
445    ###)   
446   
447###)
448
449class CourseResultImport(WAeUPImport):###(
450    """ CourseresultImport """
451    name = "course_result"
452    plural_name = "%ss" % name
453    commit_after = 1000000
454    required_modes = ('create','edit','remove')
455
456    def create(self,mapping):###(
457        students_folder = self.portal_url.getPortalObject().campus.students
458        if getattr(self,'_v_courses',None) is None:
459            res = self.courses_catalog()
460            self._v_courses = {}
461            for brain in res:
462                self._v_courses[brain.code] = brain
463        if getattr(self,'_v_level_created',None) is None:
464            self._v_level_created = []
465        if getattr(self,'_v_student_study_course',None) is None:
466            self._v_student_study_course = {}
467        msg = ''
468        key = ''
469        matric_no = mapping.get('matric_no','')
470        id = mapping.get('id','')
471        while True:
472            course_id = mapping.get('code')
473            if course_id not in self._v_courses.keys():
474                msg = "no course with id: %s" % course_id
475                break
476            result = self.findStudent('create',student_id=id,matric_no=matric_no)
477            msg = result['msg']
478            if msg:
479                break
480            student_record = result['student_record']
481            student_id = mapping['student_id']  = student_record.id
482            level_id = mapping.get('level_id','')
483            code = mapping.get('code','')
484            level_ident = "%(student_id)s_%(level_id)s" % vars()
485            if level_ident not in self._v_level_created:
486                context = self._v_student_study_course.get(student_id,None)
487                if context is None:
488                    try:
489                        context = getattr(getattr(students_folder,
490                                                "%(student_id)s" % vars()),
491                                        'study_course')
492                        self._v_student_study_course[student_id] = context
493                    except:
494                        msg = "could not create level %(level_id)s for %(student_id)s" % vars()
495                        break
496                if level_id not in context.objectIds():
497                    context.invokeFactory('StudentStudyLevel',"%(level_id)s" % vars())
498                    level = getattr(context,"%(level_id)s" % vars())
499                    self.portal_workflow.doActionFor(level,'open')
500                    session_id = mapping.get('session_id','')
501                    if session_id:
502                        level.getContent().edit(mapping={'session': "%s" % session_id,})
503                    self.portal_workflow.doActionFor(level,'close')
504                    self._v_level_created += level_ident,
505            mapping['key'] = key = "%(student_id)s|%(level_id)s|%(code)s" % vars()
506            #overwrite semester and credits in create mode
507            for k in ('semester','credits',):
508                mapping[k] = getattr(self._v_courses[course_id],k)
509            # edit course result in create mode if it exists
510            if self.course_results.getRecordByKey(key) is None:
511                try:
512                    self.course_results.addRecord(**mapping)
513                except ValueError:
514                    msg = "unknown error: %s" % key
515            else:
516                self.course_results.modifyRecord(**mapping)
517            break
518        return key,msg,mapping
519    ###)
520
521    def edit(self,mapping): ###(
522        msg = ''
523        key = ''
524        matric_no = mapping.get('matric_no','')
525        id = mapping.get('id','')
526        while True:
527            result = self.findStudent('edit',student_id=id,matric_no=matric_no)
528            msg = result['msg']
529            if msg:
530                break
531            student_record = result['student_record']
532            student_id = student_record.id
533            level_id = mapping.get('level_id','')
534            code = mapping.get('code','')
535            #code = mapping['code']
536            mapping['key'] = key = "%(student_id)s|%(level_id)s|%(code)s" % vars()
537            if self.course_results.getRecordByKey(key) is None:
538                msg =  "no course result with key %(key)s" % vars()
539                break
540            # don't overwrite session id but check if session ids match
541            # (helps to avoid overwriting of course results)
542            session_in_course_result = self.course_results.getRecordByKey(key)['session_id']
543            if mapping.get('session_id','') and not session_in_course_result == mapping.get('session_id',''):
544                msg =  "import session_id %s does not match session_id %s in course result" % (mapping['session_id'],session_in_course_result)
545                break
546            self.course_results.modifyRecord(**mapping)
547            break
548        return key,msg,mapping
549    ###)
550
551    def remove(self,mapping):###(
552        key = ''
553        msg = ''
554        matric_no = mapping.get('matric_no','')
555        id = mapping.get('id','')
556        while True:
557            result = self.findStudent('edit',student_id=id,matric_no=matric_no)
558            msg = result['msg']
559            if msg:
560                break
561            student_record = result['student_record']
562            student_id = student_record.id
563            level_id = mapping.get('level_id','')
564            code = mapping.get('code','')
565            key = "%(student_id)s|%(level_id)s|%(code)s" % vars()
566            if self.course_results.getRecordByKey(key) is None:
567                msg =  "no course result with key %(key)s" % vars()
568                break
569            self.course_results.deleteRecord(key)
570            break
571        return key,msg,mapping
572    ###)
573###)
574
575class CertificateCourseImport(WAeUPImport):###(
576    name = "certificate_course"
577    plural_name = "%ss" % name
578    commit_after = 1000
579    required_modes = ('create','edit')
580
581    def create(self,mapping):
582        if getattr(self,'_v_courses',None) is None:
583            res = self.courses_catalog()
584            self._v_courses= [course.code for course in res]
585        if getattr(self,'_v_ceritficates',None) is None:
586            res = self.portal_catalog(portal_type = "Certificate")
587            self._v_certificates = {}
588            for cert in res:
589                self._v_certificates[cert.getId] = cert.getObject()
590        msg = ''
591        while True:
592            certificate_course_id = mapping.get('code')
593            if certificate_course_id not in self._v_courses:
594                msg =  "no course with id: %s" % certificate_course_id
595                break
596            cert_id = mapping['certificate_code']
597            cert = self._v_certificates.get(cert_id,None)
598            if cert is None:
599                msg =  "no certificate with id: %s" % cert_id
600                break
601            level_id = mapping.get('level')
602            level = getattr(cert,level_id,None)
603            if level is None:
604                cert.invokeFactory('StudyLevel', level_id)
605                level = getattr(cert,level_id,None)
606            elif hasattr(level,certificate_course_id):
607                msg =  "duplicate certificate course id: %(certificate_course_id)s " % vars()
608                msg += "in %(cert_id)s/ %(level_id)s" % vars()
609                break
610            level.invokeFactory('CertificateCourse', certificate_course_id)
611            c = getattr(level,certificate_course_id)
612            c.getContent().edit(mapping=mapping)
613            break
614        return certificate_course_id,msg,mapping
615    ###)
616
617class DepartmentImport(WAeUPImport):###(
618    name = "department"
619    plural_name = "%ss" % name
620    commit_after = 1000
621
622    def create(self,mapping):###(
623        "create a department in the correct faculty"
624        faculty_id = mapping['faculty_code']
625        msg = ''
626        if getattr(self,'_v_faculties',None) is None:
627            res = self.portal_catalog(portal_type = "Faculty")
628            self._v_faculties = {}
629            for f in res:
630                self._v_faculties[f.getId] = f.getObject()
631        department_id = mapping.get('code','')
632        while True:
633            faculty = self._v_faculties.get(faculty_id,None)
634            if faculty is None:
635                msg =  "no faculty with id: %s" % faculty_id
636                break
637            else:
638                d = getattr(faculty,department_id,None)
639                if d is None or d.portal_type == "Faculty":
640                    try:
641                        faculty.invokeFactory('Department', department_id)
642                    except BadRequest,E:
643                        msg =  "%s" % E
644                        break
645                    d = getattr(faculty,department_id)
646                    d.invokeFactory('CoursesFolder','courses')
647                    courses = getattr(d,'courses')
648                    dict = {'Title': 'Courses'}
649                    courses.getContent().edit(mapping=dict)
650                    d.invokeFactory('CertificatesFolder','certificates')
651                    certificates = getattr(d,'certificates')
652                    dict = {'Title': 'Certificates'}
653                    certificates.getContent().edit(mapping=dict)
654                    d.getContent().edit(mapping=mapping)
655            break
656        return department_id,msg,mapping
657    ###)
658
659    def edit(self,mapping): ###(
660        "edit a department in the correct faculty"
661        academics_folder = self.portal_url.getPortalObject().campus.academics
662        faculty_id = mapping['faculty_code']
663        department_id = mapping.get('code','')
664        msg = ''
665        while True:
666            try:
667                d = getattr(getattr(academics_folder,faculty_id),department_id,None)
668            except KeyError:
669                msg =  "department %s or faculty %s wrong" % (department_id,faculty_id)
670                break
671            if d is None or d.portal_type == "Faculty":
672                msg =  "department %s not found" % (department_id)
673                break
674            d.getContent().edit(mapping=mapping)
675            break
676        return department_id,msg,mapping
677    ###)
678###)
679
680class FacultyImport(WAeUPImport):###(
681    name = "faculty"
682    plural_name = "faculties"
683    commit_after = 100
684   
685
686    def create(self,mapping): ###(
687        "create a faculty"
688        academics_folder = self.portal_url.getPortalObject().campus.academics
689        faculty_id = mapping.get('code','')
690        msg = ''
691        while True:
692            if faculty_id in academics_folder.objectIds():
693                msg =  "faculty with id: %s exists" % faculty_id
694                break
695            try:
696                academics_folder.invokeFactory('Faculty', faculty_id)
697            except BadRequest,E:
698                msg =  "%s" % E
699                break
700            f = getattr(academics_folder,faculty_id,None)
701            f.getContent().edit(mapping=mapping)
702            break
703        return faculty_id,msg,mapping
704        ###)
705
706    def edit(self,mapping): ###(
707        "edit a faculty"
708        academics_folder = self.portal_url.getPortalObject().campus.academics
709        faculty_id = mapping['code']
710        msg = ''
711        while True:
712            f = getattr(academics_folder,faculty_id,None)
713            if f is None:
714                msg =  "faculty with id: %s does not exist" % faculty_id
715            f.getContent().edit(mapping=mapping)
716            break
717        return faculty_id,msg,mapping
718    ###)
719###)
720
721class StudentImport(WAeUPImport):###(
722    name = "student"
723    plural_name = "%ss" % name
724    commit_after = 500
725
726    field2types_student = {   ###(
727                      'StudentApplication':
728                          {'id': 'application',
729                           #'title': 'Application Data',
730                           'wf_transition_return': 'close',
731                           'wf_transition_admit': 'remain',
732                           'wf_transition_graduate': 'close',
733                           'wf_transition_pay_school_fee': 'close',
734                           'wf_transition_validate_courses': 'close',
735                           'wf_transition_reject_clearance': 'remain',
736                           'fields':
737                             ('jamb_reg_no',
738                              'entry_mode',
739                              'entry_session',
740                              'jamb_score',
741                              'app_email',
742                              'app_mobile',
743                              'jamb_age',
744                              'jamb_state',
745                              'jamb_lga',
746                              'jamb_sex',
747                              'app_ac_pin',
748                              'app_reg_pin',
749                              'app_ac_date',                             
750                              )
751                              },
752                      'StudentClearance':
753                          {'id': 'clearance',
754                           #'title': 'Clearance/Eligibility Record',
755                           'wf_transition_return': 'close',
756                           'wf_transition_admit': 'remain',
757                           'wf_transition_graduate': 'close',
758                           'wf_transition_pay_school_fee': 'close',
759                           'wf_transition_validate_courses': 'close',
760                           'wf_transition_reject_clearance': 'open',
761                           'fields':
762                              ('matric_no',
763                              'nationality',
764                              'lga',
765                              'birthday',
766                              'clr_ac_pin',
767                              'request_date',
768                              'cleared_date',
769                              'clearance_officer',
770                              )
771                              },
772                         'StudentPersonal':
773                          {'id': 'personal',
774                           #'title': 'Personal Data',
775                           'wf_transition_return': 'open',
776                           'wf_transition_admit': 'remain',
777                           'wf_transition_graduate': 'close',
778                           'wf_transition_pay_school_fee': 'open',
779                           'wf_transition_validate_courses': 'open',
780                           'wf_transition_reject_clearance': 'remain',
781                           'fields':
782                             ('firstname',
783                              'middlename',
784                              'lastname',
785                              'sex',
786                              'email',
787                              'phone',
788                              'perm_address',
789                              'marit_stat',
790                              'disabled',
791                              )
792                              },
793                         'StudentStudyCourse':
794                          {'id': 'study_course',
795                           #'title': 'Study Course',
796                           'wf_transition_return': 'open',
797                           'wf_transition_admit': 'remain',
798                           'wf_transition_graduate': 'close',
799                           'wf_transition_pay_school_fee': 'open',
800                           'wf_transition_validate_courses': 'open',
801                           'wf_transition_reject_clearance': 'remain',
802                           'fields':
803                             ('study_course',
804                              'current_level',
805                              'current_session',
806                              'current_mode',  #is no longer used and visible but can still be imported
807                              'current_verdict',
808                              'previous_verdict',
809                              )
810                              },
811                         'StudentAccommodation':
812                          {'id': 'accommodation_final',
813                           'title': '',
814                           'wf_transition_return': 'remain',
815                           'wf_transition_admit': 'remain',
816                           'wf_transition_graduate': 'remain',
817                           'wf_transition_pay_school_fee': 'remain',
818                           'wf_transition_validate_courses': 'remain',
819                           'wf_transition_reject_clearance': 'remain',
820                           'fields':
821                           ('acco_maint_date',
822                              'acco_maint_code',
823                              'acco_maint_fee',
824                              'acco_maint_sc_pin',
825                              'acco_maint_pay_id',
826                              'acco_res_date',
827                              'acco_res_sc_pin',
828                              'bed',
829                              'session',
830                              'student_status',
831                              )     
832                              },
833                         'PaymentsFolder':
834                          {'id': 'payments',
835                           #'title': 'Payments',
836                           'wf_transition_return': 'open',
837                           'wf_transition_admit': 'open',
838                           'wf_transition_graduate': 'close',
839                           'wf_transition_pay_school_fee': 'open',
840                           'wf_transition_validate_courses': 'open',
841                           'wf_transition_reject_clearance': 'remain',
842                           'fields':
843                             ()
844                              },
845                         }
846    ###)
847
848    def create(self,mapping): ###(
849        "create student records due import"
850        logger = logging.getLogger('WAeUPImport.StudentImport.create')
851        students_folder = self.portal_url.getPortalObject().campus.students
852        jamb_reg_no = mapping.get('jamb_reg_no',None)
853        matric_no = mapping.get('matric_no',None)
854        entry_mode = mapping.get('entry_mode',None)
855        password = mapping.get('password',None)
856        msg = ''
857        student_id = mapping.get('id',None)
858        while True:
859            if student_id:
860                #msg = "student_id must not be specified in create mode"
861                #break
862                res = self.students_catalog(id = student_id)
863                if res:
864                    msg = "student_id %s already assigned" % res[0].id
865                    break     
866                self.waeup_tool.restorePictureFolder(student_id)           
867            else:
868                student_id = self.waeup_tool.generateStudentId('?')
869            if jamb_reg_no and not entry_mode == 'transfer':
870                res = self.students_catalog(jamb_reg_no = jamb_reg_no)
871                if res:
872                    msg = "jamb_reg_no already assigned to student %s" % res[0].id
873                    break
874            if matric_no:
875                res = self.students_catalog(matric_no = matric_no)
876                if res:
877                    msg = "matric_no already assigned to student %s" % res[0].id
878                    break
879            if not matric_no and not jamb_reg_no:
880                msg = "jamb_reg_no or matric_no must be specified"
881                break
882           
883            students_folder.invokeFactory('Student', student_id)
884            student_obj = getattr(students_folder,student_id)
885            f2t = self.field2types_student
886            d = {}
887            transition = mapping.get('reg_transition','admit')
888            if transition == 'admitted':
889                transition = 'admit'
890            elif transition == 'returning':
891                transition = 'return'
892            if transition not in ('admit','return','pay_school_fee','validate_courses','graduate','reject_clearance'):
893                msg = "no valid transition provided"
894                break
895            for pt in f2t.keys():
896                if pt == 'StudentAccommodation':
897                    if mapping.get('bed',None):
898                        student_obj.invokeFactory(pt,f2t[pt]['id'])
899                    else:
900                        continue
901                else:
902                    student_obj.invokeFactory(pt,f2t[pt]['id'])
903                sub_obj = getattr(student_obj,f2t[pt]['id'])
904                sub_doc = sub_obj.getContent()
905                #d['Title'] = f2t[pt]['title']
906                for field in f2t[pt]['fields']:
907                    d[field] = mapping.get(field,'')
908
909                if pt == "StudentApplication":
910                    #d['jamb_sex']  = 'M'
911                    #if mapping.get('sex'):
912                    #    d['jamb_sex']  = 'F'
913                    d['jamb_firstname'] = mapping.get('firstname',None)
914                    d['jamb_middlename'] = mapping.get('middlename',None)
915                    d['jamb_lastname'] = mapping.get('lastname',None)
916
917                # if pt == "StudyCourse":
918                #     for von,zu in (('entry_mode','current_mode'),
919                #                    ('entry_session','current_session')):
920                #         if mapping.get(zu,None) is None and mapping.get(von,None) is not None:
921                #             d[zu] = mapping[von]
922                sub_doc.edit(mapping = d)
923
924                #import pdb;pdb.set_trace()
925                new_state = f2t[pt]['wf_transition_%(transition)s' % vars()]
926                if new_state != "remain":
927                    self.portal_workflow.doActionFor(sub_obj,new_state,dest_container=sub_obj)
928            self.portal_workflow.doActionFor(student_obj,transition)
929            student_obj.manage_setLocalRoles(student_id, ['Owner',])
930            mapping['id'] = student_id
931            if password:
932                self.waeup_tool.makeStudentMember(student_id,password)
933            break
934        return student_id,msg,mapping
935    ###)
936
937    def remove(self,mapping): ###(
938        "remove student records due import"
939        logger = logging.getLogger('WAeUPImport.StudentImport.remove')
940        students_folder = self.portal_url.getPortalObject().campus.students
941        stdir = self.portal_directories.students
942        student_id = mapping.get('id',None)
943        msg = ''
944        export_file = "%s/export/students_removed.csv" % (i_home)
945        reimport_file = "%s/export/students_for_reimport.csv" % (i_home)
946       
947        toexport_for_reimport = {
948       
949                    'application':
950                             ('jamb_reg_no',
951                              'entry_mode',
952                              'entry_session',
953                              'jamb_score',
954                              'app_email',
955                              'app_mobile',
956                              'jamb_age',
957                              'jamb_state',
958                              'jamb_lga',
959                              'jamb_sex',
960                              'app_ac_pin',
961                              'app_reg_pin',
962                              'app_ac_date',                             
963                              ),
964                    'clearance':
965                              ('matric_no',
966                              'nationality',
967                              'lga',
968                              'birthday',
969                              'clr_ac_pin',
970                              'request_date',
971                              'cleared_date',
972                              'clearance_officer',
973                              ),
974                    'study_course':
975                              ('study_course',
976                              'current_level',
977                              'current_session',
978                              'current_verdict',
979                              'previous_verdict',
980                              ),
981                    'personal': 
982                             ('firstname',
983                              'middlename',
984                              'lastname',
985                              'sex',
986                              'email',
987                              'phone',
988                              'perm_address',
989                              'marit_stat',
990                              'disabled',
991                              ),
992                    'accommodation': 
993                             ('acco_maint_date',
994                              'acco_maint_code',
995                              'acco_maint_fee',
996                              'acco_maint_sc_pin',
997                              'acco_maint_pay_id',
998                              'acco_res_date',
999                              'acco_res_sc_pin',
1000                              'bed',
1001                              'session',
1002                              'student_status',
1003                              ),                             
1004                   }
1005
1006        sub_types = ['StudentApplication','StudentClearance','StudentPersonal','StudentStudyCourse','StudentAccommodation']
1007        non_image_keys = {}
1008        for i in sub_types:
1009            pt_ob = getattr(self.types_tool,i)
1010            sub_schemas = pt_ob.schemas
1011            for i in sub_schemas:
1012                if i.startswith('student_'):
1013                    schema = getattr(self.schema_tool,i)
1014                    field_id = i.replace('student_','')
1015                    non_image_keys[field_id] = [key for key in schema.keys()
1016                                                if schema[key].meta_type != "CPS Image Field"]
1017       
1018        # export field names must be unique but, unfortunately, firstname, middlename and lastname are not
1019        # thus we have to omit them
1020        non_image_keys['clearance'].remove('firstname')
1021        non_image_keys['clearance'].remove('middlename')
1022        non_image_keys['clearance'].remove('lastname')
1023        toexport = non_image_keys
1024        #import pdb;pdb.set_trace()
1025        while True:
1026            if hasattr(students_folder,student_id):
1027                # begin export
1028                line = []
1029                fields = ['student_id','reg_state','password']
1030                line_for_reimport = []
1031                fields_for_reimport = ['student_id','reg_state','password','import_mode']               
1032                #fields = []
1033                #for f in self.students_catalog.schema():
1034                #    fields.append(f)               
1035                for k in toexport.keys():
1036                    for f in toexport[k]:
1037                        fields.append(f)
1038                for k in toexport_for_reimport.keys():
1039                    for f in toexport_for_reimport[k]:
1040                        fields_for_reimport.append(f)                       
1041                if not os.path.exists(export_file):       
1042                    headline = ','.join(fields)
1043                    open(export_file,"a").write(headline +'\n')
1044                if not os.path.exists(reimport_file): 
1045                    headline_for_reimport = ','.join(fields_for_reimport)                   
1046                    open(reimport_file,"a").write(headline_for_reimport +'\n')                   
1047                format = '"%(' + ')s","%('.join(fields) + ')s"'
1048                format_for_reimport = '"%(' + ')s","%('.join(fields_for_reimport) + ')s"'
1049                res = self.students_catalog(id = student_id)
1050                student = res[0]
1051                student_obj = getattr(students_folder,student_id)
1052                #d = student.getFormattedStudentEntry(student)
1053                d = {'student_id':student_id,'reg_state':student.review_state,'import_mode':'create'}
1054                for k in toexport.keys()[0:]:
1055                    if k.startswith('acco'):
1056                        session = self.session
1057                        subobject = 'accommodation_' + session
1058                    else:
1059                        subobject = k
1060                    try:
1061                        object = getattr(student_obj,subobject)
1062                        object_doc = object.getContent()
1063                    except:
1064                        for f in toexport[k]:
1065                            d[f] = ''
1066                        continue
1067                    for f in toexport[k]:
1068                        d[f] = getattr(object_doc,f,'')
1069                if hasattr(stdir, student_id):
1070                    d['password'] = self.waeup_tool.getCredential(student_id)
1071                    stdir.deleteEntry(student_id)
1072                else:
1073                    d['password'] = "not set"
1074                self.waeup_tool.removePictureFolder(student_id)       
1075                line.append(format % d)
1076                open(export_file,"a").write('\n'.join(line) +'\n')
1077                line_for_reimport.append(format_for_reimport % d)
1078                open(reimport_file,"a").write('\n'.join(line_for_reimport) +'\n')               
1079                self.course_results.exportRemoveAllCourses(student_id = student_id, export = True, remove = True)
1080                # remove should be false, otherwise an uncatalog error occurs if payment objects exist
1081                self.payments_catalog.exportRemoveAllPayments(student_id = student_id, export = True, remove = False)
1082                self.waeup_tool.exportAllStudyLevels(student_id = student_id)
1083                # end export
1084                students_folder.manage_delObjects((student_id),) 
1085                try:
1086                    self.removed_student_ids.addRecord(id = student_id)
1087                except: 
1088                    msg = "Student already in removed_student_ids"
1089            else:
1090                msg = "Student object not found"
1091                break
1092     
1093            break
1094        return student_id,msg,mapping     
1095
1096
1097    def edit(self,mapping): ###(
1098        "edit student records due import"
1099        wftool = self.portal_workflow
1100        logger = logging.getLogger('WAeUPImport.StudentImport.edit')
1101        students_folder = self.portal_url.getPortalObject().campus.students
1102        student_id = mapping.get('id',None)
1103        jamb_reg_no = mapping.get('jamb_reg_no',None)
1104        matric_no = mapping.get('matric_no',None)
1105        editable_keys = mapping.keys()
1106        password = mapping.get('password',None)
1107        msg = ''
1108        while True:
1109            if student_id:
1110                res = self.students_catalog(id = student_id)
1111                if not res:
1112                    msg = "no student with id %s" % student_id
1113                    break
1114                student_record = res[0]
1115                if matric_no and student_record.matric_no:
1116                    if  matric_no != student_record.matric_no and not matric_no == 'transferred':
1117                        res = self.students_catalog(matric_no = matric_no)
1118                        if res:
1119                            msg = "matric_no already assigned to student %s" % res[0].id
1120                            break
1121                        msg = "old matric_no %s overwritten with %s" % (student_record.matric_no,matric_no)
1122                        #logger.info("%s, old matric_no %s overwritten with %s" % (student_record.id,student_record.matric_no,matric_no))
1123                if jamb_reg_no and student_record.jamb_reg_no:
1124                    if jamb_reg_no != student_record.jamb_reg_no:
1125                        res = self.students_catalog(jamb_reg_no = jamb_reg_no)
1126                        if res:
1127                            msg = "jamb_reg_no already assigned to student %s" % res[0].id
1128                            break
1129                        msg = "old jamb_reg_no %s overwritten with %s" % (student_record.jamb_reg_no,jamb_reg_no)
1130                        #logger.info("%s, old reg_no %s overwritten with %s" % (student_record.id,student_record.jamb_reg_no,jamb_reg_no))
1131            elif jamb_reg_no:
1132                res = self.students_catalog(jamb_reg_no = jamb_reg_no)
1133                if not res:
1134                    msg = "no student with jamb_reg_no %s" % jamb_reg_no
1135                    break
1136                student_record = res[0]
1137                editable_keys.remove('jamb_reg_no')
1138            elif matric_no:
1139                res = self.students_catalog(matric_no = matric_no)
1140                if not res:
1141                    msg = "no student with matric_no %s" % matric_no
1142                    break
1143                student_record = res[0]
1144                editable_keys.remove('matric_no')
1145            student_id = student_record.id
1146            student_obj = getattr(students_folder,student_id)
1147            f2t = self.field2types_student
1148            d = {}
1149            any_change = False
1150            #special treatment for StudentStudyLevel
1151            d['verdict']  = mapping.get('current_verdict','')
1152            d['session']  = mapping.get('current_session','')
1153            current_level = mapping.get('current_level','')
1154            transition = mapping.get('reg_transition',None)
1155            change_reg_state = mapping.get('change_reg_state',None)  # for brute force method
1156            # the validate_courses import transition is not really useful because it does not execute validate_courses.py
1157            if transition and transition not in ('admit','return','graduate','pay_school_fee','validate_courses','reject_clearance'):
1158                msg = "no valid transition provided"
1159                break     
1160            if transition:
1161                #import pdb;pdb.set_trace()
1162                try:
1163                    self.portal_workflow.doActionFor(student_obj,transition)
1164                except:
1165                    msg = "reg_transition not allowed"
1166                    break
1167            elif change_reg_state:
1168                msg = self.waeup_tool.changeStudentState(student_obj, change_reg_state)   
1169                if msg:
1170                    break             
1171               
1172            while d['session'] and d['verdict'] and current_level:
1173                sub_obj = getattr(student_obj,'study_course',None)
1174                if sub_obj is None:
1175                    break
1176                level_obj = getattr(sub_obj,current_level,None)
1177                if  level_obj is None:
1178                    break
1179                any_change = True
1180                level_obj.getContent().edit(mapping = d)
1181                try:
1182                    wftool.doActionFor(level_obj,'close')
1183                except:
1184                    pass
1185                break
1186           
1187            for pt in f2t.keys():
1188                #if pt == "StudentApplication":
1189                #    d['jamb_sex']  = 'M'
1190                #    if mapping.get('sex'):
1191                #        d['jamb_sex']  = 'F'
1192                intersect = set(f2t[pt]['fields']).intersection(set(editable_keys))
1193                #import pdb;pdb.set_trace()
1194                object_id = f2t[pt]['id']
1195                sub_obj = getattr(student_obj,object_id,None)
1196                if intersect and pt not in ('StudentStudyLevel',):
1197                    if sub_obj is None:
1198                        try:
1199                            student_obj.invokeFactory(pt,object_id)
1200                        except:
1201                            continue
1202                        sub_obj = getattr(student_obj,object_id)
1203                        #if f2t[pt]['title'] != '':
1204                        #    d['Title'] = f2t[pt]['title']
1205                    sub_doc = sub_obj.getContent()
1206                    for field in intersect:
1207                        changed = False
1208                        if getattr(sub_doc,field,None) != mapping.get(field,''):
1209                            any_change = True
1210                            changed = True
1211                            d[field] = mapping.get(field,'')
1212                        if changed:
1213                            sub_doc.edit(mapping = d)
1214                if transition:
1215                    new_state = f2t[pt]['wf_transition_%(transition)s' % vars()]
1216                    if new_state != "remain":
1217                        try:
1218                            self.portal_workflow.doActionFor(sub_obj,new_state,dest_container=sub_obj)
1219                        except:
1220                            pass
1221             
1222            if password:
1223                self.waeup_tool.editPassword(student_id,password)
1224            break
1225        return student_id,msg,mapping
1226    ###)
1227###)
1228
1229class StudentStudyLevelImport(WAeUPImport):###(
1230    """ StudentStudyLevelImport """
1231    name = "student_study_level"
1232    plural_name = "%ss" % name
1233    commit_after = 1000
1234    required_modes = ('create',)
1235
1236    def create(self,mapping): ###(
1237        "edit student levels and create StudentStudyLevel object if not existent"
1238        wftool = self.portal_workflow
1239        logger = logging.getLogger('WAeUPImport.StudentStudyLevelImport.create')
1240        students_folder = self.portal_url.getPortalObject().campus.students
1241        student_id = mapping.get('id',None)
1242        matric_no = mapping.get('matric_no',None)
1243        editable_keys = mapping.keys()
1244        key = ''
1245        msg = ''
1246        while True:
1247            result = self.findStudent('create',student_id=student_id,matric_no=matric_no)
1248            msg = result['msg']
1249            if msg:
1250                break
1251            student_record = result['student_record']
1252            student_id = student_record.id
1253            mapping['id'] = student_id
1254            session = mapping.get('session','')
1255            level = key = mapping.get('code','')
1256            if not level.isdigit():
1257                msg = 'student %s: imported level is empty' % (student_id,)
1258                break
1259            study_course_obj = getattr(getattr(students_folder,student_id),'study_course',None)
1260            if study_course_obj is None:
1261                msg = 'student %s: no study_course object' % student_id
1262                break
1263            level_obj = getattr(study_course_obj,level,None)
1264            if  level_obj is None:
1265                # The only difference to the edit method is that we create a StudentStudyLevel object
1266                try:
1267                    study_course_obj.invokeFactory('StudentStudyLevel',"%s" % level)
1268                    level_obj = getattr(context,"%s" % level)
1269                except:
1270                    continue
1271            level_obj.getContent().edit(mapping = mapping)
1272            level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1273            if level_review_state != "closed":
1274                wftool.doActionFor(level_obj,'close')
1275            break
1276        return key,msg,mapping
1277    ###)
1278
1279    def edit(self,mapping): ###(
1280        "edit student levels"
1281        wftool = self.portal_workflow
1282        logger = logging.getLogger('WAeUPImport.StudentStudyLevelImport.edit')
1283        students_folder = self.portal_url.getPortalObject().campus.students
1284        student_id = mapping.get('id',None)
1285        matric_no = mapping.get('matric_no',None)
1286        key = ''
1287        msg = ''
1288        while True:
1289            result = self.findStudent('create',student_id=student_id,matric_no=matric_no)
1290            msg = result['msg']
1291            if msg:
1292                break
1293            student_record = result['student_record']
1294            student_id = student_record.id
1295            mapping['id'] = student_id
1296            session = mapping.get('session','')
1297            level = key = mapping.get('code','')
1298            #import pdb;pdb.set_trace()
1299            if not level.isdigit():
1300                msg = 'student %s: imported level is empty' % (student_id,)
1301                break
1302            study_course_obj = getattr(getattr(students_folder,student_id),'study_course',None)
1303            if study_course_obj is None:
1304                msg = 'student %s: no study_course object' % student_id
1305                break
1306            level_obj = getattr(study_course_obj,level,None)
1307            if  level_obj is None:
1308                msg = 'student %s: no study_level object for level %s' % (student_id,level)
1309                break
1310            level_obj.getContent().edit(mapping = mapping)
1311            break
1312        return key,msg,mapping
1313    ###)
1314###)
1315
1316class VerdictImport(WAeUPImport):###(
1317    """ VerdictImport """
1318    name = "verdict"
1319    plural_name = "%ss" % name
1320    commit_after = 1000
1321    required_modes = ('create','edit')
1322
1323    def create(self,mapping): ###(
1324        "edit student verdicts and create StudentStudyLevel object if not existent"
1325        wftool = self.portal_workflow
1326        logger = logging.getLogger('WAeUPImport.VerdictImport.create')
1327        students_folder = self.portal_url.getPortalObject().campus.students
1328        student_id = mapping.get('id',None)
1329        matric_no = mapping.get('matric_no',None)
1330        editable_keys = mapping.keys()
1331        key = ''
1332        while True:
1333            result = self.findStudent('create',student_id=student_id,matric_no=matric_no)
1334            #student_record,msg = self.getStudentRecord(mapping)
1335            msg = result['msg']
1336            if msg:
1337                break
1338            student_record = result['student_record']
1339            student_id = student_record.id
1340            mapping['id'] = student_id
1341            d = {}
1342            #import pdb;pdb.set_trace()
1343            any_change = False
1344            #special treatment for StudentStudyLevel
1345            current_session = d['session'] = mapping.get('current_session','')
1346            if current_session and student_record.session != current_session:
1347                msg = 'student %s: imported session %s does not match current_session %s' % (student_id,
1348                                                                                            current_session,
1349                                                                                            student_record.session)
1350                break
1351            current_level = mapping.get('current_level','')
1352            if not current_level.isdigit():
1353                msg = 'student %s: imported level is empty' % (student_id,)
1354                break
1355            if current_level and student_record.level != current_level:
1356                msg = 'student %s: imported level %s does not match current_level %s' % (student_id,
1357                                                                                        current_level,
1358                                                                                        student_record.level)
1359                break
1360            student_review_state =  student_record.review_state
1361            if student_review_state == 'deactivated':
1362                msg = "student %s in review_state %s" % (student_id, student_review_state)
1363                break
1364            if student_review_state not in ('courses_validated','returning'):
1365                msg = "student %s in wrong review_state %s" % (student_id, student_review_state)
1366                break
1367            student_obj = getattr(students_folder,student_id)
1368            # f2t = self.field2types_student
1369            study_course_obj = getattr(student_obj,'study_course',None)
1370            if study_course_obj is None:
1371                msg = 'student %s: no study_course object' % student_id
1372                break
1373            level_obj = getattr(study_course_obj,current_level,None)
1374
1375            if  level_obj is None:
1376                # The only difference to the edit method is that we create a StudentStudyLevel object
1377                try:
1378                    study_course_obj.invokeFactory('StudentStudyLevel',"%s" % current_level)
1379                    level_obj = getattr(context,"%s" % current_level)
1380                    level_obj.portal_workflow.doActionFor(level,'open')
1381                except:
1382                    continue
1383                #msg = 'student %s: no study_level object for level %s' % (student_id,
1384                #                                                                current_level)
1385                #break
1386
1387            verdict = d['verdict'] = d['current_verdict']  = mapping.get('current_verdict','')
1388
1389            #if verdict == student_record.verdict:
1390            #    msg = 'student %s: verdict already set to %s' % (student_id,
1391            #                                                            verdict)
1392
1393            level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1394            if level_review_state != "closed":
1395                wftool.doActionFor(level_obj,'close')
1396                # msg = 'student %s: level %s is not closed' % (student_id,
1397                #                                                      current_level)
1398
1399            study_course_obj.getContent().edit(mapping = d)
1400            level_obj.getContent().edit(mapping = d)
1401            if student_review_state != "returning":
1402                wftool.doActionFor(student_obj,'return')
1403            # try:
1404            #     wftool.doActionFor(level_obj,'close')
1405            # except:
1406            #     pass
1407            break
1408        return student_id,msg,mapping
1409    ###)
1410
1411
1412    def edit(self,mapping): ###(
1413        "edit student verdicts"
1414        wftool = self.portal_workflow
1415        logger = logging.getLogger('WAeUPImport.VerdictImport.edit')
1416        students_folder = self.portal_url.getPortalObject().campus.students
1417        student_id = mapping.get('id',None)
1418        matric_no = mapping.get('matric_no',None)
1419        editable_keys = mapping.keys()
1420        key = ''
1421        while True:
1422            result = self.findStudent('edit',student_id=student_id,matric_no=matric_no)
1423            #student_record,msg = self.getStudentRecord(mapping)
1424            msg = result['msg']
1425            if msg:
1426                break
1427            student_record = result['student_record']
1428            key_used = result['key_used']
1429            if key_used in editable_keys:
1430                editable_keys.remove(key_used)
1431            student_id = student_record.id
1432            mapping['id'] = student_id
1433            d = {}
1434            #import pdb;pdb.set_trace()
1435            any_change = False
1436            #special treatment for StudentStudyLevel
1437            current_session = d['session'] = mapping.get('current_session','')
1438            if current_session and student_record.session != current_session:
1439                msg = 'student %s: imported session %s does not match current_session %s' % (student_id,
1440                                                                                            current_session,
1441                                                                                            student_record.session)
1442                break
1443            current_level = mapping.get('current_level','')
1444            if not current_level.isdigit():
1445                msg = 'student %s: imported level is empty' % (student_id,)
1446                break
1447            if current_level and student_record.level != current_level:
1448                msg = 'student %s: imported level %s does not match current_level %s' % (student_id,
1449                                                                                        current_level,
1450                                                                                        student_record.level)
1451                break
1452            student_review_state =  student_record.review_state
1453            if student_review_state == 'deactivated':
1454                msg = "student %s in review_state %s" % (student_id, student_review_state)
1455                break
1456            if student_review_state not in ('courses_validated','returning'):
1457                msg = "student %s in wrong review_state %s" % (student_id, student_review_state)
1458                break
1459            student_obj = getattr(students_folder,student_id)
1460            # f2t = self.field2types_student
1461            study_course_obj = getattr(student_obj,'study_course',None)
1462            if study_course_obj is None:
1463                msg = 'student %s: no study_course object' % student_id
1464                break
1465            verdict = d['verdict'] = d['current_verdict']  = mapping.get('current_verdict','')
1466
1467            level_obj = getattr(study_course_obj,current_level,None)
1468            if  level_obj is None:
1469                pass
1470                #msg = 'student %s: no study_level object for level %s' % (student_id,current_level)
1471                #break
1472            else:
1473                level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1474                if level_review_state != "closed":
1475                    self.waeup_tool.changeWorkflowState(level_obj, 'closed')
1476                level_obj.getContent().edit(mapping = d)
1477            study_course_obj.getContent().edit(mapping = d)           
1478            if student_review_state != "returning":
1479                self.waeup_tool.changeStudentState(student_obj, 'returning')
1480            break
1481        return student_id,msg,mapping
1482    ###)
1483
1484   
1485   
1486class PaymentImport(WAeUPImport):###(
1487    """ PaymentImport """
1488    name = "payment"
1489    plural_name = "%ss" % name
1490    commit_after = 2000
1491    required_modes = ('create',)
1492
1493    def create(self,mapping): ###(
1494        "create payment object"
1495        wftool = self.portal_workflow
1496        logger = logging.getLogger('WAeUPImport.PaymentImport.create')
1497        students_folder = self.portal_url.getPortalObject().campus.students
1498        student_id = mapping.get('id',None)
1499        order_id = key= mapping.get('order_id',None)
1500        payment_type = mapping.get('type',None)
1501        editable_keys = mapping.keys()
1502        key = ''
1503        msg = ''
1504        while True:
1505            result = self.findStudent('create',student_id=student_id)
1506            msg = result['msg']
1507            if msg:
1508                break           
1509            if payment_type == 'sc':
1510                hyphen = order_id.rfind('-')
1511                if not hyphen > -1:
1512                    msg = '%s: wrong order_id of sc payment' % student_id
1513                    break
1514                payment_object_id = 'p' + order_id[hyphen+1:]
1515            elif payment_type == 'online':
1516                payment_object_id = 'p' + order_id[6:]
1517            else:
1518                msg = '%s: no payment type defined' % student_id
1519                break
1520            student_record = result['student_record']
1521            student_id = student_record.id
1522
1523            mapping['id'] = student_id
1524            payments_folder = getattr(getattr(students_folder,student_id),'payments',None)
1525            if payments_folder is None:
1526                msg = '%s: no payments folder' % student_id
1527                break
1528            if getattr(payments_folder,payment_object_id,False):
1529                msg = '%s: payment object with id %s exists' % (student_id,payment_object_id)
1530                break
1531            try:
1532                #import pdb;pdb.set_trace()
1533                payments_folder.invokeFactory('Payment',"%s" % payment_object_id)
1534                payment_obj = getattr(payments_folder,"%s" % payment_object_id)
1535            except:
1536                msg = '%s: payment object %s cannot be created' % (student_id,payment_object_id)
1537                break
1538            payment_obj.getContent().edit(mapping = mapping)
1539            wftool.doActionFor(payment_obj,'close')
1540            break
1541        return key,msg,mapping
1542    ###)
1543   
1544   
1545
1546    def remove(self,mapping):
1547        order_id = mapping.get('order_id')
1548        student_id = mapping.get('id')
1549        msg = ''
1550        while True:
1551            if not student_id and order_id:
1552                msg = 'student_id or order_id wrong'
1553                break
1554            students_folder = self.portal_url.getPortalObject().campus.students
1555            payments_folder = getattr(getattr(students_folder,student_id),'payments',None)
1556            payment_object_id = 'p' + order_id[6:]
1557
1558            if payments_folder is None:
1559                msg = '%s: no payments folder' % student_id
1560                break
1561            if not getattr(payments_folder,payment_object_id,False):
1562                msg = '%s: payment object with id %s does not exist' % (student_id,payment_object_id)
1563                break
1564
1565            payments_folder.manage_delObjects((payment_object_id),)
1566
1567            #if self.payments_catalog.getRecordByKey(order_id) is None:
1568            #    msg =  "no payment record with order_id %(order_id)s" % vars()
1569            #    break
1570            #self.payments_catalog.deleteRecord(order_id)
1571            break
1572        return order_id,msg,mapping       
1573   
1574   
1575###)
Note: See TracBrowser for help on using the repository browser.