First commit for this branch. Adds files for Flask and flask-restless

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
+

web_db/flask/app/datalogger/__init__.py

@@ -0,0 +1 @@
+from datalogger import *

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'])

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)
+

web_db/flask/run.py

@@ -0,0 +1,4 @@
+from app import app
+
+if __name__ == '__main__':
+    app.run(debug=True)

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()