chore(sql): 增加 UC 入库编码生产任务一次性回补脚本

与种子 SQL 分开，按空任务入库工单补派五步任务；并在种子/Python 回补说明中交叉引用。

Co-authored-by: Cursor <cursoragent@cursor.com>

backend/app/crud/lab_sample_process.py

@@ -179,6 +179,17 @@ def upsert_supplement(
             del_flag=0,
         )
         db.add(row)
+    # 同步到新模块补充表/生产接收，保证实验室样本处理数据联动
+    from app.services.lab_sample_processing import sync_legacy_supplement_to_processing
+
+    sync_legacy_supplement_to_processing(
+        db,
+        tenant_no=tenant_no,
+        lab_storage_code=code,
+        sample_type_name=type_name,
+        payload=clean_payload,
+        operator_id=user_id,
+    )
     db.commit()
     db.refresh(row)
     return get_supplement(db, tenant_no=tenant_no, lab_storage_code=code) or {}

backend/app/services/uc_msc_builtin_template.py

@@ -0,0 +1,472 @@
+"""确保 UC 入库编码对应的 5 步内置工艺路线 / 任务组合存在。
+
+步骤顺序（业务确认）：
+1. 脐带MSC原代细胞培养
+2. 脐带MSC原代细胞培养半换液
+3. 脐带MSC原代二次贴壁
+4. 脐带MSC原代重铺操作
+5. 干细胞冻存
+
+内容从既有「干细胞培养（内置模版）」按工序代码拷贝，排除传代。
+"""
+
+from __future__ import annotations
+
+from datetime import datetime
+from typing import Any, Dict, List, Optional
+
+from sqlalchemy.orm import Session
+
+from app.models.models import (
+    BizProcessRoute,
+    BizProcessRouteStep,
+    BizProcessRouteStepConsumable,
+    BizProcessRouteStepDataCollection,
+    BizProcessRouteStepOutput,
+    BizProcessRouteStepReagent,
+    BizProductionTaskSet,
+    BizProductionTaskSetItem,
+)
+from app.core.utils import generate_uuid
+from app.utils.lab_storage_code_task_set import (
+    BC_MSC_BUILTIN_SET_NAME,
+    UC_MSC_BUILTIN_SET_NAME,
+)
+
+UC_MSC_ROUTE_CODE = "MSC原代-UC-BUILTIN"
+UC_MSC_ROUTE_NAME = UC_MSC_BUILTIN_SET_NAME
+SOURCE_MSC_ROUTE_CODE = "MSC培养-BUILTIN"
+SOURCE_MSC_ROUTE_NAME = BC_MSC_BUILTIN_SET_NAME
+
+# process_code → 目标 step_order
+UC_MSC_STEP_ORDER: List[str] = [
+    "SOP-SC-003-E01-01",  # 原代细胞培养
+    "SOP-SC-004-E01-01",  # 半换液
+    "SOP-SC-006-E01-01",  # 二次贴壁
+    "SOP-SC-005-E01-01",  # 重铺
+    "SOP-SC-008-E01-01",  # 冻存
+]
+
+
+def _now() -> datetime:
+    return datetime.now()
+
+
+def get_uc_msc_builtin_set(
+    db: Session, *, tenant_no: str
+) -> Optional[BizProductionTaskSet]:
+    return (
+        db.query(BizProductionTaskSet)
+        .filter(
+            BizProductionTaskSet.tenant_no == tenant_no,
+            BizProductionTaskSet.set_name == UC_MSC_BUILTIN_SET_NAME,
+            BizProductionTaskSet.is_builtin == "1",
+            BizProductionTaskSet.del_flag == 0,
+        )
+        .first()
+    )
+
+
+def _find_source_route(db: Session, *, tenant_no: str) -> BizProcessRoute:
+    route = (
+        db.query(BizProcessRoute)
+        .filter(
+            BizProcessRoute.tenant_no == tenant_no,
+            BizProcessRoute.route_code == SOURCE_MSC_ROUTE_CODE,
+            BizProcessRoute.del_flag == 0,
+        )
+        .first()
+    )
+    if route:
+        return route
+    route = (
+        db.query(BizProcessRoute)
+        .filter(
+            BizProcessRoute.tenant_no == tenant_no,
+            BizProcessRoute.route_name == SOURCE_MSC_ROUTE_NAME,
+            BizProcessRoute.is_builtin == "1",
+            BizProcessRoute.del_flag == 0,
+        )
+        .first()
+    )
+    if not route:
+        raise ValueError(
+            f"缺少源工艺路线 {SOURCE_MSC_ROUTE_CODE}/{SOURCE_MSC_ROUTE_NAME}，无法创建 UC 模版"
+        )
+    return route
+
+
+def _clone_step_children(
+    db: Session,
+    *,
+    src_step_id: str,
+    dst_step_id: str,
+    tenant_no: str,
+    user_id: Optional[str],
+    create_dept_id: str,
+    now: datetime,
+) -> None:
+    reagent_rows = (
+        db.query(BizProcessRouteStepReagent)
+        .filter(
+            BizProcessRouteStepReagent.step_id == src_step_id,
+            BizProcessRouteStepReagent.tenant_no == tenant_no,
+            BizProcessRouteStepReagent.del_flag == 0,
+        )
+        .all()
+    )
+    for r in reagent_rows:
+        db.add(
+            BizProcessRouteStepReagent(
+                id=generate_uuid(),
+                step_id=dst_step_id,
+                reagent_code=r.reagent_code,
+                reagent_name=r.reagent_name,
+                spec=r.spec,
+                standard_usage=r.standard_usage,
+                unit=r.unit,
+                is_key_material=r.is_key_material,
+                tenant_no=tenant_no,
+                order_num=r.order_num,
+                remark=r.remark,
+                create_by=user_id,
+                create_dept_id=create_dept_id or "",
+                create_time=now,
+                update_by=user_id,
+                update_time=now,
+                del_flag=0,
+            )
+        )
+
+    consumable_rows = (
+        db.query(BizProcessRouteStepConsumable)
+        .filter(
+            BizProcessRouteStepConsumable.step_id == src_step_id,
+            BizProcessRouteStepConsumable.tenant_no == tenant_no,
+            BizProcessRouteStepConsumable.del_flag == 0,
+        )
+        .all()
+    )
+    for c in consumable_rows:
+        db.add(
+            BizProcessRouteStepConsumable(
+                id=generate_uuid(),
+                step_id=dst_step_id,
+                consumable_code=c.consumable_code,
+                consumable_name=c.consumable_name,
+                spec_model=c.spec_model,
+                standard_usage=c.standard_usage,
+                unit=c.unit,
+                is_required=c.is_required,
+                remark=c.remark,
+                tenant_no=tenant_no,
+                order_num=c.order_num,
+                create_by=user_id,
+                create_dept_id=create_dept_id or "",
+                create_time=now,
+                update_by=user_id,
+                update_time=now,
+                del_flag=0,
+            )
+        )
+
+    output_rows = (
+        db.query(BizProcessRouteStepOutput)
+        .filter(
+            BizProcessRouteStepOutput.step_id == src_step_id,
+            BizProcessRouteStepOutput.tenant_no == tenant_no,
+            BizProcessRouteStepOutput.del_flag == 0,
+        )
+        .all()
+    )
+    for o in output_rows:
+        db.add(
+            BizProcessRouteStepOutput(
+                id=generate_uuid(),
+                step_id=dst_step_id,
+                output_type_id=o.output_type_id,
+                output_name=o.output_name,
+                output_barcode=o.output_barcode,
+                tenant_no=tenant_no,
+                order_num=o.order_num,
+                remark=o.remark,
+                create_by=user_id,
+                create_dept_id=create_dept_id or "",
+                create_time=now,
+                update_by=user_id,
+                update_time=now,
+                del_flag=0,
+            )
+        )
+
+    dc_rows = (
+        db.query(BizProcessRouteStepDataCollection)
+        .filter(
+            BizProcessRouteStepDataCollection.step_id == src_step_id,
+            BizProcessRouteStepDataCollection.tenant_no == tenant_no,
+            BizProcessRouteStepDataCollection.del_flag == 0,
+        )
+        .all()
+    )
+    for d in dc_rows:
+        db.add(
+            BizProcessRouteStepDataCollection(
+                id=generate_uuid(),
+                step_id=dst_step_id,
+                collection_name=d.collection_name,
+                unit=d.unit,
+                tenant_no=tenant_no,
+                order_num=d.order_num,
+                remark=d.remark,
+                create_by=user_id,
+                create_dept_id=create_dept_id or "",
+                create_time=now,
+                update_by=user_id,
+                update_time=now,
+                del_flag=0,
+            )
+        )
+
+
+def _source_steps_by_code(
+    db: Session, *, route_id: str, tenant_no: str
+) -> Dict[str, BizProcessRouteStep]:
+    rows = (
+        db.query(BizProcessRouteStep)
+        .filter(
+            BizProcessRouteStep.route_id == route_id,
+            BizProcessRouteStep.tenant_no == tenant_no,
+            BizProcessRouteStep.del_flag == 0,
+        )
+        .all()
+    )
+    out: Dict[str, BizProcessRouteStep] = {}
+    for row in rows:
+        code = (row.process_code or "").strip()
+        if code and code not in out:
+            out[code] = row
+    return out
+
+
+def ensure_uc_msc_builtin_template(
+    db: Session,
+    *,
+    tenant_no: str,
+    user_id: Optional[str] = None,
+    create_dept_id: str = "",
+) -> Dict[str, Any]:
+    """幂等创建 UC 5 步内置路线与任务组合；已存在则直接返回。"""
+    existing = get_uc_msc_builtin_set(db, tenant_no=tenant_no)
+    if existing and (existing.status or "1") == "1":
+        item = (
+            db.query(BizProductionTaskSetItem)
+            .filter(
+                BizProductionTaskSetItem.set_id == existing.id,
+                BizProductionTaskSetItem.tenant_no == tenant_no,
+                BizProductionTaskSetItem.del_flag == 0,
+            )
+            .order_by(
+                BizProductionTaskSetItem.order_num.asc(),
+                BizProductionTaskSetItem.create_time.asc(),
+            )
+            .first()
+        )
+        if item and item.route_id:
+            route = (
+                db.query(BizProcessRoute)
+                .filter(
+                    BizProcessRoute.id == item.route_id,
+                    BizProcessRoute.tenant_no == tenant_no,
+                    BizProcessRoute.del_flag == 0,
+                )
+                .first()
+            )
+            step_count = (
+                db.query(BizProcessRouteStep.id)
+                .filter(
+                    BizProcessRouteStep.route_id == item.route_id,
+                    BizProcessRouteStep.tenant_no == tenant_no,
+                    BizProcessRouteStep.del_flag == 0,
+                )
+                .count()
+            )
+            if route and step_count >= len(UC_MSC_STEP_ORDER):
+                return {
+                    "created": False,
+                    "setId": existing.id,
+                    "setName": existing.set_name,
+                    "routeId": route.id,
+                    "routeCode": route.route_code,
+                    "stepCount": step_count,
+                }
+
+    source = _find_source_route(db, tenant_no=tenant_no)
+    by_code = _source_steps_by_code(db, route_id=source.id, tenant_no=tenant_no)
+    missing = [c for c in UC_MSC_STEP_ORDER if c not in by_code]
+    if missing:
+        raise ValueError(
+            "源工艺路线缺少工序，无法创建 UC 模版：" + "、".join(missing)
+        )
+
+    now = _now()
+    route = (
+        db.query(BizProcessRoute)
+        .filter(
+            BizProcessRoute.tenant_no == tenant_no,
+            BizProcessRoute.route_code == UC_MSC_ROUTE_CODE,
+            BizProcessRoute.del_flag == 0,
+        )
+        .first()
+    )
+    if not route:
+        route = BizProcessRoute(
+            id=generate_uuid(),
+            route_code=UC_MSC_ROUTE_CODE,
+            route_name=UC_MSC_ROUTE_NAME,
+            product_type_id=source.product_type_id,
+            version=source.version,
+            is_current="0",
+            equipment_ids=source.equipment_ids,
+            equipment_name=source.equipment_name,
+            tenant_no=tenant_no,
+            order_num=0,
+            remark="内置模版：UC 入库编码自动派发（5 步，不含传代）",
+            is_builtin="1",
+            create_by=user_id,
+            create_dept_id=create_dept_id or "",
+            create_time=now,
+            update_by=user_id,
+            update_time=now,
+            del_flag=0,
+        )
+        db.add(route)
+        db.flush()
+    else:
+        route.route_name = UC_MSC_ROUTE_NAME
+        route.is_builtin = "1"
+        route.update_by = user_id
+        route.update_time = now
+        db.add(route)
+
+    # 重建步骤（幂等：软删旧步骤后按目标顺序插入）
+    old_steps = (
+        db.query(BizProcessRouteStep)
+        .filter(
+            BizProcessRouteStep.route_id == route.id,
+            BizProcessRouteStep.tenant_no == tenant_no,
+            BizProcessRouteStep.del_flag == 0,
+        )
+        .all()
+    )
+    for s in old_steps:
+        s.del_flag = 1
+        s.update_by = user_id
+        s.update_time = now
+        db.add(s)
+    db.flush()
+
+    for order, code in enumerate(UC_MSC_STEP_ORDER, start=1):
+        src = by_code[code]
+        new_step = BizProcessRouteStep(
+            id=generate_uuid(),
+            route_id=route.id,
+            process_id=src.process_id,
+            step_order=order,
+            process_code=src.process_code,
+            category_id=src.category_id,
+            process_name=src.process_name,
+            description=src.description,
+            equipment_ids=src.equipment_ids,
+            equipment_name=src.equipment_name,
+            estimated_duration=src.estimated_duration,
+            sop_ids=src.sop_ids,
+            sop_content=src.sop_content,
+            tenant_no=tenant_no,
+            order_num=order,
+            remark=src.remark,
+            create_by=user_id,
+            create_dept_id=create_dept_id or "",
+            create_time=now,
+            update_by=user_id,
+            update_time=now,
+            del_flag=0,
+        )
+        db.add(new_step)
+        db.flush()
+        _clone_step_children(
+            db,
+            src_step_id=src.id,
+            dst_step_id=new_step.id,
+            tenant_no=tenant_no,
+            user_id=user_id,
+            create_dept_id=create_dept_id or "",
+            now=now,
+        )
+
+    header = existing or BizProductionTaskSet(
+        id=generate_uuid(),
+        set_name=UC_MSC_BUILTIN_SET_NAME,
+        status="1",
+        tenant_no=tenant_no,
+        order_num=0,
+        remark="内置模版：UC 入库编码自动派发",
+        is_builtin="1",
+        create_by=user_id,
+        create_dept_id=create_dept_id or "",
+        create_time=now,
+        update_by=user_id,
+        update_time=now,
+        del_flag=0,
+    )
+    if existing:
+        header.status = "1"
+        header.is_builtin = "1"
+        header.update_by = user_id
+        header.update_time = now
+    db.add(header)
+    db.flush()
+
+    items = (
+        db.query(BizProductionTaskSetItem)
+        .filter(
+            BizProductionTaskSetItem.set_id == header.id,
+            BizProductionTaskSetItem.tenant_no == tenant_no,
+            BizProductionTaskSetItem.del_flag == 0,
+        )
+        .all()
+    )
+    for it in items:
+        it.del_flag = 1
+        it.update_by = user_id
+        it.update_time = now
+        db.add(it)
+    db.flush()
+
+    item = BizProductionTaskSetItem(
+        id=generate_uuid(),
+        set_id=header.id,
+        task_name="{lab_storage_code}样本处理",
+        route_id=route.id,
+        route_name=route.route_name,
+        description=UC_MSC_BUILTIN_SET_NAME,
+        remark=None,
+        tenant_no=tenant_no,
+        order_num=1,
+        create_by=user_id,
+        create_dept_id=create_dept_id or "",
+        create_time=now,
+        update_by=user_id,
+        update_time=now,
+        del_flag=0,
+    )
+    db.add(item)
+    db.flush()
+
+    return {
+        "created": True,
+        "setId": header.id,
+        "setName": header.set_name,
+        "routeId": route.id,
+        "routeCode": route.route_code,
+        "stepCount": len(UC_MSC_STEP_ORDER),
+    }

