package data_manage import ( "encoding/json" "eta_gn/eta_api/models" "eta_gn/eta_api/models/data_manage" "eta_gn/eta_api/models/data_manage/request" "eta_gn/eta_api/models/data_manage/response" "eta_gn/eta_api/models/system" "eta_gn/eta_api/services/data" correlationServ "eta_gn/eta_api/services/data/correlation" "eta_gn/eta_api/utils" "fmt" "math" "strconv" "strings" "time" ) //多图配置 // MultipleGraphConfigSave // @Title 保存配置接口 // @Description 保存配置接口 // @Param request body request.SaveMultipleGraphConfigReq true "type json string" // @Success Ret=200 返回图表id // @router /multiple_graph/config/save [post] func (this *ChartInfoController) MultipleGraphConfigSave() { 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 request.SaveMultipleGraphConfigReq err := json.Unmarshal(this.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } if req.EdbInfoIdA <= 0 { if this.Lang == utils.EnLangVersion { br.Msg = "Indicator A not selected" } else { br.Msg = "指标A未选择" } br.IsSendEmail = false return } _, err = data_manage.GetEdbInfoById(req.EdbInfoIdA) if err != nil { br.Msg = "指标A异常" br.ErrMsg = "指标A异常,err:" + err.Error() if utils.IsErrNoRow(err) { br.Msg = `指标A不存在` br.IsSendEmail = false } return } if req.EdbInfoIdB <= 0 { if this.Lang == utils.EnLangVersion { br.Msg = "Indicator B not selected" } else { br.Msg = "指标B未选择" } br.IsSendEmail = false return } _, err = data_manage.GetEdbInfoById(req.EdbInfoIdB) if err != nil { br.Msg = "指标B异常" br.ErrMsg = "指标B异常,err:" + err.Error() if utils.IsErrNoRow(err) { br.Msg = `指标B不存在` br.IsSendEmail = false } return } curveStrByte, err := json.Marshal(req.Curve) if err != nil { br.Msg = `曲线图配置异常` br.ErrMsg = `曲线图配置异常,ERR:` + err.Error() return } if req.Correlation.LeadValue <= 0 { br.Msg = `分析周期不允许设置为负数或0` br.IsSendEmail = false return } correlationStrByte, err := json.Marshal(req.Correlation) if err != nil { br.Msg = `相关性配置异常` br.ErrMsg = `相关性配置异常,ERR:` + err.Error() return } rollingCorrelationStrByte, err := json.Marshal(req.RollingCorrelation) if err != nil { br.Msg = `滚动相关性配置异常` br.ErrMsg = `滚动相关性配置异常,ERR:` + err.Error() return } var multipleGraphConfig *data_manage.MultipleGraphConfig if req.MultipleGraphConfigId > 0 { multipleGraphConfig, err = data_manage.GetMultipleGraphConfigById(req.MultipleGraphConfigId) if err != nil { br.Msg = `不存在该配置` br.ErrMsg = `不存在该配置` return } multipleGraphConfig.EdbInfoIdA = req.EdbInfoIdA multipleGraphConfig.EdbInfoIdB = req.EdbInfoIdB multipleGraphConfig.Curve = string(curveStrByte) multipleGraphConfig.Correlation = string(correlationStrByte) multipleGraphConfig.RollingCorrelation = string(rollingCorrelationStrByte) multipleGraphConfig.ModifyTime = time.Now() err = multipleGraphConfig.Update([]string{"EdbInfoIdA", "EdbInfoIdB", "Curve", "Correlation", "RollingCorrelation", "ModifyTime"}) } else { multipleGraphConfig = &data_manage.MultipleGraphConfig{ //MultipleGraphConfigId: 0, EdbInfoIdA: req.EdbInfoIdA, EdbInfoIdB: req.EdbInfoIdB, Curve: string(curveStrByte), Correlation: string(correlationStrByte), RollingCorrelation: string(rollingCorrelationStrByte), SysUserId: this.SysUser.AdminId, SysUserRealName: this.SysUser.RealName, ModifyTime: time.Now(), CreateTime: time.Now(), } err = data_manage.AddMultipleGraphConfig(multipleGraphConfig) } if err != nil { br.Msg = `保存失败` br.ErrMsg = `保存失败，Err:` + err.Error() return } br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = multipleGraphConfig br.IsAddLog = true } // MultipleGraphPreview // @Title 批量添加图表的预览接口 // @Description 批量添加图表的预览接口 // @Param request body request.SaveMultipleGraphConfigReq true "type json string" // @Success Ret=200 返回图表id // @router /multiple_graph/preview [post] func (this *ChartInfoController) MultipleGraphPreview() { 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 request.SaveMultipleGraphConfigReq err := json.Unmarshal(this.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{req.EdbInfoIdA, req.EdbInfoIdB}) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } maxYear := 0 var edbInfoMappingA, edbInfoMappingB *data_manage.ChartEdbInfoMapping for _, v := range mappingList { if v.EdbInfoId == req.EdbInfoIdA { edbInfoMappingA = v } if v.EdbInfoId == req.EdbInfoIdB { edbInfoMappingB = v } if v.LatestDate != "" { latestDateT, _ := time.Parse(utils.FormatDate, v.LatestDate) maxYear = latestDateT.Year() } } if edbInfoMappingA == nil { br.Msg = "指标A不存在" br.IsSendEmail = false return } if edbInfoMappingB == nil { br.Msg = "指标B不存在" br.IsSendEmail = false return } resp := response.PreviewMultipleGraphConfigResp{} chartInfo := new(data_manage.ChartInfoView) chartInfo.Calendar = `公历` chartInfo.ChartName = edbInfoMappingA.EdbName + "与" + edbInfoMappingB.EdbName // 曲线图表信息 { tmpChartInfo := *chartInfo curveConf := req.Curve edbInfoType := 0 if curveConf.EdbInfoType { edbInfoType = 1 } for _, v := range mappingList { v.EdbInfoType = 1 v.IsOrder = false if v.EdbInfoId == req.EdbInfoIdB { v.LeadValue = curveConf.LeadValue v.LeadUnit = curveConf.LeadUnit v.EdbInfoType = edbInfoType v.IsOrder = curveConf.IsOrder } } startDate, endDate := utils.GetDateByDateTypeV2(curveConf.DateType, curveConf.StartDate, curveConf.EndDate, curveConf.StartYear, maxYear) // 获取图表中的指标数据 edbList, _, _, _, err, errMsg := data.GetChartEdbData(tmpChartInfo.ChartInfoId, tmpChartInfo.ChartType, tmpChartInfo.Calendar, startDate, endDate, mappingList, tmpChartInfo.ExtraConfig, tmpChartInfo.SeasonExtraConfig) if err != nil { br.Msg = "获取失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } warnEdbList := make([]string, 0) tmpEdbList := make([]data_manage.ChartEdbInfoMapping, 0) for _, v := range edbList { if v.IsNullData { warnEdbList = append(warnEdbList, v.EdbName+"("+v.EdbCode+")") } chartEdbInfoMapping := *v chartEdbInfoMapping.IsOrder = false if v.EdbInfoId == req.EdbInfoIdA { chartEdbInfoMapping.IsAxis = 1 chartEdbInfoMapping.MinData = curveConf.LeftMin chartEdbInfoMapping.MaxData = curveConf.LeftMax chartEdbInfoMapping.ChartColor = `#00F` chartEdbInfoMapping.LeadValue = curveConf.LeadValue chartEdbInfoMapping.LeadUnit = curveConf.LeadUnit chartEdbInfoMapping.ChartWidth = 3 chartEdbInfoMapping.EdbInfoType = edbInfoType } else { chartEdbInfoMapping.IsAxis = 0 chartEdbInfoMapping.MinData = curveConf.RightMin chartEdbInfoMapping.MaxData = curveConf.RightMax chartEdbInfoMapping.ChartColor = `#F00` chartEdbInfoMapping.LeadValue = curveConf.LeadValue chartEdbInfoMapping.LeadUnit = curveConf.LeadUnit chartEdbInfoMapping.ChartWidth = 1 chartEdbInfoMapping.IsOrder = curveConf.IsOrder chartEdbInfoMapping.EdbInfoType = edbInfoType } tmpEdbList = append(tmpEdbList, chartEdbInfoMapping) } if len(warnEdbList) > 0 { tmpChartInfo.WarnMsg = `图表引用指标异常，异常指标：` + strings.Join(warnEdbList, "，") } tmpChartInfo.Source = utils.CHART_SOURCE_DEFAULT tmpChartInfo.DateType = curveConf.DateType tmpChartInfo.StartDate = startDate tmpChartInfo.EndDate = endDate tmpChartInfo.ChartType = utils.CHART_TYPE_CURVE resp.CurveData = response.CurveResp{ ChartInfo: tmpChartInfo, EdbInfoList: tmpEdbList, } } // 相关性图表信息 { correlationConf := req.Correlation // 配置了数据才有返回 if correlationConf.LeadValue > 0 { tmpChartInfo := *chartInfo moveUnitDays, ok := utils.FrequencyDaysMap[correlationConf.CalculateUnit] if !ok { br.Msg = "错误的分析周期" br.IsSendEmail = false return } startDate := time.Now().AddDate(0, 0, -correlationConf.CalculateValue*moveUnitDays).Format(utils.FormatDate) endDate := time.Now().Format(utils.FormatDate) xEdbIdValue, yDataList, e := correlationServ.GetChartDataByEdbInfo(edbInfoMappingA, edbInfoMappingB, correlationConf.LeadValue, correlationConf.LeadUnit, startDate, endDate, "") if e != nil { br.Msg = "获取失败" br.ErrMsg = "获取相关性图表, 图表计算值失败, Err:" + e.Error() return } tmpChartInfo.ChartName += fmt.Sprint(`(`, correlationConf.CalculateValue, correlationConf.CalculateUnit, `)`) tmpChartInfo.Source = utils.CHART_SOURCE_CORRELATION resp.CorrelationData = response.CorrelationResp{ ChartInfo: tmpChartInfo, EdbInfoList: mappingList, XEdbIdValue: xEdbIdValue, YDataList: yDataList, CorrelationChartInfo: data_manage.CorrelationInfo{ LeadValue: correlationConf.LeadValue, LeadUnit: correlationConf.LeadUnit, StartDate: startDate, EndDate: endDate, EdbInfoIdFirst: edbInfoMappingA.EdbInfoId, EdbInfoIdSecond: edbInfoMappingB.EdbInfoId, }, } } } // 滚动相关性图表信息 { correlationConf := req.Correlation rollingCorrelationConfList := req.RollingCorrelation // 配置了数据才有返回 if correlationConf.LeadValue > 0 { //moveUnitDays, ok := utils.FrequencyDaysMap[correlationConf.CalculateUnit] //if !ok { // br.Msg = "错误的分析周期" // br.IsSendEmail = false // return //} //startDate := time.Now().AddDate(0, 0, -correlationConf.CalculateValue*moveUnitDays).Format(utils.FormatDate) //endDate := time.Now().Format(utils.FormatDate) // 数据的开始/结束日期 curveConf := req.Curve startDate, endDate := utils.GetDateByDateTypeV2(curveConf.DateType, curveConf.StartDate, curveConf.EndDate, curveConf.StartYear, maxYear) rollingCorrelationData := make([]interface{}, 0) for _, rollingCorrelationConf := range rollingCorrelationConfList { if rollingCorrelationConf.CalculateValue > 0 && rollingCorrelationConf.CalculateUnit != `` { tmpChartInfo := *chartInfo tmpChartInfo.Source = utils.CHART_SOURCE_ROLLING_CORRELATION // ”指标A名称“+”指标B名称“+"滚动相关性"+”滚动相关性计算窗口值“+”滚动相关性计算窗口单位“ // 若滚动相关性的计算周期为30天 // 1、B即不领先也不滞后时：“指标A名称”与“指标B名称"30天滚动相关性; // 2、B有领先时：“指标A名称”与“指标B名称(领先15天)"30天滚动相关性； // 3、B滞后时：“指标A名称”与“指标B名称(滞后15天)"30天滚动相关性 if rollingCorrelationConf.LeadValue == 0 { tmpChartInfo.ChartName = fmt.Sprintf(`%s与%s%d%s滚动相关性`, edbInfoMappingA.EdbName, edbInfoMappingB.EdbName, rollingCorrelationConf.CalculateValue, rollingCorrelationConf.CalculateUnit) } else if rollingCorrelationConf.LeadValue < 0 { tmpChartInfo.ChartName = fmt.Sprintf(`%s与%s(滞后%d%s)%d%s滚动相关性`, edbInfoMappingA.EdbName, edbInfoMappingB.EdbName, int(math.Abs(float64(rollingCorrelationConf.LeadValue))), rollingCorrelationConf.LeadUnit, rollingCorrelationConf.CalculateValue, rollingCorrelationConf.CalculateUnit) } else { tmpChartInfo.ChartName = fmt.Sprintf(`%s与%s(领先%d%s)%d%s滚动相关性`, edbInfoMappingA.EdbName, edbInfoMappingB.EdbName, int(math.Abs(float64(rollingCorrelationConf.LeadValue))), rollingCorrelationConf.LeadUnit, rollingCorrelationConf.CalculateValue, rollingCorrelationConf.CalculateUnit) } dataResp, e := correlationServ.GetRollingCorrelationChartDataByEdbInfo(edbInfoMappingA, edbInfoMappingB, rollingCorrelationConf.LeadValue, rollingCorrelationConf.LeadUnit, rollingCorrelationConf.CalculateValue, rollingCorrelationConf.CalculateUnit, startDate, endDate, tmpChartInfo.ChartName, tmpChartInfo.ChartNameEn) if e != nil { br.Msg = "获取失败" br.ErrMsg = "获取滚动相关性图表, 图表计算值失败, Err:" + e.Error() return } rollingCorrelationData = append(rollingCorrelationData, response.RollingCorrelationResp{ ChartInfo: tmpChartInfo, EdbInfoList: mappingList, DataResp: dataResp, CorrelationChartInfo: data_manage.CorrelationInfo{ LeadValue: rollingCorrelationConf.LeadValue, LeadUnit: rollingCorrelationConf.LeadUnit, CalculateValue: rollingCorrelationConf.CalculateValue, CalculateUnit: rollingCorrelationConf.CalculateUnit, StartDate: startDate, EndDate: endDate, EdbInfoIdFirst: edbInfoMappingA.EdbInfoId, EdbInfoIdSecond: edbInfoMappingB.EdbInfoId, }, }) } else { rollingCorrelationData = append(rollingCorrelationData, nil) } } resp.RollingCorrelationData = rollingCorrelationData } else { resp.RollingCorrelationData = []interface{}{nil, nil} } } br.Ret = 200 br.Success = true br.Msg = "获取成功" br.Data = resp } // MultipleGraphPreviewCurve // @Title 批量添加图表的预览曲线图接口（只返回曲线图的数据） // @Description 批量添加图表的预览曲线图接口 // @Param request body request.SaveMultipleGraphConfigReq true "type json string" // @Success Ret=200 返回图表id // @router /multiple_graph/preview_cure [post] func (this *ChartInfoController) MultipleGraphPreviewCurve() { 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 request.SaveMultipleGraphConfigReq err := json.Unmarshal(this.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{req.EdbInfoIdA, req.EdbInfoIdB}) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } var edbInfoMappingA, edbInfoMappingB *data_manage.ChartEdbInfoMapping for _, v := range mappingList { if v.EdbInfoId == req.EdbInfoIdA { edbInfoMappingA = v } if v.EdbInfoId == req.EdbInfoIdB { edbInfoMappingB = v } } if edbInfoMappingA == nil { br.Msg = "指标A不存在" br.IsSendEmail = false return } if edbInfoMappingB == nil { br.Msg = "指标B不存在" br.IsSendEmail = false return } resp := response.PreviewMultipleGraphConfigResp{} chartInfo := new(data_manage.ChartInfoView) chartInfo.Calendar = `公历` chartInfo.ChartName = edbInfoMappingA.EdbName + "与" + edbInfoMappingB.EdbName // 曲线图表信息 { tmpChartInfo := *chartInfo curveConf := req.Curve startDate := curveConf.StartDate endDate := curveConf.EndDate switch curveConf.DateType { case 1: startDate = "2000-01-01" case 2: startDate = "2010-01-01" case 3: startDate = "2015-01-01" case 4: //startDate = strconv.Itoa(time.Now().Year()) + "-01-01" startDate = "2021-01-01" case 5: startDate = startDate + "-01" endDate = endDate + "-01" case 6: startDate = startDate + "-01" case 7: startDate = "2018-01-01" case 8: startDate = "2019-01-01" case 9: startDate = "2020-01-01" case 11: startDate = "2022-01-01" } edbInfoType := 0 if curveConf.EdbInfoType { edbInfoType = 1 } for _, v := range mappingList { v.EdbInfoType = 1 v.IsOrder = false if v.EdbInfoId == req.EdbInfoIdB { v.LeadValue = curveConf.LeadValue v.LeadUnit = curveConf.LeadUnit v.EdbInfoType = edbInfoType v.IsOrder = curveConf.IsOrder } } // 获取图表中的指标数据 edbList, _, _, _, err, errMsg := data.GetChartEdbData(tmpChartInfo.ChartInfoId, tmpChartInfo.ChartType, tmpChartInfo.Calendar, startDate, endDate, mappingList, tmpChartInfo.ExtraConfig, tmpChartInfo.SeasonExtraConfig) if err != nil { br.Msg = "获取失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } warnEdbList := make([]string, 0) tmpEdbList := make([]data_manage.ChartEdbInfoMapping, 0) for _, v := range edbList { if v.IsNullData { warnEdbList = append(warnEdbList, v.EdbName+"("+v.EdbCode+")") } chartEdbInfoMapping := *v chartEdbInfoMapping.IsOrder = false chartEdbInfoMapping.EdbInfoType = 1 if v.EdbInfoId == req.EdbInfoIdA { chartEdbInfoMapping.IsAxis = 1 chartEdbInfoMapping.MinData = curveConf.LeftMin chartEdbInfoMapping.MaxData = curveConf.LeftMax chartEdbInfoMapping.ChartColor = `#00F` //chartEdbInfoMapping.LeadValue = curveConf.LeadValue //chartEdbInfoMapping.LeadUnit = curveConf.LeadUnit chartEdbInfoMapping.ChartWidth = 3 } else { chartEdbInfoMapping.IsAxis = 0 chartEdbInfoMapping.MinData = curveConf.RightMin chartEdbInfoMapping.MaxData = curveConf.RightMax chartEdbInfoMapping.ChartColor = `#F00` chartEdbInfoMapping.LeadValue = curveConf.LeadValue chartEdbInfoMapping.LeadUnit = curveConf.LeadUnit chartEdbInfoMapping.ChartWidth = 1 chartEdbInfoMapping.IsOrder = curveConf.IsOrder chartEdbInfoMapping.EdbInfoType = edbInfoType } tmpEdbList = append(tmpEdbList, chartEdbInfoMapping) } if len(warnEdbList) > 0 { tmpChartInfo.WarnMsg = `图表引用指标异常，异常指标：` + strings.Join(warnEdbList, "，") } tmpChartInfo.Source = utils.CHART_SOURCE_DEFAULT tmpChartInfo.DateType = curveConf.DateType tmpChartInfo.StartDate = startDate tmpChartInfo.EndDate = endDate tmpChartInfo.ChartType = utils.CHART_TYPE_CURVE resp.CurveData = response.CurveResp{ ChartInfo: tmpChartInfo, EdbInfoList: tmpEdbList, } } br.Ret = 200 br.Success = true br.Msg = "获取成功" br.Data = resp } // MultipleGraphConfigSaveChart // @Title 保存图表接口 // @Description 保存图表接口 // @Param request body request.SaveMultipleGraphChartReq true "type json string" // @Success Ret=200 返回图表id // @router /multiple_graph/chart/save [post] func (this *ChartInfoController) MultipleGraphConfigSaveChart() { 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 request.SaveMultipleGraphChartReq err := json.Unmarshal(this.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } cacheKey := "CACHE_CHART_INFO_ADD_" + strconv.Itoa(sysUser.AdminId) if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) { br.Msg = "系统处理中，请稍后重试！" br.ErrMsg = "系统处理中，请稍后重试！" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody) return } defer func() { _ = utils.Rc.Delete(cacheKey) }() if req.MultipleGraphConfigId <= 0 { br.Msg = "配置未保存" br.IsSendEmail = false return } if req.IsSaveAs { CopyMultipleGraphConfigSaveChart(req, this, br, sysUser) return } mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{req.EdbInfoIdA, req.EdbInfoIdB}) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } var edbInfoMappingA, edbInfoMappingB *data_manage.ChartEdbInfoMapping for _, v := range mappingList { if v.EdbInfoId == req.EdbInfoIdA { edbInfoMappingA = v } if v.EdbInfoId == req.EdbInfoIdB { edbInfoMappingB = v } } if edbInfoMappingA == nil { br.Msg = "指标A不存在" br.IsSendEmail = false return } if edbInfoMappingB == nil { br.Msg = "指标B不存在" br.IsSendEmail = false return } multipleGraphConfigChartMapping, err := data_manage.GetMultipleGraphConfigChartMappingByIdAndSource(req.MultipleGraphConfigId, req.Source) if err != nil && !utils.IsErrNoRow(err) { br.Msg = `保存失败` br.ErrMsg = "获取配置与图表的关联关系失败，ERR:" + err.Error() return } err = nil var isAdd bool var chartInfoId int if multipleGraphConfigChartMapping == nil || multipleGraphConfigChartMapping.Id <= 0 { isAdd = true } else { chartInfo, err := data_manage.GetChartInfoById(multipleGraphConfigChartMapping.ChartInfoId) if err != nil && !utils.IsErrNoRow(err) { br.Msg = `保存失败` br.ErrMsg = "获取图表信息失败，ERR:" + err.Error() return } // 说明图还在，没有被删除 if chartInfo != nil && chartInfo.ChartInfoId > 0 { chartInfoId = multipleGraphConfigChartMapping.ChartInfoId req.ChartName = chartInfo.ChartName req.ClassifyId = chartInfo.ChartClassifyId } } var chartInfo *data_manage.ChartInfo var errMsg string isSendEmail := true switch req.Source { case 1: // 曲线图 curveConf := req.Curve edbInfoType := 1 //1:标准指标,0:领先指标 if !curveConf.EdbInfoType { edbInfoType = 0 } chartSaveItemList := []*data_manage.ChartSaveItem{ { EdbInfoId: edbInfoMappingA.EdbInfoId, MaxData: curveConf.LeftMax, MinData: curveConf.LeftMin, IsOrder: false, IsAxis: 1, EdbInfoType: 1, //LeadValue: curveConf.LeadValue, //LeadUnit: curveConf.LeadUnit, ChartStyle: "spline", ChartColor: `#00F`, PredictChartColor: "", ChartWidth: 3, Source: utils.CHART_SOURCE_DEFAULT, }, { EdbInfoId: edbInfoMappingB.EdbInfoId, MaxData: curveConf.RightMax, MinData: curveConf.RightMin, IsOrder: curveConf.IsOrder, IsAxis: 0, EdbInfoType: edbInfoType, LeadValue: curveConf.LeadValue, LeadUnit: curveConf.LeadUnit, ChartStyle: "spline", ChartColor: `#F00`, PredictChartColor: "", ChartWidth: 1, Source: utils.CHART_SOURCE_DEFAULT, }, } if chartInfoId <= 0 { addChartReq := data_manage.AddChartInfoReq{ ChartEdbInfoList: chartSaveItemList, ChartClassifyId: req.ClassifyId, ChartName: req.ChartName, ChartType: utils.CHART_TYPE_CURVE, DateType: curveConf.DateType, StartDate: curveConf.StartDate, EndDate: curveConf.EndDate, StartYear: curveConf.StartYear, Calendar: "公历", LeftMin: fmt.Sprint(curveConf.LeftMin), LeftMax: fmt.Sprint(curveConf.LeftMax), RightMin: fmt.Sprint(curveConf.RightMin), RightMax: fmt.Sprint(curveConf.RightMax), Right2Min: fmt.Sprint(curveConf.Right2Min), Right2Max: fmt.Sprint(curveConf.Right2Max), } chartInfo, err, errMsg, isSendEmail = data.AddChartInfo(addChartReq, sysUser.AdminId, sysUser.RealName, this.Lang) } else { editChartReq := data_manage.EditChartInfoReq{ ChartInfoId: multipleGraphConfigChartMapping.ChartInfoId, ChartName: req.ChartName, ChartClassifyId: req.ClassifyId, ChartEdbInfoList: chartSaveItemList, ChartType: utils.CHART_TYPE_CURVE, DateType: curveConf.DateType, StartDate: curveConf.StartDate, EndDate: curveConf.EndDate, StartYear: curveConf.StartYear, Calendar: "公历", LeftMin: fmt.Sprint(curveConf.LeftMin), LeftMax: fmt.Sprint(curveConf.LeftMax), RightMin: fmt.Sprint(curveConf.RightMin), RightMax: fmt.Sprint(curveConf.RightMax), Right2Min: fmt.Sprint(curveConf.Right2Min), Right2Max: fmt.Sprint(curveConf.Right2Max), } chartInfo, err, errMsg, isSendEmail = data.EditChartInfo(editChartReq, sysUser, this.Lang) if err != nil { br.Msg = "保存失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = err.Error() br.IsSendEmail = isSendEmail return } } case 2, 3, 4: // 相关性图（滚动相关性） correlationConf := req.Correlation // 配置了数据才有返回 if correlationConf.LeadValue > 0 { leadValue := correlationConf.LeadValue leadUnit := correlationConf.LeadUnit baseCalculateValue := correlationConf.CalculateValue baseCalculateUnit := correlationConf.CalculateUnit calculateValue := baseCalculateValue calculateUnit := baseCalculateUnit chartSource := utils.CHART_SOURCE_CORRELATION // 默认是相关性图 moveUnitDays, ok := utils.FrequencyDaysMap[calculateUnit] if !ok { br.Msg = "错误的分析周期" br.IsSendEmail = false return } startDate := time.Now().AddDate(0, 0, -correlationConf.CalculateValue*moveUnitDays).Format(utils.FormatDate) endDate := time.Now().Format(utils.FormatDate) // 日期类型 var dateType int if req.Source != 2 { chartSource = utils.CHART_SOURCE_ROLLING_CORRELATION var rollingCorrelation data_manage.RollingCorrelationConfig if req.Source == 3 { rollingCorrelation = req.RollingCorrelation[0] } else { rollingCorrelation = req.RollingCorrelation[1] } leadValue = rollingCorrelation.LeadValue leadUnit = rollingCorrelation.LeadUnit calculateValue = rollingCorrelation.CalculateValue calculateUnit = rollingCorrelation.CalculateUnit // 开始日期，结束日期 dateType = req.Curve.DateType startDate, endDate = utils.GetDateByDateType(req.Curve.DateType, req.Curve.StartDate, req.Curve.EndDate) } // 图例, 图表来源 var sourceFrom, extraConfig string if req.CorrelationExtraConfig != nil { b, e := json.Marshal(req.CorrelationExtraConfig) if e != nil { br.Msg = "保存失败" br.ErrMsg = fmt.Sprintf("相关性图表图例信息JSON格式化失败, Err: %v", e) return } extraConfig = string(b) } if req.SourcesFrom != nil { b, e := json.Marshal(req.SourcesFrom) if e != nil { br.Msg = "保存失败" br.ErrMsg = fmt.Sprintf("图表来源JSON格式化失败, Err: %v", e) return } sourceFrom = string(b) } correlationChartInfoReq := data_manage.CorrelationChartInfoReq{ LeadValue: leadValue, LeadUnit: leadUnit, CalculateValue: calculateValue, CalculateUnit: calculateUnit, BaseCalculateValue: baseCalculateValue, BaseCalculateUnit: baseCalculateUnit, DateType: dateType, StartDate: startDate, EndDate: endDate, EdbInfoIdList: []data_manage.CorrelationChartInfoEdbItemReq{ { EdbInfoId: edbInfoMappingA.EdbInfoId, Name: "", NameEn: "", }, { EdbInfoId: edbInfoMappingB.EdbInfoId, Name: "", NameEn: "", }, }, } if chartInfoId <= 0 { addChartReq := data_manage.AddChartInfoReq{ ChartClassifyId: req.ClassifyId, ChartName: req.ChartName, ChartType: utils.CHART_TYPE_CURVE, Calendar: "公历", CorrelationChartInfo: correlationChartInfoReq, ExtraConfig: extraConfig, SourcesFrom: sourceFrom, } chartInfo, err, errMsg, isSendEmail = correlationServ.AddChartInfo(addChartReq, chartSource, sysUser, this.Lang) } else { editChartReq := data_manage.EditChartInfoReq{ ChartInfoId: multipleGraphConfigChartMapping.ChartInfoId, ChartName: req.ChartName, ChartClassifyId: req.ClassifyId, ChartType: utils.CHART_TYPE_CURVE, Calendar: "公历", CorrelationChartInfo: correlationChartInfoReq, ExtraConfig: extraConfig, SourcesFrom: sourceFrom, } chartInfo, err, errMsg, isSendEmail = correlationServ.EditChartInfo(editChartReq, sysUser, this.Lang) if err != nil { br.Msg = "保存失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = err.Error() br.IsSendEmail = isSendEmail return } } } default: br.Msg = "错误的来源" br.ErrMsg = "错误的来源,source:" + strconv.Itoa(req.Source) br.IsSendEmail = false return } if err != nil { br.Msg = "保存失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = err.Error() br.IsSendEmail = isSendEmail return } // 如果图没有建立关联关系，那么就需要添加关系 if isAdd { multipleGraphConfigChartMapping = &data_manage.MultipleGraphConfigChartMapping{ //Id: 0, MultipleGraphConfigId: req.MultipleGraphConfigId, ChartInfoId: chartInfo.ChartInfoId, Source: req.Source, ModifyTime: time.Now(), CreateTime: time.Now(), } err = data_manage.AddMultipleGraphConfigChartMapping(multipleGraphConfigChartMapping) if err != nil { br.Msg = "保存失败" br.ErrMsg = "保存配置与图表的关联关系失败，ERR:" + err.Error() return } } else if multipleGraphConfigChartMapping != nil { multipleGraphConfigChartMapping.ChartInfoId = chartInfo.ChartInfoId multipleGraphConfigChartMapping.ModifyTime = time.Now() err = multipleGraphConfigChartMapping.Update([]string{"ChartInfoId", "ModifyTime"}) if err != nil { br.Msg = "保存失败" br.ErrMsg = "保存配置与图表的关联关系失败，ERR:" + err.Error() return } } //新增操作日志 { chartLog := new(data_manage.ChartInfoLog) chartLog.ChartInfoId = chartInfo.ChartInfoId chartLog.ChartName = req.ChartName chartLog.ChartClassifyId = req.ClassifyId chartLog.SysUserId = sysUser.AdminId chartLog.SysUserRealName = sysUser.RealName chartLog.UniqueCode = chartInfo.UniqueCode chartLog.CreateTime = time.Now() chartLog.Content = string(this.Ctx.Input.RequestBody) chartLog.Status = "多图配置保存图表" chartLog.Method = this.Ctx.Input.URI() go data_manage.AddChartInfoLog(chartLog) } resp := new(data_manage.AddChartInfoResp) resp.ChartInfoId = chartInfo.ChartInfoId resp.UniqueCode = chartInfo.UniqueCode resp.ChartType = chartInfo.ChartType br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true } // CopyMultipleGraphConfigSaveChart 图表另存为 func CopyMultipleGraphConfigSaveChart(req request.SaveMultipleGraphChartReq, this *ChartInfoController, br *models.BaseResponse, sysUser *system.Admin) { mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{req.EdbInfoIdA, req.EdbInfoIdB}) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } var edbInfoMappingA, edbInfoMappingB *data_manage.ChartEdbInfoMapping for _, v := range mappingList { if v.EdbInfoId == req.EdbInfoIdA { edbInfoMappingA = v } if v.EdbInfoId == req.EdbInfoIdB { edbInfoMappingB = v } } if edbInfoMappingA == nil { br.Msg = "指标A不存在" br.IsSendEmail = false return } if edbInfoMappingB == nil { br.Msg = "指标B不存在" br.IsSendEmail = false return } multipleGraphConfigChartMapping, err := data_manage.GetMultipleGraphConfigChartMappingByIdAndSource(req.MultipleGraphConfigId, req.Source) if err != nil { br.Msg = `保存失败` br.ErrMsg = "获取配置与图表的关联关系失败，ERR:" + err.Error() return } // 原图 oldChartInfo, err := data_manage.GetChartInfoById(multipleGraphConfigChartMapping.ChartInfoId) if err != nil { if !utils.IsErrNoRow(err) { br.Msg = `保存失败` br.ErrMsg = "获取图表信息失败，ERR:" + err.Error() return } br.Msg = "原图不存在" br.IsSendEmail = false return } // 说明图还在，没有被删除 if oldChartInfo == nil || oldChartInfo.ChartInfoId <= 0 { br.Msg = "原图不存在" br.IsSendEmail = false } var chartInfo *data_manage.ChartInfo var errMsg string isSendEmail := true switch req.Source { case 1: // 曲线图 curveConf := req.Curve edbInfoType := 1 //1:标准指标,0:领先指标 if !curveConf.EdbInfoType { edbInfoType = 0 } chartSaveItemList := []*data_manage.ChartSaveItem{ { EdbInfoId: edbInfoMappingA.EdbInfoId, MaxData: curveConf.LeftMax, MinData: curveConf.LeftMin, IsOrder: false, IsAxis: 1, EdbInfoType: 1, //LeadValue: curveConf.LeadValue, //LeadUnit: curveConf.LeadUnit, ChartStyle: "spline", ChartColor: `#00F`, PredictChartColor: "", ChartWidth: 3, Source: utils.CHART_SOURCE_DEFAULT, }, { EdbInfoId: edbInfoMappingB.EdbInfoId, MaxData: curveConf.RightMax, MinData: curveConf.RightMin, IsOrder: curveConf.IsOrder, IsAxis: 0, EdbInfoType: edbInfoType, LeadValue: curveConf.LeadValue, LeadUnit: curveConf.LeadUnit, ChartStyle: "spline", ChartColor: `#F00`, PredictChartColor: "", ChartWidth: 1, Source: utils.CHART_SOURCE_DEFAULT, }, } addChartReq := data_manage.AddChartInfoReq{ ChartEdbInfoList: chartSaveItemList, ChartClassifyId: req.ClassifyId, ChartName: req.ChartName, ChartType: utils.CHART_TYPE_CURVE, DateType: curveConf.DateType, StartDate: curveConf.StartDate, EndDate: curveConf.EndDate, StartYear: curveConf.StartYear, Calendar: "公历", LeftMin: fmt.Sprint(curveConf.LeftMin), LeftMax: fmt.Sprint(curveConf.LeftMax), RightMin: fmt.Sprint(curveConf.RightMin), RightMax: fmt.Sprint(curveConf.RightMax), } chartInfo, err, errMsg, isSendEmail = data.AddChartInfo(addChartReq, sysUser.AdminId, sysUser.RealName, this.Lang) case 2: // 相关性图 correlationConf := req.Correlation // 配置了数据才有返回 if correlationConf.LeadValue > 0 { leadValue := correlationConf.LeadValue leadUnit := correlationConf.LeadUnit calculateValue := correlationConf.CalculateValue calculateUnit := correlationConf.CalculateUnit moveUnitDays, ok := utils.FrequencyDaysMap[calculateUnit] if !ok { br.Msg = "错误的分析周期" br.IsSendEmail = false return } startDate := time.Now().AddDate(0, 0, -correlationConf.CalculateValue*moveUnitDays).Format(utils.FormatDate) endDate := time.Now().Format(utils.FormatDate) correlationChartInfoReq := data_manage.CorrelationChartInfoReq{ LeadValue: leadValue, LeadUnit: leadUnit, CalculateValue: calculateValue, CalculateUnit: calculateUnit, StartDate: startDate, EndDate: endDate, EdbInfoIdList: []data_manage.CorrelationChartInfoEdbItemReq{ { EdbInfoId: edbInfoMappingA.EdbInfoId, Name: "", NameEn: "", }, { EdbInfoId: edbInfoMappingB.EdbInfoId, Name: "", NameEn: "", }, }, } chartInfo, err, errMsg, isSendEmail = correlationServ.CopyChartInfo(multipleGraphConfigChartMapping.MultipleGraphConfigId, req.ClassifyId, req.ChartName, correlationChartInfoReq, oldChartInfo, sysUser, this.Lang) } default: br.Msg = "错误的来源" br.ErrMsg = "错误的来源,source:" + strconv.Itoa(req.Source) br.IsSendEmail = false return } if err != nil { br.Msg = "保存失败" if errMsg != `` { br.Msg = errMsg } br.ErrMsg = err.Error() br.IsSendEmail = isSendEmail return } //新增操作日志 { chartLog := new(data_manage.ChartInfoLog) chartLog.ChartInfoId = chartInfo.ChartInfoId chartLog.ChartName = req.ChartName chartLog.ChartClassifyId = req.ClassifyId chartLog.SysUserId = sysUser.AdminId chartLog.SysUserRealName = sysUser.RealName chartLog.UniqueCode = chartInfo.UniqueCode chartLog.CreateTime = time.Now() chartLog.Content = string(this.Ctx.Input.RequestBody) chartLog.Status = "多图配置另存为图表" chartLog.Method = this.Ctx.Input.URI() go data_manage.AddChartInfoLog(chartLog) } resp := new(data_manage.AddChartInfoResp) resp.ChartInfoId = chartInfo.ChartInfoId resp.UniqueCode = chartInfo.UniqueCode resp.ChartType = chartInfo.ChartType br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true } // MultipleGraphConfigSaveEdb // @Title 保存指标接口 // @Description 保存指标接口 // @Param request body request.SaveMultipleGraphEdbReq true "type json string" // @Success Ret=200 返回指标id // @router /multiple_graph/edb/save [post] func (this *ChartInfoController) MultipleGraphConfigSaveEdb() { 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 request.SaveMultipleGraphEdbReq err := json.Unmarshal(this.Ctx.Input.RequestBody, &req) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } cacheKey := "CACHE_CHART_EDB_INFO_ADD_" + strconv.Itoa(sysUser.AdminId) if !utils.Rc.SetNX(cacheKey, 1, 30*time.Second) { br.Msg = "系统处理中，请稍后重试！" br.ErrMsg = "系统处理中，请稍后重试！" + sysUser.RealName + ";data:" + string(this.Ctx.Input.RequestBody) return } defer func() { _ = utils.Rc.Delete(cacheKey) }() mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{req.EdbInfoIdA, req.EdbInfoIdB}) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } var edbInfoMappingA, edbInfoMappingB *data_manage.ChartEdbInfoMapping for _, v := range mappingList { if v.EdbInfoId == req.EdbInfoIdA { edbInfoMappingA = v } if v.EdbInfoId == req.EdbInfoIdB { edbInfoMappingB = v } } if edbInfoMappingA == nil { br.Msg = "指标A不存在" br.IsSendEmail = false return } if edbInfoMappingB == nil { br.Msg = "指标B不存在" br.IsSendEmail = false return } correlationConf := req.Correlation // 配置了数据才有返回 if correlationConf.LeadValue <= 0 { br.Msg = "相关性计算窗口必须大于0" br.IsSendEmail = false return } // 滚动相关性配置 var rollingCorrelation data_manage.RollingCorrelationConfig switch req.Source { case 3: rollingCorrelation = req.RollingCorrelation[0] case 4: rollingCorrelation = req.RollingCorrelation[1] default: br.Msg = "错误的来源" br.ErrMsg = "错误的来源,source:" + strconv.Itoa(req.Source) br.IsSendEmail = false return } // 配置了数据才有返回 if rollingCorrelation.CalculateValue <= 0 { br.Msg = "滚动相关性计算窗口必须大于0" br.IsSendEmail = false return } multipleGraphConfigEdbMapping, err := data_manage.GetMultipleGraphConfigEdbMappingByIdAndSource(req.MultipleGraphConfigId, req.Source) if err != nil && !utils.IsErrNoRow(err) { br.Msg = `保存失败` br.ErrMsg = "获取配置与图表的关联关系失败，ERR:" + err.Error() return } err = nil var isAdd bool var edbInfoId int if multipleGraphConfigEdbMapping == nil || multipleGraphConfigEdbMapping.MultipleGraphConfigId <= 0 { isAdd = true } else { edbInfo, err := data_manage.GetEdbInfoById(multipleGraphConfigEdbMapping.EdbInfoId) if err != nil && !utils.IsErrNoRow(err) { br.Msg = `保存失败` br.ErrMsg = "获取图表信息失败，ERR:" + err.Error() return } // 说明指标还在，没有被删除 if edbInfo != nil && edbInfo.EdbInfoId > 0 && !req.IsSaveAs { edbInfoId = multipleGraphConfigEdbMapping.EdbInfoId req.EdbName = edbInfo.EdbName req.ClassifyId = edbInfo.ClassifyId req.Frequency = edbInfo.Frequency req.Unit = edbInfo.Unit } } // 关联指标 edbInfoIdArr := []data_manage.EdbInfoFromTag{ { EdbInfoId: edbInfoMappingA.EdbInfoId, FromTag: "A", MoveValue: 0, }, { EdbInfoId: edbInfoMappingB.EdbInfoId, FromTag: "B", MoveValue: 0, }, } calculateFormula := request.EdbCalculateFormula{ BaseCalculateValue: correlationConf.CalculateValue, BaseCalculateUnit: correlationConf.CalculateUnit, LeadValue: rollingCorrelation.LeadValue, LeadUnit: rollingCorrelation.LeadUnit, CalculateValue: rollingCorrelation.CalculateValue, CalculateUnit: rollingCorrelation.CalculateUnit, } calculateFormulaByte, err := json.Marshal(calculateFormula) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } var respItem *data.AddPredictEdbDataResponse if edbInfoId <= 0 || req.IsSaveAs { req2 := &data_manage.EdbInfoCalculateBatchSaveReqByEdbLib{ AdminId: sysUser.AdminId, AdminName: sysUser.RealName, EdbName: req.EdbName, Frequency: req.Frequency, Unit: req.Unit, ClassifyId: req.ClassifyId, Formula: string(calculateFormulaByte), Source: utils.DATA_SOURCE_CALCULATE_CORRELATION, EdbInfoIdArr: edbInfoIdArr, Calendar: `公历`, } // 调用指标库去添加 reqJson, err := json.Marshal(req2) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } respItem, err = data.BatchSaveEdbCalculateData(string(reqJson), this.Lang) if err != nil { br.Msg = "新增失败" br.ErrMsg = "新增失败,Err:" + err.Error() return } } else { req2 := &data_manage.EdbInfoCalculateBatchEditReqByEdbLib{ EdbInfoId: edbInfoId, EdbName: req.EdbName, Frequency: req.Frequency, Unit: req.Unit, ClassifyId: req.ClassifyId, Formula: string(calculateFormulaByte), Source: utils.DATA_SOURCE_CALCULATE_CORRELATION, EdbInfoIdArr: edbInfoIdArr, Calendar: `公历`, } // 调用指标库去更新 reqJson, err := json.Marshal(req2) if err != nil { br.Msg = "参数解析异常！" br.ErrMsg = "参数解析失败，Err:" + err.Error() return } respItem, err = data.BatchEditEdbCalculateData(string(reqJson), this.Lang) if err != nil { br.Msg = "编辑失败" br.ErrMsg = "编辑失败,Err:" + err.Error() return } } if respItem == nil { br.Msg = "保存失败" br.ErrMsg = "保存失败" return } if respItem.Ret != 200 { br.Msg = respItem.Msg br.ErrMsg = respItem.ErrMsg return } resp := respItem.Data //添加es data.AddOrEditEdbInfoToEs(resp.EdbInfoId) // 如果不是另存为的话，那么需要建立配置与指标的关系 if !req.IsSaveAs { // 如果指标没有建立关联关系，那么就需要添加关系 if isAdd { multipleGraphConfigEdbMapping = &data_manage.MultipleGraphConfigEdbMapping{ //Id: 0, MultipleGraphConfigId: req.MultipleGraphConfigId, EdbInfoId: resp.EdbInfoId, Source: req.Source, ModifyTime: time.Now(), CreateTime: time.Now(), } err = data_manage.AddMultipleGraphConfigEdbMapping(multipleGraphConfigEdbMapping) if err != nil { br.Msg = "保存失败" br.ErrMsg = "保存配置与指标的关联关系失败，ERR:" + err.Error() return } } else if multipleGraphConfigEdbMapping != nil { multipleGraphConfigEdbMapping.EdbInfoId = resp.EdbInfoId multipleGraphConfigEdbMapping.ModifyTime = time.Now() err = multipleGraphConfigEdbMapping.Update([]string{"EdbInfoId", "ModifyTime"}) if err != nil { br.Msg = "保存失败" br.ErrMsg = "保存配置与指标的关联关系失败，ERR:" + err.Error() return } } } //新增操作日志 //{ // edbLog := new(data_manage.EdbInfoLog) // edbLog.EdbInfoId = resp.EdbInfoId // edbLog.SourceName = edbInfo.SourceName // edbLog.Source = edbInfo.Source // edbLog.EdbCode = edbInfo.EdbCode // edbLog.EdbName = req2.EdbName // edbLog.ClassifyId = req2.ClassifyId // 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.AddEdbInfoLog(edbLog) //} br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true } // GetMultipleGraphConfig // @Title 保存配置接口 // @Description 保存配置接口 // @Param UniqueCode query int true "图表唯一编码,如果是管理后台访问，传固定字符串:7c69b590249049942070ae9dcd5bf6dc" // @Success Ret=200 返回图表id // @router /multiple_graph/config/detail [get] func (this *ChartInfoController) GetMultipleGraphConfig() { 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 } uniqueCode := this.GetString("UniqueCode") if uniqueCode == "" { br.Msg = "参数错误" br.ErrMsg = "参数错误,uniqueCode is empty" return } chartInfo, err := data_manage.GetChartInfoViewByUniqueCode(uniqueCode) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表信息失败，Err:" + err.Error() return } if chartInfo == nil { br.Msg = "获取失败" br.ErrMsg = "获取图表信息失败，Err:" + err.Error() return } multipleGraphConfigChartMapping, err := data_manage.GetMultipleGraphConfigChartMappingByChartId(chartInfo.ChartInfoId) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取滚动相关性图表的配置信息失败，Err:" + err.Error() return } multipleGraphConfig, err := data_manage.GetMultipleGraphConfigById(multipleGraphConfigChartMapping.MultipleGraphConfigId) if err != nil { br.Msg = `获取失败` br.ErrMsg = `获取配置失败，ERR：` + err.Error() return } // 生成的图表 multipleGraphConfigChartMappingList := make([]response.MultipleGraphConfigChartMapping, 0) { chartMappingList, err := data_manage.GetMultipleGraphConfigChartMappingListById(multipleGraphConfigChartMapping.MultipleGraphConfigId) if err != nil { br.Msg = `获取失败` br.ErrMsg = `获取关联图表配置失败，ERR：` + err.Error() return } chartInfoIdList := make([]int, 0) chartMappingMap := make(map[int]*data_manage.MultipleGraphConfigChartMapping) for _, v := range chartMappingList { chartInfoIdList = append(chartInfoIdList, v.ChartInfoId) chartMappingMap[v.ChartInfoId] = v } chartList, err := data_manage.GetChartInfoByIdList(chartInfoIdList) if err != nil { br.Msg = `获取失败` br.ErrMsg = `获取关联图表列表失败，ERR：` + err.Error() return } for _, v := range chartList { var mapping response.MultipleGraphConfigChartMapping if tmpInfo, ok := chartMappingMap[v.ChartInfoId]; ok { mapping.ChartInfoId = tmpInfo.ChartInfoId mapping.Source = tmpInfo.Source mapping.MultipleLocationSource = tmpInfo.Source if v.ChartInfoId == chartInfo.ChartInfoId { mapping.CorrelationExtraConfig = chartInfo.ExtraConfig mapping.SourcesFrom = chartInfo.SourcesFrom } multipleGraphConfigChartMappingList = append(multipleGraphConfigChartMappingList, mapping) } } } // 生成的指标 multipleGraphConfigEdbMappingList := make([]response.MultipleGraphConfigEdbMapping, 0) { edbMappingList, err := data_manage.GetMultipleGraphConfigEdbMappingListById(multipleGraphConfigChartMapping.MultipleGraphConfigId) if err != nil { br.Msg = `获取失败` br.ErrMsg = `获取关联指标配置失败，ERR：` + err.Error() return } edbInfoIdList := make([]int, 0) edbMappingMap := make(map[int]*data_manage.MultipleGraphConfigEdbMapping) for _, v := range edbMappingList { edbInfoIdList = append(edbInfoIdList, v.EdbInfoId) edbMappingMap[v.EdbInfoId] = v } edbList, err := data_manage.GetEdbInfoByIdList(edbInfoIdList) if err != nil { br.Msg = `获取失败` br.ErrMsg = `获取关联图表列表失败，ERR：` + err.Error() return } for _, v := range edbList { if tmpInfo, ok := edbMappingMap[v.EdbInfoId]; ok { multipleGraphConfigEdbMappingList = append(multipleGraphConfigEdbMappingList, response.MultipleGraphConfigEdbMapping{ EdbInfoId: tmpInfo.EdbInfoId, Source: tmpInfo.Source, MultipleLocationSource: tmpInfo.Source, }) } } } // 关联指标 mappingList, err := data_manage.GetChartEdbMappingListByEdbInfoIdList([]int{multipleGraphConfig.EdbInfoIdA, multipleGraphConfig.EdbInfoIdB}) if err != nil { br.Msg = "获取失败" br.ErrMsg = "获取图表，指标信息失败，Err:" + err.Error() return } resp := response.MultipleGraphConfigDetailResp{ EdbInfoList: mappingList, MultipleGraphConfig: *multipleGraphConfig, ChartMappingList: multipleGraphConfigChartMappingList, EdbMappingList: multipleGraphConfigEdbMappingList, } br.Ret = 200 br.Success = true br.Msg = "保存成功" br.Data = resp br.IsAddLog = true }