|
@@ -6,7 +6,8 @@ import (
|
|
|
)
|
|
|
|
|
|
func GetSessionByToken(token string) (item *CygxClptSession, err error) {
|
|
|
- sql := `SELECT * FROM cygx_clpt_session WHERE access_token=? AND expire_time> NOW() ORDER BY session_id DESC LIMIT 1 `
|
|
|
+ //sql := `SELECT * FROM cygx_clpt_session WHERE access_token=? AND expire_time> NOW() ORDER BY session_id DESC LIMIT 1 `
|
|
|
+ sql := `SELECT * FROM cygx_clpt_session WHERE access_token=? ORDER BY session_id DESC LIMIT 1 `
|
|
|
o := orm.NewOrm()
|
|
|
err = o.Raw(sql, token).QueryRow(&item)
|
|
|
return
|
|
@@ -24,7 +25,7 @@ type CygxClptSession struct {
|
|
|
UnionId string `description:"用户unionid,最大长度:64"`
|
|
|
}
|
|
|
|
|
|
-//添加用户session信息
|
|
|
+// 添加用户session信息
|
|
|
func AddCygxClptSession(item *CygxClptSession) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
_, err = o.Insert(item)
|
|
@@ -38,7 +39,7 @@ func GetXzsSessionCountByToken(token string) (count int, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户token详情
|
|
|
+// 获取用户token详情
|
|
|
func GetUnionidByToken(token string) (item *CygxClptSession, err error) {
|
|
|
sql := `SELECT * FROM cygx_xzs_session WHERE access_token=? LIMIT 1 `
|
|
|
o := orm.NewOrm()
|
|
@@ -46,7 +47,7 @@ func GetUnionidByToken(token string) (item *CygxClptSession, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据用户openid获取token
|
|
|
+// 根据用户openid获取token
|
|
|
func GetTokenByOpenId(mobile string) (item *CygxClptSession, err error) {
|
|
|
sql := `SELECT * FROM cygx_clpt_session WHERE mobile=? AND expire_time> NOW() ORDER BY session_id DESC LIMIT 1 `
|
|
|
o := orm.NewOrm()
|
|
@@ -54,7 +55,7 @@ func GetTokenByOpenId(mobile string) (item *CygxClptSession, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//用户绑定手机号时同时绑定外呼手机号
|
|
|
+// 用户绑定手机号时同时绑定外呼手机号
|
|
|
func BindSessionMobile(mobile, token string) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `UPDATE cygx_clpt_session SET mobile=? WHERE access_token=? `
|
|
@@ -62,9 +63,9 @@ func BindSessionMobile(mobile, token string) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据用户id和平台id获取用户关系
|
|
|
+// 根据用户id和平台id获取用户关系
|
|
|
func GetUserSessionByUserId(userId int) (item *CygxClptSession, err error) {
|
|
|
sql := `SELECT * FROM cygx_clpt_session WHERE user_id=? `
|
|
|
err = orm.NewOrm().Raw(sql, userId).QueryRow(&item)
|
|
|
return
|
|
|
-}
|
|
|
+}
|