|
@@ -14,28 +14,17 @@ import (
|
|
"eta_gn/eta_api/services/data/data_manage_permission"
|
|
"eta_gn/eta_api/services/data/data_manage_permission"
|
|
"eta_gn/eta_api/utils"
|
|
"eta_gn/eta_api/utils"
|
|
"fmt"
|
|
"fmt"
|
|
- "github.com/rdlucklib/rdluck_tools/paging"
|
|
|
|
"strconv"
|
|
"strconv"
|
|
"strings"
|
|
"strings"
|
|
"time"
|
|
"time"
|
|
|
|
+
|
|
|
|
+ "github.com/rdlucklib/rdluck_tools/paging"
|
|
)
|
|
)
|
|
|
|
|
|
-// ChartInfoController
|
|
|
|
-// @Description: 跨品种分析图表
|
|
|
|
type ChartInfoController struct {
|
|
type ChartInfoController struct {
|
|
controllers.BaseAuthController
|
|
controllers.BaseAuthController
|
|
}
|
|
}
|
|
|
|
|
|
-// List
|
|
|
|
-// @Title 跨品种分析图表列表接口
|
|
|
|
-// @Description 跨品种分析图表列表接口
|
|
|
|
-// @Param PageSize query int true "每页数据条数"
|
|
|
|
-// @Param CurrentIndex query int true "当前页页码,从1开始"
|
|
|
|
-// @Param ChartClassifyId query int true "分类id"
|
|
|
|
-// @Param Keyword query string true "搜索关键词"
|
|
|
|
-// @Param IsShowMe query bool true "是否只看我的,true、false"
|
|
|
|
-// @Param Source query int true "图表类型,10:跨品种分析
|
|
|
|
-// @Success 200 {object} data_manage.ChartListResp
|
|
|
|
// @router /chart_info/list [get]
|
|
// @router /chart_info/list [get]
|
|
func (c *ChartInfoController) List() {
|
|
func (c *ChartInfoController) List() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -77,7 +66,6 @@ func (c *ChartInfoController) List() {
|
|
var condition string
|
|
var condition string
|
|
var pars []interface{}
|
|
var pars []interface{}
|
|
|
|
|
|
- // 普通图表
|
|
|
|
condition += ` AND source = ? `
|
|
condition += ` AND source = ? `
|
|
pars = append(pars, source)
|
|
pars = append(pars, source)
|
|
|
|
|
|
@@ -94,14 +82,12 @@ func (c *ChartInfoController) List() {
|
|
condition += ` AND ( chart_name LIKE '%` + keyword + `%' )`
|
|
condition += ` AND ( chart_name LIKE '%` + keyword + `%' )`
|
|
}
|
|
}
|
|
|
|
|
|
- //只看我的
|
|
|
|
isShowMe, _ := c.GetBool("IsShowMe")
|
|
isShowMe, _ := c.GetBool("IsShowMe")
|
|
if isShowMe {
|
|
if isShowMe {
|
|
condition += ` AND sys_user_id = ? `
|
|
condition += ` AND sys_user_id = ? `
|
|
pars = append(pars, sysUser.AdminId)
|
|
pars = append(pars, sysUser.AdminId)
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取当前账号的不可见指标
|
|
|
|
noPermissionChartIdList := make([]int, 0)
|
|
noPermissionChartIdList := make([]int, 0)
|
|
{
|
|
{
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
@@ -122,7 +108,6 @@ func (c *ChartInfoController) List() {
|
|
pars = append(pars, noPermissionChartIdList)
|
|
pars = append(pars, noPermissionChartIdList)
|
|
}
|
|
}
|
|
|
|
|
|
- //获取图表信息
|
|
|
|
list, err := data_manage.GetChartListByCondition(condition, pars, startSize, pageSize)
|
|
list, err := data_manage.GetChartListByCondition(condition, pars, startSize, pageSize)
|
|
if err != nil && !utils.IsErrNoRow(err) {
|
|
if err != nil && !utils.IsErrNoRow(err) {
|
|
br.Success = true
|
|
br.Success = true
|
|
@@ -150,7 +135,6 @@ func (c *ChartInfoController) List() {
|
|
}
|
|
}
|
|
if chartInfoIds != "" {
|
|
if chartInfoIds != "" {
|
|
chartInfoIds = strings.Trim(chartInfoIds, ",")
|
|
chartInfoIds = strings.Trim(chartInfoIds, ",")
|
|
- //判断是否需要展示英文标识
|
|
|
|
edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
|
|
edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
|
|
if e != nil {
|
|
if e != nil {
|
|
br.Msg = "获取失败"
|
|
br.Msg = "获取失败"
|
|
@@ -163,7 +147,6 @@ func (c *ChartInfoController) List() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
for i := 0; i < listLen; i++ {
|
|
for i := 0; i < listLen; i++ {
|
|
- //判断是否需要展示英文标识
|
|
|
|
if edbTmpList, ok := chartEdbMap[list[i].ChartInfoId]; ok {
|
|
if edbTmpList, ok := chartEdbMap[list[i].ChartInfoId]; ok {
|
|
list[i].IsEnChart = data.CheckIsEnChart(list[i].ChartNameEn, edbTmpList, list[i].Source, list[i].ChartType)
|
|
list[i].IsEnChart = data.CheckIsEnChart(list[i].ChartNameEn, edbTmpList, list[i].Source, list[i].ChartType)
|
|
}
|
|
}
|
|
@@ -201,11 +184,6 @@ func (c *ChartInfoController) List() {
|
|
br.Data = resp
|
|
br.Data = resp
|
|
}
|
|
}
|
|
|
|
|
|
-// Preview
|
|
|
|
-// @Title 跨品种分析图表-预览数据
|
|
|
|
-// @Description 跨品种分析图表-获取预览数据
|
|
|
|
-// // @Param request body request.ChartConfigReq true "type json string"
|
|
|
|
-// @Success 200 {object} data_manage.ChartEdbInfoDetailResp
|
|
|
|
// @router /chart_info/preview [post]
|
|
// @router /chart_info/preview [post]
|
|
func (c *ChartInfoController) Preview() {
|
|
func (c *ChartInfoController) Preview() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -250,7 +228,6 @@ func (c *ChartInfoController) Preview() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 品种配置
|
|
|
|
varietyListList := len(req.VarietyList)
|
|
varietyListList := len(req.VarietyList)
|
|
if varietyListList < 0 {
|
|
if varietyListList < 0 {
|
|
br.Msg = "请选择品种"
|
|
br.Msg = "请选择品种"
|
|
@@ -258,7 +235,6 @@ func (c *ChartInfoController) Preview() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 日期配置
|
|
|
|
dateConfigList := len(req.DateConfigList)
|
|
dateConfigList := len(req.DateConfigList)
|
|
if dateConfigList < 0 {
|
|
if dateConfigList < 0 {
|
|
br.Msg = "请选择日期"
|
|
br.Msg = "请选择日期"
|
|
@@ -274,7 +250,6 @@ func (c *ChartInfoController) Preview() {
|
|
chartInfo := new(data_manage.ChartInfoView)
|
|
chartInfo := new(data_manage.ChartInfoView)
|
|
chartInfo.ChartType = utils.CHART_SOURCE_CROSS_HEDGING
|
|
chartInfo.ChartType = utils.CHART_SOURCE_CROSS_HEDGING
|
|
|
|
|
|
- // 获取图表x轴y轴
|
|
|
|
edbInfoList, dataResp, err, errMsg, isSendEmail := cross_variety.GetChartData(0, req)
|
|
edbInfoList, dataResp, err, errMsg, isSendEmail := cross_variety.GetChartData(0, req)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.IsSendEmail = isSendEmail
|
|
br.IsSendEmail = isSendEmail
|
|
@@ -290,18 +265,12 @@ func (c *ChartInfoController) Preview() {
|
|
EdbInfoList: edbInfoList,
|
|
EdbInfoList: edbInfoList,
|
|
DataResp: dataResp,
|
|
DataResp: dataResp,
|
|
}
|
|
}
|
|
- //resp.EdbInfoList = edbList
|
|
|
|
br.Data = resp
|
|
br.Data = resp
|
|
br.Ret = 200
|
|
br.Ret = 200
|
|
br.Success = true
|
|
br.Success = true
|
|
br.Msg = "获取成功"
|
|
br.Msg = "获取成功"
|
|
}
|
|
}
|
|
|
|
|
|
-// Add
|
|
|
|
-// @Title 新增图表接口
|
|
|
|
-// @Description 新增图表接口
|
|
|
|
-// @Param request body request.AddChartInfoReq true "type json string"
|
|
|
|
-// @Success 200 {object} data_manage.AddChartInfoResp
|
|
|
|
// @router /chart_info/add [post]
|
|
// @router /chart_info/add [post]
|
|
func (c *ChartInfoController) Add() {
|
|
func (c *ChartInfoController) Add() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -336,7 +305,6 @@ func (c *ChartInfoController) Add() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 添加图表
|
|
|
|
req.ChartNameEn = req.ChartName
|
|
req.ChartNameEn = req.ChartName
|
|
chartInfo, err, errMsg, isSendEmail := cross_variety.AddChartInfo(req, sysUser, c.Lang)
|
|
chartInfo, err, errMsg, isSendEmail := cross_variety.AddChartInfo(req, sysUser, c.Lang)
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -349,7 +317,6 @@ func (c *ChartInfoController) Add() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartInfoId = chartInfo.ChartInfoId
|
|
chartLog.ChartInfoId = chartInfo.ChartInfoId
|
|
@@ -376,11 +343,6 @@ func (c *ChartInfoController) Add() {
|
|
br.IsAddLog = true
|
|
br.IsAddLog = true
|
|
}
|
|
}
|
|
|
|
|
|
-// Edit
|
|
|
|
-// @Title 编辑图表接口
|
|
|
|
-// @Description 编辑图表接口
|
|
|
|
-// @Param request body request.EditChartInfoReq true "type json string"
|
|
|
|
-// @Success Ret=200 保存成功
|
|
|
|
// @router /chart_info/edit [post]
|
|
// @router /chart_info/edit [post]
|
|
func (c *ChartInfoController) Edit() {
|
|
func (c *ChartInfoController) Edit() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -419,9 +381,6 @@ func (c *ChartInfoController) Edit() {
|
|
resp := new(data_manage.AddChartInfoResp)
|
|
resp := new(data_manage.AddChartInfoResp)
|
|
resp.ChartInfoId = chartItem.ChartInfoId
|
|
resp.ChartInfoId = chartItem.ChartInfoId
|
|
resp.UniqueCode = chartItem.UniqueCode
|
|
resp.UniqueCode = chartItem.UniqueCode
|
|
- //resp.ChartType = req.ChartType
|
|
|
|
-
|
|
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartName = chartItem.ChartName
|
|
chartLog.ChartName = chartItem.ChartName
|
|
@@ -444,11 +403,6 @@ func (c *ChartInfoController) Edit() {
|
|
br.IsAddLog = true
|
|
br.IsAddLog = true
|
|
}
|
|
}
|
|
|
|
|
|
-// Detail
|
|
|
|
-// @Title 获取图表详情
|
|
|
|
-// @Description 获取图表详情接口
|
|
|
|
-// @Param ChartInfoId query int true "图表id"
|
|
|
|
-// @Success 200 {object} data_manage.ChartInfoDetailResp
|
|
|
|
// @router /chart_info/detail [get]
|
|
// @router /chart_info/detail [get]
|
|
func (c *ChartInfoController) Detail() {
|
|
func (c *ChartInfoController) Detail() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -483,7 +437,6 @@ func (c *ChartInfoController) Detail() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取主题样式
|
|
|
|
chartTheme, err := data.GetChartThemeConfig(chartInfo.ChartThemeId, utils.CHART_SOURCE_DEFAULT, 5)
|
|
chartTheme, err := data.GetChartThemeConfig(chartInfo.ChartThemeId, utils.CHART_SOURCE_DEFAULT, 5)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "获取失败"
|
|
br.Msg = "获取失败"
|
|
@@ -506,36 +459,6 @@ func (c *ChartInfoController) Detail() {
|
|
br.ErrMsg = "解析跨品种分析配置失败,Err:" + err.Error()
|
|
br.ErrMsg = "解析跨品种分析配置失败,Err:" + err.Error()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
-
|
|
|
|
- //mappingList, err := cross_varietyModel.GetChartVarietyMappingList(chartInfo.ChartInfoId)
|
|
|
|
- //if err != nil {
|
|
|
|
- // br.Msg = "获取品种失败"
|
|
|
|
- // br.ErrMsg = "获取品种失败,Err:" + err.Error()
|
|
|
|
- // return
|
|
|
|
- //}
|
|
|
|
- // 获取跨品种分析配置
|
|
|
|
- //chartInfoCrossVariety, err := cross_varietyModel.GetChartInfoCrossVarietyByChartInfoId(chartInfo.ChartInfoId)
|
|
|
|
- //if err != nil {
|
|
|
|
- // br.Msg = "获取跨品种分析配置失败"
|
|
|
|
- // br.ErrMsg = "获取跨品种分析配置失败,Err:" + err.Error()
|
|
|
|
- // return
|
|
|
|
- //}
|
|
|
|
- //
|
|
|
|
- //varietyIdList := make([]int,0)
|
|
|
|
- //for _,v:=range mappingList{
|
|
|
|
- // varietyIdList = append(varietyIdList,v.ChartVarietyId)
|
|
|
|
- //}
|
|
|
|
- //config := request.ChartConfigReq{
|
|
|
|
- // TagX: chartInfoCrossVariety.ChartXTagId,
|
|
|
|
- // TagY: chartInfoCrossVariety.ChartYTagId,
|
|
|
|
- // CalculateValue: chartInfoCrossVariety.CalculateValue,
|
|
|
|
- // CalculateUnit: chartInfoCrossVariety.CalculateUnit,
|
|
|
|
- // DateConfigList: config.DateConfigList,
|
|
|
|
- // VarietyList: varietyIdList,
|
|
|
|
- //}
|
|
|
|
- //config.TagX =
|
|
|
|
-
|
|
|
|
- // 获取图表x轴y轴
|
|
|
|
edbList, dataResp, err, errMsg, isSendEmail := cross_variety.GetChartData(0, config)
|
|
edbList, dataResp, err, errMsg, isSendEmail := cross_variety.GetChartData(0, config)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.IsSendEmail = isSendEmail
|
|
br.IsSendEmail = isSendEmail
|
|
@@ -547,15 +470,6 @@ func (c *ChartInfoController) Detail() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 完善指标信息
|
|
|
|
- //edbList, e := correlationServ.GetChartEdbInfoFormat(chartInfo.ChartInfoId, edbInfoMappingA, edbInfoMappingB)
|
|
|
|
- //if e != nil {
|
|
|
|
- // br.Msg = "获取失败"
|
|
|
|
- // br.ErrMsg = "获取跨品种分析图表, 完善指标信息失败, Err:" + e.Error()
|
|
|
|
- // return
|
|
|
|
- //}
|
|
|
|
-
|
|
|
|
- // 判断是否加入我的图库
|
|
|
|
if chartInfoId > 0 && chartInfo != nil {
|
|
if chartInfoId > 0 && chartInfo != nil {
|
|
{
|
|
{
|
|
var myChartCondition string
|
|
var myChartCondition string
|
|
@@ -579,13 +493,7 @@ func (c *ChartInfoController) Detail() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- //图表操作权限
|
|
|
|
chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
|
|
chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
|
|
- ////判断是否需要展示英文标识
|
|
|
|
- //chartInfo.IsEnChart = data.CheckIsEnChart(chartInfo.ChartNameEn, edbList[0:1], chartInfo.Source, chartInfo.ChartType)
|
|
|
|
- //chartInfo.UnitEn = edbInfoMappingA.UnitEn
|
|
|
|
-
|
|
|
|
- // 另存为
|
|
|
|
chartInfo.Button = data_manage.ChartViewButton{
|
|
chartInfo.Button = data_manage.ChartViewButton{
|
|
IsEdit: chartInfo.IsEdit,
|
|
IsEdit: chartInfo.IsEdit,
|
|
IsEnChart: chartInfo.IsEnChart,
|
|
IsEnChart: chartInfo.IsEnChart,
|
|
@@ -595,11 +503,9 @@ func (c *ChartInfoController) Detail() {
|
|
}
|
|
}
|
|
|
|
|
|
chartInfo.HaveOperaAuth = true
|
|
chartInfo.HaveOperaAuth = true
|
|
- // 指标权限
|
|
|
|
{
|
|
{
|
|
edbClassifyPermissionMap := make(map[int]data_manage_permission.EdbClassifyPermission)
|
|
edbClassifyPermissionMap := make(map[int]data_manage_permission.EdbClassifyPermission)
|
|
classifyMap := make(map[int]*data_manage.EdbClassify)
|
|
classifyMap := make(map[int]*data_manage.EdbClassify)
|
|
- // 分类
|
|
|
|
{
|
|
{
|
|
classifyIdList := make([]int, 0)
|
|
classifyIdList := make([]int, 0)
|
|
for _, v := range edbList {
|
|
for _, v := range edbList {
|
|
@@ -616,7 +522,6 @@ func (c *ChartInfoController) Detail() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- // 遍历到校验map
|
|
|
|
for _, v := range edbList {
|
|
for _, v := range edbList {
|
|
edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
|
|
edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
|
|
ClassifyId: v.ClassifyId,
|
|
ClassifyId: v.ClassifyId,
|
|
@@ -625,7 +530,6 @@ func (c *ChartInfoController) Detail() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取所有有权限的指标和分类
|
|
|
|
permissionEdbIdList, permissionClassifyIdList, err := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUser.AdminId, 0, 0)
|
|
permissionEdbIdList, permissionClassifyIdList, err := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUser.AdminId, 0, 0)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "获取失败"
|
|
br.Msg = "获取失败"
|
|
@@ -634,7 +538,6 @@ func (c *ChartInfoController) Detail() {
|
|
}
|
|
}
|
|
|
|
|
|
for _, v := range edbList {
|
|
for _, v := range edbList {
|
|
- // 数据权限
|
|
|
|
edbItem, ok := edbClassifyPermissionMap[v.EdbInfoId]
|
|
edbItem, ok := edbClassifyPermissionMap[v.EdbInfoId]
|
|
if !ok {
|
|
if !ok {
|
|
continue
|
|
continue
|
|
@@ -656,11 +559,6 @@ func (c *ChartInfoController) Detail() {
|
|
br.Data = resp
|
|
br.Data = resp
|
|
}
|
|
}
|
|
|
|
|
|
-// Relation
|
|
|
|
-// @Title 获取图表的关联信息
|
|
|
|
-// @Description 获取图表的关联信息
|
|
|
|
-// @Param ChartInfoId query int true "图表id"
|
|
|
|
-// @Success 200 {object} data_manage.ChartInfoDetailResp
|
|
|
|
// @router /chart_info/relation [get]
|
|
// @router /chart_info/relation [get]
|
|
func (c *ChartInfoController) Relation() {
|
|
func (c *ChartInfoController) Relation() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -728,7 +626,6 @@ func (c *ChartInfoController) Relation() {
|
|
xTag, yTag,
|
|
xTag, yTag,
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取品种列表
|
|
|
|
varietyList, err := cross_varietyModels.GetVarietyListByIdList(config.VarietyList)
|
|
varietyList, err := cross_varietyModels.GetVarietyListByIdList(config.VarietyList)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "获取品种信息失败"
|
|
br.Msg = "获取品种信息失败"
|
|
@@ -746,11 +643,6 @@ func (c *ChartInfoController) Relation() {
|
|
br.Data = resp
|
|
br.Data = resp
|
|
}
|
|
}
|
|
|
|
|
|
-// Copy
|
|
|
|
-// @Title 复制并新增图表接口
|
|
|
|
-// @Description 新增图表接口
|
|
|
|
-// @Param request body data_manage.CopyAddChartInfoReq true "type json string"
|
|
|
|
-// @Success 200 {object} data_manage.AddChartInfoResp
|
|
|
|
// @router /chart_info/copy [post]
|
|
// @router /chart_info/copy [post]
|
|
func (c *ChartInfoController) Copy() {
|
|
func (c *ChartInfoController) Copy() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -787,7 +679,6 @@ func (c *ChartInfoController) Copy() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取原图表信息
|
|
|
|
oldChartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
oldChartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "获取原图表信息失败"
|
|
br.Msg = "获取原图表信息失败"
|
|
@@ -811,7 +702,6 @@ func (c *ChartInfoController) Copy() {
|
|
config.MarkersAreas = oldChartInfo.MarkersAreas
|
|
config.MarkersAreas = oldChartInfo.MarkersAreas
|
|
config.ChartNameEn = oldChartInfo.ChartNameEn
|
|
config.ChartNameEn = oldChartInfo.ChartNameEn
|
|
|
|
|
|
- // 添加图表
|
|
|
|
chartInfo, err, errMsg, isSendEmail := cross_variety.AddChartInfo(config, sysUser, c.Lang)
|
|
chartInfo, err, errMsg, isSendEmail := cross_variety.AddChartInfo(config, sysUser, c.Lang)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "保存失败"
|
|
br.Msg = "保存失败"
|
|
@@ -833,7 +723,6 @@ func (c *ChartInfoController) Copy() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartInfoId = chartInfo.ChartInfoId
|
|
chartLog.ChartInfoId = chartInfo.ChartInfoId
|
|
@@ -860,10 +749,6 @@ func (c *ChartInfoController) Copy() {
|
|
br.IsAddLog = true
|
|
br.IsAddLog = true
|
|
}
|
|
}
|
|
|
|
|
|
-// Move
|
|
|
|
-// @Title 移动图表接口
|
|
|
|
-// @Description 移动图表接口
|
|
|
|
-// @Success 200 {object} data_manage.MoveChartInfoReq
|
|
|
|
// @router /chart_info/move [post]
|
|
// @router /chart_info/move [post]
|
|
func (c *ChartInfoController) Move() {
|
|
func (c *ChartInfoController) Move() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -908,9 +793,7 @@ func (c *ChartInfoController) Move() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //移动排序
|
|
|
|
updateCol := make([]string, 0)
|
|
updateCol := make([]string, 0)
|
|
- //如果有传入 上一个兄弟节点分类id
|
|
|
|
if req.PrevChartInfoId > 0 {
|
|
if req.PrevChartInfoId > 0 {
|
|
prevChartInfo, err := data_manage.GetChartInfoById(req.PrevChartInfoId)
|
|
prevChartInfo, err := data_manage.GetChartInfoById(req.PrevChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -925,24 +808,18 @@ func (c *ChartInfoController) Move() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //如果是移动在两个兄弟节点之间
|
|
|
|
if req.NextChartInfoId > 0 {
|
|
if req.NextChartInfoId > 0 {
|
|
- //下一个兄弟节点
|
|
|
|
nextChartInfo, err := data_manage.GetChartInfoById(req.NextChartInfoId)
|
|
nextChartInfo, err := data_manage.GetChartInfoById(req.NextChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "移动失败"
|
|
br.Msg = "移动失败"
|
|
br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
|
|
br.ErrMsg = "获取下一个兄弟节点分类信息失败,Err:" + err.Error()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
|
|
|
|
if prevChartInfo.Sort == nextChartInfo.Sort || prevChartInfo.Sort == chartInfo.Sort {
|
|
if prevChartInfo.Sort == nextChartInfo.Sort || prevChartInfo.Sort == chartInfo.Sort {
|
|
- //变更兄弟节点的排序
|
|
|
|
updateSortStr := `sort + 2`
|
|
updateSortStr := `sort + 2`
|
|
_ = data_manage.UpdateChartInfoSortByClassifyId(prevChartInfo.ChartClassifyId, prevChartInfo.Sort, prevChartInfo.ChartInfoId, []int{chartInfo.Source}, updateSortStr)
|
|
_ = data_manage.UpdateChartInfoSortByClassifyId(prevChartInfo.ChartClassifyId, prevChartInfo.Sort, prevChartInfo.ChartInfoId, []int{chartInfo.Source}, updateSortStr)
|
|
} else {
|
|
} else {
|
|
- //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
|
|
|
|
if nextChartInfo.Sort-prevChartInfo.Sort == 1 {
|
|
if nextChartInfo.Sort-prevChartInfo.Sort == 1 {
|
|
- //变更兄弟节点的排序
|
|
|
|
updateSortStr := `sort + 1`
|
|
updateSortStr := `sort + 1`
|
|
_ = data_manage.UpdateChartInfoSortByClassifyId(prevChartInfo.ChartClassifyId, prevChartInfo.Sort, prevChartInfo.ChartInfoId, []int{chartInfo.Source}, updateSortStr)
|
|
_ = data_manage.UpdateChartInfoSortByClassifyId(prevChartInfo.ChartClassifyId, prevChartInfo.Sort, prevChartInfo.ChartInfoId, []int{chartInfo.Source}, updateSortStr)
|
|
}
|
|
}
|
|
@@ -968,7 +845,6 @@ func (c *ChartInfoController) Move() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
|
|
|
|
if firstClassify != nil && firstClassify.ChartClassifyId > 0 && firstClassify.Sort == 0 {
|
|
if firstClassify != nil && firstClassify.ChartClassifyId > 0 && firstClassify.Sort == 0 {
|
|
updateSortStr := ` sort + 1 `
|
|
updateSortStr := ` sort + 1 `
|
|
_ = data_manage.UpdateChartInfoSortByClassifyId(firstClassify.ChartClassifyId, 0, firstClassify.ChartInfoId-1, []int{chartInfo.Source}, updateSortStr)
|
|
_ = data_manage.UpdateChartInfoSortByClassifyId(firstClassify.ChartClassifyId, 0, firstClassify.ChartInfoId-1, []int{chartInfo.Source}, updateSortStr)
|
|
@@ -979,7 +855,6 @@ func (c *ChartInfoController) Move() {
|
|
updateCol = append(updateCol, "Sort", "ModifyTime")
|
|
updateCol = append(updateCol, "Sort", "ModifyTime")
|
|
}
|
|
}
|
|
|
|
|
|
- //更新
|
|
|
|
if len(updateCol) > 0 {
|
|
if len(updateCol) > 0 {
|
|
err = chartInfo.Update(updateCol)
|
|
err = chartInfo.Update(updateCol)
|
|
if err != nil {
|
|
if err != nil {
|
|
@@ -995,12 +870,9 @@ func (c *ChartInfoController) Move() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //添加es数据
|
|
|
|
go data.EsAddOrEditChartInfo(req.ChartInfoId)
|
|
go data.EsAddOrEditChartInfo(req.ChartInfoId)
|
|
- //修改my eta es数据
|
|
|
|
go data.EsAddOrEditMyChartInfoByChartInfoId(req.ChartInfoId)
|
|
go data.EsAddOrEditMyChartInfoByChartInfoId(req.ChartInfoId)
|
|
|
|
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartName = chartInfo.ChartName
|
|
chartLog.ChartName = chartInfo.ChartName
|
|
@@ -1021,12 +893,6 @@ func (c *ChartInfoController) Move() {
|
|
br.Msg = "移动成功"
|
|
br.Msg = "移动成功"
|
|
}
|
|
}
|
|
|
|
|
|
-// Refresh
|
|
|
|
-// @Title 图表刷新接口
|
|
|
|
-// @Description 图表刷新接口
|
|
|
|
-// @Param ChartInfoId query int true "图表id"
|
|
|
|
-// @Param UniqueCode query string true "唯一code"
|
|
|
|
-// @Success Ret=200 刷新成功
|
|
|
|
// @router /chart_info/refresh [get]
|
|
// @router /chart_info/refresh [get]
|
|
func (c *ChartInfoController) Refresh() {
|
|
func (c *ChartInfoController) Refresh() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -1075,7 +941,6 @@ func (c *ChartInfoController) Refresh() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取关联的指标信息
|
|
|
|
_, _, edbInfoIdList, err := cross_variety.GetXYEdbIdList(config.TagX, config.TagY, config.VarietyList)
|
|
_, _, edbInfoIdList, err := cross_variety.GetXYEdbIdList(config.TagX, config.TagY, config.VarietyList)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "刷新失败,获取指标信息失败"
|
|
br.Msg = "刷新失败,获取指标信息失败"
|
|
@@ -1083,13 +948,11 @@ func (c *ChartInfoController) Refresh() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 批量刷新
|
|
|
|
err, isAsync := data.EdbInfoRefreshAllFromBaseV3(edbInfoIdList, false, false, false)
|
|
err, isAsync := data.EdbInfoRefreshAllFromBaseV3(edbInfoIdList, false, false, false)
|
|
if err != nil {
|
|
if err != nil {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //清除图表缓存
|
|
|
|
{
|
|
{
|
|
key := utils.HZ_CHART_LIB_DETAIL + chartInfo.UniqueCode
|
|
key := utils.HZ_CHART_LIB_DETAIL + chartInfo.UniqueCode
|
|
_ = utils.Rc.Delete(key)
|
|
_ = utils.Rc.Delete(key)
|
|
@@ -1103,11 +966,6 @@ func (c *ChartInfoController) Refresh() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-// EnInfoEdit
|
|
|
|
-// @Title 编辑图表英文信息接口
|
|
|
|
-// @Description 编辑图表英文信息接口
|
|
|
|
-// @Param request body data_manage.EditChartEnInfoReq true "type json string"
|
|
|
|
-// @Success Ret=200 编辑成功
|
|
|
|
// @router /chart_info/en/edit [post]
|
|
// @router /chart_info/en/edit [post]
|
|
func (c *ChartInfoController) EnInfoEdit() {
|
|
func (c *ChartInfoController) EnInfoEdit() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -1139,7 +997,6 @@ func (c *ChartInfoController) EnInfoEdit() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //判断指标名称是否存在
|
|
|
|
chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
if utils.IsErrNoRow(err) {
|
|
if utils.IsErrNoRow(err) {
|
|
@@ -1152,26 +1009,6 @@ func (c *ChartInfoController) EnInfoEdit() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 校验名称是否有重复
|
|
|
|
- //{
|
|
|
|
- // var condition string
|
|
|
|
- // var pars []interface{}
|
|
|
|
- // condition += " AND chart_info_id <> ? AND chart_name_en = ? AND source = ?"
|
|
|
|
- // pars = append(pars, req.ChartInfoId, req.ChartNameEn, utils.CHART_SOURCE_CROSS_HEDGING)
|
|
|
|
- // existItem, err := data_manage.GetChartInfoByCondition(condition, pars)
|
|
|
|
- // if err != nil {
|
|
|
|
- // if !utils.IsErrNoRow(err) {
|
|
|
|
- // br.Msg = "判断英文图表名称是否存在失败"
|
|
|
|
- // br.ErrMsg = "判断英文图表名称是否存在失败,Err:" + err.Error()
|
|
|
|
- // return
|
|
|
|
- // }
|
|
|
|
- // }
|
|
|
|
- // if err == nil && existItem.ChartInfoId > 0 {
|
|
|
|
- // br.Msg = existItem.ChartName + ":" + req.ChartNameEn + "图表名称已存在"
|
|
|
|
- // return
|
|
|
|
- // }
|
|
|
|
- //}
|
|
|
|
-
|
|
|
|
chartItem.ChartNameEn = req.ChartNameEn
|
|
chartItem.ChartNameEn = req.ChartNameEn
|
|
chartItem.ModifyTime = time.Now().Local()
|
|
chartItem.ModifyTime = time.Now().Local()
|
|
if e := chartItem.Update([]string{"ChartNameEn", "ModifyTime"}); e != nil {
|
|
if e := chartItem.Update([]string{"ChartNameEn", "ModifyTime"}); e != nil {
|
|
@@ -1187,15 +1024,9 @@ func (c *ChartInfoController) EnInfoEdit() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //添加es数据
|
|
|
|
go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
|
|
go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
|
|
- //修改my eta es数据
|
|
|
|
go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
|
|
go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
|
|
|
|
|
|
- //指标 修改es信息
|
|
|
|
- //go data.AddOrEditEdbInfoToEs(edbInfo.EdbInfoId)
|
|
|
|
-
|
|
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartName = chartItem.ChartName
|
|
chartLog.ChartName = chartItem.ChartName
|
|
@@ -1210,7 +1041,6 @@ func (c *ChartInfoController) EnInfoEdit() {
|
|
chartLog.Method = c.Ctx.Input.URL()
|
|
chartLog.Method = c.Ctx.Input.URL()
|
|
go data_manage.AddChartInfoLog(chartLog)
|
|
go data_manage.AddChartInfoLog(chartLog)
|
|
}
|
|
}
|
|
- // 清除缓存
|
|
|
|
if utils.Re == nil && utils.Rc != nil {
|
|
if utils.Re == nil && utils.Rc != nil {
|
|
_ = utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
|
|
_ = utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
|
|
_ = utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
|
|
_ = utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
|
|
@@ -1222,11 +1052,6 @@ func (c *ChartInfoController) EnInfoEdit() {
|
|
br.IsAddLog = true
|
|
br.IsAddLog = true
|
|
}
|
|
}
|
|
|
|
|
|
-// DeleteChart
|
|
|
|
-// @Title 删除跨品种分析分类/图表
|
|
|
|
-// @Description 删除跨品种分析分类/图表接口
|
|
|
|
-// @Param request body data_manage.DeleteChartClassifyReq true "type json string"
|
|
|
|
-// @Success 200 Ret=200 删除成功
|
|
|
|
// @router /chart_info/delete [post]
|
|
// @router /chart_info/delete [post]
|
|
func (c *ChartInfoController) DeleteChart() {
|
|
func (c *ChartInfoController) DeleteChart() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -1258,7 +1083,6 @@ func (c *ChartInfoController) DeleteChart() {
|
|
}
|
|
}
|
|
|
|
|
|
resp := new(data_manage.AddChartInfoResp)
|
|
resp := new(data_manage.AddChartInfoResp)
|
|
- //删除图表
|
|
|
|
chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
chartInfo, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
if utils.IsErrNoRow(err) {
|
|
if utils.IsErrNoRow(err) {
|
|
@@ -1275,7 +1099,6 @@ func (c *ChartInfoController) DeleteChart() {
|
|
br.Msg = "图表已删除,请刷新页面"
|
|
br.Msg = "图表已删除,请刷新页面"
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- //图表操作权限
|
|
|
|
ok := data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
|
|
ok := data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
|
|
if !ok {
|
|
if !ok {
|
|
br.Msg = "没有该图表的操作权限"
|
|
br.Msg = "没有该图表的操作权限"
|
|
@@ -1285,7 +1108,6 @@ func (c *ChartInfoController) DeleteChart() {
|
|
|
|
|
|
myIds := make([]int, 0)
|
|
myIds := make([]int, 0)
|
|
{
|
|
{
|
|
- // 获取引用该图表的MyCharts, 用于ES删除
|
|
|
|
var myCond string
|
|
var myCond string
|
|
var myPars []interface{}
|
|
var myPars []interface{}
|
|
myCond += ` AND a.chart_info_id = ? `
|
|
myCond += ` AND a.chart_info_id = ? `
|
|
@@ -1300,17 +1122,14 @@ func (c *ChartInfoController) DeleteChart() {
|
|
myIds = append(myIds, m.MyChartId)
|
|
myIds = append(myIds, m.MyChartId)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- //删除图表及关联指标
|
|
|
|
err = data_manage.DeleteChartInfoAndData(chartInfo.ChartInfoId)
|
|
err = data_manage.DeleteChartInfoAndData(chartInfo.ChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
br.Msg = "删除失败"
|
|
br.Msg = "删除失败"
|
|
br.ErrMsg = "删除失败,Err:" + err.Error()
|
|
br.ErrMsg = "删除失败,Err:" + err.Error()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- //删除ES
|
|
|
|
{
|
|
{
|
|
go data.EsDeleteChartInfo(chartInfo.ChartInfoId)
|
|
go data.EsDeleteChartInfo(chartInfo.ChartInfoId)
|
|
- // 删除MY ETA 图表 es数据
|
|
|
|
go data.EsDeleteMyChartInfoByMyChartIds(myIds)
|
|
go data.EsDeleteMyChartInfoByMyChartIds(myIds)
|
|
}
|
|
}
|
|
|
|
|
|
@@ -1338,8 +1157,6 @@ func (c *ChartInfoController) DeleteChart() {
|
|
var tmpPars []interface{}
|
|
var tmpPars []interface{}
|
|
|
|
|
|
tmpCondition += " AND level=1 "
|
|
tmpCondition += " AND level=1 "
|
|
- //pars = append(pars, chartInfo.ChartClassifyId)
|
|
|
|
-
|
|
|
|
tmpCondition += " AND chart_classify_id>? ORDER BY chart_classify_id ASC LIMIT 1 "
|
|
tmpCondition += " AND chart_classify_id>? ORDER BY chart_classify_id ASC LIMIT 1 "
|
|
tmpPars = append(tmpPars, chartInfo.ChartClassifyId)
|
|
tmpPars = append(tmpPars, chartInfo.ChartClassifyId)
|
|
|
|
|
|
@@ -1362,7 +1179,6 @@ func (c *ChartInfoController) DeleteChart() {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartName = chartInfo.ChartName
|
|
chartLog.ChartName = chartInfo.ChartName
|
|
@@ -1385,13 +1201,6 @@ func (c *ChartInfoController) DeleteChart() {
|
|
br.IsAddLog = true
|
|
br.IsAddLog = true
|
|
}
|
|
}
|
|
|
|
|
|
-// SearchByEs
|
|
|
|
-// @Title 图表模糊搜索(从es获取)
|
|
|
|
-// @Description 图表模糊搜索(从es获取)
|
|
|
|
-// @Param Keyword query string true "图表名称"
|
|
|
|
-// @Param IsShowMe query bool true "是否只看我的,true、false"
|
|
|
|
-// @Param Source query int true "来源,3:拟合方程,4:滚动拟合方程,默认0:全部"
|
|
|
|
-// @Success 200 {object} data_manage.ChartInfo
|
|
|
|
// @router /chart_info/search_by_es [get]
|
|
// @router /chart_info/search_by_es [get]
|
|
func (c *ChartInfoController) SearchByEs() {
|
|
func (c *ChartInfoController) SearchByEs() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -1424,7 +1233,6 @@ func (c *ChartInfoController) SearchByEs() {
|
|
keyword = c.GetString("KeyWord")
|
|
keyword = c.GetString("KeyWord")
|
|
}
|
|
}
|
|
|
|
|
|
- //只看我的
|
|
|
|
isShowMe, _ := c.GetBool("IsShowMe")
|
|
isShowMe, _ := c.GetBool("IsShowMe")
|
|
showSysId := 0
|
|
showSysId := 0
|
|
if isShowMe {
|
|
if isShowMe {
|
|
@@ -1437,7 +1245,6 @@ func (c *ChartInfoController) SearchByEs() {
|
|
var total int64
|
|
var total int64
|
|
var err error
|
|
var err error
|
|
|
|
|
|
- // 获取当前账号的不可见指标
|
|
|
|
noPermissionChartIdList := make([]int, 0)
|
|
noPermissionChartIdList := make([]int, 0)
|
|
{
|
|
{
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
obj := data_manage.EdbInfoNoPermissionAdmin{}
|
|
@@ -1472,7 +1279,6 @@ func (c *ChartInfoController) SearchByEs() {
|
|
}
|
|
}
|
|
if chartInfoIds != "" {
|
|
if chartInfoIds != "" {
|
|
chartInfoIds = strings.Trim(chartInfoIds, ",")
|
|
chartInfoIds = strings.Trim(chartInfoIds, ",")
|
|
- //判断是否需要展示英文标识
|
|
|
|
edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
|
|
edbList, e := data_manage.GetChartEdbMappingListByChartInfoIds(chartInfoIds)
|
|
if e != nil {
|
|
if e != nil {
|
|
br.Msg = "获取失败"
|
|
br.Msg = "获取失败"
|
|
@@ -1487,16 +1293,13 @@ func (c *ChartInfoController) SearchByEs() {
|
|
for _, v := range searchList {
|
|
for _, v := range searchList {
|
|
tmp := new(data_manage.ChartInfoMore)
|
|
tmp := new(data_manage.ChartInfoMore)
|
|
tmp.ChartInfo = *v
|
|
tmp.ChartInfo = *v
|
|
- // 图表数据权限
|
|
|
|
tmp.HaveOperaAuth = true
|
|
tmp.HaveOperaAuth = true
|
|
- //判断是否需要展示英文标识
|
|
|
|
if _, ok := chartEdbMap[v.ChartInfoId]; ok {
|
|
if _, ok := chartEdbMap[v.ChartInfoId]; ok {
|
|
tmp.IsEnChart = data.CheckIsEnChart(v.ChartNameEn, []*data_manage.ChartEdbInfoMapping{}, v.Source, v.ChartType)
|
|
tmp.IsEnChart = data.CheckIsEnChart(v.ChartNameEn, []*data_manage.ChartEdbInfoMapping{}, v.Source, v.ChartType)
|
|
}
|
|
}
|
|
finalList = append(finalList, tmp)
|
|
finalList = append(finalList, tmp)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- //新增搜索词记录
|
|
|
|
{
|
|
{
|
|
searchKeyword := new(data_manage.SearchKeyword)
|
|
searchKeyword := new(data_manage.SearchKeyword)
|
|
searchKeyword.KeyWord = keyword
|
|
searchKeyword.KeyWord = keyword
|
|
@@ -1515,19 +1318,15 @@ func (c *ChartInfoController) SearchByEs() {
|
|
br.Data = resp
|
|
br.Data = resp
|
|
}
|
|
}
|
|
|
|
|
|
-// GetChartInfoDetailFromUniqueCode 根据编码获取图表详情
|
|
|
|
func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCache bool, sysUser *system.Admin) (resp *data_manage.ChartInfoDetailFromUniqueCodeResp, isOk bool, msg, errMsg string) {
|
|
func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCache bool, sysUser *system.Admin) (resp *data_manage.ChartInfoDetailFromUniqueCodeResp, isOk bool, msg, errMsg string) {
|
|
resp = new(data_manage.ChartInfoDetailFromUniqueCodeResp)
|
|
resp = new(data_manage.ChartInfoDetailFromUniqueCodeResp)
|
|
|
|
|
|
adminId := sysUser.AdminId
|
|
adminId := sysUser.AdminId
|
|
|
|
|
|
- // 指标数据map
|
|
|
|
edbClassifyPermissionMap := make(map[int]data_manage_permission.EdbClassifyPermission)
|
|
edbClassifyPermissionMap := make(map[int]data_manage_permission.EdbClassifyPermission)
|
|
defer func() {
|
|
defer func() {
|
|
if isOk {
|
|
if isOk {
|
|
- // 这里跟当前用户相关的信息重新查询写入resp, 不使用缓存中的
|
|
|
|
{
|
|
{
|
|
- //判断是否加入我的图库
|
|
|
|
var myChartCondition string
|
|
var myChartCondition string
|
|
var myChartPars []interface{}
|
|
var myChartPars []interface{}
|
|
myChartCondition += ` AND a.admin_id=? `
|
|
myChartCondition += ` AND a.admin_id=? `
|
|
@@ -1550,10 +1349,8 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
|
|
|
|
resp.ChartInfo.HaveOperaAuth = true
|
|
resp.ChartInfo.HaveOperaAuth = true
|
|
|
|
|
|
- // 指标权限
|
|
|
|
{
|
|
{
|
|
classifyMap := make(map[int]*data_manage.EdbClassify)
|
|
classifyMap := make(map[int]*data_manage.EdbClassify)
|
|
- // 分类
|
|
|
|
{
|
|
{
|
|
classifyIdList := make([]int, 0)
|
|
classifyIdList := make([]int, 0)
|
|
for _, v := range resp.EdbInfoList {
|
|
for _, v := range resp.EdbInfoList {
|
|
@@ -1569,7 +1366,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- // 指标
|
|
|
|
if len(edbClassifyPermissionMap) < 0 {
|
|
if len(edbClassifyPermissionMap) < 0 {
|
|
edbInfoIdList := make([]int, 0)
|
|
edbInfoIdList := make([]int, 0)
|
|
for _, v := range resp.EdbInfoList {
|
|
for _, v := range resp.EdbInfoList {
|
|
@@ -1589,7 +1385,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取所有有权限的指标和分类
|
|
|
|
permissionEdbIdList, permissionClassifyIdList, err := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUser.AdminId, 0, 0)
|
|
permissionEdbIdList, permissionClassifyIdList, err := data_manage_permission.GetUserEdbAndClassifyPermissionList(sysUser.AdminId, 0, 0)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "获取所有有权限的指标和分类失败,Err:" + err.Error()
|
|
errMsg = "获取所有有权限的指标和分类失败,Err:" + err.Error()
|
|
@@ -1597,7 +1392,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
|
|
|
|
for _, v := range resp.EdbInfoList {
|
|
for _, v := range resp.EdbInfoList {
|
|
- // 数据权限
|
|
|
|
edbItem, ok := edbClassifyPermissionMap[v.EdbInfoId]
|
|
edbItem, ok := edbClassifyPermissionMap[v.EdbInfoId]
|
|
if !ok {
|
|
if !ok {
|
|
continue
|
|
continue
|
|
@@ -1611,7 +1405,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
}()
|
|
}()
|
|
|
|
|
|
- //判断是否存在缓存,如果存在缓存,那么直接从缓存中获取
|
|
|
|
key := data.GetChartInfoDataKey(chartInfo.ChartInfoId)
|
|
key := data.GetChartInfoDataKey(chartInfo.ChartInfoId)
|
|
if utils.Re == nil && isCache {
|
|
if utils.Re == nil && isCache {
|
|
if utils.Re == nil && utils.Rc.IsExist(key) {
|
|
if utils.Re == nil && utils.Rc.IsExist(key) {
|
|
@@ -1627,7 +1420,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- // 获取主题样式
|
|
|
|
chartTheme, err := data.GetChartThemeConfig(chartInfo.ChartThemeId, utils.CHART_SOURCE_DEFAULT, 5)
|
|
chartTheme, err := data.GetChartThemeConfig(chartInfo.ChartThemeId, utils.CHART_SOURCE_DEFAULT, 5)
|
|
if err != nil {
|
|
if err != nil {
|
|
msg = "获取失败"
|
|
msg = "获取失败"
|
|
@@ -1651,14 +1443,12 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
errMsg = "解析跨品种分析配置失败,Err:" + err.Error()
|
|
errMsg = "解析跨品种分析配置失败,Err:" + err.Error()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
- // 获取图表x轴y轴
|
|
|
|
edbList, dataResp, err, msg, _ := cross_variety.GetChartData(0, config)
|
|
edbList, dataResp, err, msg, _ := cross_variety.GetChartData(0, config)
|
|
if err != nil {
|
|
if err != nil {
|
|
errMsg = "获取图表,指标信息失败,Err:" + err.Error()
|
|
errMsg = "获取图表,指标信息失败,Err:" + err.Error()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
if chartInfoId > 0 && chartInfo != nil {
|
|
if chartInfoId > 0 && chartInfo != nil {
|
|
- //判断是否加入我的图库
|
|
|
|
{
|
|
{
|
|
var myChartCondition string
|
|
var myChartCondition string
|
|
var myChartPars []interface{}
|
|
var myChartPars []interface{}
|
|
@@ -1681,14 +1471,7 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- //图表操作权限
|
|
|
|
chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
|
|
chartInfo.IsEdit = data.CheckOpChartPermission(sysUser, chartInfo.SysUserId, true)
|
|
- //判断是否需要展示英文标识
|
|
|
|
- //chartInfo.IsEnChart = data.CheckIsEnChart(chartInfo.ChartNameEn, edbList[0:1], chartInfo.Source, chartInfo.ChartType)
|
|
|
|
- //chartInfo.UnitEn = edbInfoMappingA.UnitEn
|
|
|
|
-
|
|
|
|
- //isSaveAs := true
|
|
|
|
- // 另存为
|
|
|
|
chartInfo.Button = data_manage.ChartViewButton{
|
|
chartInfo.Button = data_manage.ChartViewButton{
|
|
IsEdit: chartInfo.IsEdit,
|
|
IsEdit: chartInfo.IsEdit,
|
|
IsEnChart: chartInfo.IsEnChart,
|
|
IsEnChart: chartInfo.IsEnChart,
|
|
@@ -1697,7 +1480,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
IsSetName: chartInfo.IsSetName,
|
|
IsSetName: chartInfo.IsSetName,
|
|
}
|
|
}
|
|
|
|
|
|
- // 图表的指标来源
|
|
|
|
sourceNameList, sourceNameEnList := data.GetEdbSourceByEdbInfoIdList(edbList)
|
|
sourceNameList, sourceNameEnList := data.GetEdbSourceByEdbInfoIdList(edbList)
|
|
chartInfo.ChartSource = strings.Join(sourceNameList, ",")
|
|
chartInfo.ChartSource = strings.Join(sourceNameList, ",")
|
|
chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
|
|
chartInfo.ChartSourceEn = strings.Join(sourceNameEnList, ",")
|
|
@@ -1707,7 +1489,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
resp.EdbInfoList = edbList
|
|
resp.EdbInfoList = edbList
|
|
resp.Status = true
|
|
resp.Status = true
|
|
|
|
|
|
- // 遍历到校验map
|
|
|
|
for _, v := range edbList {
|
|
for _, v := range edbList {
|
|
edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
|
|
edbClassifyPermissionMap[v.EdbInfoId] = data_manage_permission.EdbClassifyPermission{
|
|
ClassifyId: v.ClassifyId,
|
|
ClassifyId: v.ClassifyId,
|
|
@@ -1716,7 +1497,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
- // 将数据加入缓存
|
|
|
|
if utils.Re == nil {
|
|
if utils.Re == nil {
|
|
d, _ := json.Marshal(resp)
|
|
d, _ := json.Marshal(resp)
|
|
_ = utils.Rc.Put(key, d, 2*time.Hour)
|
|
_ = utils.Rc.Put(key, d, 2*time.Hour)
|
|
@@ -1725,11 +1505,6 @@ func GetChartInfoDetailFromUniqueCode(chartInfo *data_manage.ChartInfoView, isCa
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
-// Save
|
|
|
|
-// @Title 保存图表
|
|
|
|
-// @Description 保存图表
|
|
|
|
-// @Param request body request.SaveChartReq true "type json string"
|
|
|
|
-// @Success Ret=200 保存成功
|
|
|
|
// @router /chart_info/save [post]
|
|
// @router /chart_info/save [post]
|
|
func (c *ChartInfoController) Save() {
|
|
func (c *ChartInfoController) Save() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -1772,7 +1547,6 @@ func (c *ChartInfoController) Save() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- // 更新图表上下限
|
|
|
|
chartItem.LeftMin = req.LeftMin
|
|
chartItem.LeftMin = req.LeftMin
|
|
chartItem.LeftMax = req.LeftMax
|
|
chartItem.LeftMax = req.LeftMax
|
|
chartItem.XMin = req.XMin
|
|
chartItem.XMin = req.XMin
|
|
@@ -1788,7 +1562,6 @@ func (c *ChartInfoController) Save() {
|
|
resp.ChartInfoId = chartItem.ChartInfoId
|
|
resp.ChartInfoId = chartItem.ChartInfoId
|
|
resp.UniqueCode = chartItem.UniqueCode
|
|
resp.UniqueCode = chartItem.UniqueCode
|
|
|
|
|
|
- // 新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartName = chartItem.ChartName
|
|
chartLog.ChartName = chartItem.ChartName
|
|
@@ -1811,11 +1584,6 @@ func (c *ChartInfoController) Save() {
|
|
br.IsAddLog = true
|
|
br.IsAddLog = true
|
|
}
|
|
}
|
|
|
|
|
|
-// BaseInfoEdit
|
|
|
|
-// @Title 编辑图表基础信息接口
|
|
|
|
-// @Description 编辑图表基础信息接口
|
|
|
|
-// @Param request body data_manage.EditChartBaseInfoReq true "type json string"
|
|
|
|
-// @Success Ret=200 编辑成功
|
|
|
|
// @router /chart_info/base/edit [post]
|
|
// @router /chart_info/base/edit [post]
|
|
func (c *ChartInfoController) BaseInfoEdit() {
|
|
func (c *ChartInfoController) BaseInfoEdit() {
|
|
br := new(models.BaseResponse).Init()
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -1847,7 +1615,6 @@ func (c *ChartInfoController) BaseInfoEdit() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //判断指标名称是否存在
|
|
|
|
chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
chartItem, err := data_manage.GetChartInfoById(req.ChartInfoId)
|
|
if err != nil {
|
|
if err != nil {
|
|
if utils.IsErrNoRow(err) {
|
|
if utils.IsErrNoRow(err) {
|
|
@@ -1867,15 +1634,8 @@ func (c *ChartInfoController) BaseInfoEdit() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
- //添加es数据
|
|
|
|
go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
|
|
go data.EsAddOrEditChartInfo(chartItem.ChartInfoId)
|
|
- //修改my eta es数据
|
|
|
|
go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
|
|
go data.EsAddOrEditMyChartInfoByChartInfoId(chartItem.ChartInfoId)
|
|
-
|
|
|
|
- //指标 修改es信息
|
|
|
|
- //go data.AddOrEditEdbInfoToEs(edbInfo.EdbInfoId)
|
|
|
|
-
|
|
|
|
- //新增操作日志
|
|
|
|
{
|
|
{
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog := new(data_manage.ChartInfoLog)
|
|
chartLog.ChartName = chartItem.ChartName
|
|
chartLog.ChartName = chartItem.ChartName
|
|
@@ -1891,7 +1651,6 @@ func (c *ChartInfoController) BaseInfoEdit() {
|
|
go data_manage.AddChartInfoLog(chartLog)
|
|
go data_manage.AddChartInfoLog(chartLog)
|
|
}
|
|
}
|
|
|
|
|
|
- // 清除缓存
|
|
|
|
if utils.Re == nil && utils.Rc != nil {
|
|
if utils.Re == nil && utils.Rc != nil {
|
|
_ = utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
|
|
_ = utils.Rc.Delete(utils.HZ_CHART_LIB_DETAIL + chartItem.UniqueCode) //图表分享链接缓存
|
|
_ = utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
|
|
_ = utils.Rc.Delete(data.GetChartInfoDataKey(req.ChartInfoId))
|