NEW_coffee_project/coffeeproject/app/main/views.py

# 主業務邏輯中的視圖和路由的定義
import os
import datetime
from turtle import title
from flask import Flask, redirect, render_template, request, session, Response, jsonify
from sqlalchemy.sql.expression import desc, false, null
# 導入藍圖程序，用於構建路由
from werkzeug.utils import redirect
from werkzeug.wrappers import response
from . import main
from coffee_manage20221221 import mqtt
# 導入db，用於操作數據庫
from coffee_manage20221221 import db
# 導入實體類，用於操作數據庫
from ..models import *
import json
from datetime import datetime as dt
from datetime import timedelta
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
# from distutils.util import strtobool   # 將字串 string 轉成布林 boolean 

# import psutil
import subprocess
import shutil
import stat

import datetime
import paho.mqtt.publish as publish
import paho.mqtt.client as mqtt_1
import random
import paramiko
from flask_mqtt import Mqtt

pool = ThreadPoolExecutor(25)
s_sock = 0
lock = threading.Lock()


# 主頁的訪問路徑
@main.route('/')
def main_index():
    # # 獲取登入信息
    # if 'id' in session and 'uname' in session and 'status' in session:
    #     username = session['uname']
    #     status = session['status']
    #
    #     if status == 9:
    #         return render_template('signin_disable.html')
    #     elif status == 8:
    #         return render_template('signin_new.html')
    #
    #     # Rita 參數 params 是用來取得參數的 locals=() 所有參數
    #     return render_template('index.html', params=locals())
    # else:
    #     return render_template('sign_in.html')
    return render_template("index.html", title='ERP WEB')


