Le repo des sources pour le site web des JM2L
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 

1316 lines
57 KiB

  1. # -*- coding: utf8 -*-
  2. from pyramid.httpexceptions import HTTPFound, HTTPNotFound, HTTPForbidden
  3. from pyramid.httpexceptions import HTTPBadRequest, HTTPUnauthorized
  4. from pyramid.renderers import render_to_response
  5. from pyramid.response import Response
  6. from pyramid.view import notfound_view_config, forbidden_view_config
  7. from pyramid.view import view_config
  8. from pyramid_mailer import get_mailer
  9. from mako.template import Template
  10. # Import Web Forms
  11. from .forms import *
  12. # Database access imports
  13. from .models import *
  14. from sqlalchemy.exc import DBAPIError
  15. from sqlalchemy import func, or_
  16. # Usefull tools
  17. from slugify import slugify
  18. from icalendar import Calendar
  19. from pytz import timezone
  20. from icalendar import Event as Evt
  21. from pyramid_mailer import get_mailer
  22. from pyramid_mailer.message import Attachment, Message
  23. # Then, standard libs
  24. import webhelpers.paginate as paginate
  25. import unicodedata
  26. import time
  27. import datetime
  28. import re
  29. CurrentYear = 2015
  30. ## =-=- Here, We keep some usefull function -=-=
  31. def remove_accents(input_str):
  32. """ This function is intended to remove all accent from input unicode string """
  33. nkfd_form = unicodedata.normalize('NFKD', input_str)
  34. only_ascii = nkfd_form.encode('ASCII', 'ignore')
  35. return only_ascii
  36. ## =-=- Here, We handle ICal requests -=-=
  37. @view_config(route_name='progr_iCal', renderer="string")
  38. def ICal_Progamme_Request(request):
  39. year = int(request.matchdict.get('year', CurrentYear))
  40. # Initialization
  41. DicResult = dict()
  42. # Query database
  43. # Compute days used by all events matching the specified input year
  44. Events = DBSession.query(Event)\
  45. .filter(Event.for_year == year)\
  46. .filter(Event.event_type != 'Stand')\
  47. .order_by(Event.start_time)
  48. cal = Calendar()
  49. cal.add('prodid', '-//Programme %d//jm2l.linux-azur.org//' % year)
  50. cal.add('version', '2.0')
  51. tz = timezone('Europe/Paris')
  52. for ev in Events:
  53. if ev.event_type:
  54. event = Evt()
  55. event['uid'] = "%d/%d" % ( year, ev.uid )
  56. event.add('summary', ev.name )
  57. event.add('dtstart', ev.start_time.replace(tzinfo=tz) )
  58. event.add('dtend', ev.end_time.replace(tzinfo=tz) )
  59. event.add('created', ev.last_change.replace(tzinfo=tz) )
  60. event.add('description', "http://www.linux-azur.org/event/%s/%s" % (ev.for_year, ev.slug) )
  61. event.add('url', "http://www.linux-azur.org/event/%s/%s" % (ev.for_year, ev.slug) )
  62. event.add('priority', 5)
  63. cal.add_component(event)
  64. return cal.to_ical()
  65. ## =-=- Here, We handle Json requests -=-=
  66. @view_config(route_name='users_json', renderer="json")
  67. def JSON_User_Request(request):
  68. """ Build a JSON answer with active users and pagination handling """
  69. # Check arguments consitency
  70. pageSize = request.params.get('pageSize',"8")
  71. current_page = request.params.get('pageNum',"1")
  72. UserQuery = request.params.get('searchTerm', u"")
  73. # Don't answer to users that aren't logged
  74. if not request.user:
  75. raise HTTPForbidden(u'Vous devez vous identifier pour obtenir une réponse.')
  76. # Check consistancy of parameters
  77. if pageSize.isdigit() and current_page.isdigit():
  78. current_page = int(current_page)
  79. pageSize = int(pageSize)
  80. else:
  81. return HTTPBadRequest('pageSize and pageNum accept only digits.')
  82. # Query database
  83. Users = DBSession.query(User.uid, User.nom, User.prenom)\
  84. .filter(User.slug.contains( remove_accents(UserQuery) ))
  85. page_url = paginate.PageURL_WebOb(request)
  86. records = paginate.Page(Users, current_page, url=page_url, items_per_page=pageSize)
  87. ListMatchUser = map( lambda u:{"id": u.uid, "text":"%s %s" % ( u.prenom, u.nom )}, records )
  88. return { "Results": ListMatchUser, "Total":records.item_count,
  89. "logged_in":request.authenticated_userid }
  90. @view_config(route_name='tiers_json', renderer="json")
  91. def JSON_Tiers_Request(request):
  92. """ Build a JSON answer with active users and pagination handling """
  93. # Check arguments consitency
  94. pageSize = request.params.get('pageSize',"8")
  95. current_page = request.params.get('pageNum',"1")
  96. TiersQuery = request.params.get('searchTerm', u"")
  97. # Don't answer to users that aren't logged
  98. if not request.user:
  99. raise HTTPForbidden(u'Vous devez vous identifier pour obtenir une réponse.')
  100. # Check consistancy of parameters
  101. if pageSize.isdigit() and current_page.isdigit():
  102. current_page = int(current_page)
  103. pageSize = int(pageSize)
  104. else:
  105. return HTTPBadRequest('pageSize and pageNum accept only digits.')
  106. # Query database
  107. JTiers = DBSession.query(Tiers.uid, Tiers.name)\
  108. .filter(Tiers.slug.contains( remove_accents(TiersQuery) ))
  109. page_url = paginate.PageURL_WebOb(request)
  110. records = paginate.Page(JTiers, current_page, url=page_url, items_per_page=pageSize)
  111. ListMatchTiers = map( lambda t:{"id": t.uid, "text": t.name }, records )
  112. return { "Results": ListMatchTiers, "Total":records.item_count,
  113. "logged_in":request.authenticated_userid }
  114. @view_config(route_name='progr_json', renderer="json")
  115. def JSON_Progamme_Request(request):
  116. year = int(request.matchdict.get('year', CurrentYear))
  117. # Initialization
  118. DicResult = dict()
  119. # Query database
  120. # Compute days used by all events matching the specified input year
  121. Days = DBSession.query( func.strftime('%d', Event.start_time).label('day') )\
  122. .filter(Event.for_year == year)\
  123. .filter(Event.event_type != None)\
  124. .group_by(func.strftime('%d', Event.start_time)).all()
  125. for Day in Days:
  126. Events = DBSession.query(Event)\
  127. .filter(Event.for_year == year)\
  128. .filter(Event.event_type != 'Stand')\
  129. .filter("strftime('%d', start_time) = :dow").params(dow=Day.day)\
  130. .order_by(Event.start_time)
  131. ListEv = []
  132. for ev in Events:
  133. if ev.event_type:
  134. ListEv.append( {
  135. "uid":"%d/%d" % ( year, ev.uid ),
  136. "desc":ev.name,
  137. "startDate":ev.start_time.strftime('%Y-%m-%dT%H:%M:%S'),
  138. "endDate":ev.end_time.strftime('%Y-%m-%dT%H:%M:%S'),
  139. "placeName":ev.Salle and (ev.Salle.name or "unk") ,
  140. "status":ev.event_type
  141. } )
  142. DicResult[Day.day] = ListEv
  143. return { 'all':DicResult }
  144. @view_config(route_name='timeline_json', renderer="json")
  145. def JSON_TimeLine_Request(request):
  146. year = int(request.matchdict.get('year', CurrentYear))
  147. # Initialization
  148. DicResult = dict()
  149. # Query database
  150. # Compute days used by all events matching the specified input year
  151. Days = DBSession.query( func.strftime('%d', Event.start_time).label('day') )\
  152. .filter(Event.for_year == year)\
  153. .filter(Event.event_type != None)\
  154. .group_by(func.strftime('%d', Event.start_time)).all()
  155. ListEv = []
  156. for Day in Days:
  157. Events = DBSession.query(Event)\
  158. .filter(Event.for_year == year)\
  159. .filter(Event.event_type != 'Stand')\
  160. .filter("strftime('%d', start_time) = :dow").params(dow=Day.day)\
  161. .order_by(Event.start_time)
  162. ListEv = []
  163. for ev in Events:
  164. if ev.event_type:
  165. ListEv.append( {
  166. #"uid":"%d/%d" % ( year, ev.uid ),
  167. "headline":ev.name,
  168. "startDate":ev.start_time.strftime('%Y,%m,%d,%H,%M'),
  169. "endDate":ev.end_time.strftime('%Y,%m,%d,%H,%M'),
  170. "text":ev.Salle and (ev.Salle.name or "unk"),
  171. "tags":ev.Salle and (ev.Salle.name or "unk") ,
  172. #"status":ev.event_type,
  173. "asset": {
  174. "media":"", #http://jm2l.linux-azur.org/sites/jm2l.linux-azur.org/files/videos/2012/2012_Introduction_aux_logiciels_libres__Frederic_Couchet.ogv",
  175. "credit":"",
  176. "caption":"" }
  177. } )
  178. break
  179. DicResult = {
  180. "lang":"fr",
  181. "headline":"JM2L 2015",
  182. "type":"default",
  183. "startDate":"2015,11,28,10",
  184. "text":"<i><span class='c1'>9ème Édition</span></i>",
  185. "asset":
  186. {
  187. "media":"https://www.youtube.com/watch?v=DnfjrxVoLao",
  188. "credit":"JM2L",
  189. "caption":""
  190. }
  191. }
  192. DicResult["date"] = ListEv
  193. return { 'timeline':DicResult }
  194. ## =-=- Here, We handle HTTP requests - Public Part -=-=
  195. @view_config(route_name='home', renderer="jm2l:templates/NewIndex.mako")
  196. def index_page(request):
  197. MainTab = {'accueil':'active', "logged_in":request.authenticated_userid }
  198. return MainTab
  199. @view_config(route_name='programme', renderer="jm2l:templates/Public/Programme.mako")
  200. def programme(request):
  201. year = int(request.matchdict.get('year'))
  202. if 2006 > year:
  203. return HTTPBadRequest('The first JM2L event was in 2006.')
  204. # Query database about selected Year.
  205. Events = DBSession.query(Event)\
  206. .filter(Event.for_year == year)\
  207. .order_by(Event.start_time)
  208. Days = DBSession.query(func.strftime('%d-%m-%Y', Event.start_time))\
  209. .filter(Event.for_year == year)\
  210. .filter(Event.event_type != None)\
  211. .group_by(func.strftime('%d', Event.start_time)).all()
  212. ListDay = []
  213. for day in Days:
  214. RefDay = datetime.datetime.strptime(day[0],'%d-%m-%Y')
  215. ListDay.append( ( RefDay.strftime('%A %d %b %Y'),
  216. RefDay.strftime('%d') ) )
  217. MainTab = {'programme':'active','DisplayYear':year, \
  218. 'Events':Events, 'Event':Event, 'Days':ListDay, "logged_in":request.authenticated_userid }
  219. return MainTab
  220. @view_config(route_name='presse', renderer="jm2l:templates/Public/Presse.mako")
  221. def static_presse(request):
  222. year = int(request.matchdict.get('year', None))
  223. content = DBSession.query(JM2L_Year).filter(JM2L_Year.year_uid==year).first()
  224. MainTab = {'presse':'active', "logged_in":request.authenticated_userid, 'content':content, 'DisplayYear':year}
  225. return MainTab
  226. @view_config(route_name='edit_presse', renderer="jm2l:templates/Staff/EditPresse.mako")
  227. def edit_presse(request):
  228. year = int(request.matchdict.get('year', None))
  229. content = DBSession.query(JM2L_Year).filter(JM2L_Year.year_uid==year).first()
  230. form = DossPresse(request.POST, content, meta={'csrf_context': request.session})
  231. if request.method == 'POST' and form.validate():
  232. form.populate_obj(content)
  233. MainTab = {'presse':'active', "logged_in":request.authenticated_userid, 'form':form, 'DisplayYear':year}
  234. return MainTab
  235. @view_config(route_name='plan', renderer="jm2l:templates/Public/Plan.mako")
  236. def static_plan(request):
  237. MainTab = {'plan':'active', "logged_in":request.authenticated_userid }
  238. return MainTab
  239. ## =-=- Here, We handle HTTP requests - Staff Logged Part -=-=
  240. @view_config(route_name='list_task', renderer='jm2l:templates/Staff/list.mako')
  241. def list_view(request):
  242. if request.user is None:
  243. # Don't answer to users that aren't logged
  244. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  245. if not request.user.Staff:
  246. # Don't answer to users that aren't logged
  247. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  248. DicTask = {}
  249. taskgroup = DBSession.query( TasksArea ).all()
  250. for grp in taskgroup:
  251. tasks = DBSession.query( Tasks )\
  252. .filter( Tasks.area_uid==grp.uid )\
  253. .order_by(Tasks.closed, Tasks.due_date).all()
  254. DicTask[grp] = tasks
  255. return {'tasks': DicTask }
  256. @view_config(route_name='handle_task', renderer='jm2l:templates/Staff/tasks.mako')
  257. def tasks(request):
  258. if request.user is None:
  259. # Don't answer to users that aren't logged
  260. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  261. if not request.user.Staff:
  262. # Don't answer to users that aren't logged
  263. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  264. task_id = request.matchdict.get('task_id')
  265. # Convert the pole_id GET parameter to int or 0
  266. try:
  267. pole_id = int(request.params.get('pole_id'))
  268. except (ValueError, TypeError):
  269. pole_id = 0
  270. # Get areas from db
  271. Areas = DBSession.query(TasksArea.uid, TasksArea.name)\
  272. .order_by('name').all()
  273. # Get users from db
  274. Users = DBSession.query(User)\
  275. .filter(User.Staff==1)\
  276. .order_by('nom').all()
  277. if task_id:
  278. Task = Tasks.by_id(int(task_id))
  279. if not Task:
  280. raise HTTPNotFound()
  281. form = EditStaffTasks(request.POST, Task, meta={'csrf_context': request.session})
  282. else:
  283. Task = Tasks()
  284. # Check if the supplied pole_id is in the Areas' range
  285. Task.area_uid = pole_id if 1 < pole_id <= len(Areas) else 1
  286. form = StaffTasks(request.POST, Task, meta={'csrf_context': request.session})
  287. # Put some areas on form
  288. form.area_uid.choices = Areas
  289. # Put some users on form
  290. form.closed_by.choices = [(u.uid, "%s %s" % (u.nom, u.prenom))
  291. for u in Users]
  292. form.due_date.type = "date"
  293. if request.method == 'POST' and form.validate():
  294. form.populate_obj(Task)
  295. Task.closed = False
  296. if 'uid' in form._fields.keys():
  297. DBSession.merge(Task)
  298. else:
  299. DBSession.add(Task)
  300. DBSession.flush()
  301. return HTTPFound(location=request.route_url('list_task')+"#"+slugify(Task.area.name))
  302. return {'form':form, 'area':slugify(Areas[Task.area_uid-1].name)}
  303. @view_config(route_name='handle_pole', renderer='jm2l:templates/Staff/pole.mako')
  304. def tasks_area(request):
  305. if request.user is None:
  306. # Don't answer to users that aren't logged
  307. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  308. if not request.user.Staff:
  309. # Don't answer to users that aren't logged
  310. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  311. pole_id = request.matchdict.get('pole_id')
  312. if pole_id:
  313. Pole = TasksArea.by_id(int(pole_id))
  314. if not Pole:
  315. raise HTTPNotFound()
  316. form = EditStaffArea(request.POST, Pole, meta={'csrf_context': request.session})
  317. else:
  318. Pole = TasksArea()
  319. form = StaffArea(request.POST, Pole, meta={'csrf_context': request.session})
  320. if request.method == 'POST' and form.validate():
  321. form.populate_obj(Pole)
  322. if 'uid' in form._fields.keys():
  323. DBSession.merge(Pole)
  324. else:
  325. DBSession.add(Pole)
  326. return HTTPFound(location=request.route_url('list_task')+"#"+slugify(Pole.name))
  327. return {'form':form }
  328. @view_config(route_name='action_task')
  329. def action_task(request):
  330. if request.user is None:
  331. # Don't answer to users that aren't logged
  332. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  333. if not request.user.Staff:
  334. # Don't answer to users that aren't logged
  335. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  336. action = request.matchdict.get('action')
  337. task_id = request.matchdict.get('task_id')
  338. Task = Tasks.by_id(int(task_id))
  339. if action=='close':
  340. Task.closed = True
  341. request.session.flash(('info', u'La tâche a été fermé, Félicitations !'))
  342. DBSession.merge(Task)
  343. if action=='open':
  344. Task.closed = False
  345. request.session.flash(('info', u'La tâche a été ré-ouverte !'))
  346. DBSession.merge(Task)
  347. if action=='delete':
  348. request.session.flash(('info', u'La tâche a été supprimée !'))
  349. DBSession.delete(Task)
  350. return HTTPFound(location=request.route_url('list_task')+"#"+slugify(Task.area.name))
  351. @view_config(route_name='action_task_area')
  352. def action_task_area(request):
  353. action = request.matchdict.get('action')
  354. pole_id = request.matchdict.get('pole_id')
  355. Pole = TasksArea.by_id(int(pole_id))
  356. if not Pole:
  357. raise HTTPNotFound()
  358. if action=='delete':
  359. request.session.flash(('info', u'Le pôle a été supprimé !'))
  360. DBSession.delete(Pole)
  361. return HTTPFound(location=request.route_url('list_task'))
  362. @view_config(route_name='list_salles', renderer='jm2l:templates/Salles/list.mako')
  363. def list_salles(request):
  364. if request.user is None:
  365. # Don't answer to users that aren't logged
  366. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  367. if not request.user.Staff:
  368. # Don't answer to users that aren't logged
  369. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  370. DicSalle = {}
  371. years = DBSession.query( JM2L_Year ).all()
  372. for year in years:
  373. salles = DBSession.query( Salles )\
  374. .filter( Salles.year_uid==year.year_uid )\
  375. .order_by(Salles.name).all()
  376. DicSalle[year] = salles
  377. return {'DicSalle': DicSalle }
  378. @view_config(route_name='handle_salle', renderer='jm2l:templates/Salles/salle.mako')
  379. def handle_salle(request):
  380. if request.user is None:
  381. # Don't answer to users that aren't logged
  382. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  383. if not request.user.Staff:
  384. # Don't answer to users that aren't logged
  385. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  386. salle_id = request.matchdict.get('salle_id')
  387. if salle_id:
  388. Salle = Salles.by_id(int(salle_id))
  389. if not Salle:
  390. raise HTTPNotFound()
  391. form = EditSalleForm(request.POST, Salle, meta={'csrf_context': request.session})
  392. else:
  393. Salle = Salles()
  394. form = SalleForm(request.POST, Salle, meta={'csrf_context': request.session})
  395. form.year_uid.choices = map(tuple, DBSession.query(JM2L_Year.year_uid, JM2L_Year.year_uid).all())
  396. form.phy_salle_id.choices = map(tuple, DBSession.query(SallePhy.uid, SallePhy.name).all())
  397. if request.method == 'POST' and form.validate():
  398. form.populate_obj(Salle)
  399. if 'uid' in form._fields.keys():
  400. DBSession.merge(Salle)
  401. else:
  402. DBSession.add(Salle)
  403. return HTTPFound(location=request.route_url('list_salles'))
  404. return {'form':form }
  405. @view_config(route_name='handle_salle_phy', renderer='jm2l:templates/Salles/salle_phy.mako')
  406. def handle_salle_phy(request):
  407. if request.user is None:
  408. # Don't answer to users that aren't logged
  409. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  410. if not request.user.Staff:
  411. # Don't answer to users that aren't logged
  412. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  413. salle_id = request.matchdict.get('salle_id')
  414. if salle_id:
  415. Salle = SallePhy.by_id(int(salle_id))
  416. if not Salle:
  417. raise HTTPNotFound()
  418. form = EditSallePhyForm(request.POST, Salle, meta={'csrf_context': request.session})
  419. else:
  420. Salle = SallePhy()
  421. form = SallePhyForm(request.POST, Salle, meta={'csrf_context': request.session})
  422. if request.method == 'POST' and form.validate():
  423. form.populate_obj(Salle)
  424. Salle.slug = slugify(Salle.name)
  425. if 'uid' in form._fields.keys():
  426. DBSession.merge(Salle)
  427. else:
  428. DBSession.add(Salle)
  429. return HTTPFound(location=request.route_url('list_salles'))
  430. return {'form':form }
  431. @view_config(route_name='action_salle')
  432. def action_salle(request):
  433. if request.user is None:
  434. # Don't answer to users that aren't logged
  435. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  436. if not request.user.Staff:
  437. # Don't answer to users that aren't logged
  438. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  439. action = request.matchdict.get('action')
  440. salle_id = request.matchdict.get('salle_id')
  441. Salle = Salles.by_id(int(salle_id))
  442. if not Salle:
  443. raise HTTPNotFound()
  444. if action=='delete':
  445. request.session.flash(('info', u'La Salle a été supprimée !'))
  446. DBSession.delete(Salle)
  447. return HTTPFound(location=request.route_url('list_salles'))
  448. ## =-=- Here, We handle HTTP requests - User Logged Part -=-=
  449. @view_config(route_name='exchange', renderer="jm2l:templates/Logistique/Logistique.mako")
  450. def exchange(request):
  451. modtype = request.matchdict.get('modtype', None)
  452. action = request.matchdict.get('action', None)
  453. uid = int(request.matchdict.get('id', -1))
  454. Exch = Exchange.by_id(uid)
  455. if not Exch:
  456. MainTab = {
  457. 'Exchanges':Exchange,
  458. 'Type':modtype[-1:],
  459. 'reload':True,
  460. 'logged_in':request.authenticated_userid
  461. }
  462. return MainTab
  463. if action in ['delete', 'accept', 'refuse', 'deal']:
  464. if action=='delete': # delete exchange
  465. DBSession.delete(Exch)
  466. elif action=='accept': # accept exchange
  467. Exch.exch_done=True
  468. DBSession.merge(Exch)
  469. elif action=='refuse': # refuse exchange
  470. Exch.exch_done=False
  471. if Exch.exch_state=="Ask":
  472. Exch.provider_id = None
  473. elif Exch.exch_state=="Proposal":
  474. Exch.asker_id = None
  475. DBSession.merge(Exch)
  476. elif action=='deal':
  477. # ask to deal the exchange
  478. if Exch.exch_state=="Ask":
  479. Exch.provider_id = request.user.uid
  480. elif Exch.exch_state=="Proposal":
  481. Exch.asker_id = request.user.uid
  482. # Return javascript to parent page
  483. response = render_to_response('jm2l:templates/modals_js.mako',
  484. {'modtype':modtype, 'action':action},
  485. request=request)
  486. response.content_type = 'text/javascript'
  487. return response
  488. else:
  489. MainTab = {
  490. 'Exchanges':Exchange,
  491. 'Type':modtype[-1:],
  492. 'reload':True,
  493. 'logged_in':request.authenticated_userid
  494. }
  495. return MainTab
  496. @view_config(route_name='sejour')
  497. def sejour(request):
  498. if request.user is None:
  499. # Don't answer to users that aren't logged
  500. raise HTTPForbidden(u'Vous devez vous identifier pour obtenir une réponse.')
  501. if request.method == 'POST':
  502. print request.POST
  503. return HTTPFound(location='/MesJM2L#Sejour')
  504. @view_config(route_name='vote_logo')
  505. def vote_logo(request):
  506. if request.user is None:
  507. # Don't answer to users that aren't logged
  508. raise HTTPForbidden(u'Vous devez vous identifier pour obtenir une réponse.')
  509. else:
  510. vote = int(request.matchdict.get('num', -1))
  511. come = request.params.get('come_from')
  512. if vote:
  513. request.user.vote_logo=vote
  514. DBSession.merge(request.user)
  515. request.session.flash(('info',u'Votre vote à été pris en compte.'))
  516. return HTTPFound('/')
  517. else:
  518. request.session.flash(('warning',u"Votre vote n'a été pris en compte."))
  519. if come:
  520. return HTTPFound(location=come)
  521. raise HTTPForbidden(u'Vous devez vous identifier pour obtenir une réponse.')
  522. @view_config(route_name='jm2l', renderer="jm2l:templates/jm2l.mako")
  523. def jm2l_page(request):
  524. if request.user is None:
  525. # Don't answer to users that aren't logged
  526. raise HTTPForbidden('Vous devez vous identifier pour obtenir une réponse.')
  527. page = int(request.params.get('page', 1))
  528. UserNum = request.params.get('user')
  529. if UserNum:
  530. profil = User.by_id(int(UserNum))
  531. if not profil:
  532. raise HTTPNotFound()
  533. if not request.user.Staff:
  534. raise HTTPForbidden(u'Vous n\'avez pas l\'autorité suffisante pour effectuer cette action.')
  535. else:
  536. profil = request.user
  537. # Build Form
  538. profil_form = ProfilForm(request.POST, profil, meta={'csrf_context': request.session})
  539. miam_form = MiamForm(request.POST, profil, meta={'csrf_context': request.session})
  540. if request.method == 'POST' and profil_form.validate():
  541. ToDelete = list()
  542. # First, we remove entries no more present
  543. for obj in profil_form.tiersship.object_data:
  544. MatchEntry = filter( lambda x: x.object_data and x.object_data._sa_instance_state == obj._sa_instance_state,
  545. profil_form.tiersship.entries )
  546. if not MatchEntry:
  547. ToDelete.append(obj)
  548. # Then, it's time to consider new entries
  549. for entry in profil_form.tiersship.entries:
  550. if entry.object_data is None:
  551. TmpUser = User_Tiers()
  552. entry.object_data = TmpUser
  553. profil.tiersship.append(TmpUser)
  554. profil_form.tiersship.object_data = profil.tiersship
  555. profil_form.populate_obj(profil)
  556. # We should remove it as it's not in original data
  557. for obj in ToDelete:
  558. #profil.tiersship.remove(obj)
  559. DBSession.delete(obj)
  560. profil.last_change = datetime.datetime.utcnow()
  561. profil.slug = slugify(remove_accents('%s %s' % (profil.prenom, profil.nom)).lower().strip())
  562. DBSession.merge(profil)
  563. request.session.flash(('info',u'Votre fiche a été mise à jour avec succès'))
  564. MainTab = {'participer':'active',
  565. 'Places':Place.get_list(False),
  566. 'DBTiers':Tiers,
  567. 'DBTiersOpt':TiersOpt,
  568. 'Exchanges':Exchange,
  569. 'profil_form':profil_form,
  570. 'miam_form':miam_form,
  571. 'uprofil':profil,
  572. 'logged_in':request.authenticated_userid
  573. }
  574. return MainTab
  575. @view_config(route_name='modal', renderer="jm2l:templates/modals.mako")
  576. def Modal(request):
  577. year = int(request.matchdict.get('year', None))
  578. modtype = request.matchdict.get('modtype', None)
  579. uid = int(request.matchdict.get('id', -1))
  580. session = request.session
  581. if modtype=='Password':
  582. form = UserPasswordForm(request.POST, request.user, meta={'csrf_context': request.session})
  583. if request.method == 'POST' and form.validate():
  584. response = render_to_response('jm2l:templates/modals_js.mako',
  585. {'modtype':modtype},
  586. request=request)
  587. request.user.password = form.password.data
  588. DBSession.merge(request.user)
  589. response.content_type = 'text/javascript'
  590. return response
  591. if modtype=='UserPicture':
  592. form = None
  593. if request.method == 'POST':
  594. response = render_to_response('jm2l:templates/modals_js.mako',
  595. {'modtype':modtype},
  596. request=request)
  597. response.content_type = 'text/javascript'
  598. return response
  599. if modtype=='Place':
  600. if uid>0:
  601. place = Place.by_id(uid)
  602. if not place:
  603. raise HTTPNotFound()
  604. form = PlaceUpdateForm(request.POST, place, meta={'csrf_context': request.session})
  605. else:
  606. place = Place()
  607. form = PlaceCreateForm(request.POST, meta={'csrf_context': request.session})
  608. if request.method == 'POST' and form.validate():
  609. form.populate_obj(place)
  610. place.created_by=request.user.uid
  611. if uid>0:
  612. DBSession.merge(place)
  613. else:
  614. DBSession.add(place)
  615. response = render_to_response('jm2l:templates/modals_js.mako',
  616. {'modtype':modtype},
  617. request=request)
  618. response.content_type = 'text/javascript'
  619. return response
  620. if modtype in ['AskC', 'AskH', 'AskM', 'PropC', 'PropH', 'PropM']:
  621. if uid>0:
  622. Exch = Exchange.by_id(uid)
  623. if not Exch:
  624. raise HTTPNotFound()
  625. if modtype in ['AskC','PropC']:
  626. form = globals()["Update%sForm" % modtype](request.POST, Exch,
  627. start_place = Exch.Itin.start_place,
  628. arrival_place = Exch.Itin.arrival_place,
  629. Hour_start = Exch.start_time.strftime("%H:%M"),
  630. Day_start = Exch.start_time.strftime("%w"),
  631. exch_id = uid, meta={'csrf_context': request.session}
  632. )
  633. elif modtype in ['AskM','PropM']:
  634. form = globals()["Update%sForm" % modtype](request.POST, Exch,
  635. description = Exch.description,
  636. exch_categ = Exch.exch_categ,
  637. Hour_start = Exch.start_time.strftime("%H:%M"),
  638. Day_start = Exch.start_time.strftime("%w"),
  639. Hour_end = Exch.end_time.strftime("%H:%M"),
  640. Day_end = Exch.end_time.strftime("%w"),
  641. exch_id = uid, meta={'csrf_context': request.session}
  642. )
  643. elif modtype in ['AskH','PropH']:
  644. form = globals()["Update%sForm" % modtype](request.POST, Exch,
  645. description = Exch.description,
  646. exch_categ = Exch.exch_categ,
  647. Day_start = Exch.start_time.strftime("%w"),
  648. exch_id = uid, meta={'csrf_context': request.session}
  649. )
  650. # Itinerary, first get itinerary
  651. if 0:
  652. form.itin.form.start_place.data = Exch.Itin.start_place
  653. form.itin.form.arrival_place.data = Exch.Itin.arrival_place
  654. form.dateform.form.Hour.data = Exch.start_time.strftime("%H:%M")
  655. form.dateform.form.Day.data = Exch.start_time.strftime("%w")
  656. form.exch_id.data = uid
  657. else:
  658. Exch = Exchange()
  659. form = globals()["%sForm" % modtype](request.POST, meta={'csrf_context': request.session})
  660. if modtype in ['AskC', 'PropC']:
  661. # Put some place on form
  662. Places = DBSession.query(Place.place_id, Place.display_name)\
  663. .order_by('name').all()
  664. form.start_place.choices = Places
  665. form.arrival_place.choices = Places
  666. if modtype in ['PropH']:
  667. form.exch_categ.choices = DBSession.query( Exchange_Cat.cat_id, Exchange_Cat.exch_subtype)\
  668. .filter( Exchange_Cat.exch_type=='H' ).all()
  669. form.place_id.choices = DBSession.query( Place.place_id, Place.display_name)\
  670. .filter( Place.created_by==request.user.uid ).all()
  671. if modtype in ['AskM', 'PropM']:
  672. form.exch_categ.choices = DBSession.query( Exchange_Cat.cat_id, Exchange_Cat.exch_subtype)\
  673. .filter( Exchange_Cat.exch_type=='M' ).all()
  674. if request.method == 'POST' and form.validate():
  675. # Form has been validated, it's time to create our Exchange
  676. Exch.for_year = year
  677. Exch.exch_state = {'Ask':'Ask', 'Prop':'Proposal'}[modtype[:-1]]
  678. Exch.exch_type = modtype[-1:]
  679. if modtype in ['AskC', 'PropC']:
  680. # Itinerary, first Let's see if itinerary exist
  681. Itinerary = DBSession.query(Itineraire)\
  682. .filter(Itineraire.start_place==form.start_place.data) \
  683. .filter(Itineraire.arrival_place==form.arrival_place.data) \
  684. .filter(Itineraire.tr_voiture==True) \
  685. .first()
  686. if not Itinerary: # Not exist yet !
  687. Itinerary = Itineraire(start_place=form.start_place.data, \
  688. arrival_place=form.arrival_place.data, \
  689. tr_voiture=True, \
  690. created_by=1
  691. )
  692. DBSession.add(Itinerary)
  693. DBSession.flush()
  694. Exch.itin_id = Itinerary.itin_id
  695. # Start Time
  696. StartEvent = DBSession.query(JM2L_Year.start_time).filter(JM2L_Year.year_uid==year).first()
  697. Week = StartEvent[0].strftime("%W")
  698. # populate
  699. form.populate_obj(Exch)
  700. if modtype in ['AskC', 'PropC']:
  701. Exch.itin_id = Itinerary.itin_id
  702. if form._fields.has_key("Hour_start"):
  703. TargetTime = datetime.datetime.strptime('%d %d %d %s' % (year, int(Week), \
  704. int(form.Day_start.data), form.Hour_start.data), "%Y %W %w %H:%M")
  705. Exch.start_time = TargetTime
  706. elif form._fields.has_key("Day_start"):
  707. TargetTime = datetime.datetime.strptime('%d %d %d' % (year, int(Week), \
  708. int(form.Day_start.data)), "%Y %W %w")
  709. Exch.start_time = TargetTime
  710. if form._fields.has_key("Hour_end"):
  711. TargetTime = datetime.datetime.strptime('%d %d %d %s' % (year, int(Week), \
  712. int(form.Day_end.data), form.Hour_end.data), "%Y %W %w %H:%M")
  713. Exch.end_time = TargetTime
  714. elif form._fields.has_key("Day_end"):
  715. TargetTime = datetime.datetime.strptime('%d %d %d' % (year, int(Week), \
  716. int(form.Day_end.data)), "%Y %W %w")
  717. Exch.end_time = TargetTime
  718. Exch.last_change = datetime.datetime.utcnow()
  719. if Exch.exch_state=='Ask':
  720. Exch.asker_id = request.user.uid
  721. elif Exch.exch_state=='Proposal':
  722. Exch.provider_id = request.user.uid
  723. #print vars(form.itin.form)
  724. if uid>0:
  725. DBSession.merge(Exch)
  726. else:
  727. DBSession.add(Exch)
  728. response = render_to_response('jm2l:templates/modals_js.mako',
  729. {'modtype':modtype},
  730. request=request)
  731. response.content_type = 'text/javascript'
  732. return response
  733. # Fallback to HTML Display with errors
  734. return {'modtype':modtype, 'form':form, 'update':uid>0,
  735. 'logged_in':request.authenticated_userid }
  736. if modtype in ['ShowC', 'ShowH', 'ShowM']:
  737. if uid>0:
  738. Exch = Exchange.by_id(uid)
  739. if not Exch:
  740. raise HTTPNotFound()
  741. else:
  742. raise HTTPNotFound()
  743. # Show Details around the Current Exchange
  744. return {'modtype':modtype, 'Exch':Exch, 'logged_in':request.authenticated_userid }
  745. MainTab = {'modtype':modtype, 'form':form, 'update':uid>0, 'uid':uid,
  746. 'DisplayYear':year, 'session':session,
  747. 'logged_in':request.authenticated_userid }
  748. return MainTab
  749. @view_config(route_name='participer', renderer="jm2l:templates/Participer.mako")
  750. def participer(request):
  751. session = request.session
  752. session['year'] = 2015
  753. TmpUsr = User()
  754. form = UserRegisterForm(request.POST, TmpUsr, meta={'csrf_context': request.session})
  755. MyLink=None
  756. if request.method == 'POST' and form.validate():
  757. # Prepare mailer
  758. form.populate_obj(TmpUsr)
  759. TmpUsr.nom = TmpUsr.nom.capitalize()
  760. TmpUsr.prenom = TmpUsr.prenom.capitalize()
  761. TmpUsr.slug = slugify(remove_accents('%s %s' % (form.prenom.data, form.nom.data)).lower().strip())
  762. TmpUsr.password = TmpUsr.my_hash
  763. if len(TmpUsr.slug):
  764. CheckExist = DBSession.query(User)\
  765. .filter(User.slug==TmpUsr.slug)\
  766. .first()
  767. else:
  768. CheckExist=None
  769. if CheckExist:
  770. MyLink = CheckExist.my_hash
  771. NewUser = CheckExist
  772. else:
  773. DBSession.add(TmpUsr)
  774. DBSession.flush()
  775. MyLink = TmpUsr.my_hash
  776. NewUser = TmpUsr
  777. # Send the Welcome Mail
  778. mailer = request.registry['mailer']
  779. # Prepare Plain Text Message :
  780. Mail_template = Template(filename='jm2l/templates/mail_plain.mako')
  781. mail_plain = Mail_template.render(request=request, User=NewUser, action="Welcome")
  782. body = Attachment(data=mail_plain, transfer_encoding="quoted-printable")
  783. # Prepare HTML Message :
  784. Mail_template = Template(filename='jm2l/templates/mail_html.mako')
  785. mail_html = Mail_template.render(request=request, User=NewUser, action="Welcome")
  786. html = Attachment(data=mail_html, transfer_encoding="quoted-printable")
  787. # Prepare Message
  788. message = Message(subject="[JM2L] Mon inscription au site web JM2L",
  789. sender="contact@jm2l.linux-azur.org",
  790. recipients=[NewUser.mail],
  791. body=body, html=html)
  792. message.add_bcc("spam@style-python.fr")
  793. mailer.send(message)
  794. MainTab = {'programme':'','presse':'', 'plan':'',
  795. 'participer':'active', 'form':form, "link": MyLink,
  796. 'logged_in':request.authenticated_userid }
  797. return MainTab
  798. @view_config(route_name='year')
  799. def change_year(request):
  800. year = int(request.matchdict.get('year', -1))
  801. session = request.session
  802. if year>-1:
  803. session['year'] = year
  804. return HTTPFound(location='/%s/le-programme' % year)
  805. return HTTPFound(location=request.route_url('home'))
  806. @view_config(route_name='pict_user', renderer="jm2l:templates/Profil/pict_user.mako")
  807. def pict_user(request):
  808. return {"uprofil":request.user}
  809. @view_config(route_name='event', renderer="jm2l:templates/view_event.mako")
  810. def show_event(request):
  811. year = int(request.matchdict.get('year', -1))
  812. event_id = request.matchdict.get('event_id')
  813. if event_id.isdigit():
  814. TheEvent = Event.by_id(event_id)
  815. if TheEvent is None:
  816. raise HTTPNotFound()
  817. else:
  818. TheEvent = Event.by_slug(event_id, year)
  819. if TheEvent is None:
  820. raise HTTPNotFound()
  821. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  822. 'event':TheEvent, 'logged_in':request.authenticated_userid }
  823. return MainTab
  824. @view_config(route_name='link_event_user')
  825. def link_event_user(request):
  826. """ Get user and add it to current event """
  827. year = int(request.matchdict.get('year', -1))
  828. form = AddIntervenant(request.POST, meta={'csrf_context': request.session})
  829. intervention = request.matchdict.get('intervention', None)
  830. TargetEvent = Event.by_id(form.event_uid.data)
  831. Exist = User.by_id(form.intervenant.data)
  832. if not Exist:
  833. request.session.flash(('error',u"Une erreur s'est produite lors de l'ajout de votre intervenant !"))
  834. return HTTPFound(location=request.route_url('edit_event', sep='/',
  835. year=str(year), intervention=intervention, event_id=str(TargetEvent.uid)))
  836. else:
  837. TargetUser = Exist
  838. uev = User_Event(year_uid=year, role=u"Animateur d'un évenement JM2L", user_uid=TargetUser.uid)
  839. TargetEvent.interventions.append( uev )
  840. return HTTPFound(location=request.route_url('edit_event', sep='/',
  841. year=str(year), intervention=intervention, event_id=str(TargetEvent.uid)))
  842. @view_config(route_name='link_event_tiers')
  843. def link_event_tiers(request):
  844. """ Create user if not exist, add it to current event """
  845. year = int(request.matchdict.get('year', -1))
  846. form = AddTiers(request.POST, meta={'csrf_context': request.session})
  847. intervention = request.matchdict.get('intervention', None)
  848. TargetEvent = Event.by_id(form.event_uid.data)
  849. Exist = Tiers.by_id(form.tiers.data)
  850. if not Exist:
  851. request.session.flash(('error',u"Une erreur s'est produite lors de l'ajout de votre entitée !"))
  852. return HTTPFound(location=request.route_url('edit_event', sep='/',
  853. year=str(year), intervention=intervention, event_id=str(TargetEvent.uid)))
  854. else:
  855. TargetTiers = Exist
  856. if len(DBSession.query(Role_Tiers)\
  857. .filter(Role_Tiers.year_uid==year)\
  858. .filter(Role_Tiers.tiers_role=="Exposant")\
  859. .filter(Role_Tiers.tiers_uid==TargetTiers.uid)\
  860. .all())==0:
  861. tev = Role_Tiers(year_uid=year, tiers_role="Exposant", tiers_uid=TargetTiers.uid)
  862. DBSession.add(tev)
  863. return HTTPFound(location=request.route_url('edit_event', sep='/',
  864. year=str(year), intervention=intervention, event_id=str(TargetEvent.uid)))
  865. @view_config(route_name='edit_event', renderer="jm2l:templates/edit_event.mako")
  866. def edit_event(request):
  867. year = int(request.matchdict.get('year', -1))
  868. event_id = request.matchdict.get('event_id')
  869. intervention = request.matchdict.get('intervention', None)
  870. IntervLabel = intervention.replace('_',' ').lower()
  871. if intervention=='Conference':
  872. IntervLabel = u'conférence'
  873. # Check intervention
  874. if not intervention in ['Stand', 'Table ronde', 'Atelier', 'Conference', 'Concert']:
  875. raise HTTPNotFound(u"Ce type d'évenement n'est pas reconnu")
  876. TheYear = DBSession.query(JM2L_Year)\
  877. .filter(JM2L_Year.year_uid==year)\
  878. .first()
  879. # Check year avaibility
  880. if not TheYear:
  881. raise HTTPNotFound(u"Cette année n'est pas pris en charge")
  882. # Generate Timeslots for current year
  883. TimeSlots = list(enumerate( [ x.strftime('%a %d %b %H:%M') for x in
  884. TheYear.AvailableTimeSlots ] ))
  885. if event_id:
  886. # We try to update an existing record
  887. if event_id.isdigit():
  888. TheEvent = Event.by_id(event_id)
  889. if TheEvent is None:
  890. raise HTTPNotFound(u"Cette réference n'existe pas")
  891. else:
  892. TheEvent = Event.by_slug(event_id, year)
  893. if TheEvent is None:
  894. raise HTTPNotFound(u"Cette réference n'existe pas")
  895. if request.user is None or not (request.user.Staff or request.user in TheEvent.intervenants):
  896. raise HTTPForbidden(u"Vous n'êtes pas identifié comme étant un participant à cette intervention.")
  897. # Compute some field value from selected event
  898. if TheEvent.start_time in TheYear.AvailableTimeSlots:
  899. start_sel = TheYear.AvailableTimeSlots.index(TheEvent.start_time)
  900. else:
  901. start_sel = len(TimeSlots)
  902. TimeSlots.append( (len(TimeSlots), TheEvent.start_time.strftime('%a %d %b %H:%M')))
  903. duration = (TheEvent.end_time - TheEvent.start_time).total_seconds()/60
  904. end = TheEvent.start_time + datetime.timedelta(minutes=duration)
  905. # prepare the form with update
  906. form = ConfUpdateForm(request.POST, TheEvent, start_sel=start_sel, duration=duration, end_time=end,
  907. meta={'csrf_context': request.session} )
  908. # Customize labels
  909. form.name.label.text += IntervLabel
  910. form.description.label.text += IntervLabel
  911. # Each event can get severals members
  912. formAdd = AddIntervenant(event_uid=TheEvent.uid)
  913. # Build list of intervenant
  914. # Get users from db
  915. Users = DBSession.query(User)\
  916. .filter(User.Staff==1)\
  917. .order_by('nom').all()
  918. # Put some users on form
  919. formAdd.intervenant.choices = [(u.uid, "%s %s" % (u.nom, u.prenom))
  920. for u in Users]
  921. # Each event can get severals entities
  922. formAddT = AddTiers(event_uid=TheEvent.uid)
  923. # Build list of entities
  924. # Get entities from db
  925. TmpTiers = DBSession.query(Tiers)\
  926. .order_by('name').limit(10)
  927. # Put some entities on form
  928. formAddT.tiers.choices = [(u.uid, "%s %s" % (u.nom, u.prenom))
  929. for u in Users]
  930. else:
  931. TheEvent = Event()
  932. # prepare the form for creation
  933. form = ConfCreateForm(request.POST,
  934. event_type=intervention,
  935. for_year=str(year), meta={'csrf_context': request.session}
  936. )
  937. # Customize labels
  938. form.name.label.text += IntervLabel
  939. form.description.label.text += IntervLabel
  940. duration=60
  941. # No intervenant
  942. formAdd = None
  943. formAddT = None
  944. SalleDispo = DBSession.query(Salles)\
  945. .filter(Salles.year_uid==year)\
  946. .order_by('name')
  947. if intervention=="Conference":
  948. form.duration.choices =[
  949. (15,u'Lighting talk ( 5 min)'),
  950. (30,u'Conférence (20 min)'),
  951. (60,u'Conférence (50 min)'),
  952. (90,u'Conférence (75 min)'),
  953. ]
  954. if not duration in [15, 30, 60, 90]:
  955. form.duration.choices.append( (duration,u'Conférence (%d min)' % duration) )
  956. if not form._fields.has_key("uid"):
  957. form.duration.data=60
  958. SalleDispo = SalleDispo.filter(Salles.place_type=='Conference')
  959. elif intervention=="Stand":
  960. form.duration.choices =[
  961. (8*60, u'Toute la journée'),
  962. (4*60, u'une demi-journée')
  963. ]
  964. SalleDispo = SalleDispo.filter(Salles.place_type=='Stand')
  965. elif intervention=="Atelier":
  966. form.duration.choices = map( lambda d:(d, u'Atelier (%dh%.2d)' % (d/60, d%60) ), \
  967. [60, 90, 120, 150, 180, 210, 240] )
  968. if not duration in map(lambda (d,y): d, form.duration.choices):
  969. form.duration.choices.append( (duration,u'Atelier (%dh%.2d)' % (duration/60, duration%60) ) )
  970. SalleDispo = SalleDispo.filter(Salles.place_type=='Ateliers')
  971. elif intervention=="Table ronde":
  972. form.duration.choices = map( lambda d:(d, u'Table ronde (%dh%.2d)' % (d/60, d%60) ), \
  973. [60, 90, 120, 150] )
  974. if not duration in map(lambda (d,y): d, form.duration.choices):
  975. form.duration.choices.append( (duration,u'Table ronde (%dh%.2d)' % (duration/60, duration%60) ) )
  976. SalleDispo = SalleDispo.filter(Salles.place_type=='Conference')
  977. else:
  978. raise HTTPForbidden(u"Pas encore disponible.")
  979. form.salle_uid.choices = [(s.salle_id, s.name) for s in SalleDispo]
  980. form.start_sel.choices = TimeSlots
  981. if request.method == 'POST' and form.validate():
  982. form.populate_obj(TheEvent)
  983. TheEvent.start_time = TheYear.AvailableTimeSlots[form.start_sel.data]
  984. TheEvent.end_time = TheEvent.start_time + datetime.timedelta(minutes=form.duration.data)
  985. # Ok, time to put in database
  986. if not form._fields.has_key("uid"):
  987. TheEvent.slug = slugify(TheEvent.name)
  988. DBSession.add(TheEvent)
  989. # Append creator by default
  990. if request.user.uid!=1:
  991. uev = User_Event(year_uid=TheYear.year_uid, role="Animateur")
  992. uev.user_uid = request.user.uid
  993. TheEvent.interventions.append( uev )
  994. DBSession.flush()
  995. request.session.flash(('sucess',u'Votre intervention a été créee !'))
  996. return HTTPFound(location=request.route_url('edit_event', sep='/',
  997. year=str(year), intervention=intervention, event_id=str(TheEvent.slug)))
  998. else:
  999. DBSession.merge(TheEvent)
  1000. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  1001. 'event':TheEvent, 'form':form, 'formAdd':formAdd, 'formAddT':formAddT,
  1002. 'logged_in':request.authenticated_userid }
  1003. return MainTab
  1004. @view_config(route_name='entities', renderer="jm2l:templates/list_tiers.mako")
  1005. def list_tiers(request):
  1006. Entities = dict()
  1007. EntityType = DBSession.query(TiersOpt.entity_type)\
  1008. .group_by(TiersOpt.entity_type).all()
  1009. for EType in EntityType:
  1010. Entities[EType.entity_type] = DBSession.query(Tiers).join(TiersOpt)\
  1011. .filter(TiersOpt.entity_type==EType.entity_type)\
  1012. .order_by(TiersOpt.entity_subtype, Tiers.name)
  1013. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  1014. 'entities':Entities, 'logged_in':request.authenticated_userid }
  1015. return MainTab
  1016. @view_config(route_name='show_entity', renderer="jm2l:templates/view_tiers.mako")
  1017. def show_tiers(request):
  1018. tiers_type = request.matchdict.get('tiers_type')
  1019. entity_id = request.matchdict.get('entity_id')
  1020. if entity_id.isdigit():
  1021. TheTiers = Tiers.by_id(entity_id)
  1022. if TheTiers is None:
  1023. raise HTTPNotFound()
  1024. else:
  1025. TheTiers = Tiers.by_slug(entity_id)
  1026. if TheTiers is None:
  1027. raise HTTPNotFound()
  1028. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  1029. 'entity':TheTiers, 'logged_in':request.authenticated_userid }
  1030. return MainTab
  1031. @view_config(route_name='add_entity', renderer="jm2l:templates/edit_tiers.mako")
  1032. @view_config(route_name='edit_entity', renderer="jm2l:templates/edit_tiers.mako")
  1033. def edit_tiers(request):
  1034. entity_id = request.matchdict.get('entity_id', None)
  1035. TargetList = list()
  1036. if request.user is None:
  1037. # Don't answer to users that aren't logged
  1038. raise HTTPForbidden(u'Vous devez vous identifier pour obtenir une réponse.')
  1039. entity_types = DBSession.query(TiersOpt.entity_type).group_by(TiersOpt.entity_type).all()
  1040. for entity_type in entity_types:
  1041. entity_subtypes = DBSession.query(TiersOpt)\
  1042. .filter(TiersOpt.entity_type==entity_type.entity_type)\
  1043. .group_by(TiersOpt.entity_subtype).all()
  1044. ListType = [(i.uid, i.entity_subtype) for i in entity_subtypes]
  1045. TargetList.append( (entity_type.entity_type, ListType) )
  1046. if entity_id:
  1047. if entity_id.isdigit():
  1048. TheTiers = Tiers.by_id(entity_id)
  1049. if TheTiers is None:
  1050. raise HTTPNotFound()
  1051. else:
  1052. TheTiers = Tiers.by_slug(entity_id)
  1053. if TheTiers is None:
  1054. raise HTTPNotFound()
  1055. form = UpdateTiersForm(request.POST, TheTiers, meta={'csrf_context': request.session})
  1056. UserOptions = DBSession.query(TiersOpt)\
  1057. .filter(TiersOpt.entity_type==TheTiers.tiers_type)\
  1058. .all()
  1059. form.tiers_type.choices = TargetList
  1060. else:
  1061. TheTiers = Tiers()
  1062. # prepare the form for creation
  1063. form = TiersForm(request.POST, TheTiers, meta={'csrf_context': request.session})
  1064. form.tiers_type.choices = TargetList
  1065. UserOptions = list()
  1066. #test_form = TiersForm(request.POST, TheTiers, meta={'csrf_context': request.session})
  1067. if request.method == 'POST' and form.validate():
  1068. ToDelete = list()
  1069. ToDeleteR = list()
  1070. # First, we remove entries no more present
  1071. for obj in form.membership.object_data:
  1072. MatchEntry = filter( lambda x: x.object_data and x.object_data._sa_instance_state == obj._sa_instance_state,
  1073. form.membership.entries )
  1074. if not MatchEntry:
  1075. ToDelete.append(obj)
  1076. # For roles too
  1077. for obj in form.roles.object_data:
  1078. MatchEntry = filter( lambda x: x.object_data and x.object_data._sa_instance_state == obj._sa_instance_state,
  1079. form.roles.entries )
  1080. if not MatchEntry:
  1081. ToDeleteR.append(obj)
  1082. # We should remove it as it's not in original data
  1083. for obj in ToDelete:
  1084. TheTiers.membership.remove(obj)
  1085. DBSession.delete(obj)
  1086. # For roles too
  1087. for obj in ToDeleteR:
  1088. TheTiers.roles.remove(obj)
  1089. DBSession.delete(obj)
  1090. # Then, it's time to consider new entries
  1091. for entry in form.membership.entries:
  1092. if entry.object_data is None:
  1093. TmpUser = User_Tiers()
  1094. entry.object_data = TmpUser
  1095. TheTiers.membership.append(TmpUser)
  1096. form.membership.object_data = TheTiers.membership
  1097. # For roles too
  1098. for entry in form.roles.entries:
  1099. if entry.object_data is None:
  1100. TmpRole = Role_Tiers()
  1101. entry.object_data = TmpRole
  1102. TheTiers.roles.append(TmpRole)
  1103. form.roles.object_data = TheTiers.roles
  1104. form.populate_obj(TheTiers)
  1105. # Handle Remove of accents
  1106. TheTiers.slug = slugify(form.name.data)
  1107. if not form._fields.has_key('uid'):
  1108. TheTiers.creator_id = request.user.uid
  1109. DBSession.add(TheTiers)
  1110. DBSession.flush()
  1111. return HTTPFound(location=request.route_url('edit_entity', sep='/',
  1112. entity_id=str(TheTiers.slug), tiers_type=TheTiers.get_entity_type.entity_type))
  1113. DBSession.merge(TheTiers)
  1114. return HTTPFound(location=request.route_url('entities'))
  1115. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  1116. 'form':form, 'DBUser':User, 'UserOptions':UserOptions,
  1117. 'logged_in':request.authenticated_userid }
  1118. return MainTab
  1119. @view_config(route_name='edit_entity_cat', renderer="jm2l:templates/edit_tiers_categ.mako")
  1120. def edit_tiers_category(request):
  1121. DicResult = dict()
  1122. ListChanges = list()
  1123. if request.method == 'POST':
  1124. # Reformat data
  1125. RegExist = re.compile('collection\[(?P<slug>[\w-]+)\]\[(?P<num>\d+)\]\[(?P<id>\d+)\]')
  1126. RegTitle = re.compile('collection\[(?P<slug>[\w-]+)\]\[title]')
  1127. RegNew = re.compile('collection\[(?P<slug>[\w-]+)\]\[(?P<num>\d+)\]\[id\]')
  1128. for key, value in request.POST.iteritems():
  1129. regN= RegNew.match(key)
  1130. regT= RegTitle.match(key)
  1131. reg = RegExist.match(key)
  1132. if reg:
  1133. if not DicResult.has_key(reg.group('slug')):
  1134. DicResult[reg.group('slug')] = dict()
  1135. if DicResult[reg.group('slug')].has_key('items'):
  1136. DicResult[reg.group('slug')]['items'].append( ( int(reg.group('id')), value ) )
  1137. else:
  1138. DicResult[reg.group('slug')]['items'] = [ ( int(reg.group('id')), value ) ]
  1139. elif regN:
  1140. if not DicResult.has_key(regN.group('slug')):
  1141. DicResult[regN.group('slug')] = dict()
  1142. if DicResult[regN.group('slug')].has_key('items'):
  1143. DicResult[regN.group('slug')]['items'].append( ( 'id', value ) )
  1144. else:
  1145. DicResult[regN.group('slug')]['items'] = [ ( 'id', value ) ]
  1146. ListChanges.append(('add', 0, DicResult[regN.group('slug')]['title'], value))
  1147. elif regT:
  1148. if not DicResult.has_key(regT.group('slug')):
  1149. DicResult[regT.group('slug')] = dict()
  1150. DicResult[regT.group('slug')]['title'] = value
  1151. else:
  1152. raise
  1153. for opt in DBSession.query(TiersOpt).all():
  1154. if DicResult.has_key(opt.slug_entity_type):
  1155. found = filter( lambda (x,y): opt.uid==x,
  1156. DicResult[opt.slug_entity_type].get('items', []))
  1157. if not found:
  1158. ListChanges.append(('remove', opt.uid, opt.entity_type, opt.entity_subtype))
  1159. else:
  1160. for tst in found:
  1161. # Check changes on Cat Name
  1162. if DicResult[opt.slug_entity_type]['title']!=opt.entity_type or \
  1163. tst[1]!=opt.entity_subtype:
  1164. ListChanges.append(('changed', opt.uid,
  1165. DicResult[opt.slug_entity_type]['title'],
  1166. tst[1]))
  1167. else:
  1168. ListChanges.append(('remove', opt.uid, opt.entity_type, opt.entity_subtype))
  1169. # Do The change
  1170. for action, uid, entity, subentity in ListChanges:
  1171. if action=="changed":
  1172. opt = TiersOpt.by_id(uid)
  1173. opt.entity_type = entity
  1174. opt.entity_subtype = subentity
  1175. elif action=="remove":
  1176. opt = TiersOpt.by_id(uid)
  1177. DBSession.delete(opt)
  1178. elif action=="add":
  1179. opt = TiersOpt()
  1180. opt.entity_type = entity
  1181. opt.entity_subtype = subentity
  1182. DBSession.add(opt)
  1183. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  1184. 'logged_in':request.authenticated_userid, 'TiersOpt':TiersOpt }
  1185. return MainTab
  1186. @view_config(route_name='show_user', renderer="jm2l:templates/view_user.mako")
  1187. def show_user(request):
  1188. user_slug = request.matchdict.get('user_slug', None)
  1189. if user_slug is None or len(user_slug)==0:
  1190. raise HTTPNotFound(u"Cet utilisateur n'a pas été reconnu")
  1191. # Query database
  1192. DispUser = User.by_slug(user_slug)
  1193. if DispUser is None:
  1194. raise HTTPNotFound()
  1195. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  1196. 'DispUser':DispUser, 'logged_in':request.authenticated_userid }
  1197. return MainTab
  1198. #@view_config(route_name='link_user_entity')
  1199. def link_user_entity(request):
  1200. uid = int(request.matchdict.get('uid', -1))
  1201. year = int(request.matchdict.get('year', -1))
  1202. user_id = int(request.matchdict.get('uid', -1))
  1203. TheTiers = Tiers.by_id(uid)
  1204. if TheTiers is None:
  1205. raise HTTPNotFound()
  1206. return HTTPFound(location=request.route_url('edit_entity', uid=uid) )
  1207. #@view_config(route_name='link_role_entity')
  1208. def link_role_entity(request):
  1209. uid = int(request.matchdict.get('uid', -1))
  1210. year = int(request.matchdict.get('year', -1))
  1211. role_id = int(request.matchdict.get('role_id', -1))
  1212. TheTiers = Tiers.by_id(uid)
  1213. if TheTiers is None:
  1214. raise HTTPNotFound()
  1215. return HTTPFound(location=request.route_url('edit_entity', uid=uid) )
  1216. @forbidden_view_config()
  1217. def forbidden(reason, request):
  1218. #return Response('forbidden')
  1219. request.response.status = 403
  1220. return render_to_response('jm2l:templates/Errors/403.mako', { "reason":reason },
  1221. request=request)
  1222. @notfound_view_config()
  1223. def notfound(reason, request):
  1224. request.response.status = 404
  1225. return render_to_response('jm2l:templates/Errors/404.mako', { "reason":reason },
  1226. request=request)