import bge # Bibliothèque Blender Game Engine (UPBGE)
import twin_threading # Multithreading (multitâches)
from twin_serial import jumeau, jumeau_stop, serial_close # Liaison série
from twin_daq import get, daq, csv_generate, plot, plot_generate # Acquisition des données
import time

###############################################################################
# montchg_lib.py
# @title: Bibliothèque utilisateur du monte-charge
# @project: Blender-EduTech
# @lang: fr
# @authors: Philippe Roy <philippe.roy@ac-grenoble.fr>
# @copyright: Copyright (C) 2022-2023 Philippe Roy
# @license: GNU GPL
###############################################################################

# Récupérer la scène UPBGE
scene = bge.logic.getCurrentScene()

# UPBGE constants
JUST_ACTIVATED = bge.logic.KX_INPUT_JUST_ACTIVATED
JUST_RELEASED = bge.logic.KX_INPUT_JUST_RELEASED
ACTIVATE = bge.logic.KX_INPUT_ACTIVE
# JUST_DEACTIVATED = bge.logic.KX_SENSOR_JUST_DEACTIVATED

# Threads de commandes
threads_cmd=[]

# Threads de visualisation de données
threads_plot=[]

###############################################################################
# Voyants
###############################################################################

# Ordre pour allumer le voyant niveau 0
def voy_0 (order):
    scene.objects['Led niveau 0']['activated']=order

# Ordre pour allumer le voyant niveau 1
def voy_1 (order):
    scene.objects['Led niveau 1']['activated']=order

###############################################################################
# Actionneurs
###############################################################################

# Ordre pour le moteur phase monter
def mot_m (order):
    scene.objects['Moteur']['up']=order
    
# Ordre pour le moteur phase descendre
def mot_d (order):
    scene.objects['Moteur']['down']=order

# Réglage de la vitesse du moteur numérique
def mot_digitset (speed=None):
    if speed==None:
        scene.objects['Moteur']['speed_setting']=31.4 # Vitesse du moteur numérique : 31,4 rad /s ( 5 tr / s )
    else:
        scene.objects['Moteur']['speed_setting']=speed

###############################################################################
# Capteurs
###############################################################################

# Compte-rendu du capteur de présence cabine niveau 0
def pc_0 ():
    if scene.objects['Microrupteur niveau 0']['activated'] or scene.objects['Microrupteur niveau 0']['activated_real']:
        return True
    else:
        return False

# Compte-rendu du capteur de présence cabine niveau 0
def pc_1 ():
    if scene.objects['Microrupteur niveau 1']['activated'] or scene.objects['Microrupteur niveau 1']['activated_real']:
        return True
    else:
        return False

###############################################################################
# Boutons poussoirs
###############################################################################

# Compte-rendu du bouton pousssoir appel niveau 0 
def ba_0 ():
    if scene.objects['Bp niveau 0']['activated'] or scene.objects['Bp niveau 0']['activated_real']:
        return True
    else:
        return False

# Compte-rendu du bouton pousssoir appel niveau 1 
def ba_1 ():
    if scene.objects['Bp niveau 1']['activated'] or scene.objects['Bp niveau 1']['activated_real']:
        return True
    else:
        return False

###############################################################################
# Cycle
###############################################################################

##
# Temporisation
##

def tempo (duree):
    time.sleep(duree)

##
# t (temps)
##

def get_t ():
    # return truncate(scene.objects['System']['time'], 3)
    return round(scene.objects['System']['time'], 3)

def set_t (date):
    scene.objects['System']['time']=date

def reset_t ():
    scene.objects['System']['time']=0

##
# Départ
##

def start(fct):
    twin_threading.start(threads_cmd, "commands", fct)

##
# Arrêt
##

def stop():
   
    # Jumeau
    if scene.objects['System']['twins']:
        serial_close(scene.objects['System']['board'])
        time.sleep(1)

    # Suivi de données
    if scene.objects['System']['daq']:
        csv_generate()
    if scene.objects['System']['plot']:
        plot_generate(threads_plot)

    # Thread
    twin_threading.stop(threads_cmd, "commands")

##
# Fin naturelle
##

def end():
    fin()

def fin():
    if scene.objects['System']['debug_thread']:
        print ("Thread commands is arrived.")
    time.sleep(0.125)
    scene.objects['System']['thread_cmd']=False
    time.sleep(0.125)