package controllers
|
|
import (
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/logger.git"
|
"strconv"
|
"vamicro/system-service/models"
|
"vamicro/system-service/service"
|
"vamicro/system-service/vo"
|
)
|
|
type UserController struct{}
|
|
// @Summary 添加用户
|
// @Description 添加用户
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Param user body vo.UserVo true "新建用户信息"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/user/add [post]
|
func (uc UserController) Add(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var userVo vo.UserVo
|
if err := c.BindJSON(&userVo);err !=nil {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
var sv service.UserService
|
flag,data := sv.AddUser(userVo)
|
if flag {
|
return &bhomeclient.Reply{ Success: true, Data: data }
|
} else {
|
return &bhomeclient.Reply{ Msg: data}
|
}
|
}
|
|
// @Summary 用户登录
|
// @Description 用户登录
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Param user body vo.UserVo true "用户信息"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/sys/login [post]
|
func (uc UserController) Login(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
userName := c.PostForm("username")
|
password := c.PostForm("password")
|
logger.Debug("username:", userName, "password:", password)
|
logger.Debug("新的newcode")
|
if userName == "" || password == "" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
var sv service.UserService
|
flag, info := sv.Login(vo.UserVo{
|
UserName: userName,
|
Password: password,
|
})
|
if flag {
|
return &bhomeclient.Reply{ Success: true, Data: info }
|
} else if "未授权用户" == info.RoleName {
|
return &bhomeclient.Reply{ Msg: "授权已过期，请购买新的授权"}
|
} else {
|
return &bhomeclient.Reply{ Msg: "用户名或密码错误"}
|
}
|
}
|
|
|
// @Summary 刷新用户token
|
// @Description 刷新用户token
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Param user body vo.UserVo true "用户信息"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/sys/refresh_token [get]
|
func (uc UserController) RefreshToken(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
userId := c.Header("Login_user_id")
|
logger.Debug("current userId:", userId)
|
|
return &bhomeclient.Reply{ Success: true, Data: ""}
|
}
|
|
// @Summary 用户退出登录
|
// @Description 用户退出登录
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/sys/logout [post]
|
func (uc UserController) Logout(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
return &bhomeclient.Reply{ Success: true, Msg: "退出成功"}
|
}
|
|
// @Summary 查找所有用户
|
// @Description 查找所有用户
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-u/users/findAllUser [get]
|
func (uc UserController) FindAllUser(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
userId := c.Header("Login_user_id")
|
if userId == "" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
var sv service.UserService
|
d,err := sv.FindAll(userId)
|
if err ==nil {
|
return &bhomeclient.Reply{ Success: true, Data: d}
|
} else {
|
return &bhomeclient.Reply{ Msg: err.Error()}
|
}
|
}
|
|
type DelUsers struct {
|
Ids []string `json:"ids"`
|
}
|
|
// @Security ApiKeyAuth
|
// @Summary 删除用户,支持批量删除
|
// @Description 删除用户，支持批量删除
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Param reqBody body controllers.DelUsers true "删除用户id数组参数"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/user/delUser [post]
|
func (uc UserController) DelUser(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var reqBody DelUsers
|
err := c.BindJSON(&reqBody)
|
if err != nil || len(reqBody.Ids) == 0 {
|
return &bhomeclient.Reply{ Msg: "请求参数有误"}
|
}
|
|
count := 0
|
for _,uId := range reqBody.Ids {
|
var u models.SysUser
|
if rows, e := u.SelectById(uId);e == nil && rows >0 && u.Username !="basic" {
|
if b,_ := u.DeleteById(uId);b {
|
count++
|
}
|
}
|
}
|
if count >0 {
|
return &bhomeclient.Reply{ Success: true, Data: "成功删除:"+strconv.Itoa(count)+"个"}
|
} else {
|
return &bhomeclient.Reply{ Msg: "删除失败"}
|
}
|
}
|
|
// @Summary 编辑此用户，返回此用户的权限菜单
|
// @Description 编辑此用户，返回此用户的权限菜单
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Param userId formData string true "用户id"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/user/findById [post]
|
func (uc UserController) FindById(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
loginUserId := c.Header("Login_user_id")
|
userId := c.PostForm("userId")
|
logger.Debug("userid拿到:::", userId)
|
if userId == "" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
var sv service.UserService
|
userAuth, err := sv.FindByUserId(userId)
|
if err != nil {
|
logger.Debug("userid查询失败:::", userId)
|
return &bhomeclient.Reply{ Msg: "查询失败"}
|
}
|
var sv2 service.SysMenuService
|
var menuIds = make(map [string]string, 0)
|
for _,item := range userAuth.Menus {
|
menuIds[item.Id] = item.Id
|
}
|
|
d, err := sv2.GetMenuTree(loginUserId, menuIds)
|
if err ==nil {
|
return &bhomeclient.Reply{ Success: true, Data: d }
|
} else {
|
return &bhomeclient.Reply{ Msg: "查询失败"}
|
}
|
}
|
|
// @Summary 更新用户名，密码和菜单权限
|
// @Description 更新用户名，密码和菜单权限
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Param userVo body vo.UserEditVo true "用户及权限信息"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/user/saveAuth [post]
|
func (uc UserController) SaveAuth(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var userEditVo vo.UserEditVo
|
userId := c.Header("Login_user_id")
|
err := c.BindJSON(&userEditVo)
|
if err !=nil || userEditVo.Id =="" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
var sv service.UserService
|
err = sv.SaveAuth(&userEditVo, userId)
|
if nil == err {
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Msg: "更新失败，" + err.Error()}
|
}
|
}
|
|
// @Security ApiKeyAuth
|
// @Summary 修改用户密码
|
// @Description 修改用户密码
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags 用户
|
// @Param userId formData string true "用户id"
|
// @Param oldPwd formData string true "旧密码"
|
// @Param newPwd formData string true "新密码"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/user/updatePwd [post]
|
func (uc UserController) UpdatePwd(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
userId := c.Header("Login_user_id")
|
oldPwd := c.PostForm("oldPwd")
|
newPwd := c.PostForm("newPwd")
|
tarGetId := c.PostForm("userId")
|
if tarGetId != "" {
|
if newPwd == "" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
} else {
|
if userId == "" || oldPwd == "" || newPwd == "" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
tarGetId = userId
|
}
|
|
var sv service.UserService
|
succ,err := sv.UpdatePwd(tarGetId, oldPwd, newPwd, userId)
|
if succ {
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Msg: err.Error()}
|
}
|
}
|
|
// @Security ApiKeyAuth
|
// @Summary 上传用户头像
|
// @Description 上传用户头像
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags 用户
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/users/uploadHeadPic [post]
|
func (uc UserController) UploadHeadPic(h *bhomeclient.WrapperHandler, c *bhomeclient.Request)*bhomeclient.Reply{
|
file,err := c.FormFile()
|
if err==nil {
|
var sv service.UserService
|
if file.Name == "" || len(file.Bytes) == 0 {
|
return &bhomeclient.Reply{ Msg: "头像上传错误"}
|
}
|
filename := file.Name
|
headPic ,err := sv.UploadHeadPic(file.Bytes, filename)
|
if err != nil {
|
if err.Error() == "pic format error" {
|
return &bhomeclient.Reply{ Msg: "头像只允许jpg,jpeg,png的格式"}
|
} else {
|
return &bhomeclient.Reply{ Msg: "头像上传错误!"}
|
}
|
}
|
return &bhomeclient.Reply{ Success: true, Data: headPic }
|
}
|
return &bhomeclient.Reply{ Msg: "未找到上传图片"}
|
}
|
|
// @Security ApiKeyAuth
|
// @Summary 更新用户头像，昵称
|
// @Description 更新用户头像，昵称
|
// @Accept json
|
// @Produce json
|
// @Tags 用户
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
func (uc UserController) UpdateProfile(h *bhomeclient.WrapperHandler, c *bhomeclient.Request)*bhomeclient.Reply{
|
var userEditVo vo.UserEditVo
|
err := c.BindJSON(&userEditVo)
|
if err !=nil || userEditVo.Id =="" {
|
return &bhomeclient.Reply{ Msg: "参数有误"}
|
}
|
var sv service.UserService
|
if sv.UpdateProfile(&userEditVo) {
|
var userSer service.UserService
|
Profile := userSer.GetProfile(userEditVo.Id)
|
return &bhomeclient.Reply{ Success: true,Msg: "更新成功",Data: Profile}
|
} else {
|
return &bhomeclient.Reply{ Msg: "更新失败"}
|
}
|
}
|
|
// @Security ApiKeyAuth
|
// @Summary 上传用户头像
|
// @Description 上传用户头像
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags 用户
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/users/defHeadPics [get]
|
func (uc UserController) DefHeadPics(h *bhomeclient.WrapperHandler, c *bhomeclient.Request)*bhomeclient.Reply {
|
var headPic models.DefHeadPic
|
headPics, err := headPic.FindAll()
|
if nil == err {
|
return &bhomeclient.Reply{ Success: true, Data: headPics }
|
} else {
|
return &bhomeclient.Reply{ Success: false, Data: headPics }
|
}
|
}
|
|
// @Security ApiKeyAuth
|
// @Summary 获取当前用户信息
|
// @Description 获取当前用户信息
|
// @Accept x-www-form-urlencoded
|
// @Produce json
|
// @Tags 用户
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-u/users/profile [get]
|
func (uc UserController) Profile(h *bhomeclient.WrapperHandler, c *bhomeclient.Request)*bhomeclient.Reply {
|
var userSer service.UserService
|
userId := c.Header("Login_user_id")
|
Profile := userSer.GetProfile(userId)
|
logger.Debug("getProfile1:",Profile.UseIconType)
|
return &bhomeclient.Reply{ Success: true, Data: Profile }
|
}
|
