def speaker_create_token(request, token):
speaker = get_object_or_404(Speaker, invite_token=token)
request.session["pending-token"] = token
if request.user.is_authenticated():
# check for speaker profile
try:
existing_speaker = request.user.speaker_profile
except ObjectDoesNotExist:
pass
else:
del request.session["pending-token"]
additional_speakers = ProposalBase.additional_speakers.through
additional_speakers._default_manager.filter(
speaker=speaker
).update(
speaker=existing_speaker
)
messages.info(request, "You have been associated with all pending "
"talk proposals")
return redirect("dashboard")
else:
if not request.user.is_authenticated():
return redirect("account_login")
return redirect("speaker_create")
python类info()的实例源码
def register(request):
form = RegistrationForm()
if request.method == 'POST':
form = RegistrationForm(request.POST)
if form.is_valid():
form.save()
messages.info(
request,
'Kayit basarili. Simdi login olabilirsiniz.'
)
return redirect('login')
return render(request, 'register.html', {
'form': form,
})
def login(request):
form = LoginForm()
if request.method == 'POST':
form = LoginForm(request.POST)
if form.is_valid():
auth_login(request, form.user)
messages.info(
request,
'Giris yaptiniz.'
)
if request.GET.get('next'):
return redirect(request.GET['next'])
return render(request, 'login.html', {
'form': form
})
def new_place(request):
form = PlaceCreationForm()
if request.method == "POST":
form = PlaceCreationForm(request.POST)
if form.is_valid():
form.instance.user = request.user
form.save()
messages.info(
request,
'Tebrikler. Yer bildiriminiz ba?ar?yla al?nd?. '
'Editör onay?ndan geçtikten sonra yay?nlanacakt?r.'
)
return redirect('/')
return render(
request,
'new_place.html',
{
'form': form,
}
)
def get_canonical_language_list(language_list=None, request=None):
"""Returns a LanguageList object"""
try:
if language_list is None:
language_list = LanguageList.objects.get(name=LanguageList.DEFAULT)
elif language_list.isdigit():
language_list = LanguageList.objects.get(id=language_list)
else:
language_list = LanguageList.objects.get(name=language_list)
except LanguageList.DoesNotExist:
if request:
messages.info(
request,
"There is no language list matching"
" '%s' in the database" % language_list)
raise Http404
return language_list
def get_canonical_meaning_list(meaning_list=None, request=None):
"""Returns a MeaningList object"""
try:
if meaning_list is None:
meaning_list = MeaningList.objects.get(name=MeaningList.DEFAULT)
elif meaning_list.isdigit():
meaning_list = MeaningList.objects.get(id=meaning_list)
else:
meaning_list = MeaningList.objects.get(name=meaning_list)
except MeaningList.DoesNotExist:
if request:
messages.info(
request,
"There is no meaning list matching"
" '%s' in the database" % meaning_list)
raise Http404
return meaning_list
def handle(self, request):
language = Language.objects.get(ascii_name=self.data['language'])
meanings = Meaning.objects.exclude(
id__in=set(Lexeme.objects.filter(
language=language).values_list(
'meaning_id', flat=True))).all()
if meanings:
with transaction.atomic():
for m in meanings:
Lexeme.objects.create(language=language, meaning=m)
messages.info(
request,
"Added lexemes for meanings: " +
", ".join([m.gloss for m in meanings]))
else:
messages.info(
request,
'There is at least one lexeme '
'for every meaning in the database.')
def remove(request, device_id):
device_qs = (
twofa.models.Device.objects
.active_for_user(request.user).select_subclasses())
device = get_object_or_404(device_qs, pk=device_id)
if not device.can_delete():
messages.error(
request, _('The "%(auth_name)s" authenticator cannot be removed.') % {'auth_name': device.name()})
return redirect('twofa:list')
device.deleted_at = timezone.now()
device.save()
messages.success(
request, _('The "%(auth_name)s" authenticator has been removed from your account.') % {
'auth_name': device.name()})
if not twofa.models.Device.objects.active_for_user(request.user).exclude_backup().exists():
request.user.twofa_enabled = False
request.user.save()
messages.info(
request, _('Since you removed the last authenticator from your account, '
'two-factor authentication has now been disabled.'))
return redirect('twofa:list')
def verify_step2(request, uidb64, token):
bytes_uid = urlsafe_base64_decode(uidb64)
try:
uid = int(bytes_uid)
except ValueError:
raise SuspiciousOperation('verify_step2 received invalid base64 user ID: {}'.format(
bytes_uid))
if uid != request.user.id:
raise PermissionDenied('UID mismatch - user is {}, request was for {}'.format(
request.user.id, uid))
user = get_object_or_404(models.User, pk=uid)
if not verify_token_generator.check_token(user, token):
raise Http404('token invalid')
if not user.email_verified:
user.email_verified = True
user.save()
messages.success(request, _('Your email has been verified successfully. Thanks!'))
else:
messages.info(request, _('Your email address has already been verified.'))
return redirect('index')
def delete_job(request, queue_index, job_id):
queue_index = int(queue_index)
queue = get_queue_by_index(queue_index)
job = Job.fetch(job_id, connection=queue.connection)
if request.method == 'POST':
# Remove job id from queue and delete the actual job
queue.connection._lrem(queue.key, 0, job.id)
job.delete()
messages.info(request, _('You have successfully deleted %s') % job.id)
return redirect('rq_jobs', queue_index)
context_data = admin.site.each_context(request)
context_data.update({
'title': _("Delete Job"),
'queue_index': queue_index,
'job': job,
'queue': queue,
})
return render(request, 'django_rq/delete_job.html', context_data)
def requeue_job_view(request, queue_index, job_id):
queue_index = int(queue_index)
queue = get_queue_by_index(queue_index)
job = Job.fetch(job_id, connection=queue.connection)
if request.method == 'POST':
requeue_job(job_id, connection=queue.connection)
messages.info(request, _('You have successfully requeued %s') % job.id)
return redirect('rq_job_detail', queue_index, job_id)
context_data = {
'queue_index': queue_index,
'job': job,
'queue': queue,
}
return render(request, 'django_rq/delete_job.html', context_data)
def clear_queue(request, queue_index):
queue_index = int(queue_index)
queue = get_queue_by_index(queue_index)
if request.method == 'POST':
try:
queue.empty()
messages.info(request, _('You have successfully cleared the queue %s') % queue.name)
except ResponseError as e:
if 'EVALSHA' in e.message:
messages.error(request,
_('This action is not supported on Redis versions < 2.6.0, '
'please use the bulk delete command instead'))
else:
raise e
return redirect('rq_jobs', queue_index)
context_data = admin.site.each_context(request)
context_data.update({
'title': _("Clear Queue"),
'queue_index': queue_index,
'queue': queue,
})
return render(request, 'django_rq/clear_queue.html', context_data)
def requeue_all(request, queue_index):
queue_index = int(queue_index)
queue = get_queue_by_index(queue_index)
jobs = queue.get_jobs()
if request.method == 'POST':
# Confirmation received
for job in jobs:
requeue_job(job.id, connection=queue.connection)
messages.info(request, _('You have successfully requeued all %d jobs!') % len(jobs))
return redirect('rq_jobs', queue_index)
context_data = admin.site.each_context(request)
context_data.update({
'title': _("Requeue All"),
'queue_index': queue_index,
'queue': queue,
'total_jobs':len(jobs),
})
return render(request, 'django_rq/requeue_all.html', context_data)
def add_view(self, request, form_url='', extra_context=None):
language = request.GET.get('language')
draft_pk = request.GET.get('draft')
page = get_object_or_404(Page, pk=draft_pk)
# check if the current user may view the revision
# -> if the user may see the page
user = get_current_user()
if not user_can_change_page(user, page):
messages.error(request, _('Missing permission to edit this page which is necessary in order to create a '
'page version.'))
prev = request.META.get('HTTP_REFERER')
if prev:
return redirect(prev)
else:
raise Http404
if page.page_versions.filter(active=True, dirty=False, language=language).count() > 0:
messages.info(request, _('This page is already revised.'))
return self.render_close_frame()
return super(PageVersionAdmin, self).add_view(request, form_url=form_url, extra_context=extra_context)
def detail(request, pk, template_name=None, ext_ctx={}):
instance = ProcessInstance.objects.get(pk=pk)
views = import_wf_views(instance.process.code)
is_print = ext_ctx.get('is_print')
__ext_param_process = getattr(views, '__ext_param_process', None)
ctx = {}
ctx.update(ext_ctx)
if not can_view_wf(instance, request.user, ext_param_process=__ext_param_process):
messages.info(request, 'No permission to view this process')
return redirect(reverse('wf_my_wf'))
user_wf_info = user_wf_info_as_dict(instance.content_object, request.user)
ctx.update(user_wf_info)
if not is_print and instance.cur_node.can_edit \
and instance.cur_node.audit_view_type == 'edit' \
and ext_ctx['task'] and instance.cur_node.resolution == 'started':
return redirect(reverse('wf_edit', args=[instance.pk]))
detail_func = getattr(views, 'detail', _default_detail)
ret = detail_func(request, instance, ext_ctx=ctx)
if isinstance(ret, dict):
ret.update(ctx)
return _default_detail(request, instance, ret, template_name)
return ret
def upload_file_to_part(request, part_id):
try:
part = Part.objects.get(id=part_id)
except ObjectDoesNotExist:
messages.error(request, "No part found with given part_id.")
return HttpResponseRedirect(reverse('error'))
if request.method == 'POST':
form = FileForm(request.POST, request.FILES)
if form.is_valid():
partfile = PartFile(file=request.FILES['file'], part=part)
partfile.save()
return HttpResponseRedirect(reverse('part-info', kwargs={'part_id': part_id}) + '#specs')
messages.error(request, "Error uploading file.")
return HttpResponseRedirect(reverse('error'))
def volunteer_email(request):
volunteers = Volunteer.objects.filter(pk__in=request.session.get('volunteer-email-list', []))
if not volunteers.exists():
messages.error(request, _('Please select some volunteers.'))
return redirect('volunteer-list')
form = SendVolunteerMailForm(request.POST or None, initial=request.session.get('volunteer-email-stored'), volunteers=volunteers)
if request.method == 'POST' and form.is_valid():
subject = form.cleaned_data['subject']
body = form.cleaned_data['body']
request.session['volunteer-email-stored'] = {'subject': subject, 'body': body}
if form.cleaned_data['confirm']:
sent = volunteer_email_send(volunteers, subject, body)
messages.success(request, _('%(count)d mails have been sent.') % {'count': sent})
del request.session['volunteer-email-list']
return redirect('volunteer-list')
else:
messages.info(request, _('Your ready to send %(count)d emails.') % {'count': volunteers.count()})
else:
form.fields.pop('confirm')
return render(request, 'cfp/staff/volunteer_email.html', {
'volunteers': volunteers,
'form': form,
})
def talk_email(request):
talks = Talk.objects.filter(pk__in=request.session.get('talk-email-list', []))
count = talks.annotate(speakers_count=Count('speakers', distinct=True)).aggregate(Sum('speakers_count'))['speakers_count__sum']
if not talks.exists():
messages.error(request, _('Please select some talks.'))
return redirect('talk-list')
form = SendTalkMailForm(request.POST or None, initial=request.session.get('talk-email-stored'), talks=talks)
if request.method == 'POST' and form.is_valid():
subject = form.cleaned_data['subject']
body = form.cleaned_data['body']
request.session['talk-email-stored'] = {'subject': subject, 'body': body}
if form.cleaned_data['confirm']:
sent = talk_email_send(talks, subject, body)
messages.success(request, _('%(count)d mails have been sent.') % {'count': sent})
del request.session['talk-email-list']
return redirect('talk-list')
else:
messages.info(request, _('Your ready to send %(count)d emails.') % {'count': count})
else:
form.fields.pop('confirm')
return render(request, 'cfp/staff/talk_email.html', {
'talks': talks,
'form': form,
})
def speaker_email(request):
speakers = Participant.objects.filter(pk__in=request.session.get('speaker-email-list', []))
if not speakers.exists():
messages.error(request, _('Please select some speakers.'))
return redirect('participant-list')
form = SendSpeakerMailForm(request.POST or None, initial=request.session.get('speaker-email-stored'), speakers=speakers)
if request.method == 'POST' and form.is_valid():
subject = form.cleaned_data['subject']
body = form.cleaned_data['body']
request.session['speaker-email-stored'] = {'subject': subject, 'body': body}
if form.cleaned_data['confirm']:
sent = speaker_email_send(speakers, subject, body)
messages.success(request, _('%(count)d mails have been sent.') % {'count': sent})
del request.session['speaker-email-list']
return redirect('participant-list')
else:
messages.info(request, _('Your ready to send %(count)d emails.') % {'count': speakers.count()})
else:
form.fields.pop('confirm')
return render(request, 'cfp/staff/speaker_email.html', {
'speakers': speakers,
'form': form,
})
def post(self, request, *args, **kwargs):
form = self.form_class(request.POST, initial={'email' : request.user.email, 'about' : request.user.userprofile.about})
if form.is_valid():
if form.has_changed():
user = request.user
for field in form.changed_data:
if field == 'email':
if form.cleaned_data[field] != '' and User.objects.filter(email=form.cleaned_data[field]).exclude(id=user.id).exists():
messages.error(request, "Email address is already in use")
return redirect(reverse('ploghubapp:profile'))
setattr(user, field, form.cleaned_data[field])
user.save()
user.userprofile.about = form.cleaned_data['about']
user.userprofile.save()
messages.success(request, "Profile has been updated")
return redirect(reverse('ploghubapp:profile'))
else:
messages.info(request, "Data has not been changed")
return redirect(reverse('ploghubapp:profile'))
else:
messages.error(request, "Invalid form data")
return redirect(reverse('ploghubapp:profile'))
def index(request):
signupForm = SignupForm()
signinForm = SigninForm()
context = {
'signupForm': signupForm,
'signinForm': signinForm,
'message': messages.debug(request, 'Bleh!')
}
# messages.debug(request, '%s SQL statements were executed.' % count)
# messages.info(request, 'Three credits remain in your account.')
# messages.success(request, 'Profile details updated.')
# messages.warning(request, 'Your account expires in three days.')
# messages.error(request, 'Bleh!')
return render(request, 'user/index.html', context)
def form_valid(self, form):
form.save()
permission = self.object
user = User.objects.get(pk=form.cleaned_data.get('user_id'))
perm = EventPermission.objects.filter(user=user, event=permission.event).exclude(pk=permission.pk).first()
event = permission.event
if perm:
if permission.is_orga:
perm.is_orga = True
if permission.is_reviewer:
perm.is_reviewer = True
perm.save()
permission.delete()
permission = perm
permission.user = user
permission.save()
permission.event.log_action('pretalx.invite.orga.accept', person=user, orga=True)
messages.info(self.request, _('You are now part of the event team!'))
login(self.request, user, backend='django.contrib.auth.backends.ModelBackend')
return redirect(event.orga_urls.base)
def add_sub_stage(request, pk=None):
stage = get_object_or_404(
Stage, pk=pk)
if request.method == 'POST':
form = AddSubSTageForm(data=request.POST, request=request)
if form.is_valid():
child_stage = form.save(commit=False)
child_stage.stage = stage
child_stage.project = stage.project
child_stage.site = stage.site
child_stage.group = stage.group
child_stage.save()
form = int(form.cleaned_data.get('form',0))
if form:
if stage.site:
FieldSightXF.objects.create(xf_id=form, is_staged=True, stage=child_stage,site=stage.site)
else:
FieldSightXF.objects.create(xf_id=form, is_staged=True, stage=child_stage,project=stage.project)
messages.info(request, 'Sub Stage {} Saved.'.format(child_stage.name))
return HttpResponseRedirect(reverse("forms:stages-detail", kwargs={'pk': stage.id}))
order = Stage.objects.filter(stage=stage).count() + 1
instance = Stage(name="Sub Stage"+str(order), order=order)
form = AddSubSTageForm(instance=instance, request=request)
return render(request, "fsforms/add_sub_stage.html", {'form': form, 'obj': stage})
def project_edit_schedule(request, id):
schedule = get_object_or_404(
Schedule, pk=id)
if request.method == 'POST':
form = ScheduleForm(data=request.POST, instance=schedule, request=request)
if form.is_valid():
form.save()
xf = int(form.cleaned_data.get('form', 0))
if xf:
if FieldSightXF.objects.filter(project=schedule.project, schedule=schedule, is_scheduled=True).exists():
fs_xform = FieldSightXF.objects.get(project=schedule.project, schedule=schedule, is_scheduled=True)
if fs_xform.xf.id != xf:
fs_xform.xf_id = xf
fs_xform.save()
else:
FieldSightXF.objects.create(
xf_id=xf, is_scheduled=True,schedule=schedule,project=schedule.project, is_deployed=True)
messages.info(request, 'Schedule {} Saved.'.format(schedule.name))
return HttpResponseRedirect(reverse("forms:project-survey", kwargs={'project_id': schedule.project.id}))
form = ScheduleForm(instance=schedule, request=request)
if FieldSightXF.objects.filter(schedule=schedule).exists():
if FieldSightXF.objects.get(schedule=schedule).xf:
form.fields['form'].initial= FieldSightXF.objects.get(schedule=schedule).xf.id
return render(request, "fsforms/schedule_form.html",
{'form': form, 'obj': schedule.project, 'is_project':True, 'is_general':False, 'is_edit':True})
def deploy_stages(request, id):
project = Project(pk=id)
sites = project.sites.all()
main_stages = project.stages.filter(stage__isnull=True)
with transaction.atomic():
Stage.objects.filter(site__project=project).delete()
FieldSightXF.objects.filter(is_staged=True, site__project=project).delete()
for main_stage in main_stages:
for site in sites:
send_message_stages(site)
site_main_stage = Stage(name=main_stage.name, order=main_stage.order, site=site,
description=main_stage.description)
site_main_stage.save()
project_sub_stages = Stage.objects.filter(stage__id=main_stage.pk)
for project_sub_stage in project_sub_stages:
site_sub_stage = Stage(name=project_sub_stage.name, order=project_sub_stage.order, site=site,
description=project_sub_stage.description, stage=site_main_stage)
site_sub_stage.save()
if FieldSightXF.objects.filter(stage=project_sub_stage).exists():
fsxf = FieldSightXF.objects.filter(stage=project_sub_stage)[0]
FieldSightXF.objects.get_or_create(is_staged=True, xf=fsxf.xf, site=site,
fsform=fsxf, stage=site_sub_stage, is_deployed=True)
messages.info(request, 'Stages Form Deployed to Sites')
return HttpResponseRedirect(reverse("forms:setup-project-stages", kwargs={'id': id}))
def fill_form_type(request, pk=None):
field_sight_form = get_object_or_404(
FieldSightXF, pk=pk)
if request.method == 'POST':
form = FormTypeForm(request.POST)
if form.is_valid():
form_type = form.cleaned_data.get('form_type', '3')
form_type = int(form_type)
messages.info(request, 'Form Type Saved.')
if form_type == 3:
return HttpResponseRedirect(reverse("forms:library-forms-list"))
elif form_type == 2:
field_sight_form.is_scheduled = True
field_sight_form.save()
return HttpResponseRedirect(reverse("forms:fill_details_schedule", kwargs={'pk': field_sight_form.id}))
else:
field_sight_form.is_staged = True
field_sight_form.save()
return HttpResponseRedirect(reverse("forms:fill_details_stage", kwargs={'pk': field_sight_form.id}))
else:
form = FormTypeForm()
return render(request, "fsforms/stage_or_schedule.html", {'form': form, 'obj': field_sight_form})
def dispatch(self, request, *args, **kwargs):
'''
Require session data to be set to proceed, otherwise go back to step 1.
Because they have the same expiration date, this also implies that the
TemporaryRegistration object is not yet expired.
'''
if REG_VALIDATION_STR not in request.session:
return HttpResponseRedirect(reverse('registration'))
try:
self.temporaryRegistration = TemporaryRegistration.objects.get(
id=self.request.session[REG_VALIDATION_STR].get('temporaryRegistrationId')
)
except ObjectDoesNotExist:
messages.error(request,_('Invalid registration identifier passed to sign-up form.'))
return HttpResponseRedirect(reverse('registration'))
expiry = parse_datetime(
self.request.session[REG_VALIDATION_STR].get('temporaryRegistrationExpiry',''),
)
if not expiry or expiry < timezone.now():
messages.info(request,_('Your registration session has expired. Please try again.'))
return HttpResponseRedirect(reverse('registration'))
return super(StudentInfoView,self).dispatch(request,*args,**kwargs)
def dispatch(self,request,*args,**kwargs):
'''
Handle the session data passed by the prior view.
'''
lessonSession = request.session.get(PRIVATELESSON_VALIDATION_STR,{})
try:
self.lesson = PrivateLessonEvent.objects.get(id=lessonSession.get('lesson'))
except (ValueError, ObjectDoesNotExist):
messages.error(request,_('Invalid lesson identifier passed to sign-up form.'))
return HttpResponseRedirect(reverse('bookPrivateLesson'))
expiry = parse_datetime(lessonSession.get('expiry',''),)
if not expiry or expiry < timezone.now():
messages.info(request,_('Your registration session has expired. Please try again.'))
return HttpResponseRedirect(reverse('bookPrivateLesson'))
self.payAtDoor = lessonSession.get('payAtDoor',False)
return super(PrivateLessonStudentInfoView,self).dispatch(request,*args,**kwargs)
def form_valid(self, form):
data = form.clean()
if data.get('file_field'):
rules = data['file_field'].read().decode('utf8')
elif data.get('rules'):
rules = data.get('rules')
else:
messages.warning(self.request, 'Missing rules')
return self.form_invalid(form)
try:
counters = prometheus.import_rules(rules)
messages.info(self.request, 'Imported %s' % counters)
return redirect('rule-import')
except:
messages.error(self.request, 'Error importing rules')
return self.form_invalid(form)
def event_does_not_exist( request, event_id, redirect_url ): # {{{1
""" if event_id was deleted it shows event redirection or deleted page,
otherwise raises 404 """
try:
deleted_version = reversion.get_deleted(Event).get(object_id=event_id)
except Version.DoesNotExist:
raise Http404
revision_meta = deleted_version.revision.revisioninfo_set.all()
assert( len( revision_meta ) == 1 )
redirect = revision_meta[0].redirect
if redirect:
messages.info( request,
_( u'redirected from deleted event %(event_nr)s' ) % \
{'event_nr': event_id} )
return HttpResponseRedirect( reverse( redirect_url,
kwargs = {'event_id': redirect,} ) )
else:
messages.info( request,
_('You have tried to access an event which has been deleted.'))
return HttpResponseRedirect( reverse(
'event_deleted', kwargs = { 'event_id': event_id } ) )
