forked from CGM_Public/pretix_original
Resolved flake8 warnings
This commit is contained in:
@@ -8,7 +8,7 @@ import django
|
||||
|
||||
django.setup()
|
||||
|
||||
from pretix.base.models import *
|
||||
from pretix.base.models import * # NOQA
|
||||
|
||||
if Organizer.objects.exists():
|
||||
print("There already is data in your DB!")
|
||||
|
||||
@@ -2,7 +2,7 @@ from django import forms
|
||||
from django.contrib.auth.hashers import check_password
|
||||
from django.db.models import Q
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
from pytz import common_timezones
|
||||
# from pytz import common_timezones
|
||||
|
||||
from pretix.base.models import User
|
||||
|
||||
|
||||
@@ -9,7 +9,6 @@ from django.forms import Form
|
||||
from django.http import HttpRequest
|
||||
from django.template.loader import get_template
|
||||
from django.utils.translation import ugettext_lazy as _
|
||||
from pretix.base.forms import SettingsForm
|
||||
from pretix.base.models import Order, CartPosition
|
||||
from pretix.base.services.orders import mark_order_paid
|
||||
|
||||
|
||||
@@ -65,7 +65,7 @@ class OrderError(Exception):
|
||||
pass
|
||||
|
||||
|
||||
def perform_order(event, user, payment_provider, positions):
|
||||
def check_positions(event, dt, positions, quotas_locked):
|
||||
error_messages = {
|
||||
'unavailable': _('Some of the products you selected were no longer available. '
|
||||
'Please see below for details.'),
|
||||
@@ -73,18 +73,15 @@ def perform_order(event, user, payment_provider, positions):
|
||||
'the quantity you selected. Please see below for details.'),
|
||||
'price_changed': _('The price of some of the items in your cart has changed in the '
|
||||
'meantime. Please see below for details.'),
|
||||
'busy': _('We were not able to process your request completely as the '
|
||||
'server was too busy. Please try again.'),
|
||||
'max_items': _("You cannot select more than %s items per order"),
|
||||
}
|
||||
dt = now()
|
||||
quotas_locked = set()
|
||||
err = None
|
||||
|
||||
try:
|
||||
for i, cp in enumerate(positions):
|
||||
quotas = list(cp.item.quotas.all()) if cp.variation is None else list(cp.variation.quotas.all())
|
||||
if cp.expires < dt:
|
||||
if cp.expires >= dt:
|
||||
# Other checks are not necessary
|
||||
continue
|
||||
price = cp.item.check_restrictions() if cp.variation is None else cp.variation.check_restrictions()
|
||||
if price is False or len(quotas) == 0:
|
||||
err = err or error_messages['unavailable']
|
||||
@@ -109,18 +106,28 @@ def perform_order(event, user, payment_provider, positions):
|
||||
err = err or error_messages['unavailable']
|
||||
quota_ok = False
|
||||
break
|
||||
if quota_ok:
|
||||
if not event.presale_end or now() < event.presale_end:
|
||||
if quota_ok and not event.presale_end or now() < event.presale_end:
|
||||
cp = cp.clone()
|
||||
positions[i] = cp
|
||||
cp.expires = now() + timedelta(
|
||||
minutes=event.settings.get('reservation_time', as_type=int))
|
||||
cp.save()
|
||||
else:
|
||||
elif not quota_ok:
|
||||
cp.delete() # Sorry!
|
||||
if err:
|
||||
raise OrderError(err)
|
||||
else: # Everything went well
|
||||
|
||||
|
||||
def perform_order(event, user, payment_provider, positions):
|
||||
error_messages = {
|
||||
'busy': _('We were not able to process your request completely as the '
|
||||
'server was too busy. Please try again.'),
|
||||
}
|
||||
dt = now()
|
||||
quotas_locked = set()
|
||||
|
||||
try:
|
||||
check_positions(event, dt, positions, quotas_locked)
|
||||
order = place_order(event, user, positions, dt, payment_provider)
|
||||
mail(
|
||||
user, _('Your order: %(code)s') % {'code': order.code},
|
||||
|
||||
@@ -3,7 +3,7 @@ from django import forms
|
||||
|
||||
from django.contrib import messages
|
||||
from django.db.models import Sum
|
||||
from django.forms import inlineformset_factory, formset_factory, modelformset_factory, BaseInlineFormSet
|
||||
from django.forms import modelformset_factory
|
||||
from django.shortcuts import render, redirect
|
||||
from django.utils.functional import cached_property
|
||||
from django.views.generic import FormView
|
||||
|
||||
@@ -62,9 +62,7 @@ class ImportView(EventPermissionRequiredMixin, TemplateView):
|
||||
def process_mt940(self):
|
||||
return self.confirm_view(mt940import.parse(self.request.FILES.get('file')))
|
||||
|
||||
def process_csv(self):
|
||||
if 'file' in self.request.FILES:
|
||||
# if file is csv file
|
||||
def process_csv_file(self):
|
||||
try:
|
||||
data = csvimport.get_rows_from_file(self.request.FILES['file'])
|
||||
except csv.Error as e: # TODO: narrow down
|
||||
@@ -88,7 +86,7 @@ class ImportView(EventPermissionRequiredMixin, TemplateView):
|
||||
|
||||
return self.assign_view(data)
|
||||
|
||||
elif 'amount' in self.request.POST: # CSV hint given
|
||||
def process_csv_hint(self):
|
||||
data = []
|
||||
for i in range(int(self.request.POST.get('rows'))):
|
||||
data.append([
|
||||
@@ -112,6 +110,12 @@ class ImportView(EventPermissionRequiredMixin, TemplateView):
|
||||
else:
|
||||
parsed = csvimport.parse(data, hint)
|
||||
return self.confirm_view(parsed)
|
||||
|
||||
def process_csv(self):
|
||||
if 'file' in self.request.FILES:
|
||||
return self.process_csv_file()
|
||||
elif 'amount' in self.request.POST:
|
||||
return self.process_csv_hint()
|
||||
return super().get(self.request)
|
||||
|
||||
def confirm_view(self, parsed):
|
||||
|
||||
@@ -1,7 +1,6 @@
|
||||
import logging
|
||||
from django.contrib import messages
|
||||
from django.contrib.auth.decorators import login_required
|
||||
from django.core.urlresolvers import reverse
|
||||
from django.shortcuts import redirect
|
||||
import paypalrestsdk
|
||||
from pretix.base.models import Event, Order
|
||||
|
||||
@@ -108,8 +108,11 @@ class CartAdd(EventViewMixin, CartActionMixin, View):
|
||||
|
||||
self.items = self._items_from_post_data()
|
||||
|
||||
if not self.items:
|
||||
return redirect(self.get_failure_url())
|
||||
|
||||
# We do not use EventLoginRequiredMixin here, as we want to store stuff into the
|
||||
# session beforehand
|
||||
# session before redirecting to login
|
||||
if not request.user.is_authenticated() or \
|
||||
(request.user.event is not None and request.user.event != request.event):
|
||||
request.session['cart_tmp'] = json.dumps(self.items)
|
||||
@@ -119,6 +122,13 @@ class CartAdd(EventViewMixin, CartActionMixin, View):
|
||||
'event': request.event.slug,
|
||||
}), 'next'
|
||||
)
|
||||
|
||||
existing = CartPosition.objects.current.filter(user=self.request.user, event=self.request.event).count()
|
||||
if sum(i[2] for i in self.items) + existing > int(self.request.event.settings.max_items_per_order):
|
||||
# TODO: i18n plurals
|
||||
self.error_message(self.error_messages['max_items'] % self.request.event.settings.max_items_per_order)
|
||||
return redirect(self.get_failure_url())
|
||||
|
||||
return self.process()
|
||||
|
||||
def error_message(self, msg, important=False):
|
||||
@@ -129,7 +139,7 @@ class CartAdd(EventViewMixin, CartActionMixin, View):
|
||||
def _re_add_position(self, position):
|
||||
self.items.insert(0, (position.item_id, position.variation_id, 1, position))
|
||||
|
||||
def _expired_positions(self):
|
||||
def _re_add_expired_positions(self):
|
||||
positions = set()
|
||||
# For items that are already expired, we have to delete and re-add them, as they might
|
||||
# be no longer available or prices might have changed. Sorry!
|
||||
@@ -140,25 +150,24 @@ class CartAdd(EventViewMixin, CartActionMixin, View):
|
||||
positions.add(cp)
|
||||
return positions
|
||||
|
||||
def process(self):
|
||||
def _extend_existing(self, expiry):
|
||||
# Extend this user's cart session to 30 minutes from now to ensure all items in the
|
||||
# cart expire at the same time
|
||||
# We can extend the reservation of items which are not yet expired without risk
|
||||
expiry = now() + timedelta(minutes=self.request.event.settings.get('reservation_time', as_type=int))
|
||||
CartPosition.objects.current.filter(
|
||||
Q(user=self.request.user) & Q(event=self.request.event) & Q(expires__gt=now())
|
||||
).update(expires=expiry)
|
||||
|
||||
_expired = self._expired_positions()
|
||||
def _delete_expired(self, expired):
|
||||
for cp in expired:
|
||||
if cp.version_end_date is None:
|
||||
cp.delete()
|
||||
|
||||
if not self.items:
|
||||
return redirect(self.get_failure_url())
|
||||
def process(self):
|
||||
expiry = now() + timedelta(minutes=self.request.event.settings.get('reservation_time', as_type=int))
|
||||
self._extend_existing(expiry)
|
||||
|
||||
existing = CartPosition.objects.current.filter(user=self.request.user, event=self.request.event).count()
|
||||
if sum(i[2] for i in self.items) + existing > int(self.request.event.settings.max_items_per_order):
|
||||
# TODO: i18n plurals
|
||||
self.error_message(self.error_messages['max_items'] % self.request.event.settings.max_items_per_order)
|
||||
return redirect(self.get_failure_url())
|
||||
_expired = self._re_add_expired_positions()
|
||||
|
||||
# Fetch items from the database
|
||||
items_cache = {
|
||||
@@ -244,9 +253,7 @@ class CartAdd(EventViewMixin, CartActionMixin, View):
|
||||
for quota in quotas:
|
||||
quota.release()
|
||||
|
||||
for cp in _expired:
|
||||
if cp.version_end_date is None:
|
||||
cp.delete()
|
||||
self._delete_expired(_expired)
|
||||
|
||||
if not self.msg_some_unavailable:
|
||||
messages.success(self.request, _('The products have been successfully added to your cart.'))
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
from django.utils.timezone import now
|
||||
from pretix.base.models import User
|
||||
from tests.base import BrowserTest
|
||||
|
||||
|
||||
@@ -1,4 +1,3 @@
|
||||
import datetime
|
||||
import time
|
||||
from pretix.base.models import User
|
||||
from tests.base import BrowserTest
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
from pretix.settings import *
|
||||
from pretix.settings import * # NOQA
|
||||
|
||||
TEST_DIR = os.path.dirname(__file__)
|
||||
|
||||
|
||||
@@ -12,7 +12,7 @@ class TestDummyApp(AppConfig):
|
||||
version = '1.0.0'
|
||||
|
||||
def ready(self):
|
||||
from tests.testdummy import signals
|
||||
from tests.testdummy import signals # noqa
|
||||
|
||||
|
||||
default_app_config = 'tests.testdummy.TestDummyApp'
|
||||
|
||||
Reference in New Issue
Block a user