You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
297 lines
7.7 KiB
297 lines
7.7 KiB
package client
|
|
|
|
import (
|
|
"fmt"
|
|
"hudongzhuanjia/controllers"
|
|
"hudongzhuanjia/libs/im"
|
|
"hudongzhuanjia/libs/jwt"
|
|
"hudongzhuanjia/libs/wechat"
|
|
"hudongzhuanjia/logger"
|
|
"hudongzhuanjia/models"
|
|
activity_service "hudongzhuanjia/services/activity"
|
|
"hudongzhuanjia/utils/code"
|
|
"hudongzhuanjia/utils/define"
|
|
"time"
|
|
|
|
mpoauth2 "github.com/chanxuehong/wechat/mp/oauth2"
|
|
)
|
|
|
|
//用户
|
|
type UserCtl struct {
|
|
controllers.BaseCtl
|
|
}
|
|
|
|
// 录入登录
|
|
func (t *UserCtl) EntryLogin() {
|
|
account := t.MustGet("account")
|
|
password := t.MustGet("password")
|
|
activityId := t.MustGetInt("activity_id") // 需要获取
|
|
|
|
entryPeople := new(models.OrderEntryPerson)
|
|
exist, err := entryPeople.Auth(account, password, activityId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_ENTRYPEOPLE_NOT_EXIST, "录入人员不存在")
|
|
|
|
area := new(models.AreaStore)
|
|
exist, err = models.Get(area, entryPeople.AreaId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_AREASTORE_NOT_EXIST, "地区不存在")
|
|
|
|
activity := new(models.Activity)
|
|
exist, err = models.Get(activity, activityId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_ACTIVITY_NOT_EXIST, "互动不存在")
|
|
|
|
customer := new(models.Customer)
|
|
exist, err = models.Get(customer, entryPeople.Pid)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_CUSTOMER_NOT_EXIST, "客户不存在")
|
|
|
|
// 怎讲activity
|
|
token, err := jwt.GenJwtToken(define.TYPE_ENTRYPEOPLE, entryPeople.Id, customer.Id, customer.Pid, entryPeople.AreaId, entryPeople.ActivityId)
|
|
t.CheckErr(err)
|
|
t.SetSession(define.TOKEN, token)
|
|
entryPeople.Token = token
|
|
entryPeople.AreaName = area.Name
|
|
entryPeople.ActivityName = activity.Name
|
|
entryPeople.IsSpecial = customer.IsSpecial
|
|
t.JSON(map[string]interface{}{
|
|
"people": entryPeople,
|
|
})
|
|
}
|
|
|
|
func (t *UserCtl) WxLogin() {
|
|
activityId := t.MustGetInt("activity_id")
|
|
wxcode := t.MustGet("code")
|
|
|
|
logger.Error("微信code:", wxcode)
|
|
activity, exist, err := activity_service.GetActivityById(activityId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_ACTIVITY_NOT_EXIST, "互动不存在")
|
|
|
|
customer := new(models.Customer)
|
|
exist, err = models.Get(customer, activity.CustomerId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_CUSTOMER_NOT_EXIST, "客户不存在")
|
|
|
|
area := new(models.AreaStore)
|
|
exist, err = area.GetByCustomerId(customer.Id, activity.Id)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_AREASTORE_NOT_EXIST, "地区不存在")
|
|
|
|
token, err := wechat.GetToken(wxcode)
|
|
t.CheckErr(err)
|
|
if token.AccessToken == "" || token.OpenId == "" {
|
|
t.ERROR("code无效", code.MSG_ERR)
|
|
}
|
|
info, err := wechat.GetUserInfo(token)
|
|
t.CheckErr(err)
|
|
|
|
user := new(models.User)
|
|
exist, err = user.GetUserByOpenid(info.OpenId)
|
|
t.CheckErr(err)
|
|
|
|
user.Nickname = info.Nickname
|
|
user.Openid = info.OpenId
|
|
user.Gender = func() string {
|
|
if info.Sex == 1 {
|
|
return "男"
|
|
}
|
|
return "女"
|
|
}()
|
|
user.Avatar = info.HeadImageURL
|
|
user.Unionid = info.UnionId
|
|
user.City = info.City
|
|
user.Province = info.Province
|
|
user.Country = info.Country
|
|
user.CreatedAt = time.Now()
|
|
user.UpdatedAt = time.Now()
|
|
if !exist {
|
|
_, err = models.Add(user)
|
|
} else {
|
|
_, err = user.SaveUserInfo(user.Id)
|
|
}
|
|
t.CheckErr(err)
|
|
|
|
sign := new(models.SignUp)
|
|
exist, err = sign.GetByActivityId(activityId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_SIGN_UP_NOT_EXIST, "签到活动不存在")
|
|
|
|
history := new(models.SignHistory)
|
|
signExist, err := history.GetByUserId(activityId, activity.ArchId, user.Id, activity.RehearsalId, area.Id)
|
|
t.CheckErr(err)
|
|
var signIn = "未签到"
|
|
if customer.IsSpecial == 1 {
|
|
if signExist {
|
|
history = new(models.SignHistory)
|
|
history.Type = 0
|
|
history.UserId = user.Id
|
|
history.RehearsalId = activity.RehearsalId
|
|
history.ActivityId = activityId
|
|
history.SignRuleId = sign.Id
|
|
history.AreaId = area.Id
|
|
history.ArchId = activity.ArchId
|
|
history.Status = 2
|
|
_, err = models.Add(history)
|
|
t.CheckErr(err)
|
|
}
|
|
signIn = "已签到"
|
|
} else {
|
|
if signExist && history.Status == 2 { // 存在数据
|
|
signIn = "已签到"
|
|
}
|
|
}
|
|
|
|
jwtToken, err := jwt.GenJwtToken(define.TYPE_H5USER, user.Id, customer.Id, customer.Pid, area.Id, activityId)
|
|
t.CheckErr(err)
|
|
t.SetSession(define.TOKEN, jwtToken)
|
|
|
|
t.JSON(map[string]interface{}{
|
|
"user": user,
|
|
"token": jwtToken,
|
|
"activity": activity,
|
|
"sign_in": signIn,
|
|
"sign": signExist,
|
|
"sign_method": sign.SignMethod,
|
|
"real_sign_form": sign.RealSignJsonForm,
|
|
"real_sign_json": sign.RealSignJsonTitle,
|
|
"tag": "activity",
|
|
})
|
|
}
|
|
|
|
func (t *UserCtl) Login() {
|
|
//activityId := t.MustGetInt("activity_id")
|
|
wxcode := t.MustGet("code")
|
|
admin := t.DefaultInt("admin", 0)
|
|
|
|
user := new(models.User)
|
|
token, err := wechat.GetToken(wxcode)
|
|
t.CheckErr(err)
|
|
user.Openid = token.OpenId
|
|
exist, err := user.GetUserByOpenid(user.Openid)
|
|
t.CheckErr(err)
|
|
if !exist {
|
|
_, err = models.Add(user)
|
|
t.CheckErr(err)
|
|
}
|
|
|
|
area := &models.AreaStore{}
|
|
//if admin == 1 {
|
|
// username := t.MustGet("username")
|
|
// password := t.MustGet("password")
|
|
// exist, err := area.Login(activityId, username, password)
|
|
// t.CheckErr(err)
|
|
// t.Assert(exist, code.MSG_ERR_Authority, "不存在地区管理员")
|
|
// if area.UserId != user.Id {
|
|
// area.UserId = user.Id
|
|
// _, err = models.Update(area.Id, area, "user_id")
|
|
// t.CheckErr(err)
|
|
// }
|
|
//} else {
|
|
// exist, err := area.GetByUserId(activityId, user.Id)
|
|
// t.CheckErr(err)
|
|
// if exist { // 管理员
|
|
// admin = 1
|
|
// }
|
|
//}
|
|
|
|
jwtToken, err := jwt.GenJwtToken(define.TYPE_H5USER, user.Id, 0, 0, 0, 0)
|
|
t.CheckErr(err)
|
|
t.SetSession(define.TOKEN, jwtToken)
|
|
|
|
sign, err := im.AccountImport(fmt.Sprintf("%d", user.Id), user.Nickname, user.Avatar)
|
|
t.CheckErr(err)
|
|
user.Sig = sign
|
|
|
|
t.JSON(map[string]interface{}{
|
|
"user": user,
|
|
"token": jwtToken,
|
|
"area": area,
|
|
"admin": admin,
|
|
})
|
|
}
|
|
|
|
// 模拟wx login
|
|
func (t *UserCtl) DebugLogin() {
|
|
uid := t.DefaultInt("user_id", 1)
|
|
customerId := t.DefaultInt("customer_id", 1)
|
|
activityId := t.DefaultInt("activity_id", 5)
|
|
|
|
user := new(models.User)
|
|
exist, err := models.Get(user, uid)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_USER_NOT_EXIST, "用户不存在")
|
|
|
|
customer := new(models.Customer)
|
|
exist, err = models.Get(customer, customerId)
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_CUSTOMER_NOT_EXIST, "客户不存在")
|
|
|
|
area := new(models.AreaStore)
|
|
if customer.Pid == 0 {
|
|
exist, err = area.GetMainAreaById(activityId)
|
|
} else {
|
|
exist, err = area.GetAreaStoreById(customer.AreaId)
|
|
}
|
|
t.CheckErr(err)
|
|
t.Assert(exist, code.MSG_AREASTORE_NOT_EXIST, "地区不存在")
|
|
|
|
jwtToken, err := jwt.GenJwtToken(define.TYPE_H5USER, user.Id, customer.Id, customer.Pid, area.Id, activityId)
|
|
t.CheckErr(err)
|
|
t.SetSession(define.TOKEN, jwtToken)
|
|
t.JSON(map[string]interface{}{
|
|
"user": user,
|
|
"token": jwtToken,
|
|
})
|
|
}
|
|
|
|
type UserAuthCtl struct {
|
|
controllers.AuthorCtl
|
|
}
|
|
|
|
func (t *UserAuthCtl) SaveUserInfo() {
|
|
uid := t.GetAccountId()
|
|
|
|
info := mpoauth2.SessionInfo{}
|
|
t.RequestToStruct(&info)
|
|
if info.Nickname == "" && info.AvatarUrl == "" {
|
|
t.ERROR("参数错误", code.MSG_ERR_Param)
|
|
return
|
|
}
|
|
user := models.User{}
|
|
user.Nickname = info.Nickname
|
|
user.Gender = func() string {
|
|
if info.Gender == 1 {
|
|
return "男"
|
|
}
|
|
return "女"
|
|
}()
|
|
user.Avatar = info.AvatarUrl
|
|
user.Unionid = info.UnionId
|
|
user.City = info.City
|
|
user.Province = info.Province
|
|
user.Country = info.Country
|
|
_, err := user.SaveUserInfo(uid)
|
|
t.CheckErr(err)
|
|
//
|
|
//exist, err := models.Get(&user, uid)
|
|
//t.CheckErr(err)
|
|
//t.Assert(exist, code.MSG_USER_NOT_EXIST, "用户不存在")
|
|
|
|
user.Id = uid
|
|
sign, err := im.AccountImport(fmt.Sprintf("%d", user.Id), user.Avatar, user.Nickname)
|
|
t.CheckErr(err)
|
|
|
|
user.Sig = sign
|
|
t.JSON(user)
|
|
}
|
|
|
|
//退出
|
|
func (t *UserAuthCtl) Logout() {
|
|
if _, ok := t.Request.SESSION[define.TOKEN]; !ok {
|
|
t.ERROR("未登录", code.MSG_ERR_Authority)
|
|
}
|
|
t.DeleteSession(define.TOKEN)
|
|
t.SUCCESS("退出成功")
|
|
}
|