app.py

import socket
import os
import json
import time
import sqlite3

from sqlite3 import Error

from flask import Flask
from flask import Flask, redirect, request, jsonify, make_response, render_template, url_for, send_file
from miscale2 import miscale2
from PedoScore import ZScore
from Pedokom import pedokom
from threading import Thread, Event
from queue import Queue
from dbctl import apeksdbctl
from datetime import datetime

from multiprocessing import Process, Queue

import run

app = run.main()

busyo = 0
q = None
worker = None


try:
    Coms = pedokom.PedoKom('/dev/ttyUSB0', 9600, .1)
except:
    Coms = pedokom.PedoKom('/dev/ttyUSB1', 9600, .1)

def ThreadD(q):
    global busyo
    #if busyo == 1:
    #    time.sleep(3)
    
    tb = []
    #PingMe()
    busyo =1
    #Coms = pedokom.PedoKom('/dev/ttyUSB0', 9600, .1)
    #jangan lupa IMT
    
    data = q.get()
    print(data)
    print("MULAI JALAN")
    #Coms.SendCommand("pesan1;Ukur Berat Badan", 0)
    Coms.SendCommand("pesan2;Measuring...", 0)

    #HOST = '127.0.0.1'  # The server's hostname or IP address
    #PORT = 65433        # The port used by the server

    #with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    #    s.connect((HOST, PORT))
    #    s.sendall(b'miscale2.noimpedance')
    #    data = s.recv(1024)

    data_ = miscale2.mainV()
    print("BERAT: ", data_)

    Berat = float(data_["Berat"])

    #time.sleep(3)
    #Coms.SendCommand("pesan1;Mengukur Tinggi")
    #Coms.SendCommand("pesan2;Tegakkan Badan")
    isBaby = False
    if 'baby' in jk.lower():
        isBaby = True
        jk = jk.lower().replace('baby', "")

    if isBaby:
        tinggi = Coms.SendCommand("tinggi1;50",2)["Response"].split(",")
    else:
        tinggi = Coms.SendCommand("tinggi;210",2)["Response"].split(",")

    temp = tinggi[0:len(tinggi)-1]
    temp2 = []
    for i in temp:
        temp2.append(float(i))

    Tinggi = max(temp2)
    #Tinggi = max(tb) #float(Coms.SendCommand("tinggi")["Response"])
    print("TINGGI: ", Tinggi)

    #time.sleep(3)

    print("JSON: ", data)
    try:
        usia = round(float(data.get("usia",0))*12) #convert year to month
    except:
        usia = 61
    
    try:
        jk = str(data.get('kelamin', "no"))
    except:
        jk = "no"

    try:
        nama = str(data.get("namaa", "jondoe"))
    except:
        nama = "john doe"

    Gender = ""

    if jk.lower() == "boy":
        Gender = "M"
    else:
        Gender = "F"

    zee = ""

    #Convert it using age gap
    if usia <= 60:
        zimt = ZScore.ZScore(usia, Berat, Gender)
        zee = "Stunting Indicator" #"Z-Score"
    elif usia > 60:
        zimt = ZScore.IMT(Berat, Tinggi/100)
        zee = "Stunting Indicator" #"BMI (Body Mass Index)"

    #For Historical
    """
    if usia == 0 and jk == "no":
        zimt = ZScore.IMT(Berat, Tinggi/100)
        zee = "Stunting Indicator" #"BMI (Body Mass Index)"
    else:
        zimt = ZScore.ZScore(usia, Berat, Gender)
        zee = "Stunting Indicator" #"Z-Score"
    """

    resp = {"zimt": zimt, "tinggi": str(Tinggi)+" CM", "berat": str(Berat), "Pesan": zee}

    #Nama is not added Yet (HTML NOT ADDED YET)
    now = datetime.now()
    waktu = str(now.strftime("%d/%m/%Y %H:%M:%S"))
    db_ = apeksdbctl.create_connection('apeks.db')
    apeksdbctl.AddData(db_, [str(nama), str(jk), str(usia/12), str(waktu), str(Berat), str(Tinggi), str(zimt['Status'])])
    
    Coms.SendCommand("pesanx;Tinggi: " + str(Tinggi) + "CM?" + "Berat: " + str(Berat) + "KG", 0)
    q.put_nowait(resp)
    os.remove("measure.run")
    #q.task_done()

    #Coms.SendCommand("pesanx;Go WebWifi?=>apeks.net<=")

@app.route('/', methods=["GET"])
def index():
    global q, worker, busyo
    #return render_template('index.html')
    if os.path.exists("measure.run"):
        Coms.SendCommand("pesanx;    Welcome?Waiting Input...", 0)
        print("[DEBUG] Busy State Terminate...")
        os.remove("measure.run")
        worker.terminate()
        busyo = 0

    return render_template('index.html')

def PingMe():
    #time.sleep(2)
    asu = Coms.SendCommand("yuhu", 2)
    if 'uth3re?' in asu["Response"]:
        Coms.SendCommand("metoo", 0)
    print(asu)

@app.route('/purge', methods=["POST"])
def Purge():
    db_ = apeksdbctl.create_connection("apeks.db")
    apeksdbctl.PurgeData(db_)
    return "ok"

@app.route('/sane', methods=["GET", "POST"])
def Sane():
    global busyo
    print("BUSY STATE = ", busyo)
    if busyo == 1:
        return "ok"
    else:
        return "ok"

@app.route('/admin', methods=["GET", "POST"])
def Admin():
    db_ = apeksdbctl.create_connection('apeks.db')
    datas = apeksdbctl.LoadDatas(db_)
    return render_template("admin.html", data=datas)

@app.route('/clear', methods=["GET", "POST"])
def bersih():
    global busyo

    if os.path.exists("measure.run"):
        print("[DEBUG] Busy State Terminate...")
        os.remove("measure.run")
        worker.terminate()
        busyo = 0

    Coms.SendCommand("pesanx;Go WebWifi?>_<")
    Coms.SendCommand("pesanx;    Welcome?Waiting Input...")
    busyo = 0
    return "ok"

@app.route('/measure', methods=["GET", "POST"])
def measure():
    global q, worker, busyo
    
    if os.path.exists("measure.run") and busyo == 1:
        print("[DEBUG] Busy State Terminate...")
        os.remove("measure.run")
        worker.terminate()

    busyo = 1
    q = Queue(maxsize=0)
    data = request.get_json(force=True)
    
    with open("measure.run", 'w') as f:
        f.write("1")

    worker = Process(target=ThreadD, args=(q,))
    worker.daemon = True
    worker.start()
    
    q.put(data)
    
    while os.path.exists("measure.run"):
        time.sleep(2)
    #worker.join()

    resp = q.get()
    busyo = 0
    return make_response(jsonify(resp), 200)

if __name__ == '__main__':
    apeksdbctl.DbInit()
    app.run(host='0.0.0.0', port=5050, debug=True)