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) @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) ######################################################################## ######################## 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)