update
This commit is contained in:
parent
bc1b65eb8d
commit
ab29259854
@ -27,14 +27,15 @@ async def partner_summary(
|
|||||||
"""获取合伙人收益汇总"""
|
"""获取合伙人收益汇总"""
|
||||||
|
|
||||||
# 获取当前用户管理的小区ID列表,直接在数据库层面去重
|
# 获取当前用户管理的小区ID列表,直接在数据库层面去重
|
||||||
community_ids = db.query(CommunitySetMapping.community_id)\
|
query_result = db.query(CommunitySetMapping.community_id, CommunitySet.set_name)\
|
||||||
.join(CommunitySet, CommunitySetMapping.set_id == CommunitySet.id)\
|
.join(CommunitySet, CommunitySetMapping.set_id == CommunitySet.id)\
|
||||||
.filter(CommunitySet.user_id == current_user.userid)\
|
.filter(CommunitySet.user_id == current_user.userid)\
|
||||||
.distinct()\
|
.distinct()\
|
||||||
.all()
|
.all()
|
||||||
|
|
||||||
# 将结果转换为简单列表
|
# 将结果转换为简单列表
|
||||||
community_ids = [community_id[0] for community_id in community_ids]
|
community_ids = [community_id[0] for community_id in query_result]
|
||||||
|
set_names = list(set([community_id[1] for community_id in query_result]))
|
||||||
|
|
||||||
# 总订单数
|
# 总订单数
|
||||||
total_order_count = db.query(ShippingOrderDB).filter(
|
total_order_count = db.query(ShippingOrderDB).filter(
|
||||||
@ -84,7 +85,8 @@ async def partner_summary(
|
|||||||
).scalar()
|
).scalar()
|
||||||
|
|
||||||
return success_response(data=
|
return success_response(data=
|
||||||
{"community_count": len(community_ids),
|
{"set_names": "|".join(set_names),
|
||||||
|
"community_count": len(community_ids),
|
||||||
"total_order_count": total_order_count,
|
"total_order_count": total_order_count,
|
||||||
"today_order_count": today_order_count,
|
"today_order_count": today_order_count,
|
||||||
"yesterday_order_count": yesterday_order_count,
|
"yesterday_order_count": yesterday_order_count,
|
||||||
|
|||||||
BIN
jobs.sqlite
BIN
jobs.sqlite
Binary file not shown.
Loading…
Reference in New Issue
Block a user