Le repo des sources pour le site web des JM2L
Você não pode selecionar mais de 25 tópicos Os tópicos devem começar com uma letra ou um número, podem incluir traços ('-') e podem ter até 35 caracteres.
 
 
 
 
 

1039 linhas
45 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. # Import Web Forms
  9. from .forms import *
  10. # Database access imports
  11. from .models import *
  12. from sqlalchemy.exc import DBAPIError
  13. from sqlalchemy import func, or_
  14. # Usefull tools
  15. from slugify import slugify
  16. from icalendar import Calendar
  17. from pytz import timezone
  18. from icalendar import Event as Evt
  19. # Then, standard libs
  20. import webhelpers.paginate as paginate
  21. import unicodedata
  22. import time
  23. import datetime
  24. import re
  25. CurrentYear = 2015
  26. ## =-=- Here, We keep some usefull function -=-=
  27. def remove_accents(input_str):
  28. """ This function is intended to remove all accent from input unicode string """
  29. nkfd_form = unicodedata.normalize('NFKD', input_str)
  30. only_ascii = nkfd_form.encode('ASCII', 'ignore')
  31. return only_ascii
  32. @view_config(route_name='tester', renderer="jm2l:templates/tester.mako")
  33. def Tester(request):
  34. JTiers = DBSession.query(Tiers).all()
  35. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  36. 'Tiers':JTiers, "logged_in":request.authenticated_userid }
  37. return MainTab
  38. ## =-=- Here, We handle ICal requests -=-=
  39. @view_config(route_name='progr_iCal', renderer="string")
  40. def ICal_Progamme_Request(request):
  41. year = int(request.matchdict.get('year', CurrentYear))
  42. # Initialization
  43. DicResult = dict()
  44. # Query database
  45. # Compute days used by all events matching the specified input year
  46. Events = DBSession.query(Event)\
  47. .filter(Event.for_year == year)\
  48. .filter(Event.event_type != 'Stand')\
  49. .order_by(Event.start_time)
  50. cal = Calendar()
  51. cal.add('prodid', '-//Programme %d//jm2l.linux-azur.org//' % year)
  52. cal.add('version', '2.0')
  53. tz = timezone('Europe/Paris')
  54. for ev in Events:
  55. if ev.event_type:
  56. event = Evt()
  57. event['uid'] = "%d/%d" % ( year, ev.uid )
  58. event.add('summary', ev.name )
  59. event.add('dtstart', ev.start_time.replace(tzinfo=tz) )
  60. event.add('dtend', ev.end_time.replace(tzinfo=tz) )
  61. event.add('created', ev.last_change.replace(tzinfo=tz) )
  62. event.add('description', "http://www.linux-azur.org/event/%s/%s" % (ev.for_year, ev.slug) )
  63. event.add('url', "http://www.linux-azur.org/event/%s/%s" % (ev.for_year, ev.slug) )
  64. event.add('priority', 5)
  65. cal.add_component(event)
  66. return cal.to_ical()
  67. ## =-=- Here, We handle Json requests -=-=
  68. @view_config(route_name='users_json', renderer="json")
  69. def JSON_User_Request(request):
  70. """ Build a JSON answer with active users and pagination handling """
  71. # Check arguments consitency
  72. pageSize = request.params.get('pageSize',"8")
  73. current_page = request.params.get('pageNum',"1")
  74. UserQuery = request.params.get('searchTerm', u"")
  75. # Don't answer to users that aren't logged
  76. if not request.user:
  77. return HTTPUnauthorized('You have to be logged to hope an answer.')
  78. # Check consistancy of parameters
  79. if pageSize.isdigit() and current_page.isdigit():
  80. current_page = int(current_page)
  81. pageSize = int(pageSize)
  82. else:
  83. return HTTPBadRequest('pageSize and pageNum accept only digits.')
  84. # Query database
  85. Users = DBSession.query(User.uid, User.nom, User.prenom)\
  86. .filter(User.slug.contains( remove_accents(UserQuery) ))
  87. page_url = paginate.PageURL_WebOb(request)
  88. records = paginate.Page(Users, current_page, url=page_url, items_per_page=pageSize)
  89. ListMatchUser = map( lambda u:{"id": u.uid, "text":"%s %s" % ( u.prenom, u.nom )}, records )
  90. return { "Results": ListMatchUser, "Total":records.item_count,
  91. "logged_in":request.authenticated_userid }
  92. @view_config(route_name='tiers_json', renderer="json")
  93. def JSON_Tiers_Request(request):
  94. """ Build a JSON answer with active users and pagination handling """
  95. # Check arguments consitency
  96. pageSize = request.params.get('pageSize',"8")
  97. current_page = request.params.get('pageNum',"1")
  98. TiersQuery = request.params.get('searchTerm', u"")
  99. # Don't answer to users that aren't logged
  100. if not request.user:
  101. return HTTPUnauthorized('You have to be logged to hope an answer.')
  102. # Check consistancy of parameters
  103. if pageSize.isdigit() and current_page.isdigit():
  104. current_page = int(current_page)
  105. pageSize = int(pageSize)
  106. else:
  107. return HTTPBadRequest('pageSize and pageNum accept only digits.')
  108. # Query database
  109. JTiers = DBSession.query(Tiers.uid, Tiers.name)\
  110. .filter(Tiers.slug.contains( remove_accents(TiersQuery) ))
  111. page_url = paginate.PageURL_WebOb(request)
  112. records = paginate.Page(JTiers, current_page, url=page_url, items_per_page=pageSize)
  113. ListMatchTiers = map( lambda t:{"id": t.uid, "text": t.name }, records )
  114. return { "Results": ListMatchTiers, "Total":records.item_count,
  115. "logged_in":request.authenticated_userid }
  116. @view_config(route_name='progr_json', renderer="json")
  117. def JSON_Progamme_Request(request):
  118. year = int(request.matchdict.get('year', CurrentYear))
  119. # Initialization
  120. DicResult = dict()
  121. # Query database
  122. # Compute days used by all events matching the specified input year
  123. Days = DBSession.query( func.strftime('%d', Event.start_time).label('day') )\
  124. .filter(Event.for_year == year)\
  125. .filter(Event.event_type != None)\
  126. .group_by(func.strftime('%d', Event.start_time)).all()
  127. for Day in Days:
  128. Events = DBSession.query(Event)\
  129. .filter(Event.for_year == year)\
  130. .filter(Event.event_type != 'Stand')\
  131. .filter("strftime('%d', start_time) = :dow").params(dow=Day.day)\
  132. .order_by(Event.start_time)
  133. ListEv = []
  134. for ev in Events:
  135. if ev.event_type:
  136. ListEv.append( {
  137. "uid":"%d/%d" % ( year, ev.uid ),
  138. "desc":ev.name,
  139. "startDate":ev.start_time.strftime('%Y-%m-%dT%H:%M:%S'),
  140. "endDate":ev.end_time.strftime('%Y-%m-%dT%H:%M:%S'),
  141. "placeName":ev.Salle and (ev.Salle.name or "unk") ,
  142. "status":ev.event_type
  143. } )
  144. DicResult[Day.day] = ListEv
  145. return { 'all':DicResult }
  146. @view_config(route_name='timeline_json', renderer="json")
  147. def JSON_TimeLine_Request(request):
  148. year = int(request.matchdict.get('year', CurrentYear))
  149. # Initialization
  150. DicResult = dict()
  151. # Query database
  152. # Compute days used by all events matching the specified input year
  153. Days = DBSession.query( func.strftime('%d', Event.start_time).label('day') )\
  154. .filter(Event.for_year == year)\
  155. .filter(Event.event_type != None)\
  156. .group_by(func.strftime('%d', Event.start_time)).all()
  157. ListEv = []
  158. for Day in Days:
  159. Events = DBSession.query(Event)\
  160. .filter(Event.for_year == year)\
  161. .filter(Event.event_type != 'Stand')\
  162. .filter("strftime('%d', start_time) = :dow").params(dow=Day.day)\
  163. .order_by(Event.start_time)
  164. ListEv = []
  165. for ev in Events:
  166. if ev.event_type:
  167. ListEv.append( {
  168. #"uid":"%d/%d" % ( year, ev.uid ),
  169. "headline":ev.name,
  170. "startDate":ev.start_time.strftime('%Y,%m,%d,%H,%M'),
  171. "endDate":ev.end_time.strftime('%Y,%m,%d,%H,%M'),
  172. "text":ev.Salle and (ev.Salle.name or "unk"),
  173. "tags":ev.Salle and (ev.Salle.name or "unk") ,
  174. #"status":ev.event_type,
  175. "asset": {
  176. "media":"", #http://jm2l.linux-azur.org/sites/jm2l.linux-azur.org/files/videos/2012/2012_Introduction_aux_logiciels_libres__Frederic_Couchet.ogv",
  177. "credit":"",
  178. "caption":"" }
  179. } )
  180. break
  181. DicResult = {
  182. "lang":"fr",
  183. "headline":"JM2L 2015",
  184. "type":"default",
  185. "startDate":"2015,11,28,10",
  186. "text":"<i><span class='c1'>9ème Édition</span></i>",
  187. "asset":
  188. {
  189. "media":"",
  190. "credit":"JM2L",
  191. "caption":""
  192. }
  193. }
  194. DicResult["date"] = ListEv
  195. return { 'timeline':DicResult }
  196. ## =-=- Here, We handle HTTP requests - Public Part -=-=
  197. @view_config(route_name='home', renderer="jm2l:templates/NewIndex.mako")
  198. def index_page(request):
  199. page = int(request.params.get('page', 1))
  200. paginator = Entry.get_paginator(request, page)
  201. profil = User.by_id(4)
  202. profil_form = ProfilForm(request.POST, profil, meta={'csrf_context': request.session})
  203. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'', 'paginator':paginator,
  204. "logged_in":request.authenticated_userid }
  205. return MainTab
  206. @view_config(route_name='programme', renderer="jm2l:templates/Public/Programme.mako")
  207. def programme(request):
  208. year = int(request.matchdict.get('year'))
  209. if 2006 > year:
  210. return HTTPBadRequest('The first JM2L event was in 2006.')
  211. # Query database about selected Year.
  212. Events = DBSession.query(Event)\
  213. .filter(Event.for_year == year)\
  214. .order_by(Event.start_time)
  215. Days = DBSession.query(func.strftime('%d-%m-%Y', Event.start_time))\
  216. .filter(Event.for_year == year)\
  217. .filter(Event.event_type != None)\
  218. .group_by(func.strftime('%d', Event.start_time)).all()
  219. ListDay = []
  220. for day in Days:
  221. RefDay = datetime.datetime.strptime(day[0],'%d-%m-%Y')
  222. ListDay.append( ( RefDay.strftime('%A %d %b %Y'),
  223. RefDay.strftime('%d') ) )
  224. MainTab = {'programme':'active','presse':'', 'plan':'', 'participer':'', 'DisplayYear':year, \
  225. 'Events':Events, 'Event':Event, 'Days':ListDay, "logged_in":request.authenticated_userid }
  226. return MainTab
  227. @view_config(route_name='presse', renderer="jm2l:templates/Public/Presse.mako")
  228. def static_presse(request):
  229. year = int(request.matchdict.get('year', None))
  230. content = DBSession.query(JM2L_Year).filter(JM2L_Year.year_uid==year).first()
  231. MainTab = {'programme':'','presse':'active', 'plan':'', 'participer':'',
  232. "logged_in":request.authenticated_userid, 'content':content, 'DisplayYear':year}
  233. return MainTab
  234. @view_config(route_name='edit_presse', renderer="jm2l:templates/Staff/EditPresse.mako")
  235. def edit_presse(request):
  236. year = int(request.matchdict.get('year', None))
  237. content = DBSession.query(JM2L_Year).filter(JM2L_Year.year_uid==year).first()
  238. form = DossPresse(request.POST, content, meta={'csrf_context': request.session})
  239. if request.method == 'POST' and form.validate():
  240. form.populate_obj(content)
  241. MainTab = {'programme':'','presse':'active', 'plan':'', 'participer':'',
  242. "logged_in":request.authenticated_userid, 'form':form, 'DisplayYear':year}
  243. return MainTab
  244. @view_config(route_name='plan', renderer="jm2l:templates/Public/Plan.mako")
  245. def static_plan(request):
  246. MainTab = {'programme':'','presse':'', 'plan':'active', 'participer':'',
  247. "logged_in":request.authenticated_userid }
  248. return MainTab
  249. ## =-=- Here, We handle HTTP requests - Staff Logged Part -=-=
  250. @view_config(route_name='list_task', renderer='jm2l:templates/Staff/list.mako')
  251. def list_view(request):
  252. DicTask = {}
  253. taskgroup = DBSession.query( TasksArea ).all()
  254. for grp in taskgroup:
  255. tasks = DBSession.query( Tasks )\
  256. .filter( Tasks.area_uid==grp.uid )\
  257. .order_by(Tasks.closed, Tasks.due_date).all()
  258. DicTask[grp] = tasks
  259. return {'tasks': DicTask }
  260. @view_config(route_name='handle_task', renderer='jm2l:templates/Staff/tasks.mako')
  261. def tasks(request):
  262. task_id = request.matchdict.get('task_id')
  263. if task_id:
  264. Task = Tasks.by_id(int(task_id))
  265. if not Task:
  266. raise HTTPNotFound()
  267. form = EditStaffTasks(request.POST, Task, meta={'csrf_context': request.session})
  268. else:
  269. Task = Tasks()
  270. form = StaffTasks(request.POST, Task, meta={'csrf_context': request.session})
  271. # Put some areas on form
  272. Areas = DBSession.query(TasksArea.uid, TasksArea.name)\
  273. .order_by('name').all()
  274. form.area_uid.choices = Areas
  275. # Put some users on form
  276. Users = DBSession.query(User)\
  277. .filter(User.Staff==1)\
  278. .order_by('nom').all()
  279. form.closed_by.choices = [(u.uid, "%s %s" % (u.nom, u.prenom))
  280. for u in Users]
  281. if request.method == 'POST' and form.validate():
  282. form.populate_obj(Task)
  283. Task.closed = False
  284. if 'uid' in form._fields.keys():
  285. DBSession.merge(Task)
  286. else:
  287. DBSession.add(Task)
  288. return HTTPFound(location=request.route_url('list_task'))
  289. return {'form':form }
  290. @view_config(route_name='handle_pole', renderer='jm2l:templates/Staff/pole.mako')
  291. def tasks_area(request):
  292. pole_id = request.matchdict.get('pole_id')
  293. if pole_id:
  294. Pole = TasksArea.by_id(int(pole_id))
  295. if not Pole:
  296. raise HTTPNotFound()
  297. form = EditStaffArea(request.POST, Pole, meta={'csrf_context': request.session})
  298. else:
  299. Pole = TasksArea()
  300. form = StaffArea(request.POST, Pole, meta={'csrf_context': request.session})
  301. if request.method == 'POST' and form.validate():
  302. form.populate_obj(Pole)
  303. if 'uid' in form._fields.keys():
  304. DBSession.merge(Pole)
  305. else:
  306. DBSession.add(Pole)
  307. return HTTPFound(location=request.route_url('list_task'))
  308. return {'form':form }
  309. @view_config(route_name='action_task')
  310. def action_task(request):
  311. action = request.matchdict.get('action')
  312. task_id = request.matchdict.get('task_id')
  313. raise 'test'
  314. Task = Tasks.by_id(int(task_id))
  315. if action=='close':
  316. Task.closed = True
  317. if action=='open':
  318. Task.closed = False
  319. DBSession.merge(Task)
  320. request.session.flash('Task was successfully closed!')
  321. return HTTPFound(location=request.route_url('list_task'))
  322. ## =-=- Here, We handle HTTP requests - User Logged Part -=-=
  323. @view_config(route_name='exchange', renderer="jm2l:templates/Logistique/Logistique.mako")
  324. def exchange(request):
  325. modtype = request.matchdict.get('modtype', None)
  326. action = request.matchdict.get('action', None)
  327. uid = int(request.matchdict.get('id', -1))
  328. Exch = Exchange.by_id(uid)
  329. if not Exch:
  330. MainTab = {
  331. 'Exchanges':Exchange,
  332. 'Type':modtype[-1:],
  333. 'reload':True,
  334. 'logged_in':request.authenticated_userid
  335. }
  336. return MainTab
  337. if action in ['delete', 'accept', 'refuse', 'deal']:
  338. if action=='delete': # delete exchange
  339. DBSession.delete(Exch)
  340. elif action=='accept': # accept exchange
  341. Exch.exch_done=True
  342. DBSession.merge(Exch)
  343. elif action=='refuse': # refuse exchange
  344. Exch.exch_done=False
  345. if Exch.exch_state=="Ask":
  346. Exch.provider_id = None
  347. elif Exch.exch_state=="Proposal":
  348. Exch.asker_id = None
  349. DBSession.merge(Exch)
  350. elif action=='deal':
  351. # ask to deal the exchange
  352. if Exch.exch_state=="Ask":
  353. Exch.provider_id = request.user.uid
  354. elif Exch.exch_state=="Proposal":
  355. Exch.asker_id = request.user.uid
  356. # Return javascript to parent page
  357. response = render_to_response('jm2l:templates/modals_js.mako',
  358. {'modtype':modtype, 'action':action},
  359. request=request)
  360. response.content_type = 'text/javascript'
  361. return response
  362. else:
  363. MainTab = {
  364. 'Exchanges':Exchange,
  365. 'Type':modtype[-1:],
  366. 'reload':True,
  367. 'logged_in':request.authenticated_userid
  368. }
  369. return MainTab
  370. @view_config(route_name='jm2l', renderer="jm2l:templates/jm2l.mako")
  371. def jm2l_page(request):
  372. if request.user is None:
  373. # Don't answer to users that aren't logged
  374. return HTTPUnauthorized('You have to be logged to hope an answer.')
  375. page = int(request.params.get('page', 1))
  376. UserNum = request.params.get('user')
  377. if UserNum:
  378. profil = User.by_id(int(UserNum))
  379. if not profil:
  380. raise HTTPNotFound()
  381. else:
  382. profil = request.user
  383. # Build Form
  384. profil_form = ProfilForm(request.POST, profil, meta={'csrf_context': request.session})
  385. if request.method == 'POST' and profil_form.validate():
  386. ToDelete = list()
  387. # First, we remove entries no more present
  388. for obj in profil_form.tiersship.object_data:
  389. MatchEntry = filter( lambda x: x.object_data and x.object_data._sa_instance_state == obj._sa_instance_state,
  390. profil_form.tiersship.entries )
  391. if not MatchEntry:
  392. ToDelete.append(obj)
  393. # Then, it's time to consider new entries
  394. for entry in profil_form.tiersship.entries:
  395. if entry.object_data is None:
  396. TmpUser = User_Tiers()
  397. entry.object_data = TmpUser
  398. profil.tiersship.append(TmpUser)
  399. profil_form.tiersship.object_data = profil.tiersship
  400. profil_form.populate_obj(profil)
  401. # We should remove it as it's not in original data
  402. for obj in ToDelete:
  403. #profil.tiersship.remove(obj)
  404. DBSession.delete(obj)
  405. profil.last_change = datetime.datetime.utcnow()
  406. profil.slug = slugify(remove_accents('%s %s' % (profil.prenom, profil.nom)).lower().strip())
  407. DBSession.merge(profil)
  408. MainTab = {'participer':'active',
  409. 'Places':Place.get_list(False),
  410. 'DBTiers':Tiers,
  411. 'DBTiersOpt':TiersOpt,
  412. 'Exchanges':Exchange,
  413. 'profil_form':profil_form,
  414. 'uprofil':profil,
  415. 'logged_in':request.authenticated_userid
  416. }
  417. return MainTab
  418. @view_config(route_name='modal', renderer="jm2l:templates/modals.mako")
  419. def Modal(request):
  420. year = int(request.matchdict.get('year', None))
  421. modtype = request.matchdict.get('modtype', None)
  422. uid = int(request.matchdict.get('id', -1))
  423. session = request.session
  424. if modtype=='UserPicture':
  425. form = None
  426. if modtype=='Place':
  427. if uid>0:
  428. place = Place.by_id(uid)
  429. if not place:
  430. raise HTTPNotFound()
  431. form = PlaceUpdateForm(request.POST, place, meta={'csrf_context': request.session})
  432. else:
  433. place = Place()
  434. form = PlaceCreateForm(request.POST, meta={'csrf_context': request.session})
  435. if request.method == 'POST' and form.validate():
  436. form.populate_obj(place)
  437. place.created_by=request.user.uid
  438. if uid>0:
  439. DBSession.merge(place)
  440. else:
  441. DBSession.add(place)
  442. response = render_to_response('jm2l:templates/modals_js.mako',
  443. {'modtype':modtype},
  444. request=request)
  445. response.content_type = 'text/javascript'
  446. return response
  447. else:
  448. print form.errors
  449. if modtype in ['AskC', 'AskH', 'AskM', 'PropC', 'PropH', 'PropM']:
  450. if uid>0:
  451. Exch = Exchange.by_id(uid)
  452. if not Exch:
  453. raise HTTPNotFound()
  454. if modtype in ['AskC','PropC']:
  455. form = globals()["Update%sForm" % modtype](request.POST, Exch,
  456. start_place = Exch.Itin.start_place,
  457. arrival_place = Exch.Itin.arrival_place,
  458. Hour_start = Exch.start_time.strftime("%H:%M"),
  459. Day_start = Exch.start_time.strftime("%w"),
  460. exch_id = uid, meta={'csrf_context': request.session}
  461. )
  462. elif modtype in ['AskM','PropM']:
  463. form = globals()["Update%sForm" % modtype](request.POST, Exch,
  464. description = Exch.description,
  465. exch_categ = Exch.exch_categ,
  466. Hour_start = Exch.start_time.strftime("%H:%M"),
  467. Day_start = Exch.start_time.strftime("%w"),
  468. Hour_end = Exch.end_time.strftime("%H:%M"),
  469. Day_end = Exch.end_time.strftime("%w"),
  470. exch_id = uid, meta={'csrf_context': request.session}
  471. )
  472. elif modtype in ['AskH','PropH']:
  473. form = globals()["Update%sForm" % modtype](request.POST, Exch,
  474. description = Exch.description,
  475. exch_categ = Exch.exch_categ,
  476. Day_start = Exch.start_time.strftime("%w"),
  477. exch_id = uid, meta={'csrf_context': request.session}
  478. )
  479. # Itinerary, first get itinerary
  480. if 0:
  481. form.itin.form.start_place.data = Exch.Itin.start_place
  482. form.itin.form.arrival_place.data = Exch.Itin.arrival_place
  483. form.dateform.form.Hour.data = Exch.start_time.strftime("%H:%M")
  484. form.dateform.form.Day.data = Exch.start_time.strftime("%w")
  485. form.exch_id.data = uid
  486. else:
  487. Exch = Exchange()
  488. form = globals()["%sForm" % modtype](request.POST, meta={'csrf_context': request.session})
  489. if modtype in ['AskC', 'PropC']:
  490. # Put some place on form
  491. Places = DBSession.query(Place.place_id, Place.display_name)\
  492. .order_by('name').all()
  493. form.start_place.choices = Places
  494. form.arrival_place.choices = Places
  495. if modtype in ['PropH']:
  496. form.exch_categ.choices = DBSession.query( Exchange_Cat.cat_id, Exchange_Cat.exch_subtype)\
  497. .filter( Exchange_Cat.exch_type=='H' ).all()
  498. form.place_id.choices = DBSession.query( Place.place_id, Place.display_name)\
  499. .filter( Place.created_by==request.user.uid ).all()
  500. if modtype in ['AskM', 'PropM']:
  501. form.exch_categ.choices = DBSession.query( Exchange_Cat.cat_id, Exchange_Cat.exch_subtype)\
  502. .filter( Exchange_Cat.exch_type=='M' ).all()
  503. if request.method == 'POST' and form.validate():
  504. # Form has been validated, it's time to create our Exchange
  505. Exch.for_year = year
  506. Exch.exch_state = {'Ask':'Ask', 'Prop':'Proposal'}[modtype[:-1]]
  507. Exch.exch_type = modtype[-1:]
  508. if modtype in ['AskC', 'PropC']:
  509. # Itinerary, first Let's see if itinerary exist
  510. Itinerary = DBSession.query(Itineraire)\
  511. .filter(Itineraire.start_place==form.start_place.data) \
  512. .filter(Itineraire.arrival_place==form.arrival_place.data) \
  513. .filter(Itineraire.tr_voiture==True) \
  514. .first()
  515. if not Itinerary: # Not exist yet !
  516. Itinerary = Itineraire(start_place=form.start_place.data, \
  517. arrival_place=form.arrival_place.data, \
  518. tr_voiture=True, \
  519. created_by=1
  520. )
  521. DBSession.add(Itinerary)
  522. DBSession.flush()
  523. print form.start_place.data
  524. print form.arrival_place.data
  525. print form.itin_id.data
  526. Exch.itin_id = Itinerary.itin_id
  527. # Start Time
  528. StartEvent = DBSession.query(JM2L_Year.start_time).filter(JM2L_Year.year_uid==year).first()
  529. Week = StartEvent[0].strftime("%W")
  530. # populate
  531. form.populate_obj(Exch)
  532. if modtype in ['AskC', 'PropC']:
  533. Exch.itin_id = Itinerary.itin_id
  534. if form._fields.has_key("Hour_start"):
  535. TargetTime = datetime.datetime.strptime('%d %d %d %s' % (year, int(Week), \
  536. int(form.Day_start.data), form.Hour_start.data), "%Y %W %w %H:%M")
  537. Exch.start_time = TargetTime
  538. elif form._fields.has_key("Day_start"):
  539. TargetTime = datetime.datetime.strptime('%d %d %d' % (year, int(Week), \
  540. int(form.Day_start.data)), "%Y %W %w")
  541. Exch.start_time = TargetTime
  542. if form._fields.has_key("Hour_end"):
  543. TargetTime = datetime.datetime.strptime('%d %d %d %s' % (year, int(Week), \
  544. int(form.Day_end.data), form.Hour_end.data), "%Y %W %w %H:%M")
  545. Exch.end_time = TargetTime
  546. elif form._fields.has_key("Day_end"):
  547. TargetTime = datetime.datetime.strptime('%d %d %d' % (year, int(Week), \
  548. int(form.Day_end.data)), "%Y %W %w")
  549. Exch.end_time = TargetTime
  550. Exch.last_change = datetime.datetime.utcnow()
  551. if Exch.exch_state=='Ask':
  552. Exch.asker_id = request.user.uid
  553. elif Exch.exch_state=='Proposal':
  554. Exch.provider_id = request.user.uid
  555. #print vars(form.itin.form)
  556. if uid>0:
  557. DBSession.merge(Exch)
  558. else:
  559. DBSession.add(Exch)
  560. response = render_to_response('jm2l:templates/modals_js.mako',
  561. {'modtype':modtype},
  562. request=request)
  563. response.content_type = 'text/javascript'
  564. return response
  565. # Fallback to HTML Display with errors
  566. return {'modtype':modtype, 'form':form, 'update':uid>0,
  567. 'logged_in':request.authenticated_userid }
  568. if modtype in ['ShowC', 'ShowH', 'ShowM']:
  569. if uid>0:
  570. Exch = Exchange.by_id(uid)
  571. if not Exch:
  572. raise HTTPNotFound()
  573. else:
  574. raise HTTPNotFound()
  575. # Show Details around the Current Exchange
  576. return {'modtype':modtype, 'Exch':Exch, 'logged_in':request.authenticated_userid }
  577. MainTab = {'modtype':modtype, 'form':form, 'update':uid>0, 'uid':uid,
  578. 'DisplayYear':year, 'session':session,
  579. 'logged_in':request.authenticated_userid }
  580. return MainTab
  581. @view_config(route_name='participer', renderer="jm2l:templates/Participer.mako")
  582. def participer(request):
  583. session = request.session
  584. session['year'] = 2015
  585. TmpUsr = User()
  586. form = UserRegisterForm(request.POST, TmpUsr, meta={'csrf_context': request.session})
  587. MyLink=None
  588. if request.method == 'POST' and form.validate():
  589. form.populate_obj(TmpUsr)
  590. TmpUsr.nom = TmpUsr.nom.capitalize()
  591. TmpUsr.prenom = TmpUsr.prenom.capitalize()
  592. TmpUsr.slug = slugify(remove_accents('%s %s' % (form.prenom, form.nom)).lower().strip())
  593. TmpUsr.password = TmpUsr.my_hash
  594. if len(TmpUsr.slug):
  595. CheckExist = DBSession.query(User)\
  596. .filter(User.slug==TmpUsr.slug)\
  597. .first()
  598. else:
  599. CheckExist=None
  600. if CheckExist:
  601. MyLink = CheckExist.my_hash
  602. else:
  603. DBSession.add(TmpUsr)
  604. DBSession.flush()
  605. MyLink = TmpUsr.my_hash
  606. MainTab = {'programme':'','presse':'', 'plan':'',
  607. 'participer':'active', 'form':form, "link": MyLink,
  608. 'logged_in':request.authenticated_userid }
  609. return MainTab
  610. @view_config(route_name='year')
  611. def change_year(request):
  612. year = int(request.matchdict.get('year', -1))
  613. session = request.session
  614. if year>-1:
  615. session['year'] = year
  616. return HTTPFound(location='/%s/le-programme' % year)
  617. return HTTPFound(location=request.route_url('home'))
  618. @view_config(route_name='event', renderer="jm2l:templates/view_event.mako")
  619. def show_event(request):
  620. year = int(request.matchdict.get('year', -1))
  621. event_id = request.matchdict.get('event_id')
  622. if event_id.isdigit():
  623. TheEvent = Event.by_id(event_id)
  624. if TheEvent is None:
  625. raise HTTPNotFound()
  626. else:
  627. TheEvent = Event.by_slug(event_id, year)
  628. if TheEvent is None:
  629. raise HTTPNotFound()
  630. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  631. 'event':TheEvent, 'logged_in':request.authenticated_userid }
  632. return MainTab
  633. @view_config(route_name='link_event')
  634. def link_event(request):
  635. """ Create user if not exist, add it to current event """
  636. year = int(request.matchdict.get('year', -1))
  637. form = AddIntervenant(request.POST, meta={'csrf_context': request.session})
  638. intervention = request.matchdict.get('intervention', None)
  639. TargetEvent = Event.by_id(form.event_uid.data)
  640. Exist = DBSession.query(User)\
  641. .filter(User.nom==form.nom.data)\
  642. .filter(User.prenom==form.prenom.data)\
  643. .first()
  644. if Exist:
  645. TargetUser = Exist
  646. else:
  647. # Add it to user base
  648. TargetUser = User(nom=form.nom.data,
  649. prenom=form.prenom.data, password=form.nom.data)
  650. DBSession.add(TargetUser)
  651. DBSession.flush()
  652. uev = User_Event(year_uid=year, role="Animateur", user_uid=TargetUser.uid)
  653. TargetEvent.interventions.append( uev )
  654. return HTTPFound(location=request.route_url('edit_event', sep='/',
  655. year=str(year), intervention=intervention, uid=str(TargetEvent.uid)))
  656. @view_config(route_name='edit_event', renderer="jm2l:templates/edit_event.mako")
  657. def edit_event(request):
  658. year = int(request.matchdict.get('year', -1))
  659. event_id = request.matchdict.get('event_id')
  660. intervention = request.matchdict.get('intervention', None)
  661. IntervLabel = intervention.replace('_',' ').lower()
  662. if intervention=='Conference':
  663. IntervLabel = u'conférence'
  664. # Check intervention
  665. if not intervention in ['Stand', 'Table ronde', 'Atelier', 'Conference']:
  666. raise HTTPNotFound(u"Ce type d'évenement n'est pas reconnu")
  667. TheYear = DBSession.query(JM2L_Year)\
  668. .filter(JM2L_Year.year_uid==year)\
  669. .all()
  670. # Check year avaibility
  671. if not TheYear:
  672. raise HTTPNotFound(u"Cette année n'est pas pris en charge")
  673. # Generate Timeslots for current year
  674. TimeSlots = list(enumerate( [ x.strftime('%a %d %b %H:%M') for x in
  675. TheYear[0].AvailableTimeSlots ] ))
  676. if event_id:
  677. # We try to update an existing record
  678. if event_id.isdigit():
  679. TheEvent = Event.by_id(event_id)
  680. if TheEvent is None:
  681. raise HTTPNotFound(u"Cette réference n'existe pas")
  682. else:
  683. TheEvent = Event.by_slug(event_id, year)
  684. if TheEvent is None:
  685. raise HTTPNotFound(u"Cette réference n'existe pas")
  686. if not (request.user.uid==1 or request.user in TheEvent.intervenants):
  687. return HTTPForbidden(u"Vous n'êtes pas identifié comme étant un participant à cette intervention.")
  688. # Compute some field value from selected event
  689. if TheEvent.start_time in TheYear[0].AvailableTimeSlots:
  690. start_sel = TheYear[0].AvailableTimeSlots.index(TheEvent.start_time)
  691. else:
  692. start_sel = len(TimeSlots)
  693. TimeSlots.append( (len(TimeSlots), TheEvent.start_time.strftime('%a %d %b %H:%M')))
  694. duration = (TheEvent.end_time - TheEvent.start_time).total_seconds()/60
  695. end = TheEvent.start_time + datetime.timedelta(minutes=duration)
  696. # prepare the form with update
  697. form = ConfUpdateForm(request.POST, TheEvent, start_sel=start_sel, duration=duration, end_time=end,
  698. meta={'csrf_context': request.session} )
  699. # Customize labels
  700. form.name.label.text += IntervLabel
  701. form.description.label.text += IntervLabel
  702. # Each event can get severals members
  703. formAdd = AddIntervenant(event_uid=TheEvent.uid)
  704. else:
  705. TheEvent = Event()
  706. # prepare the form for creation
  707. form = ConfCreateForm(request.POST,
  708. event_type=intervention,
  709. for_year=str(year), meta={'csrf_context': request.session}
  710. )
  711. # Customize labels
  712. form.name.label.text += IntervLabel
  713. form.description.label.text += IntervLabel
  714. duration=60
  715. # No intervenant
  716. formAdd = None
  717. if intervention=="Conference":
  718. form.duration.choices =[
  719. (15,u'Lighting talk ( 5 min)'),
  720. (30,u'Conférence (20 min)'),
  721. (60,u'Conférence (50 min)'),
  722. (90,u'Conférence (75 min)'),
  723. ]
  724. if not duration in [15, 30, 60, 90]:
  725. form.duration.choices.append( (duration,u'Conférence (%d min)' % duration) )
  726. if not form._fields.has_key("uid"):
  727. form.duration.data=60
  728. elif intervention=="Stand":
  729. form.duration.choices =[
  730. (8*60, u'Toute la journée'),
  731. (4*60, u'une demi-journée')
  732. ]
  733. elif intervention=="Atelier":
  734. form.duration.choices = map( lambda d:(d, u'Atelier (%dh%.2d)' % (d/60, d%60) ), \
  735. [60, 90, 120, 150, 180, 210, 240] )
  736. if not duration in map(lambda (d,y): d, form.duration.choices):
  737. form.duration.choices.append( (duration,u'Atelier (%dh%.2d)' % (duration/60, duration%60) ) )
  738. elif intervention=="Table_Ronde":
  739. form.duration.choices = map( lambda d:(d, u'Table ronde (%dh%.2d)' % (d/60, d%60) ), \
  740. [60, 90, 120, 150] )
  741. if not duration in map(lambda (d,y): d, form.duration.choices):
  742. form.duration.choices.append( (duration,u'Table ronde (%dh%.2d)' % (duration/60, duration%60) ) )
  743. else:
  744. return HTTPForbidden(u"Pas encore disponible.")
  745. SalleDispo = DBSession.query(Salles)\
  746. .filter(Salles.year_uid==year)\
  747. .order_by('name')
  748. form.salle_uid.choices = [(s.salle_id, s.name) for s in SalleDispo]
  749. form.start_sel.choices = TimeSlots
  750. if request.method == 'POST' and form.validate():
  751. form.populate_obj(TheEvent)
  752. TheEvent.start_time = TheYear[0].AvailableTimeSlots[form.start_sel.data]
  753. TheEvent.end_time = TheEvent.start_time + datetime.timedelta(minutes=form.duration.data)
  754. # Ok, time to put in database
  755. if not form._fields.has_key("uid"):
  756. TheEvent.slug = slugify(TheEvent.name)
  757. DBSession.add(TheEvent)
  758. # Append creator by default
  759. if request.user.uid!=1:
  760. uev = User_Event(year_uid=TheYear.year_uid, role="Animateur")
  761. uev.user_uid = request.user.uid
  762. TheEvent.interventions.append( uev )
  763. DBSession.flush()
  764. return HTTPFound(location=request.route_url('edit_event', sep='/',
  765. year=str(year), intervention=intervention, event_id=str(TheEvent.slug)))
  766. else:
  767. DBSession.merge(TheEvent)
  768. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  769. 'event':TheEvent, 'form':form, 'formAdd':formAdd,
  770. 'logged_in':request.authenticated_userid }
  771. return MainTab
  772. @view_config(route_name='entities', renderer="jm2l:templates/list_tiers.mako")
  773. def list_tiers(request):
  774. Entities = dict()
  775. EntityType = DBSession.query(TiersOpt.entity_type)\
  776. .group_by(TiersOpt.entity_type).all()
  777. for EType in EntityType:
  778. Entities[EType.entity_type] = DBSession.query(Tiers).join(TiersOpt)\
  779. .filter(TiersOpt.entity_type==EType.entity_type)\
  780. .order_by(TiersOpt.entity_subtype, Tiers.name)
  781. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  782. 'entities':Entities, 'logged_in':request.authenticated_userid }
  783. return MainTab
  784. @view_config(route_name='show_entity', renderer="jm2l:templates/view_tiers.mako")
  785. def show_tiers(request):
  786. tiers_type = request.matchdict.get('tiers_type')
  787. entity_id = request.matchdict.get('entity_id')
  788. if entity_id.isdigit():
  789. TheTiers = Tiers.by_id(entity_id)
  790. if TheTiers is None:
  791. raise HTTPNotFound()
  792. else:
  793. TheTiers = Tiers.by_slug(entity_id)
  794. if TheTiers is None:
  795. raise HTTPNotFound()
  796. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  797. 'entity':TheTiers, 'logged_in':request.authenticated_userid }
  798. return MainTab
  799. @view_config(route_name='add_entity', renderer="jm2l:templates/edit_tiers.mako")
  800. @view_config(route_name='edit_entity', renderer="jm2l:templates/edit_tiers.mako",
  801. permission='edit')
  802. def edit_tiers(request):
  803. entity_id = request.matchdict.get('entity_id', None)
  804. TargetList = list()
  805. entity_types = DBSession.query(TiersOpt.entity_type).group_by(TiersOpt.entity_type).all()
  806. for entity_type in entity_types:
  807. entity_subtypes = DBSession.query(TiersOpt)\
  808. .filter(TiersOpt.entity_type==entity_type.entity_type)\
  809. .group_by(TiersOpt.entity_subtype).all()
  810. ListType = [(i.uid, i.entity_subtype) for i in entity_subtypes]
  811. TargetList.append( (entity_type.entity_type, ListType) )
  812. if entity_id:
  813. if entity_id.isdigit():
  814. TheTiers = Tiers.by_id(entity_id)
  815. if TheTiers is None:
  816. raise HTTPNotFound()
  817. else:
  818. TheTiers = Tiers.by_slug(entity_id)
  819. if TheTiers is None:
  820. raise HTTPNotFound()
  821. form = UpdateTiersForm(request.POST, TheTiers, meta={'csrf_context': request.session})
  822. UserOptions = DBSession.query(TiersOpt)\
  823. .filter(TiersOpt.entity_type==TheTiers.tiers_type)\
  824. .all()
  825. form.tiers_type.choices = TargetList
  826. else:
  827. TheTiers = Tiers()
  828. # prepare the form for creation
  829. form = TiersForm(request.POST, TheTiers, meta={'csrf_context': request.session})
  830. form.tiers_type.choices = TargetList
  831. UserOptions = list()
  832. #test_form = TiersForm(request.POST, TheTiers, meta={'csrf_context': request.session})
  833. if request.method == 'POST' and form.validate():
  834. ToDelete = list()
  835. # First, we remove entries no more present
  836. for obj in form.membership.object_data:
  837. MatchEntry = filter( lambda x: x.object_data and x.object_data._sa_instance_state == obj._sa_instance_state,
  838. form.membership.entries )
  839. if not MatchEntry:
  840. ToDelete.append(obj)
  841. # We should remove it as it's not in original data
  842. for obj in ToDelete:
  843. TheTiers.membership.remove(obj)
  844. DBSession.delete(obj)
  845. # Then, it's time to consider new entries
  846. for entry in form.membership.entries:
  847. if entry.object_data is None:
  848. TmpUser = User_Tiers()
  849. entry.object_data = TmpUser
  850. TheTiers.membership.append(TmpUser)
  851. form.membership.object_data = TheTiers.membership
  852. form.populate_obj(TheTiers)
  853. # Handle Remove of accents
  854. TheTiers.slug = slugify(form.name.data)
  855. if not form._fields.has_key('uid'):
  856. TheTiers.creator_id = request.user.uid
  857. DBSession.add(TheTiers)
  858. DBSession.flush()
  859. return HTTPFound(location=request.route_url('edit_entity', sep='/',
  860. entity_id=str(TheTiers.slug), tiers_type=TheTiers.get_entity_type.entity_type))
  861. DBSession.merge(TheTiers)
  862. return HTTPFound(location=request.route_url('entities'))
  863. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  864. 'form':form, 'DBUser':User, 'UserOptions':UserOptions,
  865. 'logged_in':request.authenticated_userid }
  866. return MainTab
  867. @view_config(route_name='edit_entity_cat', renderer="jm2l:templates/edit_tiers_categ.mako")
  868. def edit_tiers_category(request):
  869. DicResult = dict()
  870. ListChanges = list()
  871. if request.method == 'POST':
  872. # Reformat data
  873. RegExist = re.compile('collection\[(?P<slug>[\w-]+)\]\[(?P<num>\d+)\]\[(?P<id>\d+)\]')
  874. RegTitle = re.compile('collection\[(?P<slug>[\w-]+)\]\[title]')
  875. RegNew = re.compile('collection\[(?P<slug>[\w-]+)\]\[(?P<num>\d+)\]\[id\]')
  876. for key, value in request.POST.iteritems():
  877. regN= RegNew.match(key)
  878. regT= RegTitle.match(key)
  879. reg = RegExist.match(key)
  880. if reg:
  881. if not DicResult.has_key(reg.group('slug')):
  882. DicResult[reg.group('slug')] = dict()
  883. if DicResult[reg.group('slug')].has_key('items'):
  884. DicResult[reg.group('slug')]['items'].append( ( int(reg.group('id')), value ) )
  885. else:
  886. DicResult[reg.group('slug')]['items'] = [ ( int(reg.group('id')), value ) ]
  887. elif regN:
  888. if not DicResult.has_key(regN.group('slug')):
  889. DicResult[regN.group('slug')] = dict()
  890. if DicResult[regN.group('slug')].has_key('items'):
  891. DicResult[regN.group('slug')]['items'].append( ( 'id', value ) )
  892. else:
  893. DicResult[regN.group('slug')]['items'] = [ ( 'id', value ) ]
  894. ListChanges.append(('add', 0, DicResult[regN.group('slug')]['title'], value))
  895. elif regT:
  896. if not DicResult.has_key(regT.group('slug')):
  897. DicResult[regT.group('slug')] = dict()
  898. DicResult[regT.group('slug')]['title'] = value
  899. else:
  900. raise
  901. for opt in DBSession.query(TiersOpt).all():
  902. if DicResult.has_key(opt.slug_entity_type):
  903. found = filter( lambda (x,y): opt.uid==x,
  904. DicResult[opt.slug_entity_type].get('items', []))
  905. if not found:
  906. ListChanges.append(('remove', opt.uid, opt.entity_type, opt.entity_subtype))
  907. else:
  908. for tst in found:
  909. # Check changes on Cat Name
  910. if DicResult[opt.slug_entity_type]['title']!=opt.entity_type or \
  911. tst[1]!=opt.entity_subtype:
  912. ListChanges.append(('changed', opt.uid,
  913. DicResult[opt.slug_entity_type]['title'],
  914. tst[1]))
  915. else:
  916. ListChanges.append(('remove', opt.uid, opt.entity_type, opt.entity_subtype))
  917. # Do The change
  918. for action, uid, entity, subentity in ListChanges:
  919. if action=="changed":
  920. opt = TiersOpt.by_id(uid)
  921. opt.entity_type = entity
  922. opt.entity_subtype = subentity
  923. elif action=="remove":
  924. opt = TiersOpt.by_id(uid)
  925. DBSession.delete(opt)
  926. elif action=="add":
  927. opt = TiersOpt()
  928. opt.entity_type = entity
  929. opt.entity_subtype = subentity
  930. DBSession.add(opt)
  931. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  932. 'logged_in':request.authenticated_userid, 'TiersOpt':TiersOpt }
  933. return MainTab
  934. @view_config(route_name='show_user', renderer="jm2l:templates/view_user.mako")
  935. def show_user(request):
  936. user_slug = request.matchdict.get('user_slug', None)
  937. # Query database
  938. DispUser = User.by_slug(user_slug)
  939. MainTab = {'programme':'','presse':'', 'plan':'', 'participer':'',
  940. 'DispUser':DispUser, 'logged_in':request.authenticated_userid }
  941. return MainTab
  942. #@view_config(route_name='link_user_entity')
  943. def link_user_entity(request):
  944. uid = int(request.matchdict.get('uid', -1))
  945. year = int(request.matchdict.get('year', -1))
  946. user_id = int(request.matchdict.get('uid', -1))
  947. TheTiers = Tiers.by_id(uid)
  948. if TheTiers is None:
  949. raise HTTPNotFound()
  950. return HTTPFound(location=request.route_url('edit_entity', uid=uid) )
  951. #@view_config(route_name='link_role_entity')
  952. def link_role_entity(request):
  953. uid = int(request.matchdict.get('uid', -1))
  954. year = int(request.matchdict.get('year', -1))
  955. role_id = int(request.matchdict.get('role_id', -1))
  956. TheTiers = Tiers.by_id(uid)
  957. if TheTiers is None:
  958. raise HTTPNotFound()
  959. return HTTPFound(location=request.route_url('edit_entity', uid=uid) )
  960. @notfound_view_config()
  961. def notfound(reason, request):
  962. request.response.status = 404
  963. return render_to_response('jm2l:templates/Errors/404.mak', { "reason":reason },
  964. request=request)
  965. @forbidden_view_config()
  966. def forbidden(reason, request):
  967. return Response('forbidden')
  968. request.response.status = 404
  969. return render_to_response('jm2l:templates/Errors/404.mak', { "reason":reason },
  970. request=request)