diff --git a/app/main.py b/app/main.py index 335e041..abf5156 100644 --- a/app/main.py +++ b/app/main.py @@ -72,6 +72,10 @@ ADMIN_TOKEN = os.getenv("ADMIN_TOKEN", "") # ── Подписка через Telegram-бота (подписанные deep-link) ────────────────────── SUB_LINK_SECRET = os.getenv("SUB_LINK_SECRET", "") # общий секрет бота и веба +# ── Уведомления о платежах в Telegram ───────────────────────────────────────── +BOT_TOKEN = os.getenv("TOKEN", "") +PAYMENT_NOTIFY_CHAT_ID = int(os.getenv("PAYMENT_NOTIFY_CHAT_ID", "156921693")) + # ── Вход по почте (magic-code через SMTP) ───────────────────────────────────── SMTP_HOST = os.getenv("SMTP_HOST", "") SMTP_PORT = int(os.getenv("SMTP_PORT", "465")) @@ -362,6 +366,13 @@ def _db_ensure_auth_table(): con.execute(f"ALTER TABLE WEB_ACCOUNTS ADD COLUMN {_c} {_ddl}") except Exception as _amig: print(f"WEB_ACCOUNTS migrate error: {_amig}") + # Авто-миграция WEB_PAYMENTS: флаг отправленного уведомления (дедуп) + try: + pcols = {row[1] for row in con.execute("PRAGMA table_info(WEB_PAYMENTS)")} + if "notified" not in pcols: + con.execute("ALTER TABLE WEB_PAYMENTS ADD COLUMN notified INTEGER DEFAULT 0") + except Exception as _pmig: + print(f"WEB_PAYMENTS migrate error: {_pmig}") con.commit() except Exception as e: print(f"WEB_AUTH_TOKENS create error: {e}") @@ -1748,6 +1759,45 @@ def _db_set_autorenew_flag(account_id, enable: bool) -> dict: return {"autorenew": False, "has_method": False} +def _tg_send(chat_id, text): + """Отправка сообщения в Telegram напрямую через Bot API (для уведомлений из веба).""" + if not BOT_TOKEN or not chat_id: + return + try: + data = _urlparse.urlencode({"chat_id": chat_id, "text": text, + "disable_web_page_preview": "true"}).encode() + req = _urlreq.Request(f"https://api.telegram.org/bot{BOT_TOKEN}/sendMessage", + data=data, method="POST") + with _urlreq.urlopen(req, timeout=15) as resp: + resp.read() + except Exception as e: + print(f"tg notify error: {e}") + + +def _notify_owner_payment(payment_id): + """Уведомляет владельца об УСПЕШНОМ платеже. Дедуп через WEB_PAYMENTS.notified (шлём один раз).""" + try: + with sqlite3.connect(DB_PATH, timeout=10) as con: + con.row_factory = sqlite3.Row + cur = con.execute("UPDATE WEB_PAYMENTS SET notified=1 WHERE payment_id=? AND COALESCE(notified,0)=0", + (payment_id,)) + con.commit() + if cur.rowcount != 1: + return # уже уведомляли + row = con.execute("SELECT amount, purpose, email FROM WEB_PAYMENTS WHERE payment_id=?", + (payment_id,)).fetchone() + except Exception: + return + if not row: + return + label = {"donate": "Донат", "api_pro": "API-тариф", "file": "Оплата файла", + "sub": "Подписка"}.get(row["purpose"], row["purpose"] or "Платёж") + text = f"💰 Оплата получена\n{label}: {int(round(row['amount'] or 0))} ₽" + if row["email"]: + text += f"\n📧 {row['email']}" + _tg_send(PAYMENT_NOTIFY_CHAT_ID, text) + + def _db_mark_payment_paid(payment_id, purpose, api_key, extra=None, payment_method=None): """extra: metadata платежа (job_id для file, account_id для sub). payment_method: объект payment_method из ЮKassa (для сохранения при автопродлении).""" @@ -1777,6 +1827,8 @@ def _db_mark_payment_paid(payment_id, purpose, api_key, extra=None, payment_meth job_id = extra.get("job_id") if job_id and _db_get_url_res_f(job_id) == "awaiting_payment": _db_set_url_res_f(job_id, "-") + # Уведомление владельцу в Telegram (в отдельном потоке — не блокируем event loop) + threading.Thread(target=_notify_owner_payment, args=(payment_id,), daemon=True).start() except Exception as e: print(f"mark paid error: {e}") @@ -2681,6 +2733,8 @@ _ADMIN_HTML = """ .bars{ display:flex; align-items:flex-end; gap:5px; height:90px; } .bars .b{ flex:1; background:var(--blue); border-radius:4px 4px 0 0; min-height:2px; position:relative; opacity:.85; } .bars .b span{ position:absolute; bottom:-18px; left:0; right:0; text-align:center; font-size:10px; color:var(--sec); } + .bars .b b{ position:absolute; top:-15px; left:0; right:0; text-align:center; font-size:10px; font-weight:600; color:var(--ink); } + .bars{ margin-top:16px; } .muted{ color:var(--sec); } #gate{ max-width:360px; margin:80px auto; background:#fff; border-radius:16px; padding:24px; text-align:center; } #gate input{ width:100%; padding:11px 12px; border:1px solid var(--line); border-radius:10px; font:inherit; margin:14px 0; } @@ -2711,6 +2765,7 @@ _ADMIN_HTML = """
Доход (успешно)
—
Заходы сегодня
—
Документов обработано
—
+
Время обработки
—
@@ -2724,6 +2779,12 @@ _ADMIN_HTML = """
+
+

По дням

+
+
ДатаЗаходыУник.ФайловСтраницИсходникРезультат
+
+

Платежи

@@ -2746,6 +2807,7 @@ _ADMIN_HTML = """ function esc(s){ return String(s==null?'':s).replace(/[&<>"]/g, function(c){ return {'&':'&','<':'<','>':'>','"':'"'}[c]; }); } function money(v){ return Math.round(v||0).toLocaleString('ru-RU') + ' ₽'; } function size(mb){ if(mb==null) return '—'; mb=+mb; if(!mb) return '—'; return mb>=1024 ? (mb/1024).toFixed(2)+' ГБ' : mb.toFixed(1)+' МБ'; } + function dur(sec){ sec=Math.round(sec||0); if(sec<60) return sec+' с'; var m=Math.floor(sec/60); if(m<60) return m+' мин'; var h=Math.floor(m/60); if(h<24) return h+' ч '+(m%60)+' мин'; return Math.floor(h/24)+' дн '+(h%24)+' ч'; } function dts(ts){ if(!ts) return '—'; var d=new Date(ts*1000); return d.toLocaleString('ru-RU',{day:'2-digit',month:'2-digit',year:'numeric',hour:'2-digit',minute:'2-digit'}); } function dOnly(ts){ if(!ts) return '—'; var d=new Date(ts*1000); return d.toLocaleDateString('ru-RU'); } function daysLeft(ts){ var s=Math.max(0,(ts*1000-Date.now())/86400000); return s>=365 ? Math.round(s/365)+' г.' : Math.round(s)+' дн.'; } @@ -2776,6 +2838,8 @@ _ADMIN_HTML = """ document.getElementById('m-vis-sub').textContent = 'уник. ' + (d.visits.unique_today||0).toLocaleString('ru-RU') + ' · 7 дн. ' + (d.visits.last7||0).toLocaleString('ru-RU'); document.getElementById('m-docs').textContent = (d.docs.total_count||0).toLocaleString('ru-RU'); document.getElementById('m-docs-sub').textContent = (d.docs.total_pages||0).toLocaleString('ru-RU') + ' стр. · ' + size(d.docs.total_result_mb); + document.getElementById('m-time').textContent = dur(d.docs.total_seconds); + document.getElementById('m-time-sub').textContent = '~' + (d.docs.avg_page_seconds||0).toFixed(1) + ' с/стр'; // Подписки var subs = d.subs.list || []; @@ -2789,11 +2853,20 @@ _ADMIN_HTML = """ document.getElementById('bars').innerHTML = days.length ? days.map(function(x){ var h = Math.round(x.count/mx*100); var dd = x.day.slice(8)+'.'+x.day.slice(5,7); - return '
'+dd+'
'; + return '
'+x.count+''+dd+'
'; }).join('') : '
Пока нет данных
'; document.getElementById('vis-total').textContent = '· всего ' + (d.visits.total||0).toLocaleString('ru-RU') + ' (уник. ' + (d.visits.unique_total||0).toLocaleString('ru-RU') + ')'; + // По дням (свежие сверху) + var daily = (d.daily||[]).slice().reverse(); + document.getElementById('t-daily').innerHTML = daily.length ? daily.map(function(x){ + var dd = x.day.slice(8)+'.'+x.day.slice(5,7)+'.'+x.day.slice(0,4); + return ''; + }).join('') : ''; + // Платежи var bp = d.payments.by_purpose || {}; document.getElementById('pay-breakdown').textContent = '· ' + Object.keys(bp).map(function(k){ @@ -2939,8 +3012,41 @@ def _admin_collect_stats() -> dict: agg = con.execute( f"SELECT COUNT(*) c, COALESCE(SUM({pages_expr}),0) p, " "COALESCE(SUM(source_size_mb),0) ssz, COALESCE(SUM(result_size_mb),0) rsz FROM FILES").fetchone() + # Общее время обработки + среднее на страницу (elapsed_time = 'H:MM:SS.ffffff') + tot_sec = 0.0 + pages_timed = 0 + for r in con.execute( + f"SELECT elapsed_time AS et, {pages_expr} AS pg FROM FILES " + "WHERE elapsed_time IS NOT NULL AND TRIM(elapsed_time) NOT IN ('','-')"): + try: + pp = str(r["et"]).split(":") + if len(pp) == 3: + tot_sec += int(pp[0]) * 3600 + int(pp[1]) * 60 + float(pp[2]) + pages_timed += (r["pg"] or 0) + except Exception: + pass out["docs"] = {"recent": docs, "total_count": agg["c"], "total_pages": agg["p"], - "total_source_mb": agg["ssz"], "total_result_mb": agg["rsz"]} + "total_source_mb": agg["ssz"], "total_result_mb": agg["rsz"], + "total_seconds": tot_sec, "avg_page_seconds": (tot_sec / pages_timed) if pages_timed else 0} + # По дням: заходы/уник + файлы/страницы/размеры (последние 14 дней) + _today = datetime.date.today() + _cutoff = (_today - datetime.timedelta(days=13)).strftime("%Y.%m.%d") + files_by_day = {} + for r in con.execute( + f"SELECT date AS d, COUNT(*) c, COALESCE(SUM({pages_expr}),0) p, " + "COALESCE(SUM(source_size_mb),0) s, COALESCE(SUM(result_size_mb),0) rs " + "FROM FILES WHERE date >= ? GROUP BY date", (_cutoff,)): + files_by_day[(r["d"] or "").replace(".", "-")] = { + "files": r["c"], "pages": r["p"], "src_mb": r["s"], "res_mb": r["rs"]} + daily = [] + for i in range(13, -1, -1): + dkey = (_today - datetime.timedelta(days=i)).strftime("%Y-%m-%d") + vc = next((x["count"] for x in days if x["day"] == dkey), 0) + fb = files_by_day.get(dkey, {}) + daily.append({"day": dkey, "visits": vc, "uniques": udays.get(dkey, 0), + "files": fb.get("files", 0), "pages": fb.get("pages", 0), + "src_mb": fb.get("src_mb", 0), "res_mb": fb.get("res_mb", 0)}) + out["daily"] = daily return out
ДатаСуммаНазначениеСтатусEmail
'+dd+''+(x.visits||0)+''+(x.uniques||0)+ + ''+(x.files||0)+''+(x.pages||0).toLocaleString('ru-RU')+ + ''+size(x.src_mb)+''+size(x.res_mb)+'
Пока нет данных