source: WAeUP_SRP/trunk/WAeUPTables.py @ 1725

Last change on this file since 1725 was 1725, checked in by joachim, 17 years ago

fill registered courses list if empty

  • Property svn:keywords set to Id
File size: 28.0 KB
Line 
1#-*- mode: python; mode: fold -*-
2# (C) Copyright 2005 AixtraWare <http://aixtraware.de>
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: WAeUPTables.py 1725 2007-04-30 16:44:58Z joachim $
20
21from zope.interface import implements
22from Globals import InitializeClass
23from Products.ZCatalog.ZCatalog import ZCatalog
24from Products.ZCatalog.ProgressHandler import ZLogHandler
25from AccessControl import ClassSecurityInfo
26from Products.CMFCore.permissions import ModifyPortalContent
27import urllib
28import DateTime,time
29import csv,re
30import logging
31import Globals
32p_home = Globals.package_home(globals())
33i_home = Globals.INSTANCE_HOME
34from Products.AdvancedQuery import Eq, Between, Le,In
35
36from interfaces import IWAeUPTable
37
38class AttributeHolder(object):
39    pass
40
41def dict2ob(dict):
42    ob = AttributeHolder()
43    for key, value in dict.items():
44        setattr(ob, key, value)
45    return ob
46
47
48class WAeUPTable(ZCatalog): ###(
49
50    implements(IWAeUPTable)
51    security = ClassSecurityInfo()
52
53    def refreshCatalog(self, clear=0, pghandler=None):
54        """ don't refresh for a normal table """
55
56        if self.REQUEST and self.REQUEST.RESPONSE:
57            self.REQUEST.RESPONSE.redirect(
58              URL1 +
59              '/manage_catalogAdvanced?manage_tabs_message=Catalog%20refresh%20not%20implemented')
60
61    def manage_catalogClear(self, REQUEST=None, RESPONSE=None, URL1=None):
62        """ clears the whole enchilada """
63        #self._catalog.clear()
64
65        if REQUEST and RESPONSE:
66            RESPONSE.redirect(
67              URL1 +
68              '/manage_catalogAdvanced?manage_tabs_message=Catalog%20Clearing%20disabled')
69
70    def addRecord(self, **data):
71        # The uid is the same as "bed".
72        uid = data[self.key]
73        res = self.searchResults({"%s" % self.key : uid})
74        if len(res) > 0:
75            raise ValueError("More than one record with uid %s" % uid)
76        self.catalog_object(dict2ob(data), uid=uid)
77        return uid
78
79    def deleteRecord(self, uid):
80        self.uncatalog_object(uid)
81
82    def searchAndSetRecord(self, **data):
83        raise NotImplemented
84
85    def modifyRecord(self, **data):
86        #records = self.searchResults(uid=uid)
87        uid = data[self.key]
88        records = self.searchResults({"%s" % self.key : uid})
89        if len(records) > 1:
90            # Can not happen, but anyway...
91            raise ValueError("More than one record with uid %s" % uid)
92        if len(records) == 0:
93            raise KeyError("No record for uid %s" % uid)
94        record = records[0]
95        record_data = {}
96        for field in self.schema() + self.indexes():
97            record_data[field] = getattr(record, field)
98        # Add the updated data:
99        record_data.update(data)
100        self.catalog_object(dict2ob(record_data), uid)
101
102    def reindexIndex(self, name, REQUEST,pghandler=None):
103        if isinstance(name, str):
104            name = (name,)
105        paths = self._catalog.uids.items()
106        i = 0
107        #import pdb;pdb.set_trace()
108        for p,rid in paths:
109            i += 1
110            metadata = self.getMetadataForRID(rid)
111            record_data = {}
112            for field in name:
113                record_data[field] = metadata.get(field)
114            uid = metadata.get(self.key)
115            self.catalog_object(dict2ob(record_data), uid, idxs=name,
116                                update_metadata=0)
117
118    security.declareProtected(ModifyPortalContent,"exportAllRecords")
119    def exportAllRecords(self):
120        "export a WAeUPTable"
121        #import pdb;pdb.set_trace()
122        fields = [field for field in self.schema()]
123        format = ','.join(['"%%(%s)s"' % fn for fn in fields])
124        csv = []
125        csv.append(','.join(['"%s"' % fn for fn in fields]))
126        for uid in self._catalog.uids:
127            records = self.searchResults({"%s" % self.key : uid})
128            if len(records) > 1:
129                # Can not happen, but anyway...
130                raise ValueError("More than one record with uid %s" % uid)
131            if len(records) == 0:
132                raise KeyError("No record for uid %s" % uid)
133            rec = records[0]
134            csv.append(format % rec)
135        current = DateTime.DateTime().strftime("%d-%m-%y_%H_%M_%S")
136        open("%s/import/%s-%s.csv" % (i_home,self.getId(),current),"w+").write('\n'.join(csv))
137
138###)
139
140class AccommodationTable(WAeUPTable): ###(
141
142    meta_type = 'WAeUP Accommodation Tool'
143    name = "accommodation"
144    key = "bed"
145    def __init__(self):
146        WAeUPTable.__init__(self, 'portal_accommodation')
147
148    def searchAndReserveBed(self, student_id,bed_type):
149        records = self.searchResults({'student' : student_id})
150        if len(records) > 0:
151            return -1,"Student with Id %s already booked bed %s." % (student_id,records[0].bed)
152
153        records = [r for r in self.searchResults({'bed_type' : bed_type}) if not r.student]
154        #import pdb;pdb.set_trace()
155        if len(records) == 0:
156            return -2,"No bed available"
157        rec = records[0]
158        self.modifyRecord(bed=rec.bed,student=student_id)
159        s_logger = logging.getLogger('WAeUPTables.AccommodationTable.searchAndReserveBed')
160        s_logger.info('%s reserved bed %s' % (student_id,rec.bed))
161        return 1,rec.bed
162
163
164InitializeClass(AccommodationTable)
165
166###)
167
168class PinTable(WAeUPTable): ###(
169    from ZODB.POSException import ConflictError
170    meta_type = 'WAeUP Pin Tool'
171    name = "pins"
172    key = 'pin'
173    def __init__(self):
174        WAeUPTable.__init__(self, 'portal_pins')
175
176
177    def searchAndSetRecord(self, uid, student_id,prefix):
178        #records = self.searchResults(uid=uid)
179        records = self.searchResults(student = student_id)
180        #import pdb;pdb.set_trace()
181        if len(records) > 0:
182            for r in records:
183                if r.pin != uid and r.prefix_batch.startswith(prefix):
184                    return -2
185        records = self.searchResults({"%s" % self.key : uid})
186        if len(records) > 1:
187            # Can not happen, but anyway...
188            raise ValueError("More than one record with uid %s" % uid)
189        if len(records) == 0:
190            return -1
191        record = records[0]
192        if record.student == "":
193            record_data = {}
194            for field in self.schema() + self.indexes():
195                record_data[field] = getattr(record, field)
196            # Add the updated data:
197            record_data['student'] = student_id
198            try:
199                self.catalog_object(dict2ob(record_data), uid)
200                return 1
201            except ConflictError:
202                return 2
203        if record.student.upper() != student_id.upper():
204            return 0
205        if record.student.upper() == student_id.upper():
206            return 2
207        return -3
208
209InitializeClass(PinTable)
210
211###)
212
213class PumeResultsTable(WAeUPTable): ###(
214
215    meta_type = 'WAeUP PumeResults Tool'
216    name = "pumeresults"
217    key = "jamb_reg_no"
218    def __init__(self):
219        WAeUPTable.__init__(self, 'portal_pumeresults')
220
221
222InitializeClass(PumeResultsTable)
223
224###)
225
226class StudentsCatalog(WAeUPTable): ###(
227    security = ClassSecurityInfo()
228
229    meta_type = 'WAeUP Students Catalog'
230    name = "students_catalog"
231    key = "id"
232    affected_types = {   ###(
233                      'StudentApplication':
234                          {'id': 'application',
235                           'fields':
236                             ('jamb_reg_no',
237                              'entry_mode',
238                              'entry_level',
239                              'entry_session',
240                              )
241                              },
242                      'StudentClearance':
243                          {'id': 'clearance',
244                           'fields':
245                             ('matric_no',
246                              )
247                              },
248                         'StudentPersonal':
249                          {'id': 'personal',
250                           'fields':
251                             ('name',
252                              'sex',
253                              'email',
254                              'phone',
255                              )
256                              },
257                         'StudentStudyCourse':
258                          {'id': 'study_course',
259                           'fields':
260                             ('course',
261                              'faculty',
262                              'department',
263                              'level',
264                              'mode',
265                              'session',
266                              'verdict',
267                              )
268                              },
269                         }
270    ###)
271
272    def __init__(self):
273        WAeUPTable.__init__(self, 'students_catalog')
274        return
275
276    def manage_catalogClear(self, REQUEST=None, RESPONSE=None, URL1=None):
277        """ clears the whole enchilada """
278        self._catalog.clear()
279
280        if REQUEST and RESPONSE:
281            RESPONSE.redirect(
282              URL1 +
283              '/manage_catalogAdvanced?manage_tabs_message=Catalog%20Cleared')
284
285    def manage_catalogReindex(self, REQUEST, RESPONSE, URL1): ###(
286        """ clear the catalog, then re-index everything """
287
288        elapse = time.time()
289        c_elapse = time.clock()
290
291        pgthreshold = self._getProgressThreshold()
292        handler = (pgthreshold > 0) and ZLogHandler(pgthreshold) or None
293        self.refreshCatalog(clear=1, pghandler=handler)
294
295        elapse = time.time() - elapse
296        c_elapse = time.clock() - c_elapse
297
298        RESPONSE.redirect(
299            URL1 +
300            '/manage_catalogAdvanced?manage_tabs_message=' +
301            urllib.quote('Catalog Updated \n'
302                         'Total time: %s\n'
303                         'Total CPU time: %s' % (`elapse`, `c_elapse`)))
304    ###)
305
306    def get_from_doc_department(self,doc): ###(
307        "return the students department"
308        if doc is None:
309            return None
310        certificate_res = self.portal_catalog(id = doc.study_course)
311        if len(certificate_res) != 1:
312            return None
313        return certificate_res[0].getPath().split('/')[-3]
314
315    def get_from_doc_faculty(self,doc):
316        "return the students faculty"
317        if doc is None:
318            return None
319        certificate_res = self.portal_catalog(id = doc.study_course)
320        if len(certificate_res) != 1:
321            return None
322        return certificate_res[0].getPath().split('/')[-4]
323
324    def get_from_doc_level(self,doc):
325        "return the students level"
326        if doc is None:
327            return None
328        return getattr(doc,'current_level',None)
329
330    def get_from_doc_mode(self,doc):
331        "return the students mode"
332        if doc is None:
333            return None
334        cm = getattr(doc,'current_mode',None)
335        return cm
336       
337
338    def get_from_doc_session(self,doc):
339        "return the students current_session"
340        if doc is None:
341            return None
342        return getattr(doc,'current_session',None)
343
344    def get_from_doc_entry_session(self,doc):
345        "return the students entry_session"
346        if doc is None:
347            return None
348        es = getattr(doc,'entry_session',None)
349        if len(es) == 2:
350            return es
351        try:
352            digit = int(doc.jamb_reg_no[0])
353        except:
354            return "xx"
355        if digit < 8:
356            return "0%c" % doc.jamb_reg_no[0]
357        return "9%c" % doc.jamb_reg_no[0]
358
359    def get_from_doc_session(self,doc):
360        "return the students session"
361        if doc is None:
362            return None
363        return getattr(doc,'current_session',None)
364
365    def get_from_doc_course(self,doc):
366        "return the students study_course"
367        if doc is None:
368            return None
369        return getattr(doc,'study_course',None)
370
371    def get_from_doc_name(self,doc):
372        "return the students name from the personal"
373        if doc is None:
374            return None
375        return "%s %s %s" % (doc.firstname,doc.middlename,doc.lastname)
376
377    def get_from_doc_verdict(self,doc):
378        "return the students study_course"
379        if doc is None:
380            return None
381        return getattr(doc,'current_verdict',None)
382    ###)
383
384    def reindexIndex(self, name, REQUEST,pghandler=None): ###(
385        if isinstance(name, str):
386            name = (name,)
387        reindextypes = {}
388        reindex_special = []
389        #import pdb;pdb.set_trace()
390        for n in name:
391            if n in ("review_state","registered_courses"):
392                reindex_special.append(n)
393            else:
394                for pt in self.affected_types.keys():
395                    if n in self.affected_types[pt]['fields']:
396                        if reindextypes.has_key(pt):
397                            reindextypes[pt].append(n)
398                        else:
399                            reindextypes[pt]= [n]
400                        break
401        students = self.portal_catalog(portal_type="Student")
402        aq_portal = self.portal_catalog.evalAdvancedQuery
403        num_objects = len(students)
404        if pghandler:
405            pghandler.init('Refreshing catalog: %s' % self.absolute_url(1), num_objects)
406        noattr = set(('StudentClearance','StudentPersonal')) & set(reindextypes.keys())
407        for i in xrange(num_objects):
408            if pghandler: pghandler.report(i)
409            student_brain = students[i]
410            student_object = student_brain.getObject()
411            data = {}
412            modified = False
413            sid = data['id'] = student_brain.getId
414            if reindex_special and 'review_state' in reindex_special:
415                modified = True
416                data['review_state'] = student_brain.review_state
417            sub_objects = False
418            for pt in reindextypes.keys():
419                modified = True
420                try:
421                    doc = getattr(student_object,self.affected_types[pt]['id']).getContent()
422                    sub_objects = True
423                except:
424                    continue
425                for field in self.affected_types[pt]['fields']:
426                    if hasattr(self,'get_from_doc_%s' % field):
427                        data[field] = getattr(self,'get_from_doc_%s' % field)(doc)
428                    else:
429                        data[field] = getattr(doc,field)
430                #from pdb import set_trace;set_trace()
431            if not sub_objects and noattr:
432                import_res = self.returning_import(id = sid)
433                if not import_res:
434                    continue
435                import_record = import_res[0]
436                data['matric_no'] = import_record.matric_no
437                data['sex'] = import_record.Sex == 'F'
438                data['name'] = "%s %s %s" % (import_record.Firstname,
439                                             import_record.Middlename,
440                                             import_record.Lastname)
441                data['matric_no'] = import_record.Entryregno
442            if reindex_special and 'registered_courses' in reindex_special:
443                query = Eq('id','study_course') & Eq('path',student_brain.getPath())
444                brains = aq_portal(query)
445                while brains:
446                    study_course_path = brains[0].getPath()
447                    level_brains = self.portal_catalog(path = study_course_path,
448                                                       portal_type = "StudentStudyLevel")
449                    if not level_brains:
450                        break
451                    modified = True
452                    level_ids = [l.getId for l in level_brains]
453                    level_ids.sort()
454                    for l in level_brains:
455                        if l.getId == level_ids[-1]:
456                            level_path = l.getPath()
457                            break
458                    result_brains = self.portal_catalog(path = level_path,
459                                                        portal_type = "StudentCourseResult")
460                    course_ids = [cr.getId for cr in result_brains]
461                    courses = []
462                    for c in course_ids:
463                        if c.endswith('_co'):
464                            courses.append(c[:-3])
465                        else:
466                            courses.append(c)
467                    data['registered_courses'] = courses
468                    break
469            if modified:
470                self.modifyRecord(**data)
471        if pghandler: pghandler.finish()
472    ###)
473
474    def refreshCatalog(self, clear=0, pghandler=None): ###(
475        """ re-index everything we can find """
476        students_folder = self.portal_url.getPortalObject().campus.students
477        if clear:
478            self._catalog.clear()
479        students = self.portal_catalog(portal_type="Student")
480        num_objects = len(students)
481        if pghandler:
482            pghandler.init('Refreshing catalog: %s' % self.absolute_url(1), num_objects)
483        for i in xrange(num_objects):
484            if pghandler: pghandler.report(i)
485            student_brain = students[i]
486            spath = student_brain.getPath()
487            student_obj = student_brain.getObject()
488            data = {}
489            sid = data['id'] = student_brain.getId
490            data['review_state'] = student_brain.review_state
491            sub_objects = False
492            for pt in self.affected_types.keys():
493                modified = True
494                try:
495                    doc = getattr(student_object,self.affected_types[pt]['id']).getContent()
496                    sub_objects = True
497                except:
498                    continue
499                for field in self.affected_types[pt]['fields']:
500                    if hasattr(self,'get_from_doc_%s' % field):
501                        data[field] = getattr(self,'get_from_doc_%s' % field)(doc)
502                    else:
503                        data[field] = getattr(doc,field)
504                #from pdb import set_trace;set_trace()
505            if not sub_objects and noattr:
506                import_res = self.returning_import(id = sid)
507                if not import_res:
508                    continue
509                import_record = import_res[0]
510                data['matric_no'] = import_record.matric_no
511                data['sex'] = import_record.Sex == 'F'
512                data['name'] = "%s %s %s" % (import_record.Firstname,
513                                             import_record.Middlename,
514                                             import_record.Lastname)
515                data['matric_no'] = import_record.Entryregno
516            study_course = getattr(student_obj,'study_course',None)
517            current_level = data.get('level',None)
518            data['registered_courses'] = []
519            if study_course and current_level and current_level in study_course.objectIds():
520                level_obj = getattr(study_course,current_level)
521                courses = []
522                for c in level_obj.objectIds():
523                    if c.endswith('_co'):
524                        courses.append(c[:-3])
525                    else:
526                        courses.append(c)
527                data['registered_courses'] = courses
528            self.addRecord(**data)
529        if pghandler: pghandler.finish()
530    ###)
531
532    security.declarePrivate('notify_event_listener') ###(
533    def notify_event_listener(self,event_type,object,infos):
534        "listen for events"
535        if not infos.has_key('rpath'):
536            return
537        pt = getattr(object,'portal_type',None)
538        mt = getattr(object,'meta_type',None)
539        students_catalog = self.students_catalog
540        data = {}
541        if pt == 'Student' and\
542           mt == 'CPS Proxy Folder' and\
543           event_type.startswith('workflow'):
544            data['id'] = object.getId()
545            data['review_state'] = self.portal_workflow.getInfoFor(object,'review_state',None)
546            students_catalog.modifyRecord(**data)
547            return
548        rpl = infos['rpath'].split('/')
549        if pt == 'Student' and event_type == "sys_add_object":
550            student_id = object.id
551            try:
552                self.addRecord(id = student_id)
553            except ValueError:
554                pass
555            return
556        elif pt == 'StudentCourseResult' and mt == 'CPS Proxy Folder':
557            if event_type not in ("sys_add_object","sys_del_object"):
558                return
559            course_id = object.getId()
560            student_id = object.absolute_url_path().split('/')[-4]
561            res = self(id = student_id)
562            if not res:
563                return
564            student_rec = res[0]
565            registered_courses = student_rec.registered_courses
566            if not registered_courses:
567                level_obj = object.aq_parent
568                courses = []
569                for c in level_obj.objectIds():
570                    if c.endswith('_co'):
571                        courses.append(c[:-3])
572                    else:
573                        courses.append(c)
574                #from pdb import set_trace;set_trace()
575                registered_courses = courses
576            else:
577                if event_type == "sys_add_object":
578                    registered_courses.append(course_id)
579                if event_type == "sys_del_object":
580                    if course_id in registered_courses:
581                        registered_courses.remove(course_id)
582            data['id'] = student_id
583            data['registered_courses'] = registered_courses
584            self.modifyRecord(**data)
585        if pt not in self.affected_types.keys():
586            return
587        if event_type not in ('sys_modify_object'):
588            return
589        if mt == 'CPS Proxy Folder':
590            return
591        for field in self.affected_types[pt]['fields']:
592            if hasattr(self,'get_from_doc_%s' % field):
593                data[field] = getattr(self,'get_from_doc_%s' % field)(object)
594            else:
595                data[field] = getattr(object,field)
596        data['id'] = rpl[2]
597        self.modifyRecord(**data)
598    ###)
599
600
601InitializeClass(StudentsCatalog)
602
603###)
604
605class CoursesCatalog(WAeUPTable): ###(
606    security = ClassSecurityInfo()
607
608    meta_type = 'WAeUP Courses Catalog'
609    name = "students_catalog"
610    key = "code"
611    def __init__(self):
612        WAeUPTable.__init__(self, 'courses_catalog')
613
614    def manage_catalogReindex(self, REQUEST, RESPONSE, URL1): ###(
615        """ clear the catalog, then re-index everything """
616
617        elapse = time.time()
618        c_elapse = time.clock()
619
620        pgthreshold = self._getProgressThreshold()
621        handler = (pgthreshold > 0) and ZLogHandler(pgthreshold) or None
622        self.refreshCatalog(clear=1, pghandler=handler)
623
624        elapse = time.time() - elapse
625        c_elapse = time.clock() - c_elapse
626
627        RESPONSE.redirect(
628            URL1 +
629            '/manage_catalogAdvanced?manage_tabs_message=' +
630            urllib.quote('Catalog Updated \n'
631                         'Total time: %s\n'
632                         'Total CPU time: %s' % (`elapse`, `c_elapse`)))
633    ###)
634
635    def reindexIndex(self, name, REQUEST,pghandler=None): ###(
636        if isinstance(name, str):
637            name = (name,)
638        courses = self.portal_catalog(portal_type="Course")
639        num_objects = len(courses)
640        if pghandler:
641            pghandler.init('Refreshing catalog: %s' % self.absolute_url(1), num_objects)
642        for i in xrange(num_objects):
643            if pghandler: pghandler.report(i)
644            course_brain = courses[i]
645            course_object = course_brain.getObject()
646            pl = course_brain.getPath().split('/')
647            data = {}
648            cid = data[self.key] = course_brain.getId
649            data['faculty'] = pl[-4]
650            data['department'] = pl[-3]
651            doc = course_object.getContent()
652            for field in name:
653                if field not in (self.key,'faculty','department'):
654                    data[field] = getattr(doc,field)
655            self.modifyRecord(**data)
656        if pghandler: pghandler.finish()
657    ###)
658
659    def refreshCatalog(self, clear=0, pghandler=None): ###(
660        """ re-index everything we can find """
661        if clear:
662            self._catalog.clear()
663        courses = self.portal_catalog(portal_type="Course")
664        num_objects = len(courses)
665        if pghandler:
666            pghandler.init('Refreshing catalog: %s' % self.absolute_url(1), num_objects)
667        #from pdb import set_trace;set_trace()
668        for i in xrange(num_objects):
669            if pghandler: pghandler.report(i)
670            course_brain = courses[i]
671            course_doc = course_brain.getObject().getContent()
672            pl = course_brain.getPath().split('/')
673            data = {}
674            for field in self.schema():
675                data[field] = getattr(course_doc,field,None)
676            data[self.key] = course_brain.getId
677            ai = pl.index('academics')
678            data['faculty'] = pl[ai +1]
679            data['department'] = pl[ai +2]
680            if clear:
681                self.addRecord(**data)
682            else:
683                self.modifyRecord(**data)
684        if pghandler: pghandler.finish()
685    ###)
686
687    security.declarePrivate('notify_event_listener') ###(
688    def notify_event_listener(self,event_type,object,infos):
689        "listen for events"
690        if not infos.has_key('rpath'):
691            return
692        pt = getattr(object,'portal_type',None)
693        mt = getattr(object,'meta_type',None)
694        if pt != 'Course':
695            return
696        data = {}
697        rpl = infos['rpath'].split('/')
698        if event_type not in ("sys_add_object","sys_modify_object","sys_del_object"):
699            return
700        course_id = object.getId()
701        data[self.key] = course_id
702        if event_type == "sys_add_object" and mt == 'CPS Proxy Folder':
703            try:
704                self.addRecord(**data)
705            except ValueError:
706                return
707            course_id = object.getId()
708            doc = object.getContent()
709            if doc is None:
710                return
711            for field in self.schema():
712                data[field] = getattr(doc,field,None)
713            data[self.key] = course_id
714            ai = rpl.index('academics')
715            data['faculty'] = rpl[ai +1]
716            data['department'] = rpl[ai +2]
717            self.modifyRecord(**data)
718            return
719        if event_type == "sys_del_object":
720            self.deleteRecord(course_id)
721            return
722        if event_type == "sys_modify_object" and mt == 'Course':
723            #from pdb import set_trace;set_trace()
724            for field in self.schema():
725                data[field] = getattr(object,field,None)
726            course_id = object.aq_parent.getId()
727            data[self.key] = course_id
728            ai = rpl.index('academics')
729            data['faculty'] = rpl[ai +1]
730            data['department'] = rpl[ai +2]
731            self.modifyRecord(**data)
732    ###)
733
734
735InitializeClass(CoursesCatalog)
736###)
737
738class OnlinePaymentsImport(WAeUPTable): ###(
739
740    meta_type = 'WAeUP Online Payment Transactions'
741    name = "online_payments_import"
742    key = "order_id"
743    def __init__(self):
744        WAeUPTable.__init__(self, self.name)
745
746
747InitializeClass(CoursesCatalog)
748###)
749
750class ReturningImport(WAeUPTable): ###(
751
752    meta_type = 'Returning Import Table'
753    name = "returning_import"
754    key = "matric_no"
755    def __init__(self):
756        WAeUPTable.__init__(self, 'returning_import')
757
758
759InitializeClass(ReturningImport)
760###)
761
762class ResultsImport(WAeUPTable): ###(
763
764    meta_type = 'Results Import Table'
765    name = "results_import"
766    key = "key"
767    def __init__(self):
768        WAeUPTable.__init__(self, 'results_import')
769
770
771InitializeClass(ResultsImport)
772
773###)
774
775class PaymentsCatalog(WAeUPTable): ###(
776
777    meta_type = 'WAeUP Payments Catalog'
778    name = "students_catalog"
779    key = "id"
780    def __init__(self):
781        WAeUPTable.__init__(self, 'payments_catalog')
782
783
784InitializeClass(PaymentsCatalog)
785
786###)
787
788# BBB:
789AccomodationTable = AccommodationTable
Note: See TracBrowser for help on using the repository browser.