app.py

from cs50 import SQL
from flask import Flask, render_template, request, redirect, flash, session
from flask_session import Session
import pandas as pd
from tempfile import mkdtemp
from werkzeug.security import check_password_hash, generate_password_hash
import seaborn as sns
import matplotlib.pyplot as plt
from sklearn.externals import joblib
import os


from helpers import apology, login_required


app = Flask(__name__)

# Ensure templates are auto-reloaded
app.config["TEMPLATES_AUTO_RELOAD"] = True

# Ensure responses aren't cached
@app.after_request
def after_request(response):
    response.headers["Cache-Control"] = "no-cache, no-store, must-revalidate"
    response.headers["Expires"] = 0
    response.headers["Pragma"] = "no-cache"
    return response

# Configure session to use filesystem (instead of signed cookies)
app.config["SESSION_FILE_DIR"] = mkdtemp()
app.config["SESSION_PERMANENT"] = False
app.config["SESSION_TYPE"] = "filesystem"

Session(app)

db = SQL("sqlite:///users.db")
zip_agg = pd.read_csv("Zip_Aggregate.csv")
loaded_model = joblib.load('str_model.pkl')
@app.route("/")
@login_required
def index():
    return render_template("input.html")

@app.route("/input", methods=["GET", "POST"])
@login_required
def input():

    if request.method == "POST":
        db.execute("INSERT INTO address (uid, agr, basement, condo, policycount, crsdiscount, elevatedbuilding, elevationdifference, floodzone, houseworship, locationofcontents, latitude, longitude, numstories, nonprofit, obstructiontype, occupancytype, postfirm, yearbuilt, zipcode, yearofloss) VALUES (:user_id, :agriculture, :basement, :condominium, :policycount, :crsdiscount, :elevatedbuilding,:elevationdifference, :floodzone, :houseworship, :locationofcontents, :latitude, :longitude, :numstories, :nonprofit, :obstructiontype, :occupancytype, :postfirm, :yearbuilt, :zipcode, :yearofloss)", user_id=session["user_id"], agriculture=request.form.get("agriculture"), basement=request.form.get("basement"), condominium=request.form.get("condominium"), policycount=request.form.get("policycount"), crsdiscount=request.form.get("crsdiscount"), elevatedbuilding=request.form.get("elevatedbuilding"), elevationdifference=request.form.get("elevationdifference"), floodzone=request.form.get("floodzone"), houseworship=request.form.get("houseworship"), locationofcontents=request.form.get("locationofcontents"), latitude=request.form.get("latitude"), longitude=request.form.get("longitude"), numstories=request.form.get("numberofstories"), nonprofit=request.form.get("nonprofit"), obstructiontype=request.form.get("obstruction"), occupancytype=request.form.get("occupancy"), postfirm=request.form.get("postfirm"), yearbuilt=request.form.get("yearbuilt"), zipcode=request.form.get("zipcode"), yearofloss=request.form.get("damageyear"))

        db.execute("UPDATE accounts SET numaddresses = numaddresses + 1 where uid = :user_id", user_id=session["user_id"])

        flash("Location Added!")

        #Calculate Loss Ratio and Update db
        zip_temp = zip_agg[zip_agg['ZipCode'] == int(request.form.get("zipcode"))]
        len_zip = len(zip_temp)
        min_LR = round(zip_temp['loss_ratio_building'].min(),2)
        max_LR = round(zip_temp['loss_ratio_building'].max(),2)
        mean_LR = round(zip_temp['loss_ratio_building'].mean(),2)
        zip_URL = ''
        if len_zip > 1:
            len_image = True
            ax = sns.boxplot(x="ZipCode", y="loss_ratio_building",
                             palette=["r", "g"],
                             data=zip_agg[zip_agg['ZipCode'] == int(request.form.get("zipcode"))])
            ax.set_xlabel('Zip Code')
            ax.set_ylabel('Building Loss Ratio')

            fig = ax.get_figure()
            fig.set_size_inches(4.5, 5)
            fig.savefig('static/%s.png' % int(request.form.get("zipcode")))
            zip_URL = "static/%s.png" % int(request.form.get("zipcode"))
            plt.close(fig)
        else:
            len_image = False

        agriculturestructureindicator_input = request.form.get("agriculture")
        basementenclosurecrawlspacetype_input = float(request.form.get("basement"))
        condominiumindicator_input = request.form.get("condominium")
        policycount_input = float(request.form.get("policycount"))
        crsdiscount_input = float(request.form.get("crsdiscount"))
        elevatedbuildingindicator_input = request.form.get("elevatedbuilding")
        elevationdifference_input = float(request.form.get("elevationdifference"))
        floodzone_input = request.form.get("floodzone")
        houseworship_input = request.form.get("houseworship")
        latitude_input = float(request.form.get("latitude"))
        locationofcontents_input = request.form.get("locationofcontents")
        longitude_input = float(request.form.get("longitude"))
        numberoffloorsintheinsuredbuilding_input = float(request.form.get("numberofstories"))
        nonprofitindicator_input = request.form.get("nonprofit")
        obstructiontype_input = request.form.get("obstruction")
        occupancytype_input = float(request.form.get("occupancy"))
        postfirmconstructionindicator_input = request.form.get("postfirm")
        yearofloss_input = int(request.form.get("damageyear"))
        yearbuilt_input = int(request.form.get("yearbuilt"))
        ZipCode_input = int(request.form.get("zipcode"))

        df = pd.DataFrame({'agriculturestructureindicator': [agriculturestructureindicator_input],
                           'basementenclosurecrawlspacetype': [basementenclosurecrawlspacetype_input],
                           'condominiumindicator': [condominiumindicator_input],
                           'policycount': [policycount_input],
                           'crsdiscount': [crsdiscount_input],
                           'elevatedbuildingindicator': [elevatedbuildingindicator_input],
                           'elevationdifference': [elevationdifference_input],
                           'floodzone': [floodzone_input],
                           'houseworship': [houseworship_input],
                           'latitude': [latitude_input],
                           'locationofcontents': [locationofcontents_input],
                           'longitude': [longitude_input],
                           'numberoffloorsintheinsuredbuilding': [numberoffloorsintheinsuredbuilding_input],
                           'nonprofitindicator': [nonprofitindicator_input],
                           'obstructiontype': [obstructiontype_input],
                           'occupancytype': [occupancytype_input],
                           'postfirmconstructionindicator': [postfirmconstructionindicator_input],
                           'yearofloss': [yearofloss_input],
                           'yearbuilt': [yearbuilt_input],
                           'ZipCode': [ZipCode_input]})
        LR = str(round(loaded_model.predict(df)[0],2))
        LR = float(LR)
        db.execute(
            "UPDATE address SET lossratio = :lossratio WHERE uid = :user_id and agr = :agriculture and basement = :basement and condo = :condominium and policycount = :policycount and crsdiscount = :crsdiscount and latitude = :latitude and longitude = :longitude and zipcode = :zipcode and yearbuilt = :yearbuilt and postfirm = :postfirm and occupancytype = :occupancytype and obstructiontype = :obstructiontype and nonprofit = :nonprofit and numstories = :numstories and locationofcontents = :locationofcontents and houseworship = :houseworship and floodzone = :floodzone and elevationdifference = :elevationdifference and elevatedbuilding = :elevatedbuilding and yearofloss = :yearofloss",
            lossratio=LR, user_id=session["user_id"], agriculture=request.form.get("agriculture"),
            basement=request.form.get("basement"), condominium=request.form.get("condominium"),
            policycount=request.form.get("policycount"), crsdiscount=request.form.get("crsdiscount"),
            elevatedbuilding=request.form.get("elevatedbuilding"),
            elevationdifference=request.form.get("elevationdifference"), floodzone=request.form.get("floodzone"),
            houseworship=request.form.get("houseworship"), locationofcontents=request.form.get("locationofcontents"),
            latitude=request.form.get("latitude"), longitude=request.form.get("longitude"),
            numstories=request.form.get("numberofstories"), nonprofit=request.form.get("nonprofit"),
            obstructiontype=request.form.get("obstruction"), occupancytype=request.form.get("occupancy"),
            postfirm=request.form.get("postfirm"), yearbuilt=request.form.get("yearbuilt"),
            zipcode=request.form.get("zipcode"), yearofloss=request.form.get("damageyear"))
        if LR <= 0.05:
            col = "green"
        elif (LR > 0.05) and (LR <= 0.2):
            col = "yellow"
        elif LR > 0.2:
            col = "red"

        return render_template("my_map.html", lat=request.form.get("latitude"), lon=request.form.get("longitude"), col=col, LR=LR, len_image=len_image, zip_URL=zip_URL, min_LR=min_LR, max_LR=max_LR, mean_LR=mean_LR, len_zip=len_zip, zip=request.form.get("zipcode"))

    else:
        return render_template("input.html")


@app.route("/login", methods=["GET", "POST"])
def login():

    # Forget any user_id
    session.clear()

    # User reached route via POST (as by submitting a form via POST)
    if request.method == "POST":

        # Ensure username was submitted
        if not request.form.get("username"):
            return apology("must provide username", 403)

        # Ensure password was submitted
        elif not request.form.get("password"):
            return apology("must provide password", 403)

        # Query database for username
        rows = db.execute("SELECT * FROM accounts WHERE username = :username", username=request.form.get("username"))

        # Ensure username exists and password is correct
        if len(rows) != 1 or not check_password_hash(rows[0]["hash"], request.form.get("password")):
            return apology("invalid username and/or password", 403)

        # Remember which user has logged in
        session["user_id"] = rows[0]["uid"]

        # Redirect user to home page
        return render_template("input.html")

    # User reached route via GET (as by clicking a link or via redirect)
    else:
        return render_template("login.html")



@app.route("/register", methods=["GET", "POST"])
def register():

    if request.method == "POST":

        if not request.form.get("username"):
            return apology("Must provide username", 400)

        elif not request.form.get("password"):
            return apology("Must provide password", 400)

        elif request.form.get("password") != request.form.get("confirmation"):
            return apology("Password do not match", 400)

        hash = generate_password_hash(request.form.get("password"))

        check_user_id = db.execute("SELECT * FROM accounts WHERE username = :username", username = request.form.get("username"))

        if len(check_user_id) >= 1:
            return apology("username taken", 400)

        new_user_id = db.execute("INSERT INTO accounts (username, hash) VALUES (:username, :hash)", username = request.form.get("username"), hash = hash)

        session["user_id"] = new_user_id
        flash("Registered")
        return render_template("input.html")

    else:

        return render_template("register.html")

@app.route("/logout")
def logout():

    # Forget any user_id
    session.clear()

    # Redirect user to login form
    return redirect("/")


@app.route("/history", methods=["GET", "POST"])
@login_required
def history():

    """Show history of transactions"""
    if request.method == "GET":
        transactions = db.execute("SELECT agr, basement, condo, policycount, crsdiscount, elevatedbuilding, elevationdifference, floodzone, houseworship, locationofcontents, latitude, longitude, numstories, nonprofit, obstructiontype, occupancytype, postfirm, yearbuilt, zipcode, date, lossratio FROM address WHERE uid = :user_id ORDER BY date ASC", user_id=session["user_id"])
        return render_template("history.html", transactions=transactions)

    elif request.method == "POST":
        db.execute("DELETE FROM address WHERE uid = :user_id", user_id=session["user_id"])
        return render_template("history.html")

@app.route('/about', methods=["GET"])
@login_required
def about():
	return render_template("about.html")

@app.route('/input_information', methods=["GET"])
@login_required
def input_information():
	return render_template("info.html")



if __name__ == '__main__':
    port = int(os.environ.get("PORT", 33507))
    app.run(port=port)