104 lines
2.6 KiB
Go
104 lines
2.6 KiB
Go
package dao
|
||
|
||
import (
|
||
"context"
|
||
"strconv"
|
||
|
||
"go-common/app/admin/main/reply/model"
|
||
"go-common/library/database/elastic"
|
||
"go-common/library/ecode"
|
||
"go-common/library/log"
|
||
"strings"
|
||
"time"
|
||
)
|
||
|
||
const (
|
||
// log api
|
||
_logURL = "/x/admin/search/log"
|
||
)
|
||
|
||
// ReportLogData report log data
|
||
type ReportLogData struct {
|
||
Sort string `json:"sort"`
|
||
Order string `json:"order"`
|
||
Page model.Page `json:"page"`
|
||
Result []*ReportLogResult `json:"result"`
|
||
}
|
||
|
||
// ReportLogResult ReportLogResult
|
||
type ReportLogResult struct {
|
||
AdminName string `json:"uname"`
|
||
AdminID int64 `json:"uid"`
|
||
Business int64 `json:"business"`
|
||
Type int32 `json:"type"`
|
||
Oid int64 `json:"oid"`
|
||
OidStr string `json:"oid_str"`
|
||
Action string `json:"action"`
|
||
Ctime string `json:"ctime"`
|
||
Index0 int64 `json:"int_0"`
|
||
Index1 int64 `json:"int_1"`
|
||
Index2 int64 `json:"int_2"`
|
||
Content string `json:"extra_data"`
|
||
}
|
||
|
||
// ReportLog get notice info.
|
||
func (d *Dao) ReportLog(c context.Context, sp model.LogSearchParam) (data *ReportLogData, err error) {
|
||
var (
|
||
// log_audit评论的索引是按时间分区的，最早的数据是2018年的，所以这里最早时间是写死的2018年
|
||
stime = time.Date(2018, 1, 1, 0, 0, 0, 0, time.UTC)
|
||
etime = time.Now()
|
||
)
|
||
if sp.CtimeFrom != "" {
|
||
if stime, err = time.Parse(model.DateFormat, sp.CtimeFrom); err != nil {
|
||
log.Error("time.Parse(%v) error", sp.CtimeFrom)
|
||
stime = time.Date(2018, 1, 1, 0, 0, 0, 0, time.UTC)
|
||
}
|
||
}
|
||
if sp.CtimeTo != "" {
|
||
if etime, err = time.Parse(model.DateFormat, sp.CtimeTo); err != nil {
|
||
log.Error("time.Parse(%v) error", sp.CtimeTo)
|
||
etime = time.Date(2018, 1, 1, 0, 0, 0, 0, time.UTC)
|
||
}
|
||
}
|
||
action := strings.Split(sp.Action, ",")
|
||
r := d.es.NewRequest("log_audit").IndexByTime("log_audit_41", elastic.IndexTypeYear, stime, etime).WhereIn("action", action).
|
||
WhereRange("ctime", stime.Format(model.DateFormat), etime.Format(model.DateFormat), elastic.RangeScopeLcRc)
|
||
if sp.Pn <= 0 {
|
||
sp.Pn = 1
|
||
}
|
||
if sp.Ps <= 0 {
|
||
sp.Ps = 20
|
||
}
|
||
if sp.Order == "" {
|
||
sp.Order = "ctime"
|
||
}
|
||
if sp.Sort == "" {
|
||
sp.Sort = "desc"
|
||
}
|
||
r = r.Order(sp.Order, sp.Sort).Pn(int(sp.Pn)).Ps(int(sp.Ps))
|
||
if sp.Oid > 0 {
|
||
r = r.WhereEq("oid", strconv.FormatInt(sp.Oid, 10))
|
||
}
|
||
if sp.Mid > 0 {
|
||
r = r.WhereEq("int_0", sp.Mid)
|
||
}
|
||
if sp.Type > 0 {
|
||
r = r.WhereEq("type", sp.Type)
|
||
}
|
||
if sp.Other > 0 {
|
||
r = r.WhereEq("int_1", sp.Other)
|
||
}
|
||
log.Warn(r.Params())
|
||
err = r.Scan(c, &data)
|
||
if err != nil {
|
||
log.Error("r.Scan(%v) error(%v)", c, err)
|
||
return
|
||
}
|
||
if data == nil {
|
||
err = ecode.ServerErr
|
||
log.Error("log_audit error")
|
||
return
|
||
}
|
||
return
|
||
}
|