原始数据导入检查

app/services/original_data.py

@@ -62,6 +62,21 @@ class OriginalDataService(BaseService[OriginalData]):
                 failed_count = 0
                 failed_items = []
 
+                nyid = data[0].get('NYID')
+                is_exists = db.query(OriginalData).filter(
+                    OriginalData.NYID == nyid
+                ).count()
+
+                if is_exists > 0:
+                    return {
+                        'success': True,
+                        'message': '数据已存在',
+                        'total_count': 0,
+                        'success_count': success_count,
+                        'failed_count': failed_count,
+                        'failed_items': failed_items
+                    }
+
                 for item_data in data:
                     try: