[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_126":-5,"_20":127,"_22":128,"_129":130,"_131":132,"_26":133,"_24":134,"_135":-5,"_136":-5,"_137":52,"_138":139,"_140":52,"_141":-5,"_142":-5,"_143":144},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","umgroupkzcommits","name","fbsm-hr-weekly","branchName","main","version","path","main.ts","project",{"_33":70,"_13":14,"_44":71,"_72":-5,"_73":52,"_74":75,"_76":75,"_77":78,"_79":-5,"_80":81,"_82":-5,"_83":52,"_84":-5,"_85":-5,"_86":87,"_88":89,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_103":104,"_105":106,"_107":108,"_109":52},"tree",[55,56],"file",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":54},"contents",[],"upstream","pull","ahead","behind","envVars","id","aac497b1-4e7b-4676-955b-ac407ca530cc","fileId","c5517d60-a5e0-11f1-a966-1607ee4eb77e","parentId","branchId","dd00cead-ebf7-4fe1-ab38-5f89b9bbe8dc","branchVersion",17,"latest",true,"createdAt",["D",1789457712020],12,"fileType","interval","content","/** Еженедельный свод по HR-процессу портала FBSM.\n *\n * Отчёт отвечает участникам процесса на три вопроса: что зависло, где просрочка\n * и что нужно сделать, чтобы дело пошло дальше. Разбор — чистая функция\n * buildReport(): её проверяют тесты на фикстурах в репозитории коннектора\n * (tests/hrweekly_test.ts), не трогая портал.\n *\n * Коды полей у смарт-процесса портальные (ufCrm9_<метка времени создания поля>),\n * задать их при создании нельзя — поэтому карта кодов живёт здесь константой\n * FBSM_HR и верна только для портала fbsm. Другой портал потребует своей карты.\n *\n * Переменные окружения вала:\n * B24_HOOK_FBSM — входящий вебхук портала целиком, https://портал/rest//<токен>/\n * HR_CHAT_ID — номер чата Битрикса, по умолчанию 117 («Руководство + HR»)\n * HR_DRY_RUN=1 — собрать отчёт и напечатать в лог, ничего не отправляя\n */\n\n/** Часовой пояс, в котором люди читают отчёт (Астана, UTC+5). Дни «в стадии»\n * считаются календарными в нём, а не по разнице часов: сотрудник, заведённый\n * вчера вечером, должен читаться как «1 день», а не «0». */\nconst TZ_MINUTES = 300;\n\nexport interface HrConfig {\n entityTypeId: number;\n categoryId: number;\n /** Префикс привязки задачи к элементу процесса: UF_CRM_TASK = [\"T414_13\"].\n * Число 414 — внутренний код типа в модуле задач, не entityTypeId. */\n taskPrefix: string;\n /** Со скольких дней стояния без задачи карточка считается зависшей. */\n stallDays: number;\n /** Сколько строк печатать в одном блоке, прежде чем свернуть остаток. */\n maxLines: number;\n fioField: string;\n positionField: string;\n deptField: string;\n ibanField: string;\n hireDateField: string;\n vacancyDueField: string;\n /** Стадия, начиная с которой человек считается принятым (по коду). */\n hiredStage: string;\n /** Стадия, с которой заполненная дата приёма законна: на ней сотрудника\n * и оформляют. Раньше неё дата означает разрыв между фактом и стадией,\n * начиная с неё — обычный ход дела. */\n hireDateOkFromStage: string;\n docFields: Record;\n /** Документы, без которых нельзя считать оформление законченным. */\n requiredForHired: string[];\n checkFields: Record;\n /** Отметки из checkFields, которые ставят не всем: их отсутствие у человека\n * в штате — не недоделка, и в свод они не идут. */\n optionalChecks: string[];\n}\n\nexport const FBSM_HR: HrConfig = {\n entityTypeId: 1044,\n categoryId: 17,\n taskPrefix: \"T414_\",\n stallDays: 3,\n maxLines: 7,\n fioField: \"ufCrm9_1784631608\",\n positionField: \"ufCrm9_1784615011\",\n deptField: \"ufCrm9_1784614963\",\n ibanField: \"ufCrm9_1784618549\",\n hireDateField: \"ufCrm9_1784629411\",\n vacancyDueField: \"ufCrm9_1784618262\",\n hiredStage: \"DT1044_17:UC_JTICC3\",\n hireDateOkFromStage: \"DT1044_17:CLIENT\",\n docFields: {\n ufCrm9_1784618496: \"удостоверение\",\n ufCrm9_1784618569: \"документ об образовании\",\n ufCrm9_1784618605: \"справка 075/у\",\n ufCrm9_1784618622: \"справка психоневро\",\n ufCrm9_1784618635: \"справка нарко\",\n ufCrm9_1784790486: \"справка туб\",\n ufCrm9_1786533084677: \"справка о судимости\",\n ufCrm9_1786600941770: \"справка о счёте\",\n ufCrm9_1784628386: \"скан ТД\",\n ufCrm9_1784629616: \"договор матответственности\",\n ufCrm9_1784629728: \"приказ о приёме\",\n },\n requiredForHired: [\"ufCrm9_1784618496\", \"ufCrm9_1784628386\", \"ufCrm9_1784629728\"],\n checkFields: {\n ufCrm9_1784628410: \"Енбек\",\n ufCrm9_1784628434: \"Битрикс24\",\n ufCrm9_1784628472: \"1С\",\n ufCrm9_1784628499: \"система з/п\",\n ufCrm9_1784628531: \"доп. ПО\",\n ufCrm9_1784629400: \"принят в штат\",\n },\n // «Система з.п.» с 15.09.2026 ставит робот на входе в «В штате» — строку про\n // неё Андрей из свода убрал, как и про доп. ПО.\n optionalChecks: [\"ufCrm9_1784628531\", \"ufCrm9_1784628499\"],\n};\n\nexport interface HrStage {\n id: string;\n name: string;\n sort: number;\n /** \"S\" — успех, \"F\" — провал, null — рабочая стадия. */\n semantics: string | null;\n}\n\nexport interface HrItem {\n id: number;\n stageId: string;\n assignedById?: number;\n createdTime: string;\n movedTime: string;\n [field: string]: unknown;\n}\n\nexport interface HrTask {\n id: string;\n title: string;\n status: string;\n deadline: string | null;\n closedDate: string | null;\n responsible?: { name?: string };\n ufCrmTask?: string[] | null;\n}\n\nexport interface ReportInput {\n items: HrItem[];\n tasks: HrTask[];\n stages: HrStage[];\n now: Date;\n domain: string;\n cfg: HrConfig;\n /** Названия значений списочных полей: код поля → id значения → название. */\n enums?: Record>;\n /** Имена ответственных: id пользователя → имя. */\n users?: Record;\n}\n\nexport interface ReportStats {\n inWork: number;\n stalled: number;\n overdueTasks: number;\n lateVacancies: number;\n dataErrors: number;\n weekNew: number;\n weekClosed: number;\n}\n\nexport interface Report {\n text: string;\n stats: ReportStats;\n}\n\n/** Календарный день в поясе портала как целое число — чтобы вычитать дни, а не часы. */\nfunction dayNumber(iso: string | Date): number {\n const ms = iso instanceof Date ? iso.getTime() : Date.parse(iso);\n return Math.floor((ms + TZ_MINUTES * 60_000) / 86_400_000);\n}\n\nfunction daysBetween(from: string, to: Date): number {\n return dayNumber(to) - dayNumber(from);\n}\n\nfunction ddmm(d: Date | string): string {\n const ms = d instanceof Date ? d.getTime() : Date.parse(d);\n const shifted = new Date(ms + TZ_MINUTES * 60_000);\n const day = String(shifted.getUTCDate()).padStart(2, \"0\");\n const month = String(shifted.getUTCMonth() + 1).padStart(2, \"0\");\n return `${day}.${month}`;\n}\n\n/** Задача закрыта, если завершена (5) или отклонена (7): ни та ни другая уже\n * никого никуда не двинет, и карточка под ними считается брошенной. */\nfunction isOpen(t: HrTask): boolean {\n return t.status !== \"5\" && t.status !== \"7\";\n}\n\n/** Пустое значение поля. Строки \"0\" и \"N\" тоже пустые: Битрикс отдаёт снятую\n * галочку строкой \"N\" (а не false и не нулём), и наивная проверка на непустую\n * строку считала бы её поставленной. Найдено живым прогоном по порталу fbsm\n * 25 августа 2026: чек-лист оформления не показывал ни одной недоделки, хотя\n * половина отметок в карточках снята. */\nfunction filled(v: unknown): boolean {\n if (v === null || v === undefined) return false;\n if (Array.isArray(v)) return v.length > 0;\n if (typeof v === \"string\") {\n const s = v.trim();\n return s.length > 0 && s !== \"0\" && s !== \"N\";\n }\n if (typeof v === \"number\") return v !== 0;\n if (typeof v === \"boolean\") return v;\n return true;\n}\n\n/** Поставленная галочка. Битрикс отдаёт булево поле смарт-процесса строкой\n * \"Y\"/\"N\"; числа и true приходят из фикстур и из других версий портала. */\nfunction checked(v: unknown): boolean {\n return v === \"Y\" || v === true || v === 1 || v === \"1\";\n}\n\n/** «Магазин - Астаны - Республика» в строке чата съедает половину ширины,\n * а различает точки только хвост. */\nfunction shortDept(name: string): string {\n return name.replace(/^Магазин\\s*-\\s*/i, \"\").trim();\n}\n\nfunction clip(s: string, max: number): string {\n return s.length <= max ? s : `${s.slice(0, max - 1).trimEnd()}…`;\n}\n\nfunction text(item: HrItem, field: string, enums?: ReportInput[\"enums\"]): string {\n const raw = item[field];\n if (!filled(raw)) return \"\";\n const map = enums?.[field];\n if (map) return map[String(raw)] ?? String(raw);\n return String(raw).trim();\n}\n\n/** IBAN Казахстана: KZ + 2 контрольные цифры + 16 знаков. В это поле регулярно\n * попадает номер карты или имя латиницей — такую запись бухгалтерия не проведёт. */\nfunction looksLikeKzIban(v: string): boolean {\n return /^KZ\\d{2}[A-Za-z0-9]{16}$/.test(v.replace(/\\s+/g, \"\"));\n}\n\nfunction itemTasks(item: HrItem, tasks: HrTask[], cfg: HrConfig): HrTask[] {\n const link = `${cfg.taskPrefix}${item.id}`;\n return tasks.filter((t) => (t.ufCrmTask ?? []).some((l) => String(l) === link));\n}\n\nfunction missingDocs(item: HrItem, cfg: HrConfig): string[] {\n return Object.entries(cfg.docFields)\n .filter(([code]) => !filled(item[code]))\n .map(([, name]) => name);\n}\n\nfunction personLine(item: HrItem, input: ReportInput): string {\n const fio = text(item, input.cfg.fioField, input.enums) || \"без ФИО\";\n const dept = shortDept(text(item, input.cfg.deptField, input.enums));\n const pos = text(item, input.cfg.positionField, input.enums);\n const where = [pos, dept].filter(Boolean).join(\", \");\n return where ? `${fio} · ${where}` : fio;\n}\n\nfunction link(item: HrItem, input: ReportInput): string {\n return `https://${input.domain}/crm/type/${input.cfg.entityTypeId}/details/${item.id}/`;\n}\n\nfunction who(item: HrItem, input: ReportInput): string {\n const id = item.assignedById;\n const name = id === undefined ? \"\" : (input.users?.[String(id)] ?? \"\");\n return name ? ` · отв. ${name}` : \"\";\n}\n\n/** Блок печатается только если в нём что-то есть; длинный сворачивается с честным\n * остатком — молчаливое обрезание читалось бы как «больше зависаний нет». */\nfunction block(title: string, lines: string[], max: number): string[] {\n if (lines.length === 0) return [];\n const head = lines.slice(0, max);\n const rest = lines.length - head.length;\n const out = [`[B]${title}[/B]`, ...head];\n if (rest > 0) out.push(`…и ещё ${rest} — весь список в карточках процесса`);\n out.push(\"\");\n return out;\n}\n\nexport function buildReport(input: ReportInput): Report {\n const { items, tasks, stages, now, cfg } = input;\n const byId = new Map(stages.map((s) => [s.id, s]));\n const working = stages.filter((s) => s.semantics === null).sort((a, b) => a.sort - b.sort);\n const firstStage = working[0]?.id;\n\n /** Место стадии в цепочке. Неизвестная стадия уходит в конец: считать её\n * ранней значило бы выдумывать ошибки на пустом месте. */\n const stageOrder = (id: string): number => byId.get(id)?.sort ?? Number.MAX_SAFE_INTEGER;\n\n const live = items.filter((i) => byId.get(i.stageId)?.semantics === null);\n const weekAgo = dayNumber(now) - 7;\n\n const stalledLines: string[] = [];\n const overdueLines: string[] = [];\n const vacancyLines: string[] = [];\n const errorLines: string[] = [];\n const todo: { days: number; line: string }[] = [];\n let stalled = 0, overdueTasks = 0, lateVacancies = 0;\n\n for (const item of [...live].sort((a, b) => Date.parse(a.movedTime) - Date.parse(b.movedTime))) {\n const stage = byId.get(item.stageId)!;\n const days = daysBetween(item.movedTime, now);\n const mine = itemTasks(item, tasks, cfg);\n const open = mine.filter(isOpen);\n const missing = missingDocs(item, cfg);\n const person = personLine(item, input);\n const beforeHireDateStage = stageOrder(item.stageId) < stageOrder(cfg.hireDateOkFromStage);\n\n // Стадия «В штате» — конец пути в этой воронке: отсутствие задачи там не\n // зависание, а норма. Недоделки по такому человеку идут блоком ошибок ниже.\n if (open.length === 0 && days >= cfg.stallDays && item.stageId !== cfg.hiredStage) {\n stalled++;\n const need = missing.length > 0\n ? `нет: ${missing.slice(0, 3).join(\", \")}${\n missing.length > 3 ? ` и ещё ${missing.length - 3}` : \"\"\n }`\n : \"документы собраны, ждёт перевода\";\n stalledLines.push(\n `• [URL=${\n link(item, input)\n }]#${item.id}[/URL] ${person} · ${days} дн в «${stage.name}» · ${need}${who(item, input)}`,\n );\n todo.push({\n days,\n line: missing.length > 0\n ? `#${item.id} ${person} — дособрать: ${missing.slice(0, 3).join(\", \")}${\n who(item, input)\n }`\n : `#${item.id} ${person} — перевести из «${stage.name}» дальше${who(item, input)}`,\n });\n }\n\n // Задача подбора на первой стадии не идёт в этот блок: она же и есть срок\n // вакансии, и показывать её дважды — задачей и вакансией — значит удваивать\n // одну и ту же беду.\n for (const t of open) {\n if (item.stageId === firstStage) break;\n if (!t.deadline) continue;\n const late = daysBetween(t.deadline, now);\n if (late <= 0) continue;\n overdueTasks++;\n const resp = t.responsible?.name ? ` · ${t.responsible.name}` : \"\";\n overdueLines.push(\n `• [URL=${link(item, input)}]#${item.id}[/URL] ${person} · «${\n clip(t.title, 52)\n }» · +${late} дн${resp}`,\n );\n todo.push({\n days: late,\n line: `#${item.id} ${person} — закрыть задачу «${clip(t.title, 52)}»${resp}`,\n });\n }\n\n // Срок вакансии берётся из ДЕДЛАЙНА ЗАДАЧИ подбора, а не из поля «Желаемый\n // срок закрытия»: дедлайн люди двигают по ходу дела, а поле забывают, и две\n // даты расходятся на недели — по карточке #19 портала fbsm на 38 дней.\n // Задача без дедлайна сроком не считается: это осознанная пауза, а не провал.\n if (item.stageId === firstStage) {\n const due = open.map((t) => t.deadline).filter((d): d is string => !!d)\n .sort((a, b) => Date.parse(a) - Date.parse(b))[0];\n if (due) {\n const late = daysBetween(due, now);\n if (late > 0) {\n lateVacancies++;\n const pos = text(item, cfg.positionField, input.enums) || \"вакансия\";\n const dept = shortDept(text(item, cfg.deptField, input.enums));\n const where = dept ? ` · ${dept}` : \"\";\n vacancyLines.push(\n `• [URL=${link(item, input)}]#${item.id}[/URL] ${pos}${where}` +\n ` · срок задачи был ${ddmm(due)} (+${late} дн)${who(item, input)}`,\n );\n todo.push({\n days: late,\n line: `#${item.id} ${pos}${where} — закрыть вакансию, срок был ${ddmm(due)}${\n who(item, input)\n }`,\n });\n }\n }\n }\n\n // Ошибки в данных: то, из-за чего отчётность и бухгалтерия дадут неверную картину.\n // Дата приёма и отметка «принят в штат» вне стадии «В штате» — один и тот же\n // разрыв между фактом и стадией, поэтому и строка про него одна. Но дата\n // приёма законна уже на «Оформлении»: её там и заполняют, чтобы напечатать\n // приказ, — и ошибкой она считается только на стадиях раньше.\n if (item.stageId !== cfg.hiredStage) {\n const hiredMarks: string[] = [];\n if (filled(item[cfg.hireDateField]) && beforeHireDateStage) {\n hiredMarks.push(\"дата приёма\");\n }\n const hiredFlag = Object.entries(cfg.checkFields)\n .find(([, name]) => name === \"принят в штат\")?.[0];\n if (hiredFlag && checked(item[hiredFlag])) hiredMarks.push(\"отметка «принят в штат»\");\n if (hiredMarks.length > 0) {\n errorLines.push(\n `• #${item.id} ${person} — ${hiredMarks.join(\" и \")}, но карточка в «${stage.name}»`,\n );\n }\n }\n if (!filled(item[cfg.fioField]) && item.stageId !== firstStage) {\n errorLines.push(`• #${item.id} — карточка без ФИО в стадии «${stage.name}»`);\n }\n const iban = text(item, cfg.ibanField, input.enums);\n if (iban && !looksLikeKzIban(iban)) {\n errorLines.push(`• #${item.id} ${person} — в поле IBAN не IBAN: «${iban.slice(0, 24)}»`);\n }\n if (item.stageId === cfg.hiredStage) {\n const notDone = Object.entries(cfg.checkFields)\n .filter(([code]) => !cfg.optionalChecks.includes(code) && !checked(item[code]))\n .map(([, name]) => name);\n if (notDone.length > 0) {\n errorLines.push(`• #${item.id} ${person} — в штате, не отмечено: ${notDone.join(\", \")}`);\n }\n const lack = cfg.requiredForHired.filter((code) => !filled(item[code]))\n .map((code) => cfg.docFields[code]);\n if (lack.length > 0) {\n errorLines.push(`• #${item.id} ${person} — в штате без документов: ${lack.join(\", \")}`);\n }\n }\n }\n\n const weekNew = items.filter((i) => dayNumber(i.createdTime) >= weekAgo).length;\n const weekClosed =\n items.filter((i) =>\n byId.get(i.stageId)?.semantics !== null && dayNumber(i.movedTime) >= weekAgo\n ).length;\n\n const head = [\n `[B]HR-процессы · свод на ${ddmm(now)}[/B]`,\n `В работе ${live.length} · зависли ${stalled} · просрочено задач ${overdueTasks} · вакансии вне срока ${lateVacancies}`,\n `За неделю: новых карточек ${weekNew}, закрыто исходом ${weekClosed}`,\n \"\",\n ];\n\n const body = [\n ...block(\"🔴 Стоят без задачи — сами не сдвинутся\", stalledLines, cfg.maxLines),\n ...block(\"🟠 Просроченные задачи\", overdueLines, cfg.maxLines),\n ...block(\"🔵 Вакансии вне срока закрытия\", vacancyLines, cfg.maxLines),\n ...block(\"⚠️ Ошибки в данных\", errorLines, cfg.maxLines),\n ];\n\n if (stalled === 0 && overdueTasks === 0) {\n body.unshift(\"✅ Зависаний нет: у каждой карточки в работе есть живая задача в срок.\", \"\");\n }\n\n const actions = todo.sort((a, b) => b.days - a.days).slice(0, 5)\n .map((t, i) => `${i + 1}. ${t.line}`);\n const tail = actions.length > 0 ? [\"[B]📌 Сделать на этой неделе[/B]\", ...actions] : [];\n\n return {\n text: [...head, ...body, ...tail].join(\"\\n\").replace(/\\n{3,}/g, \"\\n\\n\").trim(),\n stats: {\n inWork: live.length,\n stalled,\n overdueTasks,\n lateVacancies,\n dataErrors: errorLines.length,\n weekNew,\n weekClosed,\n },\n };\n}\n\n// ─────────────────────────────────────────────────────────────────────────────\n// Часть, работающая на Val Town: свой минимальный клиент REST по вебхуку.\n// Коннектор сюда не тянем — валу нужен только вебхук портала из переменной\n// окружения B24_HOOK_FBSM (полный адрес вида https://портал/rest//<токен>/).\n// ─────────────────────────────────────────────────────────────────────────────\n\n// Незаданную переменную дописывать косой чертой нельзя: пустая строка превратится\n// в \"/\", проверка на непустоту пройдёт, и вместо внятной ошибки полетит запрос\n// в никуда — на собственный адрес вала.\nconst RAW_HOOK = (Deno.env.get(\"B24_HOOK_FBSM\") ?? \"\").trim();\nconst HOOK = RAW_HOOK ? RAW_HOOK.replace(/\\/?$/, \"/\") : \"\";\nconst CHAT_ID = Number(Deno.env.get(\"HR_CHAT_ID\") ?? \"117\");\n\nfunction domainOf(hook: string): string {\n const m = /^https:\\/\\/([^/]+)\\//.exec(hook);\n return m ? m[1] : \"\";\n}\n\nasync function call(method: string, params: Record = {}): Promise {\n if (!HOOK) throw new Error(\"Переменная окружения B24_HOOK_FBSM не задана\");\n const res = await fetch(HOOK + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(params),\n });\n const raw = await res.text();\n let env: { result?: unknown; error?: string; error_description?: string; next?: number };\n try {\n env = JSON.parse(raw);\n } catch {\n throw new Error(`Портал ответил не JSON на ${method}: ${raw.slice(0, 200)}`);\n }\n if (env.error) throw new Error(`${method}: ${env.error} ${env.error_description ?? \"\"}`.trim());\n return env.result as T;\n}\n\n/** Проходит все страницы выборки: Битрикс отдаёт по 50 записей за раз. */\nasync function callAll(method: string, params: Record = {}): Promise {\n const out: T[] = [];\n let start: number | undefined;\n for (let page = 0; page < 50; page++) {\n const body = start === undefined ? params : { ...params, start };\n if (!HOOK) throw new Error(\"Переменная окружения B24_HOOK_FBSM не задана\");\n const res = await fetch(HOOK + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const env = await res.json() as {\n result?: unknown;\n error?: string;\n error_description?: string;\n next?: number;\n };\n if (env.error) throw new Error(`${method}: ${env.error} ${env.error_description ?? \"\"}`.trim());\n const chunk = Array.isArray(env.result)\n ? env.result as T[]\n : Object.values((env.result ?? {}) as Record).flat();\n out.push(...chunk);\n if (env.next === undefined) break;\n start = env.next;\n await new Promise((r) => setTimeout(r, 400)); // портал держит около двух запросов в секунду\n }\n return out;\n}\n\nasync function collect(cfg: HrConfig, now: Date) {\n const items = await callAll(\"crm.item.list\", {\n entityTypeId: cfg.entityTypeId,\n filter: { categoryId: cfg.categoryId },\n });\n\n const since = new Date(now.getTime() - 180 * 86_400_000).toISOString().slice(0, 10);\n const tasks = await callAll(\"tasks.task.list\", {\n filter: { \">CREATED_DATE\": since },\n select: [\"ID\", \"TITLE\", \"STATUS\", \"DEADLINE\", \"RESPONSIBLE_ID\", \"UF_CRM_TASK\", \"CLOSED_DATE\"],\n });\n\n const stageRows = await call[]>(\"crm.status.list\", {\n filter: { ENTITY_ID: `DYNAMIC_${cfg.entityTypeId}_STAGE_${cfg.categoryId}` },\n order: { SORT: \"ASC\" },\n });\n const stages: HrStage[] = stageRows.map((r) => ({\n id: String(r.STATUS_ID),\n name: String(r.NAME),\n sort: Number(r.SORT),\n semantics: r.SEMANTICS === null || r.SEMANTICS === undefined ? null : String(r.SEMANTICS),\n }));\n\n const fields = await call>(\n \"crm.item.fields\",\n { entityTypeId: cfg.entityTypeId },\n );\n const box =\n (fields as unknown as { fields?: Record })\n .fields ?? fields;\n const enums: Record> = {};\n for (const code of [cfg.positionField, cfg.deptField]) {\n const list = box?.[code]?.items;\n if (list) enums[code] = Object.fromEntries(list.map((i) => [String(i.ID), i.VALUE.trim()]));\n }\n\n const ids = [...new Set(items.map((i) => i.assignedById).filter((v): v is number => !!v))];\n const users: Record = {};\n for (const id of ids.slice(0, 25)) {\n try {\n const rows = await call<{ NAME?: string; LAST_NAME?: string }[]>(\"user.get\", { ID: id });\n const u = rows?.[0];\n const name = [u?.NAME, u?.LAST_NAME].filter(Boolean).join(\" \").trim();\n if (name) users[String(id)] = name;\n } catch {\n // имя — украшение строки, а не смысл отчёта\n }\n }\n return { items, tasks, stages, enums, users };\n}\n\n/** Точка входа крон-вала: собрать свод и положить его в чат. */\nexport default async function (): Promise {\n const now = new Date();\n const data = await collect(FBSM_HR, now);\n const report = buildReport({ ...data, cfg: FBSM_HR, now, domain: domainOf(HOOK) });\n\n if (Deno.env.get(\"HR_DRY_RUN\") === \"1\") {\n console.log(\"СУХОЙ ПРОГОН, в чат не отправляю:\\n\\n\" + report.text);\n console.log(\"\\nстатистика: \" + JSON.stringify(report.stats));\n return;\n }\n\n const messageId = await call(\"im.message.add\", {\n DIALOG_ID: `chat${CHAT_ID}`,\n MESSAGE: report.text,\n });\n console.log(\n `HR-свод отправлен в чат ${CHAT_ID}: сообщение ${messageId}, ${JSON.stringify(report.stats)}`,\n );\n}\n","deleted",false,"label",[19],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":67,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_64":68,"_18":69},{"_33":57,"_13":58,"_35":59,"_37":-5,"_38":39,"_40":60,"_42":43,"_44":61,"_17":62,"_47":48,"_49":63,"_51":52,"_53":-5,"_64":65,"_18":66},"f45756e2-ccda-4da2-a660-78ea63580af8","monthly.ts","6a90ac52-b0ee-11f1-bedb-1607ee4eb77e",19,["D",1789474763068],1,"/** Месячная сводка по вакансиям портала FBSM в чат Битрикса — файл monthly.ts вала\n * umgroupkzcommits/fbsm-hr-weekly, расписание «0 4 1 * *» (1-го числа, 09:00 по Астане).\n *\n * Копия src/hrmonthly.ts без единого локального импорта: вал не видит репозиторий.\n * Логику правят в src/hrmonthly.ts под тестами tests/hrmonthly_test.ts и переносят сюда.\n *\n * Вакансия создана за месяц — карточка создана в этом месяце. Закрыта — в этом месяце\n * карточку перевели «В штат» и на конец месяца она всё ещё там (по истории стадий,\n * crm.stagehistory.list). Месяц — по времени Астаны (UTC+5).\n *\n * Переменные окружения вала:\n * B24_HOOK_FBSM — входящий вебхук портала целиком, https://портал/rest//<токен>/\n * HR_CHAT_ID — номер чата, по умолчанию 117 («Руководство + HR»)\n * HR_MANAGER_ID — к кому обращается сводка, по умолчанию 439 (HR-менеджер)\n * HR_DRY_RUN=1 — собрать и напечатать в лог, ничего не отправляя\n */\n\nconst TZ_MINUTES = 300;\n\nconst CFG = {\n entityTypeId: 1044,\n categoryId: 17,\n hiredStage: \"DT1044_17:UC_JTICC3\",\n fioField: \"ufCrm9_1784631608\",\n positionField: \"ufCrm9_1784615011\",\n deptField: \"ufCrm9_1784614963\",\n};\n\nconst MONTHS = [\n \"январь\", \"февраль\", \"март\", \"апрель\", \"май\", \"июнь\",\n \"июль\", \"август\", \"сентябрь\", \"октябрь\", \"ноябрь\", \"декабрь\",\n];\n\ninterface HrItem {\n id: number;\n createdTime: string;\n [field: string]: unknown;\n}\n\ninterface StageEvent {\n OWNER_ID: number | string;\n STAGE_ID: string;\n CREATED_TIME: string;\n}\n\ninterface MonthlyInput {\n items: HrItem[];\n history: StageEvent[];\n now: Date;\n domain: string;\n enums?: Record>;\n hr: { id: number; name: string };\n}\n\nfunction previousMonth(now: Date): { from: Date; to: Date; label: string } {\n const local = new Date(now.getTime() + TZ_MINUTES * 60_000);\n const y = local.getUTCFullYear();\n const m = local.getUTCMonth();\n const from = new Date(Date.UTC(y, m - 1, 1) - TZ_MINUTES * 60_000);\n const to = new Date(Date.UTC(y, m, 1) - TZ_MINUTES * 60_000);\n const shown = new Date(Date.UTC(y, m - 1, 1));\n return { from, to, label: `${MONTHS[shown.getUTCMonth()]} ${shown.getUTCFullYear()}` };\n}\n\nfunction inRange(iso: string | null | undefined, from: Date, to: Date): boolean {\n if (!iso) return false;\n const t = Date.parse(iso);\n return Number.isFinite(t) && t >= from.getTime() && t < to.getTime();\n}\n\nfunction ddmm(iso: string): string {\n const d = new Date(Date.parse(iso) + TZ_MINUTES * 60_000);\n return `${String(d.getUTCDate()).padStart(2, \"0\")}.${String(d.getUTCMonth() + 1).padStart(2, \"0\")}`;\n}\n\nfunction label(item: HrItem, input: MonthlyInput): string {\n const val = (code: string) => {\n const raw = item[code];\n if (raw === null || raw === undefined || raw === \"\" || raw === 0) return \"\";\n return input.enums?.[code]?.[String(raw)] ?? String(raw).trim();\n };\n const fio = val(CFG.fioField);\n const pos = val(CFG.positionField) || \"должность не указана\";\n const dept = val(CFG.deptField).replace(/^Магазин\\s*-\\s*/i, \"\");\n return [fio, pos, dept].filter(Boolean).join(\" · \");\n}\n\nfunction line(item: HrItem, input: MonthlyInput, date: string, verb: string): string {\n const url = `https://${input.domain}/crm/type/${CFG.entityTypeId}/details/${item.id}/`;\n return `• [URL=${url}]#${item.id}[/URL] ${label(item, input)} · ${verb} ${ddmm(date)}`;\n}\n\nconst MAX_LINES = 15;\n\nfunction listBlock(title: string, lines: string[]): string[] {\n if (lines.length === 0) return [];\n const head = lines.slice(0, MAX_LINES);\n const rest = lines.length - head.length;\n return [`[B]${title}[/B]`, ...head, ...(rest > 0 ? [`…и ещё ${rest}`] : []), \"\"];\n}\n\nfunction closedInMonth(\n history: StageEvent[],\n hiredStage: string,\n from: Date,\n to: Date,\n): Map {\n const byOwner = new Map();\n for (const e of history) {\n const t = Date.parse(e.CREATED_TIME);\n if (!Number.isFinite(t) || t >= to.getTime()) continue;\n const key = String(e.OWNER_ID);\n if (!byOwner.has(key)) byOwner.set(key, []);\n byOwner.get(key)!.push(e);\n }\n const out = new Map();\n for (const [owner, events] of byOwner) {\n events.sort((a, b) => Date.parse(a.CREATED_TIME) - Date.parse(b.CREATED_TIME));\n if (events[events.length - 1].STAGE_ID !== hiredStage) continue;\n const entries = events.filter((e) => e.STAGE_ID === hiredStage && inRange(e.CREATED_TIME, from, to));\n if (entries.length === 0) continue;\n out.set(owner, entries[entries.length - 1].CREATED_TIME);\n }\n return out;\n}\n\nfunction buildMonthlyReport(input: MonthlyInput) {\n const { from, to, label: month } = previousMonth(input.now);\n const byId = new Map(input.items.map((i) => [String(i.id), i]));\n\n const created = input.items\n .filter((i) => inRange(i.createdTime, from, to))\n .sort((a, b) => Date.parse(a.createdTime) - Date.parse(b.createdTime));\n\n const closed = [...closedInMonth(input.history, CFG.hiredStage, from, to).entries()]\n .filter(([id]) => byId.has(id))\n .sort((a, b) => Date.parse(a[1]) - Date.parse(b[1]));\n\n const text = [\n `[B]HR · вакансии за ${month}[/B]`,\n `Создано вакансий: ${created.length}`,\n `Закрыто вакансий: ${closed.length}`,\n \"\",\n ...listBlock(\"Созданы\", created.map((i) => line(i, input, i.createdTime, \"создана\"))),\n ...listBlock(\"Закрыты\", closed.map(([id, at]) => line(byId.get(id)!, input, at, \"в штате с\"))),\n `[USER=${input.hr.id}]${input.hr.name}[/USER], проверьте, пожалуйста, цифры за ${month} и подтвердите ответом в этом чате. ` +\n \"Если какой-то вакансии не хватает или она лишняя — напишите номер карточки.\",\n \"\",\n \"Закрытой считается вакансия, по которой сотрудника за месяц перевели «В штат» и он остался там на конец месяца.\",\n ].join(\"\\n\").replace(/\\n{3,}/g, \"\\n\\n\").trim();\n\n return { text, month, created: created.length, closed: closed.length, from, to };\n}\n\n// ─────────────────────────────────────────────────────────────────────────────\n// Клиент REST по вебхуку — тот же, что в main.ts этого вала.\n// ─────────────────────────────────────────────────────────────────────────────\n\nconst RAW_HOOK = (Deno.env.get(\"B24_HOOK_FBSM\") ?? \"\").trim();\nconst HOOK = RAW_HOOK ? RAW_HOOK.replace(/\\/?$/, \"/\") : \"\";\nconst CHAT_ID = Number(Deno.env.get(\"HR_CHAT_ID\") ?? \"117\");\nconst HR_MANAGER_ID = Number(Deno.env.get(\"HR_MANAGER_ID\") ?? \"439\");\n\nfunction domainOf(hook: string): string {\n const m = /^https:\\/\\/([^/]+)\\//.exec(hook);\n return m ? m[1] : \"\";\n}\n\nasync function call(method: string, params: Record = {}): Promise {\n if (!HOOK) throw new Error(\"Переменная окружения B24_HOOK_FBSM не задана\");\n const res = await fetch(HOOK + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(params),\n });\n const raw = await res.text();\n let env: { result?: unknown; error?: string; error_description?: string };\n try {\n env = JSON.parse(raw);\n } catch {\n throw new Error(`Портал ответил не JSON на ${method}: ${raw.slice(0, 200)}`);\n }\n if (env.error) throw new Error(`${method}: ${env.error} ${env.error_description ?? \"\"}`.trim());\n return env.result as T;\n}\n\n/** Проходит все страницы выборки: Битрикс отдаёт по 50 записей за раз. */\nasync function callAll(method: string, params: Record = {}): Promise {\n if (!HOOK) throw new Error(\"Переменная окружения B24_HOOK_FBSM не задана\");\n const out: T[] = [];\n let start: number | undefined;\n for (let page = 0; page < 50; page++) {\n const body = start === undefined ? params : { ...params, start };\n const res = await fetch(HOOK + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const env = await res.json() as {\n result?: unknown;\n error?: string;\n error_description?: string;\n next?: number;\n };\n if (env.error) throw new Error(`${method}: ${env.error} ${env.error_description ?? \"\"}`.trim());\n const chunk = Array.isArray(env.result)\n ? env.result as T[]\n : Object.values((env.result ?? {}) as Record).flat();\n out.push(...chunk);\n if (env.next === undefined) break;\n start = env.next;\n await new Promise((r) => setTimeout(r, 400));\n }\n return out;\n}\n\nexport default async function (): Promise {\n const now = new Date();\n\n const items = await callAll(\"crm.item.list\", {\n entityTypeId: CFG.entityTypeId,\n filter: { categoryId: CFG.categoryId },\n });\n\n const history = await callAll(\"crm.stagehistory.list\", {\n entityTypeId: CFG.entityTypeId,\n filter: { CATEGORY_ID: CFG.categoryId },\n order: { ID: \"ASC\" },\n select: [\"ID\", \"OWNER_ID\", \"STAGE_ID\", \"CREATED_TIME\"],\n });\n\n const fields = await call>(\"crm.item.fields\", {\n entityTypeId: CFG.entityTypeId,\n });\n const box = ((fields as { fields?: Record })\n .fields ?? fields) as Record;\n const enums: Record> = {};\n for (const code of [CFG.positionField, CFG.deptField]) {\n const list = box?.[code]?.items;\n if (list) enums[code] = Object.fromEntries(list.map((i) => [String(i.ID), i.VALUE.trim()]));\n }\n\n let name = \"HR-менеджер\";\n try {\n const rows = await call<{ NAME?: string; LAST_NAME?: string }[]>(\"user.get\", { ID: HR_MANAGER_ID });\n const u = rows?.[0];\n name = [u?.NAME, u?.LAST_NAME].filter(Boolean).join(\" \").trim() || name;\n } catch {\n // упоминание по id работает и без имени\n }\n\n const report = buildMonthlyReport({\n items,\n history,\n enums,\n now,\n domain: domainOf(HOOK),\n hr: { id: HR_MANAGER_ID, name },\n });\n\n if (Deno.env.get(\"HR_DRY_RUN\") === \"1\") {\n console.log(\"СУХОЙ ПРОГОН, в чат не отправляю:\\n\\n\" + report.text);\n return;\n }\n\n const messageId = await call(\"im.message.add\", {\n DIALOG_ID: `chat${CHAT_ID}`,\n MESSAGE: report.text,\n });\n console.log(\n `Месячная сводка за ${report.month} отправлена в чат ${CHAT_ID}: сообщение ${messageId}, ` +\n `создано ${report.created}, закрыто ${report.closed}`,\n );\n}\n","children",[],[58],["D",1789457712020],[],[19],"0ecf1b96-8c9e-434c-8152-9d8c0fc98ffb",["D",1788251922596],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Еженедельный HR-свод портала FBSM в чат Битрикса","imageUrl","userId","ce244983-5dfc-4662-ad1a-ca34d2e798a0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019fa853-4d22-71bf-b5fe-af55df9678e6","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_125":121},"org",{"_11":12,"_118":119,"_120":121,"_80":81,"_122":123,"_124":52},"branch",{"_17":60,"_13":16,"_33":39,"_110":70,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","umgroupkz-commits","avatar","https://avatars.githubusercontent.com/u/279207781?v=4","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":70,"_13":14,"_44":162,"_72":-5,"_73":52,"_74":75,"_76":75,"_77":78,"_79":-5,"_80":81,"_82":-5,"_83":52,"_84":-5,"_85":-5,"_86":87,"_88":89,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_103":163,"_105":164,"_107":165,"_109":52},[156,157],"files",[156,157],"counts",{"_146":87,"_147":62,"_148":87,"_32":149,"_150":151},[],{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":45,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_18":145},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],"pulls","branches","forks",{"_152":154,"_155":87},"connections",{"_152":87,"_153":87},"count","unfilledCount",2,"emptyCount",{"_33":34,"_13":19,"_35":36,"_37":-5,"_38":39,"_40":41,"_42":43,"_44":67,"_17":46,"_47":48,"_49":50,"_51":52,"_53":-5,"_64":160,"_18":161},{"_33":57,"_13":58,"_35":59,"_37":-5,"_38":39,"_40":60,"_42":43,"_44":61,"_17":62,"_47":48,"_49":63,"_51":52,"_53":-5,"_64":158,"_18":159},[],[58],[],[19],["D",1788251922596],{"_11":12,"_125":121},{"_11":12,"_118":119,"_120":121,"_80":81,"_122":123,"_124":52},{"_17":60,"_13":16,"_33":39,"_110":70,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"ctx",{"_103":-5,"_142":199,"_200":201,"_202":203,"_204":52,"_205":52,"_206":52,"_207":43,"_208":-5,"_209":-7,"_210":-7,"_211":87,"_212":52,"_213":52,"_214":-5,"_215":52,"_216":52,"_217":52,"_218":-5},"ENV",{"_170":171,"_172":173,"_174":16,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]