bi/model/gm_operater_log.go

71 lines
2.1 KiB
Go
Raw Permalink Normal View History

2022-01-26 16:40:50 +08:00
package model
import (
"github.com/1340691923/xwl_bi/engine/db"
"github.com/1340691923/xwl_bi/platform-basic-libs/util"
)
type GmOperaterLog struct {
Id int `db:"id" json:"id"`
OperaterName string `db:"operater_name" json:"operater_name"` //操作者id
OperaterId int `db:"operater_id" json:"operater_id"` //操作者id
OperaterAction string `db:"operater_action" json:"operater_action"` //请求路由
Created string `db:"created" json:"created"`
Method string `db:"method" json:"method"` //请求方法
Body []byte `db:"body" json:"-"` //请求body
OperaterRoleId int `db:"operater_role_id" json:"operater_role_id"`
FilterDate []string `db:"-" json:"date"`
BodyStr string `db:"-" json:"body_str"` //请求body
}
func (this *GmOperaterLog) ProcessSqlInsert(sqlA db.InsertBuilder) db.InsertBuilder {
return sqlA
}
func (this *GmOperaterLog) ProcessSqlUpdate(id int, sqlA db.UpdateBuilder) db.UpdateBuilder {
return sqlA
}
func (this *GmOperaterLog) TableName() string {
return "gm_operater_log"
}
func (this *GmOperaterLog) ProcessSqlWhere(sqlA db.SelectBuilder) db.SelectBuilder {
if this.OperaterId != 0 {
sqlA = sqlA.Where(db.Eq{"operater_id": this.OperaterId})
}
if this.OperaterRoleId != 0 {
sqlA = sqlA.Where(db.Eq{"operater_role_id": this.OperaterRoleId})
}
if this.OperaterAction != "" {
sqlA = sqlA.Where(db.Eq{"operater_action": this.OperaterAction})
}
if len(this.FilterDate) == 2 {
sqlA = sqlA.Where(db.GtOrEq{"created": this.FilterDate[0]})
sqlA = sqlA.Where(db.LtOrEq{"created": this.FilterDate[1]})
}
return sqlA
}
func (this *GmOperaterLog) Insert() (err error) {
body, err := util.GzipCompress(util.Bytes2str(this.Body))
if err != nil {
return
}
2022-04-10 23:22:35 +08:00
_, err = db.
SqlBuilder.
Insert(this.TableName()).
SetMap(map[string]interface{}{
2022-01-26 16:40:50 +08:00
"operater_name": this.OperaterName,
"operater_id": this.OperaterId,
"operater_action": this.OperaterAction,
"method": this.Method,
"body": body,
"operater_role_id": this.OperaterRoleId,
}).RunWith(db.Sqlx).Exec()
if err != nil {
return
}
return
}