lorawan/python/adeunisrf.py

108 lines
2.7 KiB
Python
Raw Normal View History

#!/usr/bin/env python3
# Send lora packet to node-red when being triggered by postgresql
# Nico Schottelius <nico.schottelius -at- ungleich.ch>
# 2016-11-02
# GPLv3+
import binascii
2016-11-12 16:48:33 +00:00
import lorautil
2016-11-12 17:14:59 +00:00
import logging
import sys
# L A T I T U D E L O N G I TU DE
# status temp deg min sec +hem deg min min min
# 9e 17 46 58 204 0 009 02 320 a5 9a 0e e7
# 1 2 3 4 5 6 ? 8 9 10 11 12 13 14
# on display: 46 58 122N 09 02 207E
# 46.58 204 09.02 320
# sodaq: lat=46.9699219 lon=9.0391764
# google: 46.969943, 9.038999
2016-11-12 17:14:37 +00:00
log = logging.getLogger("adeunis")
log.setLevel(logging.DEBUG)
2016-11-12 17:14:37 +00:00
known_devices = [ "0018B20000000C58", "0018B20000000C37", "0018B20000000C59", "0018B20000000CD0" ]
def convert_gps_from_stdin():
for line in sys.stdin:
res = get_gps("", line)
if res:
print(res[0][1:])
def get_gps(deveui, payload):
res = []
2016-11-12 16:52:29 +00:00
if not int(payload[0:2], 16) & (2**7):
return res
2016-11-12 17:14:37 +00:00
try:
lat_deg = float(payload[4:6])
lat_min = float(payload[6:8])
2016-11-13 08:49:57 +00:00
lat_sec = float(payload[8:11])
# lat_frac_sec = float(payload[10:11])
# lat = lat_deg + lat_min/60.0 + lat_sec/3600.0 + lat_frac_sec/36000.0
lat = lat_deg + lat_min/60.0 + lat_sec/60000.0
2016-11-12 17:14:37 +00:00
2016-11-12 19:01:34 +00:00
lon_deg = float(payload[12:15])
lon_min = float(payload[15:17])
2016-11-13 08:49:57 +00:00
lon_sec = float(payload[17:20])
# lon_frac_sec = float(payload[19:20])
# lon = lon_deg + lon_min/60.0 + lon_sec/3600.0 + lon_frac_sec/36000.0
lon = lon_deg + lon_min/60.0 + lon_sec/60000.0
2016-11-12 19:01:34 +00:00
pos = ":lat={:.6f} lon={:.6f}".format(lat, lon)
2016-11-12 17:38:14 +00:00
res = [ deveui + pos ]
2016-11-12 17:14:37 +00:00
except ValueError as e:
2016-11-12 17:38:14 +00:00
log.error("GPS decode error: {}:{} {}".format(deveui, payload, e))
return res
2016-11-13 08:49:57 +00:00
# sodaq : lat=46.9924235 lon=9.0734456
# garmin: 46 59.548 -- 9 04.360
# adeunis: 46 59 539 -- 9 04 350
def get_temp(deveui, payload):
res = []
2016-11-12 16:52:29 +00:00
if int(payload[0:2], 16) & (2**7):
res = [ deveui + ":temperature=" + str(binascii.a2b_hex(payload)[1])]
return res
def decode_adeunis(pkg):
data = pkg.split(":")
deveui = data[0]
payload = data[1]
res = []
# Only handle known devices
if not deveui in known_devices:
return res
res += get_temp(deveui, payload)
res += get_gps(deveui, payload)
2016-11-12 16:54:53 +00:00
return res
def nodered_adeunisrf(provider, data):
res = decode_adeunis(data)
if not res:
return
2016-11-12 16:56:20 +00:00
for d in res:
lorautil.nodered_send(provider, d)
if __name__ == '__main__':
conns = lorautil.pg_conn_notify()
while True:
2016-11-12 16:49:03 +00:00
lorautil.pg_wait_for_pkg(conns, nodered_adeunisrf)