{customer.get('phone', '')}\n📍 {customer.get('city', '')}, {customer.get('warehouse', '')}\n🛒 Товари:\n{items_text}💰 Сума: ${total}\n📝 Статус: {status}\n🆔 CRM: {crm_id if str(crm_id).strip() else '—'}\n"
if comment: txt += f"💬 Комент: {comment}"
kb = None
if not str(crm_id).strip() or str(crm_id) in ["—", "0", "None", ""]:
kb = InlineKeyboardMarkup(inline_keyboard=[[InlineKeyboardButton(text="✅ Створити в CRM", callback_data=f"confirm_order_{oid}")]])
await m.answer(txt, reply_markup=kb, parse_mode=ParseMode.HTML)
except Exception as e: await m.answer(f"Помилка: {e}")
# 🔥 НОВИЙ ФУНКЦІОНАЛ: НЕОПЛАЧЕНІ ЗАМОВЛЕННЯ 🔥
@dp.message(F.text == "💸 Неоплачені замовлення")
async def unpaid_orders(m: types.Message):
if str(m.chat.id) != ADMIN_CHAT_ID: return
await m.answer("🔎 Шукаю неоплачені замовлення в CRM...")
try:
# Отримуємо останні 100 замовлень
r = requests.get(
f"{CRM_API_URL}/orders",
headers={"Authorization": HUGEPROFIT_TOKEN},
params={"limit": 100, "order": "id:desc"}
)
if r.status_code != 200:
await m.answer(f"❌ Помилка CRM API: {r.status_code}")
return
orders = r.json().get("data", [])
unpaid_found = 0
for order in orders:
# Фільтруємо по статусу 10787 ("Не оплачено")
if str(order.get('order_status')) == UNPAID_STATUS_ID:
unpaid_found += 1
# Витягуємо дані
oid = order.get('order_number', '???')
date_raw = str(order.get('date_ident', ''))
# Форматування дати: 20260105 -> 05.01.2026
if len(date_raw) == 8:
date_fmt = f"{date_raw[6:8]}.{date_raw[4:6]}.{date_raw[:4]}"
else:
date_fmt = date_raw
amount = float(order.get('amount') or 0.0)
client = order.get('client', {})
client_name = f"{client.get('first_name', '')} {client.get('last_name', '')}".strip()
if not client_name: client_name = "Невідомий клієнт"
# Формуємо повідомлення
msg_text = (
f"⚠️ НЕ ОПЛАЧЕНО\n\n"
f"👤 {client_name}\n"
f"📅 {date_fmt}\n"
f"💰 {amount}$\n"
f"🆔 #{oid}\n\n"
f"👉 Відкрити замовлення в CRM"
)
await m.answer(msg_text, parse_mode="HTML", disable_web_page_preview=True)
if unpaid_found == 0:
await m.answer("✅ Неоплачених замовлень не знайдено.")
else:
await m.answer(f"Знайдено: {unpaid_found} шт.")
except Exception as e:
await m.answer(f"🔥 Помилка при обробці: {e}")
# --- CALLBACKS ---
@dp.callback_query(F.data.startswith("confirm_order_"))
async def confirm(q: types.CallbackQuery):
oid = q.data.split("_")[-1]
cell = orders_sheet.find(oid)
if not cell: await q.answer("Не знайдено"); return
row_num = cell.row; row = orders_sheet.row_values(row_num)
while len(row) < 10: row.append("")
user_email = row[1]
try: items = json.loads(row[3])
except: items = []
try: total_val = float(row[4].replace(',','.'))
except: total_val = 0.0
try: customer_info = json.loads(row[6])
except: customer_info = {}
comment_val = row[7]
crm_id = create_sale_in_crm(oid, items, total_val, customer_info, comment_val)
if crm_id:
orders_sheet.update_cell(row_num, 6, str(crm_id))
orders_sheet.update_cell(row_num, 9, "Створено в CRM")
# 🔥 ВІДПРАВКА ЛИСТА
if user_email and "@" in user_email:
send_email_html(user_email, f"Замовлення #{oid} підтверджено", get_order_email_body(oid, items, total_val))
old_text = q.message.html_text if q.message.html_text else q.message.text
new_text = f"{old_text}\n\n✅ Створено в CRM (ID: {crm_id})"
await q.message.edit_text(new_text, parse_mode=ParseMode.HTML, reply_markup=None)
await q.answer("Оброблено!")
else: await q.answer("❌ Помилка CRM", show_alert=True)
@dp.callback_query(F.data.startswith("reg_approve_"))
async def reg_app(q: types.CallbackQuery):
# Використовуємо split з обмеженням, щоб не ламати email, якщо там є _
parts = q.data.split("_")
email = "_".join(parts[2:]) # reg_approve_email@com -> email@com
cell = users_sheet.find(email)
if cell:
users_sheet.update_cell(cell.row, 4, "TRUE")
# 🔥 ВІДПРАВКА ЛИСТА
send_email_html(email, "Акаунт активовано! Вітаємо", get_activation_email_body(email))
old_text = q.message.html_text if q.message.html_text else q.message.text
await q.message.edit_text(f"{old_text}\n\n✅ АКТИВОВАНО", parse_mode="HTML", reply_markup=None)
else: await q.answer("Не знайдено в таблиці")
@dp.callback_query(F.data.startswith("reg_reject_"))
async def reg_rej(q: types.CallbackQuery):
old_text = q.message.html_text if q.message.html_text else q.message.text
await q.message.edit_text(f"{old_text}\n\n🚫 ВІДХИЛЕНО", parse_mode=ParseMode.HTML, reply_markup=None)
@dp.callback_query(F.data.startswith("up_"))
async def user_status(q: types.CallbackQuery):
parts = q.data.split("_")
# Формат up_T_login або up_F_login
status_code = parts[1]
login = "_".join(parts[2:])
val = "TRUE" if status_code == "T" else "FALSE"
c = users_sheet.find(login)
if c:
users_sheet.update_cell(c.row, 4, val)
await q.answer(f"Статус {login}: {val}")
else:
await q.answer("Користувача не знайдено")
@dp.callback_query(F.data.startswith("del_"))
async def user_del(q: types.CallbackQuery):
login = q.data.split("_", 1)[1]
c = users_sheet.find(login)
if c:
users_sheet.delete_rows(c.row)
await q.message.delete()
else:
await q.answer("Користувача не знайдено")
@dp.message(F.text == "🔄 Оновити таблицю")
async def run_sync_script(m: types.Message):
if str(m.chat.id) != ADMIN_CHAT_ID: return
status_msg = await m.answer("⏳ Запускаю оновлення таблиці (це може зайняти хвилину)...")
# --- ВИПРАВЛЕННЯ ДЛЯ CPANEL ---
# Отримуємо шлях до поточного python (того, що у віртуальному оточенні)
venv_python = sys.executable
# Шукаємо скрипт поруч із ботом
current_dir = os.path.dirname(os.path.abspath(__file__))
script_path = os.path.join(current_dir, "crm2sheets.py")
if not os.path.exists(script_path):
await status_msg.edit_text(f"❌ Помилка: файл {script_path} не знайдено.")
return
try:
# Запускаємо в окремому потоці, щоб не блокувати бота
process = await asyncio.to_thread(subprocess.run, [venv_python, script_path], capture_output=True, text=True)
if process.returncode == 0:
await status_msg.edit_text("✅ Таблицю успішно оновлено!\n\nДані з CRM завантажено.", parse_mode="HTML")
else:
# Показуємо останні 500 символів помилки
error_msg = process.stderr[-500:] if process.stderr else "Unknown error"
await status_msg.edit_text(f"❌ Помилка при оновленні:\n{error_msg}", parse_mode="HTML")
except Exception as e:
await status_msg.edit_text(f"❌ Критична помилка бота: {e}", parse_mode="HTML")
async def main():
await bot.delete_webhook(drop_pending_updates=True)
await dp.start_polling(bot)
if __name__ == "__main__":
print("Bot is starting...")
try:
asyncio.run(main())
except KeyboardInterrupt:
print("Bot stopped by user")
except Exception as e:
print(f"Critical Error: {e}")