backend/app/utils/lab_storage_code_task_set.py

@@ -2,12 +2,20 @@
 
 from typing import List, Optional, Tuple
 
+# 科研捐赠脐带间充质：UC… → 5 步原代培养模版（与细胞存储 BC 的 6 步模版分离）
+UC_MSC_BUILTIN_SET_NAME = "脐带MSC原代培养（内置模版）"
+BC_MSC_BUILTIN_SET_NAME = "干细胞培养（内置模版）"
+HSC_BUILTIN_SET_NAME = "造血干样本处理（内置模版）"
+UBMC_BUILTIN_SET_NAME = "UBMC冻存（内置模版）"
+PBMC_BUILTIN_SET_NAME = "PBMC冻存（内置模版）"
+
 # 最长前缀优先：BC 必须在 B 之前，避免 BC… 误匹配造血干
 _LAB_CODE_BUILTIN_SET_RULES: List[Tuple[str, str]] = [
-    ("UBMC", "UBMC冻存（内置模版）"),
+    ("UBMC", UBMC_BUILTIN_SET_NAME),
-    ("PBMC", "PBMC冻存（内置模版）"),
+    ("PBMC", PBMC_BUILTIN_SET_NAME),
-    ("BC", "干细胞培养（内置模版）"),
+    ("UC", UC_MSC_BUILTIN_SET_NAME),
-    ("B", "造血干样本处理（内置模版）"),
+    ("BC", BC_MSC_BUILTIN_SET_NAME),
+    ("B", HSC_BUILTIN_SET_NAME),
 ]
 
 

backend/scripts/backfill_uc_msc_production_tasks.py

