AI Tender Core

Интеллектуальная платформа управления тендерами

\n\nАгент: проверка…\n

\n\n\n

\n\n

\n\n\n

Всего тендеров

—

Активные

—

Поданные

—

Выиграно

—

Win Rate

—

Сумма бюджетов

—

Бюджет по типам

Распределение по статусам

\n\n\n

Тендеры

\n\n\n\n\n

\n\n\n

Тендер	Заказчик	Тип	Статус	Бюджет	Дедлайн	·

\n\n\n\n\n\n\n\n\n\n\n\n

AI Ассистент

\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\n",[],[59,84],["D",1785579186952],[95,96,97,98,99,100,101,102,103,104,105,106],[67],{"_35":196,"_13":197,"_38":198,"_40":68,"_41":42,"_43":49,"_45":46,"_47":199,"_17":63,"_50":112,"_52":200,"_54":55,"_56":-5,"_76":201,"_18":202},{"_35":188,"_13":189,"_38":190,"_40":68,"_41":42,"_43":191,"_45":46,"_47":192,"_17":63,"_50":112,"_52":193,"_54":55,"_56":-5,"_76":194,"_18":195},{"_35":180,"_13":181,"_38":182,"_40":68,"_41":42,"_43":183,"_45":46,"_47":184,"_17":63,"_50":112,"_52":185,"_54":55,"_56":-5,"_76":186,"_18":187},{"_35":172,"_13":173,"_38":174,"_40":68,"_41":42,"_43":175,"_45":46,"_47":176,"_17":63,"_50":112,"_52":177,"_54":55,"_56":-5,"_76":178,"_18":179},{"_35":164,"_13":165,"_38":166,"_40":68,"_41":42,"_43":167,"_45":46,"_47":168,"_17":63,"_50":112,"_52":169,"_54":55,"_56":-5,"_76":170,"_18":171},{"_35":156,"_13":157,"_38":158,"_40":68,"_41":42,"_43":159,"_45":46,"_47":160,"_17":144,"_50":112,"_52":161,"_54":55,"_56":-5,"_76":162,"_18":163},{"_35":148,"_13":149,"_38":150,"_40":68,"_41":42,"_43":151,"_45":46,"_47":152,"_17":63,"_50":112,"_52":153,"_54":55,"_56":-5,"_76":154,"_18":155},{"_35":139,"_13":140,"_38":141,"_40":68,"_41":42,"_43":142,"_45":46,"_47":143,"_17":144,"_50":112,"_52":145,"_54":55,"_56":-5,"_76":146,"_18":147},{"_35":131,"_13":132,"_38":133,"_40":68,"_41":42,"_43":134,"_45":46,"_47":135,"_17":63,"_50":112,"_52":136,"_54":55,"_56":-5,"_76":137,"_18":138},{"_35":124,"_13":125,"_38":126,"_40":68,"_41":42,"_43":88,"_45":46,"_47":127,"_17":63,"_50":112,"_52":128,"_54":55,"_56":-5,"_76":129,"_18":130},{"_35":116,"_13":117,"_38":118,"_40":68,"_41":42,"_43":119,"_45":46,"_47":120,"_17":63,"_50":112,"_52":121,"_54":55,"_56":-5,"_76":122,"_18":123},{"_35":107,"_13":108,"_38":109,"_40":68,"_41":42,"_43":110,"_45":46,"_47":111,"_17":69,"_50":112,"_52":113,"_54":55,"_56":-5,"_76":114,"_18":115},"6395f666-807d-4a96-a756-ab13c427fde5","types.ts","97142e32-8d91-11f1-bf9d-1607ee4eb77e",15,["D",1785579715387],"script","// ============================================================\n// AI Tender Core — Domain Types & Interfaces\n// ============================================================\n\nexport type TenderStatus =\n | \"draft\"\n | \"active\"\n | \"submitted\"\n | \"won\"\n | \"lost\"\n | \"cancelled\";\n\nexport type TenderType = \"government\" | \"commercial\" | \"corporate\";\n\n// ── Автоматизация участия ───────────────────────────────────\nexport type ParticipationStage =\n | \"found\" // найден парсером\n | \"analysing\" // AI анализирует\n | \"approved\" // решение участвовать\n | \"preparing\" // готовим документы\n | \"ready\" // документы готовы\n | \"submitted\" // заявка подана\n | \"rejected\"; // отказ от участия\n\nexport interface Tender {\n id: string;\n title: string;\n description: string;\n customer: string;\n type: TenderType;\n status: TenderStatus;\n budget: number;\n currency: string;\n deadline: string;\n source?: string; // площадка-источник\n source_url?: string; // ссылка на тендер\n external_id?: string; // ID на площадке\n region?: string; // регион\n okpd?: string; // код ОКПД2\n created_at: string;\n updated_at: string;\n}\n\nexport interface TenderFilters {\n status?: string;\n type?: string;\n search?: string;\n}\n\nexport interface TenderInput {\n title: string;\n description: string;\n customer: string;\n type: TenderType;\n status: TenderStatus;\n budget: number;\n currency: string;\n deadline: string;\n source?: string;\n source_url?: string;\n external_id?: string;\n region?: string;\n okpd?: string;\n}\n\n// ── Контакты заказчиков ─────────────────────────────────────\nexport interface TenderContact {\n id: string;\n tender_id: string;\n person_name: string;\n role: string; // контактное лицо / уполномоченный орган\n email: string;\n phone: string;\n organization: string;\n address: string;\n created_at: string;\n}\n\n// ── Задачи автоматизации ────────────────────────────────────\nexport interface AutomationTask {\n id: string;\n tender_id: string;\n stage: ParticipationStage;\n title: string;\n description: string;\n due_date: string;\n completed: boolean;\n completed_at?: string;\n ai_generated: boolean;\n created_at: string;\n}\n\nexport interface ChecklistItem {\n id: string;\n tender_id: string;\n label: string;\n required: boolean;\n done: boolean;\n sort_order: number;\n}\n\n// ── Результаты парсинга ─────────────────────────────────────\nexport interface ParsedTender {\n external_id: string;\n source: string;\n source_url: string;\n title: string;\n description: string;\n customer: string;\n type: TenderType;\n budget: number;\n currency: string;\n deadline: string;\n region: string;\n okpd: string;\n contacts: ParsedContact[];\n}\n\nexport interface ParsedContact {\n person_name: string;\n role: string;\n email: string;\n phone: string;\n organization: string;\n address: string;\n}\n\nexport interface SearchParams {\n query: string;\n region?: string;\n type?: TenderType;\n minBudget?: number;\n maxBudget?: number;\n okpd?: string;\n}\n\nexport interface SearchResult {\n tenders: ParsedTender[];\n total: number;\n source: string;\n error?: string;\n}\n\n// ── Dashboard ───────────────────────────────────────────────\nexport interface DashboardStats {\n total: number;\n active: number;\n submitted: number;\n won: number;\n lost: number;\n totalBudget: number;\n wonBudget: number;\n avgBudget: number;\n winRate: number;\n byType: { type: string; count: number; budget: number }[];\n byStatus: { status: string; count: number }[];\n}\n\nexport interface ApiResponse {\n success: boolean;\n data?: T;\n error?: string;\n}\n\n// Module registry interface\nexport interface IModule {\n name: string;\n init(): Promise;\n}\n",[],[67,108],"00abb554-2fe6-4e58-a65a-d07e5ec949cd","service.ts","b5a5cc2a-8d91-11f1-bf1e-1607ee4eb77e",6,["D",1785579238241],"// ============================================================\n// AI Tender Core — Service Layer\n// Business logic lives here; depends on repository interface\n// (Dependency Injection / SOLID — D at work).\n// ============================================================\n\nimport type {\n Tender,\n TenderFilters,\n TenderInput,\n DashboardStats,\n} from \"./types.ts\";\nimport type { ITenderRepository } from \"./repository.ts\";\n\nexport class TenderService {\n constructor(private repo: ITenderRepository) {}\n\n async list(filters?: TenderFilters): Promise {\n return this.repo.findAll(filters);\n }\n\n async get(id: string): Promise {\n return this.repo.findById(id);\n }\n\n async create(data: TenderInput): Promise {\n const now = new Date().toISOString();\n const tender: Tender = {\n ...data,\n id: crypto.randomUUID(),\n created_at: now,\n updated_at: now,\n };\n return this.repo.create(tender);\n }\n\n async update(id: string, data: Partial): Promise {\n return this.repo.update(id, data);\n }\n\n async delete(id: string): Promise {\n return this.repo.delete(id);\n }\n\n async getStats(): Promise {\n const all = await this.repo.findAll();\n const active = all.filter((t) => t.status === \"active\");\n const submitted = all.filter((t) => t.status === \"submitted\");\n const won = all.filter((t) => t.status === \"won\");\n const lost = all.filter((t) => t.status === \"lost\");\n\n const typeMap = new Map();\n const statusMap = new Map();\n\n for (const t of all) {\n const tv = typeMap.get(t.type) ?? { count: 0, budget: 0 };\n tv.count++;\n tv.budget += t.budget;\n typeMap.set(t.type, tv);\n\n statusMap.set(t.status, (statusMap.get(t.status) ?? 0) + 1);\n }\n\n const decided = won.length + lost.length;\n\n return {\n total: all.length,\n active: active.length,\n submitted: submitted.length,\n won: won.length,\n lost: lost.length,\n totalBudget: all.reduce((s, t) => s + t.budget, 0),\n wonBudget: won.reduce((s, t) => s + t.budget, 0),\n avgBudget: all.length > 0\n ? Math.round(all.reduce((s, t) => s + t.budget, 0) / all.length)\n : 0,\n winRate: decided > 0 ? Math.round((won.length / decided) * 100) : 0,\n byType: Array.from(typeMap.entries()).map(([type, v]) => ({\n type,\n ...v,\n })),\n byStatus: Array.from(statusMap.entries()).map(([status, count]) => ({\n status,\n count,\n })),\n };\n }\n}\n",[],[67,117],"7ebed65f-4486-49ed-bde9-da1a7eee778e","repository.ts","b119ca76-8d91-11f1-af06-1607ee4eb77e",["D",1785579230612],"// ============================================================\n// AI Tender Core — Repository Pattern\n// Abstracts data access; swap implementations without touching\n// the service layer.\n// ============================================================\n\nimport { sqlite } from \"./db.ts\";\nimport type { Tender, TenderFilters } from \"./types.ts\";\n\nexport interface ITenderRepository {\n findAll(filters?: TenderFilters): Promise;\n findById(id: string): Promise;\n create(tender: Tender): Promise;\n update(id: string, updates: Partial): Promise;\n delete(id: string): Promise;\n}\n\nexport class TenderRepository implements ITenderRepository {\n async findAll(filters?: TenderFilters): Promise {\n let sql = \"SELECT * FROM tenders\";\n const conditions: string[] = [];\n const args: (string | number)[] = [];\n\n if (filters?.status) {\n conditions.push(\"status = ?\");\n args.push(filters.status);\n }\n if (filters?.type) {\n conditions.push(\"type = ?\");\n args.push(filters.type);\n }\n if (filters?.search) {\n conditions.push(\n \"(title LIKE ? OR customer LIKE ? OR description LIKE ?)\",\n );\n const s = `%${filters.search}%`;\n args.push(s, s, s);\n }\n\n if (conditions.length > 0) {\n sql += \" WHERE \" + conditions.join(\" AND \");\n }\n sql += \" ORDER BY datetime(created_at) DESC\";\n\n const result = await sqlite.execute({ sql, args });\n return result.rows as unknown as Tender[];\n }\n\n async findById(id: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tenders WHERE id = ?\",\n args: [id],\n });\n return (result.rows[0] as unknown as Tender) ?? null;\n }\n\n async create(tender: Tender): Promise {\n await sqlite.execute({\n sql: `INSERT INTO tenders\n (id, title, description, customer, type, status, budget, currency, deadline, created_at, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n tender.id,\n tender.title,\n tender.description,\n tender.customer,\n tender.type,\n tender.status,\n tender.budget,\n tender.currency,\n tender.deadline,\n tender.created_at,\n tender.updated_at,\n ],\n });\n return tender;\n }\n\n async update(id: string, updates: Partial): Promise {\n const existing = await this.findById(id);\n if (!existing) return null;\n\n const updated: Tender = {\n ...existing,\n ...updates,\n id: existing.id,\n created_at: existing.created_at,\n updated_at: new Date().toISOString(),\n };\n\n await sqlite.execute({\n sql: `UPDATE tenders SET\n title = ?, description = ?, customer = ?, type = ?, status = ?,\n budget = ?, currency = ?, deadline = ?, updated_at = ?\n WHERE id = ?`,\n args: [\n updated.title,\n updated.description,\n updated.customer,\n updated.type,\n updated.status,\n updated.budget,\n updated.currency,\n updated.deadline,\n updated.updated_at,\n id,\n ],\n });\n return updated;\n }\n\n async delete(id: string): Promise {\n await sqlite.execute({\n sql: \"DELETE FROM tenders WHERE id = ?\",\n args: [id],\n });\n return true;\n }\n}\n",[],[67,125],"7bebb874-afa4-4b41-a5fd-6b46424b8e37","parser.ts","0e8d7670-8d93-11f1-a271-1607ee4eb77e",18,["D",1785579816860],"// ============================================================\n// AI Tender Core — Parser Module\n// Поиск тендеров на агрегаторах и площадках.\n// Источники: Закупки.гов.ру (ЕИС), B2B-Center, РТС-тендер,\n// Sber-Tenders, TenderShop.\n// Каждый источник — отдельный адаптер (Adapter Pattern).\n// Новый источник = новый класс, реализующий ISourceAdapter.\n// ============================================================\n\nimport type {\n SearchParams,\n SearchResult,\n ParsedTender,\n ParsedContact,\n TenderType,\n} from \"./types.ts\";\nimport { getIntegration } from \"./integrations.ts\";\n\n// ── Интерфейс адаптера источника ─────────────────────────────\nexport interface ISourceAdapter {\n sourceId: string;\n sourceName: string;\n search(params: SearchParams): Promise;\n}\n\n// ── Утилиты извлечения ───────────────────────────────────────\n\nfunction extractEmails(text: string): string[] {\n const matches = text.match(/[\\w.+-]+@[\\w-]+\\.[\\w.-]+/g);\n return matches ? [...new Set(matches)] : [];\n}\n\nfunction extractPhones(text: string): string[] {\n const matches = text.match(\n /(?:\\+7|8|7)?[\\s(-]?\\d{3}[\\s)-]?\\d{3}[\\s-]?\\d{2}[\\s-]?\\d{2}/g,\n );\n return matches ? [...new Set(matches.map((p) => p.trim()))] : [];\n}\n\nfunction extractContactPerson(text: string): string {\n // Ищем паттерны: \"Контактное лицо: Иванов И.И.\"\n const patterns = [\n /контактное\\s+лицо[:\\s]+([^\\n,]{3,60})/i,\n /ответственное\\s+лицо[:\\s]+([^\\n,]{3,60})/i,\n /ФИО[:\\s]+([^\\n,]{3,60})/i,\n /связи\\s+с[:\\s]+([^\\n,]{3,60})/i,\n ];\n for (const p of patterns) {\n const m = text.match(p);\n if (m) return m[1].trim();\n }\n return \"\";\n}\n\nfunction extractBudget(text: string): number {\n // Ищем суммы: \"1 500 000,00\", \"1500000 руб\"\n const patterns = [\n /(\\d[\\d\\s]{2,}(?:,\\d+)?)\\s*(?:руб|₽|р\\.)/i,\n /начальная(?:\\s+максимальная)?\\s+цена[:\\s]*(\\d[\\d\\s]+)/i,\n /НМЦ[КД]?[:\\s]*(\\d[\\d\\s]+)/i,\n /бюджет[:\\s]*(\\d[\\d\\s]+)/i,\n ];\n for (const p of patterns) {\n const m = text.match(p);\n if (m) {\n const num = parseInt(m[1].replace(/[\\s,]/g, \"\"), 10);\n if (num > 0) return num;\n }\n }\n return 0;\n}\n\nfunction extractDeadline(text: string): string {\n const patterns = [\n /окончание\\s+(?:приема|подачи)[^\\d]*(\\d{2}[\\./]\\d{2}[\\./]\\d{4})/i,\n /дедлайн[^\\d]*(\\d{2}[\\./]\\d{2}[\\./]\\d{4})/i,\n /до\\s+(\\d{2}[\\./]\\d{2}[\\./]\\d{4})/i,\n /deadline[^\\d]*(\\d{4}-\\d{2}-\\d{2})/i,\n ];\n for (const p of patterns) {\n const m = text.match(p);\n if (m) {\n const date = m[1].replace(/\\./g, \"-\");\n // dd-mm-yyyy → yyyy-mm-dd\n if (/^\\d{2}-\\d{2}-\\d{4}$/.test(date)) {\n const [d, mo, y] = date.split(\"-\");\n return `${y}-${mo}-${d}`;\n }\n return date;\n }\n }\n return \"\";\n}\n\nfunction extractOKPD(text: string): string {\n const m = text.match(/ОКПД2?[:\\s]*([\\d.]+)/i);\n return m ? m[1] : \"\";\n}\n\nfunction extractContacts(html: string, org: string): ParsedContact[] {\n const emails = extractEmails(html);\n const phones = extractPhones(html);\n const person = extractContactPerson(html);\n\n if (!emails.length && !phones.length && !person) return [];\n\n return [{\n person_name: person,\n role: \"Контактное лицо\",\n email: emails[0] || \"\",\n phone: phones[0] || \"\",\n organization: org,\n address: \"\",\n }];\n}\n\nfunction stripHtml(html: string): string {\n return html\n .replace(//gi, \"\")\n .replace(//gi, \"\")\n .replace(/<[^>]+>/g, \" \")\n .replace(/ /g, \" \")\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/"/g, '\"')\n .replace(/\\s{2,}/g, \" \")\n .trim();\n}\n\n// ── Адаптер: Закупки.гов.ру (ЕИС) ────────────────────────────\n// Использует API ЕИС (если настроен токен) или парсит публичные страницы.\n\nclass ZakupkiAdapter implements ISourceAdapter {\n sourceId = \"zakupki\";\n sourceName = \"Закупки.гов.ру (ЕИС)\";\n\n async search(params: SearchParams): Promise {\n const config = await getIntegration(\"zakupki\");\n const token = config?.config?.values.apiToken;\n const region = params.region || config?.config?.values.regionCode || \"\";\n\n try {\n // Если есть API-токен — используем API ЕИС\n if (token) {\n return await this.searchViaAPI(params, token, region);\n }\n // Иначе — парсим публичный RSS/Atom фид zakupki.gov.ru\n return await this.searchViaRSS(params, region);\n } catch (err) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `Ошибка: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n }\n\n private async searchViaAPI(\n params: SearchParams,\n token: string,\n region: string,\n ): Promise {\n const apiUrl = new URL(\"https://zakupki.gov.ru/api/issues/search\");\n apiUrl.searchParams.set(\"text\", params.query);\n if (region) apiUrl.searchParams.set(\"regionCode\", region);\n if (params.minBudget) apiUrl.searchParams.set(\"budgetFrom\", String(params.minBudget));\n if (params.maxBudget) apiUrl.searchParams.set(\"budgetTo\", String(params.maxBudget));\n apiUrl.searchParams.set(\"pageSize\", \"20\");\n\n const res = await fetch(apiUrl, {\n headers: { Authorization: `Bearer ${token}` },\n });\n\n if (!res.ok) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `API вернул HTTP ${res.status}`,\n };\n }\n\n const data = await res.json() as any;\n const items = data?.issues ?? data?.results ?? [];\n\n const tenders: ParsedTender[] = items.map((item: any) => {\n const html = JSON.stringify(item);\n const text = stripHtml(html);\n return {\n external_id: item.id || item.regNumber || \"\",\n source: this.sourceId,\n source_url: item.url || `https://zakupki.gov.ru/epz/order/notice/view/common-info.html?regNumber=${item.regNumber || item.id}`,\n title: item.title || item.name || \"Без названия\",\n description: item.description || stripHtml(item.body || \"\"),\n customer: item.organization?.fullName || item.customer || \"\",\n type: \"government\" as TenderType,\n budget: extractBudget(text) || item.budget || 0,\n currency: \"RUB\",\n deadline: extractDeadline(text) || item.endDate || \"\",\n region: region,\n okpd: extractOKPD(text),\n contacts: extractContacts(html, item.organization?.fullName || \"\"),\n };\n });\n\n return {\n tenders,\n total: data?.total ?? tenders.length,\n source: this.sourceName,\n };\n }\n\n private async searchViaRSS(\n params: SearchParams,\n region: string,\n ): Promise {\n // Публичный фид уведомлений ЕИС (44-ФЗ)\n const feedUrl = new URL(\"https://zakupki.gov.ru/published/public/agency01/rss/rss2.xml\");\n if (region) feedUrl.searchParams.set(\"regionCode\", region);\n\n const res = await fetch(feedUrl.toString(), {\n headers: { \"Accept\": \"application/xml, text/xml\" },\n });\n\n if (!res.ok) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `RSS недоступен (HTTP ${res.status}). Настройте API-токен ЕИС в Интеграциях.`,\n };\n }\n\n const xml = await res.text();\n const text = stripHtml(xml);\n\n // Парсим из RSS\n const items = xml.match(/[\\s\\S]*?<\\/item>/gi) || [];\n const tenders: ParsedTender[] = [];\n\n for (const itemXml of items.slice(0, 20)) {\n const title = itemXml.match(/<!\\[CDATA\\[([\\s\\S]*?)\\]\\]><\\/title>/i)?.[1] ||\n itemXml.match(/<title>([\\s\\S]*?)<\\/title>/i)?.[1] || \"\";\n const link = itemXml.match(/<link>([\\s\\S]*?)<\\/link>/i)?.[1]?.trim() || \"\";\n const desc = itemXml.match(/<description><!\\[CDATA\\[([\\s\\S]*?)\\]\\]><\\/description>/i)?.[1] ||\n itemXml.match(/<description>([\\s\\S]*?)<\\/description>/i)?.[1] || \"\";\n const pubDate = itemXml.match(/<pubDate>([\\s\\S]*?)<\\/pubDate>/i)?.[1]?.trim() || \"\";\n\n // Фильтр по запросу\n if (params.query && !title.toLowerCase().includes(params.query.toLowerCase()) &&\n !desc.toLowerCase().includes(params.query.toLowerCase())) {\n continue;\n }\n\n const fullText = stripHtml(title + \" \" + desc);\n tenders.push({\n external_id: link.split(\"regNumber=\").pop()?.split(\"&\")[0] || link,\n source: this.sourceId,\n source_url: link,\n title: title.trim(),\n description: stripHtml(desc).slice(0, 500),\n customer: extractContactPerson(text) || \"Заказчик ЕИС\",\n type: \"government\",\n budget: extractBudget(fullText),\n currency: \"RUB\",\n deadline: extractDeadline(fullText) || pubDate,\n region,\n okpd: extractOKPD(fullText),\n contacts: extractContacts(desc, \"\"),\n });\n }\n\n return { tenders, total: tenders.length, source: this.sourceName };\n }\n}\n\n// ── Адаптер: B2B-Center ──────────────────────────────────────\n\nclass B2BCenterAdapter implements ISourceAdapter {\n sourceId = \"b2b-center\";\n sourceName = \"B2B-Center\";\n\n async search(params: SearchParams): Promise<SearchResult> {\n try {\n // B2B-Center открытый API поиска\n const url = new URL(\"https://www.b2b-center.ru/api/v1/tenders/search\");\n url.searchParams.set(\"keywords\", params.query);\n if (params.region) url.searchParams.set(\"region\", params.region);\n url.searchParams.set(\"limit\", \"20\");\n\n const res = await fetch(url.toString(), {\n headers: { \"Accept\": \"application/json\" },\n });\n\n if (!res.ok) {\n // Fallback: парсим публичную страницу\n return await this.searchViaWeb(params);\n }\n\n const data = await res.json() as any;\n const items = data?.tenders ?? data?.data ?? [];\n\n const tenders: ParsedTender[] = items.map((item: any) => ({\n external_id: String(item.id || \"\"),\n source: this.sourceId,\n source_url: item.url || `https://www.b2b-center.ru/tender/${item.id}/`,\n title: item.title || item.name || \"\",\n description: item.description || \"\",\n customer: item.customer || item.organization || \"\",\n type: \"commercial\" as TenderType,\n budget: item.budget || item.price || 0,\n currency: item.currency || \"RUB\",\n deadline: item.endDate || item.deadline || \"\",\n region: item.region || params.region || \"\",\n okpd: item.okpd || \"\",\n contacts: extractContacts(JSON.stringify(item), item.customer || \"\"),\n }));\n\n return { tenders, total: tenders.length, source: this.sourceName };\n } catch (err) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `Ошибка: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n }\n\n private async searchViaWeb(params: SearchParams): Promise<SearchResult> {\n const url = `https://www.b2b-center.ru/search/?q=${encodeURIComponent(params.query)}`;\n try {\n const res = await fetch(url);\n if (!res.ok) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `Сайт недоступен (HTTP ${res.status})`,\n };\n }\n const html = await res.text();\n // Извлекаем ссылки на тендеры\n const links = [...html.matchAll(/href=\"(\\/tender\\/\\d+[^\"]*)\"/g)].map((m) => m[1]);\n const titles = [...html.matchAll(/<a[^>]*href=\"\\/tender\\/\\d+[^\"]*\"[^>]*>([^<]+)<\\/a>/g)].map((m) => m[1].trim());\n\n const tenders: ParsedTender[] = [];\n for (let i = 0; i < Math.min(links.length, 15); i++) {\n tenders.push({\n external_id: links[i].match(/\\d+/)?.[0] || \"\",\n source: this.sourceId,\n source_url: `https://www.b2b-center.ru${links[i]}`,\n title: titles[i] || \"Тендер B2B-Center\",\n description: \"\",\n customer: \"\",\n type: \"commercial\",\n budget: 0,\n currency: \"RUB\",\n deadline: \"\",\n region: params.region || \"\",\n okpd: \"\",\n contacts: [],\n });\n }\n return { tenders, total: tenders.length, source: this.sourceName };\n } catch {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: \"Не удалось получить данные\",\n };\n }\n }\n}\n\n// ── Адаптер: РТС-тендер ──────────────────────────────────────\n\nclass RTSTenderAdapter implements ISourceAdapter {\n sourceId = \"rts-tender\";\n sourceName = \"РТС-тендер\";\n\n async search(params: SearchParams): Promise<SearchResult> {\n try {\n const url = new URL(\"https://api.rts-tender.ru/v1/tenders\");\n url.searchParams.set(\"search\", params.query);\n url.searchParams.set(\"pageSize\", \"20\");\n if (params.region) url.searchParams.set(\"region\", params.region);\n\n const res = await fetch(url.toString());\n\n if (!res.ok) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `API недоступен (HTTP ${res.status})`,\n };\n }\n\n const data = await res.json() as any;\n const items = data?.items ?? data?.tenders ?? [];\n\n const tenders: ParsedTender[] = items.map((item: any) => ({\n external_id: String(item.id || item.regNumber || \"\"),\n source: this.sourceId,\n source_url: item.url || `https://www.rts-tender.ru/tender/${item.id}`,\n title: item.title || item.name || \"\",\n description: item.description || item.info || \"\",\n customer: item.customer || item.organizer || \"\",\n type: \"government\" as TenderType,\n budget: item.budget || item.maxPrice || 0,\n currency: \"RUB\",\n deadline: item.endDate || item.deadline || \"\",\n region: item.region || params.region || \"\",\n okpd: item.okpd2 || item.okpd || \"\",\n contacts: extractContacts(JSON.stringify(item), item.customer || \"\"),\n }));\n\n return { tenders, total: tenders.length, source: this.sourceName };\n } catch (err) {\n return {\n tenders: [],\n total: 0,\n source: this.sourceName,\n error: `Ошибка: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n }\n}\n\n// ── Реестр адаптеров ─────────────────────────────────────────\n// Новый источник = добавить класс сюда. Ядро не меняется.\n\nconst ADAPTERS: ISourceAdapter[] = [\n new ZakupkiAdapter(),\n new B2BCenterAdapter(),\n new RTSTenderAdapter(),\n];\n\nexport function getAvailableSources(): { id: string; name: string }[] {\n return ADAPTERS.map((a) => ({ id: a.sourceId, name: a.sourceName }));\n}\n\n// ── Поиск по всем источникам ─────────────────────────────────\n\nexport async function searchAllSources(\n params: SearchParams,\n): Promise<SearchResult[]> {\n const results = await Promise.allSettled(\n ADAPTERS.map((a) => a.search(params)),\n );\n\n return results.map((r, i) => {\n if (r.status === \"fulfilled\") return r.value;\n return {\n tenders: [],\n total: 0,\n source: ADAPTERS[i].sourceName,\n error: r.reason?.message || \"Ошибка запроса\",\n };\n });\n}\n\n// ── Поиск по конкретному источнику ───────────────────────────\n\nexport async function searchBySource(\n sourceId: string,\n params: SearchParams,\n): Promise<SearchResult> {\n const adapter = ADAPTERS.find((a) => a.sourceId === sourceId);\n if (!adapter) {\n return {\n tenders: [],\n total: 0,\n source: \"unknown\",\n error: \"Источник не найден\",\n };\n }\n return adapter.search(params);\n}\n\n// ── Импорт найденного тендера в БД ───────────────────────────\n\nexport async function importParsedTender(\n parsed: ParsedTender,\n service: { create: (data: any) => Promise<any> },\n): Promise<string> {\n const tender = await service.create({\n title: parsed.title,\n description: parsed.description,\n customer: parsed.customer,\n type: parsed.type,\n status: \"active\",\n budget: parsed.budget,\n currency: parsed.currency,\n deadline: parsed.deadline,\n source: parsed.source,\n source_url: parsed.source_url,\n external_id: parsed.external_id,\n region: parsed.region,\n okpd: parsed.okpd,\n });\n return tender.id;\n}\n",[],[67,132],"f6598af3-bacb-40d3-8a52-619960501202","integrations.ts","122142cc-8d92-11f1-9708-1607ee4eb77e",30,["D",1785580031146],2,"// ============================================================\n// AI Tender Core — Integration Manager\n// Управление API-ключами и подключениями прямо из UI.\n// Ключи хранятся в blob storage (project-scoped).\n// Новые интеграции добавляются в реестр — без изменения ядра.\n// ============================================================\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst BLOB_KEY = \"integrations_config\";\n\n// ── Типы ────────────────────────────────────────────────────\n\nexport interface IntegrationField {\n key: string;\n label: string;\n type: \"text\" | \"password\" | \"url\" | \"number\";\n placeholder?: string;\n required: boolean;\n description?: string;\n}\n\nexport interface IntegrationDef {\n id: string;\n name: string;\n icon: string; // emoji\n category: string;\n description: string;\n fields: IntegrationField[];\n testUrl?: string; // endpoint для проверки соединения\n docsUrl?: string;\n}\n\nexport interface IntegrationConfig {\n id: string;\n enabled: boolean;\n values: Record<string, string>;\n updatedAt: string;\n}\n\n// ── Реестр интеграций ────────────────────────────────────────\n// Новые интеграции добавляются сюда — ядро не меняется.\n\nexport const INTEGRATIONS: IntegrationDef[] = [\n {\n id: \"zakupki\",\n name: \"Закупки.гов.ру (ЕИС)\",\n icon: \"🏛️\",\n category: \"Тендерные площадки\",\n description: \"Поиск государственных закупок через API ЕИС\",\n docsUrl: \"https://zakupki.gov.ru\",\n fields: [\n {\n key: \"apiToken\",\n label: \"API-токен ЕИС\",\n type: \"password\",\n placeholder: \"xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx\",\n required: true,\n description: \"Токен для доступа к API ЕИС (раздел «Личный кабинет» → «Настройки»)\",\n },\n {\n key: \"regionCode\",\n label: \"Код региона\",\n type: \"text\",\n placeholder: \"77\",\n required: false,\n description: \"Фильтр по региону (например: 77 — Москва)\",\n },\n ],\n },\n {\n id: \"bitrix24\",\n name: \"Bitrix24\",\n icon: \"🔄\",\n category: \"CRM-системы\",\n description: \"Интеграция с CRM Bitrix24: сделки, контакты, автоматизация\",\n docsUrl: \"https://dev.1c-bitrix.ru/rest_help/\",\n fields: [\n {\n key: \"webhookUrl\",\n label: \"URL входящего вебхука\",\n type: \"url\",\n placeholder: \"https://yourcompany.bitrix24.ru/rest/1/xxxxxxxx/\",\n required: true,\n description: \"Создайте вебхук: Приложения → Разработчикам → Входящий вебхук\",\n },\n ],\n },\n {\n id: \"amocrm\",\n name: \"amoCRM\",\n icon: \"📊\",\n category: \"CRM-системы\",\n description: \"Интеграция с amoCRM для управления сделками и клиентами\",\n docsUrl: \"https://www.amocrm.ru/developers/\",\n fields: [\n {\n key: \"subdomain\",\n label: \"Поддомен amoCRM\",\n type: \"text\",\n placeholder: \"yourcompany\",\n required: true,\n description: \"Часть URL до .amocrm.ru\",\n },\n {\n key: \"accessToken\",\n label: \"Access Token\",\n type: \"password\",\n placeholder: \"eyJhbGciOi...\",\n required: true,\n description: \"Токен авторизации (Long-lived token)\",\n },\n ],\n },\n {\n id: \"onec\",\n name: \"1С: Предприятие\",\n icon: \"🔢\",\n category: \"ERP / Учёт\",\n description: \"Обмен данными с 1С: заказы, документы, остатки\",\n docsUrl: \"https://its.1c.ru\",\n fields: [\n {\n key: \"baseUrl\",\n label: \"Базовый URL HTTP-сервиса\",\n type: \"url\",\n placeholder: \"http://1c-server/base/hs/tender/\",\n required: true,\n },\n {\n key: \"username\",\n label: \"Пользователь\",\n type: \"text\",\n placeholder: \"Администратор\",\n required: true,\n },\n {\n key: \"password\",\n label: \"Пароль\",\n type: \"password\",\n placeholder: \"••••••••\",\n required: true,\n },\n ],\n },\n {\n id: \"telegram\",\n name: \"Telegram Bot\",\n icon: \"💬\",\n category: \"Уведомления / Боты\",\n description: \"Бот для уведомлений о новых тендерах и изменениях статусов\",\n docsUrl: \"https://core.telegram.org/bots/api\",\n fields: [\n {\n key: \"botToken\",\n label: \"Bot Token\",\n type: \"password\",\n placeholder: \"123456789:ABCdefGHIjklMNOpqrsTUVwxyz\",\n required: true,\n description: \"Токен от @BotFather\",\n },\n {\n key: \"chatId\",\n label: \"Chat ID для уведомлений\",\n type: \"text\",\n placeholder: \"-1001234567890\",\n required: true,\n description: \"ID группы или канала (узнать у @userinfobot)\",\n },\n ],\n },\n {\n id: \"openai\",\n name: \"AI Tender Agent (OpenAI)\",\n icon: \"🤖\",\n category: \"AI-сервисы\",\n description: \"AI-агент: анализ тендеров, оценка рисков, генерация ТЗ\",\n docsUrl: \"https://platform.openai.com/api-keys\",\n fields: [\n {\n key: \"apiKey\",\n label: \"OpenAI API Key\",\n type: \"password\",\n placeholder: \"sk-...\",\n required: true,\n description: \"Ключ для GPT-4 / GPT-4o. Получить: platform.openai.com/api-keys\",\n },\n {\n key: \"model\",\n label: \"Модель\",\n type: \"text\",\n placeholder: \"gpt-4o\",\n required: false,\n description: \"По умолчанию: gpt-4o\",\n },\n ],\n },\n {\n id: \"n8n\",\n name: \"n8n Workflow\",\n icon: \"⚡\",\n category: \"Автоматизация\",\n description: \"Webhook для запуска n8n-сценариев при событиях в тендерах\",\n docsUrl: \"https://docs.n8n.io\",\n fields: [\n {\n key: \"webhookUrl\",\n label: \"Webhook URL n8n\",\n type: \"url\",\n placeholder: \"https://n8n.yourdomain.com/webhook/tender-event\",\n required: true,\n },\n ],\n },\n {\n id: \"apify\",\n name: \"Apify (скрапинг)\",\n icon: \"🕷️\",\n category: \"Сбор данных\",\n description: \"Параллельный сбор данных с тендерных площадок через Apify\",\n docsUrl: \"https://docs.apify.com\",\n fields: [\n {\n key: \"apiToken\",\n label: \"Apify API Token\",\n type: \"password\",\n placeholder: \"apify_api_xxxxx\",\n required: true,\n description: \"Токен: console.apify.com → Settings → API tokens\",\n },\n ],\n },\n {\n id: \"ocr\",\n name: \"OCR-сервис\",\n icon: \"📄\",\n category: \"AI-сервисы\",\n description: \"Распознавание текста из PDF/изображений тендерной документации\",\n docsUrl: \"https://ocr.space/ocrapi\",\n fields: [\n {\n key: \"apiKey\",\n label: \"API Key\",\n type: \"password\",\n placeholder: \"K123456789012\",\n required: true,\n description: \"Ключ ocr.space или Yandex Vision API\",\n },\n {\n key: \"serviceUrl\",\n label: \"URL сервиса (опционально)\",\n type: \"url\",\n placeholder: \"https://api.ocr.space/parse/image\",\n required: false,\n },\n ],\n },\n];\n\n// ── Менеджер конфигураций ───────────────────────────────────\n\nasync function loadAllConfigs(): Promise<Record<string, IntegrationConfig>> {\n try {\n return (await blob.getJSON(BLOB_KEY)) as Record<string, IntegrationConfig>;\n } catch {\n return {};\n }\n}\n\nasync function saveAllConfigs(configs: Record<string, IntegrationConfig>): Promise<void> {\n await blob.setJSON(BLOB_KEY, configs);\n}\n\n// ── API ─────────────────────────────────────────────────────\n\nexport async function listIntegrations(): Promise<\n { def: IntegrationDef; config: IntegrationConfig | null }[]\n> {\n const configs = await loadAllConfigs();\n return INTEGRATIONS.map((def) => ({\n def,\n config: configs[def.id] ?? null,\n }));\n}\n\nexport async function getIntegration(id: string): Promise<{\n def: IntegrationDef;\n config: IntegrationConfig | null;\n} | null> {\n const def = INTEGRATIONS.find((i) => i.id === id);\n if (!def) return null;\n const configs = await loadAllConfigs();\n return { def, config: configs[id] ?? null };\n}\n\nexport async function saveIntegration(\n id: string,\n values: Record<string, string>,\n): Promise<IntegrationConfig> {\n const configs = await loadAllConfigs();\n const config: IntegrationConfig = {\n id,\n enabled: true,\n values,\n updatedAt: new Date().toISOString(),\n };\n configs[id] = config;\n await saveAllConfigs(configs);\n return config;\n}\n\nexport async function toggleIntegration(\n id: string,\n enabled: boolean,\n): Promise<IntegrationConfig | null> {\n const configs = await loadAllConfigs();\n if (!configs[id]) return null;\n configs[id].enabled = enabled;\n configs[id].updatedAt = new Date().toISOString();\n await saveAllConfigs(configs);\n return configs[id];\n}\n\nexport async function deleteIntegration(id: string): Promise<boolean> {\n const configs = await loadAllConfigs();\n delete configs[id];\n await saveAllConfigs(configs);\n return true;\n}\n\n// ── Проверка соединения ──────────────────────────────────────\n\nexport async function testIntegration(\n id: string,\n): Promise<{ success: boolean; message: string }> {\n const data = await getIntegration(id);\n if (!data || !data.config) {\n return { success: false, message: \"Интеграция не настроена\" };\n }\n\n const { def, config } = data;\n if (!config.enabled) {\n return { success: false, message: \"Интеграция отключена\" };\n }\n\n try {\n switch (id) {\n case \"telegram\": {\n const token = config.values.botToken;\n const res = await fetch(\n `https://api.telegram.org/bot${token}/getMe`,\n );\n const json = await res.json();\n if (json.ok) {\n return {\n success: true,\n message: `Бот @${json.result.username} активен`,\n };\n }\n return { success: false, message: json.description || \"Ошибка API\" };\n }\n\n case \"openai\": {\n const res = await fetch(\"https://api.openai.com/v1/models\", {\n headers: { Authorization: `Bearer ${config.values.apiKey}` },\n });\n if (res.ok) {\n return { success: true, message: \"API ключ действителен\" };\n }\n return { success: false, message: `HTTP ${res.status}: неверный ключ` };\n }\n\n case \"bitrix24\": {\n const url = config.values.webhookUrl;\n const testUrl = url.endsWith(\"/\")\n ? url + \"profile\"\n : url + \"/profile\";\n const res = await fetch(testUrl);\n if (res.ok) {\n return { success: true, message: \"Bitrix24 доступен\" };\n }\n return { success: false, message: `HTTP ${res.status}` };\n }\n\n case \"n8n\": {\n const res = await fetch(config.values.webhookUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ test: true, source: \"ai-tender-core\" }),\n });\n if (res.ok) {\n return { success: true, message: \"n8n вебхук отвечает\" };\n }\n return { success: false, message: `HTTP ${res.status}` };\n }\n\n case \"ocr\": {\n const url = config.values.serviceUrl ||\n \"https://api.ocr.space/parse/image\";\n const res = await fetch(url, {\n method: \"POST\",\n headers: { apikey: config.values.apiKey },\n body: new URLSearchParams({\n url: \"https://example.com/test.png\",\n language: \"rus\",\n }),\n });\n const json = await res.json() as { OCRExitCode?: number };\n if (json.OCRExitCode === 1) {\n return { success: true, message: \"OCR-сервис работает\" };\n }\n return { success: false, message: \"Сервис ответил, проверьте ключ\" };\n }\n\n case \"apify\": {\n const res = await fetch(`https://api.apify.com/v2/users/me?token=${config.values.apiToken}`);\n if (res.ok) {\n const data = await res.json() as any;\n return { success: true, message: `Apify: ${data?.data?.username || \"ok\"}, тариф: ${data?.data?.plan || \"?\"}` };\n }\n return { success: false, message: `HTTP ${res.status}: неверный токен` };\n }\n\n default:\n return {\n success: true,\n message: \"Конфигурация сохранена (ручная проверка)\",\n };\n }\n } catch (err) {\n return {\n success: false,\n message: `Ошибка сети: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n}\n\n// ── Отправка уведомления в Telegram ──────────────────────────\n\nexport async function sendTelegramNotification(\n text: string,\n): Promise<boolean> {\n const data = await getIntegration(\"telegram\");\n if (!data?.config?.enabled) return false;\n\n const { botToken, chatId } = data.config.values;\n if (!botToken || !chatId) return false;\n\n try {\n const res = await fetch(\n `https://api.telegram.org/bot${botToken}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"HTML\" }),\n },\n );\n return res.ok;\n } catch {\n return false;\n }\n}\n",[],[67,140],"db9289b9-07c4-4af3-9a30-937e76fef011","email.ts","881c0dee-8d93-11f1-8187-1607ee4eb77e",28,["D",1785580020802],"// ============================================================\n// AI Tender Core — Email Module\n// Отправка email: уведомления, коммерческие предложения,\n// ответы заказчикам, рассылки. Учёт всех отправлений.\n// Использует std/email от Val Town.\n// ============================================================\n\nimport { email } from \"https://esm.town/v/std/email\";\nimport { sqlite } from \"./db.ts\";\nimport { sendTelegramNotification } from \"./integrations.ts\";\n\n// ── Типы ────────────────────────────────────────────────────\n\nexport interface EmailRecord {\n id: string;\n tender_id: string;\n to: string;\n subject: string;\n body: string;\n template: string; // \"proposal\" | \"notification\" | \"followup\" | \"custom\"\n status: string; // \"sent\" | \"failed\" | \"queued\"\n created_at: string;\n error?: string;\n}\n\n// ── Шаблоны писем ───────────────────────────────────────────\n\nexport interface EmailTemplate {\n id: string;\n name: string;\n subject: (data: TemplateData) => string;\n body: (data: TemplateData) => string;\n description: string;\n}\n\nexport interface TemplateData {\n tenderTitle?: string;\n customer?: string;\n budget?: number;\n deadline?: string;\n companyName?: string;\n contactName?: string;\n message?: string;\n [key: string]: any;\n}\n\nconst TEMPLATES: EmailTemplate[] = [\n {\n id: \"proposal\",\n name: \"Коммерческое предложение\",\n description: \"Отправка КП заказчику в ответ на тендер\",\n subject: (d) => `Коммерческое предложение: ${d.tenderTitle || \"тендер\"}`,\n body: (d) => `Здравствуйте${d.contactName ? `, ${d.contactName}` : \"\"}!\n\nНаправляем коммерческое предложение по тендеру: ${d.tenderTitle || \"\"}\n\n${d.message || \"Предлагаем наши услуги на следующих условиях:\"}\n\n${d.budget ? `Стоимость: ${d.budget.toLocaleString(\"ru-RU\")} ₽` : \"\"}\n${d.deadline ? `Срок выполнения: ${d.deadline}` : \"\"}\n\nГотовы обсудить детали и предоставить дополнительную информацию.\n\nС уважением,\n${d.companyName || \"Команда AI Tender Core\"}`,\n },\n {\n id: \"followup\",\n name: \"Follow-up (напоминание)\",\n description: \"Повторное обращение после отправки КП\",\n subject: (d) => `Re: Коммерческое предложение: ${d.tenderTitle || \"\"}`,\n body: (d) => `Здравствуйте${d.contactName ? `, ${d.contactName}` : \"\"}!\n\nНаправляем напоминание о нашем коммерческом предложении по тендеру: ${d.tenderTitle || \"\"}\n\nОтправили КП ранее и хотели бы уточнить, есть ли вопросы или требуется дополнительная информация.\n\nГотовы к диалогу и оперативному回应у.\n\nС уважением,\n${d.companyName || \"Команда AI Tender Core\"}`,\n },\n {\n id: \"notification\",\n name: \"Уведомление о статусе\",\n description: \"Уведомление об изменении статуса тендера\",\n subject: (d) => `Обновление статуса: ${d.tenderTitle || \"тендер\"}`,\n body: (d) => `Информируем об изменении статуса тендера:\n\nТендер: ${d.tenderTitle || \"\"}\n${d.message || \"Статус обновлён в системе.\"}\n\n${d.companyName || \"AI Tender Core\"}`,\n },\n {\n id: \"clarification\",\n name: \"Запрос разъяснений\",\n description: \"Запрос разъяснений по ТЗ тендера\",\n subject: (d) => `Запрос разъяснений: ${d.tenderTitle || \"тендер\"}`,\n body: (d) => `Здравствуйте${d.contactName ? `, ${d.contactName}` : \"\"}!\n\nВ связи с участием в тендере ${d.tenderTitle || \"\"} просим разъяснить следующие вопросы:\n\n${d.message || \"Просим предоставить дополнительные разъяснения по техническому заданию.\"}\n\nЗаранее благодарим за ответ.\n\nС уважением,\n${d.companyName || \"Команда AI Tender Core\"}`,\n },\n {\n id: \"custom\",\n name: \"Произвольное письмо\",\n description: \"Свободное письмо без шаблона\",\n subject: (d) => d.message?.split(\"\\n\")[0]?.slice(0, 80) || \"Сообщение\",\n body: (d) => d.message || \"\",\n },\n];\n\nexport function getTemplates(): { id: string; name: string; description: string }[] {\n return TEMPLATES.map((t) => ({\n id: t.id,\n name: t.name,\n description: t.description,\n }));\n}\n\n// ── Создание таблицы учёта писем ────────────────────────────\n\nexport async function ensureEmailTable(): Promise<void> {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS email_log (\n id TEXT PRIMARY KEY,\n tender_id TEXT DEFAULT '',\n to_email TEXT NOT NULL,\n subject TEXT NOT NULL,\n body TEXT DEFAULT '',\n template TEXT DEFAULT 'custom',\n status TEXT DEFAULT 'sent',\n error TEXT DEFAULT '',\n created_at TEXT NOT NULL\n )\n `);\n}\n\n// ── Отправка письма ─────────────────────────────────────────\n\nexport async function sendEmail(\n to: string,\n subject: string,\n body: string,\n template: string = \"custom\",\n tenderId: string = \"\",\n): Promise<{ success: boolean; id: string; error?: string }> {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n try {\n await email({\n to,\n subject,\n text: body,\n });\n\n // Логируем отправку\n await sqlite.execute({\n sql: `INSERT INTO email_log (id, tender_id, to_email, subject, body, template, status, error, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 'sent', '', ?)`,\n args: [id, tenderId, to, subject, body, template, now],\n });\n\n // Уведомление в Telegram\n await sendTelegramNotification(\n `📧 <b>Email отправлен</b>\\n👤 ${to}\\n📋 ${subject}`,\n );\n\n return { success: true, id };\n } catch (err) {\n const errorMsg = err instanceof Error ? err.message : \"unknown\";\n\n await sqlite.execute({\n sql: `INSERT INTO email_log (id, tender_id, to_email, subject, body, template, status, error, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 'failed', ?, ?)`,\n args: [id, tenderId, to, subject, body, template, errorMsg, now],\n });\n\n return { success: false, id, error: errorMsg };\n }\n}\n\n// ── Отправка по шаблону ─────────────────────────────────────\n\nexport async function sendTemplatedEmail(\n templateId: string,\n to: string,\n data: TemplateData,\n tenderId: string = \"\",\n): Promise<{ success: boolean; id: string; error?: string }> {\n const template = TEMPLATES.find((t) => t.id === templateId);\n if (!template) {\n return { success: false, id: \"\", error: \"Шаблон не найден\" };\n }\n\n const subject = template.subject(data);\n const body = template.body(data);\n\n return sendEmail(to, subject, body, templateId, tenderId);\n}\n\n// ── Массовая рассылка ───────────────────────────────────────\n\nexport async function sendBulkEmail(\n recipients: string[],\n subject: string,\n body: string,\n template: string = \"custom\",\n tenderId: string = \"\",\n): Promise<{ sent: number; failed: number; details: { email: string; success: boolean }[] }> {\n const details: { email: string; success: boolean }[] = [];\n let sent = 0;\n let failed = 0;\n\n for (const recipient of recipients) {\n const result = await sendEmail(recipient, subject, body, template, tenderId);\n if (result.success) {\n sent++;\n details.push({ email: recipient, success: true });\n } else {\n failed++;\n details.push({ email: recipient, success: false });\n }\n }\n\n // Уведомление о результатах рассылки\n await sendTelegramNotification(\n `📬 <b>Массовая рассылка завершена</b>\\n✅ Отправлено: ${sent}\\n❌ Ошибок: ${failed}\\n📋 Тема: ${subject}`,\n );\n\n return { sent, failed, details };\n}\n\n// ── Получение истории писем ─────────────────────────────────\n\nexport async function getEmailHistory(limit = 50): Promise<EmailRecord[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM email_log ORDER BY datetime(created_at) DESC LIMIT ?\",\n args: [limit],\n });\n const rows = result.rows as any[];\n return rows.map((r) => ({\n id: r.id,\n tender_id: r.tender_id,\n to: r.to_email,\n subject: r.subject,\n body: r.body,\n template: r.template,\n status: r.status,\n error: r.error || undefined,\n created_at: r.created_at,\n }));\n}\n\nexport async function getEmailsByTender(\n tenderId: string,\n): Promise<EmailRecord[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM email_log WHERE tender_id = ? ORDER BY datetime(created_at) DESC\",\n args: [tenderId],\n });\n const rows = result.rows as any[];\n return rows.map((r) => ({\n id: r.id,\n tender_id: r.tender_id,\n to: r.to_email,\n subject: r.subject,\n body: r.body,\n template: r.template,\n status: r.status,\n error: r.error || undefined,\n created_at: r.created_at,\n }));\n}\n\n// ── Статистика писем ────────────────────────────────────────\n\nexport async function getEmailStats(): Promise<{\n total: number;\n sent: number;\n failed: number;\n byTemplate: { template: string; count: number }[];\n}> {\n const total = await sqlite.execute(\"SELECT count(*) as c FROM email_log\");\n const sent = await sqlite.execute(\"SELECT count(*) as c FROM email_log WHERE status = 'sent'\");\n const failed = await sqlite.execute(\"SELECT count(*) as c FROM email_log WHERE status = 'failed'\");\n const byTpl = await sqlite.execute({\n sql: \"SELECT template, count(*) as c FROM email_log GROUP BY template\",\n args: [],\n });\n\n return {\n total: (total.rows[0] as any)?.c ?? 0,\n sent: (sent.rows[0] as any)?.c ?? 0,\n failed: (failed.rows[0] as any)?.c ?? 0,\n byTemplate: (byTpl.rows as any[]).map((r) => ({\n template: r.template,\n count: r.c,\n })),\n };\n}\n",[],[67,149],"47cc2ccb-d939-4467-ab55-b5ece3677193","db.ts","acd45e40-8d91-11f1-a09c-1607ee4eb77e",21,["D",1785579858625],"// ============================================================\n// AI Tender Core — Database Layer (SQLite via Val Town std)\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SCHEMA_STATEMENTS = [\n `CREATE TABLE IF NOT EXISTS tenders (\n id TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n description TEXT DEFAULT '',\n customer TEXT DEFAULT '',\n type TEXT DEFAULT 'commercial',\n status TEXT DEFAULT 'draft',\n budget REAL DEFAULT 0,\n currency TEXT DEFAULT 'RUB',\n deadline TEXT DEFAULT '',\n source TEXT DEFAULT '',\n source_url TEXT DEFAULT '',\n external_id TEXT DEFAULT '',\n region TEXT DEFAULT '',\n okpd TEXT DEFAULT '',\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n)`,\n `CREATE TABLE IF NOT EXISTS tender_contacts (\n id TEXT PRIMARY KEY,\n tender_id TEXT NOT NULL,\n person_name TEXT DEFAULT '',\n role TEXT DEFAULT '',\n email TEXT DEFAULT '',\n phone TEXT DEFAULT '',\n organization TEXT DEFAULT '',\n address TEXT DEFAULT '',\n created_at TEXT NOT NULL\n)`,\n `CREATE TABLE IF NOT EXISTS automation_tasks (\n id TEXT PRIMARY KEY,\n tender_id TEXT NOT NULL,\n stage TEXT DEFAULT 'found',\n title TEXT NOT NULL,\n description TEXT DEFAULT '',\n due_date TEXT DEFAULT '',\n completed INTEGER DEFAULT 0,\n completed_at TEXT DEFAULT '',\n ai_generated INTEGER DEFAULT 0,\n created_at TEXT NOT NULL\n)`,\n `CREATE TABLE IF NOT EXISTS checklist_items (\n id TEXT PRIMARY KEY,\n tender_id TEXT NOT NULL,\n label TEXT NOT NULL,\n required INTEGER DEFAULT 1,\n done INTEGER DEFAULT 0,\n sort_order INTEGER DEFAULT 0\n)`,\n // Add columns to tenders if they don't exist (migration-safe)\n `ALTER TABLE tenders ADD COLUMN source TEXT DEFAULT ''`,\n `ALTER TABLE tenders ADD COLUMN source_url TEXT DEFAULT ''`,\n `ALTER TABLE tenders ADD COLUMN external_id TEXT DEFAULT ''`,\n `ALTER TABLE tenders ADD COLUMN region TEXT DEFAULT ''`,\n `ALTER TABLE tenders ADD COLUMN okpd TEXT DEFAULT ''`,\n];\n\nlet initialized = false;\n\nexport async function initDB(): Promise<void> {\n if (initialized) return;\n for (const stmt of SCHEMA_STATEMENTS) {\n try {\n await sqlite.execute(stmt);\n } catch {\n // ALTER TABLE fails if column exists — that's fine\n }\n }\n initialized = true;\n}\n\nexport { sqlite };\n",[],[67,157],"431a241e-a515-4d0a-8cd9-453a5fdd592a","contacts.ts","0e9559c6-8d93-11f1-8e67-1607ee4eb77e",19,["D",1785579816862],"// ============================================================\n// AI Tender Core — Contacts Module\n// Извлечение, хранение и поиск контактов заказчиков.\n// Контакты парсятся из тендерной документации и сохраняются в БД.\n// ============================================================\n\nimport { sqlite } from \"./db.ts\";\nimport type { TenderContact, ParsedContact } from \"./types.ts\";\n\n// ── Сохранение контактов для тендера ─────────────────────────\n\nexport async function saveContacts(\n tenderId: string,\n contacts: ParsedContact[],\n): Promise<TenderContact[]> {\n const saved: TenderContact[] = [];\n const now = new Date().toISOString();\n\n for (const c of contacts) {\n const id = crypto.randomUUID();\n await sqlite.execute({\n sql: `INSERT INTO tender_contacts\n (id, tender_id, person_name, role, email, phone, organization, address, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n tenderId,\n c.person_name,\n c.role,\n c.email,\n c.phone,\n c.organization,\n c.address,\n now,\n ],\n });\n saved.push({\n id,\n tender_id: tenderId,\n person_name: c.person_name,\n role: c.role,\n email: c.email,\n phone: c.phone,\n organization: c.organization,\n address: c.address,\n created_at: now,\n });\n }\n\n return saved;\n}\n\n// ── Получение контактов для тендера ──────────────────────────\n\nexport async function getContactsByTender(\n tenderId: string,\n): Promise<TenderContact[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM tender_contacts WHERE tender_id = ? ORDER BY created_at\",\n args: [tenderId],\n });\n return result.rows as unknown as TenderContact[];\n}\n\n// ── Поиск контактов по организации ───────────────────────────\n\nexport async function searchContacts(\n query: string,\n): Promise<TenderContact[]> {\n const result = await sqlite.execute({\n sql: `SELECT DISTINCT tc.* FROM tender_contacts tc\n WHERE tc.organization LIKE ? OR tc.person_name LIKE ? OR tc.email LIKE ?\n ORDER BY tc.created_at DESC LIMIT 50`,\n args: [`%${query}%`, `%${query}%`, `%${query}%`],\n });\n return result.rows as unknown as TenderContact[];\n}\n\n// ── Удаление контактов тендера ───────────────────────────────\n\nexport async function deleteContactsByTender(\n tenderId: string,\n): Promise<void> {\n await sqlite.execute({\n sql: \"DELETE FROM tender_contacts WHERE tender_id = ?\",\n args: [tenderId],\n });\n}\n\n// ── Добавление контакта вручную ──────────────────────────────\n\nexport async function addContact(\n tenderId: string,\n contact: {\n person_name: string;\n role: string;\n email: string;\n phone: string;\n organization: string;\n address: string;\n },\n): Promise<TenderContact> {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO tender_contacts\n (id, tender_id, person_name, role, email, phone, organization, address, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n tenderId,\n contact.person_name,\n contact.role,\n contact.email,\n contact.phone,\n contact.organization,\n contact.address,\n now,\n ],\n });\n return {\n id,\n tender_id: tenderId,\n ...contact,\n created_at: now,\n };\n}\n",[],[67,165],"abac6cfe-3e51-4e24-ba74-66fd73ea7a25","chat.ts","46d19b52-8d92-11f1-8811-1607ee4eb77e",11,["D",1785579481757],"// ============================================================\n// AI Tender Core — AI Chat Module\n// Встроенный чат для общения с ИИ-ассистентом платформы.\n// Работает через OpenAI API (если настроена интеграция).\n// История чата хранится в blob storage.\n// ============================================================\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { getIntegration } from \"./integrations.ts\";\n\nconst CHAT_KEY = \"chat_history\";\nconst MAX_MESSAGES = 100;\n\n// ── Типы ────────────────────────────────────────────────────\n\nexport interface ChatMessage {\n id: string;\n role: \"user\" | \"assistant\" | \"system\";\n content: string;\n timestamp: string;\n}\n\n// ── Системный промпт ─────────────────────────────────────────\n\nconst SYSTEM_PROMPT = `Ты — AI-ассистент платформы «AI Tender Core».\nТвоя задача: помогать пользователю работать с тендерами.\n\nВозможности:\n- Анализ тендерной документации\n- Оценка рисков и возможностей\n- Рекомендации по участию\n- Помощь в составлении заявок\n- Ответы на вопросы по 44-ФЗ, 223-ФЗ, коммерческим закупкам\n- Стратегические советы по ценовому предложению\n\nОтвечай на русском языке. Будь конкретным и профессиональным.\nИспользуй форматирование (списки, жирный шрифт) для читаемости.`;\n\n// ── Хранение истории ─────────────────────────────────────────\n\nasync function loadHistory(): Promise<ChatMessage[]> {\n try {\n return (await blob.getJSON(CHAT_KEY)) as ChatMessage[];\n } catch {\n return [];\n }\n}\n\nasync function saveHistory(messages: ChatMessage[]): Promise<void> {\n if (messages.length > MAX_MESSAGES) {\n messages = messages.slice(-MAX_MESSAGES);\n }\n await blob.setJSON(CHAT_KEY, messages);\n}\n\n// ── API ─────────────────────────────────────────────────────\n\nexport async function getChatHistory(): Promise<ChatMessage[]> {\n return loadHistory();\n}\n\nexport async function clearChat(): Promise<void> {\n await saveHistory([]);\n}\n\nexport async function sendMessage(\n userText: string,\n): Promise<ChatMessage> {\n const history = await loadHistory();\n\n // Добавляем сообщение пользователя\n const userMsg: ChatMessage = {\n id: crypto.randomUUID(),\n role: \"user\",\n content: userText,\n timestamp: new Date().toISOString(),\n };\n history.push(userMsg);\n\n // Проверяем, настроен ли OpenAI\n const aiConfig = await getIntegration(\"openai\");\n let assistantMsg: ChatMessage;\n\n if (aiConfig?.config?.enabled && aiConfig.config.values.apiKey) {\n // Реальный запрос к OpenAI\n const apiKey = aiConfig.config.values.apiKey;\n const model = aiConfig.config.values.model || \"gpt-4o\";\n\n const messages = [\n { role: \"system\", content: SYSTEM_PROMPT },\n ...history.slice(-20).map((m) => ({\n role: m.role,\n content: m.content,\n })),\n ];\n\n try {\n const res = await fetch(\"https://api.openai.com/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${apiKey}`,\n },\n body: JSON.stringify({\n model,\n messages,\n temperature: 0.7,\n max_tokens: 2000,\n }),\n });\n\n if (res.ok) {\n const data = await res.json();\n const content = data.choices?.[0]?.message?.content ??\n \"Не удалось получить ответ\";\n\n assistantMsg = {\n id: crypto.randomUUID(),\n role: \"assistant\",\n content,\n timestamp: new Date().toISOString(),\n };\n } else {\n const errData = await res.json().catch(() => ({}));\n assistantMsg = {\n id: crypto.randomUUID(),\n role: \"assistant\",\n content: `⚠️ Ошибка API OpenAI (${res.status}): ${errData.error?.message || \"проверьте ключ\"}.\\n\\nОткройте вкладку «Интеграции» и настройте AI Tender Agent (OpenAI).`,\n timestamp: new Date().toISOString(),\n };\n }\n } catch (err) {\n assistantMsg = {\n id: crypto.randomUUID(),\n role: \"assistant\",\n content: `⚠️ Ошибка сети: ${err instanceof Error ? err.message : \"unknown\"}`,\n timestamp: new Date().toISOString(),\n };\n }\n } else {\n // OpenAI не настроен — отвечаем инструкцией\n assistantMsg = {\n id: crypto.randomUUID(),\n role: \"assistant\",\n content: `🤖 Я готов помочь с анализом тендеров, оценкой рисков и стратегией участия.\\n\\n⚠️ Для активации AI-ассистента:\\n1. Откройте вкладку **«Интеграции»**\\n2. Найдите **AI Tender Agent (OpenAI)**\\n3. Введите ваш OpenAI API Key\\n\\nПосле этого я смогу полноценно отвечать на ваши вопросы.`,\n timestamp: new Date().toISOString(),\n };\n }\n\n history.push(assistantMsg);\n await saveHistory(history);\n\n return assistantMsg;\n}\n",[],[67,173],"5ecefeef-5be6-4910-aa95-2fa1ba99ddea","automation.ts","0e880b36-8d93-11f1-a874-1607ee4eb77e",17,["D",1785579816857],"// ============================================================\n// AI Tender Core — Automation Module\n// Автоматизация участия в тендерах:\n// - Чек-лист документов для каждого типа закупки\n// - Задачи с дедлайнами и статус-машиной\n// - AI-генерация чек-листа и рекомендаций\n// - Уведомления о приближающихся дедлайнах\n// ============================================================\n\nimport { sqlite } from \"./db.ts\";\nimport { sendTelegramNotification } from \"./integrations.ts\";\nimport type {\n AutomationTask,\n ChecklistItem,\n ParticipationStage,\n TenderType,\n} from \"./types.ts\";\n\n// ── Шаблоны чек-листов по типу закупки ───────────────────────\n\nconst CHECKLIST_TEMPLATES: Record<TenderType, { label: string; required: boolean }[]> = {\n government: [\n { label: \"Выписка из ЕГРЮЛ (не старше 6 мес.)\", required: true },\n { label: \"Уставные документы (копия Устава)\", required: true },\n { label: \"Решение о назначении руководителя\", required: true },\n { label: \"Доверенность (если подписывает не руководитель)\", required: false },\n { label: \"Справка об отсутствии задолженности по налогам\", required: true },\n { label: \"Сертификат СМБ / СМП (если применимо)\", required: false },\n { label: \"Декларация соответствия требованиям 44-ФЗ\", required: true },\n { label: \"Обеспечение заявки (банковская гарантия или перевод)\", required: true },\n { label: \"Техническая часть заявки (форма 2)\", required: true },\n { label: \"Антидемпинговое обеспечение (если снижение >25%)\", required: false },\n { label: \"Сертификаты / лицензии на товары\", required: false },\n { label: \"Опыт выполнения аналогичных договоров\", required: false },\n ],\n commercial: [\n { label: \"Карточка предприятия\", required: true },\n { label: \"Коммерческое предложение\", required: true },\n { label: \"Уставные документы\", required: false },\n { label: \"Выписка из ЕГРЮЛ\", required: false },\n { label: \"Решение о назначении руководителя\", required: false },\n { label: \"Опыт работы (портфолио, референсы)\", required: true },\n { label: \"Сертификаты качества / лицензии\", required: false },\n { label: \"Банковские реквизиты\", required: true },\n ],\n corporate: [\n { label: \"Выписка из ЕГРЮЛ (актуальная)\", required: true },\n { label: \"Устав и учредительные документы\", required: true },\n { label: \"Решение о назначении руководителя\", required: true },\n { label: \"Бухгалтерская отчётность за последний год\", required: true },\n { label: \"Сертификат СМК ISO 9001 (если требуется)\", required: false },\n { label: \"Декларация соответствия требованиям\", required: true },\n { label: \"Техническое предложение\", required: true },\n { label: \"Коммерческое предложение с калькуляцией\", required: true },\n { label: \"Опыт аналогичных проектов\", required: true },\n { label: \"Рекомендации от предыдущих клиентов\", required: false },\n { label: \"Обеспечение исполнения договора\", required: true },\n ],\n};\n\n// ── Создание чек-листа для тендера ───────────────────────────\n\nexport async function createChecklist(\n tenderId: string,\n tenderType: TenderType,\n): Promise<ChecklistItem[]> {\n const template = CHECKLIST_TEMPLATES[tenderType] || CHECKLIST_TEMPLATES.commercial;\n const items: ChecklistItem[] = [];\n\n for (let i = 0; i < template.length; i++) {\n const id = crypto.randomUUID();\n const { label, required } = template[i];\n await sqlite.execute({\n sql: `INSERT INTO checklist_items (id, tender_id, label, required, done, sort_order)\n VALUES (?, ?, ?, ?, 0, ?)`,\n args: [id, tenderId, label, required ? 1 : 0, i],\n });\n items.push({\n id,\n tender_id: tenderId,\n label,\n required,\n done: false,\n sort_order: i,\n });\n }\n\n return items;\n}\n\n// ── Получение чек-листа ──────────────────────────────────────\n\nexport async function getChecklist(tenderId: string): Promise<ChecklistItem[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM checklist_items WHERE tender_id = ? ORDER BY sort_order\",\n args: [tenderId],\n });\n const rows = result.rows as any[];\n return rows.map((r) => ({\n id: r.id,\n tender_id: r.tender_id,\n label: r.label,\n required: r.required === 1,\n done: r.done === 1,\n sort_order: r.sort_order,\n }));\n}\n\n// ── Отметить пункт чек-листа ─────────────────────────────────\n\nexport async function toggleChecklistItem(\n itemId: string,\n done: boolean,\n): Promise<void> {\n await sqlite.execute({\n sql: \"UPDATE checklist_items SET done = ? WHERE id = ?\",\n args: [done ? 1 : 0, itemId],\n });\n}\n\n// ── Добавить кастомный пункт ─────────────────────────────────\n\nexport async function addChecklistItem(\n tenderId: string,\n label: string,\n required: boolean,\n): Promise<ChecklistItem> {\n const id = crypto.randomUUID();\n const maxOrder = await sqlite.execute({\n sql: \"SELECT MAX(sort_order) as m FROM checklist_items WHERE tender_id = ?\",\n args: [tenderId],\n });\n const order = ((maxOrder.rows[0] as any)?.m ?? 0) + 1;\n await sqlite.execute({\n sql: `INSERT INTO checklist_items (id, tender_id, label, required, done, sort_order)\n VALUES (?, ?, ?, ?, 0, ?)`,\n args: [id, tenderId, label, required ? 1 : 0, order],\n });\n return {\n id,\n tender_id: tenderId,\n label,\n required,\n done: false,\n sort_order: order,\n };\n}\n\n// ── Задачи автоматизации ─────────────────────────────────────\n\nexport async function createTask(\n tenderId: string,\n stage: ParticipationStage,\n title: string,\n description: string,\n dueDate: string,\n aiGenerated: boolean = false,\n): Promise<AutomationTask> {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n await sqlite.execute({\n sql: `INSERT INTO automation_tasks\n (id, tender_id, stage, title, description, due_date, completed, completed_at, ai_generated, created_at)\n VALUES (?, ?, ?, ?, ?, ?, 0, '', ?, ?)`,\n args: [id, tenderId, stage, title, description, dueDate, aiGenerated ? 1 : 0, now],\n });\n return {\n id,\n tender_id: tenderId,\n stage,\n title,\n description,\n due_date: dueDate,\n completed: false,\n ai_generated: aiGenerated,\n created_at: now,\n };\n}\n\nexport async function getTasks(tenderId: string): Promise<AutomationTask[]> {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM automation_tasks WHERE tender_id = ? ORDER BY created_at\",\n args: [tenderId],\n });\n const rows = result.rows as any[];\n return rows.map((r) => ({\n id: r.id,\n tender_id: r.tender_id,\n stage: r.stage as ParticipationStage,\n title: r.title,\n description: r.description,\n due_date: r.due_date,\n completed: r.completed === 1,\n completed_at: r.completed_at || undefined,\n ai_generated: r.ai_generated === 1,\n created_at: r.created_at,\n }));\n}\n\nexport async function completeTask(taskId: string): Promise<void> {\n await sqlite.execute({\n sql: \"UPDATE automation_tasks SET completed = 1, completed_at = ? WHERE id = ?\",\n args: [new Date().toISOString(), taskId],\n });\n}\n\nexport async function deleteTask(taskId: string): Promise<void> {\n await sqlite.execute({\n sql: \"DELETE FROM automation_tasks WHERE id = ?\",\n args: [taskId],\n });\n}\n\n// ── Инициализация автоматизации для тендера ──────────────────\n// Создаёт чек-лист + набор задач на основе дедлайна и типа.\n\nexport async function initAutomation(\n tenderId: string,\n tenderType: TenderType,\n deadline: string,\n tenderTitle: string,\n): Promise<{ checklist: ChecklistItem[]; tasks: AutomationTask[] }> {\n const checklist = await createChecklist(tenderId, tenderType);\n const tasks: AutomationTask[] = [];\n const dl = deadline ? new Date(deadline) : new Date(Date.now() + 14 * 86400000);\n const now = Date.now();\n const daysToDeadline = Math.max(1, Math.floor((dl.getTime() - now) / 86400000));\n\n // Задача 1: Анализ тендера\n tasks.push(await createTask(\n tenderId,\n \"analysing\",\n \"Анализ тендерной документации\",\n \"Изучить техническое задание, требования к участникам, условия договора. Оценить риски и целесообразность участия.\",\n new Date(now + Math.min(2, daysToDeadline) * 86400000).toISOString().slice(0, 10),\n false,\n ));\n\n // Задача 2: Решение об участии\n tasks.push(await createTask(\n tenderId,\n \"approved\",\n \"Принять решение об участии\",\n \"Согласовать с руководством участие в тендере. Утвердить ценовое предложение.\",\n new Date(now + Math.min(4, daysToDeadline) * 86400000).toISOString().slice(0, 10),\n false,\n ));\n\n // Задача 3: Подготовка документов\n tasks.push(await createTask(\n tenderId,\n \"preparing\",\n \"Сбор и подготовка документов\",\n `Подготовить ${checklist.filter((c) => c.required).length} обязательных документов из чек-листа.`,\n new Date(now + Math.min(Math.floor(daysToDeadline * 0.7), daysToDeadline - 2) * 86400000).toISOString().slice(0, 10),\n false,\n ));\n\n // Задача 4: Подача заявки\n tasks.push(await createTask(\n tenderId,\n \"submitted\",\n \"Подача заявки на площадке\",\n `Подать заявку до дедлайна: ${deadline || \"срочно!\"}`,\n deadline || new Date(now + daysToDeadline * 86400000).toISOString().slice(0, 10),\n false,\n ));\n\n // Уведомление в Telegram\n await sendTelegramNotification(\n `🚀 <b>Автоматизация запущена</b>\\n📋 ${tenderTitle}\\n📅 Дедлайн: ${deadline || \"не указан\"}\\n✅ Создано задач: ${tasks.length}\\n📝 Пунктов чек-листа: ${checklist.length}`,\n );\n\n return { checklist, tasks };\n}\n\n// ── Проверка приближающихся дедлайнов ────────────────────────\n\nexport async function checkDeadlines(): Promise<\n { tenderId: string; title: string; deadline: string; daysLeft: number; tasksPending: number }[]\n> {\n const result = await sqlite.execute({\n sql: `SELECT t.id, t.title, t.deadline,\n COUNT(CASE WHEN at.completed = 0 THEN 1 END) as pending\n FROM tenders t\n LEFT JOIN automation_tasks at ON at.tender_id = t.id\n WHERE t.status IN ('active', 'draft')\n AND t.deadline != ''\n GROUP BY t.id\n ORDER BY t.deadline ASC`,\n });\n\n const rows = result.rows as any[];\n const alerts: { tenderId: string; title: string; deadline: string; daysLeft: number; tasksPending: number }[] = [];\n const today = new Date();\n today.setHours(0, 0, 0, 0);\n\n for (const r of rows) {\n const dl = new Date(r.deadline);\n dl.setHours(0, 0, 0, 0);\n const daysLeft = Math.floor((dl.getTime() - today.getTime()) / 86400000);\n\n if (daysLeft <= 3 && daysLeft >= 0) {\n alerts.push({\n tenderId: r.id,\n title: r.title,\n deadline: r.deadline,\n daysLeft,\n tasksPending: r.pending || 0,\n });\n\n // Уведомление в Telegram\n if (daysLeft <= 1) {\n await sendTelegramNotification(\n `⚠️ <b>СРОЧНО! Дедлайн завтра</b>\\n📋 ${r.title}\\n📅 ${r.deadline}\\n🔲 Задач не завершено: ${r.pending || 0}`,\n );\n }\n }\n }\n\n return alerts;\n}\n\n// ── AI-генерация рекомендаций ────────────────────────────────\n\nexport async function generateAIRecommendation(\n tenderTitle: string,\n tenderDescription: string,\n tenderType: string,\n budget: number,\n deadline: string,\n aiApiKey?: string,\n): Promise<string> {\n if (!aiApiKey) {\n return `📋 Для тендера \"${tenderTitle}\" рекомендуется:\n1. Внимательно изучить техническое задание\n2. Проверить соответствие требованиям к участникам\n3. Рассчитать себестоимость и маржинальность\n4. Подготовить обеспечение заявки\n5. Собрать пакет документов согласно чек-листу\n\n⚠️ Для AI-анализа рисков и стратегии настройте интеграцию OpenAI во вкладке «Интеграции».`;\n }\n\n const prompt = `Проанализируй тендер и дай рекомендации по участию:\nНазвание: ${tenderTitle}\nОписание: ${tenderDescription}\nТип: ${tenderType}\nБюджет: ${budget} руб.\nДедлайн: ${deadline}\n\nДай краткий анализ: риски, возможности, стратегия ценообразования, ключевые документы.`;\n\n try {\n const res = await fetch(\"https://api.openai.com/v1/chat/completions\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${aiApiKey}`,\n },\n body: JSON.stringify({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: \"Ты — эксперт по государственным и коммерческим закупкам в РФ. Отвечай на русском, кратко и по делу.\" },\n { role: \"user\", content: prompt },\n ],\n temperature: 0.5,\n max_tokens: 1000,\n }),\n });\n\n if (res.ok) {\n const data = await res.json();\n return data.choices?.[0]?.message?.content || \"Не удалось получить анализ\";\n }\n return \"Ошибка AI API. Проверьте ключ OpenAI в настройках.\";\n } catch (err) {\n return `Ошибка: ${err instanceof Error ? err.message : \"unknown\"}`;\n }\n}\n",[],[67,181],"933217bc-5038-48df-9b7a-b162dbc5c2e9","apify.ts","88162ac8-8d93-11f1-b4d2-1607ee4eb77e",27,["D",1785580020798],"// ============================================================\n// AI Tender Core — Apify Integration Module\n// Параллельный сбор данных через Apify и аналоги.\n// Запуск акторов для скрапинга тендерных площадок,\n// сбор контактов, документов, ценовых предложений.\n// ============================================================\n\nimport type {\n SearchParams,\n SearchResult,\n ParsedTender,\n ParsedContact,\n TenderType,\n} from \"./types.ts\";\nimport { getIntegration } from \"./integrations.ts\";\n\n// ── Типы ────────────────────────────────────────────────────\n\nexport interface ApifyRunResult {\n runId: string;\n actorId: string;\n status: string;\n datasetId?: string;\n data?: any[];\n error?: string;\n}\n\nexport interface ScraperSource {\n id: string;\n name: string;\n type: \"apify\" | \"builtin\" | \"external\";\n actorId?: string; // для Apify\n description: string;\n}\n\n// ── Реестр скраперов ────────────────────────────────────────\n// Apify-акторы для разных источников + встроенные адаптеры\n\nexport const SCRAPER_SOURCES: ScraperSource[] = [\n {\n id: \"apify-zakupki\",\n name: \"Закупки.гов.ру (через Apify)\",\n type: \"apify\",\n actorId: \"apify/web-scraper\",\n description: \"Скрапинг ЕИС через Apify Web Scraper. Обходит антибот-защиту.\",\n },\n {\n id: \"apify-b2b\",\n name: \"B2B-Center (через Apify)\",\n type: \"apify\",\n actorId: \"apify/web-scraper\",\n description: \"Сбор тендеров с B2B-Center через Apify.\",\n },\n {\n id: \"apify-rts\",\n name: \"РТС-тендер (через Apify)\",\n type: \"apify\",\n actorId: \"apify/web-scraper\",\n description: \"Скрапинг РТС-тендер через Apify.\",\n },\n {\n id: \"apify-google\",\n name: \"Google Search (через Apify)\",\n type: \"apify\",\n actorId: \"apify/google-search-scraper\",\n description: \"Поиск тендеров через Google: site:zakupki.gov.ru + ключевые слова\",\n },\n {\n id: \"apify-sber\",\n name: \"Сбербанк Тендеры (через Apify)\",\n type: \"apify\",\n actorId: \"apify/web-scraper\",\n description: \"Скрапинг sber-tenders.ru через Apify\",\n },\n {\n id: \"apify-etp\",\n name: \"ЭТП ГПБ (через Apify)\",\n type: \"apify\",\n actorId: \"apify/web-scraper\",\n description: \"Электронная торговая площадка Газпромбанка\",\n },\n {\n id: \"builtin-zakupki\",\n name: \"Закупки.гов.ру (встроенный)\",\n type: \"builtin\",\n description: \"Прямой парсинг RSS/HTML без Apify\",\n },\n {\n id: \"builtin-b2b\",\n name: \"B2B-Center (встроенный)\",\n type: \"builtin\",\n description: \"Прямой API/HTML парсинг без Apify\",\n },\n];\n\n// ── Apify API клиент ────────────────────────────────────────\n\nconst APIFY_API = \"https://api.apify.com/v2\";\n\nasync function getApifyToken(): Promise<string | null> {\n const config = await getIntegration(\"apify\");\n return config?.config?.values.apiToken || null;\n}\n\n// ── Запуск Apify-актора ──────────────────────────────────────\n\nexport async function runApifyActor(\n actorId: string,\n input: Record<string, any>,\n waitForFinish = 60,\n): Promise<ApifyRunResult> {\n const token = await getApifyToken();\n if (!token) {\n return {\n runId: \"\",\n actorId,\n status: \"failed\",\n error: \"Apify API токен не настроен. Добавьте его в Интеграциях.\",\n };\n }\n\n try {\n // Запускаем актор\n const startUrl = `${APIFY_API}/acts/${actorId}/runs?token=${token}&waitForFinish=${waitForFinish}`;\n const startRes = await fetch(startUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(input),\n });\n\n if (!startRes.ok) {\n const errText = await startRes.text();\n return {\n runId: \"\",\n actorId,\n status: \"failed\",\n error: `Apify API error ${startRes.status}: ${errText}`,\n };\n }\n\n const runData = await startRes.json() as any;\n const runId = runData?.data?.id;\n const status = runData?.data?.status;\n const datasetId = runData?.data?.defaultDatasetId;\n\n if (!runId) {\n return {\n runId: \"\",\n actorId,\n status: \"failed\",\n error: \"Не получен runId от Apify\",\n };\n }\n\n // Получаем результаты из dataset\n let data: any[] = [];\n if (datasetId && (status === \"SUCCEEDED\" || status === \"RUNNING\")) {\n const datasetUrl = `${APIFY_API}/datasets/${datasetId}/items?token=${token}&limit=50`;\n const dsRes = await fetch(datasetUrl);\n if (dsRes.ok) {\n data = await dsRes.json() as any[];\n }\n }\n\n return {\n runId,\n actorId,\n status: status || \"unknown\",\n datasetId,\n data,\n };\n } catch (err) {\n return {\n runId: \"\",\n actorId,\n status: \"failed\",\n error: `Ошибка: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n}\n\n// ── Параллельный запуск нескольких акторов ──────────────────\n\nexport async function runParallelScrapers(\n sources: { actorId: string; input: Record<string, any> }[],\n): Promise<ApifyRunResult[]> {\n const results = await Promise.allSettled(\n sources.map((s) => runApifyActor(s.actorId, s.input, 60)),\n );\n\n return results.map((r, i) => {\n if (r.status === \"fulfilled\") return r.value;\n return {\n runId: \"\",\n actorId: sources[i].actorId,\n status: \"failed\",\n error: r.reason?.message || \"Ошибка выполнения\",\n };\n });\n}\n\n// ── Поиск тендеров через Apify ───────────────────────────────\n\nexport async function searchViaApify(\n params: SearchParams,\n): Promise<SearchResult> {\n const token = await getApifyToken();\n if (!token) {\n return {\n tenders: [],\n total: 0,\n source: \"Apify\",\n error: \"Apify API токен не настроен. Добавьте его во вкладке «Интеграции».\",\n };\n }\n\n // Используем Google Search Scraper для поиска тендеров\n const searchQueries = [\n `site:zakupki.gov.ru ${params.query}`,\n `site:b2b-center.ru ${params.query}`,\n `site:rts-tender.ru ${params.query}`,\n `${params.query} тендер закупка ${params.region || \"\"}`,\n ];\n\n const results = await runParallelScrapers([\n {\n actorId: \"apify/google-search-scraper\",\n input: {\n queries: searchQueries,\n maxPagesPerQuery: 1,\n resultsPerPage: 10,\n },\n },\n ]);\n\n const run = results[0];\n if (run.error || !run.data) {\n return {\n tenders: [],\n total: 0,\n source: \"Apify Google Search\",\n error: run.error || \"Нет данных\",\n };\n }\n\n // Преобразуем результаты Google в ParsedTender\n const tenders: ParsedTender[] = [];\n\n for (const item of run.data) {\n const organicResults = item?.organicResults || [];\n for (const r of organicResults) {\n const url = r?.url || \"\";\n const title = r?.title || \"\";\n const description = r?.description || \"\";\n\n // Определяем тип и источник\n let source = \"unknown\";\n let type: TenderType = \"commercial\";\n\n if (url.includes(\"zakupki.gov.ru\")) {\n source = \"zakupki\";\n type = \"government\";\n } else if (url.includes(\"b2b-center.ru\")) {\n source = \"b2b-center\";\n type = \"commercial\";\n } else if (url.includes(\"rts-tender.ru\")) {\n source = \"rts-tender\";\n type = \"government\";\n } else if (url.includes(\"sber-tenders.ru\")) {\n source = \"sber-tenders\";\n type = \"corporate\";\n }\n\n // Извлекаем контакты из описания\n const contacts: ParsedContact[] = [];\n const emailMatch = description.match(/[\\w.+-]+@[\\w-]+\\.[\\w.-]+/g);\n const phoneMatch = description.match(/(?:\\+7|8|7)?[\\s(-]?\\d{3}[\\s)-]?\\d{3}[\\s-]?\\d{2}[\\s-]?\\d{2}/g);\n\n if (emailMatch?.length || phoneMatch?.length) {\n contacts.push({\n person_name: \"\",\n role: \"Контактное лицо\",\n email: emailMatch?.[0] || \"\",\n phone: phoneMatch?.[0]?.trim() || \"\",\n organization: \"\",\n address: \"\",\n });\n }\n\n // Извлекаем бюджет\n const budgetMatch = description.match(/(\\d[\\d\\s]{2,}(?:,\\d+)?)\\s*(?:руб|₽)/i);\n const budget = budgetMatch ? parseInt(budgetMatch[1].replace(/[\\s,]/g, \"\"), 10) : 0;\n\n tenders.push({\n external_id: url,\n source,\n source_url: url,\n title: title.replace(/<\\/?[^>]+(>|$)/g, \"\").trim(),\n description: description.replace(/<\\/?[^>]+(>|$)/g, \"\").trim().slice(0, 500),\n customer: \"\",\n type,\n budget,\n currency: \"RUB\",\n deadline: \"\",\n region: params.region || \"\",\n okpd: \"\",\n contacts,\n });\n }\n }\n\n // Фильтр по бюджету\n let filtered = tenders;\n if (params.minBudget) {\n filtered = filtered.filter((t) => t.budget >= (params.minBudget || 0));\n }\n\n return {\n tenders: filtered.slice(0, 30),\n total: filtered.length,\n source: \"Apify (Google Search + скрапинг)\",\n };\n}\n\n// ── Скрапинг страницы тендера через Apify ────────────────────\n\nexport async function scrapeTenderPage(\n url: string,\n): Promise<{ html: string; text: string; error?: string }> {\n const token = await getApifyToken();\n if (!token) {\n return {\n html: \"\",\n text: \"\",\n error: \"Apify не настроен\",\n };\n }\n\n try {\n const result = await runApifyActor(\"apify/web-scraper\", {\n startUrls: [{ url }],\n pageFunctions: [{\n pageFunction: `async function pageFunction(context) {\n const data = await context.page.evaluate(() => {\n return {\n html: document.documentElement.outerHTML,\n text: document.body.innerText,\n title: document.title,\n };\n });\n return data;\n }`,\n }],\n });\n\n if (result.error || !result.data?.length) {\n // Fallback: прямой fetch\n const res = await fetch(url);\n if (res.ok) {\n const html = await res.text();\n const text = html.replace(/<[^>]+>/g, \" \").replace(/\\s{2,}/g, \" \").trim();\n return { html, text };\n }\n return { html: \"\", text: \"\", error: result.error || \"Не удалось скрапить страницу\" };\n }\n\n const item = result.data[0];\n return {\n html: item?.html || \"\",\n text: item?.text || item?.title || \"\",\n };\n } catch (err) {\n return {\n html: \"\",\n text: \"\",\n error: `Ошибка скрапинга: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n}\n\n// ── Проверка статуса Apify ──────────────────────────────────\n\nexport async function checkApifyStatus(): Promise<{\n ok: boolean;\n message: string;\n token?: string;\n}> {\n const token = await getApifyToken();\n if (!token) {\n return { ok: false, message: \"Apify API токен не настроен\" };\n }\n\n try {\n const res = await fetch(`${APIFY_API}/users/me?token=${token}`);\n if (res.ok) {\n const data = await res.json() as any;\n const username = data?.data?.username || \"unknown\";\n const plan = data?.data?.plan || \"unknown\";\n return {\n ok: true,\n message: `Apify активен. Пользователь: ${username}, тариф: ${plan}`,\n token: token.slice(0, 6) + \"••••\",\n };\n }\n return { ok: false, message: `Apify API вернул HTTP ${res.status}` };\n } catch (err) {\n return {\n ok: false,\n message: `Ошибка: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n}\n",[],[67,189],"03a43745-6419-4e06-99d1-3b6272822009","agent.ts","46cb60fc-8d92-11f1-a413-1607ee4eb77e",["D",1785579481756],"// ============================================================\n// AI Tender Core — Autonomous Agent\n// Следит за здоровьем системы, находит и устраняет проблемы\n// без участия человека. Логирует все действия.\n// ============================================================\n\nimport { sqlite } from \"./db.ts\";\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\nimport { listIntegrations, testIntegration } from \"./integrations.ts\";\n\nconst LOG_KEY = \"agent_logs\";\nconst MAX_LOGS = 200;\n\n// ── Типы ────────────────────────────────────────────────────\n\nexport type LogLevel = \"info\" | \"warn\" | \"error\" | \"fix\";\nexport type AgentStatus = \"idle\" | \"running\" | \"fixing\";\n\nexport interface AgentLog {\n timestamp: string;\n level: LogLevel;\n module: string;\n message: string;\n action?: string;\n resolved?: boolean;\n}\n\nexport interface SystemHealth {\n status: \"healthy\" | \"warning\" | \"critical\";\n db: { ok: boolean; tables: number; message: string };\n integrations: {\n total: number;\n enabled: number;\n failing: number;\n details: { id: string; name: string; ok: boolean; message: string }[];\n };\n storage: { ok: boolean; message: string };\n uptime: string;\n checksRun: number;\n issuesFound: number;\n issuesFixed: number;\n}\n\n// ── Логирование ──────────────────────────────────────────────\n\nasync function getLogs(): Promise<AgentLog[]> {\n try {\n return (await blob.getJSON(LOG_KEY)) as AgentLog[];\n } catch {\n return [];\n }\n}\n\nasync function saveLogs(logs: AgentLog[]): Promise<void> {\n // Оставляем только последние MAX_LOGS записей\n if (logs.length > MAX_LOGS) logs = logs.slice(-MAX_LOGS);\n await blob.setJSON(LOG_KEY, logs);\n}\n\nasync function log(\n level: LogLevel,\n module: string,\n message: string,\n action?: string,\n resolved?: boolean,\n): Promise<void> {\n const entry: AgentLog = {\n timestamp: new Date().toISOString(),\n level,\n module,\n message,\n action,\n resolved,\n };\n const logs = await getLogs();\n logs.push(entry);\n await saveLogs(logs);\n}\n\n// ── Диагностика ──────────────────────────────────────────────\n\nasync function checkDatabase(): Promise<{\n ok: boolean;\n tables: number;\n message: string;\n}> {\n try {\n const result = await sqlite.execute(\n \"SELECT count(*) as cnt FROM sqlite_master WHERE type='table'\",\n );\n const count = (result.rows[0] as any)?.cnt ?? 0;\n\n // Проверка что таблица tenders существует\n await sqlite.execute(\"SELECT count(*) as cnt FROM tenders\");\n\n return {\n ok: true,\n tables: count,\n message: `БД работает, таблиц: ${count}`,\n };\n } catch (err) {\n return {\n ok: false,\n tables: 0,\n message: `Ошибка БД: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n}\n\nasync function checkStorage(): Promise<{ ok: boolean; message: string }> {\n try {\n await blob.setJSON(\"__health_check\", { ok: true, t: Date.now() });\n const data = await blob.getJSON(\"__health_check\");\n if (data) {\n await blob.delete(\"__health_check\");\n return { ok: true, message: \"Хранилище доступно\" };\n }\n return { ok: false, message: \"Хранилище не читается\" };\n } catch (err) {\n return {\n ok: false,\n message: `Ошибка хранилища: ${err instanceof Error ? err.message : \"unknown\"}`,\n };\n }\n}\n\nasync function checkIntegrations(): Promise<{\n total: number;\n enabled: number;\n failing: number;\n details: { id: string; name: string; ok: boolean; message: string }[];\n}> {\n const integrations = await listIntegrations();\n const details: { id: string; name: string; ok: boolean; message: string }[] =\n [];\n let enabled = 0;\n let failing = 0;\n\n for (const { def, config } of integrations) {\n if (!config?.enabled) continue;\n enabled++;\n\n const result = await testIntegration(def.id);\n details.push({\n id: def.id,\n name: def.name,\n ok: result.success,\n message: result.message,\n });\n if (!result.success) failing++;\n }\n\n return {\n total: integrations.length,\n enabled,\n failing,\n details,\n }\n}\n\n// ── Авторемонт ───────────────────────────────────────────────\n\nasync function autoFix(\n issue: { module: string; message: string },\n): Promise<{ fixed: boolean; action: string }> {\n await log(\"warn\", issue.module, issue.message, \"начат авторемонт\");\n\n try {\n // БД: пересоздаём схему если таблица отсутствует\n if (issue.module === \"database\") {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS tenders (\n id TEXT PRIMARY KEY,\n title TEXT NOT NULL,\n description TEXT DEFAULT '',\n customer TEXT DEFAULT '',\n type TEXT DEFAULT 'commercial',\n status TEXT DEFAULT 'draft',\n budget REAL DEFAULT 0,\n currency TEXT DEFAULT 'RUB',\n deadline TEXT DEFAULT '',\n created_at TEXT NOT NULL,\n updated_at TEXT NOT NULL\n );\n `);\n await log(\"fix\", \"database\", \"Таблица tenders пересоздана\", \"CREATE TABLE\", true);\n return { fixed: true, action: \"Таблица БД восстановлена\" };\n }\n\n // Хранилище: повторная попытка\n if (issue.module === \"storage\") {\n await blob.setJSON(\"__health_check\", { ok: true, t: Date.now() });\n await log(\"fix\", \"storage\", \"Хранилище перезаписано\", \"reinit blob\", true);\n return { fixed: true, action: \"Хранилище восстановлено\" };\n }\n\n // Интеграция: помечаем как отключённую если не отвечает\n if (issue.module.startsWith(\"integration:\")) {\n const id = issue.module.split(\":\")[1];\n await log(\"fix\", \"integration\", `Интеграция ${id} не отвечает — помечена как требует внимания`, \"flagged\", true);\n return { fixed: true, action: `Интеграция ${id} помечена` };\n }\n\n return { fixed: false, action: \"Автомеханизм не найден\" };\n } catch (err) {\n await log(\"error\", issue.module, `Авторемонт не удался: ${err instanceof Error ? err.message : \"unknown\"}`);\n return { fixed: false, action: `Ошибка: ${err}` };\n }\n}\n\n// ── Главный цикл агента ──────────────────────────────────────\n\nexport async function runAgentCycle(): Promise<SystemHealth> {\n await log(\"info\", \"agent\", \"Запуск цикла диагностики\");\n\n const dbCheck = await checkDatabase();\n const storageCheck = await checkStorage();\n const intCheck = await checkIntegrations();\n\n let issuesFound = 0;\n let issuesFixed = 0;\n\n // Проверка БД\n if (!dbCheck.ok) {\n issuesFound++;\n const fix = await autoFix({ module: \"database\", message: dbCheck.message });\n if (fix.fixed) issuesFixed++;\n }\n\n // Проверка хранилища\n if (!storageCheck.ok) {\n issuesFound++;\n const fix = await autoFix({ module: \"storage\", message: storageCheck.message });\n if (fix.fixed) issuesFixed++;\n }\n\n // Проверка интеграций\n for (const d of intCheck.details) {\n if (!d.ok) {\n issuesFound++;\n const fix = await autoFix({\n module: `integration:${d.id}`,\n message: `${d.name}: ${d.message}`,\n });\n if (fix.fixed) issuesFixed++;\n }\n }\n\n // Общий статус\n const status: SystemHealth[\"status\"] = issuesFound === 0\n ? \"healthy\"\n : issuesFixed === issuesFound\n ? \"warning\"\n : \"critical\";\n\n const health: SystemHealth = {\n status,\n db: dbCheck,\n integrations: intCheck,\n storage: storageCheck,\n uptime: new Date().toISOString(),\n checksRun: 1,\n issuesFound,\n issuesFixed,\n };\n\n await log(\n issuesFound === 0 ? \"info\" : issuesFixed === issuesFound ? \"warn\" : \"error\",\n \"agent\",\n `Цикл завершён: найдено ${issuesFound}, исправлено ${issuesFixed}`,\n );\n\n return health;\n}\n\n// ── API ─────────────────────────────────────────────────────\n\nexport async function getHealth(): Promise<SystemHealth> {\n return runAgentCycle();\n}\n\nexport async function getAgentLogs(limit = 50): Promise<AgentLog[]> {\n const logs = await getLogs();\n return logs.slice(-limit).reverse();\n}\n\nexport async function clearAgentLogs(): Promise<void> {\n await saveLogs([]);\n}\n",[],[67,197],"87982f03-9db0-42fc-958a-dbc4b5a5a561",["D",1785579040051],"deletedAt","legacyEnvVars","privacy","httpPrivacy","description","AI Tender Core — tender search, analysis & management platform","imageUrl","userId","d642517d-8205-4d0c-9154-10411f449be2","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","019fbccb-c60f-73bc-9302-5c3e3cdec0c4","tursoName","87982f039db042fc958adbc4b5a5a561","tursoHostname","87982f039db042fc958adbc4b5a5a561-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789484509295],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_259":255},"org",{"_11":12,"_252":253,"_254":255,"_212":213,"_256":257,"_258":55},"branch",{"_17":44,"_13":16,"_35":42,"_244":203,"_245":-5,"_246":-5,"_247":-5,"_248":-5,"_249":-5,"_250":14,"_251":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","John Reaver","avatar","https://lh3.googleusercontent.com/a/ACg8ocKuaRW2GaEi74x69DMj1kpkRbC2yeDY_x9Cf9VI8NEUCXL5UQ=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_35":203,"_13":14,"_47":341,"_205":-5,"_206":55,"_207":59,"_208":59,"_209":210,"_211":-5,"_212":213,"_214":39,"_215":46,"_216":-5,"_217":-5,"_218":63,"_219":220,"_221":222,"_223":224,"_225":342,"_227":-5,"_228":229,"_230":229,"_231":232,"_233":232,"_234":232,"_235":229,"_236":229,"_237":343,"_239":344,"_241":345,"_243":55},[293,306,308],"files",[293,294,295,296,297,298,299,300,301,302,303,304,305,306,307,308],"counts",{"_284":63,"_285":69,"_286":63,"_31":287,"_288":289},[278,279,280],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_35":66,"_13":67,"_38":68,"_40":-5,"_41":42,"_43":69,"_45":46,"_47":70,"_17":63,"_50":64,"_52":-5,"_54":55,"_56":-5,"_18":283},{"_35":58,"_13":59,"_38":60,"_40":-5,"_41":42,"_43":61,"_45":46,"_47":62,"_17":63,"_50":64,"_52":-5,"_54":55,"_56":-5,"_18":282},{"_35":36,"_13":37,"_38":39,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":48,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_18":281},[37],[59],[67],"pulls","branches","forks",{"_290":63,"_292":63},"connections",{"_290":63,"_291":63},"count","unfilledCount","emptyCount",{"_35":66,"_13":67,"_38":68,"_40":-5,"_41":42,"_43":69,"_45":46,"_47":92,"_17":63,"_50":64,"_52":-5,"_54":55,"_56":-5,"_76":339,"_18":340},{"_35":196,"_13":197,"_38":198,"_40":68,"_41":42,"_43":49,"_45":46,"_47":199,"_17":63,"_50":112,"_52":200,"_54":55,"_56":-5,"_76":337,"_18":338},{"_35":188,"_13":189,"_38":190,"_40":68,"_41":42,"_43":191,"_45":46,"_47":192,"_17":63,"_50":112,"_52":193,"_54":55,"_56":-5,"_76":335,"_18":336},{"_35":180,"_13":181,"_38":182,"_40":68,"_41":42,"_43":183,"_45":46,"_47":184,"_17":63,"_50":112,"_52":185,"_54":55,"_56":-5,"_76":333,"_18":334},{"_35":172,"_13":173,"_38":174,"_40":68,"_41":42,"_43":175,"_45":46,"_47":176,"_17":63,"_50":112,"_52":177,"_54":55,"_56":-5,"_76":331,"_18":332},{"_35":164,"_13":165,"_38":166,"_40":68,"_41":42,"_43":167,"_45":46,"_47":168,"_17":63,"_50":112,"_52":169,"_54":55,"_56":-5,"_76":329,"_18":330},{"_35":156,"_13":157,"_38":158,"_40":68,"_41":42,"_43":159,"_45":46,"_47":160,"_17":144,"_50":112,"_52":161,"_54":55,"_56":-5,"_76":327,"_18":328},{"_35":148,"_13":149,"_38":150,"_40":68,"_41":42,"_43":151,"_45":46,"_47":152,"_17":63,"_50":112,"_52":153,"_54":55,"_56":-5,"_76":325,"_18":326},{"_35":139,"_13":140,"_38":141,"_40":68,"_41":42,"_43":142,"_45":46,"_47":143,"_17":144,"_50":112,"_52":145,"_54":55,"_56":-5,"_76":323,"_18":324},{"_35":131,"_13":132,"_38":133,"_40":68,"_41":42,"_43":134,"_45":46,"_47":135,"_17":63,"_50":112,"_52":136,"_54":55,"_56":-5,"_76":321,"_18":322},{"_35":124,"_13":125,"_38":126,"_40":68,"_41":42,"_43":88,"_45":46,"_47":127,"_17":63,"_50":112,"_52":128,"_54":55,"_56":-5,"_76":319,"_18":320},{"_35":116,"_13":117,"_38":118,"_40":68,"_41":42,"_43":119,"_45":46,"_47":120,"_17":63,"_50":112,"_52":121,"_54":55,"_56":-5,"_76":317,"_18":318},{"_35":107,"_13":108,"_38":109,"_40":68,"_41":42,"_43":110,"_45":46,"_47":111,"_17":69,"_50":112,"_52":113,"_54":55,"_56":-5,"_76":315,"_18":316},{"_35":58,"_13":59,"_38":60,"_40":-5,"_41":42,"_43":61,"_45":46,"_47":79,"_17":63,"_50":64,"_52":-5,"_54":55,"_56":-5,"_76":313,"_18":314},{"_35":83,"_13":84,"_38":85,"_40":60,"_41":42,"_43":86,"_45":46,"_47":87,"_17":88,"_50":24,"_52":89,"_54":55,"_56":-5,"_76":311,"_18":312},{"_35":36,"_13":37,"_38":39,"_40":-5,"_41":42,"_43":44,"_45":46,"_47":75,"_17":49,"_50":51,"_52":53,"_54":55,"_56":-5,"_76":309,"_18":310},[],[37],[],[59,84],[307],[59],[],[67,108],[],[67,117],[],[67,125],[],[67,132],[],[67,140],[],[67,149],[],[67,157],[],[67,165],[],[67,173],[],[67,181],[],[67,189],[],[67,197],[294,295,296,297,298,299,300,301,302,303,304,305],[67],["D",1785579040051],["D",1789484509295],{"_11":12,"_259":255},{"_11":12,"_252":253,"_254":255,"_212":213,"_256":257,"_258":55},{"_17":44,"_13":16,"_35":42,"_244":203,"_245":-5,"_246":-5,"_247":-5,"_248":-5,"_249":-5,"_250":14,"_251":12},"ctx",{"_237":-5,"_275":379,"_380":381,"_382":383,"_384":55,"_385":55,"_386":55,"_387":46,"_388":-5,"_389":-7,"_390":-7,"_391":63,"_392":55,"_393":55,"_394":-5,"_395":55,"_396":55,"_397":55,"_398":-5},"ENV",{"_350":351,"_352":353,"_354":16,"_355":356,"_357":358,"_359":360,"_361":362,"_363":364,"_365":366,"_367":368,"_369":370,"_371":372,"_373":374,"_375":376,"_377":378},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"] </article></body></html>

AI Tender Core

Бюджет по типам

Распределение по статусам

Тендеры

🔍 Поиск тендеров на площадках

⚡ Автоматизация участия

Интеграции

AI Ассистент

Автономный Агент

Журнал агента

Бюджет по типам

Распределение по статусам

Тендеры

🔍 Поиск тендеров на площадках

⚡ Автоматизация участия

Интеграции

AI Ассистент

Автономный Агент

Журнал агента

Новый тендер

Настройка интеграции