Контрагенты из 1С в компании CRM

curl -s -H "X-Api-Key: $VIBE_API_KEY" "$VIBE_URL/v1/companies/fields"

const res = await fetch(`${VIBE_URL}/v1/companies/fields`, {
  headers: { 'X-Api-Key': VIBE_API_KEY },
})
const { data } = await res.json()
const strings = Object.entries(data.fields)
  .filter(([name, f]) => name.startsWith('ufCrm') && f.type === 'string')
  .map(([name, f]) => `${name} — ${f.label}`)

{
  "success": true,
  "data": {
    "fields": {
      "id": { "type": "number", "readonly": true, "label": "ID" },
      "title": { "type": "string", "readonly": false, "label": "Название", "description": "Название компании." },
      "ufCrm_1729594209": { "type": "string", "readonly": false, "label": "Код контрагента в 1С" }
    }
  }
}

curl -s -H "X-Api-Key: $VIBE_API_KEY" "$VIBE_URL/v1/onec/tools"

const res = await fetch(`${VIBE_URL}/v1/onec/tools`, {
  headers: { 'X-Api-Key': VIBE_API_KEY },
})
const { data: catalog } = await res.json()
const tool = catalog.tools.find(t => t.method === ONEC_METHOD)
const columns = tool.inputSchema.properties.columns.items.enum

{
  "success": true,
  "data": {
    "loaded": true,
    "tools": [
      {
        "method": "counterparty.list",
        "title": "Контрагенты",
        "description": "Список контрагентов",
        "inputSchema": {
          "type": "object",
          "properties": {
            "columns": {
              "type": "array",
              "items": { "type": "string", "enum": ["Код", "Наименование", "ИНН"] }
            }
          }
        }
      }
    ]
  }
}

curl -s -X POST -H "X-Api-Key: $VIBE_API_KEY" -H "Content-Type: application/json" \
  "$VIBE_URL/v1/onec/tools/counterparty.list/call" \
  -d '{ "columns": ["Код", "Наименование"], "limit": 500, "offset": 0 }'

curl -s -H "X-Api-Key: $VIBE_API_KEY" \
  "$VIBE_URL/v1/onec/operations/cl9x2k4t70000qz8h3m1vb7ry"

const queued = await fetch(`${VIBE_URL}/v1/onec/tools/${encodeURIComponent(ONEC_METHOD)}/call`, {
  method: 'POST',
  headers: { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' },
  body: JSON.stringify({ columns: [CODE_COLUMN, NAME_COLUMN], limit: 500, offset: 0 }),
}).then(res => res.json())

const result = await waitFor(queued.data.operationId)

{
  "success": true,
  "data": {
    "operationId": "cl9x2k4t70000qz8h3m1vb7ry",
    "type": "getData",
    "status": "succeeded",
    "createdAt": "2026-09-14T12:00:00.000Z",
    "finishedAt": "2026-09-14T12:00:04.000Z",
    "expiresAt": "2026-09-14T12:15:00.000Z",
    "result": {
      "columns": ["Код", "Наименование"],
      "rows": [
        { "Код": "000012", "Наименование": "ООО Север" },
        { "Код": "000013", "Наименование": "ООО Юг" }
      ],
      "truncated": true,
      "nextOffset": 2
    }
  }
}

curl -s -X POST -H "X-Api-Key: $VIBE_API_KEY" -H "Content-Type: application/json" \
  "$VIBE_URL/v1/companies/search" \
  -d '{
    "filter": { "ufCrm_1729594209": ["000012", "000013"] },
    "select": ["id", "title", "ufCrm_1729594209"],
    "limit": 50
  }'

