kpt-pasture/module/backend/system_service.go

package backend

import (
	"context"
	"errors"
	"fmt"
	"kpt-pasture/model"
	"kpt-pasture/util"
	"net/http"
	"strings"
	"time"

	"gitee.com/xuyiping_admin/pkg/logger/zaplog"
	"go.uber.org/zap"

	pasturePb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/cow"
	operationPb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/operation"
	"gitee.com/xuyiping_admin/pkg/jwt"
	"gitee.com/xuyiping_admin/pkg/xerr"
	"gorm.io/gorm"
)

const (
	CurrentUserName = "userName"
	CurrentFarmId   = "FarmId"
)

// Login 用户登录
func (s *StoreEntry) Login(ctx context.Context, req *pasturePb.SearchUserRequest) (*pasturePb.SystemUserResponse, error) {
	systemUser := &model.SystemUser{}
	if err := s.DB.Where("name = ?", req.Name).
		First(systemUser).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	if systemUser.Password != req.Password {
		return nil, xerr.Customf("密码错误，来自用户:%s", req.Name)
	}

	if systemUser.IsShow == pasturePb.IsShow_No {
		return nil, xerr.Customf("该账号已被禁用，请联系管理员")
	}

	if systemUser.IsDelete == pasturePb.IsShow_No {
		return nil, xerr.Customf("该账号已被删除，请联系管理员")
	}

	if len(systemUser.PastureIds) <= 0 {
		return nil, xerr.Custom("当前用户未配置相关牧场数据,请联系管理员！")
	}

	systemRoleList := make([]*model.SystemRole, 0)
	if err := s.DB.Model(new(model.SystemRole)).
		Where("is_show = ? and is_delete = ?", pasturePb.IsShow_Ok, pasturePb.IsShow_Ok).
		Where("id IN ?", systemUser.GetRoleIds()).
		Find(&systemRoleList).Error; err != nil {
		zaplog.Error("Login", zap.Any("systemRole", err))
	}

	roleNameList := make([]string, 0)
	for _, role := range systemRoleList {
		roleNameList = append(roleNameList, role.Name)
	}

	jwtToken := jwt.NewJWTTokenGen(s.Cfg.AppName, s.Cfg.JwtTokenKeyConfig.PrivateKey)
	token, err := jwtToken.GenerateToken(systemUser.Name, s.Cfg.JwtExpireTime)
	if err != nil {
		return nil, xerr.WithStack(err)
	}
	if token == "" {
		return nil, xerr.Custom("获取token错误")
	}

	expires := time.Now().Local().Add(time.Duration(s.Cfg.JwtExpireTime) * time.Second).Format(util.LayoutTime)
	farmList, err := s.FindPastureListByIds(ctx, systemUser.GetPastureIds())
	if err != nil || len(farmList) == 0 {
		return nil, xerr.Custom("牧场信息错误")
	}

	return &pasturePb.SystemUserResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: &pasturePb.SystemUserData{
			AccessToken:  token,
			Expires:      expires,
			RefreshToken: token,
			Username:     systemUser.Name,
			Roles:        roleNameList,
			Avatar:       systemUser.Avatar,
			FarmId:       farmList[0].FarmId,
		},
	}, nil
}

