如何将kwargs传递给Django信号

如何解决如何将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
            })