db cache time to time.Hour

This commit is contained in:
源文雨 2023-04-11 13:59:33 +08:00
parent 28cb0491f7
commit 8050f12d51
20 changed files with 21 additions and 21 deletions

View File

@ -27,7 +27,7 @@ func init() {
db.DBPath = engine.DataFolder() + "bookreview.db" db.DBPath = engine.DataFolder() + "bookreview.db"
// os.RemoveAll(dbpath) // os.RemoveAll(dbpath)
_, _ = engine.GetLazyData("bookreview.db", true) _, _ = engine.GetLazyData("bookreview.db", true)
err := db.Open(time.Hour * 24) err := db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -26,7 +26,7 @@ func init() {
db.DBPath = en.DataFolder() + "cxh.db" db.DBPath = en.DataFolder() + "cxh.db"
// os.RemoveAll(dbpath) // os.RemoveAll(dbpath)
_, _ = en.GetLazyData("cxh.db", true) _, _ = en.GetLazyData("cxh.db", true)
err := db.Open(time.Hour * 24) err := db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -27,7 +27,7 @@ func init() {
db.DBPath = engine.DataFolder() + "cp.db" db.DBPath = engine.DataFolder() + "cp.db"
// os.RemoveAll(dbpath) // os.RemoveAll(dbpath)
_, _ = engine.GetLazyData("cp.db", true) _, _ = engine.GetLazyData("cp.db", true)
err := db.Open(time.Hour * 24) err := db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -35,7 +35,7 @@ func init() {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -27,7 +27,7 @@ func LoadText(dbfile string) error {
if err != nil { if err != nil {
return err return err
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
return err return err
} }

View File

@ -41,7 +41,7 @@ func init() {
if _, err := en.GetLazyData("dishes.db", true); err != nil { if _, err := en.GetLazyData("dishes.db", true); err != nil {
logrus.Warnln("[dish]获取菜谱数据库文件失败") logrus.Warnln("[dish]获取菜谱数据库文件失败")
} else if err = db.Open(time.Hour * 24); err != nil { } else if err = db.Open(time.Hour); err != nil {
logrus.Warnln("[dish]连接菜谱数据库失败") logrus.Warnln("[dish]连接菜谱数据库失败")
} else if err = db.Create("dishes", &dish{}); err != nil { } else if err = db.Create("dishes", &dish{}); err != nil {
logrus.Warnln("[dish]同步菜谱数据表失败") logrus.Warnln("[dish]同步菜谱数据表失败")

View File

@ -40,7 +40,7 @@ func init() {
PrivateDataFolder: "driftbottle", PrivateDataFolder: "driftbottle",
}) })
seaSide.DBPath = en.DataFolder() + "sea.db" seaSide.DBPath = en.DataFolder() + "sea.db"
err := seaSide.Open(time.Hour * 24) err := seaSide.Open(time.Hour)
if err != nil { if err != nil {
panic(err) panic(err)
} }

View File

@ -38,7 +38,7 @@ func init() {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -33,7 +33,7 @@ func init() {
getdb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool { getdb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
db.DBPath = engine.DataFolder() + "pics.db" db.DBPath = engine.DataFolder() + "pics.db"
_, _ = engine.GetLazyData("pics.db", false) _, _ = engine.GetLazyData("pics.db", false)
err := db.Open(time.Hour * 24) err := db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -32,7 +32,7 @@ func init() { // 插件主体
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -73,7 +73,7 @@ func init() { // 插件主体
go func() { go func() {
db.DBPath = engine.DataFolder() + "config.db" db.DBPath = engine.DataFolder() + "config.db"
err := db.Open(time.Hour * 24) err := db.Open(time.Hour)
if err != nil { if err != nil {
panic(err) panic(err)
} }

View File

@ -47,7 +47,7 @@ func (n *nsetu) scanall(path string) error {
root := os.DirFS(path) root := os.DirFS(path)
_ = n.db.Close() _ = n.db.Close()
_ = os.Remove(n.db.DBPath) _ = os.Remove(n.db.DBPath)
err := n.db.Open(time.Hour * 24) err := n.db.Open(time.Hour)
if err != nil { if err != nil {
return err return err
} }

View File

@ -43,7 +43,7 @@ func init() {
logrus.Infoln("[nsetu] set setu dir to", setupath) logrus.Infoln("[nsetu] set setu dir to", setupath)
} }
} }
err := ns.db.Open(time.Hour * 24) err := ns.db.Open(time.Hour)
if err != nil { if err != nil {
panic(err) panic(err)
} }

View File

@ -30,7 +30,7 @@ func init() {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -54,7 +54,7 @@ func init() { // 插件主体
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -82,7 +82,7 @@ var (
)) ))
getdb = fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool { getdb = fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
民政局.db.DBPath = engine.DataFolder() + "结婚登记表.db" 民政局.db.DBPath = engine.DataFolder() + "结婚登记表.db"
err := 民政局.db.Open(time.Hour * 24) err := 民政局.db.Open(time.Hour)
if err == nil { if err == nil {
// 创建群配置表 // 创建群配置表
err = 民政局.db.Create("updateinfo", &updateinfo{}) err = 民政局.db.Create("updateinfo", &updateinfo{})

View File

@ -66,7 +66,7 @@ func init() { // 插件主体
// 如果数据库不存在则下载 // 如果数据库不存在则下载
pool.db.DBPath = engine.DataFolder() + "SetuTime.db" pool.db.DBPath = engine.DataFolder() + "SetuTime.db"
_, _ = engine.GetLazyData("SetuTime.db", false) _, _ = engine.GetLazyData("SetuTime.db", false)
err := pool.db.Open(time.Hour * 24) err := pool.db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -17,7 +17,7 @@ var (
// 开启并检查数据库链接 // 开启并检查数据库链接
getDB = fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool { getDB = fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
database.db.DBPath = engine.DataFolder() + "steam.db" database.db.DBPath = engine.DataFolder() + "steam.db"
err := database.db.Open(time.Hour * 24) err := database.db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("[steam] ERROR: ", err)) ctx.SendChain(message.Text("[steam] ERROR: ", err))
return false return false

View File

@ -37,7 +37,7 @@ func init() {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false
} }
err = db.Open(time.Hour * 24) err = db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text("ERROR: ", err)) ctx.SendChain(message.Text("ERROR: ", err))
return false return false

View File

@ -100,7 +100,7 @@ func init() { // 插件主体
)) ))
getdb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool { getdb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
vilginfo.db.DBPath = engine.DataFolder() + "ernieVilg.db" vilginfo.db.DBPath = engine.DataFolder() + "ernieVilg.db"
err := vilginfo.db.Open(time.Hour * 24) err := vilginfo.db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text(serviceErr, err)) ctx.SendChain(message.Text(serviceErr, err))
return false return false
@ -302,7 +302,7 @@ func init() { // 插件主体
)) ))
getmodeldb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool { getmodeldb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
modelinfo.db.DBPath = engine.DataFolder() + "ernieModel.db" modelinfo.db.DBPath = engine.DataFolder() + "ernieModel.db"
err := modelinfo.db.Open(time.Hour * 24) err := modelinfo.db.Open(time.Hour)
if err != nil { if err != nil {
ctx.SendChain(message.Text(modelErr, err)) ctx.SendChain(message.Text(modelErr, err))
return false return false