meiandClaude Fable 5
79774070fc
后端: - 修复登录校验、DB 并发(单例+WAL+纯Go sqlite)、会话密钥持久化等核心缺陷 - 新增 Timer CRUD/签到/手动触发、执行日志、仪表盘、驱动元数据等 API - 统一驱动接口: 带 context 的执行器、真实错误返回、敏感字段掩码、连通性测试 - 补全钉钉执行器; Timer 触发/提醒去重; 配置支持默认值与环境变量覆盖 前端: - Vite+Vue3+TS+Pinia+Element Plus, 由驱动元数据动态渲染配置表单 - 登录/仪表盘(倒计时环)/定时器/规则/账号/日志/设置页面, 支持暗色模式 - 主题色 #66ccff, 信号波纹 logo, go:embed 单二进制部署 构建: Dockerfile 增加前端构建阶段; 补充各驱动配置文档 Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
103 lines
2.3 KiB
Go
103 lines
2.3 KiB
Go
// Package log 提供规则执行日志的查询接口
|
|
package log
|
|
|
|
import (
|
|
"strconv"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/ssdomei232/goodBaby/api/response"
|
|
"github.com/ssdomei232/goodBaby/api/user"
|
|
"github.com/ssdomei232/goodBaby/handler/db"
|
|
"github.com/ssdomei232/goodBaby/model"
|
|
)
|
|
|
|
const (
|
|
defaultPageSize = 20
|
|
maxPageSize = 200
|
|
)
|
|
|
|
// HandleGetLogs 分页查询当前用户的执行日志
|
|
func HandleGetLogs(c *gin.Context) {
|
|
userInfo, err := user.GetUserInfoByGinCtx(c)
|
|
if err != nil {
|
|
response.Unauthorized(c, "获取用户信息失败")
|
|
return
|
|
}
|
|
|
|
gormDB, err := db.GetGormDB()
|
|
if err != nil {
|
|
response.ServerError(c, "服务器内部错误")
|
|
return
|
|
}
|
|
|
|
page := intQuery(c, "page", 1, 1, 1<<20)
|
|
pageSize := intQuery(c, "page_size", defaultPageSize, 1, maxPageSize)
|
|
|
|
query := gormDB.Model(&model.ExecutionLog{}).Where("uid = ?", userInfo.ID)
|
|
if ruleID := c.Query("rule_id"); ruleID != "" {
|
|
query = query.Where("rule_id = ?", ruleID)
|
|
}
|
|
if success := c.Query("success"); success == "true" || success == "false" {
|
|
query = query.Where("success = ?", success == "true")
|
|
}
|
|
|
|
var total int64
|
|
if err := query.Count(&total).Error; err != nil {
|
|
response.ServerError(c, "获取执行日志失败")
|
|
return
|
|
}
|
|
|
|
logs := []model.ExecutionLog{}
|
|
if err := query.Order("id DESC").
|
|
Offset((page - 1) * pageSize).
|
|
Limit(pageSize).
|
|
Find(&logs).Error; err != nil {
|
|
response.ServerError(c, "获取执行日志失败")
|
|
return
|
|
}
|
|
|
|
response.OK(c, gin.H{
|
|
"total": total,
|
|
"page": page,
|
|
"page_size": pageSize,
|
|
"items": logs,
|
|
})
|
|
}
|
|
|
|
// HandleClearLogs 清空当前用户的执行日志
|
|
func HandleClearLogs(c *gin.Context) {
|
|
userInfo, err := user.GetUserInfoByGinCtx(c)
|
|
if err != nil {
|
|
response.Unauthorized(c, "获取用户信息失败")
|
|
return
|
|
}
|
|
|
|
gormDB, err := db.GetGormDB()
|
|
if err != nil {
|
|
response.ServerError(c, "服务器内部错误")
|
|
return
|
|
}
|
|
|
|
if err := gormDB.Where("uid = ?", userInfo.ID).Delete(&model.ExecutionLog{}).Error; err != nil {
|
|
response.ServerError(c, "清空执行日志失败")
|
|
return
|
|
}
|
|
|
|
response.OK(c, "已清空执行日志")
|
|
}
|
|
|
|
func intQuery(c *gin.Context, key string, fallback, min, max int) int {
|
|
raw := c.Query(key)
|
|
if raw == "" {
|
|
return fallback
|
|
}
|
|
value, err := strconv.Atoi(raw)
|
|
if err != nil || value < min {
|
|
return fallback
|
|
}
|
|
if value > max {
|
|
return max
|
|
}
|
|
return value
|
|
}
|