// SearchSystemUserList 查询系统用户
func (s *StoreEntry) SearchSystemUserList(ctx context.Context, req *pasturePb.SearchUserRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchUserResponse, error) {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	systemUserList := make([]*model.SystemUser, 0)
	var count int64 = 0
	pref := s.DB.Model(new(model.SystemUser)).
		Where("is_delete = ?", operationPb.IsShow_OK).
		Where("FIND_IN_SET(?, pasture_ids) > ?", userModel.AppPasture.Id, 0)

	if req.Name != "" {
		pref.Where("name like ?", fmt.Sprintf("%s%s%s", "%", req.Name, "%"))
	}

	if req.Mobile != "" {
		pref.Where("mobile = ?", req.Mobile)
	}

	if len(req.DepthId) > 0 {
		depthIds := ""
		for _, v := range req.DepthId {
			depthIds += fmt.Sprintf("%d,", v)
		}
		pref.Where("dept_ids = ?", strings.TrimRight(depthIds, ","))
	}

	if req.IsShow > 0 {
		pref.Where("is_show = ?", req.IsShow)
	}

	if err = pref.Order("is_show asc,id desc").
		Count(&count).
		Limit(int(pagination.PageSize)).
		Offset(int(pagination.PageOffset)).
		Find(&systemUserList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	roleList, err := s.SearchSystemRoleListByIds(ctx, userModel.AppPasture.Id, []int64{})
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	deptList, err := s.SearchSystemDeptListByIds(ctx, userModel.AppPasture.Id, []int64{})
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	appPastureList, err := s.FindPastureList(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	return &pasturePb.SearchUserResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: &pasturePb.SearchUserData{
			List:     model.SystemUserSlice(systemUserList).ToPB(deptList, roleList, appPastureList),
			Total:    int32(count),
			PageSize: pagination.PageSize,
			Page:     pagination.Page,
		},
	}, nil
}

func (s *StoreEntry) SystemUserList(ctx context.Context, pastureId int64) ([]*model.SystemUser, error) {
	systemUserList := make([]*model.SystemUser, 0)
	if err := s.DB.Model(new(model.SystemUser)).
		Where("pasture_id = ?", pastureId).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		Where("is_show = ? ", pasturePb.IsShow_Ok).
		Find(&systemUserList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}
	return systemUserList, nil
}

// DeleteSystemUser 删除系统用户
func (s *StoreEntry) DeleteSystemUser(ctx context.Context, userId int64) error {
	systemUser := &model.SystemUser{Id: userId}
	if err := s.DB.Model(new(model.SystemUser)).First(systemUser).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return xerr.Custom("该用户不存在")
		}
		return xerr.WithStack(err)
	}

	if err := s.DB.Model(systemUser).
		Update("is_delete", operationPb.IsShow_NO).Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

// IsShowSystemUser 用户是否启用
func (s *StoreEntry) IsShowSystemUser(ctx context.Context, userId int64) error {
	systemUser := &model.SystemUser{Id: userId}
	if err := s.DB.First(systemUser).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return xerr.Custom("该用户不存在")
		}
		return xerr.WithStack(err)
	}
	isShow := pasturePb.IsShow_No
	if systemUser.IsShow == pasturePb.IsShow_No {
		isShow = pasturePb.IsShow_Ok
	}

	if err := s.DB.Model(systemUser).
		Update("is_show", isShow).Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

// SystemUserCreateOrUpdate 创建或者更新系统用户
func (s *StoreEntry) SystemUserCreateOrUpdate(ctx context.Context, req *pasturePb.SearchUserRequest) error {
	deptIds, pastureIds := "", ""
	for _, pasture := range req.PastureDepthList {
		appPasture, err := s.GetAppPastureListByFarmId(ctx, pasture.FarmId)
		if err != nil {
			return xerr.WithStack(err)
		}
		pastureIds += fmt.Sprintf("%d,", appPasture.Id)
		if len(pasture.DepthList) > 0 {
			for _, dept := range pasture.DepthList {
				deptIds += fmt.Sprintf("%d,", dept.Id)
			}
		}
		if len(pastureIds) > 0 {
			pastureIds = strings.TrimSuffix(pastureIds, ",")
		}

		if len(deptIds) > 0 {
			deptIds = strings.TrimSuffix(deptIds, ",")
		}
	}

	systemUser := &model.SystemUser{}
	if req.Id > 0 {
		systemUser.Id = int64(req.Id)
		if err := s.DB.Model(new(model.SystemUser)).
			First(systemUser).Error; err != nil {
			return xerr.WithStack(err)
		}

		systemUser.UserUpdate(req, deptIds, pastureIds)
		if err := s.DB.Model(new(model.SystemUser)).
			Select("name", "nick_name", "mobile", "gender", "dept_ids", "pasture_ids", "remarks", "is_show").
			Where("id = ?", systemUser.Id).
			Updates(systemUser).Error; err != nil {
			return xerr.WithStack(err)
		}

	} else {
		var count int64
		if err := s.DB.Model(new(model.SystemUser)).
			Where("name = ?", req.Name).
			Where("mobile = ?", req.Mobile).
			Where("is_show = ?", pasturePb.IsShow_Ok).
			Count(&count).Error; err != nil {
			return xerr.WithStack(err)
		}

		if count > 0 {
			return xerr.Customf("系统中该用户名称已经存在: %s_%s", req.Name, req.Mobile)
		}

		newSystemUser := model.NewSystemUser(req, deptIds, pastureIds, req.PastureDepthList)
		if err := s.DB.Model(new(model.SystemUser)).
			Create(newSystemUser).Error; err != nil {
			return xerr.WithStack(err)
		}
	}

	return nil
}

