kpt-pasture/module/backend/system_service_more.go

package backend

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

	"go.uber.org/zap"

	"gitee.com/xuyiping_admin/pkg/logger/zaplog"

	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/xerr"
	"gorm.io/gorm"
)

// CreateOrUpdateSystemMenu 添加或者更新系统菜单权限
func (s *StoreEntry) CreateOrUpdateSystemMenu(ctx context.Context, req *pasturePb.SearchMenuRequest) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}

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

		// 更新数据
		systemMenu.MenuUpdate(req)
		if err = s.DB.Model(new(model.SystemMenu)).
			Select("name", "path", "title", "menu_type", "parent_id", "frame_src", "frame_loading",
				"keepalive", "hidden_tag", "show_link", "show_parent", "icon", "component", "redirect", "auths",
				"rank", "extra_icon", "enter_transition", "leave_transition", "active_path", "is_delete", "is_show").
			Where("id = ?", req.Id).
			Where("pasture_id = ?", userModel.AppPasture.Id).
			Updates(systemMenu).
			Error; err != nil {
			return xerr.WithStack(err)
		}
	} else {
		newSystemMenu := model.NewSystemMenu(userModel.AppPasture.Id, req)
		if err = s.DB.Model(new(model.SystemMenu)).Create(newSystemMenu).Error; err != nil {
			return xerr.WithStack(err)
		}
	}

	return nil
}

func (s *StoreEntry) SystemMenuTree(ctx context.Context) (*pasturePb.SystemMenuTreeResponse, error) {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}
	systemMenuList := make([]*model.SystemMenu, 0)
	if err = s.DB.Model(new(model.SystemMenu)).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		Where("is_show = ?", pasturePb.IsShow_Ok).
		Find(&systemMenuList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}
	return &pasturePb.SystemMenuTreeResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: model.SystemMenuSlice(systemMenuList).ToPB(),
	}, nil
}

// SearchSystemMenuList 菜单列表查询
func (s *StoreEntry) SearchSystemMenuList(ctx context.Context, req *pasturePb.SearchMenuRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchMenuResponse, error) {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}
	systemMenuList := make([]*model.SystemMenu, 0)
	var count int64 = 0

	pref := s.DB.Model(new(model.SystemMenu)).
		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 err = pref.Order("parent_id").Count(&count).
		Find(&systemMenuList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	return &pasturePb.SearchMenuResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: &pasturePb.SearchMenuData{
			Page:     pagination.Page,
			Total:    int32(count),
			PageSize: pagination.PageSize,
			List:     model.SystemMenuSlice(systemMenuList).ToPB(),
		},
	}, nil
}

// DeleteSystemMenu 删除系统菜单
func (s *StoreEntry) DeleteSystemMenu(ctx context.Context, menuId int64) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}

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

	if err = s.DB.Model(new(model.SystemMenu)).
		Where("id = ?", menuId).
		Update("is_delete", pasturePb.IsShow_No).
		Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

func (s *StoreEntry) SearchSystemDeptList(ctx context.Context, req *pasturePb.SearchDeptRequest, pagination *pasturePb.PaginationModel) (*pasturePb.SearchDeptResponse, error) {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	deptList := make([]*model.SystemDept, 0)
	var count int64 = 0
	pastureId := userModel.AppPasture.Id
	pref := s.DB.Model(new(model.SystemDept)).
		Where("pasture_id = ?", pastureId).
		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("sort desc").
		Count(&count).
		Limit(int(pagination.PageSize)).
		Offset(int(pagination.PageOffset)).
		Find(&deptList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	systemUserList, _ := s.SystemUserList(ctx, pastureId)

	return &pasturePb.SearchDeptResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: &pasturePb.DeptData{
			List:     model.SystemDeptSlice(deptList).ToPB(systemUserList),
			Total:    int32(count),
			PageSize: pagination.PageSize,
			Page:     pagination.Page,
		},
	}, nil
}

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

	dept := &model.SystemDept{}
	if err = s.DB.Model(new(model.SystemDept)).
		Where("id = ?", id).
		Where("pasture_id = ?", userModel.AppPasture.Id).
		First(dept).Error; err != nil {
		return xerr.WithStack(err)
	}

	if dept.IsShow == pasturePb.IsShow_No {
		return nil
	}
	if err = s.DB.Model(new(model.SystemDept)).
		Update("is_delete", operationPb.IsShow_NO).
		Error; err != nil {
		return xerr.WithStack(err)
	}
	return nil
}

