页面部分实现

1.1/frps.py

@@ -0,0 +1,135 @@
+import requests
+import json
+import os
+from datetime import datetime
+
+# --- 配置保持不变 ---
+BASE_URL = "http://106.75.72.40:7500/api/proxy/tcp"
+PRIMARY_AUTH = "Basic YWRtaW46bGljYWhr"
+X_AUTH = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyIjp7ImlkIjoxLCJsb2NhbGUiOiJ6aC1jbiIsInZpZXdNb2RlIjoibGlzdCIsInNpbmdsZUNsaWNrIjpmYWxzZSwicGVybSI6eyJhZG1pbiI6dHJ1ZSwiZXhlY3V0ZSI6dHJ1ZSwiY3JlYXRlIjp0cnVlLCJyZW5hbWUiOnRydWUsIm1vZGlmeSI6dHJ1ZSwiZGVsZXRlIjp0cnVlLCJzaGFyZSI6dHJ1ZSwiZG93bmxvYWQiOnRydWV9LCJjb21tYW5kcyI6W10sImxvY2tQYXNzd29yZCI6ZmFsc2UsImhpZGVEb3RmaWxlcyI6ZmFsc2V9LCJleHAiOjE3Njc2Njg3NzgsImlhdCI6MTc2NzY2MTU3OCwiaXNzIjoiRmlsZSBCcm93c2VyIn0.z9zycFSf3XpUDRhGjziUJ-PUeHIsRba23AI6itqXM-w"
+
+headers = {
+    "Authorization": PRIMARY_AUTH,
+    "x-auth": X_AUTH,
+    "User-Agent": "Mozilla/5.0"
+}
+
+
+def get_today_str():
+    return datetime.now().strftime("%Y_%m_%d")
+
+
+def find_closest_item(items, is_date_level=True):
+    if not items or not isinstance(items, list): return None
+    today = datetime.now()
+    scored_items = []
+    for item in items:
+        if not isinstance(item, dict): continue
+        path = item.get('path', '')
+        if not path: continue
+        try:
+            if is_date_level:
+                date_str = path.split('/')[-1]
+                current_date = datetime.strptime(date_str, "%Y_%m_%d")
+            else:
+                mod_str = item.get('modified', '')
+                if mod_str:
+                    current_date = datetime.fromisoformat(mod_str.replace('Z', '+00:00'))
+                else:
+                    continue
+            diff = abs((today - current_date.replace(tzinfo=None)).total_seconds())
+            scored_items.append((diff, item))
+        except:
+            continue
+
+    if not scored_items: return None
+    scored_items.sort(key=lambda x: x[0])
+    return scored_items[0][1]
+
+
+def debug_process_106():
+    today_str = get_today_str()
+    print(f"=== 开始 106 网站深度调试 (目标日期: {today_str}) ===")
+
+    try:
+        resp = requests.get(BASE_URL, headers=headers, timeout=15)
+        if resp.status_code != 200:
+            print(f"❌ 错误: 主接口访问失败, 状态码: {resp.status_code}")
+            return
+
+        proxies = resp.json().get('proxies', [])
+        data_proxies = [p for p in proxies if p.get('name', '').endswith('_data')]
+
+        for item in data_proxies:
+            name = item.get('name', 'Unknown')
+            # 每一个站点的处理都包裹在独立的 try 里，防止相互干扰
+            try:
+                status = str(item.get('status', '')).lower().strip()
+                conf = item.get('conf') or {}
+                port = conf.get('remote_port')
+
+                print(f"--- [检查站点: {name}] ---")
+
+                if status != 'online':
+                    print(f"   ⚠ 判定错误: 站点离线 ({status})")
+                    continue
+
+                if not port:
+                    print(f"   ❌ 判定错误: 缺少端口配置")
+                    continue
+
+                # Data 目录请求
+                res2 = requests.get(f"http://106.75.72.40:{port}/api/resources/Data/", headers=headers, timeout=10)
+                if res2.status_code != 200:
+                    print(f"   ❌ 判定错误: Data目录 HTTP {res2.status_code}")
+                    continue
+
+                it2 = res2.json().get('items', [])
+                closest_date = find_closest_item(it2, True)
+                if not closest_date:
+                    print(f"   ❌ 判定错误: Data目录为空")
+                    continue
+
+                path_date = closest_date.get('path', '')
+                date_val = path_date.split('/')[-1]
+
+                if date_val != today_str:
+                    print(f"   ⚠ 判定错误: 日期不符 (最新: {date_val})")
+                    continue
+
+                # 文件列表请求
+                res3 = requests.get(f"http://106.75.72.40:{port}/api/resources{path_date}/", headers=headers,
+                                    timeout=10)
+                it3 = res3.json().get('items', [])
+                closest_file = find_closest_item(it3, False)
+                if not closest_file:
+                    print(f"   ❌ 判定错误: 日期文件夹内无文件")
+                    continue
+
+                # 文件内容请求 - 关键防御点
+                path_csv = closest_file.get('path', '')
+                res4 = requests.get(f"http://106.75.72.40:{port}/api/resources{path_csv}", headers=headers, timeout=10)
+
+                try:
+                    file_data = res4.json()
+                    if file_data is None:
+                        print(f"   ❌ 判定错误: 接口返回了 Null (NoneType)")
+                        continue
+
+                    content = file_data.get('content', '')
+                    if not content:
+                        print(f"   ❌ 判定错误: content 字段为空")
+                    else:
+                        print(f"   ✅ 检查通过: 数据最新，长度 {len(content)}")
+                except Exception as json_e:
+                    print(f"   ❌ 判定错误: 解析 JSON 失败 (非标准格式)")
+
+            except Exception as site_e:
+                print(f"   ❌ 判定错误: 站点逻辑崩溃: {site_e}")
+
+    except Exception as global_e:
+        print(f"❌ 全局严重错误: {global_e}")
+
+
+if __name__ == "__main__":
+    debug_process_106()

1.1/frps_final.py

@@ -0,0 +1,169 @@
+import requests
+import json
+import os
+from datetime import datetime
+
+# --- 基础配置 ---
+BASE_URL = "http://106.75.72.40:7500/api/proxy/tcp"
+PRIMARY_AUTH = "Basic YWRtaW46bGljYWhr"
+LOGIN_PAYLOAD = {"username": "admin", "password": "licahk", "recaptcha": ""}
+
+SAVE_DIR = "downloaded_data"
+if not os.path.exists(SAVE_DIR):
+    os.makedirs(SAVE_DIR)
+
+
+def get_today_str():
+    return datetime.now().strftime("%Y_%m_%d")
+
+
+def get_dynamic_token(port):
+    """
+    为指定端口的站点执行登录，获取最新的 x-auth token
+    """
+    login_url = f"http://106.75.72.40:{port}/api/login"
+    try:
+        # 登录不需要 x-auth，只需要 Basic Auth 或特定的 Payload
+        resp = requests.post(login_url, json=LOGIN_PAYLOAD, timeout=10)
+        if resp.status_code == 200:
+            # 登录成功后，token 通常直接返回在响应体中（纯字符串或 JSON）
+            token = resp.text.strip().replace('"', '')
+            return token
+        else:
+            print(f"   ❌ 登录失败: 端口 {port}, 状态码 {resp.status_code}")
+            return None
+    except Exception as e:
+        print(f"   ❌ 登录异常: {port}, {e}")
+        return None
+
+
+def find_closest_item(items, is_date_level=True):
+    if not items or not isinstance(items, list): return None
+    today = datetime.now()
+    scored_items = []
+    today_str = get_today_str()
+
+    for item in items:
+        name_val = item.get('name', '')
+        path_val = item.get('path', '')
+        target_str = name_val if name_val else path_val.split('/')[-1]
+
+        try:
+            if is_date_level:
+                current_date = datetime.strptime(target_str, "%Y_%m_%d")
+            else:
+                mod_str = item.get('modified', '')
+                current_date = datetime.fromisoformat(mod_str.replace('Z', '+00:00'))
+
+            diff = abs((today - current_date.replace(tzinfo=None)).total_seconds())
+            scored_items.append((diff, item, target_str))
+        except:
+            continue
+
+    if not scored_items: return None
+    scored_items.sort(key=lambda x: x[0])
+    return scored_items[0]
+
+
+def process_site(proxy_item):
+    name = proxy_item.get('name', '')
+    # 严格过滤：只处理以 _data 结尾的站点
+    if not name.lower().endswith('_data'):
+        return
+
+    name_upper = name.upper()
+    is_tower_underscore = "TOWER_" in name_upper
+    is_tower_i = "TOWER" in name_upper and not is_tower_underscore
+
+    if not (is_tower_underscore or is_tower_i):
+        return
+
+    print(f"\n--- [正在处理站点: {name}] ---")
+    try:
+        port = proxy_item.get('conf', {}).get('remote_port')
+        if not port: return
+
+        # 动态获取当前站点的 Token
+        token = get_dynamic_token(port)
+        if not token:
+            print(f"   跳过: 无法获取有效的 x-auth")
+            return
+
+        headers = {
+            "Authorization": PRIMARY_AUTH,
+            "x-auth": token,
+            "User-Agent": "Mozilla/5.0"
+        }
+        today_str = get_today_str()
+
+        # Step 1: 进入 data 根目录 (路径根据类型区分大小写)
+        api_root = "/api/resources/Data/" if is_tower_underscore else "/api/resources/data/"
+        res1 = requests.get(f"http://106.75.72.40:{port}{api_root}", headers=headers, timeout=10)
+
+        # Step 2: 寻找并进入日期目录
+        items1 = res1.json().get('items', [])
+        best_date = find_closest_item(items1, is_date_level=True)
+        if not best_date or best_date[2] != today_str:
+            print(f"   ⚠ 跳过: 未找到今日 ({today_str}) 的文件夹")
+            return
+
+        date_path = f"{api_root}{best_date[2]}/"
+        res2 = requests.get(f"http://106.75.72.40:{port}{date_path}", headers=headers, timeout=10)
+
+        # Step 3: 寻找日期目录下的最新文件
+        items2 = res2.json().get('items', [])
+        best_file = find_closest_item(items2, is_date_level=False)
+        if not best_file:
+            print(f"   ❌ 日期文件夹内无文件")
+            return
+
+        # 获取文件的完整 path
+        file_item = best_file[1]
+        full_path = file_item.get('path')
+        if not full_path:
+            full_path = f"{date_path}{file_item.get('name')}"
+
+        # --- 获取内容层级 (根据站点类型采用不同接口) ---
+        if is_tower_i:
+            # TowerI 模式：使用 /api/raw/{path} 获取二进制流
+            download_url = f"http://106.75.72.40:{port}/api/raw{full_path}"
+            res3 = requests.get(download_url, headers=headers, timeout=20, stream=True)
+            if res3.status_code == 200:
+                save_path = os.path.join(SAVE_DIR, f"{name}_{today_str}.bin")
+                with open(save_path, 'wb') as f:
+                    f.write(res3.content)
+                print(f"   ✅ 二进制保存成功: {save_path} (大小: {len(res3.content)} 字节)")
+        else:
+            # Tower_ 模式：原来的 JSON content 模式
+            file_api_url = f"http://106.75.72.40:{port}/api/resources{full_path}"
+            res3 = requests.get(file_api_url, headers=headers, timeout=20)
+            try:
+                content_str = res3.json().get('content', '')
+                if content_str:
+                    save_path = os.path.join(SAVE_DIR, f"{name}_{today_str}.json")
+                    with open(save_path, 'w', encoding='utf-8') as f:
+                        f.write(content_str)
+                    print(f"   ✅ JSON数据保存成功: {save_path}")
+            except:
+                print(f"   ❌ TOWER_ 站点格式错误或无内容")
+
+    except Exception as e:
+        print(f"   ❌ 站点处理失败: {str(e)}")
+
+
+def main():
+    print(f"任务启动: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}")
+    # 主接口获取站点列表
+    try:
+        # 注意：主控制台可能也需要 token，这里先用硬编码，如果不行也需要为 7500 端口做登录
+        main_headers = {"Authorization": PRIMARY_AUTH, "User-Agent": "Mozilla/5.0"}
+        resp = requests.get(BASE_URL, headers=main_headers, timeout=15)
+        proxies = resp.json().get('proxies', [])
+        for p in proxies:
+            process_site(p)
+    except Exception as e:
+        print(f"❌ 全局错误: {e}")
+
+
+if __name__ == "__main__":
+    main()

1.1/test1.py

@@ -0,0 +1,313 @@
+import os
+import json
+import time
+import threading
+import requests
+from datetime import datetime
+from flask import Flask, jsonify
+from flask_sqlalchemy import SQLAlchemy
+from flask_cors import CORS
+from lxml import etree
+
+# --- 初始化 Flask App ---
+app = Flask(__name__)
+CORS(app)  # 解决前端 Vite 5173 端口的跨域问题
+
+# --- 数据库配置 (SQLite) ---
+# 数据库文件将生成在 backend 目录下
+app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///monitor_data.db'
+app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
+db = SQLAlchemy(app)
+
+
+# --- 数据库模型 ---
+class ErrorLog(db.Model):
+    id = db.Column(db.Integer, primary_key=True)
+    source = db.Column(db.String(50))  # 106网站 / 82网站
+    name = db.Column(db.String(100))  # 设备名称/站点ID
+    reason = db.Column(db.String(255))  # 状态描述
+    offset = db.Column(db.String(50))  # 日期偏移 (如: 滞后 2 天)
+    latest_time = db.Column(db.String(50))  # 最新文件日期
+    check_time = db.Column(db.String(50))  # 本次检查时间
+    content = db.Column(db.Text, nullable=True)  # 专门存储 Tower_ 站点的 JSON 内容
+
+
+# 每次启动时确保表结构已建立
+with app.app_context():
+    db.create_all()
+
+# --- 基础配置 ---
+DATA_ROOT = "data"
+FRPS_DIR = os.path.join(DATA_ROOT, "frps_106")
+WEATHER_DIR = os.path.join(DATA_ROOT, "weather_82")
+
+for d in [FRPS_DIR, WEATHER_DIR]:
+    os.makedirs(d, exist_ok=True)
+
+CONFIG = {
+    "106": {
+        "base_url": "http://106.75.72.40:7500/api/proxy/tcp",
+        "primary_auth": "Basic YWRtaW46bGljYWhr",
+        "login_payload": {"username": "admin", "password": "licahk", "recaptcha": ""}
+    },
+    "82": {
+        "base_url": "http://82.156.1.111/weather/php",
+        "login": {'username': 'renlixin', 'password': 'licahk', 'login': '123'}
+    }
+}
+
+is_running = False  # 全局任务状态锁
+
+
+# --- 通用工具函数 ---
+
+def add_error_to_db(source, name, reason, latest_time="N/A", content=None):
+    """计算日期偏移并记录到数据库"""
+    days_diff = "N/A"
+    if latest_time and latest_time != "N/A":
+        try:
+            # 兼容 2024_01_01 和 2024-01-01 格式
+            clean_date_str = str(latest_time).split()[0].replace('_', '-')
+            target_date = datetime.strptime(clean_date_str, "%Y-%m-%d").date()
+            today_date = datetime.now().date()
+            diff = (today_date - target_date).days
+            days_diff = f"滞后 {diff} 天" if diff > 0 else "当天已同步"
+        except:
+            days_diff = "解析失败"
+
+    log = ErrorLog(
+        source=source,
+        name=name,
+        reason=reason,
+        offset=days_diff,
+        latest_time=latest_time,
+        check_time=datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
+        content=content
+    )
+    db.session.add(log)
+
+
+def find_closest_item(items, is_date_level=True):
+    if not items or not isinstance(items, list): return None
+    today = datetime.now()
+    scored_items = []
+    for item in items:
+        if not isinstance(item, dict): continue
+        name_val = item.get('name', '')
+        path_val = item.get('path', '')
+        target_str = name_val if name_val else path_val.split('/')[-1]
+        try:
+            if is_date_level:
+                current_date = datetime.strptime(target_str, "%Y_%m_%d")
+            else:
+                mod_str = item.get('modified', '')
+                if mod_str:
+                    current_date = datetime.fromisoformat(mod_str.replace('Z', '+00:00'))
+                else:
+                    continue
+            diff = abs((today - current_date.replace(tzinfo=None)).total_seconds())
+            scored_items.append((diff, item, target_str))
+        except:
+            continue
+    if not scored_items: return None
+    scored_items.sort(key=lambda x: x[0])
+    return scored_items[0]
+
+
+def process_text_content(raw_content):
+    if not raw_content: return ""
+    lines = str(raw_content).split('\n')
+    result, current = [], ""
+    for line in lines:
+        if "    " in line:
+            current += line.strip()
+        else:
+            if current: result.append(current)
+            current = line.strip()
+    if current: result.append(current)
+    return "\n".join(result)
+
+
+# --- 106 业务逻辑 ---
+
+def get_106_dynamic_token(port):
+    url = f"http://106.75.72.40:{port}/api/login"
+    try:
+        resp = requests.post(url, json=CONFIG["106"]["login_payload"], timeout=10)
+        if resp.status_code == 200:
+            return resp.text.strip().replace('"', '')
+    except:
+        pass
+    return None
+
+
+def run_106_logic():
+    c = CONFIG["106"]
+    today_str = datetime.now().strftime("%Y_%m_%d")
+    try:
+        main_headers = {"Authorization": c["primary_auth"], "User-Agent": "Mozilla/5.0"}
+        resp = requests.get(c["base_url"], headers=main_headers, timeout=15)
+        if resp.status_code != 200:
+            add_error_to_db("106网站", "主入口API", f"访问失败: HTTP {resp.status_code}")
+            return
+
+        for item in resp.json().get('proxies', []):
+            name = item.get('name', 'Unknown')
+            if not name.lower().endswith('_data'): continue
+
+            status = str(item.get('status', '')).lower().strip()
+            if status != 'online':
+                add_error_to_db("106网站", name, f"设备离线 ({status})")
+                continue
+
+            name_up = name.upper()
+            is_tower_underscore = "TOWER_" in name_up
+            is_tower_i = "TOWER" in name_up and not is_tower_underscore
+            if not (is_tower_underscore or is_tower_i): continue
+
+            try:
+                port = item.get('conf', {}).get('remote_port')
+                token = get_106_dynamic_token(port)
+                if not token:
+                    add_error_to_db("106网站", name, "Token获取失败")
+                    continue
+
+                headers = {"Authorization": c["primary_auth"], "x-auth": token, "User-Agent": "Mozilla/5.0"}
+                api_root = "/api/resources/Data/" if is_tower_underscore else "/api/resources/data/"
+
+                res2 = requests.get(f"http://106.75.72.40:{port}{api_root}", headers=headers, timeout=10)
+                best_date = find_closest_item(res2.json().get('items', []), is_date_level=True)
+
+                if not best_date or best_date[2] != today_str:
+                    add_error_to_db("106网站", name, "未找到今日文件夹", best_date[2] if best_date else "N/A")
+                    continue
+
+                date_path = f"{api_root}{best_date[2]}/"
+                res3 = requests.get(f"http://106.75.72.40:{port}{date_path}", headers=headers, timeout=10)
+                best_file = find_closest_item(res3.json().get('items', []), is_date_level=False)
+
+                if not best_file:
+                    add_error_to_db("106网站", name, "文件夹内无文件", best_date[2])
+                    continue
+
+                file_item = best_file[1]
+                full_path = file_item.get('path') or f"{date_path}{file_item.get('name')}"
+
+                if is_tower_i:
+                    # TowerI 模式：.bin 文件存入磁盘
+                    raw_url = f"http://106.75.72.40:{port}/api/raw{full_path}"
+                    res4 = requests.get(raw_url, headers=headers, timeout=20)
+                    if res4.status_code == 200:
+                        save_path = os.path.join(FRPS_DIR, f"{name}_{today_str}.bin")
+                        with open(save_path, 'wb') as f:
+                            f.write(res4.content)
+                        add_error_to_db("106网站", name, "运行正常 (Bin已存盘)", today_str)
+                else:
+                    # Tower_ 模式：JSON 内容存入数据库
+                    file_api_url = f"http://106.75.72.40:{port}/api/resources{full_path}"
+                    res4 = requests.get(file_api_url, headers=headers, timeout=20)
+                    file_json = res4.json()
+                    raw_content = file_json.get('content', '') if file_json else None
+                    if raw_content:
+                        clean_content = process_text_content(raw_content)
+                        add_error_to_db("106网站", name, "运行正常", today_str, content=clean_content)
+                    else:
+                        add_error_to_db("106网站", name, "JSON内容为空", best_date[2])
+
+            except Exception as e:
+                add_error_to_db("106网站", name, f"站点处理崩溃: {str(e)}")
+    except Exception as e:
+        add_error_to_db("106网站", "全局逻辑", str(e))
+
+
+# --- 82 业务逻辑 ---
+
+def run_82_logic():
+    c = CONFIG["82"]
+    session = requests.Session()
+    today_fmt = datetime.now().strftime("%Y-%m-%d")
+    try:
+        session.post(f"{c['base_url']}/login.php", data=c["login"], timeout=10)
+        resp = session.post(f"{c['base_url']}/GetStationList.php", timeout=10)
+        stations = etree.HTML(resp.content).xpath('//option/@value')
+        stations = [s for s in stations if s and str(s).strip()]
+
+        for sid in stations:
+            try:
+                r = session.post(f"{c['base_url']}/getLastWeatherData.php", data=str(sid),
+                                 headers={'Content-Type': 'text/plain'}, timeout=10)
+                data = r.json()
+                if not data:
+                    add_error_to_db("82网站", sid, "返回 Null 数据")
+                    continue
+
+                latest = str(data.get('date', ['N/A'])[-1])
+                status_msg = "当天已同步" if latest.startswith(today_fmt) else "数据滞后"
+                # 82网站数据通常直接存为文件备查，记录入库
+                add_error_to_db("82网站", sid, status_msg, latest)
+
+                # 可选：将82网站的完整JSON也存入content
+                # db.session.query(ErrorLog).filter_by(name=sid).update({"content": json.dumps(data, ensure_ascii=False)})
+
+            except Exception as e:
+                add_error_to_db("82网站", sid, f"请求异常: {str(e)}")
+    except Exception as e:
+        add_error_to_db("82网站", "初始化模块", str(e))
+
+
+# --- 任务调度 ---
+
+def background_worker():
+    global is_running
+    with app.app_context():
+        try:
+            # 1. 覆盖逻辑：清空旧数据
+            ErrorLog.query.delete()
+            db.session.commit()
+
+            # 2. 执行爬虫
+            run_106_logic()
+            run_82_logic()
+
+            # 3. 最终提交
+            db.session.commit()
+        except Exception as e:
+            print(f"后台任务出错: {e}")
+        finally:
+            is_running = False
+
+
+# --- API 路由 ---
+
+@app.route('/api/run', methods=['POST'])
+def trigger_run():
+    global is_running
+    if is_running:
+        return jsonify({"message": "Task already running"}), 400
+    is_running = True
+    threading.Thread(target=background_worker).start()
+    return jsonify({"message": "Task started"})
+
+
+@app.route('/api/status', methods=['GET'])
+def get_status():
+    return jsonify({"is_running": is_running})
+
+
+@app.route('/api/logs', methods=['GET'])
+def get_logs():
+    logs = ErrorLog.query.order_by(ErrorLog.source.desc()).all()
+    return jsonify([{
+        "source": l.source,
+        "name": l.name,
+        "reason": l.reason,
+        "offset": l.offset,
+        "latest_time": l.latest_time,
+        "check_time": l.check_time,
+        "content": l.content
+    } for l in logs])
+
+
+if __name__ == "__main__":
+    # 使用 5000 端口，请确保前端 Vite 配置了正确的 Proxy
+    app.run(host="0.0.0.0", port=5000, debug=True)

1.1/光谱气象站final.py

@@ -0,0 +1,121 @@
+import os
+import json
+import time
+import requests
+from lxml import etree
+from datetime import datetime
+
+# --- 配置区 ---
+BASE_URL = "http://82.156.1.111/weather/php"
+LOGIN_DATA = {'username': 'renlixin', 'password': 'licahk', 'login': '123'}
+OUTPUT_DIR = "weather_data_test"
+os.makedirs(OUTPUT_DIR, exist_ok=True)
+
+session = requests.Session()
+
+
+def fetch_stations():
+    resp = session.post(f"{BASE_URL}/GetStationList.php")
+    if resp.status_code != 200: return []
+    tree = etree.HTML(resp.content)
+    stations = [s for s in tree.xpath('//option/@value') if s and str(s).strip()]
+    return stations
+
+
+def get_latest_data_item(station_id, data_list):
+    """
+    核心改进：从列表中筛选出日期距离今天最近的一条数据
+    """
+    if not data_list or not isinstance(data_list, list):
+        return None
+
+    today = datetime.now().date()
+    parsed_items = []
+
+    for item in data_list:
+        try:
+            # 兼容处理：如果是字符串列表，直接解析；如果是对象列表，取特定键
+            date_str = item.split()[0] if isinstance(item, str) else item.get('date', '').split()[0]
+            current_date = datetime.strptime(date_str, "%Y-%m-%d").date()
+
+            # 计算与今天的差异（天数绝对值）
+            diff = abs((today - current_date).days)
+            parsed_items.append({
+                'diff': diff,
+                'date_obj': current_date,
+                'original_data': item
+            })
+        except:
+            continue
+
+    if not parsed_items:
+        return None
+
+    # --- 逻辑更新：按时间差异升序排序（diff越小说明离今天越近） ---
+    parsed_items.sort(key=lambda x: x['diff'])
+
+    # 返回距离最近的那一条原始数据
+    return parsed_items[0]
+
+
+def save_json(name, data):
+    path = os.path.join(OUTPUT_DIR, f"{name}.json")
+    with open(path, 'w', encoding='utf-8') as f:
+        json.dump(data, f, indent=2, ensure_ascii=False)
+
+
+def main():
+    print("正在登录...")
+    session.post(f"{BASE_URL}/login.php", data=LOGIN_DATA)
+
+    stations = fetch_stations()
+    print(f"成功获取 {len(stations)} 个有效站点")
+
+    for i, sid in enumerate(stations, 1):
+        print(f"[{i}/{len(stations)}] 处理站点: {sid}")
+        try:
+            resp = session.post(f"{BASE_URL}/getLastWeatherData.php",
+                                data=str(sid),
+                                headers={'Content-Type': 'text/plain'})
+
+            if resp.status_code == 200:
+                full_data = resp.json()
+
+                # 假设 API 返回的 JSON 中 'date' 键对应的是数据列表
+                # 我们调用 get_latest_data_item 来锁定那唯一的一条最新数据
+                data_key = 'date' if 'date' in full_data else 'items'  # 根据实际键名调整
+                target_list = full_data.get(data_key, [])
+
+                latest_result = get_latest_data_item(sid, target_list)
+
+                if latest_result:
+                    # 重新构造保存内容：只保留最接近今天的数据
+                    final_payload = {
+                        "proxy_name": sid,
+                        "status": "online",
+                        "latest_date": str(latest_result['date_obj']),
+                        "days_diff": latest_result['diff'],
+                        "data_content": latest_result['original_data']
+                    }
+
+                    # 如果不是今天，输出警告
+                    if latest_result['diff'] != 0:
+                        print(f"  ⚠️  非当天数据: {latest_result['date_obj']} (差 {latest_result['diff']} 天)")
+                    else:
+                        print(f"  ✨ 数据已同步至今天")
+
+                    save_json(sid, final_payload)
+                else:
+                    print(f"  ⚪ 站点 {sid} 未找到有效日期数据")
+
+            else:
+                print(f"  ❌ 请求失败: {resp.status_code}")
+
+        except Exception as e:
+            print(f"  ❌ 错误: {e}")
+
+        time.sleep(0.3)
+
+
+if __name__ == "__main__":
+    main()

1.1/整合.py

