main.py

import sys

import wiringpi
import spidev
from numpy import median
import wiringpi
import Adafruit_DHT
import Adafruit_BMP.BMP085 as BMP085

from mcp3008 import MCP3008
from sharpPM10 import sharpPM10
from mq import *
import lcd_driver

import MySQLdb
import config

degree_symbol = u"\u00b0"


print('starting...')

dht_model = 22
dht_pin = 4

sharp_pin = 21
sharp_channel = 1
mq_channel = 0

green_led = 6
yellow_led = 13

try:
    wiringpi.wiringPiSetupGpio() 
    wiringpi.pinMode(green_led, 1)
    wiringpi.pinMode(yellow_led, 1)

    wiringpi.digitalWrite(yellow_led, 1) # power on the yellow LED
    wiringpi.digitalWrite(green_led, 1) # power on the green LED

    Adafruit_BMP085 = BMP085.BMP085()
    ADC = MCP3008(0, 0) # CE0
    MQ = MQ(adc=ADC, analog_channel=mq_channel)
    sharpPM10 = sharpPM10(led_pin=sharp_pin, pm10_pin=sharp_channel, adc=ADC)
    lcd = lcd_driver.lcd()
except:
    wiringpi.digitalWrite(green_led, 0) # power off the green LED

while True:
    wiringpi.digitalWrite(yellow_led, 1) # power on the yellow LED
    lcd.lcd_print(['reading sensors...'])
    
    humidity, temp_dht = Adafruit_DHT.read_retry(dht_model, dht_pin) # (sensor_type, pin_number)
    pressure = Adafruit_BMP085.read_pressure()
    dust_density = sharpPM10.read()
    gas = MQ.MQPercentage()
    
    db = MySQLdb.connect(config.host, config.user, config.password, config.db_name)
    print('connected')

    cursor = db.cursor()
    
    sql = ("INSERT INTO readings (temp, humidity, pressure, dust, lpg, co, smoke)\
            VALUES ({0:0.1f},{1:0.1f},{2:0.2f},{3:0.3f},{4:0.4f},{5:0.4f},{6:0.4f})").format(
            temp_dht or 0,
            humidity or 0,
            pressure/100 or 0,
            dust_density or 0,
            gas['GAS_LPG'] or 0,
            gas['CO'] or 0,
            gas['SMOKE'] or 0)

    try:
        cursor.execute(sql)
        db.commit()
        print('success')
        wiringpi.digitalWrite(yellow_led, 0) # power off the yellow LED
        
        lcd.lcd_print([
            ('Temp: {0:0.1f}C').format(temp_dht or 0),
            ('Humidity: {0:0.1f}%').format(humidity or 0)
        ])
        
    except:
        db.rollback()
        lcd.lcd_print(['error :('])
        print('failed!')
        wiringpi.digitalWrite(green_led, 0) # power off the green LED


    db.close()
    print('connection closed')
    time.sleep(1800) #900sec = 15min