// ResetPasswordSystemUser 重置系统用户密码
func (s *StoreEntry) ResetPasswordSystemUser(ctx context.Context, req *pasturePb.ResetUserPasswordRequest) error {
	systemUser := &model.SystemUser{}
	if err := s.DB.Model(new(model.SystemUser)).
		Where("id = ?", req.Id).
		First(systemUser).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return xerr.Custom("该用户不存在")
		}
		return xerr.WithStack(err)
	}

	if err := s.DB.Model(systemUser).
		Update("password", req.Password).Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

func (s *StoreEntry) SystemUserRole(ctx context.Context, userId int64) (*pasturePb.SystemUserRoleResponse, error) {
	systemUser := &model.SystemUser{Id: userId}
	if err := s.DB.Model(new(model.SystemUser)).
		First(systemUser).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return nil, xerr.Custom("该用户不存在")
		}
		return nil, xerr.WithStack(err)
	}

	if systemUser.IsDelete == pasturePb.IsShow_No {
		return nil, xerr.Custom("该用户已删除")
	}

	return &pasturePb.SystemUserRoleResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: &pasturePb.UserRoleData{
			RoleIds: systemUser.GetRoleIds(),
		},
	}, nil
}

func (s *StoreEntry) SystemUserRoleSave(ctx context.Context, req *pasturePb.SystemUserRoleRequest) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}

	systemUser := &model.SystemUser{Id: int64(req.UserId)}
	if err = s.DB.Model(new(model.SystemUser)).
		First(systemUser).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return xerr.Custom("该用户不存在")
		}
		return xerr.WithStack(err)
	}

	if systemUser.IsDelete == pasturePb.IsShow_No {
		return xerr.Custom("该用户已删除")
	}

	if systemUser.IsShow == pasturePb.IsShow_No {
		return xerr.Custom("该用户已禁用")
	}

	systemRoleList := make([]*model.SystemRole, 0)
	if err = s.DB.Model(new(model.SystemRole)).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		Where("id IN ?", req.RoleIds).
		Find(&systemRoleList).Error; err != nil {
		return xerr.WithStack(err)
	}

	if len(systemRoleList) <= 0 {
		return xerr.Custom("该用户没有角色")
	}

	roleIdsStr := ""
	for _, systemRole := range systemRoleList {
		roleIdsStr += fmt.Sprintf("%d,", systemRole.Id)
	}

	if len(roleIdsStr) > 0 {
		roleIdsStr = strings.TrimRight(roleIdsStr, ",")
	}

	if err = s.DB.Model(systemUser).
		Update("role_ids", roleIdsStr).Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

// GetSystemUserMenu 返回系统用户相关菜单权限
func (s *StoreEntry) GetSystemUserMenu(ctx context.Context) (*pasturePb.SystemUserMenuTreeResponse, error) {
	// 根据用户token获取用户数据
	systemUser, err := s.GetCurrentSystemUser(ctx)
	if err != nil {
		return nil, xerr.Custom("该用户数据不存在")
	}
	if len(systemUser.RoleIds) <= 0 {
		return nil, xerr.Custom("该用户没有角色")
	}

	// 获取用户角色数据
	systemRoleList := make([]*model.SystemRole, 0)
	if err = s.DB.Where("id IN ?", systemUser.GetRoleIds()).
		Find(&systemRoleList).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return nil, xerr.Custom("该用户角色不存在")
		}
		return nil, xerr.WithStack(err)
	}
	// 获取用户菜单
	systemMenuList := make([]*model.SystemMenu, 0)
	if err = s.DB.Table(fmt.Sprintf("%s as a", new(model.SystemRoleMenu).TableName())).
		Select("b.*").
		Joins("LEFT JOIN system_menu AS b ON a.menu_id = b.id").
		Where("a.role_id IN ? and b.is_delete = ?", systemUser.GetRoleIds(), pasturePb.IsShow_Ok).
		Find(&systemMenuList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	// 获取菜单权限
	return &pasturePb.SystemUserMenuTreeResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: model.SystemMenuSlice(systemMenuList).ToTree(),
	}, nil
}

// SystemRoleCreateOrUpdate 添加角色
func (s *StoreEntry) SystemRoleCreateOrUpdate(ctx context.Context, req *pasturePb.SearchRoleRequest) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}

	if req.Id > 0 {
		systemRole := &model.SystemRole{}
		if err = s.DB.Model(systemRole).
			Where("id = ?", req.Id).
			Where("pasture_id = ?", userModel.AppPasture.Id).
			First(systemRole).Error; err != nil {
			return xerr.WithStack(err)
		}

		if systemRole.IsDelete == pasturePb.IsShow_No {
			return xerr.Custom("角色已删除")
		}

		systemRole.RoleUpdate(req)
		if err = s.DB.Model(systemRole).
			Select("name", "remarks", "is_show", "is_delete").
			Where("id = ?", req.Id).
			Where("pasture_id = ?", userModel.AppPasture.Id).
			Updates(systemRole).Error; err != nil {
			return xerr.WithStack(err)
		}

	} else {
		newSystemRole := model.NewSystemRole(userModel.AppPasture.Id, req)
		if err = s.DB.Model(new(model.SystemRole)).Create(newSystemRole).Error; err != nil {
			return xerr.WithStack(err)
		}
	}

	return nil
}

// DeleteSystemRole 删除系统角色
func (s *StoreEntry) DeleteSystemRole(ctx context.Context, roleId int64) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}
	systemRole := &model.SystemRole{}
	if err = s.DB.Model(new(model.SystemRole)).
		Where("id = ? ", roleId).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		First(systemRole).Error; err != nil {
		return xerr.WithStack(err)
	}

	if err = s.DB.Model(systemRole).
		Update("is_delete", pasturePb.IsShow_No).Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

// IsShowSystemRole 角色是否启用
func (s *StoreEntry) IsShowSystemRole(ctx context.Context, roleId int64) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}
	systemRole := &model.SystemRole{}
	if err = s.DB.Model(new(model.SystemRole)).
		Where("id = ?", roleId).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		First(systemRole).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return xerr.Custom("该角色不存在")
		}
		return xerr.WithStack(err)
	}

	isShow := pasturePb.IsShow_No
	if systemRole.IsShow == pasturePb.IsShow_No {
		isShow = pasturePb.IsShow_Ok
	}

	if err = s.DB.Model(systemRole).Update("is_show", isShow).Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

// SearchSystemRoleList 查询系统角色
func (s *StoreEntry) SearchSystemRoleList(ctx context.Context, req *pasturePb.SearchRoleRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchRoleResponse, error) {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	systemRoleList := make([]*model.SystemRole, 0)
	var count int64 = 0

	pref := s.DB.Model(new(model.SystemRole)).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		Where("is_delete = ?", operationPb.IsShow_OK)
	if req.Name != "" {
		pref.Where("name like ?", fmt.Sprintf("%s%s%s", "%", req.Name, "%"))
	}

	if req.IsShow > 0 {
		pref.Where("is_show = ?", req.IsShow)
	}

	if err = pref.Order("is_show asc,id desc").
		Count(&count).
		Limit(int(pagination.PageSize)).
		Offset(int(pagination.PageOffset)).
		Find(&systemRoleList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	return &pasturePb.SearchRoleResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: &pasturePb.SearchRoleData{
			Page:     pagination.Page,
			Total:    int32(count),
			PageSize: pagination.PageSize,
			List:     model.SystemRoleSlice(systemRoleList).ToPB(),
		},
	}, nil
}

