Nginx+Mariadb+PHP+Python

雖然透過ThingSpeak呈現溫濕度圖表非常的方便，只要註冊申請帳號，透過api傳送資料到ThingSpeak，就會自動把圖畫出來，但在一些特殊狀況下，如沒有對外的網路，那就沒有辦法把資料上傳到ThingSpeak，所以此篇在Raspberry Pi上建立Nginx+Mariadb，透過Python讀取DHT22溫濕度後把資料寫到Mariadb資料庫，然後讀取資料庫中的歷史資料，用python + bokeh + pandas產生圖表網頁，讓使用者可以連到本機的網站觀看目前Raspberry Pi的溫濕度狀況，如下圖…

目前把整個溫濕度所需要安裝的套件，設定的內容及程式原始碼，透過Ansible去處理，使用方式和moodlebox一樣，使用moodlebox的原始程式，修改成go38box，整個ansible的資料夾架構及設定方式與moodlebox相同，安裝方式請參考

網站架構

溫濕度網站的架構非常的簡單，就只是一般的網頁，此網頁樣版來自於https://templated.co/azure，只做小部分修改，在溫濕度圖的地方使用兩個iFrame把溫度與濕度的html嵌入到首頁中，然後固定時間會重新載入溫濕度的html檔，所以在整個網站顯示的部分沒什麼特別的程式，也沒有使用到php，會安裝php主要是因為使用phpmyadmin去管理設定資料庫

溫濕度網址：http://go38box.local
PhpMyAdmin網址：http://go38box.local/phpmyadmin

Nginx設定

設定檔「/etc/nginx/sites-available/default」，內容如下，主要修改了root，預設的網站根目錄為「/var/www/html」目前修改成「/var/www/html/temperature」，用ansible安裝是不需要再手動設定

#
server {
        listen 80 default_server;
        listen [::]:80 default_server;

        root /var/www/html/temperature;

        index index.php index.html index.htm index.nginx-debian.html;

        server_name go38box;

        location / {
                try_files $uri $uri/ =404;
        }

        location ~ [^/]\.php(/|$) {
                include fastcgi_params;
                fastcgi_split_path_info ^(.+\.php)(/.+)$;
                fastcgi_read_timeout    300;
                fastcgi_pass    unix:/var/run/php/php7.0-fpm.sock;
                fastcgi_index   index.php;
                fastcgi_param   PATH_INFO       $fastcgi_path_info;
                fastcgi_param   SCRIPT_FILENAME $document_root$fastcgi_script_name;
                fastcgi_param   PHP_VALUE "max_execution_time=300\n upload_max_filesize=50M\n post_max_size=50M";
                client_max_body_size    50M;
        }

}

資料庫

DHT22所讀取的溫濕度會寫到Raspberry PI本機中建立的mariadb資料庫中，可以透過下方的網址及帳號密碼登入觀看及設定

網址：http://go38box.local/phpmyadmin
帳號：go38box
密碼：Go38box4$
資料庫：temperature

目前建立一個名稱為temperature的資料庫，裡面有3張資料表，欄位說明及結構如下

資料表 temp

temp儲存溫濕度的記錄，欄位說明如下：

datetime：資料的日期時間
temp：溫度，取到小數點第一位
humidity 濕度，取到小數點第一位

資料結構如下圖：

資料表 smtp

smtp資料表，存放有關寄送溫濕度異常E-MAIL的設定，此表中只會有一筆設定資料，如果要修改參數可以直接修改欄位內容即可

