Compare commits
No commits in common. "c4610358f1e411beae2a54bd743486e6b78b2691" and "6b95624b3ec6630550fe30e093c2f1f38bf38605" have entirely different histories.
c4610358f1
...
6b95624b3e
12
Dockerfile
12
Dockerfile
|
|
@ -1,12 +0,0 @@
|
|||
FROM golang:alpine AS builder
|
||||
WORKDIR /build
|
||||
ADD go.mod .
|
||||
COPY . .
|
||||
RUN go build
|
||||
FROM alpine
|
||||
RUN apk add --no-cache tzdata
|
||||
ENV TZ=Europe/Zurich
|
||||
WORKDIR /build
|
||||
COPY --from=builder /build/mini-beieli-lorahandler /build/mini-beieli-lorahandler
|
||||
CMD ["./mini-beieli-lorahandler"]
|
||||
EXPOSE 8080
|
||||
5
go.mod
5
go.mod
|
|
@ -1,5 +0,0 @@
|
|||
module nbit.ch/mini-beieli-lorahandler/v2
|
||||
|
||||
go 1.17
|
||||
|
||||
require github.com/gomodule/redigo v1.8.9
|
||||
12
go.sum
12
go.sum
|
|
@ -1,12 +0,0 @@
|
|||
github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
|
||||
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
|
||||
github.com/gomodule/redigo v1.8.9 h1:Sl3u+2BI/kk+VEatbj0scLdrFhjPmbxOc1myhDP41ws=
|
||||
github.com/gomodule/redigo v1.8.9/go.mod h1:7ArFNvsTjH8GMMzB4uy1snslv2BwmginuMs06a1uzZE=
|
||||
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
|
||||
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
|
||||
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
|
||||
github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY=
|
||||
github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
|
||||
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
|
||||
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo=
|
||||
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
|
||||
587
main.go
587
main.go
|
|
@ -11,7 +11,6 @@ import (
|
|||
"log"
|
||||
"net/http"
|
||||
"os"
|
||||
"strconv"
|
||||
"strings"
|
||||
"time"
|
||||
)
|
||||
|
|
@ -20,7 +19,7 @@ const (
|
|||
MyDB = "beieliscaledb"
|
||||
username = "beieli"
|
||||
password = "beieli4president"
|
||||
outputfile = "/data/mini-beieli-lorahandler.log"
|
||||
outputfile = "/home/beieli/mini-beieli-lorahandler/mini-beieli-lorahandler.log"
|
||||
NOT_PLAUSIBLE_16 = 65535
|
||||
NOT_PLAUSIBLE_32 = 2147483647
|
||||
)
|
||||
|
|
@ -214,298 +213,270 @@ func DecodePayload(s string, deveui string, devaddr string, lrrlat float32, lrrl
|
|||
pl_130 = payload_130{}
|
||||
br := bytes.NewReader(ba)
|
||||
fmt.Printf("Payload String: %s\n", s)
|
||||
if len(s) > 2 {
|
||||
if s[0:2] == "01" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_1)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else if s[0:2] == "02" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_2)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else if s[0:2] == "80" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_128)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else if s[0:2] == "81" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_129)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else if s[0:2] == "82" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_130)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else {
|
||||
fmt.Printf("Payload String is unknown: %s\n", s)
|
||||
if s[0:2] == "01" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_1)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
if s[0:2] == "01" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_1.Version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_1.Vbat)
|
||||
fmt.Printf(" offset: %d\n", pl_1.O)
|
||||
fmt.Printf(" humidity: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_1.H1, pl_1.H2, pl_1.H3, pl_1.H4, pl_1.H5, pl_1.H6, pl_1.H7, pl_1.H8)
|
||||
fmt.Printf(" pressure: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_1.P1, pl_1.P2, pl_1.P3, pl_1.P4, pl_1.P5, pl_1.P6, pl_1.P7, pl_1.P8)
|
||||
fmt.Printf(" weight: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_1.W1, pl_1.W2, pl_1.W3, pl_1.W4, pl_1.W5, pl_1.W6, pl_1.W7, pl_1.W8)
|
||||
fmt.Printf(" temp: %d,\n", pl_1.T)
|
||||
fmt.Printf(" temp_change: [%d,%d,%d,%d,%d,%d,%d],\n", pl_1.TC1, pl_1.TC2, pl_1.TC3, pl_1.TC4, pl_1.TC5, pl_1.TC6, pl_1.TC7)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of first Packet
|
||||
var tfp = (time.Now().Unix() / 60) - int64(pl_1.O)
|
||||
humidity_values := []uint8{pl_1.H1, pl_1.H2, pl_1.H3, pl_1.H4, pl_1.H5, pl_1.H6, pl_1.H7, pl_1.H8}
|
||||
valid_measurements := 0
|
||||
for _, v := range humidity_values {
|
||||
if v > 0 {
|
||||
valid_measurements = valid_measurements + 1
|
||||
}
|
||||
}
|
||||
fmt.Printf("Valid Measurements: %d,\n", valid_measurements)
|
||||
var step int64
|
||||
if valid_measurements > 1 {
|
||||
step = int64(int(pl_1.O) / (valid_measurements - 1))
|
||||
}
|
||||
|
||||
// the first temperature is usually too high (maybe becaus of lorawan send, so we take
|
||||
// the second measurement as first..., the same for humidity, which is usually too low...
|
||||
t := pl_1.T
|
||||
t = t + int16(pl_1.TC1)
|
||||
if valid_measurements > 0 {
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_1.Vbat, pl_1.H1, pl_1.P1, pl_1.W1, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
//t = t + int16(pl_1.TC1)
|
||||
if valid_measurements > 1 {
|
||||
WriteDatapoint(tfp+(step), deveui, devaddr, 0, pl_1.H2, pl_1.P2, pl_1.W2, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC2)
|
||||
if valid_measurements > 2 {
|
||||
WriteDatapoint(tfp+(2*step), deveui, devaddr, 0, pl_1.H3, pl_1.P3, pl_1.W3, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC3)
|
||||
if valid_measurements > 3 {
|
||||
WriteDatapoint(tfp+(3*step), deveui, devaddr, 0, pl_1.H4, pl_1.P4, pl_1.W4, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC4)
|
||||
if valid_measurements > 4 {
|
||||
WriteDatapoint(tfp+(4*step), deveui, devaddr, 0, pl_1.H5, pl_1.P5, pl_1.W5, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC5)
|
||||
if valid_measurements > 5 {
|
||||
WriteDatapoint(tfp+(5*step), deveui, devaddr, 0, pl_1.H6, pl_1.P6, pl_1.W6, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC6)
|
||||
if valid_measurements > 6 {
|
||||
WriteDatapoint(tfp+(6*step), deveui, devaddr, 0, pl_1.H7, pl_1.P7, pl_1.W7, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC7)
|
||||
if valid_measurements > 7 {
|
||||
WriteDatapoint(tfp+(7*step), deveui, devaddr, 0, pl_1.H8, pl_1.P8, pl_1.W8, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
}
|
||||
} else if s[0:2] == "02" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_2.Version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_2.Vbat)
|
||||
fmt.Printf(" offset: %d\n", pl_2.O)
|
||||
fmt.Printf(" weight: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_2.W1, pl_2.WC1, pl_2.WC2, pl_2.WC3, pl_2.WC4, pl_2.WC5, pl_2.WC6, pl_2.W8)
|
||||
fmt.Printf(" temp: %d,\n", pl_2.T)
|
||||
fmt.Printf(" temp_change: [%d,%d,%d,%d,%d,%d,%d],\n", pl_2.TC1, pl_2.TC2, pl_2.TC3, pl_2.TC4, pl_2.TC5, pl_2.TC6, pl_2.TC7)
|
||||
fmt.Printf(" humidity: %d\n", pl_2.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_2.P)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of first Packet
|
||||
var tfp = (time.Now().Unix() / 60) - int64(pl_2.O)
|
||||
temp_change_values := []int8{pl_2.TC1, pl_2.TC2, pl_2.TC3, pl_2.TC4, pl_2.TC5, pl_2.TC6, pl_2.TC7}
|
||||
valid_measurements := 1
|
||||
for _, v := range temp_change_values {
|
||||
if v < 127 {
|
||||
valid_measurements = valid_measurements + 1
|
||||
}
|
||||
}
|
||||
fmt.Printf("Valid Measurements: %d,\n", valid_measurements)
|
||||
var step int64
|
||||
if valid_measurements > 1 {
|
||||
step = int64(int(pl_2.O) / (valid_measurements - 1))
|
||||
}
|
||||
|
||||
// the first temperature is usually too high (maybe becaus of lorawan send, so we take
|
||||
// the second measurement as first...
|
||||
t := pl_2.T
|
||||
w := pl_2.W1
|
||||
t = t + int16(pl_2.TC1)
|
||||
if valid_measurements > 0 {
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_2.Vbat, pl_2.H, pl_2.P, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
//t = t + int16(pl_2.TC1)
|
||||
if valid_measurements == 2 {
|
||||
w = pl_2.W8
|
||||
} else {
|
||||
w = w + uint16(pl_2.WC1)
|
||||
}
|
||||
if valid_measurements > 1 {
|
||||
WriteDatapoint(tfp+(step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC2)
|
||||
if valid_measurements == 3 {
|
||||
w = pl_2.W8
|
||||
} else {
|
||||
w = w + uint16(pl_2.WC2)
|
||||
}
|
||||
if valid_measurements > 2 {
|
||||
WriteDatapoint(tfp+(2*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC3)
|
||||
if valid_measurements == 4 {
|
||||
w = pl_2.W8
|
||||
} else {
|
||||
w = w + uint16(pl_2.WC3)
|
||||
}
|
||||
if valid_measurements > 3 {
|
||||
WriteDatapoint(tfp+(3*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC4)
|
||||
if valid_measurements == 5 {
|
||||
w = pl_2.W8
|
||||
} else {
|
||||
w = w + uint16(pl_2.WC4)
|
||||
}
|
||||
if valid_measurements > 4 {
|
||||
WriteDatapoint(tfp+(4*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC5)
|
||||
if valid_measurements == 6 {
|
||||
w = pl_2.W8
|
||||
} else {
|
||||
w = w + uint16(pl_2.WC5)
|
||||
}
|
||||
if valid_measurements > 5 {
|
||||
WriteDatapoint(tfp+(5*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC6)
|
||||
if valid_measurements == 7 {
|
||||
w = pl_2.W8
|
||||
} else {
|
||||
w = w + uint16(pl_2.WC6)
|
||||
}
|
||||
if valid_measurements > 6 {
|
||||
WriteDatapoint(tfp+(6*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC7)
|
||||
w = pl_2.W8
|
||||
if valid_measurements > 7 {
|
||||
WriteDatapoint(tfp+(7*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
}
|
||||
} else if s[0:2] == "80" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_128.Version)
|
||||
fmt.Printf(" fw_version: %d,\n", pl_128.Fw_version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_128.Vbat)
|
||||
fmt.Printf(" humidity: %d\n", pl_128.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_128.P)
|
||||
fmt.Printf(" weight1: %d\n", pl_128.W1)
|
||||
fmt.Printf(" weight2: %d\n", pl_128.W2)
|
||||
fmt.Printf(" cal_1_0: %d\n", pl_128.W1_0)
|
||||
fmt.Printf(" cal_2_0: %d\n", pl_128.W2_0)
|
||||
fmt.Printf(" cal_1_C: %f\n", pl_128.W1_C)
|
||||
fmt.Printf(" cal_2_C: %f\n", pl_128.W2_C)
|
||||
fmt.Printf(" temp: %d\n", pl_128.T)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of Packet received
|
||||
var tfp = (time.Now().Unix() / 60)
|
||||
|
||||
// we calculate the weight...
|
||||
var w32 int32
|
||||
var w uint16
|
||||
w1_0_real := pl_128.W1_0
|
||||
w2_0_real := pl_128.W2_0
|
||||
w32 = int32(((float64(pl_128.W1-w1_0_real) / float64(pl_128.W1_C)) + (float64(pl_128.W2-w2_0_real) / float64(pl_128.W2_C))) / 5.0)
|
||||
if w32 < 0 {
|
||||
w = 0
|
||||
} else if w32 > 65535 {
|
||||
// this is not realistic (>320 kg), we set this to 0 as well...
|
||||
w = 0
|
||||
} else {
|
||||
w = uint16(w32)
|
||||
}
|
||||
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_128.Vbat, pl_128.H, pl_128.P, w, pl_128.W1, pl_128.W2, pl_128.T, lrrlat, lrrlon, pl_128.Fw_version, pl_128.W1_0, pl_128.W2_0, pl_128.W1_C, pl_128.W2_C)
|
||||
}
|
||||
ProcessInitPacket(deveui, pl_128.W1_0, pl_128.W2_0, pl_128.W1_C, pl_128.W2_C, pl_128.W1, pl_128.W2)
|
||||
} else if s[0:2] == "81" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_129.Version)
|
||||
fmt.Printf(" fw_version: %d,\n", pl_129.Fw_version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_129.Vbat)
|
||||
fmt.Printf(" humidity: %d\n", pl_129.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_129.P)
|
||||
fmt.Printf(" weight1: %d\n", pl_129.W1)
|
||||
fmt.Printf(" weight2: %d\n", pl_129.W2)
|
||||
fmt.Printf(" weight: %d\n", pl_129.W)
|
||||
fmt.Printf(" temp: %d\n", pl_129.T)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of Packet received
|
||||
var tfp = (time.Now().Unix() / 60)
|
||||
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_129.Vbat, pl_129.H, pl_129.P, pl_129.W, pl_129.W1, pl_129.W2, pl_129.T, lrrlat, lrrlon, pl_129.Fw_version, 0, 0, 0, 0)
|
||||
}
|
||||
} else if s[0:2] == "82" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_130.Version)
|
||||
fmt.Printf(" fw_version: %d,\n", pl_130.Fw_version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_130.Vbat)
|
||||
fmt.Printf(" weight1: %d\n", pl_130.W1)
|
||||
fmt.Printf(" weight2: %d\n", pl_130.W2)
|
||||
fmt.Printf(" cal_1_0: %d\n", pl_130.W1_0)
|
||||
fmt.Printf(" cal_2_0: %d\n", pl_130.W2_0)
|
||||
fmt.Printf(" cal_1_C: %f\n", pl_130.W1_C)
|
||||
fmt.Printf(" cal_2_C: %f\n", pl_130.W2_C)
|
||||
fmt.Printf(" temp: %d\n", pl_130.T)
|
||||
fmt.Printf(" humidity: %d\n", pl_130.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_130.P)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of Packet received
|
||||
var tfp = (time.Now().Unix() / 60)
|
||||
|
||||
// we calculate the weight...
|
||||
var w32 int32
|
||||
var w uint16
|
||||
w1_0_real := pl_130.W1_0
|
||||
w2_0_real := pl_130.W2_0
|
||||
w32 = int32(((float64(pl_130.W1-w1_0_real) / float64(pl_130.W1_C)) + (float64(pl_130.W2-w2_0_real) / float64(pl_130.W2_C))) / 5.0)
|
||||
if w32 < 0 {
|
||||
w = 0
|
||||
} else if w32 > 65535 {
|
||||
// this is not realistic (>320 kg), we set this to 0 as well...
|
||||
w = 0
|
||||
} else {
|
||||
w = uint16(w32)
|
||||
}
|
||||
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_130.Vbat, pl_130.H, pl_130.P, w, pl_130.W1, pl_130.W2, pl_130.T, lrrlat, lrrlon, pl_130.Fw_version, pl_130.W1_0, pl_130.W2_0, pl_130.W1_C, pl_130.W2_C)
|
||||
}
|
||||
} else if s[0:2] == "02" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_2)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
// Send alert if necessary
|
||||
if val, ok := alertMap[deveui]; ok {
|
||||
sendAlert(deveui, val)
|
||||
delete(alertMap, deveui)
|
||||
// alte Werte loeschen
|
||||
deleteValues(deveui)
|
||||
} else if s[0:2] == "80" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_128)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
if val2, ok2 := alertLogMap[deveui]; ok2 {
|
||||
WriteStringToFile(val2, deveui, false)
|
||||
delete(alertLogMap, deveui)
|
||||
} else if s[0:2] == "81" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_129)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else if s[0:2] == "82" {
|
||||
err := binary.Read(br, binary.LittleEndian, &pl_130)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
}
|
||||
} else {
|
||||
fmt.Printf("Payload String is not longer that 2 chars, ignore it\n")
|
||||
fmt.Printf("Payload String is unknown: %s\n", s)
|
||||
}
|
||||
if s[0:2] == "01" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_1.Version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_1.Vbat)
|
||||
fmt.Printf(" offset: %d\n", pl_1.O)
|
||||
fmt.Printf(" humidity: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_1.H1, pl_1.H2, pl_1.H3, pl_1.H4, pl_1.H5, pl_1.H6, pl_1.H7, pl_1.H8)
|
||||
fmt.Printf(" pressure: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_1.P1, pl_1.P2, pl_1.P3, pl_1.P4, pl_1.P5, pl_1.P6, pl_1.P7, pl_1.P8)
|
||||
fmt.Printf(" weight: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_1.W1, pl_1.W2, pl_1.W3, pl_1.W4, pl_1.W5, pl_1.W6, pl_1.W7, pl_1.W8)
|
||||
fmt.Printf(" temp: %d,\n", pl_1.T)
|
||||
fmt.Printf(" temp_change: [%d,%d,%d,%d,%d,%d,%d],\n", pl_1.TC1, pl_1.TC2, pl_1.TC3, pl_1.TC4, pl_1.TC5, pl_1.TC6, pl_1.TC7)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of first Packet
|
||||
var tfp = (time.Now().Unix() / 60) - int64(pl_1.O)
|
||||
humidity_values := []uint8{pl_1.H1, pl_1.H2, pl_1.H3, pl_1.H4, pl_1.H5, pl_1.H6, pl_1.H7, pl_1.H8}
|
||||
valid_measurements := 0
|
||||
for _, v := range humidity_values {
|
||||
if v > 0 {
|
||||
valid_measurements = valid_measurements + 1
|
||||
}
|
||||
}
|
||||
fmt.Printf("Valid Measurements: %d,\n", valid_measurements)
|
||||
var step int64
|
||||
if valid_measurements > 1 {
|
||||
step = int64(int(pl_1.O) / (valid_measurements - 1))
|
||||
}
|
||||
|
||||
// the first temperature is usually too high (maybe becaus of lorawan send, so we take
|
||||
// the second measurement as first..., the same for humidity, which is usually too low...
|
||||
t := pl_1.T
|
||||
t = t + int16(pl_1.TC1)
|
||||
if valid_measurements > 0 {
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_1.Vbat, pl_1.H1, pl_1.P1, pl_1.W1, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
//t = t + int16(pl_1.TC1)
|
||||
if valid_measurements > 1 {
|
||||
WriteDatapoint(tfp+(step), deveui, devaddr, 0, pl_1.H2, pl_1.P2, pl_1.W2, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC2)
|
||||
if valid_measurements > 2 {
|
||||
WriteDatapoint(tfp+(2*step), deveui, devaddr, 0, pl_1.H3, pl_1.P3, pl_1.W3, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC3)
|
||||
if valid_measurements > 3 {
|
||||
WriteDatapoint(tfp+(3*step), deveui, devaddr, 0, pl_1.H4, pl_1.P4, pl_1.W4, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC4)
|
||||
if valid_measurements > 4 {
|
||||
WriteDatapoint(tfp+(4*step), deveui, devaddr, 0, pl_1.H5, pl_1.P5, pl_1.W5, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC5)
|
||||
if valid_measurements > 5 {
|
||||
WriteDatapoint(tfp+(5*step), deveui, devaddr, 0, pl_1.H6, pl_1.P6, pl_1.W6, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC6)
|
||||
if valid_measurements > 6 {
|
||||
WriteDatapoint(tfp+(6*step), deveui, devaddr, 0, pl_1.H7, pl_1.P7, pl_1.W7, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_1.TC7)
|
||||
if valid_measurements > 7 {
|
||||
WriteDatapoint(tfp+(7*step), deveui, devaddr, 0, pl_1.H8, pl_1.P8, pl_1.W8, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
}
|
||||
} else if s[0:2] == "02" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_2.Version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_2.Vbat)
|
||||
fmt.Printf(" offset: %d\n", pl_2.O)
|
||||
fmt.Printf(" weight: [%d,%d,%d,%d,%d,%d,%d,%d],\n", pl_2.W1, pl_2.WC1, pl_2.WC2, pl_2.WC3, pl_2.WC4, pl_2.WC5, pl_2.WC6, pl_2.W8)
|
||||
fmt.Printf(" temp: %d,\n", pl_2.T)
|
||||
fmt.Printf(" temp_change: [%d,%d,%d,%d,%d,%d,%d],\n", pl_2.TC1, pl_2.TC2, pl_2.TC3, pl_2.TC4, pl_2.TC5, pl_2.TC6, pl_2.TC7)
|
||||
fmt.Printf(" humidity: %d\n", pl_2.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_2.P)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of first Packet
|
||||
var tfp = (time.Now().Unix() / 60) - int64(pl_2.O)
|
||||
temp_change_values := []int8{pl_2.TC1, pl_2.TC2, pl_2.TC3, pl_2.TC4, pl_2.TC5, pl_2.TC6, pl_2.TC7}
|
||||
valid_measurements := 1
|
||||
for _, v := range temp_change_values {
|
||||
if v < 127 {
|
||||
valid_measurements = valid_measurements + 1
|
||||
}
|
||||
}
|
||||
fmt.Printf("Valid Measurements: %d,\n", valid_measurements)
|
||||
var step int64
|
||||
if valid_measurements > 1 {
|
||||
step = int64(int(pl_2.O) / (valid_measurements - 1))
|
||||
}
|
||||
|
||||
// the first temperature is usually too high (maybe becaus of lorawan send, so we take
|
||||
// the second measurement as first...
|
||||
t := pl_2.T
|
||||
w := pl_2.W1
|
||||
t = t + int16(pl_2.TC1)
|
||||
if valid_measurements > 0 {
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_2.Vbat, pl_2.H, pl_2.P, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
//t = t + int16(pl_2.TC1)
|
||||
w = w + uint16(pl_2.WC1)
|
||||
if valid_measurements > 1 {
|
||||
WriteDatapoint(tfp+(step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC2)
|
||||
w = w + uint16(pl_2.WC2)
|
||||
if valid_measurements > 2 {
|
||||
WriteDatapoint(tfp+(2*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC3)
|
||||
w = w + uint16(pl_2.WC3)
|
||||
if valid_measurements > 3 {
|
||||
WriteDatapoint(tfp+(3*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC4)
|
||||
w = w + uint16(pl_2.WC4)
|
||||
if valid_measurements > 4 {
|
||||
WriteDatapoint(tfp+(4*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC5)
|
||||
w = w + uint16(pl_2.WC5)
|
||||
if valid_measurements > 5 {
|
||||
WriteDatapoint(tfp+(5*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC6)
|
||||
w = w + uint16(pl_2.WC6)
|
||||
if valid_measurements > 6 {
|
||||
WriteDatapoint(tfp+(6*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
t = t + int16(pl_2.TC7)
|
||||
w = pl_2.W8
|
||||
if valid_measurements > 7 {
|
||||
WriteDatapoint(tfp+(7*step), deveui, devaddr, 0, 1, 0, w, 0, 0, t, lrrlat, lrrlon, 0, 0, 0, 0, 0)
|
||||
}
|
||||
}
|
||||
} else if s[0:2] == "80" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_128.Version)
|
||||
fmt.Printf(" fw_version: %d,\n", pl_128.Fw_version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_128.Vbat)
|
||||
fmt.Printf(" humidity: %d\n", pl_128.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_128.P)
|
||||
fmt.Printf(" weight1: %d\n", pl_128.W1)
|
||||
fmt.Printf(" weight2: %d\n", pl_128.W2)
|
||||
fmt.Printf(" cal_1_0: %d\n", pl_128.W1_0)
|
||||
fmt.Printf(" cal_2_0: %d\n", pl_128.W2_0)
|
||||
fmt.Printf(" cal_1_C: %f\n", pl_128.W1_C)
|
||||
fmt.Printf(" cal_2_C: %f\n", pl_128.W2_C)
|
||||
fmt.Printf(" temp: %d\n", pl_128.T)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of Packet received
|
||||
var tfp = (time.Now().Unix() / 60)
|
||||
|
||||
// we calculate the weight...
|
||||
var w32 int32
|
||||
var w uint16
|
||||
w1_0_real := pl_128.W1_0
|
||||
w2_0_real := pl_128.W2_0
|
||||
w32 = int32(((float64(pl_128.W1-w1_0_real) / float64(pl_128.W1_C)) + (float64(pl_128.W2-w2_0_real) / float64(pl_128.W2_C))) / 5.0)
|
||||
if w32 < 0 {
|
||||
w = 0
|
||||
} else if w32 > 65535 {
|
||||
// this is not realistic (>320 kg), we set this to 0 as well...
|
||||
w = 0
|
||||
} else {
|
||||
w = uint16(w32)
|
||||
}
|
||||
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_128.Vbat, pl_128.H, pl_128.P, w, pl_128.W1, pl_128.W2, pl_128.T, lrrlat, lrrlon, pl_128.Fw_version, pl_128.W1_0, pl_128.W2_0, pl_128.W1_C, pl_128.W2_C)
|
||||
}
|
||||
ProcessInitPacket(deveui, pl_128.W1_0, pl_128.W2_0, pl_128.W1_C, pl_128.W2_C, pl_128.W1, pl_128.W2)
|
||||
} else if s[0:2] == "81" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_129.Version)
|
||||
fmt.Printf(" fw_version: %d,\n", pl_129.Fw_version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_129.Vbat)
|
||||
fmt.Printf(" humidity: %d\n", pl_129.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_129.P)
|
||||
fmt.Printf(" weight1: %d\n", pl_129.W1)
|
||||
fmt.Printf(" weight2: %d\n", pl_129.W2)
|
||||
fmt.Printf(" weight: %d\n", pl_129.W)
|
||||
fmt.Printf(" temp: %d\n", pl_129.T)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of Packet received
|
||||
var tfp = (time.Now().Unix() / 60)
|
||||
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_129.Vbat, pl_129.H, pl_129.P, pl_129.W, pl_129.W1, pl_129.W2, pl_129.T, lrrlat, lrrlon, pl_129.Fw_version, 0, 0, 0, 0)
|
||||
}
|
||||
} else if s[0:2] == "82" {
|
||||
fmt.Printf("{\n")
|
||||
fmt.Printf(" version: %d,\n", pl_130.Version)
|
||||
fmt.Printf(" fw_version: %d,\n", pl_130.Fw_version)
|
||||
fmt.Printf(" vbat: %d,\n", pl_130.Vbat)
|
||||
fmt.Printf(" weight1: %d\n", pl_130.W1)
|
||||
fmt.Printf(" weight2: %d\n", pl_130.W2)
|
||||
fmt.Printf(" cal_1_0: %d\n", pl_130.W1_0)
|
||||
fmt.Printf(" cal_2_0: %d\n", pl_130.W2_0)
|
||||
fmt.Printf(" cal_1_C: %f\n", pl_130.W1_C)
|
||||
fmt.Printf(" cal_2_C: %f\n", pl_130.W2_C)
|
||||
fmt.Printf(" temp: %d\n", pl_130.T)
|
||||
fmt.Printf(" humidity: %d\n", pl_130.H)
|
||||
fmt.Printf(" pressure: %d\n", pl_130.P)
|
||||
fmt.Printf("}\n")
|
||||
if write2file {
|
||||
// Time of Packet received
|
||||
var tfp = (time.Now().Unix() / 60)
|
||||
|
||||
// we calculate the weight...
|
||||
var w32 int32
|
||||
var w uint16
|
||||
w1_0_real := pl_130.W1_0
|
||||
w2_0_real := pl_130.W2_0
|
||||
w32 = int32(((float64(pl_130.W1-w1_0_real) / float64(pl_130.W1_C)) + (float64(pl_130.W2-w2_0_real) / float64(pl_130.W2_C))) / 5.0)
|
||||
if w32 < 0 {
|
||||
w = 0
|
||||
} else if w32 > 65535 {
|
||||
// this is not realistic (>320 kg), we set this to 0 as well...
|
||||
w = 0
|
||||
} else {
|
||||
w = uint16(w32)
|
||||
}
|
||||
|
||||
WriteDatapoint(tfp, deveui, devaddr, pl_130.Vbat, pl_130.H, pl_130.P, w, pl_130.W1, pl_130.W2, pl_130.T, lrrlat, lrrlon, pl_130.Fw_version, pl_130.W1_0, pl_130.W2_0, pl_130.W1_C, pl_130.W2_C)
|
||||
}
|
||||
}
|
||||
// Send alert if necessary
|
||||
if val, ok := alertMap[deveui]; ok {
|
||||
sendAlert(deveui, val)
|
||||
delete(alertMap, deveui)
|
||||
// alte Werte loeschen
|
||||
deleteValues(deveui)
|
||||
}
|
||||
if val2, ok2 := alertLogMap[deveui]; ok2 {
|
||||
WriteStringToFile(val2, deveui, false)
|
||||
delete(alertLogMap, deveui)
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -545,7 +516,7 @@ func WriteDatapoint(mytime int64, deveui string, devaddr string, v uint8, h uint
|
|||
s = fmt.Sprintf("measurement,deveui=%s devaddr=\"%s\",%sh=%di,p=%di,w=%di,t=%.1f,lrrlat=%f,lrrlon=%f%s %d\n", deveui, devaddr, sv, h, int32(p)+825, uint32(w)*5, float32(t)/10, lrrlat, lrrlon, sfw, mytime*60*1000*1000*1000)
|
||||
}
|
||||
|
||||
implausible = (w1 == NOT_PLAUSIBLE_32) || (w2 == NOT_PLAUSIBLE_32) || (w == NOT_PLAUSIBLE_16) || (w == 0)
|
||||
implausible = (w1 == NOT_PLAUSIBLE_32) || (w2 == NOT_PLAUSIBLE_32) || (w == NOT_PLAUSIBLE_16)
|
||||
|
||||
WriteStringToFile(s, deveui, implausible)
|
||||
|
||||
|
|
@ -559,38 +530,6 @@ func WriteDatapoint(mytime int64, deveui string, devaddr string, v uint8, h uint
|
|||
location, _ := time.LoadLocation("Europe/Zurich")
|
||||
alertMap[deveui] = fmt.Sprintf("*** Schwarmalarm ***\n%s\n%s\nGewichtsverlust: %d g", getDevAlias(deveui), time.Unix(mytime*60, 0).In(location).Format("02.01.2006 15:04"), w_loss)
|
||||
}
|
||||
|
||||
// minmax Alert
|
||||
fmt.Println("debug minmax alert")
|
||||
minmax := getDevMinmax(deveui)
|
||||
fmt.Printf("debug getDevMinmax: minmax = %s\n", minmax)
|
||||
if minmax != "0,0" {
|
||||
tokens := strings.Split(minmax, ",")
|
||||
if len(tokens) == 2 {
|
||||
min, _ := strconv.ParseInt(tokens[0], 10, 32)
|
||||
max, _ := strconv.ParseInt(tokens[1], 10, 32)
|
||||
fmt.Printf("debug min: %d, max: %d\n", min, max)
|
||||
minmaxstatus := GetMinMaxStatus(deveui)
|
||||
fmt.Printf("debug minmaxstatus: %s\n", minmaxstatus)
|
||||
if (w_gram < uint32(min)) && (minmaxstatus != "MINALERT") {
|
||||
fmt.Printf("debug minalert\n")
|
||||
SetMinMaxStatus(deveui, "MINALERT")
|
||||
alertLogMap[deveui] = fmt.Sprintf("alert,deveui=%s reason=\"minmaxlarm\",w=%di,w_min=%di %d\n", deveui, w_gram, min, mytime*60*1000*1000*1000)
|
||||
location, _ := time.LoadLocation("Europe/Zurich")
|
||||
alertMap[deveui] = fmt.Sprintf("*** Min/Max-Alarm ***\n%s\n%s\nUnterschreiten des Minimalgewichts: %d g (Minimal: %d g)", getDevAlias(deveui), time.Unix(mytime*60, 0).In(location).Format("02.01.2006 15:04"), w_gram, min)
|
||||
} else if (w_gram > uint32(max)) && (minmaxstatus != "MAXALERT") {
|
||||
fmt.Printf("debug maxalert\n")
|
||||
SetMinMaxStatus(deveui, "MAXALERT")
|
||||
alertLogMap[deveui] = fmt.Sprintf("alert,deveui=%s reason=\"minmaxlarm\",w=%di,w_max=%di %d\n", deveui, w_gram, max, mytime*60*1000*1000*1000)
|
||||
location, _ := time.LoadLocation("Europe/Zurich")
|
||||
alertMap[deveui] = fmt.Sprintf("*** Min/Max-Alarm ***\n%s\n%s\nUeberschreiten des Maximalgewichts: %d g (Maximal: %d g)", getDevAlias(deveui), time.Unix(mytime*60, 0).In(location).Format("02.01.2006 15:04"), w_gram, max)
|
||||
} else if (w_gram > uint32(min+100)) && (w_gram < uint32(max-100)) {
|
||||
fmt.Printf("debug resettonormal\n")
|
||||
SetMinMaxStatus(deveui, "NORMAL")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
@ -610,9 +549,9 @@ func WriteStringToFile(s string, deveui string, implausible bool) {
|
|||
|
||||
// Also write to individual files
|
||||
datestr := time.Now().Format("2006-01")
|
||||
individual_file := "/data/logs/" + deveui + "-" + datestr + ".log"
|
||||
individual_file := "/home/beieli/mini-beieli-lorahandler/logs/" + deveui + "-" + datestr + ".log"
|
||||
if implausible {
|
||||
individual_file = "/data/logs/" + "implausible" + "-" + datestr + ".log"
|
||||
individual_file = "/home/beieli/mini-beieli-lorahandler/logs/" + "implausible" + "-" + datestr + ".log"
|
||||
}
|
||||
|
||||
fi, err := os.OpenFile(individual_file, os.O_CREATE|os.O_APPEND|os.O_WRONLY, 0644)
|
||||
|
|
|
|||
|
|
@ -3,7 +3,6 @@ package main
|
|||
import (
|
||||
"fmt"
|
||||
"github.com/gomodule/redigo/redis"
|
||||
"os"
|
||||
"strconv"
|
||||
"time"
|
||||
)
|
||||
|
|
@ -13,14 +12,6 @@ var globalPool *redis.Pool
|
|||
const lastvaluesPrefix string = "lastvalues:"
|
||||
const devPrefix string = "dev:"
|
||||
|
||||
func getenv(key, fallback string) string {
|
||||
value := os.Getenv(key)
|
||||
if len(value) == 0 {
|
||||
return fallback
|
||||
}
|
||||
return value
|
||||
}
|
||||
|
||||
type CalSettings struct {
|
||||
w1_0 int32
|
||||
w2_0 int32
|
||||
|
|
@ -37,7 +28,7 @@ func newPool() *redis.Pool {
|
|||
// Dial is an application supplied function for creating and
|
||||
// configuring a connection.
|
||||
Dial: func() (redis.Conn, error) {
|
||||
c, err := redis.Dial("tcp", getenv("REDIS_CONNECTION_STRING", ":6379"))
|
||||
c, err := redis.Dial("tcp", ":6379")
|
||||
if err != nil {
|
||||
panic(err.Error())
|
||||
}
|
||||
|
|
@ -204,26 +195,6 @@ func getSmsnumber(deveui string) string {
|
|||
return res
|
||||
}
|
||||
|
||||
func getDevMinmax(deveui string) string {
|
||||
res := "0,0"
|
||||
|
||||
if deveui == "" {
|
||||
return res
|
||||
}
|
||||
|
||||
conn := globalPool.Get()
|
||||
defer conn.Close()
|
||||
|
||||
minmax, err := redis.String(conn.Do("HGET", devPrefix+deveui, "minmax"))
|
||||
if err == nil {
|
||||
res = minmax
|
||||
} else {
|
||||
fmt.Println(err)
|
||||
}
|
||||
|
||||
return res
|
||||
}
|
||||
|
||||
func GetDownlinkCommand(deveui string) string {
|
||||
// 0: do nothing...
|
||||
res := "do_nothing"
|
||||
|
|
@ -246,37 +217,6 @@ func GetDownlinkCommand(deveui string) string {
|
|||
return res
|
||||
}
|
||||
|
||||
func SetMinMaxStatus(deveui string, status string) error {
|
||||
conn := globalPool.Get()
|
||||
defer conn.Close()
|
||||
|
||||
// SET object
|
||||
_, err := conn.Do("HMSET", devPrefix+deveui, "minmaxstatus", status)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func GetMinMaxStatus(deveui string) string {
|
||||
res := "NORMAL"
|
||||
|
||||
if deveui == "" {
|
||||
return res
|
||||
}
|
||||
|
||||
conn := globalPool.Get()
|
||||
defer conn.Close()
|
||||
|
||||
minmax, err := redis.String(conn.Do("HGET", devPrefix+deveui, "minmaxstatus"))
|
||||
if err == nil {
|
||||
res = minmax
|
||||
}
|
||||
|
||||
return res
|
||||
}
|
||||
|
||||
func SetDownlinkCommand(deveui string, new_command string) error {
|
||||
conn := globalPool.Get()
|
||||
defer conn.Close()
|
||||
|
|
|
|||
Loading…
Reference in New Issue