Unlock — табло

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_278":279,"_280":281},"routes/_app.x.$handle.$name",{"_98":97,"_32":44,"_107":88,"_27":108,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":57,"_125":-5,"_126":-5,"_127":128},"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":25,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",179,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":20,"_34":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":20,"_34":35},"deleted",false,"deletedHere","path","tv.html","latestPath","fileId","6c12220a-8b4f-11f1-8469-1607ee4eb77e","name","fileType","content","\n\n\n\n\nUnlock — табло\n\n\n\n\n

🏆Гонка месяцаU. Unlock

обновляется · —

\n \n

Загружаю данные…

\n\n\n","\n\n \n \n \n Unlock — табло\n \n \n \n

\n 🏆Гонка месяцаU. Unlock\n

\n обновляется · —\n

Брокер

Сделки

Задатки

Комиссия

Задачи

Отставание

Загружаю данные…

\n \n \n","createdAt",["D",1788339774167],"branchVersion","branchId","5a76b817-f255-4528-a3a4-76e6a27bfac9","id","47c70ae1-859e-4751-8e55-f5f72caa1026","voronka-dnya",["D",1784824972725],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","caa5b6a0-dd4e-4cd6-a997-9389a6a43948","pinnedFileId","8c600d22-86b5-11f1-862b-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019eff71-5749-76b5-abdd-e25a47b3deca","tursoName","47c70ae1859e47518e55f5f72caa1026","tursoHostname","47c70ae1859e47518e55f5f72caa1026-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789560070146],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_106":102},"org",{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":25},"branch",{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"isOwned",286,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","tambovtsev007","handle","displayName","Кирилл Тамбовцев","avatar","https://lh3.googleusercontent.com/a/ACg8ocKCNneTjcn307kcxhB_NS1R7_0SBhSKM-2hy73z0JvhXFipwkhs=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_32":44,"_37":273,"_46":-5,"_47":25,"_48":49,"_50":49,"_51":-5,"_52":-5,"_18":53,"_54":55,"_56":57,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":274,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":275,"_82":276,"_84":277,"_86":25},"tree",[236,237,238,239,240,241,242,243,244],"files",[236,237,238,239,240,241,242,243,244],"counts",{"_225":61,"_226":227,"_228":61,"_229":230,"_231":232},"contents",[144,145,146,147,148,149,150,151,152],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[129,130,131,132,133,134,135],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":143,"_137":-5},{"_42":142,"_137":-5},{"_42":141,"_137":-5},{"_42":140,"_137":-5},{"_42":139,"_137":-5},{"_42":138,"_137":-5},{"_42":136,"_137":-5},"803e2f46-f09d-49b2-bec7-a6ab0ac73e5e","reporterId","98209be9-0c3a-4450-8ba5-7dd4b592d334","260830b1-1075-4e3b-a49a-9298fa6c851b","7e36f1bb-47f7-44ad-b4d6-d539e5f99a8c","5c1dd51b-f3ba-4039-9098-8d74146e957c","111ccc35-0294-4e6b-b35d-600149ea2269","548f1497-538d-422c-914a-c85affed9e6d",{"_42":217,"_32":218,"_30":219,"_154":-5,"_40":41,"_39":220,"_155":25,"_37":221,"_13":222,"_33":20,"_34":223,"_24":25,"_158":-5,"_27":224},{"_42":210,"_32":211,"_30":212,"_154":-5,"_40":41,"_39":213,"_155":25,"_37":214,"_13":191,"_33":20,"_34":215,"_24":25,"_158":-5,"_27":216},{"_42":202,"_32":203,"_30":204,"_154":-5,"_40":41,"_39":205,"_155":25,"_37":206,"_13":207,"_33":166,"_34":208,"_24":25,"_158":-5,"_27":209},{"_42":194,"_32":195,"_30":196,"_154":-5,"_40":41,"_39":197,"_155":25,"_37":198,"_13":199,"_33":166,"_34":200,"_24":25,"_158":-5,"_27":201},{"_42":186,"_32":187,"_30":188,"_154":-5,"_40":41,"_39":189,"_155":25,"_37":190,"_13":191,"_33":20,"_34":192,"_24":25,"_158":-5,"_27":193},{"_42":178,"_32":179,"_30":55,"_154":-5,"_40":41,"_39":180,"_155":25,"_37":181,"_13":182,"_33":183,"_34":184,"_24":25,"_158":-5,"_27":185},{"_42":169,"_32":170,"_30":171,"_154":-5,"_40":41,"_39":172,"_155":25,"_37":173,"_13":174,"_33":175,"_34":176,"_24":25,"_158":-5,"_27":177},{"_42":160,"_32":161,"_30":162,"_154":-5,"_40":41,"_39":163,"_155":25,"_37":164,"_13":165,"_33":166,"_34":167,"_24":25,"_158":-5,"_27":168},{"_42":153,"_32":28,"_30":31,"_154":-5,"_40":41,"_39":14,"_155":25,"_37":156,"_13":157,"_33":20,"_34":36,"_24":25,"_158":-5,"_27":159},"702ec26d-598b-4676-9b9e-c5c1b3924379","parentId","latest",["D",1788339774167],23,"label",[28],"4458f7fe-39af-4003-a7c3-275985533fac","reminders.ts","a1a8aaa4-9709-11f1-b07e-1607ee4eb77e",160,["D",1787829663979],5,"script","// Воронка Дня — тексты напоминаний (вынесено из main.ts: у Val Town лимит 80 000 символов на файл)\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { addDays, init } from \"./main.ts\";\n\n// кому и что напоминать; kind: 'morning' | 'evening'\nexport async function buildReminders(kind) {\n await init();\n const now = new Date();\n const msk = new Date(now.getTime() + 3 * 3600 * 1000);\n const date = msk.toISOString().slice(0, 10);\n const brokers = await sqlite.execute({\n sql: \"SELECT id,name FROM brokers WHERE active=1\",\n args: [],\n });\n const items = await sqlite.execute({\n sql: \"SELECT broker_id,done FROM items WHERE date=?\",\n args: [date],\n });\n const cian = await sqlite.execute({\n sql: \"SELECT broker_id,morning,evening FROM cian WHERE date=?\",\n args: [date],\n });\n const subs = await sqlite.execute({\n sql:\n \"SELECT endpoint,broker_id,p256dh,auth FROM push_subs WHERE role='broker'\",\n args: [],\n });\n // выходные/больничные/отпуска: этих брокеров сегодня не дёргаем и не считаем «без плана»\n const offs = await sqlite.execute({\n sql: \"SELECT broker_id FROM days_off WHERE date=?\",\n args: [date],\n });\n const offIds = new Set(offs.rows.map((r) => Number(r.broker_id)));\n const out = [];\n\n // контроль 10 дней: задатки без выхода на сделку и сделки без оплаты (7 дней регистрация + 3 на расчёт)\n const limit10 = addDays(date, -10);\n const fio = (s) => String(s || \"\").trim();\n const dd = (s) => String(s).slice(8, 10) + \".\" + String(s).slice(5, 7);\n let staleZ = [], staleD = [];\n if (kind === \"morning\" || kind === \"boss-morning\") {\n const zq = await sqlite.execute({\n sql:\n `SELECT z.broker_id, z.client, z.buyer, z.comm_sum, z.deal_date, b.name FROM zadatki z\n JOIN brokers b ON b.id=z.broker_id\n WHERE z.status='approved' AND COALESCE(z.cancel_req,0)=0 AND z.deal_date<=? ORDER BY z.deal_date LIMIT 30`,\n args: [limit10],\n });\n const dq = await sqlite.execute({\n sql:\n `SELECT d.broker_id, d.client, d.crm_id, d.comm_in, d.deal_date, b.name FROM dkp d\n JOIN brokers b ON b.id=d.broker_id\n WHERE d.status='approved' AND COALESCE(d.paid,0)=0 AND d.deal_date<=? ORDER BY d.deal_date LIMIT 30`,\n args: [limit10],\n });\n staleZ = zq.rows;\n staleD = dq.rows;\n }\n\n // напоминания руководителю: утром — обход планов, вечером — внести цифры\n if (kind === \"boss-morning\" || kind === \"boss-evening\") {\n const bossSubs = await sqlite.execute({\n sql: \"SELECT endpoint,p256dh,auth FROM push_subs WHERE role='boss'\",\n args: [],\n });\n if (!bossSubs.rows.length) return out;\n const yday = addDays(date, -1);\n const ydayItems = await sqlite.execute({\n sql: \"SELECT broker_id,done FROM items WHERE date=?\",\n args: [yday],\n });\n const month = date.slice(0, 7);\n const manual = await sqlite.execute({\n sql:\n \"SELECT broker_id,deals,zad_cnt,income FROM manual_month WHERE month=?\",\n args: [month],\n });\n const nameOf = (id) => {\n const b = brokers.rows.find((x) => Number(x.id) === id);\n return b ? String(b.name).split(\" \")[0] : \"\";\n };\n let title = \"\", body = \"\";\n if (kind === \"boss-morning\") {\n const noPlan = brokers.rows\n .filter((b) =>\n !offIds.has(Number(b.id)) &&\n !items.rows.some((i) => Number(i.broker_id) === Number(b.id))\n )\n .map((b) => nameOf(Number(b.id)));\n const noCian = brokers.rows.filter((b) => {\n const ci = cian.rows.find((x) => Number(x.broker_id) === Number(b.id));\n return !ci || ci.morning === null || ci.morning === undefined;\n }).length;\n title = \"Обход команды\";\n body = noPlan.length\n ? `Без плана на сегодня: ${\n noPlan.join(\", \")\n }. Загляните в «Обход» и спросите по задачам`\n : (noCian\n ? `Планы сданы, но ${noCian} чел. без базы Циан — уточните`\n : \"Планы сданы. Посмотрите акценты и дайте комментарии по задачам\");\n } else {\n const unmarked = brokers.rows.filter((b) =>\n ydayItems.rows.some((i) =>\n Number(i.broker_id) === Number(b.id) &&\n (i.done === null || i.done === undefined)\n )\n ).map((b) => nameOf(Number(b.id)));\n const noNums = brokers.rows.filter((b) => {\n const m = manual.rows.find((x) => Number(x.broker_id) === Number(b.id));\n return !m ||\n (m.deals === null && m.zad_cnt === null && m.income === null);\n }).map((b) => nameOf(Number(b.id)));\n title = \"Итоги дня\";\n const parts = [];\n if (noNums.length) parts.push(`внести цифры: ${noNums.join(\", \")}`);\n if (unmarked.length) {\n parts.push(`не отметили вчера: ${unmarked.join(\", \")}`);\n }\n body = parts.length\n ? parts.join(\" · \")\n : \"Внесите сделки, задатки и доход, если что-то изменилось\";\n }\n for (const s of bossSubs.rows) {\n out.push({\n sub: {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n payload: { title, body, url: \"/\" },\n });\n }\n // отдельным пушем — ДКП, которые ещё не ушли в Росфинмониторинг (напоминаем, пока не отметите)\n const rfmRows = await sqlite.execute({\n sql: `SELECT id,client,crm_id,deal_sum,deal_date FROM dkp\n WHERE rfm=1 AND status='approved' AND COALESCE(rfm_sent,0)=0\n ORDER BY deal_date LIMIT 20`,\n args: [],\n });\n if (rfmRows.rows.length) {\n const n = rfmRows.rows.length;\n const first = rfmRows.rows[0];\n const body = n === 1\n ? `${String(first.client || first.crm_id)} · ${\n Number(first.deal_sum).toLocaleString(\"ru-RU\")\n } ₽ от ${\n String(first.deal_date)\n }. Отметьте во вкладке «Сделки», когда отправите`\n : `${n} ДКП ждут отправки, самый ранний — от ${\n String(first.deal_date)\n }. Список во вкладке «Сделки»`;\n for (const s of bossSubs.rows) {\n out.push({\n sub: {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n payload: { title: \"📤 Росфинмониторинг\", body, url: \"/\" },\n });\n }\n }\n // руководителю: висящие задатки и неоплаченные сделки старше 10 дней — одним пушем на каждую тему\n if (kind === \"boss-morning\") {\n const bossPush = (title, body) => {\n for (const s of bossSubs.rows) {\n out.push({\n sub: {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n payload: { title, body, url: \"/\" },\n });\n }\n };\n if (staleZ.length) {\n const list = staleZ.slice(0, 3).map((z) =>\n `${fio(z.name).split(\" \")[0]}: ${fio(z.client || z.buyer)} от ${\n dd(z.deal_date)\n }`\n ).join(\"; \");\n bossPush(\n \"⏳ Задатки висят 10+ дней\",\n `${staleZ.length} шт — ${list}${\n staleZ.length > 3 ? \" и другие\" : \"\"\n }. Доведите до сделки или разваливайте`,\n );\n }\n if (staleD.length) {\n const list = staleD.slice(0, 3).map((z) =>\n `${fio(z.name).split(\" \")[0]}: ${fio(z.client || z.crm_id)} от ${\n dd(z.deal_date)\n }`\n ).join(\"; \");\n bossPush(\n \"💸 Нет оплаты 10+ дней после сделки\",\n `${staleD.length} шт — ${list}${\n staleD.length > 3 ? \" и другие\" : \"\"\n }. Проверьте расчёты и отметьте оплату в реестре`,\n );\n }\n }\n return out;\n }\n\n for (const b of brokers.rows) {\n const id = Number(b.id);\n if (offIds.has(id)) continue; // выходной / больничный / отпуск — не беспокоим\n const mine = items.rows.filter((i) => Number(i.broker_id) === id);\n const ci = cian.rows.find((x) => Number(x.broker_id) === id) || {};\n let title = \"\", body = \"\";\n if (kind === \"morning\") {\n const hasPlan = mine.length > 0;\n const hasCian = ci.morning !== null && ci.morning !== undefined;\n if (hasPlan && hasCian) continue;\n title = \"Доброе утро! План на день\";\n body = !hasPlan\n ? \"Заполните план по 5 этапам и укажите базу на Циан — 60 секунд\"\n : \"Остался Циан: укажите, сколько объектов у вас в базе\";\n } else {\n const unmarked = mine.filter((i) =>\n i.done === null || i.done === undefined\n ).length;\n const hasEve = ci.evening !== null && ci.evening !== undefined;\n if (!mine.length && !hasEve) {\n title = \"Итоги дня\";\n body =\n \"Плана на сегодня не было. Отметьте базу Циан и запланируйте завтра\";\n } else if (unmarked === 0 && hasEve) continue;\n else {\n title = \"Итоги дня\";\n body = unmarked > 0\n ? `Отметьте ${unmarked} пункт(ов) плана: ✓ или ✕ с комментарием`\n : \"Остался Циан: укажите базу объектов на вечер\";\n }\n }\n for (const s of subs.rows) {\n if (Number(s.broker_id) !== id) continue;\n out.push({\n sub: {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n payload: { title, body, url: \"/\" },\n });\n }\n }\n // брокерам утром: их задатки 10+ дней и сделки без оплаты 10+ дней (даже если план уже сдан)\n if (kind === \"morning\") {\n const push = (bid, title, body) => {\n for (const s of subs.rows) {\n if (Number(s.broker_id) !== bid) continue;\n out.push({\n sub: {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n payload: { title, body, url: \"/\" },\n });\n }\n };\n const byB = (rows) => {\n const m = {};\n rows.forEach((r) => {\n (m[Number(r.broker_id)] = m[Number(r.broker_id)] || []).push(r);\n });\n return m;\n };\n const zByB = byB(staleZ), dByB = byB(staleD);\n for (const bid of Object.keys(zByB)) {\n if (offIds.has(Number(bid))) continue;\n const list = zByB[bid].slice(0, 3).map((z) =>\n `${fio(z.client || z.buyer)} от ${dd(z.deal_date)}`\n ).join(\", \");\n push(\n Number(bid),\n \"⏳ Задаток висит больше 10 дней\",\n `${list}${\n zByB[bid].length > 3 ? \" и другие\" : \"\"\n } — доведите до сделки или запросите развал`,\n );\n }\n for (const bid of Object.keys(dByB)) {\n if (offIds.has(Number(bid))) continue;\n const list = dByB[bid].slice(0, 3).map((z) =>\n `${fio(z.client || z.crm_id)} от ${dd(z.deal_date)}`\n ).join(\", \");\n push(\n Number(bid),\n \"💸 Сделка без оплаты 10+ дней\",\n `${list}${\n dByB[bid].length > 3 ? \" и другие\" : \"\"\n } — уточните оплату у руководителя`,\n );\n }\n }\n return out;\n}",[161],"867faf3e-41a2-4948-a61a-3ec45363f370","notify.ts","1b8a4a5a-8b28-11f1-b70f-1607ee4eb77e",176,["D",1788339653580],9,"interval","// Воронка Дня — напоминания (Cron-триггер, расписание: 0,30 6,7,16,18 * * *)\n// 06:30 UTC = 09:30 МСК — брокерам: заполнить план на день\n// 07:00 UTC = 10:00 МСК — руководителю: проверить планы и задачи\n// 16:00 UTC = 19:00 МСК — руководителю: внести цифры и изменения\n// 18:00 UTC = 21:00 МСК — брокерам: отметить итоги дня\nimport webpush from \"npm:web-push@3.6.7\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { buildReminders } from \"./reminders.ts\";\nimport { dropSubscription, vapidPub } from \"./main.ts\";\n\n// отметка о работе крона — для чек-контроля в панели руководителя (/api/health)\nconst mark = (k: string, v: string) =>\n sqlite.execute({\n sql:\n \"INSERT INTO settings(key,value) VALUES(?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value\",\n args: [k, v],\n }).catch(() => {});\n\nfunction pickKind(d: Date): string | null {\n const h = d.getUTCHours(), m = d.getUTCMinutes();\n if (h === 6 && m >= 25 && m <= 35) return \"morning\";\n if (h === 7 && m < 10) return \"boss-morning\";\n if (h === 16 && m < 10) return \"boss-evening\";\n if (h === 18 && m < 10) return \"evening\";\n return null;\n}\n\nexport default async function () {\n await mark(\"cron_seen\", new Date().toISOString()); // «крон живой» — даже если рассылать нечего\n const kind = pickKind(new Date());\n if (!kind) {\n console.log(\"Не время рассылки — пропуск\");\n return;\n }\n\n const priv = Deno.env.get(\"VAPID_PRIVATE_KEY\");\n if (!priv) {\n console.log(\n \"Нет VAPID_PRIVATE_KEY в переменных окружения — рассылка пропущена\",\n );\n return;\n }\n webpush.setVapidDetails(\"mailto:tambovtsev007@gmail.com\", vapidPub(), priv);\n\n const jobs = await buildReminders(kind);\n\n let sent = 0, gone = 0, failed = 0;\n for (const j of jobs) {\n try {\n await webpush.sendNotification(j.sub, JSON.stringify(j.payload));\n sent++;\n } catch (e) {\n const code = e && e.statusCode;\n if ([400, 401, 403, 404, 410].includes(code)) {\n await dropSubscription(j.sub.endpoint); // умершая или подписанная старым ключом\n gone++;\n } else {\n failed++;\n console.log(\"push error\", code, e && e.body);\n }\n }\n }\n await mark(\n \"notify_last\",\n JSON.stringify({ kind, sent, gone, failed, at: new Date().toISOString() }),\n );\n console.log(\n `[${kind}] отправлено ${sent}, отписок удалено ${gone}, ошибок ${failed}`,\n );\n}",[170],"a4f75a41-80a0-48bd-bad4-9bc2c3743a14","main.ts",174,["D",1788339628685],32,"http","import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { parseVal, readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { registerExtra } from \"./extra.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\n/* Росфинмониторинг: отправляем только ДКП на сумму от 5 млн ₽ (ДДУ не отправляем) */\nconst RFM_LIMIT = 5000000;\nconst RFM_DELAY_MS = 30000; // напоминание через 30 секунд после подтверждения сделки\n\n/* ---------- schema ---------- */\nconst SCHEMA_V = \"2026-08-24a\"; // меняйте при изменении схемы — тогда init пройдёт полностью\nlet ready = false;\nexport async function init() {\n if (ready) return;\n // быстрый путь: схема уже актуальна — 1 запрос вместо ~50 на каждом холодном старте\n try {\n const v = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key='schema_v'\",\n args: [],\n });\n if (v.rows.length && String(v.rows[0].value) === SCHEMA_V) {\n ready = true;\n return;\n }\n } catch (_e) { /* таблицы ещё нет — полная инициализация */ }\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS brokers(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n pin TEXT NOT NULL UNIQUE,\n active INTEGER NOT NULL DEFAULT 1,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS items(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER NOT NULL,\n date TEXT NOT NULL,\n stage INTEGER NOT NULL,\n text TEXT NOT NULL,\n label TEXT NOT NULL DEFAULT '',\n amount INTEGER NOT NULL DEFAULT 0,\n done INTEGER,\n comment TEXT NOT NULL DEFAULT '',\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS cian(\n broker_id INTEGER NOT NULL,\n date TEXT NOT NULL,\n morning INTEGER,\n evening INTEGER,\n PRIMARY KEY (broker_id, date)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS settings(\n key TEXT PRIMARY KEY,\n value TEXT NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS deals_manual(\n broker_id INTEGER NOT NULL,\n month TEXT NOT NULL,\n count INTEGER NOT NULL DEFAULT 0,\n PRIMARY KEY (broker_id, month)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS manual_month(\n broker_id INTEGER NOT NULL,\n month TEXT NOT NULL,\n deals INTEGER,\n zad_cnt INTEGER,\n zad_sum INTEGER,\n income INTEGER,\n PRIMARY KEY (broker_id, month)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS push_subs(\n endpoint TEXT PRIMARY KEY,\n broker_id INTEGER,\n role TEXT NOT NULL DEFAULT 'broker',\n p256dh TEXT NOT NULL,\n auth TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS zadatki(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER NOT NULL,\n crm_id TEXT NOT NULL,\n buyer TEXT NOT NULL,\n deal_sum INTEGER NOT NULL,\n comm_pct REAL NOT NULL,\n comm_sum INTEGER NOT NULL,\n deal_date TEXT NOT NULL,\n doc_name TEXT,\n status TEXT NOT NULL DEFAULT 'pending',\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n decided_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS dkp(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER NOT NULL,\n crm_id TEXT NOT NULL,\n side TEXT NOT NULL,\n person TEXT NOT NULL,\n deal_sum INTEGER NOT NULL,\n deal_date TEXT NOT NULL,\n doc_name TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS net_income(\n broker_id INTEGER NOT NULL,\n month TEXT NOT NULL,\n amount INTEGER NOT NULL,\n PRIMARY KEY (broker_id, month)\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS days_off(\n broker_id INTEGER NOT NULL,\n date TEXT NOT NULL,\n kind TEXT NOT NULL DEFAULT 'off',\n PRIMARY KEY (broker_id, date)\n )`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_items_bd ON items(broker_id, date)`,\n },\n { sql: `CREATE INDEX IF NOT EXISTS idx_items_d ON items(date)` },\n ]);\n await sqlite.execute({\n sql: `INSERT INTO settings(key,value) SELECT 'manager_pin','2024'\n WHERE NOT EXISTS (SELECT 1 FROM settings WHERE key='manager_pin')`,\n args: [],\n });\n try {\n await sqlite.execute({\n sql: `ALTER TABLE brokers ADD COLUMN deals_total INTEGER`,\n args: [],\n });\n } catch (_e) { /* колонка уже есть */ }\n // фото брокера для экрана на телевизоре\n try {\n await sqlite.execute({\n sql: `ALTER TABLE brokers ADD COLUMN photo TEXT`,\n args: [],\n });\n } catch (_e) { /* колонка уже есть */ }\n for (\n const col of [\n \"plan_deals INTEGER\",\n \"plan_sum INTEGER\",\n \"plan_zad INTEGER\",\n \"gross_add INTEGER\",\n ]\n ) {\n try {\n await sqlite.execute({\n sql: `ALTER TABLE manual_month ADD COLUMN ${col}`,\n args: [],\n });\n } catch (_e) { /* есть */ }\n }\n for (\n const col of [\n \"kind TEXT\",\n \"client TEXT\",\n \"developer TEXT\",\n \"complex TEXT\",\n \"channel TEXT\",\n \"broker_pct REAL\",\n \"broker_sum INTEGER\",\n \"cancel_req INTEGER\",\n \"cancel_date TEXT\",\n \"cancel_reason TEXT\",\n \"annulled_at TEXT\",\n \"archived INTEGER\",\n \"converted_at TEXT\",\n ]\n ) {\n try {\n await sqlite.execute({\n sql: `ALTER TABLE zadatki ADD COLUMN ${col}`,\n args: [],\n });\n } catch (_e) { /* есть */ }\n }\n for (\n const col of [\n \"sector TEXT\",\n \"client TEXT\",\n \"developer TEXT\",\n \"complex TEXT\",\n \"channel TEXT\",\n \"comm_in INTEGER\",\n \"ka INTEGER\",\n \"ka_pct REAL\",\n \"broker_pct REAL\",\n \"broker_sum INTEGER\",\n \"status TEXT\",\n \"decided_at TEXT\",\n \"comm_pct REAL\",\n \"agn_num TEXT\",\n \"agn_date TEXT\",\n \"agn_sign TEXT\",\n \"ddu_num TEXT\",\n \"ddu_date TEXT\",\n \"paid INTEGER\",\n \"ka_sum INTEGER\",\n \"counter TEXT\",\n \"paid_at TEXT\",\n \"doc_type TEXT\",\n \"rfm INTEGER\",\n \"rfm_sent INTEGER\",\n \"rfm_sent_at TEXT\",\n \"rfm_notified INTEGER\",\n \"agn_doc_name TEXT\",\n ]\n ) {\n try {\n await sqlite.execute({\n sql: `ALTER TABLE dkp ADD COLUMN ${col}`,\n args: [],\n });\n } catch (_e) { /* есть */ }\n }\n await sqlite.execute({\n sql:\n `UPDATE dkp SET doc_type = CASE WHEN sector='new' THEN 'ddu' ELSE 'dkp' END WHERE doc_type IS NULL`,\n args: [],\n });\n await sqlite.execute({\n sql:\n `UPDATE dkp SET rfm = CASE WHEN doc_type='dkp' AND deal_sum >= ${RFM_LIMIT} THEN 1 ELSE 0 END WHERE rfm IS NULL`,\n args: [],\n });\n // (разовые миграции августа-2026 отработали и удалены из кода)\n // токен для открытия табло без ПИНа\n const tk = Math.random().toString(36).slice(2, 10) +\n Math.random().toString(36).slice(2, 6);\n await sqlite.execute({\n sql: `INSERT INTO settings(key,value) SELECT 'tv_token', ?\n WHERE NOT EXISTS (SELECT 1 FROM settings WHERE key='tv_token')`,\n args: [tk],\n });\n await sqlite.execute({\n sql: `INSERT INTO settings(key,value) VALUES('schema_v',?)\n ON CONFLICT(key) DO UPDATE SET value=excluded.value`,\n args: [SCHEMA_V],\n });\n ready = true;\n}\n\n/* ---------- helpers ---------- */\nconst DATE_RE = /^\\d{4}-\\d{2}-\\d{2}$/;\nfunction okDate(s) {\n return typeof s === \"string\" && DATE_RE.test(s);\n}\nexport function addDays(dateStr, n) {\n const d = new Date(dateStr + \"T00:00:00Z\");\n d.setUTCDate(d.getUTCDate() + n);\n return d.toISOString().slice(0, 10);\n}\n/* автоцифры месяца из реестра: сделки и суммы — по дате сделки, доход — по дате оплаты */\nasync function autoMonths(months, brokerId) {\n const ph = months.map(() => \"?\").join(\",\");\n const bFilter = brokerId ? \" AND broker_id=?\" : \"\";\n const args = (extra) => (brokerId ? [...extra, brokerId] : extra);\n // один сетевой пакет к базе вместо трёх\n const [deals, paid, zad] = await sqlite.batch([\n {\n sql: `SELECT broker_id, substr(deal_date,1,7) AS month, COUNT(*) AS cnt,\n SUM(deal_sum) AS deal_sum, SUM(COALESCE(comm_in,0)) AS gross,\n SUM(broker_sum) AS broker_sum,\n SUM(CASE WHEN paid=1 THEN 0 ELSE broker_sum END) AS unpaid\n FROM dkp WHERE status='approved' AND substr(deal_date,1,7) IN (${ph})${bFilter}\n GROUP BY broker_id, month`,\n args: args(months),\n },\n {\n sql:\n `SELECT broker_id, substr(paid_at,1,7) AS month, COUNT(*) AS cnt, SUM(broker_sum) AS sum,\n SUM(COALESCE(comm_in,0)) AS gross_paid\n FROM dkp WHERE paid=1 AND paid_at IS NOT NULL AND substr(paid_at,1,7) IN (${ph})${bFilter}\n GROUP BY broker_id, month`,\n args: args(months),\n },\n {\n sql:\n `SELECT broker_id, substr(deal_date,1,7) AS month, COUNT(*) AS cnt, SUM(comm_sum) AS sum\n FROM zadatki WHERE status='approved' AND substr(deal_date,1,7) IN (${ph})${bFilter}\n GROUP BY broker_id, month`,\n args: args(months),\n },\n ]);\n const map = {};\n const cell = (b, m) => {\n const k = b + \"|\" + m;\n if (!map[k]) {\n map[k] = {\n broker_id: b,\n month: m,\n deals: 0,\n deal_sum: 0,\n gross: 0,\n zad_cnt: 0,\n zad_sum: 0,\n income: 0,\n paid_cnt: 0,\n unpaid: 0,\n };\n }\n return map[k];\n };\n for (const r of deals.rows) {\n const x = cell(Number(r.broker_id), String(r.month));\n x.deals = Number(r.cnt) || 0;\n x.deal_sum = Number(r.deal_sum) || 0;\n x.gross = Number(r.gross) || 0;\n x.unpaid = Number(r.unpaid) || 0;\n }\n for (const r of paid.rows) {\n const x = cell(Number(r.broker_id), String(r.month));\n x.income = Number(r.sum) || 0;\n x.paid_cnt = Number(r.cnt) || 0;\n x.gross_paid = Number(r.gross_paid) || 0; // валовая по ОПЛАЧЕННЫМ (месяц расчёта) — для табло\n }\n for (const r of zad.rows) {\n const x = cell(Number(r.broker_id), String(r.month));\n x.zad_cnt = Number(r.cnt) || 0;\n x.zad_sum = Number(r.sum) || 0;\n }\n return Object.values(map);\n}\n\nfunction todayMsk() {\n return new Date(Date.now() + 3 * 3600 * 1000).toISOString().slice(0, 10);\n}\nconst MONTHS_RU = [\n \"январе\",\n \"феврале\",\n \"марте\",\n \"апреле\",\n \"мае\",\n \"июне\",\n \"июле\",\n \"августе\",\n \"сентябре\",\n \"октябре\",\n \"ноябре\",\n \"декабре\",\n];\nfunction monthRu(m) {\n const i = Number(String(m).slice(5, 7)) - 1;\n return (MONTHS_RU[i] || m) + \" \" + String(m).slice(0, 4);\n}\nfunction prevMonthOf(dateStr) {\n const d = new Date(dateStr.slice(0, 7) + \"-01T00:00:00Z\");\n d.setUTCMonth(d.getUTCMonth() - 1);\n return d.toISOString().slice(0, 7);\n}\nasync function getUser(c) {\n const pin = c.req.header(\"x-pin\") || \"\";\n if (!pin) return null;\n const s = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key='manager_pin'\",\n args: [],\n });\n if (s.rows.length && String(s.rows[0].value) === pin) return { role: \"boss\" };\n const b = await sqlite.execute({\n sql: \"SELECT id,name FROM brokers WHERE pin=? AND active=1\",\n args: [pin],\n });\n if (b.rows.length) {\n return {\n role: \"broker\",\n id: Number(b.rows[0].id),\n name: String(b.rows[0].name),\n };\n }\n return null;\n}\nfunction jerr(c, msg, code) {\n return c.json({ error: msg }, code || 400);\n}\nfunction editable(dateStr) {\n const now = new Date();\n const todayUtc = now.toISOString().slice(0, 10);\n const from = addDays(todayUtc, -2);\n const to = addDays(todayUtc, 1);\n return dateStr >= from && dateStr <= to;\n}\n\n/* ---------- middleware ---------- */\napp.use(\"/api/*\", async (c, next) => {\n await init();\n if (c.req.path === \"/api/login\") return next();\n if (c.req.path === \"/api/tv\") return next(); // табло: доступ по токену из ссылки\n const user = await getUser(c);\n if (!user) return jerr(c, \"unauthorized\", 401);\n c.set(\"user\", user);\n return next();\n});\n\n/* ---------- auth ---------- */\napp.post(\"/api/login\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const pin = String(body.pin || \"\");\n if (!/^\\d{4,6}$/.test(pin)) return jerr(c, \"ПИН — от 4 до 6 цифр\");\n const s = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key='manager_pin'\",\n args: [],\n });\n if (s.rows.length && String(s.rows[0].value) === pin) {\n return c.json({ role: \"boss\", name: \"Руководитель\" });\n }\n const b = await sqlite.execute({\n sql: \"SELECT id,name FROM brokers WHERE pin=? AND active=1\",\n args: [pin],\n });\n if (b.rows.length) {\n return c.json({\n role: \"broker\",\n id: Number(b.rows[0].id),\n name: String(b.rows[0].name),\n });\n }\n return jerr(c, \"Неверный ПИН-код\", 401);\n});\n\n/* ---------- broker: day ---------- */\napp.get(\"/api/day\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const date = c.req.query(\"date\");\n if (!okDate(date)) return jerr(c, \"bad date\");\n const items = await sqlite.execute({\n sql:\n \"SELECT id,stage,text,label,amount,done,comment FROM items WHERE broker_id=? AND date=? ORDER BY stage,id\",\n args: [user.id, date],\n });\n const ci = await sqlite.execute({\n sql: \"SELECT morning,evening FROM cian WHERE broker_id=? AND date=?\",\n args: [user.id, date],\n });\n const prev = await sqlite.execute({\n sql:\n \"SELECT morning,evening FROM cian WHERE broker_id=? AND date<=? ORDER BY date DESC LIMIT 1\",\n args: [user.id, date],\n });\n let last = null;\n if (prev.rows.length) {\n const r = prev.rows[0];\n last = r.evening !== null && r.evening !== undefined\n ? Number(r.evening)\n : (r.morning !== null && r.morning !== undefined\n ? Number(r.morning)\n : null);\n }\n return c.json({\n items: items.rows,\n cian: ci.rows.length ? ci.rows[0] : { morning: null, evening: null },\n cianLast: last,\n });\n});\n\napp.post(\"/api/items\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const date = b.date, stage = Number(b.stage);\n const text = String(b.text || \"\").trim().slice(0, 300);\n const label = String(b.label || \"\").trim().slice(0, 40);\n const amount = Math.max(0, Math.floor(Number(b.amount) || 0));\n if (!okDate(date) || !(stage >= 1 && stage <= 5) || !text) {\n return jerr(c, \"bad item\");\n }\n if (!editable(date)) {\n return jerr(c, \"Редактировать можно только сегодня и вчера\");\n }\n const r = await sqlite.execute({\n sql:\n \"INSERT INTO items(broker_id,date,stage,text,label,amount) VALUES (?,?,?,?,?,?)\",\n args: [user.id, date, stage, text, label, amount],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n});\n\napp.delete(\"/api/items/:id\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const cur = await sqlite.execute({\n sql: \"SELECT date FROM items WHERE id=? AND broker_id=?\",\n args: [id, user.id],\n });\n if (!cur.rows.length) return jerr(c, \"not found\", 404);\n if (!editable(String(cur.rows[0].date))) {\n return jerr(c, \"Редактировать можно только сегодня и вчера\");\n }\n await sqlite.execute({\n sql: \"DELETE FROM items WHERE id=? AND broker_id=?\",\n args: [id, user.id],\n });\n return c.json({ ok: true });\n});\n\napp.post(\"/api/items/:id/mark\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const done = b.done === null ? null : (b.done ? 1 : 0);\n const comment = String(b.comment || \"\").slice(0, 500);\n const cur = await sqlite.execute({\n sql: \"SELECT date FROM items WHERE id=? AND broker_id=?\",\n args: [Number(c.req.param(\"id\")), user.id],\n });\n if (!cur.rows.length) return jerr(c, \"not found\", 404);\n if (!editable(String(cur.rows[0].date))) {\n return jerr(c, \"Редактировать можно только сегодня и вчера\");\n }\n await sqlite.execute({\n sql: \"UPDATE items SET done=?, comment=? WHERE id=? AND broker_id=?\",\n args: [done, comment, Number(c.req.param(\"id\")), user.id],\n });\n return c.json({ ok: true });\n});\n\napp.post(\"/api/items/:id/carry\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({\n sql:\n \"SELECT date,stage,text,label,amount FROM items WHERE id=? AND broker_id=?\",\n args: [id, user.id],\n });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n const it = r.rows[0];\n const to = addDays(String(it.date), 1);\n await sqlite.execute({\n sql:\n \"INSERT INTO items(broker_id,date,stage,text,label,amount) VALUES (?,?,?,?,?,?)\",\n args: [\n user.id,\n to,\n Number(it.stage),\n String(it.text),\n String(it.label || \"\"),\n Number(it.amount) || 0,\n ],\n });\n return c.json({ ok: true, to });\n});\n\napp.post(\"/api/cian\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const date = b.date, field = b.field;\n const value = Math.max(0, Math.min(999, Math.floor(Number(b.value) || 0)));\n if (!okDate(date) || (field !== \"morning\" && field !== \"evening\")) {\n return jerr(c, \"bad cian\");\n }\n if (!editable(date)) {\n return jerr(c, \"Редактировать можно только сегодня и вчера\");\n }\n await sqlite.execute({\n sql:\n \"INSERT INTO cian(broker_id,date,morning,evening) VALUES (?,?,NULL,NULL) ON CONFLICT(broker_id,date) DO NOTHING\",\n args: [user.id, date],\n });\n await sqlite.execute({\n sql: field === \"morning\"\n ? \"UPDATE cian SET morning=? WHERE broker_id=? AND date=?\"\n : \"UPDATE cian SET evening=? WHERE broker_id=? AND date=?\",\n args: [value, user.id, date],\n });\n return c.json({ ok: true });\n});\n\n/* ---------- broker: история месяца ---------- */\napp.get(\"/api/history\", async (c) => {\n const user = c.get(\"user\");\n const month = String(c.req.query(\"month\") || \"\");\n if (!/^\\d{4}-\\d{2}$/.test(month)) return jerr(c, \"bad month\");\n let brokerId = user.id;\n if (user.role === \"boss\") {\n brokerId = Number(c.req.query(\"broker_id\"));\n if (!brokerId) return jerr(c, \"broker_id required\");\n }\n const from = month + \"-01\";\n const to = month + \"-31\";\n const items = await sqlite.execute({\n sql: `SELECT id,date,stage,text,label,amount,done,comment FROM items\n WHERE broker_id=? AND date BETWEEN ? AND ? ORDER BY date DESC, stage, id`,\n args: [brokerId, from, to],\n });\n const cian = await sqlite.execute({\n sql:\n \"SELECT date,morning,evening FROM cian WHERE broker_id=? AND date BETWEEN ? AND ? ORDER BY date\",\n args: [brokerId, from, to],\n });\n return c.json({\n month,\n broker_id: brokerId,\n items: items.rows,\n cian: cian.rows,\n });\n});\n\n/* ---------- broker: stats (сырьё, агрегация на клиенте) ---------- */\napp.get(\"/api/mystats\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const date = c.req.query(\"date\");\n if (!okDate(date)) return jerr(c, \"bad date\");\n const from30 = addDays(date, -29), from7 = addDays(date, -6);\n const curMonth = date.slice(0, 7), prevMonth = prevMonthOf(date);\n const fromAll = prevMonth + \"-01\";\n // один батч из 7 запросов + авторасчёт параллельно — два сетевых пакета вместо восьми\n const [batch, auto] = await Promise.all([\n sqlite.batch([\n {\n sql:\n \"SELECT date,stage,amount,done FROM items WHERE broker_id=? AND date BETWEEN ? AND ?\",\n args: [user.id, fromAll, date],\n },\n {\n sql:\n \"SELECT date,morning,evening FROM cian WHERE broker_id=? AND date<=? ORDER BY date\",\n args: [user.id, date],\n },\n {\n sql:\n \"SELECT month,deals,zad_cnt,zad_sum,income,gross_add,plan_deals,plan_sum,plan_zad FROM manual_month WHERE broker_id=? AND month IN (?,?)\",\n args: [user.id, curMonth, prevMonth],\n },\n { sql: \"SELECT deals_total FROM brokers WHERE id=?\", args: [user.id] },\n {\n sql:\n \"SELECT month,deals,zad_cnt,zad_sum,income,gross_add FROM manual_month WHERE broker_id=?\",\n args: [user.id],\n },\n {\n sql:\n \"SELECT COUNT(*) AS cnt FROM dkp WHERE broker_id=? AND status='approved'\",\n args: [user.id],\n },\n {\n sql: `SELECT DISTINCT m FROM (\n SELECT substr(paid_at,1,7) AS m FROM dkp WHERE broker_id=? AND paid=1 AND paid_at IS NOT NULL\n UNION SELECT substr(deal_date,1,7) FROM dkp WHERE broker_id=? AND status='approved'\n UNION SELECT month FROM manual_month WHERE broker_id=?\n UNION SELECT month FROM net_income WHERE broker_id=?\n ) WHERE m IS NOT NULL ORDER BY m`,\n args: [user.id, user.id, user.id, user.id],\n },\n ]),\n autoMonths([curMonth, prevMonth], user.id),\n ]);\n const [items, ci, manual, me, histManual, totCnt, histMonths] = batch;\n // всего сделок = вписанная база (до приложения) + одобренные сделки из реестра за всё время\n const totAuto = totCnt.rows.length ? Number(totCnt.rows[0].cnt) || 0 : 0;\n const totBase =\n me.rows.length && me.rows[0].deals_total !== null &&\n me.rows[0].deals_total !== undefined\n ? Number(me.rows[0].deals_total)\n : null;\n const dealsTotal = totBase === null && totAuto === 0\n ? null\n : (totBase || 0) + totAuto;\n const months = histMonths.rows.map((r) => String(r.m)).filter((m) =>\n /^\\d{4}-\\d{2}$/.test(m)\n );\n if (!months.includes(curMonth)) months.push(curMonth);\n const histAuto = months.length ? await autoMonths(months, user.id) : [];\n return c.json({\n items: items.rows,\n cian: ci.rows,\n from30,\n from7,\n curMonth,\n prevMonth,\n manual: manual.rows,\n dealsTotal,\n auto,\n history: { months, auto: histAuto, manual: histManual.rows },\n });\n});\n\n/* ---------- boss ---------- */\napp.get(\"/api/team\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const date = c.req.query(\"date\");\n if (!okDate(date)) return jerr(c, \"bad date\");\n const from30 = addDays(date, -29), from7 = addDays(date, -6);\n const curMonth = date.slice(0, 7), prevMonth = prevMonthOf(date);\n const fromAll = prevMonth + \"-01\";\n // один батч из 7 запросов + авторасчёт параллельно\n const [batch, auto] = await Promise.all([\n sqlite.batch([\n {\n sql: \"SELECT id,name,pin,active,deals_total FROM brokers ORDER BY name\",\n args: [],\n },\n {\n sql:\n \"SELECT broker_id,date,stage,amount,done FROM items WHERE date BETWEEN ? AND ?\",\n args: [fromAll, date],\n },\n {\n sql:\n \"SELECT broker_id,date,morning,evening FROM cian WHERE date BETWEEN ? AND ? ORDER BY date\",\n args: [from30, date],\n },\n {\n sql:\n `SELECT c.broker_id, COALESCE(c.evening, c.morning) AS val FROM cian c\n JOIN (SELECT broker_id, MAX(date) AS d FROM cian\n WHERE COALESCE(evening, morning) IS NOT NULL GROUP BY broker_id) x\n ON x.broker_id=c.broker_id AND x.d=c.date`,\n args: [],\n },\n {\n sql:\n `SELECT i.broker_id, i.stage, i.text, i.label, i.done, i.comment, b.name\n FROM items i JOIN brokers b ON b.id=i.broker_id\n WHERE i.date=? ORDER BY b.name, i.stage, i.id`,\n args: [date],\n },\n {\n sql:\n \"SELECT broker_id,month,deals,zad_cnt,zad_sum,income,gross_add,plan_deals,plan_sum,plan_zad FROM manual_month WHERE month IN (?,?)\",\n args: [curMonth, prevMonth],\n },\n {\n sql:\n \"SELECT broker_id, COUNT(*) AS cnt FROM dkp WHERE status='approved' GROUP BY broker_id\",\n args: [],\n },\n ]),\n autoMonths([curMonth, prevMonth]),\n ]);\n const [brokers, items, ci, cianLast, todayItems, manual, totalAuto] = batch;\n return c.json({\n brokers: brokers.rows,\n items: items.rows,\n cian: ci.rows,\n cianLast: cianLast.rows,\n today: todayItems.rows,\n from30,\n from7,\n date,\n curMonth,\n prevMonth,\n manual: manual.rows,\n auto,\n totalAuto: totalAuto.rows,\n });\n});\n\napp.post(\"/api/manual\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const brokerId = Number(b.broker_id);\n const month = String(b.month || \"\");\n if (!brokerId || !/^\\d{4}-\\d{2}$/.test(month)) return jerr(c, \"bad manual\");\n const clean = (v, max) => {\n if (v === undefined || v === null) return null;\n const n = Number(v);\n if (!Number.isFinite(n) || n < 0) return NaN;\n return Math.min(max, Math.floor(n));\n };\n const deals = clean(b.deals, 99);\n const zadCnt = clean(b.zad_cnt, 999);\n const zadSum = clean(b.zad_sum, 9999999999);\n const income = clean(b.income, 9999999999);\n const planDeals = clean(b.plan_deals, 99);\n const planSum = clean(b.plan_sum, 9999999999);\n const planZad = clean(b.plan_zad, 999);\n const grossAdd = clean(b.gross_add, 9999999999);\n const all = [\n deals,\n zadCnt,\n zadSum,\n income,\n grossAdd,\n planDeals,\n planSum,\n planZad,\n ];\n if (all.some((v) => Number.isNaN(v))) return jerr(c, \"bad manual value\");\n // сброс правки к авточислу из реестра\n const RESETTABLE = [\n \"deals\",\n \"zad_cnt\",\n \"zad_sum\",\n \"income\",\n \"gross_add\",\n \"plan_deals\",\n \"plan_sum\",\n \"plan_zad\",\n ];\n const reset = Array.isArray(b.reset)\n ? b.reset.filter((f) => RESETTABLE.includes(String(f)))\n : [];\n if (reset.length) {\n await sqlite.execute({\n sql: `UPDATE manual_month SET ${\n reset.map((f) => `${f}=NULL`).join(\",\")\n } WHERE broker_id=? AND month=?`,\n args: [brokerId, month],\n });\n if (all.every((v) => v === null)) return c.json({ ok: true, reset });\n }\n if (all.every((v) => v === null)) return jerr(c, \"nothing to set\");\n await sqlite.execute({\n sql:\n `INSERT INTO manual_month(broker_id,month,deals,zad_cnt,zad_sum,income,gross_add,plan_deals,plan_sum,plan_zad) VALUES (?,?,?,?,?,?,?,?,?,?)\n ON CONFLICT(broker_id,month) DO UPDATE SET\n deals=COALESCE(excluded.deals,manual_month.deals),\n zad_cnt=COALESCE(excluded.zad_cnt,manual_month.zad_cnt),\n zad_sum=COALESCE(excluded.zad_sum,manual_month.zad_sum),\n income=COALESCE(excluded.income,manual_month.income),\n gross_add=COALESCE(excluded.gross_add,manual_month.gross_add),\n plan_deals=COALESCE(excluded.plan_deals,manual_month.plan_deals),\n plan_sum=COALESCE(excluded.plan_sum,manual_month.plan_sum),\n plan_zad=COALESCE(excluded.plan_zad,manual_month.plan_zad)`,\n args: [\n brokerId,\n month,\n deals,\n zadCnt,\n zadSum,\n income,\n grossAdd,\n planDeals,\n planSum,\n planZad,\n ],\n });\n return c.json({ ok: true });\n});\n\n// всего сделок за всё время в компании\napp.post(\"/api/brokers/:id/total\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const n = Number(b.deals_total);\n if (!id || !Number.isFinite(n) || n < 0) {\n return jerr(c, \"Введите число от 0 до 9999\");\n }\n await sqlite.execute({\n sql: \"UPDATE brokers SET deals_total=? WHERE id=?\",\n args: [Math.min(9999, Math.floor(n)), id],\n });\n return c.json({ ok: true });\n});\n\napp.post(\"/api/brokers\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const name = String(b.name || \"\").trim().slice(0, 80);\n const pin = String(b.pin || \"\");\n if (!name) return jerr(c, \"Укажите имя брокера\");\n if (!/^\\d{4,6}$/.test(pin)) return jerr(c, \"ПИН — от 4 до 6 цифр\");\n const s = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key='manager_pin'\",\n args: [],\n });\n if (s.rows.length && String(s.rows[0].value) === pin) {\n return jerr(c, \"Этот ПИН занят руководителем\");\n }\n try {\n const r = await sqlite.execute({\n sql: \"INSERT INTO brokers(name,pin) VALUES (?,?)\",\n args: [name, pin],\n });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n } catch (_e) {\n return jerr(c, \"Такой ПИН уже занят другим брокером\");\n }\n});\n\napp.post(\"/api/brokers/:id\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n if (b.active !== undefined) {\n await sqlite.execute({\n sql: \"UPDATE brokers SET active=? WHERE id=?\",\n args: [b.active ? 1 : 0, id],\n });\n }\n if (b.pin !== undefined) {\n const pin = String(b.pin);\n if (!/^\\d{4,6}$/.test(pin)) return jerr(c, \"ПИН — от 4 до 6 цифр\");\n try {\n await sqlite.execute({\n sql: \"UPDATE brokers SET pin=? WHERE id=?\",\n args: [pin, id],\n });\n } catch (_e) {\n return jerr(c, \"Такой ПИН уже занят\");\n }\n }\n if (b.name !== undefined) {\n const name = String(b.name).trim().slice(0, 80);\n if (name) {\n await sqlite.execute({\n sql: \"UPDATE brokers SET name=? WHERE id=?\",\n args: [name, id],\n });\n }\n }\n return c.json({ ok: true });\n});\n\napp.post(\"/api/settings\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n if (b.manager_pin !== undefined) {\n const pin = String(b.manager_pin);\n if (!/^\\d{4,6}$/.test(pin)) return jerr(c, \"ПИН — от 4 до 6 цифр\");\n const clash = await sqlite.execute({\n sql: \"SELECT id FROM brokers WHERE pin=?\",\n args: [pin],\n });\n if (clash.rows.length) return jerr(c, \"Этот ПИН занят брокером\");\n await sqlite.execute({\n sql: \"UPDATE settings SET value=? WHERE key='manager_pin'\",\n args: [pin],\n });\n }\n return c.json({ ok: true });\n});\n\n/* ---------- мгновенные push (задаток / ДКП / одобрение) ---------- */\nasync function sendPushTo(rows, payload) {\n try {\n const mod = await import(\"npm:web-push@3.6.7\");\n const webpush = mod.default || mod;\n const priv = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"VAPID_PRIVATE_KEY\")\n : null;\n if (!priv) return;\n webpush.setVapidDetails(\"mailto:tambovtsev007@gmail.com\", vapidPub(), priv);\n for (const s of rows) {\n try {\n await webpush.sendNotification(\n {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n JSON.stringify(payload),\n );\n } catch (e) {\n const code = e && e.statusCode;\n // 404/410 — подписка умерла; 400/401/403 — подписка под старым VAPID-ключом.\n // Убираем из базы, чтобы кнопка «Включить» создала свежую под текущим ключом.\n if ([400, 401, 403, 404, 410].includes(code)) {\n await dropSubscription(String(s.endpoint));\n }\n }\n }\n } catch (_e) { /* web-push недоступен — не мешаем основному запросу */ }\n}\nasync function notifyBoss(title, body) {\n try {\n const subs = await sqlite.execute({\n sql: \"SELECT endpoint,p256dh,auth FROM push_subs WHERE role='boss'\",\n args: [],\n });\n if (subs.rows.length) {\n await sendPushTo(subs.rows, { title, body, url: \"/\" });\n }\n } catch (_e) {}\n}\nasync function notifyBroker(id, title, body) {\n try {\n const subs = await sqlite.execute({\n sql:\n \"SELECT endpoint,p256dh,auth FROM push_subs WHERE role='broker' AND broker_id=?\",\n args: [id],\n });\n if (subs.rows.length) {\n await sendPushTo(subs.rows, { title, body, url: \"/\" });\n }\n } catch (_e) {}\n}\n\n/* дополнительные API (выходные, развал задатков) — в extra.ts из-за лимита 80К символов */\nregisterExtra(app, { jerr, notifyBoss, notifyBroker });\n\n/* ---------- документы (blob-хранилище) ---------- */\nconst DOC_RE =\n /^data:(application\\/pdf|application\\/msword|application\\/vnd\\.openxmlformats-officedocument\\.wordprocessingml\\.document|image\\/(jpeg|jpg|png|webp));base64,/;\nfunction checkDoc(doc) {\n if (typeof doc !== \"string\" || !DOC_RE.test(doc)) {\n return \"Приложите файл: PDF, Word или фото\";\n }\n if (doc.length > 4500000) return \"Файл слишком большой (до ~3 МБ)\";\n return null;\n}\napp.get(\"/api/doc/:kind/:id\", async (c) => {\n const user = c.get(\"user\");\n const kind = c.req.param(\"kind\"), id = Number(c.req.param(\"id\")); // z — задаток, d — ДКП/ДДУ, a — агентский\n if ((kind !== \"z\" && kind !== \"d\" && kind !== \"a\") || !id) {\n return jerr(c, \"bad doc\");\n }\n const table = kind === \"z\" ? \"zadatki\" : \"dkp\";\n const cols = kind === \"z\"\n ? \"broker_id,doc_name\"\n : \"broker_id,doc_name,agn_doc_name\";\n const r = await sqlite.execute({\n sql: `SELECT ${cols} FROM ${table} WHERE id=?`,\n args: [id],\n });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n if (user.role !== \"boss\" && Number(r.rows[0].broker_id) !== user.id) {\n return jerr(c, \"forbidden\", 403);\n }\n let dataUrl;\n try {\n dataUrl = await (await blob.get(`doc:${kind}:${id}`)).text();\n } catch (_e) {\n return jerr(c, \"Файл не найден\", 404);\n }\n const m = dataUrl.match(/^data:([^;]+);base64,(.*)$/s);\n if (!m) return jerr(c, \"bad file\", 500);\n const bin = Uint8Array.from(atob(m[2]), (ch) => ch.charCodeAt(0));\n const name = String(\n (kind === \"a\" ? r.rows[0].agn_doc_name : r.rows[0].doc_name) ||\n (\"document-\" + id),\n );\n c.header(\"Content-Type\", m[1]);\n c.header(\n \"Content-Disposition\",\n `attachment; filename*=UTF-8''${encodeURIComponent(name)}`,\n );\n return c.body(bin);\n});\n\n/* ---------- процент брокера на месяц сделки (снапшот, чтобы не спорить потом) ---------- */\nconst NDS = 1.05; // НДС 5% уже включён во входящую комиссию\nfunction pctScheme(deals) {\n return deals >= 4 ? 55 : deals === 3 ? 50 : deals === 2 ? 45 : 40;\n}\nasync function brokerPctFor(brokerId, dealDate) {\n const prevM = prevMonthOf(dealDate);\n const r = await sqlite.execute({\n sql: \"SELECT deals FROM manual_month WHERE broker_id=? AND month=?\",\n args: [brokerId, prevM],\n });\n if (\n r.rows.length && r.rows[0].deals !== null && r.rows[0].deals !== undefined\n ) {\n return pctScheme(Number(r.rows[0].deals));\n }\n const a = await sqlite.execute({\n sql:\n \"SELECT COUNT(*) AS cnt FROM dkp WHERE broker_id=? AND status='approved' AND substr(deal_date,1,7)=?\",\n args: [brokerId, prevM],\n });\n return pctScheme(a.rows.length ? Number(a.rows[0].cnt) || 0 : 0);\n}\n\n/* ---------- задатки/брони: фиксация брокером + одобрение руководителем ---------- */\nconst CHANNELS = [\"Прямой\", \"Домклик\", \"Трендагент\"];\napp.post(\"/api/zadatki\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const kind = b.kind === \"bron\" ? \"bron\" : \"zadatok\";\n const crm = String(b.crm_id || \"\").trim().slice(0, 60);\n const client = String(b.client || \"\").trim().slice(0, 120);\n const dealSum = Math.floor(Number(b.deal_sum) || 0);\n const dealDate = String(b.deal_date || \"\");\n const docName = String(b.doc_name || \"\").trim().slice(0, 150);\n if (!crm) return jerr(c, \"Укажите № заявки в CRM\");\n if (!client) return jerr(c, \"Укажите фамилию клиента\");\n if (!(dealSum > 0)) return jerr(c, \"Укажите сумму сделки\");\n if (!okDate(dealDate)) return jerr(c, \"Укажите дату\");\n const docErr = checkDoc(b.doc);\n if (docErr) return jerr(c, docErr);\n\n const bpct = await brokerPctFor(user.id, dealDate);\n let buyer = null,\n pct = null,\n commSum = 0,\n developer = null,\n complexN = null,\n channel = null,\n brokerSum = null;\n\n if (kind === \"zadatok\") {\n buyer = String(b.buyer || \"\").trim().slice(0, 120);\n pct = Number(b.comm_pct);\n if (!buyer) return jerr(c, \"Укажите фамилию покупателя\");\n if (!Number.isFinite(pct) || pct <= 0 || pct > 100) {\n return jerr(c, \"Процент комиссии — от 0,1 до 100\");\n }\n commSum = Math.round(dealSum * pct / 100);\n } else {\n developer = String(b.developer || \"\").trim().slice(0, 120);\n complexN = String(b.complex || \"\").trim().slice(0, 120);\n channel = String(b.channel || \"\");\n pct = Number(b.comm_pct);\n if (!developer) return jerr(c, \"Укажите застройщика\");\n if (!complexN) return jerr(c, \"Укажите ЖК\");\n if (!CHANNELS.includes(channel)) {\n return jerr(c, \"Выберите канал: Прямой, Домклик или Трендагент\");\n }\n if (!Number.isFinite(pct) || pct <= 0 || pct > 100) {\n return jerr(c, \"Процент комиссии застройщика — от 0,1 до 100\");\n }\n commSum = Math.round(dealSum * pct / 100);\n brokerSum = Math.round(commSum / NDS * bpct / 100);\n }\n\n const r = await sqlite.execute({\n sql:\n `INSERT INTO zadatki(broker_id,crm_id,buyer,deal_sum,comm_pct,comm_sum,deal_date,doc_name,kind,client,developer,complex,channel,broker_pct,broker_sum)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [\n user.id,\n crm,\n buyer || \"\",\n dealSum,\n pct ?? 0,\n commSum,\n dealDate,\n docName || null,\n kind,\n client,\n developer,\n complexN,\n channel,\n kind === \"bron\" ? bpct : null,\n brokerSum,\n ],\n });\n const id = Number(r.lastInsertRowid);\n await blob.set(`doc:z:${id}`, String(b.doc));\n const label = kind === \"bron\"\n ? \"Новая бронь (новостройка)\"\n : \"Новый задаток на одобрение\";\n await notifyBoss(\n label,\n `${user.name}: ${client}, комиссия ${\n commSum.toLocaleString(\"ru-RU\")\n } ₽. Откройте и одобрите`,\n );\n return c.json({\n ok: true,\n id,\n comm_sum: commSum,\n broker_pct: kind === \"bron\" ? bpct : null,\n broker_sum: brokerSum,\n });\n});\n\napp.get(\"/api/zadatki\", async (c) => {\n const user = c.get(\"user\");\n if (user.role === \"broker\") {\n const r = await sqlite.execute({\n sql:\n `SELECT id,crm_id,buyer,deal_sum,comm_pct,comm_sum,deal_date,doc_name,status,created_at,\n kind,client,complex,broker_pct,broker_sum,cancel_req,cancel_date,cancel_reason\n FROM zadatki WHERE broker_id=? ORDER BY id DESC LIMIT 50`,\n args: [user.id],\n });\n return c.json({ rows: r.rows });\n }\n if (c.req.query(\"all\") === \"1\") {\n const r = await sqlite.execute({\n sql:\n `SELECT z.*, b.name AS broker_name FROM zadatki z JOIN brokers b ON b.id=z.broker_id\n ORDER BY z.deal_date DESC, z.id DESC`,\n args: [],\n });\n return c.json({ rows: r.rows });\n }\n const month = String(c.req.query(\"month\") || \"\");\n const useMonth = /^\\d{4}-\\d{2}$/.test(month);\n const r = await sqlite.execute({\n sql: useMonth\n ? `SELECT z.*, b.name AS broker_name FROM zadatki z JOIN brokers b ON b.id=z.broker_id\n WHERE z.status='pending' OR z.deal_date LIKE ?\n ORDER BY CASE z.status WHEN 'pending' THEN 0 ELSE 1 END, z.deal_date DESC, z.id DESC LIMIT 300`\n : `SELECT z.*, b.name AS broker_name FROM zadatki z JOIN brokers b ON b.id=z.broker_id\n WHERE z.status='pending' OR z.decided_at >= datetime('now','-60 days')\n ORDER BY CASE z.status WHEN 'pending' THEN 0 ELSE 1 END, z.id DESC LIMIT 200`,\n args: useMonth ? [month + \"-%\"] : [],\n });\n return c.json({ rows: r.rows, month: useMonth ? month : null });\n});\n\napp.delete(\"/api/zadatki/:id\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const cur = await sqlite.execute({\n sql: \"SELECT * FROM zadatki WHERE id=?\",\n args: [id],\n });\n if (!cur.rows.length) return jerr(c, \"not found\", 404);\n await sqlite.execute({ sql: \"DELETE FROM zadatki WHERE id=?\", args: [id] });\n try {\n await blob.delete(`doc:z:${id}`);\n } catch (_e) {}\n return c.json({ ok: true });\n});\n\n/* ---------- ретро-данные прошлых месяцев (ручной ввод/корректировка) ---------- */\napp.get(\"/api/retro\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const month = String(c.req.query(\"month\") || \"\");\n if (!/^\\d{4}-(0[1-9]|1[0-2])$/.test(month)) return jerr(c, \"bad month\");\n const manual = await sqlite.execute({\n sql:\n \"SELECT broker_id,deals,zad_cnt,zad_sum,income,gross_add,plan_deals,plan_sum,plan_zad FROM manual_month WHERE month=?\",\n args: [month],\n });\n const net = await sqlite.execute({\n sql: \"SELECT broker_id,amount FROM net_income WHERE month=?\",\n args: [month],\n });\n const auto = await autoMonths([month]);\n return c.json({ month, manual: manual.rows, net: net.rows, auto });\n});\n\napp.post(\"/api/zadatki/:id/decide\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const approve = !!b.approve;\n const cur = await sqlite.execute({\n sql: \"SELECT * FROM zadatki WHERE id=? AND status='pending'\",\n args: [id],\n });\n if (!cur.rows.length) return jerr(c, \"Задаток не найден или уже решён\", 404);\n const z = cur.rows[0];\n await sqlite.execute({\n sql: \"UPDATE zadatki SET status=?, decided_at=datetime('now') WHERE id=?\",\n args: [approve ? \"approved\" : \"rejected\", id],\n });\n if (approve) {\n await notifyBroker(\n Number(z.broker_id),\n \"Задаток зафиксирован ✅\",\n `${z.buyer}: комиссия ${\n Number(z.comm_sum).toLocaleString(\"ru-RU\")\n } ₽ учтена в вашем результате`,\n );\n } else {\n await notifyBroker(\n Number(z.broker_id),\n \"Задаток отклонён\",\n `${z.buyer}: уточните данные у руководителя и отправьте заново`,\n );\n }\n return c.json({ ok: true });\n});\n\n/* ---------- ДКП / сделки: реестр + расчёт комиссии брокера на момент сделки ---------- */\napp.post(\"/api/dkp\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const sector = b.sector === \"new\" ? \"new\" : \"secondary\";\n const crm = String(b.crm_id || \"\").trim().slice(0, 60);\n const dealSum = Math.floor(Number(b.deal_sum) || 0);\n const commPct = Number(b.comm_pct);\n const dealDate = String(b.deal_date || \"\");\n const docName = String(b.doc_name || \"\").trim().slice(0, 150);\n if (!crm) return jerr(c, \"Укажите № заявки в CRM\");\n if (!(dealSum > 0)) return jerr(c, \"Укажите сумму сделки\");\n if (!Number.isFinite(commPct) || commPct <= 0 || commPct > 100) {\n return jerr(\n c,\n sector === \"new\"\n ? \"Укажите % комиссии застройщика (0,1–100)\"\n : \"Укажите % входящей комиссии (0,1–100)\",\n );\n }\n if (!okDate(dealDate)) return jerr(c, \"Укажите дату сделки\");\n const docErr = checkDoc(b.doc);\n if (docErr) return jerr(c, docErr);\n // агентский договор (PDF/фото) — по желанию, вторым файлом\n let agnDocName = null;\n if (b.agn_doc) {\n const e2 = checkDoc(b.agn_doc);\n if (e2) return jerr(c, \"Агентский договор: \" + e2);\n agnDocName = String(b.agn_doc_name || \"agentskiy\").trim().slice(0, 150);\n }\n const commIn = Math.round(dealSum * commPct / 100);\n const docType = sector === \"new\"\n ? (b.doc_type === \"dkp\" ? \"dkp\" : \"ddu\")\n : \"dkp\";\n const rfm = docType === \"dkp\" && dealSum >= RFM_LIMIT ? 1 : 0;\n\n const bpct = await brokerPctFor(user.id, dealDate);\n let side = null,\n person = null,\n client = null,\n developer = null,\n complexN = null,\n channel = null;\n let ka = 0, kaPct = null, kaSum = 0, brokerSum;\n let agnNum = null,\n agnDate = null,\n agnSign = null,\n dduNum = null,\n dduDate = null,\n counter = null;\n\n if (sector === \"secondary\") {\n side = String(b.side || \"\");\n person = String(b.person || \"\");\n client = String(b.client || \"\").trim().slice(0, 120);\n counter = String(b.counter || \"\").trim().slice(0, 120);\n if (side !== \"Покупатель\" && side !== \"Продавец\") {\n return jerr(c, \"Кого сопровождаем: покупатель или продавец\");\n }\n if (person !== \"Физлицо\" && person !== \"Юрлицо\") {\n return jerr(c, \"Физлицо или юрлицо?\");\n }\n if (!client) return jerr(c, \"Укажите фамилию клиента\");\n agnNum = String(b.agn_num || \"\").trim().slice(0, 80);\n agnDate = String(b.agn_date || \"\");\n agnSign = String(b.agn_sign || \"\");\n if (!agnNum) return jerr(c, \"Укажите № агентского договора\");\n if (!okDate(agnDate)) return jerr(c, \"Укажите дату агентского договора\");\n if (agnSign !== \"Онлайн\" && agnSign !== \"Офлайн\") {\n return jerr(c, \"Формат агентского договора: онлайн или офлайн?\");\n }\n ka = b.ka ? 1 : 0;\n if (ka) {\n kaPct = Number(b.ka_pct);\n if (!Number.isFinite(kaPct) || kaPct <= 0 || kaPct >= 100) {\n return jerr(c, \"Процент контрагента — от 0,1 до 99\");\n }\n if (kaPct >= commPct) {\n return jerr(c, \"Процент контрагента должен быть меньше нашей комиссии\");\n }\n kaSum = Math.round(dealSum * kaPct / 100 / NDS);\n }\n const base = commIn / NDS - kaSum;\n brokerSum = Math.round(base * bpct / 100);\n } else {\n client = String(b.client || \"\").trim().slice(0, 120);\n developer = String(b.developer || \"\").trim().slice(0, 120);\n complexN = String(b.complex || \"\").trim().slice(0, 120);\n channel = String(b.channel || \"\");\n dduNum = String(b.ddu_num || \"\").trim().slice(0, 80);\n dduDate = String(b.ddu_date || \"\");\n if (!client) return jerr(c, \"Укажите фамилию клиента\");\n if (!developer) return jerr(c, \"Укажите застройщика\");\n if (!complexN) return jerr(c, \"Укажите ЖК\");\n if (!CHANNELS.includes(channel)) {\n return jerr(c, \"Выберите канал: Прямой, Домклик или Трендагент\");\n }\n if (!dduNum) {\n return jerr(c, docType === \"dkp\" ? \"Укажите № ДКП\" : \"Укажите № ДДУ\");\n }\n if (!okDate(dduDate)) {\n return jerr(\n c,\n docType === \"dkp\" ? \"Укажите дату ДКП\" : \"Укажите дату ДДУ\",\n );\n }\n brokerSum = Math.round(commIn / NDS * bpct / 100);\n }\n\n const r = await sqlite.execute({\n sql:\n `INSERT INTO dkp(broker_id,crm_id,side,person,deal_sum,deal_date,doc_name,sector,client,developer,complex,channel,comm_in,comm_pct,ka,ka_pct,ka_sum,broker_pct,broker_sum,agn_num,agn_date,agn_sign,ddu_num,ddu_date,counter,doc_type,rfm,agn_doc_name,rfm_sent,rfm_notified,status,paid)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,0,0,'pending',0)`,\n args: [\n user.id,\n crm,\n side || \"\",\n person || \"\",\n dealSum,\n dealDate,\n docName || null,\n sector,\n client,\n developer,\n complexN,\n channel,\n commIn,\n commPct,\n ka,\n kaPct,\n kaSum,\n bpct,\n brokerSum,\n agnNum,\n agnDate,\n agnSign,\n dduNum,\n dduDate,\n counter,\n docType,\n rfm,\n agnDocName,\n ],\n });\n const id = Number(r.lastInsertRowid);\n await blob.set(`doc:d:${id}`, String(b.doc));\n if (b.agn_doc) await blob.set(`doc:a:${id}`, String(b.agn_doc));\n const what = sector === \"new\"\n ? `новостройка ${complexN}`\n : String(side).toLowerCase();\n const dealMonth = dealDate.slice(0, 7);\n const backdated = dealMonth < todayMsk().slice(0, 7)\n ? ` Дата сделки — ${dealDate}, поэтому она учтена в ${\n monthRu(dealMonth)\n }, а не в текущем месяце.`\n : \"\";\n await notifyBoss(\n \"Сделка на одобрение\",\n `${user.name}: ${what}, ${\n dealSum.toLocaleString(\"ru-RU\")\n } ₽, комиссия ${commPct}% = ${\n commIn.toLocaleString(\"ru-RU\")\n } ₽. Брокеру ${bpct}% = ${\n brokerSum.toLocaleString(\"ru-RU\")\n } ₽.${backdated}`,\n );\n const race = await raceLine(user.id, dealDate.slice(0, 7), \"deal\");\n await notifyBroker(\n user.id,\n \"Поздравляем со сделкой!\",\n `Твоя комиссия: ${brokerSum.toLocaleString(\"ru-RU\")} руб. ${race}`,\n );\n return c.json({\n ok: true,\n id,\n comm_in: commIn,\n ka_sum: kaSum,\n broker_pct: bpct,\n broker_sum: brokerSum,\n month: dealMonth,\n rfm,\n });\n});\n\napp.post(\"/api/dkp/:id/decide\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const approve = !!b.approve;\n const cur = await sqlite.execute({\n sql: \"SELECT * FROM dkp WHERE id=? AND status='pending'\",\n args: [id],\n });\n if (!cur.rows.length) return jerr(c, \"Сделка не найдена или уже решена\", 404);\n const d = cur.rows[0];\n await sqlite.execute({\n sql: \"UPDATE dkp SET status=?, decided_at=datetime('now') WHERE id=?\",\n args: [approve ? \"approved\" : \"rejected\", id],\n });\n const label = String(d.sector) === \"new\"\n ? String(d.complex || \"новостройка\")\n : String(d.crm_id);\n if (approve) {\n await notifyBroker(\n Number(d.broker_id),\n \"Сделка подтверждена!\",\n `Сумма к выплате ${Number(d.broker_sum).toLocaleString(\"ru-RU\")} (${\n Number(d.broker_pct)\n }%), зачисление происходит в течение 3-х дней после поступления на счёт компании.`,\n );\n if (Number(d.rfm) === 1 && !Number(d.rfm_sent)) scheduleRfmPing(id, d);\n } else {\n await notifyBroker(\n Number(d.broker_id),\n \"Сделка отклонена\",\n `${label}: уточните данные у руководителя и отправьте заново`,\n );\n }\n return c.json({\n ok: true,\n rfm: Number(d.rfm) === 1 ? 1 : 0,\n month: String(d.deal_date).slice(0, 7),\n });\n});\n\n/* ---------- Росфинмониторинг: ДКП от 5 млн ---------- */\nconst rfmJobs = new Set();\nfunction scheduleRfmPing(id, d) {\n const job = (async () => {\n try {\n await new Promise((r) => setTimeout(r, RFM_DELAY_MS));\n const cur = await sqlite.execute({\n sql: \"SELECT rfm_sent FROM dkp WHERE id=?\",\n args: [id],\n });\n if (cur.rows.length && Number(cur.rows[0].rfm_sent)) return; // уже отметили — не дёргаем\n await sqlite.execute({\n sql: \"UPDATE dkp SET rfm_notified=1 WHERE id=?\",\n args: [id],\n });\n await notifyBoss(\n \"📤 Отправить ДКП в Росфинмониторинг\",\n `${String(d.client || d.crm_id)} · ${\n Number(d.deal_sum).toLocaleString(\"ru-RU\")\n } ₽ · ДКП от ${\n String(d.deal_date)\n }. Откройте вкладку «Сделки» и отметьте, когда отправите.`,\n );\n } catch (_e) {\n\n /* напомним ещё раз из блока в дашборде и из ежедневного напоминания */\n }\n })();\n rfmJobs.add(job);\n job.finally(() => rfmJobs.delete(job));\n}\n\napp.get(\"/api/rfm\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const r = await sqlite.execute({\n sql:\n `SELECT d.id,d.crm_id,d.client,d.counter,d.side,d.person,d.sector,d.complex,d.deal_sum,d.deal_date,\n d.doc_name,d.doc_type,d.rfm_sent,d.rfm_sent_at,d.decided_at,b.name AS broker_name\n FROM dkp d JOIN brokers b ON b.id=d.broker_id\n WHERE d.rfm=1 AND d.status='approved'\n ORDER BY d.rfm_sent ASC, d.deal_date DESC, d.id DESC LIMIT 200`,\n args: [],\n });\n return c.json({ rows: r.rows, limit: RFM_LIMIT });\n});\n\napp.post(\"/api/dkp/:id/rfm\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const sent = b.sent ? 1 : 0;\n const at = sent\n ? (okDate(String(b.sent_at || \"\")) ? String(b.sent_at) : todayMsk())\n : null;\n const cur = await sqlite.execute({\n sql: \"SELECT id FROM dkp WHERE id=?\",\n args: [id],\n });\n if (!cur.rows.length) return jerr(c, \"not found\", 404);\n await sqlite.execute({\n sql: \"UPDATE dkp SET rfm_sent=?, rfm_sent_at=? WHERE id=?\",\n args: [sent, at, id],\n });\n return c.json({ ok: true, rfm_sent: sent, rfm_sent_at: at });\n});\n\nasync function raceLine(brokerId, month, mode) {\n const byDeal = mode === \"deal\";\n const r = await sqlite.execute({\n sql: byDeal\n ? `SELECT d.broker_id, b.name, SUM(d.broker_sum) AS s, COUNT(*) AS n\n FROM dkp d JOIN brokers b ON b.id=d.broker_id\n WHERE d.status<>'rejected' AND d.deal_date LIKE ? GROUP BY d.broker_id ORDER BY s DESC`\n : `SELECT d.broker_id, b.name, SUM(d.broker_sum) AS s, COUNT(*) AS n\n FROM dkp d JOIN brokers b ON b.id=d.broker_id\n WHERE d.status='approved' AND d.paid=1 AND d.paid_at LIKE ? GROUP BY d.broker_id ORDER BY s DESC`,\n args: [month + \"-%\"],\n });\n const rows = r.rows.map((x) => ({\n id: Number(x.broker_id),\n name: String(x.name),\n s: Number(x.s) || 0,\n n: Number(x.n) || 0,\n }));\n const idx = rows.findIndex((x) => x.id === brokerId);\n if (idx < 0) return \"Так держать — вперёд за следующей!\";\n const me = rows[idx];\n const fmt = (v) => Number(v).toLocaleString(\"ru-RU\");\n if (idx === 0) {\n const next = rows[1];\n const lead = next ? me.s - next.s : me.s;\n return next\n ? `Вы №1 в месяце: ${fmt(me.s)} ₽, отрыв ${\n fmt(lead)\n } ₽. Не сбавляйте — отрыв держится только следующей сделкой 🚀`\n : `Вы №1 в месяце: ${\n fmt(me.s)\n } ₽. Задайте планку повыше — следующая сделка сделает месяц рекордным 🚀`;\n }\n const ahead = rows[idx - 1];\n const gap = ahead.s - me.s + 1;\n return `Вы ${idx + 1}-й в месяце: ${fmt(me.s)} ₽. До ${\n ahead.name.split(\" \")[0]\n } — ${fmt(gap)} ₽. Одна сделка, и вы выше 🔥`;\n}\n\n// отметка «оплатили брокеру» в реестре\napp.post(\"/api/dkp/:id/paid\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const cur = await sqlite.execute({\n sql: \"SELECT * FROM dkp WHERE id=?\",\n args: [id],\n });\n if (!cur.rows.length) return jerr(c, \"not found\", 404);\n const d = cur.rows[0];\n const paid = b.paid ? 1 : 0;\n const was = Number(d.paid) ? 1 : 0;\n const sum = Number(d.broker_sum) || 0;\n let paidAt = d.paid_at ? String(d.paid_at) : null;\n\n if (paid && !was) {\n paidAt = okDate(String(b.paid_at || \"\")) ? String(b.paid_at) : todayMsk();\n } else if (!paid && was) {\n paidAt = null;\n }\n await sqlite.execute({\n sql: \"UPDATE dkp SET paid=?, paid_at=? WHERE id=?\",\n args: [paid, paidAt, id],\n });\n\n if (paid && !was) {\n const num = String(d.crm_id || \"\").trim();\n await notifyBroker(\n Number(d.broker_id),\n `Поздравляем со сделкой № ${num}`,\n `Сумма в размере ${\n sum.toLocaleString(\"ru-RU\")\n } рублей выплачена! Зачисление средств происходит в течение одних рабочих суток.`,\n );\n }\n return c.json({ ok: true, paid, paid_at: paidAt });\n});\n\napp.delete(\"/api/dkp/:id\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const cur = await sqlite.execute({\n sql:\n \"SELECT broker_id,deal_date,status,paid,paid_at,broker_sum FROM dkp WHERE id=?\",\n args: [id],\n });\n if (!cur.rows.length) return jerr(c, \"not found\", 404);\n await sqlite.execute({ sql: \"DELETE FROM dkp WHERE id=?\", args: [id] });\n try {\n await blob.delete(`doc:d:${id}`);\n } catch (_e) {}\n try {\n await blob.delete(`doc:a:${id}`);\n } catch (_e) {}\n return c.json({ ok: true });\n});\n\napp.get(\"/api/dkp\", async (c) => {\n const user = c.get(\"user\");\n if (user.role === \"broker\") {\n const r = await sqlite.execute({\n sql:\n `SELECT id,crm_id,side,person,sector,client,developer,complex,deal_sum,comm_pct,broker_pct,broker_sum,deal_date,doc_name,status,paid,paid_at,created_at FROM dkp\n WHERE broker_id=? ORDER BY id DESC LIMIT 50`,\n args: [user.id],\n });\n return c.json({ rows: r.rows });\n }\n const r = await sqlite.execute({\n sql:\n `SELECT d.*, b.name AS broker_name FROM dkp d JOIN brokers b ON b.id=d.broker_id ORDER BY d.id DESC`,\n args: [],\n });\n return c.json({ rows: r.rows });\n});\n\n/* ---------- чистый доход брокера по месяцам ---------- */\napp.get(\"/api/netincome\", async (c) => {\n const user = c.get(\"user\");\n if (user.role === \"broker\") {\n const r = await sqlite.execute({\n sql:\n \"SELECT month,amount FROM net_income WHERE broker_id=? ORDER BY month\",\n args: [user.id],\n });\n return c.json({ rows: r.rows });\n }\n const r = await sqlite.execute({\n sql: \"SELECT broker_id,month,amount FROM net_income ORDER BY month\",\n args: [],\n });\n return c.json({ rows: r.rows });\n});\n\napp.post(\"/api/netincome\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const brokerId = Number(b.broker_id);\n const month = String(b.month || \"\");\n if (!brokerId || !/^\\d{4}-\\d{2}$/.test(month)) {\n return jerr(c, \"bad netincome\");\n }\n if (b.amount === null) {\n await sqlite.execute({\n sql: \"DELETE FROM net_income WHERE broker_id=? AND month=?\",\n args: [brokerId, month],\n });\n return c.json({ ok: true });\n }\n const n = Math.floor(Number(b.amount));\n if (!Number.isFinite(n) || n < 0 || n > 9999999999) {\n return jerr(c, \"Введите сумму цифрами\");\n }\n await sqlite.execute({\n sql: `INSERT INTO net_income(broker_id,month,amount) VALUES (?,?,?)\n ON CONFLICT(broker_id,month) DO UPDATE SET amount=excluded.amount`,\n args: [brokerId, month, n],\n });\n return c.json({ ok: true });\n});\n\n/* ---------- табло для телевизора ---------- */\n// ссылка и фото — только руководителю\napp.get(\"/api/tv/link\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const r = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key='tv_token'\",\n args: [],\n });\n const ph = await sqlite.execute({\n sql: \"SELECT id,photo FROM brokers\",\n args: [],\n });\n return c.json({\n token: r.rows.length ? String(r.rows[0].value) : \"\",\n photos: ph.rows.map((x) => ({\n id: Number(x.id),\n photo: x.photo ? String(x.photo) : null,\n })),\n });\n});\n\napp.post(\"/api/brokers/:id/photo\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const photo = b.photo === null ? null : String(b.photo || \"\");\n if (photo !== null) {\n if (!/^data:image\\/(png|jpeg|jpg|webp);base64,/.test(photo)) {\n return jerr(c, \"Нужен файл-картинка\");\n }\n if (photo.length > 400000) return jerr(c, \"Фото слишком большое\");\n }\n await sqlite.execute({\n sql: \"UPDATE brokers SET photo=? WHERE id=?\",\n args: [photo, id],\n });\n return c.json({ ok: true });\n});\n\napp.get(\"/api/tv\", async (c) => {\n await init();\n const token = String(c.req.query(\"t\") || \"\");\n const s = await sqlite.execute({\n sql: \"SELECT value FROM settings WHERE key='tv_token'\",\n args: [],\n });\n const real = s.rows.length ? String(s.rows[0].value) : \"\";\n if (!token || token !== real) return jerr(c, \"unauthorized\", 401);\n\n const now = new Date();\n const msk = new Date(now.getTime() + 3 * 3600 * 1000);\n const date = msk.toISOString().slice(0, 10);\n const month = date.slice(0, 7);\n const from = month + \"-01\";\n\n const prevM = prevMonthOf(date);\n // два сетевых пакета: батч из 5 запросов + авторасчёт (внутри тоже один батч)\n const [batch, autoAll] = await Promise.all([\n sqlite.batch([\n {\n sql:\n \"SELECT id,name,photo,deals_total FROM brokers WHERE active=1 ORDER BY name\",\n args: [],\n },\n {\n sql:\n \"SELECT broker_id,stage,amount,done FROM items WHERE date BETWEEN ? AND ?\",\n args: [from, date],\n },\n {\n sql:\n \"SELECT broker_id,month,deals,zad_cnt,zad_sum,income,gross_add,plan_deals,plan_sum,plan_zad FROM manual_month WHERE month IN (?,?)\",\n args: [month, prevM],\n },\n {\n sql:\n \"SELECT broker_id,date,morning,evening FROM cian WHERE date<=? ORDER BY date\",\n args: [date],\n },\n {\n sql:\n \"SELECT broker_id, COUNT(*) AS cnt FROM dkp WHERE status='approved' GROUP BY broker_id\",\n args: [],\n },\n ]),\n autoMonths([month, prevM]),\n ]);\n const [brokers, items, manualAll, cian, tvTotals] = batch;\n const manual = {\n rows: manualAll.rows.filter((r) => String(r.month) === month),\n };\n const manualPrev = {\n rows: manualAll.rows.filter((r) => String(r.month) === prevM),\n };\n const tvAuto = autoAll.filter((x) => x.month === month);\n const prevAuto = autoAll.filter((x) => x.month === prevM);\n const rows = brokers.rows.map((b) => {\n const id = Number(b.id);\n const mine = items.rows.filter((i) => Number(i.broker_id) === id);\n const marked = mine.filter((i) => i.done !== null && i.done !== undefined);\n const done = mine.filter((i) => Number(i.done) === 1).length;\n const m = manual.rows.find((x) => Number(x.broker_id) === id) || {};\n const a = tvAuto.find((x) => x.broker_id === id) || {};\n const num = (v, d) => (v === null || v === undefined ? d : Number(v));\n let cianV = null;\n cian.rows.filter((x) => Number(x.broker_id) === id).forEach((x) => {\n const v = x.evening !== null && x.evening !== undefined\n ? Number(x.evening)\n : (x.morning !== null && x.morning !== undefined\n ? Number(x.morning)\n : null);\n if (v !== null) cianV = v;\n });\n return {\n id,\n name: String(b.name),\n photo: b.photo ? String(b.photo) : null,\n deals: num(m.deals, a.deals || 0),\n zadCnt: num(m.zad_cnt, a.zad_cnt || 0),\n zadSum: num(m.zad_sum, a.zad_sum || 0),\n income: num(m.income, a.income || 0),\n gross: (Number(a.gross_paid) || 0) + num(m.gross_add, 0), // валовая по ОПЛАЧЕННЫМ сделкам + ручная добавка\n tasks: mine.length,\n tasksDone: done,\n disc: marked.length ? Math.round(done / marked.length * 100) : null,\n cian: cianV,\n dealsTotal: (() => {\n const tb = b.deals_total === null || b.deals_total === undefined\n ? null\n : Number(b.deals_total);\n const ta = Number(\n (tvTotals.rows.find((x) => Number(x.broker_id) === id) || {}).cnt,\n ) || 0;\n return tb === null && ta === 0 ? null : (tb || 0) + ta;\n })(),\n planDeals: num(m.plan_deals, 0),\n planSum: num(m.plan_sum, 0),\n planZad: num(m.plan_zad, 0),\n };\n });\n\n const best = (key, tie) => {\n let win = null;\n for (const r of rows) {\n if (!r[key]) continue;\n if (\n !win || r[key] > win[key] || (r[key] === win[key] && r[tie] > win[tie])\n ) win = r;\n }\n return win ? win.id : null;\n };\n const leaders = {\n deals: best(\"deals\", \"gross\"),\n gross: best(\"gross\", \"deals\"),\n zad: best(\"zadSum\", \"zadCnt\"),\n };\n\n let champ = null;\n for (const b of brokers.rows) {\n const m = manualPrev.rows.find((x) =>\n Number(x.broker_id) === Number(b.id)\n ) ||\n (prevAuto.find((x) => x.broker_id === Number(b.id)) ? {} : null);\n if (!m) continue;\n const pa = prevAuto.find((x) => x.broker_id === Number(b.id)) || {};\n const cand = {\n name: String(b.name),\n photo: b.photo ? String(b.photo) : null,\n gross: (Number(pa.gross_paid) || 0) +\n (m.gross_add === null || m.gross_add === undefined\n ? 0\n : Number(m.gross_add)),\n deals: m.deals === null || m.deals === undefined\n ? (pa.deals || 0)\n : Number(m.deals),\n zadCnt: m.zad_cnt === null || m.zad_cnt === undefined\n ? (pa.zad_cnt || 0)\n : Number(m.zad_cnt),\n zadSum: m.zad_sum === null || m.zad_sum === undefined\n ? (pa.zad_sum || 0)\n : Number(m.zad_sum),\n month: prevM,\n };\n if (cand.gross <= 0 && cand.deals <= 0 && cand.zadCnt <= 0) continue;\n // чемпион — по тем же правилам, что и рейтинг: сделки → кол-во задатков → сумма задатков\n if (\n !champ ||\n cand.deals > champ.deals ||\n (cand.deals === champ.deals && cand.zadCnt > champ.zadCnt) ||\n (cand.deals === champ.deals && cand.zadCnt === champ.zadCnt &&\n cand.zadSum > champ.zadSum)\n ) {\n champ = cand;\n }\n }\n\n return c.json({\n month,\n date,\n rows,\n champ,\n leaders,\n updated: new Date().toISOString(),\n });\n});\n\napp.get(\"/tv\", async (c) => {\n await init();\n const html = await readFile(\"/tv.html\", import.meta.url);\n c.header(\"Cache-Control\", \"no-store, max-age=0\");\n return c.html(html);\n});\n\n/* ---------- push-уведомления ---------- */\nconst VAPID_PUBLIC =\n \"BIZ4zEZvINg_O2ThywxRHNeceB5Nd27EJva0c8KnhQ7pd0hvERL0kiTVqsRMSmJ_CGRcLC0fzuYsexYBc3HeebI\";\n/* единый публичный ключ: и для подписки, и для отправки — иначе пуши тихо умирают с 401/403 */\nexport function vapidPub() {\n const env = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"VAPID_PUBLIC_KEY\")\n : null;\n return env || VAPID_PUBLIC;\n}\n\napp.get(\"/api/push/key\", (c) => c.json({ key: vapidPub() }));\n\n/* проверка уведомлений: шлём тестовый пуш на свои устройства, возвращаем результат по каждому */\napp.post(\"/api/push/test\", async (c) => {\n const user = c.get(\"user\");\n const subs = await sqlite.execute(\n user.role === \"boss\"\n ? {\n sql: \"SELECT endpoint,p256dh,auth FROM push_subs WHERE role='boss'\",\n args: [],\n }\n : {\n sql:\n \"SELECT endpoint,p256dh,auth FROM push_subs WHERE role='broker' AND broker_id=?\",\n args: [user.id],\n },\n );\n if (!subs.rows.length) return c.json({ devices: 0, results: [] });\n const results = [];\n try {\n const mod = await import(\"npm:web-push@3.6.7\");\n const webpush = mod.default || mod;\n const priv = typeof Deno !== \"undefined\"\n ? Deno.env.get(\"VAPID_PRIVATE_KEY\")\n : null;\n if (!priv) {\n return c.json({\n devices: subs.rows.length,\n results: [],\n error: \"no-vapid-key\",\n });\n }\n webpush.setVapidDetails(\"mailto:tambovtsev007@gmail.com\", vapidPub(), priv);\n for (const s of subs.rows) {\n try {\n await webpush.sendNotification(\n {\n endpoint: String(s.endpoint),\n keys: { p256dh: String(s.p256dh), auth: String(s.auth) },\n },\n JSON.stringify({\n title: \"Проверка 🔔\",\n body: \"Уведомления работают\",\n url: \"/\",\n }),\n );\n results.push({ ok: true });\n } catch (e) {\n const code = (e && e.statusCode) || 0;\n if ([400, 401, 403, 404, 410].includes(code)) {\n await dropSubscription(String(s.endpoint));\n }\n results.push({ ok: false, code });\n }\n }\n } catch (_e) {\n return c.json({\n devices: subs.rows.length,\n results: [],\n error: \"web-push\",\n });\n }\n return c.json({ devices: subs.rows.length, results });\n});\n\napp.post(\"/api/push/subscribe\", async (c) => {\n const user = c.get(\"user\");\n const b = await c.req.json().catch(() => ({}));\n const sub = b.subscription || {};\n const endpoint = String(sub.endpoint || \"\");\n const keys = sub.keys || {};\n const p256dh = String(keys.p256dh || \"\"), auth = String(keys.auth || \"\");\n if (!endpoint || !p256dh || !auth) return jerr(c, \"bad subscription\");\n await sqlite.execute({\n sql:\n `INSERT INTO push_subs(endpoint,broker_id,role,p256dh,auth) VALUES (?,?,?,?,?)\n ON CONFLICT(endpoint) DO UPDATE SET broker_id=excluded.broker_id, role=excluded.role,\n p256dh=excluded.p256dh, auth=excluded.auth`,\n args: [\n endpoint,\n user.role === \"broker\" ? user.id : null,\n user.role,\n p256dh,\n auth,\n ],\n });\n return c.json({ ok: true });\n});\n\napp.post(\"/api/push/unsubscribe\", async (c) => {\n const b = await c.req.json().catch(() => ({}));\n const endpoint = String(b.endpoint || \"\");\n if (endpoint) {\n await sqlite.execute({\n sql: \"DELETE FROM push_subs WHERE endpoint=?\",\n args: [endpoint],\n });\n }\n return c.json({ ok: true });\n});\n\napp.get(\"/api/push/subs\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const r = await sqlite.execute({\n sql: `SELECT broker_id, COUNT(*) AS devices FROM push_subs\n WHERE role='broker' AND broker_id IS NOT NULL GROUP BY broker_id`,\n args: [],\n });\n return c.json({\n rows: r.rows.map((x) => ({\n broker_id: Number(x.broker_id),\n devices: Number(x.devices),\n })),\n });\n});\n\napp.get(\"/api/push/status\", async (c) => {\n const user = c.get(\"user\");\n const r = await sqlite.execute({\n sql:\n \"SELECT COUNT(*) AS n FROM push_subs WHERE role=? AND (broker_id IS ? OR broker_id=?)\",\n args: [\n user.role,\n user.role === \"broker\" ? null : null,\n user.role === \"broker\" ? user.id : -1,\n ],\n });\n return c.json({ count: Number(r.rows[0]?.n || 0) });\n});\n\nexport async function dropSubscription(endpoint) {\n await sqlite.execute({\n sql: \"DELETE FROM push_subs WHERE endpoint=?\",\n args: [endpoint],\n });\n}\n\n/* ---------- service worker + manifest ---------- */\nconst SW_JS = `self.addEventListener('push', (e) => {\n let d = { title: 'Воронка Дня', body: '', url: '/' };\n try { d = Object.assign(d, e.data ? e.data.json() : {}); } catch (err) {}\n e.waitUntil(self.registration.showNotification(d.title, {\n body: d.body, icon: '/icon.png', badge: '/icon.png', tag: 'voronka', data: { url: d.url }\n }));\n});\nself.addEventListener('notificationclick', (e) => {\n e.notification.close();\n const url = (e.notification.data && e.notification.data.url) || '/';\n e.waitUntil(clients.matchAll({ type: 'window', includeUncontrolled: true }).then((list) => {\n for (const c of list) { if ('focus' in c) return c.focus(); }\n return clients.openWindow(url);\n }));\n});\nself.addEventListener('install', () => self.skipWaiting());\nself.addEventListener('activate', (e) => e.waitUntil(self.clients.claim()));\n`;\n\napp.get(\"/sw.js\", (c) => {\n c.header(\"Content-Type\", \"application/javascript; charset=utf-8\");\n c.header(\"Cache-Control\", \"no-store\");\n return c.body(SW_JS);\n});\n\napp.get(\"/manifest.json\", (c) =>\n c.json({\n name: \"Unlock\",\n short_name: \"Unlock\",\n start_url: \"/\",\n display: \"standalone\",\n background_color: \"#f4f5f9\",\n theme_color: \"#1e1b4b\",\n icons: [\n { src: \"/icon.png\", sizes: \"192x192\", type: \"image/png\", purpose: \"any\" },\n { src: \"/icon.png\", sizes: \"512x512\", type: \"image/png\", purpose: \"any\" },\n {\n src: \"/icon.png\",\n sizes: \"512x512\",\n type: \"image/png\",\n purpose: \"maskable\",\n },\n ],\n }));\n\nconst ICON_B64 =\n \"iVBORw0KGgoAAAANSUhEUgAAAgAAAAIACAIAAAB7GkOtAAAQ6klEQVR42u3deXyU9Z3A8VyQA9AExCSwgEopIQiKVFQOAUWreKBUFJYiYG1VtljP2trWbbVodaloX1WoihZFRLxBDlnUFQ88kBsCIodcSbgJISRkJtM/fL12X+7qajXwPDPzfv+tPL/55uH3md+QmUltnt8qBYDkk2YEAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAABQvzKMIFgdi4tmz5gWyKX7njtg3boNST7/U7p0fvn5yYFcunvv87Zs2eavAE4AAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAAAIAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAAAgAgAAAIAAACAAAAgCAAAAgAAAIAAACAIAAACAAELa/AGnphoAAkHRSU1MNISsr0xAQAJJOZsOGhhBgAGIx40cACCoAmQKQkpWVFdSlo5GI+SMABHUC8OpHSlZmYEOoFQAEIMlFo1EngOQ8AUQEAAFIcgE+DQxw7wuPo45qEtiPvrbW/BGApBapDSwAOY1yzL9FYUFwAXACQACSPADBnQDymx9j/oUF+YFc99ChQ04ACECyOxTcLpCff6z5FxYGE4CKiv2GjwAku6oDVUFdukAAgjsB7NtXYfgIQLI7UFUVCegXgfLzmyf58Bs2bNi0aV4wAXACQABISUmp3F/pBBCI9t//XlCfh7F37153PgJASsX+YJ4MFhYW5ORkJ/PkO51YHNSly8q3u/MRAFL27t0XzM8+La2ofbtknnznToEFoLS03J2PAJBSXr4jqEsXdyhyAgjEttIydz4CQJCvBhR3+H7Sjr1BgwYBHoBKy5wAEABSUsrKA9sLkvkEcFq3rg0aNAjq6hs/2+TORwBIKSsL7ATQuVNxo5wk/UCIc87uHdSlq6trtm4tdecjAKRs2rwlqEtnZGT06H5aco6931l9grr0uvUbYr4OhhDIMILArVu/McCr9+3Tc+68N5Nt5kXt27Vq1TKoq6/9dH2CzfOjDl/zoaqnlnjjmwDwZXbu3FVRsT+ozyXu07tnEs783H59A7z6mk8+TYZN/6v+YzEIDy8BJfshoGWLwmR7N0BaWtqQKwYGuIAlS5fH+9b/T+3+9fu/IwCJZs0nawO8+hWDLk2qaZ991pktW7YI6uqxWGzpspXxu+/X195dv38aAhDHlq9YFeDVf3TpRQ0bJtHXQw7/8eAAr/7puvWVlZVxN7TDt1NrgAAku2CfEubmHt3/vH5JMurjj2vdq+cZAS5g0eJl8fjEP94vgQCEV8nqT4L9fqihQwYlyah/MfraoD4B9HPvvveBJ/6OAgLA/6itrV2xcnWACzitW9fTT/tBws+5Y3HRpQMuCHABsVjs7XcW2P01QAD4ggXvfxjsAn558+iEH/Ltt90Y7NP/VSVrdu3eY/fXAAHgC94J+pWBH3Tt0jeh3xNwZq/uwb76n5KS8tb8d+3+GiAA/J+bfuHimpqagA8Bt1yfnp6Yt0TjRo3uuet3gS9j1px5dn8NEAD+t5qamg8/WhTsGjoWF4269icJOd47f//rAD/74XObNm9Ztjzs7wAIz86rAQKQXObMfT3wNdww+toORYn2JQH9z+t32cCLA1/GzFlz7f4aIAB8VQDeqKurC3YNDRo0uP8//piRkTgfEtWmdat7xtwRhpW8MmO23V8DBIAvt2PHzkWLlwa+jI7FRWPu/G1ijLRZs6aTJ03Iy80NfCVLl61YVbLGTY4A8JWmvzonDMsYcsXAn4+6Ot6HmZOTPWniQ21atwrDYiZPec7Tf4cAAeD/89IrMwP/XaDP3XrT6AEXnR+/k8zOznrk4XGdO3UMw2L276+c/mp4X/8J/w6rAQKQFPbtqwjJbwqmpqaOGztm4CUXxuMYmzXNmzp54pm9uodkPVOnvXjwYLXbGwHgazzz7AshWUlGRsa4sWOu/emI+Bpgm9atXnr+qS4ndwrJemprax+d+KQbGwHg673/wcLw/Gthamrq7b+66Q933JaRnh4X0zur75mvvPj0cW1ah2dJz70wvax8e2gnFi+vrngVSACSxSOPTQrVekYOH/ryC5PbnnBcmIeWk5P9pzF3/P2xvzbNyw3PqqLRuvF/e9wtjQDwTU2fMXvrttJQLalzp46zpk8bNvTyYD9M7at0P73bnFef+9fBl4VtYdOef/mzTZs9rXYIEAC+qUg0+sijk8K2quzsrDF3/nbGS1O6n9EtPKsq7tB+0uMPT336sVC97PO5gwer73/wIfczAsA/Z/Izz4XtEPDfR4Gpkx976okJgf+GZVH7dg/8+e5Z058N7YeYTnxicnn5DjczoZXaPL+VKYTT5ZddMvbeO8O8wiVLV0yZ+vz0V2dXVR08kgeRC/v/cOiQQad06Rzm4WzfvqPPOQNC/vW/cfeiyqkl++0MApAU0tPT5s56od332oZ8nZWVlbPmzHvjzfnz33n/8O13ublH9+7VvW+fXuec3adJk8bh//GNuv7WV2e+ZvfXAAHgW+rZ4/QpTz4SL6uNRKMLFy5++90Fy5evWr6yZNeu3d/xD2xRWHBixw6dOhX3OKNbl5NPiqPvKnhr/nvDRl4b8kUKAAIQdhP++uf+558TjysvK9++atXqTZu3lpaWlZaVbyst27Vrd3V1TXV1dXV1TXVNdWpKalZWVmZWZnZ2VnZWdvNjmhUW5rdoUdCisKDVv7Ts2LFDs6Z58fjAq6oOntv/R5s2bxEAAQi5DCMIuT/88b4+vXvm5GTH3coL8o8tyD82CX9kd465L/y7P6T4LaDwKy0rv/ve+80hXsx7/a0pU18wBwSA+vHU09PefmeBOYTf9u07bv31v5sDAkC9icVit9x2R0WFlz5DLRKJXPNvN3/3f/oGAeALSsvKb7r1t7FYzChC6/d33fvxoiXmgABQ/+bOe3PCo383h3B65tkXn5z8rDkgABwu94198L33PzSHsHnjv97+ze/uMgcEgMMoGq27ZtRN69ZtMIrwWLpsxajRt0SiUaNAADi89u2rGHbVdTt37jKKMFi9Zu3wq0YdyY9Cqkfx+I4q7wITgGS3Zcu2K68atX9/pVEEq2T1J4OH/mT3nr1GgQBw5KxYWfLjEdeE/JMmE9uqkjWDh15t90cACMDiJcuHjbiu8sABozjy3lvw4aAhI/fstfsjAATk48VLBw0euWPHTqM4kl56Zeawkdclxktw8fWSun8AEAC+YOWq1ZcMGrZ+w2dGcQTEYrFxD46/4ebba2trTQMBIHibN2+99LJh3h9wuFVU7B/509Hj/jI+wd6PHS9Pqz39FwC+3J69e4de+bNHJz5pFIfJipUlFwwY/Mab840CASB0otG6u+4eO+r6W/16aP2qq6t7eMLEiwcO/WzTZtMgwfhGsETTsmWLB8aOOa1bV6P47jZt3nLjLb/5aOHihH+kIf92MK//CADf+FiXlnbN1cNv/MWorKxM0/h2IpHIoxOfHPeX8dXVNUnykEPbALv/YdwrjCDx1NXVjX/kiXPOH+hrZL7lVrhw8fkXXX7PfQ8kz+6PEwAJaMBF5//qlze0bFFoFN/Eho2b/nTfA7Nfm5ek5QvfIcDTfwHgO8nMzLxqxNCfX3d1kyaNTeOrlJfveGjCY5OnPBeJRJL69BOmBtj9BYD6kZeb+7Orrxw+bHDjxjLwBVu3lY7/2+NTp7106NAh0whPA+z+AkA9O/roo64aPnTE8CF5ubmmsWz5yicmTXllxuwkf9YfwgbY/QWAwyUzM/OSi/uPuHJIx+KiJHz4hw4dmjn7Pyc99cyixcvcDCFsgN1fADgSunY5adBlAy7s/8OjjmqSDI/340VLnn9xxoyZcyoqbDEhbYDdXwA4oho2bNjv7N4XX3Be7949GuXkJNiji8Vii5csf23u67PmzPNu3pA3wO4vAAQmMzOzZ4/Tz+3Xt0/vHoUF+XH9WCoq9r+74IO35r837423tm/f4Ycb/gbY/QWAsGjb9vhePU7vfka3U7t2adasabxs+ouWLPto4aJ33n1/2fKV0Widn2NcZMDWLwCEV5vWrbqeclKXkzuf2LGofft2jRs1CsnCDh6sXr1m7cpVJStWlny8aOkna9cl2Gc1J0MD7P4CQPzcMampbVq3Kmrfrm3b4084vs0Jx7c5rk3rI3BEiMViO3fu2rR5y7r1G9dv+Gz9+o1rP123YeOmujpP8+OyBPZ9ASBBZGZmtijMLywoKCzMb35Ms7ymeU3zcpvm5TVp0rhx40Y5OTmNcnKys7MyMjLS09PSMzLS09JSUlKi0WgkEo1EI5HayMHq6qoDVQeqqg5UVe3bV7F79949e/bs2r1n167dZWXbt24rLS0r9z1ciZEBW78AAEkUA5u+AAAQIj4OGkAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAEAAjABAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABABAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABABAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQAQAAAEAAABAEAAABAAAAQAAAEAQAAAEAAABAAAAQBAAAAQAAAEAAABAODw+Qc4Gk9i3Q+HzwAAAABJRU5ErkJggg==\";\nlet iconBin = null;\napp.get(\"/icon.png\", (c) => {\n if (!iconBin) {\n iconBin = Uint8Array.from(atob(ICON_B64), (ch) =>\n ch.charCodeAt(0));\n }\n c.header(\"Content-Type\", \"image/png\");\n c.header(\"Cache-Control\", \"public, max-age=604800\");\n return c.body(iconBin);\n});\n\n/* ---------- pages ---------- */\n/* статика: держим в памяти и отдаём 304, если у браузера уже свежая версия */\nconst staticCache = {};\nasync function serveStatic(c, path, type) {\n let e = staticCache[path];\n if (!e) {\n const body = await readFile(path, import.meta.url);\n let h = 0;\n for (let i = 0; i < body.length; i++) {\n h = (h * 31 + body.charCodeAt(i)) >>> 0;\n }\n e = staticCache[path] = {\n body,\n etag: `W/\"${h.toString(36)}-${body.length.toString(36)}\"`,\n };\n }\n c.header(\"Cache-Control\", \"no-cache\");\n c.header(\"ETag\", e.etag);\n if (c.req.header(\"if-none-match\") === e.etag) return c.body(null, 304);\n c.header(\"Content-Type\", type);\n return c.body(e.body);\n}\napp.get(\n \"/app.js\",\n (c) => serveStatic(c, \"/app.js\", \"application/javascript; charset=utf-8\"),\n);\napp.get(\n \"/app2.js\",\n (c) => serveStatic(c, \"/app2.js\", \"application/javascript; charset=utf-8\"),\n);\napp.get(\n \"/app3.js\",\n (c) => serveStatic(c, \"/app3.js\", \"application/javascript; charset=utf-8\"),\n);\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\napp.get(\"/\", (c) => {\n init().catch(() => {}); // БД прогревается в фоне, страницу отдаём сразу\n return serveStatic(c, \"/index.html\", \"text/html; charset=utf-8\");\n});\n\nexport default app.fetch;",[179],"f2e14f97-763c-46d6-a449-0f29d58be9a6","index.html","e74c06e6-86b5-11f1-8d64-1607ee4eb77e",178,["D",1788339757584],25,"v",[187],"4f884a08-a2f1-4ce3-92cc-d99a6eecb31b","extra.ts","60041434-9fca-11f1-90d5-1607ee4eb77e",175,["D",1788339639483],3,"// Дополнительные API: выходные/больничные/отпуска брокеров и развал задатков.\n// Вынесено из main.ts из-за лимита Val Town в 80 000 символов на файл.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst DATE_RE = /^\\d{4}-\\d{2}-\\d{2}$/;\nconst KIND_RU = { off: \"выходной\", sick: \"больничный\", vac: \"отпуск\" };\n\nexport function registerExtra(app, h) {\n const { jerr, notifyBoss, notifyBroker } = h;\n\n /* ---------- выходной / больничный / отпуск ---------- */\n app.post(\"/api/dayoff\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const kind = [\"off\", \"sick\", \"vac\"].includes(b.kind) ? b.kind : \"off\";\n const from = String(b.from || \"\"), to = String(b.to || b.from || \"\");\n if (!DATE_RE.test(from) || !DATE_RE.test(to) || to < from) {\n return jerr(c, \"Неверные даты\");\n }\n const days = [];\n const d = new Date(from + \"T00:00:00Z\");\n const end = new Date(to + \"T00:00:00Z\");\n while (d <= end && days.length < 62) {\n days.push(d.toISOString().slice(0, 10));\n d.setUTCDate(d.getUTCDate() + 1);\n }\n for (const day of days) {\n await sqlite.execute({\n sql: `INSERT INTO days_off(broker_id,date,kind) VALUES(?,?,?)\n ON CONFLICT(broker_id,date) DO UPDATE SET kind=excluded.kind`,\n args: [user.id, day, kind],\n });\n }\n await notifyBoss(\n \"🏖 \" + (KIND_RU[kind] || \"выходной\"),\n `${user.name}: ${from}${to !== from ? \" — \" + to : \"\"}`,\n );\n return c.json({ ok: true, days: days.length });\n });\n\n app.post(\"/api/dayoff/del\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"broker\") return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n if (!DATE_RE.test(String(b.date || \"\"))) return jerr(c, \"bad date\");\n await sqlite.execute({\n sql: \"DELETE FROM days_off WHERE broker_id=? AND date=?\",\n args: [user.id, String(b.date)],\n });\n return c.json({ ok: true });\n });\n\n app.get(\"/api/dayoff\", async (c) => {\n const user = c.get(\"user\");\n const date = String(c.req.query(\"date\") || \"\");\n if (!DATE_RE.test(date)) return jerr(c, \"bad date\");\n if (user.role === \"boss\") {\n const r = await sqlite.execute({\n sql: \"SELECT broker_id,date,kind FROM days_off WHERE date=?\",\n args: [date],\n });\n return c.json({ rows: r.rows });\n }\n const r = await sqlite.execute({\n sql:\n \"SELECT date,kind FROM days_off WHERE broker_id=? AND date>=? ORDER BY date LIMIT 90\",\n args: [user.id, date],\n });\n return c.json({ rows: r.rows });\n });\n\n /* ---------- архив: задаток вышел на сделку (статистику не трогаем — статус остаётся approved) ---------- */\n app.post(\"/api/zadatki/:id/archive\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const on = b.on ? 1 : 0;\n await sqlite.execute({\n sql:\n `UPDATE zadatki SET archived=?, converted_at=CASE WHEN ? THEN datetime('now') ELSE NULL END\n WHERE id=? AND status='approved'`,\n args: [on, on, id],\n });\n return c.json({ ok: true });\n });\n\n /* ---------- здоровье системы: последний запуск крона, рассылки, подписки, ключи ---------- */\n app.get(\"/api/health\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const s = await sqlite.execute({\n sql:\n \"SELECT key,value FROM settings WHERE key IN ('cron_seen','notify_last')\",\n args: [],\n });\n const subs = await sqlite.execute({\n sql: \"SELECT role, COUNT(*) AS n FROM push_subs GROUP BY role\",\n args: [],\n });\n const kv = {};\n for (const r of s.rows) kv[String(r.key)] = String(r.value);\n return c.json({\n cronSeen: kv.cron_seen || null,\n notifyLast: kv.notify_last || null,\n subs: subs.rows.map((r) => ({ role: String(r.role), n: Number(r.n) })),\n vapid: typeof Deno !== \"undefined\" && !!Deno.env.get(\"VAPID_PRIVATE_KEY\"),\n now: new Date().toISOString(),\n });\n });\n\n /* ---------- развал задатка: запрос брокера → согласование руководителя ---------- */\n app.post(\"/api/zadatki/:id/cancelreq\", async (c) => {\n const user = c.get(\"user\");\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const reason = String(b.reason || \"\").trim().slice(0, 300);\n const date = DATE_RE.test(String(b.date)) ? String(b.date) : null;\n if (!id || !reason || !date) {\n return jerr(c, \"Укажите дату и причину развала\");\n }\n const r = await sqlite.execute({\n sql:\n \"SELECT broker_id,status,client,buyer,comm_sum FROM zadatki WHERE id=?\",\n args: [id],\n });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n const z = r.rows[0];\n if (user.role === \"broker\" && Number(z.broker_id) !== user.id) {\n return jerr(c, \"forbidden\", 403);\n }\n if (String(z.status) !== \"approved\") {\n return jerr(c, \"Развалить можно только зафиксированный задаток\");\n }\n await sqlite.execute({\n sql:\n \"UPDATE zadatki SET cancel_req=1, cancel_date=?, cancel_reason=? WHERE id=?\",\n args: [date, reason, id],\n });\n await notifyBoss(\n \"⛔ Запрос на развал\",\n `${user.name || \"Брокер\"}: ${\n String(z.client || z.buyer || \"\")\n }, комиссия ${\n Number(z.comm_sum || 0).toLocaleString(\"ru-RU\")\n } ₽. Причина: ${reason}. Откройте «Сделки» и согласуйте`,\n );\n return c.json({ ok: true });\n });\n\n app.post(\"/api/zadatki/:id/canceldecide\", async (c) => {\n const user = c.get(\"user\");\n if (user.role !== \"boss\") return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const r = await sqlite.execute({\n sql:\n \"SELECT broker_id,client,buyer,cancel_req,status FROM zadatki WHERE id=?\",\n args: [id],\n });\n if (!r.rows.length || !Number(r.rows[0].cancel_req)) {\n return jerr(c, \"Запрос на развал не найден\");\n }\n const z = r.rows[0];\n const who = String(z.client || z.buyer || \"\");\n if (b.ok) {\n await sqlite.execute({\n sql:\n \"UPDATE zadatki SET status='annulled', cancel_req=0, annulled_at=datetime('now') WHERE id=?\",\n args: [id],\n });\n await notifyBroker(\n Number(z.broker_id),\n \"Развал подтверждён\",\n `${who}: задаток аннулирован и убран из статистики`,\n );\n } else {\n await sqlite.execute({\n sql: \"UPDATE zadatki SET cancel_req=0 WHERE id=?\",\n args: [id],\n });\n await notifyBroker(\n Number(z.broker_id),\n \"Развал отклонён\",\n `${who}: руководитель оставил задаток в силе — уточните детали`,\n );\n }\n return c.json({ ok: true });\n });\n}",[195],"e6332e19-ce7f-4d2f-bc4b-05c06895704b","app3.js","4528f4ca-a6ac-11f1-870e-1607ee4eb77e",173,["D",1788339603596],2,"/* Панель руководителя — дополнения (вынесено из app2.js: лимит Val Town 80 000 символов) */\n/* чек-контроль: карточка «Здоровье системы» в настройках */\nfunction healthCardHtml() {\n const h = bossHealth;\n if (!h) return \"\";\n const age = (t) => {\n if (!t) return null;\n return (Date.now() - Date.parse(t)) / 3600000;\n };\n const cronAge = age(h.cronSeen);\n let last = null;\n try {\n last = h.notifyLast ? JSON.parse(h.notifyLast) : null;\n } catch (e) {}\n const cronTxt = h.cronSeen\n ? (cronAge > 13\n ? `молчит ${\n Math.round(cronAge)\n } ч — проверьте Cron-триггер notify.ts в val.town`\n : `работает ✓ (был ${Math.round(cronAge)} ч назад)`)\n : \"ещё не отчитывался (появится после ближайшего запуска)\";\n const row = (l, v) =>\n `

