From fd31206bcb8b084720291a53c986db771d8f5975 Mon Sep 17 00:00:00 2001
From: qixiaoning <jony.kee@outlook.com>
Date: 星期四, 18 九月 2025 13:58:16 +0800
Subject: [PATCH] 抓拍预警记录查询修改，备份还原接口问题修复，应用安装接口调试
---
push-service/service/eventPushService.go | 16 ++++++++++++++--
1 files changed, 14 insertions(+), 2 deletions(-)
diff --git a/push-service/service/eventPushService.go b/push-service/service/eventPushService.go
index ce7fccb..2b01a84 100644
--- a/push-service/service/eventPushService.go
+++ b/push-service/service/eventPushService.go
@@ -11,6 +11,7 @@
"basic.com/pubsub/protomsg.git"
"basic.com/valib/bhomeclient.git"
"basic.com/valib/bhomedbapi.git"
+ "basic.com/valib/logger.git"
uuid "github.com/satori/go.uuid"
)
@@ -83,10 +84,12 @@
} else { //鏂板
if er > 0 {
err = errors.New("鍚嶇О涓嶅厑璁搁噸澶�")
+ logger.Debug(err)
return false
}
eventPushE.Id = uuid.NewV4().String()
if err = tx.Table("event_push").Create(&eventPushE).Error; err != nil {
+ logger.Debug(err)
return false
}
}
@@ -102,6 +105,7 @@
EventPushId: eventPushE.Id,
}
if err = tx.Table("event_push_server").Create(&ipPortE).Error; err != nil {
+ logger.Debug(err)
return false
}
}
@@ -110,18 +114,24 @@
Id: uuid.NewV4().String(),
Enable: urlVo.Enable,
Url: urlVo.Url,
+ ServerIp: urlVo.ServerIp,
+ Port: urlVo.Port,
Type: models.PUSH_URL_TYPE,
EventPushId: eventPushE.Id,
}
if err = tx.Table("event_push_server").Create(&urlE).Error; err != nil {
+ logger.Debug(err)
return false
}
}
+
+ logger.Debug("hhhhhhh")
for _, rule := range body.Rules {
rule.Id = uuid.NewV4().String()
rule.EventPushId = eventPushE.Id
if err = tx.Table("event_push_rule").Create(&rule).Error; err != nil {
+ logger.Debug(err)
return false
}
}
@@ -266,8 +276,10 @@
})
} else if pushServer.Type == models.PUSH_URL_TYPE {
resultVo.Urls = append(resultVo.Urls, vo.EventUrlVo{
- Enable: pushServer.Enable,
- Url: pushServer.Url,
+ Enable: pushServer.Enable,
+ Url: pushServer.Url,
+ ServerIp: pushServer.ServerIp,
+ Port: pushServer.Port,
})
}
}
--
Gitblit v1.8.0