Context navigation

source: WAeUP_SRP/trunk/WAeUPImport.py @ 5331

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

Note: See TracBrowser for help on using the repository browser.

Download in other formats: