Merge pull request #438 from mrduckspace/master

GPIO Control

CHANGELOG.md

@@ -3,6 +3,7 @@
 ### __[v2.4.4]__ - unreleased
 ##### Added
 - Divera-Plugin: Plugin zum Ansteuern der Divera-Api. [#415](https://github.com/Schrolli91/BOSWatch/pull/415)
+- GPIO-Control: Plugin zum Ansteuern der GPIO Pins. [#438](https://github.com/Schrolli91/BOSWatch/pull/438)
 ##### Changed
 - MySQL-Plugin: Index für die RIC Adresse hinzugefügt [#411](https://github.com/Schrolli91/BOSWatch/issues/411)
 - MySQL-Plugin: INSERT Befehl für MySQL 8.x angepasst, Spaltennamen escaped [#410](https://github.com/Schrolli91/BOSWatch/issues/410)

plugins/gpiocontrol/gpiocontrol.py

@@ -0,0 +1,118 @@
+#!/usr/bin/python
+# -*- coding: UTF-8 -*-
+
+"""
+
+@author: KS
+
+@requires: none
+"""
+
+# Imports
+
+import RPi.GPIO as GPIO
+import time
+import threading
+
+import logging # Global logger
+from includes import globalVars  # Global variables
+
+# Helper function, uncomment to use
+from includes.helper import timeHandler
+from includes.helper import wildcardHandler
+from includes.helper import configHandler
+
+##
+#
+# onLoad (init) function of plugin
+# will be called one time by the pluginLoader on start
+#
+def onLoad():
+	"""
+	While loading the plugins by pluginLoader.loadPlugins()
+	this onLoad() routine is called one time for initialize the plugin
+
+	@requires:  nothing
+
+	@return:    nothing
+	@exception: Exception if init has an fatal error so that the plugin couldn't work
+
+	"""
+	global GPIOPIN
+	global waitTime
+
+	GPIOPIN = globalVars.config.getint("gpiocontrol","pin")
+	waitTime = globalVars.config.getint("gpiocontrol","triggertime")
+
+	GPIO.setmode(GPIO.BCM)
+	GPIO.setwarnings(False)
+	GPIO.setup(GPIOPIN, GPIO.OUT)
+
+	#GPIO schalten beim START
+    	#GPIO.output(GPIOPIN, GPIO.LOW)
+	#time.sleep(1)
+
+	GPIO.output(GPIOPIN, GPIO.HIGH)
+
+	return
+
+#
+#
+# Main function of plugin
+# will be called by the alarmHandler
+#
+def run(typ,freq,data):
+	"""
+	@type    typ:  string (FMS|ZVEI|POC)
+	@param   typ:  Typ of the dataset
+	@type    data: map of data (structure see readme.md in plugin folder)
+	@param   data: Contains the parameter for dispatch
+	@type    freq: string
+	@keyword freq: frequency of the SDR Stick
+
+	@requires:  If necessary the configuration hast to be set in the config.ini.
+
+	@return:    nothing
+	@exception: nothing, make sure this function will never thrown an exception
+	"""
+	try:
+		if configHandler.checkConfig("gpiocontrol"): #read and debug the config (let empty if no config used)
+
+			logging.debug(globalVars.config.get("gpiocontrol", "pin"))
+			logging.debug(globalVars.config.get("gpiocontrol", "triggertime"))
+
+			########## User Plugin CODE ##########
+			if typ == "FMS":
+				th = threading.Thread(target = trigger)
+				th.start()
+				#logging.warning("%s not supported", typ)
+			elif typ == "ZVEI":
+				th = threading.Thread(target = trigger)
+				th.start()
+				#logging.warning("%s not supported", typ)
+			elif typ == "POC":
+				if globalVars.config.get("gpiocontrol", "activerics") == "":
+                    		th = threading.Thread(target = trigger)
+                    		th.start()
+              			else
+                 			if  data["ric"] in globalVars.config.get("gpiocontrol", "activerics"):
+                				th = threading.Thread(target = trigger)
+                    				th.start()
+                    			else:
+                        			logging.info("Ric not in activerics")
+			else:
+				logging.warning("Invalid Typ: %s", typ)
+			########## User Plugin CODE ##########
+
+	except:
+		logging.error("unknown error")
+		logging.debug("unknown error", exc_info=True)
+
+def trigger():
+	GPIO.output(GPIOPIN, GPIO.LOW)
+	logging.info("GPIOPIN %s angeschaltet", GPIOPIN)
+	time.sleep(waitTime)
+        GPIO.output(GPIOPIN, GPIO.HIGH)
+	logging.info("GPIOPIN %s ausgeschaltet", GPIOPIN)
+
+	return