add log

pkg/deviceAlarm/deviceAlarm.go

@@ -1,6 +1,7 @@
 package deviceAlarm
 
 import (
+	"fmt"
 	"github.com/gogf/gf/database/gredis"
 	"github.com/gogf/gf/util/gconv"
 )
@@ -36,8 +37,10 @@ func NewAlarm(host string, port, db int) *Alarm {
 func (a *Alarm) SetAlarm(params *AlarmParams) error {
 	key := AlarmPrefix + params.DeviceCode
 	buffStr := gconv.String(params)
+	fmt.Printf("保存数据---------------%s", buffStr)
 	_, err := a.redisClient.Do("SET", key, buffStr)
 	if err != nil {
+		fmt.Printf("err---------------%s", err.Error())
 		return err
 	}
 	_, err = a.redisClient.Do("EXPIRE", key, dataExpires)

pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -204,7 +204,7 @@ func (t *TempAlarmNode) evaluateConditions(message *protocol.Message) bool {
 	}
 
 	if reply.AlarmParams.FirstReportTime == 0 {
-		fmt.Printf("请求rpc接口保存数据------------------\r\n")
+		fmt.Printf("温度:%f,超过预设值,请求rpc接口保存数据------------------\r\n", data["temperature"])
 		setArgs := rpcs.ArgsAlarmInfo{
 			DeviceCode:      deviceId,
 			FirstReportTime: time.Now().Unix(),