Context navigation

source: WAeUP_SRP/base/WAeUPImport.py @ 3454

Last change on this file since 3454 was 3431, checked in by Henrik Bettermann, 17 years ago

getAccommodationInfo.py: adjust to Okene version

WAeUPImport.py: remove redundant line

Property svn:keywords set to Id

File size: 63.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 3431 2008-04-08 15:51:10Z 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.academics_folder = waeup_tool.portal_url.getPortalObject().campus.academics
67	self.schema_tool = getToolByName(waeup_tool, 'portal_schemas')
68	self.layout_tool = getToolByName(waeup_tool, 'portal_layouts')
69	self.portal_workflow = getToolByName(waeup_tool, 'portal_workflow')
70	self.portal_url = getToolByName(waeup_tool, 'portal_url')
71	self.portal_catalog = waeup_tool.portal_catalog
72	self.students_catalog = waeup_tool.students_catalog
73	self.courses_catalog = waeup_tool.courses_catalog
74	self.course_results = waeup_tool.course_results
75	self.applicants_catalog = waeup_tool.applicants_catalog
76	#self.mode = mode
77	# self.import_method = getattr(self, '%s' % mode,None)
78	errors = []
79	# if self.import_method is None:
80	# errors.append('No importer method %s' % mode)
81	self.pending_path = "%s/import/%s.pending" % (i_home,self.plural_name)
82	self.pending_tmp = "%s/import/%s.pending.tmp" % (i_home,self.plural_name)
83	self.pending_backup = "%s/import/%s.pending.old" % (i_home,self.plural_name)
84	self.pending_fn = os.path.split(self.pending_path)[1]
85	self.imported_path = "%s/import/%s.imported" % (i_home,self.plural_name)
86	self.imported_fn = os.path.split(self.imported_path)[1]
87	iname = "import_%s" % self.name
88	self.logger = logging.getLogger('WAeUPImport.%sImport' % self.plural_name.capitalize())
89	self.schema = self.schema_tool._getOb(iname,None)
90	#self.pending_schema = self.schema_tool._getOb("%s_pending" % iname,None)
91	self.layout = self.layout_tool._getOb(iname,None)
92	while True:
93	if self.schema is None:
94	errors.append('no schema %s' % iname)
95	# if self.pending_schema is None:
96	# self.pending_schema = self.schema
97	if self.layout is None:
98	errors.append('no such layout %s' % iname)
99	if errors:
100	break
101	self.data_keys = self.schema.keys()
102	self.csv_keys = self.schema.keys()
103	info = {}
104	info['imported_from'] = ''
105	info['import_record_no'] = 0
106	info['imported_by'] = self.imported_by
107	info['import_date'] = self.import_date.strftime("%d/%m/%y %H:%M:%S")
108	info['error'] = ''
109	self.info = info
110	self.csv_keys.extend(self.info)
111	self.validators = {}
112	for widget in self.layout.keys():
113	self.validators[widget] = self.layout[widget].validate
114	self.required_keys = {}
115	for mode in self.required_modes:
116	self.required_keys[mode] = [self.layout.getIdUnprefixed(id)
117	for id,widget in self.layout.objectItems()
118	if widget.is_required]
119	break
120	self.init_errors = ','.join(errors)
121	###)
122
123	def findStudent(self,mode,student_id=None, matric_no=None, jamb_reg_no=None): ###(
124	student_record = None
125	msg = ''
126	key_used = ''
127	while True:
128	if student_id:
129	key_used = 'student_id'
130	res = self.students_catalog(id = student_id)
131	if not res:
132	msg = "no student with id %s" % student_id
133	break
134	student_record = res[0]
135	if matric_no and student_record.matric_no:
136	if matric_no != student_record.matric_no:
137	msg = "old matric_no %s overwritten with %s" % (student_record.matric_no,matric_no)
138	#logger.info("%s, old matric_no %s overwritten with %s" % (student_record.id,student_record.matric_no,matric_no))
139	if jamb_reg_no and student_record.jamb_reg_no:
140	if jamb_reg_no != student_record.jamb_reg_no:
141	msg = "old reg_no %s overwritten with %s" % (student_record.jamb_reg_no,jamb_reg_no)
142	#logger.info("%s, old reg_no %s overwritten with %s" % (student_record.id,student_record.jamb_reg_no,jamb_reg_no))
143	elif jamb_reg_no:
144	key_used = 'jamb_reg_no'
145	res = self.students_catalog(jamb_reg_no = jamb_reg_no)
146	if res:
147	if mode == 'create':
148	msg = "jamb_reg_no exists"
149	break
150	else:
151	if mode == 'edit':
152	msg = "no student with jamb_reg_no %s" % jamb_reg_no
153	break
154	student_record = res[0]
155	elif matric_no:
156	key_used = 'matric_no'
157	res = self.students_catalog(matric_no = matric_no)
158	if not res:
159	msg = "no student with matric_no %s" % matric_no
160	break
161	student_record = res[0]
162	else:
163	msg = "neither id, matric_no nor reg_no specified"
164	break
165	d = {}
166	d['student_record'] = student_record
167	d['key_used'] = key_used
168	d['msg'] = msg
169	return d
170	###)
171
172	def makeIdLists(self): ###(
173	pending_digests = []
174	pending = []
175	# pending_student_ids = []
176	# pending_matric_nos = []
177	# pending_reg_ns = []
178	if os.path.exists(self.pending_path):
179	datafile = open(self.pending_path,"r")
180	reader = csv.reader(datafile)
181	old_headline = reader.next()
182	#datafile.seek(0)
183	pending_csv_reader = csv.DictReader(datafile,old_headline,)
184	#pending_csv_reader.next() # skip headline
185	for item in pending_csv_reader:
186	digest = makeDigest(item,self.data_keys)
187	if digest not in pending_digests:
188	pending_digests += digest,
189	pending += item,
190	datafile.close()
191	#copy2(self.pending_path,self.pending_backup)
192	return pending, pending_digests
193	###)
194
195	def checkHeadline(self,headline): ###(
196	""" check the headline of a csv file """
197	import_keys = [k.strip() for k in headline if not (k.strip().startswith('ignore')
198	or k.strip() in self.info.keys())]
199	# import_keys = [k.strip() for k in headline if not (k.strip() in self.info.keys())]
200	diff2schema = set(import_keys).difference(set(self.schema.keys()))
201	diff2layout = set(import_keys).difference(set(self.layout.keys()))
202	#if diff2schema and diff2schema != set(['id',]):
203	if diff2schema:
204	return list(diff2schema)
205	return []
206	###)
207
208	def getHeadlineFields(self,headline,values): ###(
209	""" check the headline of a csv file """
210	# import_keys = [k.strip() for k in headline if not (k.strip().startswith('ignore')
211	# or k.strip() in self.info.keys())]
212	import_keys = [k.strip() for k in headline if not (k.strip() in self.info.keys())]
213	info_keys = [k.strip() for k in headline if k.strip() in self.info.keys()]
214	si = set(import_keys)
215	ss = set(self.schema.keys())
216
217	invalid_keys = si - ss
218	keys = []
219	i = 0
220	duplicates = False
221	singels = []
222	msg = ''
223	while True:
224	if len(values) != len(import_keys):
225	if len(values) == len(import_keys) + len(info_keys):
226	msg += "fields from pending file in headline"
227	else:
228	msg += "%d fields in headline but %d values" % (len(import_keys),len(values))
229	break
230	for k in import_keys:
231	if k in singels:
232	keys += (k,'%s' % k,values[i],'(duplicate)'),
233	msg += ("duplicate %s," % k)
234	keys[singels.index(k)] = (k,'%s' % k,values[singels.index(k)],'(duplicate)')
235	elif k in invalid_keys and not k.startswith(IGNORE):
236	keys += (k,NO_KEY,values[i],'(invalid)'),
237	else:
238	keys += (k,k,values[i],''),
239	i += 1
240	singels += k,
241	break
242	return msg,keys
243	###)
244	###)
245
246	class ApplicationImport(WAeUPImport):###(
247	name = "application"
248	plural_name = "%ss" % name
249	commit_after = 1000
250
251	def create(self,mapping):###(
252	reg_no = mapping.get('reg_no')
253	msg = ''
254	while True:
255	try:
256	self.applicants_catalog.addRecord(**mapping)
257	except ValueError:
258	msg = "applicant record with reg_no %s already exists" % reg_no
259	break
260	return reg_no,msg,mapping
261	###)
262
263	def edit(self,mapping):###(
264	reg_no = mapping.get('reg_no')
265	status = mapping.get('status')
266	msg = ''
267	while True:
268	res = self.applicants_catalog(reg_no = reg_no)
269	if len(res):
270	if res[0].status == 'created' and status != 'created':
271	msg = "student object with id %s for %s already created, status cannot be changed" % (res[0].student_id, reg_no)
272	elif status == 'created' and res[0].status != 'created':
273	msg = "student object for %s has not yet been created, status cannot be set to 'created'" % (reg_no)
274	else:
275	self.applicants_catalog.modifyRecord(**mapping)
276	else:
277	msg = "applicant record with reg_no %s does not exist" % reg_no
278	break
279	return reg_no,msg,mapping
280	###)
281
282	###)
283
284	class CertificateImport(WAeUPImport):###(
285	name = "certificate"
286	plural_name = "%ss" % name
287	commit_after = 100000
288
289	def create(self,mapping):###(
290	if getattr(self,'_v_certificate_list',None) is None:
291	self._v_certificate_list = []
292	if getattr(self,'_v_department_certificates',None) is None:
293	departments = self.portal_catalog(portal_type = "Department")
294	self._v_department_certificates = {}
295	for department in departments:
296	certificates_container = getattr(department.getObject(),"certificates",None)
297	self._v_department_certificates[department.getId] = {'container': certificates_container,
298	'certificates': certificates_container.objectIds(),
299	}
300	department_id = mapping['department_code']
301	msg = ''
302	certificate_id = mapping.get('code')
303	while True:
304	department_certificates = self._v_department_certificates.get(department_id,None)
305	if department_certificates is None:
306	msg = "No Department with ID: %s" % department_id
307	break
308	certificates_container = department_certificates['container']
309	certificates = department_certificates['certificates']
310	if certificate_id in self._v_certificate_list:
311	msg = "Duplicate Certificate ID: %s" % department_id
312	break
313	if certificate_id in certificates:
314	msg = "Duplicate Certificate ID: %s" % department_id
315	break
316	try:
317	certificates_container.invokeFactory('Certificate', certificate_id)
318	except BadRequest,E:
319	msg = "%s" % E
320	break
321	self._v_certificate_list.append(certificate_id)
322	certificate = getattr(certificates_container,certificate_id)
323	certificate.getContent().edit(mapping=mapping)
324	break
325	return certificate_id,msg,mapping
326	###)
327
328	def edit(self,mapping):###(
329	certificate_id = mapping.get('code')
330	res = self.portal_catalog(id=certificate_id)
331	msg = ''
332	while True:
333	if not res:
334	msg = "no certificate with id: %s" % certificate_id
335	break
336	c = res[0].getObject()
337	c.getContent().edit(mapping=mapping)
338	break
339	return certificate_id,msg,mapping
340	###)
341	###)
342
343	class CourseImport(WAeUPImport):###(
344	name = "course"
345	plural_name = "%ss" % name
346	commit_after = 1000
347
348	def create(self,mapping):###(
349	if getattr(self,'_v_course_list',None) is None:
350	self._v_course_list = []
351	if getattr(self,'_v_department_courses',None) is None:
352	departments = self.portal_catalog(portal_type = "Department")
353	self._v_department_courses = {}
354	for department in departments:
355	courses_container = getattr(department.getObject(),"courses",None)
356	if courses_container is not None:
357	self._v_department_courses[department.getId] = {'container': courses_container,
358	'courses': courses_container.objectIds(),
359	}
360	department_id = mapping['department_code']
361	course_id = mapping.get('code','')
362	msg = ''
363	while True:
364	department_courses = self._v_department_courses.get(department_id,None)
365	if department_courses is None:
366	msg = "no department with id: %(department_id)s" % vars()
367	break
368	courses_container = department_courses['container']
369	courses = department_courses['courses']
370	if course_id in self._v_course_list:
371	msg = "duplicate course id: %(course_id)s" % vars()
372	break
373	if course_id in courses:
374	msg = "course %(course_id)s already exists in department %(department_id)s" % vars()
375	break
376	try:
377	courses_container.invokeFactory('Course', course_id)
378	except BadRequest,E:
379	msg = "%s" % E
380	break
381	self._v_course_list.append(course_id)
382	course = getattr(courses_container,course_id)
383	course.getContent().edit(mapping=mapping)
384	break
385	return course_id,msg,mapping
386	###)
387
388	def edit(self,mapping): ###(
389	course_id = mapping.get('code','')
390	course = self.courses_catalog.getRecordByKey(course_id)
391	msg = ''
392	while True:
393	if course is None:
394	msg = "no course with id: %s" % course_id
395	break
396	course_object = getattr(getattr(getattr(getattr(self.academics_folder,course.faculty),
397	course.department),
398	'courses'),
399	course_id)
400	course_object.getContent().edit(mapping=mapping)
401	break
402	return course_id,msg,mapping
403	###)
404	###)
405
406	class CourseResultImport(WAeUPImport):###(
407	""" CourseresultImport """
408	name = "course_result"
409	plural_name = "%ss" % name
410	commit_after = 1000000
411	required_modes = ('create','edit','remove')
412
413	def create(self,mapping):###(
414	students_folder = self.portal_url.getPortalObject().campus.students
415	if getattr(self,'_v_courses',None) is None:
416	res = self.courses_catalog()
417	self._v_courses = {}
418	for brain in res:
419	self._v_courses[brain.code] = brain
420	if getattr(self,'_v_level_created',None) is None:
421	self._v_level_created = []
422	if getattr(self,'_v_student_study_course',None) is None:
423	self._v_student_study_course = {}
424	msg = ''
425	key = ''
426	matric_no = mapping.get('matric_no','')
427	id = mapping.get('id','')
428	while True:
429	course_id = mapping.get('code')
430	if course_id not in self._v_courses.keys():
431	msg = "no course with id: %s" % course_id
432	break
433	result = self.findStudent('create',student_id=id,matric_no=matric_no)
434	msg = result['msg']
435	if msg:
436	break
437	student_record = result['student_record']
438	student_id = mapping['student_id'] = student_record.id
439	level_id = mapping.get('level_id','')
440	code = mapping.get('code','')
441	level_ident = "%(student_id)s_%(level_id)s" % vars()
442	if level_ident not in self._v_level_created:
443	context = self._v_student_study_course.get(student_id,None)
444	if context is None:
445	try:
446	context = getattr(getattr(students_folder,
447	"%(student_id)s" % vars()),
448	'study_course')
449	self._v_student_study_course[student_id] = context
450	except:
451	msg = "could not create level %(level_id)s for %(student_id)s" % vars()
452	break
453	if level_id not in context.objectIds():
454	context.invokeFactory('StudentStudyLevel',"%(level_id)s" % vars())
455	level = getattr(context,"%(level_id)s" % vars())
456	self.portal_workflow.doActionFor(level,'open')
457	level.getContent().edit(mapping={'session': "%(session_id)s" % mapping,})
458	self.portal_workflow.doActionFor(level,'close')
459	self._v_level_created += level_ident,
460	mapping['key'] = key = "%(student_id)s\|%(level_id)s\|%(code)s" % vars()
461	#overwrite semester and credits in create mode
462	for k in ('semester','credits',):
463	mapping[k] = getattr(self._v_courses[course_id],k)
464	try:
465	self.course_results.addRecord(**mapping)
466	except ValueError:
467	msg = "course result already exists: %s" % key
468	break
469	return key,msg,mapping
470	###)
471
472	def edit(self,mapping): ###(
473	msg = ''
474	key = ''
475	matric_no = mapping.get('matric_no','')
476	id = mapping.get('id','')
477	while True:
478	result = self.findStudent('edit',student_id=id,matric_no=matric_no)
479	msg = result['msg']
480	if msg:
481	break
482	student_record = result['student_record']
483	student_id = student_record.id
484	level_id = mapping.get('level_id','')
485	code = mapping.get('code','')
486	#code = mapping['code']
487	mapping['key'] = key = "%(student_id)s\|%(level_id)s\|%(code)s" % vars()
488	if self.course_results.getRecordByKey(key) is None:
489	msg = "no course result with key %(key)s" % vars()
490	break
491	self.course_results.modifyRecord(**mapping)
492	break
493	return key,msg,mapping
494	###)
495
496	def remove(self,mapping):###(
497	key = ''
498	msg = ''
499	matric_no = mapping.get('matric_no','')
500	id = mapping.get('id','')
501	while True:
502	result = self.findStudent('edit',student_id=id,matric_no=matric_no)
503	msg = result['msg']
504	if msg:
505	break
506	student_record = result['student_record']
507	student_id = student_record.id
508	level_id = mapping.get('level_id','')
509	code = mapping.get('code','')
510	key = "%(student_id)s\|%(level_id)s\|%(code)s" % vars()
511	if self.course_results.getRecordByKey(key) is None:
512	msg = "no course result with key %(key)s" % vars()
513	break
514	self.course_results.deleteRecord(key)
515	break
516	return key,msg,mapping
517	###)
518	###)
519
520	class CertificateCourseImport(WAeUPImport):###(
521	name = "certificate_course"
522	plural_name = "%ss" % name
523	commit_after = 100000
524	required_modes = ('create','edit')
525
526	def create(self,mapping):
527	if getattr(self,'_v_courses',None) is None:
528	res = self.courses_catalog()
529	self._v_courses= [course.code for course in res]
530	if getattr(self,'_v_ceritficates',None) is None:
531	res = self.portal_catalog(portal_type = "Certificate")
532	self._v_certificates = {}
533	for cert in res:
534	self._v_certificates[cert.getId] = cert.getObject()
535	msg = ''
536	while True:
537	certificate_course_id = mapping.get('code')
538	if certificate_course_id not in self._v_courses:
539	msg = "no course with id: %s" % certificate_course_id
540	break
541	cert_id = mapping['certificate_code']
542	cert = self._v_certificates.get(cert_id,None)
543	if cert is None:
544	msg = "no certificate with id: %s" % cert_id
545	break
546	level_id = mapping.get('level')
547	level = getattr(cert,level_id,None)
548	if level is None:
549	cert.invokeFactory('StudyLevel', level_id)
550	level = getattr(cert,level_id,None)
551	elif hasattr(level,certificate_course_id):
552	msg = "duplicate certificate course id: %(certificate_course_id)s " % vars()
553	msg += "in %(cert_id)s/ %(level_id)s" % vars()
554	break
555	level.invokeFactory('CertificateCourse', certificate_course_id)
556	c = getattr(level,certificate_course_id)
557	c.getContent().edit(mapping=mapping)
558	break
559	return certificate_course_id,msg,mapping
560	###)
561
562	class DepartmentImport(WAeUPImport):###(
563	name = "department"
564	plural_name = "%ss" % name
565	commit_after = 1000
566
567	def create(self,mapping):###(
568	"create a department in the correct faculty"
569	faculty_id = mapping['faculty_code']
570	msg = ''
571	if getattr(self,'_v_faculties',None) is None:
572	res = self.portal_catalog(portal_type = "Department")
573	self._v_faculties = {}
574	for f in res:
575	self._v_faculties[f.getId] = f.getObject()
576	department_id = mapping.get('code','')
577	while True:
578	faculty = self._v_faculties.get(faculty_id,None)
579	if faculty is None:
580	msg = "no faculty with id: %s" % faculty_id
581	break
582	else:
583	d = getattr(faculty,department_id,None)
584	if d is None or d.portal_type == "Faculty":
585	try:
586	faculty.invokeFactory('Department', department_id)
587	except BadRequest,E:
588	msg = "%s" % E
589	break
590	d = getattr(faculty,department_id)
591	d.invokeFactory('CoursesFolder','courses')
592	courses = getattr(d,'courses')
593	dict = {'Title': 'Courses'}
594	courses.getContent().edit(mapping=dict)
595	d.invokeFactory('CertificatesFolder','certificates')
596	certificates = getattr(d,'certificates')
597	dict = {'Title': 'Certificates'}
598	certificates.getContent().edit(mapping=dict)
599	d.getContent().edit(mapping=mapping)
600	break
601	return department_id,msg,mapping
602	###)
603
604	def edit(self,mapping): ###(
605	"edit a department in the correct faculty"
606	academics_folder = self.portal_url.getPortalObject().campus.academics
607	faculty_id = mapping['faculty_code']
608	department_id = mapping.get('code','')
609	msg = ''
610	while True:
611	try:
612	d = getattr(getattr(academics_folder,faculty_id),department_id,None)
613	except KeyError:
614	msg = "department %s or faculty %s wrong" % (department_id,faculty_id)
615	break
616	if d is None or d.portal_type == "Faculty":
617	msg = "department %s not found" % (department_id)
618	break
619	d.getContent().edit(mapping=mapping)
620	break
621	return department_id,msg,mapping
622	###)
623	###)
624
625	class FacultyImport(WAeUPImport):###(
626	name = "faculty"
627	plural_name = "faculties"
628	commit_after = 100
629
630	def create(self,mapping): ###(
631	"create a faculty"
632	academics_folder = self.portal_url.getPortalObject().campus.academics
633	faculty_id = mapping.get('code','')
634	msg = ''
635	while True:
636	if faculty_id in academics_folder.objectIds():
637	msg = "faculty with id: %s exists" % faculty_id
638	break
639	logger.info('Creating Faculty %(code)s, %(title)s' % mapping)
640	try:
641	academics_folder.invokeFactory('Faculty', faculty_id)
642	except BadRequest,E:
643	msg = "%s" % E
644	break
645	f = getattr(academics_folder,faculty_id,None)
646	f.getContent().edit(mapping=mapping)
647	break
648	return faculty_id,msg,mapping
649	###)
650
651	def edit(self,mapping): ###(
652	"edit a faculty"
653	academics_folder = self.portal_url.getPortalObject().campus.academics
654	faculty_id = mapping['code']
655	msg = ''
656	while True:
657	f = getattr(academics_folder,faculty_id,None)
658	if f is None:
659	msg = "faculty with id: %s does not exist" % faculty_id
660	f.getContent().edit(mapping=mapping)
661	break
662	return faculty_id,msg,mapping
663	###)
664	###)
665
666	class StudentImport(WAeUPImport):###(
667	name = "student"
668	plural_name = "%ss" % name
669	commit_after = 100
670
671	field2types_student = { ###(
672	'StudentApplication':
673	{'id': 'application',
674	'title': 'Application Data',
675	'wf_transition_return': 'close',
676	'wf_transition_admit': 'remain',
677	'fields':
678	('jamb_reg_no',
679	'entry_mode',
680	'entry_session',
681	'jamb_score',
682	'app_email',
683	'jamb_age',
684	'jamb_state',
685	'jamb_lga',
686	'jamb_sex',
687	)
688	},
689	#'StudentPume':
690	# {'id': 'pume',
691	# 'title': 'Pume Data',
692	# 'wf_transition_return': 'close',
693	# 'wf_transition_admit': 'close',
694	# 'fields':
695	# ('pume_score',
696	# )
697	# },
698	'StudentClearance':
699	{'id': 'clearance',
700	'title': 'Clearance/Eligibility Record',
701	'wf_transition_return': 'close',
702	'wf_transition_admit': 'remain',
703	'fields':
704	('matric_no',
705	'nationality',
706	'lga',
707	'birthday',
708	)
709	},
710	'StudentPersonal':
711	{'id': 'personal',
712	'title': 'Personal Data',
713	'wf_transition_return': 'open',
714	'wf_transition_admit': 'remain',
715	'fields':
716	('firstname',
717	'middlename',
718	'lastname',
719	'sex',
720	'email',
721	'phone',
722	'perm_address',
723	)
724	},
725	'StudentStudyCourse':
726	{'id': 'study_course',
727	'title': 'Study Course',
728	'wf_transition_return': 'open',
729	'wf_transition_admit': 'remain',
730	'fields':
731	('study_course',
732	'current_level',
733	'current_session',
734	'current_mode',
735	'current_verdict',
736	'previous_verdict',
737	)
738	},
739	# 'StudentStudyLevel':
740	# {'id': 'current_level',
741	# 'title': '',
742	# 'wf_transition_return': 'open',
743	# 'wf_transition_admit': 'remain',
744	# 'fields':
745	# ('verdict',
746	# 'session',
747	# )
748	# },
749	'PaymentsFolder':
750	{'id': 'payments',
751	'title': 'Payments',
752	'wf_transition_return': 'open',
753	'wf_transition_admit': 'open',
754	'fields':
755	()
756	},
757	}
758	###)
759
760	def create(self,mapping): ###(
761	"create student records due import"
762	logger = logging.getLogger('WAeUPTool.mass_create_student')
763	students_folder = self.portal_url.getPortalObject().campus.students
764	jamb_reg_no = mapping.get('jamb_reg_no',None)
765	matric_no = mapping.get('matric_no',None)
766	msg = ''
767	student_id = mapping.get('id',None)
768	while True:
769	if student_id:
770	msg = "student_id must not be specified in create mode"
771	break
772	if jamb_reg_no:
773	res = self.students_catalog(jamb_reg_no = jamb_reg_no)
774	if res:
775	msg = "jamb_reg_no already assigned to student %s" % res[0].id
776	break
777	if matric_no:
778	res = self.students_catalog(matric_no = matric_no)
779	if res:
780	msg = "matric_no already assigned to student %s" % res[0].id
781	break
782	if not matric_no and not jamb_reg_no:
783	msg = "jamb_reg_no or matric_no must be specified"
784	break
785	student_id = self.waeup_tool.generateStudentId('?')
786	students_folder.invokeFactory('Student', student_id)
787	student_obj = getattr(students_folder,student_id)
788	f2t = self.field2types_student
789	d = {}
790	transition = mapping.get('reg_transition','admit')
791	if transition not in ('admit','return'):
792	msg = "no valid transition provided"
793	break
794	for pt in f2t.keys():
795	student_obj.invokeFactory(pt,f2t[pt]['id'])
796	sub_obj = getattr(student_obj,f2t[pt]['id'])
797	sub_doc = sub_obj.getContent()
798	d['Title'] = f2t[pt]['title']
799	for field in f2t[pt]['fields']:
800	d[field] = mapping.get(field,'')
801
802	if pt == "StudentApplication":
803	#d['jamb_sex'] = 'M'
804	#if mapping.get('sex'):
805	# d['jamb_sex'] = 'F'
806	d['jamb_firstname'] = mapping.get('firstname',None)
807	d['jamb_middlename'] = mapping.get('middlename',None)
808	d['jamb_lastname'] = mapping.get('lastname',None)
809
810	# if pt == "StudyCourse":
811	# for von,zu in (('entry_mode','current_mode'),
812	# ('entry_session','current_session')):
813	# if mapping.get(zu,None) is None and mapping.get(von,None) is not None:
814	# d[zu] = mapping[von]
815	sub_doc.edit(mapping = d)
816
817	#import pdb;pdb.set_trace()
818	new_state = f2t[pt]['wf_transition_%(transition)s' % vars()]
819	if new_state != "remain":
820	self.portal_workflow.doActionFor(sub_obj,new_state,dest_container=sub_obj)
821	self.portal_workflow.doActionFor(student_obj,transition)
822	student_obj.manage_setLocalRoles(student_id, ['Owner',])
823	mapping['id'] = student_id
824	break
825	return student_id,msg,mapping
826	###)
827
828	def edit(self,mapping): ###(
829	"edit student records due import"
830	wftool = self.portal_workflow
831	logger = logging.getLogger('WAeUPTool.mass_edit_student')
832	students_folder = self.portal_url.getPortalObject().campus.students
833	student_id = mapping.get('id',None)
834	jamb_reg_no = mapping.get('jamb_reg_no',None)
835	matric_no = mapping.get('matric_no',None)
836	editable_keys = mapping.keys()
837	msg = ''
838	while True:
839	if student_id:
840	res = self.students_catalog(id = student_id)
841	if not res:
842	msg = "no student with id %s" % student_id
843	break
844	student_record = res[0]
845	if matric_no and student_record.matric_no:
846	if matric_no != student_record.matric_no:
847	res = self.students_catalog(matric_no = matric_no)
848	if res:
849	msg = "matric_no already assigned to student %s" % res[0].id
850	break
851	msg = "old matric_no %s overwritten with %s" % (student_record.matric_no,matric_no)
852	#logger.info("%s, old matric_no %s overwritten with %s" % (student_record.id,student_record.matric_no,matric_no))
853	if jamb_reg_no and student_record.jamb_reg_no:
854	if jamb_reg_no != student_record.jamb_reg_no:
855	res = self.students_catalog(jamb_reg_no = jamb_reg_no)
856	if res:
857	msg = "jamb_reg_no already assigned to student %s" % res[0].id
858	break
859	msg = "old jamb_reg_no %s overwritten with %s" % (student_record.jamb_reg_no,jamb_reg_no)
860	#logger.info("%s, old reg_no %s overwritten with %s" % (student_record.id,student_record.jamb_reg_no,jamb_reg_no))
861	elif jamb_reg_no:
862	res = self.students_catalog(jamb_reg_no = jamb_reg_no)
863	if not res:
864	msg = "no student with jamb_reg_no %s" % jamb_reg_no
865	break
866	student_record = res[0]
867	editable_keys.remove('jamb_reg_no')
868	elif matric_no:
869	res = self.students_catalog(matric_no = matric_no)
870	if not res:
871	msg = "no student with matric_no %s" % matric_no
872	break
873	student_record = res[0]
874	editable_keys.remove('matric_no')
875	## included only to change wf state from admitted to returning
876	#if student_record.review_state not in ('admitted','objection_raised'):
877	# return '%s' % student_record.id ,"student is not in state admitted or objection_raised"
878	## end inclusion
879	student_id = student_record.id
880	student_obj = getattr(students_folder,student_id)
881	f2t = self.field2types_student
882	d = {}
883	any_change = False
884	#special treatment for StudentStudyLevel
885	d['verdict'] = mapping.get('current_verdict','')
886	d['session'] = mapping.get('current_session','')
887	current_level = mapping.get('current_level','')
888	while d['session'] and d['verdict'] and current_level:
889	sub_obj = getattr(student_obj,'study_course',None)
890	if sub_obj is None:
891	break
892	level_obj = getattr(sub_obj,current_level,None)
893	if level_obj is None:
894	break
895	any_change = True
896	level_obj.getContent().edit(mapping = d)
897	try:
898	wftool.doActionFor(level_obj,'close')
899	except:
900	pass
901	break
902	for pt in f2t.keys():
903	#if pt == "StudentApplication":
904	# d['jamb_sex'] = 'M'
905	# if mapping.get('sex'):
906	# d['jamb_sex'] = 'F'
907	intersect = set(f2t[pt]['fields']).intersection(set(editable_keys))
908	if intersect and pt not in ('StudentStudyLevel',):
909	object_id = f2t[pt]['id']
910	sub_obj = getattr(student_obj,object_id,None)
911	if sub_obj is None:
912	try:
913	student_obj.invokeFactory(pt,object_id)
914	except:
915	continue
916	sub_obj = getattr(student_obj,object_id)
917	if f2t[pt]['title'] != '':
918	d['Title'] = f2t[pt]['title']
919	sub_doc = sub_obj.getContent()
920	for field in intersect:
921	changed = False
922	if getattr(sub_doc,field,None) != mapping.get(field,''):
923	any_change = True
924	changed = True
925	d[field] = mapping.get(field,'')
926	if changed:
927	sub_doc.edit(mapping = d)
928	## included only to change wf state from admitted to returning
929	# if student_record.review_state in ('admitted','objection_raised'):
930	# new_state = f2t[pt]['wf_transition_return']
931	# sub_obj = getattr(student_obj,f2t[pt]['id'],None)
932	# if sub_obj and new_state != "remain":
933	# try:
934	# self.portal_workflow.doActionFor(sub_obj,new_state,dest_container=sub_obj)
935	# except:
936	# #logger.info('%s, wf transition %s of %s failed' % (student_id,new_state,sub_obj.id))
937	# pass
938	#if student_record.review_state in ('admitted','objection_raised'):
939	# wfaction = 'return'
940	# try:
941	# self.portal_workflow.doActionFor(student_obj,wfaction)
942	# logger.info('%s, wf state changed' % student_id)
943	# any_change = True
944	# except:
945	# logger.info('%s, wf transition failed, old state = %s' % (student_id,student_record.review_state))
946	# pass
947	## end inclusion
948	break
949	# if not any_change:
950	# msg = 'not modified'
951	return student_id,msg,mapping
952	###)
953	###)
954
955	class StudentStudyLevelImport(WAeUPImport):###(
956	""" StudentStudyLevelImport """
957	name = "student_study_level"
958	plural_name = "%ss" % name
959	commit_after = 1000000
960	required_modes = ('create',)
961
962	def create(self,mapping): ###(
963	"edit student levels and create StudentStudyLevel object if not existent"
964	wftool = self.portal_workflow
965	logger = logging.getLogger('WAeUPTool.mass_create_level')
966	students_folder = self.portal_url.getPortalObject().campus.students
967	student_id = mapping.get('id',None)
968	matric_no = mapping.get('matric_no',None)
969	editable_keys = mapping.keys()
970	key = ''
971	msg = ''
972	while True:
973	result = self.findStudent('create',student_id=student_id,matric_no=matric_no)
974	msg = result['msg']
975	if msg:
976	break
977	student_record = result['student_record']
978	student_id = student_record.id
979	mapping['id'] = student_id
980	session = mapping.get('session','')
981	level = key = mapping.get('code','')
982	if not level.isdigit():
983	msg = 'student %s: imported level is empty' % (student_id,)
984	break
985	study_course_obj = getattr(getattr(students_folder,student_id),'study_course',None)
986	if study_course_obj is None:
987	msg = 'student %s: no study_course object' % student_id
988	break
989	level_obj = getattr(study_course_obj,level,None)
990	if level_obj is None:
991	# The only difference to the edit method is that we create a StudentStudyLevel object
992	try:
993	study_course_obj.invokeFactory('StudentStudyLevel',"%s" % level)
994	level_obj = getattr(context,"%s" % level)
995	except:
996	continue
997	level_obj.getContent().edit(mapping = mapping)
998	level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
999	if level_review_state != "closed":
1000	wftool.doActionFor(level_obj,'close')
1001	break
1002	return key,msg,mapping
1003	###)
1004
1005	def edit(self,mapping): ###(
1006	"edit student levels"
1007	wftool = self.portal_workflow
1008	logger = logging.getLogger('WAeUPTool.mass_edit_level')
1009	students_folder = self.portal_url.getPortalObject().campus.students
1010	student_id = mapping.get('id',None)
1011	matric_no = mapping.get('matric_no',None)
1012	key = ''
1013	msg = ''
1014	while True:
1015	result = self.findStudent('create',student_id=student_id,matric_no=matric_no)
1016	msg = result['msg']
1017	if msg:
1018	break
1019	student_record = result['student_record']
1020	student_id = student_record.id
1021	mapping['id'] = student_id
1022	session = mapping.get('session','')
1023	level = key = mapping.get('code','')
1024	#import pdb;pdb.set_trace()
1025	if not level.isdigit():
1026	msg = 'student %s: imported level is empty' % (student_id,)
1027	break
1028	study_course_obj = getattr(getattr(students_folder,student_id),'study_course',None)
1029	if study_course_obj is None:
1030	msg = 'student %s: no study_course object' % student_id
1031	break
1032	level_obj = getattr(study_course_obj,level,None)
1033	if level_obj is None:
1034	msg = 'student %s: no study_level object for level %s' % (student_id,level)
1035	break
1036	level_obj.getContent().edit(mapping = mapping)
1037	break
1038	return key,msg,mapping
1039	###)
1040	###)
1041
1042	class VerdictImport(WAeUPImport):###(
1043	""" VerdictImport """
1044	name = "verdict"
1045	plural_name = "%ss" % name
1046	commit_after = 100000
1047	required_modes = ('create','edit')
1048
1049	def create(self,mapping): ###(
1050	"edit student verdicts and create StudentStudyLevel object if not existent"
1051	wftool = self.portal_workflow
1052	logger = logging.getLogger('WAeUPTool.mass_edit_verdict')
1053	students_folder = self.portal_url.getPortalObject().campus.students
1054	student_id = mapping.get('id',None)
1055	matric_no = mapping.get('matric_no',None)
1056	editable_keys = mapping.keys()
1057	key = ''
1058	while True:
1059	result = self.findStudent('create',student_id=student_id,matric_no=matric_no)
1060	#student_record,msg = self.getStudentRecord(mapping)
1061	msg = result['msg']
1062	if msg:
1063	break
1064	student_record = result['student_record']
1065	student_id = student_record.id
1066	mapping['id'] = student_id
1067	d = {}
1068	#import pdb;pdb.set_trace()
1069	any_change = False
1070	#special treatment for StudentStudyLevel
1071	current_session = d['session'] = mapping.get('current_session','')
1072	if current_session and student_record.session != current_session:
1073	msg = 'student %s: imported session %s does not match current_session %s' % (student_id,
1074	current_session,
1075	student_record.session)
1076	break
1077	current_level = mapping.get('current_level','')
1078	if not current_level.isdigit():
1079	msg = 'student %s: imported level is empty' % (student_id,)
1080	break
1081	if current_level and student_record.level != current_level:
1082	msg = 'student %s: imported level %s does not match current_level %s' % (student_id,
1083	current_level,
1084	student_record.level)
1085	break
1086	student_review_state = student_record.review_state
1087	if student_review_state == 'deactivated':
1088	msg = "student %s in review_state %s" % (student_id, student_review_state)
1089	break
1090	if student_review_state not in ('courses_validated','returning'):
1091	msg = "student %s in wrong review_state %s" % (student_id, student_review_state)
1092	break
1093	student_obj = getattr(students_folder,student_id)
1094	# f2t = self.field2types_student
1095	study_course_obj = getattr(student_obj,'study_course',None)
1096	if study_course_obj is None:
1097	msg = 'student %s: no study_course object' % student_id
1098	break
1099	level_obj = getattr(study_course_obj,current_level,None)
1100
1101	if level_obj is None:
1102	# The only difference to the edit method is that we create a StudentStudyLevel object
1103	try:
1104	study_course_obj.invokeFactory('StudentStudyLevel',"%s" % current_level)
1105	level_obj = getattr(context,"%s" % current_level)
1106	level_obj.portal_workflow.doActionFor(level,'open')
1107	except:
1108	continue
1109	#msg = 'student %s: no study_level object for level %s' % (student_id,
1110	# current_level)
1111	#break
1112
1113	verdict = d['verdict'] = d['current_verdict'] = mapping.get('current_verdict','')
1114
1115	#if verdict == student_record.verdict:
1116	# msg = 'student %s: verdict already set to %s' % (student_id,
1117	# verdict)
1118
1119	level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1120	if level_review_state != "closed":
1121	wftool.doActionFor(level_obj,'close')
1122	# msg = 'student %s: level %s is not closed' % (student_id,
1123	# current_level)
1124
1125	study_course_obj.getContent().edit(mapping = d)
1126	level_obj.getContent().edit(mapping = d)
1127	if student_review_state != "returning":
1128	wftool.doActionFor(student_obj,'return')
1129	# try:
1130	# wftool.doActionFor(level_obj,'close')
1131	# except:
1132	# pass
1133	break
1134	return student_id,msg,mapping
1135	###)
1136
1137	def create_old(self,mapping): ###(
1138	"edit student verdicts and create StudentStudyLevel object if not existent"
1139	wftool = self.portal_workflow
1140	logger = logging.getLogger('WAeUPTool.mass_edit_verdict')
1141	students_folder = self.portal_url.getPortalObject().campus.students
1142	student_id = mapping.get('id',None)
1143	matric_no = mapping.get('matric_no',None)
1144	editable_keys = mapping.keys()
1145	while True:
1146	key = ''
1147	msg = ''
1148	if student_id:
1149	student_record = self.students_catalog.getRecordByKey(student_id)
1150	if student_record is None:
1151	#return '',"no student with id %s" % student_id
1152	msg = "no student with id %s" % student_id
1153	break
1154	if matric_no and student_record.matric_no and matric_no != student_record.matric_no:
1155	msg = 'student %s: matric_no %s does not match %s' % (student_record.id,
1156	student_record.matric_no,
1157	matric_no)
1158	break
1159	mapping['matric_no'] = student_record.matric_no
1160	elif matric_no:
1161	res = self.students_catalog(matric_no = matric_no)
1162	if not res:
1163	msg = "no student with matric_no %s" % matric_no
1164	break
1165	student_record = res[0]
1166	editable_keys.remove('matric_no')
1167	else:
1168	msg = "no id or matric_no specified"
1169	break
1170	student_id = student_record.id
1171	mapping['id'] = student_id
1172	d = {}
1173	#import pdb;pdb.set_trace()
1174	any_change = False
1175	#special treatment for StudentStudyLevel
1176	current_session = d['session'] = mapping.get('current_session','')
1177	if current_session and student_record.session != current_session:
1178	msg = 'student %s: imported session %s does not match current_session %s' % (student_id,
1179	current_session,
1180	student_record.session)
1181	break
1182	current_level = mapping.get('current_level','')
1183	if not current_level.isdigit():
1184	msg = 'student %s: imported level is empty' % (student_id,)
1185	break
1186	if current_level and student_record.level != current_level:
1187	msg = 'student %s: imported level %s does not match current_level %s' % (student_id,
1188	current_level,
1189	student_record.level)
1190	break
1191	student_review_state = student_record.review_state
1192	if student_review_state == 'deactivated':
1193	msg = "student %s in review_state %s" % (student_id, student_review_state)
1194	break
1195	if student_review_state not in ('courses_validated','returning'):
1196	msg = "student %s in wrong review_state %s" % (student_id, student_review_state)
1197	break
1198	student_obj = getattr(students_folder,student_id)
1199	# f2t = self.field2types_student
1200	study_course_obj = getattr(student_obj,'study_course',None)
1201	if study_course_obj is None:
1202	msg = 'student %s: no study_course object' % student_id
1203	break
1204	level_obj = getattr(study_course_obj,current_level,None)
1205
1206	if level_obj is None:
1207	# The only difference to the edit method is that we create a StudentStudyLevel object
1208	try:
1209	study_course_obj.invokeFactory('StudentStudyLevel',"%s" % current_level)
1210	level_obj = getattr(context,"%s" % current_level)
1211	level_obj.portal_workflow.doActionFor(level,'open')
1212	except:
1213	continue
1214	#msg = 'student %s: no study_level object for level %s' % (student_id,
1215	# current_level)
1216	#break
1217
1218	verdict = d['verdict'] = d['current_verdict'] = mapping.get('current_verdict','')
1219
1220	#if verdict == student_record.verdict:
1221	# msg = 'student %s: verdict already set to %s' % (student_id,
1222	# verdict)
1223
1224	level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1225	if level_review_state != "closed":
1226	wftool.doActionFor(level_obj,'close')
1227	# msg = 'student %s: level %s is not closed' % (student_id,
1228	# current_level)
1229
1230	study_course_obj.getContent().edit(mapping = d)
1231	level_obj.getContent().edit(mapping = d)
1232	if student_review_state != "returning":
1233	wftool.doActionFor(student_obj,'return')
1234	# try:
1235	# wftool.doActionFor(level_obj,'close')
1236	# except:
1237	# pass
1238	break
1239	return student_id,msg,mapping
1240	###)
1241
1242	def edit(self,mapping): ###(
1243	"edit student verdicts"
1244	wftool = self.portal_workflow
1245	logger = logging.getLogger('WAeUPTool.mass_edit_verdict')
1246	students_folder = self.portal_url.getPortalObject().campus.students
1247	student_id = mapping.get('id',None)
1248	matric_no = mapping.get('matric_no',None)
1249	editable_keys = mapping.keys()
1250	key = ''
1251	while True:
1252	result = self.findStudent('edit',student_id=student_id,matric_no=matric_no)
1253	#student_record,msg = self.getStudentRecord(mapping)
1254	msg = result['msg']
1255	if msg:
1256	break
1257	student_record = result['student_record']
1258	key_used = result['key_used']
1259	if key_used in editable_keys:
1260	editable_keys.remove(key_used)
1261	student_id = student_record.id
1262	mapping['id'] = student_id
1263	d = {}
1264	#import pdb;pdb.set_trace()
1265	any_change = False
1266	#special treatment for StudentStudyLevel
1267	current_session = d['session'] = mapping.get('current_session','')
1268	if current_session and student_record.session != current_session:
1269	msg = 'student %s: imported session %s does not match current_session %s' % (student_id,
1270	current_session,
1271	student_record.session)
1272	break
1273	current_level = mapping.get('current_level','')
1274	if not current_level.isdigit():
1275	msg = 'student %s: imported level is empty' % (student_id,)
1276	break
1277	if current_level and student_record.level != current_level:
1278	msg = 'student %s: imported level %s does not match current_level %s' % (student_id,
1279	current_level,
1280	student_record.level)
1281	break
1282	student_review_state = student_record.review_state
1283	if student_review_state == 'deactivated':
1284	msg = "student %s in review_state %s" % (student_id, student_review_state)
1285	break
1286	if student_review_state not in ('courses_validated','returning'):
1287	msg = "student %s in wrong review_state %s" % (student_id, student_review_state)
1288	break
1289	student_obj = getattr(students_folder,student_id)
1290	# f2t = self.field2types_student
1291	study_course_obj = getattr(student_obj,'study_course',None)
1292	if study_course_obj is None:
1293	msg = 'student %s: no study_course object' % student_id
1294	break
1295	level_obj = getattr(study_course_obj,current_level,None)
1296	if level_obj is None:
1297	msg = 'student %s: no study_level object for level %s' % (student_id,
1298	current_level)
1299	break
1300	verdict = d['verdict'] = d['current_verdict'] = mapping.get('current_verdict','')
1301
1302	#if verdict == student_record.verdict:
1303	# msg = 'student %s: verdict already set to %s' % (student_id,
1304	# verdict)
1305
1306	level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1307	if level_review_state != "closed":
1308	wftool.doActionFor(level_obj,'close')
1309	# msg = 'student %s: level %s is not closed' % (student_id,
1310	# current_level)
1311
1312	study_course_obj.getContent().edit(mapping = d)
1313	level_obj.getContent().edit(mapping = d)
1314	if student_review_state != "returning":
1315	wftool.doActionFor(student_obj,'return')
1316	# try:
1317	# wftool.doActionFor(level_obj,'close')
1318	# except:
1319	# pass
1320	break
1321	return student_id,msg,mapping
1322	###)
1323
1324	def edit_old(self,mapping): ###(
1325	"edit student verdicts"
1326	wftool = self.portal_workflow
1327	logger = logging.getLogger('WAeUPTool.mass_edit_verdict')
1328	students_folder = self.portal_url.getPortalObject().campus.students
1329	student_id = mapping.get('id',None)
1330	matric_no = mapping.get('matric_no',None)
1331	editable_keys = mapping.keys()
1332	key = ''
1333	while True:
1334	msg = ''
1335	if student_id:
1336	student_record = self.students_catalog.getRecordByKey(student_id)
1337	if student_record is None:
1338	#return '',"no student with id %s" % student_id
1339	msg = "no student with id %s" % student_id
1340	break
1341	if matric_no and student_record.matric_no and matric_no != student_record.matric_no:
1342	msg = 'student %s: matric_no %s does not match %s' % (student_record.id,
1343	student_record.matric_no,
1344	matric_no)
1345	break
1346	mapping['matric_no'] = student_record.matric_no
1347	elif matric_no:
1348	res = self.students_catalog(matric_no = matric_no)
1349	if not res:
1350	msg = "no student with matric_no %s" % matric_no
1351	break
1352	student_record = res[0]
1353	editable_keys.remove('matric_no')
1354	else:
1355	msg = "no id or matric_no specified"
1356	break
1357	student_id = student_record.id
1358	mapping['id'] = student_id
1359	d = {}
1360	#import pdb;pdb.set_trace()
1361	any_change = False
1362	#special treatment for StudentStudyLevel
1363	current_session = d['session'] = mapping.get('current_session','')
1364	if current_session and student_record.session != current_session:
1365	msg = 'student %s: imported session %s does not match current_session %s' % (student_id,
1366	current_session,
1367	student_record.session)
1368	break
1369	current_level = mapping.get('current_level','')
1370	if not current_level.isdigit():
1371	msg = 'student %s: imported level is empty' % (student_id,)
1372	break
1373	if current_level and student_record.level != current_level:
1374	msg = 'student %s: imported level %s does not match current_level %s' % (student_id,
1375	current_level,
1376	student_record.level)
1377	break
1378	student_review_state = student_record.review_state
1379	if student_review_state == 'deactivated':
1380	msg = "student %s in review_state %s" % (student_id, student_review_state)
1381	break
1382	if student_review_state not in ('courses_validated','returning'):
1383	msg = "student %s in wrong review_state %s" % (student_id, student_review_state)
1384	break
1385	student_obj = getattr(students_folder,student_id)
1386	# f2t = self.field2types_student
1387	study_course_obj = getattr(student_obj,'study_course',None)
1388	if study_course_obj is None:
1389	msg = 'student %s: no study_course object' % student_id
1390	break
1391	level_obj = getattr(study_course_obj,current_level,None)
1392	if level_obj is None:
1393	msg = 'student %s: no study_level object for level %s' % (student_id,
1394	current_level)
1395	break
1396	verdict = d['verdict'] = d['current_verdict'] = mapping.get('current_verdict','')
1397
1398	#if verdict == student_record.verdict:
1399	# msg = 'student %s: verdict already set to %s' % (student_id,
1400	# verdict)
1401
1402	level_review_state = wftool.getInfoFor(level_obj,'review_state',None)
1403	if level_review_state != "closed":
1404	wftool.doActionFor(level_obj,'close')
1405	# msg = 'student %s: level %s is not closed' % (student_id,
1406	# current_level)
1407
1408	study_course_obj.getContent().edit(mapping = d)
1409	level_obj.getContent().edit(mapping = d)
1410	if student_review_state != "returning":
1411	wftool.doActionFor(student_obj,'return')
1412	# try:
1413	# wftool.doActionFor(level_obj,'close')
1414	# except:
1415	# pass
1416	break
1417	return student_id,msg,mapping
1418	###)
1419	###)

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

Download in other formats: