Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # Обрабатываем создание нового аккаунта на сайте
- @receiver(post_save, sender=User)
- def account_save_handler(sender, **kwargs):
- transaction.on_commit(lambda: task_account_save_handler.delay(
- kwargs['instance'].pk, kwargs['created']))
- #Задача Сelery для обработки пользователя на сайте
- @shared_task(bind=True)
- def task_account_save_handler(self, pk, is_created):
- try:
- on_account_saved(pk, is_created)
- except exceptions.AmoApiException as exc:
- raise self.retry(exc=exc)
- except Exception as exc:
- logger.error('Exception: {}'.format(pk, exc))
- # Собственно обработчик регистрации
- def on_account_saved(pk, is_created):
- user = User.objects.get(pk=pk)
- if not user.external_id and is_created:
- ### DO something
- user.external_id=new_contact.id
- user.external_type='type_1'
- user.save(update_fields=['external_id', 'external_type'])
- #User.objects.filter(pk=user.pk).update(external_type='type_1', external_id=new_contact.id)
- ### DO something
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement