diff --git a/app/api/v1/job/job.py b/app/api/v1/job/job.py
index 4999fb4..8a12434 100644
--- a/app/api/v1/job/job.py
+++ b/app/api/v1/job/job.py
@@ -1,252 +1,179 @@
+from typing import Dict, Any, Optional
+
 from fastapi import APIRouter, BackgroundTasks, Depends
-from typing import Dict, Any
- 
-from app.services.job import create_data_router_service, PlatformType, DataType
+
 from app.core.clickhouse import clickhouse_manager
-from app.controllers.job import (
-    UniversalDataController, 
-    UniversalDataRequest, 
-    BatchDataRequest,
-    create_universal_data_controller
+from app.schemas.ingest import (
+    IngestBatchRequest,
+    IngestSingleRequest,
+    PlatformType,
+    ChannelType,
+    DataType,
 )
+from app.services.ingest import IngestService
+from app.log import logger
 
 
-router = APIRouter(tags=["通用数据接口"])
+router = APIRouter(tags=["数据入库"])
 
 
-async def get_universal_data_controller() -> UniversalDataController:
-    """获取通用数据控制器实例"""
-    clickhouse_client = await clickhouse_manager.get_client()
-    data_router_service = create_data_router_service(clickhouse_client)
-    return create_universal_data_controller(data_router_service)
+async def get_ingest_service() -> IngestService:
+    client = await clickhouse_manager.get_client()
+    return IngestService(client)
 
 
 @router.post("/data/store", summary="存储单条数据")
-async def store_single_data(
-    request: UniversalDataRequest,
-    controller: UniversalDataController = Depends(get_universal_data_controller)
+async def store_single(
+    request: IngestSingleRequest,
+    service: IngestService = Depends(get_ingest_service),
 ) -> Dict[str, Any]:
-    """
-    通用数据存储接口 - 存储单条数据
-    
-    支持的平台:
-    - boss: Boss直聘
-    - qcwy: 前程无忧
-    - zhilian: 智联招聘
-    
-    支持的数据类型:
-    - job: 职位数据
-    - company: 公司数据
-    
-    示例请求:
-    ```json
-    {
-        "data": {
-            "jobBaseInfoVO": {
-                "encryptJobId": "abc123",
-                "positionName": "Python开发工程师",
-                "locationName": "北京"
-            },
-            "brandComInfoVO": {
-                "brandName": "某科技公司",
-                "industryName": "互联网"
-            }
-        },
-        "data_type": "job",
-        "platform": "boss",
-        "check_duplicate": true,
-        "duplicate_key": "encrypt_job_id"
+    result = await service.store_single(
+        platform=request.platform.value,
+        channel=request.channel.value,
+        data_type=request.data_type.value,
+        data=request.data,
+        check_duplicate=request.check_duplicate,
+    )
+    return {"code": 200, "data": result, "message": "ok"}
+
+
+@router.post("/data/batch", summary="批量存储数据")
+@router.post("/data/batch-store", summary="批量存储数据(兼容)")
+async def store_batch(
+    request: IngestBatchRequest,
+    service: IngestService = Depends(get_ingest_service),
+) -> Dict[str, Any]:
+    result = await service.store_batch(
+        platform=request.platform.value,
+        channel=request.channel.value,
+        data_type=request.data_type.value,
+        data_list=request.data_list,
+        check_duplicate=request.check_duplicate,
+    )
+    return {
+        "code": 200,
+        "data": result,
+        "message": f"批量处理完成: 成功 {result['success']} 条, 重复 {result['duplicate']} 条, 失败 {result['failed']} 条",
     }
-    ```
-    """
-    return await controller.store_single_data(request)
 
 
-@router.post("/data/batch-store", summary="批量存储数据")
-async def store_batch_data(
-    request: BatchDataRequest,
-    controller: UniversalDataController = Depends(get_universal_data_controller)
+@router.post("/data/batch-async", summary="异步批量存储数据")
+@router.post("/data/batch-store-async", summary="异步批量存储数据(兼容)")
+async def store_batch_async(
+    request: IngestBatchRequest,
+    background_tasks: BackgroundTasks,
+    service: IngestService = Depends(get_ingest_service),
 ) -> Dict[str, Any]:
-    """
-    通用数据存储接口 - 批量存储数据
-    
-    示例请求:
-    ```json
-    {
-        "data_list": [
-            {
-                "jobBaseInfoVO": {
-                    "encryptJobId": "abc123",
-                    "positionName": "Python开发工程师"
-                }
-            },
-            {
-                "jobBaseInfoVO": {
-                    "encryptJobId": "def456",
-                    "positionName": "Java开发工程师"
-                }
-            }
-        ],
-        "data_type": "job",
-        "platform": "boss",
-        "check_duplicate": true
+    platform_names = {"boss": "Boss直聘", "qcwy": "前程无忧", "zhilian": "智联招聘"}
+    name = platform_names.get(request.platform.value, request.platform.value)
+    logger.info(f"收到批量请求: [{name}] {request.data_type.value} x{len(request.data_list)} 条")
+
+    async def _task():
+        r = await service.store_batch(
+            platform=request.platform.value,
+            channel=request.channel.value,
+            data_type=request.data_type.value,
+            data_list=request.data_list,
+            check_duplicate=request.check_duplicate,
+        )
+        logger.info(
+            f"批量处理完成: [{name}] 成功 {r['success']} 条, 重复 {r['duplicate']} 条, 失败 {r['failed']} 条"
+        )
+
+    background_tasks.add_task(_task)
+    return {
+        "code": 202,
+        "message": f"批量数据已加入异步处理队列，共 {len(request.data_list)} 条",
+        "platform": request.platform,
+        "data_type": request.data_type,
     }
-    ```
-    """
-    return await controller.store_batch_data(request)
-
-
-@router.post("/data/store-async", summary="异步存储单条数据")
-async def store_single_data_async(
-    request: UniversalDataRequest,
-    background_tasks: BackgroundTasks,
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """
-    通用数据存储接口 - 异步存储单条数据
-    
-    适用于大量数据或不需要立即返回结果的场景
-    """
-    return await controller.store_single_data_async(background_tasks, request)
-
-
-@router.post("/data/batch-store-async", summary="异步批量存储数据")
-async def store_batch_data_async(
-    request: BatchDataRequest,
-    background_tasks: BackgroundTasks,
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """
-    通用数据存储接口 - 异步批量存储数据
-    
-    适用于大批量数据处理场景
-    """
-    return await controller.store_batch_data_async(background_tasks, request)
 
 
 @router.get("/data", summary="查询数据")
 async def query_data(
-    platform: str,
-    data_type: str,
+    platform: PlatformType,
+    data_type: DataType,
+    channel: ChannelType = ChannelType.MINI,
     page: int = 1,
     page_size: int = 20,
-    controller: UniversalDataController = Depends(get_universal_data_controller)
+    service: IngestService = Depends(get_ingest_service),
+) -> Dict[str, Any]:
+    offset = (page - 1) * page_size
+    result = await service.query_data(
+        platform=platform.value,
+        channel=channel.value,
+        data_type=data_type.value,
+        limit=page_size,
+        offset=offset,
+    )
+    return {
+        "code": 200,
+        "data": {
+            "items": result.get("data", []),
+            "total": result.get("count", 0),
+            "page": page,
+            "page_size": page_size,
+        },
+    }
+
+
+@router.get("/platforms", summary="获取注册表信息")
+async def get_platforms() -> Dict[str, Any]:
+    return {"code": 200, "data": IngestService.get_registry_info()}
+
+
+@router.get("/data/stats", summary="各平台爬虫入库统计")
+async def get_ingest_stats(
+    platform: Optional[PlatformType] = None,
+    days: int = 7,
 ) -> Dict[str, Any]:
     """
-    通用数据查询接口
-    
-    参数:
-    - platform: 平台类型 (boss/qcwy/zhilian)
-    - data_type: 数据类型 (job/company)
-    - page: 页码，默认1
-    - page_size: 每页大小，默认20
+    查询各平台 ClickHouse 入库统计：总量、今日新增、最近入库时间、近 N 天每日趋势。
+    用于前端爬虫监控页面展示。
     """
-    # 转换字符串参数为枚举类型
-    platform_enum = PlatformType(platform)
-    data_type_enum = DataType(data_type)
-    return await controller.query_data(platform_enum, data_type_enum, page, page_size)
+    from app.core.clickhouse import clickhouse_manager
 
-@router.get("/platforms", summary="获取支持的平台和数据类型")
-async def get_supported_platforms(
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """
-    获取支持的平台和数据类型信息
-    
-    返回:
-    - 支持的平台列表
-    - 支持的数据类型列表
-    - 各平台的默认重复检查字段
-    """
-    return await controller.get_supported_platforms()
+    client = await clickhouse_manager.get_client()
 
+    platforms = [platform.value] if platform else ["boss", "qcwy", "zhilian"]
+    table_map = {"boss": "boss_job", "qcwy": "qcwy_job", "zhilian": "zhilian_job"}
 
-# 为了兼容性，提供平台特定的路由别名
-@router.post("/boss/job", summary="Boss直聘职位数据存储")
-async def store_boss_job_data(
-    data: Dict[str, Any],
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """Boss直聘职位数据存储的便捷接口"""
-    request = UniversalDataRequest(
-        data=data,
-        data_type="job",
-        platform="boss",
-        check_duplicate=True,
-    )
-    return await controller.store_single_data(request)
+    result: Dict[str, Any] = {}
+    for p in platforms:
+        table = f"job_data.{table_map[p]}"
+        try:
+            r_total = await client.query(f"SELECT count() FROM {table}")
+            total = r_total.result_rows[0][0] if r_total.result_rows else 0
 
+            r_today = await client.query(
+                f"SELECT count() FROM {table} WHERE toDate(created_at) = today()"
+            )
+            today = r_today.result_rows[0][0] if r_today.result_rows else 0
 
-@router.post("/boss/company", summary="Boss直聘公司数据存储")
-async def store_boss_company_data(
-    data: Dict[str, Any],
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """Boss直聘公司数据存储的便捷接口"""
-    request = UniversalDataRequest(
-        data=data,
-        data_type="company",
-        platform="boss",
-        check_duplicate=True,
-    )
-    return await controller.store_single_data(request)
+            r_last = await client.query(f"SELECT max(created_at) FROM {table}")
+            last_at_raw = r_last.result_rows[0][0] if r_last.result_rows else None
+            last_at = str(last_at_raw).split(".")[0] if last_at_raw else None
 
+            r_daily = await client.query(
+                f"SELECT toDate(created_at) AS day, count() AS cnt "
+                f"FROM {table} "
+                f"WHERE created_at >= today() - {days} "
+                f"GROUP BY day ORDER BY day DESC"
+            )
+            daily_counts = [
+                {"date": str(row[0]), "count": int(row[1])}
+                for row in r_daily.result_rows
+            ]
 
-@router.post("/qcwy/job", summary="前程无忧职位数据存储")
-async def store_qcwy_job_data(
-    data: Dict[str, Any],
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """前程无忧职位数据存储的便捷接口"""
-    request = UniversalDataRequest(
-        data=data,
-        data_type="job",
-        platform="qcwy",
-        check_duplicate=True,
-    )
-    return await controller.store_single_data(request)
+            result[p] = {
+                "total": total,
+                "today": today,
+                "last_ingest_at": last_at,
+                "daily_counts": daily_counts,
+            }
+        except Exception as e:
+            logger.warning(f"stats query failed for {p}: {e}")
+            result[p] = {"total": 0, "today": 0, "last_ingest_at": None, "daily_counts": [], "error": str(e)}
 
+    return {"code": 200, "data": result}
 
-@router.post("/qcwy/company", summary="前程无忧公司数据存储")
-async def store_qcwy_company_data(
-    data: Dict[str, Any],
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """前程无忧公司数据存储的便捷接口"""
-    request = UniversalDataRequest(
-        data=data,
-        data_type="company",
-        platform="qcwy",
-        check_duplicate=True,
-    )
-    return await controller.store_single_data(request)
-
-
-@router.post("/zhilian/job", summary="智联招聘职位数据存储")
-async def store_zhilian_job_data(
-    data: Dict[str, Any],
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """智联招聘职位数据存储的便捷接口"""
-    request = UniversalDataRequest(
-        data=data,
-        data_type="job",
-        platform="zhilian",
-        check_duplicate=True,
-    )
-    return await controller.store_single_data(request)
-
-
-@router.post("/zhilian/company", summary="智联招聘公司数据存储")
-async def store_zhilian_company_data(
-    data: Dict[str, Any],
-    controller: UniversalDataController = Depends(get_universal_data_controller)
-) -> Dict[str, Any]:
-    """智联招聘公司数据存储的便捷接口"""
-    request = UniversalDataRequest(
-        data=data,
-        data_type="company",
-        platform="zhilian",
-        check_duplicate=True,
-    )
-    return await controller.store_single_data(request)
\ No newline at end of file
diff --git a/tests/ingest/test_configs_boss.py b/tests/ingest/test_configs_boss.py
new file mode 100644
index 0000000..c42f0d5
--- /dev/null
+++ b/tests/ingest/test_configs_boss.py
@@ -0,0 +1,109 @@
+"""
+Boss直聘 ingest config 解析函数单元测试 — QUAL-02
+覆盖 _extract_job_id / _extract_company_name / _build_boss_push
+"""
+
+from app.services.ingest.configs.boss import (
+    _extract_job_id,
+    _extract_company_name,
+    _build_boss_push,
+)
+
+
+# ─── _extract_job_id ─────────────────────────────────
+
+def test_extract_job_id_from_jobBaseInfoVO():
+    data = {"jobBaseInfoVO": {"jobId": "ABCD123"}}
+    assert _extract_job_id(data) == "ABCD123"
+
+
+def test_extract_job_id_converts_int():
+    data = {"jobBaseInfoVO": {"jobId": 999}}
+    assert _extract_job_id(data) == "999"
+
+
+def test_extract_job_id_missing_inner():
+    """jobBaseInfoVO 存在但无 jobId → None"""
+    data = {"jobBaseInfoVO": {}}
+    assert _extract_job_id(data) is None
+
+
+def test_extract_job_id_missing_outer():
+    """缺 jobBaseInfoVO → None"""
+    data = {}
+    assert _extract_job_id(data) is None
+
+
+# ─── _extract_company_name ────────────────────────────
+
+def test_extract_company_name_from_name():
+    data = {"name": "字节跳动"}
+    assert _extract_company_name(data) == "字节跳动"
+
+
+def test_extract_company_name_from_companyFullInfoVO():
+    data = {"companyFullInfoVO": {"name": "腾讯科技"}}
+    assert _extract_company_name(data) == "腾讯科技"
+
+
+def test_extract_company_name_missing():
+    data = {}
+    assert _extract_company_name(data) is None
+
+
+# ─── _build_boss_push ─────────────────────────────────
+
+def test_build_boss_push_full():
+    data = {
+        "bossBaseInfoVO": {"brandName": "字节"},
+        "jobBaseInfoVO": {
+            "positionName": "算法工程师",
+            "jobDesc": "负责推荐算法",
+            "degreeName": "本科",
+            "requiredSkills": ["Python", "TensorFlow"],
+            "salaryWelfareInfo": ["五险一金"],
+            "experienceName": "3-5年",
+            "lowSalary": 25,
+            "highSalary": 40,
+            "locationName": "北京",
+            "locationDesc": "朝阳区",
+            "encryptJobId": "ENC_JOB_001",
+        },
+        "brandComInfoVO": {
+            "brandName": "字节跳动",
+            "encryptBrandId": "ENC_BRAND_001",
+            "scaleName": "10000人以上",
+            "industryName": "互联网",
+            "introduce": "全球领先的科技公司",
+        },
+    }
+    result = _build_boss_push(data)
+    assert result is not None
+    assert result["source_type"] == "Boss直聘"
+    assert result["title"] == "算法工程师"
+    assert "ENC_JOB_001" in result["url"]
+    assert result["company_id"] == "ENC_BRAND_001"
+    assert result["company_name"] == "字节跳动"
+    assert "25" in result["salary"] and "40" in result["salary"]
+
+
+def test_build_boss_push_partial():
+    """缺字段不 raise，返回合理降级值"""
+    data = {}
+    result = _build_boss_push(data)
+    assert result is not None
+    assert result["source_type"] == "Boss直聘"
+    # safe_get 在缺字段时返回 None 或 ''，两种均可接受
+    assert result["title"] in (None, "")
+
+
+def test_build_boss_push_skill_join():
+    """多技能列表通过 safe_join 拼接"""
+    data = {
+        "jobBaseInfoVO": {"requiredSkills": ["Go", "Rust"]},
+        "bossBaseInfoVO": {},
+        "brandComInfoVO": {},
+    }
+    result = _build_boss_push(data)
+    assert "Go" in result["skill"]
+    assert "Rust" in result["skill"]
diff --git a/tests/ingest/test_configs_qcwy.py b/tests/ingest/test_configs_qcwy.py
new file mode 100644
index 0000000..ed921cb
--- /dev/null
+++ b/tests/ingest/test_configs_qcwy.py
@@ -0,0 +1,110 @@
+"""
+前程无忧 (51Job) ingest config 解析函数单元测试 — QUAL-02
+覆盖 _extract_job_id / _extract_update_dt / _extract_company_name / _build_qcwy_push
+"""
+
+from app.services.ingest.configs.qcwy import (
+    _extract_job_id,
+    _extract_update_dt,
+    _extract_company_name,
+    _build_qcwy_push,
+)
+
+
+# ─── _extract_job_id ─────────────────────────────────
+
+def test_qcwy_extract_job_id_normal():
+    data = {"jobId": "5001234567"}
+    assert _extract_job_id(data) == "5001234567"
+
+
+def test_qcwy_extract_job_id_int():
+    data = {"jobId": 5001234567}
+    assert _extract_job_id(data) == "5001234567"
+
+
+def test_qcwy_extract_job_id_missing():
+    data = {}
+    assert _extract_job_id(data) is None
+
+
+# ─── _extract_update_dt ──────────────────────────────
+
+def test_qcwy_extract_update_dt_normal():
+    data = {"updateDateTime": "2026-03-01 12:00:00"}
+    assert _extract_update_dt(data) == "2026-03-01 12:00:00"
+
+
+def test_qcwy_extract_update_dt_missing():
+    data = {}
+    assert _extract_update_dt(data) is None
+
+
+# ─── _extract_company_name ────────────────────────────
+
+def test_qcwy_extract_company_name_from_companyName():
+    data = {"companyName": "阿里巴巴"}
+    assert _extract_company_name(data) == "阿里巴巴"
+
+
+def test_qcwy_extract_company_name_from_company_name_fallback():
+    data = {"company_name": "阿里巴巴网络"}
+    assert _extract_company_name(data) == "阿里巴巴网络"
+
+
+def test_qcwy_extract_company_name_missing():
+    data = {}
+    assert _extract_company_name(data) is None
+
+
+# ─── _build_qcwy_push ─────────────────────────────────
+
+def test_qcwy_build_push_welfare_list():
+    """welfare 为对象列表 → 提取 chineseTitle"""
+    data = {
+        "jobWelfareCodeDataList": [
+            {"chineseTitle": "五险一金", "code": "A1"},
+            {"chineseTitle": "年终奖", "code": "A2"},
+        ],
+        "jobName": "Java 开发工程师",
+        "companyName": "阿里巴巴",
+        "jobSalaryMax": 25000,
+        "jobSalaryMin": 18000,
+        "jobHref": "https://example.com/job/12345.html",
+        "coId": "co123",
+    }
+    result = _build_qcwy_push(data)
+    assert result is not None
+    assert result["source_type"] == "前程无忧"
+    assert "五险一金" in result["welfare"]
+    assert "年终奖" in result["welfare"]
+    assert result["title"] == "Java 开发工程师"
+
+
+def test_qcwy_build_push_welfare_string():
+    """welfare 为字符串 → 清理括号后返回"""
+    data = {
+        "jobWelfareCodeDataList": "[五险一金,年终奖]",
+        "jobName": "产品经理",
+        "companyName": "腾讯",
+    }
+    result = _build_qcwy_push(data)
+    assert result is not None
+    assert "五险一金" in result["welfare"]
+
+
+def test_qcwy_build_push_partial():
+    """缺字段不 raise，source_type 正确"""
+    data = {}
+    result = _build_qcwy_push(data)
+    assert result is not None
+    assert result["source_type"] == "前程无忧"
+    assert result["title"] is None or result["title"] == ""
+
+
+def test_qcwy_build_push_salary_format():
+    """薪资字段格式化"""
+    data = {"jobSalaryMax": 30000, "jobSalaryMin": 20000}
+    result = _build_qcwy_push(data)
+    assert "30000" in result["salary"]
+    assert "20000" in result["salary"]
diff --git a/tests/ingest/test_configs_zhilian.py b/tests/ingest/test_configs_zhilian.py
new file mode 100644
index 0000000..25304a2
--- /dev/null
+++ b/tests/ingest/test_configs_zhilian.py
@@ -0,0 +1,109 @@
+"""
+智联招聘 ingest config 解析函数单元测试 — QUAL-02
+覆盖 _extract_number / _extract_fpt / _extract_company_name / _build_zhilian_push
+"""
+
+from app.services.ingest.configs.zhilian import (
+    _extract_number,
+    _extract_fpt,
+    _extract_company_name,
+    _build_zhilian_push,
+)
+
+
+# ─── _extract_number ─────────────────────────────────
+
+def test_zhilian_extract_number_normal():
+    data = {"number": "ZL98765"}
+    assert _extract_number(data) == "ZL98765"
+
+
+def test_zhilian_extract_number_int():
+    data = {"number": 98765}
+    assert _extract_number(data) == "98765"
+
+
+def test_zhilian_extract_number_missing():
+    data = {}
+    assert _extract_number(data) is None
+
+
+# ─── _extract_fpt ────────────────────────────────────
+
+def test_zhilian_extract_fpt_normal():
+    data = {"firstPublishTime": "2026-03-15 09:00:00"}
+    assert _extract_fpt(data) == "2026-03-15 09:00:00"
+
+
+def test_zhilian_extract_fpt_missing():
+    data = {}
+    assert _extract_fpt(data) is None
+
+
+# ─── _extract_company_name ────────────────────────────
+
+def test_zhilian_extract_company_name_from_companyName():
+    data = {"companyName": "华为技术"}
+    assert _extract_company_name(data) == "华为技术"
+
+
+def test_zhilian_extract_company_name_from_name_fallback():
+    data = {"name": "华为有限公司"}
+    assert _extract_company_name(data) == "华为有限公司"
+
+
+def test_zhilian_extract_company_name_missing():
+    data = {}
+    assert _extract_company_name(data) is None
+
+
+# ─── _build_zhilian_push ─────────────────────────────
+
+def test_zhilian_build_push_skill_labels():
+    """skillLabel 为对象列表 → 提取 value"""
+    data = {
+        "skillLabel": [
+            {"value": "Python"},
+            {"value": "深度学习"},
+        ],
+        "companyName": "百度",
+        "name": "算法工程师",
+        "salary60": "25k-40k",
+        "workCity": "北京",
+        "cityDistrict": "海淀区",
+        "companyId": 1001,
+        "positionURL": "https://zhaopin.com/jobs/ABC123.htm",
+    }
+    result = _build_zhilian_push(data)
+    assert result is not None
+    assert result["source_type"] == "智联招聘"
+    assert "Python" in result["skill"]
+    assert "深度学习" in result["skill"]
+    assert result["title"] == "算法工程师"
+    assert result["company_name"] == "百度"
+    assert result["salary"] == "25k-40k"
+
+
+def test_zhilian_build_push_empty_skill_labels():
+    """skillLabel 为空列表 → skill 为空字符串"""
+    data = {"skillLabel": []}
+    result = _build_zhilian_push(data)
+    assert result is not None
+    assert result["skill"] == ""
+
+
+def test_zhilian_build_push_partial():
+    """缺字段不 raise，source_type 正确"""
+    data = {}
+    result = _build_zhilian_push(data)
+    assert result is not None
+    assert result["source_type"] == "智联招聘"
+    # safe_get 在缺字段时返回 None 或 ''，两种均可接受
+    assert result["title"] in (None, "")
+
+
+def test_zhilian_build_push_recruiter_number_str():
+    """招募人数字段转字符串"""
+    data = {"recruitNumber": 5}
+    result = _build_zhilian_push(data)
+    assert result["number"] == "5"
diff --git a/web/src/api/index.js b/web/src/api/index.js
index 0d06ea8..062ff81 100644
--- a/web/src/api/index.js
+++ b/web/src/api/index.js
@@ -40,7 +40,7 @@ export default {
   createDept: (data) => request.post('/dept/create', data),
   updateDept: (data) => request.post('/dept/update', data),
   deleteDept: (params) => request.delete('/dept/delete', { params }),
-  
+
   // 数据统计 / 数据报表（统一改用 /reports 路由）
   getDailyStatistics: (params = {}) => request.get('/reports/daily', { params }),
   getWeeklyStatistics: (params = {}) => request.get('/reports/weekly', { params }),
@@ -51,26 +51,25 @@ export default {
   getIndustryAnalysis: (params = {}) => request.get('/reports/industry-analysis', { params }),
   getCompanyRanking: (params = {}) => request.get('/reports/company-ranking', { params }),
   getReportsHealth: () => request.get('/reports/health'),
-  
+
   // 薪资分析
   // 其余分析接口如需扩展，请对齐 /reports 下的实际端点
-  
+
   // 工作经验分布
   // 保留占位以便后续扩展
-  
+
   // 学历要求分布
   // 保留占位以便后续扩展
-  
+
   // 平台间数据对比
   getPlatformComparison: (params = {}) => request.get('/reports/platform-comparison', { params }),
-  
+
   // 数据质量报告
   getDataQualityReport: (params = {}) => request.get('/reports/data-quality', { params }),
-  
+
   // 导出数据报表
   // 导出报表暂未提供后端端点，前端页面将隐藏导出按钮
 
-
   // 数据清洗
   uploadCleaningFile: (formData) => request.post('/cleaning/upload', formData),
   getCleaningTasks: (params) => request.get('/cleaning/list', { params }),
@@ -87,4 +86,8 @@ export default {
 
   // 通用数据查询
   queryPlatformData: (params) => request.get('/job/data', { params }),
+
+  // 爬虫入库统计（各平台总量/今日/最近入库时间/近7天趋势）
+  getIngestStats: (params = {}) => request.get('/job/data/stats', { params }),
 }
+
diff --git a/web/src/views/cleaning/monitor.vue b/web/src/views/cleaning/monitor.vue
index 258d1d0..eb3ae94 100644
--- a/web/src/views/cleaning/monitor.vue
+++ b/web/src/views/cleaning/monitor.vue
@@ -1,193 +1,357 @@
-
 <template>
-  <CommonPage title="公司信息清洗监控">
-    <div class="flex flex-col gap-4">
-      <!-- 1. 统计概览 -->
-      <n-grid :x-gap="12" :cols="4">
-        <n-grid-item>
-          <n-card :bordered="false" embedded class="bg-gray-50 dark:bg-gray-800">
-            <n-statistic label="总待处理">
-              <template #prefix>
-                <TheIcon icon="mdi:clipboard-clock" :size="24" :color="themeVars.primaryColor" />
-              </template>
-              {{ stats.total_pending }}
-            </n-statistic>
-          </n-card>
-        </n-grid-item>
-        <n-grid-item>
-          <n-card :bordered="false" embedded class="bg-gray-50 dark:bg-gray-800">
-             <n-statistic label="今日已清洗">
-               <template #prefix>
-                 <TheIcon icon="mdi:check-circle" :size="24" :color="themeVars.successColor" />
-               </template>
-               {{ stats.today_processed }}
-               <template #suffix>
-                 <span class="text-xs text-gray-400">家</span>
-               </template>
-             </n-statistic>
-          </n-card>
-        </n-grid-item>
-      </n-grid>
+  <CommonPage title="公司清洗控制台">
+    <div class="monitor-shell">
+      <section class="monitor-hero">
+        <div class="hero-copy">
+          <span class="hero-badge">MySQL Company Pipeline</span>
+          <h1>公司清洗现在只写 MySQL，ClickHouse 只保留职位数据。</h1>
+          <p>
+            在这里统一完成候选提取、批量执行、失败重试和结果查看。队列、详情、状态统计都已经切到新的
+            MySQL 流程。
+          </p>
+          <div class="hero-pills">
+            <span class="hero-pill">运行中 {{ totalProcessing }}</span>
+            <span class="hero-pill">活跃来源 {{ activeSources }}</span>
+          </div>
+        </div>
+        <div class="hero-actions">
+          <n-button type="primary" size="large" :loading="refreshing" @click="refreshAll">
+            <template #icon>
+              <TheIcon icon="mdi:refresh" />
+            </template>
+            刷新面板
+          </n-button>
+          <div class="hero-note">
+            <span>最近刷新</span>
+            <strong>{{ lastRefreshLabel }}</strong>
+            <small>自动刷新 30s</small>
+          </div>
+        </div>
+      </section>
 
-      <!-- 2. 任务控制台 -->
-      <n-card title="任务控制台" size="medium">
-        <template #header-extra>
-            <n-button text type="primary" @click="fetchStats">
-                <template #icon><TheIcon icon="mdi:refresh" /></template>
-                刷新数据
+      <!-- 爬虫入库统计区域 -->
+      <section class="ingest-section">
+        <div class="ingest-title">
+          <TheIcon icon="mdi:spider-web" />
+          <span>爬虫职位入库统计</span>
+          <small>近 7 天 · 数据来自 ClickHouse</small>
+        </div>
+        <div class="ingest-platform-grid">
+          <div
+            v-for="p in ingestPlatformCards"
+            :key="p.platform"
+            class="ingest-platform-card"
+          >
+            <div class="ingest-platform-label">
+              <TheIcon :icon="platformIconMap[p.platform]" />
+              {{ p.label }}
+            </div>
+            <div class="ingest-platform-total">{{ p.total.toLocaleString() }}</div>
+            <div class="ingest-platform-meta">
+              今日 +{{ p.today }}
+            </div>
+            <div class="ingest-platform-time">
+              最近: {{ p.last_ingest_at || '--' }}
+            </div>
+          </div>
+        </div>
+        <div class="ingest-trend" v-if="trendRows.length > 0">
+          <div class="ingest-trend-label">近 7 天每日入库趋势</div>
+          <n-data-table
+            size="small"
+            :columns="trendColumns"
+            :data="trendRows"
+            :pagination="false"
+            :bordered="false"
+            class="ingest-trend-table"
+          />
+        </div>
+      </section>
+
+      <section class="metric-grid">
+        <n-card :bordered="false" class="metric-card metric-card--pending">
+          <div class="metric-label">待处理队列</div>
+          <div class="metric-value">{{ stats.total_pending || 0 }}</div>
+          <div class="metric-meta">待抓取公司详情的记录数</div>
+        </n-card>
+        <n-card :bordered="false" class="metric-card metric-card--done">
+          <div class="metric-label">今日已完成</div>
+          <div class="metric-value">{{ stats.today_processed || 0 }}</div>
+          <div class="metric-meta">今日成功写入 MySQL 的公司数</div>
+        </n-card>
+        <n-card :bordered="false" class="metric-card metric-card--failed">
+          <div class="metric-label">职位写入</div>
+          <div class="metric-value">{{ totalJobsStored }}</div>
+          <div class="metric-meta">公司清洗后同步到 ClickHouse 的职位数</div>
+        </n-card>
+        <n-card :bordered="false" class="metric-card metric-card--rate">
+          <div class="metric-label">整体完成率</div>
+          <div class="metric-value">{{ completionRate }}%</div>
+          <div class="metric-meta">当前 {{ totalProcessing }} 条记录正在执行</div>
+        </n-card>
+      </section>
+
+      <section class="pipeline-strip">
+        <div class="pipeline-step">
+          <span>01</span>
+          <strong>职位候选抽取</strong>
+          <p>从 ClickHouse 职位表提取公司候选，不再依赖公司表。</p>
+        </div>
+        <div class="pipeline-step">
+          <span>02</span>
+          <strong>MySQL 队列去重</strong>
+          <p>统一按来源和公司 ID 去重，进入待处理队列。</p>
+        </div>
+        <div class="pipeline-step">
+          <span>03</span>
+          <strong>详情抓取入库</strong>
+          <p>结构化字段和 `raw_json` 同步写入 MySQL 公司表。</p>
+        </div>
+        <div class="pipeline-step">
+          <span>04</span>
+          <strong>结果监控重试</strong>
+          <p>失败记录保留队列状态，可直接重试并查看最终 JSON。</p>
+        </div>
+      </section>
+
+      <section class="control-grid">
+        <n-card :bordered="false" class="control-card">
+          <template #header>
+            <div class="section-title">
+              <TheIcon icon="mdi:magnify-scan" />
+              <span>候选提取</span>
+            </div>
+          </template>
+          <div class="control-body">
+            <n-select
+              v-model:value="selectedSource"
+              :options="sourceOptions"
+              placeholder="选择提取来源"
+              class="control-field"
+            />
+            <n-input-number
+              v-model:value="analyzeLimit"
+              :min="1"
+              :max="5000"
+              class="control-field"
+              placeholder="提取数量"
+            >
+              <template #suffix>条</template>
+            </n-input-number>
+            <n-button type="info" secondary :loading="analyzing" @click="handleAnalyze">
+              开始提取
             </n-button>
-        </template>
-        <n-grid :x-gap="24" :cols="2">
-            <!-- 左侧：数据分析 -->
-            <n-grid-item>
-                <div class="flex flex-col gap-3">
-                    <div class="flex items-center gap-2">
-                        <TheIcon icon="mdi:magnify-scan" class="text-info" :size="20"/>
-                        <span class="font-bold text-gray-700 dark:text-gray-200">数据分析 (Analysis)</span>
-                    </div>
-                    <n-space align="center">
-                        <n-select
-                            v-model:value="selectedSource"
-                            size="medium"
-                            :options="sourceOptions"
-                            style="width: 150px"
-                            placeholder="选择数据源"
-                        />
-                        <n-input-number
-                            v-model:value="analyzeLimit"
-                            size="medium"
-                            :min="1"
-                            :max="5000"
-                            style="width: 140px"
-                            placeholder="分析数量"
-                        >
-                            <template #suffix>条</template>
-                        </n-input-number>
-                        <n-button
-                            size="medium"
-                            type="info"
-                            secondary
-                            :loading="analyzing"
-                            @click="handleAnalyze"
-                        >
-                            分析待处理数据
-                        </n-button>
-                    </n-space>
-                    <n-alert type="info" :show-icon="false" class="mt-2">
-                        扫描原始招聘数据，将未处理的公司提取到 Pending 队列中
-                    </n-alert>
-                </div>
-            </n-grid-item>
-            
-             <!-- 右侧：任务执行 -->
-            <n-grid-item>
-                 <div class="flex flex-col gap-3 border-l pl-6 border-gray-100 dark:border-gray-700">
-                    <div class="flex items-center gap-2">
-                         <TheIcon icon="mdi:spider-web" class="text-primary" :size="20"/>
-                         <span class="font-bold text-gray-700 dark:text-gray-200">批量执行 (Execution)</span>
-                    </div>
-                     <n-space align="center">
-                        <n-select
-                            v-model:value="globalProxy"
-                            size="medium"
-                            :options="batchProxyOptions"
-                            style="width: 200px"
-                            placeholder="使用全局代理 (可选)"
-                            clearable
-                        />
-                        <n-input-number
-                            v-model:value="runLimit"
-                            size="medium"
-                            :min="1"
-                            :max="5000"
-                            style="width: 120px"
-                            placeholder="每批数量"
-                        />
-                        <n-input-number
-                            v-model:value="batchMaxDelay"
-                            size="medium"
-                            :min="1"
-                            :max="60"
-                            style="width: 120px"
-                            placeholder="最大延时"
-                        >
-                             <template #suffix>秒</template>
-                        </n-input-number>
-                    </n-space>
-                    <n-alert type="warning" :show-icon="false" class="mt-2">
-                        <span class="font-bold">配置应用于：</span> 下方所有执行操作
-                    </n-alert>
-                </div>
-            </n-grid-item>
-        </n-grid>
-      </n-card>
+          </div>
+          <n-alert type="info" :show-icon="false">
+            从 ClickHouse 的职位表抽取未清洗过的公司候选，写入 MySQL 队列表。
+          </n-alert>
+        </n-card>
+
+        <n-card :bordered="false" class="control-card">
+          <template #header>
+            <div class="section-title">
+              <TheIcon icon="mdi:database-sync" />
+              <span>批量执行</span>
+            </div>
+          </template>
+          <div class="control-body control-body--wide">
+            <n-select
+              v-model:value="globalProxy"
+              :options="batchProxyOptions"
+              placeholder="全局代理，可选"
+              clearable
+              class="control-field control-field--grow"
+            />
+            <n-input-number
+              v-model:value="runLimit"
+              :min="1"
+              :max="5000"
+              class="control-field"
+              placeholder="执行数量"
+            >
+              <template #suffix>条</template>
+            </n-input-number>
+            <n-input-number
+              v-model:value="batchMaxDelay"
+              :min="1"
+              :max="60"
+              class="control-field"
+              placeholder="最大延时"
+            >
+              <template #suffix>秒</template>
+            </n-input-number>
+          </div>
+          <n-alert type="warning" :show-icon="false">
+            这些配置会应用到批量执行和单条重试。
+          </n-alert>
+        </n-card>
+      </section>
+
+      <section class="platform-grid">
+        <n-card
+          v-for="platform in platformCards"
+          :key="platform.source"
+          :bordered="false"
+          class="platform-card"
+        >
+          <div class="platform-header">
+            <div>
+              <div class="platform-title">
+                <TheIcon :icon="platform.icon" />
+                <span>{{ platform.label }}</span>
+              </div>
+              <div class="platform-subtitle">今日队列状态</div>
+            </div>
+            <n-tag size="small" :bordered="false" :type="platform.failed > 0 ? 'error' : 'success'">
+              {{ platform.total }} 总量
+            </n-tag>
+          </div>
+
+          <div class="platform-stats">
+            <div class="platform-stat">
+              <span>Pending</span>
+              <strong>{{ platform.pending }}</strong>
+            </div>
+            <div class="platform-stat">
+              <span>Done</span>
+              <strong>{{ platform.done }}</strong>
+            </div>
+            <div class="platform-stat">
+              <span>Processing</span>
+              <strong>{{ platform.processing }}</strong>
+            </div>
+            <div class="platform-stat">
+              <span>Failed</span>
+              <strong>{{ platform.failed }}</strong>
+            </div>
+          </div>
+
+          <div class="platform-job-strip">
+            <span>职位同步</span>
+            <strong>{{ platform.jobs_stored }}</strong>
+            <small
+              >抓取 {{ platform.jobs_fetched }} / 重复 {{ platform.jobs_duplicate }} / 失败
+              {{ platform.jobs_failed }}</small
+            >
+          </div>
+
+          <n-progress
+            type="line"
+            :percentage="platform.rate"
+            :height="10"
+            :show-indicator="false"
+            processing
+            class="platform-progress"
+          />
+
+          <div class="platform-footer">
+            <span class="platform-rate">完成率 {{ platform.rate.toFixed(1) }}%</span>
+            <div class="platform-actions">
+              <n-button size="small" tertiary @click="focusQueue(platform.source)"> 队列 </n-button>
+              <n-button
+                size="small"
+                type="primary"
+                secondary
+                :disabled="platform.pending === 0"
+                :loading="!!platformRunningMap[platform.source]"
+                @click="handleExecuteBySource(platform.source)"
+              >
+                执行
+              </n-button>
+            </div>
+          </div>
+        </n-card>
+      </section>
+
+      <n-card :bordered="false" class="queue-card">
+        <template #header>
+          <div class="section-title">
+            <TheIcon icon="mdi:format-list-bulleted-square" />
+            <span>实时队列</span>
+          </div>
+        </template>
+        <template #header-extra>
+          <n-button text type="primary" @click="fetchDetail">
+            <template #icon>
+              <TheIcon icon="mdi:refresh" />
+            </template>
+            刷新队列
+          </n-button>
+        </template>
+
+        <div class="queue-toolbar">
+          <div class="queue-filters">
+            <n-select
+              v-model:value="drawerSource"
+              :options="sourceOptions"
+              clearable
+              placeholder="筛选来源"
+              class="queue-filter"
+              @update:value="handleDrawerFilter"
+            />
+            <n-select
+              v-model:value="drawerStatus"
+              :options="statusOptions"
+              clearable
+              placeholder="筛选状态"
+              class="queue-filter"
+              @update:value="handleDrawerFilter"
+            />
+          </div>
+          <div class="queue-summary">
+            <span>当前记录</span>
+            <strong>{{ pagination.itemCount }}</strong>
+          </div>
+        </div>
 
-      <!-- 3. 数据表格 -->
-      <n-card title="各平台进度详情" size="medium">
         <n-data-table
-          :columns="columns"
-          :data="stats.details"
-          :loading="loading"
+          remote
+          :columns="detailColumns"
+          :data="detailData"
+          :loading="detailLoading"
+          :pagination="pagination"
+          :scroll-x="1200"
+          @update:page="handlePageChange"
         />
       </n-card>
-      
-      <!-- 说明 -->
-      <n-card title="说明" size="small">
-          <n-ul>
-              <n-li>系统每天凌晨 02:00 自动扫描待处理公司ID。</n-li>
-              <n-li>pending (待处理): 已识别但尚未获取详情的公司。</n-li>
-              <n-li>done (已完成): 已成功获取详情并入库。</n-li>
-              <n-li>failed (失败): 获取详情失败，需重试或检查爬虫。</n-li>
-          </n-ul>
-      </n-card>
-      
-      <!-- 详情抽屉 -->
-      <n-drawer v-model:show="showDrawer" width="1200">
-        <n-drawer-content title="待处理公司列表">
-          <div class="flex gap-2 mb-4 items-center justify-between">
-             <div class="flex gap-2">
-                 <n-select 
-                    v-model:value="drawerSource" 
-                    :options="sourceOptions" 
-                    placeholder="平台" 
-                    clearable 
-                    size="medium"
-                    style="width: 160px"
-                    @update:value="handleDrawerFilter"
-                 />
-                 <n-select 
-                    v-model:value="drawerStatus" 
-                    :options="statusOptions" 
-                    placeholder="状态" 
-                    clearable 
-                    size="medium"
-                    style="width: 160px"
-                    @update:value="handleDrawerFilter"
-                 />
-             </div>
-             <div class="flex items-center gap-2">
-                 <n-button size="medium" @click="handleBatchActionInDrawer" disabled>
-                     批量操作 (开发中)
-                 </n-button>
-             </div>
-          </div>
-          <n-data-table
-            remote
-            :columns="detailColumns"
-            :data="detailData"
-            :loading="detailLoading"
-            :pagination="pagination"
-            :scroll-x="1200"
-            @update:page="handlePageChange"
-          />
-        </n-drawer-content>
-      </n-drawer>
 
-      <!-- JSON 查看模态框 -->
-      <n-modal v-model:show="showResultModal" preset="card" title="公司详情" style="width: 800px">
+      <n-card :bordered="false" class="guide-card">
+        <template #header>
+          <div class="section-title">
+            <TheIcon icon="mdi:information-outline" />
+            <span>运行说明</span>
+          </div>
+        </template>
+        <div class="guide-grid">
+          <div class="guide-item">
+            <strong>候选提取</strong>
+            <p>从 ClickHouse 职位表提取公司 ID，去重后写入 MySQL 队列。</p>
+          </div>
+          <div class="guide-item">
+            <strong>批量执行</strong>
+            <p>调用各站公司详情接口，把结构化字段和 `raw_json` 一起写入 MySQL。</p>
+          </div>
+          <div class="guide-item">
+            <strong>失败重试</strong>
+            <p>队列中 `failed` 记录可以单条重试，不再回写 ClickHouse 公司表。</p>
+          </div>
+        </div>
+      </n-card>
+
+      <n-modal
+        v-model:show="showResultModal"
+        preset="card"
+        title="公司详情 JSON"
+        style="width: 900px"
+      >
         <n-code :code="resultJson" language="json" word-wrap />
       </n-modal>
-      <n-modal v-model:show="showSingleResultModal" preset="card" title="任务执行结果" style="width: 800px">
+      <n-modal
+        v-model:show="showSingleResultModal"
+        preset="card"
+        title="任务执行结果"
+        style="width: 900px"
+      >
         <n-code :code="singleResultJson" language="json" word-wrap />
       </n-modal>
     </div>
@@ -195,428 +359,1017 @@
 </template>
 
 <script setup>
-import { ref, onMounted, h, reactive, computed } from 'vue'
-import { NGrid, NGridItem, NCard, NStatistic, NDataTable, NButton, NUl, NLi, NTag, NInputNumber, NSelect, NDrawer, NDrawerContent, NModal, NCode, NSpace, NDropdown, useMessage, NIcon, useThemeVars, NText, NAlert } from 'naive-ui'
+import { computed, h, onBeforeUnmount, onMounted, reactive, ref } from 'vue'
+import {
+  NAlert,
+  NButton,
+  NCard,
+  NCode,
+  NDataTable,
+  NInputNumber,
+  NModal,
+  NProgress,
+  NSelect,
+  NTag,
+  useMessage,
+} from 'naive-ui'
+
 import CommonPage from '@/components/page/CommonPage.vue'
 import TheIcon from '@/components/icon/TheIcon.vue'
 import api from '@/api'
 import proxyApi from '@/api/proxy'
 
-const themeVars = useThemeVars()
-
 const message = useMessage()
-const loading = ref(false)
-const running = ref(false)
-const analyzing = ref(false)
+
 const stats = ref({
-    total_pending: 0,
-    today_processed: 0,
-    details: []
+  total_pending: 0,
+  today_processed: 0,
+  details: [],
 })
 
-// Drawer state
-const showDrawer = ref(false)
+// ─── 爬虫入库统计 ─────────────────────────────────────
+const ingestStatsRaw = ref({})
+const platformIconMap = {
+  boss: 'mdi:alpha-b-box-outline',
+  qcwy: 'mdi:alpha-q-box-outline',
+  zhilian: 'mdi:alpha-z-box-outline',
+}
+const platformLabelMap = {
+  boss: 'Boss直聘',
+  qcwy: '前程无忧',
+  zhilian: '智联招聘',
+}
+
+const ingestPlatformCards = computed(() =>
+  ['boss', 'qcwy', 'zhilian'].map((p) => ({
+    platform: p,
+    label: platformLabelMap[p],
+    total: ingestStatsRaw.value[p]?.total || 0,
+    today: ingestStatsRaw.value[p]?.today || 0,
+    last_ingest_at: ingestStatsRaw.value[p]?.last_ingest_at || null,
+  }))
+)
+
+const trendColumns = computed(() => [
+  { title: '日期', key: 'date', width: 110 },
+  { title: 'Boss', key: 'boss', width: 80 },
+  { title: '前程无忧', key: 'qcwy', width: 90 },
+  { title: '智联招聘', key: 'zhilian', width: 90 },
+])
+
+const trendRows = computed(() => {
+  const allDates = new Set()
+  const dateMap = { boss: {}, qcwy: {}, zhilian: {} }
+  ;['boss', 'qcwy', 'zhilian'].forEach((p) => {
+    const daily = ingestStatsRaw.value[p]?.daily_counts || []
+    daily.forEach((item) => {
+      allDates.add(item.date)
+      dateMap[p][item.date] = item.count
+    })
+  })
+  return [...allDates].sort().reverse().map((date) => ({
+    date,
+    boss: dateMap.boss[date] ?? 0,
+    qcwy: dateMap.qcwy[date] ?? 0,
+    zhilian: dateMap.zhilian[date] ?? 0,
+  }))
+})
+
+const fetchIngestStats = async () => {
+  try {
+    const res = await api.getIngestStats({ days: 7 })
+    if (res.code === 200) {
+      ingestStatsRaw.value = res.data || {}
+    }
+  } catch (e) {
+    // 静默失败，不影响主监控面板
+    console.warn('fetchIngestStats failed:', e)
+  }
+}
+const refreshing = ref(false)
+const analyzing = ref(false)
 const detailLoading = ref(false)
+const lastRefreshedAt = ref(null)
+
 const detailData = ref([])
-const drawerSource = ref(null)
-const drawerStatus = ref(null)
-const pagination = reactive({
-    page: 1,
-    pageSize: 20,
-    itemCount: 0,
-    prefix: ({ itemCount }) => `共 ${itemCount} 条`
-})
-
-const statusOptions = [
-    { label: '全部状态', value: null },
-    { label: '待处理', value: 'pending' },
-    { label: '已完成', value: 'done' },
-    { label: '失败', value: 'failed' }
-]
-
-// Modals
 const showResultModal = ref(false)
 const resultJson = ref('')
 const showSingleResultModal = ref(false)
 const singleResultJson = ref('')
 
-// Config & State
 const allProxies = ref([])
-const executingMap = ref({}) 
+const executingMap = ref({})
 const platformRunningMap = ref({})
 
-// Global Configs
 const runLimit = ref(100)
-const analyzeLimit = ref(1000)
+const analyzeLimit = ref(100)
 const selectedSource = ref(null)
 const globalProxy = ref(null)
 const batchMaxDelay = ref(5)
+const drawerSource = ref(null)
+const drawerStatus = ref(null)
 
-const sourceOptions = [
-    { label: '全部数据源', value: null },
-    { label: 'Boss直聘', value: 'boss' },
-    { label: '前程无忧', value: 'qcwy' },
-    { label: '智联招聘', value: 'zhilian' }
-]
-
-const batchProxyOptions = computed(() => {
-    if (!allProxies.value || !allProxies.value.length) return []
-    const source = selectedSource.value
-    return allProxies.value
-        .filter((item) => {
-            if (!item.is_active) return false
-            if (!source) return true
-            if (source === 'boss') return item.platform === 'boss' || item.platform === 'all'
-            if (source === 'qcwy') return item.platform === 'qcwy' || item.platform === 'all'
-            if (source === 'zhilian') return item.platform === 'zhilian' || item.platform === 'all'
-            return true
-        })
-        .map((item) => ({
-            label: `${item.name} (${item.proxy_type.toUpperCase()})`,
-            value: item.proxy_url
-        }))
+const pagination = reactive({
+  page: 1,
+  pageSize: 20,
+  itemCount: 0,
+  prefix: ({ itemCount }) => `共 ${itemCount} 条`,
 })
 
-// --- Columns Definitions ---
-
-const columns = [
-    {
-        title: '平台',
-        key: 'source',
-        render(row) {
-             const map = { 'boss': 'Boss直聘', 'qcwy': '前程无忧', 'zhilian': '智联招聘' }
-             return map[row.source] || row.source
-        }
-    },
-    {
-        title: '待处理',
-        key: 'pending',
-        render(row) {
-            return h(NTag, { type: 'warning', bordered: false }, { default: () => row.pending })
-        }
-    },
-    {
-        title: '已完成',
-        key: 'done',
-        render(row) {
-            return h(NTag, { type: 'success', bordered: false }, { default: () => row.done })
-        }
-    },
-    {
-        title: '失败',
-        key: 'failed',
-        render(row) {
-            return row.failed > 0 
-                ? h(NTag, { type: 'error', bordered: false }, { default: () => row.failed })
-                : '-'
-        }
-    },
-    {
-        title: '完成率',
-        key: 'rate',
-        render(row) {
-            if (!row.total) return '0%'
-            const rate = ((row.done / row.total) * 100).toFixed(1)
-            return `${rate}%`
-        }
-    },
-    {
-        title: '操作',
-        key: 'actions',
-        width: 250,
-        render(row) {
-            return h(
-                'div',
-                { class: 'flex gap-2 items-center' },
-                [
-                    h(
-                        NButton,
-                        {
-                            size: 'small', // Keep buttons small in table, but not tiny
-                            type: 'primary',
-                            secondary: true,
-                            disabled: row.pending === 0,
-                            loading: !!platformRunningMap.value[row.source],
-                            onClick: () => handleExecuteBySource(row.source)
-                        },
-                        { 
-                            default: () => '执行任务',
-                            icon: () => h(TheIcon, { icon: 'mdi:play' }) 
-                        }
-                    ),
-                    h(
-                        NButton,
-                        {
-                            size: 'small',
-                            tertiary: true,
-                            onClick: () => openDetail(row.source)
-                        },
-                        { default: () => '查看详情' }
-                    )
-                ]
-            )
-        }
-    }
+const sourceOptions = [
+  { label: '全部数据源', value: null },
+  { label: 'Boss直聘', value: 'boss' },
+  { label: '前程无忧', value: 'qcwy' },
+  { label: '智联招聘', value: 'zhilian' },
 ]
 
+const statusOptions = [
+  { label: '全部状态', value: null },
+  { label: '待处理', value: 'pending' },
+  { label: '处理中', value: 'processing' },
+  { label: '已完成', value: 'done' },
+  { label: '失败', value: 'failed' },
+]
+
+const platformMeta = {
+  boss: { label: 'Boss直聘', icon: 'mdi:alpha-b-box-outline' },
+  qcwy: { label: '前程无忧', icon: 'mdi:alpha-q-box-outline' },
+  zhilian: { label: '智联招聘', icon: 'mdi:alpha-z-box-outline' },
+}
+const platformSources = ['boss', 'qcwy', 'zhilian']
+
+const batchProxyOptions = computed(() => {
+  if (!allProxies.value.length) return []
+  const source = selectedSource.value
+  return allProxies.value
+    .filter((item) => {
+      if (!item.is_active) return false
+      if (!source) return true
+      return item.platform === source || item.platform === 'all'
+    })
+    .map((item) => ({
+      label: `${item.name} (${item.proxy_type.toUpperCase()})`,
+      value: item.proxy_url,
+    }))
+})
+
+const normalizedDetails = computed(() => {
+  const detailMap = new Map((stats.value.details || []).map((item) => [item.source, item]))
+  return platformSources.map((source) => {
+    const item = detailMap.get(source) || {}
+    const pending = Number(item.pending || 0)
+    const processing = Number(item.processing || 0)
+    const done = Number(item.done || 0)
+    const failed = Number(item.failed || 0)
+    const jobsFetched = Number(item.jobs_fetched || 0)
+    const jobsStored = Number(item.jobs_stored || 0)
+    const jobsDuplicate = Number(item.jobs_duplicate || 0)
+    const jobsFailed = Number(item.jobs_failed || 0)
+    const total = Number(item.total || pending + processing + done + failed)
+    return {
+      source,
+      pending,
+      processing,
+      done,
+      failed,
+      jobs_fetched: jobsFetched,
+      jobs_stored: jobsStored,
+      jobs_duplicate: jobsDuplicate,
+      jobs_failed: jobsFailed,
+      total,
+      rate: total ? (done / total) * 100 : 0,
+    }
+  })
+})
+
+const totalFailed = computed(() =>
+  normalizedDetails.value.reduce((sum, item) => sum + (item.failed || 0), 0)
+)
+
+const totalJobsStored = computed(() =>
+  normalizedDetails.value.reduce((sum, item) => sum + (item.jobs_stored || 0), 0)
+)
+
+const totalProcessing = computed(() =>
+  normalizedDetails.value.reduce((sum, item) => sum + (item.processing || 0), 0)
+)
+
+const activeSources = computed(
+  () => normalizedDetails.value.filter((item) => item.total > 0).length
+)
+
+const lastRefreshLabel = computed(() => {
+  if (!lastRefreshedAt.value) return '--:--:--'
+  return new Date(lastRefreshedAt.value).toLocaleTimeString('zh-CN', { hour12: false })
+})
+
+const completionRate = computed(() => {
+  const total = normalizedDetails.value.reduce((sum, item) => sum + item.total, 0)
+  const done = normalizedDetails.value.reduce((sum, item) => sum + item.done, 0)
+  return total ? ((done / total) * 100).toFixed(1) : '0.0'
+})
+
+const platformCards = computed(() =>
+  normalizedDetails.value.map((item) => ({
+    ...item,
+    ...platformMeta[item.source],
+  }))
+)
+
 const detailColumns = [
-    {
-        title: '平台',
-        key: 'source',
-        width: 80,
-        render(row) {
-             const map = { 'boss': 'Boss', 'qcwy': '前程', 'zhilian': '智联' }
-             return map[row.source] || row.source
-        }
+  {
+    title: '平台',
+    key: 'source',
+    width: 100,
+    render(row) {
+      return platformMeta[row.source]?.label || row.source
     },
-    {
-        title: '公司名称',
-        key: 'company_name',
-        width: 200,
-        ellipsis: { tooltip: true }
+  },
+  {
+    title: '公司名称',
+    key: 'company_name',
+    width: 220,
+    ellipsis: { tooltip: true },
+  },
+  {
+    title: '公司ID',
+    key: 'company_id',
+    width: 160,
+    ellipsis: { tooltip: true },
+  },
+  {
+    title: '状态',
+    key: 'status',
+    width: 100,
+    render(row) {
+      const typeMap = { pending: 'warning', processing: 'info', done: 'success', failed: 'error' }
+      return h(
+        NTag,
+        { type: typeMap[row.status] || 'default', size: 'small', bordered: false },
+        { default: () => row.status }
+      )
     },
-    {
-        title: '公司ID',
-        key: 'company_id',
-        width: 150,
-        ellipsis: { tooltip: true }
+  },
+  {
+    title: '错误信息',
+    key: 'error_msg',
+    minWidth: 220,
+    ellipsis: { tooltip: true },
+    render(row) {
+      return row.error_msg || '-'
     },
-    {
-        title: '状态',
-        key: 'status',
-        width: 90,
-        render(row) {
-            const typeMap = { 'pending': 'warning', 'done': 'success', 'failed': 'error' }
-            return h(NTag, { type: typeMap[row.status] || 'default', size: 'small' }, { default: () => row.status })
-        }
+  },
+  {
+    title: '职位同步',
+    key: 'jobs_summary',
+    minWidth: 220,
+    render(row) {
+      return `${row.jobs_stored || 0} 入库 / ${row.jobs_duplicate || 0} 重复 / ${
+        row.jobs_failed || 0
+      } 失败`
     },
-    {
-        title: '更新时间',
-        key: 'updated_at',
-        width: 170,
-        render(row) {
-            return row.updated_at ? row.updated_at.replace('T', ' ').split('.')[0] : '-'
-        }
+  },
+  {
+    title: '更新时间',
+    key: 'updated_at',
+    width: 180,
+    render(row) {
+      return row.updated_at ? row.updated_at.replace('T', ' ').split('.')[0] : '-'
     },
-    {
-        title: '操作',
-        key: 'actions',
-        width: 150,
-        fixed: 'right',
-        render(row) {
-            if (row.status === 'pending' || row.status === 'failed') {
-                return h(
-                    NButton,
-                    {
-                        size: 'tiny',
-                        type: 'primary',
-                        loading: !!executingMap.value[row.company_id],
-                        onClick: () => handleExecuteSingle(row)
-                    },
-                    { default: () => row.status === 'failed' ? '重试' : '执行' }
-                )
-            }
-            if (row.status === 'done') {
-                return h(
-                    NButton,
-                    {
-                        size: 'tiny',
-                        tertiary: true,
-                        onClick: () => viewCompanyResult(row)
-                    },
-                    { default: () => '查看结果' }
-                )
-            }
-            return null
-        }
-    }
+  },
+  {
+    title: '操作',
+    key: 'actions',
+    width: 170,
+    fixed: 'right',
+    render(row) {
+      if (row.status === 'pending' || row.status === 'failed') {
+        return h(
+          NButton,
+          {
+            size: 'small',
+            type: 'primary',
+            loading: !!executingMap.value[row.company_id],
+            onClick: () => handleExecuteSingle(row),
+          },
+          { default: () => (row.status === 'failed' ? '重试' : '执行') }
+        )
+      }
+      if (row.status === 'processing') {
+        return h(
+          NButton,
+          {
+            size: 'small',
+            disabled: true,
+          },
+          { default: () => '处理中' }
+        )
+      }
+      return h(
+        NButton,
+        {
+          size: 'small',
+          tertiary: true,
+          onClick: () => viewCompanyResult(row),
+        },
+        { default: () => '查看结果' }
+      )
+    },
+  },
 ]
 
-// --- Actions ---
-
 const fetchStats = async () => {
-    loading.value = true
-    try {
-        const res = await api.getCompanyCleaningStats()
-        if (res.code === 200) {
-            stats.value = res.data
-        }
-    } finally {
-        loading.value = false
+  try {
+    const res = await api.getCompanyCleaningStats()
+    if (res.code === 200) {
+      stats.value = res.data || { total_pending: 0, today_processed: 0, details: [] }
     }
+  } catch (e) {
+    message.error(`刷新统计失败: ${e.message}`)
+  }
 }
 
 const fetchDetail = async () => {
-    detailLoading.value = true
-    try {
-        const res = await api.getCompanyCleaningList({
-            page: pagination.page,
-            page_size: pagination.pageSize,
-            source: drawerSource.value || undefined,
-            status: drawerStatus.value || undefined
-        })
-        if (res.code === 200) {
-            detailData.value = res.data
-            pagination.itemCount = res.total
-        }
-    } finally {
-        detailLoading.value = false
+  detailLoading.value = true
+  try {
+    const res = await api.getCompanyCleaningList({
+      page: pagination.page,
+      page_size: pagination.pageSize,
+      source: drawerSource.value || undefined,
+      status: drawerStatus.value || undefined,
+    })
+    if (res.code === 200) {
+      detailData.value = res.data || []
+      pagination.itemCount = res.total || 0
     }
+  } finally {
+    detailLoading.value = false
+  }
 }
 
-const openDetail = (source) => {
-    drawerSource.value = source
-    drawerStatus.value = null
-    pagination.page = 1
-    showDrawer.value = true
-    fetchDetail()
+const refreshAll = async () => {
+  refreshing.value = true
+  try {
+    await Promise.all([fetchStats(), fetchDetail(), fetchIngestStats()])
+    lastRefreshedAt.value = Date.now()
+  } finally {
+    refreshing.value = false
+  }
 }
 
 const handleDrawerFilter = () => {
-    pagination.page = 1
-    fetchDetail()
+  pagination.page = 1
+  fetchDetail()
 }
 
 const handlePageChange = (page) => {
-    pagination.page = page
-    fetchDetail()
+  pagination.page = page
+  fetchDetail()
+}
+
+const focusQueue = (source) => {
+  drawerSource.value = source
+  drawerStatus.value = null
+  pagination.page = 1
+  fetchDetail()
 }
 
 const viewCompanyResult = async (row) => {
-    if (row.status !== 'done') {
-        message.warning('当前记录未完成清洗')
-        return
-    }
-    try {
-        const res = await api.getCompanyCleaningDetail({
-            source: row.source,
-            company_id: row.company_id,
-            company_name: row.company_name
-        })
-        if (res.code === 200 && res.data) {
-            const content = res.data.data || res.data
-            resultJson.value = JSON.stringify(content, null, 2)
-            showResultModal.value = true
-        } else {
-            message.warning(res.msg || '未找到公司清洗结果')
-        }
-    } catch (e) {
-        message.error('获取公司详情失败')
+  if (row.status !== 'done') {
+    message.warning('当前记录未完成清洗')
+    return
+  }
+  try {
+    const res = await api.getCompanyCleaningDetail({
+      source: row.source,
+      company_id: row.company_id,
+      company_name: row.company_name,
+    })
+    if (res.code === 200 && res.data) {
+      const content = res.data.data || res.data
+      resultJson.value = JSON.stringify(content, null, 2)
+      showResultModal.value = true
+    } else {
+      message.warning(res.msg || '未找到公司清洗结果')
     }
+  } catch (e) {
+    message.error('获取公司详情失败')
+  }
 }
 
 const handleAnalyze = async () => {
-    if (!analyzeLimit.value || analyzeLimit.value <= 0) {
-        message.warning('请先填写分析数量')
-        return
-    }
-    try {
-        analyzing.value = true
-        await api.collectPendingCompanies({
-            limit: analyzeLimit.value,
-            source: selectedSource.value || null
-        })
-        message.success(`已完成数据分析，收集待处理公司 (上限 ${analyzeLimit.value} 条)`)
-        await fetchStats()
-    } catch (e) {
-        message.error('数据分析失败')
-    } finally {
-        analyzing.value = false
+  if (!analyzeLimit.value || analyzeLimit.value <= 0) {
+    message.warning('请先填写提取数量')
+    return
+  }
+  try {
+    analyzing.value = true
+    const res = await api.collectPendingCompanies({
+      limit: analyzeLimit.value,
+      source: selectedSource.value || null,
+    })
+    const totalCreated = Number(res?.data?.total_created || 0)
+    const sourceSummaries = Object.values(res?.data?.sources || {})
+    const sourceText = sourceSummaries
+      .map(
+        (item) => `${platformMeta[item.source]?.label || item.source} +${item.created_count || 0}`
+      )
+      .join('，')
+    if (totalCreated > 0) {
+      message.success(sourceText || `已完成候选提取，新增 ${totalCreated} 条`)
+    } else {
+      message.warning(
+        sourceText || '本次没有新增候选，通常是该来源最近窗口内没有可提取数据，或已全部入库/入队'
+      )
     }
+    await refreshAll()
+  } catch (e) {
+    message.error(`数据提取失败: ${e.message}`)
+  } finally {
+    analyzing.value = false
+  }
 }
 
 const handleExecuteSingle = async (row) => {
-    try {
-        executingMap.value[row.company_id] = true
-        
-        const payload = {
-            source: row.source,
-            company_id: row.company_id,
-            max_delay_seconds: batchMaxDelay.value || 5 
-        }
-        if (globalProxy.value) {
-            payload.proxy = globalProxy.value
-        }
-        
-        const res = await api.runSingleCompanyCleaning(payload)
-        const success = res && res.code === 200 && res.data && res.data.success
-        
-        if (success) {
-            message.success('任务执行成功')
-            await fetchDetail()
-        } else {
-            const detail = {
-                request: payload,
-                response: res
-            }
-            singleResultJson.value = JSON.stringify(detail, null, 2)
-            showSingleResultModal.value = true
-            message.error((res && res.msg) || '任务执行失败')
-        }
-    } catch (e) {
-        message.error('执行异常: ' + e.message)
-    } finally {
-        executingMap.value[row.company_id] = false
+  try {
+    executingMap.value[row.company_id] = true
+    const payload = {
+      source: row.source,
+      company_id: row.company_id,
+      max_delay_seconds: batchMaxDelay.value || 5,
     }
+    if (globalProxy.value) {
+      payload.proxy = globalProxy.value
+    }
+    const res = await api.runSingleCompanyCleaning(payload)
+    const success = !!(res && res.code === 200 && res.data && res.data.success)
+    if (success) {
+      message.success('任务执行成功')
+      await refreshAll()
+      return
+    }
+    singleResultJson.value = JSON.stringify({ request: payload, response: res }, null, 2)
+    showSingleResultModal.value = true
+    message.error((res && res.msg) || '任务执行失败')
+  } catch (e) {
+    message.error(`执行异常: ${e.message}`)
+  } finally {
+    executingMap.value[row.company_id] = false
+  }
 }
 
 const handleExecuteBySource = async (source) => {
-    if (!runLimit.value || runLimit.value <= 0) {
-        message.warning('请先填写执行数量')
-        return
+  if (!runLimit.value || runLimit.value <= 0) {
+    message.warning('请先填写执行数量')
+    return
+  }
+  try {
+    platformRunningMap.value[source] = true
+    const payload = {
+      limit: runLimit.value,
+      source,
+      max_delay_seconds: batchMaxDelay.value || 5,
     }
-    try {
-        platformRunningMap.value[source] = true
-        
-        const payload = {
-            limit: runLimit.value,
-            source: source,
-            max_delay_seconds: batchMaxDelay.value || 5,
-        }
-        if (globalProxy.value) {
-            payload.proxy = globalProxy.value
-        }
-
-        const res = await api.runPendingCompanies(payload)
-        if (res.code === 200) {
-            message.success(res.msg || '已触发批量任务')
-            await fetchStats()
-        } else {
-            message.error(res.msg || '触发失败')
-        }
-    } catch (e) {
-        message.error('触发失败: ' + e.message)
-    } finally {
-        platformRunningMap.value[source] = false
+    if (globalProxy.value) {
+      payload.proxy = globalProxy.value
     }
+    const res = await api.runPendingCompanies(payload)
+    if (res.code === 200) {
+      message.success(res.msg || '已触发批量任务')
+      await refreshAll()
+      return
+    }
+    message.error(res.msg || '触发失败')
+  } catch (e) {
+    message.error(`触发失败: ${e.message}`)
+  } finally {
+    platformRunningMap.value[source] = false
+  }
 }
 
 const loadProxies = async () => {
-    try {
-        const res = await proxyApi.list({ page: 1, page_size: 100, is_active: true })
-        allProxies.value = res.data || res.data?.data || []
-    } catch (e) {
-        allProxies.value = []
-    }
+  try {
+    const res = await proxyApi.list({ page: 1, page_size: 100, is_active: true })
+    allProxies.value = res.data || res.data?.data || []
+  } catch (e) {
+    allProxies.value = []
+  }
 }
 
-const handleBatchActionInDrawer = () => {
-    message.info('功能开发中...')
-}
+let refreshTimer = null
 
 onMounted(() => {
-    fetchStats()
-    loadProxies()
+  refreshAll()
+  loadProxies()
+  refreshTimer = window.setInterval(() => {
+    refreshAll()
+  }, 30000)
+})
+
+onBeforeUnmount(() => {
+  if (refreshTimer) {
+    window.clearInterval(refreshTimer)
+  }
 })
 </script>
 
 <style scoped>
-.stats-card {
-    transition: all 0.3s ease;
-    background-color: #fff; /* Fallback for white */
+.monitor-shell {
+  display: flex;
+  flex-direction: column;
+  gap: 20px;
 }
-.stats-card:hover {
-    transform: translateY(-2px);
-    box-shadow: 0 4px 12px rgba(0, 0, 0, 0.05);
+
+/* ─── 爬虫统计区域 ─────────────────────────────────── */
+.ingest-section {
+  background: var(--n-card-color, #fff);
+  border-radius: 16px;
+  padding: 20px 24px;
+  display: flex;
+  flex-direction: column;
+  gap: 14px;
+  box-shadow: 0 1px 3px rgba(0,0,0,.06);
+}
+
+.ingest-title {
+  display: flex;
+  align-items: center;
+  gap: 8px;
+  font-size: 14px;
+  font-weight: 600;
+  color: var(--n-text-color);
+}
+
+.ingest-title small {
+  font-weight: 400;
+  font-size: 12px;
+  opacity: .6;
+  margin-left: 4px;
+}
+
+.ingest-platform-grid {
+  display: grid;
+  grid-template-columns: repeat(3, 1fr);
+  gap: 12px;
+}
+
+.ingest-platform-card {
+  background: var(--n-card-color, #f8fafc);
+  border: 1px solid var(--n-border-color, #e5e7eb);
+  border-radius: 12px;
+  padding: 14px 16px;
+  display: flex;
+  flex-direction: column;
+  gap: 4px;
+}
+
+.ingest-platform-label {
+  display: flex;
+  align-items: center;
+  gap: 6px;
+  font-size: 12px;
+  font-weight: 600;
+  color: var(--n-text-color-disabled);
+  text-transform: uppercase;
+  letter-spacing: .04em;
+}
+
+.ingest-platform-total {
+  font-size: 28px;
+  font-weight: 700;
+  color: var(--n-text-color);
+  line-height: 1.2;
+  margin-top: 4px;
+}
+
+.ingest-platform-meta {
+  font-size: 12px;
+  color: #10b981;
+  font-weight: 500;
+}
+
+.ingest-platform-time {
+  font-size: 11px;
+  opacity: .5;
+  margin-top: 2px;
+}
+
+.ingest-trend-label {
+  font-size: 12px;
+  font-weight: 600;
+  opacity: .6;
+  margin-bottom: 6px;
+}
+
+.ingest-trend-table {
+  border-radius: 8px;
+  overflow: hidden;
+}
+
+.monitor-hero {
+  display: flex;
+  justify-content: space-between;
+  gap: 20px;
+  padding: 28px;
+  border-radius: 24px;
+  color: #f8fafc;
+  background: radial-gradient(circle at top right, rgba(255, 255, 255, 0.16), transparent 32%),
+    linear-gradient(135deg, #0f172a, #153e75 52%, #0f766e);
+}
+
+.hero-copy {
+  max-width: 720px;
+}
+
+.hero-badge {
+  display: inline-flex;
+  padding: 6px 12px;
+  border-radius: 999px;
+  font-size: 12px;
+  font-weight: 700;
+  letter-spacing: 0.08em;
+  text-transform: uppercase;
+  background: rgba(255, 255, 255, 0.14);
+}
+
+.hero-copy h1 {
+  margin: 14px 0 10px;
+  font-size: 32px;
+  line-height: 1.15;
+  font-weight: 800;
+}
+
+.hero-copy p {
+  margin: 0;
+  max-width: 640px;
+  color: rgba(248, 250, 252, 0.8);
+  line-height: 1.65;
+}
+
+.hero-pills {
+  display: flex;
+  flex-wrap: wrap;
+  gap: 10px;
+  margin-top: 18px;
+}
+
+.hero-pill {
+  display: inline-flex;
+  align-items: center;
+  padding: 8px 12px;
+  border-radius: 999px;
+  font-size: 12px;
+  font-weight: 700;
+  color: #e2e8f0;
+  background: rgba(15, 23, 42, 0.26);
+}
+
+.hero-actions {
+  display: flex;
+  flex-direction: column;
+  align-items: flex-end;
+  justify-content: space-between;
+  gap: 16px;
+}
+
+.hero-note {
+  display: grid;
+  gap: 4px;
+  min-width: 120px;
+  padding: 14px 16px;
+  border-radius: 16px;
+  text-align: right;
+  background: rgba(15, 23, 42, 0.26);
+}
+
+.hero-note span {
+  font-size: 12px;
+  color: rgba(248, 250, 252, 0.72);
+}
+
+.hero-note strong {
+  font-size: 22px;
+  line-height: 1;
+}
+
+.hero-note small {
+  font-size: 12px;
+  color: rgba(248, 250, 252, 0.72);
+}
+
+.metric-grid,
+.control-grid,
+.platform-grid,
+.guide-grid,
+.pipeline-strip {
+  display: grid;
+  gap: 16px;
+}
+
+.metric-grid {
+  grid-template-columns: repeat(4, minmax(0, 1fr));
+}
+
+.control-grid {
+  grid-template-columns: repeat(2, minmax(0, 1fr));
+}
+
+.platform-grid {
+  grid-template-columns: repeat(3, minmax(0, 1fr));
+}
+
+.pipeline-strip {
+  grid-template-columns: repeat(4, minmax(0, 1fr));
+}
+
+.metric-card,
+.control-card,
+.platform-card,
+.queue-card,
+.guide-card {
+  border-radius: 22px;
+  overflow: hidden;
+  box-shadow: 0 18px 40px rgba(15, 23, 42, 0.06);
+}
+
+.metric-card {
+  color: #0f172a;
+}
+
+.metric-card :deep(.n-card__content),
+.control-card :deep(.n-card__content),
+.platform-card :deep(.n-card__content),
+.queue-card :deep(.n-card__content),
+.guide-card :deep(.n-card__content) {
+  display: grid;
+  gap: 12px;
+}
+
+.metric-card--pending {
+  background: linear-gradient(160deg, #fff7ed, #ffedd5);
+}
+
+.metric-card--done {
+  background: linear-gradient(160deg, #ecfdf5, #d1fae5);
+}
+
+.metric-card--failed {
+  background: linear-gradient(160deg, #fef2f2, #fee2e2);
+}
+
+.metric-card--rate {
+  background: linear-gradient(160deg, #eff6ff, #dbeafe);
+}
+
+.metric-label {
+  font-size: 13px;
+  font-weight: 700;
+  color: rgba(15, 23, 42, 0.7);
+}
+
+.metric-value {
+  font-size: 36px;
+  line-height: 1;
+  font-weight: 800;
+}
+
+.metric-meta {
+  font-size: 13px;
+  color: rgba(15, 23, 42, 0.62);
+}
+
+.section-title {
+  display: inline-flex;
+  align-items: center;
+  gap: 10px;
+  font-size: 16px;
+  font-weight: 700;
+}
+
+.control-body {
+  display: flex;
+  flex-wrap: wrap;
+  gap: 12px;
+  align-items: center;
+}
+
+.control-body--wide {
+  align-items: stretch;
+}
+
+.control-field {
+  width: 160px;
+}
+
+.control-field--grow {
+  flex: 1 1 240px;
+  min-width: 220px;
+}
+
+.platform-card {
+  background: radial-gradient(circle at top right, rgba(59, 130, 246, 0.1), transparent 28%),
+    linear-gradient(180deg, #ffffff, #f8fafc);
+}
+
+.platform-header,
+.platform-footer,
+.queue-toolbar {
+  display: flex;
+  justify-content: space-between;
+  gap: 16px;
+  align-items: center;
+}
+
+.platform-title {
+  display: inline-flex;
+  align-items: center;
+  gap: 8px;
+  font-size: 18px;
+  font-weight: 700;
+}
+
+.platform-subtitle,
+.platform-rate,
+.queue-summary span,
+.guide-item p {
+  color: #64748b;
+}
+
+.platform-stats {
+  display: grid;
+  grid-template-columns: repeat(4, minmax(0, 1fr));
+  gap: 10px;
+}
+
+.platform-stat {
+  padding: 12px 14px;
+  border-radius: 16px;
+  background: #f8fafc;
+}
+
+.platform-stat span {
+  display: block;
+  font-size: 12px;
+  color: #64748b;
+}
+
+.platform-stat strong {
+  display: block;
+  margin-top: 6px;
+  font-size: 24px;
+  line-height: 1;
+}
+
+.platform-progress {
+  margin-top: -2px;
+}
+
+.platform-job-strip {
+  display: grid;
+  gap: 4px;
+  padding: 12px 14px;
+  border-radius: 16px;
+  background: linear-gradient(135deg, #eff6ff, #ecfeff);
+}
+
+.platform-job-strip span {
+  font-size: 12px;
+  color: #64748b;
+}
+
+.platform-job-strip strong {
+  font-size: 24px;
+  line-height: 1;
+}
+
+.platform-job-strip small {
+  color: #475569;
+}
+
+.platform-actions,
+.queue-filters {
+  display: flex;
+  gap: 10px;
+  align-items: center;
+}
+
+.queue-card :deep(.n-card-header),
+.guide-card :deep(.n-card-header),
+.control-card :deep(.n-card-header) {
+  padding-bottom: 8px;
+}
+
+.queue-filter {
+  width: 170px;
+}
+
+.queue-summary {
+  display: inline-flex;
+  gap: 10px;
+  align-items: baseline;
+}
+
+.queue-summary strong {
+  font-size: 22px;
+  line-height: 1;
+}
+
+.pipeline-step {
+  padding: 18px;
+  border-radius: 20px;
+  background: linear-gradient(180deg, rgba(255, 255, 255, 0.92), rgba(248, 250, 252, 0.98)),
+    linear-gradient(135deg, #dbeafe, #f0fdf4);
+  box-shadow: 0 14px 30px rgba(15, 23, 42, 0.05);
+}
+
+.pipeline-step span {
+  display: inline-flex;
+  margin-bottom: 10px;
+  font-size: 12px;
+  font-weight: 800;
+  letter-spacing: 0.08em;
+  color: #0f766e;
+}
+
+.pipeline-step strong {
+  display: block;
+  margin-bottom: 8px;
+  font-size: 16px;
+}
+
+.pipeline-step p {
+  margin: 0;
+  line-height: 1.65;
+  color: #64748b;
+}
+
+.guide-grid {
+  grid-template-columns: repeat(3, minmax(0, 1fr));
+}
+
+.guide-item {
+  padding: 16px;
+  border-radius: 18px;
+  background: #f8fafc;
+}
+
+.guide-item strong {
+  display: block;
+  margin-bottom: 6px;
+}
+
+.guide-item p {
+  margin: 0;
+  line-height: 1.6;
+}
+
+@media (max-width: 1200px) {
+  .metric-grid,
+  .platform-grid,
+  .guide-grid,
+  .pipeline-strip {
+    grid-template-columns: repeat(2, minmax(0, 1fr));
+  }
+}
+
+@media (max-width: 900px) {
+  .monitor-hero,
+  .control-grid,
+  .metric-grid,
+  .platform-grid,
+  .guide-grid,
+  .pipeline-strip {
+    grid-template-columns: 1fr;
+  }
+
+  .monitor-hero,
+  .hero-actions,
+  .queue-toolbar {
+    align-items: stretch;
+    text-align: left;
+  }
+
+  .hero-actions {
+    align-items: flex-start;
+  }
+
+  .hero-note {
+    text-align: left;
+  }
+
+  .queue-toolbar {
+    flex-direction: column;
+  }
+
+  .queue-filters {
+    width: 100%;
+    flex-wrap: wrap;
+  }
+
+  .queue-filter,
+  .control-field,
+  .control-field--grow {
+    width: 100%;
+  }
 }
 </style>