53 lines
1.6 KiB
Go
53 lines
1.6 KiB
Go
|
package dao
|
||
|
|
|
||
|
|
import (
|
||
|
|
"go-common/app/admin/ep/tapd/model"
|
||
|
|
"go-common/library/ecode"
|
||
|
|
)
|
||
|
|
|
||
|
|
// AddURLEvent Add URL Event.
|
||
|
|
func (d *Dao) AddURLEvent(urlEvent *model.UrlEvent) error {
|
||
|
|
return d.db.Create(urlEvent).Error
|
||
|
|
}
|
||
|
|
|
||
|
|
// QueryURLEventByUrlAndEvent Query URL Event By Url And Event.
|
||
|
|
func (d *Dao) QueryURLEventByUrlAndEvent(urlID int64, eventType string) (urlEvents []*model.UrlEvent, err error) {
|
||
|
|
err = d.db.Model(&model.HookUrl{}).Where("url_id = ? and event = ?", urlID, eventType).Find(&urlEvents).Error
|
||
|
|
if err == ecode.NothingFound {
|
||
|
|
err = nil
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
// QueryURLEventByUrl Query URL Event By Url.
|
||
|
|
func (d *Dao) QueryURLEventByUrl(urlID int64) (urlEvents []*model.UrlEvent, err error) {
|
||
|
|
err = d.db.Model(&model.HookUrl{}).Where("url_id = ?", urlID).Find(&urlEvents).Error
|
||
|
|
if err == ecode.NothingFound {
|
||
|
|
err = nil
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
// QueryURLEventByEventAndStatus Query URL Event By Event and status.
|
||
|
|
func (d *Dao) QueryURLEventByEventAndStatus(event string, status int) (urlEvents []*model.UrlEvent, err error) {
|
||
|
|
err = d.db.Model(&model.HookUrl{}).Where("event = ? and status = ?", event, status).Find(&urlEvents).Error
|
||
|
|
if err == ecode.NothingFound {
|
||
|
|
err = nil
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
// QueryURLEventByStatus Query URL Event By Status.
|
||
|
|
func (d *Dao) QueryURLEventByStatus(status int) (urlEvents []*model.UrlEvent, err error) {
|
||
|
|
err = d.db.Model(&model.HookUrl{}).Where("status = ?", status).Find(&urlEvents).Error
|
||
|
|
if err == ecode.NothingFound {
|
||
|
|
err = nil
|
||
|
|
}
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
// UpdateURLEventStatus Update URL Event status.
|
||
|
|
func (d *Dao) UpdateURLEventStatus(id int64, status int) error {
|
||
|
|
return d.db.Model(&model.UrlEvent{}).Where("id=?", id).Update("status", status).Error
|
||
|
|
}
|