ingest-jobs 接口文档

用于将外部岗位数据写入最新岗位模型：

• job_posts
• job_post_contents
• job_post_contacts（电话/邮箱，独立私有存储）
• job_post_compensations
• job_post_requirements
• job_post_locations
• job_post_work_types / job_post_visas / job_post_benefits / job_post_tags

1. 接口信息

• 方法: POST
• 地址: /functions/v1/ingest-jobs
• 鉴权: HMAC 签名（verify_jwt = false）
• 时间容忍: 5 分钟（x-timestamp 与服务端当前时间差）

2. 请求头

3. 请求体格式

支持以下 3 种：

• { "jobs": [ ... ] }
• [ ... ]
• 单个 job 对象 { ... }

4. Job 字段说明

先看 6 条关键规则：

1. 幂等键是 source_channel + external_ref。
   同一组合重复推送会更新同一条岗位；如果不传 external_ref，系统自动生成，可能导致重复岗位。

2. title、description、region_code、salary_min、salary_type_code、work_type_codes、occupation_codes、contact_phone/contact_email(二选一) 是核心字段。
   这些不满足会被判为 invalid。

3. 所有 *_code 都必须能在 taxonomy 中查到。
   比如 region_code 必须存在于 region 分类。

4. 不再兼容旧字段。
   传入 visa_types/benefits/tags/korean_req/salary_display/salary_type/work_type 会直接返回错误。

5. description 与 duties 不会被接口自动拆分、合并或去重。
   description 原样写入 job_post_contents.description_i18n，duties 原样写入 job_post_contents.duties_i18n；若两者都传且内容重复，系统也会按两个字段分别保存。

6. 联系方式会独立私有存储。
   contact_phone/contact_email 会写入 job_post_contacts（不在 job_post_contents 持久化）；前端“立即联系”应按需调用 get_job_post_contact 获取。

字段中 i18n object 示例建议包含 4 国语言：{ "zh": "中文", "ko": "한국어", "vi": "Tiếng Việt", "ru": "Русский" }。
所有 string / i18n object 字段传 string 时，都会先按 zh 文本处理，也就是转成 { "zh": "..." }。
注意：文档里说的“补齐”不是自动翻译。当前只有 title 会在缺少 zh/ko/vi/ru 任一键时，用已有文本原样回填到这 4 个必填语言键中以通过校验；summary、description、duties 等其他 i18n 字段不会自动补齐，也不会自动翻译。

description 与 duties 推荐写法：

• description：写岗位上下文与范围，例如“韩企电子厂两班倒，主要在 SMT 产线作业，需要可长期站立。”
• duties：写动作型职责，例如“按 SOP 装配、完成首件自检、与线长交接异常。”
• description 必填；duties 选填。若来源数据无法区分，建议先保证 description 充分，再补充 duties 的动作项。

联系方式安全模型：

• 入参侧：contact_phone 与 contact_email 二选一必填（可同时传）。
• 存储侧：电话/邮箱写入 job_post_contacts，与 job_posts 一对一；不在 job_post_contents 中持久化。
• 读取侧：用户端点击“立即联系”时，调用 RPC get_job_post_contact(p_job_post_id) 按需获取。
• contact_note 仅用于补充说明（如联系时间、注意事项），不替代电话/邮箱字段。

Taxonomy 依赖字段（字段名 + 备注）：

补充规则：

• 上述 code 来自 public.taxonomy_items.code，并按所属 public.taxonomies.code 分类校验。
• 仅 is_active = true 的 taxonomy item 可用。
• 传入不存在/已停用 code 会返回 invalid（例如 region_code invalid: xxx）。

9 类 taxonomy 可用 code 与注释（当前）：

• 覆盖字段：region_code、salary_type_code、work_type_codes、visa_codes、benefit_codes、tag_codes、occupation_codes、education_code、experience_code。
• 数据来源：supabase/migrations/02_seed_taxonomies.sql（初始化种子）+ supabase/migrations/17_job_occupations_and_bundle_update.sql、supabase/migrations/21_expand_occupation_taxonomy.sql（岗位分类扩充）；运行时仍以数据库中 is_active = true 的 taxonomy_items 为准。

