97 lines
2.6 KiB
Go
97 lines
2.6 KiB
Go
package api
|
||
|
||
import (
|
||
"github.com/kataras/iris/v12"
|
||
"github.com/sirupsen/logrus"
|
||
"main/database"
|
||
"main/model"
|
||
"main/utils"
|
||
"strconv"
|
||
"strings"
|
||
)
|
||
|
||
func getSystem(ctx iris.Context) {
|
||
username := utils.GetLoginUser(ctx)
|
||
if utils.DataIsNil(username) {
|
||
return
|
||
}
|
||
date := ctx.URLParam("date")
|
||
//username := "admin"
|
||
db := database.GetInstance().GetMysqlDb()
|
||
var systemList []resSystem
|
||
var ids []int
|
||
if err := db.Model(&model.SysInfo{}).Select("max(id)").Where("date = ? and username = ?", date, username.Username).Group("ip").Scan(&ids).Error; err != nil {
|
||
logrus.Errorln("sql执行失败：", err)
|
||
}
|
||
if err := db.Model(&model.SysInfo{}).Where("id in (?)", ids).Find(&systemList).Error; err != nil {
|
||
logrus.Errorln("sql执行失败：", err)
|
||
}
|
||
err := ctx.JSON(utils.FormatRes(iris.StatusOK, "", systemList))
|
||
if utils.ErrHandle(ctx, err) {
|
||
return
|
||
}
|
||
}
|
||
|
||
// 获取当前系统信息
|
||
func getSysInfo(ctx iris.Context) {
|
||
username := utils.GetLoginUser(ctx)
|
||
if utils.DataIsNil(username) {
|
||
return
|
||
}
|
||
//username := "admin"
|
||
date := ctx.URLParam("date")
|
||
ip := ctx.URLParam("ip")
|
||
db := database.GetInstance().GetMysqlDb()
|
||
var sysInfoList []model.SysInfo
|
||
var res []resSysInfo
|
||
if err := db.Where("username = ? and date = ? and ip = ?", username.Username, date, ip).Find(&sysInfoList).Error; err != nil {
|
||
logrus.Errorln("sql执行失败：", err)
|
||
}
|
||
for _, sysInfo := range sysInfoList {
|
||
var diskList []resDisk
|
||
diskLists := strings.Split(sysInfo.DiskPoint, ",")
|
||
for i, disk := range diskLists {
|
||
if strings.Contains(disk, "docker") {
|
||
continue
|
||
}
|
||
diskPer, err := strconv.ParseFloat(strings.Split(sysInfo.DiskPer, ",")[i], 64)
|
||
if utils.ErrHandle(ctx, err) {
|
||
return
|
||
}
|
||
diskList = append(diskList, resDisk{
|
||
Point: disk,
|
||
Total: strings.Split(sysInfo.DiskTotal, ",")[i],
|
||
Used: strings.Split(sysInfo.DiskUsed, ",")[i],
|
||
Per: utils.Round(diskPer, 2),
|
||
})
|
||
}
|
||
res = append(res, resSysInfo{
|
||
Datetime: sysInfo.Datetime,
|
||
CpuPer: utils.Round(sysInfo.CpuPer, 2),
|
||
Mem: resMem{
|
||
MemPer: utils.Round(sysInfo.MemPer, 2),
|
||
MemUsed: sysInfo.MemUsed,
|
||
MemTotal: sysInfo.MemTotal,
|
||
},
|
||
Disk: diskList,
|
||
Net: resNet{
|
||
Sent: sysInfo.SentSpeed,
|
||
Rec: sysInfo.RecSpeed,
|
||
},
|
||
})
|
||
}
|
||
err := ctx.JSON(utils.FormatRes(iris.StatusOK, "", res))
|
||
if utils.ErrHandle(ctx, err) {
|
||
return
|
||
}
|
||
}
|
||
|
||
//func updateSysInfo(ctx iris.Context) {
|
||
// date := ctx.URLParam("date")
|
||
// crontab.UpdateSysInfo(date)
|
||
// err := ctx.JSON(utils.FormatRes(iris.StatusOK, "", fmt.Sprintf("%s 日期数据同步完成", date)))
|
||
// if utils.ErrHandle(ctx, err) {
|
||
// return
|
||
// }
|
||
//}
|