import schedule
import time
import os
from tradingview_ta import TA_Handler, Interval, Exchange
from tkinter import *

import mysql.connector
import time

def job():
            mydb= mysql.connector.connect(
            host="localhost",
            user="root",
            password ="" ,
            database = "trading3" )
            if mydb.is_connected(): 
              print("good....") 
            else:print("nooo") 

            qu= mydb.cursor(buffered=True)

        



            
        #funaction fror test if the last burash close is breakdown or not 

            

            #funaction fror test if the last bullish close is breakup or not 







        
         

            user="iiii725iiii"
            passw="iiLL7255##1410"
            from tvDatafeed import TvDatafeed, Interval
            tv=TvDatafeed(user,passw )

            query = "SELECT * FROM company limit 2 ;"
            qu.execute(query)
            results = qu.fetchall()
        

        # استعراض البيانات: كل عمود في متغير
            for row in results:
                idd = row[0]
                id_company = row[1]
                print(id_company)

                try:
                    column3_data = row[2]  # البيانات من العمود الثالث

                    nifty_index_data1 = tv.get_hist(symbol=str(id_company), exchange='TADAWUL', interval=Interval.in_daily,n_bars=1)
                    #nifty_index_data2 = tv.get_hist(symbol=str(id_company), exchange='TADAWUL', interval=Interval.in_weekly,n_bars=1)
                    #nifty_index_data3 = tv.get_hist(symbol=str(id_company), exchange='TADAWUL', interval=Interval.in_monthly,n_bars=2)

                    # استعراض البيانات أو استخدامها
                    print(f"Column 1: {idd}, Column 2: {id_company}, Column 3: {column3_data}")

                    idcompanny = str(id_company)
                    base_path3 = "C:\\xampp\htdocs\\readexcelnew\\month\\"
                    file_name = idcompanny + '.csv'
                    file_path3 = base_path3 + "/" + file_name
                    base_path2 = "C:\\xampp\htdocs\\readexcelnew\\week\\"
                    file_name2 = idcompanny + '.csv'
                    file_path2 = base_path2 + "/" + file_name

                    base_path1 = "C:\\xampp\htdocs\\readexcelnew\\day\\"
                    file_name1 = idcompanny + '.csv'
                    file_path1 = base_path1 + file_name
                    print(file_path1)
                    import csv
                    import pandas as pd

                    nifty_index_data1.to_csv(file_path1, index=False)
                    #nifty_index_data2.to_csv(file_path2, index=False)
                    #nifty_index_data3.to_csv(file_path3, index=False)
                    print("\ngood1")
                    time.sleep(7)

                    xc = None
           
                       





                except EXCEPTION as e:
                 continue
                 print(e)



                # records = qu.fetchall()
                #  print("Total number of rows in table: ", qu.rowcount)

        # إغلاق الاتصال
            qu.close()


        # index
        #tv.get_hist(symbol='4263',exchange='TADAWUL',interval=Interval.INTERVAL_1_DAY,n_bars=160)
        #nifty_index_data2=tv.get_hist(symbol='1303',exchange='TADAWUL',interval=Interval.in_1_hour,n_bars=1000)

        #nifty_index_data1=tv.get_hist(symbol='4100',exchange='TADAWUL',interval=Interval.in_daily,n_bars=100)
        #nifty_index_data2=tv.get_hist(symbol='4100',exchange='TADAWUL',interval=Interval.in_weekly,n_bars=20)
        #nifty_index_data3=tv.get_hist(symbol='4100',exchange='TADAWUL',interval=Interval.in_monthly,n_bars=10)

        # futures continuous contract


        # downloading data for extended market hours
        #extended_price_data = tv.get_hist(symbol="EICHERMOT",exchange="NSE",interval=Interval.in_daily,n_bars=500, extended_session=False)


         

        #print(is_sellingcandel_or_baying(opencandel,closecandel,highcandel,lowcandel))

        #sql="select * from CANDEL "
            no_ofrow=9
        #get_data_toshow(no_ofrow,sql,qu)
        






                #print(nifty_index_data2)
        #print( tesla.get_analysis().indicators["open"])
        #print( tesla.get_analysis().indicators["close"])
        #print( tesla.get_analysis().indicators["high"])
        #print( tesla.get_analysis().indicators["low"])
            mydb.close



 
 

# جدولة المهمة لتعمل كل يوم في الساعة 8:00 صباحًا
schedule.every().day.at("11:22").do(job)

while True:
    schedule.run_pending()
    time.sleep(1)  # الانتظار لمدة ثانية