# 主業務邏輯中的視圖和路由的定義 import os import datetime from flask import Flask, redirect, render_template, request, session, Response, jsonify from sqlalchemy.sql.expression import desc # 導入藍圖程序，用於構建路由 from werkzeug.utils import redirect from . import main from coffee_manage import mqtt # 導入db，用於操作數據庫 from coffee_manage import db # 導入實體類，用於操作數據庫 from ..models import * import json from datetime import datetime as dt from sqlalchemy import text import pymysql import pandas as pd from concurrent.futures import ThreadPoolExecutor import cv2 import pickle import socket import time import threading import numpy as np import math from .mqtt import MQTT from matplotlib import pyplot as plt import random from matplotlib.backends.backend_tkagg import FigureCanvasTkAgg as FigureCanvas import io from flask import make_response pool = ThreadPoolExecutor(25) s_sock = 0 lock = threading.Lock() ''' mydb = pymysql.connect(host='52.69.200.169', port=3306, user='coffee', password='skyeye', database='Coffee', charset='utf8') mycursor = mydb.cursor() ''' # 主頁的訪問路徑 @main.route('/') def main_index(): # 獲取登入信息 if 'id' in session and 'uname' in session: username = session['uname'] # Rita 參數 params 是用來取得參數的 locals=() 所有參數 return render_template('index.html', params=locals()) else: # Rita 是否應改為 registration 註冊, 沒有會員資料就導到註冊去 return render_template('sign_in.html') # Rita 測試 # 使用者名稱測試 # !!! AttributeError: 'NoneType' object has no attribute 'vacuum' @main.route('/loading/S', methods=['GET', 'POST']) def S_loading(stid): if request.method == 'GET': # 色選機 return else: pass @main.route('/loading/P', methods=['GET', 'POST']) def P_loading(ptid): if request.method == 'GET': # 脫皮機 return else: pass @main.route('/loading/C', methods=['GET', 'POST']) def C_loading(ctid): if request.method == 'GET': tank_actuator = clean_tank_actuator.query.filter_by(tank_num='C'+ctid).order_by(text('datetime desc')).first() tank_vacuum = tank_actuator.vacuum tank_pump_waterFloat = tank_actuator.pump_waterFloat tank_pump_waterL2 = tank_actuator.pump_waterL2 tank_pump_waterL4 = tank_actuator.pump_waterL4 tank_solenoid_waterL3 = tank_actuator.solenoid_waterL3 tank_solenoid_waterL5 = tank_actuator.solenoid_waterL5 tank_stepping_motor = tank_actuator.stepping_motor print('tank_stepping_motor:', tank_stepping_motor) # 感測器_浮選清洗_超音波感測器 tank_UltraSonic = clean_tank_UltraSonic.query.filter_by(tank_num='C'+ctid).order_by(text('datetime desc')).first() UltraSonic= tank_UltraSonic.UltraSonic return jsonify({"UltraSonic":UltraSonic, "tank_vacuum":tank_vacuum, "tank_pump_waterFloat":tank_pump_waterFloat, "tank_pump_waterL2":tank_pump_waterL2, "tank_pump_waterL4":tank_pump_waterL4, "tank_solenoid_waterL3":tank_solenoid_waterL3, "tank_solenoid_waterL5":tank_solenoid_waterL5, "tank_stepping_motor":tank_stepping_motor }) else: pass @main.route('/loading/F', methods=['GET', 'POST']) def F_loading(ftid): if request.method == 'GET': # 制動器_發酵槽_ALL tank_actuator = ferment_tank_actuator.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() tank_vacuum = tank_actuator.vacuum tank_threewayvalve_input = tank_actuator.threewayvalve_input tank_diskvalve = tank_actuator.diskvalve tank_solenoid_water_total = tank_actuator.solenoid_tank_water_total tank_solenoid_disinfect = tank_actuator.solenoid_tank_disinfect outer_solenoid_water = tank_actuator.solenoid_outer_water tank_solenoid_water_in = tank_actuator.solenoid_tank_water_in tank_pump_sensor = tank_actuator.pump_sensor tank_threewayvalve_bean = tank_actuator.threewayvalve_bean outer_threewayvalve_float = tank_actuator.threewayvalve_outer_float tank_motor = tank_actuator.motor tank_heater1 = tank_actuator.heater1 tank_heater2 = tank_actuator.heater2 tank_temp_enable = tank_actuator.temp_enable tank_temp = tank_actuator.temp # 感測器_發酵桶_SHT11 tank_SHT11 = ferment_tank_SHT11.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() SHT11_Temp = float(tank_SHT11.SHT11_Temp) SHT11_Humidity = float(tank_SHT11.SHT11_Humidity) # 感測器_發酵桶_二氧化碳 tank_CO2 = ferment_tank_CO2.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() CO2 = float(tank_CO2.CO2) # 感測器_發酵桶_酸鹼值 tank_PH = ferment_tank_PH.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() tank_ORP = ferment_tank_ORP.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() tank_DO = ferment_tank_DO.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() tank_EC = ferment_tank_EC.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() PH = float(tank_PH.PH) ORP = float(tank_ORP.ORP) DO = float(tank_DO.DO) EC = float(tank_EC.EC) # 感測器_發酵桶_氣壓 tank_PA = ferment_tank_PA.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() PA = float(tank_PA.PA) # 感測器_發酵桶_超音波感測器 tank_UltraSonic = ferment_tank_UltraSonic.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() UltraSonic= int(tank_UltraSonic.UltraSonic) # 感測器_發酵桶_水位計 tank_WaterLevel = ferment_tank_WaterLevel.query.filter_by(tank_num='F'+ftid).order_by(text('datetime desc')).first() WaterLevel = tank_WaterLevel.WaterLevel return jsonify({"UltraSonic":UltraSonic, "SHT11_Temp": SHT11_Temp, "SHT11_Humidity":SHT11_Humidity, "CO2":CO2, "PH":PH, "ORP":ORP, "DO":DO, "EC":EC, "PA":PA, "WaterLevel":WaterLevel, "tank_vacuum":tank_vacuum, "tank_threewayvalve_input":tank_threewayvalve_input, "tank_diskvalve":tank_diskvalve, "tank_solenoid_water_total":tank_solenoid_water_total, "tank_solenoid_disinfect":tank_solenoid_disinfect, "outer_solenoid_water":outer_solenoid_water, "tank_solenoid_water_in":tank_solenoid_water_in, "tank_pump_sensor":tank_pump_sensor, "tank_threewayvalve_bean":tank_threewayvalve_bean, "outer_threewayvalve_float":outer_threewayvalve_float, "tank_motor":tank_motor, "tank_heater1":tank_heater1, "tank_heater2":tank_heater2, "tank_temp_enable":tank_temp_enable, "tank_temp":tank_temp }) else: pass @main.route('/loading/D', methods=['GET', 'POST']) def D_loading(dtid): if request.method == 'GET': # 感測器_乾燥桶_超音波感測器 tank_UltraSonic = dry_tank_UltraSonic.query.filter_by(tank_num="D"+dtid).order_by(text('datetime desc')).first() UltraSonic = tank_UltraSonic.UltraSonic # 感測器_乾燥桶_SHT11 tank_SHT11 = dry_tank_SHT11.query.filter_by(tank_num="D"+dtid).order_by(text('datetime desc')).first() SHT11_Temp = tank_SHT11.SHT11_Temp SHT11_Humidity = tank_SHT11.SHT11_Humidity # 感測器_乾燥桶_土壤三合一 tank_Soil = dry_tank_Soil.query.filter_by(tank_num="D"+dtid).order_by(text('datetime desc')).first() soil_Temp = tank_Soil.soil_Temp soil_Humidity = tank_Soil.soil_Humidity soil_EC = tank_Soil.soil_EC # 感測器_乾燥桶_氣壓 tank_PA = dry_tank_PA.query.filter_by(tank_num="D"+dtid).order_by(text('datetime desc')).first() PA = tank_PA.PA # 制動器_乾燥桶_ALL tank_brake = dry_tank_brake.query.filter_by(tank_num="D"+dtid).order_by(text('datetime desc')).first() # tank_vacuum = 'ON' if i<100 else 2 if i>100 else 0 tank_vacuum = tank_brake.vacuum tank_threewayvalve = tank_brake.threewayvalve tank_diskvalve = tank_brake.diskvalve tank_solenoid_disinfect = tank_brake.solenoid_disinfect tank_solenoid_water = tank_brake.solenoid_water tank_motor = tank_brake.motor tank_blower = tank_brake.blower tank_heater1 = tank_brake.heater1 tank_heater2 = tank_brake.heater2 tank_temp1_enable = tank_brake.temp1_enable tank_temp1 = tank_brake.temp1 #return jsonify({"peeling": peeling_rpm}) return jsonify({"UltraSonic":UltraSonic, "SHT11_Temp": SHT11_Temp, "SHT11_Humidity":SHT11_Humidity, "soil_Temp":soil_Temp, "soil_Humidity":soil_Humidity, "soil_EC":soil_EC, "PA":PA, "tank_vacuum":tank_vacuum, "tank_threewayvalve":tank_threewayvalve, "tank_diskvalve":tank_diskvalve, "tank_solenoid_disinfect":tank_solenoid_disinfect, "tank_solenoid_water":tank_solenoid_water, "tank_motor":tank_motor, "tank_blower":tank_blower, "tank_heater1":tank_heater1, "tank_heater2":tank_heater2, "tank_temp1_enable":tank_temp1_enable, "tank_temp1":tank_temp1 }) else: pass @main.route('/index_new') def index_new(): return render_template('index_new.html', params=locals()) @main.route('/user/') def user(name): return render_template('hello.html', name=name) ''' @main.route('/plot.png') def plot(): # 重新整理會有問題 # 圖的寬和高 fig = plt.figure() # 在圖中新增子圖, 通常多個圖才會用到？ axis = fig.add_subplot(1, 1, 1) # x、軸資料 xs = range(100) ys = [random.randint(1, 50) for x in xs] axis.plot(xs, ys) canvas = FigureCanvas(fig) output = io.BytesIO() canvas.print_png(output) response = make_response(output.getvalue()) response.mimetype = 'image/png' return response ''' @main.route('/chart//', methods=['GET', 'POST']) def chart(sensor_name, tid): if request.method == 'GET': return render_template('sensor_chart.html', **locals()) elif request.method == 'POST': starttime = request.values['sensor_starttime'] # 2021-07-19T09:00 endtime = request.values['sensor_endtime'] # 2021-07-19T12:00 sensor_name = request.values['sensors'] print('sensor_name:', sensor_name) # 判斷資料索取區間起<迄 if starttime < endtime : # print('starttime endtime:', starttime, endtime) #　print('TF:', starttime迄 else: return render_template('sensor_chart.html', **locals()) # Rita 測試 # 乾燥桶感測器/制動器測試 # Rita 須加上區分桶號 !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! @main.route('/dry_tank/1', methods=['GET']) def dry_tank(): if request.method == 'GET': return render_template('dry_tank.html') @main.route('/clean', methods=['GET']) def clean(): # 制動器_浮選清洗_ALL tank_actuator = clean_tank_actuator.query.filter_by(tank_num='C1').order_by(text('datetime desc')).first() tank_vacuum = 'ON' if tank_actuator.vacuum == 1 else 'OFF' tank_pump_waterFloat = 'ON' if tank_actuator.pump_waterFloat == 1 else 'OFF' tank_pump_waterL2 = 'ON' if tank_actuator.pump_waterL2 == 1 else 'OFF' tank_pump_waterL4 = 'ON' if tank_actuator.pump_waterL4 == 1 else 'OFF' tank_solenoid_waterL3 = 'ON' if tank_actuator.solenoid_waterL3 == 1 else 'OFF' tank_solenoid_waterL5 = 'ON' if tank_actuator.solenoid_waterL5 == 1 else 'OFF' tank_stepping_motor = tank_actuator.stepping_motor print('tank_stepping_motor:', tank_stepping_motor) # 感測器_浮選清洗_超音波感測器 tank_UltraSonic = clean_tank_UltraSonic.query.filter_by(tank_num='C1').order_by(text('datetime desc')).first() return render_template('clean.html', **locals()) @main.route('/ferment', methods=['GET']) def ferment(): ''' # 制動器_入料儲豆槽_真空吸料機 input_vacuum = ferment_input_actuator.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() #　print('input_vacuum.vacuum:', input_vacuum.vacuum) input_vacuum = 'ON' if (input_vacuum.vacuum == 1) else 'OFF' # print('input_vacuum:', input_vacuum) # 制動器_發酵槽_ALL tank_actuator = ferment_tank_actuator.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() tank_vacuum = 'ON' if tank_actuator.vacuum == 1 else 'OFF' tank_threewayvalve_input = 'ON' if tank_actuator.threewayvalve_input == 1 else 'OFF' tank_diskvalve = 'ON' if tank_actuator.diskvalve == 1 else 'OFF' tank_solenoid_water_total = 'ON' if tank_actuator.solenoid_tank_water_total == 1 else 'OFF' tank_solenoid_disinfect = 'ON' if tank_actuator.solenoid_tank_disinfect == 1 else 'OFF' outer_solenoid_water = 'ON' if tank_actuator.solenoid_outer_water == 1 else 'OFF' tank_solenoid_water_in = 'ON' if tank_actuator.solenoid_tank_water_in == 1 else 'OFF' tank_pump_sensor = 'ON' if tank_actuator.pump_sensor == 1 else 'OFF' tank_threewayvalve_bean = 'ON' if tank_actuator.threewayvalve_bean == 1 else 'OFF' outer_threewayvalve_float = 'ON' if tank_actuator.threewayvalve_outer_float == 1 else 'OFF' tank_motor = tank_actuator.motor tank_heater1 = 'ON' if tank_actuator.heater1 == 1 else 'OFF' tank_heater2 = 'ON' if tank_actuator.heater2 == 1 else 'OFF' tank_temp_enable = 'ON' if tank_actuator.temp_enable == 1 else 'OFF' tank_temp = tank_actuator.temp # 制動器_出料儲豆槽_真空吸引機 output_vacuum = ferment_output_actuator.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() #print('output_vacuum.vacuum: ', output_vacuum.vacuum) output_vacuum = 'ON' if (output_vacuum.vacuum == 1) else 'OFF' #print('output_vacuum: ', output_vacuum) # 感測器_入料儲豆槽_超音波感測器 input_UltraSonic = ferment_input_UltraSonic.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_發酵桶_SHT11 tank_SHT11 = ferment_tank_SHT11.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_發酵桶_二氧化碳 tank_CO2 = ferment_tank_CO2.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_發酵桶_酸鹼值 tank_PH = ferment_tank_PH.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() tank_ORP = ferment_tank_ORP.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() tank_DO = ferment_tank_DO.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() tank_EC = ferment_tank_EC.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_發酵桶_氣壓 tank_PA = ferment_tank_PA.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_發酵桶_超音波感測器 tank_UltraSonic = ferment_tank_UltraSonic.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_發酵桶_水位計 tank_WaterLevel = ferment_tank_WaterLevel.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() # 感測器_出料儲豆槽_超音波感測器 output_UltraSonic = ferment_output_UltraSonic.query.filter_by(tank_num='F1').order_by(text('datetime desc')).first() ''' return render_template('ferment.html', **locals()) @main.route('/dry', methods=['GET']) def dry(): if request.method == 'GET': ''' # 感測器_入料儲豆槽_超音波感測器 input_UltraSonic = dry_input_sensor.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() # 感測器_乾燥桶_SHT11 tank_SHT11 = dry_tank_SHT11.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() # 感測器_乾燥桶_土壤三合一 tank_Soil = dry_tank_Soil.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() # 感測器_乾燥桶_氣壓 tank_PA = dry_tank_PA.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() # 感測器_乾燥桶_超音波感測器 tank_UltraSonic = dry_tank_UltraSonic.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() # 感測器_出料儲豆槽_超音波感測器 output_UltraSonic = dry_output_sensor.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() tank_brake = dry_tank_brake.query.filter_by(tank_num='D1').order_by(text('datetime desc')).first() tank_vacuum = 'ON' if tank_brake.vacuum == 1 else 'OFF' tank_threewayvalve = 'ON' if tank_brake.threewayvalve == 1 else 'OFF' tank_diskvalve = 'ON' if tank_brake.diskvalve == 1 else 'OFF' tank_solenoid_disinfect = 'ON' if tank_brake.solenoid_disinfect == 1 else 'OFF' tank_solenoid_water = 'ON' if tank_brake.solenoid_water == 1 else 'OFF' tank_motor = tank_brake.motor tank_blower = 'ON' if tank_brake.blower == 1 else 'OFF' tank_heater1 = 'ON' if tank_brake.heater1 == 1 else 'OFF' tank_heater2 = 'ON' if tank_brake.heater2 == 1 else 'OFF' tank_temp1_enable = 'ON' if tank_brake.temp1_enable == 1 else 'OFF' tank_temp1 = tank_brake.temp1 ''' return render_template('dry.html', **locals()) @main.route('/clean_container/', methods=['GET', 'POST']) def clean_container(tid): if request.method == 'GET': # 制動器_入料儲豆槽_真空吸料機 input_vacuum = clean_input_actuator.query.filter_by(tank_num='C'+str(tid)).order_by(text('datetime desc')).first() input_vacuum = 'ON' if (input_vacuum.vacuum == 1) else 'OFF' # 制動器_浮選清洗_ALL tank_actuator = clean_tank_actuator.query.filter_by(tank_num='C'+str(tid)).order_by(text('datetime desc')).first() tank_vacuum = 'ON' if tank_actuator.vacuum == 1 else 'OFF' tank_pump_waterFloat = 'ON' if tank_actuator.pump_waterFloat == 1 else 'OFF' tank_pump_waterL2 = 'ON' if tank_actuator.pump_waterL2 == 1 else 'OFF' tank_pump_waterL4 = 'ON' if tank_actuator.pump_waterL4 == 1 else 'OFF' tank_solenoid_waterL3 = 'ON' if tank_actuator.solenoid_waterL3 == 1 else 'OFF' tank_solenoid_waterL5 = 'ON' if tank_actuator.solenoid_waterL5 == 1 else 'OFF' tank_stepping_motor = tank_actuator.stepping_motor # 制動器_出料儲豆槽_真空吸料機 output_vacuum = clean_output_actuator.query.filter_by(tank_num='C'+str(tid)).order_by(text('datetime desc')).first() output_vacuum = 'ON' if (output_vacuum.vacuum == 1) else 'OFF' # 感測器_浮選清洗_超音波感測器 tank_UltraSonic = clean_tank_UltraSonic.query.filter_by(tank_num='C'+str(tid)).order_by(text('datetime desc')).first() return render_template('clean_container.html', title='clean_container', **locals()) elif request.method == 'POST': pass @main.route('/ferment_container/', methods=['GET', 'POST']) def ferment_container(tid): if request.method == 'GET': # 制動器_入料儲豆槽_真空吸料機 input_vacuum = ferment_input_actuator.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() #　print('input_vacuum.vacuum:', input_vacuum.vacuum) input_vacuum = 'ON' if (input_vacuum.vacuum == 1) else 'OFF' # print('input_vacuum:', input_vacuum) # 制動器_發酵槽_ALL tank_actuator = ferment_tank_actuator.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() tank_vacuum = 'ON' if tank_actuator.vacuum == 1 else 'OFF' tank_threewayvalve_input = 'ON' if tank_actuator.threewayvalve_input == 1 else 'OFF' tank_diskvalve = 'ON' if tank_actuator.diskvalve == 1 else 'OFF' tank_solenoid_water_total = 'ON' if tank_actuator.solenoid_tank_water_total == 1 else 'OFF' tank_solenoid_disinfect = 'ON' if tank_actuator.solenoid_tank_disinfect == 1 else 'OFF' outer_solenoid_water = 'ON' if tank_actuator.solenoid_outer_water == 1 else 'OFF' tank_solenoid_water_in = 'ON' if tank_actuator.solenoid_tank_water_in == 1 else 'OFF' tank_pump_sensor = 'ON' if tank_actuator.pump_sensor == 1 else 'OFF' tank_threewayvalve_bean = 'ON' if tank_actuator.threewayvalve_bean == 1 else 'OFF' outer_threewayvalve_float = 'ON' if tank_actuator.threewayvalve_outer_float == 1 else 'OFF' tank_motor = tank_actuator.motor tank_heater1 = 'ON' if tank_actuator.heater1 == 1 else 'OFF' tank_heater2 = 'ON' if tank_actuator.heater2 == 1 else 'OFF' tank_temp_enable = 'ON' if tank_actuator.temp_enable == 1 else 'OFF' tank_temp = tank_actuator.temp # 制動器_出料儲豆槽_真空吸引機 output_vacuum = ferment_output_actuator.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() #print('output_vacuum.vacuum: ', output_vacuum.vacuum) output_vacuum = 'ON' if (output_vacuum.vacuum == 1) else 'OFF' #print('output_vacuum: ', output_vacuum) # 感測器_入料儲豆槽_超音波感測器 input_UltraSonic = ferment_input_UltraSonic.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() # 感測器_發酵桶_SHT11 tank_SHT11 = ferment_tank_SHT11.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() # 感測器_發酵桶_二氧化碳 tank_CO2 = ferment_tank_CO2.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() # 感測器_發酵桶_酸鹼值 tank_PH = ferment_tank_PH.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() tank_ORP = ferment_tank_ORP.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() tank_DO = ferment_tank_DO.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() tank_EC = ferment_tank_EC.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() # 感測器_發酵桶_氣壓 tank_PA = ferment_tank_PA.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() # 感測器_發酵桶_超音波感測器 tank_UltraSonic = ferment_tank_UltraSonic.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() # 感測器_發酵桶_水位計 tank_WaterLevel = ferment_tank_WaterLevel.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() num_tank_WaterLevel = float(tank_WaterLevel.WaterLevel) # 感測器_出料儲豆槽_超音波感測器 output_UltraSonic = ferment_output_UltraSonic.query.filter_by(tank_num='F'+str(tid)).order_by(text('datetime desc')).first() return render_template('ferment_container.html', title='ferment_container', **locals()) elif request.method == 'POST': pass @main.route('/dry_container_schedule', methods=['GET', 'POST']) def dry_container_schedule(): if request.method == 'GET': if 'id' in session and 'uname' in session: username = session['uname'] # 感測器_入料儲豆槽_超音波感測器 input_UltraSonic = dry_input_sensor.query.order_by(text('datetime desc')).first() # 感測器_乾燥桶_超音波感測器 tank_UltraSonic = dry_tank_UltraSonic.query.order_by(text('datetime desc')).first() return render_template('dry_container_schedule.html', title='dry_container_schedule', **locals()) elif request.method == 'POST': pass @main.route('/dry_container/', methods=['GET', 'POST']) def dry_container(tid): if request.method == 'GET': if 'id' in session and 'uname' in session: username = session['uname'] # Rita 參數 params 是用來取得參數的 locals=() 所有參數 ''' # 開啟本機 coffeetest 資料庫 # mydb = pymysql.connect(host='127.0.0.1', port=3306, user='root', password='g53743001', database='coffeetest', charset='utf8') mydb = pymysql.connect(host='52.69.200.169', port=3306, user='coffee', password='skyeye', database='Coffee', charset='utf8') mycursor = mydb.cursor() ''' # 感測器_入料儲豆槽_超音波感測器 input_UltraSonic = dry_input_sensor.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() # 感測器_乾燥桶_SHT11 tank_SHT11 = dry_tank_SHT11.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() num_SHT11_temp = float(tank_SHT11.SHT11_Temp) # 感測器_乾燥桶_土壤三合一 tank_Soil = dry_tank_Soil.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() num_Soil_temp = float(tank_Soil.soil_Temp) # 感測器_乾燥桶_氣壓 tank_PA = dry_tank_PA.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() # 感測器_乾燥桶_超音波感測器 tank_UltraSonic = dry_tank_UltraSonic.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() # 感測器_出料儲豆槽_超音波感測器 output_UltraSonic = dry_output_sensor.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() # 制動器_入料儲豆槽_真空吸引機 input_vacuum = dry_input_brake.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() # print("input_vacuum:", input_vacuum) input_vacuum = input_vacuum.vacuum #print('input_vacuum:', input_vacuum.vacuum) # 制動器_乾燥桶_ALL tank_brake = dry_tank_brake.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() tank_vacuum = tank_brake.vacuum tank_threewayvalve = tank_brake.threewayvalve tank_diskvalve = tank_brake.diskvalve tank_solenoid_disinfect = tank_brake.solenoid_disinfect tank_solenoid_water = tank_brake.solenoid_water tank_motor = tank_brake.motor tank_blower = tank_brake.blower tank_heater1 = tank_brake.heater1 tank_heater2 = tank_brake.heater2 tank_temp1_enable = tank_brake.temp1_enable tank_temp1 = tank_brake.temp1 ''' tank_vacuum = 'ON' if tank_brake.vacuum == 1 else 'OFF' tank_threewayvalve = 'ON' if tank_brake.threewayvalve == 1 else 'OFF' tank_diskvalve = 'ON' if tank_brake.diskvalve == 1 else 'OFF' tank_solenoid_disinfect = 'ON' if tank_brake.solenoid_disinfect == 1 else 'OFF' tank_solenoid_water = 'ON' if tank_brake.solenoid_water == 1 else 'OFF' tank_motor = tank_brake.motor tank_blower = 'ON' if tank_brake.blower == 1 else 'OFF' tank_heater1 = 'ON' if tank_brake.heater1 == 1 else 'OFF' tank_heater2 = 'ON' if tank_brake.heater2 == 1 else 'OFF' tank_temp1_enable = 'ON' if tank_brake.temp1_enable == 1 else 'OFF' tank_temp1 = tank_brake.temp1 ''' ''' data = mycursor.execute( 'SELECT * FROM dry_tank_brake ORDER BY datetime DESC;') data = mycursor.fetchone() ''' # 制動器_出料儲豆槽_真空吸引機 output_vacuum = dry_output_brake.query.filter_by(tank_num='D'+str(tid)).order_by(text('datetime desc')).first() #print('output_vacuum.vacuum: ', output_vacuum.vacuum) output_vacuum = 'ON' if (output_vacuum.vacuum == 1) else 'OFF' #print('output_vacuum: ', output_vacuum) # 傳 MQTT 給阿超, 阿超讓硬體動作, 將資料儲存到資料庫 input_data = set_dry_input.query.order_by(text('datetime desc')).first() schedule_input_height = input_data.input_height schedule_input_entertime = input_data.input_entertime schedule_input_exittime = input_data.input_exittime schedule_tank_height = input_data.tank_height return render_template('dry_container.html', title='dry_container', **locals()) elif request.method == 'POST': # 表單輸入處 print('/dry_input_setting POST') set = set_dry_input() set.input_height = request.form['schedule_input_height'] set.input_entertime = request.form['schedule_input_entertime'] set.input_exittime = request.form['schedule_input_exittime'] set.tank_height = request.form['schedule_tank_height'] #將數據保存進資料庫 - 註冊 db.session.add(set) # 手動提交，目的是為了獲取提交後的user的id db.session.commit() # 當user成功插入進資料庫之後，程序會自動將所有信息取出來在賦值給user # 完成登入的操作 # setting = Set_dry_input.query.order_by(text('datetime desc')).first() #session['id'] = set.userID #session['uname'] = set.username return redirect('/dry_container') # 登入頁面的訪問路徑 @main.route('/login', methods=['GET', 'POST']) def login_views(): if request.method == 'GET': if 'id' in session and 'uname' in session: return redirect('/') else: return render_template('sign_in.html') else: # 接收前端傳過來的資料 username = request.form['username'] password = request.form['password'] # 使用接收的用戶和密碼到資料庫中查詢 # Rita first() 避免欄位中的 null 值 ??? user = User.query.filter_by( username=username, password=password).first() # 如果用戶存在，將信息保存置session並重定向回首頁，否則重定向回登入頁 if user: resp = redirect('/') # 判斷是否有記住密碼 if 'rem' in request.form: userID = str(user.userID) max_age = 60*60*24*365 # Rita max_age??? resp.set_cookie("username", username, max_age=max_age) resp.set_cookie("userID", userID, max_age=max_age) session['uname'] = user.username session['id'] = user.userID return resp else: errMsg = "Wrong login or password" return render_template('sign_in.html', errMsg=errMsg) # 登入重設密碼的頁面 # Rita reset_pwd1 - Email # Rita reset_pwd2 - New password / Confirm password @main.route('/reset_password', methods=['POST', 'GET']) def reset_password_views(): if request.method == 'GET': if 'mail' in session: del session['mail'] return render_template('reset_pwd1.html') else: # 如果有id在session裡，代表從reset_pwd2過來的 ??????????????? if "mail" in session: new_pwd = request.form['new_pwd'] confirm_pwd = request.form['confirm_pwd'] # 判斷密碼是否一致 if new_pwd == confirm_pwd: mail = session['mail'] user = User.query.filter_by(mail=mail).first() user.password = new_pwd db.session.add(user) del session['mail'] # 修改完後回登入頁 return redirect('/login') else: errMsg = "Passwords does not match" # Rita 前面的 errMsg 是指網頁上的 {{errMsg}} 位置 return render_template('reset_pwd2.html', errMsg=errMsg) email = request.form['email'] user = User.query.filter_by(mail=email).first() if user: # Rita 有找到對應 email session['mail'] = user.mail return render_template('reset_pwd2.html') else: errMsg = "Wrong email.Please try again" return render_template('reset_pwd1.html', errMsg=errMsg) # 註冊頁面的訪問路徑 @main.route('/register', methods=['POST', "GET"]) def register_views(): if request.method == 'GET': return render_template('registration.html') else: # 獲取文本框的值並賦值給user實體對象 user = User() user.firstname = request.form['firstname'] user.lastname = request.form['lastname'] user.mail = request.form['email'] user.phone = request.form['phone'] user.username = request.form['username'] user.password = request.form['password'] user.status = 1 # Rita app\models.py 設定 0:admin;1:new;9:disable #將數據保存進資料庫 - 註冊 db.session.add(user) # 手動提交，目的是為了獲取提交後的user的id db.session.commit() # 當user成功插入進資料庫之後，程序會自動將所有信息取出來在賦值給user # 完成登入的操作 user = User.query.filter_by(username=user.username).first() session['id'] = user.userID session['uname'] = user.username return redirect('/') # 驗證email訪問路徑 @main.route('/check_email') def check_email_views(): email = request.args['email'] user = User.query.filter_by(mail=email).first() if user: # Rita email 錯誤時會顯示 Incorrect email address result = {"errMsg": " "} else: result = {"pass": " "} return json.dumps(result) # ??? 輸出 result 意義??? # 驗證username訪問路徑 @main.route('/check_username') def check_username_views(): username = request.args['username'] user = User.query.filter_by(username=username).first() if user: result = {"errMsg": " "} else: result = {"pass": " "} return json.dumps(result) # 咖啡貨櫃的訪問路徑 @main.route('/cargo_list', methods=['GET', 'POST']) def cargo_list_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo_list.html', params=locals()) else: pass # 貨櫃1的訪問路徑 @main.route('/cargo1', methods=['GET', 'POST']) def cargo1_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo1.html', params=locals()) else: pass # 貨櫃1排程的訪問路徑 @main.route('/cargo1_schedule', methods=['GET', 'POST']) def cargo1_schedule_views(): username = session['uname'] if request.method == 'GET': # 將已儲存的排程資料傳給前端 # 進豆閥 try: bean = BeanValve.query.order_by(text('datetime desc')).first() datetime = bean.datetime beans = BeanValve.query.filter_by( datetime=datetime).all() except Exception as e: pass # 清洗機 try: wash = WashMachine.query.order_by(text('datetime desc')).first() datetime = wash.datetime washes = WashMachine.query.filter_by(datetime=datetime).all() except Exception as e: pass # 輸送帶1 try: belt1 = ConveyorBelt1.query.order_by(text('datetime desc')).first() datetime = belt1.datetime belts1 = ConveyorBelt1.query.filter_by(datetime=datetime).all() except Exception as e: pass # /////////////////////////////////////////////////////////////////////////////////////////// # 消毒機 try: disinfect = Cargo1Disinfect.query.order_by( text('datetime desc')).first() datetime = disinfect.datetime disinfects = Cargo1Disinfect.query.filter_by( datetime=datetime).all() except Exception as e: pass # 色選機 try: color = ColorMachine.query.order_by(text('datetime desc')).first() datetime = color.datetime colors = ColorMachine.query.filter_by(datetime=datetime).all() except Exception as e: pass # 輸送帶2 try: belt2 = ConveyorBelt2.query.order_by(text('datetime desc')).first() datetime = belt2.datetime belts2 = ConveyorBelt2.query.filter_by(datetime=datetime).all() except Exception as e: pass # 去皮機 try: peeling = PeelingMachine.query.order_by( text('datetime desc')).first() datetime = peeling.datetime peelings = PeelingMachine.query.filter_by(datetime=datetime).all() except Exception as e: pass # 輸送帶3 try: belt3 = ConveyorBelt3.query.order_by(text('datetime desc')).first() datetime = belt3.datetime belts3 = ConveyorBelt3.query.filter_by(datetime=datetime).all() except Exception as e: pass return render_template('cargo1_schedule.html', params=locals()) else: current_time = dt.now() # 循環從前端提交過來的資料 for i in request.form: # 進豆閥 if i[:10] == 'inletValve': if i[:19] == 'inletValve_duration': bean = BeanValve() bean.duration = request.form[i] elif i[:18] == 'inletValve_from_hr': iv_from_hr = request.form[i] elif i[:19] == 'inletValve_from_min': iv_from_min = request.form[i] bean.start = iv_from_hr + ":" + iv_from_min elif i[:16] == 'inletValve_to_hr': iv_to_hr = request.form[i] elif i[:17] == 'inletValve_to_min': iv_to_min = request.form[i] bean.end = iv_to_hr + ":" + iv_to_min bean.datetime = current_time db.session.add(bean) db.session.commit() # 清洗機 elif i[:4] == 'wash': if i[:13] == 'wash_duration': wash = WashMachine() wash.duration = request.form[i] elif i[:12] == 'wash_from_hr': wash_from_hr = request.form[i] elif i[:13] == 'wash_from_min': wash_from_min = request.form[i] wash.start = wash_from_hr + ":" + wash_from_min elif i[:10] == 'wash_to_hr': wash_to_hr = request.form[i] elif i[:11] == 'wash_to_min': wash_to_min = request.form[i] wash.end = wash_to_hr + ":" + wash_to_min wash.datetime = current_time db.session.add(wash) db.session.commit() # 輸送帶1 elif i[:5] == 'belt1': if i[:14] == 'belt1_duration': belt1 = ConveyorBelt1() belt1.duration = request.form[i] elif i[:13] == 'belt1_from_hr': belt1_from_hr = request.form[i] elif i[:14] == 'belt1_from_min': belt1_from_min = request.form[i] belt1.start = belt1_from_hr + ":" + belt1_from_min elif i[:11] == 'belt1_to_hr': belt1_to_hr = request.form[i] elif i[:12] == 'belt1_to_min': belt1_to_min = request.form[i] belt1.end = belt1_to_hr + ":" + belt1_to_min belt1.datetime = current_time db.session.add(belt1) db.session.commit() # 消毒 elif i[:9] == 'disinfect': if i[:18] == 'disinfect_duration': disinfect = Cargo1Disinfect() disinfect.duration = request.form[i] elif i[:17] == 'disinfect_from_hr': di_from_hr = request.form[i] elif i[:18] == 'disinfect_from_min': di_from_min = request.form[i] disinfect.start = di_from_hr + ":" + di_from_min elif i[:15] == 'disinfect_to_hr': di_to_hr = request.form[i] elif i[:16] == 'disinfect_to_min': di_to_min = request.form[i] disinfect.end = di_to_hr + ":" + di_to_min disinfect.datetime = current_time db.session.add(disinfect) db.session.commit() # 色選機 elif i[:5] == 'color': if i[:14] == 'color_duration': color = ColorMachine() color.duration = request.form[i] elif i[:13] == 'color_from_hr': color_from_hr = request.form[i] elif i[:14] == 'color_from_min': color_from_min = request.form[i] color.start = color_from_hr + ":" + color_from_min elif i[:11] == 'color_to_hr': color_to_hr = request.form[i] elif i[:12] == 'color_to_min': color_to_min = request.form[i] color.end = color_to_hr + ":" + color_to_min color.datetime = current_time db.session.add(color) db.session.commit() # 輸送帶2 elif i[:5] == 'belt2': if i[:14] == 'belt2_duration': belt2 = ConveyorBelt2() belt2.duration = request.form[i] elif i[:13] == 'belt2_from_hr': belt2_from_hr = request.form[i] elif i[:14] == 'belt2_from_min': belt2_from_min = request.form[i] belt2.start = belt2_from_hr + ":" + belt2_from_min elif i[:11] == 'belt2_to_hr': belt2_to_hr = request.form[i] elif i[:12] == 'belt2_to_min': belt2_to_min = request.form[i] belt2.end = belt2_to_hr + ":" + belt2_to_min belt2.datetime = current_time db.session.add(belt2) db.session.commit() # 去皮機 elif i[:6] == 'peeled': if i[:15] == 'peeled_duration': peeling = PeelingMachine() peeling.duration = request.form[i] elif i[:14] == 'peeled_from_hr': peeled_from_hr = request.form[i] elif i[:15] == 'peeled_from_min': peeled_from_min = request.form[i] peeling.start = peeled_from_hr + ":" + peeled_from_min elif i[:12] == 'peeled_to_hr': peeled_to_hr = request.form[i] elif i[:13] == 'peeled_to_min': peeled_to_min = request.form[i] peeling.end = peeled_to_hr + ":" + peeled_to_min peeling.datetime = current_time db.session.add(peeling) db.session.commit() # 輸送帶3 elif i[:5] == 'belt3': if i[:14] == 'belt3_duration': belt3 = ConveyorBelt3() belt3.duration = request.form[i] elif i[:13] == 'belt3_from_hr': belt3_from_hr = request.form[i] elif i[:14] == 'belt3_from_min': belt3_from_min = request.form[i] belt3.start = belt3_from_hr + ":" + belt3_from_min elif i[:11] == 'belt3_to_hr': belt3_to_hr = request.form[i] elif i[:12] == 'belt3_to_min': belt3_to_min = request.form[i] belt3.end = belt3_to_hr + ":" + belt3_to_min belt3.datetime = current_time db.session.add(belt3) db.session.commit() return render_template('cargo1.html', params=locals()) # 貨櫃2的訪問路徑 @main.route('/cargo2', methods=['GET', 'POST']) def cargo2_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo2.html', params=locals()) else: pass # 貨櫃2排程的發酵槽訪問路徑 @main.route('/cargo2_schedule_tanks', methods=['GET', 'POST']) def cargo2_schedule_tanks_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo2_schedule_tanks.html', params=locals()) else: pass # 貨櫃2排程發酵槽的清單訪問路徑 @main.route('/cargo2_schedule/', methods=['GET', 'POST']) def cargo2_schedule_views(tid): username = session['uname'] if request.method == 'GET': # 將已儲存的排程資料傳給前端 # 打菌 try: bacteria = Bacteria.query.filter_by(tank_num=int( tid)).order_by(text('datetime desc')).first() datetime = bacteria.datetime bacterias = Bacteria.query.filter_by(datetime=datetime).all() except Exception as e: pass # 消毒 try: disinfect = Cargo2Disinfect.query.filter_by( tank_num=int(tid)).order_by(text('datetime desc')).first() datetime = disinfect.datetime disinfects = Cargo2Disinfect.query.filter_by( datetime=datetime).all() except Exception as e: pass # 加熱 try: heating = Heating.query.filter_by(tank_num=int( tid)).order_by(text('datetime desc')).first() datetime = heating.datetime heatings = Heating.query.filter_by(datetime=datetime).all() except Exception as e: pass # 攪拌 try: stir = Stir.query.filter_by(tank_num=int(tid)).order_by( text('datetime desc')).first() datetime = stir.datetime stirs = Stir.query.filter_by(datetime=datetime).all() except Exception as e: pass # 注水 try: water = WaterInjection.query.filter_by( tank_num=int(tid)).order_by(text('datetime desc')).first() datetime = water.datetime waters = WaterInjection.query.filter_by(datetime=datetime).all() except Exception as e: pass # 開上閥 try: top = TopValve.query.filter_by(tank_num=int( tid)).order_by(text('datetime desc')).first() datetime = top.datetime tops = TopValve.query.filter_by(datetime=datetime).all() except Exception as e: pass # 開下閥 try: bottom = BottomValve.query.filter_by(tank_num=int( tid)).order_by(text('datetime desc')).first() datetime = bottom.datetime bottoms = BottomValve.query.filter_by(datetime=datetime).all() except Exception as e: pass # 溫度 try: tem = Temperature.query.filter_by(tank_num=int( tid)).order_by(text('datetime desc')).first() datetime = tem.datetime tems = Temperature.query.filter_by(datetime=datetime).all() except Exception as e: pass return render_template('cargo2_schedule.html', params=locals()) else: current_time = dt.now() # 循環從前端提交過來的資料 for i in request.form: # 打菌 if i[:8] == 'bacteria': if i[:17] == 'bacteria_duration': bacteria = Bacteria() bacteria.duration = request.form[i] elif i[:16] == 'bacteria_from_hr': bac_from_hr = request.form[i] elif i[:17] == 'bacteria_from_min': bac_from_min = request.form[i] bacteria.start = bac_from_hr + ":" + bac_from_min elif i[:14] == 'bacteria_to_hr': bac_to_hr = request.form[i] elif i[:15] == 'bacteria_to_min': bac_to_min = request.form[i] bacteria.end = bac_to_hr + ":" + bac_to_min bacteria.datetime = current_time bacteria.tank_num = int(tid) db.session.add(bacteria) db.session.commit() # 消毒 elif i[:9] == 'disinfect': if i[:18] == 'disinfect_duration': disinfect = Cargo2Disinfect() disinfect.duration = request.form[i] elif i[:17] == 'disinfect_from_hr': di_from_hr = request.form[i] elif i[:18] == 'disinfect_from_min': di_from_min = request.form[i] disinfect.start = di_from_hr + ":" + di_from_min elif i[:15] == 'disinfect_to_hr': di_to_hr = request.form[i] elif i[:16] == 'disinfect_to_min': di_to_min = request.form[i] disinfect.end = di_to_hr + ":" + di_to_min disinfect.datetime = current_time disinfect.tank_num = int(tid) db.session.add(disinfect) db.session.commit() # 加熱 elif i[:7] == 'heating': if i[:16] == 'heating_duration': heating = Heating() heating.duration = request.form[i] elif i[:15] == 'heating_from_hr': heat_from_hr = request.form[i] elif i[:16] == 'heating_from_min': heat_from_min = request.form[i] heating.start = heat_from_hr + ":" + heat_from_min elif i[:13] == 'heating_to_hr': heat_to_hr = request.form[i] elif i[:14] == 'heating_to_min': heat_to_min = request.form[i] heating.end = heat_to_hr + ":" + heat_to_min heating.datetime = current_time heating.tank_num = int(tid) db.session.add(heating) db.session.commit() # 攪拌 elif i[:4] == 'stir': if i[:13] == 'stir_duration': stir = Stir() stir.duration = request.form[i] elif i[:12] == 'stir_from_hr': stir_from_hr = request.form[i] elif i[:13] == 'stir_from_min': stir_from_min = request.form[i] stir.start = stir_from_hr + ":" + stir_from_min elif i[:10] == 'stir_to_hr': stir_to_hr = request.form[i] elif i[:11] == 'stir_to_min': stir_to_min = request.form[i] stir.end = stir_to_hr + ":" + stir_to_min stir.datetime = current_time stir.tank_num = int(tid) db.session.add(stir) db.session.commit() # 注水 elif i[:5] == 'water': if i[:14] == 'water_duration': water = WaterInjection() water.duration = request.form[i] elif i[:13] == 'water_from_hr': water_from_hr = request.form[i] elif i[:14] == 'water_from_min': water_from_min = request.form[i] water.start = water_from_hr + ":" + water_from_min elif i[:11] == 'water_to_hr': water_to_hr = request.form[i] elif i[:12] == 'water_to_min': water_to_min = request.form[i] water.end = water_to_hr + ":" + water_to_min water.datetime = current_time water.tank_num = int(tid) db.session.add(water) db.session.commit() # 開上閥 elif i[:9] == 'highValve': if i[:18] == 'highValve_duration': top = TopValve() top.duration = request.form[i] elif i[:17] == 'highValve_from_hr': h_valve_from_hr = request.form[i] elif i[:18] == 'highValve_from_min': h_valve_from_min = request.form[i] top.start = h_valve_from_hr + ":" + h_valve_from_min elif i[:15] == 'highValve_to_hr': h_valve_to_hr = request.form[i] elif i[:16] == 'highValve_to_min': h_valve_to_min = request.form[i] top.end = h_valve_to_hr + ":" + h_valve_to_min top.datetime = current_time top.tank_num = int(tid) db.session.add(top) db.session.commit() # 開下閥 elif i[:8] == 'lowValve': if i[:17] == 'lowValve_duration': bottom = BottomValve() bottom.duration = request.form[i] elif i[:16] == 'lowValve_from_hr': l_valve_from_hr = request.form[i] elif i[:17] == 'lowValve_from_min': l_valve_from_min = request.form[i] bottom.start = l_valve_from_hr + ":" + l_valve_from_min elif i[:14] == 'lowValve_to_hr': l_valve_to_hr = request.form[i] elif i[:15] == 'lowValve_to_min': l_valve_to_min = request.form[i] bottom.end = l_valve_to_hr + ":" + l_valve_to_min bottom.datetime = current_time bottom.tank_num = int(tid) db.session.add(bottom) db.session.commit() # 溫度 elif i[:3] == 'tem': if i[:12] == 'tem_duration': tem = Temperature() tem.duration = request.form[i] elif i[:11] == 'tem_from_hr': tem_from_hr = request.form[i] elif i[:12] == 'tem_from_min': tem_from_min = request.form[i] tem.start = tem_from_hr + ":" + tem_from_min elif i[:9] == 'tem_to_hr': tem_to_hr = request.form[i] elif i[:10] == 'tem_to_min': tem_to_min = request.form[i] tem.end = tem_to_hr + ":" + tem_to_min tem.datetime = current_time tem.tank_num = int(tid) db.session.add(tem) db.session.commit() return render_template('cargo2.html', params=locals()) # 貨櫃2感測器的發酵槽訪問路徑 @main.route('/cargo2_sensor_tanks', methods=['GET', 'POST']) def cargo2_sensor_tanks_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo2_sensor_tanks.html', params=locals()) else: pass # 貨櫃2感測器發酵槽的清單訪問路徑 @main.route('/cargo2_sensor/', methods=['GET', 'POST']) def s_tank_views(tid): # 判斷用戶是否已關閉瀏覽器或登出後，在訪問這個route，如果沒有session就回登入頁 try: username = session['uname'] except KeyError: return redirect('/') if request.method == 'GET': # Rita 網頁端 params.tank_tem.tem # Coffee/CoffeeProject/app/templates/cargo2_sensor.html tank_tem = TankTemSensor.query.filter_by(tank_num=int(tid)).order_by(text('datetime desc')).first() tank_ph = TankPHSensor.query.filter_by(tank_num=int(tid)).order_by(text('datetime desc')).first() tank_ec = TankECSensor.query.filter_by(tank_num=int(tid)).order_by(text('datetime desc')).first() tank_sonic = TankSonicSensor.query.filter_by(tank_num=int(tid)).order_by(text('datetime desc')).first() return render_template('cargo2_sensor.html', params=locals()) else: pass # 貨櫃2感測器發酵槽歷史數據的訪問路徑 @main.route('/history_data', methods=['GET', 'POST']) def history_data_views(): if request.method == 'GET': # json # tid:tid_D1 # sensor_name:soil_Temp # avg:1 # max:1 # min:1 # time-interval:month # date-start:2021-07-01 # date-end:2021-07-28 info = request.args.to_dict() evt = info['evt'] avg = int(info['avg']) max = int(info['max']) min = int(info['min']) time_interval = info['time-interval'] print(info) # Rita {'evt': '1-溫濕度', 'avg': '1', 'max': '0', 'min': '0', 'time-interval': 'month', # 'date-start': '2021-05-04', 'date-end': '2021-05-18'} {'all': [], 'avg': []} # print(info) # {'evt': '1-溫濕度', 'avg': '1', 'max': '0', 'min': '0', 'time-interval': 'hour', 'date-start': '2021-01-01', 'date-end': '2021-07-27'} # print(D) # {'all': [['2021-Feb-19_16:46:10', '24.4'], ['2021-Feb-19_16:46:20', '24.4'], ['2021-Feb-19_16:46:30', '24.4'], ['2021-Feb-19_16:46:41', '24.4'], ['2021-Feb-19_16:46:50', '24.4'], ['2021-Feb-19_16:47:00', '24.4'], ['2021-Feb-19_16:47:10', '24.4'], ['2021-Feb-19_16:47:20', '24.4'], ['2021-Feb-19_16:47:30', '24.4'], ['2021-Feb-19_16:47:40', '24.5'], ['2021-Feb-19_16:47:50', '24.5'], ['2021-Feb-19_16:48:00', '24.5'], ['2021-Feb-19_16:48:10', '24.5'], ['2021-Feb-19_16:48:20', '24.5'], ['2021-Feb-19_16:48:29', '24.5'], ['2021-Feb-19_16:48:39', '24.5'], ['2021-Feb-19_16:48:50', '24.5'], ['2021-Feb-19_16:49:00', '24.5'], ['2021-Feb-19_16:49:10', '24.5'], ['2021-Feb-19_16:49:19', '24.5'], ['2021-Feb-19_16:49:29', '24.5'], ['2021-Feb-19_16:49:39', '24.5'], ['2021-Feb-19_16:49:49', '24.5'], ['2021-Feb-19_16:49:59', '24.5'], ['2021-Feb-19_16:50:10', '24.5'], ['2021-Feb-19_16:50:19', '24.5'], ['2021-Feb-19_16:50:29', '24.5'], ['2021-Feb-19_16:50:39', '24.5'], ['2021-Feb-19_16:50:49', '24.5'], ['2021-Feb-19_16:50:59', '24.5'], ['2021-Feb-19_18:07:10', '25.3'], ['2021-Feb-19_18:07:20', '25.3'], ['2021-Feb-19_18:07:30', '25.3'], ['2021-Feb-19_18:07:40', '25.3'], ['2021-Feb-19_18:07:49', '25.3'], ['2021-Feb-19_18:07:59', '25.3'], ['2021-Feb-19_18:08:10', '25.3'], ['2021-Feb-19_18:08:20', '25.3'], ['2021-Feb-19_18:08:30', '25.2'], ['2021-Feb-19_18:08:39', '25.2'], ['2021-Feb-19_18:08:49', '25.2']], # 'avg': [['2021-02-19 16:00:00', '24.5'], ['2021-02-19 18:00:00', '25.3']]} # 192.168.50.65 - - [27/Jul/2021 11:57:23] "GET /history_data?evt=1-溫濕度&avg=1&max=0&min=0&time-interval=hour&date-start=2021-01-01&date-end=2021-07-27 HTTP/1.1" 200 - date_start = info['date-start'] date_end_list = info['date-end'].split('-') # 先把 'date-end' 的 '2021-05-18' 拆成 ['2021', '05', '18'] date_end_list[2] = str(int(date_end_list[2]) + 1) # 18 + 1 = 19 再轉成 str → '19' date_end = '-'.join(date_end_list) # '2021-05-19' tank_num = evt.split('-')[0] # 1 sensor = evt.split('-')[1] # 溫濕度 L = [] D = {} maxData = [] minData = [] avgData = [] def sensorData(data_name): # data_name = "tem" def dataResample(time_interval, how, data_name): # dataResample('month', how???, "tem") # 下方 "hour" interval = 0 # 設置resample的第一個參數，要按照逐月、逐日或逐時 if time_interval == 'month': interval = "M" # interval = "M" elif time_interval == 'day': interval = "D" elif time_interval == 'hour': interval = "H" if how == "max": # data = df.resample(interval, how={data_name:how}) # 最新版的pandas data = df.resample(interval).max() # 取樣頻率 'H' # 刪除有 NaN 的列, any 任何一欄位為空則刪 (all 全部欄位為空值才刪) data = data.dropna(axis=0, how='any') if time_interval == ('hour' or 'day'): data.index = pd.to_datetime( data.index, format='%Y-%b-%d_%H:%M:%S') # 将数据类型转换为日期类型 for a in range(0, len(data.index)): l = [] # 如果是逐時，才顯示小時分秒 if time_interval == 'hour': l.append(str(data.index[a])) else: l.append(str(data.index[a]).split(' ')[0]) l.append(str(data[data_name][a])) maxData.append(l) D['max'] = maxData elif how == "mean": # data = df.resample(interval, how={data_name:how}) # 最新版的pandas data = df.resample(interval).mean() # 刪除具有NaN的值 data = data.dropna(axis=0, how='any') # 將平均數取自小數1位 data = data.round({data_name: 1}) for a in range(0, len(data.index)): l = [] # 如果是逐時，才顯示小時分秒 if time_interval == 'hour': l.append(str(data.index[a])) else: l.append(str(data.index[a]).split(' ')[0]) l.append(str(data[data_name][a])) avgData.append(l) D['avg'] = avgData elif how == "min": # data = df.resample(interval, how={data_name:how}) # 最新版的pandas data = df.resample(interval).min() # 刪除具有NaN的值 data = data.dropna(axis=0, how='any') for a in range(0, len(data.index)): # print(data.index[a]) l = [] # 如果是逐時，才顯示小時分秒 if time_interval == 'hour': l.append(str(data.index[a])) else: l.append(str(data.index[a]).split(' ')[0]) l.append(str(data[data_name][a])) minData.append(l) D['min'] = minData df = pd.DataFrame(L, columns=["datetime", data_name]) # 指定欄標籤名稱為 ["datetime", "tem"] df['datetime'] = pd.to_datetime( df['datetime'], format='%Y-%b-%d_%H:%M:%S') # 将数据类型转换为日期类型 # print(df['datetime']) # 0 2021-02-19 16:46:10 # 1 2021-02-19 16:46:20 # 2 2021-02-19 16:46:30 # 3 2021-02-19 16:46:41 df[data_name] = df[data_name].astype(float) df = df.set_index('datetime') # 将datetime设置为index # print(df) # datetime tem # 2021-02-19 16:46:10 24.4 # 2021-02-19 16:46:20 24.4 if time_interval == 'month': if max: dataResample(time_interval, "max", data_name) if avg: dataResample(time_interval, "mean", data_name) if min: dataResample(time_interval, "min", data_name) elif time_interval == 'day': if max: dataResample(time_interval, "max", data_name) if avg: dataResample(time_interval, "mean", data_name) if min: dataResample(time_interval, "min", data_name) elif time_interval == 'hour': if max: dataResample(time_interval, "max", data_name) if avg: dataResample(time_interval, "mean", data_name) if min: dataResample(time_interval, "min", data_name) if sensor == '溫濕度': # tank_tem = TankTemSensor.query.filter_by(tank_num=int(tank_num)).order_by(text('datetime desc')).all() # [7/27 Benson] tank_tem = TankTemSensor.query.filter_by(tank_num=int(tank_num)).filter(TankTemSensor.datetime.between(date_start, date_end)).all() tank_tem = dry_tank_SHT11.query.filter(dry_tank_SHT11.datetime.between(date_start, date_end)).all() # .filter_by(tank_num="D"+tank_num) for tem in tank_tem: l = [] # l = [] time = dt.strftime(tem.datetime, '%Y-%b-%d_%H:%M:%S') # time = '2021-Feb-19_16:46:10' 轉換時間格式 # time = dt.strftime(tem.datetime, '%Y-%m-%d') l.append(time) # l = ['2021-Feb-19_16:46:10'] #l.append(tem.tem) # l = ['2021-Feb-19_16:46:10', '24.4'] l.append(tem.SHT11_Temp) L.append(l) # L = [['2021-Feb-19_16:46:10', '24.4']] # print(L) D['all'] = L # D = {'all': [['2021-Feb-19_16:46:10', '24.4']]} # all 所有符合數據 sensorData("tem") elif sensor == '酸鹼值': tank_ph = TankPHSensor.query.filter_by(tank_num=int(tank_num)).filter( TankPHSensor.datetime.between(date_start, date_end)).all() for ph in tank_ph: l = [] time = dt.strftime(ph.datetime, '%Y-%b-%d_%H:%M:%S') # time = dt.strftime(tem.datetime, '%Y-%m-%d') l.append(time) l.append(ph.ph) L.append(l) # print(L) D['all'] = L sensorData("ph") elif sensor == 'EC值': tank_ec = TankECSensor.query.filter_by(tank_num=int(tank_num)).filter( TankECSensor.datetime.between(date_start, date_end)).all() for ec in tank_ec: l = [] time = dt.strftime(ec.datetime, '%Y-%b-%d_%H:%M:%S') # time = dt.strftime(tem.datetime, '%Y-%m-%d') l.append(time) l.append(ec.ec) L.append(l) # print(L) D['all'] = L sensorData("ec") elif sensor == '超音波': tank_sonic = TankSonicSensor.query.filter_by(tank_num=int(tank_num)).filter( TankSonicSensor.datetime.between(date_start, date_end)).all() for sonic in tank_sonic: l = [] time = dt.strftime(sonic.datetime, '%Y-%b-%d_%H:%M:%S') # time = dt.strftime(tem.datetime, '%Y-%m-%d') l.append(time) l.append(sonic.sonic) L.append(l) # print(L) D['all'] = L sensorData("sonic") print(D) return json.dumps(D) else: pass # 貨櫃2制動器的發酵槽訪問路徑 @main.route('/cargo2_actuator_tanks', methods=['GET', 'POST']) def cargo2_actuator_tanks_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo2_actuator_tanks.html', params=locals()) else: pass # 貨櫃2制動器發酵槽的清單訪問路徑 @main.route('/cargo2_actuator/', methods=['GET', 'POST']) def cargo2_actuator_views(tid): username = session['uname'] if request.method == 'GET': return render_template('cargo2_actuator.html', params=locals()) else: pass # 貨櫃3的訪問路徑 @main.route('/cargo3', methods=['GET', 'POST']) def cargo3_views(): username = session['uname'] if request.method == 'GET': return render_template('cargo3.html', params=locals()) else: pass # 貨櫃3排程的訪問路徑 @main.route('/cargo3_schedule', methods=['GET', 'POST']) def cargo3_schedule_views(): username = session['uname'] if request.method == 'GET': # 將已儲存的排程資料傳給前端 # 提升機 try: hoist = Hoist.query.order_by(text('datetime desc')).first() datetime = hoist.datetime hoists = Hoist.query.filter_by(datetime=datetime).all() except Exception as e: pass # 烘乾機 try: dryer = Dryer.query.order_by(text('datetime desc')).first() datetime = dryer.datetime dryers = Dryer.query.filter_by(datetime=datetime).all() except Exception as e: pass return render_template('cargo3_schedule.html', params=locals()) else: # Rita： "POST /b_cargo3 HTTP/1.1" 404 - current_time = dt.now() # 循環從前端提交過來的資料 for i in request.form: print('Rita test i :', i) # 堤升機 if i[:5] == 'hoist': if i[:14] == 'hoist_duration': hoist = Hoist() hoist.duration = request.form[i] elif i[:13] == 'hoist_from_hr': ho_from_hr = request.form[i] elif i[:14] == 'hoist_from_min': ho_from_min = request.form[i] hoist.start = ho_from_hr + ":" + ho_from_min elif i[:11] == 'hoist_to_hr': ho_to_hr = request.form[i] elif i[:12] == 'hoist_to_min': ho_to_min = request.form[i] hoist.end = ho_to_hr + ":" + ho_to_min hoist.datetime = current_time db.session.add(hoist) db.session.commit() # 烘乾機 elif i[:5] == 'dryer': if i[:14] == 'dryer_duration': dryer = Dryer() dryer.duration = request.form[i] elif i[:13] == 'dryer_from_hr': dry_from_hr = request.form[i] elif i[:14] == 'dryer_from_min': dry_from_min = request.form[i] dryer.start = dry_from_hr + ":" + dry_from_min elif i[:11] == 'dryer_to_hr': dry_to_hr = request.form[i] elif i[:12] == 'dryer_to_min': dry_to_min = request.form[i] dryer.end = dry_to_hr + ":" + dry_to_min dryer.datetime = current_time db.session.add(dryer) db.session.commit() return render_template('cargo3.html', params=locals()) # 影像串流的訪問路徑 @main.route('/video', methods=['GET', 'POST']) def video_views(): username = session['uname'] if request.method == 'GET': return render_template('video.html', params=locals()) else: pass # 影像的訪問路徑 @main.route('/learn', methods=['GET', 'POST']) def learn_views(): username = session['uname'] if request.method == 'GET': return render_template('learn.html', params=locals()) else: pass # 獲取relay狀態路徑 @main.route('/relay', methods=['GET', 'POST']) def relay_views(): if request.method == 'GET': relay = Relay.query.order_by(text('datetime desc')).first() relay_status = relay.status return jsonify({"relay": relay_status}) else: pass # 獲取脫皮機狀態路徑 @main.route('/peeling', methods=['GET', 'POST']) def peeling_views(): if request.method == 'GET': peeling = PeelingMachineRPM.query.order_by( text('datetime desc')).first() peeling_rpm = peeling.rpm return jsonify({"peeling": peeling_rpm}) else: pass # 退出的訪問路徑 @main.route('/logout') def logout_views(): if 'id' in session and 'uname' in session: del session['id'] del session['uname'] return redirect('/') @main.route("/udp_client", methods=['POST', 'GET']) def udp_views(): # sl(0.5) global c_sock if request.method == 'GET': # def close(): # global c_sock # sl(600) # c_sock.close() # c_sock = 0 # print("c_sock is closing") max_length = 65000 # max_length = 95000 # lab1的IP host = "192.168.50.65" # lab2的IP # host = "192.168.51.160" port = 8000 c_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) # t = threading.Thread(target=close) # t.daemon = True # t.start() print("test") # dict = request.args.to_dict() # nr = int(dict['nr']) # if nr == 1: # camara = 0 # elif nr == 2: # camara = 'rtsp://admin:admin@192.168.50.182/av2_0' # elif nr == 3: # camara = 'rtsp://admin:abcd1234@192.168.51.101/av2_0' # 地下室小兵 # cap = cv2.VideoCapture('rtsp://admin:abcd1234@192.168.51.48/av2_0') # 主機攝像頭 # cap = cv2.VideoCapture(0) # 外面小兵 # cap = cv2.VideoCapture('rtsp://admin:admin@192.168.50.182/av2_0') cap = cv2.VideoCapture('rtsp://192.168.50.182/av0_0') # cap = cv2.VideoCapture(0) # cap = cv2.VideoCapture(camara) ret, frame = cap.read() while ret: # compress frame frame = cv2.resize(frame, (550, 400), interpolation=cv2.INTER_AREA) retval, buffer = cv2.imencode(".jpg", frame) if retval: # convert to byte array buffer = buffer.tobytes() # get size of the frame buffer_size = len(buffer) num_of_packs = 1 if buffer_size > max_length: num_of_packs = math.ceil(buffer_size / max_length) frame_info = {"packs": num_of_packs} # send the number of packs to be expected # print("Number of packs:", num_of_packs) c_sock.sendto(pickle.dumps(frame_info), (host, port)) left = 0 right = max_length for i in range(num_of_packs): # print("left:", left) # print("right:", right) # truncate data to send data = buffer[left:right] left = right right += max_length # send the frames accordingly c_sock.sendto(data, (host, port)) ret, frame = cap.read() print("done") return "done" else: c_sock.shutdown(2) c_sock.close() c_sock = 0 print("c_sock is closing") # 影像串流的路徑 @main.route("/video_feed", methods=['POST', 'GET']) def video_feed_views(): print("test2") global s_sock if request.method == 'GET': # 於10分鐘之後，自動關閉socket server # if s_sock == 0: # def socket_server_views(): # global s_sock # print("test") # print(s_sock) # sl(600) # if s_sock != 0: # s_sock.close() # s_sock = 0 # print('s_sock is closed') # # pool.submit(socket_server_views) host = "192.168.50.65" port = 8000 max_length = 65540 # max_length = 95540 s_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) s_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) s_sock.bind((host, port)) frame_info = None buffer = None frame = None encodedImage = None print("-> waiting for connection") # 影像生成器函數，將影像以jpg格式傳給前端 def generate(): while True: with lock: global s_sock, frame_info, buffer, frame, encodedImage if s_sock == 0: break data, address = s_sock.recvfrom(max_length) if len(data) < 100: frame_info = pickle.loads(data) if frame_info: nums_of_packs = frame_info["packs"] for i in range(nums_of_packs): if s_sock == 0: break data, address = s_sock.recvfrom(max_length) if i == 0: buffer = data else: buffer += data frame = np.frombuffer(buffer, dtype=np.uint8) frame = frame.reshape(frame.shape[0], 1) frame = cv2.imdecode(frame, cv2.IMREAD_UNCHANGED) # print(frame) # 如果frame為None就跳過 if frame is None: continue frame = cv2.resize( frame, (640, 360), interpolation=cv2.INTER_AREA) # encode the frame in JPEG format (flag, encodedImage) = cv2.imencode(".jpg", frame) # ensure the frame was successfully encoded if not flag: continue # yield the output frame in the byte format yield (b'--frame\r\n' b'Content-Type: image/jpeg\r\n\r\n' + bytearray(encodedImage) + b'\r\n') # return the response generated along with the specific media # type (mime type) return Response(generate(), mimetype="multipart/x-mixed-replace; boundary=frame") else: if s_sock != 0: s_sock.close() s_sock = 0 print('s_sock is closed') return "s_sock is closed" print("test") return "s_sock is closed" D = {"input_vacuum_status": 0, "tank_vacuum_status": 0, "tank_threewayvalve_status": 0, "tank_diskvalve_status": 0, "tank_solenoid_disinfect_status": 0, "tank_solenoid_water_status": 0, "tank_motor_status": 'none', "tank_blower_status": 0, "tank_heater1_status": 0, "tank_heater2_status": 0, "temp1_enable": 0, "temp1": 0, "output_vacuum_status": 0, "tank_threewayvalve_input_status":0, "tank_solenoid_water_total_status": 0, "tank_solenoid_disinfect_status": 0, "outer_solenoid_water_status": 0, "tank_solenoid_water_in_status":0, "tank_pump_sensor_status": 0, "tank_threewayvalve_bean_status":0, "outer_threewayvalve_float_status":0, "tank_temp_enable_status":0, "tank_temp_status": 'none', "tank_pump_waterFloat_status": 0, "tank_pump_waterL2_status": 0, "tank_pump_waterL4_status": 0, "tank_solenoid_waterL3_status": 0, "tank_solenoid_waterL5_status": 0, "tank_stepping_motor_status": 'none', } pub_topic = 'AISKY/Coffee/MK-G/b8:27:eb:b4:59:3e' # sub_topic = 'AISKY/Coffee/MK-G/b8:27:eb:b4:59:3e/Log' # mqttObj = MQTT('aisky-client', 'aiskyc', '60.250.156.234', 1883, 60, sub_topic) mqttObj = MQTT() # mqtt發布 # @main.route('/mqtt/', methods=['POST']) @main.route('/mqtt/', methods=['POST']) def mqtt_views(tid): import json dict = request.form.to_dict() json = json.dumps(dict) # print('dict:', dict) # dict: {'tank-number': '1', 'command': 'tank_vacuum_status', 'value': 'on'} # print('json:', json) # json: {"tank-number": "1", tank_vacuum_status", "value": "on"} topic = 'AISKY/Coffee/MK-G/b8:27:eb:b4:59:3e' # res = mqttObj.mqttPublish(pub_topic, json) # print(res) # sl(2) # print(mqttObj.res) # # print('test') mqtt.publish(topic, json) # 入料儲豆槽真空吸料機(ON吸料/OFF排氣) if dict['command'] == 'input_vacuum_status': time.sleep(1) # D[input_vacuum_status]: 0 print('D[input_vacuum_status]:', D['input_vacuum_status']) if D['input_vacuum_status'] == 'on': return 'on' elif D['input_vacuum_status'] == 'off': return 'off' else: return "input_vacuum_status signal was not received" # 真空吸料機 elif dict['command'] == 'tank_vacuum_status': time.sleep(1) if D['tank_vacuum_status'] == 'on': return 'on' elif D['tank_vacuum_status'] == 'off': return 'off' else: return "tank_vacuum_status signal was not received" # 三通閥(ON吸料/OFF排氣) elif dict['command'] == 'tank_threewayvalve_status': time.sleep(1) if D['tank_threewayvalve_status'] == 'on': return 'on' elif D['tank_threewayvalve_status'] == 'off': return 'off' else: return "tank_threewayvalve_status signal was not received" # 蝴蝶閥(ON開/OFF關) elif dict['command'] == 'tank_diskvalve_status': time.sleep(1) print("D['tank_diskvalve_status']", D['tank_diskvalve_status']) if D['tank_diskvalve_status'] == 'on': return 'on' elif D['tank_diskvalve_status'] == 'off': return 'off' else: return "tank_diskvalve_status signal was not received" # 電磁閥(ON噴灑消毒/OFF關) elif dict['command'] == 'tank_solenoid_disinfect_status': time.sleep(1) if D['tank_solenoid_disinfect_status'] == 'on': return 'on' elif D['tank_solenoid_disinfect_status'] == 'off': return 'off' else: return "tank_solenoid_disinfect_status signal was not received" # 電磁閥(ON排水/OFF關) elif dict['command'] == 'tank_solenoid_water_status': time.sleep(1) if D['tank_solenoid_water_status'] == 'on': return 'on' elif D['tank_solenoid_water_status'] == 'off': return 'off' else: return "tank_solenoid_water_status signal was not received" # 馬達(單位RPM) elif dict['command'] == 'tank_motor_status': print("D['tank_motor_status']", D['tank_motor_status']) time.sleep(1) if D['tank_motor_status'] == '0': return 'off' elif type(D['tank_motor_status']) == int: return 'on' else: return "tank_motor_status signal was not received" # 鼓風機(ON開/OFF關) elif dict['command'] == 'tank_blower_status': time.sleep(1) if D['tank_blower_status'] == 'on': return 'on' elif D['tank_blower_status'] == 'off': return 'off' else: return "tank_blower_status signal was not received" # 加熱棒 1(ON開/OFF關) elif dict['command'] == 'tank_heater1_status': time.sleep(1) if D['tank_heater1_status'] == 'on': return 'on' elif D['tank_heater1_status'] == 'off': return 'off' else: return "tank_heater1_status signal was not received" # 加熱棒 2(ON開/OFF關) elif dict['command'] == 'tank_heater2_status': time.sleep(1) if D['tank_heater2_status'] == 'on': return 'on' elif D['tank_heater2_status'] == 'off': return 'off' else: return "tank_heater2_status signal was not received" # 溫度控制(ON開/OFF關) elif dict['command'] == 'temp1_enable': time.sleep(1) if D['temp1_enable'] == 'on': return 'on' elif D['temp1_enable'] == 'off': return 'off' else: return "temp1_enable_status signal was not received" # 設定溫度 (限整數) elif dict['command'] == 'temp1': time.sleep(1) if D['temp1'] == '0': return 'off' elif type(D['temp1']) == int: return 'on' else: return "temp1 signal was not received" # 出料儲豆槽真空吸料機(ON吸料/OFF排氣) elif dict['command'] == 'output_vacuum_status': time.sleep(1) if D['output_vacuum_status'] == 'on': return 'on' elif D['output_vacuum_status'] == 'off': return 'off' else: return "output_vacuum_status signal was not received" # 發酵槽入料三通閥 elif dict['command'] == 'tank_threewayvalve_input_status': time.sleep(1) if D['tank_threewayvalve_input_status'] == 'on': return 'on' elif D['tank_threewayvalve_input_status'] == 'off': return 'off' else: return "tank_threewayvalve_input_status signal was not received" # 發酵槽總進水 elif dict['command'] == 'tank_solenoid_water_total_status': time.sleep(1) if D['tank_solenoid_water_total_status'] == 'on': return 'on' elif D['tank_solenoid_water_total_status'] == 'off': return 'off' else: return "tank_solenoid_water_total_status signal was not received" # 發酵槽桶內消毒/打菌 elif dict['command'] == 'tank_solenoid_disinfect_status': time.sleep(1) if D['tank_solenoid_disinfect_status'] == 'on': return 'on' elif D['tank_solenoid_disinfect_status'] == 'off': return 'off' else: return "tank_solenoid_disinfect_status signal was not received" # 發酵槽夾層進水 elif dict['command'] == 'outer_solenoid_water_status': time.sleep(1) if D['outer_solenoid_water_status'] == 'on': return 'on' elif D['outer_solenoid_water_status'] == 'off': return 'off' else: return "outer_solenoid_water_status signal was not received" # 發酵槽桶內進水 elif dict['command'] == 'tank_solenoid_water_in_status': time.sleep(1) if D['tank_solenoid_water_in_status'] == 'on': return 'on' elif D['tank_solenoid_water_in_status'] == 'off': return 'off' else: return "tank_solenoid_water_in_status signal was not received" # 發酵槽雙核隔膜泵 elif dict['command'] == 'tank_pump_sensor_status': time.sleep(1) if D['tank_pump_sensor_status'] == 'on': return 'on' elif D['tank_pump_sensor_status'] == 'off': return 'off' else: return "tank_pump_sensor_status signal was not received" # 發酵槽感測器下豆三通閥 elif dict['command'] == 'tank_threewayvalve_bean_status': time.sleep(1) if D['tank_threewayvalve_bean_status'] == 'on': return 'on' elif D['tank_threewayvalve_bean_status'] == 'off': return 'off' else: return "tank_threewayvalve_bean_status signal was not received" # 發酵槽外桶浮選三通閥 elif dict['command'] == 'outer_threewayvalve_float_status': time.sleep(1) if D['outer_threewayvalve_float_status'] == 'on': return 'on' elif D['outer_threewayvalve_float_status'] == 'off': return 'off' else: return "outer_threewayvalve_float_status signal was not received" # 發酵槽溫控開關 elif dict['command'] == 'tank_temp_enable_status': time.sleep(1) if D['tank_temp_enable_status'] == 'on': return 'on' elif D['tank_temp_enable_status'] == 'off': return 'off' else: return "tank_temp_enable_status signal was not received" # 發酵槽設定溫度 elif dict['command'] == 'tank_temp_status': time.sleep(1) if D['tank_temp_status'] == '0': return 'off' elif type(D['tank_temp_status']) == int: return 'on' else: return "tank_temp_status signal was not received" # 清洗浮選槽浮選槽注水 elif dict['command'] == 'tank_pump_waterFloat_status': time.sleep(1) if D['tank_pump_waterFloat_status'] == 'on': return 'on' elif D['tank_pump_waterFloat_status'] == 'off': return 'off' else: return "tank_pump_waterFloat_status signal was not received" # 清洗浮選槽清洗第 2 層灑水 elif dict['command'] == 'tank_pump_waterL2_status': time.sleep(1) if D['tank_pump_waterL2_status'] == 'on': return 'on' elif D['tank_pump_waterL2_status'] == 'off': return 'off' else: return "tank_pump_waterL2_status signal was not received" # 清洗浮選槽清洗第 4 層灑水 elif dict['command'] == 'tank_pump_waterL4_status': time.sleep(1) if D['tank_pump_waterL4_status'] == 'on': return 'on' elif D['tank_pump_waterL4_status'] == 'off': return 'off' else: return "tank_pump_waterL4_status signal was not received" # 清洗浮選槽清洗第 3 層電磁閥 elif dict['command'] == 'tank_solenoid_waterL3_status': time.sleep(1) if D['tank_solenoid_waterL3_status'] == 'on': return 'on' elif D['tank_solenoid_waterL3_status'] == 'off': return 'off' else: return "tank_solenoid_waterL3_status signal was not received" # 清洗浮選槽清洗第 5 層電磁閥 elif dict['command'] == 'tank_solenoid_waterL5_status': time.sleep(1) if D['tank_solenoid_waterL5_status'] == 'on': return 'on' elif D['tank_solenoid_waterL5_status'] == 'off': return 'off' else: return "tank_solenoid_waterL5_status signal was not received" # 清洗浮選槽步進馬達 elif dict['command'] == 'tank_stepping_motor_status': time.sleep(1) if D['tank_stepping_motor_status'] == '0': return 'off' elif type(D['tank_stepping_motor_status']) == int: return 'on' else: return "tank_stepping_motor_status signal was not received" return "publish done" # 處理mqtt訂閱的信息 @mqtt.on_message() def handle_mqtt_message(client, userdata, message): payload = message.payload.decode() payload = json.loads(payload) # print("-------msg-------") # print('name :', p['name']) # print('email :', p['email']) print('payload:', payload) # 入料儲豆槽真空吸料機(ON吸料/OFF排氣) if payload['command'] == 'input_vacuum_status': if payload['response'] == 'on': D['input_vacuum_status'] = 'on' else: D['input_vacuum_status'] = 'off' # 真空吸料機 elif payload['command'] == 'tank_vacuum_status': if payload['response'] == 'on': # print('test') D['tank_vacuum_status'] = 'on' else: D['tank_vacuum_status'] = 'off' # 三通閥(ON吸料/OFF排氣) elif payload['command'] == 'tank_threewayvalve_status': if payload['response'] == 'on': # print('test') D['tank_threewayvalve_status'] = 'on' else: D['tank_threewayvalve_status'] = 'off' # 蝴蝶閥(ON開/OFF關) elif payload['command'] == 'tank_diskvalve_status': if payload['response'] == 'on': # print('test') D['tank_diskvalve_status'] = 'on' else: D['tank_diskvalve_status'] = 'off' # 電磁閥(ON噴灑消毒/OFF關) elif payload['command'] == 'tank_solenoid_disinfect_status': if payload['response'] == 'on': # print('test') D['tank_solenoid_disinfect_status'] = 'on' else: D['tank_solenoid_disinfect_status'] = 'off' # 電磁閥(ON排水/OFF關) elif payload['command'] == 'tank_solenoid_water_status': if payload['response'] == 'on': # print('test') D['tank_solenoid_water_status'] = 'on' else: D['tank_solenoid_water_status'] = 'off' # 馬達(單位RPM) elif payload['command'] == 'tank_motor_status': if payload['response'] == 'off': D['tank_motor_status'] = '0' else: D['tank_motor_status'] = payload['response'] # 鼓風機(ON開/OFF關) elif payload['command'] == 'tank_blower_status': if payload['response'] == 'on': # print('test') D['tank_blower_status'] = 'on' else: D['tank_blower_status'] = 'off' # 加熱棒 1(ON開/OFF關) elif payload['command'] == 'tank_heater1_status': if payload['response'] == 'on': # print('test') D['tank_heater1_status'] = 'on' else: D['tank_heater1_status'] = 'off' # 加熱棒 2(ON開/OFF關) elif payload['command'] == 'tank_heater2_status': if payload['response'] == 'on': # print('test') D['tank_heater2_status'] = 'on' else: D['tank_heater2_status'] = 'off' # 出料儲豆槽真空吸料機(ON吸料/OFF排氣) elif payload['command'] == 'output_vacuum_status': if payload['response'] == 'on': # print('test') D['output_vacuum_status'] = 'on' else: D['output_vacuum_status'] = 'off' # 發酵槽入料三通閥 elif payload['command'] == 'tank_threewayvalve_input_status': if payload['response'] == 'on': # print('test') D['tank_threewayvalve_input_status'] = 'on' else: D['tank_threewayvalve_input_status'] = 'off' # 發酵槽總進水 elif payload['command'] == 'tank_solenoid_water_total_status': if payload['response'] == 'on': D['tank_solenoid_water_total_status'] = 'on' else: D['tank_solenoid_water_total_status'] = 'off' # 發酵槽桶內消毒/打菌 elif payload['command'] == 'tank_solenoid_disinfect_status': if payload['response'] == 'on': D['tank_solenoid_disinfect_status'] = 'on' else: D['tank_solenoid_disinfect_status'] = 'off' # 發酵槽夾層進水 elif payload['command'] == 'outer_solenoid_water_status': if payload['response'] == 'on': D['outer_solenoid_water_status'] = 'on' else: D['outer_solenoid_water_status'] = 'off' # 發酵槽桶內進水 elif payload['command'] == 'tank_solenoid_water_in_status': if payload['response'] == 'on': D['tank_solenoid_water_in_status'] = 'on' else: D['tank_solenoid_water_in_status'] = 'off' # 發酵槽雙核隔膜泵 elif payload['command'] == 'tank_pump_sensor_status': if payload['response'] == 'on': D['tank_pump_sensor_status'] = 'on' else: D['tank_pump_sensor_status'] = 'off' # 發酵槽感測器下豆三通閥 elif payload['command'] == 'tank_threewayvalve_bean_status': if payload['response'] == 'on': D['tank_threewayvalve_bean_status'] = 'on' else: D['tank_threewayvalve_bean_status'] = 'off' # 發酵槽外桶浮選三通閥 elif payload['command'] == 'outer_threewayvalve_float_status': if payload['response'] == 'on': D['outer_threewayvalve_float_status'] = 'on' else: D['outer_threewayvalve_float_status'] = 'off' # 發酵槽溫控開關 elif payload['command'] == 'tank_temp_enable_status': if payload['response'] == 'on': D['tank_temp_enable_status'] = 'on' else: D['tank_temp_enable_status'] = 'off' # 發酵槽設定溫度 elif payload['command'] == 'tank_temp_status': if payload['response'] == 'off': D['tank_temp_status'] = '0' else: D['tank_temp_status'] = payload['response'] # 清洗浮選槽浮選槽注水 elif payload['command'] == 'tank_pump_waterFloat_status': if payload['response'] == 'on': D['tank_temp_status'] = 'on' else: D['tank_temp_status'] = 'off' # 清洗浮選槽清洗第 2 層灑水 elif payload['command'] == 'tank_pump_waterL2_status': if payload['response'] == 'on': D['tank_pump_waterL2_status'] = 'on' else: D['tank_pump_waterL2_status'] = 'off' # 清洗浮選槽清洗第 4 層灑水 elif payload['command'] == 'tank_pump_waterL4_status': if payload['response'] == 'on': D['tank_pump_waterL4_status'] = 'on' else: D['tank_pump_waterL4_status'] = 'off' # 清洗浮選槽清洗第 3 層電磁閥 elif payload['command'] == 'tank_solenoid_waterL3_status': if payload['response'] == 'on': D['tank_solenoid_waterL3_status'] = 'on' else: D['tank_solenoid_waterL3_status'] = 'off' # 清洗浮選槽清洗第 5 層電磁閥 elif payload['command'] == 'tank_solenoid_waterL5_status': if payload['response'] == 'on': D['tank_solenoid_waterL5_status'] = 'on' else: D['tank_solenoid_waterL5_status'] = 'off' # 清洗浮選槽步進馬達 elif payload['command'] == 'tank_stepping_motor_status': if payload['response'] == 'off': D['tank_stepping_motor_status'] = '0' else: D['tank_stepping_motor_status'] = payload['response']