@@ -0,0 +1,252 @@
+#!/usr/bin/env python3
+"""为 UC 开头实验室入库编码的入库生产工单补派 5 步脐带MSC原代任务。
+
+默认 dry-run；加 --apply 才写库。会先幂等确保内置模版存在。
+
+用法（在 backend 目录、已配置可连目标库的 .env）:
+  python -m scripts.backfill_uc_msc_production_tasks
+  python -m scripts.backfill_uc_msc_production_tasks --apply
+  python -m scripts.backfill_uc_msc_production_tasks --tenant zkxw --apply
+
+等价一次性 SQL（与种子脚本分开）:
+  docs/sql/migrations/2026-11-13-uc-msc-production-task-backfill.sql
+"""
+from __future__ import annotations
+
+import argparse
+import os
+import sys
+from typing import Any, Dict, List, Optional, Tuple
+
+sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
+
+from sqlalchemy import or_
+from sqlalchemy.orm import Session
+
+from app.core.database import SessionLocal
+from app.crud import production_task_set as production_task_set_svc
+from app.models.models import (
+    BizProductionTask,
+    BizProductionTaskSet,
+    BizProductionWorkOrder,
+    BizSampleReception,
+)
+from app.services.uc_msc_builtin_template import ensure_uc_msc_builtin_template
+from app.utils.lab_storage_code_task_set import UC_MSC_BUILTIN_SET_NAME
+
+
+def _list_candidate_work_orders(
+    db: Session, *, tenant_no: str
+) -> List[Tuple[BizProductionWorkOrder, BizSampleReception]]:
+    """UC 接收记录关联的入库工单，且当前无有效生产任务。"""
+    q = (
+        db.query(BizProductionWorkOrder, BizSampleReception)
+        .join(
+            BizSampleReception,
+            BizSampleReception.id == BizProductionWorkOrder.reception_id,
+        )
+        .filter(
+            BizProductionWorkOrder.tenant_no == tenant_no,
+            BizProductionWorkOrder.del_flag == 0,
+            BizProductionWorkOrder.work_order_type == "inbound",
+            BizProductionWorkOrder.work_order_status.in_(("dpz", "jxz")),
+            BizSampleReception.tenant_no == tenant_no,
+            BizSampleReception.del_flag == 0,
+            BizSampleReception.accept_conclusion == "js",
+            BizSampleReception.lab_storage_code.isnot(None),
+            BizSampleReception.lab_storage_code != "",
+            or_(
+                BizSampleReception.lab_storage_code.like("UC%"),
+                BizSampleReception.lab_storage_code.like("uc%"),
+            ),
+        )
+        .order_by(BizSampleReception.reception_time.asc())
+    )
+    rows = q.all()
+    out: List[Tuple[BizProductionWorkOrder, BizSampleReception]] = []
+    for wo, rec in rows:
+        has_task = (
+            db.query(BizProductionTask.id)
+            .filter(
+                BizProductionTask.work_order_id == wo.id,
+                BizProductionTask.tenant_no == tenant_no,
+                BizProductionTask.del_flag == 0,
+            )
+            .first()
+        )
+        if has_task:
+            continue
+        code = (rec.lab_storage_code or "").strip().upper()
+        if not code.startswith("UC"):
+            continue
+        out.append((wo, rec))
+    return out
+
+
+def _dispatch_one(
+    db: Session,
+    *,
+    tenant_no: str,
+    user_id: Optional[str],
+    create_dept_id: str,
+    wo: BizProductionWorkOrder,
+    rec: BizSampleReception,
+    set_id: str,
+) -> Dict[str, Any]:
+    result = production_task_set_svc.create_tasks_from_set(
+        db,
+        tenant_no=tenant_no,
+        user_id=user_id,
+        create_dept_id=create_dept_id or "",
+        work_order_id=wo.id,
+        set_id=set_id,
+    )
+    return {
+        "workOrderId": wo.id,
+        "workOrderNo": wo.work_order_no,
+        "sampleCode": wo.sample_code or rec.sample_code,
+        "labStorageCode": rec.lab_storage_code,
+        "createdCount": result.get("createdCount"),
+        "tasks": [
+            {"id": t.get("id"), "taskName": t.get("taskName"), "routeId": t.get("routeId")}
+            for t in (result.get("list") or [])
+        ],
+    }
+
+
+def run(
+    *,
+    tenant_no: str,
+    apply: bool,
+    user_id: Optional[str],
+    create_dept_id: str,
+) -> Dict[str, Any]:
+    db = SessionLocal()
+    try:
+        ensure_info = ensure_uc_msc_builtin_template(
+            db,
+            tenant_no=tenant_no,
+            user_id=user_id,
+            create_dept_id=create_dept_id,
+        )
+        set_row = (
+            db.query(BizProductionTaskSet)
+            .filter(
+                BizProductionTaskSet.tenant_no == tenant_no,
+                BizProductionTaskSet.set_name == UC_MSC_BUILTIN_SET_NAME,
+                BizProductionTaskSet.is_builtin == "1",
+                BizProductionTaskSet.status == "1",
+                BizProductionTaskSet.del_flag == 0,
+            )
+            .first()
+        )
+        if not set_row:
+            raise RuntimeError("UC 内置任务组合创建失败")
+
+        candidates = _list_candidate_work_orders(db, tenant_no=tenant_no)
+        preview = [
+            {
+                "workOrderId": wo.id,
+                "workOrderNo": wo.work_order_no,
+                "workOrderStatus": wo.work_order_status,
+                "sampleCode": wo.sample_code or rec.sample_code,
+                "labStorageCode": rec.lab_storage_code,
+                "receptionId": rec.id,
+                "receptionTime": str(rec.reception_time) if rec.reception_time else None,
+            }
+            for wo, rec in candidates
+        ]
+
+        if not apply:
+            db.rollback()
+            return {
+                "dryRun": True,
+                "template": ensure_info,
+                "candidateCount": len(preview),
+                "candidates": preview,
+                "message": "dry-run：未写库。确认后加 --apply 执行补派。",
+            }
+
+        dispatched: List[Dict[str, Any]] = []
+        errors: List[Dict[str, Any]] = []
+        for wo, rec in candidates:
+            try:
+                dispatched.append(
+                    _dispatch_one(
+                        db,
+                        tenant_no=tenant_no,
+                        user_id=user_id,
+                        create_dept_id=create_dept_id,
+                        wo=wo,
+                        rec=rec,
+                        set_id=set_row.id,
+                    )
+                )
+            except Exception as exc:  # noqa: BLE001 - 汇总后继续
+                errors.append(
+                    {
+                        "workOrderId": wo.id,
+                        "workOrderNo": wo.work_order_no,
+                        "labStorageCode": rec.lab_storage_code,
+                        "error": str(exc),
+                    }
+                )
+        db.commit()
+        return {
+            "dryRun": False,
+            "template": ensure_info,
+            "candidateCount": len(preview),
+            "dispatchedCount": len(dispatched),
+            "dispatched": dispatched,
+            "errorCount": len(errors),
+            "errors": errors,
+        }
+    except Exception:
+        db.rollback()
+        raise
+    finally:
+        db.close()
+
+
+def main(argv: Optional[List[str]] = None) -> int:
+    parser = argparse.ArgumentParser(
+        description="回补 UC 入库编码生产工单的 5 步脐带MSC原代任务"
+    )
+    parser.add_argument(
+        "--tenant",
+        default="zkxw",
+        help="租户编号，默认 zkxw",
+    )
+    parser.add_argument(
+        "--apply",
+        action="store_true",
+        help="实际写库；默认仅 dry-run",
+    )
+    parser.add_argument(
+        "--user-id",
+        default=None,
+        help="写库 create_by/update_by，可选",
+    )
+    parser.add_argument(
+        "--create-dept-id",
+        default="",
+        help="写库 create_dept_id，可选",
+    )
+    args = parser.parse_args(argv)
+
+    result = run(
+        tenant_no=(args.tenant or "zkxw").strip() or "zkxw",
+        apply=bool(args.apply),
+        user_id=(args.user_id or None),
+        create_dept_id=(args.create_dept_id or ""),
+    )
+    import json
+
+    print(json.dumps(result, ensure_ascii=False, indent=2, default=str))
+    if result.get("errorCount"):
+        return 2
+    return 0
+
+
+if __name__ == "__main__":
+    raise SystemExit(main())

backend/scripts/restore_lab_sample_processing_excel_extras.py

@@ -0,0 +1,30 @@
+"""恢复被误软删的 Excel 补充字段（真菌/内毒素/CD34 等）并同步旧台账。
+
+用法:
+  ENV_FILE=.../backend/.env python backend/scripts/restore_lab_sample_processing_excel_extras.py
+"""
+from __future__ import annotations
+
+import sys
+from pathlib import Path
+
+ROOT = Path(__file__).resolve().parents[2]
+BACKEND = ROOT / "backend"
+if str(BACKEND) not in sys.path:
+    sys.path.insert(0, str(BACKEND))
+
+from app.core.database import SessionLocal  # noqa: E402
+from app.services.lab_sample_processing import restore_retired_excel_extras  # noqa: E402
+
+
+def main() -> None:
+    db = SessionLocal()
+    try:
+        result = restore_retired_excel_extras(db, tenant_no="zkxw")
+        print(result)
+    finally:
+        db.close()
+
+
+if __name__ == "__main__":
+    main()

