From 95882d5f96dbdf7cefde893c4fdc74ad82a23bfd Mon Sep 17 00:00:00 2001 From: aaron <> Date: Fri, 14 Mar 2025 08:47:55 +0800 Subject: [PATCH] update --- app/tasks/daily_tasks.py | 14 +++++++++----- jobs.sqlite | Bin 24576 -> 24576 bytes 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/app/tasks/daily_tasks.py b/app/tasks/daily_tasks.py index bbb0a14..7482664 100644 --- a/app/tasks/daily_tasks.py +++ b/app/tasks/daily_tasks.py @@ -247,6 +247,14 @@ async def daily_partner_settlement(): settlement_history = [] for stat in yesterday_stats: + community = db.query(CommunityDB).filter( + CommunityDB.id == stat.community_id, + CommunityDB.community_profit_sharing != None + ).first() + + if not community: + logger.info(f"小区 {stat.community_name} 没有分成比例,跳过结算") + continue # 检查是否已存在该日期的结算记录 existing_settlement = db.query(SettlementHistoryDB).filter( @@ -270,10 +278,6 @@ async def daily_partner_settlement(): total_original_amount += stat.total_original_amount total_final_amount += stat.total_final_amount - community = db.query(CommunityDB).filter( - CommunityDB.id == stat.community_id - ).first() - # 找到所有的运营商 community_sets = db.query(CommunitySet).filter( CommunitySet.community_set_mappings.any( @@ -377,7 +381,7 @@ async def daily_partner_settlement(): settle_details=settle_details ) settlement_history.append(settlement) - + db.add_all(settlement_history) db.commit() diff --git a/jobs.sqlite b/jobs.sqlite index 41011d691cb9800b99e01160026efdc51dd31a28..c9039fb8c6d656dc6507fab9a1b96a38faf51b79 100644 GIT binary patch delta 71 zcmZoTz}Rqrae_3X`a~ILM)i#eC&k#WM0PZ=PIa2>=q|I_M_iVLk$-cR^n4Na@BHuh bfAIgW delta 71 zcmZoTz}Rqrae_3Xz(g5mMuCk9C&kz=b8s}UPIa2>=q|I_M_iVLk#BRB^n4Nacl_V^ bfAIg