|
@@ -15,7 +15,7 @@ import (
|
|
|
var ERR_NO_ADMIN_RECORD = errors.New("用户关系没有入库")
|
|
|
var ERR_ADMIN_NOT_BIND = errors.New("用户没有绑定")
|
|
|
|
|
|
-//通过openid获取用户信息
|
|
|
+// 通过openid获取用户信息
|
|
|
func GetAdminUserItemByOpenId(openid string) (item *custom.AdminWx, err error) {
|
|
|
item = &custom.AdminWx{}
|
|
|
|
|
@@ -78,7 +78,7 @@ func GetAdminUserItemByOpenId(openid string) (item *custom.AdminWx, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据管理员id和平台id获取用户信息
|
|
|
+// 根据管理员id和平台id获取用户信息
|
|
|
func GetAdminUserItemByAdminId(adminId, platform int) (item *custom.AdminWx, err error) {
|
|
|
item = &custom.AdminWx{}
|
|
|
//获取用户信息
|
|
@@ -92,7 +92,7 @@ func GetAdminUserItemByAdminId(adminId, platform int) (item *custom.AdminWx, err
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//通过用户 关系表记录 和 用户记录 格式化返回 用户数据
|
|
|
+// 通过用户 关系表记录 和 用户记录 格式化返回 用户数据
|
|
|
func formatWxUserAndUserRecord(adminWx *custom.AdminWx, adminRecord *admin_record.AdminRecord) {
|
|
|
adminWx.OpenId = adminRecord.OpenId
|
|
|
adminWx.UnionId = adminRecord.UnionId
|
|
@@ -109,7 +109,7 @@ func formatWxUserAndUserRecord(adminWx *custom.AdminWx, adminRecord *admin_recor
|
|
|
//wxUser.BindAccount = userRecord.BindAccount
|
|
|
}
|
|
|
|
|
|
-//通过用户 用户记录 和 来源平台 格式化返回 用户数据
|
|
|
+// 通过用户 用户记录 和 来源平台 格式化返回 用户数据
|
|
|
func formatWxUser(adminWx *custom.AdminWx, platform int) {
|
|
|
//根据用户id和平台id获取用户关系
|
|
|
adminRecord, adminRecordErr := admin_record.GetAdminRecordByAdminId(adminWx.AdminId, platform)
|
|
@@ -130,21 +130,24 @@ func formatWxUser(adminWx *custom.AdminWx, platform int) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//用户绑定
|
|
|
-func BindWxUser(openid, userName, password string, registerPlatform int) (adminWx *custom.AdminWx, err error) {
|
|
|
+// BindWxUser 用户绑定
|
|
|
+func BindWxUser(openid, userName, password string, registerPlatform int) (adminWx *custom.AdminWx, err error, errMsg string) {
|
|
|
if userName == "" || password == "" {
|
|
|
- err = errors.New("账号密码必填")
|
|
|
+ errMsg = `账号密码必填`
|
|
|
+ err = errors.New(errMsg)
|
|
|
return
|
|
|
}
|
|
|
//根据账号密码获取管理员信息(校验账号密码是否正常)
|
|
|
adminInfo, err := admin.CheckAdmin(userName, password)
|
|
|
if err != nil {
|
|
|
if err.Error() != utils.ErrNoRow() {
|
|
|
- err = errors.New("账号或密码错误")
|
|
|
+ errMsg = `账号或密码错误`
|
|
|
+ err = errors.New(errMsg)
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
if adminInfo.Enabled == 0 {
|
|
|
+ errMsg = `账号已被禁用,请联系管理员`
|
|
|
err = errors.New("您的账号已被禁用,如需登录,请联系管理员")
|
|
|
return
|
|
|
}
|
|
@@ -191,13 +194,13 @@ func BindWxUser(openid, userName, password string, registerPlatform int) (adminW
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//用户解绑
|
|
|
+// 用户解绑
|
|
|
func UnbindWxUser(openid string) (err error) {
|
|
|
err = admin_record.UnBindAdminRecordByOpenid(openid)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//微信登录
|
|
|
+// 微信登录
|
|
|
func WxLogin(wxPlatform int, wxAccessToken *WxAccessToken, wxUserInfo *WxUserInfo) (token string, adminWx *custom.AdminWx, err error, errMsg string) {
|
|
|
errMsg = `微信登录失败`
|
|
|
openId := wxAccessToken.Openid
|
|
@@ -277,7 +280,7 @@ QUERY_WX_USER:
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//添加第三方用户(微信)记录
|
|
|
+// 添加第三方用户(微信)记录
|
|
|
func AddUserRecord(openId, unionId, nickName, realName, province, city, country, headimgurl, sessionKey string, platform, sex, subscribe int) (adminRecord *admin_record.AdminRecord, err error) {
|
|
|
find, err := admin_record.GetAdminRecordByOpenId(openId)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|