[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_164":165,"_166":167},"routes/_app.x.$handle.$name",{"_93":92,"_32":44,"_102":83,"_26":36,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":24,"_116":117,"_118":24,"_119":-5,"_120":-5,"_121":122},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":36,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":76,"_77":78,"_79":80,"_81":24},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":29},"file",{"_30":31,"_32":27,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","new-file-3030.ts","latestPath","ochistka.ts","fileId","e046a6e6-9c6b-11f1-ab38-1607ee4eb77e","name","fileType","script","content","","createdAt",["D",1787212256325],"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",{"_93":92,"_101":97},"org",{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},"branch",{"_13":82,"_32":83,"_42":41,"_84":43,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":44,"_91":92},"isOwned",12,"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",{"_42":43,"_32":44,"_37":160,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":36,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":-5,"_63":-5,"_64":-5,"_65":-5,"_66":67,"_68":67,"_69":70,"_71":70,"_72":70,"_73":67,"_74":67,"_75":161,"_77":162,"_79":163,"_81":24},"tree",[151,152],"files",[151,152],"counts",{"_140":59,"_141":142,"_143":59,"_144":145,"_146":147},"contents",[123,124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":131,"_32":132,"_30":133,"_126":-5,"_40":41,"_39":134,"_127":24,"_37":135,"_13":136,"_33":137,"_35":138,"_23":24,"_129":-5,"_26":139},{"_42":125,"_32":27,"_30":31,"_126":-5,"_40":41,"_39":14,"_127":24,"_37":128,"_13":59,"_33":34,"_35":36,"_23":24,"_129":-5,"_26":130},"c513f5b2-26b5-461c-9af6-8665c2cf67aa","parentId","latest",["D",1787212256325],"label",[27],"af8980f3-b7a5-476b-8409-f2870c7dd378","main.ts","0674b70c-9c5f-11f1-b42b-1607ee4eb77e",4,["D",1787211998381],3,"interval","// Сторож воронок 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\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 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 async function notify(to: number, text: string, key?: string) {\n if (key) {\n const seen = memory[key];\n if (seen && new Date(seen).getTime() > now.getTime() - 20 * 3600_000) {\n say(` (уже говорил: ${key})`);\n return;\n }\n memory[key] = 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 // ── проверка 1: сделки без следующего шага ──\n const noAct = deals.filter((d) => {\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 (now.getUTCHours() >= WORK_FROM && !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}",[132],"pulls","branches",1,"forks","envVars",{"_148":142,"_150":59},"connections",{"_148":59,"_149":59},"count","unfilledCount","emptyCount",{"_42":131,"_32":132,"_30":133,"_126":-5,"_40":41,"_39":134,"_127":24,"_37":157,"_13":136,"_33":137,"_35":138,"_23":24,"_129":-5,"_154":158,"_26":159},{"_42":125,"_32":27,"_30":31,"_126":-5,"_40":41,"_39":14,"_127":24,"_37":153,"_13":59,"_33":34,"_35":36,"_23":24,"_129":-5,"_154":155,"_26":156},["D",1787212256325],"children",[],[27],["D",1787211998381],[],[132],["D",1787206736896],{"_93":92,"_101":97},{"_93":92,"_94":95,"_96":97,"_18":53,"_98":99,"_100":24},{"_13":82,"_32":83,"_42":41,"_84":43,"_85":-5,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":44,"_91":92},"ctx",{"_75":-5,"_120":197,"_198":199,"_200":201,"_202":24,"_203":24,"_204":24,"_205":206,"_207":-5,"_208":-7,"_209":-7,"_210":59,"_211":24,"_212":24,"_213":-5,"_214":24,"_215":24,"_216":24,"_217":-5},"ENV",{"_168":169,"_170":171,"_172":83,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v5