Kaynağa Gözat

用户操作日志

hsun 1 yıl önce
ebeveyn
işleme
d46f27fd40

+ 11 - 0
models/admin_operate_record.go

@@ -0,0 +1,11 @@
+package models
+
+import "github.com/beego/beego/v2/client/orm"
+
+// ClearAdminOperateRecord 清理用户操作日志
+func ClearAdminOperateRecord(date string) (err error) {
+	o := orm.NewOrmUsingDB("eta")
+	sql := `DELETE FROM admin_operate_record WHERE create_time <= ?`
+	_, err = o.Raw(sql, date).Exec()
+	return
+}

+ 0 - 11
models/sys_user_login_record.go

@@ -1,11 +0,0 @@
-package models
-
-import "github.com/beego/beego/v2/client/orm"
-
-// ClearSysUserLoginRecord 清理用户登录日志
-func ClearSysUserLoginRecord(date string) (err error) {
-	o := orm.NewOrmUsingDB("eta")
-	sql := `DELETE FROM sys_user_login_record WHERE create_time <= ?`
-	_, err = o.Raw(sql, date).Exec()
-	return
-}

+ 28 - 0
services/admin.go

@@ -0,0 +1,28 @@
+package services
+
+import (
+	"context"
+	"eta/eta_task/models"
+	"eta/eta_task/services/alarm_msg"
+	"eta/eta_task/utils"
+	"fmt"
+	"time"
+)
+
+// ClearAdminOperateLog 清理三个月前的用户操作日志
+func ClearAdminOperateLog(cont context.Context) (err error) {
+	defer func() {
+		if err != nil {
+			tips := fmt.Sprintf("清理用户操作日志, ClearAdminOperateLog error: %s", err.Error())
+			fmt.Println(tips)
+			go alarm_msg.SendAlarmMsg(tips, 2)
+		}
+	}()
+
+	preTime := time.Now().Local().AddDate(0, -3, 0).Format(utils.FormatDateTime)
+	e := models.ClearAdminOperateRecord(preTime)
+	if e != nil {
+		err = fmt.Errorf("ClearAdminOperateRecord: %s", e.Error())
+	}
+	return
+}

+ 3 - 3
services/task.go

@@ -79,9 +79,9 @@ func releaseTask() {
 	clearReportSaveLog := task.NewTask("clearReportSaveLog", "0 15 23 * * *", ClearReportSaveLog)
 	task.AddTask("定时清理报告保存日志", clearReportSaveLog)
 
-	// 每天清理两个月前的用户登录日志
-	clearSysUserLoginLog := task.NewTask("clearSysUserLoginLog", "0 18 23 * * *", ClearUserLoginLog)
-	task.AddTask("定时清理用户登录日志", clearSysUserLoginLog)
+	// 每天清理三个月前的用户操作日志
+	clearAdminOperateLog := task.NewTask("clearAdminOperateLog", "0 20 23 * * *", ClearAdminOperateLog)
+	task.AddTask("定时清理用户操作日志", clearAdminOperateLog)
 }
 
 func RefreshData(cont context.Context) (err error) {

+ 0 - 28
services/user_login.go

@@ -1,28 +0,0 @@
-package services
-
-import (
-	"context"
-	"eta/eta_task/models"
-	"eta/eta_task/services/alarm_msg"
-	"eta/eta_task/utils"
-	"fmt"
-	"time"
-)
-
-// ClearUserLoginLog 每天清理两个月前的用户登录日志
-func ClearUserLoginLog(cont context.Context) (err error) {
-	defer func() {
-		if err != nil {
-			tips := fmt.Sprintf("用户登录日志清理, ClearUserLoginLog error: %s", err.Error())
-			fmt.Println(tips)
-			go alarm_msg.SendAlarmMsg(tips, 2)
-		}
-	}()
-
-	preTime := time.Now().Local().AddDate(0, -2, 0).Format(utils.FormatDateTime)
-	e := models.ClearSysUserLoginRecord(preTime)
-	if e != nil {
-		err = fmt.Errorf("ClearSysUserLoginRecord: %s", e.Error())
-	}
-	return
-}