Django ORM获取1:N关联的最新Deal对象失败，求排查问题

需求背景 #

RealEstate与Deal为1:N关联，需为每个RealEstate获取其未取消的最新Deal对象（按deal_year、deal_month、deal_day倒序排序）。

第一种方案：prefetch_related + Prefetch + Subquery 问题分析 #

核心问题 #

1. Subquery的OuterRef作用域错误
   在Prefetch的queryset中，latest_deals里的OuterRef("id")指向的是Deal对象的id，而非RealEstate的id，导致无法关联到当前RealEstate对应的Deal集合，Subquery无法正确筛选出对应RealEstate的最新Deal。

2. 未同步过滤取消状态
   外层filter(deals__is_deal_canceled=False)仅过滤出有未取消Deal的RealEstate，但deal_q和Subquery中未添加is_deal_canceled=False的过滤条件，可能导致Subquery选中已取消的Deal，最终Prefetch到的latest_deals为空。

3. Prefetch逻辑冗余
   用id__in=Subquery(latest_deals)的方式无法实现“每个RealEstate对应单个最新Deal”的匹配，因为Subquery是针对全局Deal的，而非每个RealEstate单独计算。

修正后的代码 #

from django.db.models import OuterRef, Subquery

# 定义获取单个RealEstate最新未取消Deal的子查询
latest_deal_subquery = Deal.objects.filter(
    real_estate_id=OuterRef("id"),
    is_deal_canceled=False
).order_by("-deal_year", "-deal_month", "-deal_day").values("id")[:1]

# 筛选符合地理范围且有未取消Deal的RealEstate
real_estates = RealEstate.objects.filter(
    deals__is_deal_canceled=False,
    latitude__gte=dto.sw_lat,
    latitude__lte=dto.ne_lat,
    longitude__gte=dto.sw_lng,
    longitude__lte=dto.ne_lng
).distinct()

# 使用Prefetch关联每个RealEstate的最新Deal
real_estates = real_estates.prefetch_related(
    Prefetch(
        lookup="deals",
        queryset=Deal.objects.filter(id__in=Subquery(latest_deal_subquery)),
        to_attr="latest_deals"
    )
)

# 此时每个real_estate.latest_deals为包含单个最新Deal的列表

第二种方案：annotate + FilteredRelation + Subquery 问题分析 #

核心问题 #

1. FilteredRelation的条件语法错误
   FilteredRelation的condition中deals=Subquery(...)是无效写法，正确的关联字段匹配应使用deals__id=Subquery(...)，因为deals是反向关联名称，无法直接赋值匹配id。

2. FilteredRelation与select_related不兼容
   FilteredRelation生成的是过滤后的关联集合，而非单个对象，因此select_related("latest_deal")无法生效，无法将其作为单个关联对象加载。

3. 未过滤取消状态
   Subquery中未添加is_deal_canceled=False，若RealEstate的最新Deal是已取消的，会导致latest_deal为空。

修正后的方案（改用annotate获取单个最新Deal） #

如果需要直接将最新Deal作为RealEstate的属性，推荐用annotate结合Subquery获取单个对象：

from django.db.models import OuterRef, Subquery

# 定义获取最新未取消Deal对象的子查询
latest_deal_obj_subquery = Deal.objects.filter(
    real_estate_id=OuterRef("id"),
    is_deal_canceled=False
).order_by("-deal_year", "-deal_month", "-deal_day")[:1]

qs = RealEstate.objects.annotate(
    latest_deal=Subquery(latest_deal_obj_subquery)
).filter(
    deals__is_deal_canceled=False,
    latitude__gte=dto.sw_lat,
    latitude__lte=dto.ne_lat,
    longitude__gte=dto.sw_lng,
    longitude__lte=dto.ne_lng
).distinct()

# 此时real_estate.latest_deal即为最新Deal对象（需Django 1.11+支持Subquery返回对象）

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