@@ -19,7 +19,7 @@ CONFIG = {
     "106": {
         "base_url": "http://106.75.72.40:7500/api/proxy/tcp",
         "primary_auth": "Basic YWRtaW46bGljYWhr",
-        "x_auth": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VyIjp7ImlkIjoxLCJsb2NhbGUiOiJ6aC1jbiIsInZpZXdNb2RlIjoibGlzdCIsInNpbmdsZUNsaWNrIjpmYWxzZSwicGVybSI6eyJhZG1pbiI6dHJ1ZSwiZXhlY3V0ZSI6dHJ1ZSwiY3JlYXRlIjp0cnVlLCJyZW5hbWUiOnRydWUsIm1vZGlmeSI6dHJ1ZSwiZGVsZXRlIjp0cnVlLCJzaGFyZSI6dHJ1ZSwiZG93bmxvYWQiOnRydWV9LCJjb21tYW5kcyI6W10sImxvY2tQYXNzd29yZCI6ZmFsc2UsImhpZGVEb3RmaWxlcyI6ZmFsc2V9LCJleHAiOjE3Njc2Njg3NzgsImlhdCI6MTc2NzY2MTU3OCwiaXNzIjoiRmlsZSBCcm93c2VyIn0.z9zycFSf3XpUDRhGjziUJ-PUeHIsRba23AI6itqXM-w"
+        "login_payload": {"username": "admin", "password": "licahk", "recaptcha": ""}
     },
     "82": {
         "base_url": "http://82.156.1.111/weather/php",
@@ -37,7 +37,6 @@ def add_error(source, name, reason, latest_time="N/A"):
     days_diff = "N/A"
     if latest_time and latest_time != "N/A":
         try:
-            # 兼容 2026_01_06 和 2026-01-06 格式
             clean_date_str = str(latest_time).split()[0].replace('_', '-')
             target_date = datetime.strptime(clean_date_str, "%Y-%m-%d").date()
             today_date = datetime.now().date()
@@ -63,12 +62,12 @@ def find_closest_item(items, is_date_level=True):
     scored_items = []
     for item in items:
         if not isinstance(item, dict): continue
-        path = item.get('path', '')
+        name_val = item.get('name', '')
-        if not path: continue
+        path_val = item.get('path', '')
+        target_str = name_val if name_val else path_val.split('/')[-1]
         try:
             if is_date_level:
-                date_str = path.split('/')[-1]
+                current_date = datetime.strptime(target_str, "%Y_%m_%d")
-                current_date = datetime.strptime(date_str, "%Y_%m_%d")
             else:
                 mod_str = item.get('modified', '')
                 if mod_str:
@@ -76,13 +75,12 @@ def find_closest_item(items, is_date_level=True):
                 else:
                     continue
             diff = abs((today - current_date.replace(tzinfo=None)).total_seconds())
-            scored_items.append((diff, item))
+            scored_items.append((diff, item, target_str))
         except:
             continue
-
     if not scored_items: return None
     scored_items.sort(key=lambda x: x[0])
-    return scored_items[0][1]
+    return scored_items[0]
 
 
 def process_text_content(raw_content):
@@ -105,16 +103,28 @@ def save_json(folder, name, data):
         json.dump(data, f, indent=4, ensure_ascii=False)
 
 
-# --- 106 网站逻辑 (强化防御版) ---
+# --- 106 网站逻辑 ---
+
+def get_106_dynamic_token(port):
+    """为106特定端口站点执行登录获取 Token"""
+    url = f"http://106.75.72.40:{port}/api/login"
+    try:
+        resp = requests.post(url, json=CONFIG["106"]["login_payload"], timeout=10)
+        if resp.status_code == 200:
+            return resp.text.strip().replace('"', '')
+    except:
+        pass
+    return None
+
 
 def run_106_logic():
-    print("\n>>> 开始处理 106 网站 (FRPS)...")
+    print("\n>>> 开始处理 106 网站 (FRPS - 修正逻辑)...")
     c = CONFIG["106"]
-    headers = {"Authorization": c["primary_auth"], "x-auth": c["x_auth"], "User-Agent": "Mozilla/5.0"}
     today_str = datetime.now().strftime("%Y_%m_%d")
 
     try:
-        resp = requests.get(c["base_url"], headers=headers, timeout=15)
+        main_headers = {"Authorization": c["primary_auth"], "User-Agent": "Mozilla/5.0"}
+        resp = requests.get(c["base_url"], headers=main_headers, timeout=15)
         if resp.status_code != 200:
             add_error("106网站", "主入口API", f"访问失败: HTTP {resp.status_code}")
             return
@@ -123,81 +133,97 @@ def run_106_logic():
         for item in proxies:
             if not isinstance(item, dict): continue
             name = item.get('name', 'Unknown')
-            if not name.endswith('_data'): continue
+            if not name.lower().endswith('_data'): continue
 
-            try:
+            # 1. 状态预检 - 离线拦截逻辑
-                # 1. 状态预检 - 彻底解决 NoneType 问题
             status_raw = item.get('status', '')
             status = str(status_raw).lower().strip() if status_raw else "unknown"
 
-                conf = item.get('conf') or {}
+            # 如果离线，直接保存并记录错误，不再进行后续 API 访问
-                port = conf.get('remote_port')
-
-                # 离线直接判定，严禁继续访问二级接口
             if status != 'online':
                 add_error("106网站", name, f"设备离线 (当前状态: {status})")
                 save_json(FRPS_DIR, name, item)
                 continue
 
+            # 2. 识别站点类型并进行在线处理
+            name_up = name.upper()
+            is_tower_underscore = "TOWER_" in name_up
+            is_tower_i = "TOWER" in name_up and not is_tower_underscore
+            if not (is_tower_underscore or is_tower_i): continue
+
+            try:
+                conf = item.get('conf') or {}
+                port = conf.get('remote_port')
                 if not port:
                     add_error("106网站", name, "配置错误: 缺少 remote_port")
                     continue
 
-                # 2. 只有 Online 才进行二级访问
+                # 只有 Online 才获取子站点 Token
-                res2 = requests.get(f"http://106.75.72.40:{port}/api/resources/Data/", headers=headers, timeout=10)
+                token = get_106_dynamic_token(port)
+                if not token:
+                    add_error("106网站", name, "Token获取失败(登录异常)")
+                    continue
+
+                headers = {"Authorization": c["primary_auth"], "x-auth": token, "User-Agent": "Mozilla/5.0"}
+
+                # 查找 Data 根目录 (根据类型区分大小写)
+                api_root = "/api/resources/Data/" if is_tower_underscore else "/api/resources/data/"
+                res2 = requests.get(f"http://106.75.72.40:{port}{api_root}", headers=headers, timeout=10)
                 if res2.status_code != 200:
                     add_error("106网站", name, f"无法打开Data目录 (HTTP {res2.status_code})")
                     continue
 
                 it2 = res2.json().get('items', [])
-                closest_date = find_closest_item(it2, True)
+                best_date = find_closest_item(it2, is_date_level=True)
-                if not closest_date:
+                if not best_date or best_date[2] != today_str:
-                    add_error("106网站", name, "Data目录为空")
+                    add_error("106网站", name, "未找到今日文件夹", best_date[2] if best_date else "N/A")
-                    continue
+                    if not best_date: continue
 
-                path_date = closest_date.get('path', '')
+                date_path = f"{api_root}{best_date[2]}/"
-                date_val = path_date.split('/')[-1]
 
-                # 记录日期不对的情况，但尝试继续抓取
+                # 查找文件夹内最新文件
-                if date_val != today_str:
+                res3 = requests.get(f"http://106.75.72.40:{port}{date_path}", headers=headers, timeout=10)
-                    add_error("106网站", name, "日期非当天", date_val)
-
-                # 3. 访问日期内文件列表
-                res3 = requests.get(f"http://106.75.72.40:{port}/api/resources{path_date}/", headers=headers,
-                                    timeout=10)
                 it3 = res3.json().get('items', [])
-                closest_file = find_closest_item(it3, False)
+                best_file = find_closest_item(it3, is_date_level=False)
-                if not closest_file:
+                if not best_file:
-                    add_error("106网站", name, "文件夹内无文件", date_val)
+                    add_error("106网站", name, "文件夹内无文件", best_date[2])
                     continue
 
-                # 4. 读取内容并进行 NoneType 防御
+                file_item = best_file[1]
-                path_csv = closest_file.get('path', '')
+                full_path = file_item.get('path') or f"{date_path}{file_item.get('name')}"
-                res4 = requests.get(f"http://106.75.72.40:{port}/api/resources{path_csv}", headers=headers, timeout=10)
+
+                # 3. 根据类型下载内容
+                if is_tower_i:
+                    # TowerI 模式：使用 raw 接口获取二进制
+                    raw_url = f"http://106.75.72.40:{port}/api/raw{full_path}"
+                    res4 = requests.get(raw_url, headers=headers, timeout=20)
+                    if res4.status_code == 200:
+                        save_path = os.path.join(FRPS_DIR, f"{name}_{today_str}.bin")
+                        with open(save_path, 'wb') as f:
+                            f.write(res4.content)
+                        print(f"   ✅ {name} 二进制数据保存成功")
+                else:
+                    # Tower_ 模式：使用 resources 接口获取 JSON
+                    file_api_url = f"http://106.75.72.40:{port}/api/resources{full_path}"
+                    res4 = requests.get(file_api_url, headers=headers, timeout=20)
                     file_json = res4.json()
-
+                    raw_content = file_json.get('content', '') if file_json else None
-                if file_json is None:
+                    if raw_content:
-                    add_error("106网站", name, "内容接口返回 Null", date_val)
+                        save_path = os.path.join(FRPS_DIR, f"{name}_{today_str}.json")
-                    continue
+                        with open(save_path, 'w', encoding='utf-8') as f:
-
+                            f.write(process_text_content(raw_content))
-                raw_content = file_json.get('content', '')
+                        print(f"   ✅ {name} JSON数据保存成功")
-                if not raw_content:
+                    else:
-                    add_error("106网站", name, "content字段为空", date_val)
+                        add_error("106网站", name, "文件内容为空", best_date[2])
-
-                save_json(FRPS_DIR, name, {
-                    "status": status,
-                    "latest_path": path_csv,
-                    "content": process_text_content(raw_content)
-                })
 
             except Exception as e:
-                add_error("106网站", name, f"站点级崩溃: {str(e)}")
+                add_error("106网站", name, f"站点处理崩溃: {str(e)}")
 
     except Exception as e:
         add_error("106网站", "全局逻辑", f"主进程崩溃: {str(e)}")
 
 
-# --- 82 网站逻辑 ---
+# --- 82 网站逻辑 (保持原样) ---
 
 def run_82_logic():
     print("\n>>> 开始处理 82 网站 (Weather)...")
@@ -253,7 +279,6 @@ def export_to_excel():
 
     df = pd.DataFrame(error_logs)
     cols = ["数据来源", "站点/代理名称", "错误原因", "日期偏移量", "最新数据时间", "检查时间"]
-    # 过滤掉 dataframe 中不存在的列，防止报错
     df = df[[c for c in cols if c in df.columns]]
     df.to_excel(EXCEL_PATH, index=False)
     print(f"\n[!] 错误报表已生成至: {EXCEL_PATH} (共 {len(error_logs)} 条)")

zhandianxinxi/.idea/.gitignore

@@ -0,0 +1,8 @@
+# 默认忽略的文件
+/shelf/
+/workspace.xml
+# 基于编辑器的 HTTP 客户端请求
+/httpRequests/
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml

zhandianxinxi/.idea/misc.xml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Black">
+    <option name="sdkName" value="Python 3.12 (zhandianxinxi)" />
+  </component>
+  <component name="ProjectRootManager">
+    <output url="file://$PROJECT_DIR$/out" />
+  </component>
+</project>

zhandianxinxi/.idea/modules.xml

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/zhandianxinxi.iml" filepath="$PROJECT_DIR$/zhandianxinxi.iml" />
+    </modules>
+  </component>
+</project>

zhandianxinxi/.idea/vcs.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$/.." vcs="Git" />
+  </component>
+</project>

zhandianxinxi/my-vue-app/.gitignore

@@ -0,0 +1,24 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+pnpm-debug.log*
+lerna-debug.log*
+
+node_modules
+dist
+dist-ssr
+*.local
+
+# Editor directories and files
+.vscode/*
+!.vscode/extensions.json
+.idea
+.DS_Store
+*.suo
+*.ntvs*
+*.njsproj
+*.sln
+*.sw?

zhandianxinxi/my-vue-app/.vscode/extensions.json

@@ -0,0 +1,3 @@
+{
+  "recommendations": ["Vue.volar"]
+}

zhandianxinxi/my-vue-app/README.md

@@ -0,0 +1,5 @@
+# Vue 3 + Vite
+
+This template should help get you started developing with Vue 3 in Vite. The template uses Vue 3 `<script setup>` SFCs, check out the [script setup docs](https://v3.vuejs.org/api/sfc-script-setup.html#sfc-script-setup) to learn more.
+
+Learn more about IDE Support for Vue in the [Vue Docs Scaling up Guide](https://vuejs.org/guide/scaling-up/tooling.html#ide-support).

zhandianxinxi/my-vue-app/index.html

@@ -0,0 +1,13 @@
+<!doctype html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <link rel="icon" type="image/svg+xml" href="/vite.svg" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>my-vue-app</title>
+  </head>
+  <body>
+    <div id="app"></div>
+    <script type="module" src="/src/main.js"></script>
+  </body>
+</html>

zhandianxinxi/my-vue-app/package.json

@@ -0,0 +1,21 @@
+{
+  "name": "my-vue-app",
+  "private": true,
+  "version": "0.0.1",
+  "type": "module",
+  "scripts": {
+    "dev": "vite",
+    "build": "vite build"
+  },
+  "dependencies": {
+    "vue": "^3.3.4",
+    "element-plus": "^2.3.14",
+    "axios": "^1.5.1",
+    "@element-plus/icons-vue": "^2.1.0",
+    "vue-json-viewer": "^3.0.4"
+  },
+  "devDependencies": {
+    "vite": "4.5.0",
+    "@vitejs/plugin-vue": "4.5.0"
+  }
+}

zhandianxinxi/my-vue-app/public/vite.svg

@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" aria-hidden="true" role="img" class="iconify iconify--logos" width="31.88" height="32" preserveAspectRatio="xMidYMid meet" viewBox="0 0 256 257"><defs><linearGradient id="IconifyId1813088fe1fbc01fb466" x1="-.828%" x2="57.636%" y1="7.652%" y2="78.411%"><stop offset="0%" stop-color="#41D1FF"></stop><stop offset="100%" stop-color="#BD34FE"></stop></linearGradient><linearGradient id="IconifyId1813088fe1fbc01fb467" x1="43.376%" x2="50.316%" y1="2.242%" y2="89.03%"><stop offset="0%" stop-color="#FFEA83"></stop><stop offset="8.333%" stop-color="#FFDD35"></stop><stop offset="100%" stop-color="#FFA800"></stop></linearGradient></defs><path fill="url(#IconifyId1813088fe1fbc01fb466)" d="M255.153 37.938L134.897 252.976c-2.483 4.44-8.862 4.466-11.382.048L.875 37.958c-2.746-4.814 1.371-10.646 6.827-9.67l120.385 21.517a6.537 6.537 0 0 0 2.322-.004l117.867-21.483c5.438-.991 9.574 4.796 6.877 9.62Z"></path><path fill="url(#IconifyId1813088fe1fbc01fb467)" d="M185.432.063L96.44 17.501a3.268 3.268 0 0 0-2.634 3.014l-5.474 92.456a3.268 3.268 0 0 0 3.997 3.378l24.777-5.718c2.318-.535 4.413 1.507 3.936 3.838l-7.361 36.047c-.495 2.426 1.782 4.5 4.151 3.78l15.304-4.649c2.372-.72 4.652 1.36 4.15 3.788l-11.698 56.621c-.732 3.542 3.979 5.473 5.943 2.437l1.313-2.028l72.516-144.72c1.215-2.423-.88-5.186-3.54-4.672l-25.505 4.922c-2.396.462-4.435-1.77-3.759-4.114l16.646-57.705c.677-2.35-1.37-4.583-3.769-4.113Z"></path></svg>

zhandianxinxi/my-vue-app/src/App.vue

@@ -0,0 +1,289 @@
+<template>
+  <div class="container">
+    <el-card shadow="never" class="main-card">
+      <template #header>
+        <div class="header-row">
+          <div class="left-panel">
+            <h2 class="sys-title">📡 终端数据监控大屏</h2>
+            <div class="sys-status">
+              <span v-if="isRunning" class="status-running">
+                <el-icon class="is-loading"><Loading /></el-icon> 正在与远程服务器同步数据...
+              </span>
+              <span v-else class="status-idle">
+                <el-icon><CircleCheck /></el-icon> 数据已更新 ({{ lastUpdateTime }})
+              </span>
+            </div>
+          </div>
+          <el-button type="primary" :loading="isRunning" @click="handleManualRefresh" round icon="Refresh">
+            立即刷新同步
+          </el-button>
+        </div>
+      </template>
+
+      <div class="toolbar">
+        <div class="filter-section">
+          <el-radio-group v-model="filters.site" size="default">
+            <el-radio-button label="all">全部来源</el-radio-button>
+            <el-radio-button label="106">106 代理</el-radio-button>
+            <el-radio-button label="82">82 气象站</el-radio-button>
+          </el-radio-group>
+
+          <el-input
+              v-model="filters.keyword"
+              placeholder="搜索设备名称..."
+              prefix-icon="Search"
+              style="width: 220px; margin-left: 20px;"
+              clearable
+          />
+        </div>
+
+        <div class="action-section">
+          <el-checkbox v-model="showHidden" label="显示已屏蔽" border style="margin-right: 15px"/>
+          <el-button
+              type="warning"
+              plain
+              icon="Hide"
+              :disabled="selectedRows.length === 0"
+              @click="hideSelectedDevices"
+          >
+            屏蔽选中 ({{ selectedRows.length }})
+          </el-button>
+        </div>
+      </div>
+
+      <el-table
+          :data="sortedData"
+          style="width: 100%; margin-top: 20px;"
+          border
+          stripe
+          height="650"
+          v-loading="isRunning"
+          @selection-change="val => selectedRows = val"
+      >
+        <el-table-column type="selection" width="50" align="center" />
+
+        <el-table-column prop="source" label="来源" width="100" align="center">
+          <template #default="scope">
+            <el-tag size="small" effect="plain">{{ scope.row.source }}</el-tag>
+          </template>
+        </el-table-column>
+
+        <el-table-column label="设备名称" min-width="220">
+          <template #default="scope">
+            <el-link type="primary" :underline="false" @click="showDetails(scope.row)" class="device-link">
+              {{ scope.row.name }}
+            </el-link>
+            <el-tag v-if="isHidden(scope.row.name)" type="info" size="small" style="margin-left:8px">已屏蔽</el-tag>
+          </template>
+        </el-table-column>
+
+        <el-table-column label="运行状态" width="140" align="center">
+          <template #default="{ row }">
+            <el-tag :type="getStatusType(row)" effect="dark" round>
+              {{ getStatusLabel(row) }}
+            </el-tag>
+          </template>
+        </el-table-column>
+
+        <el-table-column prop="reason" label="状态详情" min-width="200">
+          <template #default="{ row }">
+            <span :style="{ color: getStatusColor(row) }">
+              {{ row.reason }}
+            </span>
+          </template>
+        </el-table-column>
+
+        <el-table-column prop="offset" label="数据时效" width="120" align="center" />
+
+        <el-table-column prop="latest_time" label="最新日期" width="160" align="center" />
+
+        <el-table-column label="管理" width="100" align="center" v-if="showHidden">
+          <template #default="{ row }">
+            <el-button v-if="isHidden(row.name)" type="info" link @click="restoreDevice(row.name)">恢复</el-button>
+          </template>
+        </el-table-column>
+      </el-table>
+
+      <div class="footer-stats">
+        <span>总监控: {{ rawData.length }}</span> |
+        <span style="color: #F56C6C">严重问题: {{ stats.critical }}</span> |
+        <span style="color: #E6A23C">滞后警告: {{ stats.warning }}</span>
+      </div>
+    </el-card>
+
+    <el-drawer
+        v-model="drawerVisible"
+        title="设备数据详情"
+        size="45%"
+        destroy-on-close
+    >
+      <div v-if="activeDevice" class="drawer-content">
+        <el-descriptions :title="`站点名称：${activeDevice.name}`" :column="1" border>
+          <el-descriptions-item label="所属来源">{{ activeDevice.source }}</el-descriptions-item>
+          <el-descriptions-item label="当前状态">
+            <el-tag :type="getStatusType(activeDevice)">{{ getStatusLabel(activeDevice) }}</el-tag>
+          </el-descriptions-item>
+          <el-descriptions-item label="检测到最新时间">{{ activeDevice.latest_time }}</el-descriptions-item>
+          <el-descriptions-item label="异常原因">{{ activeDevice.reason }}</el-descriptions-item>
+        </el-descriptions>
+
+        <h3 style="margin: 25px 0 10px 0;">📦 原始 JSON 数据报文</h3>
+        <div class="json-container">
+          <json-viewer
+              v-if="parsedJson"
+              :value="parsedJson"
+              :expand-depth="5"
+              copyable
+              boxed
+              sort
+          />
+          <el-empty v-else description="该站点暂无详细 JSON 数据内容" />
+        </div>
+      </div>
+    </el-drawer>
+  </div>
+</template>
+
+<script setup>
+import { ref, reactive, computed, onMounted } from 'vue'
+import axios from 'axios'
+import { ElMessage } from 'element-plus'
+
+// --- 数据响应式变量 ---
+const rawData = ref([])
+const isRunning = ref(false)
+const lastUpdateTime = ref('-')
+const selectedRows = ref([])
+const showHidden = ref(false)
+const drawerVisible = ref(false)
+
+// 初始值设为 null，模板中通过 v-if 保护
+const activeDevice = ref(null)
+
+const filters = reactive({ site: 'all', keyword: '' })
+const ignoredDevices = ref(JSON.parse(localStorage.getItem('ignored_list') || '[]'))
+
+// --- 逻辑处理 ---
+
+const getStatusLevel = (row) => {
+  if (!row || !row.reason) return 'success'
+  if (row.reason.includes('离线') || row.reason.includes('失败')) return 'critical'
+  if (row.offset && row.offset.includes('滞后')) return 'warning'
+  return 'success'
+}
+
+const getStatusType = (row) => {
+  const level = getStatusLevel(row)
+  return level === 'critical' ? 'danger' : (level === 'warning' ? 'warning' : 'success')
+}
+
+const getStatusLabel = (row) => {
+  const level = getStatusLevel(row)
+  return level === 'critical' ? '连接异常' : (level === 'warning' ? '同步滞后' : '运行正常')
+}
+
+const getStatusColor = (row) => {
+  const level = getStatusLevel(row)
+  return level === 'critical' ? '#F56C6C' : (level === 'warning' ? '#E6A23C' : '#606266')
+}
+
+const isHidden = (name) => ignoredDevices.value.includes(name)
+
+const sortedData = computed(() => {
+  let list = rawData.value.filter(item => {
+    const matchSite = filters.site === 'all' || item.source.includes(filters.site)
+    const matchKey = !filters.keyword || item.name.toLowerCase().includes(filters.keyword.toLowerCase())
+    const hideLogic = showHidden.value ? true : !isHidden(item.name)
+    return matchSite && matchKey && hideLogic
+  })
+  return list.sort((a, b) => {
+    const weight = { 'critical': 3, 'warning': 2, 'success': 1 }
+    return weight[getStatusLevel(b)] - weight[getStatusLevel(a)]
+  })
+})
+
+const stats = computed(() => ({
+  critical: rawData.value.filter(r => getStatusLevel(r) === 'critical').length,
+  warning: rawData.value.filter(r => getStatusLevel(r) === 'warning').length
+}))
+
+const parsedJson = computed(() => {
+  if (!activeDevice.value || !activeDevice.value.content) return null
+  try {
+    return JSON.parse(activeDevice.value.content)
+  } catch (e) {
+    return activeDevice.value.content
+  }
+})
+
+// --- 交互方法 ---
+
+const showDetails = (row) => {
+  activeDevice.value = row
+  drawerVisible.value = true
+}
+
+const hideSelectedDevices = () => {
+  const names = selectedRows.value.map(r => r.name)
+  ignoredDevices.value = [...new Set([...ignoredDevices.value, ...names])]
+  localStorage.setItem('ignored_list', JSON.stringify(ignoredDevices.value))
+  ElMessage.success('已屏蔽选中设备')
+}
+
+const restoreDevice = (name) => {
+  ignoredDevices.value = ignoredDevices.value.filter(n => n !== name)
+  localStorage.setItem('ignored_list', JSON.stringify(ignoredDevices.value))
+}
+
+const fetchLogs = async () => {
+  try {
+    const res = await axios.get('/api/logs')
+    rawData.value = res.data
+    if (res.data.length > 0) lastUpdateTime.value = res.data[0].check_time
+  } catch (e) {
+    console.error("无法获取日志数据")
+  }
+}
+
+const checkStatus = async () => {
+  try {
+    const res = await axios.get('/api/status')
+    isRunning.value = res.data.is_running
+    if (isRunning.value) {
+      setTimeout(checkStatus, 3000)
+    } else {
+      fetchLogs()
+    }
+  } catch (e) {
+    isRunning.value = false
+  }
+}
+
+const handleManualRefresh = async () => {
+  if (isRunning.value) return
+  try {
+    await axios.post('/api/run')
+    isRunning.value = true
+    checkStatus()
+  } catch (e) {
+    ElMessage.error('启动同步失败，请检查后端连接')
+  }
+}
+
+onMounted(() => {
+  checkStatus()
+  fetchLogs()
+})
+</script>
+
+<style scoped>
+.container { padding: 20px; max-width: 1400px; margin: 0 auto; font-family: sans-serif; }
+.header-row { display: flex; justify-content: space-between; align-items: center; }
+.sys-title { margin: 0; color: #303133; }
+.sys-status { font-size: 13px; color: #909399; margin-top: 5px; }
+.toolbar { background: #f8f9fa; padding: 15px; border-radius: 8px; display: flex; justify-content: space-between; align-items: center; margin-top: 20px; border: 1px solid #ebeef5; }
+.device-link { font-weight: bold; }
+.footer-stats { margin-top: 20px; text-align: right; color: #606266; font-size: 14px; }
+.json-container { border: 1px solid #eee; border-radius: 4px; overflow: hidden; }
+.drawer-content { padding: 0 5px; }
+</style>

zhandianxinxi/my-vue-app/src/assets/vue.svg

@@ -0,0 +1 @@
+<svg xmlns="http://www.w3.org/2000/svg" xmlns:xlink="http://www.w3.org/1999/xlink" aria-hidden="true" role="img" class="iconify iconify--logos" width="37.07" height="36" preserveAspectRatio="xMidYMid meet" viewBox="0 0 256 198"><path fill="#41B883" d="M204.8 0H256L128 220.8L0 0h97.92L128 51.2L157.44 0h47.36Z"></path><path fill="#41B883" d="m0 0l128 220.8L256 0h-51.2L128 132.48L50.56 0H0Z"></path><path fill="#35495E" d="M50.56 0L128 133.12L204.8 0h-47.36L128 51.2L97.92 0H50.56Z"></path></svg>

zhandianxinxi/my-vue-app/src/main.js

@@ -0,0 +1,17 @@
+import { createApp } from 'vue'
+import App from './App.vue'
+import ElementPlus from 'element-plus'
+import 'element-plus/dist/index.css'
+import * as ElementPlusIconsVue from '@element-plus/icons-vue'
+import JsonViewer from 'vue-json-viewer'
+
+const app = createApp(App)
+
+// 注册所有图标
+for (const [key, component] of Object.entries(ElementPlusIconsVue)) {
+    app.component(key, component)
+}
+
+app.use(ElementPlus)
+app.use(JsonViewer)
+app.mount('#app')

zhandianxinxi/my-vue-app/src/style.css

@@ -0,0 +1,79 @@
+:root {
+  font-family: system-ui, Avenir, Helvetica, Arial, sans-serif;
+  line-height: 1.5;
+  font-weight: 400;
+
+  color-scheme: light dark;
+  color: rgba(255, 255, 255, 0.87);
+  background-color: #242424;
+
+  font-synthesis: none;
+  text-rendering: optimizeLegibility;
+  -webkit-font-smoothing: antialiased;
+  -moz-osx-font-smoothing: grayscale;
+}
+
+a {
+  font-weight: 500;
+  color: #646cff;
+  text-decoration: inherit;
+}
+a:hover {
+  color: #535bf2;
+}
+
+body {
+  margin: 0;
+  display: flex;
+  place-items: center;
+  min-width: 320px;
+  min-height: 100vh;
+}
+
+h1 {
+  font-size: 3.2em;
+  line-height: 1.1;
+}
+
+button {
+  border-radius: 8px;
+  border: 1px solid transparent;
+  padding: 0.6em 1.2em;
+  font-size: 1em;
+  font-weight: 500;
+  font-family: inherit;
+  background-color: #1a1a1a;
+  cursor: pointer;
+  transition: border-color 0.25s;
+}
+button:hover {
+  border-color: #646cff;
+}
+button:focus,
+button:focus-visible {
+  outline: 4px auto -webkit-focus-ring-color;
+}
+
+.card {
+  padding: 2em;
+}
+
+#app {
+  max-width: 1280px;
+  margin: 0 auto;
+  padding: 2rem;
+  text-align: center;
+}
+
+@media (prefers-color-scheme: light) {
+  :root {
+    color: #213547;
+    background-color: #ffffff;
+  }
+  a:hover {
+    color: #747bff;
+  }
+  button {
+    background-color: #f9f9f9;
+  }
+}

zhandianxinxi/my-vue-app/vite.config.js

@@ -0,0 +1,16 @@
+// vite.config.js
+import { defineConfig } from 'vite'
+import vue from '@vitejs/plugin-vue'
+
+export default defineConfig({
+  plugins: [vue()],
+  server: {
+    proxy: {
+      '/api': {
+        target: 'http://127.0.0.1:5000', // 必须指向你的 Flask 地址
+        changeOrigin: true,
+        rewrite: (path) => path // 保持路径 /api 不变
+      }
+    }
+  }
+})

zhandianxinxi/zhandianxinxi.iml

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="PYTHON_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="jdk" jdkName="Python 3.12 (zhandianxinxi)" jdkType="Python SDK" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>