bot.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
Vergi Hatırlatıcı Telegram Bot
GİB vergi güncellemelerini kullanıcılara ileten Telegram bot
"""

import os
import logging
import asyncio
from datetime import datetime, timedelta
from typing import List, Dict
import json

from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup
from telegram.ext import (
    Application, 
    CommandHandler, 
    CallbackQueryHandler,
    MessageHandler,
    filters,
    ContextTypes
)
from telegram.constants import ParseMode

from database import DatabaseConnection
from scraper import GIBScraper

class VergiBot:
    """Vergi Hatırlatıcı Bot Ana Sınıfı"""
    
    def __init__(self, token: str):
        self.token = token
        self.app = Application.builder().token(token).build()
        self.db = DatabaseConnection()
        self.scraper = GIBScraper()
        
        # Logging setup
        self.setup_logging()
        
        # Bot komutlarını kaydet
        self.register_handlers()
        
    def setup_logging(self):
        """Logging konfigürasyonu"""
        logging.basicConfig(
            level=logging.INFO,
            format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
            handlers=[
                logging.FileHandler('logs/bot.log', encoding='utf-8'),
                logging.StreamHandler()
            ]
        )
        self.logger = logging.getLogger(__name__)
        
    def register_handlers(self):
        """Bot komut handler'larını kaydet"""
        # Komut handler'ları
        self.app.add_handler(CommandHandler("start", self.start_command))
        self.app.add_handler(CommandHandler("yardim", self.help_command))
        self.app.add_handler(CommandHandler("guncellemeler", self.updates_command))
        self.app.add_handler(CommandHandler("duyurular", self.announcements_command))
        self.app.add_handler(CommandHandler("takvim", self.calendar_command))
        self.app.add_handler(CommandHandler("hatirlatici", self.reminder_command))
        self.app.add_handler(CommandHandler("durum", self.status_command))
        self.app.add_handler(CommandHandler("test", self.test_command))
        
        # Callback handler'ı
        self.app.add_handler(CallbackQueryHandler(self.button_callback))
        
        # Mesaj handler'ı
        self.app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, self.handle_message))
        
    async def start_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Bot başlatma komutu"""
        user = update.effective_user
        chat_id = update.effective_chat.id
        
        try:
            # Kullanıcıyı veritabanına kaydet
            self.db.execute_query(
                """INSERT IGNORE INTO users (user_id, username, chat_id, created_at, is_active) 
                   VALUES (%s, %s, %s, %s, %s)""",
                (user.id, user.username or "Unknown", chat_id, datetime.now(), True)
            )
            
            welcome_message = f"""
🏛️ **Vergi Hatırlatıcı Bot'a Hoş Geldiniz!**

Merhaba {user.first_name}! 

Bu bot, Gelir İdaresi Başkanlığı'ndan (GİB) vergi güncellemelerini takip etmenize yardımcı olur.

📋 **Mevcut Özellikler:**
• Güncel vergi duyuruları
• Vergi takvimi hatırlatmaları  
• Beyanname son teslim tarihleri
• KDV, Kurumlar Vergisi güncellemeleri
• Otomatik hatırlatmalar

🎯 **Kullanılabilir Komutlar:**
/guncellemeler - Son vergi güncellemeleri
/duyurular - GİB duyuruları
/takvim - Vergi takvimi
/hatirlatici - Hatırlatma ayarları
/yardim - Tüm komutlar
/durum - Bot durumu

Başlamak için /guncellemeler komutunu kullanabilirsiniz!
            """
            
            # Hızlı menü keyboard'u
            keyboard = [
                [InlineKeyboardButton("📢 Son Güncellemeler", callback_data="updates")],
                [InlineKeyboardButton("📅 Vergi Takvimi", callback_data="calendar")],
                [InlineKeyboardButton("🔔 Hatırlatıcı Ayarla", callback_data="reminder")],
                [InlineKeyboardButton("ℹ️ Yardım", callback_data="help")]
            ]
            reply_markup = InlineKeyboardMarkup(keyboard)
            
            await update.message.reply_text(
                welcome_message, 
                parse_mode=ParseMode.MARKDOWN,
                reply_markup=reply_markup
            )
            
            self.logger.info(f"Yeni kullanıcı kaydedildi: {user.id} - {user.username}")
            
        except Exception as e:
            self.logger.error(f"Start command hatası: {str(e)}")
            await update.message.reply_text("❌ Bir hata oluştu. Lütfen tekrar deneyin.")
            
    async def help_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Yardım komutu"""
        help_text = """
📖 **Vergi Hatırlatıcı Bot - Komut Rehberi**

🔸 **/start** - Bot'u başlat
🔸 **/guncellemeler** - En son vergi güncellemeleri
🔸 **/duyurular** - GİB resmi duyuruları  
🔸 **/takvim** - Bu ay ve gelecek ay vergi tarihleri
🔸 **/hatirlatici** - Otomatik hatırlatma ayarları
🔸 **/durum** - Bot ve sistem durumu
🔸 **/test** - Bağlantı testi
🔸 **/yardim** - Bu yardım menüsü

💡 **İpuçları:**
• Bot günlük otomatik güncelleme yapar
• Önemli tarihlerde hatırlatma gönderir
• Tüm veriler GİB'den çekilir

❓ Sorun yaşıyorsanız /test komutunu deneyin.
        """
        
        await update.message.reply_text(help_text, parse_mode=ParseMode.MARKDOWN)
        
    async def updates_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Son güncellemeler komutu"""
        try:
            await update.message.reply_text("🔄 Son vergi güncellemeleri çekiliyor...")
            
            # Scraper'dan güncellemeleri çek
            updates_data = self.scraper.get_all_updates()
            
            message_parts = ["📢 **SON VERGİ GÜNCELLEMELERİ**\n"]
            
            # Duyuruları ekle
            if updates_data['announcements']:
                message_parts.append("🏛️ **GİB Duyuruları:**")
                for i, announcement in enumerate(updates_data['announcements'][:5], 1):
                    date_str = announcement['date'].strftime("%d.%m.%Y")
                    message_parts.append(f"{i}. {announcement['title']}")
                    message_parts.append(f"   📅 {date_str} | 🔗 [Detay]({announcement['url']})\n")
            
            # Haberleri ekle  
            if updates_data['news']:
                message_parts.append("\n📰 **Vergi Haberleri:**")
                for i, news in enumerate(updates_data['news'][:3], 1):
                    date_str = news['date'].strftime("%d.%m.%Y")
                    message_parts.append(f"{i}. {news['title']}")
                    message_parts.append(f"   📝 {news['content'][:100]}...")
                    message_parts.append(f"   📅 {date_str}\n")
            
            message_parts.append(f"\n🕐 Son güncelleme: {datetime.now().strftime('%d.%m.%Y %H:%M')}")
            
            full_message = "\n".join(message_parts)
            
            await update.message.reply_text(
                full_message, 
                parse_mode=ParseMode.MARKDOWN,
                disable_web_page_preview=True
            )
            
        except Exception as e:
            self.logger.error(f"Updates command hatası: {str(e)}")
            await update.message.reply_text("❌ Güncellemeler yüklenirken hata oluştu.")
            
    async def announcements_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Duyurular komutu"""
        try:
            await update.message.reply_text("📢 GİB duyuruları yükleniyor...")
            
            announcements = self.scraper.scrape_gib_announcements()
            
            if not announcements:
                await update.message.reply_text("📭 Şu anda yeni duyuru bulunmuyor.")
                return
                
            message_parts = ["📢 **GİB RESMİ DUYURULARI**\n"]
            
            for i, announcement in enumerate(announcements[:8], 1):
                date_str = announcement['date'].strftime("%d.%m.%Y")
                message_parts.append(f"**{i}. {announcement['title']}**")
                message_parts.append(f"🏛️ Kaynak: {announcement['source']}")
                message_parts.append(f"📅 Tarih: {date_str}")
                message_parts.append(f"🔗 [Detaylı Bilgi]({announcement['url']})\n")
                
            full_message = "\n".join(message_parts)
            
            await update.message.reply_text(
                full_message,
                parse_mode=ParseMode.MARKDOWN,
                disable_web_page_preview=True
            )
            
        except Exception as e:
            self.logger.error(f"Announcements command hatası: {str(e)}")
            await update.message.reply_text("❌ Duyurular yüklenirken hata oluştu.")
            
    async def calendar_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Vergi takvimi komutu"""
        try:
            await update.message.reply_text("📅 Vergi takvimi yükleniyor...")
            
            calendar_data = self.scraper.scrape_tax_calendar()
            
            # Yaklaşan tarihleri filtrele (30 gün içinde)
            now = datetime.now()
            upcoming_dates = [
                item for item in calendar_data 
                if item['deadline_date'] >= now and item['deadline_date'] <= now + timedelta(days=30)
            ]
            
            if not upcoming_dates:
                await update.message.reply_text("📅 Önümüzdeki 30 gün içinde vergi yükümlülüğü bulunmuyor.")
                return
                
            # Tarihe göre sırala
            upcoming_dates.sort(key=lambda x: x['deadline_date'])
            
            message_parts = ["📅 **YAKIN VERGİ TARİHLERİ** (30 Gün)\n"]
            
            for i, tax_date in enumerate(upcoming_dates[:8], 1):
                days_left = (tax_date['deadline_date'] - now).days
                date_str = tax_date['deadline_date'].strftime("%d.%m.%Y")
                
                if days_left <= 3:
                    urgency = "🚨"
                elif days_left <= 7:
                    urgency = "⚠️"
                else:
                    urgency = "📋"
                    
                message_parts.append(f"{urgency} **{tax_date['tax_type']}**")
                message_parts.append(f"📅 Son Tarih: {date_str} ({days_left} gün kaldı)")
                message_parts.append(f"📝 {tax_date['description']}\n")
                
            full_message = "\n".join(message_parts)
            
            await update.message.reply_text(full_message, parse_mode=ParseMode.MARKDOWN)
            
        except Exception as e:
            self.logger.error(f"Calendar command hatası: {str(e)}")
            await update.message.reply_text("❌ Vergi takvimi yüklenirken hata oluştu.")

    async def reminder_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Hatırlatıcı ayarlama komutu"""
        try:
            keyboard = [
                [InlineKeyboardButton("🔔 1 gün önceden", callback_data="remind_1")],
                [InlineKeyboardButton("🔔 3 gün önceden", callback_data="remind_3")],
                [InlineKeyboardButton("🔔 1 hafta önceden", callback_data="remind_7")],
                [InlineKeyboardButton("❌ Hatırlatıcıyı Kapat", callback_data="remind_off")]
            ]
            reply_markup = InlineKeyboardMarkup(keyboard)
            
            message = """
🔔 **HATIRLATICI AYARLARI**

Vergi yükümlülükleriniz için ne kadar önceden hatırlatma almak istiyorsunuz?

**Mevcut Hatırlatmalar:**
• Kurumlar Vergisi beyannamesi
• KDV beyannamesi  
• Muhtasar beyanname
• Gelir vergisi stopajı
• Diğer önemli vergi tarihleri

Aşağıdan bir seçenek seçin:
            """
            
            await update.message.reply_text(
                message, 
                parse_mode=ParseMode.MARKDOWN,
                reply_markup=reply_markup
            )
            
        except Exception as e:
            self.logger.error(f"Reminder command hatası: {str(e)}")
            await update.message.reply_text("❌ Hatırlatıcı ayarları yüklenirken hata oluştu.")
            
    async def status_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Bot durumu komutu"""
        try:
            db_status = "✅ Bağlı"
            try:
                self.db.execute_query("SELECT 1")
            except:
                db_status = "❌ Bağlantı sorunu"
                
            status_message = f"""
