pyPLC/pyPlcWorker.py

129 lines
5.5 KiB
Python
Raw Normal View History

# Worker for the pyPLC
#
2022-11-30 19:28:59 +00:00
# Tested on
# - Windows10 with python 3.9 and
# - Raspbian with python 3.9
#
#------------------------------------------------------------
import pyPlcHomeplug
import fsmEvse
import fsmPev
from pyPlcModes import *
2022-11-11 10:21:28 +00:00
import addressManager
import time
2022-11-30 19:28:59 +00:00
import subprocess
2022-12-06 17:35:17 +00:00
import hardwareInterface
import connMgr
2022-11-11 10:21:28 +00:00
class pyPlcWorker():
2022-11-16 18:33:37 +00:00
def __init__(self, callbackAddToTrace=None, callbackShowStatus=None, mode=C_EVSE_MODE, isSimulationMode=0):
print("initializing pyPlcWorker")
self.nMainFunctionCalls=0
self.mode = mode
self.strUserAction = ""
2022-11-11 10:21:28 +00:00
self.addressManager = addressManager.addressManager()
self.callbackAddToTrace = callbackAddToTrace
self.callbackShowStatus = callbackShowStatus
2022-11-15 18:36:20 +00:00
self.oldAvlnStatus = 0
2022-11-16 18:33:37 +00:00
self.isSimulationMode = isSimulationMode
self.connMgr = connMgr.connMgr(self.workerAddToTrace, self.showStatus)
self.hp = pyPlcHomeplug.pyPlcHomeplug(self.workerAddToTrace, self.showStatus, self.mode, self.addressManager, self.connMgr, self.isSimulationMode)
2023-02-13 20:34:13 +00:00
self.hardwareInterface = hardwareInterface.hardwareInterface(self.workerAddToTrace, self.showStatus)
2022-11-22 20:34:27 +00:00
self.hp.printToUdp("pyPlcWorker init")
2022-11-30 19:28:59 +00:00
# Find out the version number, using git.
# see https://stackoverflow.com/questions/14989858/get-the-current-git-hash-in-a-python-script
try:
strLabel = str(subprocess.check_output(["git", "describe", "--tags"], text=True).strip())
except:
strLabel = "(unknown version. 'git describe --tags' failed.)"
self.workerAddToTrace("[pyPlcWorker] Software version " + strLabel)
if (self.mode == C_EVSE_MODE):
2023-02-13 20:34:13 +00:00
self.evse = fsmEvse.fsmEvse(self.addressManager, self.workerAddToTrace, self.hardwareInterface, self.showStatus)
if (self.mode == C_PEV_MODE):
self.pev = fsmPev.fsmPev(self.addressManager, self.connMgr, self.workerAddToTrace, self.hardwareInterface, self.showStatus)
def __del__(self):
if (self.mode == C_PEV_MODE):
try:
del(self.pev)
except:
pass
2022-11-22 20:34:27 +00:00
def workerAddToTrace(self, s):
# The central logging function. All logging messages from the different parts of the project
# shall come here.
#print("workerAddToTrace " + s)
self.callbackAddToTrace(s) # give the message to the upper level, eg for console log.
self.hp.printToUdp(s) # give the message to the udp for remote logging.
def showStatus(self, s, selection = "", strAuxInfo1="", strAuxInfo2=""):
2023-02-13 20:34:13 +00:00
self.callbackShowStatus(s, selection)
if (selection == "pevState"):
self.hardwareInterface.showOnDisplay(s, strAuxInfo1, strAuxInfo2)
2022-11-15 18:36:20 +00:00
def handleTcpConnectionTrigger(self):
if (self.mode == C_PEV_MODE) and (self.connMgr.getConnectionLevel()==50) and (self.oldAvlnStatus==0):
2022-11-22 20:34:27 +00:00
self.workerAddToTrace("[PLCWORKER] Network is established, ready for TCP.")
self.oldAvlnStatus = 1
self.pev.reInit()
return
if (self.connMgr.getConnectionLevel()<50):
2022-11-15 18:36:20 +00:00
self.oldAvlnStatus = 0
def mainfunction(self):
self.nMainFunctionCalls+=1
2022-10-14 21:36:03 +00:00
#self.showStatus("pyPlcWorker loop " + str(self.nMainFunctionCalls))
self.connMgr.mainfunction()
self.handleTcpConnectionTrigger()
2022-12-06 17:35:17 +00:00
self.hp.mainfunction() # call the lower-level workers
self.hardwareInterface.mainfunction()
if (self.mode == C_EVSE_MODE):
if (self.nMainFunctionCalls>8*33): # ugly. Wait with EVSE high level handling, until the modem restarted.
self.evse.mainfunction() # call the evse state machine
if (self.mode == C_PEV_MODE):
self.pev.mainfunction() # call the pev state machine
def handleUserAction(self, strAction):
self.strUserAction = strAction
2022-12-19 17:09:39 +00:00
print("user action " + strAction)
if (strAction == "P"):
print("switching to PEV mode")
self.mode = C_PEV_MODE
if (hasattr(self, 'evse')):
print("deleting evse")
del self.evse
self.hp.enterPevMode()
if (not hasattr(self, 'pev')):
print("creating pev")
2022-12-19 17:09:39 +00:00
self.pev = fsmPev.fsmPev(self.addressManager, self.workerAddToTrace, self.hardwareInterface, self.callbackShowStatus)
self.pev.reInit()
if (strAction == "E"):
print("switching to EVSE mode")
self.mode = C_EVSE_MODE
if (hasattr(self, 'pev')):
print("deleting pev")
del self.pev
self.hp.enterEvseMode()
if (not hasattr(self, 'evse')):
print("creating fsmEvse")
2022-11-22 20:34:27 +00:00
self.evse = fsmEvse.fsmEvse(self.workerAddToTrace)
self.evse.reInit()
if (strAction == "L"):
print("switching to LISTEN mode")
self.mode = C_LISTEN_MODE
2022-10-24 21:19:45 +00:00
self.hp.enterListenMode()
if (hasattr(self, 'evse')):
print("deleting evse")
del self.evse
if (hasattr(self, 'pev')):
print("deleting pev")
del self.pev
2022-12-19 17:09:39 +00:00
if (strAction == "space"):
print("stopping the charge process")
if (hasattr(self, 'pev')):
self.pev.stopCharging()
2022-10-24 21:19:45 +00:00
# self.addToTrace("UserAction " + strAction)
2022-10-16 00:57:57 +00:00
self.hp.sendTestFrame(strAction)