from tradingview_ta import TA_Handler, Interval, Exchange
from tkinter import *

import mysql.connector
import time
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)

 



tesla = TA_Handler(
    symbol="2040",
    screener="ksa",
    exchange="TADAWUL",
    interval=Interval.INTERVAL_1_DAY
)
#funaction fror test if the last burash close is breakdown or not 

       

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







  
last_bullish=00
last_second_bullish=00
last_bearish=00
last_second_bearish=00
type_of_stock_day=0
type_of_stock_week=0
type_of_stock_month=0

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=3)
        #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
       # with open(file_path1, newline='') as csvfile:
       #     reader = csv.reader(csvfile, delimiter=',', quotechar='"')
         #   for row in reader:
              #  row2 = (row,)
              #  row2 = str(row2)
                # row2 = [('row',)]
                # print(', '.join(row))

                # values = f"'{xc}', '{row2}'"
                # note the formatting
               # values = (xc, 1, row2)
                # values = (row2,)
                # sql = "INSERT INTO sqltoscv (id,type_of_frame,content)  VALUES  (%s,%s,'%s') ;"
                # sql = f"INSERT INTO sqltoscv (id,type_of_frame,content) VALUES ({values})"  # note the f-string expression
              #  sql = """insert into sqltoscv(id,type_of_frame,content) values(%s,%s,%s)"""

             #   print(sql)
                # qu.execute("INSERT INTO sqltoscv (content) VALUES(%s)" % (str(row2)))
              #  qu.execute(sql, values)
                # qu.execute(sql)
             #   mydb.commit()
             #   print("\ngood2")
                # xc+= 1





    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)


opencandel= tesla.get_analysis().indicators["open"]
closecandel= tesla.get_analysis().indicators["close"]
highcandel= tesla.get_analysis().indicators["high"]
lowcandel= tesla.get_analysis().indicators["low"]

#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