backend/tests/test_lab_sample_processing.py

@@ -48,6 +48,183 @@ class LabSampleProcessingFieldsTest(unittest.TestCase):
         self.assertEqual(fmap["cd34Count"].dept, DEPT_QC)
         self.assertEqual(fmap["originalBloodWeightG"].dept, DEPT_PRODUCTION)
 
+    def test_source_fields_not_overridden_by_extra(self):
+        from datetime import datetime
+        from app.services.lab_sample_processing import _build_row
+        from types import SimpleNamespace
+
+        sample = SimpleNamespace(id="S1", sample_code="ZKZX34000865", collection_protocol_id="P1")
+        party = SimpleNamespace(mother_name="真实妈妈")
+        coll = SimpleNamespace(
+            sample_collect_time=None,
+            maternal_blood_collect_time=datetime(2026, 11, 4, 5, 20),
+        )
+        hospital = SimpleNamespace(hospital_name="真实医院")
+        protocol = SimpleNamespace(
+            consent_form_urls="protocol-consent/a",
+            health_survey_form_urls="",
+        )
+        reception = SimpleNamespace(
+            id="R1",
+            reception_time=None,
+            receive_temperature=None,
+            handler_name="接收人",
+            remark=None,
+            lab_storage_code="B0000103",
+        )
+        production = SimpleNamespace(
+            id="PR1",
+            original_blood_weight_g=72.08,
+            hes_volume_ml=None,
+            blood_type="B",
+            infectious_four_test_result="zc",
+            enriched_blood_weight_g=None,
+            cryopreservation_volume_ml=None,
+            handler_name="操作人",
+            remark=None,
+            original_blood_volume_ml=None,
+            nucleated_cell_count_1e8=None,
+            inoculation_amount=None,
+            cryopreservation_time=None,
+            storage_total_tubes=None,
+            available_cell_count_1e7=None,
+        )
+        row = _build_row(
+            dataset=DATASET_HSC,
+            sample=sample,
+            type_name="围产期造血干细胞",
+            party=party,
+            coll=coll,
+            hospital=hospital,
+            reception=reception,
+            production=production,
+            extra={
+                "motherName": "Excel妈妈",
+                "originalBloodWeightG": 1,
+                "cd34Count": "11.4",
+            },
+            protocol=protocol,
+            check_flags={
+                "健康调查表": True,
+                "样本信息正确，标识清晰": True,
+                "针路密闭": True,
+                "容器无破损": True,
+            },
+        )
+        self.assertEqual(row["sampleCode"], "B0000103")
+        self.assertEqual(row["protocolSampleCode"], "ZKZX34000865")
+        self.assertEqual(row["motherName"], "真实妈妈")
+        self.assertEqual(row["originalBloodWeightG"], 72.08)
+        self.assertEqual(row["bloodType"], "B")
+        self.assertEqual(row["cd34Count"], "11.4")
+        self.assertEqual(row["hasMaternalBlood"], "是")
+        self.assertEqual(row["hasConsent"], "是")
+        self.assertEqual(row["hasHealthSurvey"], "是")
+        self.assertEqual(row["labelClear"], "是")
+        self.assertEqual(row["infectiousFourCard"], "正常")
+        self.assertIn("针路密闭", row["receiveCheck"] or "")
+        self.assertFalse(row["fromExtraOnly"])
+
+    def test_infectious_code_roundtrip(self):
+        from app.services.lab_sample_processing import _infectious_code, _infectious_label
+
+        self.assertEqual(_infectious_label("zc"), "正常")
+        self.assertEqual(_infectious_label("bzc"), "不正常")
+        self.assertEqual(_infectious_code("正常"), "zc")
+        self.assertEqual(_infectious_code("不正常"), "bzc")
+
+    def test_extra_field_keys_include_fungus(self):
+        from app.services.lab_sample_processing import _extra_field_keys
+
+        keys = _extra_field_keys(DATASET_MSC)
+        self.assertIn("fungusTest", keys)
+        self.assertIn("endotoxinTest", keys)
+        self.assertIn("bacteriaTest", keys)
+        self.assertIn("mycoplasmaTest", keys)
+
+    def test_msc_donation_collect_and_transport_fallback(self):
+        from datetime import datetime
+        from app.services.lab_sample_processing import _build_row
+        from types import SimpleNamespace
+
+        sample = SimpleNamespace(id="D1", sample_code="KYJZ1", collection_protocol_id=None)
+        party = SimpleNamespace(mother_name="孙玲")
+        coll = SimpleNamespace(
+            sample_collect_time=datetime(2026, 10, 10, 10, 5),
+            maternal_blood_collect_time=None,
+        )
+        reception = SimpleNamespace(
+            id="R1",
+            reception_time=datetime(2026, 10, 10, 15, 40, 57),
+            receive_temperature="23.1",
+            handler_name="侯以婷",
+            remark=None,
+            lab_storage_code="UC2026006",
+        )
+        row = _build_row(
+            dataset=DATASET_MSC,
+            sample=sample,
+            type_name="脐带间充质干细胞",
+            party=party,
+            coll=coll,
+            hospital=None,
+            reception=reception,
+            production=None,
+            extra={},
+        )
+        self.assertEqual(row["sampleCode"], "UC2026006")
+        self.assertEqual(row["collectTime"], "2026-10-10 10:05:00")
+        self.assertEqual(row["transportTempC"], "23.1")
+        self.assertNotIn("导出自存", row["motherName"] or "")
+
+    def test_legacy_supplement_fills_empty_source_fields(self):
+        from app.services.lab_sample_processing import _build_row, _merge_extra_with_legacy
+        from types import SimpleNamespace
+
+        extra = _merge_extra_with_legacy(
+            {},
+            {"infectiousFourTestLabel": "正常", "labMaterialCode": "202611006"},
+        )
+        sample = SimpleNamespace(id="S1", sample_code="UBMC202611006", collection_protocol_id=None)
+        reception = SimpleNamespace(
+            id="R1",
+            reception_time=None,
+            receive_temperature=None,
+            handler_name=None,
+            remark=None,
+            lab_storage_code="UBMC202611006",
+        )
+        production = SimpleNamespace(
+            id="PR1",
+            original_blood_weight_g=None,
+            hes_volume_ml=None,
+            blood_type=None,
+            infectious_four_test_result=None,
+            enriched_blood_weight_g=None,
+            cryopreservation_volume_ml=None,
+            handler_name=None,
+            remark=None,
+            original_blood_volume_ml=None,
+            nucleated_cell_count_1e8=None,
+            inoculation_amount=None,
+            cryopreservation_time=None,
+            storage_total_tubes=None,
+            available_cell_count_1e7=None,
+        )
+        row = _build_row(
+            dataset=DATASET_UBMC,
+            sample=sample,
+            type_name="脐血单个核细胞",
+            party=None,
+            coll=None,
+            hospital=None,
+            reception=reception,
+            production=production,
+            extra=extra,
+        )
+        self.assertEqual(row["infectiousFourCard"], "正常")
+        self.assertEqual(row["labMaterialCode"], "202611006")
+
 
 if __name__ == "__main__":
     unittest.main()

backend/tests/test_lab_storage_code_task_set.py

@@ -1,19 +1,36 @@
 import unittest
 
-from app.utils.lab_storage_code_task_set import match_builtin_task_set_name_by_lab_storage_code
+from app.utils.lab_storage_code_task_set import (
+    BC_MSC_BUILTIN_SET_NAME,
+    HSC_BUILTIN_SET_NAME,
+    UC_MSC_BUILTIN_SET_NAME,
+    match_builtin_task_set_name_by_lab_storage_code,
+)
 
 
 class TestMatchBuiltinTaskSetName(unittest.TestCase):
     def test_bc_before_b(self):
         self.assertEqual(
             match_builtin_task_set_name_by_lab_storage_code("BC20260101"),
-            "干细胞培养（内置模版）",
+            BC_MSC_BUILTIN_SET_NAME,
         )
 
     def test_b_only(self):
         self.assertEqual(
             match_builtin_task_set_name_by_lab_storage_code("B20260101"),
-            "造血干样本处理（内置模版）",
+            HSC_BUILTIN_SET_NAME,
+        )
+
+    def test_uc_msc(self):
+        self.assertEqual(
+            match_builtin_task_set_name_by_lab_storage_code("UC2026010"),
+            UC_MSC_BUILTIN_SET_NAME,
+        )
+
+    def test_uc_case_insensitive(self):
+        self.assertEqual(
+            match_builtin_task_set_name_by_lab_storage_code("uc2026016"),
+            UC_MSC_BUILTIN_SET_NAME,
         )
 
     def test_ubmc(self):
