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 0000000..d36a43c Binary files /dev/null and b/web_db/flask/database.db differ 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