opms_backend/opms_admin/app/handler/user.go

package handler

import (
	"context"
	"dashoo.cn/micro/app/model"
	"dashoo.cn/micro/app/service"
	"dashoo.cn/opms_libary/myerrors"
	"github.com/gogf/gf/errors/gerror"
	"github.com/gogf/gf/util/gvalid"

	"dashoo.cn/common_definition/comm_def"

	"github.com/gogf/gf/frame/g"
)

type User struct{}

// GetList 获取用户列表
func (h *User) GetList(ctx context.Context, req *model.SysUserSearchReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if req.PageSize == 0 {
		req.PageSize = DefaultPageNum
	}
	userService, err := service.NewUserService(ctx)
	if err != nil {
		g.Log().Error(err)
		return err
	}

	total, list, err := userService.GetUserList(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	rsp.Data = g.Map{"list": list, "total": total}
	return nil
}

// Create 添加用户
func (h *User) Create(ctx context.Context, req *model.AddUserReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	//req.RoleIds = utils.IntArrayToIdsString(req.RoleArray)
	//req.PostIds = utils.IntArrayToIdsString(req.PostArray)
	userService, err := service.NewUserService(ctx)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	//userinfo, err := micro_srv.GetUserInfo(ctx)
	//if err != nil {
	//	return err
	//}
	err = userService.AddUser(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	return nil
}

// UpdateById 更新用户
func (h *User) UpdateById(ctx context.Context, req *model.EditUserReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if req.Id == 0 {
		return NoParamsErr
	}
	if err := gvalid.CheckStruct(ctx, req, nil); err != nil {
		return err
	}
	//req.RoleIds = utils.IntArrayToIdsString(req.RoleArray)
	//req.PostIds = utils.IntArrayToIdsString(req.PostArray)
	userService, err := service.NewUserService(ctx)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	// 获取用户信息
	//userInfo, err := micro_srv.GetUserInfo(ctx)
	//if err != nil {
	//	return err
	//}
	err = userService.EditUser(req)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	return nil
}

//// GetAddOrUpdateEntity 获取用户实体信息
//func (e *User) GetAddOrUpdateEntity(ctx context.Context, req *comm_def.IdReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetAddOrUpdateEntity request @ " + tenant)
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//
//	data, err := service.GetEntity(req.Id)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	// 获取用户权限 角色
//	permissionService, err := permission.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	userRoles, err := permissionService.GetRoleIdsByUser(gconv.Int32(req.Id))
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	userPositions, err := permissionService.GetPositionIdsByUser(gconv.Int32(req.Id))
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//
//	rsp.Data = g.Map{
//		"entity":   data,
//		"role_ids": convert.ToStringArray(userRoles),
//		"post_ids": convert.ToStringArray(userPositions),
//	}
//	return nil
//}
//
//// GetEntityByUuId 根据UUID获取用户实体信息
//func (e *User) GetEntityByUuId(ctx context.Context, req *user_def.UuIdReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetEntityByUuId request @ " + tenant)
//	// 参数校验
//	if req.Uuid == "" {
//		return NoParamsErr
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	data, err := service.GetEntityByUuId(req.Uuid)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = data
//	return nil
//}

// DeleteByIds 删除 支持批量删除
func (h *User) DeleteByIds(ctx context.Context, req *comm_def.IdsReq, rsp *comm_def.CommonMsg) error {
	// 参数校验
	if len(req.Ids) == 0 {
		return NoParamsErr
	}
	userService, err := service.NewUserService(ctx)
	if err != nil {
		g.Log().Error(err)
		return gerror.New("系统异常，请重新尝试")
	}

	err = userService.DeleteUserByIds(ctx, req.Ids)
	_, err, rsp.Code, rsp.Msg = myerrors.CheckError(err)
	if err != nil {
		g.Log().Error(err)
		return err
	}
	return nil
}

//// ResetPassword 密码重置（管理员进行操作）
//func (e *User) ResetPassword(ctx context.Context, req *user_def.ResetPwdReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.ResetPassword request @ " + tenant)
//	if req.Id == 0 || req.Password == "" {
//		return NoParamsErr
//	}
//	if err = gvalid.CheckStruct(ctx, req, nil); err != nil {
//		return err
//	}
//	// todo:校验用户是否有修改权限
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	userInfo, err := micro_srv.GetUserInfo(ctx)
//	if err != nil {
//		return err
//	}
//	err = service.ResetPassword(&userInfo, req.Id, req.Password)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	return nil
//}
//
//// SetStatus 设置用户状态
//func (e *User) SetStatus(ctx context.Context, req *user_def.SetStatusReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.SetStatus request @ " + tenant)
//	// 参数校验
//	if req.Id == 0 {
//		return NoParamsErr
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	userInfo, err := micro_srv.GetUserInfo(ctx)
//	if err != nil {
//		return err
//	}
//	err = service.SetStatus(&userInfo, req.Id, req.Enabled)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	return nil
//}
//
//// GetUserBelongDept 获取部门下所属用户
//func (e *User) GetUserBelongDept(ctx context.Context, req *user_def.DeptIdReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetUserBelongDept request @ " + tenant)
//	// 参数校验
//	if req.DeptId == 0 {
//		return NoParamsErr
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//
//	list, err := service.GetUserBelongDept(req.DeptId)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = list
//	return nil
//}
//
//// GetIdByUuid 根据uuid 获取用户id
//func (e *User) GetIdByUuid(ctx context.Context, req *user_def.UuIdReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetIdByUuid request @ " + tenant)
//	// 参数校验
//	if req.Uuid == "" {
//		return NoParamsErr
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//
//	userId, err := service.GetIdByUuid(req.Uuid)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = userId
//	return nil
//}
//
//// GetDictList 获取用户列表字典项（返回字典数据形式，一般用来绑定用户的下拉列表）
//func (e *User) GetDictList(ctx context.Context, req *user_def.DictSelectReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetDictList request @ " + tenant)
//
//	service, err := user.NewService(tenant)
//	if flag, err, _, _ := myerrors.CheckError(err); flag {
//		return err
//	}
//
//	list, err := service.GetDict(req)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = list
//	return nil
//}
//
//// GetUsersDictByDepartment 获取当前部门下用户信息列表（返回字典数据形式，一般用来绑定用户的下拉列表）
//func (e *User) GetUsersDictByDepartment(ctx context.Context, req *user_def.DeptIdReq,
//	rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetUsersDictByDepartment request @ " + tenant)
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	list, err := service.GetUsersDictByDepartment(req.DeptId)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		g.Log().Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = list
//	return nil
//}
//
//// GetProfile 获取用户信息
//func (e *User) GetProfile(ctx context.Context, numParams interface{}, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetProfile request @ " + tenant)
//
//	service, err := user.NewService(tenant)
//	if flag, err, _, _ := myerrors.CheckError(err); flag {
//		return err
//	}
//	userInfo, err := micro_srv.GetUserInfo(ctx)
//	if err != nil {
//		return err
//	}
//	profile, err := service.GetProfile(int64(userInfo.Id))
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		glog.Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = profile
//	return nil
//}
//
//// UpdateProfile 更新Profile
//func (e *User) UpdateProfile(ctx context.Context, req *user_def.EditProfileEntity, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.UpdateProfile request @ " + tenant)
//	if req.Id == 0 {
//		return NoParamsErr
//	}
//	validErr := gvalid.CheckStruct(ctx, req, nil)
//	if validErr != nil {
//		return validErr.Current()
//	}
//	service, err := user.NewService(tenant)
//	if flag, err, _, _ := myerrors.CheckError(err); flag {
//		return err
//	}
//	userInfo, err := micro_srv.GetUserInfo(ctx)
//	if err != nil {
//		return err
//	}
//	err = service.UpdateProfile(&userInfo, req)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		glog.Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	return nil
//}
//
//// SetAvatar 设置用户头像
//func (e *User) SetAvatar(ctx context.Context, req *user_def.AvatarReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.SetAvatar request @ " + tenant)
//	if req.FileUrl == "" {
//		return NoParamsErr
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	userInfo, err := micro_srv.GetUserInfo(ctx)
//	if err != nil {
//		return err
//	}
//	err = service.SetAvatar(&userInfo, req.FileUrl)
//	_, err, code, msg := myerrors.CheckError(err)
//	if err != nil {
//		glog.Error(err)
//		return err
//	}
//	rsp.Code = code
//	rsp.Msg = msg
//	return nil
//}
//
//// ChangePassword 用户修改密码
//func (e *User) ChangePassword(ctx context.Context, req *user_def.PWDReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.ChangePassword request @ " + tenant)
//	gvalidErr := gvalid.CheckStruct(ctx, req, nil)
//	if gvalidErr != nil {
//		return gvalidErr.Current()
//	}
//	service, err := user.NewService(tenant)
//	if flag, err, _, _ := myerrors.CheckError(err); flag {
//		return err
//	}
//	userInfo, err := micro_srv.GetUserInfo(ctx)
//	if err != nil {
//		return err
//	}
//	err = service.ChangePassword(&userInfo, req.OldPassword, req.NewPassword)
//	_, err, code, msg := myerrors.CheckError(err)
//	rsp.Code = code
//	rsp.Msg = msg
//	return err
//}
//
//// GetUserByUserName 根据用户名获取用户信息
//func (e *User) GetUserByUserName(ctx context.Context, req *user_def.UserNameReq, rsp *comm_def.CommonMsg) error {
//	// 获取租户码
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	g.Log().Info("Received User.GetUserByUserName request @ " + tenant)
//	if req.UserName == "" {
//
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//
//	userEntity, err := service.GetUserByUserName(req.UserName)
//	_, err, code, msg := myerrors.CheckError(err)
//	rsp.Code = code
//	rsp.Msg = msg
//	rsp.Data = userEntity
//	return nil
//}
//
//func (e *User) SendResetPasswordEmail(ctx context.Context, req *user_def.UserNameReq, rsp *comm_def.CommonMsg) error {
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	email, expired, err := service.SendResetPasswordEmail(req)
//	_, err, code, msg := myerrors.CheckError(err)
//	rsp.Code = code
//	rsp.Msg = msg
//	if err == nil {
//		rsp.Data = map[string]interface{}{
//			"email":   email,
//			"expired": expired,
//		}
//	}
//	return nil
//}
//
//func (e *User) ResetPasswordFromEmail(ctx context.Context, req *user.ResetPasswordFromEmailReq, rsp *comm_def.CommonMsg) error {
//	tenant, err := micro_srv.GetTenant(ctx)
//	if err != nil {
//		return err
//	}
//	service, err := user.NewService(tenant)
//	if err != nil {
//		g.Log().Error(err)
//		return gerror.New("系统异常，请重新尝试")
//	}
//	err = service.ResetPasswordFromEmail(ctx, req)
//	_, err, code, msg := myerrors.CheckError(err)
//	rsp.Code = code
//	rsp.Msg = msg
//	return nil
//}