add log

pkg/deviceAlarm/deviceAlarm.go

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

pkg/ruleEngine/nodes/temp_alarm_node.go

@@ -204,14 +204,12 @@ func (t *TempAlarmNode) evaluateConditions(message *protocol.Message) bool {
 	}
 
 	if reply.AlarmParams.FirstReportTime == 0 {
-		fmt.Printf("温度:%f,超过预设值,请求rpc接口保存数据------------------\r\n", data["temperature"])
 		setArgs := rpcs.ArgsAlarmInfo{
 			DeviceCode:      deviceId,
 			FirstReportTime: time.Now().Unix(),
 		}
 		err = server.RPCCallByName(nil, rpcs.DeviceManagerName, "DeviceManager.SetAlarm", setArgs, &setReply)
 		if err != nil {
-			fmt.Printf("err------------------:%s\r\n", err.Error())
 			return false
 		}
 		return false