From ad4ad76f4cd6db55ddceedcff5bf588547786f31 Mon Sep 17 00:00:00 2001
From: qixiaoning <jony.kee@outlook.com>
Date: 星期一, 11 八月 2025 13:47:24 +0800
Subject: [PATCH] 推送配置相关接口修改调整字段设置，数据关联
---
push-service/service/eventPushService.go | 10 ++++++++++
1 files changed, 10 insertions(+), 0 deletions(-)
diff --git a/push-service/service/eventPushService.go b/push-service/service/eventPushService.go
index ce7fccb..fa16fe4 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
}
}
--
Gitblit v1.8.0