707 lines
25 KiB
Python
707 lines
25 KiB
Python
import uuid
|
|
|
|
import requests
|
|
from django.contrib.auth import get_user_model
|
|
from django.db import models
|
|
|
|
# Create your models here.
|
|
from django.db.models import Q
|
|
from django.db.models.signals import post_save, pre_save
|
|
from django.dispatch import receiver
|
|
from django.utils import timezone
|
|
from solo.models import SingletonModel
|
|
from django.utils.translation import ugettext_lazy as _
|
|
from stdimage import StdImageField
|
|
from stdimage.validators import MaxSizeValidator
|
|
from django.db import connection
|
|
|
|
from PaiementStripe.models import Paiement_stripe
|
|
from QrcodeCashless.models import CarteCashless
|
|
from TiBillet import settings
|
|
import stripe
|
|
|
|
import logging
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class OptionGenerale(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False, unique=True, db_index=True)
|
|
name = models.CharField(max_length=30)
|
|
poids = models.PositiveSmallIntegerField(default=0, verbose_name=_("Poids"))
|
|
|
|
def __str__(self):
|
|
return self.name
|
|
|
|
class Meta:
|
|
ordering = ('poids',)
|
|
verbose_name = _('Options Generales')
|
|
verbose_name_plural = _('Options Generales')
|
|
|
|
|
|
@receiver(post_save, sender=OptionGenerale)
|
|
def poids_option_generale(sender, instance: OptionGenerale, created, **kwargs):
|
|
if created:
|
|
# poids d'apparition
|
|
if instance.poids == 0:
|
|
instance.poids = len(OptionGenerale.objects.all()) + 1
|
|
|
|
instance.save()
|
|
|
|
|
|
class Configuration(SingletonModel):
|
|
organisation = models.CharField(max_length=50, verbose_name=_("Nom de l'organisation"))
|
|
short_description = models.CharField(max_length=250, verbose_name=_("Description courte"))
|
|
|
|
adress = models.CharField(max_length=250)
|
|
phone = models.CharField(max_length=20)
|
|
email = models.EmailField()
|
|
|
|
site_web = models.URLField(blank=True, null=True)
|
|
|
|
twitter = models.URLField(blank=True, null=True)
|
|
facebook = models.URLField(blank=True, null=True)
|
|
instagram = models.URLField(blank=True, null=True)
|
|
|
|
adhesion_obligatoire = models.BooleanField(default=False)
|
|
|
|
name_required_for_ticket = models.BooleanField(default=False, verbose_name=_("Billet nominatifs"))
|
|
|
|
carte_restaurant = StdImageField(upload_to='images/',
|
|
null=True, blank=True,
|
|
validators=[MaxSizeValidator(1920, 1920)],
|
|
variations={
|
|
'fhd': (1920, 1920),
|
|
'hdr': (720, 720),
|
|
'med': (480, 480),
|
|
'thumbnail': (150, 90),
|
|
},
|
|
delete_orphans=True,
|
|
verbose_name=_('Carte du restaurant')
|
|
)
|
|
|
|
img = StdImageField(upload_to='images/',
|
|
null=True, blank=True,
|
|
# validators=[MaxSizeValidator(1920, 1920)],
|
|
variations={
|
|
'fhd': (1920, 1920),
|
|
'hdr': (720, 720),
|
|
'med': (480, 480),
|
|
'thumbnail': (150, 90),
|
|
},
|
|
delete_orphans=True,
|
|
verbose_name='Background'
|
|
)
|
|
|
|
mollie_api_key = models.CharField(max_length=50,
|
|
blank=True, null=True)
|
|
|
|
stripe_api_key = models.CharField(max_length=110, blank=True, null=True)
|
|
stripe_test_api_key = models.CharField(max_length=110, blank=True, null=True)
|
|
stripe_mode_test = models.BooleanField(default=True)
|
|
|
|
activer_billetterie = models.BooleanField(default=True, verbose_name=_("Activer la billetterie"))
|
|
|
|
jauge_max = models.PositiveSmallIntegerField(default=50, verbose_name=_("Jauge maximale"))
|
|
|
|
option_generale_radio = models.ManyToManyField(OptionGenerale,
|
|
blank=True,
|
|
related_name="radiobutton")
|
|
|
|
option_generale_checkbox = models.ManyToManyField(OptionGenerale,
|
|
blank=True,
|
|
related_name="checkbox")
|
|
|
|
server_cashless = models.URLField(
|
|
max_length=300,
|
|
blank=True,
|
|
null=True,
|
|
verbose_name=_("Adresse du serveur Cashless")
|
|
)
|
|
|
|
key_cashless = models.CharField(
|
|
max_length=41,
|
|
blank=True,
|
|
null=True,
|
|
verbose_name=_("Clé d'API du serveur cashless")
|
|
)
|
|
|
|
|
|
class Product(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False, unique=True, db_index=True)
|
|
|
|
name = models.CharField(max_length=50)
|
|
|
|
publish = models.BooleanField(default=False)
|
|
|
|
img = StdImageField(upload_to='images/',
|
|
null=True, blank=True,
|
|
validators=[MaxSizeValidator(1920, 1920)],
|
|
variations={
|
|
'fhd': (1920, 1920),
|
|
'hdr': (720, 720),
|
|
'med': (480, 480),
|
|
'thumbnail': (150, 90),
|
|
},
|
|
delete_orphans=True,
|
|
verbose_name='Image'
|
|
)
|
|
|
|
BILLET, PACK, RECHARGE_CASHLESS, VETEMENT, MERCH, ADHESION = 'B', 'P', 'R', 'T', 'M', 'A'
|
|
TYPE_CHOICES = [
|
|
(BILLET, _('Billet')),
|
|
(PACK, _("Pack d'objets")),
|
|
(RECHARGE_CASHLESS, _('Recharge cashless')),
|
|
(VETEMENT, _('Vetement')),
|
|
(MERCH, _('Merchandasing')),
|
|
(ADHESION, ('Adhésion')),
|
|
]
|
|
|
|
categorie_article = models.CharField(max_length=3, choices=TYPE_CHOICES, default=BILLET,
|
|
verbose_name=_("Type d'article"))
|
|
|
|
id_product_stripe = models.CharField(max_length=30, null=True, blank=True)
|
|
|
|
def __str__(self):
|
|
return f"{self.name}"
|
|
|
|
def get_id_product_stripe(self):
|
|
configuration = Configuration.get_solo()
|
|
if configuration.stripe_api_key and not self.id_product_stripe:
|
|
if configuration.stripe_mode_test:
|
|
stripe.api_key = configuration.stripe_test_api_key
|
|
else:
|
|
stripe.api_key = configuration.stripe_api_key
|
|
|
|
if self.img:
|
|
# noinspection PyUnresolvedReferences
|
|
domain_url = connection.tenant.domains.all()[0].domain
|
|
# noinspection PyUnresolvedReferences
|
|
images = [f"https://{domain_url}{self.img.med.url}", ]
|
|
else:
|
|
images = []
|
|
|
|
product = stripe.Product.create(
|
|
name=f"{self.name}",
|
|
images=images
|
|
)
|
|
self.id_product_stripe = product.id
|
|
self.save()
|
|
|
|
return self.id_product_stripe
|
|
|
|
elif self.id_product_stripe:
|
|
return self.id_product_stripe
|
|
else:
|
|
return False
|
|
|
|
def reset_id_stripe(self):
|
|
self.id_product_stripe = None
|
|
self.save()
|
|
|
|
|
|
class Price(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False, unique=True, db_index=True)
|
|
|
|
product = models.ForeignKey(Product, on_delete=models.PROTECT, related_name="prices")
|
|
|
|
name = models.CharField(max_length=50)
|
|
prix = models.FloatField()
|
|
|
|
NA, DIX, VINGT = 'NA', 'DX', 'VG'
|
|
TVA_CHOICES = [
|
|
(NA, _('Non applicable')),
|
|
(DIX, _("10 %")),
|
|
(VINGT, _('20 %')),
|
|
]
|
|
|
|
vat = models.CharField(max_length=2,
|
|
choices=TVA_CHOICES,
|
|
default=NA,
|
|
verbose_name=_("Taux TVA"),
|
|
)
|
|
|
|
id_price_stripe = models.CharField(max_length=30, null=True, blank=True)
|
|
|
|
stock = models.SmallIntegerField(blank=True, null=True)
|
|
max_per_user = models.PositiveSmallIntegerField(default=10)
|
|
|
|
def range_max(self):
|
|
return range(self.max_per_user + 1)
|
|
|
|
def __str__(self):
|
|
return f"{self.product.name} {self.name}"
|
|
|
|
def get_id_price_stripe(self):
|
|
configuration = Configuration.get_solo()
|
|
if configuration.stripe_api_key and not self.id_price_stripe:
|
|
if configuration.stripe_mode_test:
|
|
stripe.api_key = configuration.stripe_test_api_key
|
|
else:
|
|
stripe.api_key = configuration.stripe_api_key
|
|
|
|
price = stripe.Price.create(
|
|
unit_amount=int("{0:.2f}".format(self.prix).replace('.', '')),
|
|
currency="eur",
|
|
product=self.product.get_id_product_stripe(),
|
|
nickname=self.name,
|
|
)
|
|
|
|
self.id_price_stripe = price.id
|
|
self.save()
|
|
return self.id_price_stripe
|
|
|
|
elif self.id_price_stripe:
|
|
return self.id_price_stripe
|
|
else:
|
|
return False
|
|
|
|
def reset_id_stripe(self):
|
|
self.id_price_stripe = None
|
|
self.save()
|
|
|
|
|
|
class Event(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False, unique=True, db_index=True)
|
|
|
|
name = models.CharField(max_length=200)
|
|
datetime = models.DateTimeField()
|
|
|
|
short_description = models.CharField(max_length=250)
|
|
long_description = models.TextField(blank=True, null=True)
|
|
|
|
products = models.ManyToManyField(Product, blank=True)
|
|
|
|
img = StdImageField(upload_to='images/',
|
|
validators=[MaxSizeValidator(1920, 1920)],
|
|
variations={
|
|
'fhd': (1920, 1920),
|
|
'hdr': (1280, 1280),
|
|
'crop': (510, 310, True),
|
|
},
|
|
delete_orphans=True
|
|
)
|
|
|
|
reservations = models.PositiveSmallIntegerField(default=0)
|
|
|
|
CONCERT = "LIV"
|
|
FESTIVAL = "FES"
|
|
REUNION = "REU"
|
|
CONFERENCE = "CON"
|
|
TYPE_CHOICES = [
|
|
(CONCERT, _('Concert')),
|
|
(FESTIVAL, _('Festival')),
|
|
(REUNION, _('Réunion')),
|
|
(CONFERENCE, _('Conférence')),
|
|
]
|
|
|
|
categorie = models.CharField(max_length=3, choices=TYPE_CHOICES, default=CONCERT,
|
|
verbose_name=_("Catégorie d'évènement"))
|
|
|
|
def complet(self):
|
|
# TODO: Benchmarker et tester si c'est pas mieux dans template
|
|
if self.reservations >= Configuration.get_solo().jauge_max:
|
|
return True
|
|
else:
|
|
return False
|
|
|
|
def __str__(self):
|
|
return f"{self.datetime.strftime('%d/%m')} {self.name}"
|
|
|
|
class Meta:
|
|
ordering = ('datetime',)
|
|
verbose_name = _('Evenement')
|
|
verbose_name_plural = _('Evenements')
|
|
|
|
|
|
class Reservation(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False, unique=True, db_index=True)
|
|
datetime = models.DateTimeField(auto_now=True)
|
|
|
|
user_commande = models.ForeignKey(settings.AUTH_USER_MODEL, on_delete=models.PROTECT)
|
|
|
|
event = models.ForeignKey(Event,
|
|
on_delete=models.PROTECT,
|
|
related_name="reservation")
|
|
|
|
CANCELED, UNPAID, PAID, VALID, = 'C', 'N', 'P', 'V'
|
|
TYPE_CHOICES = [
|
|
(CANCELED, _('Annulée')),
|
|
(UNPAID, _('Non payée')),
|
|
(PAID, _('Payée')),
|
|
(VALID, _('Validée')),
|
|
]
|
|
|
|
status = models.CharField(max_length=3, choices=TYPE_CHOICES, default=UNPAID,
|
|
verbose_name=_("Status de la réservation"))
|
|
|
|
paiement = models.OneToOneField(Paiement_stripe, on_delete=models.PROTECT, blank=True, null=True,
|
|
related_name='reservation')
|
|
|
|
options = models.ManyToManyField(OptionGenerale, blank=True)
|
|
|
|
class Meta:
|
|
ordering = ('-datetime',)
|
|
|
|
def user_mail(self):
|
|
return self.user_commande.email
|
|
|
|
def __str__(self):
|
|
return f"{str(self.uuid).partition('-')[0]} - {self.user_commande.email}"
|
|
# def total_billet(self):
|
|
# total = 0
|
|
# for ligne in self.paiements.all():
|
|
# if ligne.billet:
|
|
# total += ligne.qty
|
|
# return total
|
|
#
|
|
# def total_prix(self):
|
|
# total = 0
|
|
# for ligne in self.paiements.all():
|
|
# if ligne.product:
|
|
# total += ligne.qty * ligne.product.prix
|
|
#
|
|
# return total
|
|
#
|
|
# def _options_(self):
|
|
# return " - ".join([f"{option.name}" for option in self.options.all()])
|
|
#
|
|
|
|
|
|
@receiver(post_save, sender=Reservation)
|
|
def trigger_reservation(sender, instance: Reservation, created, **kwargs):
|
|
if instance.status == Reservation.PAID:
|
|
if instance.tickets:
|
|
for ticket in instance.tickets.filter(status=Ticket.NOT_ACTIV):
|
|
logger.info(f'trigger_reservation, activation des tickets {ticket} NOT_SCANNED')
|
|
ticket.status = Ticket.NOT_SCANNED
|
|
ticket.save()
|
|
|
|
|
|
class Ticket(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, default=uuid.uuid4, editable=False, unique=True, db_index=True)
|
|
|
|
first_name = models.CharField(max_length=200)
|
|
last_name = models.CharField(max_length=200)
|
|
|
|
reservation = models.ForeignKey(Reservation, on_delete=models.CASCADE, related_name="tickets")
|
|
|
|
NOT_ACTIV, NOT_SCANNED, SCANNED = 'N', 'K', 'S'
|
|
SCAN_CHOICES = [
|
|
(NOT_ACTIV, _('Non actif')),
|
|
(NOT_SCANNED, _('Non scanné')),
|
|
(SCANNED, _('scanné')),
|
|
]
|
|
|
|
status = models.CharField(max_length=1, choices=SCAN_CHOICES, default=NOT_ACTIV,
|
|
verbose_name=_("Status du scan"))
|
|
|
|
def event(self):
|
|
return self.reservation.event
|
|
|
|
event.allow_tags = True
|
|
event.short_description = 'Évènement'
|
|
event.admin_order_field = 'reservation__event'
|
|
|
|
def datetime(self):
|
|
return self.reservation.datetime
|
|
|
|
datetime.allow_tags = True
|
|
datetime.short_description = 'Date de reservation'
|
|
datetime.admin_order_field = 'reservation__datetime'
|
|
|
|
class meta:
|
|
ordering = ('-datetime',)
|
|
|
|
|
|
class LigneArticle(models.Model):
|
|
uuid = models.UUIDField(primary_key=True, db_index=True, default=uuid.uuid4)
|
|
datetime = models.DateTimeField(auto_now=True)
|
|
|
|
price = models.ForeignKey(Price, on_delete=models.CASCADE)
|
|
|
|
qty = models.SmallIntegerField()
|
|
|
|
carte = models.ForeignKey(CarteCashless, on_delete=models.PROTECT, blank=True, null=True)
|
|
|
|
paiement_stripe = models.ForeignKey(Paiement_stripe, on_delete=models.PROTECT, blank=True, null=True)
|
|
|
|
CANCELED, UNPAID, PAID, VALID, = 'C', 'N', 'P', 'V'
|
|
TYPE_CHOICES = [
|
|
(CANCELED, _('Annulée')),
|
|
(UNPAID, _('Non payée')),
|
|
(PAID, _('Payée')),
|
|
(VALID, _('Validée par serveur cashless')),
|
|
]
|
|
|
|
status = models.CharField(max_length=3, choices=TYPE_CHOICES, default=UNPAID,
|
|
verbose_name=_("Status de ligne article"))
|
|
|
|
class Meta:
|
|
ordering = ('-datetime',)
|
|
|
|
def status_stripe(self):
|
|
if self.paiement_stripe:
|
|
return self.paiement_stripe.status
|
|
else:
|
|
return _('no stripe send')
|
|
|
|
|
|
@receiver(pre_save, sender=LigneArticle)
|
|
def trigger_LigneArticle(sender, instance: LigneArticle, update_fields=None, **kwargs):
|
|
# if not created
|
|
if not instance._state.adding:
|
|
old_instance = sender.objects.get(pk=instance.pk)
|
|
new_instance = pre_save_signal_status(old_instance, instance)
|
|
|
|
'''
|
|
if instance.paiement_stripe:
|
|
logger.info(f"Trigger LigneArticle {instance.status}")
|
|
if instance.paiement_stripe.status != Paiement_stripe.VALID:
|
|
lignes_dans_paiement_stripe = instance.paiement_stripe.lignearticle_set.all()
|
|
|
|
# toute les lignes d'article sont VALID
|
|
if len(lignes_dans_paiement_stripe) == len(lignes_dans_paiement_stripe.filter(status=LigneArticle.VALID)):
|
|
|
|
# Si le paiement à une reservation, on la passe en payée.
|
|
# Cela enclanchera la création et l'envoie des billets
|
|
if instance.paiement_stripe.reservation:
|
|
if instance.paiement_stripe.reservation.status not in [Reservation.PAID, Reservation.VALID]:
|
|
instance.paiement_stripe.reservation.status = Reservation.PAID
|
|
instance.paiement_stripe.reservation.save()
|
|
|
|
# on passe le status du paiement stripe en VALID
|
|
logger.info(
|
|
f"Trigger LigneArticle {instance} check_status_stripe Passage de {instance.paiement_stripe} {instance.paiement_stripe.status} à VALID")
|
|
instance.paiement_stripe.status = Paiement_stripe.VALID
|
|
instance.paiement_stripe.save()
|
|
'''
|
|
|
|
|
|
@receiver(pre_save, sender=Paiement_stripe)
|
|
def trigger_paiement_stripe(sender, instance: Paiement_stripe, update_fields=None, **kwargs):
|
|
# if not create
|
|
if not instance._state.adding:
|
|
old_instance = sender.objects.get(pk=instance.pk)
|
|
new_instance = pre_save_signal_status(old_instance, instance)
|
|
|
|
'''
|
|
# Si il y a une reservation, on a la met en payée
|
|
if instance.reservation:
|
|
if instance.reservation.status not in [Reservation.PAID, Reservation.VALID]:
|
|
logger.info(f"trigger_paiement_stripe, reservation : {instance.reservation} payé ! status = PAID")
|
|
instance.reservation.status = Reservation.PAID
|
|
instance.reservation.save()
|
|
'''
|
|
|
|
|
|
########################################################################
|
|
######################## SIGNAL PRE & POST SAVE ########################
|
|
########################################################################
|
|
|
|
|
|
######################## TRIGGER LIGNE ARTICLE ########################
|
|
|
|
# post_save ici nécéssaire pour mettre a jour le status du paiement stripe en validé
|
|
# si toutes les lignes articles sont VALID.
|
|
@receiver(post_save, sender=LigneArticle)
|
|
def set_paiement_and_reservation_valid(sender, instance: LigneArticle, **kwargs):
|
|
if instance.status == LigneArticle.VALID:
|
|
lignes_dans_paiement_stripe = instance.paiement_stripe.lignearticle_set.all()
|
|
if len(lignes_dans_paiement_stripe) == len(lignes_dans_paiement_stripe.filter(status=LigneArticle.VALID)):
|
|
# on passe le status du paiement stripe en VALID
|
|
logger.info(f" TRIGGER LIGNE ARTICLE set_paiement_and_reservation_valid {instance.price} "
|
|
f"paiement stripe {instance.paiement_stripe} {instance.paiement_stripe.status} à VALID")
|
|
instance.paiement_stripe.status = Paiement_stripe.VALID
|
|
instance.paiement_stripe.save()
|
|
|
|
|
|
def check_paid(old_instance, new_instance):
|
|
# Type :
|
|
old_instance: LigneArticle
|
|
new_instance: LigneArticle
|
|
logger.info(f" TRIGGER LIGNE ARTICLE check_paid {old_instance.price}")
|
|
|
|
if new_instance.price.product.categorie_article in \
|
|
[Product.RECHARGE_CASHLESS, Product.ADHESION]:
|
|
send_to_cashless(new_instance)
|
|
|
|
|
|
def send_to_cashless(instance):
|
|
# Type :
|
|
instance: LigneArticle
|
|
|
|
logger.info(f" send_to_cashless {instance.price}")
|
|
data_for_cashless = {'uuid_commande': instance.paiement_stripe.uuid}
|
|
data_for_cashless['uuid'] = instance.carte.uuid
|
|
|
|
if instance.price.product.categorie_article == Product.RECHARGE_CASHLESS:
|
|
data_for_cashless['recharge_qty'] = instance.price.prix
|
|
|
|
if instance.price.product.categorie_article == Product.ADHESION:
|
|
data_for_cashless['tarif_adhesion'] = instance.price.prix
|
|
|
|
# si il y a des données a envoyer au serveur cashless :
|
|
sess = requests.Session()
|
|
configuration = Configuration.get_solo()
|
|
r = sess.post(
|
|
f'{configuration.server_cashless}/api/billetterie_endpoint',
|
|
headers={
|
|
'Authorization': f'Api-Key {configuration.key_cashless}'
|
|
},
|
|
data=data_for_cashless,
|
|
)
|
|
|
|
sess.close()
|
|
logger.info(
|
|
f" demande au serveur cashless pour un rechargement. réponse : {r.status_code} ")
|
|
|
|
if r.status_code == 200:
|
|
instance.status = LigneArticle.VALID
|
|
else:
|
|
logger.error(
|
|
f"erreur réponse serveur cashless {r.status_code} {r.text} pour paiement stripe {instance.price} uuid {instance.uuid}")
|
|
|
|
|
|
######################## TRIGGER PAIEMENT STRIPE ########################
|
|
|
|
|
|
def set_ligne_article_paid(old_instance, new_instance):
|
|
# Type :
|
|
old_instance: Paiement_stripe
|
|
new_instance: Paiement_stripe
|
|
|
|
logger.info(f" TRIGGER PAIEMENT STRIPE set_ligne_article_paid {old_instance}.")
|
|
logger.info(f" On passe toutes les lignes d'article non validées en payées !")
|
|
|
|
lignes_article = new_instance.lignearticle_set.exclude(status=LigneArticle.VALID)
|
|
for ligne_article in lignes_article:
|
|
logger.info(f" {ligne_article.price} {ligne_article.status} to P]")
|
|
ligne_article.status = LigneArticle.PAID
|
|
ligne_article.save()
|
|
|
|
# si ya une reservation, on la met aussi en payée :
|
|
if new_instance.reservation:
|
|
new_instance.reservation.status = Reservation.PAID
|
|
new_instance.reservation.save()
|
|
|
|
|
|
def expire_paiement_stripe(old_instance, new_instance):
|
|
logger.info(f" TRIGGER PAIEMENT STRIPE expire_paiement_stripe {old_instance.status} to {new_instance.status}")
|
|
pass
|
|
|
|
|
|
def valide_stripe_paiement(old_instance, new_instance):
|
|
logger.info(f" TRIGGER PAIEMENT STRIPE valide_stripe_paiement {old_instance.status} to {new_instance.status}")
|
|
pass
|
|
|
|
######################## TRIGGER RESERVATION ########################
|
|
|
|
|
|
def send_billet_to_mail(old_instance, new_instance):
|
|
logger.info(f" TRIGGER RESERVATION send_billet_to_mail {old_instance.status} to {new_instance.status}")
|
|
pass
|
|
|
|
|
|
######################## MOTEUR TRIGGER ########################
|
|
|
|
def error_regression(old_instance, new_instance):
|
|
logger.info(f"models_trigger erreur_regression {old_instance.status} to {new_instance.status}")
|
|
logger.error(f"######################## error_regression ########################")
|
|
# raise Exception('Regression de status impossible.')
|
|
pass
|
|
|
|
|
|
# def pass(old_instance, new_instance):
|
|
|
|
# On déclare les transitions possibles entre différents etats des statuts.
|
|
# Exemple première ligne : Si status passe de PENDING vers PAID, alors on lance set_ligne_article_paid
|
|
class Transitions():
|
|
''''''
|
|
'''
|
|
Reservation choices :
|
|
(CANCELED, _('Annulée')),
|
|
(UNPAID, _('Non payée')),
|
|
(PAID, _('Payée')),
|
|
(VALID, _('Validée')),
|
|
'''
|
|
RESERVATION = {
|
|
Reservation.UNPAID: {
|
|
Reservation.PAID : send_billet_to_mail
|
|
},
|
|
Reservation.PAID: {
|
|
LigneArticle.PAID: send_billet_to_mail,
|
|
'_else_': error_regression,
|
|
},
|
|
Reservation.VALID: {
|
|
'_all_': error_regression,
|
|
}
|
|
}
|
|
'''
|
|
Paiement_stripe choices :
|
|
(NON, 'Lien de paiement non créé'),
|
|
(OPEN, 'Envoyée a Stripe'),
|
|
(PENDING, 'En attente de paiement'),
|
|
(EXPIRE, 'Expiré'),
|
|
(PAID, 'Payée'),
|
|
(VALID, 'Payée et validée'), # envoyé sur serveur cashless
|
|
(CANCELED, 'Annulée'),
|
|
'''
|
|
PAIEMENT_STRIPE = {
|
|
Paiement_stripe.PENDING: {
|
|
Paiement_stripe.PAID: set_ligne_article_paid,
|
|
Paiement_stripe.EXPIRE: expire_paiement_stripe,
|
|
Paiement_stripe.CANCELED: expire_paiement_stripe,
|
|
},
|
|
Paiement_stripe.PAID: {
|
|
Paiement_stripe.PAID: set_ligne_article_paid,
|
|
Paiement_stripe.VALID: valide_stripe_paiement,
|
|
'_else_': error_regression,
|
|
},
|
|
Paiement_stripe.VALID: {
|
|
'_all_': error_regression,
|
|
}
|
|
}
|
|
'''
|
|
LigneArticle Choices :
|
|
(CANCELED, _('Annulée')),
|
|
(UNPAID, _('Non payée')),
|
|
(PAID, _('Payée')),
|
|
(VALID, _('Validée par serveur cashless')),
|
|
'''
|
|
LIGNEARTICLE = {
|
|
LigneArticle.UNPAID: {
|
|
LigneArticle.PAID: check_paid,
|
|
},
|
|
LigneArticle.PAID: {
|
|
LigneArticle.PAID: check_paid,
|
|
# LigneArticle.VALID: valide_stripe_paiement,
|
|
'_else_': error_regression,
|
|
},
|
|
LigneArticle.VALID: {
|
|
'_all_': error_regression,
|
|
}
|
|
}
|
|
|
|
|
|
def pre_save_signal_status(old_instance, new_instance):
|
|
# import ipdb; ipdb.set_trace()
|
|
sender_str = old_instance.__class__.__name__.upper()
|
|
dict_transition = getattr(Transitions, f"{sender_str}", None)
|
|
if dict_transition:
|
|
logger.info(f"dict_transition {sender_str} {new_instance} : {old_instance.status} to {new_instance.status}")
|
|
transitions = dict_transition.get(old_instance.status, None)
|
|
if transitions:
|
|
# Par ordre de préférence :
|
|
trigger_function = transitions.get('_all_', (
|
|
transitions.get(new_instance.status, (
|
|
transitions.get('_else_', None)
|
|
))))
|
|
|
|
if trigger_function:
|
|
# import ipdb; ipdb.set_trace()
|
|
|
|
if not callable(trigger_function):
|
|
raise Exception(f'Fonction {trigger_function} is not callable. Disdonc !?')
|
|
trigger_function(old_instance, new_instance)
|