id：此id為key值，因為此資料表為設定用，所以只需要一筆資料，程式會讀取id=0的該筆資料當做設定值
hostname：網站網址，目前預設為 go38box.local
from_addr：寄件者E-MAIL，目前使用gmail當作smtp來寄送mail
to_addr：收件者E-MAIL
smtp_addr：gmail的smtp網址為 smtp.gmail.com
smtp_port：gmail的smtp port為 587
smtp_password：smtp的密碼，使用gmail當作smtp寄送mail，所以此密碼為from_addr 的E-MAIL密碼，目前此欄位有加密
send_time：最後一次寄送E-Mail的時間(程式會自動更新此欄位)
send_status：目前溫濕度狀態，1為異常、0為正常，此欄位請不要修改(程式會自動更新此欄位)
send_wait_time：每執行一次都會檢查是否異常，此欄位儲存單位是秒數，主要在溫濕度一直在異常狀態下不會重復的寄送，例如此欄位目前預設值為3600秒，也就是1小時，當送出一封異常E-MAIL後，會自動更新欄位中的send_time最後送出異常E-Mail的時間，每次執行會用目前的時間和send_time相減，看是否超過此欄位所設定的時間(1小時)，如果超過則會再寄送一次異常E-MAIL
send_check_time：每執行一次都會檢查是否正常，此欄位儲存單位是秒數，如果上一次寄送異常E-MAIL的時間和目前時間相比是否大於所設定的send_check_time，大於的話才會切換為正常，必免溫濕度剛好在設定的邊界值跳動會一直送出異常與正常的E-MAIL，例如目前設定660，代表11分鐘內，不會寄送恢復正常的E-MAIL，如果超過，則會更新send_time及send_status設為0

資料表 config

id：此id為key值，因為此資料表為設定用，所以只需要一筆資料，程式會讀取id=0的該筆資料當做設定值
send_mail：此欄位主要設定是否要寄送E-MAIL，0(不寄送)，1(寄送)
temp_max：設定溫度正常範圍的最高溫度，目前預設為30度
temp_min：設定溫度正常範圍的最低溫度，目前預設為10度
humidity_max：設定濕度正常範圍的最高濕度，目前預設為70%
humidity_min：設定濕度正常範圍的最低濕度，目前預設為40%
time_offset：當程式取得新的溫濕度後，會先抓資料庫中最後一筆資料回來做參考比對，檢查與最後一筆資料的時間是否超過time_offset的設定值，目前預設為100秒，如果與上一筆資料時間相差超過100秒，則會直接寫入資料庫，如果沒有超過，則會再比對目前溫濕度是否和最後一筆的溫濕度相差超過difference的設定值，如果超過也是不寫入資料庫中，主要就是去DHT22元件的異常值
difference：溫濕度的正負差，目前設定為5
thingspeak_key：如果有申請thingspeak，也想把資料上傳到thingspeak的話，註冊後會取得一組thingspeak_key，要上傳的話把key填入此欄位，如果不想上傳的話就清空此欄位，請參考文內的ThingSpeak 說明

Python 主程式

在開始前，請先閱讀開發環境及設備及取得溫濕度這兩個章節，確認溫濕度元件已接上RaspberryPi並且可以讀取到溫濕度

#!/usr/bin/python
# coding:utf-8

import sys, os, logging
import Adafruit_DHT
import httplib, urllib
import time,datetime
import MySQLdb
import base64
import smtplib
import pandas as pd
from bokeh.models import BoxAnnotation
from bokeh.plotting import figure, output_file, show
from bokeh.models import HoverTool
from Crypto.Cipher import DES
from email.MIMEMultipart import MIMEMultipart
from email.MIMEText import MIMEText

# 程式檔案路徑
fPath = "/home/go38box/DHT22/"

# log 參數設定
FORMAT = '%(asctime)s - %(message)s'
logpath = fPath + "tempLogs"
logging.basicConfig(format = FORMAT, filename = logpath)
logger = logging.getLogger('tcpserver')
"""
console = logging.StreamHandler()
aformat = logging.Formatter('%(asctime)s - %(message)s')
console.setFormatter(aformat)
logger.addHandler(console)
"""

def main():
    writeToDb = False
    errId = -1

    # 連接資料庫
    db = db_connect()
    # 取得最後一筆資料
    lastRecord = get_last_record(db)
    # 取得config資料表中的設定
    [dbSendMail,dbTempMax,dbTempMin,dbHumidityMax,dbHumidityMin,dbTimeOffset,dbDifference,dbThingSpeakApiKey] = get_config(db)
    #取得目前時間
    dtnow = datetime.datetime.now()
    #取得溫濕度
    [temp,humidity] = dht22() 
    # 目前時間和最後一筆資料的時間相差幾秒
    timeoffset = (dtnow - lastRecord[0]).seconds

    # 送溫濕度到ThingSpeak，如果設定值為空的話，就不傳送
    if dbThingSpeakApiKey!='':
        params = urllib.urlencode({'field1': '{0:0.1f}'.format(temp), 'field2': '{0:0.1f}'.format(humidity), 'key': dbThingSpeakApiKey})
        post_to_thingspeak2(params)

    #溫濕度在0~100間才處理
    if (humidity >0 and humidity <= 100) and (temp >0 and temp<=100):
        if timeoffset > dbTimeOffset: 
            #目前時間和資料庫中最後一筆資料的時間超過X秒就直接寫入資料庫
            logger.warning('Msg =>last(%s Temp:%s Humidity:%s) New(%s Temp:%6.2f Humidity:%6.2f) event:%s', lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,'timeoffset > 60')
            writeToDb = True
            errId=2
        else: 
            #目前時間和資料庫在X秒內，就檢查和上一筆的溫濕度不可超過所設定的範圍
            #超過則不寫入資料庫
            #溫度+-5度 ,濕度+-5度
            #正負值由資料庫中設定
            if (temp > lastRecord[1]+dbDifference) or (temp < lastRecord[1]-dbDifference): 
                logger.warning('Msg =>last(%s Temp:%s Humidity:%s) New(%s Temp:%6.2f Humidity:%6.2f) event:%s', lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,'(temp > lastRecord[1]+'+str(dbDifference)+') or (temp < lastRecord[1]-'+str(dbDifference)+')')
                writeToDb = False
                errId=3
            elif (humidity > lastRecord[2]+dbDifference) or (humidity < lastRecord[2]-dbDifference):
                logger.warning('Msg =>last(%s Temp:%s Humidity:%s) New(%s Temp:%6.2f Humidity:%6.2f) event:%s', lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,'(humidity > lastRecord[2]+'+str(dbDifference)+') or (humidity < lastRecord[2]-'+str(dbDifference)+')')
                writeToDb = False
                errId=4
            else:
                writeToDb = True
    else:
        # 溫濕度不在0~100間
        logger.warning('Msg =>last(%s Temp:%s Humidity:%s) New(%s Temp:%6.2f Humidity:%6.2f) event:%s', lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,'(humidity >0 and humidity <= 100) and (temp >0 and temp<=100)')    
        writeToDb = False
        errId=1

    # 依上方的判斷(writeToDb)，決定是否要寫入資料庫
    if writeToDb:    
        #logger.warning('Msg =>last(%s Temp:%s Humidity:%s) New(%s Temp:%6.2f Humidity:%6.2f) event:%s', lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,'OK')
        # 將目前的溫濕度寫入資料庫
        insert_to_mysql(db,dtnow,temp,humidity);
        # 取得目前時間
        dataframe = select_data(db,1)
        lastRecordNew = get_last_record(db)
        build_temp(dataframe[0],lastRecordNew,dbTempMax,dbTempMin)
        build_humidity(dataframe[1],lastRecordNew,dbHumidityMax,dbHumidityMin)
    # 依資料表config中欄位「send_mail」的設定，判斷是否要寄送E-Mail    
    if dbSendMail==1 :
        if writeToDb == True and (lastRecordNew[1]>=dbTempMin and lastRecordNew[1]<=dbTempMax and lastRecordNew[2]>=dbHumidityMin and lastRecordNew[2]<=dbHumidityMax):
            send_email(db,lastRecord[0],lastRecord[1],lastRecord[2],lastRecordNew[0],lastRecordNew[1],lastRecordNew[2],dbTempMax,dbTempMin,dbHumidityMax,dbHumidityMin,dbTimeOffset,dbDifference,timeoffset,0)    
        elif writeToDb == False:
            # print 'writeToDb=false'
            send_email(db,lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,dbTempMax,dbTempMin,dbHumidityMax,dbHumidityMin,dbTimeOffset,dbDifference,timeoffset,errId)
        elif lastRecordNew[1]<dbTempMin or lastRecordNew[1]>dbTempMax or lastRecordNew[2]<dbHumidityMin or lastRecordNew[2]>dbHumidityMax :
            # print 'maxmine'
            errId=5
            logger.warning('Msg =>last(%s Temp:%s Humidity:%s) New(%s Temp:%6.2f Humidity:%6.2f) event:%s', lastRecord[0],lastRecord[1],lastRecord[2],dtnow,temp,humidity,'溫濕度異常，不在所設定的範圍內！')    
            send_email(db,lastRecord[0],lastRecord[1],lastRecord[2],lastRecordNew[0],lastRecordNew[1],lastRecordNew[2],dbTempMax,dbTempMin,dbHumidityMax,dbHumidityMin,dbTimeOffset,dbDifference,timeoffset,errId)

    db.close()