${l}${v}

`;\n const subsTxt =\n (h.subs || []).map((s) => (s.role === \"boss\" ? \"вы: \" : \"брокеры: \") + s.n)\n .join(\" · \") || \"нет\";\n return `

🩺 Здоровье системы

\n ${row(\"Крон напоминаний\", cronTxt)}\n ${\n row(\n \"Последняя рассылка\",\n last\n ? `${\n last.at ? String(last.at).slice(0, 16).replace(\"T\", \" \") : \"\"\n } UTC · отправлено ${last.sent}${\n last.failed\n ? ` · ошибок ${last.failed}`\n : \"\"\n }`\n : \"—\",\n )\n }\n ${row(\"Push-подписки\", subsTxt)}\n ${\n row(\n \"VAPID-ключ на сервере\",\n h.vapid ? \"есть ✓\" : 'НЕТ — пуши не уйдут',\n )\n }\n

Если крон «молчит» дольше 13 часов или нет ключа — уведомления не приходят. Кнопка «Проверить» выше шлёт тестовый пуш прямо сейчас.

`;\n}\n\n/* ---- вкладка «Реестр»: все закрытые сделки по годам/месяцам (по дате сделки), с поиском ---- */\nlet archQ = \"\", archOpen = {};\nfunction archMatch(d, q) {\n return [\n d.client,\n d.counter,\n d.broker_name,\n d.crm_id,\n d.agn_num,\n d.complex,\n d.developer,\n d.ddu_num,\n ]\n .some((v) => String(v || \"\").toLowerCase().includes(q));\n}\nfunction archTabHtml() {\n return `

📁 Реестр сделок

\n \n

Все одобренные сделки компании, месяцы — по дате сделки. Тап по месяцу — развернуть/свернуть. 📎 — договор сделки, 📄 — агентский договор. Наша = комиссия − НДС − контрагенту − брокеру.

`;\n}\nfunction fillArchList() {\n const el = document.getElementById(\"archList\");\n if (!el) return;\n const q = archQ.trim().toLowerCase();\n const deals = bossDkp.filter((d) =>\n String(d.status) === \"approved\" && (!q || archMatch(d, q))\n );\n if (!deals.length) {\n el.innerHTML =\n '

' +\n (q ? \"Ничего не найдено по запросу\" : \"Пока нет одобренных сделок\") +\n \"

\";\n return;\n }\n const byM = {};\n deals.forEach((d) => {\n const m = String(d.deal_date).slice(0, 7);\n (byM[m] = byM[m] || []).push(d);\n });\n const nds = (v) => v - Math.round(v / 1.05);\n el.innerHTML = Object.keys(byM).sort().reverse().map((m) => {\n const list = byM[m].slice().sort((a, b) =>\n String(b.deal_date).localeCompare(String(a.deal_date)) ||\n Number(b.id) - Number(a.id)\n );\n const cIn = list.reduce((a, d) => a + (Number(d.comm_in) || 0), 0);\n const open = q\n ? true\n : (archOpen[m] !== undefined ? archOpen[m] : m === teamData.curMonth);\n const head =\n `

\n ${monthTitle(m)} · сделок: ${list.length}\n ${\n money(cIn)\n } ${\n open ? \"▲\" : \"▼\"\n }

`;\n if (!open) return head;\n return head +\n `

\n \n ${\n list.map((d, i) => {\n const ci = Number(d.comm_in) || 0,\n nd = nds(ci),\n ka = Number(d.ka_sum) || 0,\n bs = Number(d.broker_sum) || 0,\n our = ci - nd - ka - bs;\n const nw = String(d.sector) === \"new\";\n return `\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n `;\n }).join(\"\")\n }

№	Дата	Брокер	Клиент	Сопров.	Тип	Договор	Агентский	Сумма	Комиссия	К-агент	НДС	Наша	Оплата
${i + 1}	${esc(d.deal_date)}	${esc(d.broker_name)}	${esc(d.client \|\| \"\")}${\n d.counter ? ` встр. ${esc(d.counter)} ` : \"\"\n } CRM ${esc(d.crm_id)}	${nw ? \"Покупка\" : esc(d.side \|\| \"—\")}${\n !nw && d.person ? ` ${esc(d.person)} ` : \"\"\n }	${nw ? \"🏗 Новостр.\" : \"Вторичка\"}${\n nw && d.complex ? ` ${esc(d.complex)} ` : \"\"\n }	${\n String(d.doc_type \|\| (nw ? \"ddu\" : \"dkp\")) === \"dkp\" ? \"ДКП\" : \"ДДУ\"\n }${d.ddu_num ? \" \" + esc(d.ddu_num) : \"\"}${\n Number(d.rfm)\n ? ` ${\n Number(d.rfm_sent) ? \"РФМ ✅\" : \"РФМ 📤\"\n } `\n : \"\"\n }	${\n d.agn_num\n ? `№ ${esc(d.agn_num)}${\n d.agn_date\n ? ' от ' + esc(d.agn_date) + (d.agn_sign\n ? \" · \" + esc(String(d.agn_sign).toLowerCase())\n : \"\") + \" \"\n : \"\"\n }`\n : \"—\"\n }	${\n money(Number(d.deal_sum))\n }	${money(ci)}	${\n ka ? money(ka) : \"—\"\n }	${money(nd)}	${money(our)}	${\n Number(d.paid)\n ? \"✅ \" + esc(String(d.paid_at \|\| \"\").slice(0, 10))\n : \"⏳ ждёт\"\n }	${\n d.agn_doc_name\n ? ` `\n : \"\"\n }

`;\n }).join(\"\");\n}",[203],"46fec315-29e0-4e38-8eb7-decb66cb67b2","app2.js","a3b02774-8f60-11f1-b320-1607ee4eb77e",177,["D",1788339713757],"/* ================= BOSS ================= */\nlet teamData = null;\nlet bossZad = [],\n bossDkp = [],\n bossZadAll = [],\n bossNet = [],\n bossNetMonth = null,\n bossRfm = [],\n bossOffs = [],\n bossHealth = null;\nlet bossTab = localStorage.getItem(\"vd_btab\") || \"home\";\nlet bossZadMonth = null, bossRetro = null, bossRetroMonth = null;\nfunction bossSetTab(t) {\n bossTab = t;\n localStorage.setItem(\"vd_btab\", t);\n if (t === \"months\" && !bossRetro) {\n renderBoss();\n loadRetro();\n } else renderBoss();\n window.scrollTo(0, 0);\n}\nasync function loadRetro() {\n if (!bossRetroMonth) bossRetroMonth = teamData.curMonth;\n try {\n bossRetro = await api(\"/api/retro?month=\" + bossRetroMonth);\n } catch (e) {\n bossRetro = null;\n }\n renderBoss();\n}\nfunction retroShift(n) {\n bossRetroMonth = shiftMonth(bossRetroMonth || teamData.curMonth, n);\n bossRetro = null;\n renderBoss();\n loadRetro();\n}\nasync function loadBossZad() {\n try {\n bossZad =\n (await api(\"/api/zadatki?month=\" + (bossZadMonth || teamData.curMonth)))\n .rows || [];\n } catch (e) {\n bossZad = [];\n }\n renderBoss();\n}\nfunction zadShift(n) {\n bossZadMonth = shiftMonth(bossZadMonth || teamData.curMonth, n);\n loadBossZad();\n}\nasync function loadBoss() {\n // всё грузим параллельно: главное — команда, остальное подтягивается тем же заходом\n const soft = (p, f) => p.then((r) => r).catch(() => f);\n const pre = window.__warm;\n window.__warm = null;\n const team = pre || api(\"/api/team?date=\" + TODAY);\n const tvP = soft(api(\"/api/tv/link\"), null);\n const subsP = soft(api(\"/api/push/subs\"), { rows: [] });\n const dkpP = soft(api(\"/api/dkp\"), { rows: [] });\n const zAllP = soft(api(\"/api/zadatki?all=1\"), { rows: [] });\n const rfmP = soft(api(\"/api/rfm\"), { rows: [] });\n const offP = soft(api(\"/api/dayoff?date=\" + TODAY), { rows: [] });\n const healthP = soft(api(\"/api/health\"), null);\n teamData = await team;\n const zMonP = soft(\n api(\"/api/zadatki?month=\" + (bossZadMonth || teamData.curMonth)),\n { rows: [] },\n );\n const [tv, subs, dkp, zAll, zMon, rfm, off, health] = await Promise.all([\n tvP,\n subsP,\n dkpP,\n zAllP,\n zMonP,\n rfmP,\n offP,\n healthP,\n ]);\n if (tv) {\n tvToken = tv.token;\n tvPhotos = {};\n (tv.photos || []).forEach((x) => {\n tvPhotos[x.id] = x.photo;\n });\n }\n pushSubs = subs.rows || [];\n bossDkp = dkp.rows || [];\n bossZadAll = zAll.rows || [];\n bossZad = zMon.rows || [];\n bossRfm = rfm.rows || [];\n bossOffs = off.rows || [];\n bossHealth = health;\n renderBoss();\n}\nfunction renderBoss() {\n const t = teamData;\n const d7 = lastNDates(7);\n const d30start = lastNDates(30)[0];\n const items30 = t.items.filter((i) => String(i.date) >= d30start);\n const yesterday = d7[5];\n const active = t.brokers.filter((b) => Number(b.active) === 1);\n const N = active.length;\n const itemsToday = t.today;\n const submittedIds = new Set(itemsToday.map((r) => Number(r.broker_id)));\n const submitted = active.filter((b) => submittedIds.has(Number(b.id))).length;\n const yItems = t.items.filter((i) => String(i.date) === yesterday);\n const discY = yItems.length\n ? Math.round(\n yItems.filter((i) => Number(i.done) === 1).length / yItems.length * 100,\n )\n : null;\n const inWork = items30.filter((i) => {\n const s = Number(i.stage);\n const d = i.done === null || i.done === undefined ? null : Number(i.done);\n return s === 3 && d !== 0;\n }).reduce((a, i) => a + (Number(i.amount) || 0), 0);\n // ручные данные от руководителя: ключ \"id|месяц\" → {deals,zad_cnt,zad_sum,income}\n const man = {};\n (t.manual || []).forEach((r) => {\n man[Number(r.broker_id) + \"|\" + String(r.month)] = r;\n });\n // сделки и их суммы — по месяцу подписания, деньги — по месяцу оплаты\n const agg = {};\n (t.auto || []).forEach((r) => {\n agg[Number(r.broker_id) + \"|\" + String(r.month)] = r;\n });\n\n const cianByBroker = {};\n t.cian.forEach((r) => {\n const id = Number(r.broker_id);\n (cianByBroker[id] = cianByBroker[id] || []).push(r);\n });\n Object.values(cianByBroker).forEach((a) =>\n a.sort((x, y) => String(x.date) < String(y.date) ? -1 : 1)\n );\n let cianSum = 0, cianKnown = 0;\n active.forEach((b) => {\n const v = cianNow(Number(b.id));\n if (v !== null) {\n cianSum += v;\n cianKnown++;\n }\n });\n const cianAvg = cianKnown\n ? (cianSum / cianKnown).toFixed(1).replace(\".\", \",\")\n : \"—\";\n\n const sc = stageCounts(items30);\n const fnData = STAGES.map((s, i) => ({ n: s.name, v: sc[i] }));\n\n const rows = active.map((b, idx) => {\n const id = Number(b.id);\n const bi = t.items.filter((i) => Number(i.broker_id) === id);\n const bi30 = bi.filter((i) => String(i.date) >= d30start);\n const bi7 = bi.filter((i) => String(i.date) >= d7[0]);\n const disc = bi7.length\n ? Math.round(\n bi7.filter((i) => Number(i.done) === 1).length / bi7.length * 100,\n )\n : null;\n const sum = bi30.filter((i) => {\n const s = Number(i.stage);\n const d = i.done === null || i.done === undefined ? null : Number(i.done);\n return s === 3 && d !== 0;\n }).reduce((a, i) => a + (Number(i.amount) || 0), 0);\n const cianV = cianNow(id);\n const mCur = monthStats(bi, t.curMonth),\n mPrev = monthStats(bi, t.prevMonth);\n const mc = man[id + \"|\" + t.curMonth] || {},\n mp = man[id + \"|\" + t.prevMonth] || {};\n const aC = agg[id + \"|\" + t.curMonth] || {},\n aP = agg[id + \"|\" + t.prevMonth] || {};\n const autoC = {\n deals: Number(aC.deals) || 0,\n zadC: Number(aC.zad_cnt) || 0,\n zadS: Number(aC.zad_sum) || 0,\n income: Number(aC.income) || 0,\n gross: Number(aC.gross) || 0,\n };\n const dealsCur = eff(mc.deals, autoC.deals);\n const dealsPrev = eff(mp.deals, Number(aP.deals) || 0);\n const zadC = eff(mc.zad_cnt, autoC.zadC),\n zadS = eff(mc.zad_sum, autoC.zadS);\n const income = eff(mc.income, autoC.income);\n // всего сделок = вписанная база + одобренные из реестра за всё время\n const totBase = b.deals_total === null || b.deals_total === undefined\n ? null\n : Number(b.deals_total);\n const totAuto = Number(\n ((t.totalAuto || []).find((x) => Number(x.broker_id) === id) || {}).cnt,\n ) || 0;\n const dealsTotal = totBase === null && totAuto === 0\n ? null\n : (totBase || 0) + totAuto;\n return {\n id,\n name: String(b.name),\n color: AVA_COLORS[idx % AVA_COLORS.length],\n plan: submittedIds.has(id),\n disc,\n cian: cianV,\n narC: mCur.nar.cnt,\n narS: mCur.nar.sum,\n zadC,\n zadS,\n income,\n dealsTotal,\n totBase,\n totAuto,\n auto: autoC,\n ovDeals: mc.deals !== null && mc.deals !== undefined,\n ovZadC: mc.zad_cnt !== null && mc.zad_cnt !== undefined,\n ovZadS: mc.zad_sum !== null && mc.zad_sum !== undefined,\n ovInc: mc.income !== null && mc.income !== undefined,\n dealSum: Number(aC.deal_sum) || 0,\n unpaid: Number(aC.unpaid) || 0,\n paidCnt: Number(aC.paid_cnt) || 0,\n grossAdd: mc.gross_add === null || mc.gross_add === undefined\n ? 0\n : Number(mc.gross_add),\n grossAuto: Number(aC.gross_paid) || 0, // валовая из реестра — по дате оплаты («зашло»), как на табло\n planDeals: eff(mc.plan_deals, 0),\n planSum: eff(mc.plan_sum, 0),\n planZad: eff(mc.plan_zad, 0),\n dealsCur,\n dealsPrev,\n pct: pct(dealsPrev),\n sum,\n };\n });\n\n const teamDiscSeries = d7.map((d) => {\n const di = t.items.filter((i) => String(i.date) === d);\n return di.length\n ? Math.round(\n di.filter((i) => Number(i.done) === 1).length / di.length * 100,\n )\n : 0;\n });\n const teamCianSeries = d7.map((d) => {\n let s = 0;\n active.forEach((b) => {\n const v = cianOnDate(cianByBroker[Number(b.id)] || [], d);\n if (v !== null) s += v;\n });\n return s;\n });\n\n const lowCian = rows.filter((r) => r.cian !== null && r.cian < 8).map((r) =>\n r.name\n );\n // выходные/больничные/отпуска на сегодня: не считаем «без плана» и показываем значок\n const offMap = {};\n (bossOffs || []).forEach((o) => {\n offMap[Number(o.broker_id)] = String(o.kind);\n });\n const OFF_ICO = { off: \"🏖\", sick: \"🤒\", vac: \"🌴\" };\n const OFF_RU = { off: \"выходной\", sick: \"больничный\", vac: \"отпуск\" };\n const noPlan = active.filter((b) =>\n !submittedIds.has(Number(b.id)) && !offMap[Number(b.id)]\n ).map((b) => String(b.name));\n const offList = active.filter((b) => offMap[Number(b.id)]).map((b) =>\n String(b.name).split(\" \")[0] + \" (\" + OFF_RU[offMap[Number(b.id)]] + \")\"\n );\n\n const tot = {\n cian: rows.reduce((a, r) => a + (r.cian || 0), 0),\n narC: rows.reduce((a, r) => a + r.narC, 0),\n narS: rows.reduce((a, r) => a + r.narS, 0),\n zadC: rows.reduce((a, r) => a + r.zadC, 0),\n zadS: rows.reduce((a, r) => a + r.zadS, 0),\n dealsCur: rows.reduce((a, r) => a + r.dealsCur, 0),\n dealsPrev: rows.reduce((a, r) => a + r.dealsPrev, 0),\n dealsTotal: rows.reduce((a, r) => a + (r.dealsTotal || 0), 0),\n income: rows.reduce((a, r) => a + (r.income || 0), 0),\n sum: rows.reduce((a, r) => a + r.sum, 0),\n };\n\n // planы сегодня по брокерам\n const todayByBroker = {};\n itemsToday.forEach((r) => {\n const id = Number(r.broker_id);\n (todayByBroker[id] = todayByBroker[id] ||\n { name: String(r.name), items: [] }).items.push(r);\n });\n\n const cancelCnt =\n bossZadAll.filter((z) =>\n Number(z.cancel_req) === 1 && String(z.status) === \"approved\"\n ).length;\n // сводка месяца: комиссия по сделкам месяца — зашла/ждёт; и общий заход по датам оплаты\n const dealsMonth = bossDkp.filter((d) =>\n String(d.status) === \"approved\" &&\n String(d.deal_date).slice(0, 7) === t.curMonth\n );\n const dmPaid = dealsMonth.filter((d) => Number(d.paid)).reduce(\n (a, d) => a + (Number(d.comm_in) || 0),\n 0,\n );\n const dmWait = dealsMonth.filter((d) => !Number(d.paid)).reduce(\n (a, d) => a + (Number(d.comm_in) || 0),\n 0,\n );\n const enteredReg = bossDkp.filter((d) =>\n String(d.status) === \"approved\" && Number(d.paid) &&\n String(d.paid_at || \"\").slice(0, 7) === t.curMonth\n )\n .reduce((a, d) => a + (Number(d.comm_in) || 0), 0);\n const grossAddSum = (t.manual || []).filter((r) =>\n String(r.month) === t.curMonth && r.gross_add !== null &&\n r.gross_add !== undefined\n )\n .reduce((a, r) => a + Number(r.gross_add), 0);\n const entered = enteredReg + grossAddSum;\n const pendCnt = bossZad.filter((z) => z.status === \"pending\").length +\n bossDkp.filter((d) => String(d.status) === \"pending\").length + cancelCnt;\n const rfmCnt = rfmPending().length;\n const homeHtml = `\n

\n \n \n

\n ${\n N === 0\n ? `

👋

Начните с командыДобавьте брокеров во вкладке «Настройки» — каждому задайте ПИН, по которому он войдёт с телефона.

`\n : \"\"\n }\n ${\n pendCnt\n ? `

📝

Ждут одобрения: ${pendCnt}Задатки и сделки — нажмите, чтобы перейти во вкладку «Сделки»

`\n : \"\"\n }\n ${\n rfmCnt\n ? `

📤

В Росфинмониторинг: ${rfmCnt} ДКПСделки от 5 млн ₽ ждут отправки — нажмите, чтобы открыть список и отметить

`\n : \"\"\n }\n ${\n cancelCnt\n ? `

⛔

Запросы на развал: ${cancelCnt}Брокер просит аннулировать задаток — нажмите, чтобы согласовать

`\n : \"\"\n }\n ${\n bossHealth && bossHealth.cronSeen &&\n (Date.now() - Date.parse(bossHealth.cronSeen)) / 3600000 > 13\n ? `

🚨

Напоминания не рассылаютсяКрон молчит ${\n Math.round((Date.now() - Date.parse(bossHealth.cronSeen)) / 3600000)\n } ч — откройте «Настройки → Здоровье системы»

`\n : \"\"\n }\n

${submitted} / ${N}

Планов сдано сегодня

${\n discY === null ? \"—\" : discY + \"%\"\n }

Выполнение планов вчера

${tot.dealsCur}

Сделки в этом месяце

💰 зашло: ${\n money(dmPaid)\n }
⏳ ждёт захода: ${\n money(dmWait)\n }
прошлый месяц: ${tot.dealsPrev}

${tot.zadC}

Задатки в этом месяце

📝 комиссия ожидается:
${\n money(tot.zadS)\n }
зайдёт при выходе на сделку

${\n money(entered)\n }

Зашло комиссии в компанию в этом месяце

по датам оплаты${\n grossAddSum ? \" · включая внесённое вручную \" + money(grossAddSum) : \"\"\n }

${tot.narC}

Наработки в этом месяце

на ${\n money(tot.narS)\n }

${\n money(inWork)\n }

Наработки в работе, 30 дн.

${\n cianKnown ? cianSum + \" / \" + CIAN_PLAN * N : \"—\"\n }

Объектов на Циан · план ${CIAN_PLAN}×${N}

${cianAvg}

Циан: среднее на брокера · план ${CIAN_PLAN}

${\n money(tot.income)\n }

Доход команды (выплаты брокерам)

по датам оплаты

\n ${\n noPlan.length && N > 0\n ? `

⚠️

Не сдали план сегодня${\n esc(noPlan.join(\", \"))\n }

`\n : \"\"\n }\n ${\n offList.length\n ? `

🏖

Сегодня не работают${\n esc(offList.join(\", \"))\n } — напоминания им не приходят, план не требуется

`\n : \"\"\n }\n ${\n lowCian.length\n ? `

🏠

ЦианБаза меньше 8 объектов: ${\n esc(lowCian.join(\", \"))\n } — входящего потока с базы не будет.

`\n : \"\"\n }\n ${\n (() => {\n const z = rows.filter((r) => r.dealsCur === 0);\n if (!z.length || !rows.some((r) => r.dealsCur > 0)) return \"\";\n return `

🫱

Пока без сделок в этом месяце${\n esc(\n z.map((r) =>\n String(r.name).split(\" \")[0] +\n (r.zadC ? \" (задатков \" + r.zadC + \")\" : \"\")\n ).join(\", \"),\n )\n } — видно только вам. Разберите с ними ближайшие выходы на сделку.

`;\n })()\n }\n\n ${roundHtml(rows, todayByBroker)}\n\n ${\n sc[0] + sc[1] + sc[2] + sc[3] + sc[4] > 0\n ? `\n

Воронка команды · 30 дней

${funnelHtml(fnData, false)}

`\n : \"\"\n }\n\n ${\n rows.length\n ? `\n

Брокеры · работа

\n \n \n \n ${\n rows.map((r) => {\n const cls = r.disc === null\n ? \"pn\"\n : r.disc >= 85\n ? \"pg\"\n : r.disc >= 70\n ? \"py\"\n : \"pr\";\n return `\n \n \n \n \n \n \n `;\n }).join(\"\")\n }\n \n \n \n \n \n \n \n \n \n

Брокер	План	Дисц. 7дн	Циан /${CIAN_PLAN}	Нараб. мес	В работе	Задатки мес	Сумма задатков
${\n esc(r.name.split(\" \").map((x) => x[0] \|\| \"\").join(\"\").slice(0, 2))\n } ${esc(r.name)}	${\n r.plan\n ? \"✅\"\n : (offMap[Number(r.id)] ? OFF_ICO[offMap[Number(r.id)]] : \"⏰\")\n }	${\n r.disc === null ? \"—\" : r.disc + \"%\"\n }	${r.cian === null ? \"—\" : r.cian}	${r.narC} ${r.narS ? money(r.narS) : \"\"}	${money(r.sum)}	${cellBox(r.id, \"zad_cnt\", r.zadC, r.auto.zadC, r.ovZadC, 0)}	${\n cellBox(r.id, \"zad_sum\", r.zadS, r.auto.zadS, r.ovZadS, 1)\n }
ИТОГО			${tot.cian}	${tot.narC} ${\n money(tot.narS)\n }	${money(tot.sum)}	${tot.zadC}	${money(tot.zadS)}

\n\n

Брокеры · деньги

\n \n \n \n ${\n rows.map((r) =>\n `\n \n \n \n \n \n \n `\n ).join(\"\")\n }\n \n \n \n \n \n \n \n \n \n \n \n

Брокер	Сд. пред. мес	Сделки мес по дате сделки	Валовая выручка входящая комиссия	%	Доход мес по дате оплаты	Оплачено	Сделок всего
${\n esc(r.name.split(\" \").map((x) => x[0] \|\| \"\").join(\"\").slice(0, 2))\n } ${esc(r.name)}	${\n cellBox(\n r.id,\n \"deals\",\n r.dealsPrev,\n Number((agg[r.id + \"\|\" + t.prevMonth] \|\| {}).deals) \|\| 0,\n man[r.id + \"\|\" + t.prevMonth] &&\n man[r.id + \"\|\" + t.prevMonth].deals !== null &&\n man[r.id + \"\|\" + t.prevMonth].deals !== undefined,\n 0,\n t.prevMonth,\n )\n }	${cellBox(r.id, \"deals\", r.dealsCur, r.auto.deals, r.ovDeals, 0)}	${grossBox(r.id, r.grossAdd, r.grossAuto)}	0 ? \"pg\" : \"pn\"\n }\">${r.pct}%	${cellBox(r.id, \"income\", r.income, r.auto.income, r.ovInc, 1)}	${r.paidCnt} сдел.${\n r.unpaid ? ` ждёт ${money(r.unpaid)} ` : \"\"\n }	${\n r.dealsTotal === null\n ? 'задать'\n : `${r.dealsTotal}${\n r.totAuto && r.totBase !== null\n ? ` база ${r.totBase} + ${r.totAuto} новых `\n : \"\"\n }`\n }
ИТОГО	${tot.dealsPrev}	${tot.dealsCur}	${\n money(rows.reduce((a, r) => a + r.grossAdd + r.grossAuto, 0))\n }		${money(tot.income)}		${tot.dealsTotal}

Цифры считаются сами из реестра сделок и задатков. Впишите своё значение — оно перекроет авто; чтобы вернуть расчёт, нажмите «вернуть авто».
Валовая выручка — входящая комиссия компании (объект 30 млн × 3% = 900 000 ₽). Здесь ручная сумма не перекрывает реестр, а складывается с ним: впишите то, что было до приложения, и новые сделки прибавятся сверху.

\n\n

Выполнение планов по дням · команда

${weekHtml(d7, teamDiscSeries)}

База команды на Циан по дням

${weekHtml(d7, teamCianSeries, true)}

`\n : \"\"\n }`;\n\n const dealsHtml = cancelReqHtml() + rfmBossHtml() + zadBossHtml() +\n dkpBossHtml() + annulledHtml();\n const monthsHtml = retroHtml();\n const settingsHtml = `\n ${pushCardHtml()}\n ${healthCardHtml()}\n ${pushTeamHtml()}\n ${tvCardHtml()}\n

Брокеры и доступ

\n ${\n t.brokers.length\n ? t.brokers.map((b) => `\n

${esc(b.name)}

\n ПИН ${esc(b.pin)}\n \n

`).join(\"\")\n : '

Брокеров пока нет — добавьте первого ниже

'\n }\n

\n \n \n \n

ПИН — 4–6 цифр, по нему брокер входит в приложение со своего телефона.

🔒 ПИН руководителя

\n \n \n

Стартовый ПИН — 2024. Обязательно смените его после первого входа.

\n `;\n\n $(\"#bossContent\").innerHTML = `\n

\n ${\n [\n [\"home\", \"📊\", \"Сегодня\"],\n [\"deals\", \"📝\", \"Сделки\"],\n [\"arch\", \"📁\", \"Реестр\"],\n [\"months\", \"🗓\", \"Месяцы\"],\n [\"settings\", \"⚙️\", \"Настройки\"],\n ].map((t) =>\n ``\n ).join(\"\")\n }\n

\n ${\n bossTab === \"home\"\n ? homeHtml\n : bossTab === \"deals\"\n ? dealsHtml\n : bossTab === \"arch\"\n ? archTabHtml()\n : bossTab === \"months\"\n ? monthsHtml\n : settingsHtml\n }\n `;\n if (bossTab === \"arch\") fillArchList();\n}\n/* ---- задатки: одобрение + история по месяцам + удаление ---- */\nfunction zadBossHtml() {\n const m = bossZadMonth || teamData.curMonth;\n const pend = bossZad.filter((z) => z.status === \"pending\");\n const hist = bossZad.filter((z) =>\n z.status !== \"pending\" && z.status !== \"annulled\" &&\n String(z.deal_date).slice(0, 7) === m\n );\n const apr = hist.filter((z) => z.status === \"approved\");\n const aprSum = apr.reduce((a, z) => a + Number(z.comm_sum), 0);\n return `

📝 Задатки на одобрение${\n pend.length ? ` · ${pend.length}` : \"\"\n }

\n ${\n pend.length\n ? pend.map((z) => `\n

${esc(z.broker_name)} → ${\n esc(z.client || z.buyer)\n }${\n z.kind === \"bron\"\n ? \" · 🏗 \" + esc(z.complex || \"\") + \" (\" + esc(z.developer || \"\") +\n \", \" + esc(z.channel || \"\") + \")\"\n : (z.buyer && z.client ? \" · пок. \" + esc(z.buyer) : \"\")\n } · CRM ${esc(z.crm_id)}\n

сделка ${money(Number(z.deal_sum))} · комиссия ${\n money(Number(z.comm_sum))\n }${\n z.broker_sum\n ? ` · брокеру ${Number(z.broker_pct)}% = ${\n money(Number(z.broker_sum))\n }`\n : \"\"\n } · ${esc(z.deal_date)}

\n \n

\n \n \n

`).join(\"\")\n : '

Новых задатков на одобрение нет

'\n }\n

После «Одобрить» задаток сразу учитывается в таблице месяца и на табло ТВ.

\n\n

🗂 История задатков\n ${\n monthTitle(m)\n }

\n ${\n hist.length\n ? `\n

Зафиксировано за месяц: ${apr.length} на ${\n money(aprSum)\n }

\n ${\n hist.map((z) =>\n `

${esc(z.broker_name)} → ${\n esc(z.client || z.buyer)\n }${z.kind === \"bron\" ? \" · 🏗 \" + esc(z.complex || \"\") : \"\"} · CRM ${\n esc(z.crm_id)\n }\n

${money(Number(z.deal_sum))} · комиссия ${\n money(Number(z.comm_sum))\n }${\n z.broker_sum\n ? ` · брокеру ${Number(z.broker_pct)}% = ${\n money(Number(z.broker_sum))\n }`\n : \"\"\n } · ${esc(z.deal_date)}

\n \n ${stChip(String(z.status))}\n

`\n ).join(\"\")\n }`\n : '

За этот месяц задатков через приложение не было. Цифры прошлых месяцев можно внести вручную во вкладке «Месяцы».

'\n }\n

Удаление одобренного задатка автоматически вычитает его из цифр месяца и с табло.

`;\n}\nasync function decideZad(id, approve) {\n if (!approve && !confirm(\"Отклонить задаток? Брокер получит уведомление.\")) {\n return;\n }\n await api(\"/api/zadatki/\" + id + \"/decide\", {\n method: \"POST\",\n body: JSON.stringify({ approve }),\n });\n toast(approve ? \"Задаток зафиксирован ✅\" : \"Задаток отклонён\");\n await loadBoss();\n}\nasync function deleteZad(id, status) {\n const msg = status === \"approved\"\n ? \"Удалить задаток? Он будет вычтен из цифр месяца и с табло.\"\n : \"Удалить эту запись о задатке?\";\n if (!confirm(msg)) return;\n await api(\"/api/zadatki/\" + id, { method: \"DELETE\" });\n toast(\"Задаток удалён\");\n bossRetro = null;\n await loadBoss();\n}\n\n/* ---- ретро-данные: ручной ввод прошлых месяцев ---- */\n/* Циан брокера: последнее заполнение за 30 дней, иначе последнее известное вообще */\nfunction cianNow(id) {\n const t = teamData || {};\n const rows = (t.cian || []).filter((r) => Number(r.broker_id) === id).sort((\n a,\n b,\n ) => String(a.date) < String(b.date) ? -1 : 1);\n const v = latestCian(rows);\n if (v !== null) return v;\n const f = (t.cianLast || []).find((r) => Number(r.broker_id) === id);\n return f ? num(f.val) : null;\n}\n\n/* планы месяца — отдельная таблица во вкладке «Месяцы» */\nfunction planTableHtml(m) {\n const t = teamData;\n const active = t.brokers.filter((b) => Number(b.active) === 1);\n if (!active.length) return \"\";\n const A = {};\n (bossRetro && bossRetro.auto || []).forEach((r) => {\n A[Number(r.broker_id)] = r;\n });\n const M = {};\n (bossRetro && bossRetro.manual || []).forEach((r) => {\n M[Number(r.broker_id)] = r;\n });\n const eff = (man, au, f, af) =>\n man[f] !== null && man[f] !== undefined\n ? Number(man[f])\n : Number((au || {})[af] || 0);\n let pd = 0, ps = 0, pz = 0, fd = 0, fs = 0, fz = 0;\n const rows = active.map((b) => {\n const id = Number(b.id), man = M[id] || {}, au = A[id] || {};\n const planD = Number(man.plan_deals) || 0,\n planS = Number(man.plan_sum) || 0,\n planZ = Number(man.plan_zad) || 0;\n // факт по сумме — ВАЛОВАЯ (оплаченные из реестра + ручная добавка): планы ставятся по валовой\n const factD = eff(man, au, \"deals\", \"deals\"),\n factZ = eff(man, au, \"zad_cnt\", \"zad_cnt\");\n const factS = (Number((au || {}).gross_paid) || 0) +\n (man.gross_add !== null && man.gross_add !== undefined\n ? Number(man.gross_add)\n : 0);\n pd += planD;\n ps += planS;\n pz += planZ;\n fd += factD;\n fs += factS;\n fz += factZ;\n return `

${\n esc(b.name)\n }

\n ${planCell(id, \"plan_deals\", planD, 0, m)}${\n planFact(factD, planD, 0)\n }\n ${planCell(id, \"plan_sum\", planS, 1, m)}${\n planFact(factS, planS, 1)\n }\n ${planCell(id, \"plan_zad\", planZ, 0, m)}${\n planFact(factZ, planZ, 0)\n }`;\n }).join(\"\");\n return `

🎯 Планы · ${monthTitle(m)}

\n \n \n ${rows}\n \n \n \n \n \n

Брокер	План сделок	Факт	План валовой	Факт	План задатков	Факт
ИТОГО	${pd}	${fd}	${\n money(ps)\n }	${money(fs)}	${pz}	${fz}

Личные цели брокера на месяц — он видит прогресс у себя в «Динамике». Тап по числу, чтобы задать.

`;\n}\n\nfunction retroHtml() {\n const t = teamData;\n const m = bossRetroMonth || t.curMonth;\n const active = t.brokers.filter((b) => Number(b.active) === 1);\n const head = `

🗓 Данные месяца\n ${\n monthTitle(m)\n }

`;\n if (!bossRetro || bossRetro.month !== m) {\n return head +\n '

Загружаю…

';\n }\n if (!active.length) {\n return head +\n '

Сначала добавьте брокеров во вкладке «Настройки»

';\n }\n const A = {};\n (bossRetro.auto || []).forEach((r) => {\n A[Number(r.broker_id)] = r;\n });\n const rows = active.map((b) => {\n const id = Number(b.id);\n const man = (bossRetro.manual || []).find((x) =>\n Number(x.broker_id) === id\n ) || {};\n const net = (bossRetro.net || []).find((x) => Number(x.broker_id) === id);\n const au = A[id] || {};\n const has = (f) => man[f] !== null && man[f] !== undefined;\n const val = (f, af) => has(f) ? Number(man[f]) : Number(au[af] || 0);\n return `\n

${esc(b.name)}

\n ${\n cellBox(\n id,\n \"deals\",\n val(\"deals\", \"deals\"),\n Number(au.deals) || 0,\n has(\"deals\"),\n 0,\n m,\n )\n }\n ${\n grossBox(\n id,\n has(\"gross_add\") ? Number(man.gross_add) : 0,\n Number(au.gross_paid) || 0,\n m,\n )\n }\n ${\n cellBox(\n id,\n \"zad_cnt\",\n val(\"zad_cnt\", \"zad_cnt\"),\n Number(au.zad_cnt) || 0,\n has(\"zad_cnt\"),\n 0,\n m,\n )\n }\n ${\n cellBox(\n id,\n \"zad_sum\",\n val(\"zad_sum\", \"zad_sum\"),\n Number(au.zad_sum) || 0,\n has(\"zad_sum\"),\n 1,\n m,\n )\n }\n ${\n cellBox(\n id,\n \"income\",\n val(\"income\", \"income\"),\n Number(au.income) || 0,\n has(\"income\"),\n 1,\n m,\n )\n }\n ${\n (() => {\n // чистый доход считается сам: доход − 6%. Приоритет: ручной доход → авто из реестра → вписанный чистый (старые месяцы)\n const base = has(\"income\")\n ? Number(man.income)\n : (Number(au.income) > 0\n ? Number(au.income)\n : (net ? Number(net.amount) : 0));\n return `${\n base\n ? `${money(Math.round(base * 0.94))}`\n : '—'\n }`;\n })()\n }\n `;\n }).join(\"\");\n return head + `\n

💡

РетроспективаЛистайте месяцы стрелками. Сделки и задатки считаются по дате сделки, доход и валовая выручка — по дате оплаты («зашло» — когда отмечена оплата), как на табло. Впишите своё число, чтобы перекрыть расчёт, или нажмите «вернуть авто». Ручная валовая складывается с реестром — можно внести прошлые месяцы разом.

\n \n \n ${rows}\n

Брокер	Сделки	Валовая выручка	Задатки шт	Задатки ₽	Доход ₽	Чистый доход

Тап по числу — правка вручную, ↺ рядом возвращает авторасчёт. «Чистый доход» считается сам: доход − 6%; тап по нему — вписать доход до вычета для старых месяцев.

\n ${planTableHtml(m)}`;\n}\n\nasync function editNetR(id, cur) {\n const m = bossRetroMonth || teamData.curMonth;\n const s = prompt(\n \"Доход брокера за \" + monthTitle(m) +\n \" ДО вычета 6%, ₽ (чистый посчитается сам; пусто — убрать):\",\n cur || \"\",\n );\n if (s === null) return;\n const clean = String(s).replace(/\\D/g, \"\");\n if (clean === \"\") {\n await api(\"/api/netincome\", {\n method: \"POST\",\n body: JSON.stringify({ broker_id: id, month: m, amount: null }),\n });\n } else {\n const n = parseInt(clean, 10);\n if (!Number.isFinite(n) || n < 0) {\n toast(\"Введите сумму цифрами\");\n return;\n }\n await api(\"/api/netincome\", {\n method: \"POST\",\n body: JSON.stringify({ broker_id: id, month: m, amount: n }),\n });\n }\n toast(\"Сохранено ✓\");\n await loadRetro();\n}\n\n/* ---- Росфинмониторинг: ДКП от 5 млн, пока не отмечены как отправленные ---- */\nfunction rfmPending() {\n return bossRfm.filter((d) => !Number(d.rfm_sent));\n}\nfunction rfmBossHtml() {\n const pend = rfmPending();\n const sent = bossRfm.filter((d) => Number(d.rfm_sent));\n const line = (d) =>\n `

${esc(d.client || d.crm_id)}${\n d.counter ? \" / встр. \" + esc(d.counter) : \"\"\n } · CRM ${esc(d.crm_id)}${\n String(d.sector) === \"new\" ? \" · 🏗 \" + esc(d.complex || \"\") : \"\"\n }\n

ДКП от ${esc(d.deal_date)} · ${\n money(Number(d.deal_sum))\n } · ${esc(d.person || \"\")} · брокер ${esc(d.broker_name)}${\n d.rfm_sent_at ? \" · отправлено \" + esc(d.rfm_sent_at) : \"\"\n }

\n \n \n Отправлено\n \n

`;\n return `

📤 В Росфинмониторинг${\n pend.length ? ` · ${pend.length}` : \"\"\n }

\n ${\n pend.length\n ? pend.map(line).join(\"\")\n : '

Всё отправлено — новых ДКП от 5 млн ₽ нет

'\n }\n

Сюда попадают только ДКП на сумму от 5 000 000 ₽ — по вторичке и по новостройкам, если сделка оформлена ДКП. ДДУ не отправляем. Напоминание приходит через 30 секунд после подтверждения сделки и потом каждый день, пока не поставите галочку.

\n ${\n sent.length\n ? `

Уже отправлено · ${sent.length}

${\n sent.slice(0, 20).map(line).join(\"\")\n }

`\n : \"\"\n }`;\n}\nasync function toggleRfm(id, val) {\n try {\n const r = await api(\"/api/dkp/\" + id + \"/rfm\", {\n method: \"POST\",\n body: JSON.stringify({ sent: val ? 1 : 0 }),\n });\n const d = bossRfm.find((x) => Number(x.id) === id);\n if (d) {\n d.rfm_sent = r.rfm_sent;\n d.rfm_sent_at = r.rfm_sent_at;\n }\n toast(\n val\n ? \"Отмечено: отправлено в Росфинмониторинг ✓\"\n : \"Отметка снята — напомню снова\",\n );\n renderBoss();\n } catch (e) {\n renderBoss();\n }\n}\n\n/* ---- сделки на одобрение + единый реестр (первичка/вторичка) ---- */\nfunction dkpPendHtml() {\n const pend = bossDkp.filter((d) => String(d.status) === \"pending\");\n return `

📄 Сделки на одобрение${\n pend.length ? ` · ${pend.length}` : \"\"\n }

\n ${\n pend.length\n ? pend.map((d) => {\n const nw = String(d.sector) === \"new\";\n const dt = String(d.doc_type || (nw ? \"ddu\" : \"dkp\")) === \"dkp\"\n ? \"ДКП\"\n : \"ДДУ\";\n const dog = nw\n ? (d.ddu_num\n ? dt + \" \" + esc(String(d.ddu_num)) +\n (d.ddu_date ? \" от \" + esc(String(d.ddu_date)) : \"\")\n : \"\")\n : (d.agn_num\n ? \"АД \" + esc(String(d.agn_num)) +\n (d.agn_date ? \" от \" + esc(String(d.agn_date)) : \"\") +\n (d.agn_sign ? \" · \" + esc(String(d.agn_sign)) : \"\")\n : \"\");\n const backdated = String(d.deal_date).slice(0, 7) < teamData.curMonth\n ? `

📅 дата сделки в прошлом месяце — учтётся в ${\n monthTitle(String(d.deal_date).slice(0, 7))\n }, не в текущем

`\n : \"\";\n const rfmWarn = Number(d.rfm)\n ? `

📤 ДКП от 5 млн — после подтверждения попадёт в список для Росфинмониторинга

`\n : \"\";\n return `

${esc(d.broker_name)} → ${esc(d.client || \"\")}${\n d.counter ? \" / встр. \" + esc(d.counter) : \"\"\n }${\n nw\n ? \" · 🏗 \" + esc(d.complex || \"\") + \" (\" + esc(d.developer || \"\") +\n \", \" + esc(d.channel || \"\") + \")\"\n : \" · \" + esc(d.side || \"\") + \" · \" + esc(d.person || \"\")\n } · CRM ${esc(d.crm_id)}\n

сделка ${money(Number(d.deal_sum))} · комиссия ${\n d.comm_pct ? Number(d.comm_pct) + \"% = \" : \"\"\n }${money(Number(d.comm_in) || 0)}${\n Number(d.ka)\n ? \" · контрагенту \" + Number(d.ka_pct) + \"% = \" +\n money(Number(d.ka_sum) || 0)\n : \"\"\n } · брокеру ${Number(d.broker_pct)}% = ${\n money(Number(d.broker_sum) || 0)\n } · ${esc(d.deal_date)}

\n ${dog ? `

${dog}

` : \"\"}${backdated}${rfmWarn}

\n \n

\n \n \n

`;\n }).join(\"\")\n : '

Новых сделок на одобрение нет

'\n }\n

Только после «Одобрить» сделка попадает в цифры месяца, на табло и в реестр как подтверждённая.

`;\n}\nasync function decideDkp(id, approve) {\n if (!approve && !confirm(\"Отклонить сделку? Брокер получит уведомление.\")) {\n return;\n }\n const r = await api(\"/api/dkp/\" + id + \"/decide\", {\n method: \"POST\",\n body: JSON.stringify({ approve }),\n });\n if (approve && r && Number(r.rfm)) {\n toast(\n \"Сделка подтверждена ✅ ДКП от 5 млн — напомню про Росфинмониторинг через 30 сек\",\n );\n } else {\n toast(approve ? \"Сделка подтверждена ✅\" : \"Сделка отклонена\");\n }\n bossRetro = null;\n await loadBoss();\n}\nasync function togglePaid(id, val) {\n const d = bossDkp.find((x) => Number(x.id) === id);\n let payload = { paid: val ? 1 : 0 };\n if (val) {\n const def = TODAY;\n const s = prompt(\"Дата оплаты (доход попадёт в этот месяц):\", def);\n if (s === null) {\n renderBoss();\n return;\n }\n const v = String(s).trim() || def;\n if (!/^\\d{4}-\\d{2}-\\d{2}$/.test(v)) {\n toast(\"Дата в формате ГГГГ-ММ-ДД\");\n renderBoss();\n return;\n }\n payload.paid_at = v;\n }\n try {\n const r = await api(\"/api/dkp/\" + id + \"/paid\", {\n method: \"POST\",\n body: JSON.stringify(payload),\n });\n if (d) {\n d.paid = r.paid;\n d.paid_at = r.paid_at;\n }\n toast(\n val\n ? (\"Оплачено ✓ доход учтён в \" +\n monthTitle(String(r.paid_at).slice(0, 7)))\n : \"Отметка об оплате снята\",\n );\n teamData = await api(\"/api/team?date=\" + TODAY);\n bossRetro = null;\n renderBoss();\n } catch (e) {\n renderBoss();\n }\n}\n/* ---- развал задатков: согласование и архив разваленных ---- */\nfunction cancelReqHtml() {\n const reqs = bossZadAll.filter((z) =>\n Number(z.cancel_req) === 1 && String(z.status) === \"approved\"\n );\n if (!reqs.length) return \"\";\n return `

⛔ Запросы на развал · ${reqs.length}

${\n reqs.map((z) =>\n `

${esc(z.broker_name)} → ${\n esc(z.client || z.buyer || \"\")\n } · CRM ${esc(z.crm_id)}\n

${money(Number(z.deal_sum))} · комиссия ${\n money(Number(z.comm_sum) || 0)\n } · задаток от ${esc(z.deal_date)}

Развал ${\n esc(z.cancel_date || \"\")\n } · причина: ${esc(z.cancel_reason || \"\")}

\n \n \n

`\n ).join(\"\")\n }\n

После подтверждения задаток аннулируется: уходит из статистики месяца, реестра и табло, но сохраняется в списке «Разваленные» ниже.

`;\n}\nasync function zadCancelDecide(id, ok) {\n if (\n ok &&\n !confirm(\n \"Подтвердить развал? Задаток будет аннулирован и вычтен из статистики.\",\n )\n ) return;\n await api(\"/api/zadatki/\" + id + \"/canceldecide\", {\n method: \"POST\",\n body: JSON.stringify({ ok }),\n });\n toast(ok ? \"Задаток аннулирован ⛔\" : \"Развал отклонён — задаток в силе\");\n await loadBoss();\n}\nfunction annulledHtml() {\n const a = bossZadAll.filter((z) => String(z.status) === \"annulled\");\n if (!a.length) return \"\";\n return `

🗑 Разваленные задатки и брони · ${a.length}

\n \n ${\n a.map((z) =>\n `\n \n \n \n \n `\n ).join(\"\")\n }

Дата задатка	Брокер	Клиент	Сумма	Комиссия	Дата развала	Причина
${\n esc(z.deal_date)\n }	${esc(z.broker_name)}	${esc(z.client \|\| z.buyer \|\| \"\")} CRM ${\n esc(z.crm_id)\n }	${\n money(Number(z.deal_sum))\n }	${\n money(Number(z.comm_sum) \|\| 0)\n }	${esc(z.cancel_date \|\| \"\")}	${esc(z.cancel_reason \|\| \"\")}

Архив: в статистике, реестре и на табло эти задатки не учитываются. Хранится бессрочно.

`;\n}\n/* реестр: отдельные списки — market: 'sec'|'new', what: 'deal'|'zad'; arch=true — только архив */\nfunction regRows(market, what, arch) {\n const isNew = market === \"new\";\n let all;\n if (what === \"deal\") {\n // архив сделки: одобрена и оплачена (деньги пришли, брокеру выплачено)\n const inArch = (d) =>\n String(d.status) === \"approved\" && Number(d.paid) === 1;\n all = bossDkp.filter((d) =>\n isNew === (String(d.sector) === \"new\") && (arch ? inArch(d) : !inArch(d))\n ).map((d) => ({\n kind: \"dkp\",\n market,\n id: Number(d.id),\n typ: \"Сделка\",\n date: String(d.deal_date),\n broker: String(d.broker_name),\n crm: String(d.crm_id),\n client: String(d.client || \"\") + (d.counter ? \" / \" + d.counter : \"\"),\n contract: isNew\n ? (d.ddu_num\n ? (String(d.doc_type || \"ddu\") === \"dkp\" ? \"ДКП \" : \"ДДУ \") +\n d.ddu_num + (d.ddu_date ? \" от \" + d.ddu_date : \"\")\n : \"—\")\n : (d.agn_num\n ? \"АД \" + d.agn_num + (d.agn_date ? \" от \" + d.agn_date : \"\") +\n (d.agn_sign ? \", \" + String(d.agn_sign).toLowerCase() : \"\")\n : \"—\"),\n rfm: Number(d.rfm) ? (Number(d.rfm_sent) ? \"sent\" : \"todo\") : null,\n sum: Number(d.deal_sum),\n comm: Number(d.comm_in) || 0,\n commPct: d.comm_pct ? Number(d.comm_pct) : null,\n ka: Number(d.ka)\n ? { pct: Number(d.ka_pct), sum: Number(d.ka_sum) || 0 }\n : null,\n bpct: d.broker_pct ? Number(d.broker_pct) : null,\n bsum: d.broker_sum ? Number(d.broker_sum) : null,\n status: String(d.status || \"approved\"),\n paid: Number(d.paid) ? 1 : 0,\n paidAt: d.paid_at ? String(d.paid_at) : null,\n hasPaid: true,\n doc: String(d.doc_name || \"document\"),\n agnDoc: d.agn_doc_name ? String(d.agn_doc_name) : null,\n }));\n } else {\n // архив задатка: вручную отмечен «вышел на сделку»\n all = bossZadAll.filter((z) =>\n isNew === (String(z.kind) === \"bron\") &&\n String(z.status) !== \"annulled\" &&\n (arch ? Number(z.archived) === 1 : !Number(z.archived))\n ).map((z) => ({\n kind: \"zad\",\n market,\n id: Number(z.id),\n typ: String(z.kind) === \"bron\" ? \"Бронь\" : \"Задаток\",\n date: String(z.deal_date),\n broker: String(z.broker_name),\n crm: String(z.crm_id),\n client: String(z.client || z.buyer || \"\"),\n contract: \"—\",\n rfm: null,\n sum: Number(z.deal_sum),\n comm: Number(z.comm_sum) || 0,\n commPct: z.comm_pct ? Number(z.comm_pct) : null,\n bpct: z.broker_pct ? Number(z.broker_pct) : null,\n bsum: z.broker_sum ? Number(z.broker_sum) : null,\n status: String(z.status),\n paid: 0,\n hasPaid: false,\n doc: String(z.doc_name || \"document\"),\n archived: Number(z.archived) ? 1 : 0,\n }));\n }\n all.sort((a, b) => a.date < b.date ? -1 : a.date > b.date ? 1 : a.id - b.id);\n all.forEach((r, i) => {\n r.n = i + 1;\n });\n all.reverse();\n return all;\n}\n/* таблица с секциями: каждая секция — полоса-заголовок с итогами + свои строки */\nfunction regTable(sections) {\n const secHtml = (s) => {\n if (!s.rows.length) return \"\";\n const a = s.rows.filter((r) => r.status === \"approved\");\n const cIn = a.reduce((x, r) => x + (r.comm || 0), 0);\n const bar =\n `${s.label} · ${s.rows.length} шт · комиссия по одобренным ${\n money(cIn)\n }`;\n return bar + s.rows.map((r) =>\n `\n ${r.n}${\n esc(r.date)\n }${esc(r.broker)}\n ${esc(r.client)}

CRM ${esc(r.crm)}

\n ${esc(r.contract)}\n ${\n r.rfm === \"sent\"\n ? '✅'\n : r.rfm === \"todo\"\n ? '📤'\n : '—'\n }\n ${money(r.sum)}\n ${\n r.comm ? money(r.comm) : \"—\"\n }${r.commPct ? `

${r.commPct}%

` : \"\"}\n ${\n r.ka\n ? `${money(r.ka.sum)}

${r.ka.pct}%

`\n : '—'\n }\n ${\n r.bsum\n ? `${money(r.bsum)}

${r.bpct}%

`\n : \"—\"\n }\n ${stChip(r.status)}\n ${\n r.hasPaid\n ? `${\n r.paidAt\n ? `

${\n esc(r.paidAt)\n }

`\n : \"\"\n }`\n : '—'\n }\n ${\n r.agnDoc\n ? ` `\n : \"\"\n }${\n r.kind === \"zad\" && r.status === \"approved\"\n ? (r.archived\n ? ` `\n : ` `)\n : \"\"\n } \n `\n ).join(\"\");\n };\n return `

\n \n ${sections.map(secHtml).join(\"\")}

№	Дата	Брокер	Клиент	Договор	РФМ	Сумма	Комиссия	К-агент	Брокеру	Статус	Оплачено

`;\n}\n/* цвета секций */\nconst MKT_NEW = {\n barBg: \"rgba(72,150,255,.18)\",\n rowBg: \"rgba(72,150,255,.07)\",\n};\nconst MKT_SEC = {\n barBg: \"rgba(255,178,36,.17)\",\n rowBg: \"rgba(255,178,36,.06)\",\n};\n/* сводка по группе (по одобренным): шт, входящая, НДС, контрагентам, брокерам, не выплачено, наша */\nfunction regStat(rows) {\n const a = rows.filter((r) => r.status === \"approved\");\n const cIn = a.reduce((x, r) => x + (r.comm || 0), 0);\n const nds = cIn - Math.round(cIn / 1.05);\n const ka = a.reduce((x, r) => x + (r.ka ? r.ka.sum : 0), 0);\n const bsum = a.reduce((x, r) => x + (r.bsum || 0), 0);\n const bUnpaid = a.filter((r) => r.hasPaid && !r.paid).reduce(\n (x, r) => x + (r.bsum || 0),\n 0,\n );\n return {\n n: a.length,\n cIn,\n nds,\n ka,\n bsum,\n bUnpaid,\n our: cIn - nds - ka - bsum,\n };\n}\n/* мини-сводка: заголовок + строки направлений + итог; сделки и задатки НЕ смешиваются */\nfunction miniDash(title, heads, lines, foot) {\n return `

${title}

\n ${\n heads.map((h) => ``).join(\"\")\n }\n ${\n lines.map((l) =>\n `${\n l.vals.map((v) =>\n ``\n ).join(\"\")\n }`\n ).join(\"\")\n }\n

	${h}
${l.label}	${v}

\n ${\n foot\n ? `

${foot}

`\n : \"\"\n }

`;\n}\nfunction dashDeals(nwD, secD) {\n const V =\n (s) => [\n s.n || \"—\",\n s.cIn ? money(s.cIn) : \"—\",\n s.nds ? money(s.nds) : \"—\",\n s.ka ? money(s.ka) : \"—\",\n s.bsum ? money(s.bsum) : \"—\",\n s.bUnpaid ? `${money(s.bUnpaid)}` : \"—\",\n s.cIn ? `${money(s.our)}` : \"—\",\n ];\n return miniDash(\n \"📄 Сделки — доход\",\n [\"Шт\", \"Входящая\", \"НДС 5%\", \"К-агентам\", \"Брокерам\", \"Не выпл.\", \"Наша\"],\n [{\n label: \"🏗 Новостройки\",\n vals: V(regStat(nwD)),\n st: `background:${MKT_NEW.rowBg}`,\n }, {\n label: \"🏠 Вторичка\",\n vals: V(regStat(secD)),\n st: `background:${MKT_SEC.rowBg}`,\n }, {\n label: \"Итого\",\n vals: V(regStat(nwD.concat(secD))),\n st: \"background:rgba(61,220,151,.13);font-weight:800\",\n }],\n \"Наша = входящая комиссия − НДС − контрагентам − брокерам · только одобренные сделки\",\n );\n}\nfunction dashZads(nwZ, secZ) {\n const V =\n (s) => [\n s.n || \"—\",\n s.cIn ? money(s.cIn) : \"—\",\n s.nds ? money(s.nds) : \"—\",\n s.bsum ? money(s.bsum) : \"—\",\n s.cIn ? `${money(s.our)}` : \"—\",\n ];\n return miniDash(\n \"📝 Задатки и брони — прогноз\",\n [\"Шт\", \"Комиссия\", \"НДС 5%\", \"Брокерам\", \"Наша\"],\n [{\n label: \"🏗 Брони\",\n vals: V(regStat(nwZ)),\n st: `background:${MKT_NEW.rowBg}`,\n }, {\n label: \"🏠 Задатки\",\n vals: V(regStat(secZ)),\n st: `background:${MKT_SEC.rowBg}`,\n }, {\n label: \"Итого\",\n vals: V(regStat(nwZ.concat(secZ))),\n st: \"background:rgba(61,220,151,.13);font-weight:800\",\n }],\n \"Это ещё не доход — прогноз по зафиксированной комиссии, если задатки выйдут на сделку\",\n );\n}\nlet bossArchOpen = false;\nasync function zadArchive(id, on) {\n await api(\"/api/zadatki/\" + id + \"/archive\", {\n method: \"POST\",\n body: JSON.stringify({ on }),\n });\n toast(\n on ? \"Задаток в архиве — вышел на сделку 📦\" : \"Задаток возвращён в работу\",\n );\n await loadBoss();\n}\nfunction dkpBossHtml() {\n // две таблицы с секциями внутри: брони→задатки и сделки первичка→вторичка; сверху сводный дашборд\n const nwZ = regRows(\"new\", \"zad\"),\n secZ = regRows(\"sec\", \"zad\"),\n nwD = regRows(\"new\", \"deal\"),\n secD = regRows(\"sec\", \"deal\");\n const aZn = regRows(\"new\", \"zad\", true),\n aZs = regRows(\"sec\", \"zad\", true),\n aDn = regRows(\"new\", \"deal\", true),\n aDs = regRows(\"sec\", \"deal\", true);\n const archZ = aZn.concat(aZs),\n archD = aDn.concat(aDs),\n archCnt = archZ.length + archD.length;\n const zads = nwZ.concat(secZ), deals = nwD.concat(secD);\n const bsumA = (rows) =>\n rows.filter((r) => r.kind === \"dkp\" && r.status === \"approved\").reduce(\n (a, r) => a + (r.bsum || 0),\n 0,\n );\n const unpaid = (rows) =>\n rows.filter((r) => r.kind === \"dkp\" && r.status === \"approved\" && !r.paid)\n .reduce((a, r) => a + (r.bsum || 0), 0);\n // сводки считают ВСЁ (активные + архив) — архивация не меняет цифры\n const dash =\n `

\n ${dashDeals(nwD.concat(aDn), secD.concat(aDs))}${\n dashZads(nwZ.concat(aZn), secZ.concat(aZs))\n }

`;\n const block = (title, sections, rows, what) =>\n rows.length\n ? `

${title} · ${rows.length}

\n ${\n what === \"deal\"\n ? `

Брокерам по одобренным сделкам: ${\n money(bsumA(rows))\n }${\n unpaid(rows)\n ? ` · не оплачено: ${\n money(unpaid(rows))\n }`\n : \"\"\n }

`\n : \"\"\n }\n ${regTable(sections)}

`\n : \"\";\n const any = zads.length || deals.length || archCnt;\n return dkpPendHtml() + `\n \n

🗂 Реестр сделок и задатков\n ${\n any\n ? ``\n : \"\"\n }

\n ${any ? dash : \"\"}\n ${\n block(\n \"📝 Задатки и брони\",\n [\n { label: \"🏗 Брони · новостройки\", rows: nwZ, ...MKT_NEW },\n { label: \"🏠 Задатки · вторичка\", rows: secZ, ...MKT_SEC },\n ],\n zads,\n \"zad\",\n )\n }\n ${\n block(\n \"📄 Сделки\",\n [\n {\n label: \"🏗 Сделки · новостройки (первичный рынок)\",\n rows: nwD,\n ...MKT_NEW,\n },\n { label: \"🏠 Сделки · вторичный рынок\", rows: secD, ...MKT_SEC },\n ],\n deals,\n \"deal\",\n )\n }\n ${\n archCnt\n ? `

📦 Архив · ${archCnt}${\n bossArchOpen ? \"▲ свернуть\" : \"▼ показать\"\n }

\n ${\n bossArchOpen\n ? block(\n \"📦 Задатки, вышедшие на сделку\",\n [\n { label: \"🏗 Брони\", rows: aZn, ...MKT_NEW },\n { label: \"🏠 Задатки\", rows: aZs, ...MKT_SEC },\n ],\n archZ,\n \"zadarch\",\n ) + block(\n \"📦 Оплаченные сделки (расчёт завершён)\",\n [\n { label: \"🏗 Новостройки\", rows: aDn, ...MKT_NEW },\n { label: \"🏠 Вторичка\", rows: aDs, ...MKT_SEC },\n ],\n archD,\n \"dealarch\",\n )\n : \"\"\n }`\n : \"\"\n }\n ${\n !any\n ? '

Реестр пока пуст — записи появятся из задатков, броней и сделок брокеров.

'\n : \"\"\n }\n

Внутри каждой таблицы — цветная полоса направления с итогом (голубая — новостройки, жёлтая — вторичка), под ней его записи. По любой записи: 📎 — открыть документ, расчёт виден в строке. Галочка «Оплачено» — выплатили брокеру: спросим дату, и доход попадёт в месяц оплаты, а сама сделка и её сумма останутся в месяце подписания. Хранится бессрочно.

`;\n}\nasync function deleteDkp(id) {\n if (\n !confirm(\n \"Удалить сделку из реестра? Одобренная будет вычтена из сделок месяца.\",\n )\n ) return;\n await api(\"/api/dkp/\" + id, { method: \"DELETE\" });\n toast(\"Сделка удалена\");\n bossRetro = null;\n await loadBoss();\n}\nfunction exportDkp() {\n const stTxt = {\n pending: \"На одобрении\",\n approved: \"Одобрено\",\n rejected: \"Отклонено\",\n };\n const secD = bossDkp.filter((d) => String(d.sector) !== \"new\");\n const nwD = bossDkp.filter((d) => String(d.sector) === \"new\");\n const secZ = bossZadAll.filter((z) =>\n String(z.kind) !== \"bron\" && String(z.status) !== \"annulled\"\n );\n const nwZ = bossZadAll.filter((z) =>\n String(z.kind) === \"bron\" && String(z.status) !== \"annulled\"\n );\n const annZ = bossZadAll.filter((z) => String(z.status) === \"annulled\");\n const rows = [[\"РЕЕСТР СДЕЛОК И ЗАДАТКОВ\"], [\n \"Выгружено\",\n new Date().toLocaleString(\"ru-RU\"),\n ], []];\n rows.push([\"ВТОРИЧНЫЙ РЫНОК — СДЕЛКИ (ДКП), Росфинмониторинг и отчётность\"]);\n rows.push([\n \"№\",\n \"Дата сделки\",\n \"Брокер\",\n \"№ заявки CRM\",\n \"Клиент\",\n \"Встречная сторона\",\n \"Кого сопровождаем\",\n \"Тип лица\",\n \"№ агентского договора\",\n \"Дата АД\",\n \"Подписан\",\n \"Сумма сделки, ₽\",\n \"Комиссия, %\",\n \"Комиссия, ₽\",\n \"Контрагент\",\n \"% контрагента\",\n \"Сумма контрагента, ₽\",\n \"% брокера\",\n \"Сумма брокера, ₽\",\n \"В Росфинмониторинг\",\n \"Отправлено в РФМ\",\n \"Дата отправки в РФМ\",\n \"Статус\",\n \"Оплачено брокеру\",\n \"Дата оплаты\",\n \"Месяц дохода\",\n \"Файл\",\n \"Загружен\",\n ]);\n secD.slice().reverse().forEach((d, i) =>\n rows.push([\n i + 1,\n String(d.deal_date),\n String(d.broker_name),\n String(d.crm_id),\n String(d.client || \"\"),\n String(d.counter || \"\"),\n String(d.side || \"\"),\n String(d.person || \"\"),\n String(d.agn_num || \"\"),\n String(d.agn_date || \"\"),\n String(d.agn_sign || \"\"),\n Number(d.deal_sum),\n d.comm_pct ? Number(d.comm_pct) : \"\",\n d.comm_in ? Number(d.comm_in) : \"\",\n Number(d.ka) ? \"Да\" : \"Нет\",\n Number(d.ka) ? Number(d.ka_pct) : \"\",\n Number(d.ka) ? Number(d.ka_sum) || 0 : \"\",\n d.broker_pct ? Number(d.broker_pct) : \"\",\n d.broker_sum ? Number(d.broker_sum) : \"\",\n Number(d.rfm) ? \"Да\" : \"Нет\",\n Number(d.rfm) ? (Number(d.rfm_sent) ? \"Да\" : \"НЕТ — отправить\") : \"\",\n String(d.rfm_sent_at || \"\"),\n stTxt[String(d.status)] || \"Одобрено\",\n Number(d.paid) ? \"Да\" : \"Нет\",\n String(d.paid_at || \"\"),\n d.paid_at ? String(d.paid_at).slice(0, 7) : \"\",\n String(d.doc_name || \"\"),\n String(d.created_at || \"\"),\n ])\n );\n rows.push([]);\n rows.push([\"ВТОРИЧНЫЙ РЫНОК — ЗАДАТКИ\"]);\n rows.push([\n \"№\",\n \"Дата\",\n \"Брокер\",\n \"№ заявки CRM\",\n \"Клиент\",\n \"Покупатель\",\n \"Сумма сделки, ₽\",\n \"Комиссия, %\",\n \"Комиссия, ₽\",\n \"Статус\",\n \"Файл\",\n ]);\n secZ.slice().reverse().forEach((z, i) =>\n rows.push([\n i + 1,\n String(z.deal_date),\n String(z.broker_name),\n String(z.crm_id),\n String(z.client || \"\"),\n String(z.buyer || \"\"),\n Number(z.deal_sum),\n z.comm_pct ? Number(z.comm_pct) : \"\",\n Number(z.comm_sum) || \"\",\n stTxt[String(z.status)] || \"\",\n String(z.doc_name || \"\"),\n ])\n );\n rows.push([]);\n rows.push([\"ПЕРВИЧНЫЙ РЫНОК — СДЕЛКИ (НОВОСТРОЙКИ)\"]);\n rows.push([\n \"№\",\n \"Дата сделки\",\n \"Брокер\",\n \"№ заявки CRM\",\n \"Клиент\",\n \"Застройщик\",\n \"ЖК\",\n \"Канал\",\n \"Тип договора\",\n \"№ договора\",\n \"Дата договора\",\n \"Сумма сделки, ₽\",\n \"Комиссия застройщика, %\",\n \"Комиссия, ₽\",\n \"% брокера\",\n \"Сумма брокера, ₽\",\n \"В Росфинмониторинг\",\n \"Отправлено в РФМ\",\n \"Дата отправки в РФМ\",\n \"Статус\",\n \"Оплачено брокеру\",\n \"Дата оплаты\",\n \"Месяц дохода\",\n \"Файл\",\n \"Загружен\",\n ]);\n nwD.slice().reverse().forEach((d, i) =>\n rows.push([\n i + 1,\n String(d.deal_date),\n String(d.broker_name),\n String(d.crm_id),\n String(d.client || \"\"),\n String(d.developer || \"\"),\n String(d.complex || \"\"),\n String(d.channel || \"\"),\n String(d.doc_type || \"ddu\") === \"dkp\" ? \"ДКП\" : \"ДДУ\",\n String(d.ddu_num || \"\"),\n String(d.ddu_date || \"\"),\n Number(d.deal_sum),\n d.comm_pct ? Number(d.comm_pct) : \"\",\n d.comm_in ? Number(d.comm_in) : \"\",\n d.broker_pct ? Number(d.broker_pct) : \"\",\n d.broker_sum ? Number(d.broker_sum) : \"\",\n Number(d.rfm) ? \"Да\" : \"Нет\",\n Number(d.rfm) ? (Number(d.rfm_sent) ? \"Да\" : \"НЕТ — отправить\") : \"\",\n String(d.rfm_sent_at || \"\"),\n stTxt[String(d.status)] || \"Одобрено\",\n Number(d.paid) ? \"Да\" : \"Нет\",\n String(d.paid_at || \"\"),\n d.paid_at ? String(d.paid_at).slice(0, 7) : \"\",\n String(d.doc_name || \"\"),\n String(d.created_at || \"\"),\n ])\n );\n rows.push([]);\n rows.push([\"ПЕРВИЧНЫЙ РЫНОК — БРОНИ\"]);\n rows.push([\n \"№\",\n \"Дата\",\n \"Брокер\",\n \"№ заявки CRM\",\n \"Клиент\",\n \"Застройщик\",\n \"ЖК\",\n \"Канал\",\n \"Сумма сделки, ₽\",\n \"Комиссия застройщика, %\",\n \"Комиссия, ₽\",\n \"% брокера\",\n \"Сумма брокера, ₽\",\n \"Статус\",\n \"Файл\",\n ]);\n nwZ.slice().reverse().forEach((z, i) =>\n rows.push([\n i + 1,\n String(z.deal_date),\n String(z.broker_name),\n String(z.crm_id),\n String(z.client || \"\"),\n String(z.developer || \"\"),\n String(z.complex || \"\"),\n String(z.channel || \"\"),\n Number(z.deal_sum),\n z.comm_pct ? Number(z.comm_pct) : \"\",\n Number(z.comm_sum) || \"\",\n z.broker_pct ? Number(z.broker_pct) : \"\",\n z.broker_sum ? Number(z.broker_sum) : \"\",\n stTxt[String(z.status)] || \"\",\n String(z.doc_name || \"\"),\n ])\n );\n if (annZ.length) {\n rows.push([]);\n rows.push([\n \"РАЗВАЛЕННЫЕ ЗАДАТКИ И БРОНИ (аннулированы, в статистике не учитываются)\",\n ]);\n rows.push([\n \"№\",\n \"Дата задатка\",\n \"Брокер\",\n \"№ заявки CRM\",\n \"Клиент\",\n \"Сумма сделки, ₽\",\n \"Комиссия, ₽\",\n \"Дата развала\",\n \"Причина\",\n ]);\n annZ.slice().reverse().forEach((z, i) =>\n rows.push([\n i + 1,\n String(z.deal_date),\n String(z.broker_name),\n String(z.crm_id),\n String(z.client || z.buyer || \"\"),\n Number(z.deal_sum),\n Number(z.comm_sum) || \"\",\n String(z.cancel_date || \"\"),\n String(z.cancel_reason || \"\"),\n ])\n );\n }\n rows.push([]);\n rows.push([\n \"Расчёт: комиссия = сумма сделки × наш %; контрагенту = сумма сделки × его % / 1,05;\",\n ]);\n rows.push([\n \"база брокера = комиссия / 1,05 − сумма контрагента; брокеру = база × его % на месяц сделки\",\n ]);\n rows.push([\n \"Сделка и её сумма учитываются в месяце подписания, доход брокера — в месяце оплаты\",\n ]);\n rows.push([\n \"Валовая выручка = входящая комиссия компании (колонка «Комиссия, ₽»), а не стоимость объекта\",\n ]);\n rows.push([\n \"В Росфинмониторинг направляются только ДКП на сумму от 5 000 000 ₽; ДДУ не направляются\",\n ]);\n const csv = \"\" +\n rows.map((r) =>\n r.map((c) => '\"' + String(c == null ? \"\" : c).replace(/\"/g, '\"\"') + '\"')\n .join(\";\")\n ).join(\"\\r\\n\");\n const blob = new Blob([csv], { type: \"text/csv;charset=utf-8;\" });\n const a = document.createElement(\"a\");\n a.href = URL.createObjectURL(blob);\n a.download = \"reestr_\" + TODAY + \".csv\";\n document.body.appendChild(a);\n a.click();\n a.remove();\n toast(\"Реестр выгружен 📥\");\n}\n\nasync function saveManual(id, month, payload) {\n await api(\"/api/manual\", {\n method: \"POST\",\n body: JSON.stringify({ broker_id: id, month, ...payload }),\n });\n await loadBoss();\n}\n/* ---------- ячейка таблицы: тап по числу → правка, ↺ → назад к авторасчёту ---------- */\nfunction cellBox(id, field, val, autoVal, isOv, isMoney, month) {\n const m = month || teamData.curMonth;\n const num = Number(val) || 0;\n const shown = num ? (isMoney ? money(num) : num) : \"—\";\n const auto = Number(autoVal) || 0;\n const autoTxt = isMoney ? money(auto) : auto;\n return `

\n ${shown}\n ${\n isOv\n ? ``\n : \"\"\n }\n

`;\n}\n/* ---------- валовая выручка: ручная сумма СКЛАДЫВАЕТСЯ с комиссией из реестра ---------- */\nfunction grossBox(id, addVal, autoVal, month) {\n const m = month || teamData.curMonth;\n const add = Number(addVal) || 0,\n auto = Number(autoVal) || 0,\n tot = add + auto;\n const hint = add && auto\n ? `вручную ${money(add)} + оплачено ${money(auto)}`\n : add\n ? \"внесено вручную\"\n : auto\n ? \"оплаченные из реестра\"\n : \"\";\n return `

\n ${\n tot ? money(tot) : \"—\"\n }\n ${\n add\n ? ``\n : \"\"\n }\n

\n ${hint ? `

${hint}

` : \"\"}\n

`;\n}\nfunction askResetGross(id, month, add) {\n if (\n !confirm(\n \"Убрать вручную внесённые \" + money(add) +\n \"?\\nОстанется только комиссия из реестра сделок.\",\n )\n ) return;\n resetCell(id, \"gross_add\", month);\n}\nfunction cellEdit(el) {\n const d = el.dataset, wrap = el.parentNode;\n const isMoney = d.money === \"1\", raw = Number(d.raw) || 0;\n wrap.innerHTML = ``;\n const i = wrap.querySelector(\"input\");\n i.focus();\n i.select();\n}\nasync function cellCommit(inp, id, field, month) {\n if (inp.dataset.esc) {\n await refreshBossData();\n return;\n }\n await saveCell(id, field, month, inp.value);\n}\nfunction planCell(id, field, val, isMoney, month) {\n const m = month || teamData.curMonth;\n const num = Number(val) || 0;\n return `${\n num ? (isMoney ? money(num) : num) : \"задать\"\n }`;\n}\nfunction planFact(fact, plan, isMoney) {\n const f = Number(fact) || 0;\n const txt = isMoney ? money(f) : f;\n if (!Number(plan)) return `${txt}`;\n const ok = f >= Number(plan);\n return `${txt} ${\n ok\n ? \"✅\"\n : `

ещё ${\n isMoney ? money(Number(plan) - f) : Number(plan) - f\n }

`\n }`;\n}\nasync function saveCell(id, field, month, raw) {\n const str = String(raw).replace(/\\s/g, \"\");\n if (str === \"\") {\n await resetCell(id, field, month, true);\n return;\n }\n const n = parseInt(str.replace(/\\D/g, \"\"), 10);\n if (!Number.isFinite(n) || n < 0) {\n toast(\"Введите число\");\n await refreshBossData();\n return;\n }\n await api(\"/api/manual\", {\n method: \"POST\",\n body: JSON.stringify({ broker_id: id, month, [field]: n }),\n });\n await refreshBossData();\n toast(\"Сохранено ✓\");\n}\nfunction askReset(id, field, month, autoTxt) {\n if (\n !confirm(\n \"Вернуть автоматический расчёт (\" + autoTxt +\n \")?\\nВаша правка будет удалена.\",\n )\n ) return;\n resetCell(id, field, month);\n}\nasync function resetCell(id, field, month, quiet) {\n await api(\"/api/manual\", {\n method: \"POST\",\n body: JSON.stringify({ broker_id: id, month, reset: [field] }),\n });\n await refreshBossData();\n toast(quiet ? \"Вернули авторасчёт ↺\" : \"Вернули авторасчёт ↺\");\n}\nasync function refreshBossData() {\n const month = bossRetroMonth || (teamData && teamData.curMonth);\n const [team, retro] = await Promise.all([\n api(\"/api/team?date=\" + TODAY),\n bossRetro && month\n ? api(\"/api/retro?month=\" + month).catch(() => bossRetro)\n : Promise.resolve(bossRetro),\n ]);\n teamData = team;\n bossRetro = retro;\n renderBoss();\n}\nasync function editTotal(id, cur) {\n const v = prompt(\n \"Сделок за всё время ДО приложения (новые из реестра прибавляются сами):\",\n cur || \"\",\n );\n if (v === null) return;\n const n = parseInt(String(v).replace(/\\D/g, \"\"), 10);\n if (!Number.isFinite(n) || n < 0 || n > 9999) {\n toast(\"Введите число от 0 до 9999\");\n return;\n }\n await api(\"/api/brokers/\" + id + \"/total\", {\n method: \"POST\",\n body: JSON.stringify({ deals_total: n }),\n });\n toast(\"Сохранено ✓\");\n await loadBoss();\n}\nasync function addBroker() {\n const name = $(\"#nbName\").value.trim(), pin = $(\"#nbPin\").value.trim();\n if (!name) {\n toast(\"Укажите имя брокера\");\n return;\n }\n if (!/^\\d{4,6}$/.test(pin)) {\n toast(\"ПИН — от 4 до 6 цифр\");\n return;\n }\n await api(\"/api/brokers\", {\n method: \"POST\",\n body: JSON.stringify({ name, pin }),\n });\n toast(\"Брокер добавлен ✓\");\n await loadBoss();\n}\nasync function toggleBroker(id, active) {\n await api(\"/api/brokers/\" + id, {\n method: \"POST\",\n body: JSON.stringify({ active }),\n });\n await loadBoss();\n}\nasync function changeManagerPin() {\n const pin = $(\"#mPin\").value.trim();\n if (!/^\\d{4,6}$/.test(pin)) {\n toast(\"ПИН — от 4 до 6 цифр\");\n return;\n }\n await api(\"/api/settings\", {\n method: \"POST\",\n body: JSON.stringify({ manager_pin: pin }),\n });\n PIN = pin;\n localStorage.setItem(\"vd_pin\", PIN);\n toast(\"ПИН руководителя изменён ✓\");\n await loadBoss();\n}\n\n/* ================= EXCEL ================= */\nfunction exportXls() {\n if (!teamData) return;\n const t = teamData;\n const d7 = lastNDates(7);\n const active = t.brokers.filter((b) => Number(b.active) === 1);\n const submittedIds = new Set(t.today.map((r) => Number(r.broker_id)));\n const cianByBroker = {};\n t.cian.forEach((r) => {\n const id = Number(r.broker_id);\n (cianByBroker[id] = cianByBroker[id] || []).push(r);\n });\n Object.values(cianByBroker).forEach((a) =>\n a.sort((x, y) => String(x.date) < String(y.date) ? -1 : 1)\n );\n let rows = [];\n rows.push([\"ОТЧЁТ ПО КОМАНДЕ\"]);\n rows.push([\"Дата\", new Date().toLocaleDateString(\"ru-RU\")]);\n rows.push([]);\n const man = {};\n (t.manual || []).forEach((r) => {\n man[Number(r.broker_id) + \"|\" + String(r.month)] = r;\n });\n rows.push([\n \"Брокер\",\n \"План сдан\",\n \"Дисциплина 7дн %\",\n \"Объектов на Циан (план \" + CIAN_PLAN + \")\",\n \"Наработки мес (кол-во)\",\n \"Наработки мес (сумма)\",\n \"Задатки мес (кол-во)\",\n \"Задатки мес (сумма)\",\n \"Сделки пред. мес\",\n \"Сделки этот мес\",\n \"Процент %\",\n \"Доход мес, ₽\",\n \"Сделок всего в компании\",\n \"Наработки в работе 30дн, ₽\",\n ]);\n let tnc = 0,\n tns = 0,\n tzc = 0,\n tzs = 0,\n tdp = 0,\n tdc = 0,\n tinc = 0,\n tsum = 0,\n tc = 0,\n ttot = 0;\n const d30s = lastNDates(30)[0];\n active.forEach((b) => {\n const id = Number(b.id);\n const bi = t.items.filter((i) => Number(i.broker_id) === id);\n const bi7 = bi.filter((i) => String(i.date) >= d7[0]);\n const disc = bi7.length\n ? Math.round(\n bi7.filter((i) => Number(i.done) === 1).length / bi7.length * 100,\n )\n : \"\";\n const sum = bi.filter((i) => String(i.date) >= d30s).filter((i) => {\n const s = Number(i.stage);\n const d = i.done === null || i.done === undefined ? null : Number(i.done);\n return s === 3 && d !== 0;\n }).reduce((a, i) => a + (Number(i.amount) || 0), 0);\n const cianV = cianNow(id);\n const mCur = monthStats(bi, t.curMonth),\n mPrev = monthStats(bi, t.prevMonth);\n const mc = man[id + \"|\" + t.curMonth] || {},\n mp = man[id + \"|\" + t.prevMonth] || {};\n const dealsCur = eff(mc.deals, 0);\n const dealsPrev = eff(mp.deals, 0);\n const zc = eff(mc.zad_cnt, 0), zs = eff(mc.zad_sum, 0);\n const inc = mc.income === null || mc.income === undefined\n ? \"\"\n : Number(mc.income);\n const dtot = b.deals_total === null || b.deals_total === undefined\n ? \"\"\n : Number(b.deals_total);\n tnc += mCur.nar.cnt;\n tns += mCur.nar.sum;\n tzc += zc;\n tzs += zs;\n tdp += dealsPrev;\n tdc += dealsCur;\n tinc += inc || 0;\n tsum += sum;\n tc += cianV || 0;\n ttot += dtot || 0;\n rows.push([\n String(b.name),\n submittedIds.has(id) ? \"Да\" : \"Нет\",\n disc,\n cianV === null ? \"\" : cianV,\n mCur.nar.cnt,\n mCur.nar.sum,\n zc,\n zs,\n dealsPrev,\n dealsCur,\n pct(dealsPrev),\n inc,\n dtot,\n sum,\n ]);\n });\n rows.push([\n \"ИТОГО\",\n \"\",\n \"\",\n tc,\n tnc,\n tns,\n tzc,\n tzs,\n tdp,\n tdc,\n \"\",\n tinc,\n ttot,\n tsum,\n ]);\n rows.push([]);\n rows.push([\"ВОРОНКА КОМАНДЫ · 30 ДНЕЙ\"]);\n rows.push([\"Этап\", \"Кол-во\", \"Конверсия из предыдущего\"]);\n const sc = stageCounts(t.items.filter((i) => String(i.date) >= d30s));\n STAGES.forEach((s, i) =>\n rows.push([\n s.name,\n sc[i],\n i && sc[i - 1] ? Math.round(sc[i] / sc[i - 1] * 100) + \"%\" : \"—\",\n ])\n );\n rows.push([]);\n rows.push([\"ПЛАНЫ НА СЕГОДНЯ\"]);\n rows.push([\"Брокер\", \"Этап\", \"Действие\", \"Цифра\", \"Статус\", \"Комментарий\"]);\n t.today.forEach((r) => {\n rows.push([\n String(r.name),\n STAGES[Number(r.stage) - 1].name,\n String(r.text),\n String(r.label || \"\"),\n Number(r.done) === 1\n ? \"Выполнено\"\n : (Number(r.done) === 0 ? \"Не выполнено\" : \"—\"),\n String(r.comment || \"\"),\n ]);\n });\n const csv = \"\" +\n rows.map((r) =>\n r.map((c) => '\"' + String(c == null ? \"\" : c).replace(/\"/g, '\"\"') + '\"')\n .join(\";\")\n ).join(\"\\r\\n\");\n const blob = new Blob([csv], { type: \"text/csv;charset=utf-8;\" });\n const a = document.createElement(\"a\");\n a.href = URL.createObjectURL(blob);\n a.download = \"otchet_komanda_\" + TODAY + \".csv\";\n document.body.appendChild(a);\n a.click();\n a.remove();\n toast(\"Файл выгружен — откроется в Excel 📥\");\n}\n\n/* ================= NAV ================= */\nfunction refreshApp() {\n try {\n toast(\"Обновляю…\");\n } catch (e) {}\n const u = new URL(location.href);\n u.searchParams.set(\"v\", Date.now());\n location.replace(u.toString());\n}\nfunction setPane(p) {\n [\"plan\", \"eve\", \"deals\", \"hist\", \"me\"].forEach((x) => {\n $(\"#pane-\" + x).classList.toggle(\"hidden\", x !== p);\n $(\"#nav-\" + x).classList.toggle(\"on\", x === p);\n });\n if (p === \"eve\") renderEve();\n if (p === \"deals\") loadDeals();\n if (p === \"hist\") loadHistory();\n if (p === \"me\") loadMe();\n window.scrollTo(0, 0);\n}\n\n/* ================= INIT ================= */\n$(\"#loginPin\").addEventListener(\"keydown\", (e) => {\n if (e.key === \"Enter\") doLogin();\n});\nwindow.addEventListener(\"focus\", () => {\n if (todayStr() !== TODAY) location.reload();\n});\nthemeInit();\nif (PIN && ROLE) start().catch(() => logout());\nelse $(\"#loginView\").classList.remove(\"hidden\");",[211],"4e3e151d-cd51-4083-b78d-96488f167131","app.js","72640470-8f2d-11f1-a3d9-1607ee4eb77e",149,["D",1787582645179],34,"/* ================= CONST / STATE ================= */\nconst CIAN_PLAN=15;\nconst STAGES=[\n {id:1,name:'Поиск и привлечение',icon:'🔍',c:'var(--s1)'},\n {id:2,name:'Касание клиента',icon:'🤝',c:'var(--s2)'},\n {id:3,name:'Наработки',icon:'⚙️',c:'var(--s3)'},\n {id:4,name:'Задаток / Бронь',icon:'📝',c:'var(--s4)'},\n {id:5,name:'Сделка',icon:'💰',c:'var(--s5)'}\n];\nconst AVA_COLORS=['#6366f1','#0ea5e9','#f59e0b','#ec4899','#10b981','#8b5cf6','#ef4444','#14b8a6'];\nlet PIN=localStorage.getItem('vd_pin')||'';\nlet ROLE=localStorage.getItem('vd_role')||'';\nlet NAME=localStorage.getItem('vd_name')||'';\nlet day={items:[],cian:{morning:null,evening:null},cianLast:null};\nlet numMode={};\nconst $=s=>document.querySelector(s);\nconst days=['воскресенье','понедельник','вторник','среда','четверг','пятница','суббота'];\nconst dayShort=['Вс','Пн','Вт','Ср','Чт','Пт','Сб'];\nfunction todayStr(){const d=new Date();return new Date(d.getTime()-d.getTimezoneOffset()*60000).toISOString().slice(0,10);}\nconst TODAY=todayStr();\nfunction lastNDates(n){const a=[];const base=new Date(TODAY+'T00:00:00Z');for(let i=n-1;i>=0;i--){const d=new Date(base);d.setUTCDate(d.getUTCDate()-i);a.push(d.toISOString().slice(0,10));}return a;}\n/* неразрывные пробелы: сумма никогда не разрывается посреди числа при переносе строки */\nconst fmt=n=>String(n).replace(/\\B(?=(\\d{3})+(?!\\d))/g,' ');\nconst money=n=>fmt(Math.round(Number(n)||0))+' ₽';\nconst esc=s=>String(s==null?'':s).replace(/&/g,'&').replace(//g,'>').replace(/\"/g,'"');\nfunction toast(m){const t=$('#toast');t.textContent=m;t.classList.add('show');setTimeout(()=>t.classList.remove('show'),2200);}\nfunction num(v){return v===null||v===undefined?null:Number(v);}\nfunction pct(n){return n>=4?55:n===3?50:n===2?45:40;}\nfunction monthOf(d){return String(d).slice(0,7);}\nfunction eff(v,fallback){return v===null||v===undefined?fallback:Number(v);}\nfunction monthStats(items,month){\n const inM=items.filter(i=>monthOf(i.date)===month);\n const by=(stg)=>{const a=inM.filter(i=>{const s=Number(i.stage);const d=i.done===null||i.done===undefined?null:Number(i.done);return s===stg&&d!==0;});return {cnt:a.length,sum:a.reduce((x,i)=>x+(Number(i.amount)||0),0)};};\n const deals=inM.filter(i=>Number(i.stage)===5&&Number(i.done)===1).length;\n return {nar:by(3),zad:by(4),deals};\n}\n\n/* ================= API ================= */\nasync function api(path,opts={}){\n // таймаут 12 сек + один повтор для чтения: повисшее соединение больше не вешает приложение\n const isGet=!opts.method||opts.method==='GET';\n for(let t=0;t<2;t++){\n const ctl=new AbortController();\n const tm=setTimeout(()=>ctl.abort(),12000);\n try{\n const r=await fetch(path,{...opts,signal:ctl.signal,cache:'no-store',headers:{'Content-Type':'application/json','x-pin':PIN,...(opts.headers||{})}});\n clearTimeout(tm);\n if(r.status===401){logout();throw new Error('unauthorized');}\n const j=await r.json().catch(()=>({}));\n if(!r.ok){toast(j.error||'Ошибка сервера');throw new Error(j.error||'error');}\n return j;\n }catch(e){\n clearTimeout(tm);\n const network=e&&(e.name==='AbortError'||e.name==='TypeError');\n if(network&&isGet&&t===0)continue; // сеть моргнула — пробуем ещё раз\n if(network)toast('Нет связи с сервером — проверьте интернет и потяните вниз, чтобы обновить');\n throw e;\n }\n }\n}\n\n/* ================= AUTH ================= */\nasync function doLogin(){\n const pin=$('#loginPin').value.trim();\n $('#loginErr').textContent='';\n if(!/^\\d{4,6}$/.test(pin)){$('#loginErr').textContent='ПИН — от 4 до 6 цифр';return;}\n const r=await fetch('/api/login',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({pin})});\n const j=await r.json().catch(()=>({}));\n if(!r.ok){$('#loginErr').textContent=j.error||'Неверный ПИН-код';return;}\n PIN=pin;ROLE=j.role;NAME=j.name||'';\n localStorage.setItem('vd_pin',PIN);localStorage.setItem('vd_role',ROLE);localStorage.setItem('vd_name',NAME);\n start();\n}\nfunction logout(){\n PIN='';ROLE='';NAME='';\n localStorage.removeItem('vd_pin');localStorage.removeItem('vd_role');localStorage.removeItem('vd_name');\n $('#app').classList.add('hidden');\n $('#loginView').classList.remove('hidden');\n $('#loginPin').value='';\n}\n/* ---------- тема: авто по системе + ручной переключатель ---------- */\nfunction themePref(){try{return localStorage.getItem('unlock_theme')||'auto';}catch(e){return 'auto';}}\nfunction themeIsDark(t){\n if(t==='dark')return true;if(t==='light')return false;\n try{return window.matchMedia('(prefers-color-scheme:dark)').matches;}catch(e){return false;}\n}\nfunction applyTheme(t){\n const dark=themeIsDark(t);\n document.documentElement.dataset.theme=dark?'dark':'light';\n const m=document.querySelector('meta[name=theme-color]');if(m)m.content=dark?'#0e0e1a':'#f4f5f9';\n const b=$('#thmBtn');\n if(b){b.textContent=t==='auto'?'🌗':(t==='dark'?'🌙':'☀️');b.title='Тема: '+(t==='auto'?'как в системе':(t==='dark'?'тёмная':'светлая'));}\n}\nfunction cycleTheme(){\n const order=['auto','light','dark'];\n const t=order[(order.indexOf(themePref())+1)%3];\n try{localStorage.setItem('unlock_theme',t);}catch(e){}\n applyTheme(t);\n toast('Тема: '+(t==='auto'?'как в системе':(t==='dark'?'тёмная':'светлая')));\n}\nfunction themeInit(){\n applyTheme(themePref());\n try{window.matchMedia('(prefers-color-scheme:dark)').addEventListener('change',()=>{if(themePref()==='auto')applyTheme('auto');});}catch(e){}\n}\n\nasync function start(){\n themeInit();\n if(!PIN){logout();return;}\n pushInit();\n // роль уже известна с прошлого входа — стартуем загрузку данных, не дожидаясь проверки ПИНа\n const warm=ROLE==='broker'?api('/api/day?date='+TODAY).catch(()=>null)\n :ROLE==='boss'?api('/api/team?date='+TODAY).catch(()=>null):null;\n // перепроверяем роль на сервере (ПИН могли сменить/отключить)\n const r=await fetch('/api/login',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({pin:PIN})});\n const j=await r.json().catch(()=>({}));\n if(!r.ok){logout();return;}\n window.__warm=(j.role===ROLE)?warm:null;\n ROLE=j.role;NAME=j.name||'';\n localStorage.setItem('vd_role',ROLE);localStorage.setItem('vd_name',NAME);\n $('#loginView').classList.add('hidden');\n $('#app').classList.remove('hidden');\n const d=new Date();\n $('#dateStr').textContent=days[d.getDay()]+', '+d.toLocaleDateString('ru-RU',{day:'numeric',month:'long'});\n if(ROLE==='boss'){\n $('#hdrTitle').textContent='Руководитель';\n $('#app').classList.add('wide');\n $('#brokerView').classList.add('hidden');\n $('#bossView').classList.remove('hidden');\n await loadBoss();\n }else{\n $('#hdrTitle').textContent=NAME;\n $('#app').classList.remove('wide');\n $('#bossView').classList.add('hidden');\n $('#brokerView').classList.remove('hidden');\n await loadDay();\n setPane('plan');\n }\n}\n\n/* ================= BROKER: DAY ================= */\nasync function loadDay(){\n const pre=window.__warm; window.__warm=null;\n const got=pre?await pre:null;\n day=got||await api('/api/day?date='+TODAY);\n renderPlan();renderEve();loadDayoff();\n}\nfunction itemsByStage(sid){return day.items.filter(i=>Number(i.stage)===sid);}\nfunction cianMorningVal(){const m=num(day.cian.morning);if(m!==null)return m;return day.cianLast!==null?day.cianLast:0;}\nfunction cianEveVal(){const e=num(day.cian.evening);if(e!==null)return e;return cianMorningVal();}\n\n/* ---- выходной / больничный / отпуск ---- */\nlet myOff=null; // отметка на сегодня\nconst OFF_RU={off:'выходной',sick:'больничный',vac:'отпуск'};\nasync function loadDayoff(){\n try{const r=await api('/api/dayoff?date='+TODAY);myOff=(r.rows||[]).find(x=>String(x.date)===TODAY)||null;}catch(e){myOff=null;}\n keepInputsAndRender();\n}\nfunction dayOffCard(){\n if(myOff)return `

🏖

Сегодня у вас ${OFF_RU[String(myOff.kind)]||'выходной'}План не нужен, напоминания не придут, статистика не пострадает. Отменить

`;\n return `

🏖 Выходной · отпуск · больничный

`;\n}\nasync function dayOffAsk(){\n const t=prompt('Что отметить? Введите цифру:\\n1 — выходной (один день)\\n2 — больничный (период)\\n3 — отпуск (период)','1');\n if(t===null)return;\n const kind=t.trim()==='2'?'sick':t.trim()==='3'?'vac':'off';\n let from,to;\n if(kind==='off'){\n from=to=prompt('Дата выходного (ГГГГ-ММ-ДД):',TODAY);\n if(from===null)return;\n }else{\n from=prompt('С какой даты (ГГГГ-ММ-ДД):',TODAY);if(from===null)return;\n to=prompt('По какую дату (ГГГГ-ММ-ДД):',from||TODAY);if(to===null)return;\n }\n try{\n const r=await api('/api/dayoff',{method:'POST',body:JSON.stringify({kind,from:String(from).trim(),to:String(to).trim()})});\n toast('Отмечено: '+OFF_RU[kind]+' · дней: '+r.days+' ✓');\n loadDayoff();\n }catch(e){}\n}\nasync function dayOffCancel(){\n if(!confirm('Убрать отметку на сегодня и вернуться к работе?'))return;\n try{await api('/api/dayoff/del',{method:'POST',body:JSON.stringify({date:TODAY})});toast('Отметка снята');loadDayoff();}catch(e){}\n}\nfunction renderPlan(){\n let n=day.items.length;\n updCianMorning();\n $('#stages').innerHTML=dayOffCard()+STAGES.map(st=>{\n const items=itemsByStage(st.id);\n const nm=numMode[st.id];\n return `

${st.id}

${st.icon} ${st.name}

${items.length||'—'}

\n ${items.map(it=>`

${esc(it.text)}

${it.label?`

${esc(it.label)}

`:''}

`).join('')||'

Пока пусто — добавьте действие

'}\n

\n \n \n

${nm?'✕ убрать цифру':'＋ 123 добавить количество или сумму'}

\n \n \n

\n \n

`;\n }).join('');\n $('#planCount').textContent=n;\n}\nfunction toggleNum(s){numMode[s]=numMode[s]?null:'qty';keepInputsAndRender();}\nfunction setNum(s,m){numMode[s]=m;keepInputsAndRender();const i=$('#nv-'+s);if(i)i.focus();}\nfunction keepInputsAndRender(){\n const saved={};STAGES.forEach(st=>{const i=$('#in-'+st.id);if(i)saved[st.id]=i.value;});\n renderPlan();\n STAGES.forEach(st=>{const i=$('#in-'+st.id);if(i&&saved[st.id])i.value=saved[st.id];});\n}\nasync function addItem(s){\n const i=$('#in-'+s);if(!i||!i.value.trim())return;\n let label='',amount=0;\n const nm=numMode[s],nv=$('#nv-'+s);\n if(nm&&nv&&nv.value.trim()){\n const v=nv.value.replace(/\\D/g,'');\n if(v){if(nm==='sum'){label=fmt(v)+' ₽';amount=parseInt(v,10);}else{label=v+' шт';}}\n }\n await api('/api/items',{method:'POST',body:JSON.stringify({date:TODAY,stage:s,text:i.value.trim(),label,amount})});\n numMode[s]=null;\n await loadDay();\n}\nasync function delItem(id){\n await api('/api/items/'+id,{method:'DELETE'});\n await loadDay();\n}\nlet cianTimer=null;\n/* число объектов на Циан вводится вручную, без кнопок */\nfunction cianType(field,raw){\n const v=Math.max(0,parseInt(String(raw).replace(/\\D/g,'')||'0',10));\n if(field==='morning'){day.cian.morning=v;cianGapTxt('#cianGap',v);}\n else{day.cian.evening=v;cianGapTxt('#cianEveGap',v);}\n clearTimeout(cianTimer);\n cianTimer=setTimeout(()=>{api('/api/cian',{method:'POST',body:JSON.stringify({date:TODAY,field,value:v})});},500);\n}\nfunction cianGapTxt(sel,v){\n const el=$(sel); if(el)el.textContent=v>=CIAN_PLAN?'план выполнен 💪':'до плана: '+(CIAN_PLAN-v);\n}\nfunction updCianMorning(){\n const v=cianMorningVal(),el=$('#cianN');\n if(el&&document.activeElement!==el)el.value=v;\n cianGapTxt('#cianGap',v);\n}\nfunction updCianEve(){\n const v=cianEveVal(),el=$('#cianEveN');\n if(el&&document.activeElement!==el)el.value=v;\n cianGapTxt('#cianEveGap',v);\n}\n\n/* ================= BROKER: EVENING ================= */\nfunction renderEve(){\n updCianEve();\n const withItems=STAGES.filter(st=>itemsByStage(st.id).length);\n $('#eveStages').innerHTML=withItems.length?withItems.map(st=>`

${st.id}

${st.icon} ${st.name}

\n ${itemsByStage(st.id).map(it=>{\n const done=it.done===null||it.done===undefined?null:Number(it.done);\n return `

${esc(it.text)}${it.label?' · '+esc(it.label)+'':''}

\n \n \n

\n ↻ Перенести на завтра\n

`;}).join('')}\n

`).join('')\n :'

Сначала заполните план на вкладке «План утром»

';\n updEve();\n}\nasync function markItem(id,v){\n const it=day.items.find(x=>Number(x.id)===id);if(!it)return;\n it.done=v;\n renderEve();\n await api('/api/items/'+id+'/mark',{method:'POST',body:JSON.stringify({done:v,comment:it.comment||''})});\n}\nasync function saveComment(id,val){\n const it=day.items.find(x=>Number(x.id)===id);if(!it)return;\n it.comment=val;\n const done=it.done===null||it.done===undefined?null:Number(it.done);\n await api('/api/items/'+id+'/mark',{method:'POST',body:JSON.stringify({done,comment:val})});\n toast('Комментарий сохранён');\n}\nasync function carryItem(id){\n await api('/api/items/'+id+'/carry',{method:'POST',body:JSON.stringify({})});\n toast('Перенесено в план на завтра ↻');\n}\nfunction updEve(){\n const all=day.items.length;\n const done=day.items.filter(i=>Number(i.done)===1).length;\n const p=all?Math.round(done/all*100):0;\n $('#evePct').textContent=p+'%';$('#eveBar').style.width=p+'%';\n}\n\n/* ================= SHARED CHART HELPERS ================= */\nfunction funnelHtml(data,fromFirst){\n const max=Math.max(data[0].v,1);\n return data.map((r,i)=>{\n const conv=i?(data[fromFirst?0:i-1].v?Math.round(r.v/data[fromFirst?0:i-1].v*100)+'%':'—'):(fromFirst?'100%':'');\n return `

${r.n}

${r.v}

${conv}

`;}).join('')+`

${fromFirst?'% — конверсия от этапа «Поиск и привлечение»':'% — конверсия из предыдущего этапа'}

`;\n}\nfunction weekHtml(dates,vals,blue){\n const max=Math.max(...vals,1);\n return '

'+dates.map((d,i)=>{\n const dow=dayShort[new Date(d+'T00:00:00Z').getUTCDay()];\n return `

${vals[i]}

${dow}

`;\n }).join('')+'

';\n}\nfunction stageCounts(items){\n const c=[0,0,0,0,0];\n items.forEach(i=>{const s=Number(i.stage);const d=i.done===null||i.done===undefined?null:Number(i.done);if(s>=1&&s<=5&&d!==0)c[s-1]++;});\n return c;\n}\nfunction cianVal(row){const e=num(row.evening);if(e!==null)return e;return num(row.morning);}\nfunction latestCian(rows){ // rows sorted by date asc\n for(let i=rows.length-1;i>=0;i--){const v=cianVal(rows[i]);if(v!==null)return v;}\n return null;\n}\nfunction cianOnDate(rows,d){\n let v=null;\n for(const r of rows){if(String(r.date)<=d){const x=cianVal(r);if(x!==null)v=x;}else break;}\n return v;\n}\n\n/* ================= ОБХОД КОМАНДЫ (руководитель) ================= */\nlet roundOpen={}, roundTab={}, roundHist={};\nfunction askList(r,plan){\n const q=[];\n if(!plan||!plan.items.length)q.push('Плана на сегодня нет — что в работе и почему не заполнил?');\n else{\n const noMark=plan.items.filter(i=>i.done===null||i.done===undefined).length;\n if(r.yUnmarked)q.push('Вчера остались пункты без отметки ('+r.yUnmarked+') — что из этого закрыл?');\n if(noMark===plan.items.length&&r.hourLate)q.push('День идёт, отметок нет — где сейчас по плану?');\n }\n if(r.cian===null)q.push('Не внёс базу Циан — сколько объектов сейчас размещено?');\n else if(r.cian0&&r.zadC===0)q.push('Наработок '+r.narC+' на '+money(r.narS)+', задатков нет — что тормозит?');\n if(r.narC===0&&r.zadC===0)q.push('Нет ни наработок, ни задатков в этом месяце — с чем работает?');\n if(r.dealsCur===0&&r.zadC>0)q.push('Задатки есть ('+r.zadC+'), сделок нет — какие даты выхода?');\n if(!q.length)q.push('Идёт ровно — спросить, чем помочь, чтобы закрыть больше сделок');\n return q.slice(0,3);\n}\nfunction heatOf(r,plan){\n let h=0;\n if(!plan||!plan.items.length)h+=3;\n if(r.yUnmarked)h+=2;\n if(r.cian===null)h+=2; else if(r.cian<8)h+=2; else if(r.cian0&&r.zadC===0)h+=1;\n return h;\n}\nfunction roundHtml(rows,todayByBroker){\n const t=teamData||{};\n const hour=new Date().getHours();\n const yday=(()=>{const d=new Date(TODAY+'T00:00:00Z');d.setUTCDate(d.getUTCDate()-1);return d.toISOString().slice(0,10);})();\n const list=rows.map(r=>{\n const plan=todayByBroker[r.id]||null;\n const yItems=(t.items||[]).filter(i=>Number(i.broker_id)===r.id&&String(i.date)===yday);\n r.yUnmarked=yItems.filter(i=>i.done===null||i.done===undefined).length;\n r.hourLate=hour>=15;\n return {r,plan,heat:heatOf(r,plan),ask:askList(r,plan)};\n }).sort((a,b)=>b.heat-a.heat||a.r.name.localeCompare(b.r.name));\n const hot=list.filter(x=>x.heat>=4).length;\n return `

Обход команды · сегодня

${hot\n ? `Начните с ${hot===1?'одного':hot===2?'двоих':hot+' человек'} — они выделены красным. Ниже готовые вопросы по каждому.`\n : 'Команда идёт ровно. Пройдитесь по списку — вопросы под каждым уже подготовлены.'}

\n ${list.map(x=>roundCard(x)).join('')}`;\n}\nfunction roundCard(x){\n const r=x.r, plan=x.plan;\n const cls=x.heat>=4?'hot':(x.heat>=2?'warm':'');\n const flag=x.heat>=4?'нужен разбор'\n :(x.heat>=2?'есть вопросы':'в порядке');\n const open=!!roundOpen[r.id];\n const tab=roundTab[r.id]||'plan';\n const ph=tvPhotos[r.id];\n const done=plan?plan.items.filter(i=>Number(i.done)===1).length:0;\n const total=plan?plan.items.length:0;\n return `

\n ${ph?`

`:`

${esc(String(r.name).split(' ').map(y=>y[0]||'').join('').slice(0,2))}

`}\n

${esc(r.name)}

${total?`план: ${total} · закрыто ${done}`:'плана на сегодня нет'} · Циан ${r.cian===null?'—':r.cian+'/'+CIAN_PLAN} · дисц. ${r.disc===null?'—':r.disc+'%'}

\n ${flag}

${open?'▲':'▼'}

\n ${open?`

СПРОСИТЬ СЕГОДНЯ

${x.ask.map(q=>'• '+esc(q)).join('
')}

\n сделки мес: ${r.dealsCur}\n задатки: ${r.zadC}${r.zadS?' · '+money(r.zadS):''}\n наработки: ${r.narC}${r.narS?' · '+money(r.narS):''}\n доход: ${r.income===null?'—':money(r.income)}\n ${r.yUnmarked?`вчера без отметки: ${r.yUnmarked}`:''}\n

\n \n \n

\n ${tab==='plan'?planListHtml(plan):histListHtml(r.id)}\n

`:''}\n

`;\n}\nfunction planListHtml(plan){\n if(!plan||!plan.items.length)return '

План на сегодня не заполнен.

';\n return plan.items.map(it=>{\n const st=STAGES[Number(it.stage)-1];\n const d=it.done===null||it.done===undefined?null:Number(it.done);\n return `

${d===1?'✅':d===0?'❌':st.icon}

${esc(it.text)}${it.label?' · '+esc(it.label)+'':''}

\n ${it.comment?`

💬 ${esc(it.comment)}

`:''}

`;\n }).join('');\n}\nfunction histListHtml(id){\n const h=roundHist[id];\n if(!h)return '

Загружаю историю…

';\n if(!h.days.length)return '

В этом месяце записей нет.

';\n return `

Выполнено за месяц: ${h.pct}% · задач ${h.total} · ✓ ${h.done} · ✕ ${h.failed}

\n ${h.days.slice(0,12).map(d=>`

${d.label}

✓${d.done} ${d.failed?`✕${d.failed}`:''} ${d.none?`—${d.none}`:''}

`).join('')}\n ${h.topFail.length?`

Чаще срывается: ${h.topFail.map(f=>esc(f[0])+' ('+f[1]+')').join(', ')}

`:''}`;\n}\nfunction roundToggle(id){\n roundOpen[id]=!roundOpen[id];\n renderBoss();\n if(roundOpen[id]&&(roundTab[id]||'plan')==='hist')loadBrokerHist(id);\n}\nfunction roundSetTab(id,tab,ev){\n if(ev&&ev.stopPropagation)ev.stopPropagation();\n roundTab[id]=tab; renderBoss();\n if(tab==='hist')loadBrokerHist(id);\n}\nasync function loadBrokerHist(id){\n if(roundHist[id])return;\n try{\n const m=monthOf(TODAY);\n const h=await api('/api/history?month='+m+'&broker_id='+id);\n const items=h.items||[];\n const byDate={};\n items.forEach(i=>{(byDate[String(i.date)]=byDate[String(i.date)]||[]).push(i);});\n const days=Object.keys(byDate).sort().reverse().map(d=>{\n const arr=byDate[d];\n const done=arr.filter(i=>Number(i.done)===1).length;\n const failed=arr.filter(i=>Number(i.done)===0).length;\n const dt=new Date(d+'T00:00:00Z');\n return {label:dt.getUTCDate()+' '+dayShort[dt.getUTCDay()],done,failed,none:arr.length-done-failed,pct:arr.length?Math.round(done/arr.length*100):0};\n });\n const total=items.length;\n const done=items.filter(i=>Number(i.done)===1).length;\n const failed=items.filter(i=>Number(i.done)===0).length;\n const fm={};items.filter(i=>Number(i.done)===0).forEach(i=>{const k=String(i.text).trim().toLowerCase();fm[k]=(fm[k]||0)+1;});\n roundHist[id]={days,total,done,failed,pct:total?Math.round(done/total*100):0,\n topFail:Object.entries(fm).sort((a,b)=>b[1]-a[1]).slice(0,3)};\n renderBoss();\n }catch(e){}\n}\n\n/* ================= ТАБЛО ДЛЯ ТЕЛЕВИЗОРА ================= */\nlet tvToken=null, tvPhotos={}, pushSubs=[];\nfunction tvCardHtml(){\n const t=teamData||{};\n const list=(t.brokers||[]).filter(b=>Number(b.active));\n const url=tvToken?location.origin+'/tv?t='+tvToken:'';\n return `

Табло для телевизора

Открой эту ссылку на телевизоре — большое табло с лидером месяца. Обновляется само каждую минуту, ПИН не нужен.

\n \n \n \n

Фото брокеров на табло

\n ${list.length?list.map(b=>`

\n ${tvPhotos[b.id]?`

`:`

${esc(String(b.name).split(' ').map(x=>x[0]||'').join('').slice(0,2))}

`}\n

${esc(b.name)}

\n ${tvPhotos[b.id]?'Заменить':'Загрузить'}\n ${tvPhotos[b.id]?``:''}\n

`).join(''):'

Сначала добавьте брокеров ниже

'}\n

`;\n}\nfunction copyTv(){\n const i=$('#tvUrl'); if(!i)return;\n i.select(); i.setSelectionRange(0,99999);\n (navigator.clipboard?navigator.clipboard.writeText(i.value):Promise.reject())\n .then(()=>toast('Ссылка скопирована ✓'))\n .catch(()=>{try{document.execCommand('copy');toast('Ссылка скопирована ✓');}catch(e){toast('Скопируйте ссылку вручную');}});\n}\nfunction resizePhoto(file,side){\n return new Promise((res,rej)=>{\n const r=new FileReader();\n r.onload=()=>{\n const img=new Image();\n img.onload=()=>{\n const s=Math.min(img.width,img.height);\n const c=document.createElement('canvas'); c.width=side; c.height=side;\n const x=c.getContext('2d');\n x.drawImage(img,(img.width-s)/2,(img.height-s)/2,s,s,0,0,side,side);\n res(c.toDataURL('image/jpeg',0.82));\n };\n img.onerror=rej; img.src=r.result;\n };\n r.onerror=rej; r.readAsDataURL(file);\n });\n}\nasync function uploadPhoto(id,input){\n const f=input.files&&input.files[0]; if(!f)return;\n try{\n toast('Загружаю фото…');\n const photo=await resizePhoto(f,320);\n await api('/api/brokers/'+id+'/photo',{method:'POST',body:JSON.stringify({photo})});\n toast('Фото сохранено ✓');\n await loadBoss();\n }catch(e){toast('Не получилось загрузить фото');}\n}\nasync function delPhoto(id){\n await api('/api/brokers/'+id+'/photo',{method:'POST',body:JSON.stringify({photo:null})});\n toast('Фото убрано');\n await loadBoss();\n}\n\n/* ================= BROKER: HISTORY ================= */\nlet histMonth=monthOf(TODAY);\nlet histData=null;\nlet histOpen={};\nconst YESTERDAY=(()=>{const d=new Date(TODAY+'T00:00:00Z');d.setUTCDate(d.getUTCDate()-1);return d.toISOString().slice(0,10);})();\nconst MONTHS=['январь','февраль','март','апрель','май','июнь','июль','август','сентябрь','октябрь','ноябрь','декабрь'];\nfunction monthTitle(m){const [y,mm]=m.split('-');return MONTHS[Number(mm)-1]+' '+y;}\nfunction shiftMonth(m,n){const d=new Date(m+'-01T00:00:00Z');d.setUTCMonth(d.getUTCMonth()+n);return d.toISOString().slice(0,7);}\nfunction canEdit(d){return d===TODAY||d===YESTERDAY;}\nfunction dateLabel(d){\n const dt=new Date(d+'T00:00:00Z');\n return {n:dt.getUTCDate(),w:dayShort[dt.getUTCDay()]};\n}\nasync function loadHistory(){\n $('#histContent').innerHTML='

Загружаю…

';\n histData=await api('/api/history?month='+histMonth);\n renderHistory();\n}\nfunction renderHistory(){\n const h=histData;\n const items=h.items||[];\n const byDate={};\n items.forEach(i=>{(byDate[String(i.date)]=byDate[String(i.date)]||[]).push(i);});\n const cianBy={};\n (h.cian||[]).forEach(c=>{cianBy[String(c.date)]=c;});\n const dates=Object.keys(byDate).sort().reverse();\n const total=items.length;\n const done=items.filter(i=>Number(i.done)===1).length;\n const failed=items.filter(i=>Number(i.done)===0).length;\n const skipped=items.filter(i=>i.done===null||i.done===undefined).length;\n const pctDone=total?Math.round(done/total*100):0;\n const isCur=histMonth===monthOf(TODAY);\n const minMonth=shiftMonth(monthOf(TODAY),-5);\n // что чаще всего не закрывалось\n const failMap={};\n items.filter(i=>Number(i.done)===0).forEach(i=>{const k=String(i.text).trim().toLowerCase();failMap[k]=(failMap[k]||0)+1;});\n const topFail=Object.entries(failMap).sort((a,b)=>b[1]-a[1]).slice(0,3);\n\n $('#histContent').innerHTML=`\n

\n \n

${monthTitle(histMonth)}

\n \n

=80?'var(--ok)':pctDone>=60?'#f59e0b':'var(--no)'}\">${pctDone}%

Выполнено за месяц

\n задач: ${total}\n ✓ ${done}\n ✕ ${failed}\n ${skipped?`без отметки: ${skipped}`:''}\n

\n ${topFail.length?`

🔁

Чаще всего не закрывалось${topFail.map(f=>esc(f[0])+' — '+f[1]+' раз(а)').join('
')}

`:''}\n ${dates.length?dates.map(d=>histDayHtml(d,byDate[d],cianBy[d])).join(''):\n '

За этот месяц записей нет.
Планы, которые вы заполняете каждый день, появятся здесь.

'}\n

Отметки и комментарии можно менять за сегодня и вчера. Более ранние дни — только просмотр.

\n `;\n}\nfunction histDayHtml(d,items,ci){\n const lbl=dateLabel(d);\n const done=items.filter(i=>Number(i.done)===1).length;\n const failed=items.filter(i=>Number(i.done)===0).length;\n const none=items.length-done-failed;\n const p=items.length?Math.round(done/items.length*100):0;\n const open=!!histOpen[d];\n const edit=canEdit(d);\n const cianV=ci?(ci.evening!==null&&ci.evening!==undefined?ci.evening:(ci.morning!==null&&ci.morning!==undefined?ci.morning:null)):null;\n return `

${lbl.n}${lbl.w}

✓ ${done}${failed?`✕ ${failed}`:''}${none?`— ${none}`:''}\n ${cianV!==null?`· Циан ${cianV}`:''}

${open?'▲':'▼'}

\n ${open?`

\n ${items.map(it=>histItemHtml(it,edit)).join('')}\n ${edit?'':'

🔒 Этот день закрыт — правки доступны только за сегодня и вчера

'}\n

`:''}\n

`;\n}\nfunction histItemHtml(it,edit){\n const st=STAGES[Number(it.stage)-1];\n const done=it.done===null||it.done===undefined?null:Number(it.done);\n return `

${st.icon} ${esc(it.text)}${it.label?' · '+esc(it.label)+'':''}

\n ${edit?`

\n \n \n

`:`

${done===1?'✅':done===0?'❌':'—'}

`}\n

\n ${edit?`

`\n :(it.comment?`

💬 ${esc(it.comment)}

`:'')}\n

`;\n}\nfunction histShift(n){\n const m=shiftMonth(histMonth,n);\n if(m>monthOf(TODAY))return;\n histMonth=m;histOpen={};loadHistory();\n}\nfunction histToggle(d){histOpen[d]=!histOpen[d];renderHistory();}\nasync function histMark(id,v){\n const it=(histData.items||[]).find(x=>Number(x.id)===id);if(!it)return;\n const prev=it.done;\n it.done=v;renderHistory();\n try{\n await api('/api/items/'+id+'/mark',{method:'POST',body:JSON.stringify({done:v,comment:it.comment||''})});\n const cur=day.items.find(x=>Number(x.id)===id);\n if(cur){cur.done=v;updEve();}\n }catch(e){it.done=prev;renderHistory();}\n}\nasync function histComment(id,val){\n const it=(histData.items||[]).find(x=>Number(x.id)===id);if(!it)return;\n it.comment=val;\n const done=it.done===null||it.done===undefined?null:Number(it.done);\n await api('/api/items/'+id+'/mark',{method:'POST',body:JSON.stringify({done,comment:val})});\n toast('Сохранено ✓');\n}\n\n/* ================= BROKER: СДЕЛКИ (задатки и ДКП) ================= */\nlet myDeals={zadatki:[],dkp:[]};\nasync function loadDeals(){\n try{\n const [z,d]=await Promise.all([api('/api/zadatki'),api('/api/dkp')]);\n myDeals={zadatki:z.rows||[],dkp:d.rows||[]};\n }catch(e){}\n renderDeals();\n}\nfunction stChip(s){\n const m={pending:['⏳ На одобрении','st-pending'],approved:['✅ Зафиксирован','st-approved'],rejected:['✕ Отклонён','st-rejected'],annulled:['⛔ Развален','st-rejected']};\n const x=m[s]||m.pending;\n return `${x[0]}`;\n}\n/* развал задатка: брокер указывает дату и причину, руководитель согласует */\nasync function zadCancelReq(id){\n const date=prompt('Дата развала (ГГГГ-ММ-ДД):',TODAY);if(date===null)return;\n const reason=prompt('Причина развала:');if(reason===null)return;\n if(!String(reason).trim()){toast('Укажите причину развала');return;}\n try{\n await api('/api/zadatki/'+id+'/cancelreq',{method:'POST',body:JSON.stringify({date:String(date).trim(),reason:String(reason).trim()})});\n toast('Запрос на развал отправлен руководителю');\n await loadDeals();\n }catch(e){}\n}\n/* суммы вводятся с разделением разрядов: 30 000 000 */\nfunction fmtMoney(el){\n const d=String(el.value).replace(/\\D/g,'').slice(0,15);\n el.value=d?Number(d).toLocaleString('ru-RU').replace(/[  ]/g,' '):'';\n}\nfunction numOf(id){return parseInt(String(($('#'+id)||{}).value||'').replace(/\\D/g,''),10)||0;}\nfunction pctOf(id){return parseFloat(String(($('#'+id)||{}).value||'').replace(',','.'))||0;}\nfunction renderDeals(){\n const dz=myDeals.zadatki,dd=myDeals.dkp;\n $('#dealsContent').innerHTML=`\n

📝 Зафиксировать задаток / бронь

Уходит руководителю на одобрение, после — попадает в таблицу и на табло

\n \n \n \n

\n \n

\n \n \n

\n \n

Сумма комиссии: —

\n \n 📎 Договор задатка / аванса / чек брони\n \n \n

\n ${dz.length?`

Мои задатки и брони

\n ${dz.map(z=>`

${esc(z.client||z.buyer)}${z.kind==='bron'?' · 🏗 '+esc(z.complex||''):''} · CRM ${esc(z.crm_id)}\n

${money(Number(z.deal_sum))} · комиссия ${money(Number(z.comm_sum))}${z.broker_sum?` · вам ${Number(z.broker_pct)}% = ${money(Number(z.broker_sum))}`:''} · ${esc(z.deal_date)}

\n ${Number(z.cancel_req)?`

⛔ Развал на согласовании у руководителя (${esc(z.cancel_date||'')})

`:''}

\n ${stChip(String(z.status))}\n ${String(z.status)==='approved'&&!Number(z.cancel_req)?``:''}

`).join('')}\n

«Развалить» — если сделка сорвалась: укажите дату и причину, после подтверждения руководителем задаток будет аннулирован и не испортит статистику.

`:''}\n\n

📄 Сделка · загрузить документ

В день сделки. Ваш процент зафиксируется по месяцу сделки — даже если деньги придут позже

\n \n \n

\n \n

Дата агентского договора · формат

\n \n \n

\n \n Был контрагент\n \n \n

\n \n

Комиссия: — · ваш % подставится по месяцу сделки (НДС 5% учитывается)

Дата сделки — сделка попадёт в месяц этой даты, даже если вы вносите её позже

\n \n 📎 Файл ДКП / ДДУ (PDF, Word или фото)\n \n \n

\n ${dd.length?`

Мои сделки

\n ${dd.map(d=>`

${d.sector==='new'?'🏗 '+esc(d.complex||'Новостройка'):esc(d.side||'')} · CRM ${esc(d.crm_id)}\n

${money(Number(d.deal_sum))}${d.broker_sum?` · вам ${Number(d.broker_pct)}% = ${money(Number(d.broker_sum))}`:''} · ${esc(d.deal_date)}${Number(d.paid)?' · 💸 оплачено '+esc(d.paid_at||''):''}

\n ${stChip(String(d.status||'approved'))}

`).join('')}

`:''}\n `;\n zCalc();dCalc();\n}\nfunction zKindSw(){\n const bron=$('#zKind').value==='bron';\n $('#zSec').style.display=bron?'none':'block';\n $('#zNew').style.display=bron?'block':'none';\n zCalc();\n}\nfunction dSectorSw(){\n const nw=$('#dSector').value==='new';\n $('#dSec').style.display=nw?'none':'block';\n $('#dNew').style.display=nw?'block':'none';\n if(nw)dDocTypeSw();\n}\n/* на первичке сделка может быть по ДДУ или по ДКП — от этого зависит Росфинмониторинг */\nfunction dDocTypeSw(){\n const el=$('#dDocType'); if(!el)return;\n const dkp=el.value==='dkp';\n const n=$('#dDduNum'), l=$('#dDduDateL');\n if(n)n.placeholder=dkp?'№ ДКП':'№ ДДУ';\n if(l)l.textContent=dkp?'Дата ДКП':'Дата ДДУ';\n}\nfunction zCalc(){\n const el=$('#zComm'); if(!el)return;\n if(($('#zKind')||{}).value==='bron'){\n const s=numOf('zSumN'),p=pctOf('zPctN');\n const ci=s>0&&p>0?Math.round(s*p/100):0;\n el.textContent=ci>0?('Комиссия застройщика: '+money(ci)+' · вам ≈ '+money(Math.round(ci/1.05*0.4))+'–'+money(Math.round(ci/1.05*0.55))+' (по вашему %)'):'Комиссия застройщика: —';\n return;\n }\n const s=numOf('zSum'),p=pctOf('zPct');\n el.textContent='Сумма комиссии: '+(s>0&&p>0?money(Math.round(s*p/100)):'—');\n}\nfunction dCalc(){\n const el=$('#dComm'); if(!el)return;\n const nw=($('#dSector')||{}).value==='new';\n const s=numOf(nw?'dSumN':'dSum'),p=pctOf(nw?'dPctN':'dPct');\n if(!(s>0&&p>0)){el.textContent='Комиссия: — · ваш % подставится по месяцу сделки (НДС 5% учитывается)';return;}\n const ci=Math.round(s*p/100);\n let base=ci/1.05;\n let kaTxt='';\n if(!nw&&($('#dKa')||{}).checked){\n const kp=pctOf('dKaPct');\n if(kp>0){\n // контрагенту — процент от стоимости объекта, НДС снимается отдельно\n const kaSum=Math.round(s*kp/100/1.05);\n base=base-kaSum;\n kaTxt=' − контрагенту '+money(kaSum);\n }\n }\n if(base<=0){el.textContent='Проверьте проценты: контрагенту уходит больше нашей комиссии';return;}\n el.textContent='Комиссия: '+money(ci)+kaTxt+' · вам ≈ '+money(Math.round(base*0.4))+'–'+money(Math.round(base*0.55))+' (по вашему %)';\n}\nfunction fileLabel(k){\n const f=$('#'+k+'File').files[0];\n if(f){$('#'+k+'FileN').textContent=f.name;$('#'+k+'FileL').classList.add('hasfile');}\n}\nfunction readDocFile(input){\n return new Promise((res,rej)=>{\n const f=input.files[0];\n if(!f){res(null);return;}\n if(/^image\\//.test(f.type)){\n // фото документа сжимаем, чтобы не занимать хранилище\n const r=new FileReader();\n r.onload=()=>{\n const img=new Image();\n img.onload=()=>{\n const MAX=1600;\n const k=Math.min(1,MAX/Math.max(img.width,img.height));\n const c=document.createElement('canvas');\n c.width=Math.round(img.width*k);c.height=Math.round(img.height*k);\n c.getContext('2d').drawImage(img,0,0,c.width,c.height);\n res({doc:c.toDataURL('image/jpeg',0.85),name:f.name.replace(/\\.[^.]+$/,'')+'.jpg'});\n };\n img.onerror=rej;img.src=r.result;\n };\n r.onerror=rej;r.readAsDataURL(f);\n return;\n }\n if(f.size>3200000){rej(new Error('Файл до 3 МБ. Сфотографируйте документ или сожмите PDF'));return;}\n const r=new FileReader();\n r.onload=()=>res({doc:r.result,name:f.name});\n r.onerror=rej;r.readAsDataURL(f);\n });\n}\nasync function sendZadatok(){\n const kind=$('#zKind').value;\n const crm=$('#zCrm').value.trim(),client=$('#zClient').value.trim();\n const date=$('#zDate').value;\n if(!crm){toast('Укажите № заявки в CRM');return;}\n if(!client){toast('Укажите фамилию клиента');return;}\n if(!date){toast('Укажите дату');return;}\n const p={kind,crm_id:crm,client,deal_date:date};\n if(kind==='zadatok'){\n p.buyer=$('#zBuyer').value.trim();\n p.deal_sum=parseInt(String($('#zSum').value).replace(/\\D/g,''),10);\n p.comm_pct=parseFloat(String($('#zPct').value).replace(',','.'));\n if(!p.buyer){toast('Укажите фамилию покупателя');return;}\n if(!(p.deal_sum>0)){toast('Укажите сумму сделки');return;}\n if(!(p.comm_pct>0)){toast('Укажите процент комиссии');return;}\n }else{\n p.developer=$('#zDev').value.trim();p.complex=$('#zComplex').value.trim();p.channel=$('#zChannel').value;\n p.deal_sum=numOf('zSumN');\n p.comm_pct=pctOf('zPctN');\n if(!p.developer){toast('Укажите застройщика');return;}\n if(!p.complex){toast('Укажите ЖК');return;}\n if(!p.channel){toast('Выберите канал');return;}\n if(!(p.deal_sum>0)){toast('Укажите сумму сделки');return;}\n if(!(p.comm_pct>0)){toast('Укажите % комиссии застройщика');return;}\n }\n let file;\n try{file=await readDocFile($('#zFile'));}catch(e){toast(e.message||'Не удалось прочитать файл');return;}\n if(!file){toast('Приложите договор или чек брони');return;}\n p.doc=file.doc;p.doc_name=file.name;\n $('#zBtn').disabled=true;$('#zBtn').textContent='Отправляю…';\n try{\n await api('/api/zadatki',{method:'POST',body:JSON.stringify(p)});\n toast(kind==='bron'?'Бронь отправлена на одобрение ✓':'Задаток отправлен на одобрение ✓');\n await loadDeals();\n }catch(e){$('#zBtn').disabled=false;$('#zBtn').textContent='Отправить на одобрение';}\n}\nasync function sendDkp(){\n const sector=$('#dSector').value;\n const crm=$('#dCrm').value.trim(),date=$('#dDate').value;\n if(!crm){toast('Укажите № заявки в CRM');return;}\n if(!date){toast('Укажите дату сделки');return;}\n const p={sector,crm_id:crm,deal_date:date};\n if(sector==='secondary'){\n p.side=$('#dSide').value;p.person=$('#dPerson').value;\n p.client=$('#dClientS').value.trim();\n p.counter=$('#dCounter').value.trim();\n p.deal_sum=numOf('dSum');\n p.comm_pct=pctOf('dPct');\n p.agn_num=$('#dAgnNum').value.trim();p.agn_date=$('#dAgnDate').value;p.agn_sign=$('#dAgnSign').value;\n if(!p.client){toast('Укажите фамилию клиента');return;}\n if(!p.side){toast('Выберите: покупатель или продавец');return;}\n if(!p.person){toast('Выберите: физлицо или юрлицо');return;}\n if(!(p.deal_sum>0)){toast('Укажите сумму сделки');return;}\n if(!(p.comm_pct>0)){toast('Укажите % входящей комиссии');return;}\n if(!p.agn_num){toast('Укажите № агентского договора');return;}\n if(!p.agn_date){toast('Укажите дату агентского договора');return;}\n if(!p.agn_sign){toast('Выберите формат: онлайн или офлайн');return;}\n if($('#dKa').checked){\n p.ka=1;p.ka_pct=pctOf('dKaPct');\n if(!(p.ka_pct>0)){toast('Укажите процент контрагента');return;}\n }\n }else{\n p.client=$('#dClient').value.trim();p.developer=$('#dDev').value.trim();\n p.complex=$('#dComplex').value.trim();p.channel=$('#dChannel').value;\n p.deal_sum=numOf('dSumN');\n p.comm_pct=pctOf('dPctN');\n p.doc_type=($('#dDocType')||{}).value==='dkp'?'dkp':'ddu';\n p.ddu_num=$('#dDduNum').value.trim();p.ddu_date=$('#dDduDate').value;\n const dn=p.doc_type==='dkp'?'ДКП':'ДДУ';\n if(!p.client){toast('Укажите фамилию клиента');return;}\n if(!p.developer){toast('Укажите застройщика');return;}\n if(!p.complex){toast('Укажите ЖК');return;}\n if(!p.channel){toast('Выберите канал');return;}\n if(!(p.deal_sum>0)){toast('Укажите сумму сделки');return;}\n if(!(p.comm_pct>0)){toast('Укажите % комиссии застройщика');return;}\n if(!p.ddu_num){toast('Укажите № '+dn);return;}\n if(!p.ddu_date){toast('Укажите дату '+dn);return;}\n }\n let file;\n try{file=await readDocFile($('#dFile'));}catch(e){toast(e.message||'Не удалось прочитать файл');return;}\n if(!file){toast('Приложите файл документа');return;}\n p.doc=file.doc;p.doc_name=file.name;\n $('#dBtn').disabled=true;$('#dBtn').textContent='Отправляю…';\n try{\n const r=await api('/api/dkp',{method:'POST',body:JSON.stringify(p)});\n const back=r.month&&r.month

${head}
\n На iPhone уведомления включаются только из приложения на экране «Домой»:\n

1. Нажмите Поделиться — квадрат со стрелкой внизу Safari
\n 2. Выберите На экран «Домой»
\n 3. Откройте приложение с иконки и нажмите здесь Включить

`;\n }\n if(!pushSupported()){\n return `

${head}
Этот браузер не умеет присылать уведомления — откройте приложение в Chrome или Safari

`;\n }\n const on=Notification.permission==='granted'&&window.__pushOn;\n const blocked=Notification.permission==='denied';\n const status=blocked\n ? 'Уведомления запрещены в настройках телефона — разрешите их для этого приложения'\n : (on?'Включены на этом устройстве':'Утром — заполнить план, вечером — отметить итоги');\n return `

${head}
${status}

\n ${blocked?'':``}\n ${on?``:''}\n

приложение с экрана «Домой»: ${standalone?'да':'нет'} · разрешение: ${Notification.permission} · подписка: ${window.__pushOn?'есть':'нет'}

`;\n}\nfunction pushTeamHtml(){\n const t=teamData||{};\n const list=(t.brokers||[]).filter(b=>Number(b.active));\n if(!list.length)return '';\n const map={};(pushSubs||[]).forEach(x=>{map[x.broker_id]=x.devices;});\n const off=list.filter(b=>!map[b.id]);\n return `

Кому приходят напоминания

\n ${list.map(b=>`

${esc(b.name)}

${map[b.id]?'включены · устройств: '+map[b.id]:'не включены'}

`).join('')}\n ${off.length?`

\n Не включили: ${off.map(b=>esc(String(b.name).split(' ')[0])).join(', ')}.
\n На iPhone нужно один раз добавить приложение на экран «Домой» (Поделиться → «На экран Домой»), открыть его с иконки и нажать «Включить» во вкладке «Динамика».

`\n :'

Уведомления включены у всей команды ✓

'}\n

`;\n}\nasync function pushInit(){\n if(!pushSupported())return;\n try{\n const reg=await navigator.serviceWorker.register('/sw.js');\n await navigator.serviceWorker.ready;\n window.__reg=reg;\n const sub=await reg.pushManager.getSubscription();\n window.__pushOn=!!sub;\n // ключ грузим заранее: Safari разрешает подписку только внутри касания, без ожиданий\n try{window.__vapid=(await api('/api/push/key')).key;}catch(e){}\n }catch(e){window.__pushOn=false;}\n}\nfunction urlB64ToUint8(b64){\n const pad='='.repeat((4-b64.length%4)%4);\n const raw=atob((b64+pad).replace(/-/g,'+').replace(/_/g,'/'));\n return Uint8Array.from([...raw].map(c=>c.charCodeAt(0)));\n}\nasync function pushOn(){\n try{\n if(!pushSupported()){toast('Этот браузер не умеет уведомления');return;}\n // шаг 1: разрешение. iOS требует отдельного касания для самой подписки\n if(Notification.permission==='default'){\n const perm=await Notification.requestPermission();\n if(perm!=='granted'){toast('Разрешите уведомления, чтобы получать напоминания');return;}\n toast('Разрешение получено — нажмите «Включить» ещё раз');\n if(ROLE==='broker'){loadMe();renderPlan();}else loadBoss();\n return;\n }\n if(Notification.permission==='denied'){toast('Уведомления запрещены в настройках телефона');return;}\n // шаг 2: подписка — всё готово заранее, ждать нечего\n const reg=window.__reg||await navigator.serviceWorker.getRegistration();\n if(!reg){toast('Откройте приложение с экрана «Домой» и попробуйте снова');return;}\n const key=window.__vapid||(await api('/api/push/key')).key;\n const want=urlB64ToUint8(key);\n let sub=await reg.pushManager.getSubscription();\n // если старая подписка сделана под другим ключом сервера — пересоздаём, иначе пуши не доходят\n if(sub&&sub.options&&sub.options.applicationServerKey){\n const cur=new Uint8Array(sub.options.applicationServerKey);\n const same=cur.length===want.length&&cur.every((v,i)=>v===want[i]);\n if(!same){try{await sub.unsubscribe();}catch(e){}sub=null;}\n }\n if(!sub)sub=await reg.pushManager.subscribe({userVisibleOnly:true,applicationServerKey:want});\n await api('/api/push/subscribe',{method:'POST',body:JSON.stringify({subscription:sub.toJSON()})});\n window.__pushOn=true;\n toast('Напоминания включены 🔔');\n if(ROLE==='broker'){loadMe();renderPlan();}else loadBoss();\n }catch(e){\n const m=(e&&e.message)?e.message:'ошибка браузера';\n if(isIOS&&!standalone)toast('Откройте приложение с экрана «Домой»');\n else toast('Не получилось включить: '+m);\n }\n}\nasync function pushTest(){\n try{\n const r=await api('/api/push/test',{method:'POST'});\n if(!r.devices){toast('Подписок нет — нажмите «Включить» ещё раз');return;}\n if(r.error==='no-vapid-key'){toast('На сервере нет VAPID-ключа — сообщите руководителю');return;}\n if(r.error){toast('Сервис уведомлений недоступен, попробуйте позже');return;}\n const ok=(r.results||[]).filter(x=>x.ok).length;\n const bad=(r.results||[]).filter(x=>!x.ok);\n if(ok&&!bad.length)toast('Отправлено на '+ok+' устр. — проверьте шторку 🔔');\n else if(ok)toast('Дошло: '+ok+', ошибок: '+bad.length+'. Старые подписки удалены — нажмите «Включить»');\n else toast('Не дошло (код '+((bad[0]&&bad[0].code)||'?')+'). Выключите и включите уведомления заново');\n }catch(e){}\n}\nasync function pushOff(){\n try{\n const reg=await navigator.serviceWorker.getRegistration();\n const sub=reg&&await reg.pushManager.getSubscription();\n if(sub){await api('/api/push/unsubscribe',{method:'POST',body:JSON.stringify({endpoint:sub.endpoint})});await sub.unsubscribe();}\n window.__pushOn=false;\n toast('Напоминания выключены');\n if(ROLE==='broker')loadMe();else loadBoss();\n }catch(e){toast('Не получилось выключить');}\n}\n\n/* ================= BROKER: DYNAMICS ================= */\n/* прогресс к личному плану месяца */\nfunction planHtml(plan,fact){\n if(!plan.deals&&!plan.sum&&!plan.zad)return '';\n const bar=(t,f,p,fmtv)=>{\n if(!p)return '';\n const k=Math.min(100,Math.round(f/p*100));\n const left=Math.max(0,p-f);\n return `

${t}${fmtv(f)} из ${fmtv(p)}${left?' · осталось '+fmtv(left):' · выполнено 🎉'}

=100?'var(--ok)':'var(--acc)'}\">

${k}%

`;\n };\n return `

🎯 Мой план на месяц

\n ${bar('Сделки',fact.deals,plan.deals,v=>String(v))}\n ${bar('Валовая',fact.sum,plan.sum,v=>money(v))}\n ${bar('Задатки',fact.zad,plan.zad,v=>String(v))}\n

`;\n}\nasync function loadMe(){\n const [st,net]=await Promise.all([\n api('/api/mystats?date='+TODAY),\n api('/api/netincome').catch(()=>({rows:[]})),\n ]);\n const netRows=net.rows||[];\n const items=st.items;\n const d7=lastNDates(7);\n const d30start=lastNDates(30)[0];\n const items30=items.filter(i=>String(i.date)>=d30start);\n const in7=items.filter(i=>String(i.date)>=d7[0]);\n const disc7=in7.length?Math.round(in7.filter(i=>Number(i.done)===1).length/in7.length*100):null;\n const inWork=items30.filter(i=>{const s=Number(i.stage);const d=i.done===null||i.done===undefined?null:Number(i.done);return s===3&&d!==0;}).reduce((a,i)=>a+(Number(i.amount)||0),0);\n const cianRows=st.cian;\n const base=latestCian(cianRows);\n const sc=stageCounts(items30);\n const fnData=STAGES.map((s,i)=>({n:s.name,v:sc[i]}));\n const discSeries=d7.map(d=>{const di=items.filter(i=>String(i.date)===d);return di.length?Math.round(di.filter(i=>Number(i.done)===1).length/di.length*100):0;});\n const cianSeries=d7.map(d=>{const v=cianOnDate(cianRows,d);return v===null?0:v;});\n // месячные метрики: ручное значение руководителя перекрывает, иначе — авто из реестра (как на ТВ)\n const mCur=monthStats(items,st.curMonth), mPrev=monthStats(items,st.prevMonth);\n const man={};(st.manual||[]).forEach(r=>{man[String(r.month)]=r;});\n const mc=man[st.curMonth]||{}, mp=man[st.prevMonth]||{};\n const aAgg={};(st.auto||[]).forEach(r=>{aAgg[String(r.month)]=r;});\n const aCur=aAgg[st.curMonth]||{}, aPrev=aAgg[st.prevMonth]||{};\n const dealsCur=eff(mc.deals,Number(aCur.deals)||0);\n const dealsPrev=eff(mp.deals,Number(aPrev.deals)||0);\n const zadCntE=eff(mc.zad_cnt,Number(aCur.zad_cnt)||0), zadSumE=eff(mc.zad_sum,Number(aCur.zad_sum)||0);\n // доход: ручное значение руководителя, иначе — авто по оплаченным сделкам реестра\n const incomeE=mc.income!==null&&mc.income!==undefined?Number(mc.income):(Number(aCur.income)>0?Number(aCur.income):null);\n const myPct=pct(dealsPrev);\n const dealsTotal=st.dealsTotal===null||st.dealsTotal===undefined?null:Number(st.dealsTotal);\n const hasData=items.length>0;\n const netCur=netRows.find(r=>String(r.month)===st.curMonth);\n const unpaid=Number(aCur.unpaid)||0;\n // валовая выручка — по ОПЛАЧЕННЫМ сделкам (заходит при отметке «Оплачено») + ручная добавка руководителя\n const grossCur=(Number(aCur.gross_paid)||0)+(mc.gross_add===null||mc.gross_add===undefined?0:Number(mc.gross_add));\n // валовая за календарный год: по всем месяцам истории (оплаченные из реестра + ручные добавки)\n const yr=st.curMonth.slice(0,4);\n const H=st.history||{};\n const HA={};(H.auto||[]).forEach(r=>{HA[String(r.month)]=r;});\n const HM={};(H.manual||[]).forEach(r=>{HM[String(r.month)]=r;});\n let grossYear=0;\n new Set([...Object.keys(HA),...Object.keys(HM)].filter(m=>m.slice(0,4)===yr)).forEach(m=>{\n const a=HA[m]||{},mm=HM[m]||{};\n grossYear+=(Number(a.gross_paid)||0)+(mm.gross_add===null||mm.gross_add===undefined?0:Number(mm.gross_add));\n });\n const plan={deals:eff(mc.plan_deals,0),sum:eff(mc.plan_sum,0),zad:eff(mc.plan_zad,0)};\n const netK=incomeE===null?null:Math.round(incomeE*0.94);\n $('#meContent').innerHTML=`\n ${planHtml(plan,{deals:dealsCur,sum:grossCur,zad:zadCntE})}\n ${unpaid?`

⏳

Ждёт оплаты: ${money(unpaid)}Сделки подписаны и учтены в этом месяце. Как только деньги придут и руководитель отметит оплату — сумма попадёт в ваш доход того месяца.

`:''}\n

${dealsCur}

Сделок в этом месяце

${dealsPrev} — в прошлом мес.
${myPct}% — мой процент

за ${yr} год: ${money(grossYear)}

${money(grossCur)}

Валовая выручка за месяц

${zadCntE}

Задатки в этом месяце

${money(zadSumE)}

Сумма задатков

${mCur.nar.cnt}

Наработки в этом месяце

на ${money(mCur.nar.sum)}

${netK===null?'—':money(netK)}

Чистый доход

${incomeE!==null||unpaid?`

${incomeE!==null?money(incomeE)+' — до вычета 6%':''}${incomeE!==null&&unpaid?'
':''}${unpaid?money(unpaid)+' — ждёт оплаты':''}

`:''}

${base===null?'—':base+' / '+CIAN_PLAN}

Объектов размещено на Циан

${dealsTotal===null?'—':dealsTotal}

Сделок всего в компании

${disc7===null?'—':disc7+'%'}

Выполнение планов, 7 дней

${money(inWork)}

Наработки в работе, 30 дней

\n ${myNetHtml(st.history,netRows,st.curMonth)}\n ${hasData?`\n

Моя воронка · 30 дней

${funnelHtml(fnData,true)}

🔝

Верх воронки = твой доход${sc[0]>0&&sc[4]>0?`${sc[0]} контактов дали ${sc[4]} сдел${sc[4]===1?'ку':'ки(ок)'} — примерно ${Math.round(sc[0]/sc[4])} контакт(ов) на 1 сделку. `:''}Хочешь больше сделок — держи верх воронки полным: Циан, соцсети, реферальная программа, партнёры.

Выполнение планов по дням

${weekHtml(d7,discSeries)}

Моя база на Циан по дням

${weekHtml(d7,cianSeries,true)}

\n ${base!==null&&base

🏠

Циан-эффектДо плана ${CIAN_PLAN} не хватает ${CIAN_PLAN-base}. База 15+ объектов даёт заметно больше входящих: каждый объект приводит покупателей и на соседние варианты.

`:''}\n `:`

Данных пока мало.
Заполняйте план каждое утро и отмечайте итоги вечером —
динамика и конверсия появятся здесь автоматически.

`}\n ${pushCardHtml()}\n `;\n}\n\n// чистый доход брокера: карточка с периодом, крупной суммой и столбиками\nlet incRange=6;\nfunction setIncRange(n){incRange=n;loadMe();}\nfunction myNetHtml(history,netRows,curMonth){\n const h=history||{months:[],auto:[],manual:[]};\n const A={};(h.auto||[]).forEach(r=>{A[String(r.month)]=r;});\n const M={};(h.manual||[]).forEach(r=>{M[String(r.month)]=r;});\n const N={};(netRows||[]).forEach(r=>{N[String(r.month)]=Number(r.amount)||0;});\n let months=(h.months||[]).slice();\n Object.keys(N).forEach(m=>{if(months.indexOf(m)<0)months.push(m);});\n months=months.filter(m=>/^\\d{4}-\\d{2}$/.test(m)).sort();\n if(!months.length)return '';\n // добиваем шкалу пустыми месяцами до нужной длины, чтобы был ровный ряд\n const need=incRange;\n while(months.length{\n const man=M[m]||{}, au=A[m]||{};\n const gross=man.income!==null&&man.income!==undefined?Number(man.income)\n :(au.income!==null&&au.income!==undefined&&Number(au.income)>0?Number(au.income):(N[m]||0));\n const deals=man.deals!==null&&man.deals!==undefined?Number(man.deals):Number(au.deals||0);\n return {m,gross,net:Math.round(gross*0.94),deals};\n });\n const cur=rows.find(r=>r.m===curMonth)||rows[rows.length-1];\n const withMoney=rows.filter(r=>r.net>0);\n const avg=withMoney.length?Math.round(withMoney.reduce((a,r)=>a+r.net,0)/withMoney.length):0;\n const total=rows.reduce((a,r)=>a+r.net,0);\n const max=Math.max(...rows.map(r=>r.net),1);\n const bars=rows.map(r=>{\n const isCur=r.m===curMonth;\n const hh=r.net?Math.max(10,Math.round(r.net/max*104)):0;\n const [y,mm]=r.m.split('-');\n return `

${r.net?money(r.net):''}

${MONTHS[Number(mm)-1].slice(0,3)}${r.deals?r.deals+' сд.':'—'}

`;\n }).join('');\n return `

Мой чистый доход

${money(cur.net)}

${monthTitle(cur.m)} · до налога ${money(cur.gross)}

\n \n \n

${money(avg)}средний месяц

${money(total)}всего за период

${bars}

На руки после налога 6%. Доход попадает в месяц, когда руководитель отметил оплату; под столбиком — сколько сделок в этом месяце.

`;\n}",[218],"pulls","branches",1,"forks","envVars",{"_233":207,"_235":61},"connections",{"_233":61,"_234":61},"count","unfilledCount","emptyCount",{"_42":217,"_32":218,"_30":219,"_154":-5,"_40":41,"_39":220,"_155":25,"_37":270,"_13":222,"_33":20,"_34":223,"_24":25,"_158":-5,"_246":271,"_27":272},{"_42":210,"_32":211,"_30":212,"_154":-5,"_40":41,"_39":213,"_155":25,"_37":267,"_13":191,"_33":20,"_34":215,"_24":25,"_158":-5,"_246":268,"_27":269},{"_42":202,"_32":203,"_30":204,"_154":-5,"_40":41,"_39":205,"_155":25,"_37":264,"_13":207,"_33":166,"_34":208,"_24":25,"_158":-5,"_246":265,"_27":266},{"_42":194,"_32":195,"_30":196,"_154":-5,"_40":41,"_39":197,"_155":25,"_37":261,"_13":199,"_33":166,"_34":200,"_24":25,"_158":-5,"_246":262,"_27":263},{"_42":186,"_32":187,"_30":188,"_154":-5,"_40":41,"_39":189,"_155":25,"_37":258,"_13":191,"_33":20,"_34":192,"_24":25,"_158":-5,"_246":259,"_27":260},{"_42":178,"_32":179,"_30":55,"_154":-5,"_40":41,"_39":180,"_155":25,"_37":255,"_13":182,"_33":183,"_34":184,"_24":25,"_158":-5,"_246":256,"_27":257},{"_42":169,"_32":170,"_30":171,"_154":-5,"_40":41,"_39":172,"_155":25,"_37":252,"_13":174,"_33":175,"_34":176,"_24":25,"_158":-5,"_246":253,"_27":254},{"_42":160,"_32":161,"_30":162,"_154":-5,"_40":41,"_39":163,"_155":25,"_37":249,"_13":165,"_33":166,"_34":167,"_24":25,"_158":-5,"_246":250,"_27":251},{"_42":153,"_32":28,"_30":31,"_154":-5,"_40":41,"_39":14,"_155":25,"_37":245,"_13":157,"_33":20,"_34":36,"_24":25,"_158":-5,"_246":247,"_27":248},["D",1788339774167],"children",[],[28],["D",1787829663979],[],[161],["D",1788339653580],[],[170],["D",1788339628685],[],[179],["D",1788339757584],[],[187],["D",1788339639483],[],[195],["D",1788339603596],[],[203],["D",1788339713757],[],[211],["D",1787582645179],[],[218],["D",1784824972725],["D",1789560070146],{"_98":97,"_106":102},{"_98":97,"_99":100,"_101":102,"_18":53,"_103":104,"_105":25},{"_13":87,"_32":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_126":311,"_312":313,"_314":315,"_316":25,"_317":25,"_318":25,"_319":57,"_320":-5,"_321":-7,"_322":-7,"_323":61,"_324":25,"_325":25,"_326":-5,"_327":25,"_328":25,"_329":25,"_330":-5},"ENV",{"_282":283,"_284":285,"_286":88,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

📁 Реестр сделок📥 В Excel

Воронка команды · 30 дней

Брокеры · работа

Брокеры · деньги

Выполнение планов по дням · команда

База команды на Циан по дням

Брокеры и доступ

📝 Задатки на одобрение${\n pend.length ? ` · ${pend.length}` : \"\"\n }

🗂 История задатков\n ‹${\n monthTitle(m)\n }›

🎯 Планы · ${monthTitle(m)}

🗓 Данные месяца\n ‹${\n monthTitle(m)\n }›

📤 В Росфинмониторинг${\n pend.length ? ` · ${pend.length}` : \"\"\n }

📄 Сделки на одобрение${\n pend.length ? ` · ${pend.length}` : \"\"\n }

⛔ Запросы на развал · ${reqs.length}

🗑 Разваленные задатки и брони · ${a.length}

🗂 Реестр сделок и задатков\n ${\n any\n ? `📥 В Excel`\n : \"\"\n }

📦 Архив · ${archCnt}${\n bossArchOpen ? \"▲ свернуть\" : \"▼ показать\"\n }

Обход команды · сегодня

Табло для телевизора

Кому приходят напоминания

🎯 Мой план на месяц

Моя воронка · 30 дней

Выполнение планов по дням

Моя база на Циан по дням

Мой чистый доход

📁 Реестр сделок

🗂 История задатков\n ${\n monthTitle(m)\n }

🗓 Данные месяца\n ${\n monthTitle(m)\n }

🗂 Реестр сделок и задатков\n ${\n any\n ? ``\n : \"\"\n }

Diff · v179