Skip to content

Commit 1066cbe

Browse files
author
Ferhat Aslan
committed
feat: New named project and working state
1 parent 21f144f commit 1066cbe

18 files changed

Lines changed: 341 additions & 616 deletions

connections/rs232Connection.py renamed to connections/fileConnection.py

Lines changed: 18 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1,29 +1,33 @@
11
import time
22
import threading
3-
import serial
43
import parameter
4+
import glob
55

6-
class Rs232Connection(threading.Thread):
6+
class FileConnection(threading.Thread):
77

88
exit = True
99
stop = True
1010

11-
try:
12-
__ser = serial.Serial(
13-
port='/dev/ttyS0', # Open RPI buit-in serial port
14-
baudrate=9600,
15-
parity=serial.PARITY_NONE,
16-
stopbits=serial.STOPBITS_ONE,
17-
bytesize=serial.EIGHTBITS,
18-
timeout=1
19-
)
20-
except:
21-
print ("RS232-Port could not be opened!")
2211

2312
def __init__(self):
2413
threading.Thread.__init__(self)
14+
15+
#base_dir = '/sys/bus/w1/devices/'
16+
#while True:
17+
# try:
18+
# self.device_folder = glob.glob(base_dir + '28*')[0]
19+
# break
20+
# except IndexError:
21+
# sleep(0.5)
22+
# continue
23+
#self.device_file = self.device_folder + '/w1_slave'
24+
25+
# To initialise, the sensor will be read "blind"
26+
#read_temp_raw(self.device_file)
27+
28+
2529
if parameter.printMessages:
26-
print("init rs232")
30+
print("init file connection")
2731
threading.Thread.start(self)
2832

2933
def run(self):
@@ -48,7 +52,6 @@ def setStart(self):
4852

4953
def setExit(self):
5054
self.exit = False
51-
self.__ser.close
5255

5356
def __exit__(self):
5457
pass

‎connections/gbioRPIConnection.py‎

Lines changed: 0 additions & 51 deletions
This file was deleted.

‎connections/gpsConnection.py‎

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
import time
2+
import threading
3+
import gps
4+
import parameter
5+
6+
class GpsConnection(threading.Thread):
7+
8+
exit = True
9+
stop = True
10+
11+
def __init__(self):
12+
13+
threading.Thread.__init__(self)
14+
15+
#Please set your gps connection init code
16+
17+
if parameter.printMessages:
18+
print("init gps")
19+
threading.Thread.start(self)
20+
21+
def run(self):
22+
#self.lock.acquire()
23+
while self.exit:#threat wird erst beendet wenn aus while schleife herausgeganen wird
24+
if self.stop:
25+
self.request()
26+
time.sleep(parameter.timeTriggerGps)
27+
#self.lock.release()
28+
29+
def request(self):
30+
pass
31+
32+
def setStop(self):
33+
self.stop = False
34+
35+
def setStart(self):
36+
self.stop = True
37+
38+
def setExit(self):
39+
self.exit = False
40+
41+

‎connections/i2cAdafruitConnection.py‎

Lines changed: 0 additions & 56 deletions
This file was deleted.

‎connections/internetConnection.py‎

Lines changed: 108 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,108 @@
1+
import time
2+
import threading
3+
import parameter
4+
import datetime
5+
6+
from observer import observe
7+
8+
class WeatherServer(threading.Thread):
9+
exit = True
10+
stop = True
11+
12+
def __init__(self):
13+
14+
try:
15+
threading.Thread.__init__(self)
16+
threading.Thread.start(self)
17+
18+
except:
19+
print("Weather thread can not start!")
20+
21+
def run(self):
22+
while self.exit:
23+
if self.stop:
24+
self.request()
25+
time.sleep(parameter.timeTriggerMeterbus)
26+
27+
def request(self):
28+
pass
29+
30+
31+
# set function here, do not forget the self
32+
33+
def setStop(self):
34+
self.stop = False
35+
36+
def setStart(self):
37+
self.stop = True
38+
39+
def setExit(self):
40+
self.exit = False
41+
42+
def __exit__(self):
43+
pass
44+
45+
46+
class CloudConnection(threading.Thread, observe.Observable):
47+
48+
exit = True
49+
stop = True
50+
messageServer = "NO CLOUD CONNECTION!"
51+
feedback = "Ready to get feedback!"
52+
53+
def __init__(self):
54+
55+
observe.Observable.__init__(self)
56+
threading.Thread.__init__(self)
57+
58+
threading.Thread.start(self)
59+
60+
def run(self):
61+
while self.exit:
62+
if self.stop:
63+
self.notify_observersMonitoring()
64+
time.sleep(parameter.timeTriggerSendData)
65+
self.sendAllData()
66+
67+
def setIP(self, host):
68+
self.host = host
69+
70+
def getIP(self):
71+
return "123456"
72+
73+
def sendAllData(self):
74+
75+
datetimeCloud = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
76+
message = "'{}' ('TimeStamp', {}) VALUES ('{}', {})".format(parameter.systemIdentifier, self.getHeaderList(), datetimeCloud , self.getDataList())
77+
78+
try:
79+
#inside "message" you have all information about weather gps and tem sensor
80+
# it a string
81+
print (message)
82+
self.messageServer = "WITH IoT-CLOUD CONNECTED!"
83+
#print("SERVER CONNECTED!")
84+
except:
85+
if parameter.printMessages:
86+
print ("Please switch mount USB-Internetstick!")
87+
self.messageServer = "NO CLOUD CONNECTED!"
88+
89+
90+
# set your fkt here! do not forget self
91+
def setStop(self):
92+
self.stop = False
93+
94+
def setStart(self):
95+
self.stop = True
96+
97+
def setExit(self):
98+
self.exit = False
99+
100+
def getMessageServer(self):
101+
return self.messageServer
102+
103+
def getFeedback(self):
104+
return self.feedback
105+
106+
107+
def __exit__(self):
108+
self.messageServer = "NO SERVER CONNECTED!"

0 commit comments

Comments
 (0)