region（地区，字段：region_code）

salary_type（薪资类型，字段：salary_type_code）

work_type（工作类型，字段：work_type_codes）

visa（签证类型，字段：visa_codes）

benefit（福利待遇，字段：benefit_codes）

tag（职位标签，字段：tag_codes）

occupation（岗位分类，字段：occupation_codes）

若需要最新列表，可通过接口拉取：/rest/v1/taxonomy_items?select=code,label_i18n&taxonomies.code=eq.occupation&is_active=eq.true。

education（学历要求，字段：education_code）

experience（经验要求，字段：experience_code）

最小可用 payload（建议）：

• 至少包含：title + description + (contact_phone 或 contact_email) + region_code + salary_min + salary_type_code + work_type_codes + occupation_codes。

{
  "jobs": [
    {
      "source_channel": "crawler",
      "publisher_type": "organization",
      "company_name": { "zh": "安山电子厂", "ko": "안산 전자공장", "vi": "Nha may dien tu Ansan", "ru": "Завод электроники Ансан" },
      "title": { "zh": "电子厂装配工", "ko": "전자공장 조립원", "vi": "Cong nhan lap rap nha may dien tu", "ru": "Сборщик на электронном заводе" },
      "description": { "zh": "负责电子部件装配与基础质检，白夜两班制。", "ko": "전자 부품 조립 및 기초 검사, 주야 2교대." },
      "contact_phone": "010-1234-5678",
      "region_code": "gyeonggi",
      "salary_min": 120000,
      "salary_type_code": "daily",
      "work_type_codes": ["daily"],
      "occupation_codes": ["factory_assembly"]
    }
  ]
}

全字段详细 payload（示例）：

