crosstyan/srs-spi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update log level

Browse Source
This commit is contained in:
haibo.chen
2025-05-09 17:10:06 +08:00
committed by Haibo Chen(陈海博)
parent 5b4dbca9da
commit 0173c9af67
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/service/inbound.go
View File

@ -128,7 +128,7 @@ func (s *UAS) onMessage(req *sip.Request, tx sip.ServerTransaction) {
var body string var body string
switch temp.CmdType { switch temp.CmdType {
case "Keepalive": case "Keepalive":
slog.Debug("Keepalive") slog.Info("Keepalive")
if d, ok := DM.GetDevice(temp.DeviceID); ok && d.Online { if d, ok := DM.GetDevice(temp.DeviceID); ok && d.Online {
// 更新设备心跳时间 // 更新设备心跳时间
DM.UpdateDeviceHeartbeat(temp.DeviceID) DM.UpdateDeviceHeartbeat(temp.DeviceID)
@ -138,16 +138,16 @@ func (s *UAS) onMessage(req *sip.Request, tx sip.ServerTransaction) {
} }
case "SensorCatalog": // 兼容宇视，非国标 case "SensorCatalog": // 兼容宇视，非国标
case "Catalog": case "Catalog":
slog.Debug("Catalog") slog.Info("Catalog")
DM.UpdateChannels(temp.DeviceID, temp.DeviceList...) DM.UpdateChannels(temp.DeviceID, temp.DeviceList...)
//go s.AutoInvite(temp.DeviceID, temp.DeviceList...) //go s.AutoInvite(temp.DeviceID, temp.DeviceList...)
case "ConfigDownload": case "ConfigDownload":
slog.Debug("ConfigDownload") slog.Info("ConfigDownload")
DM.UpdateDeviceConfig(temp.DeviceID, &temp.BasicParam) DM.UpdateDeviceConfig(temp.DeviceID, &temp.BasicParam)
case "Alarm": case "Alarm":
slog.Debug("Alarm") slog.Info("Alarm")
case "RecordInfo": case "RecordInfo":
slog.Debug("RecordInfo") slog.Info("RecordInfo")
// 从 recordQueryResults 中获取对应通道的结果通道 // 从 recordQueryResults 中获取对应通道的结果通道
if ch, ok := s.recordQueryResults.Load(temp.DeviceID); ok { if ch, ok := s.recordQueryResults.Load(temp.DeviceID); ok {
// 发送查询结果 // 发送查询结果
@ -164,6 +164,6 @@ func (s *UAS) onMessage(req *sip.Request, tx sip.ServerTransaction) {
} }
func (s *UAS) onNotify(req *sip.Request, tx sip.ServerTransaction) { func (s *UAS) onNotify(req *sip.Request, tx sip.ServerTransaction) {
slog.Debug("Received NOTIFY request") slog.Info("Received NOTIFY request")
tx.Respond(sip.NewResponseFromRequest(req, http.StatusOK, "OK", nil)) tx.Respond(sip.NewResponseFromRequest(req, http.StatusOK, "OK", nil))
} }