# 遲接資料庫
def db_connect():
    db = MySQLdb.connect(host="localhost",user="go38box", passwd="Go38box4$",db="temperature", charset="utf8")
    return db

# 取得溫濕度
def dht22():
    humidity, temperature = Adafruit_DHT.read_retry(Adafruit_DHT.AM2302,4)

    if humidity is not None and temperature is not None:
        print('Temp={0:0.1f}* Humidity={1:0.1f}%'.format(temperature,humidity))
        return(temperature,humidity)
    else:
        print('Failed to get reading. Try again!')
        return(0,0)

# 將溫濕度送到ThingSpeak上
def post_to_thingspeak2(payload):
        headers = {"Content-type": "application/x-www-form-urlencoded","Accept": "text/plain"}
        not_connected = 1
        while (not_connected):
            try:
                conn = httplib.HTTPConnection("api.thingspeak.com",80,True,10)
                conn.connect()
                not_connected = 0
            except (httplib.HTTPException, socket.error) as ex:
                # logger.warning('Error: %s',ex)
                print "Error: %s" % ex

        conn.request("POST", "/update", payload, headers)
        response = conn.getresponse()
        print( response.status, response.reason, payload, time.strftime("%c"))
        if response.status!=200 and response.reason!='OK':
            logger.warning('ThingSpeak Error: status:%s  reason:%s. payload:%s time:%s' ,response.status, response.reason, payload, time.strftime("%c"))

        data = response.read()
        conn.close()

# 將溫濕度寫入資料庫中 
def insert_to_mysql(db,dtnow,temp,humidity):
    cursor = db.cursor()
    strnow = dtnow
    strtemp = "%.1f" %(temp)
    strhumidity = "%.1f" %(humidity)
    insert = ("INSERT INTO temp (datetime, temp, humidity) VALUES (%s, %s, %s)")
    data = (strnow,strtemp,strhumidity)
    cursor.execute(insert,data)
    db.commit()

# 從資料庫中取得最後一筆溫濕度記錄
def get_last_record(db):
    cursor = db.cursor()
    cursor.execute("select * from temp order by datetime desc limit 1")
    record = cursor.fetchone()
    lastTime = record[0]
    lastTemp = record[1]
    lastHumidity = record[2]
    # print "Last Datetime = %s  Temp = %s  Humidity = %s" %(lastTime,lastTemp,lastHumidity)
    return (lastTime,lastTemp,lastHumidity)

# 從資料庫查詢從目前時間往前x天的溫濕度資料，畫圖用
def select_data(db,sDay):
    cursor = db.cursor()
    cursor.execute("select * from temp where datetime BETWEEN DATE_SUB(NOW(),INTERVAL " + str(sDay)  +" DAY) AND NOW()")
    rows = cursor.fetchall()
    #for record in rows:
    #    print "%s %s %s" % (record[0],record[1],record[2])

    df = pd.DataFrame([[ij for ij in i] for i in rows])
    df.rename(columns={0: 'DateTime', 1: 'Temp', 2: 'Humidity'}, inplace=True);
    df_temp = df.sort_values(['DateTime'], ascending=[1]);
    df_humidity = df.sort_values(['DateTime'], ascending=[2]);
    return (df_temp,df_humidity)

# 產生溫度的html檔
def build_temp(df,lastRecord,dbTempMax,dbTempMin):
    hover = HoverTool(tooltips=[
        ("時間", "@x{%F %H:%M:%S}"),
        ("溫度", "@y{%0.2f} (°C)"),
    ],
    formatters={
        'x' : 'datetime', 
        'y' : 'printf',
    },)

    TOOLS = ["pan,wheel_zoom,box_zoom,reset,save",hover]
    p = figure(plot_width=540,plot_height=250,x_axis_type="datetime",y_range=(0, 40), tools=TOOLS,toolbar_location = "above", title="溫度  ("+str(lastRecord[0])+"  "+str(lastRecord[1])+"°C)")
    p.xgrid.grid_line_color=None
    p.ygrid.grid_line_alpha=0.5
    p.xaxis.axis_label = '時間'
    p.yaxis.axis_label = '攝氏(°C)'

    p.line(df['DateTime'], df['Temp'], color='navy', alpha=0.5)
    #p.line(df['DateTime'], df['Temp'], line_dash="4 4", line_width = 1,color='navy', alpha=0.5)
    #p.circle(df['DateTime'],df['Temp'], size=10, color="navy", alpha=0.5)
    p.add_layout(BoxAnnotation(top=dbTempMin, fill_alpha=0.1, fill_color='red'))
    p.add_layout(BoxAnnotation(bottom=dbTempMin, top=dbTempMax, fill_alpha=0.1, line_color='olive', fill_color='olive'))
    p.add_layout(BoxAnnotation(bottom=dbTempMax, fill_alpha=0.1, fill_color='red'))

    output_file(fPath+"db_temp.html")
    show(p)

