월말 정산 자동 적재

# 1) 어드민 백엔드의 스케줄러가 매월 1일 트리거.
#    (자체 cron · k8s CronJob · EventBridge · 백엔드 background job 어느 쪽이든)

# 2) 4개 schema 의 data-job 을 만든다. 아래는 첫 호출 예시.
curl -s -X POST https://api.h6s.ai/api/v1/data-jobs \
  -H "Authorization: Bearer $H6S_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"providerCode":"CB_KB","schema":"bank.transactions.cb.v1","params":{"dateRangeStart":"2026-04-01","dateRangeEnd":"2026-04-30"}}'
# 같은 호출을 hometax.tax-invoices.sales.v1 / .purchase.v1 / hometax.cash-receipts.sales.v1 까지 반복 (총 4건).

# 3) 각 응답의 id 로 status 가 SUCCEEDED 될 때까지 polling.
curl -s https://api.h6s.ai/api/v1/data-jobs/$JOB_ID \
  -H "Authorization: Bearer $H6S_API_KEY"

# 4) 결과(ContractRecord 배열) 수신.
curl -s https://api.h6s.ai/api/v1/data-jobs/$JOB_ID/results \
  -H "Authorization: Bearer $H6S_API_KEY"

# 5) 받은 records 를 그대로 자체 어드민 백엔드로 POST.
#    도메인 검증·중복 제거·정산 매칭은 어드민이 책임진다.
curl -s -X POST $ADMIN_INGEST_URL \
  -H "Authorization: Bearer $ADMIN_TOKEN" \
  -H "Content-Type: application/json" \
  -d "@results.json"

// monthly-ingest.mjs 파일. 어드민 백엔드의 매월 1일 cron 핸들러.
// Next.js admin route, NestJS @Cron, k8s CronJob 어디서 호출해도 동작한다.

const H6S_API_KEY = process.env.H6S_API_KEY;
const ADMIN_INGEST_URL = process.env.ADMIN_INGEST_URL;
const ADMIN_TOKEN = process.env.ADMIN_TOKEN;

const now = new Date();
const start = new Date(Date.UTC(now.getUTCFullYear(), now.getUTCMonth() - 1, 1));
const end = new Date(Date.UTC(start.getUTCFullYear(), start.getUTCMonth() + 1, 0));
const iso = (d) => d.toISOString().slice(0, 10);
const month = iso(start).slice(0, 7);

const jobs = [
  { providerCode: "CB_KB",   schema: "bank.transactions.cb.v1" },
  { providerCode: "HOMETAX", schema: "hometax.tax-invoices.sales.v1" },
  { providerCode: "HOMETAX", schema: "hometax.tax-invoices.purchase.v1" },
  { providerCode: "HOMETAX", schema: "hometax.cash-receipts.sales.v1" },
];

const h6s = (path, init = {}) =>
  fetch(`https://api.h6s.ai/api/v1${path}`, {
    ...init,
    headers: {
      Authorization: `Bearer ${H6S_API_KEY}`,
      "Content-Type": "application/json",
      ...(init.headers ?? {}),
    },
  }).then(async (r) => {
    if (!r.ok) throw new Error(`${r.status} ${await r.text()}`);
    return r.json();
  });

const wait = (ms) => new Promise((r) => setTimeout(r, ms));

for (const { providerCode, schema } of jobs) {
  const created = await h6s("/data-jobs", {
    method: "POST",
    body: JSON.stringify({
      providerCode,
      schema,
      params: { dateRangeStart: iso(start), dateRangeEnd: iso(end) },
    }),
  });

  let status = created.status;
  while (status !== "SUCCEEDED" && status !== "FAILED") {
    await wait(5_000);
    ({ status } = await h6s(`/data-jobs/${created.id}`));
  }
  if (status === "FAILED") throw new Error(`${schema} job ${created.id} failed`);

  const { results } = await h6s(`/data-jobs/${created.id}/results`);

  await fetch(ADMIN_INGEST_URL, {
    method: "POST",
    headers: {
      Authorization: `Bearer ${ADMIN_TOKEN}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({ schema, month, records: results }),
  });
}