f29e9723b0
schedules/anchoring — backend 를 import 하지 않는 독립 컨테이너 배치 서비스.
회사 × 협력사유형(1유통/2제조/3총판) × 가격구간(3,000원, 33,334칸)별 앵커링
값(정수 천분율)을 격주 토 00:00 KST 에 협상 성공률로 자동 조정한다.
- 판정 = "가격 흔적" 기준: last_offered_price 가 있는 종료 재협상만 표본,
DONE & bid ≤ 박제 앵커만 성공, 나머지(초과 합의·결렬·가격 쓰고 이탈) 실패.
앵커는 비노출(엔진 내부 체결 임계) — agent 무변경
- 저장 = anchoring.rate_adjustments 1개(append-only, consumed_session_ids 박제),
소비 경계 = sessions.anchoring_adjustment_id 마킹(멱등·이월). DDL 은 모듈
소유(schema.sql, sessions 3컬럼 ALTER 포함)
- 안정성: 조정 INSERT+마킹 한 트랜잭션 + rowcount 불일치 전체 롤백,
Redis TTL 7일 + 매주 조정 칸 re-SET, socket timeout 0.3s, DB 폴백,
가격 제시율 0% WARN, --once 수동 캐치업
- 정적 기본 테이블(전 구간 10‰, 상한 정확히 1억·초과분 마지막 인덱스 클램프)
기동 검증 실패 시 기동 중단
- 전체 async(SQLAlchemy+asyncpg, redis.asyncio) — negodata 가 reader 를 그대로
이식 가능(docs/인수인계.md). 최종 문서 docs/{개발용,기획용,워크플로우}.md
- 테스트 15종: 골든 벡터(§11) + DB 통합(멱등·이월·격리·rowcount 롤백)
Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
40 lines
2.6 KiB
SQL
40 lines
2.6 KiB
SQL
-- ============================================================
|
|
-- anchoring 모듈 DDL (모듈 소유 — postgres-init 에 두지 않는다)
|
|
-- 적용: psql -h <host> -U <user> -d negosium_db -f schema.sql
|
|
-- 신규 DB 구축 순서: postgres-init/01~04 → 이 파일
|
|
-- 규범: docs/개발용.md §6. IF NOT EXISTS 라 재적용 안전.
|
|
-- 컨벤션: FK/CHECK/PG ENUM 없음, SMALLINT 코드, uuid 키, TIMESTAMPTZ(UTC).
|
|
-- ============================================================
|
|
\connect negosium_db
|
|
|
|
CREATE SCHEMA IF NOT EXISTS anchoring;
|
|
|
|
-- 앵커링 값 조정 이력. append-only — UPDATE/DELETE 금지(§5), updated_at/deleted 의도적 생략.
|
|
CREATE TABLE IF NOT EXISTS anchoring.rate_adjustments (
|
|
id BIGSERIAL PRIMARY KEY,
|
|
company_id uuid NOT NULL, -- 테넌트(partner.items.company_id 유래)
|
|
supplier_type SMALLINT NOT NULL, -- 1=유통(δ20) 2=제조(δ10) 3=총판(δ15)
|
|
price_bracket_index INTEGER NOT NULL, -- 가격구간 0..33333 (앱 보장)
|
|
nego_count INTEGER NOT NULL, -- 유효 표본 수 n (>=10, 앱 보장)
|
|
success_count INTEGER NOT NULL, -- n 중 성공(BID_SUCCESS) 건수
|
|
anchor_rate_before SMALLINT NOT NULL, -- 직전 값(‰) (이력 없었으면 정적 테이블 시작값)
|
|
anchor_rate_after SMALLINT NOT NULL, -- 조정 후 값(‰), clamp [10,200] 앱 보장
|
|
consumed_session_ids JSONB NOT NULL, -- 소비한 세션 uuid 배열(창 박제 — 재현성·감사)
|
|
created_at TIMESTAMPTZ NOT NULL DEFAULT now()
|
|
);
|
|
|
|
-- 현재 값 조회 최적화: 칸별 최신 조정
|
|
CREATE INDEX IF NOT EXISTS idx_rate_adjustments_cell
|
|
ON anchoring.rate_adjustments (company_id, supplier_type, price_bracket_index, id DESC);
|
|
|
|
-- 선행요건 §13 + 소비 마킹. target_anchoring_price 는 기존 컬럼(negodata 가 생성 시 박제).
|
|
ALTER TABLE negotiation.sessions
|
|
ADD COLUMN IF NOT EXISTS anchor_rate_permille SMALLINT NULL, -- 제안 당시 rate(‰) 박제
|
|
ADD COLUMN IF NOT EXISTS last_offered_price BIGINT NULL, -- 협력사 마지막 제시가(원) — 가격 입력마다 backend 가 갱신, 종료 후 불변. NULL=가격 흔적 없음(표본 제외)
|
|
ADD COLUMN IF NOT EXISTS anchoring_adjustment_id BIGINT NULL; -- NULL=미처리 0=제외확정 >0=소비한 조정 id
|
|
|
|
-- 배치 스캔 최적화: 미처리 세션만 (부분 인덱스)
|
|
CREATE INDEX IF NOT EXISTS idx_sessions_anchoring_pending
|
|
ON negotiation.sessions (qt_type, status)
|
|
WHERE anchoring_adjustment_id IS NULL AND deleted = false;
|