-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathDiscourse-AmpelBot.py
319 lines (262 loc) · 13.2 KB
/
Discourse-AmpelBot.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
# Discourse_null7b
# Autor: Richarde
# Script zum Update eines Discourse-Forum-Posts via User "Ampel-Bot"
# wird mindestens einer von 3 Eingängen geschaltet, geht die Ampel auf Grün
# ist kein Eingang High, geht die Ampel auf Rot
# Version 1.1 vom 04.08.2021
#
# GPIO.input(5) = grün = Sicherung F7 - Dj Rot Std. (Dj-Pult)
# GPIO.input(24) = grün/weiß = Sicherung F13 - Kasse
# GPIO.input(25) = braun = Sicherung F15 - Bar Theke
#
###############################################################################
# ChangeLog:
###############################################################################
# Version 1.0 - 21.07.2021
# Richarde
# Initiale Version
###############################################################################
# Version 1.1 - 04.08.2021
# Richarde
# - Logikumkehr: Es soll ein Eingang am Raspi auf Masse geschaltet werden, wenn
# eine der überwachten Sicherungen eingeschalten wird, somit keine falschen
# Schaltvorgänge durch Induktionsspannungen (Schaltpegel 3,3 V ist sehr klein)
# - Schaltverzögerung von 2 Sekunden um jedes Prellen der Schalter zu vermeiden
###############################################################################
# Version 1.2 - 07.09.2021
# Richarde
# - interne Vorwiderstände aufschalten
###############################################################################
# Version 1.3 - 11.09.2021
# Richarde
# einzelne Auswertung der Sicherungen zusätzlich zum Hallenstatus
###############################################################################
# Version 1.31 - 11.09.2021
# Richarde
# Bugfixes
###############################################################################
# Version 1.32 - 13.09.2021
# Richarde
# Bugfixes
###############################################################################
# Version 1.33 - 14.10.2021
# Richarde
# Exception Handling DiscourseClient eingefügt
###############################################################################
# Version 1.34 - 18.12.2021
# Richarde
# Code Redundanzen entfernen
###############################################################################
# Version 1.35 - 06.01.2024
# Richarde
# Bug entfernt das in wenigen Konstellationen die Ampelzeit falsch aktualisiert wurde
#
# Version 1.4 könnte eine Kommunikation an ein Service-Postfach etablieren
# oder eine Nachricht im Forum fortschreiben welche Fehler oder ander Logs trackt
###############################################################################
# Version 1.36 - 22.01.2024
# Bugfix
# Richarde
# added Return Parameter in new method check_input
###############################################################################
# benötigte Bibliotheken für das Projekt einbinden
from pydiscourse import DiscourseClient
import RPi.GPIO as GPIO
import datetime
import pytz
import constants
import time
import locale
# Klassendefinition
class null7b:
# CLASSDATA
__instance = None # Singleton
# CONSTANTS
ROT = 'rot'
GRN = 'grn'
AN = 'an'
AUS = 'aus'
def __new__(cls):
if not null7b.__instance:
null7b.__instance = object.__new__(null7b)
return cls.__instance
def __init__(self):
self.ampel_status = self.ROT
self.f7_forum = 'xxx'
self.f13_forum = 'xxx'
self.f15_forum = 'xxx' #somit wird bei Programmstart immer ein Post abgesetzt
self.zone_ber = pytz.timezone('Europe/Berlin')
self.date_ber = datetime.datetime.now(self.zone_ber)
self.format = "%a %d.%m.%Y - %H:%M:%S"
self.datetimestring_ampel = self.date_ber.strftime(self.format)
self.datetimestring_f7 = self.date_ber.strftime(self.format)
self.datetimestring_f13 = self.date_ber.strftime(self.format)
self.datetimestring_f15 = self.date_ber.strftime(self.format)
if GPIO.input(5):
self.f7_dj = self.AUS
else:
self.f7_dj = self.AN
if GPIO.input(24):
self.f13_kasse = self.AUS
else:
self.f13_kasse = self.AN
if GPIO.input(25):
self.f15_bar_theke_licht = self.AUS
else:
self.f15_bar_theke_licht = self.AN
def check_input(self, c_fuse, i_GPIO): # i_fuse = self.f15_bar_theke_licht i_GPIO = 25
if c_fuse == self.AN: #Sicherung ist an
l_count = 0
while l_count < 4: #4 Durchgänge
l_count = l_count + 1
time.sleep(0.5) #besser 4x schauen als 1x, verringert das Risiko einer Fehlbetätigung bei flatternden Zuständen nochmals
if GPIO.input(i_GPIO) and l_count == 4: #Sicherung ist 2 Sekunden lang aus
# ok, getting serious... switch it!
c_fuse = self.AUS
if GPIO.input(i_GPIO): #Sicherung ist aus
continue # next iteration
else: #Sicherung ist an
break # leave while
elif c_fuse == self.AUS: #Sicherung ist aus
l_count = 0
while l_count < 4: #4 Durchgänge
l_count = l_count + 1
time.sleep(0.5) #besser 4x schauen als 1x, verringert das Risiko einer Fehlbetätigung bei flatternden Zuständen nochmals
if not GPIO.input(i_GPIO) and l_count == 4: #Sicherung ist 2 Sekunden lang an
# ok, getting serious... switch it!
c_fuse = self.AN
if not GPIO.input(i_GPIO): #Sicherung ist an
continue # next iteration
else: #Sicherung ist aus
break # leave while
return c_fuse # return updated status
def trigger_ampel_update(self, datetimestring_change):
if ( self.f7_dj == self.AN or self.f13_kasse == self.AN or self.f15_bar_theke_licht == self.AN ) and self.ampel_status == self.ROT: #Änderung Ampel rot -> grün
self.datetimestring_ampel = datetimestring_change
self.ampel_status = self.GRN
self.update_ampel( self.ampel_status )
elif self.f7_dj == self.AUS and self.f13_kasse == self.AUS and self.f15_bar_theke_licht == self.AUS and self.ampel_status == self.GRN: #Änderung Ampel grün -> rot
self.datetimestring_ampel = datetimestring_change
self.ampel_status = self.ROT
self.update_ampel( self.ampel_status )
elif ( self.f7_dj == self.AN or self.f13_kasse == self.AN or self.f15_bar_theke_licht == self.AN ) and self.ampel_status == self.GRN: #Ampel ist und bleibt grün
self.update_ampel( self.ampel_status )
elif self.f7_dj == self.AUS and self.f13_kasse == self.AUS and self.f15_bar_theke_licht == self.AUS and self.ampel_status == self.ROT: #Ampel ist und bleibt rot
self.update_ampel( self.ampel_status )
def get_datetimestring(self):
l_zone_ber = pytz.timezone('Europe/Berlin')
l_date_ber = datetime.datetime.now(l_zone_ber)
l_format = "%a %d.%m.%Y - %H:%M:%S"
l_ts_string = l_date_ber.strftime(l_format)
return l_ts_string
def update_ampel(self, i_setze_auf):
l_err = True #Fehlermerker #+ Version 1.33 - 14.10.2021
l_content_red = constants.content_red.replace("<datetimestring_ampel>", self.datetimestring_ampel)
l_content_red = l_content_red.replace("<datetimestring_f7>", self.datetimestring_f7)
l_content_red = l_content_red.replace("<datetimestring_f13>", self.datetimestring_f13)
l_content_red = l_content_red.replace("<datetimestring_f15>", self.datetimestring_f15)
l_content_red = l_content_red.replace("<F7>", self.f7_dj)
l_content_red = l_content_red.replace("<F13>", self.f13_kasse)
l_content_red = l_content_red.replace("<F15>", self.f15_bar_theke_licht)
l_content_grn = constants.content_grn.replace("<datetimestring_ampel>", self.datetimestring_ampel)
l_content_grn = l_content_grn.replace("<datetimestring_f7>", self.datetimestring_f7)
l_content_grn = l_content_grn.replace("<datetimestring_f13>", self.datetimestring_f13)
l_content_grn = l_content_grn.replace("<datetimestring_f15>", self.datetimestring_f15)
l_content_grn = l_content_grn.replace("<F7>", self.f7_dj)
l_content_grn = l_content_grn.replace("<F13>", self.f13_kasse)
l_content_grn = l_content_grn.replace("<F15>", self.f15_bar_theke_licht)
l_client = DiscourseClient(
constants.forum_address,
api_username = constants.api_username,
api_key = constants.api_key,)
#>>>> Version 1.33 - 14.10.2021
if i_setze_auf == self.GRN:
while l_err == True:
try:
l_client.update_post( constants.post_id, l_content_grn, constants.edit_reason )
l_err = False
except :
l_err = True
time.sleep(30)
elif i_setze_auf == self.ROT:
while l_err == True:
try:
l_client.update_post( constants.post_id, l_content_red, constants.edit_reason )
l_err = False
except :
l_err = True
time.sleep(30)
#<<<< Version 1.33 - 14.10.2021
def main(self):
l_count = 1
while True: #running forever
# Gerüst vorerst für 3 Eingänge (5, 24, 25), kann aber auf bis zu 17 erweitert werden
#F7 prüfen
self.f7_dj = self.check_input(self.f7_dj, 5)
#F13 prüfen
self.f13_kasse = self.check_input(self.f13_kasse, 24)
#F15 prüfen
self.f15_bar_theke_licht = self.check_input(self.f15_bar_theke_licht, 25)
#Hat sich was geändert?
# 3 Änderungen
if self.f7_dj != self.f7_forum and self.f13_kasse != self.f13_forum and self.f15_bar_theke_licht != self.f15_forum:
self.datetimestring_f7 = self.get_datetimestring()
self.datetimestring_f13 = self.datetimestring_f7
self.datetimestring_f15 = self.datetimestring_f7
self.f7_forum = self.f7_dj
self.f13_forum = self.f13_kasse
self.f15_forum = self.f15_bar_theke_licht
self.trigger_ampel_update(self.datetimestring_f7)
# 2 Änderungen F7 & F13
elif self.f7_dj != self.f7_forum and self.f13_kasse != self.f13_forum:
self.datetimestring_f7 = self.get_datetimestring()
self.datetimestring_f13 = self.datetimestring_f7
self.f7_forum = self.f7_dj
self.f13_forum = self.f13_kasse
self.trigger_ampel_update(self.datetimestring_f7)
# 2 Änderungen F7 & F15
elif self.f7_dj != self.f7_forum and self.f15_bar_theke_licht != self.f15_forum:
self.datetimestring_f7 = self.get_datetimestring()
self.datetimestring_f15 = self.datetimestring_f7
self.f7_forum = self.f7_dj
self.f15_forum = self.f15_bar_theke_licht
self.trigger_ampel_update(self.datetimestring_f7)
# 2 Änderungen F13 & F15
elif self.f13_kasse != self.f13_forum and self.f15_bar_theke_licht != self.f15_forum:
self.datetimestring_f13 = self.get_datetimestring()
self.datetimestring_f15 = self.datetimestring_f13
self.f13_forum = self.f13_kasse
self.f15_forum = self.f15_bar_theke_licht
self.trigger_ampel_update(self.datetimestring_f13)
# 1 Änderungen F7
elif self.f7_dj != self.f7_forum:
self.datetimestring_f7 = self.get_datetimestring()
self.f7_forum = self.f7_dj
self.trigger_ampel_update(self.datetimestring_f7)
# 1 Änderung F13
elif self.f13_kasse != self.f13_forum:
self.datetimestring_f13 = self.get_datetimestring()
self.f13_forum = self.f13_kasse
self.trigger_ampel_update(self.datetimestring_f13)
# 1 Änderung F15
elif self.f15_bar_theke_licht != self.f15_forum:
self.datetimestring_f15 = self.get_datetimestring()
self.f15_forum = self.f15_bar_theke_licht
self.trigger_ampel_update(self.datetimestring_f15)
#keine Änderungen
#else:
#do nothing, der Post ist gut so wie er ist...
# Forums-posts können nicht zu schnell hintereinander geändert werden
# ohne Wartezeit kann es zu Fehlern kommen
time.sleep(10) #10 Sekunden warten... (kaum noch notwendig, da die 3x 4 Runden schon 6 Sekunden dauern) - aber Schadet auch nix :-)
############################################################################################
#Start Program
# Umstellung auf Deutsch für Wochentagsausgabe im Datumstring
locale.setlocale(locale.LC_ALL, 'de_DE.utf8')
#SetUp GPIO PINs as Input
GPIO.setmode(GPIO.BCM) # GPIO Nummerierung statt Pin Nummerierung
GPIO.setup(5, GPIO.IN, pull_up_down=GPIO.PUD_UP ) # set GPIO 5 as input
GPIO.setup(24, GPIO.IN, pull_up_down=GPIO.PUD_UP ) # set GPIO 24 as input
GPIO.setup(25, GPIO.IN, pull_up_down=GPIO.PUD_UP ) # set GPIO 25 as input
g_null7b = null7b()
g_null7b.main()