models.py 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458
  1. # -*- coding: utf-8 -*-
  2. from __future__ import unicode_literals
  3. import ldapdb.models
  4. import unicodedata
  5. import datetime
  6. from django.db import models
  7. from django.db.models import Q
  8. from django.db.models.signals import pre_save
  9. from django.dispatch import receiver
  10. from django.contrib.auth.models import AbstractUser
  11. from django.conf import settings
  12. from django.core.validators import RegexValidator
  13. from django.core.exceptions import ValidationError
  14. from ldapdb.models.fields import CharField, IntegerField, ListField
  15. from coin.offers.models import OfferSubscription
  16. from coin.mixins import CoinLdapSyncMixin
  17. from coin import utils
  18. class Member(CoinLdapSyncMixin, AbstractUser):
  19. # USERNAME_FIELD = 'login'
  20. REQUIRED_FIELDS = ['first_name', 'last_name', 'email', ]
  21. MEMBER_TYPE_CHOICES = (
  22. ('natural_person', 'Personne physique'),
  23. ('legal_entity', 'Personne morale'),
  24. )
  25. MEMBER_STATUS_CHOICES = (
  26. ('member', 'Adhérent'),
  27. ('not_member', 'Non adhérent'),
  28. ('pending', "Demande d'adhésion"),
  29. )
  30. status = models.CharField(max_length=50, choices=MEMBER_STATUS_CHOICES,
  31. default='member', verbose_name='statut')
  32. type = models.CharField(max_length=20, choices=MEMBER_TYPE_CHOICES,
  33. default='natural_person', verbose_name='type')
  34. nickname = models.CharField(max_length=64, blank=True,
  35. verbose_name="nom d'usage",
  36. help_text='Pseudonyme, …')
  37. organization_name = models.CharField(max_length=200, blank=True,
  38. verbose_name="nom de l'organisme",
  39. help_text='Pour une personne morale')
  40. home_phone_number = models.CharField(max_length=25, blank=True,
  41. verbose_name='téléphone fixe')
  42. mobile_phone_number = models.CharField(max_length=25, blank=True,
  43. verbose_name='téléphone mobile')
  44. # TODO: use a django module that provides an address model? (would
  45. # support more countries and address types)
  46. address = models.TextField(
  47. verbose_name='adresse postale', blank=True, null=True)
  48. postal_code = models.CharField(max_length=5, blank=True, null=True,
  49. validators=[RegexValidator(regex=r'^\d{5}$',
  50. message='Code postal non valide.')],
  51. verbose_name='code postal')
  52. city = models.CharField(max_length=200, blank=True, null=True,
  53. verbose_name='commune')
  54. country = models.CharField(max_length=200, blank=True, null=True,
  55. default='France',
  56. verbose_name='pays')
  57. resign_date = models.DateField(null=True, blank=True,
  58. verbose_name="date de départ de "
  59. "l'association",
  60. help_text="En cas de départ prématuré")
  61. comments = models.TextField(blank=True, verbose_name='commentaires',
  62. help_text="Commentaires libres (informations"
  63. " spécifiques concernant l'adhésion,"
  64. " raison du départ, etc)")
  65. # Following fields are managed by the parent class AbstractUser :
  66. # username, first_name, last_name, email
  67. # However we hack the model to force theses fields to be required. (see
  68. # below)
  69. # This property is used to change password in LDAP. Used in sync_to_ldap.
  70. # Should not be defined manually. Prefer use set_password method that hash
  71. # passwords for both ldap and local db
  72. _password_ldap = None
  73. def clean(self):
  74. if self.type == 'legal_entity':
  75. if not self.organization_name:
  76. raise ValidationError("Le nom de l'organisme est obligatoire "
  77. "pour une personne morale")
  78. elif self.type == 'natural_person':
  79. if not (self.first_name and self.last_name):
  80. raise ValidationError("Le nom et prénom sont obligatoires "
  81. "pour une personne physique")
  82. def __unicode__(self):
  83. if self.type == 'legal_entity':
  84. return self.organization_name
  85. elif self.nickname:
  86. return self.nickname
  87. else:
  88. return self.first_name + ' ' + self.last_name
  89. def get_full_name(self):
  90. return str(self)
  91. def get_short_name(self):
  92. return self.username
  93. # Renvoie la date de fin de la dernière cotisation du membre
  94. def end_date_of_membership(self):
  95. x = self.membership_fees.order_by('-end_date')
  96. if x:
  97. return self.membership_fees.order_by('-end_date')[0].end_date
  98. end_date_of_membership.short_description = "Date de fin d'adhésion"
  99. def is_paid_up(self):
  100. """
  101. True si le membre est à jour de cotisation. False sinon
  102. """
  103. if self.end_date_of_membership() \
  104. and self.end_date_of_membership() >= datetime.date.today():
  105. return True
  106. else:
  107. return False
  108. def set_password(self, new_password, *args, **kwargs):
  109. """
  110. Définit le mot de passe a sauvegarder en base et dans le LDAP
  111. """
  112. super(Member, self).set_password(new_password, *args, **kwargs)
  113. self._password_ldap = utils.ldap_hash(new_password)
  114. def get_active_subscriptions(self, date=None):
  115. """
  116. Return list of OfferSubscription which are active today
  117. """
  118. if date is None:
  119. date = datetime.date.today()
  120. return OfferSubscription.objects.filter(
  121. Q(member__exact=self.pk),
  122. Q(subscription_date__lte=date),
  123. Q(resign_date__isnull=True) | Q(resign_date__gte=date))
  124. def get_inactive_subscriptions(self, date=None):
  125. """
  126. Return list of OfferSubscription which are not active today
  127. """
  128. if date is None:
  129. date = datetime.date.today()
  130. return OfferSubscription.objects.filter(
  131. Q(member__exact=self.pk),
  132. Q(subscription_date__gt=date) |
  133. Q(resign_date__lt=date))
  134. def get_ssh_keys(self):
  135. # Quick & dirty, ensure that keys are unique (otherwise, LDAP complains)
  136. return list({k.key for k in self.cryptokey_set.filter(type='RSA')})
  137. def sync_ssh_keys(self):
  138. """
  139. Called whenever a SSH key is saved
  140. """
  141. ldap_user = LdapUser.objects.get(pk=self.username)
  142. ldap_user.sshPublicKey = self.get_ssh_keys()
  143. ldap_user.save()
  144. def sync_to_ldap(self, creation, update_fields, *args, **kwargs):
  145. """
  146. Update LDAP data when a member is saved
  147. """
  148. # Do not perform LDAP query if no usefull fields to update are specified
  149. # in update_fields
  150. # Ex : at login, last_login field is updated by django auth module.
  151. relevant_fields = {'username', 'last_name', 'first_name',
  152. 'organization_name', 'email'}
  153. if update_fields and relevant_fields.isdisjoint(set(update_fields)):
  154. return
  155. # Fail if no username specified
  156. assert self.username, ('Can\'t sync with LDAP because missing username '
  157. 'value for the Member : %s' % self)
  158. # If try to sync a superuser in creation mode
  159. # Try to retrieve the user in ldap. If exists, switch to update mode
  160. # This allow to create a superuser without having to delete corresponding
  161. # username in LDAP
  162. if self.is_superuser and creation:
  163. try:
  164. ldap_user = LdapUser.objects.get(pk=self.username)
  165. creation = False
  166. except LdapUser.DoesNotExist:
  167. pass
  168. if not creation:
  169. ldap_user = LdapUser.objects.get(pk=self.username)
  170. if creation:
  171. users = LdapUser.objects
  172. if users.exists():
  173. uid_number = users.order_by('-uidNumber')[0].uidNumber + 1
  174. else:
  175. uid_number = settings.LDAP_USER_FIRST_UID
  176. ldap_user = LdapUser()
  177. ldap_user.pk = self.username
  178. ldap_user.uid = self.username
  179. ldap_user.nick_name = self.username
  180. ldap_user.uidNumber = uid_number
  181. ldap_user.homeDirectory = '/home/' + self.username
  182. if self.type == 'natural_person':
  183. ldap_user.last_name = self.last_name
  184. ldap_user.first_name = self.first_name
  185. elif self.type == 'legal_entity':
  186. ldap_user.last_name = self.organization_name
  187. ldap_user.first_name = ""
  188. # If a password is definied in _password_ldap, change it in LDAP
  189. if self._password_ldap:
  190. # Make sure password is hashed
  191. ldap_user.password = utils.ldap_hash(self._password_ldap)
  192. ldap_user.mail = self.email
  193. # Store SSH keys
  194. ldap_user.sshPublicKey = self.get_ssh_keys()
  195. ldap_user.save()
  196. # if creation:
  197. # ldap_group = LdapGroup.objects.get(pk='coin')
  198. # ldap_group.members.append(ldap_user.pk)
  199. # ldap_group.save()
  200. def delete_from_ldap(self):
  201. """
  202. Delete member from the LDAP
  203. """
  204. assert self.username, ('Can\'t delete from LDAP because missing '
  205. 'username value for the Member : %s' % self)
  206. # Delete user from LDAP
  207. ldap_user = LdapUser.objects.get(pk=self.username)
  208. ldap_user.delete()
  209. # Lorsqu'un membre est supprimé du SI, son utilisateur LDAP
  210. # correspondant est sorti du groupe "coin" afin qu'il n'ait plus
  211. # accès au SI
  212. # ldap_group = LdapGroup.objects.get(pk='coin')
  213. # if self.username in ldap_group.members:
  214. # ldap_group.members.remove(self.username)
  215. # ldap_group.save()
  216. def send_welcome_email(self):
  217. """ Envoie le courriel de bienvenue à ce membre """
  218. from coin.isp_database.models import ISPInfo
  219. utils.send_templated_email(to=self.email,
  220. subject_template='members/emails/welcome_email_subject.txt',
  221. body_template='members/emails/welcome_email.html',
  222. context={'member': self, 'branding':ISPInfo.objects.first()})
  223. class Meta:
  224. verbose_name = 'membre'
  225. # Hack to force email to be required by Member model
  226. Member._meta.get_field('email')._unique = True
  227. Member._meta.get_field('email').blank = False
  228. Member._meta.get_field('email').null = False
  229. def count_active_members():
  230. return Member.objects.filter(status='member').count()
  231. def get_automatic_username(member):
  232. """
  233. Calcul le username automatiquement en fonction
  234. du nom et du prénom
  235. """
  236. # S'il s'agit d'une entreprise, utilise son nom:
  237. if member.type == 'legal_entity' and member.organization_name:
  238. username = member.organization_name
  239. # Sinon, si un pseudo est définit, l'utilise
  240. elif member.nickname:
  241. username = member.nickname
  242. # Sinon, utilise nom et prenom
  243. elif member.first_name and member.last_name:
  244. # Première lettre de chaque partie du prénom
  245. first_name_letters = ''.join(
  246. [c[0] for c in member.first_name.split('-')]
  247. )
  248. # Concaténer avec nom de famille
  249. username = ('%s%s' % (first_name_letters, member.last_name))
  250. else:
  251. raise Exception('Il n\'y a pas sufissement d\'informations pour déterminer un login automatiquement')
  252. # Remplacer ou enlever les caractères non ascii
  253. username = unicodedata.normalize('NFD', username)\
  254. .encode('ascii', 'ignore')
  255. # Enlever ponctuation (sauf _-.) et espace
  256. punctuation = ('!"#$%&\'()*+,/:;<=>?@[\\]^`{|}~ ').encode('ascii')
  257. username = username.translate(None, punctuation)
  258. # En minuscule
  259. username = username.lower()
  260. # Maximum de 30 char
  261. username = username[:30]
  262. # Recherche dans les membres existants un username identique
  263. member = Member.objects.filter(username=username)
  264. base_username = username
  265. incr = 2
  266. # Tant qu'un membre est trouvé, incrémente un entier à la fin
  267. while member:
  268. if len(base_username) >= 30:
  269. username = base_username[30 - len(str(incr)):]
  270. else:
  271. username = base_username
  272. username = username + str(incr)
  273. member = Member.objects.filter(username=username)
  274. incr += 1
  275. return username
  276. class CryptoKey(CoinLdapSyncMixin, models.Model):
  277. KEY_TYPE_CHOICES = (('RSA', 'RSA'), ('GPG', 'GPG'))
  278. type = models.CharField(max_length=3, choices=KEY_TYPE_CHOICES,
  279. verbose_name='type')
  280. key = models.TextField(verbose_name='clé')
  281. member = models.ForeignKey('Member', verbose_name='membre')
  282. def sync_to_ldap(self, creation, *args, **kwargs):
  283. """Simply tell the member object to resync all its SSH keys to LDAP"""
  284. self.member.sync_ssh_keys()
  285. def delete_from_ldap(self, *args, **kwargs):
  286. self.member.sync_ssh_keys()
  287. def __unicode__(self):
  288. return 'Clé %s de %s' % (self.type, self.member)
  289. class Meta:
  290. verbose_name = 'clé'
  291. class MembershipFee(models.Model):
  292. PAYMENT_METHOD_CHOICES = (
  293. ('cash', 'Espèces'),
  294. ('check', 'Chèque'),
  295. ('transfer', 'Virement'),
  296. ('other', 'Autre')
  297. )
  298. member = models.ForeignKey('Member', related_name='membership_fees',
  299. verbose_name='membre')
  300. amount = models.DecimalField(null=False, max_digits=5, decimal_places=2,
  301. default=settings.MEMBER_DEFAULT_COTISATION,
  302. verbose_name='montant', help_text='en €')
  303. start_date = models.DateField(
  304. null=False,
  305. blank=False,
  306. verbose_name='date de début de cotisation')
  307. end_date = models.DateField(
  308. null=False,
  309. blank=True,
  310. verbose_name='date de fin de cotisation',
  311. help_text='par défaut, la cotisation dure un an')
  312. payment_method = models.CharField(max_length=100, null=True, blank=True,
  313. choices=PAYMENT_METHOD_CHOICES,
  314. verbose_name='moyen de paiement')
  315. reference = models.CharField(max_length=125, null=True, blank=True,
  316. verbose_name='référence du paiement',
  317. help_text='numéro de chèque, '
  318. 'référence de virement, commentaire...')
  319. payment_date = models.DateField(null=True, blank=True,
  320. verbose_name='date du paiement')
  321. def clean(self):
  322. if self.end_date is None:
  323. self.end_date = self.start_date + datetime.timedelta(364)
  324. def __unicode__(self):
  325. return '%s - %s - %i€' % (self.member, self.start_date, self.amount)
  326. class Meta:
  327. verbose_name = 'cotisation'
  328. class LdapUser(ldapdb.models.Model):
  329. # "ou=users,ou=unix,o=ILLYSE,l=Villeurbanne,st=RHA,c=FR"
  330. base_dn = settings.LDAP_USER_BASE_DN
  331. object_classes = [b'inetOrgPerson', b'organizationalPerson', b'person',
  332. b'top', b'posixAccount', b'ldapPublicKey']
  333. uid = CharField(db_column=b'uid', unique=True, max_length=255)
  334. nick_name = CharField(db_column=b'cn', unique=True, primary_key=True,
  335. max_length=255)
  336. first_name = CharField(db_column=b'givenName', max_length=255)
  337. last_name = CharField(db_column=b'sn', max_length=255)
  338. display_name = CharField(db_column=b'displayName', max_length=255,
  339. blank=True)
  340. password = CharField(db_column=b'userPassword', max_length=255)
  341. uidNumber = IntegerField(db_column=b'uidNumber', unique=True)
  342. gidNumber = IntegerField(db_column=b'gidNumber', default=2000)
  343. # Used by Sympa for logging in.
  344. mail = CharField(db_column=b'mail', max_length=255, blank=True,
  345. unique=True)
  346. homeDirectory = CharField(db_column=b'homeDirectory', max_length=255,
  347. default='/tmp')
  348. loginShell = CharField(db_column=b'loginShell', max_length=255,
  349. default='/bin/bash')
  350. sshPublicKey = ListField(db_column=b'sshPublicKey', default=[])
  351. def __unicode__(self):
  352. return self.display_name
  353. class Meta:
  354. managed = False # Indique à Django de ne pas intégrer ce model en base
  355. # class LdapGroup(ldapdb.models.Model):
  356. # "ou=groups,ou=unix,o=ILLYSE,l=Villeurbanne,st=RHA,c=FR"
  357. # base_dn = settings.LDAP_GROUP_BASE_DN
  358. # object_classes = [b'posixGroup']
  359. # gid = IntegerField(db_column=b'gidNumber', unique=True)
  360. # name = CharField(db_column=b'cn', max_length=200, primary_key=True)
  361. # members = ListField(db_column=b'memberUid')
  362. # def __unicode__(self):
  363. # return self.name
  364. # class Meta:
  365. # managed = False # Indique à Django de ne pas intégrer ce model en base
  366. @receiver(pre_save, sender=Member)
  367. def define_username(sender, instance, **kwargs):
  368. """
  369. Lors de la sauvegarde d'un membre. Si le champ username n'est pas définit,
  370. le calcul automatiquement en fonction du nom et du prénom
  371. """
  372. if not instance.username and not instance.pk:
  373. instance.username = get_automatic_username(instance)
  374. @receiver(pre_save, sender=LdapUser)
  375. def define_display_name(sender, instance, **kwargs):
  376. """
  377. Lors de la sauvegarde d'un utilisateur Ldap, le champ display_name est la
  378. concaténation de first_name et last_name
  379. """
  380. if not instance.display_name:
  381. instance.display_name = '%s %s' % (instance.first_name,
  382. instance.last_name)