{
  "jobs": [
    {
      "external_ref": "api-ansan-assembly-20260308-day-001",
      "source_channel": "api",
      "status": "active",
      "visibility": "public",
      "publisher_type": "organization",
      "company_name": {
        "zh": "安山汽车电子厂（直招）",
        "ko": "안산 자동차 전자공장(직영)",
        "vi": "Nha may dien tu o to Ansan (tuyen truc tiep)",
        "ru": "Завод автоэлектроники в Ансане (прямой набор)"
      },
      "organization_slug": "ansan-auto-electronics-direct",
      "brand_name": "Ansan E-Mobility Plant",
      "country_code": "KR",
      "title": {
        "zh": "电子零件装配/质检作业员（可当天面试）",
        "ko": "전자부품 조립·검사 사원(당일 면접 가능)",
        "vi": "Nhan vien lap rap/kiem tra linh kien dien tu (phong van trong ngay)",
        "ru": "Сборщик/контролер электронных компонентов (собеседование в день обращения)"
      },
      "summary": {
        "zh": "韩企直招，提供宿舍与通勤车，可当天安排面试和试岗",
        "ko": "한국 기업 직영 채용, 기숙사/통근버스 제공, 당일 면접 및 시범근무 가능",
        "vi": "Tuyen truc tiep, co ky tuc xa va xe dua don, phong van va thu viec trong ngay",
        "ru": "Прямой набор, общежитие и шаттл, собеседование и пробная смена в тот же день"
      },
      "description": {
        "zh": "安山汽车电子工厂装配线岗位，主要负责连接器与线束预装。恒温车间站立作业，实行两班倒（白班/夜班），入职前提供半天安全培训与岗位示教。",
        "ko": "안산 자동차 전자공장 조립라인 포지션으로 커넥터/와이어 하네스 사전 조립을 담당합니다. 항온 작업장 입식 근무, 주야 2교대이며 입사 전 안전교육을 제공합니다.",
        "vi": "Vi tri day chuyen lap rap tai nha may dien tu o to Ansan, phu trach lap rap truoc bo noi va day dien. Lam dung trong xuong dieu hoa, xoay ca ngay-dem, duoc dao tao an toan truoc khi nhan viec.",
        "ru": "Позиция на линии сборки автоэлектроники в Ансане: предварительная сборка разъемов и жгутов. Работа стоя в климатизированном цехе, дневные/ночные смены, вводный инструктаж перед выходом."
      },
      "duties": {
        "zh": "1) 按SOP完成零件装配与外观初检；2) 记录不良并与线长交接；3) 按节拍完成工位5S、物料点收和交班。",
        "ko": "1) SOP에 따라 부품 조립 및 외관 1차 검사 수행; 2) 불량 내역 기록 후 라인장 인계; 3) 공정 속도에 맞춰 5S/자재 확인/교대 인수인계 진행.",
        "vi": "1) Lap rap va kiem tra ngoai quan theo SOP; 2) Ghi nhan loi va ban giao cho truong chuyen; 3) Thuc hien 5S, kiem dem vat tu va ban giao ca theo nhip san xuat.",
        "ru": "1) Сборка и первичный визуальный контроль по SOP; 2) фиксация дефектов и передача мастеру линии; 3) выполнение 5S, прием материалов и передача смены по такту."
      },
      "working_hours": {
        "zh": "白班 08:30-17:30 / 夜班 20:30-05:30（通常加班2小时，休息共90分钟）",
        "ko": "주간 08:30-17:30 / 야간 20:30-05:30 (통상 연장 2시간, 총 휴게 90분)",
        "vi": "Ca ngay 08:30-17:30 / ca dem 20:30-05:30 (thuong tang ca 2 gio, nghi tong 90 phut)",
        "ru": "Дневная 08:30-17:30 / ночная 20:30-05:30 (обычно +2 часа переработки, перерывы 90 минут)"
      },
      "location_note": {
        "zh": "安山站2号口有班车10分钟直达，园区内配食堂、更衣室、休息区",
        "ko": "안산역 2번 출구 셔틀버스 10분, 단지 내 식당/탈의실/휴게공간 제공",
        "vi": "Tu cong so 2 ga Ansan co xe dua don 10 phut, trong khu co canteen, phong thay do va khu nghi",
        "ru": "От выхода 2 станции Ансан есть шаттл (10 минут), на территории столовая, раздевалки и зона отдыха"
      },
      "contact_phone": "010-1234-5678",
      "contact_email": "demo.hr.contact+001@gmail.com",
      "contact_note": {
        "zh": "工作日 09:00-18:00 电话/微信同号；报名请备注签证类型、韩语等级和可到岗日期",
        "ko": "평일 09:00-18:00 전화 문의 가능; 지원 시 비자 유형/한국어 수준/출근 가능일 기재",
        "vi": "Lien he ngay thuong 09:00-18:00; khi dang ky vui long ghi loai visa, trinh do tieng Han va ngay co the di lam",
        "ru": "Связь по будням 09:00-18:00; при отклике укажите тип визы, уровень корейского и дату выхода"
      },
      "salary_type_code": "daily",
      "salary_min": 120000,
      "salary_max": 180000,
      "salary_currency": "KRW",
      "salary_display_text": "日结 12万~18万韩元（夜班/加班津贴另算）",
      "salary_is_negotiable": false,
      "region_code": "gyeonggi",
      "address_line": "경기도 안산시 단원구 원시동 774-3 (안산스마트허브 5공단)",
      "latitude": 37.3215,
      "longitude": 126.8302,
      "work_type_codes": ["long_term", "daily"],
      "visa_codes": ["h2", "f4", "f2"],
      "benefit_codes": ["food_stay", "shuttle", "overtime_pay", "night_pay", "insurance"],
      "tag_codes": ["factory", "daily_pay", "immediate_start", "no_experience"],
      "occupation_codes": ["factory_assembly"],
      "korean_level_min": 1,
      "education_code": "high_school",
      "experience_code": "none",
      "requirement_notes": {
        "zh": "可接受站班与重复性作业；需提供在韩合法居留证明；无色弱色盲。",
        "ko": "입식/반복 작업 가능자, 한국 내 합법 체류 증빙 필요, 색약/색맹 불가.",
        "vi": "Chap nhan lam dung va cong viec lap lai, can chung minh cu tru hop phap, khong mu mau.",
        "ru": "Готовность к работе стоя и повторяющимся операциям; требуется легальный статус пребывания; без нарушений цветоощущения."
      }
    }
  ]
}

5. 成功响应

{
  "ok": true,
  "received": 1,
  "accepted": 1,
  "invalidCount": 0,
  "invalid": [],
  "processed": [
    {
      "job_post_id": 8,
      "external_ref": "demo-001",
      "source_channel": "seed",
      "publisher_type": "organization",
      "status": "active"
    }
  ]
}

6. 错误码

7. 请求示例（Node.js）

import crypto from 'node:crypto'

const url = 'https://<project-ref>.supabase.co/functions/v1/ingest-jobs'
const secret = process.env.INGEST_JOBS_SECRET!
const timestamp = Date.now().toString()

const body = JSON.stringify({
  jobs: [
    {
      external_ref: 'api-ansan-assembly-20260308-day-001',
      source_channel: 'api',
      publisher_type: 'organization',
      company_name: { zh: '安山汽车电子厂（直招）', ko: '안산 자동차 전자공장(직영)', vi: 'Nha may dien tu o to Ansan (tuyen truc tiep)', ru: 'Завод автоэлектроники в Ансане (прямой набор)' },
      title: { zh: '电子零件装配/质检作业员（可当天面试）', ko: '전자부품 조립·검사 사원(당일 면접 가능)', vi: 'Nhan vien lap rap/kiem tra linh kien dien tu (phong van trong ngay)', ru: 'Сборщик/контролер электронных компонентов (собеседование в день обращения)' },
      summary: { zh: '韩企直招，提供宿舍与通勤车，可当天安排面试和试岗', ko: '한국 기업 직영 채용, 기숙사/통근버스 제공, 당일 면접 및 시범근무 가능', vi: 'Tuyen truc tiep, co ky tuc xa va xe dua don, phong van va thu viec trong ngay', ru: 'Прямой набор, общежитие и шаттл, собеседование и пробная смена в тот же день' },
      description: { zh: '安山汽车电子工厂装配线岗位，主要负责连接器与线束预装。恒温车间站立作业，实行两班倒，入职前提供安全培训。', ko: '안산 자동차 전자공장 조립라인 포지션, 항온 작업장 입식 근무, 주야 2교대, 입사 전 안전교육 제공.', vi: 'Vi tri day chuyen lap rap tai nha may dien tu o to Ansan, lam dung trong xuong dieu hoa, xoay ca ngay-dem.', ru: 'Позиция на линии сборки автоэлектроники в Ансане, работа стоя в климатизированном цехе, дневные/ночные смены.' },
      duties: { zh: '按SOP完成装配与初检，记录不良并交接，完成工位5S。', ko: 'SOP 기반 조립/1차 검사, 불량 기록 및 인계, 작업장 5S 수행.', vi: 'Lap rap va kiem tra theo SOP, ghi nhan loi va ban giao, thuc hien 5S.', ru: 'Сборка и первичный контроль по SOP, фиксация дефектов и передача, выполнение 5S.' },
      working_hours: { zh: '白班 08:30-17:30 / 夜班 20:30-05:30（含加班）', ko: '주간 08:30-17:30 / 야간 20:30-05:30', vi: 'Ca ngay 08:30-17:30 / ca dem 20:30-05:30', ru: 'Дневная 08:30-17:30 / ночная 20:30-05:30' },
      region_code: 'gyeonggi',
      address_line: '경기도 안산시 단원구 원시동 774-3',
      latitude: 37.3215,
      longitude: 126.8302,
      salary_min: 120000,
      salary_max: 180000,
      salary_type_code: 'daily',
      salary_currency: 'KRW',
      salary_display_text: '日结 12万~18万韩元（夜班/加班津贴另算）',
      salary_is_negotiable: false,
      work_type_codes: ['long_term', 'daily'],
      visa_codes: ['h2', 'f4', 'f2'],
      benefit_codes: ['food_stay', 'shuttle', 'overtime_pay', 'night_pay', 'insurance'],
      tag_codes: ['factory', 'daily_pay', 'immediate_start', 'no_experience'],
      occupation_codes: ['factory_assembly'],
      korean_level_min: 1,
      education_code: 'high_school',
      experience_code: 'none',
      requirement_notes: { zh: '可接受站班与重复性作业；需提供在韩合法居留证明。', ko: '입식/반복 작업 가능자, 합법 체류 증빙 필요.', vi: 'Chap nhan lam dung va cong viec lap lai, can chung minh cu tru hop phap.', ru: 'Готовность к работе стоя и повторяющимся операциям; требуется легальный статус пребывания.' },
      status: 'active',
      visibility: 'public'
    }
  ]
})

const signature = crypto
  .createHmac('sha256', secret)
  .update(`${timestamp}.${body}`)
  .digest('base64url')

const res = await fetch(url, {
  method: 'POST',
  headers: {
    'content-type': 'application/json',
    'x-timestamp': timestamp,
    'x-signature': signature
  },
  body
})

console.log(await res.json())

8. 请求示例（Python）

import base64
import hashlib
import hmac
import json
import os
import time

import requests

url = "https://<project-ref>.supabase.co/functions/v1/ingest-jobs"
secret = os.environ["INGEST_JOBS_SECRET"]
timestamp = str(int(time.time() * 1000))

payload = {
    "jobs": [
        {
            "external_ref": "api-ansan-assembly-20260308-day-001",
            "source_channel": "api",
            "publisher_type": "organization",
            "company_name": {
                "zh": "安山汽车电子厂（直招）",
                "ko": "안산 자동차 전자공장(직영)",
                "vi": "Nha may dien tu o to Ansan (tuyen truc tiep)",
                "ru": "Завод автоэлектроники в Ансане (прямой набор)",
            },
            "title": {
                "zh": "电子零件装配/质检作业员（可当天面试）",
                "ko": "전자부품 조립·검사 사원(당일 면접 가능)",
                "vi": "Nhan vien lap rap/kiem tra linh kien dien tu (phong van trong ngay)",
                "ru": "Сборщик/контролер электронных компонентов (собеседование в день обращения)",
            },
            "description": {
                "zh": "安山汽车电子工厂装配线岗位，主要负责连接器与线束预装。",
                "ko": "안산 자동차 전자공장 조립라인 포지션, 커넥터/와이어 하네스 조립 담당.",
                "vi": "Vi tri day chuyen lap rap tai nha may dien tu o to Ansan.",
                "ru": "Позиция на линии сборки автоэлектроники в Ансане.",
            },
            "duties": {
                "zh": "按SOP完成装配与初检，记录不良并交接。",
                "ko": "SOP 기반 조립/1차 검사, 불량 기록 및 인계.",
                "vi": "Lap rap va kiem tra theo SOP, ghi nhan loi va ban giao.",
                "ru": "Сборка и первичный контроль по SOP, фиксация дефектов и передача.",
            },
            "contact_phone": "010-1234-5678",
            "region_code": "gyeonggi",
            "salary_min": 120000,
            "salary_max": 180000,
            "salary_type_code": "daily",
            "work_type_codes": ["long_term", "daily"],
            "occupation_codes": ["factory_assembly"],
            "status": "active",
            "visibility": "public",
        }
    ]
}

body = json.dumps(payload, ensure_ascii=False, separators=(",", ":"))
raw = f"{timestamp}.{body}".encode("utf-8")
digest = hmac.new(secret.encode("utf-8"), raw, hashlib.sha256).digest()
signature = base64.urlsafe_b64encode(digest).decode("utf-8").rstrip("=")

resp = requests.post(
    url,
    headers={
        "content-type": "application/json",
        "x-timestamp": timestamp,
        "x-signature": signature,
    },
    data=body.encode("utf-8"),
    timeout=30,
)

print(resp.status_code)
print(resp.json())