This commit is contained in:
aaron 2025-02-17 18:38:12 +08:00
parent 1165b07a8c
commit e44e5c04a9

View File

@ -388,14 +388,13 @@ async def get_community_building_order_count(
# 查询每个楼栋的订单数量 # 查询每个楼栋的订单数量
building_order_count = db.query( building_order_count = db.query(
ShippingOrderDB.address_community_building_id, ShippingOrderDB.address_community_building_id,
ShippingOrderDB.address_community_building_name,
func.count(ShippingOrderDB.orderid) func.count(ShippingOrderDB.orderid)
).filter( ).filter(
ShippingOrderDB.address_community_building_name.in_( ShippingOrderDB.address_community_building_id.in_(
[building.building_name for building in community_buildings] [building.id for building in community_buildings]
) )
).group_by( ).group_by(
ShippingOrderDB.address_community_building_name ShippingOrderDB.address_community_building_id
).all() ).all()
@ -404,7 +403,7 @@ async def get_community_building_order_count(
building_order_count_dict = dict(building_order_count) building_order_count_dict = dict(building_order_count)
for building in community_buildings: for building in community_buildings:
if building.building_name not in building_order_count_dict: if building.id not in building_order_count_dict:
result.append({ result.append({
"building_id": building.id, "building_id": building.id,
"building_name": building.building_name, "building_name": building.building_name,
@ -414,7 +413,7 @@ async def get_community_building_order_count(
result.append({ result.append({
"building_id": building.id, "building_id": building.id,
"building_name": building.building_name, "building_name": building.building_name,
"order_count": building_order_count_dict[building.building_name] "order_count": building_order_count_dict[building.id]
}) })