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 +}