diff --git a/app/services/original_data.py b/app/services/original_data.py index c8178eb..59249b0 100644 --- a/app/services/original_data.py +++ b/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: