hz_crm_api/controllers/eta_business/eta_business_menu.go

package eta_business

import (
	"encoding/json"
	"hongze/hz_crm_api/controllers"
	"hongze/hz_crm_api/models"
	"hongze/hz_crm_api/models/eta_business"
	etaBusinessService "hongze/hz_crm_api/services/eta_business"
	"hongze/hz_crm_api/utils"
	"html/template"
	"sort"
	"strings"
	"time"
)

// EtaBusinessMenuController ETA商家菜单
type EtaBusinessMenuController struct {
	controllers.BaseAuthController
}

// List
// @Title 商家菜单列表
// @Description 商家菜单列表
// @Param   BusinessId	query	int		false	"商家ID"
// @Param   Keyword		query	string	false	"关键词: 菜单名称"
// @Success 200 Ret=200 获取成功
// @router /menu/list [get]
func (this *EtaBusinessMenuController) List() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	resp := new(eta_business.EtaBusinessMenuListResp)
	resp.ChoiceList = make([]int, 0)
	resp.HalfChoiceList = make([]int, 0)
	resp.List = make([]*eta_business.EtaBusinessMenuItem, 0)
	// 权限校验
	ok, e := etaBusinessService.CheckEtaBusinessOperateAuth(sysUser.RoleTypeCode)
	if e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作权限校验失败, ErrMsg: " + e.Error()
		return
	}
	if !ok {
		br.Data = resp
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}

	menuCond := ``
	menuPars := make([]interface{}, 0)
	// 商家勾选的权限
	{
		businessId, _ := this.GetInt("EtaBusinessId", 0)
		if businessId > 0 {
			relateOb := new(eta_business.EtaBusinessMenuRelate)
			cond := ` AND eta_business_id = ?`
			pars := make([]interface{}, 0)
			pars = append(pars, businessId)
			relates, e := relateOb.GetItemsByCondition(cond, pars, []string{}, "")
			if e != nil {
				br.Msg = "获取失败"
				br.ErrMsg = "获取商家菜单关联列表失败, Err: " + e.Error()
				return
			}
			for _, r := range relates {
				if r.Type == 1 {
					resp.HalfChoiceList = append(resp.HalfChoiceList, r.MenuId)
					continue
				}
				resp.ChoiceList = append(resp.ChoiceList, r.MenuId)
			}
			menuCond += ` AND hidden = 0`
		}
	}

	// 关键词
	keyword := this.GetString("Keyword")
	keyword = strings.TrimSpace(keyword)
	keyword = template.HTMLEscapeString(keyword)

	// 所有菜单列表
	menuOb := new(eta_business.EtaBusinessMenu)
	order := `sort ASC, create_time DESC, menu_id DESC`
	menus, e := menuOb.GetItemsByCondition(menuCond, menuPars, []string{}, order)
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取商家菜单列表失败, Err: " + e.Error()
		return
	}

	list := make([]*eta_business.EtaBusinessMenu, 0)
	if keyword != "" {
		menuMap := make(map[int]*eta_business.EtaBusinessMenu)
		parentMap := make(map[int]*eta_business.EtaBusinessMenu)
		existMap := make(map[int]bool)

		for _, m := range menus {
			menuMap[m.MenuId] = m
		}
		for _, m := range menus {
			if m.ParentId > 0 {
				parentMap[m.MenuId] = menuMap[m.ParentId]
			}
		}

		// 遍历菜单, 取出跟关键词匹配的菜单(层级比较深, 递归效率很低, 产品要这个需求暂时也没啥办法优化=_=!)
		for _, m := range menus {
			if !strings.Contains(m.Name, keyword) {
				continue
			}
			if existMap[m.MenuId] {
				continue
			}
			existMap[m.MenuId] = true
			list = append(list, m)

			// 取出关键词所匹配的所有父级菜单
			if m.ParentId > 0 {
				parents := etaBusinessService.GetMenuParentsRecursive(menus, m.ParentId)
				for _, p := range parents {
					if !existMap[p.MenuId] {
						existMap[p.MenuId] = true
						list = append(list, p)
					}
				}
			}
		}

		sort.Slice(list, func(i, j int) bool {
			return list[j].Sort > list[i].Sort
		})
	} else {
		list = menus
	}

	items := make([]*eta_business.EtaBusinessMenuItem, 0)
	for _, v := range list {
		t := &eta_business.EtaBusinessMenuItem{
			MenuId:     v.MenuId,
			ParentId:   v.ParentId,
			Name:       v.Name,
			Sort:       v.Sort,
			Path:       v.Path,
			IconPath:   v.IconPath,
			Component:  v.Component,
			Hidden:     v.Hidden,
			MenuType:   v.MenuType,
			ButtonCode: v.ButtonCode,
			CreateTime: v.CreateTime.Format(utils.FormatDateTime),
			Children:   make([]*eta_business.EtaBusinessMenuItem, 0),
		}
		items = append(items, t)
	}

	// 递归返回树形结构
	items = etaBusinessService.GetMenuTreeRecursive(items, 0)

	resp.List = items
	br.Data = resp
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
}

// SaveRelate
// @Title 保存商家菜单关联
// @Description 保存商家菜单关联
// @Param	request	body eta_business.EtaBusinessAddReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /menu/relate/save [post]
func (this *EtaBusinessMenuController) SaveRelate() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	// 操作权限校验
	ok, e := etaBusinessService.CheckEtaBusinessOperateAuth(sysUser.RoleTypeCode)
	if e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作权限校验失败, ErrMsg: " + e.Error()
		return
	}
	if !ok {
		br.Msg = "无权操作"
		return
	}

	// 参数校验
	var req eta_business.EtaBusinessMenuRelateSaveReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + e.Error()
		return
	}
	if req.EtaBusinessId <= 0 {
		br.Msg = "参数有误"
		return
	}
	if len(req.MenuIds) == 0 {
		br.Msg = "请选择菜单"
		return
	}

	ob := new(eta_business.EtaBusinessMenuRelate)
	items := make([]*eta_business.EtaBusinessMenuRelate, 0)
	for _, v := range req.MenuIds {
		t := new(eta_business.EtaBusinessMenuRelate)
		t.MenuId = v
		t.EtaBusinessId = req.EtaBusinessId
		items = append(items, t)
	}
	for _, v := range req.HalfMenuIds {
		t := new(eta_business.EtaBusinessMenuRelate)
		t.MenuId = v
		t.Type = 1
		t.EtaBusinessId = req.EtaBusinessId
		items = append(items, t)
	}
	if e := ob.CreateMulti(req.EtaBusinessId, items); e != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存商家菜单关联失败, Err: " + e.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
}

// Add
// @Title 新增菜单
// @Description 新增菜单
// @Param	request	body eta_business.EtaBusinessMenuAddReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /menu/add [post]
func (this *EtaBusinessMenuController) Add() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	// 操作权限校验
	ok, e := etaBusinessService.CheckEtaBusinessOperateAuth(sysUser.RoleTypeCode)
	if e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作权限校验失败, ErrMsg: " + e.Error()
		return
	}
	if !ok {
		br.Msg = "无权操作"
		return
	}

	// 参数校验
	var req eta_business.EtaBusinessMenuAddReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + e.Error()
		return
	}
	req.Name = strings.TrimSpace(req.Name)
	if req.Name == "" {
		br.Msg = "请输入名称"
		return
	}
	if req.MenuType == 0 {
		req.Path = strings.TrimSpace(req.Path)
		if req.Path == "" {
			br.Msg = "请输入路由地址"
			return
		}
		req.Component = strings.TrimSpace(req.Component)
		if req.Component == "" {
			br.Msg = "请输入组件路径"
			return
		}
	} else {
		req.ButtonCode = strings.TrimSpace(req.ButtonCode)
		if req.ButtonCode == "" {
			br.Msg = "请输入按钮/字段ID"
			return
		}
	}

	// 重名校验
	{
		ob := new(eta_business.EtaBusinessMenu)
		cond := ` AND parent_id = ? AND name = ?`
		pars := make([]interface{}, 0)
		pars = append(pars, req.ParentId, req.Name)
		exist, e := ob.GetItemByCondition(cond, pars)
		if e != nil && e.Error() != utils.ErrNoRow() {
			br.Msg = "操作失败"
			br.ErrMsg = "获取同名菜单失败, Err: " + e.Error()
			return
		}
		if exist != nil {
			br.Msg = "名称已存在"
			return
		}
	}

	// 新增
	menuOb := new(eta_business.EtaBusinessMenu)
	menuOb.ParentId = req.ParentId
	menuOb.Name = req.Name
	menuOb.Sort = req.Sort
	menuOb.Path = req.Path
	menuOb.IconPath = req.IconPath
	menuOb.Component = req.Component
	menuOb.Hidden = req.Hidden
	menuOb.MenuType = req.MenuType
	menuOb.ButtonCode = req.ButtonCode
	menuOb.CreateTime = time.Now().Local()
	menuOb.ModifyTime = time.Now().Local()
	// TODO:多级菜单
	if menuOb.ParentId > 0 {
		menuOb.LevelPath = menuOb.Component
	}
	if e := menuOb.Create(); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "新增菜单失败, Err: " + e.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
}

// Edit
// @Title 编辑菜单
// @Description 编辑菜单
// @Param	request	body eta_business.EtaBusinessMenuEditReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /menu/edit [post]
func (this *EtaBusinessMenuController) Edit() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	// 操作权限校验
	ok, e := etaBusinessService.CheckEtaBusinessOperateAuth(sysUser.RoleTypeCode)
	if e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作权限校验失败, ErrMsg: " + e.Error()
		return
	}
	if !ok {
		br.Msg = "无权操作"
		return
	}

	// 参数校验
	var req eta_business.EtaBusinessMenuEditReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + e.Error()
		return
	}
	if req.MenuId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = "参数有误, MenuId"
		return
	}
	req.Name = strings.TrimSpace(req.Name)
	if req.Name == "" {
		br.Msg = "请输入名称"
		return
	}
	if req.MenuType == 0 {
		req.Path = strings.TrimSpace(req.Path)
		if req.Path == "" {
			br.Msg = "请输入路由地址"
			return
		}
		req.Component = strings.TrimSpace(req.Component)
		if req.Component == "" {
			br.Msg = "请输入组件路径"
			return
		}
	} else {
		req.ButtonCode = strings.TrimSpace(req.ButtonCode)
		if req.ButtonCode == "" {
			br.Msg = "请输入按钮/字段ID"
			return
		}
	}

	menuOb := new(eta_business.EtaBusinessMenu)
	item, e := menuOb.GetItemById(req.MenuId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Msg = "菜单不存在, 请刷新页面"
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = "获取菜单失败, Err: " + e.Error()
		return
	}

	// 重名校验
	{
		ob := new(eta_business.EtaBusinessMenu)
		cond := ` AND parent_id = ? AND name = ?`
		pars := make([]interface{}, 0)
		pars = append(pars, req.ParentId, req.Name)
		exist, e := ob.GetItemByCondition(cond, pars)
		if e != nil && e.Error() != utils.ErrNoRow() {
			br.Msg = "操作失败"
			br.ErrMsg = "获取同名菜单失败, Err: " + e.Error()
			return
		}
		if exist != nil && exist.MenuId != item.MenuId {
			br.Msg = "名称已存在"
			return
		}
	}

	// 更新
	item.Name = req.Name
	item.Sort = req.Sort
	item.Path = req.Path
	item.IconPath = req.IconPath
	item.Component = req.Component
	item.Hidden = req.Hidden
	item.ButtonCode = req.ButtonCode
	item.ModifyTime = time.Now().Local()
	// TODO:多级菜单
	cols := make([]string, 0)
	cols = append(cols, "Name", "Sort", "Path", "IconPath", "Component", "Hidden", "ButtonCode", "ModifyTime")
	if item.ParentId > 0 {
		item.LevelPath = item.Component
		cols = append(cols, "LevelPath")
	}
	if e := item.Update(cols); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "更新菜单失败, Err: " + e.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
}

// Remove
// @Title 删除菜单
// @Description 删除菜单
// @Param	request	body eta_business.EtaBusinessMenuRemoveReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /menu/remove [post]
func (this *EtaBusinessMenuController) Remove() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	// 操作权限校验
	ok, e := etaBusinessService.CheckEtaBusinessOperateAuth(sysUser.RoleTypeCode)
	if e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "操作权限校验失败, ErrMsg: " + e.Error()
		return
	}
	if !ok {
		br.Msg = "无权操作"
		return
	}

	// 参数校验
	var req eta_business.EtaBusinessMenuRemoveReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + e.Error()
		return
	}
	if req.MenuId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = "参数有误, MenuId"
		return
	}

	menuOb := new(eta_business.EtaBusinessMenu)
	_, e = menuOb.GetItemById(req.MenuId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Msg = "菜单不存在, 请刷新页面"
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = "获取菜单失败, Err: " + e.Error()
		return
	}

	// 获取所有菜单列表, 筛选出该菜单及子菜单
	menus, e := menuOb.GetItemsByCondition(``, make([]interface{}, 0), []string{}, "")
	if e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "获取菜单列表失败, Err: " + e.Error()
		return
	}
	menuIds := etaBusinessService.GetMenuChildrenIdsRecursive(menus, req.MenuId)
	menuIds = append(menuIds, req.MenuId)

	// 删除菜单
	if e = menuOb.MultiDel(menuIds); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "删除菜单及子菜单失败, Err: " + e.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
}

// IconList
// @Title 图标列表
// @Description 图标列表
// @Success 200 Ret=200 操作成功
// @router /menu/icon/list [get]
func (this *EtaBusinessMenuController) IconList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	iconOb := new(eta_business.EtaBusinessMenuIcon)
	icons, e := iconOb.GetItemsByCondition(``, make([]interface{}, 0), []string{}, "")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取菜单列表失败, Err: " + e.Error()
		return
	}
	list := make([]*eta_business.EtaBusinessMenuIconItem, 0)
	for _, v := range icons {
		list = append(list, &eta_business.EtaBusinessMenuIconItem{
			IconId:   v.IconId,
			IconPath: v.IconPath,
		})
	}

	br.Data = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
}

// IconAdd
// @Title 新增图标
// @Description 新增图标
// @Success 200 Ret=200 操作成功
// @router /menu/icon/add [post]
func (this *EtaBusinessMenuController) IconAdd() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	var req eta_business.EtaBusinessMenuIconAddReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + e.Error()
		return
	}
	req.IconPath = strings.TrimSpace(req.IconPath)
	if req.IconPath == "" {
		br.Msg = "请上传图片"
		return
	}

	iconOb := new(eta_business.EtaBusinessMenuIcon)
	iconOb.IconPath = req.IconPath
	iconOb.CreateTime = time.Now().Local()
	if e := iconOb.Create(); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = "新增菜单icon失败, Err: " + e.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
}

// SystemApiConfig
// @Title 系统配置接口列表
// @Description 系统配置接口列表
// @Success 200 {object} []system.BusinessConf
// @router /api/config/list [get]
func (this *EtaBusinessMenuController) SystemApiConfig() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var relates []*eta_business.EtaBusinessConfigRelate
	businessId, _ := this.GetInt("EtaBusinessId", 0)
	var err error
	if businessId > 0 {
		relateOb := new(eta_business.EtaBusinessConfigRelate)
		cond := ` AND eta_business_id = ?`
		pars := make([]interface{}, 0)
		pars = append(pars, businessId)
		relates, err = relateOb.GetItemsByCondition(cond, pars, []string{}, "")
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取商家菜单关联列表失败, Err: " + err.Error()
			return
		}
	}


	br.Data = relates
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
}

// SystemApiConfig
// @Title 系统配置接口列表
// @Description 系统配置接口列表
// @Success 200 {object} []system.BusinessConf
// @router /api/config/set [post]
func (this *EtaBusinessMenuController) SystemApiConfigSet() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	var req eta_business.SetBusinessConfReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + e.Error()
		return
	}
	ob := new(eta_business.EtaBusinessConfigRelate)
	items := make([]*eta_business.EtaBusinessConfigRelate, 0)
	for _, v := range req.List {
		t := new(eta_business.EtaBusinessConfigRelate)
		t.ConfigCode = v.ConfigCode
		t.ConfigValue = v.ConfigValue
		t.EtaBusinessId = req.EtaBusinessId
		items = append(items, t)
	}
	if e := ob.CreateMulti(req.EtaBusinessId, items); e != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存商家菜单关联失败, Err: " + e.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"

	br.Ret = 200
	br.Success = true
	br.Msg = "设置成功"
}