diff --git a/app/services/settlement_data.py b/app/services/settlement_data.py
index 21b912b..b880a6c 100644
--- a/app/services/settlement_data.py
+++ b/app/services/settlement_data.py
@@ -497,6 +497,9 @@ class SettlementDataService(BaseService[SettlementData]):
                                     'error': f'更新失败: {str(e)}'
                                 })
                                 logger.error(f"Failed to update record: {str(e)}")
+                        # 刷新更新到数据库
+                        db.flush()
+                        logger.info(f"Updated {updated_count} records successfully")
 
                     # ===== 执行批量插入 =====
                     if to_insert: