readwirte_text1

# -*- coding: utf-8 -*-

import MySQLdb
import serial
import time


#Datos de conexion
DB_HOST = '172.29.1.20'
DB_USER = 'root'
DB_PASS = 'tech123'
DB_NAME = 'Harnes'


#conexion y ejecucion de query
def run_query(query=''):
    datos = [DB_HOST, DB_USER, DB_PASS, DB_NAME]
    conn = MySQLdb.connect(*datos) # Conectar a la base de datos
    cursor = conn.cursor()         # Crear un cursor
    cursor.execute(query)          # Ejecutar una consulta

    if query.upper().startswith('SELECT'):
        data = cursor.fetchall()   # Traer los resultados de un select
    else:
        conn.commit()              # Hacer efectiva la escritura de datos
        data = None

    cursor.close()                 # Cerrar el cursor
    conn.close()                   # Cerrar la conexion

    return data

#leer sennal del puerto serial
def readSignal(objectSerial):
    chain = objectSerial.readline()
    listChain = chain.split(",")
    if ("i" in listChain[0]) and ("f" in listChain[-1]) and (len(listChain) == 7):
        #cadena valida
        return listChain
    else:
        return 0

def celsiusFarenheit(celsius):
    return ((float(celsius)*9)/5)+32

#main

#objectSerial
serialPort = serial.Serial('/dev/ttyS2', baudrate=9600, timeout=3.0)


while(1):
    try:
        cadena=readSignal(serialPort)
        if cadena != 0:
                idDevice=cadena[1]
                varTemperature = celsiusFarenheit(cadena[2])
                if varTemperature>30:
                    varTemperature=str(varTemperature)
                    varPressure = cadena[3]
                    varAlture = cadena[4]
                    varEngage = cadena[5]

                    run_query("INSERT INTO Insertion(Altura,Enganche,Presion,Temperatura,idDevice) VALUES ("+str(varAlture)+","+str(varEngage)+","+str(varPressure)+","+str(varTemperature)+","+str(idDevice)+")")
                    run_query("INSERT INTO Temperatura(vaTemperatura,idDevice) VALUES ("+str(varTemperature)+","+str(idDevice)+")")
                    run_query("INSERT INTO Presion(vaPresion,idDevice) VALUES ("+str(varPressure)+","+str(idDevice)+")")
                    run_query("INSERT INTO Altura(vaAltura,idDevice) VALUES ("+str(varAlture)+","+str(idDevice)+")")
                    run_query("INSERT INTO Enganche(vaEnganche,idDevice) VALUES ("+str(varEngage)+","+str(idDevice)+")")
                else: pass
        else:
                pass
    except:
        pass