# 發酵槽自動化測試頁
@main.route('/ferment_auto', methods=['GET', 'POST'])
def ferment_auto():

    os.system('python D:\\fatwolf\\company_files\\flask\\coffeeproject\\app\\test_logic.py')


    ferment_status = ferment_container_status.query.order_by(text('datetime desc')).first()
    db.session.close()
    FI1 = ferment_status.Ferment_Input_1
    FI2 = ferment_status.Ferment_Input_2
    F1 = ferment_status.Ferment_Tank_1
    F2 = ferment_status.Ferment_Tank_2
    F3 = ferment_status.Ferment_Tank_3
    F4 = ferment_status.Ferment_Tank_4
    F5 = ferment_status.Ferment_Tank_5
    F6 = ferment_status.Ferment_Tank_6
    F7 = ferment_status.Ferment_Tank_7
    F8 = ferment_status.Ferment_Tank_8
    F9 = ferment_status.Ferment_Tank_9
    F10 = ferment_status.Ferment_Tank_10
    F11 = ferment_status.Ferment_Tank_11
    F12 = ferment_status.Ferment_Tank_12
    FO1 = ferment_status.Ferment_Output_1
    FO2 = ferment_status.Ferment_Output_2

    clean_status = clean_container_status.query.order_by(text('datetime desc')).first()
    db.session.close()
    PO1 = clean_status.Peel_Output_1  # PO_Waiting  # PO_OutputtingBean
    PO2 = clean_status.Peel_Output_2
    dry_status = dry_container_status.query.order_by(text('datetime desc')).first()
    db.session.close()
    DI1 = dry_status.Dry_Input_1
    DI2 = dry_status.Dry_Input_2
    # 發酵桶_入料高度
    input_UltraSonic = ferment_input_UltraSonic.query.filter_by(tank_num='F' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    # UltraSonic = float("{:.2f}".format(34.6 - float(input_UltraSonic.UltraSonic)))
    UltraSonic_input = float(input_UltraSonic.UltraSonic)
    # 感測器_發酵桶_超音波感測器
    tank_UltraSonic = ferment_tank_UltraSonic.query.filter_by(tank_num='F' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    UltraSonic_tank = (float(tank_UltraSonic.UltraSonic))
    # 感測器_發酵桶_SHT11
    tank_SHT11 = ferment_tank_SHT11.query.filter_by(tank_num='F' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    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' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    CO2 = float(tank_CO2.CO2)
    # 感測器_發酵桶_酸鹼值
    tank_PH = ferment_tank_PH.query.filter_by(tank_num='F' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    tank_ORP = ferment_tank_ORP.query.filter_by(tank_num='F' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    tank_DO = ferment_tank_DO.query.filter_by(tank_num='F' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    tank_EC = ferment_tank_EC.query.filter_by(tank_num='F' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    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' + '1').order_by(text('datetime desc')).first()
    db.session.close()
    PA = float(tank_PA.PA)

    # 感測器_發酵桶_保溫夾層水位計
    tank_WaterLevel = ferment_tank_WaterLevel.query.filter_by(tank_num='F' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    WaterLevel = tank_WaterLevel.WaterLevel
    # 發酵桶_出料高度
    output_UltraSonic = ferment_output_UltraSonic.query.filter_by(tank_num='F' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    UltraSonic_output = float(output_UltraSonic.UltraSonic)


    return render_template('ferment_auto.html', title="[測試] 發酵自動化", **locals())
    # else:
    #     return render_template('sign_in.html')


# 乾燥槽自動化測試頁
@main.route('/dry_auto', methods=['GET', 'POST'])
def dry_auto():
    dry_status = dry_container_status.query.order_by(text('datetime desc')).first()
    db.session.close()
    DI1 = dry_status.Dry_Input_1
    DI2 = dry_status.Dry_Input_2
    D1 = dry_status.Dry_Tank_1
    D2 = dry_status.Dry_Tank_2
    D3 = dry_status.Dry_Tank_3
    D4 = dry_status.Dry_Tank_4
    D5 = dry_status.Dry_Tank_5
    D6 = dry_status.Dry_Tank_6
    D7 = dry_status.Dry_Tank_7
    D8 = dry_status.Dry_Tank_8
    D9 = dry_status.Dry_Tank_9
    D10 = dry_status.Dry_Tank_10
    D11 = dry_status.Dry_Tank_11
    D12 = dry_status.Dry_Tank_12
    DO1 = dry_status.Dry_Output_1
    DO2 = dry_status.Dry_Output_2
    #print(DI1,DI2,D1,D2,D3,D4,D5,D6,D7,D8,D9,D10,D11,D12,DO1,DO2)

    input_seneor = dry_input_sensor.query.filter_by(tank_num='D' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    UltraSonic_input = float(input_seneor.UltraSonic)
    # tank_SHT11 = dry_tank_SHT11.query.filter_by(tank_num='D' + '1').order_by(
    #     text('datetime desc')).first()
    # SHT11_Temp = float(tank_SHT11.SHT11_Temp)
    # SHT11_Humidity = float(tank_SHT11.SHT11_Humidity)
    tank_sht11 = dry_tank_sht11.query.filter_by(tank_num='D' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    sht11_Temp = float(tank_sht11.SHT11_Temp)
    sht11_Humidity = float(tank_sht11.SHT11_Humidity)
    tank_Soil = dry_tank_Soil.query.filter_by(tank_num='D' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    Soil_Temp = float(tank_Soil.soil_Temp)
    Soil_Humidity = float(tank_Soil.soil_Humidity)
    Soil_EC = float(tank_Soil.soil_EC)
    # tank_Soil = dry_tank_Soil.query.filter_by(tank_num='D' + '1').order_by(
    #     text('datetime desc')).first()
    # Soil_Temp = float(tank_Soil.Soil_Temp)
    # Soil_Humidity = float(tank_Soil.Soil_Humidity)
    # Soil_EC = float(tank_Soil.Soil_EC)

    tank_PA = dry_tank_PA.query.filter_by(tank_num='D' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    PA = float(tank_PA.PA)
    tank_UltraSonic = dry_tank_UltraSonic.query.filter_by(tank_num='D' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    UltraSonic_tank = float(tank_UltraSonic.UltraSonic)
    output_sensor = dry_output_sensor.query.filter_by(tank_num='D' + '1').order_by(
        text('datetime desc')).first()
    db.session.close()
    UltraSonic_output = float(output_sensor.UltraSonic)
    return render_template('dry_auto.html', title="[測試] 乾燥自動化", **locals())