|
@@ -643,17 +643,8 @@ def parse_pdf(pdf_id):
|
|
|
doc = fitz.open(temp_pdf_path)
|
|
doc = fitz.open(temp_pdf_path)
|
|
|
page_count = doc.page_count
|
|
page_count = doc.page_count
|
|
|
|
|
|
|
|
- # 获取当前最大页码
|
|
|
|
|
- conn = get_db_connection()
|
|
|
|
|
|
|
+ # 每个PDF的页码从1开始计算
|
|
|
max_page = 0
|
|
max_page = 0
|
|
|
- try:
|
|
|
|
|
- with conn.cursor() as cursor:
|
|
|
|
|
- cursor.execute("SELECT MAX(page_number) as max_page FROM genealogy_records")
|
|
|
|
|
- result = cursor.fetchone()
|
|
|
|
|
- if result and result['max_page']:
|
|
|
|
|
- max_page = result['max_page']
|
|
|
|
|
- finally:
|
|
|
|
|
- conn.close()
|
|
|
|
|
|
|
|
|
|
# 逐页处理
|
|
# 逐页处理
|
|
|
for i in range(page_count):
|
|
for i in range(page_count):
|
|
@@ -663,8 +654,11 @@ def parse_pdf(pdf_id):
|
|
|
pix.save(image_path)
|
|
pix.save(image_path)
|
|
|
|
|
|
|
|
# 上传图片到OSS
|
|
# 上传图片到OSS
|
|
|
- with open(image_path, 'rb') as f:
|
|
|
|
|
- image_oss_url = upload_to_oss(f, f"{pdf_info['file_name']}_page_{i+1}.png")
|
|
|
|
|
|
|
+ image_oss_url = upload_to_oss(image_path, f"{pdf_info['file_name']}_page_{i+1}.png")
|
|
|
|
|
+
|
|
|
|
|
+ # 检查上传是否成功
|
|
|
|
|
+ if not image_oss_url:
|
|
|
|
|
+ raise Exception(f"Failed to upload image to OSS: {image_path}")
|
|
|
|
|
|
|
|
# 保存到genealogy_records表
|
|
# 保存到genealogy_records表
|
|
|
conn = get_db_connection()
|
|
conn = get_db_connection()
|
|
@@ -747,6 +741,7 @@ def index():
|
|
|
|
|
|
|
|
page = request.args.get('page', 1, type=int)
|
|
page = request.args.get('page', 1, type=int)
|
|
|
version = request.args.get('version', '').strip()
|
|
version = request.args.get('version', '').strip()
|
|
|
|
|
+ print(f"Received version parameter: '{version}'")
|
|
|
source = request.args.get('source', '').strip()
|
|
source = request.args.get('source', '').strip()
|
|
|
person = request.args.get('person', '').strip()
|
|
person = request.args.get('person', '').strip()
|
|
|
file_type = request.args.get('file_type', '').strip()
|
|
file_type = request.args.get('file_type', '').strip()
|
|
@@ -1182,7 +1177,8 @@ def add_member():
|
|
|
'family_rank': request.form.get('family_rank'),
|
|
'family_rank': request.form.get('family_rank'),
|
|
|
'tags': request.form.get('tags'),
|
|
'tags': request.form.get('tags'),
|
|
|
'notes': request.form.get('notes'),
|
|
'notes': request.form.get('notes'),
|
|
|
- 'source_record_id': request.form.get('source_record_id') or None # Save source record ID
|
|
|
|
|
|
|
+ 'source_record_id': request.form.get('source_record_id') or None, # Save source record ID
|
|
|
|
|
+ 'create_uid': session['user_id'] # 记录当前操作人
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
# ... (rest of logic) ...
|
|
# ... (rest of logic) ...
|
|
@@ -1340,7 +1336,8 @@ def edit_member(member_id):
|
|
|
'family_rank': request.form.get('family_rank'),
|
|
'family_rank': request.form.get('family_rank'),
|
|
|
'tags': request.form.get('tags'),
|
|
'tags': request.form.get('tags'),
|
|
|
'notes': request.form.get('notes'),
|
|
'notes': request.form.get('notes'),
|
|
|
- 'source_record_id': request.form.get('source_record_id') or None
|
|
|
|
|
|
|
+ 'source_record_id': request.form.get('source_record_id') or None,
|
|
|
|
|
+ 'create_uid': session['user_id'] # 记录当前操作人
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
# 关系数据
|
|
# 关系数据
|