import time
from datetime import datetime
import os
import ast
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("Send Message Power by ClickSend",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 sn,transid,username,phonenumber,message,language,voicetype,domain FROM messagesentsinglevoice where status ='0' order by sn limit 10"
        #print(query)
        mycursor.execute(query)
        
        myresult = mycursor.fetchall()

        for x in myresult:

            sn = x[0]
            transid =  x[1]
            username= x[2]
            phone= x[3]; 
            message =  x[4]
            language = x[5]
            voicetype = x[6]
            domain = x[7]  
            billcode='0'
            sentcode ='0'
            print('Processing Records', x)
            
            phonenumbers= phone.split(",")
            for phonenumber in phonenumbers:
                query = "insert into messagesentsplittedvoice (transid,username,phonenumber,message,language,voicetype,domain,billcode,sentcode)  values ('{}','{}','{}','{}','{}','{}','{}','{}','{}'".format(transid,username,phonenumber.replace("+",""),message,language,voicetype,domain,billcode,sentcode)+")"
                #print(query)
                mycursor.execute(query)
                mydb.commit()
            query = "update messagesentsinglevoice set status ='1'  where sn = {} ".format(sn)
            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);