From 2162e52a04eb467e5e9ff1ee1a89f1f5a54a3108 Mon Sep 17 00:00:00 2001 From: Joerg Lehmann Date: Mon, 5 Aug 2019 17:59:55 +0200 Subject: [PATCH] read smsnumber from redis --- alert.go | 8 +++++++- persistence.go | 17 +++++++++++++++++ 2 files changed, 24 insertions(+), 1 deletion(-) diff --git a/alert.go b/alert.go index 8109738..8c53a78 100644 --- a/alert.go +++ b/alert.go @@ -2,6 +2,7 @@ package main import ( "fmt" + "strings" "io/ioutil" "log" "time" @@ -37,5 +38,10 @@ func sendSMS(phonenumber string, alertMessage string) { func sendAlert(deveui string, alertMessage string) { fmt.Printf("sendAlert: deveui=%s, message=%s\n", deveui, alertMessage) - sendSMS("41765006123",alertMessage) + smsnumber := getSmsnumber(deveui) + if (smsnumber != "") { + // we strip of the leading + + smsnumber = strings.Replace(smsnumber, "+", "", -1) + sendSMS(smsnumber,alertMessage) + } } diff --git a/persistence.go b/persistence.go index 3d0df42..f9ff1f3 100644 --- a/persistence.go +++ b/persistence.go @@ -141,3 +141,20 @@ func getDevAlias(deveui string) string { return res } + +func getSmsnumber(deveui string) string { + res := "" + if deveui == "" { + return res + } + + conn := globalPool.Get() + defer conn.Close() + + smsnumber, err := redis.String(conn.Do("HGET", devPrefix+deveui, "smsnumber")) + if err == nil { + res = smsnumber + } + + return res +}