feat: MES/MOM 出入库状态解绑与直接完结通道（后端契约 + 移动端）

- TaskTransferRequest 新增 finish_directly 开关：闭环当前任务但不产生任何下游任务，产品 overall_status 保持原样，工人无需再借道「入库(virtual_warehouse)」来关闭任务，从根源上避免产品被误标「待仓库收货」而卡住 MOM 对账 - 空 assignees 分支加防呆校验：想直接完结必须显式传 finish_directly=true，杜绝漏填导致「转交」静默退化成「直接完结」的丢件级隐患 - 直接完结跳过 _mark_after_sales_if_reactivated：不产生新任务即不构成「回流返厂」信号，否则已出库设备的正常收官会把产品误翻成售后机（该标志单向不可回退） - 补齐直接完结的独立响应文案，不再拼出「已创建 0 个下一道工序任务「None」」 - 移动端转交弹窗改为「转交个人 / 入库 / 直接完结」三选一互斥
2026-09-17 14:07:02 +08:00
parent 2539bede3c
commit 1e6c006360
3 changed files with 105 additions and 23 deletions
--- a/backend/app/schemas/task.py
+++ b/backend/app/schemas/task.py
@ -3,7 +3,7 @@ from __future__ import annotations
 import uuid
 from datetime import datetime
 from typing import Optional
-from pydantic import BaseModel, Field, field_validator
+from pydantic import BaseModel, Field, field_validator, model_validator


 # ============================================================
@ -79,7 +79,13 @@ class TaskRejectRequest(BaseModel):
 class TaskTransferBranch(BaseModel):
    """裂变分支"""
    task_name: str = Field(..., max_length=200, description="工序名称")
-    assignees: list[str] = Field(..., min_length=1, description="接收人列表")
+    assignees: list[str] = Field(
+        default_factory=list, min_length=0,
+        description=(
+            "接收人列表。允许为空数组，但仅当 finish_directly=True 时合法——"
+            "空分支不产生任何下游任务（见 TaskTransferRequest 的校验）。"
+        ),
+    )


 class TaskTransferRequest(BaseModel):
@ -88,6 +94,27 @@ class TaskTransferRequest(BaseModel):
    next_task_name: str | None = Field(None, max_length=200, description="[旧版] 下一道工序名称")
    next_tasks: list[TaskTransferBranch] | None = Field(None, description="[新版] 多分支任务列表")
    note: str | None = Field(None, description="交接备注")
+    finish_directly: bool = Field(
+        False,
+        description=(
+            "直接完结：闭环当前任务但【不产生任何下游任务】，"
+            "产品 overall_status 保持原样（不入库 → 不会变成「待仓库收货」）。"
+            "置 True 时忽略 next_tasks / next_assignees。"
+        ),
+    )
+
+    @model_validator(mode="after")
+    def _reject_silent_empty_branch(self):
+        """空 assignees 分支会让「转交」静默退化成「直接完结」——任务闭环了却没人接手，
+        是个丢件级隐患。想直接完结必须显式传 finish_directly=true，不能靠漏填凑合。"""
+        if self.finish_directly:
+            return self
+        if any(not b.assignees for b in (self.next_tasks or [])):
+            raise ValueError(
+                "分支 assignees 不能为空；若意图是「直接完结该任务」，"
+                "请改为传 finish_directly=true"
+            )
+        return self


 class TaskRecordCreate(BaseModel):
