沉降数据插入逻辑优化

2025-10-16 23:55:55 +08:00
parent ba093f1384
commit 32098cd2c1
1 changed files with 7 additions and 1 deletions
--- a/app/services/settlement_data.py
+++ b/app/services/settlement_data.py
@@ -245,7 +245,13 @@ class SettlementDataService(BaseService[SettlementData]):
                        )
                        if settlement:
                            # 跳过数据
-                            logger.info(f"Updated settlement data: {item_data.get('point_id')}-{item_data.get('NYID')}")
+                            logger.info(f"Continue settlement data: {item_data.get('point_id')}-{item_data.get('NYID')}")
+                            logger.info(f"Existing settlement data: {settlement}")
+                            failed_count += 1
+                            failed_items.append({
+                                'data': item_data,
+                                'error': '数据已存在，跳过插入操作'
+                            })
                            continue
                            # 更新操作
                            # settlement.CVALUE = item_data.get('CVALUE')