Context navigation

source: WAeUP_SRP/trunk/WAeUPImport.py @ 5655

Last change on this file since 5655 was 5613, checked in by Henrik Bettermann, 14 years ago
Improve message for pending data file.
Property svn:keywords set to `Id`
File size: 68.9 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 5613 2010-12-14 06:48:50Z 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	#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
252	class 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
310	class 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
369	class 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
449	class 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
575	class 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
617	class 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
680	class 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
721	class StudentImport(WAeUPImport):###(
722	name = "student"
723	plural_name = "%ss" % name
724	commit_after = 100
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
1229	class 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
1316	class 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
1486	class PaymentImport(WAeUPImport):###(
1487	""" PaymentImport """
1488	name = "payment"
1489	plural_name = "%ss" % name
1490	commit_after = 1000000
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	msg = ''
1549	while True:
1550	if self.payments_catalog.getRecordByKey(order_id) is None:
1551	msg = "no payment record with order_id %(order_id)s" % vars()
1552	break
1553	self.payments_catalog.deleteRecord(order_id)
1554	break
1555	return order_id,msg,mapping
1556
1557
1558	###)

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

Download in other formats: