db_get.py

import psycopg2
from datetime import datetime, date
import yfinance as yf
from decimal import Decimal
import os


def get_db_connection():
    """Veritabanı bağlantısını açar ve geri döner."""
    conn = psycopg2.connect(
        dbname=os.getenv("DB_NAME"),
        user=os.getenv("DB_USER"),
        password=os.getenv("DB_PASSWORD"),
        host=os.getenv("DB_HOST"),
        port=os.getenv("DB_PORT")
    )
    return conn


def get_donemler(hisse, donem_sayisi):
    """Veritabanından hisseye göre donem_sayisi kadar text sütunundaki veriyi döndürür."""
    # Veritabanı bağlantısı açılır
    conn = get_db_connection()
    cur = conn.cursor()

    # Sorguyu hazırla ve çalıştır
    query = """
    SELECT text 
    FROM hisse_bilanco_donem
    WHERE kod = %s
    ORDER BY text DESC
    LIMIT %s;
    """

    cur.execute(query, (hisse, donem_sayisi))

    # Sonuçları al
    donemler = cur.fetchall()

    # Bağlantıyı kapat
    cur.close()
    conn.close()

    # Verileri bir liste olarak döndür
    return [row[0] for row in donemler]


def get_kalemtipi(hisse):
    """Hisseye göre bilancoformat değerini döndüren fonksiyon."""
    try:
        # Veritabanı bağlantısını aç
        conn = get_db_connection()
        cur = conn.cursor()

        # Hisse koduna göre bilancoformat'ı sorgula
        query = "SELECT bilancoformat FROM hisse WHERE kod = %s"
        cur.execute(query, (hisse,))

        # Sonuçları al
        bilanco_format = cur.fetchone()

        # Veritabanı işlemlerini sonlandır
        cur.close()
        conn.close()

        # Bilancoformat verisi döndür
        if bilanco_format:
            return bilanco_format[0]
        else:
            return None

    except Exception as e:
        print(f"Veritabanı hatası: {e}")
        return None


def get_sektor(hisse):
    """Hisseye göre sektor_value değerini döndüren fonksiyon."""
    try:
        # Veritabanı bağlantısını aç
        conn = get_db_connection()
        cur = conn.cursor()

        # Hisse koduna göre sektor_value'yu sorgula
        query = "SELECT sektor_value FROM hisse_sektor WHERE kod = %s"
        cur.execute(query, (hisse,))

        # Sonuçları al
        sektor_value = cur.fetchone()

        # Veritabanı işlemlerini sonlandır
        cur.close()
        conn.close()

        # Sektor_value verisi döndür
        if sektor_value:
            return sektor_value[0]
        else:
            return None

    except Exception as e:
        print(f"Veritabanı hatası: {e}")
        return None


def indirilecekler():
    # Database connection
    conn = get_db_connection()
    cur = conn.cursor()

    # Bilanco_tarih tablosundaki kod, donem ikilisinin hisse_bilanco_donem tablosunda bulunmayanlarını seçme
    query = """
                SELECT DISTINCT bt.kod
                FROM bilanco_tarih bt
                LEFT JOIN hisse_bilanco_donem hbd 
                    ON bt.kod = hbd.kod 
                    AND bt.donem = hbd.text
                INNER JOIN (
                    SELECT kod, MAX(donem) AS max_donem
                    FROM bilanco_tarih
                    GROUP BY kod
                ) AS max_donem_tablosu 
                    ON bt.kod = max_donem_tablosu.kod 
                    AND bt.donem = max_donem_tablosu.max_donem
                WHERE hbd.kod IS NULL;
    """

    try:
        # Sorguyu çalıştır ve sonuçları al
        cur.execute(query)
        result = cur.fetchall()

        # Kodları bir listeye ekleme
        kod_listesi = [row[0] for row in result]

    except Exception as e:
        print(f"Hata oluştu: {e}")
        kod_listesi = []

    # Bağlantıyı kapatma
    cur.close()
    conn.close()

    return kod_listesi


def hisseler():
    # Database connection
    conn = get_db_connection()
    cur = conn.cursor()

    # Kod sütunundaki tüm verileri çek
    cur.execute("SELECT kod FROM hisse")
    rows = cur.fetchall()

    # Verileri indir_hisse listesine ekle
    indir_hisse = [row[0] for row in rows]

    # Bağlantıyı kapat
    cur.close()
    conn.close()

    return indir_hisse


def get_ozsermayekarlilik(hisse, donem):
    """
    Belirtilen hisseye ait tüm dönem ve Özsermaye Karlılık verisini çeker,
    en güncel dönem bilgisini ve float türünde bir liste olarak Özsermaye Karlılık değerlerini döndürür.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')

    Returns:
        tuple: (en güncel dönem, belirtilen hisse için Özsermaye Karlılık değerleri (float türünde bir liste)).
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # Özsermaye Karlılık verisini çekmek için sorguyu çalıştır
    query = """
    SELECT donem, deger FROM oranlar
    WHERE kod = %s AND propertyname = 'OzsermayeKarlilik' AND donem <= %s
    ORDER BY donem DESC
    LIMIT 5
    """
    cur.execute(query, (hisse, donem))

    # Tüm sonuçları float'a dönüştürülmüş bir listeye çevir
    results = cur.fetchall()
    ozsermaye_karlilik_list = [float(row[1]) if isinstance(row[1], Decimal) else row[1] for row in results]

    # En güncel dönemi al
    en_guncel_donem = results[0][0] if results else None

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return en_guncel_donem, ozsermaye_karlilik_list


def get_netkarmarji(hisse, donem):
    """
    Belirtilen hisseye ait tüm dönem ve Özsermaye Karlılık verisini çeker ve
    float türünde bir liste olarak döndürür.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')

    Returns:
        list: Belirtilen hisse için Özsermaye Karlılık değerleri (float türünde).
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # Özsermaye Karlılık verisini çekmek için sorguyu çalıştır
    query = """
    SELECT deger FROM oranlar
    WHERE kod = %s AND propertyname = 'NetKarMarji' AND donem <= %s
    ORDER BY donem DESC
    LIMIT 5
    """
    cur.execute(query, (hisse, donem))

    # Tüm sonuçları float'a dönüştürülmüş bir listeye çevir
    results = [float(row[0]) if isinstance(row[0], Decimal) else row[0] for row in cur.fetchall()]

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return results


def get_aktifdevirhizi(hisse, donem):
    """
    Belirtilen hisseye ait tüm dönem ve Özsermaye Karlılık verisini çeker ve
    float türünde bir liste olarak döndürür.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')

    Returns:
        list: Belirtilen hisse için Özsermaye Karlılık değerleri (float türünde).
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # Özsermaye Karlılık verisini çekmek için sorguyu çalıştır
    query = """
    SELECT deger FROM oranlar
    WHERE kod = %s AND propertyname = 'AktifDevirHizi' AND donem <= %s
    ORDER BY donem DESC
    LIMIT 5
    """
    cur.execute(query, (hisse, donem))

    # Tüm sonuçları float'a dönüştürülmüş bir listeye çevir
    results = [float(row[0]) if isinstance(row[0], Decimal) else row[0] for row in cur.fetchall()]

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return results


def get_aktifkarlilik(hisse,donem):
    """
    Belirtilen hisseye ait tüm dönem ve Özsermaye Karlılık verisini çeker ve
    float türünde bir liste olarak döndürür.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')

    Returns:
        list: Belirtilen hisse için Özsermaye Karlılık değerleri (float türünde).
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # Özsermaye Karlılık verisini çekmek için sorguyu çalıştır
    query = """
    SELECT deger FROM oranlar
    WHERE kod = %s AND propertyname = 'AktifKarlilik' AND donem <= %s
    ORDER BY donem DESC
    LIMIT 5
    """
    cur.execute(query, (hisse, donem))

    # Tüm sonuçları float'a dönüştürülmüş bir listeye çevir
    results = [float(row[0]) if isinstance(row[0], Decimal) else row[0] for row in cur.fetchall()]

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return results


def get_borckaynakorani(hisse, donem):
    """
    Belirtilen hisseye ait belirli bir dönem ve öncesine ait Borç Kaynak Oranı verisini çeker
    ve float türünde bir liste olarak döndürür.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')
        donem (str): İlgili dönem (örneğin '2024/03')

    Returns:
        list: Belirtilen hisse için Borç Kaynak Oranı değerleri (float türünde).
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # Borç Kaynak Oranı verisini çekmek için sorguyu çalıştır
    query = """
    SELECT deger FROM oranlar
    WHERE kod = %s AND propertyname = 'BorcKaynakOrani' AND donem <= %s
    ORDER BY donem DESC
    LIMIT 5
    """
    cur.execute(query, (hisse, donem))

    # Tüm sonuçları float'a dönüştürülmüş bir listeye çevir
    results = [float(row[0]) if isinstance(row[0], Decimal) else row[0] for row in cur.fetchall()]

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return results


def get_hbk(hisse, donem):
    """
    Belirtilen hisse ve dönem için EPS (Hisse Başına Kar) değerini döndürür.

    Args:
        hisse (str): Hisse kodu
        donem (str): İstenen dönem

    Returns:
        float or None: EPS değeri veya veri yoksa None
    """
    try:
        # Veritabanı bağlantısı oluştur
        conn = get_db_connection()
        cur = conn.cursor()

        # EPS değerini al
        eps_query = """
        SELECT deger 
        FROM oran_analiz 
        WHERE kod = %s AND donem = %s AND propertyname = '_HisseBasinaKar'
        LIMIT 1
        """
        cur.execute(eps_query, (hisse, donem))
        eps_sonuc = cur.fetchone()

        # EPS değeri döndür
        return float(eps_sonuc[0]) if eps_sonuc else None

    except Exception as e:
        print(f"Hisse {hisse} için EPS değeri alınamadı: {str(e)}")
        return None

    finally:
        cur.close()
        conn.close()


def get_hisse_sayisi(hisse, donem):
    """
    Belirtilen hisse ve dönem için ödenmiş sermaye (hisse sayısı) değerini döndürür.
    İlk sorgudan boş dönerse alternatif bir sorgu çalıştırır.

    Args:
        hisse (str): Hisse kodu
        donem (str): İstenen dönem

    Returns:
        float or None: Hisse sayısı değeri veya veri yoksa None
    """
    try:
        # Veritabanı bağlantısı oluştur
        conn = get_db_connection()
        cur = conn.cursor()

        # İlk sorguyu çalıştır
        sermaye_query = """
        SELECT deger 
        FROM oran_analiz 
        WHERE kod = %s AND donem = %s AND propertyname = '_HisseOdenmisSermaye'
        LIMIT 1
        """
        cur.execute(sermaye_query, (hisse, donem))
        sermaye_sonuc = cur.fetchone()

        # İlk sorgu sonucunu kontrol et
        if sermaye_sonuc:
            return float(sermaye_sonuc[0])

        # İlk sorgu boşsa ikinci sorguyu çalıştır
        alternatif_sermaye_query = """
        SELECT deger 
        FROM oran_analiz 
        WHERE kod = %s AND donem = %s AND propertyname = 'HisseOdenmisSermaye'
        LIMIT 1
        """
        cur.execute(alternatif_sermaye_query, (hisse, donem))
        alternatif_sermaye_sonuc = cur.fetchone()

        # İkinci sorgudan gelen değeri kontrol et ve 1.000.000 ile çarp
        if alternatif_sermaye_sonuc and alternatif_sermaye_sonuc[0] is not None:
            try:
                return float(alternatif_sermaye_sonuc[0]) * 1_000_000
            except ValueError:
                print(f"Alternatif sorgudan dönen değer sayıya dönüştürülemedi: {alternatif_sermaye_sonuc[0]}")
                return None
        else:
            return None

    except Exception as e:
        print(f"Hisse {hisse} için hisse sayısı değeri alınamadı: {str(e)}")
        return None

    finally:
        cur.close()
        conn.close()


def get_ozkaynaklar(hisse, donem):
    """
    Belirtilen hisse ve dönem için özkaynaklar değerini döndürür.
    İlk sorgudan boş dönerse alternatif bir sorgu çalıştırır ve dönen değeri 1.000.000 ile çarpar.

    Args:
        hisse (str): Hisse kodu
        donem (str): İstenen dönem

    Returns:
        float or None: Özkaynaklar değeri veya veri yoksa None
    """
    try:
        # Veritabanı bağlantısı oluştur
        conn = get_db_connection()
        cur = conn.cursor()

        # İlk sorguyu çalıştır
        ozkaynak_query = """
        SELECT deger 
        FROM oran_analiz 
        WHERE kod = %s AND donem = %s AND propertyname = '_KalemOzkaynaklar'
        LIMIT 1
        """
        cur.execute(ozkaynak_query, (hisse, donem))
        ozkaynak_sonuc = cur.fetchone()

        # İlk sorgu sonucu varsa değeri döndür
        if ozkaynak_sonuc:
            return float(ozkaynak_sonuc[0])

        # İlk sorgu boşsa alternatif sorguyu çalıştır
        alternatif_ozkaynak_query = """
        SELECT deger 
        FROM oran_analiz 
        WHERE kod = %s AND donem = %s AND propertyname = 'Ozkaynaklar'
        LIMIT 1
        """
        cur.execute(alternatif_ozkaynak_query, (hisse, donem))
        alternatif_ozkaynak_sonuc = cur.fetchone()

        # Alternatif sorgu sonucu varsa 1.000.000 ile çarpıp döndür
        return float(alternatif_ozkaynak_sonuc[0]) * 1_000_000 if alternatif_ozkaynak_sonuc else None

    except Exception as e:
        print(f"Hisse {hisse} için özkaynaklar değeri alınamadı: {str(e)}")
        return None

    finally:
        cur.close()
        conn.close()


def get_fk_sektorel(hisse, donem):
    """
    Belirtilen hisse ve dönem için FK_Sektorel değerini döndürür.
    İlk sorgudan boş dönerse hissenin sektörünü belirleyip sektörel FK değerini sorgular.

    Args:
        hisse (str): Hisse kodu
        donem (str): İstenen dönem

    Returns:
        float or None: FK_Sektorel değeri veya veri yoksa None
    """
    try:
        # Veritabanı bağlantısı oluştur
        conn = get_db_connection()
        cur = conn.cursor()

        # İlk sorguyu çalıştır
        fk_sektorel_query = """
        SELECT deger 
        FROM oran_analiz 
        WHERE kod = %s AND donem = %s AND propertyname = '_FKSektorel'
        LIMIT 1
        """
        cur.execute(fk_sektorel_query, (hisse, donem))
        fk_sektorel_sonuc = cur.fetchone()

        # İlk sorgu sonucu varsa ve 0'a eşit değilse değeri döndür
        if fk_sektorel_sonuc and float(fk_sektorel_sonuc[0]) != 0:
            return float(fk_sektorel_sonuc[0])

        # İlk sorgu boşsa sektör kodunu belirlemek için ikinci sorguyu çalıştır
        sektor_query = """
        SELECT sektor_value 
        FROM hisse_sektor 
        WHERE kod = %s
        LIMIT 1
        """
        cur.execute(sektor_query, (hisse,))
        sektor_sonuc = cur.fetchone()

        # Sektör kodu bulunamazsa None döndür
        if not sektor_sonuc:
            print(f"{hisse} için sektör bilgisi bulunamadı.")
            return None

        sektor_kodu = sektor_sonuc[0]

        # Sektör kodunu kullanarak piyasa çarpan anlık verisinden FK_Sektorel değerini al
        alternatif_fk_sektorel_query = """
        SELECT deger 
        FROM piyasa_carpan_anlik 
        WHERE kod = %s AND propertyname = 'FKSektorel'
        LIMIT 1
        """
        cur.execute(alternatif_fk_sektorel_query, (sektor_kodu,))
        alternatif_fk_sektorel_sonuc = cur.fetchone()

        # Alternatif sorgu sonucu varsa değeri döndür
        return float(alternatif_fk_sektorel_sonuc[0]) if alternatif_fk_sektorel_sonuc else None

    except Exception as e:
        print(f"Hisse {hisse} için FK_Sektorel değeri alınamadı: {str(e)}")
        return None

    finally:
        cur.close()
        conn.close()


def get_donem_tarihleri(hisse, donem):
    """
    Belirtilen hisse ve döneme ait başlangıç (start_date) ve bitiş (end_date) tarihlerini çeker.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')
        donem (int/str): Dönem bilgisi

    Returns:
        tuple: (start_date, end_date) olarak başlangıç ve bitiş tarihlerini döndürür.
               end_date yoksa bugünün tarihini döner.
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # start_date'i almak için sorguyu çalıştır
    query_start_date = """
    SELECT tarih FROM bilanco_tarih
    WHERE kod = %s AND donem = %s
    """
    cur.execute(query_start_date, (hisse, donem))
    result_start = cur.fetchone()

    if result_start is None:
        # Başlangıç tarihi bulunamazsa, None döndür.
        cur.close()
        conn.close()
        return None, None

    start_date = result_start[0]

    # end_date'i almak için bir sonraki dönemin tarihini çek
    query_end_date = """
    SELECT tarih FROM bilanco_tarih
    WHERE kod = %s AND donem > %s
    ORDER BY donem ASC
    LIMIT 1
    """
    cur.execute(query_end_date, (hisse, donem))
    result_end = cur.fetchone()

    # end_date yoksa bugünün tarihi olarak ayarla
    end_date = result_end[0] if result_end else datetime.today().strftime('%Y-%m-%d')

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return start_date, end_date


def get_today_close_price(hisse):
    """
    Belirtilen hissenin bugünkü kapanış fiyatını çeker.

    Parameters:
    hisse (str): Hisse sembolü (örn: "AAPL" veya "GARAN.IS").

    Returns:
    float or None: Bugünkü kapanış fiyatı. Veri yoksa None döner.
    """
    # Bugünün tarihini alın
    today = datetime.today().strftime('%Y-%m-%d')
    hisse = f"{hisse}.IS"
    # Hisse verisini indirin (yalnızca bugünkü veriyi almak için start ve end aynı gün olarak ayarlandı)
    data = yf.download(hisse, start=today, end=today)

    # Veri boşsa veya kapanış sütunu yoksa None döndür
    if data.empty or 'Close' not in data.columns:
        print(f"{hisse}: Fiyat verisi bulunamadı.")
        return None

    # Bugünkü kapanış fiyatını al
    today_close_price = data['Close'].iloc[0]
    return today_close_price


def db_puan_sirala(limit_puan, donem):
    # Veritabanı bağlantısını oluştur
    conn = get_db_connection()
    cursor = conn.cursor()

    # SQL sorgusunu oluştur ve çalıştır
    query = """
    SELECT kod, donem, bb_puan AS Puan, graham_deger AS Hedef_Fiyat 
    FROM puanla 
    WHERE bb_puan > %s AND donem = %s
    """
    cursor.execute(query, (limit_puan, donem))

    # Verileri liste olarak döndür
    results = cursor.fetchall()

    # Bağlantıyı kapat
    conn.close()

    return results