@@ -35,7 +52,7 @@ class TestMatchBuiltinTaskSetName(unittest.TestCase):
     def test_bc_case_insensitive(self):
         self.assertEqual(
             match_builtin_task_set_name_by_lab_storage_code("bc99"),
-            "干细胞培养（内置模版）",
+            BC_MSC_BUILTIN_SET_NAME,
         )
 
 

backend/tests/test_uc_msc_builtin_template.py

@@ -0,0 +1,41 @@
+import os
+import unittest
+
+# 避免导入 app.models 时 Settings 因缺 SECRET_KEY 失败
+os.environ.setdefault(
+    "SECRET_KEY", "test-secret-key-for-uc-msc-unit-tests-32c"
+)
+
+
+class TestUcMscBuiltinTemplate(unittest.TestCase):
+    def test_step_order_matches_business_five_nodes(self):
+        from app.services.uc_msc_builtin_template import UC_MSC_STEP_ORDER
+
+        self.assertEqual(
+            UC_MSC_STEP_ORDER,
+            [
+                "SOP-SC-003-E01-01",
+                "SOP-SC-004-E01-01",
+                "SOP-SC-006-E01-01",
+                "SOP-SC-005-E01-01",
+                "SOP-SC-008-E01-01",
+            ],
+        )
+        self.assertNotIn("SOP-SC-007-E01-01", UC_MSC_STEP_ORDER)
+
+    def test_uc_prefix_maps_to_uc_set_name(self):
+        from app.services.uc_msc_builtin_template import UC_MSC_ROUTE_CODE
+        from app.utils.lab_storage_code_task_set import (
+            UC_MSC_BUILTIN_SET_NAME,
+            match_builtin_task_set_name_by_lab_storage_code,
+        )
+
+        self.assertEqual(UC_MSC_ROUTE_CODE, "MSC原代-UC-BUILTIN")
+        self.assertEqual(
+            match_builtin_task_set_name_by_lab_storage_code("UC2026010"),
+            UC_MSC_BUILTIN_SET_NAME,
+        )
+
+
+if __name__ == "__main__":
+    unittest.main()

docs/sql/20261112_lab_sample_processing_normalize_acl.sql

@@ -0,0 +1,21 @@
+-- 实验室样本处理 ACL 归一化（可重复执行）
+-- 1) 撤销所有 lab:sample-processing* / menu:lab-sample-processing 角色菜单
+-- 2) 仅按下列角色重授：
+--    市场编辑：市场专员/临床销售/销售助理/客服/采集专员
+--    生产编辑：生产专员/实验专员/细胞实验员/研发专员
+--    质检编辑：质检专员/质量安全员
+--    主管：生产主管/质量主管/采集主管/采集经理/研发主管/研发总监/总经理/副总经理/董事长/超级管理员
+--    只读：采集接受人
+-- 说明：正式执行请用 Agent 脚本 tmp_normalize_lab_acl.py（含幂等 undelete/insert）。
+-- 本文件作为规则记录；勿在未核对角色名时直接全量套用到其他环境。
+
+UPDATE sys_role_menu rm
+JOIN sys_menu m ON m.id = rm.menu_id
+SET rm.del_flag = 1,
+    rm.update_by = 'normalize-acl',
+    rm.update_time = NOW()
+WHERE rm.del_flag = 0
+  AND (
+    m.perms LIKE 'lab:sample-processing%'
+    OR m.perms = 'menu:lab-sample-processing'
+  );

docs/sql/20261112_lab_sample_processing_restore_excel_extras.md

@@ -0,0 +1,23 @@
+# 恢复 Excel 补充字段（真菌等）
+
+## 原因
+
+`20261112_lab_sample_processing_retire_excel_demo.sql` 按「补充表 sample_code = 协议样本号」软删演示行。
+会议 Excel 实际多用实验室入库编码（`B000*` / `BC*` / `UBMC*`），与协议号不一致，导致真实样本的真菌/内毒素/CD34 等补充字段被误删。
+
+## 处理
+
+运行：
+
+```bash
+ENV_FILE=backend/.env python backend/scripts/restore_lab_sample_processing_excel_extras.py
+```
+
+脚本会：
+
+1. 找出 `update_by=retire-excel-demo` 且 `del_flag=1` 的补充行
+2. 仅恢复仍能关联到当前有效协议/接收编码的行
+3. 只写回 `SOURCE_EXTRA` 字段到有效补充表
+4. 同步旧台账 `biz_lab_sample_process_supplement`
+
+列表侧同时会从质检完成任务填空（内毒素/真菌/支原体/细菌及母血相关）。

docs/sql/20261112_lab_sample_processing_retire_excel_demo.sql

@@ -0,0 +1,14 @@
+-- 软删除实验室样本处理 Excel 演示补充行：
+-- 仅删除在协议样本表中不存在对应 sample_code 的补充记录。
+-- Excel 列结构仍由代码字段目录维护；真实列表只聚合协议/接收/生产源数据。
+
+UPDATE biz_lab_sample_processing_extra e
+LEFT JOIN biz_protocol_sample s
+  ON s.sample_code = e.sample_code
+ AND s.tenant_no = e.tenant_no
+ AND s.del_flag = 0
+SET e.del_flag = 1,
+    e.update_by = 'retire-excel-demo',
+    e.update_time = NOW()
+WHERE e.del_flag = 0
+  AND s.id IS NULL;

docs/sql/migrations/2026-11-13-uc-msc-builtin-task-set.sql

