生成镜像[0.2.7.9][ci]

README.md

@@ -192,5 +192,6 @@ def get_visible_data(current_user):
 
 
 
+
 生产环境用于创建数据库结构的临时命令：
 python manage.py shell -c "from elastic.es_connect import create_index_with_mapping; create_index_with_mapping()"

elastic/templates/elastic/manage.html

@@ -445,6 +445,11 @@ async function generateReport() {
   try {
     const params = buildReportParams();
     const resp = await fetch(`/elastic/report/?${params.toString()}`, { credentials: 'same-origin' });
+    const ct = (resp.headers.get('content-type') || '').toLowerCase();
+    if (!ct.includes('application/json')) {
+      const text = await resp.text();
+      throw new Error(text ? String(text).slice(0, 200) : `HTTP ${resp.status}`);
+    }
     const data = await resp.json();
     if (data.status !== 'success') {
       reportBox.className = 'search-result error';

elastic/templates/elastic/upload.html

@@ -494,6 +494,11 @@ uploadForm.addEventListener('submit', async (e) => {
       body: formData,
     });
     clearInterval(timer);
+    const ct = (resp.headers.get('content-type') || '').toLowerCase();
+    if (!ct.includes('application/json')) {
+      const text = await resp.text();
+      throw new Error(text ? String(text).slice(0, 200) : `HTTP ${resp.status}`);
+    }
     const data = await resp.json();
     if (!resp.ok || data.status !== 'success') {
       throw new Error(data.message || '上传识别失败');

elastic/views.py

@@ -8,6 +8,7 @@ import base64
 import json
 import csv
 import io
+from datetime import datetime, timezone, timedelta
 import tempfile
 import concurrent.futures
 from django.conf import settings
@@ -721,6 +722,7 @@ def upload_page(request):
 # 上传并识别（不入库）
 @require_http_methods(["POST"])
 def upload(request):
+    try:
         if request.session.get("user_id") is None:
             fallback_uid = request.POST.get("user_id") or request.GET.get("user_id")
             if fallback_uid:
@@ -740,11 +742,10 @@ def upload(request):
         images_dir = os.path.join(settings.MEDIA_ROOT, "images")
         os.makedirs(images_dir, exist_ok=True)
         
-    # 按照原始文件进行分组处理
         file_results = []
         
         for f in files:
-        group_images = [] # 存储该文件生成的所有图片路径信息 (abs_path, filename)
+            group_images = []
             is_pdf = f.name.lower().endswith('.pdf')
             
             if is_pdf:
@@ -779,7 +780,6 @@ def upload(request):
                         dst.write(chunk)
                 group_images.append((abs_path, filename))
 
-        # 对该组图片并行进行 OCR 识别
             def run_ocr(img_info):
                 abs_p, fname = img_info
                 try:
@@ -796,23 +796,24 @@ def upload(request):
                     if res:
                         group_data_list.append(res)
 
-        # 合并该文件的多页识别结果
             merged_group_data = {}
             for item in group_data_list:
-            if not isinstance(item, dict): continue
+                if not isinstance(item, dict):
+                    continue
                 for k, v in item.items():
                     key = str(k).strip()
-                if not key: continue
+                    if not key:
+                        continue
                     if key not in merged_group_data or merged_group_data.get(key) in (None, ''):
                         merged_group_data[key] = v
                     elif merged_group_data.get(key) != v:
                         base = key
                         idx = 2
-                    while f"{base}_{idx}" in merged_group_data: idx += 1
+                        while f"{base}_{idx}" in merged_group_data:
+                            idx += 1
                         merged_group_data[f"{base}_{idx}"] = v
 
             if not merged_group_data:
-            # 如果没识别到，至少保留一个空结构或者包含文件名的提示
                 merged_group_data = {"文件名": f.name, "提示": "未识别到具体内容"}
 
             rel_paths = [f"images/{img[1]}" for img in group_images]
@@ -830,6 +831,8 @@ def upload(request):
             "message": f"成功处理 {len(file_results)} 个文件，请确认数据后点击录入",
             "items": file_results,
         })
+    except Exception as e:
+        return JsonResponse({"status": "error", "message": str(e) or "上传失败"}, status=500)
 
 
 # 确认并入库
@@ -1024,7 +1027,7 @@ def analytics_types_view(request):
             size_int = int(size) if size is not None else 10
         except Exception:
             size_int = 10
-        data = es_analytics_types(gte=gte, lte=lte, size=size_int)
+        data = es_analytics_types(gte=gte, lte=lte, limit=size_int)
         return JsonResponse({"status": "success", "data": data})
     except Exception as e:
         return JsonResponse({"status": "error", "message": str(e)}, status=500)
@@ -1580,6 +1583,7 @@ def _dt_label(dt, interval: str):
 
 @require_http_methods(["GET"])
 def report_view(request):
+    try:
         session_user_id = request.session.get("user_id")
         if session_user_id is None:
             return JsonResponse({"status": "error", "message": "未登录"}, status=401)
@@ -1678,6 +1682,8 @@ def report_view(request):
                 },
             }
         )
+    except Exception as e:
+        return JsonResponse({"status": "error", "message": str(e) or "生成失败"}, status=500)
 
 
 @require_http_methods(["GET"])