eta_api/controllers/data_manage/my_chart.go

package data_manage

import (
	"encoding/json"
	"eta_gn/eta_api/controllers"
	"eta_gn/eta_api/models"
	"eta_gn/eta_api/models/data_manage"
	"eta_gn/eta_api/models/system"
	"eta_gn/eta_api/services/data"
	"eta_gn/eta_api/services/data/data_manage_permission"
	"eta_gn/eta_api/utils"
	"fmt"
	"github.com/rdlucklib/rdluck_tools/paging"
	"strconv"
	"strings"
	"time"
)

type MyChartController struct {
	controllers.BaseAuthController
}

// @router /chart/list [get]
func (this *MyChartController) ChartList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	chartClassifyId, _ := this.GetInt("ChartClassifyId")

	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	keyWord := this.GetString("KeyWord")

	var total int
	page := paging.GetPaging(currentIndex, pageSize, total)

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	var condition string
	var pars []interface{}

	condition += ` AND source = ? `
	pars = append(pars, utils.CHART_SOURCE_DEFAULT)

	if chartClassifyId > 0 {
		chartClassifyId, err := data_manage.GetChartClassify(chartClassifyId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "获取图表信息失败"
			br.ErrMsg = "获取信息失败,GetChartClassify,Err:" + err.Error()
			return
		}
		condition += " AND chart_classify_id IN(" + chartClassifyId + ") "
	}
	if keyWord != "" {
		condition += ` AND  ( chart_name LIKE '%` + keyWord + `%' OR chart_name_en LIKE '%` + keyWord + `%' )`
	}

	isShowMe, _ := this.GetBool("IsShowMe")
	if isShowMe {
		condition += ` AND sys_user_id = ? `
		pars = append(pars, sysUser.AdminId)
	}

	noPermissionChartIdList := make([]int, 0)
	{
		obj := data_manage.EdbInfoNoPermissionAdmin{}
		confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "获取失败"
			br.ErrMsg = "获取不可见指标配置数据失败，Err:" + err.Error()
			return
		}
		for _, v := range confList {
			noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
		}
	}

	lenNoPermissionChartIdList := len(noPermissionChartIdList)
	if lenNoPermissionChartIdList > 0 {
		condition += ` AND chart_info_id not in (` + utils.GetOrmInReplace(lenNoPermissionChartIdList) + `) `
		pars = append(pars, noPermissionChartIdList)
	}

	list, err := data_manage.GetChartListByCondition(condition, pars, startSize, pageSize)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
		return
	}

	myChartList, err := data_manage.GetMyChartListByAdminId(sysUser.AdminId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取我的图表信息失败,Err:" + err.Error()
		return
	}
	myChartMap := make(map[int]*data_manage.MyChartView)
	for _, v := range myChartList {
		myChartMap[v.ChartInfoId] = v
	}
	listLen := len(list)
	chartEdbMap := make(map[int][]*data_manage.ChartEdbInfoMapping)
	if listLen > 0 {
		classifyIdList := make([]int, 0)
		classifyMap := make(map[int]*data_manage.ChartClassify)
		for _, v := range list {
			classifyIdList = append(classifyIdList, v.ChartClassifyId)
		}
		classifyList, err := data_manage.GetChartClassifyByIdList(classifyIdList)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取分类列表失败，Err:" + err.Error()
			return
		}

		for _, v := range classifyList {
			classifyMap[v.ChartClassifyId] = v
		}

		permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, 0, 0)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取已授权分类id数据失败，Err:" + err.Error()
			return
		}

		for k, chartViewInfo := range list {
			if currClassify, ok := classifyMap[chartViewInfo.ChartClassifyId]; ok {
				list[k].HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartViewInfo.IsJoinPermission, currClassify.IsJoinPermission, chartViewInfo.ChartInfoId, chartViewInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
			}
		}

		chartInfoIds := ""
		for _, v := range list {
			chartInfoIds += strconv.Itoa(v.ChartInfoId) + ","
		}
		if chartInfoIds != "" {
			chartInfoIds = strings.Trim(chartInfoIds, ",")
			edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
			if e != nil {
				br.Msg = "获取失败"
				br.ErrMsg = "获取图表，指标信息失败，Err:" + e.Error()
				return
			}
			for _, v := range edbList {
				chartEdbMap[v.ChartInfoId] = append(chartEdbMap[v.ChartInfoId], v)
			}
		}
	}
	for i := 0; i < listLen; i++ {
		if edbTmpList, ok := chartEdbMap[list[i].ChartInfoId]; ok {
			list[i].IsEnChart = data.CheckIsEnChart(list[i].ChartNameEn, edbTmpList, list[i].Source, list[i].ChartType)
		}

		if existItem, ok := myChartMap[list[i].ChartInfoId]; ok {
			list[i].IsAdd = true
			list[i].MyChartId = existItem.MyChartId
			list[i].MyChartClassifyId = existItem.MyChartClassifyId
		}
	}

	resp := new(data_manage.ChartListResp)
	if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
		items := make([]*data_manage.ChartInfoView, 0)
		resp.Paging = page
		resp.List = items
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}

	dataCount, err := data_manage.GetChartListCountByCondition(condition, pars)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取指标信息失败"
		br.ErrMsg = "获取指标数据总数失败,Err:" + err.Error()
		return
	}
	page = paging.GetPaging(currentIndex, pageSize, dataCount)
	resp.Paging = page
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @router /classify/list [get]
func (this *MyChartController) ClassifyList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	list, err := data_manage.GetMyChartClassifyAll(sysUser.AdminId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取分类信息失败"
		br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
		return
	}

	resp := new(data_manage.MyChartClassifyResp)
	if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
		items := make([]*data_manage.MyChartClassifyItem, 0)
		resp.List = items
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}

	chartsNumMap, e := data.GetMyChartClassifyIdNumMap(sysUser.AdminId)
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败, GetMyChartClassifyIdNumMap Err: " + e.Error()
		return
	}

	results := make([]*data_manage.MyChartClassifyItem, 0)
	for _, v := range list {
		results = append(results, data_manage.FormatMyChartClassify2Item(v, chartsNumMap[v.MyChartClassifyId]))
	}
	resp.List = results

	language := `CN`
	{
		configDetail, _ := system.GetConfigDetailByCode(this.SysUser.AdminId, system.ChartLanguageVar)
		if configDetail != nil {
			language = configDetail.ConfigValue
		} else {
			configDetail, _ = system.GetDefaultConfigDetailByCode(system.ChartLanguageVar)
			if configDetail != nil {
				language = configDetail.ConfigValue
			}
		}
	}
	resp.Language = language

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

// @router /classify/add [post]
func (this *MyChartController) ClassifyAdd() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartClassifyAddReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.MyChartClassifyName == "" {
		br.Msg = "请输入分类名称"
		br.IsSendEmail = false
		return
	}

	var condition string
	var pars []interface{}

	condition += " AND admin_id=? "
	pars = append(pars, sysUser.AdminId)

	condition += " AND my_chart_classify_name=? "
	pars = append(pars, req.MyChartClassifyName)

	count, err := data_manage.GetMyChartClassifyCountByCondition(condition, pars)
	if err != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,校验名称是否存在失败,Err:" + err.Error()
		return
	}
	if count > 0 {
		br.Msg = "分类已存在，请重新输入"
		br.IsSendEmail = false
		return
	}

	sort, err := data_manage.GetMyChartClassifyMinSort(sysUser.AdminId)
	if err != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,获取最大排序失败,Err:" + err.Error()
		return
	}
	item := new(data_manage.MyChartClassify)
	item.AdminId = sysUser.AdminId
	item.MyChartClassifyName = req.MyChartClassifyName
	item.Sort = sort - 1
	item.ModifyTime = time.Now()
	item.CreateTime = time.Now()
	err = data_manage.AddMyChartClassify(item)
	if err != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,Err:" + err.Error()
		return
	}

	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "新增分类"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}

	br.Ret = 200
	br.Msg = "保存成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /classify/edit [post]
func (this *MyChartController) ClassifyEdit() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartClassifyEditReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.MyChartClassifyName == "" {
		br.Msg = "请输入分类名称"
		br.IsSendEmail = false
		return
	}
	item, err := data_manage.GetMyChartClassifyById(sysUser.AdminId, req.MyChartClassifyId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "保存失败"
		br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
		return
	}
	if item == nil {
		br.Msg = "分类不存在"
		br.ErrMsg = "分类不存在,Err:" + err.Error()
		return
	}
	var condition string
	var pars []interface{}

	condition += " AND admin_id=? "
	pars = append(pars, sysUser.AdminId)

	condition += " AND my_chart_classify_name=? "
	pars = append(pars, req.MyChartClassifyName)

	condition += " AND my_chart_classify_id<>? "
	pars = append(pars, req.MyChartClassifyId)
	count, err := data_manage.GetMyChartClassifyCountByCondition(condition, pars)
	if err != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,校验名称是否存在失败,Err:" + err.Error()
		return
	}
	if count > 0 {
		br.Msg = "分类已存在，请重新输入"
		br.IsSendEmail = false
		return
	}
	err = data_manage.ModifyMyChartClassify(req.MyChartClassifyId, req.MyChartClassifyName)
	if err != nil {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "编辑分类"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}
	br.Ret = 200
	br.Msg = "保存成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /classify/move [post]
func (this *MyChartController) ClassifyMove() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartClassifyMoveReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	item, err := data_manage.GetMyChartClassifyById(sysUser.AdminId, req.MyChartClassifyId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "移动失败，找不到该分类"
		br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
		return
	}
	if item == nil {
		br.Msg = "分类不存在"
		br.ErrMsg = "分类不存在,Err:" + err.Error()
		return
	}

	updateCol := make([]string, 0)
	if req.PrevClassifyId > 0 {
		prevClassify, err := data_manage.GetMyChartClassifyById(sysUser.AdminId, req.PrevClassifyId)
		if err != nil {
			br.Msg = "移动失败"
			br.ErrMsg = "获取上一个兄弟节点分类信息失败,Err:" + err.Error()
			return
		}

		if req.NextClassifyId > 0 {
			nextClassify, err := data_manage.GetMyChartClassifyById(sysUser.AdminId, req.NextClassifyId)
			if err != nil {
				br.Msg = "移动失败"
				br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
				return
			}
			if prevClassify.Sort == nextClassify.Sort || prevClassify.Sort == item.Sort {
				updateSortStr := `sort + 2`
				_ = data_manage.UpdateMyChartClassifySortByClassifyId(sysUser.AdminId, prevClassify.MyChartClassifyId, prevClassify.Sort, updateSortStr)
			} else {
				if nextClassify.Sort-prevClassify.Sort == 1 {
					updateSortStr := `sort + 1`
					_ = data_manage.UpdateMyChartClassifySortByClassifyId(sysUser.AdminId, 0, prevClassify.Sort, updateSortStr)
				}
			}
		}

		item.Sort = prevClassify.Sort + 1
		item.ModifyTime = time.Now()
		updateCol = append(updateCol, "Sort", "ModifyTime")
	} else {
		firstClassify, err := data_manage.GetFirstMyChartClassifyByAdminId(sysUser.AdminId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "移动失败"
			br.ErrMsg = "获取获取当前账号下的排序第一条的分类信息失败,Err:" + err.Error()
			return
		}

		if firstClassify != nil && firstClassify.MyChartClassifyId > 0 && firstClassify.Sort == 0 {
			updateSortStr := ` sort + 1 `
			_ = data_manage.UpdateMyChartClassifySortByClassifyId(sysUser.AdminId, firstClassify.MyChartClassifyId-1, 0, updateSortStr)
		}

		item.Sort = 0 //那就是排在第一位
		item.ModifyTime = time.Now()
		updateCol = append(updateCol, "Sort", "ModifyTime")
	}

	if len(updateCol) > 0 {
		err = item.Update(updateCol)
		if err != nil {
			br.Msg = "移动失败"
			br.ErrMsg = "修改失败,Err:" + err.Error()
			return
		}
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "移动分类"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}
	br.Ret = 200
	br.Msg = "保存成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /classify/delete [post]
func (this *MyChartController) ClassifyDelete() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartClassifyDeleteReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	item, err := data_manage.GetMyChartClassifyById(sysUser.AdminId, req.MyChartClassifyId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "保存失败"
		br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
		return
	}
	if item == nil {
		br.Msg = "分类已被删除"
		br.ErrMsg = "分类已被删除,Err:" + err.Error()
		return
	}

	nodeOb := new(data_manage.ChartFrameworkNode)
	cond := ` AND my_chart_classify_id = ?`
	pars := make([]interface{}, 0)
	pars = append(pars, req.MyChartClassifyId)
	nodes, e := nodeOb.GetItemsByCondition(cond, pars, []string{}, "")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取我的图表分类关联的框架节点失败, Err: " + e.Error()
		return
	}
	if len(nodes) > 0 {
		br.Msg = "该图分类已添加节点链接, 不允许删除"
		return
	}
	err = data_manage.DeleteMyChartClassify(req.MyChartClassifyId)
	if err != nil {
		br.Msg = "删除失败"
		br.ErrMsg = "删除失败,Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "删除分类"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}
	br.Ret = 200
	br.Msg = "删除成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /add [post]
func (this *MyChartController) MyChartAdd() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartAddReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取图表信息失败！"
		br.ErrMsg = "获取图表信息失败，Err:" + err.Error()
		return
	}
	if chartItem == nil {
		br.Msg = "此图表已被删除！"
		br.ErrMsg = "此图表已被删除，ChartInfoId:" + strconv.Itoa(req.ChartInfoId)
		return
	}

	var condition string
	var pars []interface{}

	condition += " AND admin_id=? "
	pars = append(pars, sysUser.AdminId)

	condition += " AND chart_info_id=? "
	pars = append(pars, req.ChartInfoId)

	existItem, err := data_manage.GetMyChartDetailByCondition(condition, pars)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,校验名称是否存在失败,Err:" + err.Error()
		return
	}
	resp := new(data_manage.MyChartAddResp)
	var myChartClassifyId string
	if existItem != nil { //修改
		fmt.Println("modify")
		for _, v := range req.MyChartClassifyId {
			myChartClassifyId += strconv.Itoa(v) + ","
		}
		resp.MyChartInfoId = existItem.MyChartId
		err = data_manage.MoveMyChartClassify(sysUser.AdminId, existItem.MyChartId, req.MyChartClassifyId)
		if err != nil {
			br.Msg = "保存失败"
			br.ErrMsg = "保存我的图表失败,MoveMyChartClassify,Err:" + err.Error()
			return
		}
	} else {
		myChart := &data_manage.MyChart{
			ChartInfoId: chartItem.ChartInfoId,
			Source:      chartItem.Source,
			AdminId:     sysUser.AdminId,
			CreateTime:  time.Now(),
			ModifyTime:  time.Now(),
		}
		newMyChartId, err := data_manage.AddMyChart(myChart)
		if err != nil {
			br.Msg = "保存失败"
			br.ErrMsg = "保存我的图表失败,Err:" + err.Error()
			return
		}

		for _, v := range req.MyChartClassifyId {
			var sort float64
			firstMapItem, _ := data_manage.GetMyChartSort(sysUser.AdminId, v, 0)
			if firstMapItem != nil {
				sort = firstMapItem.Sort
			}
			mappingItem := new(data_manage.MyChartClassifyMapping)
			mappingItem.AdminId = sysUser.AdminId
			mappingItem.MyChartId = int(newMyChartId)
			mappingItem.MyChartClassifyId = v
			mappingItem.CreateTime = time.Now()
			mappingItem.ModifyTime = time.Now()
			mappingItem.Sort = sort
			_, err = data_manage.AddMyChartClassifyMapping(mappingItem)
			if err != nil {
				br.Msg = "保存失败"
				br.ErrMsg = "保存我的图表AddMyChartClassifyMapping失败,Err:" + err.Error()
				return
			}
			myChartClassifyId += strconv.Itoa(v) + ","
		}
		{
			edbLog := new(data_manage.MyChartLog)
			edbLog.MyChartId = myChart.MyChartId
			edbLog.ChartInfoId = myChart.ChartInfoId
			edbLog.SysUserId = sysUser.AdminId
			edbLog.SysUserRealName = sysUser.RealName
			edbLog.CreateTime = time.Now()
			edbLog.Content = string(this.Ctx.Input.RequestBody)
			edbLog.Status = "新增我的图表"
			edbLog.Method = this.Ctx.Input.URI()
			go data_manage.AddMyChartLog(edbLog)
		}
		resp.MyChartInfoId = int(newMyChartId)
	}
	resp.MyChartClassifyId = strings.Trim(myChartClassifyId, ",")

	if resp.MyChartInfoId > 0 {
		go data.EsAddOrEditMyChartInfoByMyChartId(resp.MyChartInfoId)
	}

	br.Ret = 200
	br.Msg = "保存成功"
	br.Success = true
	br.Data = resp
	br.IsAddLog = true
}

// @router /add_to_classify [post]
func (this *MyChartController) MyChartAddToClassify() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartAddReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取图表信息失败！"
		br.ErrMsg = "获取图表信息失败，Err:" + err.Error()
		return
	}
	if chartItem == nil {
		br.Msg = "此图表已被删除！"
		br.ErrMsg = "此图表已被删除，ChartInfoId:" + strconv.Itoa(req.ChartInfoId)
		return
	}

	var condition string
	var pars []interface{}

	condition += " AND admin_id=? "
	pars = append(pars, sysUser.AdminId)

	condition += " AND chart_info_id=? "
	pars = append(pars, req.ChartInfoId)

	existItem, err := data_manage.GetMyChartDetailByCondition(condition, pars)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "保存失败"
		br.ErrMsg = "保存失败,校验名称是否存在失败,Err:" + err.Error()
		return
	}
	resp := new(data_manage.MyChartAddResp)
	var myChartClassifyId string
	if existItem != nil { //修改
		fmt.Println("modify")
		for _, v := range req.MyChartClassifyId {
			myChartClassifyId += strconv.Itoa(v) + ","
		}
		resp.MyChartInfoId = existItem.MyChartId
		err = data_manage.AddMyChartToMyChartClassify(sysUser.AdminId, existItem.MyChartId, req.MyChartClassifyId)
		if err != nil {
			br.Msg = "保存失败"
			br.ErrMsg = "保存我的图表失败,MoveMyChartClassify,Err:" + err.Error()
			return
		}
	} else {
		myChart := &data_manage.MyChart{
			ChartInfoId: chartItem.ChartInfoId,
			Source:      chartItem.Source,
			AdminId:     sysUser.AdminId,
			CreateTime:  time.Now(),
			ModifyTime:  time.Now(),
		}
		newMyChartId, err := data_manage.AddMyChart(myChart)
		if err != nil {
			br.Msg = "保存失败"
			br.ErrMsg = "保存我的图表失败,Err:" + err.Error()
			return
		}
		step := float64(65536)

		for _, v := range req.MyChartClassifyId {
			count, _ := data_manage.GetMyChartMaxSort(sysUser.AdminId, v)
			mappingItem := new(data_manage.MyChartClassifyMapping)
			mappingItem.AdminId = sysUser.AdminId
			mappingItem.MyChartId = int(newMyChartId)
			mappingItem.MyChartClassifyId = v
			mappingItem.CreateTime = time.Now()
			mappingItem.ModifyTime = time.Now()
			mappingItem.Sort = (float64(count) + 1) * step
			_, err = data_manage.AddMyChartClassifyMapping(mappingItem)
			if err != nil {
				br.Msg = "保存失败"
				br.ErrMsg = "保存我的图表AddMyChartClassifyMapping失败,Err:" + err.Error()
				return
			}
			myChartClassifyId += strconv.Itoa(v) + ","
		}
		{
			edbLog := new(data_manage.MyChartLog)
			edbLog.MyChartId = myChart.MyChartId
			edbLog.ChartInfoId = myChart.ChartInfoId
			edbLog.SysUserId = sysUser.AdminId
			edbLog.SysUserRealName = sysUser.RealName
			edbLog.CreateTime = time.Now()
			edbLog.Content = string(this.Ctx.Input.RequestBody)
			edbLog.Status = "新增我的图表"
			edbLog.Method = this.Ctx.Input.URI()
			go data_manage.AddMyChartLog(edbLog)
		}
		resp.MyChartInfoId = int(newMyChartId)
	}
	resp.MyChartClassifyId = strings.Trim(myChartClassifyId, ",")

	if resp.MyChartInfoId > 0 {
		go data.EsAddOrEditMyChartInfoByMyChartId(resp.MyChartInfoId)
	}

	br.Ret = 200
	br.Msg = "保存成功"
	br.Success = true
	br.Data = resp
	br.IsAddLog = true
}

// @router /get_mychart_classify_id_list [get]
func (this *MyChartController) GetMyChartClassifyIdList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	chartInfoId, _ := this.GetInt("ChartInfoId")
	if chartInfoId <= 0 {
		br.Msg = "请传入图表id"
		br.IsSendEmail = false
		return
	}

	chartClassifyIdList := make([]int, 0)

	var condition string
	var pars []interface{}

	condition += " AND admin_id=? AND chart_info_id=? "
	pars = append(pars, sysUser.AdminId, chartInfoId)

	existItem, _ := data_manage.GetMyChartDetailByCondition(condition, pars)
	if existItem != nil {
		myChartClassifyList, err := data_manage.GetMyChartClassifyList(existItem.MyChartId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "获取图表信息失败！"
			br.ErrMsg = "获取图表信息失败，Err:" + err.Error()
			return
		}

		for _, v := range myChartClassifyList {
			chartClassifyIdList = append(chartClassifyIdList, v.MyChartClassifyId)
		}
	}

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