@@ -0,0 +1,265 @@
+-- UC 入库编码自动派发：脐带MSC原代培养（内置模版）5 步
+-- 步骤：原代培养 → 半换液 → 二次贴壁 → 重铺 → 冻存（不含传代）
+-- 内容从既有「干细胞培养（内置模版）」/ MSC培养-BUILTIN 按 process_code 拷贝
+-- 幂等：已存在同名内置集合则跳过主数据创建-- 生产历史空任务工单回补（二选一，勿重复对同一工单各跑一遍）：
+--   SQL：docs/sql/migrations/2026-11-13-uc-msc-production-task-backfill.sql
+--   或 Python：
+--     cd backend && python -m scripts.backfill_uc_msc_production_tasks
+--     cd backend && python -m scripts.backfill_uc_msc_production_tasks --apply
+
+SET NAMES utf8mb4;
+
+-- 1) 工艺路线头
+INSERT INTO biz_process_route (
+  id, route_code, route_name, product_type_id, version, is_current,
+  equipment_ids, equipment_name, tenant_no, order_num, remark, is_builtin,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  'MSC原代-UC-BUILTIN',
+  '脐带MSC原代培养（内置模版）',
+  src.product_type_id,
+  src.version,
+  '0',
+  src.equipment_ids,
+  src.equipment_name,
+  src.tenant_no,
+  0,
+  '内置模版：UC 入库编码自动派发（5 步，不含传代）',
+  '1',
+  src.create_by,
+  IFNULL(src.create_dept_id, ''),
+  NOW(),
+  src.update_by,
+  NOW(),
+  0
+FROM biz_process_route src
+WHERE src.del_flag = 0
+  AND (
+    src.route_code = 'MSC培养-BUILTIN'
+    OR (src.route_name = '干细胞培养（内置模版）' AND src.is_builtin = '1')
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route x
+    WHERE x.id = 'UCMSCROUTEA5CC11F194118AC54085447A' AND x.del_flag = 0
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route x
+    WHERE x.tenant_no = src.tenant_no
+      AND x.route_code = 'MSC原代-UC-BUILTIN'
+      AND x.del_flag = 0
+  )
+ORDER BY CASE WHEN src.route_code = 'MSC培养-BUILTIN' THEN 0 ELSE 1 END
+LIMIT 1;
+
+-- 2) 路线步骤（按目标顺序）
+-- step 1 SOP-SC-003
+INSERT INTO biz_process_route_step (
+  id, route_id, process_id, step_order, process_code, category_id, process_name,
+  description, equipment_ids, equipment_name, estimated_duration, sop_ids, sop_content,
+  tenant_no, order_num, remark, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCSTEP1A5CC11F194118AC54085447A',
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  s.process_id, 1, s.process_code, s.category_id, s.process_name,
+  s.description, s.equipment_ids, s.equipment_name, s.estimated_duration, s.sop_ids, s.sop_content,
+  s.tenant_no, 1, s.remark, s.create_by, IFNULL(s.create_dept_id, ''), NOW(), s.update_by, NOW(), 0
+FROM biz_process_route_step s
+JOIN biz_process_route r ON r.id = s.route_id AND r.del_flag = 0
+WHERE s.del_flag = 0
+  AND s.process_code = 'SOP-SC-003-E01-01'
+  AND (
+    r.route_code = 'MSC培养-BUILTIN'
+    OR (r.route_name = '干细胞培养（内置模版）' AND r.is_builtin = '1')
+  )
+  AND EXISTS (
+    SELECT 1 FROM biz_process_route nr
+    WHERE nr.id = 'UCMSCROUTEA5CC11F194118AC54085447A' AND nr.del_flag = 0
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route_step x
+    WHERE x.id = 'UCMSCSTEP1A5CC11F194118AC54085447A' AND x.del_flag = 0
+  )
+LIMIT 1;
+
+-- step 2 SOP-SC-004
+INSERT INTO biz_process_route_step (
+  id, route_id, process_id, step_order, process_code, category_id, process_name,
+  description, equipment_ids, equipment_name, estimated_duration, sop_ids, sop_content,
+  tenant_no, order_num, remark, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCSTEP2A5CC11F194118AC54085447A',
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  s.process_id, 2, s.process_code, s.category_id, s.process_name,
+  s.description, s.equipment_ids, s.equipment_name, s.estimated_duration, s.sop_ids, s.sop_content,
+  s.tenant_no, 2, s.remark, s.create_by, IFNULL(s.create_dept_id, ''), NOW(), s.update_by, NOW(), 0
+FROM biz_process_route_step s
+JOIN biz_process_route r ON r.id = s.route_id AND r.del_flag = 0
+WHERE s.del_flag = 0
+  AND s.process_code = 'SOP-SC-004-E01-01'
+  AND (
+    r.route_code = 'MSC培养-BUILTIN'
+    OR (r.route_name = '干细胞培养（内置模版）' AND r.is_builtin = '1')
+  )
+  AND EXISTS (
+    SELECT 1 FROM biz_process_route nr
+    WHERE nr.id = 'UCMSCROUTEA5CC11F194118AC54085447A' AND nr.del_flag = 0
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route_step x
+    WHERE x.id = 'UCMSCSTEP2A5CC11F194118AC54085447A' AND x.del_flag = 0
+  )
+LIMIT 1;
+
+-- step 3 SOP-SC-006 二次贴壁
+INSERT INTO biz_process_route_step (
+  id, route_id, process_id, step_order, process_code, category_id, process_name,
+  description, equipment_ids, equipment_name, estimated_duration, sop_ids, sop_content,
+  tenant_no, order_num, remark, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCSTEP3A5CC11F194118AC54085447A',
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  s.process_id, 3, s.process_code, s.category_id, s.process_name,
+  s.description, s.equipment_ids, s.equipment_name, s.estimated_duration, s.sop_ids, s.sop_content,
+  s.tenant_no, 3, s.remark, s.create_by, IFNULL(s.create_dept_id, ''), NOW(), s.update_by, NOW(), 0
+FROM biz_process_route_step s
+JOIN biz_process_route r ON r.id = s.route_id AND r.del_flag = 0
+WHERE s.del_flag = 0
+  AND s.process_code = 'SOP-SC-006-E01-01'
+  AND (
+    r.route_code = 'MSC培养-BUILTIN'
+    OR (r.route_name = '干细胞培养（内置模版）' AND r.is_builtin = '1')
+  )
+  AND EXISTS (
+    SELECT 1 FROM biz_process_route nr
+    WHERE nr.id = 'UCMSCROUTEA5CC11F194118AC54085447A' AND nr.del_flag = 0
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route_step x
+    WHERE x.id = 'UCMSCSTEP3A5CC11F194118AC54085447A' AND x.del_flag = 0
+  )
+LIMIT 1;
+
+-- step 4 SOP-SC-005 重铺
+INSERT INTO biz_process_route_step (
+  id, route_id, process_id, step_order, process_code, category_id, process_name,
+  description, equipment_ids, equipment_name, estimated_duration, sop_ids, sop_content,
+  tenant_no, order_num, remark, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCSTEP4A5CC11F194118AC54085447A',
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  s.process_id, 4, s.process_code, s.category_id, s.process_name,
+  s.description, s.equipment_ids, s.equipment_name, s.estimated_duration, s.sop_ids, s.sop_content,
+  s.tenant_no, 4, s.remark, s.create_by, IFNULL(s.create_dept_id, ''), NOW(), s.update_by, NOW(), 0
+FROM biz_process_route_step s
+JOIN biz_process_route r ON r.id = s.route_id AND r.del_flag = 0
+WHERE s.del_flag = 0
+  AND s.process_code = 'SOP-SC-005-E01-01'
+  AND (
+    r.route_code = 'MSC培养-BUILTIN'
+    OR (r.route_name = '干细胞培养（内置模版）' AND r.is_builtin = '1')
+  )
+  AND EXISTS (
+    SELECT 1 FROM biz_process_route nr
+    WHERE nr.id = 'UCMSCROUTEA5CC11F194118AC54085447A' AND nr.del_flag = 0
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route_step x
+    WHERE x.id = 'UCMSCSTEP4A5CC11F194118AC54085447A' AND x.del_flag = 0
+  )
+LIMIT 1;
+
+-- step 5 SOP-SC-008 冻存
+INSERT INTO biz_process_route_step (
+  id, route_id, process_id, step_order, process_code, category_id, process_name,
+  description, equipment_ids, equipment_name, estimated_duration, sop_ids, sop_content,
+  tenant_no, order_num, remark, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCSTEP5A5CC11F194118AC54085447A',
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  s.process_id, 5, s.process_code, s.category_id, s.process_name,
+  s.description, s.equipment_ids, s.equipment_name, s.estimated_duration, s.sop_ids, s.sop_content,
+  s.tenant_no, 5, s.remark, s.create_by, IFNULL(s.create_dept_id, ''), NOW(), s.update_by, NOW(), 0
+FROM biz_process_route_step s
+JOIN biz_process_route r ON r.id = s.route_id AND r.del_flag = 0
+WHERE s.del_flag = 0
+  AND s.process_code = 'SOP-SC-008-E01-01'
+  AND (
+    r.route_code = 'MSC培养-BUILTIN'
+    OR (r.route_name = '干细胞培养（内置模版）' AND r.is_builtin = '1')
+  )
+  AND EXISTS (
+    SELECT 1 FROM biz_process_route nr
+    WHERE nr.id = 'UCMSCROUTEA5CC11F194118AC54085447A' AND nr.del_flag = 0
+  )
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_process_route_step x
+    WHERE x.id = 'UCMSCSTEP5A5CC11F194118AC54085447A' AND x.del_flag = 0
+  )
+LIMIT 1;
+
+-- 3) 任务组合头
+INSERT INTO biz_production_task_set (
+  id, set_name, status, tenant_no, order_num, remark, is_builtin,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCSET00A5CC11F194118AC54085447A',
+  '脐带MSC原代培养（内置模版）',
+  '1',
+  r.tenant_no,
+  0,
+  '内置模版：UC 入库编码自动派发',
+  '1',
+  r.create_by,
+  IFNULL(r.create_dept_id, ''),
+  NOW(),
+  r.update_by,
+  NOW(),
+  0
+FROM biz_process_route r
+WHERE r.id = 'UCMSCROUTEA5CC11F194118AC54085447A'
+  AND r.del_flag = 0
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_production_task_set x
+    WHERE x.tenant_no = r.tenant_no
+      AND x.set_name = '脐带MSC原代培养（内置模版）'
+      AND x.is_builtin = '1'
+      AND x.del_flag = 0
+  );
+
+-- 4) 任务组合条目
+INSERT INTO biz_production_task_set_item (
+  id, set_id, task_name, route_id, route_name, description, remark,
+  tenant_no, order_num, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  'UCMSCITEM0A5CC11F194118AC54085447A',
+  s.id,
+  '{lab_storage_code}样本处理',
+  'UCMSCROUTEA5CC11F194118AC54085447A',
+  '脐带MSC原代培养（内置模版）',
+  '脐带MSC原代培养（内置模版）',
+  NULL,
+  s.tenant_no,
+  1,
+  s.create_by,
+  IFNULL(s.create_dept_id, ''),
+  NOW(),
+  s.update_by,
+  NOW(),
+  0
+FROM biz_production_task_set s
+WHERE s.set_name = '脐带MSC原代培养（内置模版）'
+  AND s.is_builtin = '1'
+  AND s.del_flag = 0
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_production_task_set_item x
+    WHERE x.set_id = s.id AND x.del_flag = 0
+  );

docs/sql/migrations/2026-11-13-uc-msc-production-task-backfill.sql

@@ -0,0 +1,409 @@
+-- 【一次性回补】UC 开头实验室入库编码 → 补派「脐带MSC原代培养」5 步生产任务
+-- 与种子脚本分开：先执行 2026-11-13-uc-msc-builtin-task-set.sql（或确保模版已存在），再执行本文件。
+-- 等价于 backend/scripts/backfill_uc_msc_production_tasks.py --apply 的候选范围。
+--
+-- 候选条件（须全部满足）：
+--   1) 样本接收 accept_conclusion=js、del_flag=0
+--   2) lab_storage_code 以 UC/uc 开头（非空）
+--   3) 关联入库生产工单 work_order_type=inbound、状态 dpz/jxz、del_flag=0
+--   4) 该工单当前无任何有效生产任务（已有任务如 UC2026010 跳过）
+--
+-- 动作：
+--   - 每工单插入 1 条 biz_production_task（状态 dpz，任务名 {入库编码}样本处理）
+--   - 从 UC 内置路线复制 5 个步骤到 biz_production_task_step（及试剂/耗材/产出/采集子表）
+--   - 工单状态 dpz → jxz（已是 jxz/ywc 的不改 ywc；本脚本候选不含 ywc）
+--
+-- 幂等：已有有效任务的工单不会进入候选；重复执行影响行数应为 0。
+-- 前置：biz_process_route.route_code='MSC原代-UC-BUILTIN'（或固定 id UCMSCROUTE…）及 5 步须已存在。
+-- MySQL 5.7 / utf8mb4。未在生产库执行；执行前请先跑下方「预览」SELECT。
+
+SET NAMES utf8mb4;
+
+-- ---------------------------------------------------------------------------
+-- 0. 解析 UC 内置工艺路线
+-- ---------------------------------------------------------------------------
+SET @uc_route_id := (
+  SELECT r.id
+  FROM biz_process_route r
+  WHERE r.del_flag = 0
+    AND (
+      r.id = 'UCMSCROUTEA5CC11F194118AC54085447A'
+      OR r.route_code = 'MSC原代-UC-BUILTIN'
+      OR (r.route_name = '脐带MSC原代培养（内置模版）' AND r.is_builtin = '1')
+    )
+  ORDER BY
+    CASE
+      WHEN r.id = 'UCMSCROUTEA5CC11F194118AC54085447A' THEN 0
+      WHEN r.route_code = 'MSC原代-UC-BUILTIN' THEN 1
+      ELSE 2
+    END
+  LIMIT 1
+);
+
+SET @uc_step_count := (
+  SELECT COUNT(*)
+  FROM biz_process_route_step s
+  WHERE s.route_id = @uc_route_id
+    AND s.del_flag = 0
+);
+
+-- 预览：模版是否就绪（应 route 非空且 step_count=5）
+SELECT @uc_route_id AS uc_route_id, @uc_step_count AS uc_step_count;
+
+-- 若模版未就绪则主动失败（避免插入无步骤任务）
+SET @uc_ready := IF(@uc_route_id IS NOT NULL AND @uc_step_count = 5, 1, 0);
+-- 下面用 @uc_ready 约束所有写操作；为 0 时 INSERT 选不出行
+
+-- ---------------------------------------------------------------------------
+-- 1. 候选工单临时表
+-- ---------------------------------------------------------------------------
+DROP TEMPORARY TABLE IF EXISTS tmp_uc_wo_backfill;
+CREATE TEMPORARY TABLE tmp_uc_wo_backfill (
+  seq INT NOT NULL AUTO_INCREMENT,
+  work_order_id VARCHAR(64) NOT NULL,
+  reception_id VARCHAR(64) NOT NULL,
+  lab_storage_code VARCHAR(32) NOT NULL,
+  tenant_no VARCHAR(64) NOT NULL,
+  sample_code VARCHAR(32) NULL,
+  task_id VARCHAR(64) NULL,
+  task_no VARCHAR(32) NULL,
+  route_id VARCHAR(64) NULL,
+  PRIMARY KEY (seq),
+  UNIQUE KEY uk_wo (work_order_id)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+INSERT INTO tmp_uc_wo_backfill (
+  work_order_id, reception_id, lab_storage_code, tenant_no, sample_code, route_id
+)
+SELECT
+  wo.id,
+  rec.id,
+  TRIM(rec.lab_storage_code),
+  wo.tenant_no,
+  wo.sample_code,
+  @uc_route_id
+FROM biz_production_work_order wo
+INNER JOIN biz_sample_reception rec
+  ON rec.id = wo.reception_id
+ AND rec.tenant_no = wo.tenant_no
+ AND rec.del_flag = 0
+WHERE @uc_ready = 1
+  AND wo.del_flag = 0
+  AND wo.work_order_type = 'inbound'
+  AND wo.work_order_status IN ('dpz', 'jxz')
+  AND rec.accept_conclusion = 'js'
+  AND rec.lab_storage_code IS NOT NULL
+  AND TRIM(rec.lab_storage_code) <> ''
+  AND (
+    rec.lab_storage_code LIKE 'UC%'
+    OR rec.lab_storage_code LIKE 'uc%'
+  )
+  AND NOT EXISTS (
+    SELECT 1
+    FROM biz_production_task t
+    WHERE t.work_order_id = wo.id
+      AND t.tenant_no = wo.tenant_no
+      AND t.del_flag = 0
+  )
+ORDER BY rec.reception_time ASC, wo.create_time ASC;
+
+-- 预览候选（执行写库前请核对）
+SELECT
+  seq,
+  work_order_id,
+  lab_storage_code,
+  sample_code,
+  tenant_no,
+  reception_id
+FROM tmp_uc_wo_backfill
+ORDER BY seq;
+
+SELECT COUNT(*) AS candidate_count FROM tmp_uc_wo_backfill;
+
+-- 分配 task_id / task_no（RW + yyyymmdd + 4 位序号，接当日已有最大序号）
+SET @task_day := DATE_FORMAT(NOW(), '%Y%m%d');
+SET @task_no_base := (
+  SELECT IFNULL(MAX(CAST(SUBSTRING(t.task_no, 11) AS UNSIGNED)), 0)
+  FROM biz_production_task t
+  WHERE t.task_no LIKE CONCAT('RW', @task_day, '%')
+);
+
+UPDATE tmp_uc_wo_backfill
+SET
+  task_id = UPPER(REPLACE(UUID(), '-', '')),
+  task_no = CONCAT('RW', @task_day, LPAD(@task_no_base + seq, 4, '0'));
+
+-- ---------------------------------------------------------------------------
+-- 2. 插入生产任务
+-- ---------------------------------------------------------------------------
+INSERT INTO biz_production_task (
+  id, task_no, work_order_id, order_source, task_type, task_name, description,
+  route_id, task_status, current_assignee_user_id, started_time, completed_time,
+  conclusion, remark, attachments, equipment_ids, equipment_name,
+  tenant_no, order_num, create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  c.task_id,
+  c.task_no,
+  c.work_order_id,
+  'inbound',
+  'cell_storage',
+  CONCAT(c.lab_storage_code, '样本处理'),
+  '脐带MSC原代培养（内置模版）',
+  c.route_id,
+  'dpz',
+  NULL,
+  NULL,
+  NULL,
+  NULL,
+  '一次性SQL回补：UC入库编码自动派发',
+  NULL,
+  r.equipment_ids,
+  r.equipment_name,
+  c.tenant_no,
+  0,
+  NULL,
+  '',
+  NOW(),
+  NULL,
+  NOW(),
+  0
+FROM tmp_uc_wo_backfill c
+INNER JOIN biz_process_route r
+  ON r.id = c.route_id
+ AND r.del_flag = 0
+WHERE @uc_ready = 1
+  AND c.task_id IS NOT NULL
+  AND NOT EXISTS (
+    SELECT 1 FROM biz_production_task t
+    WHERE t.work_order_id = c.work_order_id
+      AND t.tenant_no = c.tenant_no
+      AND t.del_flag = 0
+  );
+
+-- ---------------------------------------------------------------------------
+-- 3. 步骤映射：路线步骤 → 新任务步骤 ID
+-- ---------------------------------------------------------------------------
+DROP TEMPORARY TABLE IF EXISTS tmp_uc_step_map;
+CREATE TEMPORARY TABLE tmp_uc_step_map (
+  task_id VARCHAR(64) NOT NULL,
+  work_order_id VARCHAR(64) NOT NULL,
+  tenant_no VARCHAR(64) NOT NULL,
+  route_step_id VARCHAR(64) NOT NULL,
+  task_step_id VARCHAR(64) NOT NULL,
+  step_order INT NOT NULL,
+  PRIMARY KEY (task_id, route_step_id),
+  KEY ix_route_step (route_step_id),
+  KEY ix_task_step (task_step_id)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+INSERT INTO tmp_uc_step_map (
+  task_id, work_order_id, tenant_no, route_step_id, task_step_id, step_order
+)
+SELECT
+  c.task_id,
+  c.work_order_id,
+  c.tenant_no,
+  rs.id,
+  UPPER(REPLACE(UUID(), '-', '')),
+  rs.step_order
+FROM tmp_uc_wo_backfill c
+INNER JOIN biz_process_route_step rs
+  ON rs.route_id = c.route_id
+ AND rs.del_flag = 0
+WHERE @uc_ready = 1
+  AND EXISTS (
+    SELECT 1 FROM biz_production_task t
+    WHERE t.id = c.task_id AND t.del_flag = 0
+  );
+
+-- ---------------------------------------------------------------------------
+-- 4. 插入任务步骤
+-- ---------------------------------------------------------------------------
+INSERT INTO biz_production_task_step (
+  id, task_id, step_order, process_code, category_id, process_name, description,
+  equipment_ids, equipment_name, estimated_duration, actual_duration,
+  sop_ids, sop_content, step_status, planned_start_time, started_time,
+  completed_time, completed_by, tenant_no, order_num, remark,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  m.task_step_id,
+  m.task_id,
+  rs.step_order,
+  rs.process_code,
+  rs.category_id,
+  rs.process_name,
+  rs.description,
+  rs.equipment_ids,
+  rs.equipment_name,
+  rs.estimated_duration,
+  NULL,
+  rs.sop_ids,
+  rs.sop_content,
+  'dzx',
+  NULL,
+  NULL,
+  NULL,
+  NULL,
+  m.tenant_no,
+  IFNULL(rs.order_num, rs.step_order),
+  NULL,
+  NULL,
+  '',
+  NOW(),
+  NULL,
+  NOW(),
+  0
+FROM tmp_uc_step_map m
+INNER JOIN biz_process_route_step rs
+  ON rs.id = m.route_step_id
+ AND rs.del_flag = 0
+WHERE NOT EXISTS (
+  SELECT 1 FROM biz_production_task_step x
+  WHERE x.id = m.task_step_id
+);
+
+-- ---------------------------------------------------------------------------
+-- 5. 复制路线步骤子表 → 任务步骤子表
+-- ---------------------------------------------------------------------------
+INSERT INTO biz_production_task_step_reagent (
+  id, step_id, reagent_code, reagent_name, spec, standard_usage, unit,
+  is_key_material, tenant_no, order_num, remark,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  UPPER(REPLACE(UUID(), '-', '')),
+  m.task_step_id,
+  src.reagent_code,
+  src.reagent_name,
+  src.spec,
+  src.standard_usage,
+  src.unit,
+  src.is_key_material,
+  m.tenant_no,
+  src.order_num,
+  src.remark,
+  NULL,
+  '',
+  NOW(),
+  NULL,
+  NOW(),
+  0
+FROM tmp_uc_step_map m
+INNER JOIN biz_process_route_step_reagent src
+  ON src.step_id = m.route_step_id
+ AND src.del_flag = 0;
+
+INSERT INTO biz_production_task_step_consumable (
+  id, step_id, consumable_code, consumable_name, spec_model, standard_usage,
+  unit, is_required, remark, tenant_no, order_num,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  UPPER(REPLACE(UUID(), '-', '')),
+  m.task_step_id,
+  src.consumable_code,
+  src.consumable_name,
+  src.spec_model,
+  src.standard_usage,
+  src.unit,
+  src.is_required,
+  src.remark,
+  m.tenant_no,
+  src.order_num,
+  NULL,
+  '',
+  NOW(),
+  NULL,
+  NOW(),
+  0
+FROM tmp_uc_step_map m
+INNER JOIN biz_process_route_step_consumable src
+  ON src.step_id = m.route_step_id
+ AND src.del_flag = 0;
+
+INSERT INTO biz_production_task_step_output (
+  id, step_id, output_type_id, output_name, output_barcode,
+  tenant_no, order_num, remark,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  UPPER(REPLACE(UUID(), '-', '')),
+  m.task_step_id,
+  src.output_type_id,
+  src.output_name,
+  src.output_barcode,
+  m.tenant_no,
+  src.order_num,
+  src.remark,
+  NULL,
+  '',
+  NOW(),
+  NULL,
+  NOW(),
+  0
+FROM tmp_uc_step_map m
+INNER JOIN biz_process_route_step_output src
+  ON src.step_id = m.route_step_id
+ AND src.del_flag = 0;
+
+INSERT INTO biz_production_task_step_data_collection (
+  id, step_id, collection_name, unit, tenant_no, order_num, remark,
+  create_by, create_dept_id, create_time, update_by, update_time, del_flag
+)
+SELECT
+  UPPER(REPLACE(UUID(), '-', '')),
+  m.task_step_id,
+  src.collection_name,
+  src.unit,
+  m.tenant_no,
+  src.order_num,
+  src.remark,
+  NULL,
+  '',
+  NOW(),
+  NULL,
+  NOW(),
+  0
+FROM tmp_uc_step_map m
+INNER JOIN biz_process_route_step_data_collection src
+  ON src.step_id = m.route_step_id
+ AND src.del_flag = 0;
+
+-- ---------------------------------------------------------------------------
+-- 6. 回写工单状态：有任务则 jxz（不改 ywc）
+-- ---------------------------------------------------------------------------
+UPDATE biz_production_work_order wo
+INNER JOIN tmp_uc_wo_backfill c ON c.work_order_id = wo.id
+SET
+  wo.work_order_status = 'jxz',
+  wo.update_time = NOW()
+WHERE wo.del_flag = 0
+  AND wo.work_order_status = 'dpz'
+  AND EXISTS (
+    SELECT 1 FROM biz_production_task t
+    WHERE t.work_order_id = wo.id
+      AND t.tenant_no = wo.tenant_no
+      AND t.del_flag = 0
+  );
+
+-- ---------------------------------------------------------------------------
+-- 7. 结果核对
+-- ---------------------------------------------------------------------------
+SELECT
+  c.lab_storage_code,
+  c.work_order_id,
+  wo.work_order_no,
+  wo.work_order_status,
+  t.id AS task_id,
+  t.task_no,
+  t.task_name,
+  (SELECT COUNT(*) FROM biz_production_task_step s WHERE s.task_id = t.id AND s.del_flag = 0) AS step_count
+FROM tmp_uc_wo_backfill c
+LEFT JOIN biz_production_work_order wo ON wo.id = c.work_order_id
+LEFT JOIN biz_production_task t ON t.id = c.task_id AND t.del_flag = 0
+ORDER BY c.seq;
+
+DROP TEMPORARY TABLE IF EXISTS tmp_uc_step_map;
+DROP TEMPORARY TABLE IF EXISTS tmp_uc_wo_backfill;

web-admin/src/router/modules/sqxp.ts

@@ -1335,6 +1335,59 @@ export const sqxpAdminRoutes: AppRouteRecord[] = [
     ]
   },
 
+  // ═══════════════════════════════════════════════════════════════════════════
+  // 3b. 实验室样本处理数据 (menu:lab-sample-processing)
+  // ═══════════════════════════════════════════════════════════════════════════
+  {
+    id: 'TOP0000000000000000000000000000L1',
+    name: 'LabSampleProcessing',
+    path: '/lab-sample-processing',
+    component: '/index/index',
+    meta: {
+      title: '实验室样本处理数据',
+      icon: 'ri:test-tube-line',
+      keepAlive: false,
+      isTopMenu: true,
+      menuCode: 'menu:lab-sample-processing',
+      roles: ['admin']
+    },
+    children: [
+      {
+        id: 'LAB00000000000000000000000000001',
+        name: 'LabSampleProcessingHsc',
+        path: 'hsc',
+        component: '/lab-sample-processing/hsc/index',
+        meta: {
+          title: '造血干细胞数据',
+          keepAlive: true,
+          menuCode: 'lab:sample-processing:list'
+        }
+      },
+      {
+        id: 'LAB00000000000000000000000000002',
+        name: 'LabSampleProcessingUbmc',
+        path: 'ubmc',
+        component: '/lab-sample-processing/ubmc/index',
+        meta: {
+          title: '单个核数据',
+          keepAlive: true,
+          menuCode: 'lab:sample-processing:list'
+        }
+      },
+      {
+        id: 'LAB00000000000000000000000000003',
+        name: 'LabSampleProcessingMsc',
+        path: 'msc',
+        component: '/lab-sample-processing/msc/index',
+        meta: {
+          title: '脐带间充质干细胞数据',
+          keepAlive: true,
+          menuCode: 'lab:sample-processing:list'
+        }
+      }
+    ]
+  },
+
   // ═══════════════════════════════════════════════════════════════════════════
   // 4. 运营支撑 (menu:operations)
   // 二级菜单：系统基础信息、运营支撑

web-admin/src/views/lab-sample-processing/LabSampleProcessingPage.vue

@@ -275,15 +275,28 @@
   async function handleExport() {
     exporting.value = true
     try {
-      const res = await fetchLabSampleList(props.dataset, {
+      // 列表接口 pageSize 上限为 200，导出需分页拉全量后再生成 xlsx
-        keyword: searchForm.keyword || undefined,
+      const pageSize = 200
-        dateFrom: dateRange.value?.[0],
+      let page = 1
-        dateTo: dateRange.value?.[1],
+      let total = Number.POSITIVE_INFINITY
-        page: 1,
+      const rows: Record<string, any>[] = []
-        pageSize: 5000
+      let cols = fields.value
-      })
+      while (rows.length < total) {
-      const cols = res?.fields?.length ? res.fields : fields.value
+        const res = await fetchLabSampleList(props.dataset, {
-      const rows = res?.list || []
+          keyword: searchForm.keyword || undefined,
+          dateFrom: dateRange.value?.[0],
+          dateTo: dateRange.value?.[1],
+          page,
+          pageSize
+        })
+        if (res?.fields?.length) cols = res.fields
+        total = Number(res?.total ?? 0)
+        const batch = res?.list || []
+        rows.push(...batch)
+        if (!batch.length || batch.length < pageSize) break
+        page += 1
+        if (page > 500) break
+      }
       const ExcelJS = (await import('exceljs')).default
       const workbook = new ExcelJS.Workbook()
       const sheet = workbook.addWorksheet(props.title || props.dataset)