Django中如何正确关联多对多字段实现投票关联已有用户

错误原因 #

1. 模型与序列化器不匹配：你的AvailabilityPoll模型中participants字段是关联Participant模型的多对多关系，但序列化器中participants字段使用的是基于User模型的ParticipantsSerializer，导致DRF尝试创建新的User实例，而你传入的邮箱用户已存在，因此抛出“该邮箱对应的用户已存在”的错误。
2. 序列化器create方法错误：在AvailabilityPollSerializer的create方法中，你调用了poll.users.add(user)，但AvailabilityPoll模型根本没有users字段，正确的字段名是participants。
3. Participant模型未被正确使用：你创建了Participant模型作为User的关联层，但没有在序列化和关联逻辑中正确处理这个中间模型。

修复步骤 #

1. 修正ParticipantsSerializer #

将序列化器改为基于Participant模型，同时支持通过邮箱传入用户信息：

class ParticipantsSerializer(serializers.ModelSerializer):
    email = serializers.EmailField(write_only=True)
    user_email = serializers.EmailField(source='user.email', read_only=True)

    class Meta:
        model = Participant
        fields = ['email', 'user_email']

    def validate_email(self, value):
        # 验证邮箱对应的用户存在
        if not User.objects.filter(email=value).exists():
            raise serializers.ValidationError("该邮箱对应的用户不存在")
        return value

2. 修正AvailabilityPollSerializer #

调整participants字段的序列化器，并修复create方法中的关联逻辑：

class AvailabilityPollSerializer(serializers.ModelSerializer):
    datetime_ranges = DateTimeRangeSerializer(many=True)
    participants = ParticipantsSerializer(many=True)

    class Meta:
        model = AvailabilityPoll
        fields = '__all__'

    def create(self, validated_data):
        datetime_ranges_data = validated_data.pop('datetime_ranges')
        participants_data = validated_data.pop('participants')
        poll = AvailabilityPoll.objects.create(**validated_data)

        # 处理时间范围关联
        for range_data in datetime_ranges_data:
            dt_range = DateTimeRange.objects.create(**range_data)
            poll.datetime_ranges.add(dt_range)

        # 处理参与者关联：通过邮箱找到用户，关联或创建对应的Participant实例
        for participant_data in participants_data:
            email = participant_data['email']
            user = User.objects.get(email=email)
            # 用get_or_create避免重复创建Participant
            participant, _ = Participant.objects.get_or_create(user=user)
            poll.participants.add(participant)

        return poll

3. 简化DateTimeRangeSerializer（可选） #

DateTimeRangeSerializer的create方法可以简化，因为objects.create()已经会自动保存实例：

class DateTimeRangeSerializer(serializers.ModelSerializer):
    class Meta:
        model = DateTimeRange
        fields = '__all__'

4. 保持原有请求格式不变 #

修改后的序列化器支持你原来的请求JSON格式，无需调整：

{
    "name":  "TestPoll",
    "description": "Test",
    "datetime_ranges" : [
        {
            "start_time": "2023-05-01T10:00:00Z",
            "end_time": "2023-05-01T12:00:00Z"
        },
        {
            "start_time": "2023-05-01T14:00:00Z",
            "end_time": "2023-05-01T16:00:00Z"
        }
    ],
    "participants": [
        {
            "email": "test@test.com"
        },
        {
            "email" : "test2@test2.com"
        }
    ],
    "duration": "1:00:00",
    "deadline": "2023-05-01T00:00:00Z"
}

可选优化：去掉冗余的Participant模型 #

如果不需要给参与者扩展额外字段，建议直接让AvailabilityPoll与User建立多对多关系，去掉Participant模型，逻辑会更简洁：

# 修改AvailabilityPoll模型
class AvailabilityPoll(models.Model):
    name = models.CharField(max_length=255)
    description = models.TextField(blank=True)
    duration = models.TimeField()
    datetime_ranges = models.ManyToManyField(DateTimeRange, related_name='datetime_ranges')
    deadline = models.DateTimeField()
    # 直接关联User模型
    participants = models.ManyToManyField(settings.AUTH_USER_MODEL, related_name='participants')

    def is_expired(self):
        return self.deadline <= timezone.now()

    def get_participant_count(self):
        return self.participants.count()

对应的序列化器可以简化为：

class AvailabilityPollSerializer(serializers.ModelSerializer):
    datetime_ranges = DateTimeRangeSerializer(many=True)
    # 用EmailField直接关联已有用户
    participants = serializers.ListField(child=serializers.EmailField())

    class Meta:
        model = AvailabilityPoll
        fields = '__all__'

    def create(self, validated_data):
        datetime_ranges_data = validated_data.pop('datetime_ranges')
        participants_emails = validated_data.pop('participants')
        poll = AvailabilityPoll.objects.create(**validated_data)

        for range_data in datetime_ranges_data:
            dt_range = DateTimeRange.objects.create(**range_data)
            poll.datetime_ranges.add(dt_range)

        # 通过邮箱批量获取用户并关联
        users = User.objects.filter(email__in=participants_emails)
        poll.participants.add(*users)

        return poll

内容的提问来源于stack exchange，提问作者dpeter