|
@@ -3,6 +3,7 @@ package session
|
|
|
import (
|
|
|
"gorm.io/gorm"
|
|
|
"hongze/hongze_yb/global"
|
|
|
+ "time"
|
|
|
)
|
|
|
|
|
|
// GetTokenByOpenId 根据用户id获取token
|
|
@@ -11,6 +12,12 @@ func GetTokenByOpenId(openID string) (item *Session, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+// GetTokenByToken 根据token获取信息
|
|
|
+func GetTokenByToken(token string) (item *Session, err error) {
|
|
|
+ err = getDb().Where("access_token = ? and expire_time> ? ", token, time.Now()).Order("session_id DESC").First(&item).Error
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
// 获取数据库链接
|
|
|
func getDb() *gorm.DB {
|
|
|
return global.MYSQL["rddp"]
|