liuxiulin 1 day ago
parent
commit
cd2c0fb677
1 changed files with 6 additions and 9 deletions
  1. 6 9
      pkg/deviceAlarm/deviceAlarm.go

+ 6 - 9
pkg/deviceAlarm/deviceAlarm.go

@@ -7,7 +7,7 @@ import (
 )
 
 const (
-	AlarmPrefix = "alarm:"
+	AlarmPrefix = "device:main:alarm:"
 	dataExpires = 7200
 )
 
@@ -36,18 +36,15 @@ func NewDevAlarmManager(host string, port int) *DevAlarmManager {
 
 func (a *DevAlarmManager) SetAlarm(params *AlarmParams) error {
 	key := AlarmPrefix + params.DeviceCode
-	fmt.Printf("key---------------%s\r\n", key)
-	fmt.Printf("params---------------%s\n", gjson.New(params).MustToJsonString())
 	res, err := a.redisClient.DoVar("SET", key, params)
 	if err != nil {
-		fmt.Printf("set alarm failed1: %s", err.Error())
 		return err
 	}
-	fmt.Printf("res--------------%s\n", res.String())
-	//_, err = a.redisClient.Do("EXPIRE", key, dataExpires)
-	//if err != nil {
-	//	return err
-	//}
+	fmt.Printf("params--------------%s\n,res--------------%s\n", gjson.New(params).MustToJsonString(), res.String())
+	_, err = a.redisClient.Do("EXPIRE", key, dataExpires)
+	if err != nil {
+		return err
+	}
 	return nil
 
 }