--- a/backend/app/services/task_service.py
+++ b/backend/app/services/task_service.py
@ -844,6 +844,12 @@ async def transfer_task(
    - 如果包含 'virtual_warehouse'，则将 Product 的 current_location_id 设为 'virtual_warehouse'。
    - 为每一个 assignee_id（非 virtual_warehouse）新建一条 Task 记录（状态 PENDING）。

+    动作 2'（直接完结 finish_directly=True）：
+    - 不解析任何下家，分支强制为空，直接落入下方"无下家"兜底分支。
+    - 用于「售后返厂直接发走 / 半成品被提走」这类**无需入库**的收官场景：
+      工人不必再借道「入库(virtual_warehouse)」来关闭任务，
+      从而避免把产品误标成「待仓库收货」并卡住 MOM 对账。
+
    裂变逻辑：
    - 如果 len(next_assignees) > 1：多路裂变 → 所有新任务挂到当前任务下（parent_task_id = 当前任务ID）。
    - 如果当前任务本身就是子任务（有 parent_task_id）：单路转交也挂到同一父任务下。
@ -879,6 +885,16 @@ async def transfer_task(
    now = get_beijing_time()

    # --- 动作 1：闭环当前节点 ---
+    # 🔧 直接完结走独立文案：action_type 沿用 "complete"（不新增取值，避免扰动现有
+    #   看板的完成数口径），仅在 remark 里区分，审计时可按文本筛出「直接完结」。
+    finish_directly = bool(request.finish_directly)
+    if finish_directly:
+        log_remark = request.note or f"直接完结任务「{task.task_name}」（无下游，不入库）"
+        record_remark = request.note or "[直接完结] 无下游任务，产品宏观状态保持不变"
+    else:
+        log_remark = request.note or f"完成任务「{task.task_name}」，转交至下一道工序"
+        record_remark = request.note or "[完工转交] 移交下一工序"
+
    task.status = TASK_STATUS_COMPLETED
    task.completed_at = now

@ -886,11 +902,11 @@ async def transfer_task(
        db, task_id,
        action_type="complete",
        operator_id=operator_id,
-        remark=request.note or f"完成任务「{task.task_name}」，转交至下一道工序",
+        remark=log_remark,
        task_assignee_id=task.assignee_id,
    )
    db.add(TaskRecord(task_id=task.id,
-        remark=(request.note or f"[完工转交] 移交下一工序") + _admin_proxy_note(operator_id, task.assignee_id),
+        remark=record_remark + _admin_proxy_note(operator_id, task.assignee_id),
        images="[]"))

    # --- 动作 2：解析下家 & 裂变 ---
@ -903,11 +919,16 @@ async def transfer_task(

    # 🔧 出库后又被转交出新任务 = 设备回流返厂 → 切到售后生命周期。
    #   必须在阶段校验之前执行，否则"已出库设备被转交到生产工序"会被误放行。
-    if product:
+    #   ⚠️ 直接完结【不产生新任务】，不构成"回流返厂"信号，必须跳过：
+    #   否则一台已出库设备的正常收官，会把产品误翻成售后机（该标志单向不可回退）。
+    if product and not finish_directly:
        await _mark_after_sales_if_reactivated(db, task.product_id)

    # 兼容新旧格式
-    if request.next_tasks:
+    # 🔧 直接完结：不解析任何下家，分支强制为空，直接命中下方"无下家"兜底分支。
+    if finish_directly:
+        branches: list[tuple[str | None, str]] = []
+    elif request.next_tasks:
        branches = [
            (b.task_name, a)
            for b in request.next_tasks
@ -1007,6 +1028,9 @@ async def transfer_task(
        sync_product_status(product)

        # 🔧 位置回溯：如果有新任务创建，优先新任务负责人；否则回溯到父任务
+        #    「直接完结」(finish_directly) 与旧版空分支都落到这里：
+        #    overall_status 在上面两个分支里都没被赋值，故原样保留
+        #    （已出库 / 在库 / 售后维修… 不会被改写成「待仓库收货」）。
        if not real_branches and not has_warehouse:
            await _recalc_product_location(db, task.product_id, task_id)

@ -1019,19 +1043,25 @@ async def transfer_task(
        await db.refresh(nt)
        created_task_responses.append(_to_response(nt))

-    assignee_list = ", ".join(a for _, a in real_branches) if real_branches else "仓库"
-    location_info = ""
-    if has_warehouse:
-        location_info = "，产品已入库(virtual_warehouse)"
+    # 🔧 直接完结没有下家，不能套用"已创建 N 个任务（接收人: 仓库）"的模板
+    #   （否则会拼出「已创建 0 个下一道工序任务「None」（接收人: 仓库）」这种误导文案）
+    if finish_directly:
+        message = f"任务「{task.task_name}」已直接完结（无下游任务，产品状态保持不变）"
+    else:
+        assignee_list = ", ".join(a for _, a in real_branches) if real_branches else "仓库"
+        location_info = ""
+        if has_warehouse:
+            location_info = "，产品已入库(virtual_warehouse)"
+        message = (
+            f"任务「{task.task_name}」已完成，"
+            f"已创建 {len(created_tasks)} 个下一道工序任务「{request.next_task_name}」"
+            f"（接收人: {assignee_list}）{location_info}"
+        )

    return TaskTransferResponse(
        completed_task=_to_response(refreshed_task),
        created_tasks=created_task_responses,
-        message=(
-            f"任务「{task.task_name}」已完成，"
-            f"已创建 {len(created_tasks)} 个下一道工序任务「{request.next_task_name}」"
-            f"（接收人: {assignee_list}）{location_info}"
-        ),
+        message=message,
    )