app.py - main - sysadminrus/AtolPython

app.py
164 строки7 KB
sysadminrus
New functions
28 июн 2023, 15:45
28 июн 2023, 15:45b1f1662
from flask import Flask, flash, redirect, request, render_template
import kktfunc.kktfunctions as kkt
from sql.sqlfunc import *
from libfptr10 import IFptr
import json
from kktfunc.cashier import Cashier #Кассира из json в объект

app = Flask(__name__)

def returnedjson(success=True, descr=''):
    return json.dumps({'success': success,
                       'descr':descr}, ensure_ascii=False)

@app.route("/")
def hello():
    if request.method == 'POST':
        return request.form
    elif request.method == 'GET':
        return render_template('index.html')
    else:
        return True

@app.route("/settings", methods=['POST','GET'])
def settings():
    if request.method == 'POST':
        for i in request.form:
            current_settings = Settings.get_or_none(Settings.setting == i)
            if type(current_settings) == type(None):
                current_settings = Settings(setting = i, settingvalue = request.form[i])
                current_settings.save()
            else:
                current_settings.setting = i
                current_settings.settingvalue = request.form[i]
                current_settings.save()
        return render_template('settings.html', disabled = 'disabled')
    elif request.method == 'GET':
        current_settings = Settings.select().dicts()
        if len(current_settings) > 0:
            for current_setting in current_settings:
                if current_setting.get('setting') == 'LIBFPTR_SETTING_MODEL':
                    LIBFPTR_SETTING_MODEL = current_setting['settingvalue']
                elif current_setting.get('setting') == 'LIBFPTR_SETTING_PORT':
                    LIBFPTR_SETTING_PORT = current_setting['settingvalue']
                elif current_setting.get('setting') == 'LIBFPTR_SETTING_COM_FILE':
                    LIBFPTR_SETTING_COM_FILE = current_setting['settingvalue']
                elif current_setting.get('setting') == 'LIBFPTR_SETTING_BAUDRATE':
                    LIBFPTR_SETTING_BAUDRATE = current_setting['settingvalue']
                else:
                    print('Настройка которой не ждали')
                
            return render_template('settings.html', disabled = 'disabled', model=LIBFPTR_SETTING_MODEL,
                                   port = LIBFPTR_SETTING_PORT, com = LIBFPTR_SETTING_COM_FILE, baud = LIBFPTR_SETTING_BAUDRATE)
        else:
            return render_template('settings.html', disabled = 'disabled')
    else:
        return True

@app.route("/check", methods=['POST'])
def checkstatus():
    if request.content_type == 'application/x-www-form-urlencoded':
        settings = kkt.setkktsettingsfromform(request.form)
        initedkkt = kkt.initKKT(settings)
        return render_template('settings.html', **request.form, tested = initedkkt.get('succes'), error = initedkkt.get('descr'))
        
@app.route("/openShift", methods=['POST'])
def openShift():
    if request.content_type == 'application/x-www-form-urlencoded':
        initedkkt = kkt.initKKT(None)
        if initedkkt.get('succes'):
            driver = initedkkt.get('driver')
            shiftresult = kkt.openShift(None, driver)
            if shiftresult.get('succes'):
                driver.close()
                flash('Успешно открыта')
                return render_template('message.html')
            else:
                errorstring = f'Ошибка при открытии смены {shiftresult.get("descr")}'
                driver.close()
                flash(errorstring)
                return render_template('message.html')
    else:
        inpjson = request.json
        initedkkt = kkt.initKKT(None)
        if initedkkt.get('succes'):
            driver = initedkkt.get('driver')
            shiftresult = kkt.openShift(inpjson, driver)
            if shiftresult.get('succes'):
                driver.close()
                return returnedjson(True, '')
            else:
                errorstring = f'Ошибка при открытии смены {shiftresult.get("descr")}'
                driver.close()
                return returnedjson(True, errorstring)



@app.route("/closeShift", methods=['POST'])
def closeShift():
    if request.content_type == 'application/x-www-form-urlencoded':
        initedkkt = kkt.initKKT(None)
        if initedkkt.get('succes'):
            driver = initedkkt.get('driver')
            if driver.isOpened():
                result = kkt.closeShift(None, driver)
                if result.get('succes'):
                    driver.close()
                    flash('Успешно закрыта')
                    return render_template('message.html')
                else:
                    driver.close()
                    flash(f'Ошибка закрытия {result.get("descr")}')
                    return render_template('message.html')
            else:
                driver.close()
                flash("Смена уже закрыта")
                return render_template('message.html')
        else:
            flash(f'Ошибка инициализации драйвера {initedkkt.get("descr")}')
            return render_template('message.html')
    else:
        inpjson = request.json
        initedkkt = kkt.initKKT(None)
        if initedkkt.get('succes'):
            driver = initedkkt.get('driver')
            if driver.isOpened():
                result = kkt.closeShift(inpjson, driver)
                if result.get('succes'):
                    driver.close()
                    return returnedjson(True, '')
                else:
                    driver.close()
                    return returnedjson(False, result.get('descr'))
            else:
                driver.close()
                return returnedjson(True, 'Смена закрыта')
        else:
            return returnedjson(False, f'Ошибка инициализации драйвера {initedkkt.get("descr")}')
            
        
@app.route("/receipt", methods=['POST'])
def receipt(receiptData):
    kkt = kkt.initkkt(None)
    if kkt.isinstance(IFptr):
        pass
    else: #Возвращаем ошибку инциализации
        return kkt

@app.route("/statusShift", methods=['POST'])
def statusShift():
    initedkkt = kkt.initKKT(None)
    if initedkkt.get('succes'):
        driver = initedkkt.get('driver')
        shiftStatus = kkt.checkShift(driver)
        print(shiftStatus.get('descr'))
        
    else:
        return returnedjson(False, f'Ошибка инициализации драйвера {initedkkt.get("descr")}')
        

if __name__ == "__main__":
    sqlsettings = Settings()
    sqlsettings.create_table(safe=True)
    app.secret_key = 'hjaskjdhkjasdhjahdkhakjdhqwkhJHHKHY*(Y*Y*(*Y))'
    app.run(debug=False, port=5000, host="0.0.0.0")