// @router /delete [post]
func (this *MyChartController) MyChartDelete() {
	setNxKey := "MyChartDelete_"
	deleteCache := true
	br := new(models.BaseResponse).Init()
	defer func() {
		if deleteCache {
			utils.Rc.Delete(setNxKey)
		}
		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 data_manage.MyChartDeleteReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	setNxKey += strconv.Itoa(req.MyChartId) + strconv.Itoa(req.MyChartClassifyId)
	if !utils.Rc.SetNX(setNxKey, 1, 3*time.Second) {
		deleteCache = false
		br.Msg = "系统处理中，请稍后重试！"
		br.IsSendEmail = false
		return
	}
	if req.MyChartId <= 0 {
		br.Msg = "参数错误！"
		br.ErrMsg = "参数错误，Err:" + string(this.Ctx.Input.RequestBody)
		return
	}
	isDelMyChart, err := data_manage.DeleteMyChart(req.MyChartId, req.MyChartClassifyId)
	if err != nil {
		br.Msg = "移除失败！"
		br.ErrMsg = "移除失败，Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "删除-我的图表-中的图表"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}

	if isDelMyChart {
		go data.EsDeleteMyChartInfoByMyChartId(req.MyChartId)
	} else {
		go data.EsAddOrEditMyChartInfoByMyChartId(req.MyChartId)
	}
	br.Ret = 200
	br.Msg = "移除成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /edit [post]
func (this *MyChartController) MyChartEdit() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.MyChartEditReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	for _, v := range req.MyChartClassifyId {
		myChartClassifyId := v
		count, _ := data_manage.GetMyChartClassifyMappingCount(sysUser.AdminId, req.MyChartId, myChartClassifyId)
		if count <= 0 {
			mappingItem := new(data_manage.MyChartClassifyMapping)
			mappingItem.AdminId = sysUser.AdminId
			mappingItem.MyChartId = req.MyChartId
			mappingItem.MyChartClassifyId = myChartClassifyId
			mappingItem.CreateTime = time.Now()
			_, err = data_manage.AddMyChartClassifyMapping(mappingItem)
		}
	}
	err = data_manage.DeleteMyChartClassifyMapping(sysUser.AdminId, req.MyChartId, req.CurrentMyChartClassifyId)
	if err != nil {
		br.Msg = "保存失败！"
		br.ErrMsg = "保存失败，移除分类失败，Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "编辑我的图表"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}

	if req.MyChartId > 0 {
		go data.EsAddOrEditMyChartInfoByMyChartId(req.MyChartId)
	}

	br.Ret = 200
	br.Msg = "保存成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /list [get]
func (this *MyChartController) MyChartList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	myChartClassifyId, _ := this.GetInt("MyChartClassifyId")

	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")

	myChartId, _ := this.GetInt("MyChartId")
	isShared, _ := this.GetBool("IsShared")

	var total int
	page := paging.GetPaging(currentIndex, pageSize, total)

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	var condition string
	var pars []interface{}

	chartAdminId := sysUser.AdminId
	if myChartClassifyId > 0 {
		condition += " AND c.my_chart_classify_id=? "
		pars = append(pars, myChartClassifyId)

		if isShared {
			myClassify, e := data_manage.GetMyChartClassifyByClassifyId(myChartClassifyId)
			if e != nil {
				if utils.IsErrNoRow(e) {
					br.Msg = "分类已被删除, 请刷新页面"
					return
				}
				br.Msg = "获取失败"
				br.ErrMsg = "获取分类失败, Err: " + e.Error()
				return
			}
			chartAdminId = myClassify.AdminId
		}
	}

	condition += " AND (a.admin_id = ? OR d.is_public = 1)"
	pars = append(pars, chartAdminId)

	if myChartId > 0 {
		condition += " AND a.my_chart_id=? "
		pars = append(pars, myChartId)
	}

	noPermissionChartIdList := make([]int, 0)
	{
		obj := data_manage.EdbInfoNoPermissionAdmin{}
		confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "获取失败"
			br.ErrMsg = "获取不可见指标配置数据失败，Err:" + err.Error()
			return
		}
		for _, v := range confList {
			noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
		}
	}

	lenNoPermissionChartIdList := len(noPermissionChartIdList)
	if lenNoPermissionChartIdList > 0 {
		condition += ` AND b.chart_info_id not in (` + utils.GetOrmInReplace(lenNoPermissionChartIdList) + `) `
		pars = append(pars, noPermissionChartIdList)
	}

	list, err := data_manage.GetMyChartListByCondition(condition, pars, startSize, pageSize)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
		return
	}
	myChartList, err := data_manage.GetMyChartListByAdminId(sysUser.AdminId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取我的图表信息失败,Err:" + err.Error()
		return
	}
	myChartMap := make(map[int]int)
	chartInfoIds := ""
	chartEdbMap := make(map[int][]*data_manage.ChartEdbInfoMapping)
	for _, v := range myChartList {
		myChartMap[v.ChartInfoId] = v.ChartInfoId
		chartInfoIds += strconv.Itoa(v.ChartInfoId) + ","
	}
	if chartInfoIds != "" {
		chartInfoIds = strings.Trim(chartInfoIds, ",")
		edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取图表，指标信息失败，Err:" + e.Error()
			return
		}
		for _, v := range edbList {
			chartEdbMap[v.ChartInfoId] = append(chartEdbMap[v.ChartInfoId], v)
		}
	}

	listLen := len(list)
	if listLen > 0 {
		classifyIdList := make([]int, 0)
		classifyMap := make(map[int]*data_manage.ChartClassify)
		for _, v := range list {
			classifyIdList = append(classifyIdList, v.ChartClassifyId)
		}
		classifyList, err := data_manage.GetChartClassifyByIdList(classifyIdList)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取分类列表失败，Err:" + err.Error()
			return
		}

		for _, v := range classifyList {
			classifyMap[v.ChartClassifyId] = v
		}

		permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, 0, 0)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取已授权分类id数据失败，Err:" + err.Error()
			return
		}

		for i, chartViewInfo := range list {
			if edbTmpList, ok := chartEdbMap[list[i].ChartInfoId]; ok {
				list[i].IsEnChart = data.CheckIsEnChart(list[i].ChartNameEn, edbTmpList, list[i].Source, list[i].ChartType)
			}
			if _, ok := myChartMap[list[i].ChartInfoId]; ok {
				list[i].IsAdd = true
			}

			if currClassify, ok := classifyMap[chartViewInfo.ChartClassifyId]; ok {
				list[i].HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartViewInfo.IsJoinPermission, currClassify.IsJoinPermission, chartViewInfo.ChartInfoId, chartViewInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
			} else if chartViewInfo.ChartClassifyId == 0 {
				list[i].HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartViewInfo.IsJoinPermission, 0, chartViewInfo.ChartInfoId, chartViewInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
			}
		}

	}

	resp := new(data_manage.MyChartListResp)
	if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
		items := make([]*data_manage.MyChartList, 0)
		resp.Paging = page
		resp.List = items
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}
	total, err = data_manage.GetMyChartListCountByCondition(condition, pars)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取信息失败"
		br.ErrMsg = "获取我的图表数据总数失败,Err:" + err.Error()
		return
	}
	page = paging.GetPaging(currentIndex, pageSize, total)
	resp.Paging = page
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @router /move [post]
func (this *MyChartController) MyChartMove() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	adminId := sysUser.AdminId
	var req data_manage.MoveMyChartReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	var newSort float64
	if req.PrevMyChartId <= 0 {
		firstMapItem, err := data_manage.GetMyChartSort(adminId, req.MyChartClassifyId, 0)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败，GetMyChartClassifyMapping，Err:" + err.Error()
			return
		}
		newSort = firstMapItem.Sort - 1
	} else if req.NextMyChartId <= 0 {
		latestMapItem, err := data_manage.GetMyChartSort(adminId, req.MyChartClassifyId, 1)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败，GetMyChartClassifyMapping，Err:" + err.Error()
			return
		}
		newSort = latestMapItem.Sort + 1
	} else {
		preMapItem, err := data_manage.GetMyChartClassifyMapping(adminId, req.PrevMyChartId, req.MyChartClassifyId)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败，GetMyChartClassifyMapping，Err:" + err.Error()
			return
		}
		nextMapItem, err := data_manage.GetMyChartClassifyMapping(adminId, req.NextMyChartId, req.MyChartClassifyId)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败，GetMyChartClassifyMapping，Err:" + err.Error()
			return
		}
		newSort = (preMapItem.Sort + nextMapItem.Sort) / 2

		newSort = preMapItem.Sort + 1
		var updateSortStr string
		if preMapItem.Sort == nextMapItem.Sort {
			updateSortStr = `sort + 2`
		} else if nextMapItem.Sort-preMapItem.Sort == 1 {
			updateSortStr = `sort + 1`
		}
		if updateSortStr != `` {
			_ = data_manage.UpdateMyChartSortByClassifyId(req.MyChartClassifyId, int(preMapItem.Sort), preMapItem.MyChartClassifyMappingId, updateSortStr)
		}
	}
	err = data_manage.MyChartMove(newSort, adminId, req.MyChartId, req.MyChartClassifyId)
	if err != nil {
		br.Msg = "移动失败！"
		br.ErrMsg = "移动失败，Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "移动我的图表"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}

	if req.MyChartId > 0 {
		go data.EsAddOrEditMyChartInfoByMyChartId(req.MyChartId)
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "移动成功"
	br.IsAddLog = true
}

// @router /chart/recommend/list [get]
func (this *MyChartController) ChartRecommendList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	pageSize := 6
	currentIndex := 1
	var startSize int
	startSize = paging.StartIndex(currentIndex, pageSize)

	var condition string
	var pars []interface{}

	if sysUser.AdminId > 0 {
		condition += " AND a.admin_id=? "
		pars = append(pars, sysUser.AdminId)
	}

	list, err := data_manage.GetRecommendChartListByCondition(condition, pars, startSize, pageSize)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
		return
	}

	myChartList, err := data_manage.GetMyChartListByAdminId(sysUser.AdminId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取我的图表信息失败,Err:" + err.Error()
		return
	}
	myChartMap := make(map[int]int)
	for _, v := range myChartList {
		myChartMap[v.ChartInfoId] = v.ChartInfoId
	}
	listLen := len(list)

	if listLen > 0 {
		classifyIdList := make([]int, 0)
		classifyMap := make(map[int]*data_manage.ChartClassify)
		for _, v := range list {
			classifyIdList = append(classifyIdList, v.ChartClassifyId)
		}
		classifyList, err := data_manage.GetChartClassifyByIdList(classifyIdList)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取分类列表失败，Err:" + err.Error()
			return
		}

		for _, v := range classifyList {
			classifyMap[v.ChartClassifyId] = v
		}

		permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, 0, 0)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取已授权分类id数据失败，Err:" + err.Error()
			return
		}
		for k, chartViewInfo := range list {
			if currClassify, ok := classifyMap[chartViewInfo.ChartClassifyId]; ok {
				list[k].HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartViewInfo.IsJoinPermission, currClassify.IsJoinPermission, chartViewInfo.ChartInfoId, chartViewInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
			}

			if _, ok := myChartMap[list[k].ChartInfoId]; ok {
				list[k].IsAdd = true
			}
		}

	}

	resp := new(data_manage.ChartRecommendListResp)
	if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
		items := make([]*data_manage.ChartInfoView, 0)
		resp.List = items
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}

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

// @router /search [get]
func (this *MyChartController) MyChartSearch() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	var condition string
	var pars []interface{}

	condition += " AND a.admin_id=? "
	pars = append(pars, sysUser.AdminId)

	keyWord := this.GetString("KeyWord")
	if keyWord != "" {
		condition += ` AND chart_name LIKE '%` + keyWord + `%' `
	}

	list, err := data_manage.GetMyChartSearchByCondition(condition, pars)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取图表信息失败"
		br.ErrMsg = "获取图表信息失败,Err:" + err.Error()
		return
	}
	listLen := len(list)

	if listLen > 0 {
		classifyIdList := make([]int, 0)
		classifyMap := make(map[int]*data_manage.ChartClassify)
		for _, v := range list {
			classifyIdList = append(classifyIdList, v.ChartClassifyId)
		}
		classifyList, err := data_manage.GetChartClassifyByIdList(classifyIdList)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取分类列表失败，Err:" + err.Error()
			return
		}

		for _, v := range classifyList {
			classifyMap[v.ChartClassifyId] = v
		}

		permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, 0, 0)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取已授权分类id数据失败，Err:" + err.Error()
			return
		}
		for k, chartViewInfo := range list {
			if currClassify, ok := classifyMap[chartViewInfo.ChartClassifyId]; ok {
				list[k].HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartViewInfo.IsJoinPermission, currClassify.IsJoinPermission, chartViewInfo.ChartInfoId, chartViewInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
			}
			list[k].IsAdd = true
		}

	}

	resp := new(data_manage.MyChartSearchListResp)
	if list == nil {
		list = make([]*data_manage.MyChartList, 0)
	}
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @router /search_by_es [get]
func (this *MyChartController) MyChartSearchByEs() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	keyword := this.GetString("Keyword")

	noPermissionChartIdList := make([]int, 0)
	{
		obj := data_manage.EdbInfoNoPermissionAdmin{}
		confList, err := obj.GetAllChartListByAdminId(this.SysUser.AdminId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "获取失败"
			br.ErrMsg = "获取不可见指标配置数据失败，Err:" + err.Error()
			return
		}
		for _, v := range confList {
			noPermissionChartIdList = append(noPermissionChartIdList, v.ChartInfoId)
		}
	}

	list, total, err := data.EsSearchMyChartInfo(keyword, sysUser.AdminId, noPermissionChartIdList, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取图表信息失败，Err:" + err.Error()
		return
	}

	lenList := len(list)
	if lenList <= 0 {
		list = make([]*data_manage.MyChartList, 0)
	} else {
		classifyIdList := make([]int, 0)
		chartInfoIdList := make([]int, 0)

		chartClassifyMap := make(map[int]*data_manage.ChartClassify)
		chartInfoMap := make(map[int]*data_manage.ChartInfo)
		for _, v := range list {
			classifyIdList = append(classifyIdList, v.ChartClassifyId)
			chartInfoIdList = append(chartInfoIdList, v.ChartInfoId)
		}

		{
			classifyList, err := data_manage.GetChartClassifyByIdList(classifyIdList)
			if err != nil {
				if err != nil {
					br.Msg = "获取失败"
					br.ErrMsg = "获取分类列表失败，Err:" + err.Error()
					return
				}
			}
			for _, tmpClassifyInfo := range classifyList {
				chartClassifyMap[tmpClassifyInfo.ChartClassifyId] = tmpClassifyInfo
			}
		}

		{
			tmpChartList, err := data_manage.GetChartInfoByIdList(chartInfoIdList)
			if err != nil {
				br.Msg = "获取失败"
				br.ErrMsg = "获取所有有权限的图表失败，Err:" + err.Error()
				return
			}
			for _, tmpChartInfo := range tmpChartList {
				chartInfoMap[tmpChartInfo.ChartInfoId] = tmpChartInfo
			}
		}

		permissionChartIdList, permissionClassifyIdList, err := data_manage_permission.GetUserChartAndClassifyPermissionList(this.SysUser.AdminId, 0, 0)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取已授权分类id数据失败，Err:" + err.Error()
			return
		}
		for k, tmpChartViewInfo := range list {
			list[k].IsAdd = true
			chartViewInfo, ok := chartInfoMap[tmpChartViewInfo.ChartInfoId]
			if !ok {
				continue
			}
			if currClassify, ok := chartClassifyMap[chartViewInfo.ChartClassifyId]; ok {
				list[k].HaveOperaAuth = data_manage_permission.CheckChartPermissionByPermissionIdList(chartViewInfo.IsJoinPermission, currClassify.IsJoinPermission, chartViewInfo.ChartInfoId, chartViewInfo.ChartClassifyId, permissionChartIdList, permissionClassifyIdList)
			}
		}
	}

	page := paging.GetPaging(currentIndex, pageSize, int(total))
	resp := data_manage.MyChartSearchListResp{
		List:   list,
		Paging: page,
	}

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

// @router /classify/public_list [get]
func (this *MyChartController) PublicClassifyList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	list, err := data_manage.GetPublicChartClassifyAllExceptMy(sysUser.AdminId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取公共分类信息失败"
		br.ErrMsg = "获取公共分类信息失败,Err:" + err.Error()
		return
	}

	resp := new(data_manage.PublicChartClassifyResp)
	if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
		resp.List = make([]data_manage.PublicChartClassifyList, 0)
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}

	adminIdStr := make([]string, 0)
	for _, v := range list {
		adminIdStr = append(adminIdStr, fmt.Sprint(v.AdminId))
	}
	adminMap := make(map[int]string)
	adminList, _ := system.GetSysAdminByIdSlice(adminIdStr)
	if len(adminList) > 0 {
		for _, adminInfo := range adminList {
			adminMap[adminInfo.AdminId] = adminInfo.RealName
		}
	}

	respList := make([]data_manage.PublicChartClassifyList, 0)
	existMap := make(map[int]bool, 0)
	itemsMap := make(map[int][]data_manage.PublicChartClassifyItem, 0)
	for _, v := range list {
		realName := adminMap[v.AdminId]
		if realName == "" {
			continue
		}

		if itemsMap[v.AdminId] == nil {
			itemsMap[v.AdminId] = make([]data_manage.PublicChartClassifyItem, 0)
		}
		itemsMap[v.AdminId] = append(itemsMap[v.AdminId], data_manage.PublicChartClassifyItem{
			MyChartClassifyId:   v.MyChartClassifyId,
			MyChartClassifyName: v.MyChartClassifyName,
			AdminId:             v.AdminId,
			RealName:            realName,
			IsPublic:            v.IsPublic,
			IsCompanyPublic:     v.IsCompanyPublic,
		})

		var menu data_manage.PublicChartClassifyList
		if existMap[v.AdminId] {
			continue
		}
		existMap[v.AdminId] = true
		menu.MenuAdminId = v.AdminId
		menu.MenuName = fmt.Sprintf("%s的图库", realName)
		respList = append(respList, menu)
	}

	for k, v := range respList {
		respList[k].Items = itemsMap[v.MenuAdminId]
	}
	resp.List = respList

	language := `CN`
	{
		configDetail, _ := system.GetConfigDetailByCode(this.SysUser.AdminId, system.ChartLanguageVar)
		if configDetail != nil {
			language = configDetail.ConfigValue
		} else {
			configDetail, _ = system.GetDefaultConfigDetailByCode(system.ChartLanguageVar)
			if configDetail != nil {
				language = configDetail.ConfigValue
			}
		}
	}
	resp.Language = language

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