// SearchSystemRoleListByIds 根据id查询角色列表
func (s *StoreEntry) SearchSystemRoleListByIds(ctx context.Context, pastureId int64, ids []int64) ([]*model.SystemRole, error) {
	systemRoleList := make([]*model.SystemRole, 0)
	if err := s.DB.Model(new(model.SystemRole)).
		Where("pasture_id = ?", pastureId).
		Where("is_show = ?", operationPb.IsShow_OK).
		Find(&systemRoleList, ids).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	return systemRoleList, nil
}

// GetRoleMenuList 查询系统角色对应的菜单数据
func (s *StoreEntry) GetRoleMenuList(ctx context.Context, roleId int64) (*pasturePb.SystemRoleMenuResponse, error) {
	systemRole := &model.SystemRole{
		Id: roleId,
	}
	if err := s.DB.First(systemRole).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return nil, xerr.Custom("该数据不存在")
		}
		return nil, xerr.WithStack(err)
	}

	if systemRole.IsDelete == pasturePb.IsShow_No {
		return nil, xerr.Custom("该数据已被删除")
	}

	menuList := make([]*model.SystemRoleMenu, 0)
	if err := s.DB.Where("role_id = ?", systemRole.Id).Find(&menuList).Error; err != nil {
		zaplog.Error("GetSystemRoleMenuList", zap.Any("Err", err))
	}
	return &pasturePb.SystemRoleMenuResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: model.SystemRoleMenuSlice(menuList).ToPB(),
	}, nil

}

// RoleMenuSave 保存系统角色对应的菜单数据
func (s *StoreEntry) RoleMenuSave(ctx context.Context, res *pasturePb.SystemRoleMenuRequest) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}

	if len(res.MenuIds) <= 0 {
		return xerr.Custom("请选择菜单")
	}

	systemRole := &model.SystemRole{}
	if err = s.DB.Model(new(model.SystemRole)).
		Where("id = ?", res.RoleId).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		First(systemRole).Error; err != nil {
		if errors.Is(err, gorm.ErrRecordNotFound) {
			return xerr.Custom("该数据不存在")
		}
		return xerr.WithStack(err)
	}

	if systemRole.IsDelete == pasturePb.IsShow_No {
		return xerr.Custom("该数据已删除")
	}

	if systemRole.IsShow == pasturePb.IsShow_No {
		return xerr.Custom("该数据已禁用")
	}

	if err = s.DB.Transaction(func(tx *gorm.DB) error {
		if err = tx.Model(new(model.SystemRoleMenu)).
			Where("role_id = ?", systemRole.Id).
			Delete(&model.SystemRoleMenu{}).
			Error; err != nil {
			return xerr.WithStack(err)
		}
		for _, menuId := range res.MenuIds {
			if err = tx.Model(new(model.SystemRoleMenu)).
				Create(&model.SystemRoleMenu{
					RoleId: systemRole.Id,
					MenuId: int64(menuId),
				}).Error; err != nil {
				return xerr.WithStack(err)
			}
		}
		return nil
	}); err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

func (s *StoreEntry) SystemRoleList(ctx context.Context) (*pasturePb.GetRoleListResponse, error) {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	systemRoleList := make([]*model.SystemRole, 0)
	if err = s.DB.Model(new(model.SystemRole)).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		Find(&systemRoleList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	return &pasturePb.GetRoleListResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: model.SystemRoleSlice(systemRoleList).ToPB(),
	}, nil
}