# 產生濕度的html檔
def build_humidity(df,lastRecord,dbHumidityMax,dbHumidityMin):
    hover = HoverTool(tooltips=[
        ("時間", "@x{%F %H:%M:%S}"),
        ("濕度", "@y{%0.2f} (%)"),
    ],
    formatters={
        'x' : 'datetime', 
        'y' : 'printf',
    },)

    TOOLS = ["pan,wheel_zoom,box_zoom,reset,save",hover]
    p = figure(plot_width=540,plot_height=250,x_axis_type="datetime",y_range=(20,105), tools=TOOLS,toolbar_location = "above", title="濕度  ("+str(lastRecord[0])+"  "+str(lastRecord[2])+"%)")
    p.xgrid.grid_line_color=None
    p.ygrid.grid_line_alpha=0.5
    p.xaxis.axis_label = '時間'
    p.yaxis.axis_label = '百分比(%)'

    p.line(df['DateTime'], df['Humidity'], color='navy', alpha=0.5)
    p.add_layout(BoxAnnotation(top=dbHumidityMin, fill_alpha=0.1, fill_color='red'))
    p.add_layout(BoxAnnotation(bottom=dbHumidityMin, top=dbHumidityMax, fill_alpha=0.1, line_color='olive', fill_color='olive'))
    p.add_layout(BoxAnnotation(bottom=dbHumidityMax, fill_alpha=0.1, fill_color='red'))

    output_file(fPath+"db_humidity.html")
    show(p)

# 讀取資料庫中config資料表中的設定，id=0
def get_config(db):
    cursor = db.cursor()
    cursor.execute("select * from config where id=0")
    record = cursor.fetchone()
    return(record[1],record[2],record[3],record[4],record[5],record[6],record[7],record[8])

