-
Notifications
You must be signed in to change notification settings - Fork 0
/
run_visit.go
38 lines (36 loc) · 1.19 KB
/
run_visit.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
package BaseFileSys
import (
BaseConfig "github.com/fotomxq/weeekj_core/v5/base/config"
CoreFilter "github.com/fotomxq/weeekj_core/v5/core/filter"
CoreLog "github.com/fotomxq/weeekj_core/v5/core/log"
CoreSQL "github.com/fotomxq/weeekj_core/v5/core/sql"
Router2SystemConfig "github.com/fotomxq/weeekj_core/v5/router2/system_config"
"time"
)
// 定时删除超过时间的访问记录
func runVisit() {
//捕捉异常
defer func() {
if r := recover(); r != nil {
CoreLog.Error("file visit run, ", r)
}
}()
//获取配置
configData, err := BaseConfig.GetDataString("FileVisitExpireTime")
if err != nil {
CoreLog.Error("file visit run, get config by FileVisitExpireTime, ", err)
configData = "-15120h"
}
//获取过期时间
expireAt, err := CoreFilter.GetTimeByAdd(configData)
if err != nil {
CoreLog.Error("file visit run, get expire time, ", err)
expireAt = CoreFilter.GetNowTime().Add(0 - time.Hour*15120)
}
//直接删除旧的数据
if _, err = CoreSQL.DeleteAll(Router2SystemConfig.MainDB.DB, "core_file_claim_visit", "create_at < :expire_at", map[string]interface{}{
"expire_at": expireAt,
}); err != nil {
//CoreLog.Error("file visit run, delete expire data, ", err)
}
}