基于树莓派+web设计的室内环境监控系统（毕设/课设/竞赛/实训/项目开发）

#!/usr/bin/python3.4 # coding=utf-8 import RPi.GPIO as GPIO import Adafruit_DHT as DHT import Adafruit_BMP.BMP085 as BMP import time import pymysql import smbus import threading import os import signal import smtplib from email.mime.text import MIMEText import getopt import sys from oled import oledDisplay as OLED from mylogger import mylogger, getCFG from power_controller import PowerControl class ems: # logger logger = mylogger('ems', 'log_ems') # 各线程检测频率 _saveFreq = _warnFreq = 10 _acqFreq = 1 / 6 # 采集到的数据 _humi22 = _temp22 = _illuminance = _pressure = _temperature = _altitude = _sealevel_pressure = -1 _haveco = 'E' # 各线程是否存在 _thrAcqAlive = _thrSaveAlive = _thrSendAlive = _isFirstStarted = False # 是否键盘中断 & 是否关闭OLED _isINT = _oledOFF = False # 采集线程是否运行 _isAcqRun = False # OLED显示状态 _oledStatus = 0 # OLED总状态数 _allStatus = 2 # 电源控制实例，在OLED初始化前上电 PC = PowerControl(logger) # OLED实例 _oled = OLED() # oled显示状态切换 线程锁 _oledLock = threading.Lock() _acqLock = threading.Lock() _config = getCFG('../config.json') def getLocalTime(self): localtime = time.strftime('%Y%m%d%H%M%S', time.localtime(time.time())) return localtime def getLocalTimeHuman(self): localtime = time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())) return localtime def getConnection(self, host, user, password, db, port=int(_config['database']['port']), charset='utf8'): connection = pymysql.connect(host=host, user=user, password=password, db=db, port=port, charset=charset) return connection # except Exception as exc: # print(getLocalTime(),exc) def insertDataDHT22(self, connection, table, temp, humi): # try: with connection.cursor() as cursor: sql = 'insert into ' + table + '(date,temp,humi) values (' + self.getLocalTime() + ',' + str( temp) + ',' + str( humi) + ');' cout = cursor.execute(sql) if cout >= 1: self.logger.info('Insert ' + str(cout) + ' row(s) in sensors_data.' + table) connection.commit() # except AttributeError as exc: # print(getLocalTimeHuman(),'Connection hasnt opened!',exc) # except Exception as exc: # print(getLocalTimeHuman(),'Database insert error!',exc) # connection.rollback() def insertDataGY30(self, connection, table, illuminance): # try: with connection.cursor() as cursor: sql = 'insert into ' + table + '(date,illuminance) values (' + self.getLocalTime() + ',' + str( illuminance) + ');' cout = cursor.execute(sql) if cout >= 1: self.logger.info('Insert ' + str(cout) + ' row(s) in sensors_data.' + table) connection.commit() # except AttributeError as exc: # print(getLocalTimeHuman(),'Connection hasnt opened!',exc) # except Exception as exc: # print(getLocalTimeHuman(),'Database insert error!',exc) # connection.rollback() def insertDataMQ7(self, connection, table, haveco): # try: with connection.cursor() as cursor: sql = 'insert into ' + table + '(date,haveco) values (' + self.getLocalTime() + ',"' + haveco + '");' cout = cursor.execute(sql) if cout >= 1: self.logger.info('Insert ' + str(cout) + ' row(s) in sensors_data.' + table) connection.commit() # except AttributeError as exc: # print(getLocalTimeHuman(),'Connection hasnt opened!',exc) # except Exception as exc: # print(getLocalTimeHuman(),'Database insert error!',exc) # connection.rollback() def insertDataGY68(self, connection, table, pressure, temperature, altitude, sealevel_pressure): # try: with connection.cursor() as cursor: sql = 'insert into ' + table + '(date,pressure,temperature,altitude,sealevel_pressure) values (' + self.getLocalTime() + ',' + str( pressure) + ',' + str(temperature) + ',' + str(altitude) + ',' + str(sealevel_pressure) + ');' cout = cursor.execute(sql) if cout >= 1: self.logger.info('Insert ' + str(cout) + ' row(s) in sensors_data.' + table) connection.commit() # except AttributeError as exc: # print(getLocalTimeHuman(),'Connection hasnt opened!',exc) # except Exception as exc: # print(getLocalTimeHuman(),'Database insert error!',exc) # connection.rollback() def insertDataALL(self, connection, table, temp, humi, illuminance, pressure): # try: with connection.cursor() as cursor: sql = 'insert into ' + table + '(date,temp,humi,light,press) values (' + self.getLocalTime() + ',' + str( temp) + ',' + str(humi) + ',' + str(illuminance) + ',' + str(pressure) + ');' # sql = 'insert into ' + table + '(date,temp,humi,illuminance,pressure,haveco) values (' + self.getLocalTime() + ',' + str( # temp) + ',' + str(humi) + ',' + str(illuminance) + ',' + str(pressure) + ',"' + haveco + '");' cout = cursor.execute(sql) if cout >= 1: self.logger.info('Insert ' + str(cout) + ' row(s) in capteur.' + table) connection.commit() # except AttributeError as exc: # print(getLocalTimeHuman(),'Connection hasnt opened!',exc) # except Exception as exc: # print(getLocalTimeHuman(),'Database insert error!',exc) # connection.rollback() def insert(self): try: connCloud = self.getConnection(self._config['database']['host'], self._config['database']['user'], self._config['database']['password'], 'capteur') while (True): connCloud.commit() date = self.travValue(connCloud, 'sensor_data', 'date', 'order by date desc limit 1') distance = (time.mktime(time.localtime(time.time())) - time.mktime( time.strptime(str(date[0][0]), "%Y-%m-%d %H:%M:%S"))) if self._isAcqRun: if distance >= self._saveFreq * 60 or date == None: # if self._temp22 is not None and 0 <= self._humi22 <= 100.0 and self._illuminance >= 0 and self._haveco is not None: self._acqLock.acquire() self.logger.info('Cloud Server:') # self.insertDataDHT22(connCloud, 'dht22', ('%.2f' % self._temp22), ('%.2f' % self._humi22)) # self.insertDataGY30(connCloud, 'gy30', ('%.1f' % self._illuminance)) # self.insertDataMQ7(connCloud, 'mq7', self._haveco) # self.insertDataGY68(connCloud, 'gy68', self._pressure, self._temperature, self._altitude, # self._sealevel_pressure) self.insertDataALL(connCloud, 'sensor_data', ('%.2f' % self._temp22), ('%.2f' % self._humi22), ('%.1f' % self._illuminance), ('%.2f' % self._pressure)) # date[0][0] = getLocalTime() self._acqLock.release() # else: # 错误输出错误信息，和校验数据 # self.logger.error("Insert Data Wrong! Waiting For ReAcquire") # time.sleep(10) elif self._saveFreq * 60 - distance > 600: time.sleep(540) elif self._saveFreq * 60 - distance > 300: time.sleep(240) elif self._saveFreq * 6