|
@@ -1,8 +1,8 @@
|
|
|
package deviceAlarm
|
|
|
|
|
|
import (
|
|
|
+ "fmt"
|
|
|
"github.com/gogf/gf/database/gredis"
|
|
|
- "github.com/gogf/gf/util/gconv"
|
|
|
)
|
|
|
|
|
|
const (
|
|
@@ -24,7 +24,7 @@ func NewDevAlarmManager(host string, port, db int) *DevAlarmManager {
|
|
|
red := gredis.New(&gredis.Config{
|
|
|
Host: host,
|
|
|
Port: port,
|
|
|
- Db: 14,
|
|
|
+ Db: db,
|
|
|
MaxActive: 100,
|
|
|
})
|
|
|
helper := &DevAlarmManager{
|
|
@@ -35,12 +35,14 @@ func NewDevAlarmManager(host string, port, db int) *DevAlarmManager {
|
|
|
|
|
|
func (a *DevAlarmManager) SetAlarm(params *AlarmParams) error {
|
|
|
key := AlarmPrefix + params.DeviceCode
|
|
|
- buffStr := gconv.String(params)
|
|
|
- _, err := a.redisClient.DoVar("SET", key, buffStr)
|
|
|
+ res, err := a.redisClient.DoVar("SET", key, params)
|
|
|
if err != nil {
|
|
|
-
|
|
|
+ fmt.Printf("set alarm failed1: %s", err.Error())
|
|
|
return err
|
|
|
}
|
|
|
+ if res.String() != "OK" {
|
|
|
+ fmt.Printf("set alarm failed2: %s", res.String())
|
|
|
+ }
|
|
|
//_, err = a.redisClient.Do("EXPIRE", key, dataExpires)
|
|
|
//if err != nil {
|
|
|
// return err
|