Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
96773ae7a3 | ||
|
|
ef4d687d03 | ||
|
|
f5ab0c3167 | ||
|
|
e4b62d6406 | ||
|
|
808f7dcf03 | ||
|
|
50679fa75e |
No files matched your search
@@ -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),
|
||||||
|
}
|
||||||
@@ -2,12 +2,20 @@
|
|||||||
|
|
||||||
from typing import List, Optional, Tuple
|
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… 误匹配造血干
|
# 最长前缀优先:BC 必须在 B 之前,避免 BC… 误匹配造血干
|
||||||
_LAB_CODE_BUILTIN_SET_RULES: List[Tuple[str, str]] = [
|
_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),
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -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())
|
||||||
@@ -1,19 +1,36 @@
|
|||||||
import unittest
|
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):
|
class TestMatchBuiltinTaskSetName(unittest.TestCase):
|
||||||
def test_bc_before_b(self):
|
def test_bc_before_b(self):
|
||||||
self.assertEqual(
|
self.assertEqual(
|
||||||
match_builtin_task_set_name_by_lab_storage_code("BC20260101"),
|
match_builtin_task_set_name_by_lab_storage_code("BC20260101"),
|
||||||
"干细胞培养(内置模版)",
|
BC_MSC_BUILTIN_SET_NAME,
|
||||||
)
|
)
|
||||||
|
|
||||||
def test_b_only(self):
|
def test_b_only(self):
|
||||||
self.assertEqual(
|
self.assertEqual(
|
||||||
match_builtin_task_set_name_by_lab_storage_code("B20260101"),
|
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):
|
def test_ubmc(self):
|
||||||
@@ -35,7 +52,7 @@ class TestMatchBuiltinTaskSetName(unittest.TestCase):
|
|||||||
def test_bc_case_insensitive(self):
|
def test_bc_case_insensitive(self):
|
||||||
self.assertEqual(
|
self.assertEqual(
|
||||||
match_builtin_task_set_name_by_lab_storage_code("bc99"),
|
match_builtin_task_set_name_by_lab_storage_code("bc99"),
|
||||||
"干细胞培养(内置模版)",
|
BC_MSC_BUILTIN_SET_NAME,
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -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()
|
||||||
@@ -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;执行后通知用户使用新密码并建议登录后自行修改。
|
|
||||||
@@ -1,21 +0,0 @@
|
|||||||
-- 实验室样本处理 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'
|
|
||||||
);
|
|
||||||
@@ -1,23 +0,0 @@
|
|||||||
# 恢复 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`
|
|
||||||
|
|
||||||
列表侧同时会从质检完成任务填空(内毒素/真菌/支原体/细菌及母血相关)。
|
|
||||||
@@ -1,14 +0,0 @@
|
|||||||
-- 软删除实验室样本处理 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;
|
|
||||||
@@ -1,12 +0,0 @@
|
|||||||
-- 纠正实验室样本处理部门 ACL:
|
|
||||||
-- 「采集接受人」仅挂在「质检专员」职位上,不应再授予市场字段编辑权,
|
|
||||||
-- 否则质检人员经职位角色并集会同时可改市场+质检字段。
|
|
||||||
|
|
||||||
UPDATE sys_role_menu rm
|
|
||||||
JOIN sys_role r ON r.id = rm.role_id AND r.del_flag = 0 AND r.role_name = '采集接受人'
|
|
||||||
JOIN sys_menu m ON m.id = rm.menu_id AND m.del_flag = 0
|
|
||||||
AND m.perms = 'lab:sample-processing:market:edit'
|
|
||||||
SET rm.del_flag = 1,
|
|
||||||
rm.update_by = 'migration',
|
|
||||||
rm.update_time = NOW()
|
|
||||||
WHERE rm.del_flag = 0;
|
|
||||||
@@ -1,120 +0,0 @@
|
|||||||
-- 实验室样本处理数据:补充表 + 一级模块菜单/按钮权限(不自动授权角色)
|
|
||||||
-- MySQL 5.7,可重复执行
|
|
||||||
|
|
||||||
CREATE TABLE IF NOT EXISTS biz_lab_sample_processing_extra (
|
|
||||||
id VARCHAR(64) NOT NULL,
|
|
||||||
dataset VARCHAR(16) NOT NULL COMMENT 'hsc|ubmc|msc',
|
|
||||||
sample_code VARCHAR(32) NOT NULL COMMENT '样本编码',
|
|
||||||
payload_json TEXT NULL COMMENT '补充字段 JSON',
|
|
||||||
tenant_no VARCHAR(64) NOT NULL,
|
|
||||||
order_num INT NULL,
|
|
||||||
remark VARCHAR(512) NULL,
|
|
||||||
create_by VARCHAR(64) NULL,
|
|
||||||
create_dept_id VARCHAR(64) NOT NULL DEFAULT '',
|
|
||||||
create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|
||||||
update_by VARCHAR(64) NULL,
|
|
||||||
update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
|
|
||||||
del_flag SMALLINT NOT NULL DEFAULT 0,
|
|
||||||
PRIMARY KEY (id),
|
|
||||||
KEY ix_lab_sample_extra_tenant_ds_code (tenant_no, dataset, sample_code, del_flag)
|
|
||||||
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
|
|
||||||
|
|
||||||
-- 挂到与「质检」同一 Web 虚拟根下(复用 menu:quality 的 parent_id)
|
|
||||||
INSERT INTO sys_menu (
|
|
||||||
id, menu_name, parent_id, menu_type, path, component, perms,
|
|
||||||
is_frame, visible, status, tenant_no, order_num, remark,
|
|
||||||
create_by, create_dept_id, create_time, update_by, update_time, del_flag
|
|
||||||
)
|
|
||||||
SELECT
|
|
||||||
MD5(CONCAT(quality.tenant_no, ':menu:lab-sample-processing')),
|
|
||||||
'实验室样本处理数据', quality.parent_id, 'M', '/lab-sample-processing', '/index/index',
|
|
||||||
'menu:lab-sample-processing', 1, '1', '1', quality.tenant_no,
|
|
||||||
COALESCE(quality.order_num, 50) + 1,
|
|
||||||
'20261104 会议:造血/单个核/间充质台账',
|
|
||||||
'migration', '', NOW(), 'migration', NOW(), 0
|
|
||||||
FROM sys_menu quality
|
|
||||||
WHERE quality.perms = 'menu:quality' AND quality.del_flag = 0 AND quality.status = '1'
|
|
||||||
AND NOT EXISTS (
|
|
||||||
SELECT 1 FROM sys_menu e
|
|
||||||
WHERE e.tenant_no = quality.tenant_no AND e.perms = 'menu:lab-sample-processing' AND e.del_flag = 0
|
|
||||||
);
|
|
||||||
|
|
||||||
INSERT INTO sys_menu (
|
|
||||||
id, menu_name, parent_id, menu_type, path, component, perms,
|
|
||||||
is_frame, visible, status, tenant_no, order_num, remark,
|
|
||||||
create_by, create_dept_id, create_time, update_by, update_time, del_flag
|
|
||||||
)
|
|
||||||
SELECT
|
|
||||||
MD5(CONCAT(p.tenant_no, ':lab:sample-processing:list')),
|
|
||||||
'造血干细胞数据', p.id, 'C', 'lab-sample-processing/hsc',
|
|
||||||
'/lab-sample-processing/hsc/index', 'lab:sample-processing:list',
|
|
||||||
1, '1', '1', p.tenant_no, 10, '造血干细胞数据列表',
|
|
||||||
'migration', '', NOW(), 'migration', NOW(), 0
|
|
||||||
FROM sys_menu p
|
|
||||||
WHERE p.perms = 'menu:lab-sample-processing' AND p.del_flag = 0 AND p.status = '1'
|
|
||||||
AND NOT EXISTS (
|
|
||||||
SELECT 1 FROM sys_menu e
|
|
||||||
WHERE e.tenant_no = p.tenant_no AND e.path = 'lab-sample-processing/hsc' AND e.del_flag = 0
|
|
||||||
);
|
|
||||||
|
|
||||||
INSERT INTO sys_menu (
|
|
||||||
id, menu_name, parent_id, menu_type, path, component, perms,
|
|
||||||
is_frame, visible, status, tenant_no, order_num, remark,
|
|
||||||
create_by, create_dept_id, create_time, update_by, update_time, del_flag
|
|
||||||
)
|
|
||||||
SELECT
|
|
||||||
MD5(CONCAT(p.tenant_no, ':lab:sample-processing:ubmc')),
|
|
||||||
'单个核数据', p.id, 'C', 'lab-sample-processing/ubmc',
|
|
||||||
'/lab-sample-processing/ubmc/index', 'lab:sample-processing:list',
|
|
||||||
1, '1', '1', p.tenant_no, 20, '单个核数据列表',
|
|
||||||
'migration', '', NOW(), 'migration', NOW(), 0
|
|
||||||
FROM sys_menu p
|
|
||||||
WHERE p.perms = 'menu:lab-sample-processing' AND p.del_flag = 0 AND p.status = '1'
|
|
||||||
AND NOT EXISTS (
|
|
||||||
SELECT 1 FROM sys_menu e
|
|
||||||
WHERE e.tenant_no = p.tenant_no AND e.path = 'lab-sample-processing/ubmc' AND e.del_flag = 0
|
|
||||||
);
|
|
||||||
|
|
||||||
INSERT INTO sys_menu (
|
|
||||||
id, menu_name, parent_id, menu_type, path, component, perms,
|
|
||||||
is_frame, visible, status, tenant_no, order_num, remark,
|
|
||||||
create_by, create_dept_id, create_time, update_by, update_time, del_flag
|
|
||||||
)
|
|
||||||
SELECT
|
|
||||||
MD5(CONCAT(p.tenant_no, ':lab:sample-processing:msc')),
|
|
||||||
'脐带间充质干细胞数据', p.id, 'C', 'lab-sample-processing/msc',
|
|
||||||
'/lab-sample-processing/msc/index', 'lab:sample-processing:list',
|
|
||||||
1, '1', '1', p.tenant_no, 30, '脐带间充质干细胞数据列表',
|
|
||||||
'migration', '', NOW(), 'migration', NOW(), 0
|
|
||||||
FROM sys_menu p
|
|
||||||
WHERE p.perms = 'menu:lab-sample-processing' AND p.del_flag = 0 AND p.status = '1'
|
|
||||||
AND NOT EXISTS (
|
|
||||||
SELECT 1 FROM sys_menu e
|
|
||||||
WHERE e.tenant_no = p.tenant_no AND e.path = 'lab-sample-processing/msc' AND e.del_flag = 0
|
|
||||||
);
|
|
||||||
|
|
||||||
-- 编辑按钮挂在列表菜单下(三页共用同一 list 权限父节点:造血页)
|
|
||||||
INSERT INTO sys_menu (
|
|
||||||
id, menu_name, parent_id, menu_type, path, component, perms,
|
|
||||||
is_frame, visible, status, tenant_no, order_num, remark,
|
|
||||||
create_by, create_dept_id, create_time, update_by, update_time, del_flag
|
|
||||||
)
|
|
||||||
SELECT
|
|
||||||
MD5(CONCAT(p.tenant_no, ':', btn.perms)),
|
|
||||||
btn.menu_name, p.id, 'F', '', NULL, btn.perms,
|
|
||||||
1, '0', '1', p.tenant_no, btn.order_num, btn.remark,
|
|
||||||
'migration', '', NOW(), 'migration', NOW(), 0
|
|
||||||
FROM sys_menu p
|
|
||||||
JOIN (
|
|
||||||
SELECT '市场字段编辑' AS menu_name, 'lab:sample-processing:market:edit' AS perms, 1 AS order_num, '仅可编辑市场部门字段' AS remark
|
|
||||||
UNION ALL SELECT '生产字段编辑', 'lab:sample-processing:production:edit', 2, '仅可编辑生产部门字段'
|
|
||||||
UNION ALL SELECT '质检字段编辑', 'lab:sample-processing:qc:edit', 3, '仅可编辑质检部门字段'
|
|
||||||
UNION ALL SELECT '部门主管', 'lab:sample-processing:manager', 4, '可编辑全部部门字段'
|
|
||||||
) btn
|
|
||||||
WHERE p.perms = 'lab:sample-processing:list'
|
|
||||||
AND p.path = 'lab-sample-processing/hsc'
|
|
||||||
AND p.del_flag = 0 AND p.status = '1'
|
|
||||||
AND NOT EXISTS (
|
|
||||||
SELECT 1 FROM sys_menu e
|
|
||||||
WHERE e.tenant_no = p.tenant_no AND e.perms = btn.perms AND e.del_flag = 0
|
|
||||||
);
|
|
||||||
@@ -1,50 +0,0 @@
|
|||||||
-- Issue #100:移除多余一级菜单「实验室样本处理数据」及其子菜单/按钮
|
|
||||||
-- 软删除 sys_menu 与对应 sys_role_menu;不影响质检管理下 lab-sample-process 台账
|
|
||||||
-- MySQL 5.7,可重复执行
|
|
||||||
|
|
||||||
-- 1) 角色菜单授权
|
|
||||||
UPDATE sys_role_menu rm
|
|
||||||
JOIN sys_menu m ON m.id = rm.menu_id
|
|
||||||
SET rm.del_flag = 1,
|
|
||||||
rm.update_by = 'migration',
|
|
||||||
rm.update_time = NOW()
|
|
||||||
WHERE rm.del_flag = 0
|
|
||||||
AND (
|
|
||||||
m.perms IN (
|
|
||||||
'menu:lab-sample-processing',
|
|
||||||
'lab:sample-processing:list',
|
|
||||||
'lab:sample-processing:market:edit',
|
|
||||||
'lab:sample-processing:production:edit',
|
|
||||||
'lab:sample-processing:qc:edit',
|
|
||||||
'lab:sample-processing:manager'
|
|
||||||
)
|
|
||||||
OR m.path IN (
|
|
||||||
'/lab-sample-processing',
|
|
||||||
'lab-sample-processing/hsc',
|
|
||||||
'lab-sample-processing/ubmc',
|
|
||||||
'lab-sample-processing/msc'
|
|
||||||
)
|
|
||||||
);
|
|
||||||
|
|
||||||
-- 2) 按钮 / 子菜单 / 一级菜单(先叶子后父级,同批软删即可)
|
|
||||||
UPDATE sys_menu
|
|
||||||
SET del_flag = 1,
|
|
||||||
update_by = 'migration',
|
|
||||||
update_time = NOW()
|
|
||||||
WHERE del_flag = 0
|
|
||||||
AND (
|
|
||||||
perms IN (
|
|
||||||
'menu:lab-sample-processing',
|
|
||||||
'lab:sample-processing:list',
|
|
||||||
'lab:sample-processing:market:edit',
|
|
||||||
'lab:sample-processing:production:edit',
|
|
||||||
'lab:sample-processing:qc:edit',
|
|
||||||
'lab:sample-processing:manager'
|
|
||||||
)
|
|
||||||
OR path IN (
|
|
||||||
'/lab-sample-processing',
|
|
||||||
'lab-sample-processing/hsc',
|
|
||||||
'lab-sample-processing/ubmc',
|
|
||||||
'lab-sample-processing/msc'
|
|
||||||
)
|
|
||||||
);
|
|
||||||
@@ -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
|
||||||
|
);
|
||||||
@@ -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;
|
||||||
@@ -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)
|
// 4. 运营支撑 (menu:operations)
|
||||||
// 二级菜单:系统基础信息、运营支撑
|
// 二级菜单:系统基础信息、运营支撑
|
||||||
|
|||||||
Reference in new issue
Block a user