diff --git a/app/modules/malaysia/README.md b/app/modules/malaysia/README.md index 1478771..3215ba9 100644 --- a/app/modules/malaysia/README.md +++ b/app/modules/malaysia/README.md @@ -43,6 +43,20 @@ cupang 모듈과 동일한 패턴: **malaysia_stock_db(PostgreSQL) 전용**, JSO 예) `MT-0320` 낱개 100 + `MY-0002`(MT-0320 1개 포함) 20세트 → `MT-0320` total = **120**. > 낱개 입력 시 **세트 안에 든 건 빼고** 낱개 보관분만 입력한다. 세트 안 상품은 BOM 으로 자동 계산. +### 랙(rack) 입력 — 재고조사 상세 + +재고조사 상세는 평면 수량 그리드 대신 **창고 랙 그림(A/B 두 면, 각 3행×3열×2분할 = 36칸)** +으로 입력한다. 각 칸에 `아이템 · 박스당 입수량 · 박스 수`를 넣고, 한 칸에 여러 아이템은 +`+` 로 행을 추가한다. 저장하면 서버가 SKU별로 + +``` +qty = SUM(units_per_box × box_count) +``` + +집계해 `daily_stocktake_line`을 **재생성**한다(랙이 라인의 단일 출처). 낱개·콤보(MY-) +모두 랙에 입력 가능하며, 이후 분해/확정 로직(`compute_result`/`finalize`)은 라인 기준으로 +기존과 동일하게 동작한다. 칸 코드 형식: `{면}{행}-{열}-{분할}` (예 `A3-1-1`). + --- ## 테이블 (`scripts/sql/malaysia_stock_db_init.sql`) @@ -54,7 +68,8 @@ cupang 모듈과 동일한 패턴: **malaysia_stock_db(PostgreSQL) 전용**, JSO | `set_bom` | 세트 구성표. `UNIQUE(set_code, component_code)`. prefix CHECK 내장 | | `stock_movement` | 입고/출고/조정/조사 이력. `item_code` 는 낱개만(CHECK) | | `daily_stocktake` | 재고조사 헤더. 같은 날짜+창고 finalized 1건(부분 유니크) | -| `daily_stocktake_line` | 조사 라인. `sku_code` 낱개+세트 허용, `UNIQUE(stocktake_id, sku_code)` | +| `daily_stocktake_line` | 조사 라인(SKU별 최종 qty). 랙 입력 집계로 **재생성**됨. `UNIQUE(stocktake_id, sku_code)` | +| `daily_stocktake_rack` | 랙 칸별 입력(셀×SKU×입수량×박스수). 라인의 단일 출처. `cell_code` 예 `A3-1-1` | 검증 규칙(요구사항 8)은 **DB CHECK + 서비스 레이어(`store.py`)** 양쪽에 걸려 있다. @@ -75,6 +90,7 @@ JSON API: | POST | `/malaysia/api/movements` | 낱개 movement 등록 | | POST | `/malaysia/api/movements/set-out` | 세트 출고(BOM 분해) | | GET | `/malaysia/api/stocktakes/{id}/result` | 재고조사 최종 계산 | +| POST | `/malaysia/stocktakes/{id}/rack/bulk` | 랙 입력 일괄 저장(병렬배열 `rk_cell/rk_sku/rk_upb/rk_box`) → 라인 재생성 | --- @@ -92,6 +108,8 @@ cd /opt/www/main && docker compose up -d --build ``` > 멱등 스크립트. 기존 DB 가 있으면 DROP 하지 않음. itemcode_db 는 건드리지 않음. +> **랙 입력 추가(`daily_stocktake_rack`)** 후 기존 운영 DB 에 반영하려면 위 init 스크립트를 +> 그대로 1회 재실행한다(`CREATE TABLE IF NOT EXISTS` + grant 만 적용, 기존 데이터 보존). ## 테스트 diff --git a/app/modules/malaysia/db.py b/app/modules/malaysia/db.py index 7e8cb30..a04e0c4 100644 --- a/app/modules/malaysia/db.py +++ b/app/modules/malaysia/db.py @@ -579,6 +579,93 @@ class MalaysiaStockStore: if cur.rowcount == 0: raise KeyError(line_id) + # ════════════════════════════════════════════════════════════ + # 재고조사 랙(rack) 입력 (daily_stocktake_rack) + # 랙 칸 단위로 SKU×입수량×박스수 를 저장하고, 그 집계로 + # daily_stocktake_line(SKU별 qty)을 재생성한다(랙이 라인의 단일 출처). + # ════════════════════════════════════════════════════════════ + def list_rack_entries(self, *, stocktake_id: int) -> list[dict[str, Any]]: + """재고조사의 랙 입력 항목 전체. 칸→순서대로 정렬.""" + with self._pool.connection() as conn: + rows = conn.execute( + "SELECT * FROM daily_stocktake_rack WHERE stocktake_id = %s " + "ORDER BY cell_code ASC, line_no ASC, id ASC", + (stocktake_id,), + ).fetchall() + return [self._serialize(r) for r in rows] + + def replace_rack( + self, *, stocktake_id: int, entries: list[dict[str, Any]] + ) -> dict[str, Any]: + """랙 입력 전체 교체 → SKU별 집계로 재고조사 라인 재생성. + + entries: [{"cell_code","sku_code","units_per_box","box_count"}, ...] + (입력 순서가 칸 안 line_no 가 된다.) + 한 트랜잭션: + 1) 기존 랙 항목 + 라인 전체 삭제 + 2) 검증한 랙 항목 삽입(칸별 line_no 부여) + 3) aggregate_rack 결과를 daily_stocktake_line 으로 삽입 + draft 가 아니면 ValueError. 알 수 없는 칸/코드도 ValueError. + """ + valid_cells = set(store.rack_cell_codes()) + clean: list[tuple[str, str, int, int]] = [] + for e in entries: + cell = (e.get("cell_code") or "").strip().upper() + if cell not in valid_cells: + raise ValueError(f"알 수 없는 랙 위치: {cell or '(빈값)'}") + code = store.validate_stocktake_code(str(e.get("sku_code") or "")) + upb = store.validate_qty( + e.get("units_per_box"), allow_zero=False, allow_negative=False + ) + box = store.validate_qty( + e.get("box_count"), allow_zero=False, allow_negative=False + ) + clean.append((cell, code, upb, box)) + + totals = store.aggregate_rack( + [ + {"sku_code": c, "units_per_box": u, "box_count": b} + for (_cell, c, u, b) in clean + ] + ) + + cell_seq: dict[str, int] = {} + with self._pool.connection() as conn: + with conn.transaction(): + self._assert_draft(conn, stocktake_id) + conn.execute( + "DELETE FROM daily_stocktake_rack WHERE stocktake_id = %s", + (stocktake_id,), + ) + conn.execute( + "DELETE FROM daily_stocktake_line WHERE stocktake_id = %s", + (stocktake_id,), + ) + for cell, code, upb, box in clean: + ln = cell_seq.get(cell, 0) + cell_seq[cell] = ln + 1 + conn.execute( + """ + INSERT INTO daily_stocktake_rack + (stocktake_id, cell_code, line_no, sku_code, + units_per_box, box_count) + VALUES (%s,%s,%s,%s,%s,%s) + """, + (stocktake_id, cell, ln, code, upb, box), + ) + for code in sorted(totals.keys()): + qty = totals[code] + if qty <= 0: + continue + conn.execute( + """ + INSERT INTO daily_stocktake_line (stocktake_id, sku_code, qty) + VALUES (%s,%s,%s) + """, + (stocktake_id, code, qty), + ) + return {"entries": len(clean), "lines": {k: v for k, v in totals.items() if v > 0}} + def cancel_stocktake(self, *, stocktake_id: int) -> dict[str, Any]: with self._pool.connection() as conn: row = conn.execute( diff --git a/app/modules/malaysia/router.py b/app/modules/malaysia/router.py index fd44540..52b4a00 100644 --- a/app/modules/malaysia/router.py +++ b/app/modules/malaysia/router.py @@ -468,14 +468,19 @@ async def stocktake_detail(request: Request, stocktake_id: int) -> HTMLResponse: wh = head["warehouse_code"] # 입력된 라인 qty 를 코드별 dict 로 (그리드 기본값) entered = {ln["sku_code"]: ln["qty"] for ln in head.get("lines", [])} + # 랙 입력 항목을 칸별로 묶어 전달(그림 안 입력행 복원용) + rack_by_cell: dict[str, list[dict[str, Any]]] = {} + for e in st.list_rack_entries(stocktake_id=stocktake_id): + rack_by_cell.setdefault(e["cell_code"], []).append(e) ctx = _base_ctx(request, user, st, wh=wh) ctx.update( { "page_title": f"재고조사 #{stocktake_id}", "page_subtitle": f"{head['stocktake_date']} · {wh} · {head['status']}", "stocktake": head, - "individual_items": st.list_items(kind="individual"), - "set_items": st.list_items(kind="set"), + "rack_layout": store.rack_layout(), + "rack_by_cell": rack_by_cell, + "rack_items": st.list_items(), "entered": entered, "result_rows": computed["rows"], "missing_bom": computed["missing_bom"], @@ -517,6 +522,48 @@ async def stocktake_lines_bulk( return RedirectResponse(url=f"/malaysia/stocktakes/{stocktake_id}", status_code=303) +@router.post("/stocktakes/{stocktake_id:int}/rack/bulk") +async def stocktake_rack_bulk( + request: Request, stocktake_id: int, user: dict[str, Any] = Depends(_require_user) +) -> RedirectResponse: + """랙 입력 일괄 저장. + + form 병렬 배열: rk_cell[], rk_sku[], rk_upb[], rk_box[] (DOM 순서 유지). + SKU 미선택/입수량·박스수 ≤ 0 인 행은 스킵(미입력 행 취급). + 저장 시 랙 항목 교체 + SKU별 집계로 daily_stocktake_line 재생성. + """ + st = _store(request) + if st is None: + raise HTTPException(status_code=503, detail="malaysia_stock_db 미설정") + form = await request.form() + cells = form.getlist("rk_cell") + skus = form.getlist("rk_sku") + upbs = form.getlist("rk_upb") + boxes = form.getlist("rk_box") + entries: list[dict[str, Any]] = [] + for cell, sku, upb, box in zip(cells, skus, upbs, boxes): + code = str(sku or "").strip() + if not code: + continue + try: + u = int(str(upb).strip() or 0) + b = int(str(box).strip() or 0) + except ValueError: + continue + if u <= 0 or b <= 0: + continue + entries.append( + {"cell_code": cell, "sku_code": code, "units_per_box": u, "box_count": b} + ) + try: + st.replace_rack(stocktake_id=stocktake_id, entries=entries) + except KeyError: + raise HTTPException(status_code=404, detail="재고조사를 찾을 수 없습니다.") + except ValueError as exc: + raise HTTPException(status_code=400, detail=str(exc)) + return RedirectResponse(url=f"/malaysia/stocktakes/{stocktake_id}", status_code=303) + + @router.post("/stocktakes/{stocktake_id:int}/lines/{line_id:int}/delete") async def stocktake_line_delete( request: Request, stocktake_id: int, line_id: int, diff --git a/app/modules/malaysia/store.py b/app/modules/malaysia/store.py index 6ed312f..08d44e0 100644 --- a/app/modules/malaysia/store.py +++ b/app/modules/malaysia/store.py @@ -27,6 +27,66 @@ INDIVIDUAL_PREFIXES: tuple[str, ...] = ("MT-", "MX-", "MZ-") SET_PREFIX: str = "MY-" BLOCKED_PREFIX: str = "MD-" # 뚜껑 — 재고관리 대상에서 제외 +# ── 창고 랙 레이아웃 (재고조사 랙 입력용) ── +# 그림 고정: A/B 두 면, 각 면 3행 × 3열, 각 열은 2분할 → 면당 18칸, 총 36칸. +# 행은 위→아래로 3,2,1 (그림과 동일). 칸 코드: '{면}{행}-{열}-{분할}' 예) A3-1-1. +RACK_SIDES: tuple[str, ...] = ("A", "B") +RACK_ROWS: tuple[int, ...] = (3, 2, 1) +RACK_COLS: tuple[int, ...] = (1, 2, 3) +RACK_SUBS: tuple[int, ...] = (1, 2) + + +def rack_cell_codes() -> list[str]: + """모든 랙 칸 코드 목록(검증용). 예: 'A3-1-1' ... 'B1-3-2'.""" + return [ + f"{side}{row}-{col}-{sub}" + for side in RACK_SIDES + for row in RACK_ROWS + for col in RACK_COLS + for sub in RACK_SUBS + ] + + +def rack_layout() -> list[dict[str, Any]]: + """템플릿 렌더용 중첩 구조. + + [{"side":"A","rows":[{"row":3,"cols":[["A3-1-1","A3-1-2"], ...]}, ...]}, ...] + """ + out: list[dict[str, Any]] = [] + for side in RACK_SIDES: + rows: list[dict[str, Any]] = [] + for row in RACK_ROWS: + cols = [ + [f"{side}{row}-{col}-{sub}" for sub in RACK_SUBS] + for col in RACK_COLS + ] + rows.append({"row": row, "cols": cols}) + out.append({"side": side, "rows": rows}) + return out + + +def aggregate_rack(entries: Iterable[dict[str, Any]]) -> dict[str, int]: + """랙 입력 항목을 SKU 코드별 총수량으로 집계. + + 각 항목: {"sku_code", "units_per_box", "box_count"}. + qty = SUM(units_per_box * box_count). 입수량/박스수 ≤ 0 또는 코드 공백은 스킵. + 반환: { sku_code: total_qty } (낱개·세트 코드 모두 포함 가능) + """ + totals: dict[str, int] = {} + for e in entries: + code = _norm(e.get("sku_code")) + if not code: + continue + try: + upb = int(e.get("units_per_box") or 0) + box = int(e.get("box_count") or 0) + except (TypeError, ValueError): + continue + if upb <= 0 or box <= 0: + continue + totals[code] = totals.get(code, 0) + upb * box + return totals + # ════════════════════════════════════════════════════════════ # 코드 분류 / 검증 (순수 함수) diff --git a/app/modules/malaysia/templates/malaysia/_i18n.html b/app/modules/malaysia/templates/malaysia/_i18n.html index 8904b2a..99b29e7 100644 --- a/app/modules/malaysia/templates/malaysia/_i18n.html +++ b/app/modules/malaysia/templates/malaysia/_i18n.html @@ -2,4 +2,4 @@