如何将kwargs传递给Django信号

问题描述

我想从我的序列化器发送 kwargs 到Django信号,该序列化器实际上正在创建模型 User 的对象

这是序列化器的 create 方法-

@transaction.atomic
    def create(self,validated_data):

        company = validated_data.pop('company')

        user_group = validated_data.pop('user_group')

        user_group = Group.objects.get(name=user_group)

        company = CompanyDetails.objects.create(**company)

        validated_data['company'] = company

        user = User.objects.create_user(**validated_data)

        user_and_group = user.groups.add(user_group)
        
        return user

用户 模型还具有如下所述的经理类-

class UserManager(BaseUserManager):
    
    def create_user(self,first_name,last_name,email,mobile_number,password,company,is_mobile_number_verified=None,is_email_varified=None,is_active=None):

        if not email:

            raise ValueError("You need an email to create account")
        
        user = self.model(
            email = self.normalize_email(email),first_name = first_name,last_name = last_name,mobile_number = mobile_number,password  = password,company = company,is_mobile_number_verified = is_mobile_number_verified,is_email_varified = is_email_varified,is_active = is_active
        )

        user.set_password(password)

        user.save(using = self._db)

        return user
    

models.py 中,我已连接到 User 模型的 post_save 信号,如下所示-

signals.post_save.connect(user_post_save,sender=User)

user_post_save 是一种接收方方法,用于向新注册用户发送电子邮件

我希望仅当用户注册 Organization Admin 时,此方法才发送电子邮件。因此,如何从串行器的create方法中将标志Organisation Admin= True传递给接收者。

这是我的APIView类中的post方法-

def post(self,request,format=None):

        serialized_data = RegisterUpdateUserSerializer(data=request.data)

        if serialized_data.is_valid():

            serialized_data.validated_data['is_mobile_number_verified'] = False
            serialized_data.validated_data['is_email_varified'] = False
            serialized_data.validated_data['is_active'] = False

            serialized_data.validated_data['user_group'] = 'Super Admin'

            try:
            
                user = serialized_data.save()
            
            except IntegrityError as error:

                return Response ({
                    "error": str(error),"status": status.HTTP_226_IM_USED
                    })
            
        
        else:
        
            return Response(serialized_data.errors)

        if user == None:

            return Response({
                "message" : "Oppsss.. something went wrong.","status" : status.HTTP_409_CONFLICT
            })

        else:

            return Response({
                "message":"Verification mail has been sent to your email '" + request.data['email'] +  "'. Please provide the OTP to verify your email and active your account. ","status":status.HTTP_200_OK
            })

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)