diff --git a/B03_FileInput/B03_FileInput_Email.py b/B03_FileInput/B03_FileInput_Email.py index 0d7d2001..4da46696 100644 --- a/B03_FileInput/B03_FileInput_Email.py +++ b/B03_FileInput/B03_FileInput_Email.py @@ -6,7 +6,7 @@ from typing import Any from uuid import UUID from common_util.common_util_email import send_email -from config.config_system import APP_PUBLIC_BASE_URL +from config.config_system import ADMIN_EMAIL, APP_PUBLIC_BASE_URL logger = logging.getLogger(__name__) @@ -285,3 +285,53 @@ async def send_analysis_error_email( ) logger.info("WF1 오류 이메일 발송 %s: %s", "성공" if success else "실패", to_email) return success + + +async def send_initial_design_failed_email( + *, + project_id: UUID, + project_name: str, + to_email: str, + reason: str, +) -> bool: + """초기 설계(B05·B06 자동 계산) 실패를 알리고 관리자 문의를 안내한다. + + 부분 결과를 초기값으로 삼지 않는다는 방침(2026-09-02 사용자 확정)에 따라, 체인이 + 깨진 프로젝트는 [초기화]가 되돌릴 기준이 없다. 완료 메일 대신 이 메일을 보내 + 사용자가 화면에서 헛작업을 하지 않게 한다. + """ + contact = ADMIN_EMAIL.strip() + contact_line = ( + f'

관리자에게 문의해 주세요 — ' + f"{html.escape(contact)}

" + if contact + else "

관리자에게 문의해 주세요.

" + ) + rows = "\n".join( + [ + _summary_row("프로젝트 ID", html.escape(str(project_id))), + _summary_row("중단 지점", html.escape(reason or "초기 설계 처리 실패")), + ] + ) + safe_name = html.escape(project_name) + body = f""" +

프로젝트 {safe_name}의 초기 설계 자동 계산이 + 완료되지 못했습니다.

+
+ {rows} +
+
+

초기 설계가 끝나지 않아 종·횡단 화면의 값이 기준값으로 확정되지 않았습니다. + 이 상태에서는 [초기화]로 되돌릴 초기값도 없습니다.

+ {contact_line} +
+

기술 지원팀이 확인할 수 있도록 서버 로그에도 같은 내용을 기록했습니다.

+ """ + subject = f"초기 설계 실패 알림 - {project_name}" + success = await send_email( + to_email=to_email, + subject=subject, + html=_email_shell(subject, body, accent="#dc2626"), + ) + logger.info("초기 설계 실패 이메일 발송 %s: %s", "성공" if success else "실패", to_email) + return success diff --git a/B03_FileInput/B03_FileInput_Service_Chain.py b/B03_FileInput/B03_FileInput_Service_Chain.py index de3a99b7..39bd3125 100644 --- a/B03_FileInput/B03_FileInput_Service_Chain.py +++ b/B03_FileInput/B03_FileInput_Service_Chain.py @@ -139,7 +139,9 @@ async def run_auto_design_chain( from B05_Profile.B05_Profile_Schema import RoutePoint, RouteSolveRequest from B06_Section.B06_Section_Router_Confirm import confirm_sections from common_util.common_util_initial_snapshot import ( + clear_design_failed, clear_designing, + mark_design_failed, mark_designing, save_initial_snapshot, ) @@ -167,6 +169,8 @@ async def run_auto_design_chain( # 이 체인이 끝나기 전에는 B05·B06에 들어가면 안 된다 — 반쯤 계산된 화면을 만지면 # 그 편집이 섞인 채 초기값이 찍힌다(2026-08-29 사용자 확정, CLAUDE.md 5장). mark_designing(project_root) + # 옛 실패 마커는 여기서 지운다 — 이번 체인의 결과로 다시 판정한다. + clear_design_failed(project_root) # WF1이 **실제로 확정한** 선택값(stage 1 스냅샷)을 그대로 쓴다. config 기본값을 # 쓰면 LAS 없이 설계한 프로젝트에서 있지도 않은 모델을 가리켜 404로 체인이 # 끊긴다(2026-08-30 실사고). 노선 트림도 이 지표면을 기준으로 한다. @@ -176,6 +180,7 @@ async def run_auto_design_chain( points = _planned_route_points_in_project_crs(project_root, defaults) if not points: logger.warning("자동 설계 체인 중단(계획노선 CSV 없음): project_id=%s", project_id) + mark_design_failed(project_root, "계획노선 CSV가 없어 초기 노선을 세울 수 없습니다.") return None # 3) B05 경로 계산 @@ -198,6 +203,10 @@ async def run_auto_design_chain( project_id, solve_result.status_code, ) + mark_design_failed( + project_root, + f"B05 초기 노선 계산 실패 (status={solve_result.status_code}).", + ) return None route_id = int(solve_result.route_id) logger.info( @@ -216,6 +225,10 @@ async def run_auto_design_chain( project_id, confirm_result.status_code, ) + mark_design_failed( + project_root, + f"B05 초기 노선 확정 실패 (status={confirm_result.status_code}).", + ) return None # 4.5) 배수유역 분석 → 관 지점 확정 → 배관 정착 계획선 재산출. @@ -234,6 +247,10 @@ async def run_auto_design_chain( route_id, sections_result.status_code, ) + mark_design_failed( + project_root, + f"B06 초기 횡단 확정 실패 (status={sections_result.status_code}).", + ) return None logger.info( "자동 설계 체인 완료(B05·B06 기본값 확정): project_id=%s route_id=%s", @@ -242,21 +259,25 @@ async def run_auto_design_chain( ) # 초기값 스냅샷 — 여기가 [초기화]가 되돌릴 기준선이다(CLAUDE.md 5장). - # 체인 규약대로 실패는 비치명적이다: 스냅샷이 없으면 [초기화]가 재계산으로 돈다. + # 체인 규약대로 실패는 비치명적이다: 계산 결과는 그대로 두고 실패 마커만 남겨 + # [초기화]가 재계산으로 얼버무리지 않게 한다(2026-09-02 사용자 확정). try: async with pool.acquire() as connection: await save_initial_snapshot(connection, project_root, route_id) - except Exception: # noqa: BLE001 — 스냅샷 실패가 체인을 막지는 않는다 + except Exception as exc: # noqa: BLE001 — 스냅샷 실패가 체인을 막지는 않는다 logger.exception("초기값 스냅샷 실패: project_id=%s", project_id) + mark_design_failed(project_root, f"초기값 스냅샷 저장 실패: {exc}") return { "route_id": route_id, "length_m": float(solve_result.total_length_m or 0.0), "cross_section_count": solve_result.cross_section_count, } - except Exception: + except Exception as exc: # 체인은 업로드·WF1 흐름의 부가 작업이다 — 어떤 예외도 밖으로 던지지 않는다. logger.exception("자동 설계 체인 실패: project_id=%s", project_id) + if project_root is not None: + mark_design_failed(project_root, f"초기 설계 처리 중 오류: {exc}") finally: # 성공·실패·중단 어느 쪽이든 문은 연다 — 마커가 남으면 영영 못 들어간다. if project_root is not None: diff --git a/B03_FileInput/B03_FileInput_Service_WF1.py b/B03_FileInput/B03_FileInput_Service_WF1.py index 125be8fd..5ffb7cb3 100644 --- a/B03_FileInput/B03_FileInput_Service_WF1.py +++ b/B03_FileInput/B03_FileInput_Service_WF1.py @@ -11,8 +11,10 @@ import aiomysql from B03_FileInput.B03_FileInput_Email import ( send_analysis_error_email, send_initial_analysis_complete_email, + send_initial_design_failed_email, ) from B03_FileInput.B03_FileInput_Repository import get_project_storage_relative_path +from common_util.common_util_initial_snapshot import is_design_failed, read_design_failure from common_util.common_util_storage import resolve_stored_project_path from common_util.common_util_surface_confirmation import surface_confirmation_defaults from common_util.common_util_workflow_state import fail_stage, start_stage @@ -210,14 +212,25 @@ async def trigger_wf1_analysis_and_email( # 알림 메일은 여기 한 통뿐이다 — 업로드 직후와 분석 직후로 나눠 두 통을 보내던 것을 # 초기 설계(B04~B06)까지 마친 시점의 통합 메일로 합쳤다(2026-08-08 사용자 지시). + # 체인이 깨졌으면 완료 메일 대신 관리자 문의 안내를 보낸다 — 부분 결과는 분석 + # 안 됨과 다르지 않다(2026-09-02 사용자 확정). + design_failure = read_design_failure(project_root) if is_design_failed(project_root) else "" if SEND_ANALYSIS_COMPLETION_EMAIL and project_info and project_info.get("user_email"): - await send_initial_analysis_complete_email( - project_id=project_id, - project_name=str(project_info.get("project_name") or project_id), - to_email=str(project_info["user_email"]), - analysis_result=analysis_result, - design_summary=design_summary, - ) + if design_failure: + await send_initial_design_failed_email( + project_id=project_id, + project_name=str(project_info.get("project_name") or project_id), + to_email=str(project_info["user_email"]), + reason=design_failure, + ) + else: + await send_initial_analysis_complete_email( + project_id=project_id, + project_name=str(project_info.get("project_name") or project_id), + to_email=str(project_info["user_email"]), + analysis_result=analysis_result, + design_summary=design_summary, + ) except Exception as exc: logger.exception("WF1 백그라운드 분석 실패: project_id=%s", project_id) async with pool.acquire() as connection, connection.cursor() as cursor: diff --git a/B05_Profile/B05_Profile_Api_Fetch.ts b/B05_Profile/B05_Profile_Api_Fetch.ts index 05cd24bd..b137cef6 100644 --- a/B05_Profile/B05_Profile_Api_Fetch.ts +++ b/B05_Profile/B05_Profile_Api_Fetch.ts @@ -275,7 +275,9 @@ export interface RouteResetResponse { } /** [초기화] — 사용자 편집을 전부 버리고 초기값으로 되돌린다. 초기값 스냅샷이 있으면 - * 복원이라 빠르지만, 없는 옛 프로젝트는 재계산으로 폴백하므로 분석용 타임아웃을 쓴다. */ + * 복원이라 빠르지만, 없는 옛 프로젝트는 재계산으로 폴백하므로 분석용 타임아웃을 쓴다. + * 초기 설계가 실패로 끝난 프로젝트는 서버가 409로 거부한다 — 되돌릴 기준이 없어 + * 재계산으로 얼버무리지 않는다(2026-09-02). 그 안내 문구가 그대로 오류 토스트에 뜬다. */ export async function resetRouteDesign(projectId: string): Promise { return requestJson( `/projects/${projectId}/route/reset`, diff --git a/B05_Profile/B05_Profile_Router_Lifecycle.py b/B05_Profile/B05_Profile_Router_Lifecycle.py index 1e087863..474b3426 100644 --- a/B05_Profile/B05_Profile_Router_Lifecycle.py +++ b/B05_Profile/B05_Profile_Router_Lifecycle.py @@ -149,20 +149,26 @@ async def reset_route_design(project_id: UUID) -> JSONResponse: `edits/pipe_points.json`이 사용자 편집분인 채로 남아 구조물 측점이 그것에서 다시 파생되기 때문이다. - 스냅샷이 없는 옛 프로젝트는 종전대로 자동 설계 체인을 다시 돌린다. 어느 경로든 - 사용자 편집(제어점 이동·계획선 편집·횡단 설계 지정)은 전부 버려지고, stage 2·3은 - IN_PROGRESS(검토 대기)가 된다. + 초기 설계 체인이 **실패로 끝난 프로젝트**(`initial_design.failed` 마커)는 되돌릴 + 기준이 없다 — 재계산으로 얼버무리지 않고 409로 관리자 문의를 안내한다. 부분 결과는 + 분석 안 됨과 다르지 않다(2026-09-02 사용자 확정). + + 마커도 스냅샷도 없는 옛 프로젝트는 종전대로 자동 설계 체인을 다시 돌린다. 어느 + 경로든 사용자 편집(제어점 이동·계획선 편집·횡단 설계 지정)은 전부 버려지고, stage + 2·3은 IN_PROGRESS(검토 대기)가 된다. """ from B03_FileInput.B03_FileInput_Service_Chain import run_auto_design_chain from B04_PreProcess.B04_PreProcess_Service import find_surface_model_for_selection from B05_Profile.B05_Profile_Router_Corridor import prune_corridor_files from common_util.common_util_initial_snapshot import ( has_initial_snapshot, + is_design_failed, + read_design_failure, restore_initial_snapshot, restore_snapshot_files, wipe_edited_masters, ) - from common_util.common_util_surface_confirmation import surface_confirmation_defaults + from common_util.common_util_surface_confirmation import get_surface_confirmation_params pool = get_db_pool() try: @@ -170,12 +176,37 @@ async def reset_route_design(project_id: UUID) -> JSONResponse: stored_path = await get_project_storage_relative_path(connection, project_id) project_root = Path(resolve_stored_project_path(stored_path)) if stored_path else None restored = bool(project_root and has_initial_snapshot(project_root)) + if not restored and project_root and is_design_failed(project_root): + # 초기 설계가 깨진 프로젝트 — 되돌릴 기준이 없다. 재계산은 사용자가 본 초기 + # 화면과 다른 값을 낳으므로 하지 않는다(2026-09-02 사용자 확정). + reason = read_design_failure(project_root) or "초기 설계 처리 실패" + logger.warning( + "B05 초기화 거부(초기 설계 실패 프로젝트): project_id=%s reason=%s", + project_id, + reason, + ) + return JSONResponse( + status_code=409, + content={ + "status": "error", + "code": "initial_design_failed", + "reason": reason, + "message": ( + "초기 설계가 완료되지 않아 되돌릴 초기값이 없습니다. " + "관리자에게 문의해 주세요." + ), + }, + ) async with pool.acquire() as connection: - # 확정 지표면 모델을 초기 체인과 같은 기준(config 기본값)으로 다시 찾는다. + # 확정 지표면 모델을 초기 체인과 **같은 기준**으로 다시 찾는다 — 체인은 stage 1 + # 확정 선택값을 쓴다(2026-08-30). config 기본값을 쓰면 그 선택과 어긋난 모델을 + # 집어 재계산 결과가 초기값과 달라진다(2026-09-02 실측: `classification`/5m + # 확정 프로젝트에 `csf`/1m 기본값이 걸림). try: + selection = await get_surface_confirmation_params(connection, str(project_id)) surface_model_id: int | None = await find_surface_model_for_selection( - connection, project_id, surface_confirmation_defaults() + connection, project_id, selection ) except Exception: surface_model_id = None diff --git a/common_util/common_util_initial_snapshot.py b/common_util/common_util_initial_snapshot.py index 3420a60c..e9a56e5c 100644 --- a/common_util/common_util_initial_snapshot.py +++ b/common_util/common_util_initial_snapshot.py @@ -21,6 +21,8 @@ SNAPSHOT_DIRNAME = "initial_snapshot" _DB_DUMP_NAME = "db.json" # 초기 설계 체인이 도는 동안만 존재하는 마커(진입 차단 판정용). DESIGNING_LOCK_NAME = "initial_design.lock" +# 초기 설계 체인이 실패로 끝났음을 남기는 마커. +DESIGN_FAILED_NAME = "initial_design.failed" # 프로젝트 루트 기준 상대 경로 — 정본 파일이 사는 자리 전부. _FILE_TREES = ( @@ -69,6 +71,45 @@ def clear_designing(project_root: Path) -> None: pass +def design_failed_path(project_root: Path) -> Path: + """초기 설계 체인이 실패로 끝났음을 남기는 마커. + + "스냅샷이 없다"는 사실만으로는 **실패한 프로젝트**와 스냅샷 기능 이전의 **옛 + 프로젝트**를 가를 수 없다. 앞은 [초기화]가 재계산으로 얼버무리면 안 되고(부분 결과는 + 분석 안 됨과 다르지 않다, 2026-09-02 사용자 확정), 뒤는 종전 재계산 폴백이 유일한 + 수단이다. 락과 같은 자리 — 스냅샷 대상 4트리 **밖**이라 복원에 딸려 들어가지 않는다. + """ + return Path(project_root) / DESIGN_FAILED_NAME + + +def is_design_failed(project_root: Path) -> bool: + return design_failed_path(project_root).is_file() + + +def read_design_failure(project_root: Path) -> str: + """실패 사유를 읽는다. 마커가 없거나 못 읽으면 빈 문자열.""" + try: + return design_failed_path(project_root).read_text(encoding="utf-8").strip() + except OSError: + return "" + + +def mark_design_failed(project_root: Path, reason: str) -> None: + path = design_failed_path(project_root) + try: + path.parent.mkdir(parents=True, exist_ok=True) + path.write_text(reason, encoding="utf-8") + except OSError: + pass # 마커 실패가 체인을 막지는 않는다 — 안내가 덜 정확해질 뿐이다. + + +def clear_design_failed(project_root: Path) -> None: + try: + design_failed_path(project_root).unlink(missing_ok=True) + except OSError: + pass + + def discard_initial_snapshot(project_root: Path) -> bool: """초기값을 무효화한다 — 지표면·노선이 바뀌어 옛 초기값이 더는 기준이 아닐 때.