const res = await fetch(`${VIBE_URL}/v1/companies/search`, {
  method: 'POST',
  headers: { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' },
  body: JSON.stringify({
    filter: { [CODE_FIELD]: codes },
    select: ['id', 'title', CODE_FIELD],
    limit: 50,
  }),
})
const { data: found } = await res.json()
const byCode = new Map(found.map(c => [c[CODE_FIELD], c]))

{
  "success": true,
  "data": [
    { "id": 3145, "title": "ООО Север", "ufCrm_1729594209": "000012" }
  ],
  "meta": { "total": 1, "hasMore": false, "durationMs": 277 }
}

curl -s -X POST -H "X-Api-Key: $VIBE_API_KEY" -H "Content-Type: application/json" \
  "$VIBE_URL/v1/companies" \
  -d '{ "title": "ООО Юг", "ufCrm_1729594209": "000013" }'

curl -s -X PATCH -H "X-Api-Key: $VIBE_API_KEY" -H "Content-Type: application/json" \
  "$VIBE_URL/v1/companies/3145" \
  -d '{ "title": "ООО Север-Запад" }'

const headers = { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' }

await fetch(`${VIBE_URL}/v1/companies`, {
  method: 'POST',
  headers,
  body: JSON.stringify({ title: 'ООО Юг', [CODE_FIELD]: '000013' }),
})

await fetch(`${VIBE_URL}/v1/companies/3145`, {
  method: 'PATCH',
  headers,
  body: JSON.stringify({ title: 'ООО Север-Запад' }),
})

{
  "success": true,
  "data": {
    "id": 3147,
    "title": "ООО Юг",
    "assignedById": 1,
    "createdTime": "2026-10-14T07:23:27.000Z",
    "ufCrm_1729594209": "000013"
  }
}

{
  "success": false,
  "error": {
    "code": "ONEC_NOT_CONNECTED",
    "message": "There is no 1C connection."
  }
}

// onec-counterparties.js — контрагенты 1С в компании CRM
//
// Запуск:
//   VIBE_API_KEY=… ONEC_METHOD=counterparty.list ONEC_CODE_COLUMN=Код \
//   ONEC_NAME_COLUMN=Наименование CODE_FIELD=ufCrm_1729594209 node onec-counterparties.js
const VIBE_URL = process.env.VIBE_URL ?? 'https://vibecode.bitrix24.tech'
const VIBE_API_KEY = process.env.VIBE_API_KEY
const ONEC_METHOD = process.env.ONEC_METHOD
const CODE_COLUMN = process.env.ONEC_CODE_COLUMN
const NAME_COLUMN = process.env.ONEC_NAME_COLUMN
const CODE_FIELD = process.env.CODE_FIELD                       // пользовательское поле компании под код
const ONEC_INSTANCE_ID = process.env.ONEC_INSTANCE_ID ?? null   // база 1С, если их несколько
const ONEC_FILTERS = process.env.ONEC_FILTERS ? JSON.parse(process.env.ONEC_FILTERS) : null
for (const [name, value] of Object.entries({ VIBE_API_KEY, ONEC_METHOD, CODE_COLUMN, NAME_COLUMN, CODE_FIELD })) {
  if (!value) throw new Error(`Не задана переменная окружения ${name}`)
}

const PAGE = 500
const SEARCH_CHUNK = 50
const headers = { 'X-Api-Key': VIBE_API_KEY, 'Content-Type': 'application/json' }
const query = ONEC_INSTANCE_ID ? `?instanceId=${encodeURIComponent(ONEC_INSTANCE_ID)}` : ''
const sleep = ms => new Promise(resolve => setTimeout(resolve, ms))

// 429 — запрос не принят, повторять безопасно. Пауза из Retry-After, без него растущая.
async function api(path, init = {}) {
  for (let attempt = 0; ; attempt++) {
    const res = await fetch(`${VIBE_URL}${path}`, { ...init, headers })
    const body = await res.json().catch(() => null)
    if (res.status === 429 && attempt < 5) {
      const advised = Number(res.headers.get('Retry-After'))
      await sleep((Number.isFinite(advised) && advised > 0 ? Math.min(advised, 60) : 2 ** attempt) * 1000)
      continue
    }
    if (!body?.success) {
      throw new Error(`${path}: ${body?.error?.code ?? res.status} ${body?.error?.message ?? ''}`.trim())
    }
    return body
  }
}

async function checkSetup() {
  const { data: fields } = await api('/v1/companies/fields')
  const field = fields.fields?.[CODE_FIELD]
  if (!field) throw new Error(`У компании нет поля ${CODE_FIELD}`)
  if (field.type !== 'string') throw new Error(`Поле ${CODE_FIELD} имеет тип ${field.type}, нужно «строка»`)

  const { data: catalog } = await api(`/v1/onec/tools${query}`)
  if (!catalog.loaded) throw new Error('База ещё не прислала каталог команд — администратору нужно его загрузить')
  const tool = catalog.tools.find(t => t.method === ONEC_METHOD)
  if (!tool) throw new Error(`Команды ${ONEC_METHOD} нет в каталоге базы`)
  const columns = tool.inputSchema?.properties?.columns?.items?.enum ?? []
  for (const c of [CODE_COLUMN, NAME_COLUMN]) {
    if (!columns.includes(c)) throw new Error(`Колонки «${c}» нет в команде. Доступны: ${columns.join(', ')}`)
  }
}

async function waitFor(operationId) {
  let delay = 1000
  for (;;) {
    const { data: op } = await api(`/v1/onec/operations/${operationId}`)
    if (op.status === 'succeeded') return op.result
    if (op.status === 'failed') throw new Error(`1С отказала: ${op.error?.code} ${op.error?.message ?? ''}`)
    if (op.status === 'cancelled') throw new Error('Операция отменена: отключение 1С, смена настроек или потеря доступа')
    if (op.status === 'expired') throw new Error('1С не прислала данные до expiresAt — проверьте, что база в сети')
    await sleep(delay)
    delay = Math.min(delay * 2, 5000)
  }
}

async function readPage(offset) {
  const { data: queued } = await api(`/v1/onec/tools/${encodeURIComponent(ONEC_METHOD)}/call${query}`, {
    method: 'POST',
    body: JSON.stringify({
      columns: [CODE_COLUMN, NAME_COLUMN],
      ...(ONEC_FILTERS ? { filters: ONEC_FILTERS } : {}),
      limit: PAGE,
      offset,
    }),
  })
  return waitFor(queued.operationId)
}

async function findCompanies(codes) {
  const byCode = new Map()
  for (let i = 0; i < codes.length; i += SEARCH_CHUNK) {
    const chunk = codes.slice(i, i + SEARCH_CHUNK)
    // У нескольких компаний может быть один код, поэтому страниц бывает больше одной.
    for (let offset = 0; ; ) {
      const { data, meta } = await api('/v1/companies/search', {
        method: 'POST',
        body: JSON.stringify({ filter: { [CODE_FIELD]: chunk }, select: ['id', 'title', CODE_FIELD], limit: SEARCH_CHUNK, offset }),
      })
      for (const company of data) {
        const code = String(company[CODE_FIELD])
        if (!byCode.has(code)) byCode.set(code, company)
      }
      if (!meta?.hasMore) break
      offset += data.length
    }
  }
  return byCode
}

async function syncPage(rows, stats) {
  // Строки без кода пропускаются: связать их с компанией нечем.
  const items = rows
    .map(row => ({ code: String(row[CODE_COLUMN] ?? '').trim(), title: String(row[NAME_COLUMN] ?? '').trim() }))
    .filter(item => item.code && item.title)
  stats.skipped += rows.length - items.length

  const existing = await findCompanies([...new Set(items.map(i => i.code))])
  for (const item of items) {
    const company = existing.get(item.code)
    if (!company) {
      const { data } = await api('/v1/companies', {
        method: 'POST',
        body: JSON.stringify({ title: item.title, [CODE_FIELD]: item.code }),
      })
      if (String(data[CODE_FIELD]) !== item.code) throw new Error(`Компания ${data.id} создана без кода ${item.code} — проверьте поле ${CODE_FIELD}`)
      existing.set(item.code, data)   // повтор кода на той же странице не создаст вторую компанию
      stats.created++
    } else if (company.title !== item.title) {
      await api(`/v1/companies/${company.id}`, { method: 'PATCH', body: JSON.stringify({ title: item.title }) })
      company.title = item.title
      stats.updated++
    } else {
      stats.unchanged++
    }
  }
}

async function main() {
  await checkSetup()
  const stats = { created: 0, updated: 0, unchanged: 0, skipped: 0 }
  let offset = 0
  for (;;) {
    const result = await readPage(offset)
    await syncPage(result.rows, stats)
    console.log(`Страница с позиции ${offset}: строк ${result.rows.length}`)
    if (!result.truncated || result.nextOffset === null || result.rows.length === 0) break
    offset = result.nextOffset
  }
  console.log(`Создано: ${stats.created}, обновлено: ${stats.updated}, без изменений: ${stats.unchanged}, без кода или названия: ${stats.skipped}`)
}

main().catch(error => {
  console.error(error.message)
  process.exitCode = 1
})