mirror of
https://gitee.com/xiangheng/x_admin.git
synced 2025-10-10 18:40:17 +08:00
278 lines
8.1 KiB
Go
278 lines
8.1 KiB
Go
package monitorService
|
|
|
|
import (
|
|
"errors"
|
|
"x_admin/core"
|
|
"x_admin/core/request"
|
|
"x_admin/core/response"
|
|
"x_admin/model"
|
|
. "x_admin/schema/monitorSchema"
|
|
"x_admin/util"
|
|
"x_admin/util/convert_util"
|
|
"x_admin/util/excel2"
|
|
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
var MonitorClientService = NewMonitorClientService()
|
|
|
|
// NewMonitorClientService 初始化
|
|
func NewMonitorClientService() *monitorClientService {
|
|
return &monitorClientService{
|
|
db: core.GetDB(),
|
|
CacheUtil: util.CacheUtil{
|
|
Name: "monitorClient",
|
|
},
|
|
}
|
|
}
|
|
|
|
// monitorClientService 监控-客户端信息服务实现类
|
|
type monitorClientService struct {
|
|
db *gorm.DB
|
|
CacheUtil util.CacheUtil
|
|
}
|
|
|
|
// List 监控-客户端信息列表
|
|
func (service monitorClientService) GetModel(listReq MonitorClientListReq) *gorm.DB {
|
|
// 查询
|
|
dbModel := service.db.Model(&model.MonitorClient{})
|
|
if listReq.ProjectKey != nil {
|
|
dbModel = dbModel.Where("project_key = ?", *listReq.ProjectKey)
|
|
}
|
|
if listReq.ClientId != nil {
|
|
dbModel = dbModel.Where("client_id = ?", *listReq.ClientId)
|
|
}
|
|
if listReq.UserId != nil {
|
|
dbModel = dbModel.Where("user_id = ?", *listReq.UserId)
|
|
}
|
|
if listReq.Os != nil {
|
|
dbModel = dbModel.Where("os = ?", *listReq.Os)
|
|
}
|
|
if listReq.Browser != nil {
|
|
dbModel = dbModel.Where("browser = ?", *listReq.Browser)
|
|
}
|
|
if listReq.Country != nil {
|
|
dbModel = dbModel.Where("country = ?", *listReq.Country)
|
|
}
|
|
if listReq.Province != nil {
|
|
dbModel = dbModel.Where("province = ?", *listReq.Province)
|
|
}
|
|
if listReq.City != nil {
|
|
dbModel = dbModel.Where("city = ?", *listReq.City)
|
|
}
|
|
if listReq.Operator != nil {
|
|
dbModel = dbModel.Where("operator = ?", *listReq.Operator)
|
|
}
|
|
if listReq.Ip != nil {
|
|
dbModel = dbModel.Where("ip = ?", *listReq.Ip)
|
|
}
|
|
|
|
if listReq.Ua != nil {
|
|
dbModel = dbModel.Where("ua = ?", *listReq.Ua)
|
|
}
|
|
if listReq.CreateTimeStart != nil {
|
|
dbModel = dbModel.Where("create_time >= ?", *listReq.CreateTimeStart)
|
|
}
|
|
if listReq.CreateTimeEnd != nil {
|
|
dbModel = dbModel.Where("create_time <= ?", *listReq.CreateTimeEnd)
|
|
}
|
|
|
|
return dbModel
|
|
}
|
|
|
|
// List 监控-客户端信息列表
|
|
func (service monitorClientService) List(page request.PageReq, listReq MonitorClientListReq) (res response.PageResp, e error) {
|
|
// 分页信息
|
|
limit := page.PageSize
|
|
offset := page.PageSize * (page.PageNo - 1)
|
|
dbModel := service.GetModel(listReq)
|
|
// 总数
|
|
var count int64
|
|
err := dbModel.Count(&count).Error
|
|
if e = response.CheckErr(err, "失败"); e != nil {
|
|
return
|
|
}
|
|
// 数据
|
|
var modelList []model.MonitorClient
|
|
err = dbModel.Limit(limit).Offset(offset).Order("id desc").Find(&modelList).Error
|
|
if e = response.CheckErr(err, "查询失败"); e != nil {
|
|
return
|
|
}
|
|
result := []MonitorClientResp{}
|
|
convert_util.Copy(&result, modelList)
|
|
return response.PageResp{
|
|
PageNo: page.PageNo,
|
|
PageSize: page.PageSize,
|
|
Count: count,
|
|
Lists: result,
|
|
}, nil
|
|
}
|
|
|
|
// ListAll 监控-客户端信息列表
|
|
func (service monitorClientService) ListAll(listReq MonitorClientListReq) (res []MonitorClientResp, e error) {
|
|
dbModel := service.GetModel(listReq)
|
|
|
|
var modelList []model.MonitorClient
|
|
|
|
err := dbModel.Find(&modelList).Error
|
|
if e = response.CheckErr(err, "查询全部失败"); e != nil {
|
|
return
|
|
}
|
|
convert_util.Copy(&res, modelList)
|
|
return res, nil
|
|
}
|
|
|
|
func (service monitorClientService) DetailByClientId(ClientId string) (res MonitorClientResp, e error) {
|
|
if ClientId == "" {
|
|
return res, errors.New("ClientId不能为空")
|
|
}
|
|
var obj = model.MonitorClient{}
|
|
err := service.CacheUtil.GetCache("ClientId:"+ClientId, &obj)
|
|
if err != nil {
|
|
err := service.db.Where("client_id = ?", ClientId).Order("id DESC").Limit(1).First(&obj).Error
|
|
if e = response.CheckErrDBNotRecord(err, "数据不存在!"); e != nil {
|
|
return
|
|
}
|
|
if e = response.CheckErr(err, "获取详情失败"); e != nil {
|
|
return
|
|
}
|
|
service.CacheUtil.SetCache(obj.Id, obj)
|
|
service.CacheUtil.SetCache("ClientId:"+obj.ClientId, obj)
|
|
}
|
|
|
|
convert_util.Copy(&res, obj)
|
|
return
|
|
}
|
|
|
|
// Detail 监控-客户端信息详情
|
|
func (service monitorClientService) Detail(Id int) (res MonitorClientResp, e error) {
|
|
var obj = model.MonitorClient{}
|
|
err := service.CacheUtil.GetCache(Id, &obj)
|
|
if err != nil {
|
|
err := service.db.Where("id = ?", Id).Limit(1).First(&obj).Error
|
|
if e = response.CheckErrDBNotRecord(err, "数据不存在!"); e != nil {
|
|
return
|
|
}
|
|
if e = response.CheckErr(err, "获取详情失败"); e != nil {
|
|
return
|
|
}
|
|
service.CacheUtil.SetCache(obj.Id, obj)
|
|
service.CacheUtil.SetCache("ClientId:"+obj.ClientId, obj)
|
|
}
|
|
convert_util.Copy(&res, obj)
|
|
return
|
|
}
|
|
|
|
// ErrorUser 监控-客户端信息详情
|
|
func (service monitorClientService) ErrorUsers(error_id int) (res []MonitorClientResp, e error) {
|
|
var obj = []MonitorClientResp{}
|
|
service.db.Raw("SELECT client.*,list.width,list.height,list.create_time AS create_time from x_monitor_error_list as list right join x_monitor_client as client on client.id = list.cid where list.eid = ? Order by list.id DESC LIMIT 0,20", error_id).Scan(&obj)
|
|
|
|
convert_util.Copy(&res, obj)
|
|
return
|
|
}
|
|
|
|
// Add 监控-客户端信息新增
|
|
func (service monitorClientService) Add(addReq MonitorClientAddReq) (createId int, e error) {
|
|
var obj model.MonitorClient
|
|
convert_util.StructToStruct(addReq, &obj)
|
|
err := service.db.Create(&obj).Error
|
|
e = response.CheckMysqlErr(err)
|
|
if e != nil {
|
|
return 0, e
|
|
}
|
|
service.CacheUtil.SetCache(obj.Id, obj)
|
|
service.CacheUtil.SetCache("ClientId:"+obj.ClientId, obj)
|
|
createId = obj.Id
|
|
return
|
|
}
|
|
|
|
// Del 监控-客户端信息删除
|
|
func (service monitorClientService) Del(Id int) (e error) {
|
|
var obj model.MonitorClient
|
|
err := service.db.Where("id = ?", Id).Limit(1).First(&obj).Error
|
|
// 校验
|
|
if e = response.CheckErrDBNotRecord(err, "数据不存在!"); e != nil {
|
|
return
|
|
}
|
|
if e = response.CheckErr(err, "查询数据失败"); e != nil {
|
|
return
|
|
}
|
|
// 删除
|
|
err = service.db.Delete(&obj).Error
|
|
e = response.CheckErr(err, "删除失败")
|
|
service.CacheUtil.RemoveCache(obj.Id)
|
|
service.CacheUtil.RemoveCache("ClientId:" + obj.ClientId)
|
|
return
|
|
}
|
|
|
|
// DelBatch 用户协议-批量删除
|
|
func (service monitorClientService) DelBatch(Ids []string) (e error) {
|
|
var obj []model.MonitorClient
|
|
// 查询Ids对应的数据
|
|
err := service.db.Where("id in (?)", Ids).Find(&obj).Error
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if len(obj) == 0 {
|
|
return errors.New("数据不存在")
|
|
}
|
|
err = service.db.Where("id in (?)", Ids).Delete(model.MonitorClient{}).Error
|
|
if err != nil {
|
|
return err
|
|
}
|
|
// md5集合
|
|
var Clients []string
|
|
for _, v := range obj {
|
|
Clients = append(Clients, "ClientId:"+v.ClientId)
|
|
}
|
|
|
|
// 删除缓存
|
|
service.CacheUtil.RemoveCache(Ids)
|
|
service.CacheUtil.RemoveCache(Clients)
|
|
return nil
|
|
}
|
|
|
|
// 获取Excel的列
|
|
func (service monitorClientService) GetExcelCol() []excel2.Col {
|
|
var cols = []excel2.Col{
|
|
{Name: "项目key", Key: "ProjectKey", Width: 15},
|
|
{Name: "sdk生成的客户端id", Key: "ClientId", Width: 15},
|
|
{Name: "用户id", Key: "UserId", Width: 15},
|
|
{Name: "系统", Key: "Os", Width: 15},
|
|
{Name: "浏览器", Key: "Browser", Width: 15},
|
|
{Name: "城市", Key: "City", Width: 15},
|
|
{Name: "屏幕", Key: "Width", Width: 15, Decode: core.DecodeInt},
|
|
{Name: "屏幕高度", Key: "Height", Width: 15, Decode: core.DecodeInt},
|
|
{Name: "ua记录", Key: "Ua", Width: 15},
|
|
{Name: "创建时间", Key: "CreateTime", Width: 15, Decode: util.NullTimeUtil.DecodeTime},
|
|
}
|
|
// 还可以考虑字典，请求下来加上 Replace 实现替换导出
|
|
return cols
|
|
}
|
|
|
|
// ExportFile 监控-客户端信息导出
|
|
func (service monitorClientService) ExportFile(listReq MonitorClientListReq) (res []MonitorClientResp, e error) {
|
|
// 查询
|
|
dbModel := service.GetModel(listReq)
|
|
|
|
// 数据
|
|
var modelList []model.MonitorClient
|
|
err := dbModel.Order("id asc").Find(&modelList).Error
|
|
if e = response.CheckErr(err, "查询失败"); e != nil {
|
|
return
|
|
}
|
|
result := []MonitorClientResp{}
|
|
convert_util.Copy(&result, modelList)
|
|
return result, nil
|
|
}
|
|
|
|
// 导入
|
|
func (service monitorClientService) ImportFile(importReq []MonitorClientResp) (e error) {
|
|
var importData []model.MonitorClient
|
|
convert_util.Copy(&importData, importReq)
|
|
err := service.db.Create(&importData).Error
|
|
e = response.CheckErr(err, "添加失败")
|
|
return e
|
|
}
|