import RPi.GPIO as GPIO
import sys
import Adafruit_DHT
import time
import pyodbc
from mysql.connector import connect

DEMO = 1

GPIO.setmode(GPIO.BCM)
pinList = [26, 13]
manualPinList = [5, 6]

# loop through pins and set mode and state to 'off'

for i in pinList:
    GPIO.setup(i, GPIO.OUT)
    GPIO.output(i, GPIO.LOW)


for j in manualPinList:
    GPIO.setup(j, GPIO.OUT)
    GPIO.output(j, GPIO.HIGH)

SERVER_CONNECTOR = ['']

def Connect_MYSQL():

    SERVER = 'digitechautomation.cywrzfld2wji.us-west-2.rds.amazonaws.com' #'r2ocontainers.cywrzfld2wji.us-west-2.rds.amazonaws.com'
    PORT = 3306 #1433
    DATABASE_NAME = 'CraigslistPosterTest' #'SmartPanel'
    LOGIN = 'admin' #'r2oadmin'
    PASSWORD = 'digitech123' #'pop90909'

    conn = connect(user=LOGIN, password=PASSWORD, database=DATABASE_NAME, port=PORT, host=SERVER)

    return conn


def Read_from_db_table(conn):
    cursor = conn.cursor(buffered=True)
    cursor.execute("SELECT b.mode, a.humidity, b.humidity_threshold, b.fan1, b.fan2, a.timestamp FROM CraigslistPosterTest.sp_demo_graph a INNER JOIN CraigslistPosterTest.sp_demo b ON a.sp_demo_id = b.demo WHERE demo = {0} ORDER BY a.timestamp DESC LIMIT 1".format(DEMO))
    rows = cursor.fetchall()
    return rows[0]

def main():
    while True:
        conn = Connect_MYSQL()
        mode, humidity, humidity_threshold, fan1, fan2, timestamp  = Read_from_db_table(conn)
        print('**************')
        print('demo: %s' % (DEMO))
        print('mode: %s' % (mode))
        print('humidity: %s' % (humidity))
        print('humidity threshold: %s' % (humidity_threshold))
        print('fan 1: %s' % (fan1))
        print('fan 2: %s' % (fan2))
        print('timestamp: %s' % (timestamp))
        print('**************')

        if mode == 'logic':
            if humidity > humidity_threshold:
                print "humidity > threshold - turn both fans on"
                GPIO.output(26, True)
                GPIO.output(13, True)
            else:
                print "humidity < threshold - turn both fans off"
                GPIO.output(26, False)
                GPIO.output(13, False)
        elif mode == 'manual':
            if fan1 == '1':
                print "manual - fan 1 on"
                GPIO.output(26, True)
            else:
                print "manual - fan 1 off"
                GPIO.output(26, False)

            if fan2 == '1':
                print "manual - fan 2 on"
                GPIO.output(13, True)
            else:
                print "manual - fan 2 off"
                GPIO.output(13, False)
        time.sleep(1)

if __name__ == '__main__':
    main()