|
@@ -17,7 +17,7 @@ import (
|
|
|
var ERR_NO_USER_RECORD = errors.New("用户关系没有入库")
|
|
|
var ERR_USER_NOT_BIND = errors.New("用户没有绑定")
|
|
|
|
|
|
-//通过openid获取用户信息
|
|
|
+// 通过openid获取用户信息
|
|
|
func GetWxUserItemByOpenId(openid string) (item *models.WxUserItem, err error) {
|
|
|
//通过openid获取用户关联信息
|
|
|
userRecord, userRecordErr := models.GetUserRecordByOpenId(openid)
|
|
@@ -77,7 +77,7 @@ func GetWxUserItemByOpenId(openid string) (item *models.WxUserItem, err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据用户id和平台id获取用户信息
|
|
|
+// 根据用户id和平台id获取用户信息
|
|
|
func GetWxUserItemByUserId(userId, platform int) (wxUserItem *models.WxUserItem, err error) {
|
|
|
//获取用户信息
|
|
|
wxUserItem, wxUserErr := models.GetWxUserItemByUserId(userId)
|
|
@@ -90,7 +90,7 @@ func GetWxUserItemByUserId(userId, platform int) (wxUserItem *models.WxUserItem,
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据用户邮箱和平台id获取用户信息
|
|
|
+// 根据用户邮箱和平台id获取用户信息
|
|
|
func GetWxUserItemByEmail(email string, platform int) (wxUserItem *models.WxUserItem, err error) {
|
|
|
//获取用户信息
|
|
|
wxUserItem, wxUserErr := models.GetWxUserItemByEmail(email)
|
|
@@ -104,7 +104,7 @@ func GetWxUserItemByEmail(email string, platform int) (wxUserItem *models.WxUser
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据用户手机号和平台id获取用户信息
|
|
|
+// 根据用户手机号和平台id获取用户信息
|
|
|
func GetWxUserItemByMobile(mobile string, platform int) (wxUserItem *models.WxUserItem, err error) {
|
|
|
//获取用户信息
|
|
|
wxUserItem, wxUserErr := models.GetWxUserItemByMobile(mobile)
|
|
@@ -117,7 +117,7 @@ func GetWxUserItemByMobile(mobile string, platform int) (wxUserItem *models.WxUs
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//根据用户unionid和平台id获取用户信息
|
|
|
+// 根据用户unionid和平台id获取用户信息
|
|
|
func GetWxUserItemByUnionId(unionId string, platform int) (wxUserItem *models.WxUserItem, err error) {
|
|
|
//获取用户信息
|
|
|
wxUserItem, wxUserErr := models.GetWxUserItemByUnionid(unionId)
|
|
@@ -130,7 +130,7 @@ func GetWxUserItemByUnionId(unionId string, platform int) (wxUserItem *models.Wx
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//通过用户 关系表记录 和 用户记录 格式化返回 用户数据
|
|
|
+// 通过用户 关系表记录 和 用户记录 格式化返回 用户数据
|
|
|
func formatWxUserAndUserRecord(wxUser *models.WxUserItem, userRecord *models.UserRecord) {
|
|
|
wxUser.OpenId = userRecord.OpenId
|
|
|
wxUser.UnionId = userRecord.UnionId
|
|
@@ -141,7 +141,7 @@ func formatWxUserAndUserRecord(wxUser *models.WxUserItem, userRecord *models.Use
|
|
|
wxUser.SessionKey = userRecord.SessionKey
|
|
|
}
|
|
|
|
|
|
-//通过用户 用户记录 和 来源平台 格式化返回 用户数据
|
|
|
+// 通过用户 用户记录 和 来源平台 格式化返回 用户数据
|
|
|
func formatWxUser(wxUser *models.WxUserItem, platform int) {
|
|
|
//根据用户id和平台id获取用户关系
|
|
|
userRecord, userRecordErr := models.GetUserRecordByUserId(wxUser.UserId, platform)
|
|
@@ -169,7 +169,7 @@ func formatWxUser(wxUser *models.WxUserItem, platform int) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//用户绑定
|
|
|
+// 用户绑定
|
|
|
func BindWxUser(openid, mobile, email, countryCode string) (wxUser *models.WxUserItem, err error) {
|
|
|
if mobile == "" && email == "" {
|
|
|
err = errors.New("手机号或邮箱必填一个")
|
|
@@ -268,7 +268,7 @@ func BindWxUser(openid, mobile, email, countryCode string) (wxUser *models.WxUse
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//微信登录
|
|
|
+// 微信登录
|
|
|
func WxLogin(code, openId, unionId string, wxUserInfo *WxUserInfo) (token string, userId, firstLogin, permission int, err error) {
|
|
|
if unionId == "" {
|
|
|
unionId = wxUserInfo.Unionid
|
|
@@ -374,7 +374,7 @@ func UserLogin() {
|
|
|
|
|
|
}
|
|
|
|
|
|
-//添加第三方用户(微信)记录
|
|
|
+// 添加第三方用户(微信)记录
|
|
|
func AddUserRecord(openId, unionId, nickName, realName, province, city, country, headimgurl, sessionKey string, platform, sex, subscribe int) (userRecord *models.UserRecord, err error) {
|
|
|
find, err := models.GetUserRecordByOpenId(openId)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
@@ -407,7 +407,7 @@ func AddUserRecord(openId, unionId, nickName, realName, province, city, country,
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//每天新增,删除的白名单
|
|
|
+// 每天新增,删除的白名单
|
|
|
func SendEmailUserWhiteListChange(cont context.Context) (err error) {
|
|
|
var msg string
|
|
|
var fieldStr string
|
|
@@ -757,7 +757,7 @@ func SendEmailUserWhiteListChange(cont context.Context) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//获取用户权限
|
|
|
+// 获取用户权限
|
|
|
func GetUserhasPermission(user *models.WxUserItem) (hasPermission int, err error) {
|
|
|
//判断是否已经申请过
|
|
|
applyCount, err := models.GetApplyRecordCount(user.UserId)
|
|
@@ -783,7 +783,7 @@ func GetUserhasPermission(user *models.WxUserItem) (hasPermission int, err error
|
|
|
hasPermission = 4
|
|
|
}
|
|
|
} else {
|
|
|
- if strings.Contains(companyPermission, "医药") || strings.Contains(companyPermission, "科技") || strings.Contains(companyPermission, "消费") || strings.Contains(companyPermission, "智造") {
|
|
|
+ if strings.Contains(companyPermission, "医药") || strings.Contains(companyPermission, "科技") || strings.Contains(companyPermission, "消费") || strings.Contains(companyPermission, "智造") || strings.Contains(companyPermission, "策略") {
|
|
|
hasPermission = 1
|
|
|
}
|
|
|
}
|
|
@@ -791,7 +791,7 @@ func GetUserhasPermission(user *models.WxUserItem) (hasPermission int, err error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//每周五发送当前所有的权益用户
|
|
|
+// 每周五发送当前所有的权益用户
|
|
|
func SendEmailAllUserWithRAI() (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -897,7 +897,7 @@ func SendEmailAllUserWithRAI() (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//每周五发送发送这些公司下的用户
|
|
|
+// 每周五发送发送这些公司下的用户
|
|
|
func SendEmailAllUserWithCompany() (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|