# 傳送email
def send_email(db,lastDatetime,lastTemp,lastHuminidy,newDatetime,newTemp,newHuminidy,dbTempMax,dbTempMin,dbHumidityMax,dbHumidityMin,dbTimeOffset,dbDifference,timeoffset,errId):
    cursor = db.cursor()
    cursor.execute("select * from smtp where id=0")
    record = cursor.fetchone()

    fromaddr = record[2]
    toaddr = record[3]
    pwd = decrypt_des(record[6])

    sendTime = record[7]
    sendStatus = record[8]
    sendWaitTime = record[9]
    sendCheckTime = record[10]

    sendTimeOffset = (newDatetime - sendTime).seconds
    goSendMail = False

    print 'errId=' +str(errId) 
    print 'sendTimeOffset=' +str(sendTimeOffset) 

    if errId==0:
        #errId=0代表溫濕度正常，但還要加入檢查，如果上一次寄送異常mail的時間和目前時間相比是否大於所設定的sendCheckTime，大於的話才切換為正常
        if sendStatus==1 and (sendTimeOffset > sendCheckTime):
            update_smtp_send_status(db,newDatetime,0)
            #傳送回復正常的mail
            msg = MIMEMultipart()
            msg['From'] = fromaddr
            msg['To'] = toaddr
            msg['Subject'] = "Go38 溫濕度正常"

            bodytable =  """<font color="#00A800">溫濕度正常！</font><br>"""

            bodytable += """
            <br><font color="blue">*溫度正常範圍：""" + str(dbTempMin) + """ ~ """ + str(dbTempMax) + """ (°C)</font><br>
            <font color="blue">*濕度正常範圍：""" + str(dbHumidityMin) + """ ~ """ + str(dbHumidityMax) + """ (%)</font><br>
            """

            bodytable += """
            <table align="left" border="1" cellpadding="1" cellspacing="1" style="width:500px">
                <tbody>
                    <tr>
                        <td style="text-align:center"><a href="http://"""+str(record[1])+""" " target="_blank">"""+str(record[1])+"""</a></td>
                        <td style="text-align:center">日期</td>
                        <td style="text-align:center">溫度(°C)</td>
                        <td style="text-align:center">濕度(%)</td>
                    </tr>
                    <tr>
                        <td style="text-align:center">上一筆資料</td>
                        <td style="text-align:center">"""+ str(lastDatetime) +"""</td>
                        <td style="text-align:center">"""+ str(lastTemp) +"""</td>
                        <td style="text-align:center">"""+ str(lastHuminidy) +"""</td>
                    </tr>
                    <tr>
                        <td style="text-align:center">最新資料</td>
                        <td style="text-align:center">"""+ str(newDatetime) +"""</td>
                        <td style="text-align:center">"""+ str(newTemp) +"""</td>
                        <td style="text-align:center">"""+ str(newHuminidy) +"""</td>
                    </tr>
                </tbody>
            </table>
            """
            msg.attach(MIMEText(bodytable, 'html', 'utf-8') )
            server = smtplib.SMTP(record[4], record[5])
            server.starttls()
            server.login(fromaddr, pwd)
            text = msg.as_string()
            server.sendmail(fromaddr, toaddr, text)
            server.quit()

    else:    
        #最後傳送狀態，0：傳送正常，1：傳送異常
        if sendStatus == 0:
            goSendMail = True
        elif sendStatus == 1:
            #最後一次送mail的時間和目前時間相減，相差的秒數大於所設定的sendWaitTime，則再傳送一次異常mail
            if sendTimeOffset > sendWaitTime:
                goSendMail = True

        ##傳送溫濕度異常的mail
        if goSendMail==True:
            update_smtp_send_status(db,newDatetime,1)
            msg = MIMEMultipart()
            msg['From'] = fromaddr
            msg['To'] = toaddr
            msg['Subject'] = "Go38 溫濕度異常"

            #body = str(record[1]) + "MAIL測試"


            if errId==1:
                bodytable =  """<font color="red">偵測器回傳的溫濕度不在 0~100 之間，未寫入資料庫！</font><br>"""
            elif errId==2:
                bodytable =  """<font color="red">目前時間和資料庫中最後一筆資料的時間超過"""+str(dbTimeOffset)+"""秒就直接寫入資料庫，不比對正負值！</font><br>"""
            elif errId==3:
                bodytable =  """<font color="red">目前溫度與最後一筆資料相比，在"""+str(timeoffset)+"""秒內超過所設定的正負值"""+str(dbDifference)+"""！</font><br>"""
            elif errId==4:
                bodytable =  """<font color="red">目前濕度與最後一筆資料相比，在"""+str(timeoffset)+"""秒內超過所設定的正負值"""+str(dbDifference)+"""！</font><br>"""
            elif errId==5:
                bodytable =  """<font color="red">目前溫度或濕度不在所設定的正常範圍內！</font><br>"""
            else:
                bodytable =  """<font color="red">沒有此errId<br>"""

            bodytable += """
            <br><font color="blue">*溫度正常範圍：""" + str(dbTempMin) + """ ~ """ + str(dbTempMax) + """ (°C)</font><br>
            <font color="blue">*濕度正常範圍：""" + str(dbHumidityMin) + """ ~ """ + str(dbHumidityMax) + """ (%)</font><br>
            """

            bodytable += """
            <table align="left" border="1" cellpadding="1" cellspacing="1" style="width:500px">
                <tbody>
                    <tr>
                        <td style="text-align:center"><a href="http://"""+str(record[1])+""" " target="_blank">"""+str(record[1])+"""</a></td>
                        <td style="text-align:center">日期</td>
                        <td style="text-align:center">溫度(°C)</td>
                        <td style="text-align:center">濕度(%)</td>
                    </tr>
                    <tr>
                        <td style="text-align:center">上一筆資料</td>
                        <td style="text-align:center">"""+ str(lastDatetime) +"""</td>
                        <td style="text-align:center">"""+ str(lastTemp) +"""</td>
                        <td style="text-align:center">"""+ str(lastHuminidy) +"""</td>
                    </tr>
                    <tr>
                        <td style="text-align:center">最新資料</td>
                        <td style="text-align:center">"""+ str(newDatetime) +"""</td>
                        <td style="text-align:center">"""+ str(newTemp) +"""</td>
                        <td style="text-align:center">"""+ str(newHuminidy) +"""</td>
                    </tr>
                </tbody>
            </table>
            """

            # msg.attach(MIMEText(body, 'plain'))
            msg.attach(MIMEText(bodytable, 'html', 'utf-8') )
            # msg = MIMEText(mail_msg, 'html', 'utf-8') 
            server = smtplib.SMTP(record[4], record[5])
            server.starttls()
            server.login(fromaddr, pwd)
            text = msg.as_string()
            server.sendmail(fromaddr, toaddr, text)
            server.quit()

