lkness/bi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
1340691923@qq.com 2022-03-09 15:15:26 +08:00
parent 4179e50a26
commit f14cc804a6
1 changed files with 22 additions and 27 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
controller/realdata_controller.go
View File

@ -38,36 +38,33 @@ func (this RealDataController) List(ctx *fiber.Ctx) error {
appid := strconv.Itoa(reqData.Appid) appid := strconv.Itoa(reqData.Appid)
type Res struct { type Res struct {
CreateTime string `json:"create_time" db:"-"` CreateTime string `json:"create_time" db:"-"`
CreateTimeDb time.Time `json:"-" db:"create_time"` CreateTimeDb time.Time `json:"-" db:"create_time"`
EventName string `json:"event_name" db:"event_name"` EventName string `json:"event_name" db:"event_name"`
ReportData string `json:"report_data" db:"report_data"` ReportData string `json:"report_data" db:"report_data"`
} }
filterSql := "" filterSql := ""
date := strings.Split(reqData.Date,",") date := strings.Split(reqData.Date, ",")
args := []interface{}{appid} args := []interface{}{appid}
if len(date) == 2{ if len(date) == 2 {
filterSql = filterSql+ ` and create_time >= toDateTime(?) and create_time <=toDateTime(?) ` filterSql = filterSql + ` and create_time >= toDateTime(?) and create_time <=toDateTime(?) `
args = append(args, date[0],date[1]) args = append(args, date[0], date[1])
} }
logs.Logger.Sugar().Infof("reqData.SearchKw",reqData.SearchKw) if strings.TrimSpace(reqData.SearchKw) != "" {
if strings.TrimSpace(reqData.SearchKw)!="" { filterSql = filterSql + ` and event_name like '%` + reqData.SearchKw + `%' `
filterSql = filterSql+ ` and event_name like '%`+reqData.SearchKw+`%' `
} }
sql := `select report_data,event_name,create_time as create_time from xwl_real_time_warehousing prewhere table_id = ? `+filterSql+` order by create_time desc limit 0,1000;` sql := `select report_data,event_name,create_time as create_time from xwl_real_time_warehousing prewhere table_id = ? ` + filterSql + ` order by create_time desc limit 1000;`
logs.Logger.Sugar().Infof("sql",sql,args) logs.Logger.Sugar().Infof("sql", sql, args)
var res []Res var res []Res
err := db.ClickHouseSqlx.Select(&res,sql, err := db.ClickHouseSqlx.Select(&res, sql, args...)
args..., if err != nil {
)
if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
} }
for index:= range res{ for index := range res {
res[index].CreateTime = res[index].CreateTimeDb.Format(util.TimeFormat) res[index].CreateTime = res[index].CreateTimeDb.Format(util.TimeFormat)
} }
@ -94,7 +91,7 @@ func (this RealDataController) FailDataList(ctx *fiber.Ctx) error {
realDataService := realdata.RealDataService{} realDataService := realdata.RealDataService{}
res,err := realDataService.FailDataList(reqData.Minutes,reqData.Appid) res, err := realDataService.FailDataList(reqData.Minutes, reqData.Appid)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
} }
@ -111,7 +108,7 @@ func (this RealDataController) FailDataDesc(ctx *fiber.Ctx) error {
Appid int `json:"appid"` Appid int `json:"appid"`
ErrorReason string `json:"error_reason"` ErrorReason string `json:"error_reason"`
ErrorHandling string `json:"error_handling"` ErrorHandling string `json:"error_handling"`
ReportType string `json:"report_type"` ReportType string `json:"report_type"`
} }
var reqData ReqData var reqData ReqData
@ -128,7 +125,7 @@ func (this RealDataController) FailDataDesc(ctx *fiber.Ctx) error {
realDataService := realdata.RealDataService{} realDataService := realdata.RealDataService{}
res,err := realDataService.FailDataDesc(appid,startTime,endTime,errorReason,errorHandling,reportType) res, err := realDataService.FailDataDesc(appid, startTime, endTime, errorReason, errorHandling, reportType)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
} }
@ -152,19 +149,17 @@ func (this RealDataController) ReportCount(ctx *fiber.Ctx) error {
realDataService := realdata.RealDataService{} realDataService := realdata.RealDataService{}
res,err := realDataService.ReportCount(appid,startTime,endTime) res, err := realDataService.ReportCount(appid, startTime, endTime)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
} }
return this.Success(ctx, response.SearchSuccess, map[string]interface{}{"list": res}) return this.Success(ctx, response.SearchSuccess, map[string]interface{}{"list": res})
} }
//事件失败详情 //事件失败详情
func (this RealDataController) EventFailDesc(ctx *fiber.Ctx) error { func (this RealDataController) EventFailDesc(ctx *fiber.Ctx) error {
var reqData request.EventFailDescReq var reqData request.EventFailDescReq
if err := ctx.BodyParser(&reqData); err != nil { if err := ctx.BodyParser(&reqData); err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
@ -177,7 +172,7 @@ func (this RealDataController) EventFailDesc(ctx *fiber.Ctx) error {
realDataService := realdata.RealDataService{} realDataService := realdata.RealDataService{}
res,err := realDataService.EventFailDesc(appid,startTime,endTime,dataName) res, err := realDataService.EventFailDesc(appid, startTime, endTime, dataName)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
} }
@ -205,7 +200,7 @@ func (this RealDataController) AddDebugDeviceID(ctx *fiber.Ctx) error {
debugData := debug_data.DebugData{} debugData := debug_data.DebugData{}
err :=debugData.AddDebugDeviceID(appid,deviceID,remark,c.UserID) err := debugData.AddDebugDeviceID(appid, deviceID, remark, c.UserID)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
@ -230,7 +225,7 @@ func (this RealDataController) DelDebugDeviceID(ctx *fiber.Ctx) error {
debugData := debug_data.DebugData{} debugData := debug_data.DebugData{}
err :=debugData.DelDebugDeviceID(appid,deviceID,c.UserID) err := debugData.DelDebugDeviceID(appid, deviceID, c.UserID)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)
@ -252,7 +247,7 @@ func (this RealDataController) DebugDeviceIDList(ctx *fiber.Ctx) error {
debugData := debug_data.DebugData{} debugData := debug_data.DebugData{}
res,err :=debugData.DebugDeviceIDList(appid,c.UserID) res, err := debugData.DebugDeviceIDList(appid, c.UserID)
if err != nil { if err != nil {
return this.Error(ctx, err) return this.Error(ctx, err)