fix bug

pkg/deviceAlarm/deviceAlarm.go

@@ -36,15 +36,15 @@ 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.Do("SET", key, buffStr)
+	_, err := a.redisClient.DoVar("SET", key, buffStr)
 	if err != nil {
 
 		return err
 	}
-	_, err = a.redisClient.Do("EXPIRE", key, dataExpires)
-	if err != nil {
-		return err
-	}
+	//_, err = a.redisClient.Do("EXPIRE", key, dataExpires)
+	//if err != nil {
+	//	return err
+	//}
 	return nil
 
 }

pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -26,17 +26,14 @@ type TempAlarmNode struct {
 
 func (t *TempAlarmNode) Init(ctx ruleEngine.Context, config string) error {
 	t.pool = grpool.New(10)
-	fmt.Printf("initConfig:---------------------------%s\r\n", config)
 	if config == "" {
 		t.config = &TempAlarmNodeConfig{}
 	} else {
 		c := new(TempAlarmNodeConfig)
 		err := json.Unmarshal([]byte(config), c)
 		if err != nil {
-			fmt.Printf("config转换失败：----------------%s", err.Error())
 			return err
 		}
-		fmt.Printf("config转换c：----------------%s", gjson.New(c).MustToJsonString())
 		t.config = c
 	}
 	client := utils.NewHttpClient()