appJuntaS3.py

from flask import Flask, jsonify, request, abort, redirect, url_for, render_template
import pymongo
import datetime
from datetime import timedelta
import jwt


app = Flask(__name__, template_folder='/opt/templates/')

config = {
    "username": "root",
    "password": "root",
    "host": "mongo",
    "port": 27017
}

connector = "mongodb://{username}:{password}@{host}:{port}/?authSource=admin".format(**config)
client = pymongo.MongoClient(connector)
db = client["PTIN"]
users = db["UsersA4"]
farmacs = db["MedsA4"]
sessio = db["sessio"]
camions = db ['Camions']


def checktoken(token):
    decoded_token = jwt.decode(token, 'mi_clave_secreta', algorithms=['HS256'])
    user_data = sessio.find_one({'token': token})
    if user_data is None:
        response = {'valid': 'None1'}
    else:
        user = users.find_one({'user_email': user_data['user_email']})
        if user is None:
            response = {'valid': 'None2'}
        elif datetime.datetime.now() <= (user_data['data'] + timedelta(minutes=5)):
            response = {'valid': 'ok', 'email': user['user_email'], 'type': user["user_role"]}
        else:
            response = {'valid': 'timeout'}
    return response

@app.route("/api")
def main():
    return render_template('main.html')


@app.route("/api/save", methods=['POST'])
def save():
    entry = {
        "name": request.form['name'],
        "email": request.form['email'],
        "id": request.form['idnum'],
        "when": datetime.datetime.now(),
    }
    res = users.insert_one(entry)
    users.create_index("id", unique=True)
    return render_template('main.html')

@app.route("/api/list", methods=['GET'])
def list_people():
    count = users.count_documents({})
    usuarios = users.find({})
    return render_template('list.html', count=count, usuarios=usuarios)

@app.route("/api/person/<idnum>", methods=['GET'])
def person(idnum):
    people = users.find_one({ 'id': idnum })
    if not people:
        abort(404)
    return render_template('person.html', person=people)


@app.errorhandler(404)
def not_found(error):
    app.logger.info(error)
    return redirect('404.html'), 404

@app.route("/api/get", methods=['POST'])
def get():
    name = request.form['name']
    doc = users.find_one({'name' : {'$regex': name}})
    if doc:
        app.logger.info(doc)
        return redirect(url_for('person', idnum=doc["id"]) )
    return render_template('main.html', error="Could not find that person")

@app.route("/api/login", methods=['POST'])
def prueba_login():
    data = request.get_json()
    user_email = data['user_email'] #username
    user_password = data['user_password'] #password
    doc = users.find_one({'user_email' : {'$regex': user_email}})
    if doc["user_email"]==user_email and doc["user_password"]==user_password:
        token = jwt.encode({'username': user_email}, 'mi_clave_secreta', algorithm='HS256')
        response = {'result': 'ok', 'user_given_name': doc["user_given_name"], 'user_role': doc["user_role"], 'user_picture': "https://picsum.photos/200", 'user_token': token}
######################################################Falta imatge
        entry = {
                "token": token,
                "data": datetime.datetime.now(),
                "user_email": user_email,
            }
        res = sessio.insert_one(entry)
        return jsonify(response)
    else:
        response = {'result': 'error', 'message': 'Credenciales inválidas'}
        return jsonify(response)


    
@app.route("/api/register", methods=['POST'])
def registrar():
    data = request.get_json()
    entry = {
        "user_full_name": data['user_full_name'],
        "user_given_name": data['user_given_name'],
        "user_role": "patient",
        "user_email": data['user_email'],
        "user_phone": data['user_phone'],
        "user_city": data['user_city'],
        "user_address":data['user_address'],
        "user_password": data['user_password'] ,
        "when": datetime.datetime.now(),
    }
    print(data['user_email'])
    try:
        id = users.insert_one(entry).inserted_id
        token = jwt.encode({'username': entry["user_email"]}, 'mi_clave_secreta', algorithm='HS256')
        response = {'result': 'ok', 'session_token': token}
    except pymongo.errors.DuplicateKeyError as description_error:
         response = {'result': 'error',
		     'description': str(description_error)}
    #response = {'result': 'ok'}
    return jsonify(response)

@app.route("/api/google", methods=['POST'])
def google():
    data = request.get_json()
    user_google = data['user_google_token']
###############################################################No es suficiente este token, falta info
    entry = {
            "user_full_name": data['user_full_name'],
            "user_given_name": data['user_given_name'],
            "user_email": data['user_email'],
            "user_phone": data['user_phone'],
            "user_city": data['user_city'],
            "user_address":data['user_address'],
            "user_password": data['user_password'] ,
            "when": datetime.datetime.now(),
    }
    try:
        id = users.insert_one(entry).inserted_id
        response = {'result': 'ok'}
