#!/usr/bin/env python # -*- coding: utf-8 -*- # Copyright (C) 2008-2016 Étienne Loks # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU General Public License as # published by the Free Software Foundation, either version 3 of the # License, or (at your option) any later version. # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU General Public License for more details. # You should have received a copy of the GNU General Public License # along with this program. If not, see . # See the file COPYING for details. """ Views of the project """ import datetime from itertools import groupby import json import re from django.conf import settings from django.contrib.gis.geos import GEOSGeometry, Polygon as GEOSPolygon from django.contrib.gis.gdal.error import GDALException from django.contrib.gis.measure import D from django.contrib.sites.shortcuts import get_current_site from django.core.exceptions import ObjectDoesNotExist from django.db.models import Q from django.http import HttpResponseRedirect, HttpResponse, Http404 from django.shortcuts import get_object_or_404, redirect, render from django.template import defaultfilters from django.urls import reverse from django.utils.http import urlquote from django.utils.translation import ugettext as _ from django.views.generic import TemplateView, ListView, FormView from chimere.actions import actions, get_extra_pages from chimere import models from chimere import forms from chimere import widgets from chimere.route import router from chimere.version import get_version def get_page_title(area=None): if not area: if not settings.PROJECT_NAME: return "Chimère" else: return settings.PROJECT_NAME if not settings.PROJECT_NAME: return area.name else: return settings.PROJECT_NAME + " - " + area.name def status(request): return HttpResponse('OK') def get_base_uri(request): base_uri = 'http://' if 'HTTP_REFERER' in request.META: if request.META['HTTP_REFERER'].startswith('https:'): base_uri = 'https://' if 'SERVER_NAME' in request.META: base_uri += request.META['SERVER_NAME'] if 'SERVER_PORT' in request.META and \ str(request.META['SERVER_PORT']) != '80': base_uri += ":" + str(request.META['SERVER_PORT']) return base_uri # TODO: convert to requestcontext def get_area(area_name=""): area = None if area_name and area_name.endswith('/'): area_name = area_name[:-1] if area_name: try: area = models.Area.objects.get(urn=area_name, available=True) except ObjectDoesNotExist: pass if not area: try: area = models.Area.objects.get(default=True) area_name = area.urn except ObjectDoesNotExist: pass return area, area_name def get_base_response(request, area_name=""): """ Get the base url """ current_site = get_current_site(request) base_response_dct = { 'media_path': settings.MEDIA_URL, 'version': get_version(), 'current_site': (request.is_secure() and "https://" or "http://") + current_site.domain, "MOBILE": settings.MOBILE_TEST or current_site.domain in settings.MOBILE_DOMAINS } base_url = reverse(settings.MAIN_INDEX) if not base_url.startswith('/'): base_url = '/' + base_url if area_name and area_name.endswith('/'): area_name = area_name[:-1] if area_name: base_response_dct['area_name_slash'] = area_name + "/" if base_url[-1] != '/': base_url += '/' base_url += area_name + '/' base_response_dct['extra_url'] = base_url area, area_name = get_area(area_name) base_response_dct['area'] = area base_response_dct['extra_pages'] = get_extra_pages(area) base_response_dct['area_name'] = area_name if area and area.favicon: base_response_dct['favicon'] = area.favicon if area and area.external_css: base_response_dct['css_area'] = area.external_css base_response_dct['dynamic_categories'] = \ True if area and area.dynamic_categories else False base_response_dct['PROJECT_NAME'] = get_page_title(area) if hasattr(settings, 'EXTRA_CSS'): base_response_dct['EXTRA_CSS'] = settings.EXTRA_CSS return base_response_dct, None def getShareUrl(request, area_name='', network='', attrs=''): """ Get a share url """ data = getTinyfiedUrl(request, attrs, area_name) for name, url, img, JS in settings.CHIMERE_SHARE_NETWORKS: if defaultfilters.slugify(name) == network: return HttpResponse(url % {'text': data['text'], 'url': data['url']}) return HttpResponse('') def getShareNetwork(request, area_name='', marker=None, geo_type=None): """ Get URLs to share items """ parameters = "" if marker: parameters = "{};;;{};{}-{};;;;;".format( settings.CHIMERE_DEFAULT_ZOOM, "-".join([str(m.id) for m in marker.categories.all()]), geo_type or '', marker.pk) net_dct = getTinyfiedUrl(request, parameters, area_name) share_networks = [] for network in settings.CHIMERE_SHARE_NETWORKS: share_networks.append((network[0], network[1] % net_dct, network[2])) return share_networks, net_dct def index(request, area_name=None, default_area=None, simple=False, get_response=False): """ Main page """ # show the news # only if user is not came yet today today = datetime.date.today().strftime('%y-%m-%d') news_visible = False if 'last_visit' not in request.session or \ request.session['last_visit'] != today and request.GET: request.session['last_visit'] = today news_visible = True response_dct, redir = get_base_response(request, area_name) if redir: return redir # don't mess with permalink zoomout = True if request.GET and 'lat' in request.GET \ and 'lon' in request.GET: zoomout = None if hasattr(settings, 'CHIMERE_ENABLE_ROUTING') and \ settings.CHIMERE_ENABLE_ROUTING: response_dct['itinerary_form'] = forms.RoutingForm() response_dct['routing_transport'] = settings.CHIMERE_ROUTING_TRANSPORT if request.GET and "current_feature" in request.GET: item_key = request.GET['current_feature'] current_cls = None for cls in (models.Marker, models.Polygon, models.Route): if item_key.startswith(cls.__name__.lower() + '-'): current_cls = cls break if current_cls: try: response_dct["current_feature"] = current_cls.objects.get( status='A', pk=item_key[len(current_cls.geom_attr + '-') + 1:]) except current_cls.DoesNotExist: pass if request.GET and "ty" in request.GET: response_dct['tiny'] = request.GET["ty"] response_dct.update({ 'action_selected': ('map',), 'error_message': '', 'is_map': True, 'news_visible': news_visible, 'areas_visible': settings.CHIMERE_DISPLAY_AREAS and models.Area.objects.filter(available=True).count() > 1, 'map_layer': settings.CHIMERE_DEFAULT_MAP_LAYER, 'dynamic_categories': response_dct['dynamic_categories'], 'zoomout': zoomout, 'has_default_area': models.Area.objects.filter(default=True).count(), 'has_search': response_dct['area'].use_search if response_dct['area'] else None, 'VERSION': get_version(), 'extra_css': widgets.MultiSelectWidget.Media.EXTRA_CSS, 'extra_js': widgets.MultiSelectWidget.Media.EXTRA_JS, 'extra_media': widgets.TextareaWidgetBase().media }) if hasattr(settings, 'PROJECT_IMAGE') and settings.PROJECT_IMAGE: response_dct['PROJECT_IMAGE'] = settings.PROJECT_IMAGE if hasattr(settings, 'PROJECT_IMAGE_WIDTH'): response_dct['PROJECT_IMAGE_WIDTH'] = settings.PROJECT_IMAGE_WIDTH if hasattr(settings, 'PROJECT_IMAGE_HEIGHT'): response_dct['PROJECT_IMAGE_HEIGHT'] = \ settings.PROJECT_IMAGE_HEIGHT if hasattr(settings, 'CONTACT_EMAIL') and settings.CONTACT_EMAIL: response_dct['contact_email'] = settings.CONTACT_EMAIL response_dct['share_networks'], net_dct = \ getShareNetwork(request, response_dct['area_name']) tpl = 'chimere/main_map.html' if request.GET and "simple" in request.GET: simple = True response_dct['simple'] = simple if get_response: return tpl, response_dct return render(request, tpl, response_dct) def edit(request, area_name="", item_id=None, submited=False): """ Edition page """ response_dct, redir = get_base_response(request, area_name) if redir: return redir current_actions = actions(response_dct['area_name']) redir = action_do_redirect('edit-no-page', current_actions) # a redir is always send... or there is a problem return redirect(redir) def get_edit_page(redirect_url, item_cls, item_form, multimediafile_formset=forms.MultimediaFileFormSet, picturefile_formset=forms.PictureFileFormSet): """ Edition page """ def func(request, area_name="", item_id=None, cat_type=['M']): response_dct, redir = get_base_response(request, area_name) if redir: return redir, None, None if 'area_name' in response_dct: area_name = response_dct['area_name'] subcategories = models.SubCategory.getAvailable(cat_type, area_name, submission=True) listed_subcats = [] if subcategories: for cat, subcats in subcategories: listed_subcats.append( (str(cat), [(subcat.pk, subcat.name) for subcat in subcats])) else: listed_subcats = None # if an item_id is provided: modification response_dct['item_id'] = item_id init_item, ref_item = None, None has_multimediafile_formset = True if item_id: try: init_item = item_cls.objects.get(pk=item_id) except: return redirect(redirect_url, area_name + '/' if area_name else ''), None, None ref_item = init_item modified_item = item_cls.objects.filter( ref_item=init_item, submiter_session_key=request.session.session_key) if modified_item.count(): init_item = modified_item.all()[0] response_dct['is_modification'] = True # no new submission on modification has_multimediafile_formset = False if init_item and not request.user.is_superuser and \ not init_item.submiter_session_key == \ request.session.session_key: # hide personal information for k in ('submiter_name', 'submiter_email', 'submiter_comment'): setattr(init_item, k, '') response_dct['is_superuser'] = request.user.is_superuser formset_multi, formset_picture = None, None # If the form has been submitted if request.method == 'POST': inst = None # allow to directly modify only if owner or superuser if init_item and ( request.user.is_superuser or init_item.submiter_session_key == request.session.session_key): inst = init_item form = item_form(request.POST, request.FILES, instance=inst, subcategories=listed_subcats, area_name=area_name) if has_multimediafile_formset: formset_multi = multimediafile_formset( request.POST, request.FILES, prefix='multimedia') formset_picture = picturefile_formset( request.POST, request.FILES, prefix='picture') # All validation rules pass if form.is_valid() and ( not formset_multi or formset_multi.is_valid()) and ( not formset_picture or formset_picture.is_valid()): item = form.save() # set the session key (to permit modifications) item.submiter_session_key = request.session.session_key # associate to the reference item if ref_item: item.ref_item = ref_item if item.pk != ref_item.pk: item.status = 'M' elif not item.ref_item: # initialisation item.ref_item = item # just submitted if not item.status: item.status = 'S' item.save() if item: # manage multimedia items if has_multimediafile_formset: for f in formset_multi: f.save(item) for f in formset_picture: f.save(item) base_uri = get_base_uri(request) forms.notifySubmission(base_uri, item) return redirect(reverse('form-result', args=['true'])), None, \ subcategories else: response_dct['error_message'] = _( "There are missing field(s)" " and/or errors in the submitted form.") context = "" for error_key in form.errors: context += "\n * {}: {}".format( error_key, " ; ".join(form.errors[error_key])) forms.notifyByEmail( "[] {}".format(settings.PROJECT_NAME, _('Error on form submission')), 'Context: ' + context, [email for name, email in settings.ADMINS] ) if settings.DEBUG: print(context) # return redirect(reverse('form-result')), None, \ # subcategories else: form = item_form(instance=init_item, subcategories=listed_subcats, area_name=area_name) if has_multimediafile_formset: formset_multi = multimediafile_formset(prefix='multimedia') formset_picture = picturefile_formset(prefix='picture') return None, (item_id, init_item, response_dct, form, formset_multi, formset_picture), subcategories return func def form_result(request, success='false'): res = {'success': True if success == "true" else False} return render(request, 'chimere/form_result_msg.html', res) def action_do_redirect(action_name, available_actions): # redirect to an edit is_edit = 'edit' in action_name redir = None for action, subactions in available_actions: if action.id == action_name: return if not redir and action.id != action_name: redir = action.url for subaction in subactions: if subaction.id == action_name: return if is_edit and 'edit' not in redir \ and 'edit' in subaction.id: redir = subaction.url return redir def uploadFile(request, category_id='', area_name=''): response_dct, redir = get_base_response(request, area_name) if redir: return redir Form = forms.FileForm if not category_id else forms.FullFileForm category = None if category_id: try: category = models.SubCategory.objects.get(pk=category_id) response_dct['category'] = str(category) except models.SubCategory.DoesNotExist: pass # If the form has been submitted if request.method == 'POST': form = Form(request.POST, request.FILES) # All validation rules pass if form.is_valid(): raw_file = form.cleaned_data['raw_file'] name = raw_file.name.split('.')[0] file_type = raw_file.name.split('.')[-1][0].upper() routefile = models.RouteFile(raw_file=raw_file, name=name, file_type=file_type) routefile.save() if not category_id: response_dct['gpx_id'] = routefile.pk return render( request, 'chimere/upload_file.html', response_dct) routefile.process() if not routefile.route: response_dct['errors'] = _( "Bad file. Please check it with an external software.") response_dct.update({'form': form}) return render( request, 'chimere/upload_file.html', response_dct) route = models.Route(name=form.cleaned_data['name'], route=routefile.route, associated_file=routefile, status='S') route.save() route.categories.add(category) route.save() response_dct['thanks'] = True form = Form() else: # An unbound form form = Form() response_dct.update({'form': form}) return render(request, 'chimere/upload_file.html', response_dct) def processRouteFile(request, area_name='', file_id=None): if file_id: try: route_file = models.RouteFile.objects.get(pk=file_id) route_file.process() route = route_file.route if not route: return HttpResponse(status=500) return HttpResponse('(' + json.dumps({'wkt': route, 'file_id': file_id}) + ')', 'application/javascript', status=200) except OSError as e: return HttpResponse(e.strerror, status=500) else: return HttpResponse(status=400) get_edit_marker = get_edit_page('chimere:editmarker', models.Marker, forms.MarkerForm) get_edit_route = get_edit_page('chimere:editroute', models.Route, forms.RouteForm) get_edit_polygon = get_edit_page('chimere:editpolygon', models.Polygon, forms.PolygonForm) def edit_page(get_edit, types, geom_name, widget, init_widget=True): def edit(request, area_name="", item_id=None, submited=False): if request.POST and request.POST.get("area_name"): area_name = request.POST["area_name"] response, values, sub_categories = get_edit(request, area_name, item_id, types) if response: return response item_id, init_item, response_dct, form, formset_multi, formset_picture = \ values # verify action is available current_actions = actions(response_dct['area_name']) redir = action_do_redirect('edit-' + geom_name, current_actions) if redir: return redirect(redir) # get the "manualy" declared_fields. Ie: properties querys = models.PropertyModel.getAvailable(area_name=area_name) declared_fields, filtered_properties = [], [] for query in querys: declared_fields += query.all() filtered_properties += query.filter( subcategories__id__isnull=False).all() geom_attr = geom_name if geom_attr == 'marker': geom_attr = 'point' value = getattr(init_item, geom_attr) if init_item else None if request.POST and request.POST.get(geom_attr): value = request.POST.get(geom_attr) response_dct.update({ 'action_selected': ('contribute', 'edit-' + geom_name), 'map_layer': settings.CHIMERE_DEFAULT_MAP_LAYER, 'error_message': '', 'geom_name': geom_name, 'form': form, 'formset_multi': formset_multi, 'formset_picture': formset_picture, 'dated': settings.CHIMERE_DAYS_BEFORE_EVENT, 'extra_head': form.media, 'marker_id': item_id, 'sub_categories': sub_categories, 'area_name': area_name, geom_attr + '_widget': widget().render( geom_attr, value, area_name=response_dct['area_name'], initialized=init_widget ), 'properties': declared_fields, 'filtered_properties': filtered_properties, 'submited': submited }) # manualy populate the custom widget if 'subcategory' in form.data and form.data['subcategory']: response_dct['current_category'] = int(form.data['subcategory']) return render( request, 'chimere/edit_{}.html'.format(geom_name), response_dct) return edit editMarker = edit_page(get_edit_marker, ['M', 'B'], 'marker', widgets.PointChooserWidget, init_widget=False) editMarkerTab = edit_page(get_edit_marker, ['M', 'B'], 'marker', widgets.PointChooserWidget) editRoute = edit_page(get_edit_route, ['R', 'B'], 'route', widgets.RouteChooserWidget, init_widget=False) editRouteTab = edit_page(get_edit_route, ['R', 'B'], 'route', widgets.RouteChooserWidget) editPolygon = edit_page(get_edit_polygon, ['P'], 'polygon', widgets.PolygonChooserWidget, init_widget=False) editPolygonTab = edit_page(get_edit_polygon, ['P'], 'polygon', widgets.PolygonChooserWidget) def submited(request, area_name="", action=""): """ Successful submission page """ response_dct, redir = get_base_response(request, area_name) if redir: return redir dct = {'actions': actions(response_dct['area_name']), 'action_selected': action} if hasattr(settings, 'CONTACT_EMAIL') and settings.CONTACT_EMAIL: response_dct['contact_email'] = settings.CONTACT_EMAIL response_dct.update(dct) return render(request, 'chimere/submited.html', response_dct)\ def charte(request, area_name=""): """ Affichage de la charte """ response_dct, redir = get_base_response(request, area_name) if redir: return redir response_dct.update({'actions': actions(response_dct['area_name']), 'action_selected': ('charte',)}) return render('chimere/charte.html', response_dct, request) def contactus(request, area_name=""): """ Contact page """ form = None msg = '' # If the form has been submitted if request.method == 'POST': form = forms.ContactForm(request.POST) # All validation rules pass if form.is_valid(): response = forms.notifyStaff( _("Comments/request on the map"), form.cleaned_data['content'], form.cleaned_data['email']) if response: msg = _("Thank you for your contribution. It will be taken " "into account. If you have left your email you may " "be contacted soon for more details.") else: msg = _("Temporary error. Renew your message later.") else: form = forms.ContactForm() response_dct, redir = get_base_response(request, area_name) if redir: return redir response_dct.update({'actions': actions(response_dct['area_name']), 'action_selected': ('contact',), 'contact_form': form, 'message': msg}) return render(request, 'chimere/contactus.html', response_dct) def extraPage(request, area_name="", page_id=""): """ Extra dynamic pages """ try: page = models.Page.objects.get(available=True, mnemonic=page_id) except ObjectDoesNotExist: return redirect(reverse(settings.MAIN_INDEX)) response_dct, redir = get_base_response(request, area_name) if redir: return redir response_dct.update({'actions': actions(response_dct['area_name']), 'action_selected': (page_id,), 'content': page.content, 'title': page.title}) tpl = page.template_path if page.template_path \ else 'chimere/default_extra_page.html' return render(request, tpl, response_dct) def getDetailUndefined(request, area_name): return HttpResponse('') def getDetail(request, area_name, key, popup=False): """ Get the detail of a geographic item """ cls = models.Marker pk = key if '-' in key: geo_type, pk = key.split('-') if geo_type == 'route': cls = models.Route elif geo_type == 'aggroute': cls = models.AggregatedRoute elif geo_type == 'polygon': cls = models.Polygon else: geo_type = 'marker' try: marker = cls.objects.filter(id=int(pk), status__in=['A', 'S'])[0] except (ValueError, IndexError): return HttpResponse('no results') response_dct, redir = get_base_response(request, area_name) if redir: return redir response_dct['marker'] = marker response_dct['popup'] = popup response_dct['category'] = None response_dct['extra_categories'] = [] marker_cats = list(marker.categories.all()) if request.method == 'GET': if 'simple' in request.GET and request.GET['simple']: response_dct['simple'] = True if 'categories' in request.GET and request.GET['categories']: for cat_id in request.GET['categories'].split('-'): try: category = models.SubCategory.objects.get( available=True, pk=int(cat_id)) if category not in marker_cats: continue if not response_dct['category']: response_dct['category'] = category else: response_dct['extra_categories'].append(category) except (models.SubCategory.DoesNotExist, ValueError): pass for idx, cat in enumerate(marker_cats): if not idx and not response_dct['category']: response_dct['category'] = cat elif cat not in response_dct['extra_categories'] \ and cat != response_dct['category']: response_dct['extra_categories'].append(cat) if response_dct['category']: response_dct['color'] = response_dct['category'].category.color response_dct['share_networks'], net_dct = \ getShareNetwork(request, response_dct['area_name'], marker, geo_type) response_dct['share_url'] = net_dct['url'] net_dct['to'] = settings.CONTACT_EMAIL if net_dct['to']: net_dct["body"] = _(settings.CHIMERE_MODIF_EMAIL) response_dct['modif_by_email'] = 'mailto:%(to)s?subject='\ '%(text)s&body=%(body)s%(url)s' % net_dct # to be sure there is unique IDs during a browsing response_dct['time_now'] = datetime.datetime.now().strftime('%H%M%S') response_dct['dated'] = settings.CHIMERE_DAYS_BEFORE_EVENT \ and marker.start_date response_dct['routing_enabled'] = settings.CHIMERE_ENABLE_ROUTING response_dct['properties'] = marker.getProperties(area_name=area_name) marker.set_properties_attributes(area_name=area_name) if popup: return render(request, 'chimere/detail_popup.html', response_dct) return render(request, 'chimere/detail.html', response_dct) def getDescriptionDetail(request, area_name, category_id): """ Get the description for a category """ try: category = models.Category.objects.filter(id=int(category_id))[0] except (ValueError, IndexError): return HttpResponse('no results') response_dct, redir = get_base_response(request, area_name) if redir: return redir response_dct['category'] = category return render(request, 'chimere/category_detail.html', response_dct) def checkDate(q): """ Filter a queryset to manage dates """ if not settings.CHIMERE_DAYS_BEFORE_EVENT: return q today = datetime.date.today() after = today + datetime.timedelta(settings.CHIMERE_DAYS_BEFORE_EVENT) q = q & (Q(start_date__isnull=True) | Q(start_date__gte=today, start_date__lte=after) | Q( start_date__lte=today, end_date__gte=today)) return q def _getGeoObjects(area_name, category_ids, status='A', getjson=True, item_types=('Marker', 'Route', 'Polygon'), bounding_box=None, zoom_level=None): """ Get geo objects """ zoom_need_reload = None items = [] empty = [] if not getjson else {} subcategories = list( models.SubCategory.getAvailable(None, area_name, instance=True).all()) aggregated_category_ids = [] try: zoom_level = int(zoom_level) except (ValueError, TypeError): zoom_level = None if zoom_level: # pop from main category list len_subcats = len(subcategories) for idx, subcat in enumerate(reversed(subcategories)): if not subcat.min_zoom: continue if zoom_level < subcat.min_zoom: if not zoom_need_reload or zoom_need_reload > subcat.min_zoom: zoom_need_reload = subcat.min_zoom aggregated_category_ids.append( subcategories.pop(len_subcats - 1 - idx).pk) category_ids = [ subcat.pk for subcat in subcategories if str(subcat.pk) in category_ids] # marker if 'Marker' in item_types: try: q = checkDate(Q(status__in=status, categories__in=category_ids)) query = models.Marker.objects.filter(q) if bounding_box: query = query.filter(point__contained=bounding_box) query = query.order_by('-pk') except: return empty, zoom_need_reload if getjson: items += models.Marker.getGeoJSONs( query, limit_to_categories=category_ids) else: items += list(query) # polygon if 'Polygon' in item_types: try: q = checkDate(Q(status__in=status, categories__in=category_ids)) query = models.Polygon.objects.filter(q) if bounding_box: query = query.filter(polygon__contained=bounding_box) query = query.distinct('pk').order_by('-pk') except: return empty, zoom_need_reload if aggregated_category_ids: query = models.AggregatedPolygon.objects.filter( status__in=status, subcategory__in=aggregated_category_ids).order_by( 'subcategory', '-pk') # no bounding box filter if getjson: for poly in query.all(): items.append(json.loads(poly.getGeoJSON())) else: items += list(query) else: if getjson: current_cat, colors, idx = None, None, 0 items += models.Polygon.getGeoJSONs( query, limit_to_categories=category_ids) else: items += list(query) # routes if 'Route' in item_types: # TODO: manage non aggregated and bounding box in non-aggregated if aggregated_category_ids: query = models.AggregatedRoute.objects.filter( status__in=status, subcategory__in=category_ids).order_by( 'subcategory', '-pk') if getjson: current_cat, colors, idx = None, None, 0 for route in query.all(): color = "" # aggregated view has no color and no categories if hasattr(route, 'color') and route.color: color = route.color elif hasattr(route, 'categories'): c_cat = None for cat in route.categories.all(): if cat.id in category_ids: c_cat = cat break if c_cat and not current_cat or current_cat != c_cat: idx = 0 current_cat = c_cat colors = list(models.Color.objects.filter( color_theme=c_cat.color_theme)) if colors: color = colors[idx % len(colors)].code idx += 1 else: color = "#000" items.append(json.loads(route.getGeoJSON(color=color))) else: items += list(query) else: query = models.Route.objects.filter( status__in=status, categories__pk__in=category_ids) if getjson: current_cat, colors, idx = None, None, 0 items += models.Route.getGeoJSONs( query, limit_to_categories=category_ids) else: items += list(query) if not items: return empty, zoom_need_reload return items, zoom_need_reload def getGeoObjects(request, area_name, category_ids, status): """ Get the JSON for markers and routes """ if not status: status = 'A' status = status.split('_') category_ids = str(category_ids).split('_') bounding_box = [] for attr in ['min_lon', 'min_lat', 'max_lon', 'max_lat']: value = request.GET.get(attr, None) if not value or value == 'NaN': bounding_box = None break bounding_box.append(value) if bounding_box: bounding_box = GEOSPolygon.from_bbox(bounding_box) zoom_level = request.GET.get('zoom_level', None) if zoom_level == '0': zoom_level = None jsons, zoom_need_reload = _getGeoObjects( area_name, category_ids, status, bounding_box=bounding_box, zoom_level=zoom_level) if not jsons: return HttpResponse("[]", content_type="application/json") data = json.dumps({"type": "FeatureCollection", "features": jsons, "zoom_need_reload": zoom_need_reload or ''}) return HttpResponse(data, content_type="application/json") def getMarker(request, area_name, pk): q = models.Marker.objects.filter(pk=pk, status='A') if not q.count(): return HttpResponse('{}') data = q.all()[0].getGeoJSON() return HttpResponse(data, content_type="application/json") def get_all_categories(request, area_name=None): """ Get all available categories in JSON """ context_data, redir = get_base_response(request, area_name) area = context_data["area"] subcategories = [] if area: subcategories = list(area.getCategories( 'A', area_name=context_data['area_name'])) else: categories = models.SubCategory.getAvailable() for cat, subcats in categories: subcategories += subcats subcats = [subcat.getJSONDict() for subcat in subcategories] jsons = json.dumps({'categories': subcats}) return HttpResponse(jsons) def get_available_categories(request, area_name=None, area=None, status='A', force=None): """ Get category menu for a designed area """ context_data, redir = get_base_response(request, area_name) area = context_data["area"] if redir: return redir if area and area.dynamic_categories and \ "current_extent" not in request.GET: context_data['sub_categories'] = [] return render( request, 'chimere/blocks/categories.html', context_data) if not area or not area.dynamic_categories: # Categories are not updated dynamicaly when the user move the map # so we return ALL the categories subcategories = models.SubCategory.getAvailable( area_name=context_data['area_name']) context_data['sub_categories'] = subcategories return render( request, 'chimere/blocks/categories.html', context_data) default_message = "

%s

" % \ _("No category available in this area.") if "status" not in request.GET: # there must be a status status = 'A' try: status = status.split('_') current_extent = request.GET["current_extent"].replace('M', '-')\ .replace('D', '.') area = models.SimpleArea([float(pt) for pt in current_extent.split('_')]) except: # bad extent format return HttpResponse(default_message) # if not force and area.isIn(SimpleArea(cookie.AREA):return categories = area.getCategories( status, area_name=context_data['area_name']) if not categories: return HttpResponse(default_message) get_cat = lambda subcat: subcat.category get_cat_order = lambda subcat: (subcat.category.order, subcat.category.pk, subcat.order) categories = sorted(categories, key=get_cat_order) subcategories = [(cat, list(subcats)) for cat, subcats in groupby(categories, get_cat)] context_data['sub_categories'] = subcategories return render(request, 'chimere/blocks/categories.html', context_data) def getCategory(request, area_name='', category_id=0): """ Get the JSON for a category (mainly in order to get the description) """ try: category = models.SubCategory.objects.get(pk=category_id) except ObjectDoesNotExist: return HttpResponse('[]', content_type="application/json") return HttpResponse(category.getJSON(), content_type="application/json") def getTinyfiedUrl(request, parameters, area_name=''): """ Get the tinyfied version of parameters """ data = {"urn": "", "url": "", "text": ""} try: urn = models.TinyUrl.getUrnByParameters(parameters) except: return {} response_dct, redir = get_base_response(request, area_name) if redir: return redir url = reverse('chimere:tiny', args=[(response_dct['area_name'] if response_dct['area_name'] else '') + '/', urn]) if not url.startswith('http'): url = get_base_uri(request) + url url = re.sub("([^:])\/\/", "\g<1>/", url) current_site = get_current_site(request) map_name = current_site.name if response_dct['area']: map_name += " - " + response_dct["area"].name text = "" parameter_list = parameters.split(';') if len(parameter_list) >= 5: item_id = parameter_list[4] if item_id and "-" in item_id: cls = None if item_id.startswith('point-'): cls = models.Marker elif item_id.startswith('route-'): cls = models.Route elif item_id.startswith('polygon-'): cls = models.Polygon item_id = item_id.split("-")[1] if cls: try: text = str(cls.objects.get(id=item_id)) text = str( _("Share a point of interest on the map {}: ") ).format(map_name) + text except (cls.DoesNotExist): pass if not text: text = str( _("Share a point of interest on the map {}") ).format(map_name) data["urn"] = urlquote(urn) data["url"] = urlquote(url) data["text"] = urlquote(text) return data def redirectFromTinyURN(request, area_name='', tiny_urn=''): """ Redirect from a tiny Urn """ parameters = models.TinyUrl.getParametersByUrn(tiny_urn) detail = parameters.split(';') current_item = None if len(detail) >= 5: current_item = detail[4] response_dct, redir = get_base_response(request, area_name) if redir: return redir redir_url = response_dct['extra_url'] + "?ty={}".format(tiny_urn) if current_item: redir_url += "¤t_feature={}".format(current_item) redir_url += "#" + parameters return HttpResponseRedirect(redir_url) class CategoryDirectoryView(ListView): template_name = "chimere/category_directory.html" def get_queryset(self): self.area_name = self.kwargs.get('area_name', None) if self.area_name: self.area_name = self.area_name.split('/')[0] area = get_object_or_404(models.Area, urn=self.area_name, available=True) q = area.subcategories.filter( available=True, category__available=True).order_by( 'category__order', 'category__id', 'order') if q.count(): return q return models.SubCategory.objects.filter( available=True, category__available=True).order_by( 'category__order', 'category__id', 'order') def get_context_data(self, *args, **kwargs): context = super(CategoryDirectoryView, self).get_context_data( *args, **kwargs) new_context, redirect = get_base_response(self.request, self.area_name) context.update(new_context) context.update({ 'is_directory': True, 'actions': actions(self.area_name), 'action_selected': ('categories',), }) return context class CategoryView(CategoryDirectoryView): def get_geo_items(self): # TODO: simplify on v2.3 when slug are available category_slug = self.kwargs.get('category_slug') self.area_name = self.kwargs.get('area_name', None) q = None if self.area_name: self.area_name = self.area_name.split('/')[0] area = get_object_or_404(models.Area, urn=self.area_name, available=True) q = area.subcategories.filter(available=True, category__available=True) if not q.count(): q = None if not q: q = models.SubCategory.objects.filter(available=True, category__available=True) self.category = None for subcat in q: if defaultfilters.slugify(subcat.name) == category_slug: self.category = subcat break if not self.category: raise Http404(_("Category does not exist")) items, zoom_need_reload = _getGeoObjects( self.area_name, [str(self.category.pk)], getjson=False, item_types=('Marker',)) return items def get_context_data(self, *args, **kwargs): context = super(CategoryView, self).get_context_data( *args, **kwargs) self.items = self.get_geo_items() new_context, redirect = get_base_response(self.request, self.area_name) context.update(new_context) context.update({ 'actions': actions(self.area_name), 'action_selected': ('categories',), 'category': self.category, 'items': self.items }) return context class CategoryItemView(CategoryView): def get_context_data(self, *args, **kwargs): context = super(CategoryItemView, self).get_context_data( *args, **kwargs) try: marker = models.Marker.objects.get( pk=self.kwargs['item_id'], status='A') marker.set_properties_attributes(area_name=self.area_name) context['current_marker'] = marker context['properties'] = marker.getProperties( area_name=self.area_name) except models.Marker.DoesNotExist: pass return context def route(request, area_name, lon1, lat1, lonlat_steps, lon2, lat2, transport='foot', speed=''): """ Get the JSON for a route """ try: lon1, lat1 = float(lon1), float(lat1) lon2, lat2 = float(lon2), float(lat2) steps = [float(lonlat) for lonlat in lonlat_steps.split('_') if lonlat] # regroup by 2 steps = [(steps[i * 2], steps[i * 2 + 1]) for i in range(int(len(steps) / 2))] except ValueError: return HttpResponse('no results') # prevent incoherent transport and speed if transport not in dict(settings.CHIMERE_ROUTING_TRANSPORT): transport = settings.CHIMERE_ROUTING_TRANSPORT[0][0] if speed: speed = str(speed) available_speed = [ str(sp) for sp, lbl in settings.CHIMERE_ROUTING_SPEEDS[transport]] if speed not in available_speed: speed = None if not speed: speed = settings.CHIMERE_ROUTING_SPEEDS[transport][0][0] jsons, desc, total = router.route(lon1, lat1, lon2, lat2, steps=steps, transport=transport, speed=speed) if not jsons: return HttpResponse('no results') jsonencoder = json.JSONEncoder() total = jsonencoder.encode(total) desc = jsonencoder.encode(desc) jsondecoder = json.JSONDecoder() # get associated POIs try: route = GEOSGeometry(jsonencoder.encode( jsondecoder.decode(jsons[0])['geometry'])) except GDALException: return HttpResponse(_("Bad geometry"), status=500) cats = models.SubCategory.objects.filter(routing_warn=True) message = '' if cats.count(): st_string = '{"type":"Feature", "geometry":{ "type": "Point", '\ '"coordinates": [ %f, %f ] }, "properties":{"icon_path":"%s",'\ '"icon_width":%d, "icon_height":%d}}' points = [(m.point, m.categories.all()[0].icon) for m in list(models.Marker.objects.filter( status='A', categories__in=cats, point__distance_lte=(route, D(m=15))).all())] for pt, icon in points: st = st_string % (pt.x, pt.y, icon.image.url, icon.image.width, icon.image.height) jsons.append(st) routes = models.Route.objects.filter(status='A', categories__in=cats, route__crosses=route) intersect = False for rout in routes.intersection(route): pts = rout.intersection icon = rout.categories.all()[0].icon if hasattr(pts, 'x'): pts = [pts] if pts: pt = pts[0] st = st_string % (pt.x, pt.y, icon.image.url, icon.image.width, icon.image.height) jsons.append(st) if points or intersect: message = getattr(settings, 'CHIMERE_ROUTING_WARN_MESSAGE', '') if message: message = ', "message":%s' % jsonencoder.encode( "%s" % _(message)) else: message = '' data = '{"properties":{"transport":%s, "total":%s, "description":%s}, '\ '"type": "FeatureCollection", "features":[%s]%s}' % ( jsonencoder.encode(transport), total, desc, ",".join(jsons), message) return HttpResponse(data) def rss(request, area_name=''): ''' Redirect to RSS subscription page ''' response_dct, redir = get_base_response(request, area_name) if redir: return redir response_dct.update({'actions': actions(response_dct['area_name']), 'action_selected': ('rss',), 'category_rss_feed': ''}) # If the form has been submitted if request.method == "POST": # User has defined the kind of POI he is interested in : POI in a area # (GET method is used for the link with RSS icon in the browser) if 'rss_category' in request.POST: # User wants to follow all the new POI if request.POST['rss_category'] == 'global': feeds_link = reverse('chimere:feeds-global') return redirect(feeds_link) # User wants to follow all the new POI by category or subcategory elif request.POST['rss_category'] == 'poi': response_dct['category_rss_feed'] = 'category' response_dct['sub_categories'] = \ models.SubCategory.getAvailable() return render( request, 'chimere/feeds/rss.html', response_dct) # User wants to follow all the new POI situated in a defined area elif request.POST['rss_category'] == 'area': # An unbound form form = forms.AreaForm() area_widget = widgets.AreaWidget().render('area', None) response_dct.update({ 'map_layer': settings.CHIMERE_DEFAULT_MAP_LAYER, 'extra_head': form.media, 'form': form, 'category_rss_feed': 'area', 'area_id': models.Area.getAvailable(), 'area_widget': area_widget }) return render(request, 'chimere/feeds/rss.html', response_dct) # Error when submitting the form else: error = _("Incorrect choice in the list") response_dct.update({ 'error_message': error, 'category_rss_feed': '', 'sub_categories': models.SubCategory.getAvailable()}) return render(request, 'chimere/feeds/rss.html', response_dct) # User has specified the category or subcategory he wants to follow => # we redirect him towards the related rss feed if 'subcategory' in request.POST and request.POST['subcategory'] != '': cat_id = request.POST['subcategory'] if cat_id.find("cat_") != -1: cat_id = cat_id.split('_')[1] feeds_link = reverse('chimere:feeds-cat', kwargs={'category_id': cat_id}) return redirect(feeds_link) else: feeds_link = reverse('chimere:feeds-subcat', kwargs={'category_id': cat_id}) return redirect(feeds_link) # User has specified the ID of the area he wants to follow if 'id_area' in request.POST and request.POST['id_area'] != '': feeds_link = reverse('chimere:feeds-areaid', kwargs={'area_id': request.POST['id_area']}) return redirect(feeds_link) # User has specified the area he wants to follow => we redirect him # towards the related rss feed (using upper left and lower right # coordinates) elif 'upper_left_lat' in request.POST and \ request.POST['upper_left_lat'] != '' and \ 'upper_left_lon' in request.POST and \ request.POST['upper_left_lon'] != '' and \ 'lower_right_lon' in request.POST and \ request.POST['lower_right_lon'] != '' and \ 'lower_right_lat' in request.POST and \ request.POST['lower_right_lat'] != '': coords = request.POST['upper_left_lat'] + '_' + \ request.POST['upper_left_lon'] + '_' + \ request.POST['lower_right_lat'] + '_' + \ request.POST['lower_right_lon'] feeds_link = reverse('chimere:feeds-area', kwargs={'area': coords}) return redirect(feeds_link) # GET method is used for linking with the RSS icon in the browser when user # wants to choose a category to follow elif request.method == "GET" and 'rss_category' in request.GET: if request.GET['rss_category'] == 'global': feeds_link = reverse('chimere:feeds-global') return redirect(feeds_link) if request.GET['rss_category'] == 'poi': response_dct['category_rss_feed'] = 'category' response_dct['sub_categories'] = models.SubCategory.getAvailable( ['M', 'B']) return render(request, 'chimere/feeds/rss.html', response_dct) if request.GET['rss_category'] == 'area': # An unbound form form = forms.AreaForm() response_dct.update({ 'map_layer': settings.MAP_LAYER, 'extra_head': form.media, 'form': form, 'category_rss_feed': 'area', 'area_id': models.Area.getAvailable(), 'area_widget': widgets.AreaWidget().render('area', None)}) return render(request, 'chimere/feeds/rss.html', response_dct) # User access to the RSS tab else: return render(request, 'chimere/feeds/rss.html', response_dct) class DynCSS(TemplateView): template_name = "chimere/dyn.css" content_type = 'text/css' def get_context_data(self, **kwargs): context = super(DynCSS, self).get_context_data(**kwargs) area, area_name = get_area(context['area_name']) subcategories = models.SubCategory.getAvailable(None, area_name) context['categories'] = [] for cat, subcat in subcategories: color = "#888" if cat.color: color = cat.color context['categories'].append((cat.pk, color)) return context # from django.core.paginator import Paginator, InvalidPage def property_choice_list(request, area_name='', property_slug=''): data = {} try: pm = models.PropertyModel.objects.get(slug=property_slug, available=True) except models.PropertyModel.DoesNotExist: return HttpResponse(json.dumps(data), content_type="application/json") if not request.GET or not request.GET.get('term') or \ pm.areas.count() and not pm.areas.filter(urn=area_name).count(): return HttpResponse(json.dumps(data), content_type="application/json") fltr = {'propertymodel': pm, 'available': True, 'value__icontains': request.GET.get('term')} q = models.PropertyModelChoice.objects.filter(**fltr).order_by('value') data = [{"id": p.pk, "value": p.value} for p in q.all()] return HttpResponse(json.dumps(data), content_type="application/json") class SearchView(FormView): template_name = 'search/search.html' form_class = forms.SearchForm results_per_page = settings.SEARCH_RESULTS_PER_PAGE def get_results(self, query, area=None, page=1): results, has_next = [], False start = (page - 1) * self.results_per_page end = page * self.results_per_page - 1 for model in [models.Marker, models.Route, models.Polygon]: res, _has_next = model.search( query, area=area, get_json=True, check_next=True) results += res current_result = [] duplicate_res = [] for r in results: key = r['properties']['key'] if key in current_result: # deduplicate continue current_result.append(key) extra_icons = [] if 'extra_icons' in r['properties']: extra_icons = r['properties']['extra_icons'] duplicate_res.append(r) # duplicate for each category for extra_icon in extra_icons: data = r.copy() data['properties'] = r['properties'].copy() data['properties'].update(extra_icon) duplicate_res.append(data) results = list( sorted(duplicate_res, key=lambda x: (x['properties']['category_name'], x['properties']['name'])) ) if len(results) <= start: return [], False return results[start:end], len(results) > end def get_context_data(self, **kwargs): context = super(SearchView, self).get_context_data(**kwargs) area, area_name = get_area(self.kwargs.get('area_name', None)) query, results = None, [] previous_page_number, next_page_number = None, None if "q" in self.request.GET: query = self.request.GET['q'] try: page = int(self.request.GET.get('page', 1)) assert page >= 1 except (ValueError, AssertionError): page = 1 if page > 1: previous_page_number = page - 1 results, has_next = self.get_results(query, area, page=page) if has_next: next_page_number = page + 1 context.update({ 'query': query, 'results': results, 'area_name': area_name, 'previous_page_number': previous_page_number, 'next_page_number': next_page_number }) # (paginator, page) = self.build_page() # context.update({ 'query': self.query, }) """ if self.results and hasattr(self.results, 'query') and self.results.query.backend.include_spelling: context['suggestion'] = self.form.get_suggestion() context.update(self.extra_context()) """ return context autocomplete = None if getattr(settings, 'HAYSTACK_SEARCH_ENGINE', None): from haystack.views import SearchView as HaystackSearchView from haystack.query import SearchQuerySet class SearchView(HaystackSearchView): def extra_context(self, *args, **kwargs): context = super(SearchView, self).extra_context(*args, **kwargs) context["autocomplete"] = \ settings.HAYSTACK_AUTOCOMPLETE \ if hasattr(settings, 'HAYSTACK_AUTOCOMPLETE') else False return context def autocomplete(request): sqs = SearchQuerySet().autocomplete( content_auto=request.GET.get('q', ''))[:5] suggestions = [result.object.name for result in sqs if result.object] spelling = [] if not suggestions: spelling = SearchQuerySet().spelling_suggestion( request.GET.get('q', '')) or [] # convert to list spelling... # make sure it returns a JSON object, not a bare list. # otherwise, it could be vulnerable to an XSS attack. the_data = json.dumps({ 'results': suggestions, 'spelling': spelling, }) return HttpResponse(the_data, content_type='application/json')