[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_103":84,"_27":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":25,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",12,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","0674b70c-9c5f-11f1-b42b-1607ee4eb77e","name","fileType","interval","content","// Сторож воронок FIXPRO в Битрикс24.\n//\n// Делает то, чего не умеет штатный робот Битрикса, и пишет в чат портала.\n// Запускается по расписанию раз в полчаса.\n//\n// Переменные окружения вала:\n// B24_WEBHOOK — вебхук портала целиком, вида https://ПОРТАЛ.bitrix24.kz/rest/ID/ТОКЕН/\n// B24_DRY — любое значение, чтобы только считать и ничего не менять (для проверки)\n//\n// Ничего не удаляет. Только правит поля, ставит задачи, двигает стадии и уведомляет.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst BOSS = 96; // Андрей — сигналы руководителю\nconst MANAGER = 6; // Мансур — сигналы менеджеру\nconst CAT_IN = 26; // Продажи FIXPRO\nconst CAT_ACT = 28; // FIXPRO — активные продажи\nconst CAT_ARCH = 24; // Архив WhatsApp\n\n// «Мусор» — открытая стадия-отстойник для не-клиентов. Заведена 26 августа\n// взамен закрытой: пока сделка не закрыта, все следующие сообщения этого номера\n// падают в неё, и новых карточек по нему не появляется. Работы по таким сделкам\n// нет, поэтому ругаться на них не за что — сторож их пропускает.\nconst MUSOR = \"C26:UC_MUSOR\";\n\nconst WORK_FROM = 9; // начало рабочего дня, по времени портала\nconst WORK_TO = 18;\nconst WORK_DAY = WORK_TO - WORK_FROM;\nconst TZ_OFFSET = 5; // Астана, UTC+5\n\n// Нормативы простоя на стадии — в РАБОЧИХ часах.\n// Календарные сутки считать нельзя: обращение пришло в девять вечера,\n// и к утру сторож отчитается, что менеджер не разобрал его ночью.\nconst NORM: Record = {\n \"C26:NEW\": 4,\n \"C26:PREPARATION\": 1 * WORK_DAY,\n \"C26:PREPAYMENT_INVOIC\": 5 * WORK_DAY,\n \"C26:EXECUTING\": 7 * WORK_DAY,\n \"C26:FINAL_INVOICE\": 3 * WORK_DAY,\n \"C28:NEW\": 7 * WORK_DAY,\n \"C28:PREPARATION\": 14 * WORK_DAY,\n \"C28:PREPAYMENT_INVOIC\": 21 * WORK_DAY,\n \"C28:EXECUTING\": 14 * WORK_DAY,\n};\n\n// Лестница пауз в активных продажах: после какого отказа через сколько дней вернуться.\nconst LADDER: Record = { 1: 14, 2: 30, 3: 90 };\nconst LADDER_DEFAULT = 365;\n\nconst MEMORY_KEY = \"fixpro-storozh-pamyat\";\nconst DRY = !!Deno.env.get(\"B24_DRY\");\n\ntype Deal = Record;\n\n// ─────────────────────────── обращение к порталу ───────────────────────────\n\nfunction base(): string {\n const w = Deno.env.get(\"B24_WEBHOOK\");\n if (!w) throw new Error(\"Не задана переменная окружения B24_WEBHOOK\");\n return w.endsWith(\"/\") ? w : w + \"/\";\n}\n\nasync function b24(method: string, params: unknown = {}): Promise {\n for (let attempt = 1; attempt <= 5; attempt++) {\n const r = await fetch(base() + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(params),\n });\n const text = await r.text();\n let data: any;\n try {\n data = JSON.parse(text);\n } catch {\n throw new Error(`${method}: портал ответил не JSON (${r.status})`);\n }\n if (data.error) {\n // лимит частоты и лимит операционного времени — подождать и повторить\n const retryable = /QUERY_LIMIT_EXCEEDED|OPERATION_TIME_LIMIT/i.test(\n String(data.error) + String(data.error_description ?? \"\"),\n );\n if (retryable && attempt < 5) {\n await new Promise((res) => setTimeout(res, 2000 * attempt));\n continue;\n }\n throw new Error(\n `${method}: ${data.error} ${data.error_description ?? \"\"}`,\n );\n }\n await new Promise((res) => setTimeout(res, 350)); // портал держит около двух запросов в секунду\n return data;\n }\n throw new Error(`${method}: исчерпаны попытки`);\n}\n\nasync function allPages(\n method: string,\n params: Record,\n): Promise {\n const out: any[] = [];\n let start = 0;\n for (;;) {\n const r = await b24(method, { ...params, start });\n out.push(...(r.result ?? []));\n if (!r.next) break;\n start = r.next;\n }\n return out;\n}\n\n// ─────────────────────────── время и слова ───────────────────────────\n\n/** Рабочее ли сейчас время: будни с девяти до шести по времени портала. */\nfunction rabocheeVremya(t: Date): boolean {\n const den = t.getUTCDay();\n if (den === 0 || den === 6) return false;\n const chas = t.getUTCHours();\n return chas >= WORK_FROM && chas < WORK_TO;\n}\n\n/** «Сейчас» по времени портала. */\nfunction portalNow(): Date {\n return new Date(Date.now() + TZ_OFFSET * 3600_000);\n}\n\nfunction parsePortal(s: string): Date {\n return new Date(new Date(s).getTime() + TZ_OFFSET * 3600_000);\n}\n\n/** Рабочие часы между двумя моментами: ночь и выходные не считаются. */\nfunction workHours(from: Date, to: Date): number {\n if (to <= from) return 0;\n let h = 0;\n let cur = new Date(from);\n while (cur < to) {\n const dayStart = new Date(cur);\n dayStart.setUTCHours(WORK_FROM, 0, 0, 0);\n const dayEnd = new Date(cur);\n dayEnd.setUTCHours(WORK_TO, 0, 0, 0);\n const dow = cur.getUTCDay(); // 0 — воскресенье, 6 — суббота\n if (dow !== 0 && dow !== 6) {\n const a = cur > dayStart ? cur : dayStart;\n const b = to < dayEnd ? to : dayEnd;\n if (b > a) h += (b.getTime() - a.getTime()) / 3600_000;\n }\n const next = new Date(cur);\n next.setUTCDate(next.getUTCDate() + 1);\n next.setUTCHours(WORK_FROM, 0, 0, 0);\n cur = next;\n }\n return Math.round(h * 10) / 10;\n}\n\nfunction humanHours(h: number): string {\n if (h < WORK_DAY) return `${Math.round(h * 10) / 10} ч`;\n return `${Math.round((h / WORK_DAY) * 10) / 10} раб. дн.`;\n}\n\nfunction isoPortal(d: Date): string {\n const p = (n: number) => String(n).padStart(2, \"0\");\n return `${d.getUTCFullYear()}-${p(d.getUTCMonth() + 1)}-${\n p(d.getUTCDate())\n }T${p(d.getUTCHours())}:${p(d.getUTCMinutes())}:00+0${TZ_OFFSET}:00`;\n}\n\n// ─────────────────────────── память о сказанном ───────────────────────────\n// Без неё сторож повторяет одни и те же претензии каждые полчаса,\n// и его перестают читать через день.\n\nasync function loadMemory(): Promise> {\n try {\n return (await blob.getJSON(MEMORY_KEY)) ?? {};\n } catch {\n return {};\n }\n}\n\nfunction keyOf(check: string, ids: (string | number)[]): string {\n return `${check}|${[...ids].map(String).sort().join(\",\")}`;\n}\n\n// ─────────────────────────── основной проход ───────────────────────────\n\nexport default async function storozh() {\n const now = portalNow();\n const log: string[] = [];\n const memory = await loadMemory();\n let memoryTouched = false;\n let sentCount = 0;\n\n const say = (s: string) => log.push(s);\n\n // Ключ приходит вида «проверка|5176,5178». Помним каждую сделку отдельно:\n // при общем ключе стоит одной сделке войти в список или выйти из него —\n // и весь список приходит менеджеру заново, каждые полчаса.\n // Ночью и в выходные сторож считает, но молчит: сигнал в шесть утра — это не\n // забота, а раздражение. Память при этом не помечается, поэтому накопленное\n // уходит первым же прогоном после девяти утра.\n const rabochee = rabocheeVremya(now);\n\n async function notify(to: number, text: string, key?: string) {\n if (!rabochee) {\n say(\" (не рабочее время, придержал)\");\n return;\n }\n if (key) {\n const chast = key.split(\"|\");\n const check = chast[0];\n const kazhdyy = chast[1]\n ? chast[1].split(\",\").map((id) => check + \"-\" + id)\n : [key];\n const porog = now.getTime() - 20 * 3600_000;\n const est = kazhdyy.some((k) =>\n !memory[k] || new Date(memory[k]).getTime() <= porog\n );\n if (!est) {\n say(` (уже говорил: ${key})`);\n return;\n }\n for (const k of kazhdyy) memory[k] = now.toISOString();\n memoryTouched = true;\n }\n sentCount++;\n if (!DRY) await b24(\"im.notify\", { USER_ID: to, MESSAGE: text });\n say(\n ` → ${to === BOSS ? \"руководителю\" : \"менеджеру\"}: ${\n text.replace(/\\n/g, \" / \")\n }`,\n );\n }\n\n // ── данные ──\n const stageNames: Record = {};\n for (const cat of [CAT_IN, CAT_ACT]) {\n const st = await b24(\"crm.status.list\", {\n filter: { ENTITY_ID: `DEAL_STAGE_${cat}` },\n });\n for (const s of st.result) stageNames[s.STATUS_ID] = s.NAME;\n }\n\n const srcNames: Record = {};\n for (\n const s\n of (await b24(\"crm.status.list\", { filter: { ENTITY_ID: \"SOURCE\" } }))\n .result\n ) {\n srcNames[s.STATUS_ID] = s.NAME;\n }\n\n const deals: Deal[] = [];\n for (const cat of [CAT_IN, CAT_ACT]) {\n deals.push(\n ...(await allPages(\"crm.deal.list\", {\n filter: { CATEGORY_ID: cat, CLOSED: \"N\" },\n select: [\n \"ID\",\n \"TITLE\",\n \"STAGE_ID\",\n \"CATEGORY_ID\",\n \"DATE_CREATE\",\n \"DATE_MODIFY\",\n \"ASSIGNED_BY_ID\",\n \"OPPORTUNITY\",\n \"SOURCE_ID\",\n \"UF_CRM_NEXT_TOUCH\",\n \"UF_CRM_REFUSALS\",\n ],\n })),\n );\n }\n\n // Незавершённые дела одним запросом, чтобы не дёргать портал по сделке.\n const openAct: Record = {};\n for (\n const a of await allPages(\"crm.activity.list\", {\n filter: { OWNER_TYPE_ID: 2, COMPLETED: \"N\" },\n select: [\"ID\", \"OWNER_ID\", \"END_TIME\", \"SUBJECT\", \"RESPONSIBLE_ID\"],\n })\n ) {\n (openAct[String(a.OWNER_ID)] ??= []).push(a);\n }\n\n // Сделки наших двух воронок — по ним и только по ним сторож имеет право ругаться.\n const mine = new Set(deals.map((d) => String(d.ID)));\n\n say(\n `Сделок в работе: ${deals.length}. Режим: ${DRY ? \"холостой\" : \"рабочий\"}.`,\n );\n\n // ── автодействие 1: технический источник из открытой линии ──\n let cleaned = 0;\n for (const d of deals.filter((x) => x.STAGE_ID === \"C26:NEW\")) {\n if (!d.SOURCE_ID) continue;\n const tech = /^\\d+\\|/.test(d.SOURCE_ID) || /^WZ/.test(d.SOURCE_ID);\n if (!tech) continue;\n const nm = srcNames[d.SOURCE_ID] ?? d.SOURCE_ID;\n if (!DRY) {\n await b24(\"crm.deal.update\", {\n id: d.ID,\n fields: { SOURCE_DESCRIPTION: `Пришло из: ${nm}`, SOURCE_ID: \"\" },\n });\n }\n say(` сделка ${d.ID}: источник «${nm}» убран в примечание`);\n cleaned++;\n }\n say(`Автодействие «источник»: ${cleaned || \"нечего чистить\"}`);\n\n // ── автодействие 2: дело «подтвердить получение» на Логистике ──\n let tasksMade = 0;\n for (const d of deals.filter((x) => x.STAGE_ID === \"C26:FINAL_INVOICE\")) {\n if (openAct[String(d.ID)]) continue;\n if (!DRY) {\n const due = new Date(now.getTime() + 2 * 86400_000);\n await b24(\"tasks.task.add\", {\n fields: {\n TITLE: `Подтвердить получение товара — сделка №${d.ID} ${d.TITLE}`,\n RESPONSIBLE_ID: MANAGER,\n CREATED_BY: BOSS,\n DEADLINE: isoPortal(due),\n UF_CRM_TASK: [`D_${d.ID}`],\n },\n });\n }\n say(` сделка ${d.ID}: поставлено дело на +2 дня`);\n tasksMade++;\n }\n say(`Автодействие «логистика»: ${tasksMade || \"нечего ставить\"}`);\n\n // ── автодействие 3: лестница пауз в активных продажах ──\n let moved = 0;\n for (\n const d of deals.filter(\n (x) =>\n String(x.CATEGORY_ID) === String(CAT_ACT) &&\n x.STAGE_ID === \"C28:FINAL_INVOICE\",\n )\n ) {\n if (!d.UF_CRM_NEXT_TOUCH) {\n // сделка только что легла в паузу: считаем отказ и назначаем дату возврата\n const n = Number(d.UF_CRM_REFUSALS ?? 0) + 1;\n const days = LADDER[n] ?? LADDER_DEFAULT;\n const due = new Date(now.getTime() + days * 86400_000);\n if (!DRY) {\n await b24(\"crm.deal.update\", {\n id: d.ID,\n fields: { UF_CRM_REFUSALS: n, UF_CRM_NEXT_TOUCH: isoPortal(due) },\n });\n }\n say(` ${d.TITLE}: отказ №${n}, вернуться через ${days} дн.`);\n moved++;\n } else if (parsePortal(d.UF_CRM_NEXT_TOUCH) <= now) {\n // дата подошла: поднимаем сделку обратно в переговоры и ставим задачу\n if (!DRY) {\n await b24(\"crm.item.update\", {\n entityTypeId: 2,\n id: d.ID,\n fields: { stageId: \"C28:PREPAYMENT_INVOICE\" },\n });\n await b24(\"tasks.task.add\", {\n fields: {\n TITLE:\n `Коснуться клиента: ${d.TITLE} — отказ №${d.UF_CRM_REFUSALS}, пора заходить снова`,\n RESPONSIBLE_ID: MANAGER,\n CREATED_BY: BOSS,\n DEADLINE: isoPortal(new Date(now.getTime() + 3 * 86400_000)),\n UF_CRM_TASK: [`D_${d.ID}`],\n },\n });\n }\n say(` ${d.TITLE}: дата подошла — поднял в «Переговоры идут»`);\n moved++;\n }\n }\n say(`Автодействие «паузы»: ${moved || \"нечего двигать\"}`);\n\n // ── автодействие 4: ответственный не человек ──\n // Открытая линия иногда назначает ответственным чат-бота Wazzup. Такая сделка\n // не попадает в список менеджера, и он про неё просто не знает: 26 августа так\n // потерялось двенадцать штук. Возвращаем Мансуру.\n // Живого сотрудника не трогаем, даже если это не Мансур: передача могла быть\n // осознанной, поэтому про такие только сообщаем руководителю.\n const chelovek: Record = {};\n async function etoSotrudnik(id: string): Promise {\n if (id in chelovek) return chelovek[id];\n const r = await b24(\"user.get\", { ID: Number(id) });\n chelovek[id] = Array.isArray(r.result) && r.result.length > 0;\n return chelovek[id];\n }\n\n let vernuto = 0;\n const chuzhie: Deal[] = [];\n for (const d of deals) {\n const owner = String(d.ASSIGNED_BY_ID ?? \"\");\n if (!owner) continue;\n if (await etoSotrudnik(owner)) {\n if (owner !== String(MANAGER)) chuzhie.push(d);\n continue;\n }\n if (!DRY) {\n await b24(\"crm.deal.update\", {\n id: d.ID,\n fields: { ASSIGNED_BY_ID: MANAGER },\n });\n }\n say(\n ` сделка ${d.ID}: ответственный ${owner} не сотрудник — вернул Мансуру`,\n );\n vernuto++;\n }\n say(`Автодействие «ответственный»: ${vernuto || \"все на месте\"}`);\n if (chuzhie.length) {\n await notify(\n BOSS,\n `Сделки FIXPRO на другом сотруднике (${chuzhie.length} шт.). Не трогал — проверьте, так ли задумано:\\n${\n chuzhie.slice(0, 12).map((d) =>\n `№${d.ID} ${d.TITLE} — ответственный ${d.ASSIGNED_BY_ID}`\n ).join(\"\\n\")\n }`,\n keyOf(\"chuzhoy-otvetstvennyy\", chuzhie.map((d) => d.ID)),\n );\n }\n\n // ── проверка 1: сделки без следующего шага ──\n const noAct = deals.filter((d) => {\n if (d.STAGE_ID === MUSOR) return false; // на «Мусоре» следующий шаг не нужен\n const age = (now.getTime() - parsePortal(d.DATE_CREATE).getTime()) /\n 86400_000;\n return age >= 2 && !openAct[String(d.ID)];\n });\n if (noAct.length) {\n const list = noAct.slice(0, 12).map((d) => `№${d.ID} ${d.TITLE}`).join(\n \"\\n\",\n );\n const tail = noAct.length > 12 ? `\\n...и ещё ${noAct.length - 12}` : \"\";\n await notify(\n MANAGER,\n `Сделки без следующего шага (${noAct.length} шт.). Запланируй по ним дело:\\n${list}${tail}`,\n keyOf(\"bez-dela\", noAct.map((d) => d.ID)),\n );\n } else say(\"Проверка «без дела»: чисто\");\n\n // ── проверка 2: просроченные дела ──\n const late: { deal: string; act: any }[] = [];\n for (const [dealId, acts] of Object.entries(openAct)) {\n if (!mine.has(dealId)) continue; // чужие воронки не наше дело\n for (const a of acts) {\n if (!a.END_TIME) continue;\n if (parsePortal(a.END_TIME).getTime() < now.getTime() - 86400_000) {\n late.push({ deal: dealId, act: a });\n }\n }\n }\n if (late.length) {\n const list = late.slice(0, 12).map((x) => `№${x.deal} — ${x.act.SUBJECT}`)\n .join(\"\\n\");\n await notify(\n MANAGER,\n `Просроченные дела (${late.length} шт.):\\n${list}`,\n keyOf(\"prosrocheno\", late.map((x) => x.act.ID)),\n );\n } else say(\"Проверка «просроченные дела»: чисто\");\n\n // ── проверка 3: простой на стадии дольше норматива ──\n const stuck = deals\n .map((d) => ({\n d,\n norm: NORM[d.STAGE_ID],\n idle: workHours(parsePortal(d.DATE_MODIFY), now),\n }))\n .filter((x) => x.norm && x.idle > x.norm);\n if (stuck.length) {\n const line = (x: typeof stuck[0]) =>\n `№${x.d.ID} ${x.d.TITLE}\\n стадия «${stageNames[x.d.STAGE_ID]}» — ${\n humanHours(x.idle)\n } рабочего времени, норматив ${humanHours(x.norm)}`;\n await notify(\n MANAGER,\n `Сделки стоят дольше норматива (${stuck.length} шт.). Считается только рабочее время, ночь и выходные не в счёт:\\n${\n stuck.slice(0, 12).map(line).join(\"\\n\")\n }`,\n keyOf(\"prostoy\", stuck.map((x) => x.d.ID)),\n );\n const bad = stuck.filter((x) => x.idle > x.norm * 2);\n if (bad.length) {\n await notify(\n BOSS,\n `Зависли вдвое дольше норматива (${bad.length} шт.), менеджер уведомлён:\\n${\n bad.slice(0, 12).map(line).join(\"\\n\")\n }`,\n keyOf(\"zavisli\", bad.map((x) => x.d.ID)),\n );\n }\n } else say(\"Проверка «простой»: чисто\");\n\n // ── проверка 4: просроченные паузы в активных продажах ──\n for (\n const d of deals.filter(\n (x) =>\n String(x.CATEGORY_ID) === String(CAT_ACT) &&\n x.STAGE_ID === \"C28:FINAL_INVOICE\" && x.UF_CRM_NEXT_TOUCH,\n )\n ) {\n const due = parsePortal(d.UF_CRM_NEXT_TOUCH);\n if (due >= now) continue;\n const days = Math.round((now.getTime() - due.getTime()) / 86400_000);\n await notify(\n MANAGER,\n `Завод «${d.TITLE}» ждал касания ${days} дн. назад. Пора возвращаться.`,\n `pauza-${d.ID}`,\n );\n if (days >= 3) {\n await notify(\n BOSS,\n `Просрочено касание по заводу «${d.TITLE}» на ${days} дн.`,\n `pauza-boss-${d.ID}`,\n );\n }\n }\n\n // ── проверка 5: переписка ушла в чужую воронку ──\n const since = isoPortal(new Date(now.getTime() - 2 * 3600_000));\n const chats = await allPages(\"crm.activity.list\", {\n filter: {\n PROVIDER_ID: \"IMOPENLINES_SESSION\",\n OWNER_TYPE_ID: 2,\n \">=CREATED\": since,\n },\n select: [\"ID\", \"OWNER_ID\", \"SUBJECT\", \"CREATED\"],\n });\n const seenDeals = new Set();\n for (const a of chats) {\n const id = String(a.OWNER_ID);\n if (seenDeals.has(id) || mine.has(id)) continue;\n seenDeals.add(id);\n const d = (await b24(\"crm.deal.get\", { id })).result;\n if (String(d.CATEGORY_ID) === String(CAT_ARCH)) {\n if (!DRY) {\n await b24(\"crm.item.update\", {\n entityTypeId: 2,\n id: d.ID,\n fields: { categoryId: CAT_IN, stageId: \"C26:NEW\" },\n });\n }\n await notify(\n MANAGER,\n `Сделка №${d.ID} «${d.TITLE}» пришла из архива вместе с новой перепиской — перенёс её в «Разбор обращений».`,\n `iz-arhiva-${d.ID}`,\n );\n } else {\n await notify(\n BOSS,\n `Переписка по сделке №${d.ID} «${d.TITLE}» упала в воронку ${d.CATEGORY_ID}, не в FIXPRO. Трогать не стал — возможно, чужой клиент.`,\n `chuzhaya-voronka-${d.ID}`,\n );\n }\n }\n\n // ── проверка 6: выиграна с нулевой суммой ──\n const won = await allPages(\"crm.deal.list\", {\n filter: {\n CATEGORY_ID: CAT_IN,\n STAGE_ID: \"C26:WON\",\n \">=DATE_MODIFY\": isoPortal(new Date(now.getTime() - 86400_000)),\n },\n select: [\"ID\", \"TITLE\", \"OPPORTUNITY\"],\n });\n for (const d of won.filter((x) => Number(x.OPPORTUNITY) === 0)) {\n await notify(\n BOSS,\n `Сделка №${d.ID} «${d.TITLE}» закрыта успешно с нулевой суммой.`,\n `nol-summa-${d.ID}`,\n );\n }\n\n // ── сводка руководителю: раз в сутки, в первый запуск после девяти утра ──\n const digestKey = `svodka-${now.toISOString().slice(0, 10)}`;\n if (rabochee && !memory[digestKey]) {\n const inflow = deals.filter((d) => d.STAGE_ID === \"C26:NEW\").length;\n const noSrc = deals.filter(\n (d) => String(d.CATEGORY_ID) === String(CAT_IN) && !d.SOURCE_ID,\n ).length;\n const weekAgo = isoPortal(new Date(now.getTime() - 7 * 86400_000));\n const wonWeek = await allPages(\"crm.deal.list\", {\n filter: {\n CATEGORY_ID: CAT_IN,\n STAGE_ID: \"C26:WON\",\n \">=DATE_MODIFY\": weekAgo,\n },\n select: [\"ID\", \"OPPORTUNITY\", \"SOURCE_ID\"],\n });\n const sumWeek = wonWeek.reduce((s, d) => s + Number(d.OPPORTUNITY ?? 0), 0);\n\n const byStage = Object.entries(\n deals\n .filter((d) => String(d.CATEGORY_ID) === String(CAT_IN))\n .reduce>((acc, d) => {\n acc[d.STAGE_ID] = (acc[d.STAGE_ID] ?? 0) + 1;\n return acc;\n }, {}),\n )\n .map(([st, n]) => ` ${stageNames[st] ?? st}: ${n}`)\n .join(\"\\n\");\n\n const act = deals.filter((d) => String(d.CATEGORY_ID) === String(CAT_ACT));\n const inPause = act.filter((d) =>\n d.STAGE_ID === \"C28:FINAL_INVOICE\"\n ).length;\n\n await notify(\n BOSS,\n `Сводка по FIXPRO\n\nДЕНЬГИ\nВыиграно за неделю: ${wonWeek.length} на сумму ${sumWeek}\n\nПРОЦЕСС\nВоронка входящих, по стадиям:\n${byStage}\nАктивные продажи: ${act.length} заводов, из них в паузе ${inPause}\n\nНАРУШЕНИЯ\nНе разобрано в «Разборе»: ${inflow}\nСделок без следующего шага: ${noAct.length}\nДел просрочено: ${late.length}\nСделок без источника: ${noSrc}`,\n );\n memory[digestKey] = now.toISOString();\n memoryTouched = true;\n }\n\n // ── сохраняем память, выбрасывая всё старше недели ──\n if (memoryTouched && !DRY) {\n const fresh: Record = {};\n for (const [k, v] of Object.entries(memory)) {\n if (new Date(v).getTime() > now.getTime() - 7 * 86400_000) fresh[k] = v;\n }\n await blob.setJSON(MEMORY_KEY, fresh);\n say(`Память обновлена: записей ${Object.keys(fresh).length}.`);\n }\n\n say(`Итого сообщений: ${sentCount}.`);\n console.log(log.join(\"\\n\"));\n return log.join(\"\\n\");\n}","// Сторож воронок FIXPRO в Битрикс24.\n//\n// Делает то, чего не умеет штатный робот Битрикса, и пишет в чат портала.\n// Запускается по расписанию раз в полчаса.\n//\n// Переменные окружения вала:\n// B24_WEBHOOK — вебхук портала целиком, вида https://ПОРТАЛ.bitrix24.kz/rest/ID/ТОКЕН/\n// B24_DRY — любое значение, чтобы только считать и ничего не менять (для проверки)\n//\n// Ничего не удаляет. Только правит поля, ставит задачи, двигает стадии и уведомляет.\n\nimport { blob } from \"https://esm.town/v/std/blob\";\n\nconst BOSS = 96; // Андрей — сигналы руководителю\nconst MANAGER = 6; // Мансур — сигналы менеджеру\nconst CAT_IN = 26; // Продажи FIXPRO\nconst CAT_ACT = 28; // FIXPRO — активные продажи\nconst CAT_ARCH = 24; // Архив WhatsApp\n\n// «Мусор» — открытая стадия-отстойник для не-клиентов. Заведена 26 августа\n// взамен закрытой: пока сделка не закрыта, все следующие сообщения этого номера\n// падают в неё, и новых карточек по нему не появляется. Работы по таким сделкам\n// нет, поэтому ругаться на них не за что — сторож их пропускает.\nconst MUSOR = \"C26:UC_MUSOR\";\n\nconst WORK_FROM = 9; // начало рабочего дня, по времени портала\nconst WORK_TO = 18;\nconst WORK_DAY = WORK_TO - WORK_FROM;\nconst TZ_OFFSET = 5; // Астана, UTC+5\n\n// Нормативы простоя на стадии — в РАБОЧИХ часах.\n// Календарные сутки считать нельзя: обращение пришло в девять вечера,\n// и к утру сторож отчитается, что менеджер не разобрал его ночью.\nconst NORM: Record = {\n \"C26:NEW\": 4,\n \"C26:PREPARATION\": 1 * WORK_DAY,\n \"C26:PREPAYMENT_INVOIC\": 5 * WORK_DAY,\n \"C26:EXECUTING\": 7 * WORK_DAY,\n \"C26:FINAL_INVOICE\": 3 * WORK_DAY,\n \"C28:NEW\": 7 * WORK_DAY,\n \"C28:PREPARATION\": 14 * WORK_DAY,\n \"C28:PREPAYMENT_INVOIC\": 21 * WORK_DAY,\n \"C28:EXECUTING\": 14 * WORK_DAY,\n};\n\n// Лестница пауз в активных продажах: после какого отказа через сколько дней вернуться.\nconst LADDER: Record = { 1: 14, 2: 30, 3: 90 };\nconst LADDER_DEFAULT = 365;\n\nconst MEMORY_KEY = \"fixpro-storozh-pamyat\";\nconst DRY = !!Deno.env.get(\"B24_DRY\");\n\ntype Deal = Record;\n\n// ─────────────────────────── обращение к порталу ───────────────────────────\n\nfunction base(): string {\n const w = Deno.env.get(\"B24_WEBHOOK\");\n if (!w) throw new Error(\"Не задана переменная окружения B24_WEBHOOK\");\n return w.endsWith(\"/\") ? w : w + \"/\";\n}\n\nasync function b24(method: string, params: unknown = {}): Promise {\n for (let attempt = 1; attempt <= 5; attempt++) {\n const r = await fetch(base() + method, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(params),\n });\n const text = await r.text();\n let data: any;\n try {\n data = JSON.parse(text);\n } catch {\n throw new Error(`${method}: портал ответил не JSON (${r.status})`);\n }\n if (data.error) {\n // лимит частоты и лимит операционного времени — подождать и повторить\n const retryable = /QUERY_LIMIT_EXCEEDED|OPERATION_TIME_LIMIT/i.test(\n String(data.error) + String(data.error_description ?? \"\"),\n );\n if (retryable && attempt < 5) {\n await new Promise((res) => setTimeout(res, 2000 * attempt));\n continue;\n }\n throw new Error(\n `${method}: ${data.error} ${data.error_description ?? \"\"}`,\n );\n }\n await new Promise((res) => setTimeout(res, 350)); // портал держит около двух запросов в секунду\n return data;\n }\n throw new Error(`${method}: исчерпаны попытки`);\n}\n\nasync function allPages(\n method: string,\n params: Record,\n): Promise {\n const out: any[] = [];\n let start = 0;\n for (;;) {\n const r = await b24(method, { ...params, start });\n out.push(...(r.result ?? []));\n if (!r.next) break;\n start = r.next;\n }\n return out;\n}\n\n// ─────────────────────────── время и слова ───────────────────────────\n\n/** Рабочее ли сейчас время: будни с девяти до шести по времени портала. */\nfunction rabocheeVremya(t: Date): boolean {\n const den = t.getUTCDay();\n if (den === 0 || den === 6) return false;\n const chas = t.getUTCHours();\n return chas >= WORK_FROM && chas < WORK_TO;\n}\n\n/** «Сейчас» по времени портала. */\nfunction portalNow(): Date {\n return new Date(Date.now() + TZ_OFFSET * 3600_000);\n}\n\nfunction parsePortal(s: string): Date {\n return new Date(new Date(s).getTime() + TZ_OFFSET * 3600_000);\n}\n\n/** Рабочие часы между двумя моментами: ночь и выходные не считаются. */\nfunction workHours(from: Date, to: Date): number {\n if (to <= from) return 0;\n let h = 0;\n let cur = new Date(from);\n while (cur < to) {\n const dayStart = new Date(cur);\n dayStart.setUTCHours(WORK_FROM, 0, 0, 0);\n const dayEnd = new Date(cur);\n dayEnd.setUTCHours(WORK_TO, 0, 0, 0);\n const dow = cur.getUTCDay(); // 0 — воскресенье, 6 — суббота\n if (dow !== 0 && dow !== 6) {\n const a = cur > dayStart ? cur : dayStart;\n const b = to < dayEnd ? to : dayEnd;\n if (b > a) h += (b.getTime() - a.getTime()) / 3600_000;\n }\n const next = new Date(cur);\n next.setUTCDate(next.getUTCDate() + 1);\n next.setUTCHours(WORK_FROM, 0, 0, 0);\n cur = next;\n }\n return Math.round(h * 10) / 10;\n}\n\nfunction humanHours(h: number): string {\n if (h < WORK_DAY) return `${Math.round(h * 10) / 10} ч`;\n return `${Math.round((h / WORK_DAY) * 10) / 10} раб. дн.`;\n}\n\nfunction isoPortal(d: Date): string {\n const p = (n: number) => String(n).padStart(2, \"0\");\n return `${d.getUTCFullYear()}-${p(d.getUTCMonth() + 1)}-${\n p(d.getUTCDate())\n }T${p(d.getUTCHours())}:${p(d.getUTCMinutes())}:00+0${TZ_OFFSET}:00`;\n}\n\n// ─────────────────────────── память о сказанном ───────────────────────────\n// Без неё сторож повторяет одни и те же претензии каждые полчаса,\n// и его перестают читать через день.\n\nasync function loadMemory(): Promise> {\n try {\n return (await blob.getJSON(MEMORY_KEY)) ?? {};\n } catch {\n return {};\n }\n}\n\nfunction keyOf(check: string, ids: (string | number)[]): string {\n return `${check}|${[...ids].map(String).sort().join(\",\")}`;\n}\n\n// ─────────────────────────── основной проход ───────────────────────────\n\nexport default async function storozh() {\n const now = portalNow();\n const log: string[] = [];\n const memory = await loadMemory();\n let memoryTouched = false;\n let sentCount = 0;\n\n const say = (s: string) => log.push(s);\n\n // Ключ приходит вида «проверка|5176,5178». Помним каждую сделку отдельно:\n // при общем ключе стоит одной сделке войти в список или выйти из него —\n // и весь список приходит менеджеру заново, каждые полчаса.\n // Ночью и в выходные сторож считает, но молчит: сигнал в шесть утра — это не\n // забота, а раздражение. Память при этом не помечается, поэтому накопленное\n // уходит первым же прогоном после девяти утра.\n const rabochee = rabocheeVremya(now);\n\n async function notify(to: number, text: string, key?: string) {\n if (!rabochee) {\n say(\" (не рабочее время, придержал)\");\n return;\n }\n if (key) {\n const chast = key.split(\"|\");\n const check = chast[0];\n const kazhdyy = chast[1]\n ? chast[1].split(\",\").map((id) => check + \"-\" + id)\n : [key];\n const porog = now.getTime() - 20 * 3600_000;\n const est = kazhdyy.some((k) =>\n !memory[k] || new Date(memory[k]).getTime() <= porog\n );\n if (!est) {\n say(` (уже говорил: ${key})`);\n return;\n }\n for (const k of kazhdyy) memory[k] = now.toISOString();\n memoryTouched = true;\n }\n sentCount++;\n if (!DRY) await b24(\"im.notify\", { USER_ID: to, MESSAGE: text });\n say(\n ` → ${to === BOSS ? \"руководителю\" : \"менеджеру\"}: ${\n text.replace(/\\n/g, \" / \")\n }`,\n );\n }\n\n // ── данные ──\n const stageNames: Record = {};\n for (const cat of [CAT_IN, CAT_ACT]) {\n const st = await b24(\"crm.status.list\", {\n filter: { ENTITY_ID: `DEAL_STAGE_${cat}` },\n });\n for (const s of st.result) stageNames[s.STATUS_ID] = s.NAME;\n }\n\n const srcNames: Record = {};\n for (\n const s\n of (await b24(\"crm.status.list\", { filter: { ENTITY_ID: \"SOURCE\" } }))\n .result\n ) {\n srcNames[s.STATUS_ID] = s.NAME;\n }\n\n const deals: Deal[] = [];\n for (const cat of [CAT_IN, CAT_ACT]) {\n deals.push(\n ...(await allPages(\"crm.deal.list\", {\n filter: { CATEGORY_ID: cat, CLOSED: \"N\" },\n select: [\n \"ID\",\n \"TITLE\",\n \"STAGE_ID\",\n \"CATEGORY_ID\",\n \"DATE_CREATE\",\n \"DATE_MODIFY\",\n \"ASSIGNED_BY_ID\",\n \"OPPORTUNITY\",\n \"SOURCE_ID\",\n \"UF_CRM_NEXT_TOUCH\",\n \"UF_CRM_REFUSALS\",\n ],\n })),\n );\n }\n\n // Незавершённые дела одним запросом, чтобы не дёргать портал по сделке.\n const openAct: Record = {};\n for (\n const a of await allPages(\"crm.activity.list\", {\n filter: { OWNER_TYPE_ID: 2, COMPLETED: \"N\" },\n select: [\"ID\", \"OWNER_ID\", \"END_TIME\", \"SUBJECT\", \"RESPONSIBLE_ID\"],\n })\n ) {\n (openAct[String(a.OWNER_ID)] ??= []).push(a);\n }\n\n // Сделки наших двух воронок — по ним и только по ним сторож имеет право ругаться.\n const mine = new Set(deals.map((d) => String(d.ID)));\n\n say(\n `Сделок в работе: ${deals.length}. Режим: ${DRY ? \"холостой\" : \"рабочий\"}.`,\n );\n\n // ── автодействие 1: технический источник из открытой линии ──\n let cleaned = 0;\n for (const d of deals.filter((x) => x.STAGE_ID === \"C26:NEW\")) {\n if (!d.SOURCE_ID) continue;\n const tech = /^\\d+\\|/.test(d.SOURCE_ID) || /^WZ/.test(d.SOURCE_ID);\n if (!tech) continue;\n const nm = srcNames[d.SOURCE_ID] ?? d.SOURCE_ID;\n if (!DRY) {\n await b24(\"crm.deal.update\", {\n id: d.ID,\n fields: { SOURCE_DESCRIPTION: `Пришло из: ${nm}`, SOURCE_ID: \"\" },\n });\n }\n say(` сделка ${d.ID}: источник «${nm}» убран в примечание`);\n cleaned++;\n }\n say(`Автодействие «источник»: ${cleaned || \"нечего чистить\"}`);\n\n // ── автодействие 2: дело «подтвердить получение» на Логистике ──\n let tasksMade = 0;\n for (const d of deals.filter((x) => x.STAGE_ID === \"C26:FINAL_INVOICE\")) {\n if (openAct[String(d.ID)]) continue;\n if (!DRY) {\n const due = new Date(now.getTime() + 2 * 86400_000);\n await b24(\"tasks.task.add\", {\n fields: {\n TITLE: `Подтвердить получение товара — сделка №${d.ID} ${d.TITLE}`,\n RESPONSIBLE_ID: MANAGER,\n CREATED_BY: BOSS,\n DEADLINE: isoPortal(due),\n UF_CRM_TASK: [`D_${d.ID}`],\n },\n });\n }\n say(` сделка ${d.ID}: поставлено дело на +2 дня`);\n tasksMade++;\n }\n say(`Автодействие «логистика»: ${tasksMade || \"нечего ставить\"}`);\n\n // ── автодействие 3: лестница пауз в активных продажах ──\n let moved = 0;\n for (\n const d of deals.filter(\n (x) =>\n String(x.CATEGORY_ID) === String(CAT_ACT) &&\n x.STAGE_ID === \"C28:FINAL_INVOICE\",\n )\n ) {\n if (!d.UF_CRM_NEXT_TOUCH) {\n // сделка только что легла в паузу: считаем отказ и назначаем дату возврата\n const n = Number(d.UF_CRM_REFUSALS ?? 0) + 1;\n const days = LADDER[n] ?? LADDER_DEFAULT;\n const due = new Date(now.getTime() + days * 86400_000);\n if (!DRY) {\n await b24(\"crm.deal.update\", {\n id: d.ID,\n fields: { UF_CRM_REFUSALS: n, UF_CRM_NEXT_TOUCH: isoPortal(due) },\n });\n }\n say(` ${d.TITLE}: отказ №${n}, вернуться через ${days} дн.`);\n moved++;\n } else if (parsePortal(d.UF_CRM_NEXT_TOUCH) <= now) {\n // дата подошла: поднимаем сделку обратно в переговоры и ставим задачу\n if (!DRY) {\n await b24(\"crm.item.update\", {\n entityTypeId: 2,\n id: d.ID,\n fields: { stageId: \"C28:PREPAYMENT_INVOICE\" },\n });\n await b24(\"tasks.task.add\", {\n fields: {\n TITLE:\n `Коснуться клиента: ${d.TITLE} — отказ №${d.UF_CRM_REFUSALS}, пора заходить снова`,\n RESPONSIBLE_ID: MANAGER,\n CREATED_BY: BOSS,\n DEADLINE: isoPortal(new Date(now.getTime() + 3 * 86400_000)),\n UF_CRM_TASK: [`D_${d.ID}`],\n },\n });\n }\n say(` ${d.TITLE}: дата подошла — поднял в «Переговоры идут»`);\n moved++;\n }\n }\n say(`Автодействие «паузы»: ${moved || \"нечего двигать\"}`);\n\n // ── автодействие 4: ответственный не человек ──\n // Открытая линия иногда назначает ответственным чат-бота Wazzup. Такая сделка\n // не попадает в список менеджера, и он про неё просто не знает: 26 августа так\n // потерялось двенадцать штук. Возвращаем Мансуру.\n // Живого сотрудника не трогаем, даже если это не Мансур: передача могла быть\n // осознанной, поэтому про такие только сообщаем руководителю.\n const chelovek: Record = {};\n async function etoSotrudnik(id: string): Promise {\n if (id in chelovek) return chelovek[id];\n const r = await b24(\"user.get\", { ID: Number(id) });\n chelovek[id] = Array.isArray(r.result) && r.result.length > 0;\n return chelovek[id];\n }\n\n let vernuto = 0;\n const chuzhie: Deal[] = [];\n for (const d of deals) {\n const owner = String(d.ASSIGNED_BY_ID ?? \"\");\n if (!owner) continue;\n if (await etoSotrudnik(owner)) {\n if (owner !== String(MANAGER)) chuzhie.push(d);\n continue;\n }\n if (!DRY) {\n await b24(\"crm.deal.update\", {\n id: d.ID,\n fields: { ASSIGNED_BY_ID: MANAGER },\n });\n }\n say(\n ` сделка ${d.ID}: ответственный ${owner} не сотрудник — вернул Мансуру`,\n );\n vernuto++;\n }\n say(`Автодействие «ответственный»: ${vernuto || \"все на месте\"}`);\n if (chuzhie.length) {\n await notify(\n BOSS,\n `Сделки FIXPRO на другом сотруднике (${chuzhie.length} шт.). Не трогал — проверьте, так ли задумано:\\n${\n chuzhie.slice(0, 12).map((d) =>\n `№${d.ID} ${d.TITLE} — ответственный ${d.ASSIGNED_BY_ID}`\n ).join(\"\\n\")\n }`,\n keyOf(\"chuzhoy-otvetstvennyy\", chuzhie.map((d) => d.ID)),\n );\n }\n\n // ── проверка 1: сделки без следующего шага ──\n const noAct = deals.filter((d) => {\n if (d.STAGE_ID === MUSOR) return false; // на «Мусоре» следующий шаг не нужен\n const age = (now.getTime() - parsePortal(d.DATE_CREATE).getTime()) /\n 86400_000;\n return age >= 2 && !openAct[String(d.ID)];\n });\n if (noAct.length) {\n const list = noAct.slice(0, 12).map((d) => `№${d.ID} ${d.TITLE}`).join(\n \"\\n\",\n );\n const tail = noAct.length > 12 ? `\\n...и ещё ${noAct.length - 12}` : \"\";\n await notify(\n MANAGER,\n `Сделки без следующего шага (${noAct.length} шт.). Запланируй по ним дело:\\n${list}${tail}`,\n keyOf(\"bez-dela\", noAct.map((d) => d.ID)),\n );\n } else say(\"Проверка «без дела»: чисто\");\n\n // ── проверка 2: просроченные дела ──\n const late: { deal: string; act: any }[] = [];\n for (const [dealId, acts] of Object.entries(openAct)) {\n if (!mine.has(dealId)) continue; // чужие воронки не наше дело\n for (const a of acts) {\n if (!a.END_TIME) continue;\n if (parsePortal(a.END_TIME).getTime() < now.getTime() - 86400_000) {\n late.push({ deal: dealId, act: a });\n }\n }\n }\n if (late.length) {\n const list = late.slice(0, 12).map((x) => `№${x.deal} — ${x.act.SUBJECT}`)\n .join(\"\\n\");\n await notify(\n MANAGER,\n `Просроченные дела (${late.length} шт.):\\n${list}`,\n keyOf(\"prosrocheno\", late.map((x) => x.act.ID)),\n );\n } else say(\"Проверка «просроченные дела»: чисто\");\n\n // ── проверка 3: простой на стадии дольше норматива ──\n const stuck = deals\n .map((d) => ({\n d,\n norm: NORM[d.STAGE_ID],\n idle: workHours(parsePortal(d.DATE_MODIFY), now),\n }))\n .filter((x) => x.norm && x.idle > x.norm);\n if (stuck.length) {\n const line = (x: typeof stuck[0]) =>\n `№${x.d.ID} ${x.d.TITLE}\\n стадия «${stageNames[x.d.STAGE_ID]}» — ${\n humanHours(x.idle)\n } рабочего времени, норматив ${humanHours(x.norm)}`;\n await notify(\n MANAGER,\n `Сделки стоят дольше норматива (${stuck.length} шт.). Считается только рабочее время, ночь и выходные не в счёт:\\n${\n stuck.slice(0, 12).map(line).join(\"\\n\")\n }`,\n keyOf(\"prostoy\", stuck.map((x) => x.d.ID)),\n );\n const bad = stuck.filter((x) => x.idle > x.norm * 2);\n if (bad.length) {\n await notify(\n BOSS,\n `Зависли вдвое дольше норматива (${bad.length} шт.), менеджер уведомлён:\\n${\n bad.slice(0, 12).map(line).join(\"\\n\")\n }`,\n keyOf(\"zavisli\", bad.map((x) => x.d.ID)),\n );\n }\n } else say(\"Проверка «простой»: чисто\");\n\n // ── проверка 4: просроченные паузы в активных продажах ──\n for (\n const d of deals.filter(\n (x) =>\n String(x.CATEGORY_ID) === String(CAT_ACT) &&\n x.STAGE_ID === \"C28:FINAL_INVOICE\" && x.UF_CRM_NEXT_TOUCH,\n )\n ) {\n const due = parsePortal(d.UF_CRM_NEXT_TOUCH);\n if (due >= now) continue;\n const days = Math.round((now.getTime() - due.getTime()) / 86400_000);\n await notify(\n MANAGER,\n `Завод «${d.TITLE}» ждал касания ${days} дн. назад. Пора возвращаться.`,\n `pauza-${d.ID}`,\n );\n if (days >= 3) {\n await notify(\n BOSS,\n `Просрочено касание по заводу «${d.TITLE}» на ${days} дн.`,\n `pauza-boss-${d.ID}`,\n );\n }\n }\n\n // ── проверка 5: переписка ушла в чужую воронку ──\n const since = isoPortal(new Date(now.getTime() - 2 * 3600_000));\n const chats = await allPages(\"crm.activity.list\", {\n filter: {\n PROVIDER_ID: \"IMOPENLINES_SESSION\",\n OWNER_TYPE_ID: 2,\n \">=CREATED\": since,\n },\n select: [\"ID\", \"OWNER_ID\", \"SUBJECT\", \"CREATED\"],\n });\n const seenDeals = new Set();\n for (const a of chats) {\n const id = String(a.OWNER_ID);\n if (seenDeals.has(id) || mine.has(id)) continue;\n seenDeals.add(id);\n const d = (await b24(\"crm.deal.get\", { id })).result;\n if (String(d.CATEGORY_ID) === String(CAT_ARCH)) {\n if (!DRY) {\n await b24(\"crm.item.update\", {\n entityTypeId: 2,\n id: d.ID,\n fields: { categoryId: CAT_IN, stageId: \"C26:NEW\" },\n });\n }\n await notify(\n MANAGER,\n `Сделка №${d.ID} «${d.TITLE}» пришла из архива вместе с новой перепиской — перенёс её в «Разбор обращений».`,\n `iz-arhiva-${d.ID}`,\n );\n } else {\n await notify(\n BOSS,\n `Переписка по сделке №${d.ID} «${d.TITLE}» упала в воронку ${d.CATEGORY_ID}, не в FIXPRO. Трогать не стал — возможно, чужой клиент.`,\n `chuzhaya-voronka-${d.ID}`,\n );\n }\n }\n\n // ── проверка 6: выиграна с нулевой суммой ──\n const won = await allPages(\"crm.deal.list\", {\n filter: {\n CATEGORY_ID: CAT_IN,\n STAGE_ID: \"C26:WON\",\n \">=DATE_MODIFY\": isoPortal(new Date(now.getTime() - 86400_000)),\n },\n select: [\"ID\", \"TITLE\", \"OPPORTUNITY\"],\n });\n for (const d of won.filter((x) => Number(x.OPPORTUNITY) === 0)) {\n await notify(\n BOSS,\n `Сделка №${d.ID} «${d.TITLE}» закрыта успешно с нулевой суммой.`,\n `nol-summa-${d.ID}`,\n );\n }\n\n // ── сводка руководителю: раз в сутки, в первый запуск после девяти утра ──\n const digestKey = `svodka-${now.toISOString().slice(0, 10)}`;\n if (rabochee && !memory[digestKey]) {\n const inflow = deals.filter((d) => d.STAGE_ID === \"C26:NEW\").length;\n const noSrc = deals.filter(\n (d) =>\n String(d.CATEGORY_ID) === String(CAT_IN) && d.STAGE_ID !== MUSOR &&\n !d.SOURCE_ID,\n ).length;\n const weekAgo = isoPortal(new Date(now.getTime() - 7 * 86400_000));\n const wonWeek = await allPages(\"crm.deal.list\", {\n filter: {\n CATEGORY_ID: CAT_IN,\n STAGE_ID: \"C26:WON\",\n \">=DATE_MODIFY\": weekAgo,\n },\n select: [\"ID\", \"OPPORTUNITY\", \"SOURCE_ID\"],\n });\n const sumWeek = wonWeek.reduce((s, d) => s + Number(d.OPPORTUNITY ?? 0), 0);\n\n const byStage = Object.entries(\n deals\n .filter((d) => String(d.CATEGORY_ID) === String(CAT_IN))\n .reduce>((acc, d) => {\n acc[d.STAGE_ID] = (acc[d.STAGE_ID] ?? 0) + 1;\n return acc;\n }, {}),\n )\n .map(([st, n]) => ` ${stageNames[st] ?? st}: ${n}`)\n .join(\"\\n\");\n\n const act = deals.filter((d) => String(d.CATEGORY_ID) === String(CAT_ACT));\n const inPause = act.filter((d) =>\n d.STAGE_ID === \"C28:FINAL_INVOICE\"\n ).length;\n\n await notify(\n BOSS,\n `Сводка по FIXPRO\n\nДЕНЬГИ\nВыиграно за неделю: ${wonWeek.length} на сумму ${sumWeek}\n\nПРОЦЕСС\nВоронка входящих, по стадиям:\n${byStage}\nАктивные продажи: ${act.length} заводов, из них в паузе ${inPause}\n\nНАРУШЕНИЯ\nНе разобрано в «Разборе»: ${inflow}\nСделок без следующего шага: ${noAct.length}\nДел просрочено: ${late.length}\nСделок без источника: ${noSrc}`,\n );\n memory[digestKey] = now.toISOString();\n memoryTouched = true;\n }\n\n // ── сохраняем память, выбрасывая всё старше недели ──\n if (memoryTouched && !DRY) {\n const fresh: Record = {};\n for (const [k, v] of Object.entries(memory)) {\n if (new Date(v).getTime() > now.getTime() - 7 * 86400_000) fresh[k] = v;\n }\n await blob.setJSON(MEMORY_KEY, fresh);\n say(`Память обновлена: записей ${Object.keys(fresh).length}.`);\n }\n\n say(`Итого сообщений: ${sentCount}.`);\n console.log(log.join(\"\\n\"));\n return log.join(\"\\n\");\n}","createdAt",["D",1787745179497],"branchVersion","branchId","37e3a792-9a47-4ab3-b31a-ed7295885b5a","id","c6be09ad-0510-4d51-84c3-7749653338bc","crm-storozh",["D",1787206736896],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","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",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},"branch",{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","umgroupkzcommits","handle","displayName","umgroupkz-commits","avatar","https://avatars.githubusercontent.com/u/279207781?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":163,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":164,"_79":165,"_81":166,"_83":25},"tree",[154,155],"files",[154,155],"counts",{"_143":61,"_144":145,"_146":61,"_147":148,"_149":150},"contents",[124,125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":139,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_131":132,"_38":140,"_13":141,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":142},{"_43":126,"_32":127,"_30":128,"_129":-5,"_41":42,"_40":130,"_131":132,"_38":133,"_13":134,"_33":135,"_35":136,"_24":25,"_137":-5,"_27":138},"35c104a9-cf95-4379-912d-6dd95d75343a","ochistka.ts","e046a6e6-9c6b-11f1-ab38-1607ee4eb77e","parentId",7,"latest",true,["D",1787212444600],2,"script","// Сброс памяти сторожа. Запускается только вручную кнопкой Run.\nimport { blob } from \"https://esm.town/v/std/blob\";\nexport default async function ochistka() {\n await blob.delete(\"fixpro-storozh-pamyat\");\n console.log(\"Память сторожа очищена. Ближайший прогон скажет всё заново.\");\n return \"очищено\";\n}","label",[127],"b3e3fa71-2763-445b-ba4a-12fa1b0725e1",["D",1787745179497],8,[28],"pulls","branches",1,"forks","envVars",{"_151":145,"_153":61},"connections",{"_151":61,"_152":61},"count","unfilledCount","emptyCount",{"_43":139,"_32":28,"_30":31,"_129":-5,"_41":42,"_40":14,"_131":132,"_38":160,"_13":141,"_33":34,"_35":37,"_24":25,"_137":-5,"_157":161,"_27":162},{"_43":126,"_32":127,"_30":128,"_129":-5,"_41":42,"_40":130,"_131":132,"_38":156,"_13":134,"_33":135,"_35":136,"_24":25,"_137":-5,"_157":158,"_27":159},["D",1787212444600],"children",[],[127],["D",1787745179497],[],[28],["D",1787206736896],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":55,"_99":100,"_101":25},{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_77":-5,"_121":200,"_201":202,"_203":204,"_205":25,"_206":25,"_207":25,"_208":132,"_209":-5,"_210":-7,"_211":-7,"_212":61,"_213":25,"_214":25,"_215":-5,"_216":25,"_217":25,"_218":25,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":84,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"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"]

Diff · v12