hot_leads_sender
This commit is contained in:
@@ -23,6 +23,11 @@ def build_sender_kb() -> InlineKeyboardMarkup:
|
||||
text="📍 Не использовавшие триал", callback_data=AdminSenderCallback(type="untrial").pack()
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(
|
||||
text="🔥 Горячие лиды", callback_data=AdminSenderCallback(type="hotleads").pack()
|
||||
)
|
||||
)
|
||||
builder.row(
|
||||
InlineKeyboardButton(text="📢 Кластер", callback_data=AdminSenderCallback(type="cluster-select").pack())
|
||||
)
|
||||
|
||||
@@ -114,6 +114,17 @@ async def handle_message_input(message: Message, state: FSMContext, session: Any
|
||||
""",
|
||||
cluster_name,
|
||||
)
|
||||
elif send_to == "hotleads":
|
||||
tg_ids = await session.fetch(
|
||||
"""
|
||||
SELECT DISTINCT u.tg_id
|
||||
FROM users u
|
||||
JOIN payments p ON u.tg_id = p.tg_id
|
||||
LEFT JOIN keys k ON u.tg_id = k.tg_id
|
||||
WHERE p.status = 'success'
|
||||
AND k.tg_id IS NULL
|
||||
"""
|
||||
)
|
||||
else:
|
||||
tg_ids = await session.fetch("SELECT DISTINCT tg_id FROM users")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user