7x31
/
anylink
mirror of https://github.com/bjdgyc/anylink.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

解决竞争问题

This commit is contained in:
wsczx 2022-10-17 18:05:06 +08:00
parent d277f1084f
commit 42f60a4d9d
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/dbdata/db.go
View File

@ -1,6 +1,8 @@
package dbdata package dbdata
import ( import (
"time"
"github.com/bjdgyc/anylink/base" "github.com/bjdgyc/anylink/base"
_ "github.com/go-sql-driver/mysql" _ "github.com/go-sql-driver/mysql"
_ "github.com/lib/pq" _ "github.com/lib/pq"
@ -19,6 +21,9 @@ func GetXdb() *xorm.Engine {
func initDb() { func initDb() {
var err error var err error
xdb, err = xorm.NewEngine(base.Cfg.DbType, base.Cfg.DbSource) xdb, err = xorm.NewEngine(base.Cfg.DbType, base.Cfg.DbSource)
// 初始化xorm时区
xdb.DatabaseTZ = time.Local
xdb.TZLocation = time.Local
if err != nil { if err != nil {
base.Fatal(err) base.Fatal(err)
} }

3
server/dbdata/user.go
View File

@ -135,9 +135,6 @@ func checkLocalUser(name, pwd, group string) error {
// 用户过期时间到达后，更新用户状态，并返回一个状态为过期的用户切片 // 用户过期时间到达后，更新用户状态，并返回一个状态为过期的用户切片
func CheckUserlimittime() []interface{} { func CheckUserlimittime() []interface{} {
//初始化xorm时区
xdb.DatabaseTZ = time.Local
xdb.TZLocation = time.Local
u := &User{Status: 2} u := &User{Status: 2}
xdb.Where("limittime <= ?", time.Now()).And("status = ?", 1).Update(u) xdb.Where("limittime <= ?", time.Now()).And("status = ?", 1).Update(u)
user := make(map[int64]User) user := make(map[int64]User)