// @router /classify/modify_public [post]
func (this *MyChartController) ModifyClassifyPublicStatus() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.ModifyChartClassifyPublicReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	item, err := data_manage.GetMyChartClassifyById(sysUser.AdminId, req.MyChartClassifyId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "修改失败，找不到该分类"
		br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
		return
	}
	if item == nil {
		br.Msg = "分类不存在"
		br.ErrMsg = "分类不存在,Err:" + err.Error()
		return
	}

	item.IsPublic = req.IsPublic
	item.PublicTime = time.Now()
	if req.IsPublic == 0 {
		item.IsCompanyPublic = 0
	}
	err = item.Update([]string{"IsPublic", "PublicTime", "IsCompanyPublic"})
	if err != nil {
		br.Msg = "修改失败"
		br.ErrMsg = "修改是否公开失败,Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "修改分类是否公开"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}
	br.Ret = 200
	br.Msg = "修改成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /classify/copy [post]
func (this *MyChartController) CopyClassifyAndChart() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.CopyChartClassifyReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	item, err := data_manage.GetPublicMyChartClassifyById(req.MyChartClassifyId)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "复制失败，找不到该分类"
		br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
		return
	}
	if item == nil {
		br.Msg = "分类不存在"
		br.ErrMsg = "分类不存在,Err:" + err.Error()
		return
	}

	chartClassifyList, err := data_manage.GetMyChartClassifyAll(sysUser.AdminId)
	newChartClassifyName := generateMyChartClassifyName(item.MyChartClassifyName, 1, chartClassifyList)
	newMyChartClassify, err := data_manage.CopyPublicMyChartClassifyById(item.MyChartClassifyId, sysUser.AdminId, newChartClassifyName)
	if err != nil {
		br.Msg = "复制失败"
		br.ErrMsg = "复制失败,Err:" + err.Error()
		return
	}
	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "复制分类"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}
	br.Data = newMyChartClassify
	br.Ret = 200
	br.Msg = "复制成功"
	br.Success = true
	br.IsAddLog = true
}

func generateMyChartClassifyName(myChartClassifyName string, count int, chartClassifyList []*data_manage.MyChartClassify) (newChartClassifyName string) {
	newChartClassifyName = fmt.Sprint(myChartClassifyName, count)
	for _, v := range chartClassifyList {
		if v.MyChartClassifyName == newChartClassifyName {
			count++
			newChartClassifyName = generateMyChartClassifyName(fmt.Sprint(myChartClassifyName), count, chartClassifyList)
			return
		}
	}
	return
}

// @router /classify/modify_company_public [post]
func (this *MyChartController) ModifyClassifyCompanyPublicStatus() {
	br := new(models.BaseResponse).Init()
	defer func() {
		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 data_manage.ModifyChartClassifyCompanyPublicReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	item, err := data_manage.GetPublicMyChartClassifyById(req.MyChartClassifyId)
	if err != nil {
		br.Msg = "找不到该分类"
		br.ErrMsg = "获取分类信息失败, Err:" + err.Error()
		return
	}

	if item.IsPublic != 1 {
		br.Msg = "该分类未公开，不可设置为用户可见"
		br.ErrMsg = "该分类未公开，不可设置为用户可见"
		return
	}

	item.IsCompanyPublic = req.IsCompanyPublic
	item.CompanyPublicTime = time.Now()
	err = item.Update([]string{"IsCompanyPublic", "CompanyPublicTime"})
	if err != nil {
		br.Msg = "修改失败"
		br.ErrMsg = "修改是否用户可见失败, Err:" + err.Error()
		return
	}

	{
		edbLog := new(data_manage.MyChartLog)
		edbLog.MyChartId = 0
		edbLog.ChartInfoId = 0
		edbLog.SysUserId = sysUser.AdminId
		edbLog.SysUserRealName = sysUser.RealName
		edbLog.CreateTime = time.Now()
		edbLog.Content = string(this.Ctx.Input.RequestBody)
		edbLog.Status = "修改用户是否可见"
		edbLog.Method = this.Ctx.Input.URI()
		go data_manage.AddMyChartLog(edbLog)
	}

	br.Ret = 200
	br.Msg = "修改成功"
	br.Success = true
	br.IsAddLog = true
}

// @router /classify/company_public_list [get]
func (this *MyChartController) CompanyPublicClassifyList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	var condition string
	var pars []interface{}
	keyword := this.GetString("Keyword")
	if keyword != "" {
		keyword = "%" + keyword + "%"
		condition += ` AND my_chart_classify_name LIKE ? `
		pars = append(pars, keyword)
	}
	list, err := data_manage.GetCompanyPublicClassifyList(condition, pars)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Success = true
		br.Msg = "获取用户可见分类列表失败"
		br.ErrMsg = "获取用户可见分类列表失败, Err:" + err.Error()
		return
	}

	resp := new(data_manage.MyChartClassifyResp)
	if list == nil || len(list) <= 0 || (err != nil && utils.IsErrNoRow(err)) {
		items := make([]*data_manage.MyChartClassifyItem, 0)
		resp.List = items
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		return
	}

	results := make([]*data_manage.MyChartClassifyItem, 0)
	for _, v := range list {
		results = append(results, data_manage.FormatMyChartClassify2Item(v, 0))
	}
	resp.List = results

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


// @router /classify/framework_node_list [get]
func (this *MyChartController) ClassifyFrameworkNodeList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = true
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	classifyId, _ := this.GetInt("MyChartClassifyId")
	if classifyId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = fmt.Sprintf("参数有误, MyChartClassifyId: %d", classifyId)
		return
	}

	_, e := data_manage.GetMyChartClassifyById(sysUser.AdminId, classifyId)
	if e != nil {
		if utils.IsErrNoRow(e) {
			br.Msg = "分类不存在, 请刷新页面"
			return
		}
		br.Msg = "获取失败"
		br.ErrMsg = "获取分类信息失败, Err:" + e.Error()
		return
	}

	nodeOb := new(data_manage.ChartFrameworkNode)
	cond := ` AND my_chart_classify_id = ?`
	pars := make([]interface{}, 0)
	pars = append(pars, classifyId)
	nodes, e := nodeOb.GetItemsByCondition(cond, pars, []string{}, "")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取我的图表分类关联的框架节点失败, Err: " + e.Error()
		return
	}
	resp := make([]*data_manage.ChartFrameworkNodeItem, 0)
	for _, v := range nodes {
		resp = append(resp, data_manage.FormatChartFrameworkNode2Item(v, 0))
	}

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