🤖 **BOT DURUM RAPORU**

**Sistem Durumu:**
🗄️ Veritabanı: {db_status}
🌐 Web Scraper: ✅ Çalışıyor
👥 Aktif Kullanıcı: {self.db.get_user_count()}

**Bot Bilgileri:**
📅 Son güncelleme: {datetime.now().strftime('%d.%m.%Y %H:%M')}
⚡ Uptime: Bot aktif
🔄 Otomatik güncelleme: Açık

✅ **Sistem normal çalışıyor!**
            """
            
            await update.message.reply_text(status_message, parse_mode=ParseMode.MARKDOWN)
            
        except Exception as e:
            self.logger.error(f"Status command hatası: {str(e)}")
            await update.message.reply_text("❌ Durum bilgisi alınırken hata oluştu.")
            
    async def test_command(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Test komutu"""
        try:
            await update.message.reply_text("🔧 Sistem testleri başlatılıyor...")
            
            test_results = []
            
            try:
                self.db.execute_query("SELECT 1")
                test_results.append("✅ Veritabanı bağlantısı: OK")
            except Exception as e:
                test_results.append(f"❌ Veritabanı bağlantısı: HATA")
                
            try:
                updates = self.scraper.get_all_updates()
                if updates and len(updates.get('news', [])) > 0:
                    test_results.append("✅ Web scraper: OK")
                else:
                    test_results.append("⚠️ Web scraper: Veri bulunamadı")
            except Exception as e:
                test_results.append(f"❌ Web scraper: HATA")
                
            test_results.append("✅ Bot komutları: OK")
                
            test_message = f"""
🔧 **SİSTEM TEST SONUÇLARI**

{chr(10).join(test_results)}

🕐 Test tamamlanma zamanı: {datetime.now().strftime('%d.%m.%Y %H:%M:%S')}

Sorun devam ediyorsa /yardim komutunu kullanın.
            """
            
            await update.message.reply_text(test_message, parse_mode=ParseMode.MARKDOWN)
            
        except Exception as e:
            self.logger.error(f"Test command hatası: {str(e)}")
            await update.message.reply_text("❌ Test işlemi sırasında hata oluştu.")
            
    async def button_callback(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Inline keyboard button callback'i"""
        query = update.callback_query
        await query.answer()
        
        try:
            if query.data == "updates":
                await self.updates_command(update, context)
            elif query.data == "calendar":
                await self.calendar_command(update, context)
            elif query.data == "reminder":
                await self.reminder_command(update, context)
            elif query.data == "help":
                await self.help_command(update, context)
            elif query.data.startswith("remind_"):
                await self.handle_reminder_setting(update, context, query.data)
                
        except Exception as e:
            self.logger.error(f"Button callback hatası: {str(e)}")
            await query.edit_message_text("❌ İşlem sırasında hata oluştu.")
            
    async def handle_reminder_setting(self, update: Update, context: ContextTypes.DEFAULT_TYPE, callback_data: str):
        """Hatırlatıcı ayarlarını işle"""
        query = update.callback_query
        user_id = update.effective_user.id
        
        try:
            if callback_data == "remind_off":
                self.db.execute_query(
                    "UPDATE users SET reminder_days = NULL WHERE user_id = %s",
                    (user_id,)
                )
                await query.edit_message_text(
                    "🔕 Hatırlatıcılar kapatıldı.\n\nİstediğiniz zaman /hatirlatici komutu ile tekrar açabilirsiniz."
                )
            else:
                days = int(callback_data.split("_")[1])
                
                self.db.execute_query(
                    "UPDATE users SET reminder_days = %s WHERE user_id = %s",
                    (days, user_id)
                )
                
                await query.edit_message_text(
                    f"✅ Hatırlatıcı ayarlandı!\n\n"
                    f"🔔 Vergi yükümlülüklerinizden {days} gün önce hatırlatma alacaksınız."
                )
                
        except Exception as e:
            self.logger.error(f"Reminder setting hatası: {str(e)}")
            await query.edit_message_text("❌ Hatırlatıcı ayarlanırken hata oluştu.")
            
    async def handle_message(self, update: Update, context: ContextTypes.DEFAULT_TYPE):
        """Genel mesaj handler'ı"""
        try:
            message_text = update.message.text.lower()
            
            if any(word in message_text for word in ['kdv', 'katma değer vergisi']):
                await update.message.reply_text(
                    "💡 KDV ile ilgili güncel bilgiler için /guncellemeler komutunu kullanabilirsiniz!"
                )
            else:
                await update.message.reply_text(
                    "🤖 Merhaba! Vergi ile ilgili yardım için /yardim komutunu kullanın!"
                )
                
        except Exception as e:
            self.logger.error(f"Message handler hatası: {str(e)}")
            
    async def send_scheduled_reminders(self):
        """Zamanlanmış hatırlatmaları gönder (placeholder)"""
        self.logger.info("Hatırlatma kontrolü yapıldı")