From c9b4c2f4d7b4ab41cdb3de5fc582b7788a46dbb6 Mon Sep 17 00:00:00 2001 From: Patrick McDonagh Date: Tue, 25 Oct 2016 19:01:36 -0500 Subject: [PATCH] First commit for this branch. Adds files for Flask and flask-restless --- web_db/flask/app/__init__.py | 15 ++++ web_db/flask/app/datalogger/__init__.py | 1 + web_db/flask/app/datalogger/datalogger.py | 14 ++++ web_db/flask/app/datalogger/models.py | 95 ++++++++++++++++++++++ web_db/flask/database.db | Bin 0 -> 16384 bytes web_db/flask/run.py | 4 + web_db/flask/setupdb.py | 50 ++++++++++++ 7 files changed, 179 insertions(+) create mode 100644 web_db/flask/app/__init__.py create mode 100644 web_db/flask/app/datalogger/__init__.py create mode 100644 web_db/flask/app/datalogger/datalogger.py create mode 100644 web_db/flask/app/datalogger/models.py create mode 100644 web_db/flask/database.db create mode 100644 web_db/flask/run.py create mode 100644 web_db/flask/setupdb.py diff --git a/web_db/flask/app/__init__.py b/web_db/flask/app/__init__.py new file mode 100644 index 0000000..96bbca1 --- /dev/null +++ b/web_db/flask/app/__init__.py @@ -0,0 +1,15 @@ +# project/__init__.py + +from flask import Flask, render_template, request, session +from flask.ext.sqlalchemy import SQLAlchemy + + +app = Flask('app') +app.config.update( + DEBUG=True, + SQLALCHEMY_DATABASE_URI='sqlite:///../database.db', + ) +db = SQLAlchemy(app) + +from datalogger import datalogger + diff --git a/web_db/flask/app/datalogger/__init__.py b/web_db/flask/app/datalogger/__init__.py new file mode 100644 index 0000000..2ff2340 --- /dev/null +++ b/web_db/flask/app/datalogger/__init__.py @@ -0,0 +1 @@ +from datalogger import * \ No newline at end of file diff --git a/web_db/flask/app/datalogger/datalogger.py b/web_db/flask/app/datalogger/datalogger.py new file mode 100644 index 0000000..4d311e5 --- /dev/null +++ b/web_db/flask/app/datalogger/datalogger.py @@ -0,0 +1,14 @@ + +from flask.ext.restless import APIManager + +from .models import * +from .. import app +manager = APIManager(app, flask_sqlalchemy_db=db) +manager.create_api(Config, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Data_type, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Device_type, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Device, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Doc, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Tag_class, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Tag, methods=['GET', 'POST', 'DELETE']) +manager.create_api(Tag_val, methods=['GET', 'POST', 'DELETE']) \ No newline at end of file diff --git a/web_db/flask/app/datalogger/models.py b/web_db/flask/app/datalogger/models.py new file mode 100644 index 0000000..0dabdab --- /dev/null +++ b/web_db/flask/app/datalogger/models.py @@ -0,0 +1,95 @@ +from datetime import datetime +import json + +from .. import db + + +class Config(db.Model): + __tablename__ = "configs" + id = db.Column(db.Integer, primary_key=True) + parameter = db.Column(db.String(100), unique=True) + val = db.Column(db.String(100), unique=True) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + + +class Data_type(db.Model): + __tablename__ = "data_types" + id = db.Column(db.Integer, primary_key=True) + data_type = db.Column(db.String(32), unique=True) + plc_type = db.Column(db.String(32)) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + +class Device_type(db.Model): + __tablename__ = "device_types" + id = db.Column(db.Integer, primary_key=True) + device_type = db.Column(db.String(64)) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + + +class Device(db.Model): + __tablename__ = "devices" + id = db.Column(db.Integer, primary_key=True) + device_type_id = db.Column(db.Integer, db.ForeignKey('device_types.id')) + device_type = db.relationship(Device_type, primaryjoin=device_type_id==Device_type.id) + address = db.Column(db.String(256)) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + + +class Doc(db.Model): + __tablename__ = "docs" + id = db.Column(db.Integer, primary_key=True) + name = db.Column(db.String(128)) + location = db.Column(db.String(256)) + description = db.Column(db.String(256)) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + +class Tag_class(db.Model): + __tablename__ = "tag_classes" + id = db.Column(db.Integer, primary_key=True) + class_type = db.Column(db.String(64), unique=True) + description = db.Column(db.String(128)) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + + def toJSON(self): + return json.dumps({'id': self.id, 'class_type': self.class_type, 'description': self.description, 'created_on': self.created_on, 'updated_on': self.updated_on}) + +class Tag(db.Model): + __tablename__ = "tags" + id = db.Column(db.Integer, primary_key=True) + name = db.Column(db.String(64)) + tag_class_id = db.Column(db.Integer, db.ForeignKey('tag_classes.id')) + tag_class = db.relationship(Tag_class) + tag = db.Column(db.String(128)) + device_id = db.Column(db.Integer, db.ForeignKey('devices.id')) + device_ = db.relationship(Device) + description = db.Column(db.String(64)) + data_type_id = db.Column(db.Integer, db.ForeignKey('data_types.id')) + data_type = db.relationship(Data_type) + change_threshold = db.Column(db.Float) + guarantee_sec = db.Column(db.Integer) + map_function = db.Column(db.String(64)) + units = db.Column(db.String(10)) + min_expected = db.Column(db.Float) + max_expected = db.Column(db.Float) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + + + + + +class Tag_val(db.Model): + __tablename__ = "tag_vals" + id = db.Column(db.Integer, primary_key=True) + tag_id = db.Column(db.Integer, db.ForeignKey('tags.id')) + tag = db.relationship(Tag) + val = db.Column(db.Float) + created_on = db.Column(db.DateTime(), default=datetime.utcnow) + updated_on = db.Column(db.DateTime(), default=datetime.utcnow, onupdate=datetime.utcnow) + diff --git a/web_db/flask/database.db b/web_db/flask/database.db new file mode 100644 index 0000000000000000000000000000000000000000..d36a43c3de4678930bdb81659f1ef3535ce8ba7f GIT binary patch literal 16384 zcmeHO-*4MQ96$RSr^(jQX^g0*CA@RUJ0Dl8dJTN4lK;nH*lX&2T2OcKD<0Qlj-?L*U&fey!fvPz*kb1`xxb8Jrvoe|sB*#DIMQN2Vj~l?232Y$ZA<^O3V0NircpP~i)y{LRw?U6v6UE{ z;{Ho{RVyimQZ%+VHNBl0n9a*lLFNn6<*dxN^ZChOpi<&9 zxq`eP=lR@nfzMsbX5Z$60jCiEfs~(Jl=72NF-!!TRn@G%J6~;RilLQ?^%_41Z51+0 zGAZ8NgqmK=Udd;cr2Gy3ihP5gtdz`}ujMjVugUzR({wl(jt+34g>f(FoRWG`Xs5|& zAVUf5Tw(p8vuBz6+ZHl)RWHFGyU~E0J~-5r4b4$i5L0GPt94Z|Dxj&2jTlduf|91I zjmlyOhIe9&KQuAH+`nLHqur^fTI)`Cq*=Fi9g;p;mfFP}of0uqrQLNK&_78Y z?|^Rz_889~{4>4_2f9%NC;~5mz`NLo&PtLTjYPzVkeCu8Q(~MKqZi}xi!ot3CW?X( z^^~L})`!LM5@(gmg02y9$t`E-^lIMv`W;*FDN4VuF_>E|BNn^;Ulg-Dy#Z z07c+vBVfJ%ClLM)SMkKr)`j+-BCszA$e2T;@Rq+^uU9ptc6oU@+xv|gjU^IZlB6)l zLN)NJ&eRO8tTlkwd6bO`DKCi_%`zMcLuclzbznKQGQR>$)c^+R(I+vP^5~P8OveZd z!1yV`Pw`*)_kBT+R!R||2plK^C-5lKnyfHMw`LsnG!6&c^9Hs55A?>+#wY@Z3IX!| zr~Lm=-4faviok&(K%f5ugPJx(5jb=R46*MaAG(KdhW&z3*m-o1c;{KY-O-&}K7VL* zlzDK*bZoZ#+N}fUa%Z+O`*<=pl?Hfh4Xt7OG55FjNg)z3-K2Mvs@#HqFPFHZ zmD!f?d$Sx7Qkh0>`0q??}?RQY-1}%57~WJIgQHCwxIE_x?H!ldZ>>W+5U(-uH26 zWL%Qerf$?XX3f2KU6EA6!)pza_{so>#=?^HnO3bDnr?guN4@|Feh%WRdiO4p6yjbI zF|q=m_(_drrCHYMYikSS$S<$0^{X+S5It&)Cz31VYySm6u>$%wwinGqMTHkppFT#@ zX^$FXkwhN8{ErBdq#KR;ZEe-u^O>3zy9e=3J+BnfVyt&)0+FPN{m*hA!;kSZ z{2V`dtp`6FrSy_<-DAml~=p0ItZTy7N8FLL+8&k4~9(D z4W(REtBS6}E32Ihx*+Hf^nt;w#U1h6vJ86#yV?=5dxyd%IqmjA%XokbWzKtr19vD? z6go~$u+OZ3;QbB6hJf|A_K(Lptn&Y3n!6%l#QtaS4+wsAqX({Sg`{vZ};^#Bh|2ETI{6Bdyo}P}xlF>-_ z0t81QB*^p6qCXJx6YP%dwsZZYKQuPRJiw0m4WOE~H#rW!V0e?jC;4D zknb=nn@+U2kh@?n{$W!Sdl6(8h$>LpGAx=~2mZERua??~mYd)>g0NYwsB5adB9cJ8 zp==h{nl;t6rmxjZvsN+MG*GZSK^v7?QQO+oR9N=du75+>>XG~E@1u=q_uaJFptIVt qa{xH-x~{Tvtzkfra9z;>u=^rgU=JVi{L}cKV>|It#V7)O5%?Dvggkfv literal 0 HcmV?d00001 diff --git a/web_db/flask/run.py b/web_db/flask/run.py new file mode 100644 index 0000000..5751813 --- /dev/null +++ b/web_db/flask/run.py @@ -0,0 +1,4 @@ +from app import app + +if __name__ == '__main__': + app.run(debug=True) \ No newline at end of file diff --git a/web_db/flask/setupdb.py b/web_db/flask/setupdb.py new file mode 100644 index 0000000..73b4e2b --- /dev/null +++ b/web_db/flask/setupdb.py @@ -0,0 +1,50 @@ +# the sqlalchemy db object +from app import db + +# we have to import the models so that sqlalchemy can detect them and create the db +# how else would it know what to create ? +from app.datalogger.models import * + +# creates the database +db.create_all() + +# after the last command you should now be able to see database.db file +# in the project folder + +# Data Type Seeds +data_type_REAL = Data_type(data_type='Floating Point', plc_type='REAL') +data_type_INT = Data_type(data_type='Integer', plc_type='INT') +data_type_BOOL = Data_type(data_type='Boolean', plc_type='BOOL') + +db.session.add(data_type_REAL) +db.session.add(data_type_INT) +db.session.add(data_type_BOOL) + +# Device Type Seeds +device_type_CLX = Device_type(device_type='CLX') +device_type_u800 = Device_type(device_type='Micro800') +device_type_E300 = Device_type(device_type='E300') + +db.session.add(device_type_CLX) +db.session.add(device_type_u800) +db.session.add(device_type_E300) + +# Tag Class Seeds +tag_class_stroke = Tag_class(class_type='stroke', description="Stroke Information") +tag_class_history = Tag_class(class_type='history', description="Historical Data") +tag_class_gaugeoff = Tag_class(class_type='gaugeoff', description="Gauge Off Data") +tag_class_welltest = Tag_class(class_type='welltest', description="Well Test Data") +tag_class_custom = Tag_class(class_type='custom', description="Custom Tag") +tag_class_handshake = Tag_class(class_type='handshake', description="PLC Handshake Tag") + + +db.session.add(tag_class_stroke) +db.session.add(tag_class_history) +db.session.add(tag_class_gaugeoff) +db.session.add(tag_class_welltest) +db.session.add(tag_class_custom) +db.session.add(tag_class_handshake) + +db.session.add(Device(device_type_id=1, address="192.168.1.10")) + +db.session.commit() \ No newline at end of file