Merge remote-tracking branch 'origin/sub_laptop_5' into sub_laptop_3

B04_PreProcess/B04_PreProcess_Router_Basins.py

@@ -269,7 +269,10 @@ async def _resolve(
     if context is None:
         return JSONResponse(status_code=404, content={"status": "error", "message": reason})
 
-    requested = parse_pipe_points((payload or {}).get("points"))
+    try:
+        requested = parse_pipe_points((payload or {}).get("points"))
+    except ValueError as error:  # 집계 항목(summary_item) 모양이 틀림
+        return JSONResponse(status_code=400, content={"status": "error", "message": str(error)})
     signature = route_signature(context.vertices)
     stored = (
         load_pipe_points(context.stored_path, signature, context.vertices) if use_stored else None
@@ -349,6 +352,11 @@ async def put_pipe_points(
         _basin_features(context, detail, points),
         context.crs,
     )
+    # 지정한 집계 항목을 프로젝트에 복사 · 안 쓰는 복사본 지움(PLAN 21-3 · 실패해도 저장 유지)
+    from common_util.common_util_storage import resolve_stored_project_path
+    from M02_MasterTemplete.M02_Item_Snapshot import safe_sync
+
+    await asyncio.to_thread(safe_sync, resolve_stored_project_path(context.stored_path))
     result = _payload(project_id, context, detail, points, saved=True)
     result["saved_count"] = saved
     return result