# Charging Updates

import sys
import os
import mysql.connector
import datetime
import time

import default_setting

def updatePartId (cnx):
    try:
    # connection
        cursor = cnx.cursor(dictionary=True)
        dataQuery = "SELECT order_body.id AS id, part.id AS part_id,order_body.part_number AS part_number FROM order_body JOIN part ON order_body.part_number=part.part_number WHERE order_body.part_id IS null"
        cursor.execute(dataQuery)
        data = cursor.fetchall()
        for row in data:
            try:
                id = row['id']
                partId = row['part_id']
                partNumber=row['part_number']
                print ("UPDATE-",id,partNumber,partId)
                dataUpdQuery = "UPDATE order_body SET part_id='"+str(partId)+"' WHERE id="+str(id)+" LIMIT 1"
                cursor.execute(dataUpdQuery)
                cnx.commit()
            except Exception as Err:
                print("FAIL-",str(Err),dataUpdQuery)
    except Exception as Err:
        print("FAIL-",str(Err),dataQuery)
    finally:
        cursor.close()

    return "OK  -orderPartId"

def main():
    # Default Connection / System Settings
	defaults = default_setting.defaultSettings()
	# mySql Connector
	cnx = mysql.connector.connect(user=defaults['dbuser'], password=defaults['dbpwd'],host=defaults['dbhost'],database=defaults['dbase'])

	response = updatePartId(cnx)   
#	print(response)
	
if __name__ == '__main__':
	main()