+
+ {tone.icon}
+ {headline}
+ {summary.kind !== "low_balance" && (
+
+ {groupsText}
+
+ )}
+ {onClose && (
+
+ )}
-
- {messagesText}
- {period ? ` · ${period}` : ""}
- {tableText ? ` · ${tableText}` : ""}
-
+ {summary.kind !== "low_balance" && (
+
+ {messagesText}
+ {period ? ` · ${period}` : ""}
+ {showTableText && tableText ? ` · ${tableText}` : ""}
+
+ )}
-
- {summary.hasFundsReason
- ? "Пополните счёт SMS-сервиса — отправка возобновится автоматически, повторять вручную ничего не нужно."
- : "Проверьте настройки отправки SMS в разделе «SMS-рассылки»."}
+
+ {hint}
);
diff --git a/src/services/smsProblemSummary.js b/src/services/smsProblemSummary.js
index d66f8a6..c4a7fc9 100644
--- a/src/services/smsProblemSummary.js
+++ b/src/services/smsProblemSummary.js
@@ -3,19 +3,25 @@
* @description Складывает неудачные отправки SMS в одну понятную причину.
*
* В таблице видно только «SMS не отправлено», а причина в логе — код сервиса.
- * Здесь считаем: сколько сообщений, сколько заказов, за какой период и что
- * именно случилось чаще всего (например, что на счёте закончились средства).
+ * Здесь считаем: сколько сообщений, сколько заказов, за какой период, что
+ * случилось чаще всего — и главное, актуальна ли проблема до сих пор (по балансу
+ * счёта SMS-сервиса). Пополнили счёт — предупреждение гасим, а не держим месяцами.
*/
import { getSmsFailureReason } from "./orderGroupViews";
+/** Через сколько дней после последней ошибки показываем, что всё наладилось. */
+export const RESOLVED_VISIBLE_DAYS = 7;
+
/**
* @param {Array} rows строки sms_campaign_log со статусами ошибок
* @param {Array
} visibleIds id заказов, которые сейчас видны в таблице
- * @returns {null|{reason, messages, groups, affectedInTable, hasFundsReason, firstAt, lastAt}}
+ * @param {{balance?: number|null, lowBalance?: number}} options баланс счёта SMS-сервиса
+ * @returns {null|object} null — говорить не о чем
*/
-export const summarizeSmsFailures = (rows = [], visibleIds = []) => {
+export const summarizeSmsFailures = (rows = [], visibleIds = [], options = {}) => {
+ const { balance = null, lowBalance = 100 } = options;
+ const balanceKnown = Number.isFinite(balance);
const list = Array.isArray(rows) ? rows.filter(Boolean) : [];
- if (!list.length) return null;
const reasons = new Map();
const lastByGroup = new Map();
@@ -35,19 +41,53 @@ export const summarizeSmsFailures = (rows = [], visibleIds = []) => {
}
}
- const [reason, topMessages] = [...reasons.entries()].sort((a, b) => b[1] - a[1])[0];
+ const [reason, topMessages] = list.length
+ ? [...reasons.entries()].sort((a, b) => b[1] - a[1])[0]
+ : [null, 0];
+
+ const hasFundsReason = !!reason && /закончились средства/.test(reason);
const visible = new Set(visibleIds);
- return {
+ // Базовая сводка по логу (нужна в любом состоянии).
+ const base = {
reason,
- messages: list.length,
topMessages,
+ messages: list.length,
groups: lastByGroup.size,
affectedInTable: [...lastByGroup.keys()].filter((id) => visible.has(id)).length,
hasVisibleRows: visible.size > 0,
- hasFundsReason: /закончились средства/.test(reason),
+ hasFundsReason,
firstAt,
lastAt,
+ balance,
+ balanceKnown,
+ lowBalanceThreshold: lowBalance,
+ };
+
+ const within = (days) => {
+ if (!lastAt) return false;
+ return Date.now() - new Date(lastAt).getTime() <= days * 86400000;
+ };
+
+ let kind = null;
+ if (!list.length) {
+ // Ошибок нет, но денег на счёте мало — предупреждаем заранее.
+ kind = balanceKnown && balance < lowBalance ? "low_balance" : null;
+ } else if (hasFundsReason && balanceKnown && balance >= lowBalance) {
+ // Деньги пополнены — проблема снята, показываем это недолго и без нагнетания.
+ kind = within(RESOLVED_VISIBLE_DAYS) ? "resolved" : null;
+ } else if (hasFundsReason) {
+ kind = "funds";
+ } else {
+ kind = "other";
+ }
+
+ if (!kind) return null;
+
+ return {
+ ...base,
+ kind,
+ signature: [kind, reason || "", lastAt || "", balanceKnown ? Math.round(balance) : ""].join("|"),
};
};
diff --git a/src/services/smsProblemSummary.test.js b/src/services/smsProblemSummary.test.js
index fcda378..d6d9f11 100644
--- a/src/services/smsProblemSummary.test.js
+++ b/src/services/smsProblemSummary.test.js
@@ -1,7 +1,7 @@
/**
* @file smsProblemSummary.test.js
- * @description Причина неудачных SMS для блока над таблицей: считаем по логу,
- * чаще всего встречающуюся причину пишем словами, пустой лог — ничего не показываем.
+ * @description Что показывать над таблицей: причина недоставки, «всё наладилось»,
+ * предупреждение о низком балансе — и когда не показывать ничего.
*/
import { describe, it, expect } from "vitest";
import { summarizeSmsFailures } from "./smsProblemSummary";
@@ -16,7 +16,9 @@ const row = (over = {}) => ({
...over,
});
-describe("summarizeSmsFailures", () => {
+const daysAgo = (days) => new Date(Date.now() - days * 86400000).toISOString();
+
+describe("summarizeSmsFailures — причина недоставки", () => {
it("объясняет нехватку средств и считает заказы с сообщениями", () => {
const summary = summarizeSmsFailures([
row({ order_group_id: "g1", created_at: "2026-09-10T10:06:11Z" }),
@@ -24,19 +26,11 @@ describe("summarizeSmsFailures", () => {
row({ order_group_id: "g2", created_at: "2026-09-13T06:03:04Z" }),
], ["g1", "g2"]);
+ expect(summary.kind).toBe("funds");
expect(summary.reason).toBe("на счёте SMS-сервиса закончились средства");
- expect(summary.hasFundsReason).toBe(true);
expect(summary.groups).toBe(2);
expect(summary.messages).toBe(3);
expect(summary.affectedInTable).toBe(2);
- expect(summary.firstAt).toBe("2026-09-10T10:06:11Z");
- expect(summary.lastAt).toBe("2026-09-13T06:03:03Z".replace("06:03:03", "06:03:04"));
- });
-
- it("не считает заказ в таблице, если его там нет", () => {
- const summary = summarizeSmsFailures([row({ order_group_id: "g9" })], ["g1"]);
- expect(summary.affectedInTable).toBe(0);
- expect(summary.hasVisibleRows).toBe(true);
});
it("берёт самую частую причину, когда их несколько", () => {
@@ -50,15 +44,60 @@ describe("summarizeSmsFailures", () => {
expect(summary.topMessages).toBe(2);
});
- it("пустой лог — нет повода что-то показывать", () => {
- expect(summarizeSmsFailures([], ["g1"])).toBeNull();
- expect(summarizeSmsFailures(null, [])).toBeNull();
- });
-
- it("без id заказов причина всё равно объясняется", () => {
- const summary = summarizeSmsFailures([row()], []);
- expect(summary.hasFundsReason).toBe(true);
- expect(summary.hasVisibleRows).toBe(false);
- expect(summary.affectedInTable).toBe(0);
+ it("другая причина — отдельный вид блока", () => {
+ const summary = summarizeSmsFailures([row({ sms_code: "202", error_message: "202" })], []);
+ expect(summary.kind).toBe("other");
+ });
+});
+
+describe("summarizeSmsFailures — актуальность по балансу", () => {
+ it("счёт пополнен: вместо красного предупреждения — «всё наладилось»", () => {
+ const summary = summarizeSmsFailures([row({ created_at: daysAgo(1) })], [], { balance: 12717.45 });
+ expect(summary.kind).toBe("resolved");
+ expect(summary.balance).toBe(12717.45);
+ });
+
+ it("денег на счёте нет: проблема актуальна", () => {
+ const summary = summarizeSmsFailures([row({ created_at: daysAgo(1) })], [], { balance: 42 });
+ expect(summary.kind).toBe("funds");
+ });
+
+ it("баланс узнать не удалось — считаем проблему актуальной", () => {
+ const summary = summarizeSmsFailures([row({ created_at: daysAgo(1) })], [], { balance: null });
+ expect(summary.kind).toBe("funds");
+ });
+
+ it("старая история не висит месяцами: неделя прошла — не показываем", () => {
+ const summary = summarizeSmsFailures([row({ created_at: daysAgo(8) })], [], { balance: 12717.45 });
+ expect(summary).toBeNull();
+ });
+
+ it("ошибок нет, но денег мало — предупреждаем заранее", () => {
+ const summary = summarizeSmsFailures([], [], { balance: 55 });
+ expect(summary.kind).toBe("low_balance");
+ expect(summary.balance).toBe(55);
+ expect(summary.reason).toBeNull();
+ });
+
+ it("ошибок нет и денег достаточно — блок не нужен", () => {
+ expect(summarizeSmsFailures([], [], { balance: 12717.45 })).toBeNull();
+ expect(summarizeSmsFailures(null, [], { balance: null })).toBeNull();
+ });
+});
+
+describe("отпечаток состояния для закрытия блока", () => {
+ it("меняется, когда проблема другая — закрытый блок вернётся с новой ошибкой", () => {
+ const first = summarizeSmsFailures([row({ created_at: daysAgo(1) })], [], { balance: 42 });
+ const second = summarizeSmsFailures([row({ created_at: daysAgo(2) })], [], { balance: 42 });
+ const third = summarizeSmsFailures([row({ created_at: daysAgo(1), sms_code: "202", error_message: "202" })], [], { balance: 42 });
+
+ expect(first.signature).not.toBe(second.signature);
+ expect(first.signature).not.toBe(third.signature);
+ });
+
+ it("одинаковые данные — одинаковый отпечаток (повторно не всплывает)", () => {
+ const a = summarizeSmsFailures([row({ created_at: daysAgo(1) })], [], { balance: 42 });
+ const b = summarizeSmsFailures([row({ created_at: daysAgo(1) })], [], { balance: 42 });
+ expect(a.signature).toBe(b.signature);
});
});
diff --git a/supabase/functions/sms-balance/index.ts b/supabase/functions/sms-balance/index.ts
new file mode 100644
index 0000000..80d6963
--- /dev/null
+++ b/supabase/functions/sms-balance/index.ts
@@ -0,0 +1,72 @@
+/** Баланс счёта SMS-сервиса — для предупреждения в интерфейсе.
+ *
+ * Зачем: 10–13 сентября рассылки падали с кодом 201 («не хватает средств»),
+ * и об этом никто не знал. Ключ доступа к SMS живёт только на сервере, поэтому
+ * баланс отдаём отдельной функцией, а не читаем ключ в браузере.
+ */
+import { createClient } from "npm:@supabase/supabase-js@2";
+
+const ALLOWED_ORIGINS = [
+ "https://dost.supersamsev.ru",
+ "https://supa.supersamsev.ru",
+ "https://dev.mkn8n.ru",
+ "http://localhost:5173",
+];
+
+const BALANCE_URL = "https://sms.ru/my/balance";
+// Ниже этого остатка предупреждаем заранее, до остановки отправки.
+const LOW_BALANCE_RUB = 100;
+
+const cors = (origin: string) => ({
+ "Access-Control-Allow-Origin": ALLOWED_ORIGINS.includes(origin) ? origin : ALLOWED_ORIGINS[0],
+ "Access-Control-Allow-Methods": "POST,GET,OPTIONS",
+ "Access-Control-Allow-Headers": "Content-Type,Authorization,apikey",
+});
+
+Deno.serve(async (req: Request) => {
+ const origin = req.headers.get("origin") || "";
+ const headers = { ...cors(origin), "Content-Type": "application/json" };
+
+ if (req.method === "OPTIONS") return new Response(null, { headers });
+
+ try {
+ const supabaseUrl = Deno.env.get("SUPABASE_URL") || "";
+ const serviceKey = Deno.env.get("SUPABASE_SERVICE_ROLE_KEY") || "";
+ const sb = createClient(supabaseUrl, serviceKey);
+
+ const { data: settings } = await sb
+ .from("sms_campaign_settings")
+ .select("sms_api_id")
+ .eq("campaign_type", "first_sms")
+ .single();
+
+ const apiId = settings?.sms_api_id || Deno.env.get("SMS_API_ID") || "";
+ if (!apiId) {
+ return new Response(JSON.stringify({ ok: false, error: "api_id not configured" }), { status: 500, headers });
+ }
+
+ const resp = await fetch(`${BALANCE_URL}?api_id=${encodeURIComponent(apiId)}&json=1`);
+ const text = await resp.text();
+
+ let payload: Record = {};
+ try {
+ payload = JSON.parse(text);
+ } catch {
+ return new Response(JSON.stringify({ ok: false, error: "unexpected response", raw: text.slice(0, 200) }), { status: 200, headers });
+ }
+
+ if (payload.status !== "OK") {
+ return new Response(JSON.stringify({ ok: false, code: payload.status_code ?? null, raw: text.slice(0, 200) }), { status: 200, headers });
+ }
+
+ const balance = Number(payload.balance);
+ return new Response(JSON.stringify({
+ ok: true,
+ balance,
+ low: balance < LOW_BALANCE_RUB,
+ threshold: LOW_BALANCE_RUB,
+ }), { headers });
+ } catch (e) {
+ return new Response(JSON.stringify({ ok: false, error: String(e) }), { status: 500, headers });
+ }
+});