func (s *StoreEntry) SystemDeptCreateOrUpdate(ctx context.Context, req *pasturePb.SearchDeptRequest) error {
	userModel, err := s.GetUserModel(ctx)
	if err != nil {
		return xerr.WithStack(err)
	}
	pastureId := userModel.AppPasture.Id
	if req.Id > 0 {
		systemDept := &model.SystemDept{}
		if err = s.DB.Model(new(model.SystemDept)).
			Where("id = ?", req.Id).
			Where("pasture_id = ?", pastureId).
			Where("is_delete = ?", pasturePb.IsShow_Ok).
			First(systemDept).Error; err != nil {
			zaplog.Error("SystemDeptCreateOrUpdate", zap.Any("req", req), zap.Any("err", err))
			return xerr.Customf("部门信息错误: %s", err.Error())
		}

		// 更新部门信息
		systemDept.DepthUpdate(req)
		if err = s.DB.Model(new(model.SystemDept)).
			Where("id = ?", systemDept.Id).
			Where("pasture_id = ?", pastureId).
			Select("name", "parent_id", "sort", "remarks", "is_show", "is_delete").
			Updates(systemDept).Error; err != nil {
			return xerr.WithStack(err)
		}
	} else {
		newSystemDepth := model.NewSystemDept(pastureId, req)
		if err = s.DB.Model(new(model.SystemDept)).
			Create(newSystemDepth).Error; err != nil {
			return xerr.WithStack(err)
		}
	}
	return nil
}

func (s *StoreEntry) SearchUserPastureList(ctx context.Context) (*pasturePb.SystemUserPastureListResponse, error) {
	currentUser, err := s.GetCurrentSystemUser(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

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

	return &pasturePb.SystemUserPastureListResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: model.AppPastureListSlice(farmList).ToPB(),
	}, err
}

func (s *StoreEntry) SystemDeptTree(ctx context.Context, req *pasturePb.SearchDeptRequest) (*pasturePb.DeptTreeResponse, error) {
	currentUser, err := s.GetCurrentSystemUser(ctx)
	if err != nil {
		return nil, xerr.WithStack(err)
	}

	pastureIdsStr := currentUser.PastureIds
	if pastureIdsStr == "" {
		return nil, xerr.Customf("请先将该用户绑定牧场！谢谢！")
	}

	pastureIds := currentUser.GetPastureIds()
	systemDeptList := make([]*model.SystemDept, 0)

	pref := s.DB.Model(new(model.SystemDept)).
		Where("is_delete = ?", pasturePb.IsShow_Ok)

	if req.PastureId > 0 {
		pref.Where("pasture_id = ?", req.PastureId)
	} else {
		pref.Where("pasture_id IN ?", pastureIds)
	}

	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.Find(&systemDeptList).Error; err != nil {
		return nil, xerr.WithStack(err)
	}

	if req.Name != "" {
		parentDepths, err := s.findAllParentDepths(ctx, systemDeptList, pastureIds)
		if err != nil {
			return nil, xerr.WithStack(err)
		}
		systemDeptList = append(systemDeptList, parentDepths...)
	}

	// 没有搜到部门数据，默认返回所有牧场一级数据
	if len(systemDeptList) == 0 {
		systemDeptList = s.SearchDepthPastureList(ctx)
	}

	return &pasturePb.DeptTreeResponse{
		Code: http.StatusOK,
		Msg:  "ok",
		Data: model.SystemDeptSlice(systemDeptList).ToTree(),
	}, nil
}

func (s *StoreEntry) SearchDepthPastureList(ctx context.Context) []*model.SystemDept {
	systemDeptList := make([]*model.SystemDept, 0)
	currentUser, err := s.GetCurrentSystemUser(ctx)
	if err != nil {
		return systemDeptList
	}

	pastureIds := currentUser.GetPastureIds()
	if err = s.DB.Model(new(model.SystemDept)).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		Where("pasture_id IN ?", pastureIds).
		Where("parent_id = ?", 0).
		Find(&systemDeptList).Error; err != nil {
		return systemDeptList
	}
	return systemDeptList
}

// findAllParentDepths 递归查找所有上级部门
func (s *StoreEntry) findAllParentDepths(ctx context.Context, depths []*model.SystemDept, pastureIds []int64) ([]*model.SystemDept, error) {
	var allDepths []*model.SystemDept
	var parentIDs []int64
	foundDepths := make(map[int64]bool)

	// 收集所有需要查找的父部门ID
	for _, dept := range depths {
		if dept.ParentId > 0 && !foundDepths[dept.ParentId] {
			parentIDs = append(parentIDs, dept.ParentId)
			foundDepths[dept.ParentId] = true
		}
	}

	if len(parentIDs) == 0 {
		return allDepths, nil
	}

	// 查询这些父部门
	var parentDepths []*model.SystemDept
	if err := s.DB.Model(new(model.SystemDept)).
		Where("id IN ?", parentIDs).
		Where("pasture_id IN ?", pastureIds).
		Where("is_delete = ?", pasturePb.IsShow_Ok).
		Find(&parentDepths).Error; err != nil {
		return nil, err
	}

	// 递归查找更上级的部门
	higherParents, err := s.findAllParentDepths(ctx, parentDepths, pastureIds)
	if err != nil {
		return nil, err
	}

	allDepths = append(allDepths, parentDepths...)
	allDepths = append(allDepths, higherParents...)

	return allDepths, nil
}