TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-11 04:50:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

IP阈值动作增加WebHook

Browse Source
This commit is contained in:
刘祥超
2021-09-14 15:27:48 +08:00
parent 51b938b9c7
commit ea915582c1
3 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
internal/db/models/node_ip_address_threshold_dao.go
View File

@@ -242,3 +242,11 @@ func (this *NodeIPAddressThresholdDAO) ExistsEnabledThreshold(tx *dbs.Tx, thresh
State(NodeIPAddressThresholdStateEnabled). State(NodeIPAddressThresholdStateEnabled).
Exist() Exist()
} }
// UpdateThresholdIsMatched 设置是否匹配
func (this *NodeIPAddressThresholdDAO) UpdateThresholdIsMatched(tx *dbs.Tx, thresholdId int64, isMatched bool) error {
return this.Query(tx).
Pk(thresholdId).
Set("isMatched", isMatched).
UpdateQuickly()
}

2
internal/db/models/node_ip_address_threshold_model.go
View File

@@ -7,6 +7,7 @@ type NodeIPAddressThreshold struct {
Items string `field:"items"` // 阈值条目 Items string `field:"items"` // 阈值条目
Actions string `field:"actions"` // 动作 Actions string `field:"actions"` // 动作
NotifiedAt uint64 `field:"notifiedAt"` // 上次通知时间 NotifiedAt uint64 `field:"notifiedAt"` // 上次通知时间
IsMatched uint8 `field:"isMatched"` // 上次是否匹配
State uint8 `field:"state"` // 状态 State uint8 `field:"state"` // 状态
Order uint32 `field:"order"` // 排序 Order uint32 `field:"order"` // 排序
} }
@@ -17,6 +18,7 @@ type NodeIPAddressThresholdOperator struct {
Items interface{} // 阈值条目 Items interface{} // 阈值条目
Actions interface{} // 动作 Actions interface{} // 动作
NotifiedAt interface{} // 上次通知时间 NotifiedAt interface{} // 上次通知时间
IsMatched interface{} // 上次是否匹配
State interface{} // 状态 State interface{} // 状态
Order interface{} // 排序 Order interface{} // 排序
} }

8
internal/db/models/sys_setting_dao.go
View File

@@ -32,7 +32,7 @@ func init() {
}) })
} }
// 设置配置 // UpdateSetting 设置配置
func (this *SysSettingDAO) UpdateSetting(tx *dbs.Tx, codeFormat string, valueJSON []byte, codeFormatArgs ...interface{}) error { func (this *SysSettingDAO) UpdateSetting(tx *dbs.Tx, codeFormat string, valueJSON []byte, codeFormatArgs ...interface{}) error {
if len(codeFormatArgs) > 0 { if len(codeFormatArgs) > 0 {
codeFormat = fmt.Sprintf(codeFormat, codeFormatArgs...) codeFormat = fmt.Sprintf(codeFormat, codeFormatArgs...)
@@ -77,7 +77,7 @@ func (this *SysSettingDAO) UpdateSetting(tx *dbs.Tx, codeFormat string, valueJSO
return lastErr return lastErr
} }
// 读取配置 // ReadSetting 读取配置
func (this *SysSettingDAO) ReadSetting(tx *dbs.Tx, code string, codeFormatArgs ...interface{}) (valueJSON []byte, err error) { func (this *SysSettingDAO) ReadSetting(tx *dbs.Tx, code string, codeFormatArgs ...interface{}) (valueJSON []byte, err error) {
if len(codeFormatArgs) > 0 { if len(codeFormatArgs) > 0 {
code = fmt.Sprintf(code, codeFormatArgs...) code = fmt.Sprintf(code, codeFormatArgs...)
@@ -89,7 +89,7 @@ func (this *SysSettingDAO) ReadSetting(tx *dbs.Tx, code string, codeFormatArgs .
return []byte(col), err return []byte(col), err
} }
// 对比配置中的数字大小 // CompareInt64Setting 对比配置中的数字大小
func (this *SysSettingDAO) CompareInt64Setting(tx *dbs.Tx, code string, anotherValue int64) (int8, error) { func (this *SysSettingDAO) CompareInt64Setting(tx *dbs.Tx, code string, anotherValue int64) (int8, error) {
valueJSON, err := this.ReadSetting(tx, code) valueJSON, err := this.ReadSetting(tx, code)
if err != nil { if err != nil {
@@ -105,7 +105,7 @@ func (this *SysSettingDAO) CompareInt64Setting(tx *dbs.Tx, code string, anotherV
return 0, nil return 0, nil
} }
// 读取全局配置 // ReadGlobalConfig 读取全局配置
func (this *SysSettingDAO) ReadGlobalConfig(tx *dbs.Tx) (*serverconfigs.GlobalConfig, error) { func (this *SysSettingDAO) ReadGlobalConfig(tx *dbs.Tx) (*serverconfigs.GlobalConfig, error) {
globalConfigData, err := this.ReadSetting(tx, systemconfigs.SettingCodeServerGlobalConfig) globalConfigData, err := this.ReadSetting(tx, systemconfigs.SettingCodeServerGlobalConfig)
if err != nil { if err != nil {