def ekle_donem_tarihleri(hisseler_listeler):
    # Yeni listeyi oluştur
    yeni_hisseler_listesi = []

    for hisse in hisseler_listeler:
        kod, donem, puan, hedef_fiyat = hisse  # her hisse kaydındaki verileri al
        # get_donem_tarihleri fonksiyonunu kullanarak s_date ve e_date'yi al
        s_date, e_date = get_donem_tarihleri_string(kod, donem)

        # s_date ve e_date tarihlerini 'YYYY-MM-DD' formatına dönüştür
        s_date_str = s_date.strftime('%Y-%m-%d') if isinstance(s_date, date) else s_date
        e_date_str = e_date.strftime('%Y-%m-%d') if isinstance(e_date, date) else e_date

        # Decimal değerleri stringe çevir
        puan_str = str(puan) if isinstance(puan, Decimal) else puan
        hedef_fiyat_str = str(hedef_fiyat) if isinstance(hedef_fiyat, Decimal) else hedef_fiyat

        # Yeni kayıta s_date, e_date, puan ve hedef_fiyat ekle
        yeni_kayit = (kod, donem, puan_str, hedef_fiyat_str, s_date_str, e_date_str)
        yeni_hisseler_listesi.append(yeni_kayit)

    return yeni_hisseler_listesi


def hesapla_marj(hisseler_listeler):
    marj_sonuclari = []

    for hisse_bilgisi in hisseler_listeler:
        hisse = hisse_bilgisi[0]  # Extract the ticker symbol
        tarih = hisse_bilgisi[4]  # Extract the date in string or datetime format
        hedef_fiyat = float(hisse_bilgisi[3])  # Convert target price to float

        # Convert tarih to string if it's a datetime, or use it directly if it's already a string
        tarih_str = tarih if isinstance(tarih, str) else tarih.strftime('%Y-%m-%d')

        # Fetch stock price from Yahoo Finance
        try:
            hisse_verisi = yf.Ticker(hisse)
            print(hisse_verisi.info)
            fiyat_verisi = hisse_verisi.history(start=tarih_str, end=tarih_str)

            # Retrieve the closing price if available
            if not fiyat_verisi.empty:
                fiyat = fiyat_verisi['Close'].iloc[0]  # Get closing price
                # Calculate margin
                marj = 1 - (hedef_fiyat / fiyat)
                marj_sonuclari.append((hisse, tarih_str, hedef_fiyat, fiyat, marj))
            else:
                print(f"{hisse} için {tarih_str} tarihinde fiyat verisi bulunamadı.")
                marj_sonuclari.append((hisse, tarih_str, hedef_fiyat, None, None))

        except Exception as e:
            print(f"{hisse} için fiyat verisi alınırken hata oluştu: {e}")
            marj_sonuclari.append((hisse, tarih_str, hedef_fiyat, None, None))

    return marj_sonuclari


