floraachy
/
console
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add orm.Context

This commit is contained in:
liugq 2022-12-08 20:48:59 +08:00
parent b88ec94082
commit c17359adb3
8 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/api/alerting/channel.go
View File

@ -25,7 +25,7 @@ func (h *AlertAPI) createChannel(w http.ResponseWriter, req *http.Request, ps ht
return
}
err = orm.Create(obj, "")
err = orm.Create(nil, obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)
@ -93,7 +93,7 @@ func (h *AlertAPI) updateChannel(w http.ResponseWriter, req *http.Request, ps ht
//protect
obj.ID = id
obj.Created = create
err = orm.Update(&obj, "")
err = orm.Update(nil, &obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)

6
plugin/api/alerting/rule.go
View File

@ -63,7 +63,7 @@ func (alertAPI *AlertAPI) createRule(w http.ResponseWriter, req *http.Request, p
rule.Schedule.Interval = "1m"
}
err = orm.Save(rule, "")
err = orm.Save(nil, rule)
if err != nil {
log.Error(err)
alertAPI.WriteJSON(w, util.MapStr{
@ -282,7 +282,7 @@ func (alertAPI *AlertAPI) updateRule(w http.ResponseWriter, req *http.Request, p
rule.Created = create
rule.Updated = time.Now()
err = orm.Update(rule, "")
err = orm.Update(nil, rule)
if err != nil {
alertAPI.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)
@ -598,7 +598,7 @@ func (alertAPI *AlertAPI) enableRule(w http.ResponseWriter, req *http.Request, p
clearKV(id)
}
obj.Enabled = reqObj.Enabled
err = orm.Save(obj, "")
err = orm.Save(nil, obj)
if err != nil {
log.Error(err)
alertAPI.WriteError(w, fmt.Sprintf("save rule error:%v", err), http.StatusInternalServerError)

4
plugin/api/gateway/instance.go
View File

@ -51,7 +51,7 @@ func (h *GatewayAPI) createInstance(w http.ResponseWriter, req *http.Request, ps
h.WriteError(w, "gateway instance already registered", http.StatusInternalServerError)
return
}
err = orm.Create(obj, "")
err = orm.Create(nil, obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)
@ -119,7 +119,7 @@ func (h *GatewayAPI) updateInstance(w http.ResponseWriter, req *http.Request, ps
//protect
obj.ID = id
obj.Created = create
err = orm.Update(&obj, "")
err = orm.Update(nil, &obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)

4
plugin/api/index_management/index.go
View File

@ -67,7 +67,7 @@ func (handler APIHandler) CreateDictItemAction(w http.ResponseWriter, req *http.
return
}
err = orm.Create(&dict, "")
err = orm.Create(nil, &dict)
if err != nil {
resp["status"] = false
resp["error"] = err
@ -107,7 +107,7 @@ func (handler APIHandler) UpdateDictItemAction(w http.ResponseWriter, req *http.
}
dict.UpdatedAt = time.Now()
err = orm.Update(dict, "")
err = orm.Update(nil, dict)
if err != nil {
resp["status"] = false
resp["error"] = err

4
plugin/api/insight/dashboard.go
View File

@ -22,7 +22,7 @@ func (h *InsightAPI) createDashboard(w http.ResponseWriter, req *http.Request, p
log.Error(err)
return
}
err = orm.Create(obj, "")
err = orm.Create(nil, obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)
@ -102,7 +102,7 @@ func (h *InsightAPI) updateDashboard(w http.ResponseWriter, req *http.Request, p
//protect
obj.ID = id
obj.Created = create
err = orm.Update(&obj, "")
err = orm.Update(nil, &obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)

4
plugin/api/insight/visualization.go
View File

@ -24,7 +24,7 @@ func (h *InsightAPI) createVisualization(w http.ResponseWriter, req *http.Reques
log.Error(err)
return
}
err = orm.Create(obj, "")
err = orm.Create(nil, obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)
@ -87,7 +87,7 @@ func (h *InsightAPI) updateVisualization(w http.ResponseWriter, req *http.Reques
//protect
obj.ID = id
obj.Created = create
err = orm.Update(&obj, "")
err = orm.Update(nil, &obj)
if err != nil {
h.WriteError(w, err.Error(), http.StatusInternalServerError)
log.Error(err)

4
plugin/setup/setup.go
View File

@ -411,7 +411,7 @@ func (module *Module) initialize(w http.ResponseWriter, r *http.Request, ps http
security.InitSecurity()
//保存默认集群
err=orm.Save(&cfg, "")
err=orm.Save(nil, &cfg)
if err!=nil{
panic(err)
}
@ -435,7 +435,7 @@ func (module *Module) initialize(w http.ResponseWriter, r *http.Request, ps http
Name: rbac.RoleAdminName,
})
user.Roles=role
err=orm.Save(&user, "")
err=orm.Save(nil, &user)
if err!=nil{
panic(err)
}

4
service/alerting/elasticsearch/engine.go
View File

@ -626,7 +626,7 @@ func (engine *Engine) Do(rule *alerting.Rule) error {
}
}
err = orm.Save(alertItem, "")
err = orm.Save(nil, alertItem)
if err != nil {
log.Error(err)
}
@ -1131,7 +1131,7 @@ func getLastAlertMessage(ruleID string, duration time.Duration) (*alerting.Alert
func saveAlertMessageToES(message *alerting.AlertMessage) error {
message.Updated = time.Now()
return orm.Save(message, "")
return orm.Save(nil, message)
}
func saveAlertMessage(message *alerting.AlertMessage) error {