go_process_manager/internal/app/repository/log.go

package repository

import (
	"context"

	"github.com/lzh-1625/go_process_manager/internal/app/model"
	"github.com/lzh-1625/go_process_manager/internal/app/repository/query"
	"github.com/lzh-1625/go_process_manager/log"
)

type logRepository struct{}

var LogRepository = new(logRepository)

func (l *logRepository) InsertLog(data model.ProcessLog) {
	if err := db.Create(&data).Error; err != nil {
		log.Logger.Errorw("日志插入失败", "err", err)
	}
}

func (l *logRepository) SearchLog(req model.GetLogReq) (result []*model.ProcessLog, total int64) {
	q := query.ProcessLog.WithContext(context.TODO())
	if req.Match.Name != "" {
		q = q.Where(query.ProcessLog.Name.Eq(req.Match.Name))
	}
	if req.Match.Using != "" {
		q = q.Where(query.ProcessLog.Using.Eq(req.Match.Using))
	}
	if req.Match.Log != "" {
		q = q.Where(query.ProcessLog.Log.Like("%" + req.Match.Log + "%"))
	}
	if req.Sort == "desc" {
		q = q.Order(query.ProcessLog.Time.Desc())
	}
	if req.TimeRange.StartTime != 0 {
		q = q.Where(query.ProcessLog.Time.Gte(req.TimeRange.StartTime))
	}
	if req.TimeRange.EndTime != 0 {
		q = q.Where(query.ProcessLog.Time.Lte(req.TimeRange.EndTime))
	}
	if len(req.FilterName) != 0 {
		q = q.Where(query.ProcessLog.Name.In(req.FilterName...))
	}
	result, total, _ = q.FindByPage(req.Page.From, req.Page.Size)
	return
}