def get_donem_tarihleri_string(hisse, donem):
    """
    Belirtilen hisse ve döneme ait başlangıç (start_date) ve bitiş (end_date) tarihlerini string formatında çeker.

    Args:
        hisse (str): Hisse kodu (örneğin 'ASELS')
        donem (int/str): Dönem bilgisi

    Returns:
        tuple: (start_date, end_date) olarak başlangıç ve bitiş tarihlerini döndürür.
               end_date yoksa bugünün tarihini döner.
    """
    # Veritabanı bağlantısı oluştur
    conn = get_db_connection()
    cur = conn.cursor()

    # start_date'i almak için sorguyu çalıştır
    query_start_date = """
    SELECT tarih FROM bilanco_tarih
    WHERE kod = %s AND donem = %s
    """
    cur.execute(query_start_date, (hisse, donem))
    result_start = cur.fetchone()

    if result_start is None:
        # Başlangıç tarihi bulunamazsa, None döndür.
        cur.close()
        conn.close()
        return None, None

    start_date = result_start[0].strftime('%Y-%m-%d')  # Start date string formatında

    # end_date'i almak için bir sonraki dönemin tarihini çek
    query_end_date = """
    SELECT tarih FROM bilanco_tarih
    WHERE kod = %s AND donem > %s
    ORDER BY donem ASC
    LIMIT 1
    """
    cur.execute(query_end_date, (hisse, donem))
    result_end = cur.fetchone()

    # end_date yoksa bugünün tarihi olarak ayarla ve string formatına çevir
    end_date = result_end[0].strftime('%Y-%m-%d') if result_end else datetime.today().strftime('%Y-%m-%d')

    # Veritabanı bağlantısını kapat
    cur.close()
    conn.close()

    return start_date, end_date


def get_fd_favok(hisse):
    # Veritabanına bağlan
    conn = get_db_connection()
    cursor = conn.cursor()

    # Sorguyu çalıştır
    query = """
        SELECT tarih, deger, donem
        FROM genel_piyasa_carpan
        WHERE kod = %s AND (propertyname = '_FirmaDegeriFAVOK')
        ORDER BY tarih;
    """
    cursor.execute(query, (hisse,))

    # Sonuçları al
    results = cursor.fetchall()

    # Bağlantıyı kapat
    cursor.close()
    conn.close()

    # Sonuçları döndür
    return results


def get_bugun_fiyat(hisse):
    """
    Belirtilen hisse için bugünkü kapanış fiyatını getirir.
    Önce Yahoo Finance'ten almaya çalışır, başarılı olmazsa veritabanından alır.

    Args:
        hisse (str): Hisse kodu

    Returns:
        float: Kapanış fiyatı
    """
    # Yahoo Finance'ten fiyatı almaya çalış
    hisse_yahoo = f"{hisse}.IS"
    try:
        kapanis_fiyati = yf.Ticker(hisse_yahoo).history(period="1d")['Close'].iloc[-1]
        return kapanis_fiyati
    except Exception as e:
        print(f"{hisse} için Yahoo Finance kapanış fiyatı çekilemedi: {e}")

    # Yahoo Finance başarısız olursa veritabanından al
    try:
        today_date = datetime.now().strftime('%Y-%m-%d')
        query = """
            SELECT deger FROM genel_piyasa_carpan 
            WHERE kod=%s AND tarih=%s AND propertyname='_AnKapanis'
        """
        conn = get_db_connection()
        cursor = conn.cursor()
        cursor.execute(query, (hisse, today_date))
        result = cursor.fetchone()
        conn.close()
        return result[0] if result else None
    except Exception as e:
        print(f"{hisse} için veritabanından kapanış fiyatı alınırken hata oluştu: {e}")
        return None


def db_get_date():
    try:
        # Veritabanına bağlan
        conn = get_db_connection()
        cur = conn.cursor()

        # En büyük tarih verisini sorgula
        query = "SELECT MAX(date) FROM db_save_date"
        cur.execute(query)
        max_date = cur.fetchone()[0]  # Sonuçtan tarihi al

        # Bağlantıyı kapat
        cur.close()
        conn.close()

        if not max_date:
            print("Tabloda kayıtlı tarih bulunamadı.")

        return max_date
    except Exception as e:
        print("Hata oluştu:", e)
        return None