eomsangdonandClaude Opus 5
abf586108c
통로는 났는데 `_mass_haul_context()` 를 **인자 없이** 불러 값이 늘 `None` 이었다 (`Router_HaulPlan.py:64` · `Server_Calc_Prebuild.py:170`). 오늘 세 번째로 나온 「받는 곳은 있는데 넣는 곳이 없던」 자리다. - `haul_inputs_for()` 로 B08 의 `project_haul_inputs` 를 받아 두 자리 모두에 넘긴다. ⚠ 여기서 다시 세지 않는다 — 두 값 다 B08 전개에서 나온다(CLAUDE.md 5장). - 측점별 잔토(`structure_spoil_points`)를 받으면 **그 자리 잔량에 얹는다** — 총량 비례로 흩으면 운반거리가 틀린다. 총량만 오면 종전대로 비례 분배(차선). - 저장 payload 에 받은 값·실제로 먹은 값 넷을 남긴다 — 「값이 흐르는지」를 저장분에서 바로 가릴 수 있어야 한다. 실측(route 184): 공제 0(구입이라 채집 없음) · 구조물 잔토 12.875㎥ 가 **실제로 전달됨**. ⚠ 그 노선은 사토가 0(전 구간 토취)이라 더할 잔량이 없어 `added=0` — 아래 물음 참조. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
88 lines
3.6 KiB
Python
88 lines
3.6 KiB
Python
"""유토 **배분(평형선·운반거리·장비)** 만 내주는 창구.
|
|
|
|
왜 따로 있나(2026-09-06 사용자 확정) — 배분 산식은 노하우가 몰린 자리라 브라우저 번들에
|
|
남기지 않는다. 화면은 누가토량까지만 스스로 내고(`common_util_mass_haul.ts`), 편집이
|
|
멈추면 그 결과를 여기로 보내 배분을 받아 쥔다. 그래서 유토곡선 패널을 펼치는 순간이
|
|
즉시가 된다(미리 받아 뒀으므로).
|
|
|
|
**계산은 한 벌이다** — 화면이 쓰던 TS 를 Node 진입점(`B06_Section_Server_Calc_Node.ts`)으로
|
|
그대로 돌린다(CLAUDE.md 5장). 파이썬으로 옮기면 저장 정본과 화면 값이 갈린다.
|
|
|
|
정본을 만들지 않는다 — 이 응답은 **표시 전용**이다. 저장 정본은 [저장]·[확정] 뒤
|
|
`recompute_server_side` 가 따로 낸다.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import asyncio
|
|
import logging
|
|
from typing import Any
|
|
from uuid import UUID
|
|
|
|
from fastapi import APIRouter, Body
|
|
from fastapi.responses import JSONResponse
|
|
|
|
from B06_Section.B06_Section_Server_Calc_Prebuild import (
|
|
BUNDLE,
|
|
_mass_haul_context,
|
|
haul_inputs_for,
|
|
)
|
|
from common_util.common_util_node_bundle import run_bundle_json
|
|
|
|
logger = logging.getLogger(__name__)
|
|
router = APIRouter(prefix="/api/projects", tags=["B06 Profile Cross"])
|
|
|
|
_NPM_SCRIPT = "build:server-calc"
|
|
# 측점 수 상한 — 정상 노선은 수백 곳이다. 그보다 크면 비정상 요청으로 본다.
|
|
_MAX_POINTS = 5000
|
|
|
|
|
|
@router.post("/{project_id}/sections/{route_id}/haul-plan", response_model=None)
|
|
async def compute_haul_plan(
|
|
project_id: UUID,
|
|
route_id: int,
|
|
payload: dict[str, Any] = Body(...),
|
|
) -> JSONResponse:
|
|
"""브라우저가 낸 누가토량 결과를 받아 **배분만** 돌려준다.
|
|
|
|
입력은 `common_util_mass_haul.computeMassHaul` 의 결과 한 벌이다(`points` 포함).
|
|
출력은 `{"haul_plan": {...} | null}` — 화면이 그대로 그린다.
|
|
"""
|
|
result = payload.get("result")
|
|
points = result.get("points") if isinstance(result, dict) else None
|
|
if not isinstance(points, list) or not points:
|
|
return JSONResponse(
|
|
status_code=400,
|
|
content={"status": "error", "message": "누가토량 결과가 비어 있습니다."},
|
|
)
|
|
if len(points) > _MAX_POINTS:
|
|
return JSONResponse(
|
|
status_code=400,
|
|
content={"status": "error", "message": "측점 수가 너무 많습니다."},
|
|
)
|
|
# 구조물 몫(공제·잔토)을 **넘겨야** 사토가 줄고 는다 — 인자 없이 부르면 늘 `None` 이라
|
|
# 통로만 있고 값이 안 흐른다(2026-09-09 실측으로 드러난 자리).
|
|
haul_inputs = await haul_inputs_for(project_id)
|
|
try:
|
|
output = await asyncio.to_thread(
|
|
run_bundle_json,
|
|
BUNDLE,
|
|
_NPM_SCRIPT,
|
|
{
|
|
"haul_plan_for": result,
|
|
"context": _mass_haul_context(
|
|
haul_inputs.get("collected_stone_deduction_m3"),
|
|
haul_inputs.get("structure_spoil_m3"),
|
|
haul_inputs.get("structure_spoil_points"),
|
|
),
|
|
},
|
|
)
|
|
except Exception:
|
|
logger.exception("유토 배분 계산 실패: project_id=%s route_id=%s", project_id, route_id)
|
|
return JSONResponse(
|
|
status_code=500,
|
|
content={"status": "error", "message": "유토 배분 계산에 실패했습니다."},
|
|
)
|
|
plan = output.get("haul_plan") if isinstance(output, dict) else None
|
|
return JSONResponse(content={"status": "success", "haul_plan": plan})
|