|
@@ -1,348 +1,349 @@
|
|
|
-#對整個應用做初始化操作
|
|
|
-#主要工作:
|
|
|
-# 1.構建Flask的應用以及各種配置
|
|
|
-#2.構建SQLAlchemy的應用
|
|
|
-
|
|
|
-from flask import Flask, g, request
|
|
|
-from flask_sqlalchemy import SQLAlchemy
|
|
|
-import pymysql
|
|
|
-import eventlet
|
|
|
-from flask_mqtt import Mqtt
|
|
|
-from flask_migrate import Migrate
|
|
|
-#from flask_migrate import Migrate, MigrateCommand
|
|
|
-from flask_babel import Babel
|
|
|
-# from werkzeug.wrappers import Request
|
|
|
-
|
|
|
-
|
|
|
-#綠化(綠色線程)所有系統模組,實現IO多路複用
|
|
|
-# eventlet.monkey_patch()
|
|
|
-
|
|
|
-pymysql.install_as_MySQLdb()
|
|
|
-
|
|
|
-# # db = SQLAlchemy()
|
|
|
-# def register_i18n(app):
|
|
|
-# """Register i18n with the Flask application."""
|
|
|
-# defalut_language_str = app.config['DEFAULT_LANGUAGE']
|
|
|
-# support_language_list = app.config['SUPPORTED_LANGUAGES']
|
|
|
-
|
|
|
-# # 1. 取得子資料夾路徑 land_code
|
|
|
-# @app.url_value_preprocessor
|
|
|
-# def get_lang_code(endpoint, values):
|
|
|
-# if values is not None:
|
|
|
-# g.lang_code = values.pop('lang_code', defalut_language_str)
|
|
|
-
|
|
|
-# # 2. 確認 config 內包含 lang_code
|
|
|
-# @app.before_request
|
|
|
-# def ensure_lang_support():
|
|
|
-# lang_code = g.get('lang_code', None)
|
|
|
-# if lang_code and lang_code not in support_language_list:
|
|
|
-# g.lang_code = request.accept_languages.best_match(support_language_list)
|
|
|
-
|
|
|
-# # 3. 設定多語系
|
|
|
-# @app.localeselector
|
|
|
-# def get_locale():
|
|
|
-# return g.get('lang_code')
|
|
|
-
|
|
|
-# # 4. 確認在 1. pop lang_code 參數後的 lang_code 值
|
|
|
-# @app.url_defaults
|
|
|
-# def set_langrage_code(endpoint, values):
|
|
|
-# if 'lang_code' in values or not g.lang_code:
|
|
|
-# return
|
|
|
-# if app.url_map.is_endpoint_expecting(endpoint, 'lang_code'):
|
|
|
-# values['lang_code'] = g.lang_code
|
|
|
-
|
|
|
-
|
|
|
-def create_app():
|
|
|
- app = Flask(__name__)
|
|
|
- #配置啟動模式為調適模式
|
|
|
- # app.config['DEBUG'] = True
|
|
|
- #配置數據庫的連接字符串
|
|
|
- app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://coffee:skyeye@52.69.200.169:3306/Coffee'
|
|
|
- #配置數據庫內容再更新時自動提交
|
|
|
- app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
|
|
|
- #配置session所需要的秘鑰
|
|
|
- app.config['SECRET_KEY'] = 'you guess'
|
|
|
-
|
|
|
- # template 有修改後,會自動去更新
|
|
|
- app.config['TEMPLATES_AUTO_RELOAD'] = True
|
|
|
-
|
|
|
- #如果设置成True(默认情况),Flask - SQLAlchemy将会追踪对象的修改并且发送信号。这需要额外的内存, 如果不必要的可以禁用它
|
|
|
- app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = True
|
|
|
-
|
|
|
- #資料库连接池的大小。默认是数据库引擎的默认值 (通常是5)
|
|
|
- app.config['SQLALCHEMY_POOL_SIZE'] = 100
|
|
|
-
|
|
|
- #指定資料库连接池的超时时间。默认是 10
|
|
|
- # app.config['SQLALCHEMY_POOL_TIMEOUT'] = 60
|
|
|
- app.config['SQLALCHEMY_POOL_TIMEOUT'] = 60 * 60
|
|
|
-
|
|
|
- #自动回收连接的秒数。这对 MySQL 是必须的,默认 情况下 MySQL 会自动移除闲置 8 小时或者以上的连接。 需要注意地是如果使用 MySQL 的话, Flask-SQLAlchemy 会自动地设置这个值为 2 小时
|
|
|
- app.config['SQLALCHEMY_POOL_RECYCLE'] = 60 * 60 * 8
|
|
|
-
|
|
|
- app.config['SQLALCHEMY_MAX_OVERFLOW'] = 15
|
|
|
-
|
|
|
- # app.config['SECRET'] = 'my secret key'
|
|
|
- #MQTT相關設置
|
|
|
- app.config['MQTT_BROKER_URL'] = '60.250.156.234'
|
|
|
- app.config['MQTT_BROKER_PORT'] = 1883
|
|
|
- app.config['MQTT_USERNAME'] = 'aisky-client'
|
|
|
- app.config['MQTT_PASSWORD'] = 'aiskyc'
|
|
|
- #將發送ping到代理的時間間隔設置60秒
|
|
|
- app.config['MQTT_KEEPALIVE'] = 60
|
|
|
- #出於測試目的將TLS設置為禁用
|
|
|
- app.config['MQTT_TLS_ENABLED'] = False
|
|
|
-
|
|
|
- #資料庫的初始化
|
|
|
- db = SQLAlchemy(app)
|
|
|
- db.init_app(app)
|
|
|
- mqtt = Mqtt(app)
|
|
|
-
|
|
|
- # 初始化Flask-Migrate擴展
|
|
|
- migrate = Migrate(app, db)
|
|
|
-
|
|
|
- app.config['BABEL_DEFAULT_LOCALE'] = 'zh'
|
|
|
- app.config['BABEL_DEFAULT_TIMEZONE'] = 'UTC'
|
|
|
- app.config['LANGUAGES'] = ['en', 'zh']
|
|
|
-
|
|
|
- babel = Babel(app)
|
|
|
-
|
|
|
- @babel.localeselector
|
|
|
- def get_locale():
|
|
|
- return request.accept_languages.best_match(app.config['LANGUAGES'])
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- #用來使用flask-migrate數據遷移使用,如要用在把下面模型類註釋消掉,並且將main裡的from coffee_manage import mqtt,db註釋掉(因會報導入錯誤)
|
|
|
- # # 用戶表
|
|
|
- # class User(db.Model):
|
|
|
- # __tablename__ = 'user'
|
|
|
- #
|
|
|
- # userID = db.Column(db.Integer, primary_key=True)
|
|
|
- # firstname = db.Column(db.String(30), nullable=False)
|
|
|
- # lastname = db.Column(db.String(30), nullable=False)
|
|
|
- # mail = db.Column(db.String(50), nullable=False)
|
|
|
- # phone = db.Column(db.String(20), nullable=False)
|
|
|
- # username = db.Column(db.String(30), nullable=False, unique=True)
|
|
|
- # password = db.Column(db.String(40), nullable=False)
|
|
|
- # status = db.Column(db.Integer, nullable=False, info='0:admin;1:new;9:disable')
|
|
|
- #
|
|
|
- # # 發酵槽溫度感測器表
|
|
|
- # class TankTemSensor(db.Model):
|
|
|
- # __tablename__ = 'tank_tem_sensor'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # tem = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # # 發酵槽二氧化碳感測器表
|
|
|
- # class TankCO2Sensor(db.Model):
|
|
|
- # __tablename__ = 'tank_co2_sensor'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # co2 = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # # 發酵槽酸鹼值感測器表
|
|
|
- # class TankPHSensor(db.Model):
|
|
|
- # __tablename__ = 'tank_ph_sensor'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # ph = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class BeanValve(db.Model):
|
|
|
- # __tablename__ = 'bean_valve'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class WashMachine(db.Model):
|
|
|
- # __tablename__ = 'wash_machine'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class ConveyorBelt1(db.Model):
|
|
|
- # __tablename__ = 'conveyor_belt1'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Cargo1Disinfect(db.Model):
|
|
|
- # __tablename__ = 'cargo1_disinfect'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class ColorMachine(db.Model):
|
|
|
- # __tablename__ = 'color_machine'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class ConveyorBelt2(db.Model):
|
|
|
- # __tablename__ = 'conveyor_belt2'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class PeelingMachine(db.Model):
|
|
|
- # __tablename__ = 'peeling_machine'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class ConveyorBelt3(db.Model):
|
|
|
- # __tablename__ = 'conveyor_belt3'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Bacteria(db.Model):
|
|
|
- # __tablename__ = 'bacteria'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Cargo2Disinfect(db.Model):
|
|
|
- # __tablename__ = 'cargo2_disinfect'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Heating(db.Model):
|
|
|
- # __tablename__ = 'heating'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Stir(db.Model):
|
|
|
- # __tablename__ = 'stir'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class WaterInjection(db.Model):
|
|
|
- # __tablename__ = 'water_injection'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class TopValve(db.Model):
|
|
|
- # __tablename__ = 'top_valve'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class BottomValve(db.Model):
|
|
|
- # __tablename__ = 'bottom_valve'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Temperature(db.Model):
|
|
|
- # __tablename__ = 'temperature'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Hoist(db.Model):
|
|
|
- # __tablename__ = 'hoist'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Dryer(db.Model):
|
|
|
- # __tablename__ = 'dryer'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # duration = db.Column(db.Text, nullable=False)
|
|
|
- # start = db.Column(db.Text, nullable=False)
|
|
|
- # end = db.Column(db.Text, nullable=False)
|
|
|
- #
|
|
|
- # class Relay(db.Model):
|
|
|
- # __tablename__ = 'relay'
|
|
|
- #
|
|
|
- # sn = db.Column(db.Integer, primary_key=True)
|
|
|
- # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
- # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
- # status = db.Column(db.Text, nullable=False)
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- #將main藍圖程序與app關聯到一起
|
|
|
- from .main import main as main_blueprint
|
|
|
- app.register_blueprint(main_blueprint)
|
|
|
- #將user藍圖程序與app關聯到一起
|
|
|
- from .user import user as user_blueprint
|
|
|
- app.register_blueprint(user_blueprint)
|
|
|
-
|
|
|
- # Rita 將lang藍圖程序與app關聯到一起
|
|
|
- # from .main import main
|
|
|
- # app.register_blueprint(main, url_prefix='/<lang_code>')
|
|
|
-
|
|
|
+#對整個應用做初始化操作
|
|
|
+#主要工作:
|
|
|
+# 1.構建Flask的應用以及各種配置
|
|
|
+#2.構建SQLAlchemy的應用
|
|
|
+
|
|
|
+from flask import Flask, g, request
|
|
|
+from flask_sqlalchemy import SQLAlchemy
|
|
|
+import pymysql
|
|
|
+import eventlet
|
|
|
+from flask_mqtt import Mqtt
|
|
|
+from flask_migrate import Migrate
|
|
|
+#from flask_migrate import Migrate, MigrateCommand
|
|
|
+from flask_babel import Babel
|
|
|
+# from werkzeug.wrappers import Request
|
|
|
+
|
|
|
+
|
|
|
+#綠化(綠色線程)所有系統模組,實現IO多路複用
|
|
|
+# eventlet.monkey_patch()
|
|
|
+
|
|
|
+pymysql.install_as_MySQLdb()
|
|
|
+
|
|
|
+# # db = SQLAlchemy()
|
|
|
+# def register_i18n(app):
|
|
|
+# """Register i18n with the Flask application."""
|
|
|
+# defalut_language_str = app.config['DEFAULT_LANGUAGE']
|
|
|
+# support_language_list = app.config['SUPPORTED_LANGUAGES']
|
|
|
+
|
|
|
+# # 1. 取得子資料夾路徑 land_code
|
|
|
+# @app.url_value_preprocessor
|
|
|
+# def get_lang_code(endpoint, values):
|
|
|
+# if values is not None:
|
|
|
+# g.lang_code = values.pop('lang_code', defalut_language_str)
|
|
|
+
|
|
|
+# # 2. 確認 config 內包含 lang_code
|
|
|
+# @app.before_request
|
|
|
+# def ensure_lang_support():
|
|
|
+# lang_code = g.get('lang_code', None)
|
|
|
+# if lang_code and lang_code not in support_language_list:
|
|
|
+# g.lang_code = request.accept_languages.best_match(support_language_list)
|
|
|
+
|
|
|
+# # 3. 設定多語系
|
|
|
+# @app.localeselector
|
|
|
+# def get_locale():
|
|
|
+# return g.get('lang_code')
|
|
|
+
|
|
|
+# # 4. 確認在 1. pop lang_code 參數後的 lang_code 值
|
|
|
+# @app.url_defaults
|
|
|
+# def set_langrage_code(endpoint, values):
|
|
|
+# if 'lang_code' in values or not g.lang_code:
|
|
|
+# return
|
|
|
+# if app.url_map.is_endpoint_expecting(endpoint, 'lang_code'):
|
|
|
+# values['lang_code'] = g.lang_code
|
|
|
+
|
|
|
+
|
|
|
+def create_app():
|
|
|
+ app = Flask(__name__)
|
|
|
+ #配置啟動模式為調適模式
|
|
|
+ # app.config['DEBUG'] = True
|
|
|
+ #配置數據庫的連接字符串
|
|
|
+ # app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://coffee:skyeye@52.69.200.169:3306/Coffee'
|
|
|
+ app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:Gold@53743001@localhost:3306/Coffee'
|
|
|
+ #配置數據庫內容再更新時自動提交
|
|
|
+ app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
|
|
|
+ #配置session所需要的秘鑰
|
|
|
+ app.config['SECRET_KEY'] = 'you guess'
|
|
|
+
|
|
|
+ # template 有修改後,會自動去更新
|
|
|
+ app.config['TEMPLATES_AUTO_RELOAD'] = True
|
|
|
+
|
|
|
+ #如果设置成True(默认情况),Flask - SQLAlchemy将会追踪对象的修改并且发送信号。这需要额外的内存, 如果不必要的可以禁用它
|
|
|
+ app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = True
|
|
|
+
|
|
|
+ #資料库连接池的大小。默认是数据库引擎的默认值 (通常是5)
|
|
|
+ app.config['SQLALCHEMY_POOL_SIZE'] = 100
|
|
|
+
|
|
|
+ #指定資料库连接池的超时时间。默认是 10
|
|
|
+ # app.config['SQLALCHEMY_POOL_TIMEOUT'] = 60
|
|
|
+ app.config['SQLALCHEMY_POOL_TIMEOUT'] = 60 * 60
|
|
|
+
|
|
|
+ #自动回收连接的秒数。这对 MySQL 是必须的,默认 情况下 MySQL 会自动移除闲置 8 小时或者以上的连接。 需要注意地是如果使用 MySQL 的话, Flask-SQLAlchemy 会自动地设置这个值为 2 小时
|
|
|
+ app.config['SQLALCHEMY_POOL_RECYCLE'] = 60 * 60 * 8
|
|
|
+
|
|
|
+ app.config['SQLALCHEMY_MAX_OVERFLOW'] = 15
|
|
|
+
|
|
|
+ # app.config['SECRET'] = 'my secret key'
|
|
|
+ #MQTT相關設置
|
|
|
+ app.config['MQTT_BROKER_URL'] = '60.250.156.234'
|
|
|
+ app.config['MQTT_BROKER_PORT'] = 1883
|
|
|
+ app.config['MQTT_USERNAME'] = 'aisky-client'
|
|
|
+ app.config['MQTT_PASSWORD'] = 'aiskyc'
|
|
|
+ #將發送ping到代理的時間間隔設置60秒
|
|
|
+ app.config['MQTT_KEEPALIVE'] = 60
|
|
|
+ #出於測試目的將TLS設置為禁用
|
|
|
+ app.config['MQTT_TLS_ENABLED'] = False
|
|
|
+
|
|
|
+ #資料庫的初始化
|
|
|
+ db = SQLAlchemy(app)
|
|
|
+ db.init_app(app)
|
|
|
+ mqtt = Mqtt(app)
|
|
|
+
|
|
|
+ # 初始化Flask-Migrate擴展
|
|
|
+ migrate = Migrate(app, db)
|
|
|
+
|
|
|
+ app.config['BABEL_DEFAULT_LOCALE'] = 'zh'
|
|
|
+ app.config['BABEL_DEFAULT_TIMEZONE'] = 'UTC'
|
|
|
+ app.config['LANGUAGES'] = ['en', 'zh']
|
|
|
+
|
|
|
+ babel = Babel(app)
|
|
|
+
|
|
|
+ @babel.localeselector
|
|
|
+ def get_locale():
|
|
|
+ return request.accept_languages.best_match(app.config['LANGUAGES'])
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ #用來使用flask-migrate數據遷移使用,如要用在把下面模型類註釋消掉,並且將main裡的from coffee_manage import mqtt,db註釋掉(因會報導入錯誤)
|
|
|
+ # # 用戶表
|
|
|
+ # class User(db.Model):
|
|
|
+ # __tablename__ = 'user'
|
|
|
+ #
|
|
|
+ # userID = db.Column(db.Integer, primary_key=True)
|
|
|
+ # firstname = db.Column(db.String(30), nullable=False)
|
|
|
+ # lastname = db.Column(db.String(30), nullable=False)
|
|
|
+ # mail = db.Column(db.String(50), nullable=False)
|
|
|
+ # phone = db.Column(db.String(20), nullable=False)
|
|
|
+ # username = db.Column(db.String(30), nullable=False, unique=True)
|
|
|
+ # password = db.Column(db.String(40), nullable=False)
|
|
|
+ # status = db.Column(db.Integer, nullable=False, info='0:admin;1:new;9:disable')
|
|
|
+ #
|
|
|
+ # # 發酵槽溫度感測器表
|
|
|
+ # class TankTemSensor(db.Model):
|
|
|
+ # __tablename__ = 'tank_tem_sensor'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # tem = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # # 發酵槽二氧化碳感測器表
|
|
|
+ # class TankCO2Sensor(db.Model):
|
|
|
+ # __tablename__ = 'tank_co2_sensor'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # co2 = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # # 發酵槽酸鹼值感測器表
|
|
|
+ # class TankPHSensor(db.Model):
|
|
|
+ # __tablename__ = 'tank_ph_sensor'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # ph = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class BeanValve(db.Model):
|
|
|
+ # __tablename__ = 'bean_valve'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class WashMachine(db.Model):
|
|
|
+ # __tablename__ = 'wash_machine'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class ConveyorBelt1(db.Model):
|
|
|
+ # __tablename__ = 'conveyor_belt1'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Cargo1Disinfect(db.Model):
|
|
|
+ # __tablename__ = 'cargo1_disinfect'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class ColorMachine(db.Model):
|
|
|
+ # __tablename__ = 'color_machine'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class ConveyorBelt2(db.Model):
|
|
|
+ # __tablename__ = 'conveyor_belt2'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class PeelingMachine(db.Model):
|
|
|
+ # __tablename__ = 'peeling_machine'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class ConveyorBelt3(db.Model):
|
|
|
+ # __tablename__ = 'conveyor_belt3'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Bacteria(db.Model):
|
|
|
+ # __tablename__ = 'bacteria'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Cargo2Disinfect(db.Model):
|
|
|
+ # __tablename__ = 'cargo2_disinfect'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Heating(db.Model):
|
|
|
+ # __tablename__ = 'heating'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Stir(db.Model):
|
|
|
+ # __tablename__ = 'stir'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class WaterInjection(db.Model):
|
|
|
+ # __tablename__ = 'water_injection'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class TopValve(db.Model):
|
|
|
+ # __tablename__ = 'top_valve'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class BottomValve(db.Model):
|
|
|
+ # __tablename__ = 'bottom_valve'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Temperature(db.Model):
|
|
|
+ # __tablename__ = 'temperature'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Hoist(db.Model):
|
|
|
+ # __tablename__ = 'hoist'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Dryer(db.Model):
|
|
|
+ # __tablename__ = 'dryer'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # duration = db.Column(db.Text, nullable=False)
|
|
|
+ # start = db.Column(db.Text, nullable=False)
|
|
|
+ # end = db.Column(db.Text, nullable=False)
|
|
|
+ #
|
|
|
+ # class Relay(db.Model):
|
|
|
+ # __tablename__ = 'relay'
|
|
|
+ #
|
|
|
+ # sn = db.Column(db.Integer, primary_key=True)
|
|
|
+ # datetime = db.Column(db.DateTime, nullable=False)
|
|
|
+ # tank_num = db.Column(db.Integer, nullable=False)
|
|
|
+ # status = db.Column(db.Text, nullable=False)
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ #將main藍圖程序與app關聯到一起
|
|
|
+ from .main import main as main_blueprint
|
|
|
+ app.register_blueprint(main_blueprint)
|
|
|
+ #將user藍圖程序與app關聯到一起
|
|
|
+ from .user import user as user_blueprint
|
|
|
+ app.register_blueprint(user_blueprint)
|
|
|
+
|
|
|
+ # Rita 將lang藍圖程序與app關聯到一起
|
|
|
+ # from .main import main
|
|
|
+ # app.register_blueprint(main, url_prefix='/<lang_code>')
|
|
|
+
|
|
|
return app, db, mqtt
|