95 lines
2.9 KiB
Go
95 lines
2.9 KiB
Go
package dataclean
|
|
|
|
import (
|
|
"91porn-server/models/v/usermod"
|
|
"time"
|
|
|
|
"91porn-server/common/log"
|
|
"91porn-server/models/l/loginlgmod"
|
|
"91porn-server/models/l/playlgmod"
|
|
"91porn-server/models/l/registermod"
|
|
"91porn-server/models/l/searchlogmod"
|
|
"91porn-server/models/l/visitlogmod"
|
|
"91porn-server/models/s/hotstatmod"
|
|
"91porn-server/models/s/kwrankmod"
|
|
"91porn-server/models/s/kwstatmod"
|
|
"91porn-server/models/s/statvidmod"
|
|
"91porn-server/models/v/noticefmtmod"
|
|
"91porn-server/models/v/useractmod"
|
|
)
|
|
|
|
func clearVisitLog(today time.Time, day int) {
|
|
count, err := visitlogmod.DataClean(today.AddDate(0, 0, -day))
|
|
if err != nil {
|
|
log.Error("skd dataclean clearVisitLog error", log.E(err))
|
|
return
|
|
}
|
|
log.Info("skd dataclean clearVisitLog cleaned", log.Any("count", count))
|
|
}
|
|
|
|
func clearPlayLog(today time.Time) {
|
|
if err := playlgmod.DeleteBeforeCreatedAt(nil, today.AddDate(0, 0, -3)); err != nil {
|
|
log.Error("skd dataclean clearPlayLog error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearSearchLog(today time.Time) {
|
|
if err := searchlogmod.DeleteBeforeCreatedAt(nil, today.AddDate(0, 0, -3)); err != nil {
|
|
log.Error("skd dataclean clearSearchLog error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearKeywordStat(today time.Time) {
|
|
if err := kwstatmod.DeleteBeforeSumDate(nil, today.AddDate(0, 0, -30)); err != nil {
|
|
log.Error("skd dataclean clearKeywordStat error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearNewsHot(today time.Time) {
|
|
if err := hotstatmod.DeleteBeforeCreatedAt(nil, today.AddDate(0, 0, -32)); err != nil {
|
|
log.Error("skd dataclean clearNewsHot error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearLoginTime(today time.Time) {
|
|
if err := loginlgmod.DeleteBeforeLoginTime(nil, today.AddDate(0, 0, -5)); err != nil {
|
|
log.Error("skd dataclean clearLoginTime error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearUserRegisterLog(today time.Time) {
|
|
if err := registermod.DeleteBeforeCreatedAt(nil, today.AddDate(0, 0, -7)); err != nil {
|
|
log.Error("skd dataclean clearUserRegisterLog error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearKwRankStat(today time.Time) {
|
|
if err := kwrankmod.DeleteBeforeSumDate(nil, today.AddDate(0, 0, -30)); err != nil {
|
|
log.Error("skd dataclean clearKwRankStat error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearVideoStat(today time.Time) {
|
|
if err := statvidmod.DeleteBeforeCreatedAt(nil, today.AddDate(0, 0, -7)); err != nil {
|
|
log.Error("skd dataclean clearVideoStat error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearNoticeFmt(today time.Time) {
|
|
if err := noticefmtmod.DeleteBeforeCreatedAt(nil, today.AddDate(0, 0, -5)); err != nil {
|
|
log.Error("skd dataclean clearNoticeFmt error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearUserAct(today time.Time) {
|
|
if err := useractmod.DeleteBeforeDailyDate(nil, today.AddDate(0, 0, -2)); err != nil {
|
|
log.Error("skd dataclean clearUserAct error", log.E(err))
|
|
}
|
|
}
|
|
|
|
func clearGuestUser(today time.Time) {
|
|
if err := usermod.DeleteGuestBeforeDate(nil, today.AddDate(0, 0, -7)); err != nil {
|
|
log.Error("skd dataclean clearGuestUser error", log.E(err))
|
|
}
|
|
}
|