[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","tambovtsev007","name","voronka-dnya","path","partners.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":-5,"_53":-5,"_54":55,"_56":57,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/tambovtsev007/voronka-dnya/code/partners.ts","extension","id","66449644-e653-4ecf-968a-5a936de09615","fileId","f7ac15a8-a776-11f1-97ea-1607ee4eb77e","parentId","branchId","5a76b817-f255-4528-a3a4-76e6a27bfac9","branchVersion",285,"latest",true,"createdAt",["D",1789053885180],"version",5,"fileType","script","content","// Контрагенты (наши брокеры + внешние), их документы, журнал выплат и акты сверки взаиморасчётов.\n// Отдельный файл из-за лимита Val Town 80 000 символов на файл. Подключается из main.ts: registerPartners(app, helpers).\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { notifyBoss } from \"./push.ts\";\n\nconst DOC_RE = /^data:(application\\/pdf|application\\/msword|application\\/vnd\\.openxmlformats-officedocument\\.wordprocessingml\\.document|image\\/(jpeg|jpg|png|webp));base64,/;\nconst DATE_RE = /^\\d{4}-\\d{2}-\\d{2}$/;\nconst PERIOD_RE = /^\\d{4}-\\d{2}$/;\nconst MONTHS_RU = [\"января\", \"февраля\", \"марта\", \"апреля\", \"мая\", \"июня\", \"июля\", \"августа\", \"сентября\", \"октября\", \"ноября\", \"декабря\"];\nconst MONTHS_NOM = [\"Январь\", \"Февраль\", \"Март\", \"Апрель\", \"Май\", \"Июнь\", \"Июль\", \"Август\", \"Сентябрь\", \"Октябрь\", \"Ноябрь\", \"Декабрь\"];\n\n// поля карточки контрагента, которые можно редактировать (RU-подписи для отбивок/печати)\nconst FIELDS = {\n name: \"Имя / название\", kind: \"Тип\", legal_form: \"Форма\", legal_name: \"Полное наименование\", inn: \"ИНН\", ogrn: \"ОГРН/ОГРНИП\",\n address: \"Адрес\", bank_name: \"Банк\", bik: \"БИК\", ks: \"Корр. счёт\", rs: \"Расчётный счёт\", agreement_num: \"№ договора\",\n agreement_date: \"Дата договора\", phone: \"Телефон\", email: \"E-mail\", note: \"Примечание\", nda: \"NDA\",\n};\nconst COMPANY_KEYS = [\"name\", \"legal_name\", \"inn\", \"ogrn\", \"address\", \"bank_name\", \"bik\", \"ks\", \"rs\", \"director\", \"phone\", \"email\"];\n\nlet ready = false;\nasync function init() {\n if (ready) return;\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS partners(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n broker_id INTEGER UNIQUE,\n kind TEXT NOT NULL DEFAULT 'broker',\n name TEXT NOT NULL,\n legal_form TEXT, legal_name TEXT, inn TEXT, ogrn TEXT, address TEXT,\n bank_name TEXT, bik TEXT, ks TEXT, rs TEXT,\n agreement_num TEXT, agreement_date TEXT, nda TEXT,\n phone TEXT, email TEXT, note TEXT,\n created_at TEXT DEFAULT (datetime('now')))`,\n `CREATE TABLE IF NOT EXISTS partner_docs(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n partner_id INTEGER NOT NULL,\n title TEXT NOT NULL,\n name TEXT NOT NULL,\n created_at TEXT DEFAULT (datetime('now')))`,\n `CREATE TABLE IF NOT EXISTS payouts(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n partner_id INTEGER NOT NULL,\n date TEXT NOT NULL,\n sum INTEGER NOT NULL,\n basis TEXT,\n dkp_id INTEGER,\n created_at TEXT DEFAULT (datetime('now')))`,\n `CREATE TABLE IF NOT EXISTS acts(\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n partner_id INTEGER NOT NULL,\n period TEXT NOT NULL,\n balance_start INTEGER NOT NULL DEFAULT 0,\n accrued INTEGER NOT NULL DEFAULT 0,\n paid INTEGER NOT NULL DEFAULT 0,\n balance_end INTEGER NOT NULL DEFAULT 0,\n rows_json TEXT,\n doc_name TEXT,\n auto INTEGER NOT NULL DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n UNIQUE(partner_id, period))`,\n `CREATE INDEX IF NOT EXISTS payouts_partner ON payouts(partner_id, date)`,\n ]);\n try { await sqlite.execute(\"ALTER TABLE payouts ADD COLUMN dkp_id INTEGER\"); } catch (_e) { /* уже есть */ }\n try { await sqlite.execute(\"ALTER TABLE payouts ADD COLUMN kind TEXT\"); } catch (_e) { /* уже есть */ }\n ready = true;\n}\n\n// каждому брокеру — карточка контрагента; каждой оплаченной сделке — авто-выплата брокеру (идемпотентно)\nconst SYNC_SQL = [\n `INSERT INTO partners(broker_id,kind,name)\n SELECT b.id,'broker',b.name FROM brokers b WHERE NOT EXISTS (SELECT 1 FROM partners p WHERE p.broker_id=b.id)`,\n `INSERT INTO payouts(partner_id,date,sum,basis,dkp_id)\n SELECT p.id, substr(d.paid_at,1,10), d.broker_sum, 'Сделка № '||COALESCE(d.crm_id,'')||' · '||COALESCE(d.client,''), d.id\n FROM dkp d JOIN partners p ON p.broker_id=d.broker_id\n WHERE d.status='approved' AND d.paid=1 AND d.paid_at IS NOT NULL AND COALESCE(d.broker_sum,0)>0\n AND NOT EXISTS (SELECT 1 FROM payouts y WHERE y.dkp_id=d.id)`,\n `DELETE FROM payouts WHERE dkp_id IS NOT NULL AND dkp_id NOT IN (SELECT id FROM dkp WHERE status='approved' AND paid=1)`,\n];\nasync function syncBrokers() { await sqlite.batch(SYNC_SQL); }\n\n// вызывается из main.ts при смене «Оплачено»: сразу вносим/снимаем выплату и пересобираем акт месяца\nexport async function syncPayoutForDeal(dkpId) {\n await init();\n const before = await sqlite.execute({ sql: \"SELECT partner_id, substr(date,1,7) per FROM payouts WHERE dkp_id=?\", args: [dkpId] });\n await sqlite.batch(SYNC_SQL);\n const after = await sqlite.execute({ sql: \"SELECT partner_id, substr(date,1,7) per FROM payouts WHERE dkp_id=?\", args: [dkpId] });\n const touched = new Map();\n for (const r of [...before.rows, ...after.rows]) touched.set(n(r.partner_id) + \":\" + r.per, [n(r.partner_id), String(r.per)]);\n for (const [pid, per] of touched.values()) {\n const a = await sqlite.execute({ sql: \"SELECT id FROM acts WHERE partner_id=? AND period=?\", args: [pid, per] });\n if (a.rows.length) await buildAct(pid, per, false);\n }\n}\n\nconst n = (v) => Number(v) || 0;\nconst money = (v) => n(v).toLocaleString(\"ru-RU\");\nconst ruDate = (s) => (s && DATE_RE.test(s)) ? `${s.slice(8, 10)}.${s.slice(5, 7)}.${s.slice(0, 4)}` : (s || \"\");\nconst esc = (s) => String(s ?? \"\").replace(/[&<>\"]/g, (ch) => ({ \"&\": \"&\", \"<\": \"<\", \">\": \">\", '\"': \""\" }[ch]));\nconst periodTitle = (p) => `${MONTHS_NOM[Number(p.slice(5, 7)) - 1]} ${p.slice(0, 4)}`;\nconst lastDay = (p) => new Date(Date.UTC(Number(p.slice(0, 4)), Number(p.slice(5, 7)), 0)).toISOString().slice(0, 10);\nconst prevPeriod = (d = new Date()) => {\n const y = d.getUTCFullYear(), m = d.getUTCMonth(); // прошлый месяц относительно UTC-даты\n const pm = m === 0 ? 12 : m, py = m === 0 ? y - 1 : y;\n return `${py}-${String(pm).padStart(2, \"0\")}`;\n};\n\nasync function company() {\n const r = await sqlite.execute({ sql: \"SELECT key,value FROM settings WHERE key LIKE 'company_%'\", args: [] });\n const o = {};\n for (const row of r.rows) o[String(row.key).slice(8)] = String(row.value);\n return o;\n}\n\n// начисления брокеру = его доля по ОПЛАЧЕННЫМ сделкам, месяц — по дате захода денег (единое правило системы)\nasync function accruedRows(brokerId, period) {\n if (!brokerId) return [];\n const r = await sqlite.execute({\n sql: `SELECT id,client,crm_id,sector,deal_date,paid_at,broker_pct,broker_sum FROM dkp\n WHERE broker_id=? AND status='approved' AND paid=1 AND substr(paid_at,1,7)=? ORDER BY paid_at,id`,\n args: [brokerId, period],\n });\n return r.rows.map((d) => ({\n id: n(d.id), date: String(d.paid_at || \"\").slice(0, 10), deal_date: String(d.deal_date || \"\"),\n client: String(d.client || \"\"), crm: String(d.crm_id || \"\"), rent: String(d.sector) === \"rent\",\n pct: n(d.broker_pct), sum: n(d.broker_sum),\n }));\n}\n\nasync function buildAct(partnerId, period, auto) {\n const p = await sqlite.execute({ sql: \"SELECT * FROM partners WHERE id=?\", args: [partnerId] });\n if (!p.rows.length) return null;\n const pr = p.rows[0];\n const brokerId = pr.broker_id ? n(pr.broker_id) : null;\n const rows = await accruedRows(brokerId, period);\n const pays = await sqlite.execute({\n sql: \"SELECT id,date,sum,basis,kind FROM payouts WHERE partner_id=? AND substr(date,1,7)=? ORDER BY date,id\",\n args: [partnerId, period],\n });\n // выплаты «по сделке до системы» (kind='settled') — это и начисление, и оплата: в акте идут двумя строками, сальдо не сдвигают\n const settled = pays.rows.filter((r) => String(r.kind) === \"settled\");\n for (const r of settled) rows.push({ id: null, date: String(r.date), deal_date: \"\", client: String(r.basis || \"сделка до внедрения системы\"), crm: \"\", rent: false, pct: 0, sum: n(r.sum), settled: true });\n rows.sort((a, b) => a.date.localeCompare(b.date));\n const accrued = rows.reduce((a, r) => a + r.sum, 0);\n const paid = pays.rows.reduce((a, r) => a + n(r.sum), 0);\n // сальдо на начало: всё начислено до периода минус всё выплачено до периода (settled-выплаты входят в обе части)\n const [accB, payB, setB] = await sqlite.batch([\n { sql: `SELECT COALESCE(SUM(broker_sum),0) s FROM dkp WHERE broker_id=? AND status='approved' AND paid=1 AND substr(paid_at,1,7) ({ id: n(r.id), date: String(r.date), sum: n(r.sum), basis: String(r.basis || \"\"), settled: String(r.kind) === \"settled\" })) });\n await sqlite.execute({\n sql: `INSERT INTO acts(partner_id,period,balance_start,accrued,paid,balance_end,rows_json,auto)\n VALUES(?,?,?,?,?,?,?,?)\n ON CONFLICT(partner_id,period) DO UPDATE SET balance_start=excluded.balance_start, accrued=excluded.accrued,\n paid=excluded.paid, balance_end=excluded.balance_end, rows_json=excluded.rows_json, created_at=datetime('now')`,\n args: [partnerId, period, balanceStart, accrued, paid, balanceEnd, rowsJson, auto ? 1 : 0],\n });\n const a = await sqlite.execute({ sql: \"SELECT * FROM acts WHERE partner_id=? AND period=?\", args: [partnerId, period] });\n return a.rows[0];\n}\n\n// вызывается кроном 1-го числа (boss-morning): акты за прошлый месяц по всем активным брокерам\nexport async function monthlyActs() {\n await init();\n await syncBrokers();\n const period = prevPeriod();\n const done = await sqlite.execute({ sql: \"SELECT 1 FROM settings WHERE key='acts_done' AND value=?\", args: [period] });\n if (done.rows.length) return { period, skipped: true };\n const ps = await sqlite.execute({\n sql: \"SELECT p.id FROM partners p JOIN brokers b ON b.id=p.broker_id WHERE b.active=1\",\n args: [],\n });\n let cnt = 0;\n for (const r of ps.rows) { await buildAct(n(r.id), period, true); cnt++; }\n await sqlite.execute({\n sql: \"INSERT INTO settings(key,value) VALUES('acts_done',?) ON CONFLICT(key) DO UPDATE SET value=excluded.value\",\n args: [period],\n });\n await notifyBoss(\"📑 Акты сверки готовы\", `${periodTitle(period)}: сформировано ${cnt} акт(ов). Откройте CRM → «Контрагенты», проверьте выплаты и распечатайте.`);\n return { period, count: cnt };\n}\n\nfunction actHtml(act, pr, co) {\n const rows = act.rows_json ? JSON.parse(String(act.rows_json)) : { accrued: [], paid: [] };\n const period = String(act.period);\n const p1 = `01.${period.slice(5, 7)}.${period.slice(0, 4)}`, p2 = ruDate(lastDay(period));\n const side = (o, title) => `

${title}

${esc(o.legal_name || o.name || \"\")}\n ${o.inn ? `

ИНН ${esc(o.inn)}${o.ogrn ? \" · ОГРН(ИП) \" + esc(o.ogrn) : \"\"}

` : \"\"}\n ${o.address ? `

${esc(o.address)}

` : \"\"}\n ${o.rs ? `

р/с ${esc(o.rs)}${o.bank_name ? \" в \" + esc(o.bank_name) : \"\"}${o.bik ? \", БИК \" + esc(o.bik) : \"\"}${o.ks ? \", к/с \" + esc(o.ks) : \"\"}

` : \"\"}

`;\n const dealRows = rows.accrued.map((r, i) => `${i + 1}${ruDate(r.date)}\n ${r.settled ? `Вознаграждение — ${esc(r.client)}` : `Вознаграждение по сделке ${esc(r.client)}${r.crm ? \" (№ \" + esc(r.crm) + \")\" : \"\"}${r.rent ? \", аренда\" : \"\"}${r.deal_date ? \", договор от \" + ruDate(r.deal_date) : \"\"}, ${r.pct}%`}\n ${money(r.sum)}`).join(\"\");\n const payRows = rows.paid.map((r, i) => `${rows.accrued.length + i + 1}${ruDate(r.date)}\n Оплата${r.basis ? \" — \" + esc(r.basis) : \"\"}${r.settled ? \" (сделка до внедрения системы)\" : \"\"}${money(r.sum)}`).join(\"\");\n const bs = n(act.balance_start), be = n(act.balance_end);\n const who = (v) => v > 0 ? `в пользу ${esc(pr.legal_name || pr.name)}` : v < 0 ? `в пользу ${esc(co.legal_name || co.name || \"Компании\")}` : \"\";\n return `Акт сверки · ${esc(pr.name)} · ${periodTitle(period)}\n\n

АКТ СВЕРКИ ВЗАИМНЫХ РАСЧЁТОВ

за период с ${p1} по ${p2}
между ${esc(co.legal_name || co.name || \"Компанией\")} и ${esc(pr.legal_name || pr.name)}${pr.agreement_num ? `
по договору № ${esc(pr.agreement_num)}${pr.agreement_date ? \" от \" + ruDate(pr.agreement_date) : \"\"}` : \"\"}

${side(co, \"Сторона 1 (Заказчик)\")}${side(pr, \"Сторона 2 (Исполнитель)\")}

\n\n\n${dealRows}${payRows}\n${!dealRows && !payRows ? `` : \"\"}\n\n\n

№	Операция	Начислено, ₽	Оплачено, ₽
	Сальдо на ${p1}${bs ? \" \" + who(bs) : \"\"}	${bs > 0 ? money(bs) : \"\"}	${bs < 0 ? money(-bs) : \"\"}
операций за период нет
	Обороты за период	${money(act.accrued)}	${money(act.paid)}
	Сальдо на ${p2}${be ? \" \" + who(be) : \"\"}	${be > 0 ? money(be) : \"\"}	${be < 0 ? money(-be) : \"\"}

По данным ${esc(co.legal_name || co.name || \"Компании\")} на ${p2} задолженность ${be > 0 ? `перед ${esc(pr.legal_name || pr.name)} составляет ${money(be)} ₽` : be < 0 ? `${esc(pr.legal_name || pr.name)} составляет ${money(-be)} ₽` : \"отсутствует\"}.

От Стороны 1${co.director ? \": \" + esc(co.director) : \"\"}

подпись / м.п.

От Стороны 2: ${esc(pr.legal_name || pr.name)}

подпись / м.п.

Сформировано системой Unlock · ${new Date().toLocaleString(\"ru-RU\", { timeZone: \"Europe/Moscow\" })}

\n`;\n}\n\nexport function registerPartners(app, h) {\n const { jerr } = h;\n const boss = (c) => c.get(\"user\")?.role === \"boss\";\n\n /* ---------- реквизиты компании ---------- */\n app.get(\"/api/company\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n return c.json(await company());\n });\n app.post(\"/api/company\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const stmts = [];\n for (const k of COMPANY_KEYS) {\n if (k in b) stmts.push({\n sql: \"INSERT INTO settings(key,value) VALUES(?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value\",\n args: [\"company_\" + k, String(b[k] ?? \"\").trim().slice(0, 300)],\n });\n }\n if (stmts.length) await sqlite.batch(stmts);\n return c.json({ ok: true });\n });\n\n /* ---------- контрагенты ---------- */\n app.get(\"/api/partners\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n // один сетевой пакет: синхронизация + все выборки\n const res = await sqlite.batch([\n ...SYNC_SQL,\n { sql: `SELECT p.*, b.active AS broker_active FROM partners p LEFT JOIN brokers b ON b.id=p.broker_id ORDER BY p.kind, p.name`, args: [] },\n { sql: \"SELECT partner_id, COUNT(*) cnt FROM partner_docs GROUP BY partner_id\", args: [] },\n { sql: \"SELECT partner_id, COALESCE(SUM(sum),0) s, MAX(date) last, COALESCE(SUM(CASE WHEN kind='settled' THEN sum ELSE 0 END),0) settled FROM payouts GROUP BY partner_id\", args: [] },\n { sql: \"SELECT partner_id, COUNT(*) cnt, MAX(period) last, SUM(CASE WHEN doc_name IS NULL THEN 1 ELSE 0 END) unsigned FROM acts GROUP BY partner_id\", args: [] },\n { sql: \"SELECT broker_id, COALESCE(SUM(broker_sum),0) s FROM dkp WHERE status='approved' AND paid=1 GROUP BY broker_id\", args: [] },\n { sql: \"SELECT key,value FROM settings WHERE key LIKE 'company_%'\", args: [] },\n ]);\n const [ps, docs, pays, acts, acc, co] = res.slice(SYNC_SQL.length);\n const coObj = {};\n for (const row of co.rows) coObj[String(row.key).slice(8)] = String(row.value);\n const m = (rs, k = \"partner_id\") => Object.fromEntries(rs.rows.map((r) => [String(r[k]), r]));\n const dM = m(docs), pM = m(pays), aM = m(acts), accM = m(acc, \"broker_id\");\n const rows = ps.rows.map((p) => {\n // начислено = доля по оплаченным сделкам в системе + сделки до системы (settled-выплаты)\n const accrued = (p.broker_id ? n(accM[String(p.broker_id)]?.s) : 0) + n(pM[String(p.id)]?.settled);\n const paid = n(pM[String(p.id)]?.s);\n return {\n ...p, docs: n(dM[String(p.id)]?.cnt), paid_total: paid, paid_last: pM[String(p.id)]?.last || null,\n accrued_total: accrued, balance: accrued - paid,\n acts: n(aM[String(p.id)]?.cnt), acts_last: aM[String(p.id)]?.last || null, acts_unsigned: n(aM[String(p.id)]?.unsigned),\n };\n });\n return c.json({ rows, company: coObj });\n });\n\n app.post(\"/api/partners\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const b = await c.req.json().catch(() => ({}));\n const name = String(b.name || \"\").trim().slice(0, 120);\n if (!name) return jerr(c, \"Укажите имя или название контрагента\");\n const r = await sqlite.execute({ sql: \"INSERT INTO partners(kind,name,note) VALUES('ext',?,?)\", args: [name, String(b.note || \"\").slice(0, 500)] });\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n });\n\n app.post(\"/api/partners/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const sets = [], args = [];\n for (const k of Object.keys(FIELDS)) {\n if (!(k in b) || k === \"kind\") continue;\n let v = b[k] == null ? null : String(b[k]).trim().slice(0, 500);\n if (k === \"agreement_date\" && v && !DATE_RE.test(v)) return jerr(c, \"Дата договора: формат ГГГГ-ММ-ДД\");\n if (k === \"name\" && !v) return jerr(c, \"Имя не может быть пустым\");\n sets.push(`${k}=?`); args.push(v);\n }\n if (!sets.length) return c.json({ ok: true });\n args.push(id);\n await sqlite.execute({ sql: `UPDATE partners SET ${sets.join(\",\")} WHERE id=?`, args });\n return c.json({ ok: true });\n });\n\n app.delete(\"/api/partners/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({ sql: \"SELECT broker_id FROM partners WHERE id=?\", args: [id] });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n if (r.rows[0].broker_id) return jerr(c, \"Карточку брокера удалить нельзя — переведите брокера в архив в настройках\");\n const docs = await sqlite.execute({ sql: \"SELECT id FROM partner_docs WHERE partner_id=?\", args: [id] });\n for (const d of docs.rows) { try { await blob.delete(`doc:p:${n(d.id)}`); } catch (_e) {} }\n const acts = await sqlite.execute({ sql: \"SELECT id FROM acts WHERE partner_id=?\", args: [id] });\n for (const a of acts.rows) { try { await blob.delete(`doc:act:${n(a.id)}`); } catch (_e) {} }\n await sqlite.batch([\n { sql: \"DELETE FROM partner_docs WHERE partner_id=?\", args: [id] },\n { sql: \"DELETE FROM payouts WHERE partner_id=?\", args: [id] },\n { sql: \"DELETE FROM acts WHERE partner_id=?\", args: [id] },\n { sql: \"DELETE FROM partners WHERE id=?\", args: [id] },\n ]);\n return c.json({ ok: true });\n });\n\n // карточка: документы, выплаты, акты, начисления по месяцам\n app.get(\"/api/partners/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const id = Number(c.req.param(\"id\"));\n // один пакет: карточка + документы + выплаты + акты + начисления по месяцам + «ждёт оплаты»\n const bq = \"(SELECT broker_id FROM partners WHERE id=?)\";\n const [p, docs, pays, acts, months, wait] = await sqlite.batch([\n { sql: \"SELECT p.*, b.active AS broker_active FROM partners p LEFT JOIN brokers b ON b.id=p.broker_id WHERE p.id=?\", args: [id] },\n { sql: \"SELECT id,title,name,created_at FROM partner_docs WHERE partner_id=? ORDER BY id DESC\", args: [id] },\n { sql: \"SELECT id,date,sum,basis,dkp_id,kind,created_at FROM payouts WHERE partner_id=? ORDER BY date DESC,id DESC\", args: [id] },\n { sql: \"SELECT id,period,balance_start,accrued,paid,balance_end,doc_name,auto,created_at FROM acts WHERE partner_id=? ORDER BY period DESC\", args: [id] },\n { sql: `SELECT substr(paid_at,1,7) m, COUNT(*) cnt, COALESCE(SUM(broker_sum),0) s FROM dkp\n WHERE broker_id=${bq} AND status='approved' AND paid=1 GROUP BY m ORDER BY m DESC LIMIT 24`, args: [id] },\n { sql: `SELECT COUNT(*) cnt, COALESCE(SUM(broker_sum),0) s FROM dkp WHERE broker_id=${bq} AND status='approved' AND paid=0`, args: [id] },\n ]);\n if (!p.rows.length) return jerr(c, \"not found\", 404);\n return c.json({ partner: p.rows[0], docs: docs.rows, payouts: pays.rows, acts: acts.rows, months: months.rows, waiting: wait.rows[0], fields: FIELDS });\n });\n\n /* ---------- документы контрагента (АД, NDA, реквизиты, паспорт ИП…) ---------- */\n app.post(\"/api/partners/:id/doc\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n if (typeof b.doc !== \"string\" || !DOC_RE.test(b.doc)) return jerr(c, \"Приложите файл: PDF, Word или фото\");\n if (b.doc.length > 4500000) return jerr(c, \"Файл слишком большой (до ~3 МБ)\");\n const title = String(b.title || \"Документ\").trim().slice(0, 80);\n const name = String(b.doc_name || \"document\").trim().slice(0, 150);\n const r = await sqlite.execute({ sql: \"INSERT INTO partner_docs(partner_id,title,name) VALUES(?,?,?)\", args: [id, title, name] });\n const did = Number(r.lastInsertRowid);\n await blob.set(`doc:p:${did}`, String(b.doc));\n return c.json({ ok: true, id: did });\n });\n app.delete(\"/api/partners/doc/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n try { await blob.delete(`doc:p:${id}`); } catch (_e) {}\n await sqlite.execute({ sql: \"DELETE FROM partner_docs WHERE id=?\", args: [id] });\n return c.json({ ok: true });\n });\n // скачивание: p — документ контрагента, act — подписанный скан акта\n app.get(\"/api/pdoc/:kind/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const kind = c.req.param(\"kind\"), id = Number(c.req.param(\"id\"));\n if (kind !== \"p\" && kind !== \"act\") return jerr(c, \"bad doc\");\n const r = await sqlite.execute({\n sql: kind === \"p\" ? \"SELECT name FROM partner_docs WHERE id=?\" : \"SELECT doc_name AS name FROM acts WHERE id=?\", args: [id],\n });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n let dataUrl;\n try { dataUrl = await (await blob.get(`doc:${kind}:${id}`)).text(); } catch (_e) { return jerr(c, \"Файл не найден\", 404); }\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 c.header(\"Content-Type\", m[1]);\n c.header(\"Content-Disposition\", `attachment; filename*=UTF-8''${encodeURIComponent(String(r.rows[0].name || \"document\"))}`);\n return c.body(bin);\n });\n\n /* ---------- выплаты ---------- */\n app.post(\"/api/partners/:id/payout\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const date = String(b.date || \"\"), sum = Math.round(Number(String(b.sum ?? \"\").replace(/\\s/g, \"\").replace(\",\", \".\")));\n if (!DATE_RE.test(date)) return jerr(c, \"Укажите дату выплаты\");\n if (!(sum > 0)) return jerr(c, \"Укажите сумму выплаты\");\n // kind: 'pay' — обычная выплата (аванс, премия), 'settled' — сделка до системы: начислено и выплачено, сальдо не меняет\n const kind = b.settled ? \"settled\" : \"pay\";\n const r = await sqlite.execute({\n sql: \"INSERT INTO payouts(partner_id,date,sum,basis,kind) VALUES(?,?,?,?,?)\",\n args: [id, date, sum, String(b.basis || \"\").trim().slice(0, 200), kind],\n });\n // если акт за этот месяц уже сформирован — пересобираем, чтобы сальдо не расходилось\n const per = date.slice(0, 7);\n const a = await sqlite.execute({ sql: \"SELECT id FROM acts WHERE partner_id=? AND period=?\", args: [id, per] });\n if (a.rows.length) await buildAct(id, per, false);\n return c.json({ ok: true, id: Number(r.lastInsertRowid) });\n });\n // правка внесённой вручную выплаты: дата, сумма, основание, вид (акты затронутых месяцев пересобираются)\n app.post(\"/api/payouts/:id\", async (c) => {\n if (!boss(c)) 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({ sql: \"SELECT partner_id,date,dkp_id FROM payouts WHERE id=?\", args: [id] });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n if (r.rows[0].dkp_id) return jerr(c, \"Авто-выплату по сделке править нельзя — меняйте саму сделку\");\n const date = String(b.date || \"\"), sum = Math.round(Number(String(b.sum ?? \"\").replace(/\\s/g, \"\").replace(\",\", \".\")));\n if (!DATE_RE.test(date)) return jerr(c, \"Укажите дату выплаты\");\n if (!(sum > 0)) return jerr(c, \"Укажите сумму выплаты\");\n await sqlite.execute({\n sql: \"UPDATE payouts SET date=?, sum=?, basis=?, kind=? WHERE id=?\",\n args: [date, sum, String(b.basis || \"\").trim().slice(0, 200), b.settled ? \"settled\" : \"pay\", id],\n });\n const pid = n(r.rows[0].partner_id);\n for (const per of new Set([String(r.rows[0].date).slice(0, 7), date.slice(0, 7)])) {\n const a = await sqlite.execute({ sql: \"SELECT id FROM acts WHERE partner_id=? AND period=?\", args: [pid, per] });\n if (a.rows.length) await buildAct(pid, per, false);\n }\n return c.json({ ok: true });\n });\n // переключить вид уже внесённой выплаты: обычная ↔ «сделка до системы» (акт месяца пересобирается)\n app.post(\"/api/payouts/:id/kind\", async (c) => {\n if (!boss(c)) 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({ sql: \"SELECT partner_id,date,dkp_id FROM payouts WHERE id=?\", args: [id] });\n if (!r.rows.length) return jerr(c, \"not found\", 404);\n if (r.rows[0].dkp_id) return jerr(c, \"Авто-выплату по сделке менять нельзя\");\n await sqlite.execute({ sql: \"UPDATE payouts SET kind=? WHERE id=?\", args: [b.settled ? \"settled\" : \"pay\", id] });\n const pid = n(r.rows[0].partner_id), per = String(r.rows[0].date).slice(0, 7);\n const a = await sqlite.execute({ sql: \"SELECT id FROM acts WHERE partner_id=? AND period=?\", args: [pid, per] });\n if (a.rows.length) await buildAct(pid, per, false);\n return c.json({ ok: true });\n });\n app.delete(\"/api/payouts/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const r = await sqlite.execute({ sql: \"SELECT partner_id,date,dkp_id FROM payouts WHERE id=?\", args: [id] });\n if (r.rows.length && r.rows[0].dkp_id) return jerr(c, \"Это авто-выплата по сделке: снимите «Оплачено» в сделке — запись уйдёт сама\");\n await sqlite.execute({ sql: \"DELETE FROM payouts WHERE id=?\", args: [id] });\n if (r.rows.length) {\n const pid = n(r.rows[0].partner_id), per = String(r.rows[0].date).slice(0, 7);\n const a = await sqlite.execute({ sql: \"SELECT id FROM acts WHERE partner_id=? AND period=?\", args: [pid, per] });\n if (a.rows.length) await buildAct(pid, per, false);\n }\n return c.json({ ok: true });\n });\n\n /* ---------- акты сверки ---------- */\n app.post(\"/api/partners/:id/act\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n await init();\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n const period = String(b.period || prevPeriod());\n if (!PERIOD_RE.test(period)) return jerr(c, \"Период: ГГГГ-ММ\");\n const act = await buildAct(id, period, false);\n if (!act) return jerr(c, \"not found\", 404);\n return c.json({ ok: true, act });\n });\n app.get(\"/api/acts/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const a = await sqlite.execute({ sql: \"SELECT * FROM acts WHERE id=?\", args: [id] });\n if (!a.rows.length) return jerr(c, \"not found\", 404);\n const p = await sqlite.execute({ sql: \"SELECT * FROM partners WHERE id=?\", args: [n(a.rows[0].partner_id)] });\n return c.json({ act: a.rows[0], partner: p.rows[0], company: await company() });\n });\n // печатная форма (HTML → браузер → «Сохранить как PDF»)\n app.get(\"/api/acts/:id/html\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const a = await sqlite.execute({ sql: \"SELECT * FROM acts WHERE id=?\", args: [id] });\n if (!a.rows.length) return jerr(c, \"not found\", 404);\n const p = await sqlite.execute({ sql: \"SELECT * FROM partners WHERE id=?\", args: [n(a.rows[0].partner_id)] });\n c.header(\"Content-Type\", \"text/html; charset=utf-8\");\n return c.body(actHtml(a.rows[0], p.rows[0] || {}, await company()));\n });\n // подписанный скан акта\n app.post(\"/api/acts/:id/doc\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n const b = await c.req.json().catch(() => ({}));\n if (typeof b.doc !== \"string\" || !DOC_RE.test(b.doc)) return jerr(c, \"Приложите файл: PDF, Word или фото\");\n if (b.doc.length > 4500000) return jerr(c, \"Файл слишком большой (до ~3 МБ)\");\n await blob.set(`doc:act:${id}`, String(b.doc));\n await sqlite.execute({ sql: \"UPDATE acts SET doc_name=? WHERE id=?\", args: [String(b.doc_name || \"act.pdf\").slice(0, 150), id] });\n return c.json({ ok: true });\n });\n app.delete(\"/api/acts/:id\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const id = Number(c.req.param(\"id\"));\n try { await blob.delete(`doc:act:${id}`); } catch (_e) {}\n await sqlite.execute({ sql: \"DELETE FROM acts WHERE id=?\", args: [id] });\n return c.json({ ok: true });\n });\n // ручной запуск месячного формирования (кнопка «Сформировать за прошлый месяц всем»)\n app.post(\"/api/acts/monthly\", async (c) => {\n if (!boss(c)) return jerr(c, \"forbidden\", 403);\n const b = await c.req.json().catch(() => ({}));\n const period = String(b.period || prevPeriod());\n if (!PERIOD_RE.test(period)) return jerr(c, \"Период: ГГГГ-ММ\");\n await init(); await syncBrokers();\n const ps = await sqlite.execute({ sql: \"SELECT p.id FROM partners p JOIN brokers b ON b.id=p.broker_id WHERE b.active=1\", args: [] });\n let cnt = 0;\n for (const r of ps.rows) { await buildAct(n(r.id), period, false); cnt++; }\n return c.json({ ok: true, period, count: cnt });\n });\n}","deleted",false,"label",[14],"47c70ae1-859e-4751-8e55-f5f72caa1026",["D",1784824972725],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","caa5b6a0-dd4e-4cd6-a997-9389a6a43948","pinnedFileId","8c600d22-86b5-11f1-862b-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019eff71-5749-76b5-abdd-e25a47b3deca","tursoName","47c70ae1859e47518e55f5f72caa1026","tursoHostname","47c70ae1859e47518e55f5f72caa1026-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789473046147],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":101},"org",{"_9":10,"_98":99,"_100":101,"_54":55,"_102":103,"_104":42},"branch",{"_35":88,"_11":89,"_22":28,"_90":45,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":12,"_97":10},"isOwned",286,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Кирилл Тамбовцев","avatar","https://lh3.googleusercontent.com/a/ACg8ocKCNneTjcn307kcxhB_NS1R7_0SBhSKM-2hy73z0JvhXFipwkhs=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":62,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":89,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]