chore: 清理主分支残留删除项

再次移除多余实验室样本处理一级静态路由，并删除弱密码刷新说明 SQL。

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

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冻存（内置模版）"),
-    ("PBMC", "PBMC冻存（内置模版）"),
-    ("BC", "干细胞培养（内置模版）"),
-    ("B", "造血干样本处理（内置模版）"),
+    ("UBMC", UBMC_BUILTIN_SET_NAME),
+    ("PBMC", PBMC_BUILTIN_SET_NAME),
+    ("UC", UC_MSC_BUILTIN_SET_NAME),
+    ("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/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/2026-10-16-reset-weak-password-111111.sql

@@ -1,46 +0,0 @@
--- =============================================================================
--- 弱密码刷新说明：111111 → Zkxw@123
--- 日期：2026-10-16
--- =============================================================================
---
--- 重要：sys_user.password 存储 bcrypt 哈希（每次盐随机），
---       不能用下列语句命中弱密码用户：
---         WHERE password = '111111'          -- 无效
---         WHERE password LIKE '%111111%'     -- 无效
---
--- 推荐：用 Python 脚本，并通过变量指定目标库（勿依赖本机默认 .env 误连生产）。
---
---   cd backend && source venv/bin/activate
---
---   # 方式 A：完整 URL
---   python scripts/reset_weak_password_111111.py \
---     --database-url 'mysql+pymysql://USER:PASS@HOST:3306/DBNAME' --dry-run
---
---   # 方式 B：分项变量
---   python scripts/reset_weak_password_111111.py \
---     --db-host HOST --db-port 3306 --db-user USER --db-password 'PASS' --db-name DBNAME --dry-run
---
---   # 方式 C：指定环境文件
---   python scripts/reset_weak_password_111111.py --env-file ./.env.test --dry-run
---
---   # 正式写入：去掉 --dry-run
---
--- 脚本行为：校验 del_flag=0 的用户口令是否为明文 111111（含停用账号），
---           命中则更新为 Zkxw@123 的新 bcrypt 哈希。
---
--- =============================================================================
--- 以下仅为「已知单个用户 id」时的手工 UPDATE 模板。
--- 哈希由本机生成示例（明文 Zkxw@123，bcrypt cost 12），部署前请用 Python 重新生成：
---   python -c "from app.core.security import get_password_hash; print(get_password_hash('Zkxw@123'))"
--- =============================================================================
-
--- 示例哈希（仅供手工单用户更新参考；批量请用脚本）：
--- $2b$12$ULvPCr6g9IUmI8K7nlGU5emk7hupaAz4WgFdEoQBe935Wh1pVYKCK
-
--- UPDATE sys_user
--- SET password = '$2b$12$ULvPCr6g9IUmI8K7nlGU5emk7hupaAz4WgFdEoQBe935Wh1pVYKCK',
---     update_time = NOW()
--- WHERE id = '<user_id>'
---   AND del_flag = 0;
-
--- 执行前请备份 sys_user；执行后通知用户使用新密码并建议登录后自行修改。

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,59 +1335,6 @@ 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)
   // 二级菜单：系统基础信息、运营支撑