# 更新資料表smtp中的SendTime與SendStatus
def update_smtp_send_status(db,dSendTime,dSendStatus):
    cursor = db.cursor()
    cursor.execute("update smtp set send_time='"+ str(dSendTime) +"' , send_status='"+str(dSendStatus)+"' where id=0")
    db.commit()

# 解密，主要用於資料表中smtp的smtp_password欄位，加密過程還加了一組key，目前設定為"@Go38Box"
def decrypt_des(encrypted):
    if encrypted is None:
        return ""
    try:
        key = '@Go38Box'
        # ECB方式
        generator = DES.new(key, DES.MODE_ECB)
        # 解碼
        crypted_str = base64.b64decode(encrypted)
        # 解密
        result = generator.decrypt(crypted_str)
        # 替換非空白字元
        result = result.strip("")
        #print "encrypted : "+str(encrypted)+"  cipher :"+result
        return result
    except Exception, e:
        print Exception, ":", e
        return ""

# end main
if __name__ == "__main__":
    sys.exit(main())

加解密程式

以下的程式主要是用在smtp資料表欄位「smtp_password」，注意裡面有一個變數key，下方測試是使用「1234A#CD」，而溫濕度程式在使用的是「@Go38Box」

#!/usr/bin/python
# coding:utf-8

from Crypto.Cipher import DES
import base64

def encrypt_des(cipher):
    if cipher is None:
        return ""
    try:
        key = '1234A#CD'
        # ECB方式
        generator = DES.new(key, DES.MODE_ECB)
        # 未滿8位數補空白
        pad = 8 - len(cipher) % 8
        pad_str = ""
        for i in range(pad):
            pad_str = pad_str + chr(pad)
        # 加密
        encrypted = generator.encrypt(cipher + pad_str)
        # 編碼
        result = base64.b64encode(encrypted)
        print "cipher : "+str(cipher)+"  encrypted : "+result
        # decrypt_des(result)
        return result
    except Exception, e:
        print Exception, ":", e
        return ""

def decrypt_des(encrypted):
    if encrypted is None:
        return ""
    try:
        key = '1234A#CD'
        # ECB方式
        generator = DES.new(key, DES.MODE_ECB)
        # 解碼
        crypted_str = base64.b64decode(encrypted)
        # 解密
        result = generator.decrypt(crypted_str)
        # 替換非空白字元
        result = result.strip("")
        print "encrypted : "+str(encrypted)+"  cipher :"+result
        return result
    except Exception, e:
        print Exception, ":", e
        return ""

encrypt_des('123345678')
decrypt_des('y6xH9zUHiHXjh8Y5CxVMjg==')

以上程式執行結果

cipher : 123345678  encrypted : y6xH9zUHiHXjh8Y5CxVMjg==
encrypted : y6xH9zUHiHXjh8Y5CxVMjg==  cipher :123345678
>>>

PreviousThingSpeak NextBuilding the Go38Box

Last updated 5 years ago

Was this helpful?

Nginx+Mariadb+PHP+Python

網站架構

相關檔案

index.html HEAD

index.html BODY

Nginx設定

資料庫

資料表 temp

資料表 smtp

資料表 config

Python 主程式

加解密程式

網站架構

相關檔案

index.html HEAD

index.html BODY

Nginx設定

資料庫

資料表 temp

資料表 smtp

資料表 config

Python 主程式

加解密程式