#####################################################################################Falta token aquí, añadir en response
    except pymongo.errors.DuplicateKeyError as description_error:
         response = {'result': 'error',
		     'description': str(description_error)}
    #response = {'result': 'ok'}
    return jsonify(response)

@app.route("/api/list_available_medicines", methods=['POST']) #list_available_medicines", methods=['POST'])
def search_farmacs():
    data = request.get_json()
    query = {}
    if 'filter' in data:
        try:
            filter_data = data['filter']

#            if 'med_name' in filter_data:
#                query['med_name'] = {'$regex': filter_data['med_name']}

            if 'pvp_min' in filter_data:
                query['pvp'] = {'$gte': float(filter_data['pvp_min'])}

            if 'pvp_max' in filter_data:
                if 'pvp' in query:
                    query['pvp']['$lte'] = float(filter_data['pvp_max'])
                else:
                    query['pvp'] = {'$lte': float(filter_data['pvp_max'])}

            if 'prescription_needed' in filter_data:
                if 'True' in filter_data['prescription_needed']:
                    query['prescription_needed'] = {'$eq': True}
                if 'False' in filter_data['prescription_needed']:
                    query['prescription_needed'] = {'$eq': False}

            if 'form' in filter_data:
                query['form'] = {'$in': filter_data['form']}

            if 'type_of_administration' in filter_data:
                query['type_of_administration'] = {'$in': filter_data['type_of_administration']}

         # Determinem el número de medicaments per pàgina i la pàgina que es vol obtenir
            medNum = int(filter_data['meds_per_page'])
            page = int(filter_data['page'])

         # Calculem el límit inferior i superior de medicaments a obtenir segons la pàgina i el número de medicaments per pàgina
            limit_inf = (page - 1) * medNum
            limit_sup = limit_inf + medNum

    #     # Executem la query amb els límits especificats
            results = farmacs.find(query).limit(medNum).skip(limit_inf)
        except Exception as e:
            results = str(e)
# Si no es proporciona un filtre, es retornen tots els medicaments
    else:
        results = farmacs.find()
#    results = farmacs.find()
    return jsonify([{
        'med_name': doc['med_name'],
        'codi_nacional': doc['national_code'],
        'tipus_us': str(doc['use_type']) + '€',
        'administracio': doc['type_of_administration'],
        'req_recepta': doc['prescription_needed'],
        'preu': doc['pvp'],
        'presentacio': doc['form'],
        'prospecto': doc['excipients'],
        'form': doc['form'],
    } for doc in results])

 

@app.route("/api/has_prescription", methods=['POST'])
#medicaments solament
def has_prescription():
    data = request.get_json()
    value = checktoken(data['session_token'])
    response = {'value': value['valid']}
    if value['valid'] == 'ok':    
        med = data['medicine_identifier']
        query = {'national_code': med, 'req_recepta': True}
        prescription_needed = farmacs.find_one(query)
        if prescription_needed:
            prescription_given = False
    ####################################################################################################Hablar con DDBB para que hagan una tabla o algo en la que pueda ver si un cliente tiene un medicamento determinado recetado
        else:
            prescription_given = False
        response = {'result': 'falta comprovar prescription given', 'prescription_needed': prescription_needed["prescription_needed"], 'prescription_given': prescription_given}
    return jsonify(response)

@app.route("/api/checktoken", methods=['POST'])
def check_token():
    data = request.get_json()
    return checktoken(data['token'])

@app.route("/api/mqtt", methods=['POST'])
def msg():
    data = request.get_json()
    print(data)
    return data

@app.route("/api/cancel_patient_order", methods=['POST'])
def cancelar_ordres():
    data = request.get_json()
    value = checktoken(data['session_token'])
    response = {'value': value['valid']}
    if value['valid'] == 'ok': 
        order = data['order_identifier']
    response = {'result': ''}
    return jsonify(response)

@app.route("/api/cars_full_info", methods=['POST'])
def coche_full_info():

    data = request.get_json()
    value = checktoken(data['session_token'])
    response = {'value': value['valid']}
    
    if value['valid'] == 'ok':
        coches = camions.find()
        return jsonify([{
            'id_car': doc['id_car'],
            'license_plate': doc['license_plate'],
            'battery': doc['battery'],
            'status': doc['status'],
            'autonomy': doc['autonomy'],
            'capacity': doc['capacity'],
            'last_maintenance_date': doc['last_maintenance_date'],
            'packages': doc['packages'],
            'beehive': doc['beehive'],
            'location_in ': doc['beehive'],
            'location_act': doc['beehive'],
            'location_end': doc['beehive'],
        }for doc in coches])
    else:
        #response = {'value': 'hola'}
        return jsonify(response)

    
#-----------------------------------------------------------------