import time
from datetime import datetime
import os
import mysql.connector
os.system("cls")



try:
    while True:
        
        
        mydb = mysql.connector.connect(
        host="localhost",
        user="smsEngine",
        password="guEnaR28T",
        database="smartsmsrouter"
        )

        
        mycursor = mydb.cursor()
        current_time_screen= datetime.now().strftime("%Y-%m-%d %H:%M:%S")
        current_time= datetime.now().strftime("%Y-%m-%d %H:%M")
        print("Running every 20 secs",current_time_screen,sep=' ', end=" ")
        #mycursor.execute("SELECT sn,bookname,messtype,datedue FROM schedule where username ='system' and domain='247sms.com' and status ='2'")
        query = "SELECT transid,username,bookname,message,domain,sender,messtype,flag,voicemessage,language,voicetype FROM schedule where status ='0' and datedue <= '"+current_time_screen +"'"
        #print(query)
        mycursor.execute(query)
        
        myresult = mycursor.fetchall()

        for x in myresult:
            #date_due = str(x[3].strftime("%Y-%m-%d %H:%M"))

           transid = x[0]
           username = x[1]
           bookname = x[2]
           message = x[3]
           domain = x[4]
           sender = x[5]
           messtype = x[6]
           flag = x[7]
           voicemessage = x[8]
           language = x[9]
           voicetype= x[10]
           print('Processing Records', x)
           if messtype =="1":
                if voicemessage== "1":
                    query="insert messagesentsinglevoice(transid,username,phonenumber,message,language,voicetype,status,domain) values ('{}','{}','{}','{}','{}','{}','{}','{}')".format(transid,username,bookname,message,language,voicetype,0,domain)
                else:
                    query = "insert messagesentsingle(transid,username,phonenumber,message,sender,domain,status) values ('" + transid + "','" + username + "','" + bookname + "','" + message + "','" + sender + "','" + domain + "','0')"
                
                print(query)
           else:
                query = "insert messagesentaddressbook(transid,username,bookname,message,sender,domain,flag,status) values ('" + transid + "','" + username + "','" + bookname + "','" + message + "','" + sender + "','" + domain + "','"+flag+"','0')"
                print(query)
           mycursor.execute(query)
           mydb.commit()
           query ="update schedule set status='1' where transid ='" + transid + "'"
           mycursor.execute(query)
           mydb.commit()
         
        
        mycursor.close()
        mydb.close()
        print("press cltr^c to shut down")  
        time.sleep(20)
except Exception as error :
    print("App shutdown", error);