diff --git a/CLAUDE.md b/CLAUDE.md index 980b016..43c4f18 100644 --- a/CLAUDE.md +++ b/CLAUDE.md @@ -31,7 +31,7 @@ Claude Code는 이 저장소에서 작업을 시작하기 전에 **반드시 아 - 반품관리 - 외부 쇼핑몰 API 연동 (카페24, 네이버 스마트스토어, 사방넷 등) - 개인경비 (`app/modules/expense/`, `expense_db`) -- 쿠팡 밀크런 (`app/modules/cupang/`, `cupang_db`) — 출고 달력/상자 계산/입고센터 관리, 상품은 `itemcode_db` 읽기 전용. 출고 묶음은 **상자 계산 화면의 [분배 확정] 으로만** 만든다(신규 등록 폼 없음, `/cupang/new` 는 상자 계산으로 리다이렉트). 확정 조건: 미배분 상자 0 + 담긴 센터마다 출고방식(택배/파렛트) 선택. 확정 시 센터마다 출고 묶음 1건(`status=출고준비`, 센터입고일=출고일+1일, 상자 구성은 `cupang_shipments.box_plan` JSONB 에 스냅샷 — 혼합 상자 내용물·상자 종류 표시용) + 출고리스트 엑셀 자동 다운로드(`GET /cupang/export.xlsx?date=`, 시트명 YYYYMMDD). 양식 생성은 `app/modules/cupang/export.py` 한 곳에서 만들어 xlsx·구글시트가 공유. `CUPANG_SHEET_ID` + 인증(사용자 OAuth `GOOGLE_SHEETS_OAUTH_REFRESH_TOKEN` 또는 서비스 계정 `GOOGLE_SHEETS_CREDENTIALS[_JSON]`) 설정 시 확정과 동시에 Google 스프레드시트에 출고일 시트를 생성/덮어쓰기(`app/integrations/google_sheets.py`, 미설정이면 조용히 skip). 작업 중 상태는 `cupang_box_calc_drafts` 에 이름 붙여 임시 저장/불러오기. 쿠팡 발주 엑셀(xlsx) 다중 업로드 지원(`POST /cupang/api/box-calc/upload`, openpyxl) — F13 입고예정일의 하루 전 = 출고일, 22행부터 B=쿠팡상품코드·F=센터명·G=수량을 읽어 `cupang_products.coupang_item_code` 로 제품 매칭 후 센터별 합산 → 센터 단위로 상자 계산·자동 배분 +- 쿠팡 밀크런 (`app/modules/cupang/`, `cupang_db`) — 출고 달력/상자 계산/입고센터 관리, 상품은 `itemcode_db` 읽기 전용. 출고 묶음은 **상자 계산 화면의 [분배 확정] 으로만** 만든다(신규 등록 폼 없음, `/cupang/new` 는 상자 계산으로 리다이렉트). 확정 조건: 미배분 상자 0 + 담긴 센터마다 출고방식(택배/파렛트) 선택. 확정 시 센터마다 출고 묶음 1건(`status=출고준비`, 센터입고일=출고일+1일, 상자 구성은 `cupang_shipments.box_plan` JSONB 에 스냅샷 — 혼합 상자 내용물·상자 종류 표시용) + 출고리스트 엑셀 자동 다운로드(`GET /cupang/export.xlsx?date=`, 시트명 YYYYMMDD). 양식 생성은 `app/modules/cupang/export.py` 한 곳에서 만들어 xlsx·구글시트가 공유. `CUPANG_SHEET_ID` + 인증(사용자 OAuth `GOOGLE_SHEETS_OAUTH_REFRESH_TOKEN` 또는 서비스 계정 `GOOGLE_SHEETS_CREDENTIALS[_JSON]`) 설정 시 확정과 동시에 Google 스프레드시트에 출고일 시트를 생성/덮어쓰기(`app/integrations/google_sheets.py`, 미설정이면 조용히 skip). 출고 삭제(건별/날짜 전체) 시에도 같은 날짜 시트를 동기화 — 남은 출고가 있으면 다시 쓰고, 없으면 시트 삭제(문서에 시트가 하나뿐이면 내용만 비움). 작업 중 상태는 `cupang_box_calc_drafts` 에 이름 붙여 임시 저장/불러오기. 쿠팡 발주 엑셀(xlsx) 다중 업로드 지원(`POST /cupang/api/box-calc/upload`, openpyxl) — F13 입고예정일의 하루 전 = 출고일, 22행부터 B=쿠팡상품코드·F=센터명·G=수량을 읽어 `cupang_products.coupang_item_code` 로 제품 매칭 후 센터별 합산 → 센터 단위로 상자 계산·자동 배분 - 휴가 관리 (`app/modules/vacation/`, `vacation_db`) — 월간 달력(구글식 bar)/연차·반차 신청/승인 워크플로/공휴일·연차 설정. 권한키 `vacation`·`vacation_approver` - 말레이시아 창고 재고관리 (`app/modules/malaysia/`, `malaysia_stock_db`) — 낱개(MT/MX/MZ) 입출고·조정, 세트(MY) BOM, 일일 재고조사(세트→낱개 자동 분해), 현재고 현황. 뚜껑(MD-)은 재고 집계 제외 — 단, 창고 랙에는 위치 확인용으로 배치 가능(`store.LID_ITEMS`). 상품은 `itemcode_db` 읽기 전용. 권한키 `malaysia` - 말레이시아 배송 (`app/modules/dispatch/`, `dispatch_db`) — TikTok·Shopee 출고관리. 플랫폼별 데이터 엑셀 업로드(TikTok=03_TikTok_Order_Export.xlsx, Shopee=Packing List.Doorstep Delivery.xlsx) → 1상자=1카드 출고 작업 리스트·SKU 피킹 요약·Kagayaku 전달표 자동 생성. 1상자 묶음 기준 Package ID > Tracking ID > Order ID, 같은 상자 같은 SKU 합산. 작업 상태 토글(`dispatch_logs` 기록). 받는 사람 이름/전화/주소는 상자 단위로 저장(작업 카드 표시 + 출고 엑셀 생성용 — 개인정보). 배치 다운로드 zip 에 업로드 원본 + 취합 출고 엑셀(`YYYY.MM.DD(Ddd)_tictoc|shopee.xlsx`) 포함. 엑셀은 openpyxl 파싱/생성. 권한키 `dispatch`. 상세는 `docs/DISPATCH_MODULE.md` diff --git a/app/integrations/google_sheets.py b/app/integrations/google_sheets.py index 7a50bf8..a0c3446 100644 --- a/app/integrations/google_sheets.py +++ b/app/integrations/google_sheets.py @@ -153,6 +153,43 @@ class GoogleSheetsWriter: ).execute() return int(res["replies"][0]["addSheet"]["properties"]["sheetId"]) + def delete_sheet(self, *, spreadsheet_id: str, title: str) -> dict[str, Any]: + """이름이 정확히 일치하는 시트 1장을 삭제한다. + + - 없으면 아무것도 하지 않는다(missing). + - 문서에 시트가 그 하나뿐이면 구글이 삭제를 거부하므로, + 대신 내용을 비운다(cleared). + """ + if not self.enabled: + raise RuntimeError(self.reason or "Google Sheets 미설정") + + meta = self._service.spreadsheets().get(spreadsheetId=spreadsheet_id).execute() + sheets = meta.get("sheets", []) + target = None + for sh in sheets: + props = sh.get("properties", {}) + if props.get("title") == title: + target = int(props.get("sheetId")) + break + if target is None: + return {"ok": True, "action": "missing", "title": title} + + if len(sheets) <= 1: + self._service.spreadsheets().batchUpdate( + spreadsheetId=spreadsheet_id, + body={"requests": [ + {"unmergeCells": {"range": {"sheetId": target}}}, + {"updateCells": {"range": {"sheetId": target}, "fields": "*"}}, + ]}, + ).execute() + return {"ok": True, "action": "cleared", "title": title} + + self._service.spreadsheets().batchUpdate( + spreadsheetId=spreadsheet_id, + body={"requests": [{"deleteSheet": {"sheetId": target}}]}, + ).execute() + return {"ok": True, "action": "deleted", "title": title} + def write_table( self, *, diff --git a/app/modules/cupang/router.py b/app/modules/cupang/router.py index 58e1cc2..77bcda6 100644 --- a/app/modules/cupang/router.py +++ b/app/modules/cupang/router.py @@ -243,6 +243,53 @@ def _shipments_for_date(store: Any, ship_date: str) -> list[dict[str, Any]]: return out +def _sheet_target(store: Any) -> tuple[Any, str, dict[str, Any] | None]: + """(writer, spreadsheet_id, skip 사유) — 설정이 없으면 skip 정보를 돌려준다.""" + import os # noqa: WPS433 + + from app.integrations.google_sheets import get_writer # noqa: WPS433 + + spreadsheet_id = (os.getenv("CUPANG_SHEET_ID") or "").strip() + if not spreadsheet_id: + return None, "", {"ok": False, "skipped": True, "reason": "CUPANG_SHEET_ID 미설정"} + writer = get_writer() + if not writer.enabled: + return None, "", {"ok": False, "skipped": True, "reason": writer.reason} + return writer, spreadsheet_id, None + + +def _sync_google_sheet_after_delete(store: Any, ship_date: str) -> dict[str, Any]: + """출고 삭제 후 구글 시트를 현재 상태에 맞춘다. + + - 그날 남은 출고가 없으면 해당 날짜 시트를 삭제 + - 남아 있으면 남은 내용으로 다시 기록 + 실패해도 DB 삭제는 이미 끝났으므로 예외를 밖으로 던지지 않는다. + """ + from .export import sheet_title # noqa: WPS433 + + writer, spreadsheet_id, skip = _sheet_target(store) + if skip: + return skip + + if _shipments_for_date(store, ship_date): + return _push_to_google_sheet(store, ship_date) + + try: + res = writer.delete_sheet(spreadsheet_id=spreadsheet_id, title=sheet_title(ship_date)) + except Exception as exc: # noqa: BLE001 - 사유만 남긴다 + return {"ok": False, "skipped": False, "reason": f"{type(exc).__name__}: {exc}"} + return {"ok": True, "skipped": False, **res} + + +def _log_sheet(action: str, ship_date: str, res: dict[str, Any]) -> None: + print( # noqa: T201 - 컨테이너 로그 확인용(비밀값 없음) + f"[cupang] sheet {action} date={ship_date} ok={res.get('ok')} " + f"skipped={res.get('skipped')} detail={res.get('action', '')} " + f"reason={res.get('reason', '')}", + flush=True, + ) + + def _push_to_google_sheet(store: Any, ship_date: str) -> dict[str, Any]: """확정한 출고일을 Google 스프레드시트에 시트 1장으로 기록. @@ -250,22 +297,14 @@ def _push_to_google_sheet(store: Any, ship_date: str) -> dict[str, Any]: - 인증: 서비스 계정(app/integrations/google_sheets.py). 미설정이면 조용히 skip. - 실패해도 출고 묶음 저장은 이미 끝났으므로 예외를 밖으로 던지지 않는다. """ - import os # noqa: WPS433 - - from app.integrations.google_sheets import get_writer # noqa: WPS433 - from .export import ( # noqa: WPS433 COL_FIRST, COL_LAST, FIRST_DATA_ROW, HEADER_BG, HEADER_ROW, PALLET_BG, TITLE_ROW, WIDTHS_PX, build_table, sheet_title, ) - spreadsheet_id = (os.getenv("CUPANG_SHEET_ID") or "").strip() - if not spreadsheet_id: - return {"ok": False, "skipped": True, "reason": "CUPANG_SHEET_ID 미설정"} - - writer = get_writer() - if not writer.enabled: - return {"ok": False, "skipped": True, "reason": writer.reason} + writer, spreadsheet_id, skip = _sheet_target(store) + if skip: + return skip shipments = _shipments_for_date(store, ship_date) if not shipments: @@ -410,12 +449,17 @@ async def delete( store = _store(request) if store is None: raise HTTPException(status_code=503, detail="cupang_db 미설정") + ship = store.get_shipment(shipment_id=shipment_id, with_lines=False) + ship_date = str((ship or {}).get("ship_date") or "") try: store.soft_delete(shipment_id=shipment_id) except KeyError: raise HTTPException(status_code=404, detail="출고 묶음을 찾을 수 없습니다.") + if ship_date: + _log_sheet("sync", ship_date, _sync_google_sheet_after_delete(store, ship_date)) return RedirectResponse( - url=_safe_next(next, f"/cupang/{shipment_id}"), status_code=303 + url=_safe_next(next, f"/cupang/?date={ship_date}" if ship_date else "/cupang/"), + status_code=303, ) @@ -429,10 +473,14 @@ async def hard_delete( store = _store(request) if store is None: raise HTTPException(status_code=503, detail="cupang_db 미설정") + ship = store.get_shipment(shipment_id=shipment_id, with_lines=False) + ship_date = str((ship or {}).get("ship_date") or "") try: store.hard_delete(shipment_id=shipment_id) except KeyError: raise HTTPException(status_code=404, detail="출고 묶음을 찾을 수 없습니다.") + if ship_date: + _log_sheet("sync", ship_date, _sync_google_sheet_after_delete(store, ship_date)) return RedirectResponse(url="/cupang/", status_code=303) @@ -461,6 +509,8 @@ async def day_delete( store.soft_delete(shipment_id=ship["id"]) except KeyError: continue + # 그날 출고가 모두 사라졌으면 구글 시트의 해당 날짜 시트도 지운다. + _log_sheet("sync", day, _sync_google_sheet_after_delete(store, day)) return RedirectResponse( url=_safe_next(next, f"/cupang/?date={day}"), status_code=303 ) @@ -1428,11 +1478,7 @@ async def box_calc_confirm( # 구글 스프레드시트에 출고일 시트 기록(설정돼 있을 때만). sheet = _push_to_google_sheet(store, ship_date) - print( # noqa: T201 - 컨테이너 로그로 확인용(비밀값 없음) - f"[cupang] sheet push date={ship_date} ok={sheet.get('ok')} " - f"skipped={sheet.get('skipped')} reason={sheet.get('reason', '')}", - flush=True, - ) + _log_sheet("push", ship_date, sheet) return JSONResponse({"created": created, "ship_date": ship_date, "sheet": sheet})