eta_index_lib/services/base_from_calculate.go

package services

import (
	"eta/eta_index_lib/logic"
	"eta/eta_index_lib/models"
	"eta/eta_index_lib/utils"
	"fmt"
	"sort"
	"strconv"
	"strings"
	"time"
)

// EdbCalculateBatchSave 批量指标运算
func EdbCalculateBatchSave(req models.EdbInfoCalculateBatchSaveReq, lang string) (edbInfo *models.EdbInfo, uniqueCode string, err error, errMsg string) {
	// 校验参数
	req.EdbName = strings.Trim(req.EdbName, " ")
	if req.EdbName == "" {
		err = fmt.Errorf("指标名称不能为空")
		return
	}

	if req.Frequency == "" {
		err = fmt.Errorf("频率不能为空")
		return
	}

	if req.Unit == "" {
		err = fmt.Errorf("单位不能为空")
		return
	}

	if req.ClassifyId <= 0 {
		err = fmt.Errorf("请选择分类")
		return
	}

	// 基础指标id
	fromEdbInfoId := req.FromEdbInfoId

	var formulaInt int
	var nhccDate models.NhccDate // 拟合残差的日期
	switch req.Source {
	case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS, utils.DATA_SOURCE_CALCULATE_HBZ, utils.DATA_SOURCE_CALCULATE_HCZ, utils.DATA_SOURCE_CALCULATE_TIME_SHIFT, utils.DATA_SOURCE_CALCULATE_CJJX:
		if req.Formula == "" {
			err = fmt.Errorf("请填写N值")
			return
		}
		formulaInt, _ = strconv.Atoi(req.Formula)
		if formulaInt <= 0 {
			err = fmt.Errorf(" N值输入错误,请重新输入")
			return
		}
	case utils.DATA_SOURCE_CALCULATE_ZJPJ:
		//直接拼接指标
		//校验时间格式
		_, err = time.ParseInLocation(utils.FormatDate, req.Formula, time.Local)
		if err != nil {
			err = fmt.Errorf("拼接日期有误,请重新输入")
			return
		}
	case utils.DATA_SOURCE_CALCULATE_NHCC: //拟合残差指标
		//指标校验
		if len(req.EdbInfoIdArr) != 2 {
			err = fmt.Errorf("选择的指标异常,请重新选择")
			return
		}
		fromEdbInfoId = req.EdbInfoIdArr[0].EdbInfoId

		//校验时间格式
		//数据格式：2022-11-01,2022-11-10
		timeList := strings.Split(req.Formula, ",")
		if len(timeList) != 2 {
			err = fmt.Errorf("选择时间有误,请重新输入")
			return
		}
		startDate, e := time.ParseInLocation(utils.FormatDate, timeList[0], time.Local)
		if e != nil {
			err = fmt.Errorf("开始日期有误,请重新输入")
			return
		}
		endDate, e := time.ParseInLocation(utils.FormatDate, timeList[1], time.Local)
		if e != nil {
			err = fmt.Errorf("结束日期有误,请重新输入")
			return
		}
		if utils.GetTimeSubDay(startDate, endDate) < 2 {
			err = fmt.Errorf("日期间隔不得少于两天")
			return
		}
		nhccDate.StartDate = startDate
		nhccDate.EndDate = endDate
	case utils.DATA_SOURCE_CALCULATE_JP:
		if req.Formula != "期末值" && req.Formula != "平均值" {
			err = fmt.Errorf("数据取值类型错误:" + req.Formula)
			return
		}
	case utils.DATA_SOURCE_CALCULATE_ZSXY: // 指数修匀
		if req.Formula == "" {
			err = fmt.Errorf("请填写alpha值")
			return
		}
		a, e := strconv.ParseFloat(req.Formula, 64)
		if e != nil {
			err = fmt.Errorf("alpha值输入错误, 请重新输入")
			return
		}
		if a <= 0 || a >= 1 {
			err = fmt.Errorf("alpha值输入错误, 请重新输入")
			return
		}
	}

	notNeedFromEdbSourceList := []int{utils.DATA_SOURCE_CALCULATE_KSZS, utils.DATA_SOURCE_CALCULATE_CORRELATION, utils.DATA_SOURCE_CALCULATE_ZDYFX, utils.DATA_SOURCE_CALCULATE_SUM, utils.DATA_SOURCE_CALCULATE_AVG} // 不需要传入来源指标id的 指标类型
	if fromEdbInfoId <= 0 && !utils.InArrayByInt(notNeedFromEdbSourceList, req.Source) {
		err = fmt.Errorf("请选择指标")
		return
	}
	//加入缓存机制，避免创建同一个名称的指标 start
	redisKey := fmt.Sprint("edb_lib:edb_info:calculate:batch:save:", req.Source, ":", req.EdbName)
	isExist := utils.Rc.IsExist(redisKey)
	if isExist {
		err = fmt.Errorf("指标正在处理,请勿重复提交")
		return
	} else {
		//设置3分钟缓存
		utils.Rc.SetNX(redisKey, 1, time.Second*300)
		defer func() {
			_ = utils.Rc.Delete(redisKey)
		}()
	}
	//加入缓存机制，避免创建同一个名称的指标 end

	var condition string
	var pars []interface{}
	condition += " AND edb_name=? "
	pars = append(pars, req.EdbName)

	count, err := models.GetEdbInfoCountByCondition(condition, pars)
	if err != nil {
		err = fmt.Errorf("判断指标名称是否存在失败")
		errMsg = "判断指标名称是否存在失败,Err:" + err.Error()
		return
	}

	if count > 0 {
		err = fmt.Errorf("指标名称已存在，请重新填写")
		errMsg = "指标名称已存在，请重新填写"
		return
	}

	// 来源指标
	var fromEdbInfo *models.EdbInfo
	if fromEdbInfoId > 0 {
		fromEdbInfo, err = models.GetEdbInfoById(fromEdbInfoId)
		if err != nil {
			errMsg = "获取指标信息失败:Err:" + err.Error()
			err = fmt.Errorf("获取指标信息失败")
			return
		}
	}

	//生成指标编码
	edbCode, err := utils.GenerateEdbCode(1, "")
	if err != nil {
		errMsg = "指标编码生成失败:Err:" + err.Error()
		err = fmt.Errorf("指标生成失败")
		return
	}

	timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
	uniqueCode = utils.MD5(utils.DATA_PREFIX + "_" + timestamp)

	sysUserId := req.AdminId
	sysUserName := req.AdminName

	var sourName string
	var edbInfoId int

	var baseEdbInfoModel models.BaseEdbInfoInterface
	addParam := models.AddCalculateBatchParams{
		Req:             &req,
		FromEdbInfo:     fromEdbInfo,
		EdbCode:         edbCode,
		UniqueCode:      uniqueCode,
		SysUserId:       sysUserId,
		SysUserRealName: sysUserName,
	}

	switch req.Source {
	case utils.DATA_SOURCE_CALCULATE:
		sourName = "计算指标"
		req2 := models.EdbInfoCalculateSaveReq{
			AdminId:          sysUserId,
			AdminName:        sysUserName,
			EdbName:          req.EdbName,
			Frequency:        req.Frequency,
			Unit:             req.Unit,
			ClassifyId:       req.ClassifyId,
			CalculateFormula: req.CalculateFormula,
			//EdbInfoIdArr:     req.EdbInfoIdArr,
			EmptyType:    req.EmptyType,
			MaxEmptyType: req.MaxEmptyType,
			Extra:        req.Extra,
		}

		// 放入A指标
		t := models.EdbInfoFromTag{
			EdbInfoId: req.FromEdbInfoId,
			FromTag:   "A",
		}
		req2.EdbInfoIdArr = append(req2.EdbInfoIdArr, t)
		// 放入B指标
		if len(req.EdbInfoIdArr) > 0 {
			t = models.EdbInfoFromTag{
				EdbInfoId: req.EdbInfoIdArr[0].EdbInfoId,
				FromTag:   "B",
			}
			req2.EdbInfoIdArr = append(req2.EdbInfoIdArr, t)
		}

		edbInfo, _, err, errMsg = EdbCalculateAdd(req2, lang)
	case utils.DATA_SOURCE_CALCULATE_LJZZY:
		sourName = "累计值转月值"
		if fromEdbInfo.Frequency != "月度" {
			err = fmt.Errorf("请选择月度指标")
			return
		}
		edbInfo, err = models.AddCalculateLjzzy(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_TBZ:
		if req.Frequency != fromEdbInfo.Frequency {
			err = fmt.Errorf("当前频度和原指标频度不一致")
			return
		}
		if req.Unit != "无" {
			err = fmt.Errorf("单位只允许为无，禁止选择其他单位")
			return
		}
		sourName = "同比值"
		edbInfo, err = models.AddCalculateTbz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_TCZ:
		if req.Frequency != fromEdbInfo.Frequency {
			err = fmt.Errorf("当前频度和原指标频度不一致")
			return
		}
		if req.Unit != fromEdbInfo.Unit {
			err = fmt.Errorf("当前单位和原指标单位不一致")
			return
		}
		sourName = "同差值"
		edbInfo, err = models.AddCalculateTcz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS:
		sourName = "N数值移动平均计算"
		edbInfo, err = models.AddCalculateNszydpjjs(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
	case utils.DATA_SOURCE_CALCULATE_HBZ:
		checkCount, tmpErr := models.GetLteZeroEdbDataCount(fromEdbInfo.Source, fromEdbInfo.SubSource, fromEdbInfoId)
		if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
			err = fmt.Errorf("判断环比值是否可计算失败")
			errMsg = "判断环比值是否可计算失败,Err:" + tmpErr.Error()
			return
		}
		if checkCount > 0 {
			err = fmt.Errorf("原始数据中存在0或负数，该指标不能进行环比运算")
			errMsg = "原始数据中出现0和负值时，提示该指标不能进行环比运算"
			return
		}
		sourName = "环比值"
		edbInfo, err = models.AddCalculateHbz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
	case utils.DATA_SOURCE_CALCULATE_HCZ:
		sourName = "环差值"
		edbInfo, err = models.AddCalculateHcz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
	case utils.DATA_SOURCE_CALCULATE_BP:
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_BP
		edbInfo, err = models.AddCalculateBp(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_TIME_SHIFT:
		sourName = "时间移位"
		edbInfo, err = models.AddCalculateTimeShift(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_ZJPJ:
		sourName = "直接拼接"

		if len(req.EdbInfoIdArr) != 1 {
			err = fmt.Errorf("请传入拼接日期之后的指标")
			errMsg = "请传入拼接日期之后的指标"
			return
		}

		secondEdbInfoReq := req.EdbInfoIdArr[0]
		secondEdbInfo, tmpErr := models.GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
		if tmpErr != nil {
			err = fmt.Errorf("获取拼接日期之后的指标信息失败")
			errMsg = "获取拼接日期之后的指标信息失败:Err:" + tmpErr.Error()
			return
		}

		if fromEdbInfo.EdbInfoId == secondEdbInfo.EdbInfoId {
			err = fmt.Errorf("两个指标不允许为同一个")
			errMsg = "两个指标不允许为同一个"
			return
		}
		edbInfo, err = models.AddCalculateZjpj(&req, fromEdbInfo, secondEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_LJZTBPJ:
		sourName = "累计值同比拼接"

		if fromEdbInfo.Frequency != "月度" {
			err = fmt.Errorf("待拼接指标只能筛选月度指标")
			errMsg = "待拼接指标只能筛选月度指标"
			return
		}
		if len(req.EdbInfoIdArr) != 1 {
			err = fmt.Errorf("请传入同比值指标")
			errMsg = "请传入同比值指标"
			return
		}

		secondEdbInfoReq := req.EdbInfoIdArr[0]
		tbzEdbInfo, tmpErr := models.GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
		if tmpErr != nil {
			err = fmt.Errorf("获取同比值指标信息失败")
			errMsg = "获取同比值指标信息失败:Err:" + tmpErr.Error()
			return
		}
		if tbzEdbInfo.Source != utils.DATA_SOURCE_CALCULATE_TBZ {
			err = fmt.Errorf("指标必须是传入同比值指标类型")
			errMsg = "指标必须是传入同比值指标类型"
			return
		}
		if tbzEdbInfo.Frequency != "月度" {
			err = fmt.Errorf("同比值指标只能筛选月度指标")
			errMsg = "同比值指标只能筛选月度指标"
			return
		}

		if fromEdbInfo.EdbInfoId == tbzEdbInfo.EdbInfoId {
			err = fmt.Errorf("两个指标不允许为同一个")
			errMsg = "两个指标不允许为同一个"
			return
		}
		edbInfo, err = models.AddCalculateLjztbpj(&req, fromEdbInfo, tbzEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_CJJX:
		sourName = "超季节性"
		edbInfo, err = models.AddCalculateCjjx(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
	case utils.DATA_SOURCE_CALCULATE_NHCC:
		sourName = "拟合残差"

		secondEdbInfoReq := req.EdbInfoIdArr[1]
		secondEdbInfo, tmpErr := models.GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
		if tmpErr != nil {
			err = fmt.Errorf("获取因变量的指标信息失败")
			errMsg = "获取因变量的指标信息失败:Err:" + tmpErr.Error()
			return
		}

		if fromEdbInfo.EdbInfoId == secondEdbInfo.EdbInfoId {
			err = fmt.Errorf("两个指标不允许为同一个")
			errMsg = "两个指标不允许为同一个"
			return
		}
		edbInfo, err, errMsg = models.AddCalculateNhcc(&req, fromEdbInfo, secondEdbInfo, edbCode, uniqueCode, nhccDate, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_JP:
		if !models.CheckFrequency(fromEdbInfo.Frequency, req.Frequency) {
			err = fmt.Errorf("频度异常,不允许低频降频到高频")
			return
		}
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_JP
		edbInfo, err = models.AddCalculateJp(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_NH:
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_NH
		edbInfo, err = models.AddCalculateNh(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_KSZS:
		//关联的指标信息
		if len(req.EdbInfoIdArr) < 2 {
			err = fmt.Errorf("指标数量不能小于2个，请重新选择")
			errMsg = "指标数量不能小于2个，请重新选择"
			//br.IsSendEmail = false
			return
		}
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_KSZS
		edbInfo, err = models.AddCalculateKszs(&req, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_CORRELATION:
		//关联的指标信息
		if len(req.EdbInfoIdArr) < 2 {
			err = fmt.Errorf("指标数量不能小于2个，请重新选择")
			errMsg = "指标数量不能小于2个，请重新选择"
			//br.IsSendEmail = false
			return
		}
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_CORRELATION
		edbInfo, err, errMsg = models.AddCalculateCorrelation(&req, edbCode, uniqueCode, sysUserId, sysUserName)
	case utils.DATA_SOURCE_CALCULATE_RJZ:
		if req.Frequency == "日度" {
			err = fmt.Errorf("日度指标无需进行日均值计算")
			return
		}
		if req.Frequency != fromEdbInfo.Frequency {
			err = fmt.Errorf("当前频度和原指标频度不一致")
			return
		}
		if req.Unit != fromEdbInfo.Unit {
			err = fmt.Errorf("单位只允许为和原指标频度保持一致，禁止选择其他单位")
			return
		}
		sourName = "日均值"
		edbInfo, err = models.AddCalculateRjz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
	default:
		// 获取通用的数据源处理服务
		baseEdbInfoModel = models.GetBaseEdbInfoModel(req.Source)
		// 没有找到的话，那么就直接返回报错吧
		if baseEdbInfoModel == nil {
			err = fmt.Errorf("无效计算方式")
			errMsg = "无效计算方式,source:" + strconv.Itoa(req.Source)
			return
		}
		sourName = baseEdbInfoModel.GetSourceName()
		edbInfo, err, errMsg = baseEdbInfoModel.Add(addParam)
	}

	if err != nil {
		errMsg = "生成" + sourName + "失败 Err:" + err.Error() + errMsg
		err = fmt.Errorf("生成" + sourName + "失败")
		return
	}

	if edbInfo == nil {
		err = fmt.Errorf("生成" + sourName + "失败")
		errMsg = "生成" + sourName + "失败,指标ID错误:" + strconv.Itoa(edbInfoId)
		return
	}
	edbInfoId = edbInfo.EdbInfoId

	//处理同名指标
	{
		edbNameList, tErr := models.GetEdbInfoByName(req.EdbName)
		if tErr != nil {
			err = fmt.Errorf("保存失败")
			errMsg = "获取指标信息失败，Err:" + tErr.Error()
			return
		}
		if len(edbNameList) >= 2 {
			for _, v := range edbNameList {
				edbName := v.EdbName + "(" + v.SourceName + ")"
				err = models.ModifyEdbInfoNameSource(edbName, v.EdbInfoId)
				if err != nil {
					errMsg = "修改指标名称失败，Err:" + err.Error()
					err = fmt.Errorf("保存失败")
					return
				}
			}
		}
	}

	// 更新指标最大最小值
	err, errMsg = models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
	if err != nil {
		return
	}

	// 更新ES
	go logic.UpdateEs(edbInfo.EdbInfoId)
	go DisableEdbInfoNoUpdate(edbInfo)
	return
}

// EdbCalculateBatchEdit 批量指标编辑
func EdbCalculateBatchEdit(req models.EdbInfoCalculateBatchEditReq) (edbInfo *models.EdbInfo, uniqueCode string, err error, errMsg string) {
	// 校验参数
	req.EdbName = strings.Trim(req.EdbName, " ")
	if req.EdbName == "" {
		err = fmt.Errorf("指标名称不能为空")
		return
	}

	if req.Frequency == "" {
		err = fmt.Errorf("频率不能为空")
		return
	}

	if req.Unit == "" {
		err = fmt.Errorf("单位不能为空")
		return
	}

	if req.ClassifyId <= 0 {
		err = fmt.Errorf("请选择分类")
		return
	}

	if req.EdbInfoId <= 0 {
		err = fmt.Errorf("请选择指标")
		return
	}

	//加入缓存机制，避免创建同一个名称的指标 start
	redisKey := fmt.Sprint("edb_lib:edb_info:calculate:batch:save:", req.Source, ":", req.EdbName)
	isExist := utils.Rc.IsExist(redisKey)
	if isExist {
		err = fmt.Errorf("指标正在处理,请勿重复提交")
		return
	} else {
		//设置3分钟缓存
		utils.Rc.SetNX(redisKey, 1, time.Second*300)
		defer func() {
			_ = utils.Rc.Delete(redisKey)
		}()
	}
	//加入缓存机制，避免创建同一个名称的指标 end

	var condition string
	var pars []interface{}
	condition += " AND edb_name=?  AND edb_info_id<>? "
	pars = append(pars, req.EdbName, req.EdbInfoId)

	count, err := models.GetEdbInfoCountByCondition(condition, pars)
	if err != nil {
		err = fmt.Errorf("判断指标名称是否存在失败")
		errMsg = "判断指标名称是否存在失败,Err:" + err.Error()
		return
	}

	if count > 0 {
		err = fmt.Errorf("指标名称已存在，请重新填写")
		errMsg = "指标名称已存在，请重新填写"
		return
	}

	edbInfo, err = models.GetEdbInfoById(req.EdbInfoId)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			errMsg = "指标已被删除，请刷新页面:Err:" + err.Error()
			err = fmt.Errorf("指标已被删除，请刷新页面")

			return
		}
		errMsg = "获取指标信息失败:Err:" + err.Error()
		err = fmt.Errorf("获取指标信息失败")

		return
	}
	// 基础指标id
	fromEdbInfoId := req.FromEdbInfoId

	if req.Source <= 0 {
		req.Source = edbInfo.Source
	}
	var formulaInt int
	var nhccDate models.NhccDate // 拟合残差的日期
	// 初期的参数校验
	switch req.Source {
	case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS, utils.DATA_SOURCE_CALCULATE_HBZ, utils.DATA_SOURCE_CALCULATE_HCZ, utils.DATA_SOURCE_CALCULATE_TIME_SHIFT, utils.DATA_SOURCE_CALCULATE_CJJX:
		if req.Formula == "" {
			err = fmt.Errorf("请填写N值")
			return
		}
		formulaInt, _ = strconv.Atoi(req.Formula)
		if formulaInt <= 0 {
			err = fmt.Errorf("N值输入错误,请重新输入")
			return
		}
	case utils.DATA_SOURCE_CALCULATE_ZJPJ:
		//直接拼接指标

		//校验时间格式
		_, err = time.ParseInLocation(utils.FormatDate, req.Formula, time.Local)
		if err != nil {
			err = fmt.Errorf("拼接日期有误,请重新输入")
			return
		}
	case utils.DATA_SOURCE_CALCULATE_NHCC: //拟合残差指标
		//指标校验
		if len(req.EdbInfoIdArr) != 2 {
			err = fmt.Errorf("选择的指标异常,请重新选择")
			return
		}
		fromEdbInfoId = req.EdbInfoIdArr[0].EdbInfoId

		//校验时间格式
		//数据格式：2022-11-01,2022-11-10
		timeList := strings.Split(req.Formula, ",")
		if len(timeList) != 2 {
			err = fmt.Errorf("选择时间有误,请重新输入")
			return
		}
		startDate, e := time.ParseInLocation(utils.FormatDate, timeList[0], time.Local)
		if e != nil {
			err = fmt.Errorf("开始日期有误,请重新输入")
			return
		}
		endDate, e := time.ParseInLocation(utils.FormatDate, timeList[1], time.Local)
		if e != nil {
			err = fmt.Errorf("结束日期有误,请重新输入")
			return
		}
		if utils.GetTimeSubDay(startDate, endDate) < 2 {
			err = fmt.Errorf("日期间隔不得少于两天")
			return
		}
		nhccDate.StartDate = startDate
		nhccDate.EndDate = endDate
	case utils.DATA_SOURCE_CALCULATE_JP:
		if req.Formula != "期末值" && req.Formula != "平均值" {
			err = fmt.Errorf("数据取值类型错误:" + req.Formula)
			return
		}
	case utils.DATA_SOURCE_CALCULATE_ZSXY: // 指数修匀
		if req.Formula == "" {
			err = fmt.Errorf("请填写alpha值")
			return
		}
		a, e := strconv.ParseFloat(req.Formula, 64)
		if e != nil {
			err = fmt.Errorf("alpha值输入错误, 请重新输入")
			return
		}
		if a <= 0 || a >= 1 {
			err = fmt.Errorf("alpha值输入错误, 请重新输入")
			return
		}
	}
	// 来源指标
	var fromEdbInfo *models.EdbInfo
	// 基础指标id
	if fromEdbInfoId > 0 {
		fromEdbInfo, err = models.GetEdbInfoById(fromEdbInfoId)
		if err != nil {
			errMsg = "获取指标信息失败:Err:" + err.Error()
			err = fmt.Errorf("获取指标信息失败")
			return
		}
	}

	var sourName string
	var edbInfoId int
	var baseEdbInfoModel models.BaseEdbInfoInterface
	editParams := models.EditCalculateBatchParams{
		Req:         &req,
		EdbInfo:     edbInfo,
		FromEdbInfo: fromEdbInfo,
	}

	switch req.Source {
	case utils.DATA_SOURCE_CALCULATE_LJZZY:
		sourName = "累计值转月值"
		if fromEdbInfo.Frequency != "月度" {
			err = fmt.Errorf("请选择月度指标")
			return
		}
		err = models.EditCalculateLjzzy(edbInfo, &req, fromEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_TBZ:
		sourName = "同比值"
		err = models.EditCalculateTbz(edbInfo, &req, fromEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_TCZ:
		fmt.Println("start edit", time.Now())
		sourName = "同差值"
		err = models.EditCalculateTcz(edbInfo, &req, fromEdbInfo)
		fmt.Println("end edit", time.Now())
	case utils.DATA_SOURCE_CALCULATE_NSZYDPJJS:
		sourName = "N数值移动平均计算"
		err = models.EditCalculateNszydpjjs(edbInfo, &req, fromEdbInfo, formulaInt, edbInfo.CalculateFormula)
	case utils.DATA_SOURCE_CALCULATE_HBZ:
		checkCount, tmpErr := models.GetLteZeroEdbDataCount(fromEdbInfo.Source, fromEdbInfo.SubSource, req.FromEdbInfoId)
		if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
			errMsg = "判断环比值是否可计算失败,Err:" + tmpErr.Error()
			err = fmt.Errorf("判断环比值是否可计算失败")
			return
		}
		if checkCount > 0 {
			err = fmt.Errorf("原始数据中存在0或负数，该指标不能进行环比运算")
			errMsg = "原始数据中出现0和负值时，提示该指标不能进行环比运算"
			return
		}
		sourName = "环比值"
		err = models.EditCalculateHbz(edbInfo, &req, fromEdbInfo, formulaInt, edbInfo.CalculateFormula)
	case utils.DATA_SOURCE_CALCULATE_HCZ:
		sourName = "环差值"
		err = models.EditCalculateHcz(edbInfo, &req, fromEdbInfo, formulaInt, edbInfo.CalculateFormula)
	case utils.DATA_SOURCE_CALCULATE_BP:
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_BP
		err = models.EditCalculateBp(edbInfo, &req, fromEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_TIME_SHIFT:
		sourName = "时间移位"
		err = models.EditCalculateTimeShift(edbInfo, &req, fromEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_ZJPJ:
		sourName = "直接拼接"

		if len(req.EdbInfoIdArr) != 1 {
			err = fmt.Errorf("请传入拼接日期之后的指标")
			errMsg = "请传入拼接日期之后的指标"
			return
		}

		secondEdbInfoReq := req.EdbInfoIdArr[0]
		secondEdbInfo, tmpErr := models.GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
		if tmpErr != nil {
			errMsg = "获取拼接日期之后的指标信息失败:Err:" + tmpErr.Error()
			err = fmt.Errorf("获取拼接日期之后的指标信息失败")
			return
		}

		if fromEdbInfo.EdbInfoId == secondEdbInfo.EdbInfoId {
			err = fmt.Errorf("两个指标不允许为同一个")
			errMsg = "两个指标不允许为同一个"
			return
		}
		err = models.EditCalculateZjpj(&req, edbInfo, fromEdbInfo, secondEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_LJZTBPJ: //累计值同比拼接
		sourName = "累计值同比拼接"

		if fromEdbInfo.Frequency != "月度" {
			errMsg = "待拼接指标只能筛选月度指标"
			err = fmt.Errorf("待拼接指标只能筛选月度指标")
			return
		}
		if len(req.EdbInfoIdArr) != 1 {
			errMsg = "请传入同比值指标"
			err = fmt.Errorf("请传入同比值指标")
			return
		}

		secondEdbInfoReq := req.EdbInfoIdArr[0]
		tbzEdbInfo, tmpErr := models.GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
		if tmpErr != nil {
			errMsg = "获取同比值指标信息失败:Err:" + tmpErr.Error()
			err = fmt.Errorf("获取同比值指标信息失败")

			return
		}
		if tbzEdbInfo.Source != utils.DATA_SOURCE_CALCULATE_TBZ {
			err = fmt.Errorf("指标必须是传入同比值指标类型")
			errMsg = "指标必须是传入同比值指标类型"
			return
		}
		if tbzEdbInfo.Frequency != "月度" {
			err = fmt.Errorf("同比值指标只能筛选月度指标")
			errMsg = "同比值指标只能筛选月度指标"
			return
		}

		if fromEdbInfo.EdbInfoId == tbzEdbInfo.EdbInfoId {
			err = fmt.Errorf("两个指标不允许为同一个")
			errMsg = "两个指标不允许为同一个"
			return
		}
		err = models.EditCalculateLjztbpj(&req, edbInfo, fromEdbInfo, tbzEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_CJJX:
		sourName = "超季节性"
		err = models.EditCalculateCjjx(&req, edbInfo, fromEdbInfo, formulaInt)
	case utils.DATA_SOURCE_CALCULATE_NHCC:
		sourName = "拟合残差"
		secondEdbInfoReq := req.EdbInfoIdArr[1]
		secondEdbInfo, tmpErr := models.GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
		if tmpErr != nil {
			errMsg = "获取因变量的指标信息失败:Err:" + tmpErr.Error()
			err = fmt.Errorf("获取因变量的指标信息失败")

			return
		}

		if fromEdbInfo.EdbInfoId == secondEdbInfo.EdbInfoId {
			err = fmt.Errorf("两个指标不允许为同一个")
			errMsg = "两个指标不允许为同一个"
			return
		}
		err, errMsg = models.EditCalculateNhcc(&req, edbInfo, fromEdbInfo, secondEdbInfo, nhccDate)
	case utils.DATA_SOURCE_CALCULATE_JP:
		if !models.CheckFrequency(fromEdbInfo.Frequency, req.Frequency) {
			err = fmt.Errorf("频度异常,不允许低频降频到高频")
			return
		}
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_JP
		err = models.EditCalculateJp(edbInfo, &req, fromEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_NH:
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_NH
		err = models.EditCalculateNh(edbInfo, &req, fromEdbInfo)
	case utils.DATA_SOURCE_CALCULATE_KSZS:
		//关联的指标信息
		if len(req.EdbInfoIdArr) < 2 {
			err = fmt.Errorf("指标数量不能小于2个，请重新选择")
			errMsg = "指标数量不能小于2个，请重新选择"
			//br.IsSendEmail = false
			return
		}
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_KSZS
		err = models.EditCalculateKszs(edbInfo, &req)
	case utils.DATA_SOURCE_CALCULATE_CORRELATION:
		//关联的指标信息
		if len(req.EdbInfoIdArr) < 2 {
			err = fmt.Errorf("指标数量不能小于2个，请重新选择")
			errMsg = "指标数量不能小于2个，请重新选择"
			//br.IsSendEmail = false
			return
		}
		sourName = utils.DATA_SOURCE_NAME_CALCULATE_CORRELATION
		err, errMsg = models.EditCalculateCorrelation(edbInfo, &req)
	case utils.DATA_SOURCE_CALCULATE_RJZ:
		if req.Frequency == "日度" {
			err = fmt.Errorf("日度指标无需进行日均值计算")
			return
		}
		if req.Frequency != fromEdbInfo.Frequency {
			err = fmt.Errorf("当前频度和原指标频度不一致")
			return
		}
		if req.Unit != fromEdbInfo.Unit {
			err = fmt.Errorf("单位只允许为和原指标频度保持一致，禁止选择其他单位")
			return
		}
		sourName = "日均值"
		err = models.EditCalculateRjz(edbInfo, &req, fromEdbInfo)
	default:
		// 获取通用的数据源处理服务
		baseEdbInfoModel = models.GetBaseEdbInfoModel(req.Source)
		// 没有找到的话，那么就直接返回报错吧
		if baseEdbInfoModel == nil {
			err = fmt.Errorf("无效计算方式")
			errMsg = "无效计算方式,source:" + strconv.Itoa(req.Source)
			return
		}
		sourName = baseEdbInfoModel.GetSourceName()
		err, errMsg = baseEdbInfoModel.Edit(editParams)
	}
	if err != nil {
		errMsg = "生成" + sourName + "失败 Err:" + err.Error() + errMsg
		err = fmt.Errorf("生成" + sourName + "失败")
		return
	}
	if edbInfo == nil {
		err = fmt.Errorf("生成" + sourName + "失败")
		errMsg = "生成" + sourName + "失败,指标ID错误:" + strconv.Itoa(edbInfoId)
		return
	}
	edbInfoId = edbInfo.EdbInfoId
	uniqueCode = edbInfo.UniqueCode
	//处理同名指标
	{
		edbNameList, tErr := models.GetEdbInfoByName(req.EdbName)
		if tErr != nil {
			err = fmt.Errorf("保存失败")
			errMsg = "获取指标信息失败，Err:" + tErr.Error()
			return
		}
		if len(edbNameList) >= 2 {
			for _, v := range edbNameList {
				edbName := v.EdbName + "(" + v.SourceName + ")"
				err = models.ModifyEdbInfoNameSource(edbName, v.EdbInfoId)
				if err != nil {
					errMsg = "修改指标名称失败，Err:" + err.Error()
					err = fmt.Errorf("保存失败")
					return
				}
			}
		}
	}

	// 更新指标最大最小值
	err, errMsg = models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfo)
	if err != nil {
		return
	}

	// 更新ES
	go logic.UpdateEs(edbInfo.EdbInfoId)

	// 重置计算指标中的引用关系
	go ResetEdbRelation(edbInfoId)
	return
}

// EdbCalculateAdd 新增指标运算
func EdbCalculateAdd(req models.EdbInfoCalculateSaveReq, lang string) (edbInfo *models.EdbInfo, uniqueCode string, err error, errMsg string) {
	calculateFormula := req.CalculateFormula
	calculateFormula = strings.Replace(calculateFormula, "（", "(", -1)
	calculateFormula = strings.Replace(calculateFormula, "）", ")", -1)
	calculateFormula = strings.Replace(calculateFormula, "，", ",", -1)
	calculateFormula = strings.Replace(calculateFormula, "。", ".", -1)
	calculateFormula = strings.Replace(calculateFormula, "%", "*0.01", -1)
	req.CalculateFormula = calculateFormula

	//判断是否重复指标
	edbInfoMap := make(map[int]string)
	//移除研究员选择指标中的未使用的指标
	{
		//转大写的计算公式
		upperCalculateFormulaStr := strings.ToUpper(req.CalculateFormula)
		//用到的指标
		newEdbInfoIdArr := make([]models.EdbInfoFromTag, 0)
		for _, tmpEdbInfo := range req.EdbInfoIdArr {
			_, ok := edbInfoMap[tmpEdbInfo.EdbInfoId]
			if ok {
				err = fmt.Errorf("选择指标失败，请勿选择重复指标！")
				return
			}
			edbInfoMap[tmpEdbInfo.EdbInfoId] = tmpEdbInfo.FromTag

			upperFromTag := strings.ToUpper(tmpEdbInfo.FromTag)
			if strings.Contains(upperCalculateFormulaStr, upperFromTag) {
				newEdbInfoIdArr = append(newEdbInfoIdArr, tmpEdbInfo)
			}
		}
		req.EdbInfoIdArr = newEdbInfoIdArr
	}

	// 校验指标名称是否存在
	existEdbName, err := logic.CheckExistByEdbNameAndEdbInfoId(0, 0, req.EdbName, lang)
	if err != nil {
		errMsg = "判断指标名称是否存在失败,Err:" + err.Error()
		err = fmt.Errorf("判断指标名称是否存在失败")
		return
	}

	if existEdbName {
		errMsg = "指标名称已存在，请重新填写"
		err = fmt.Errorf(errMsg)
		//br.IsSendEmail = false
		return
	}

	//检验公式
	var formulaStr string
	var edbInfoIdBytes []string
	for _, v := range req.EdbInfoIdArr {
		formulaStr += v.FromTag + ","
		edbInfoIdBytes = append(edbInfoIdBytes, v.FromTag)
	}
	formulaSlice, err := utils.CheckFormulaJson(req.CalculateFormula)
	if err != nil {
		err = fmt.Errorf("公式格式错误，请重新填写")
		return
	}
	for _, formula := range formulaSlice {
		formulaMap, e := utils.CheckFormula(formula)
		if e != nil {
			err = fmt.Errorf("公式错误，请重新填写")
			return
		}
		for _, v := range formulaMap {
			if !strings.Contains(formulaStr, v) {
				err = fmt.Errorf("公式错误，请重新填写")
				return
			}
		}
	}

	//关联的指标信息
	edbInfoList := make([]*models.EdbInfo, 0)
	//关联的指标数据表
	calculateMappingList := make([]*models.EdbInfoCalculateMapping, 0)
	for k, v := range req.EdbInfoIdArr {
		fromEdbInfo, e := models.GetEdbInfoById(v.EdbInfoId)
		if e != nil {
			if e.Error() == utils.ErrNoRow() {
				err = fmt.Errorf("生成计算指标失败")
				errMsg = "指标 " + strconv.Itoa(v.EdbInfoId) + " 不存在"
				return
			}
			err = fmt.Errorf("生成计算指标失败")
			errMsg = "获取指标失败:Err:" + e.Error()
			return
		}

		edbInfoList = append(edbInfoList, fromEdbInfo)
		//关联关系表
		{
			calculateMappingItem := &models.EdbInfoCalculateMapping{
				EdbInfoCalculateMappingId: 0,
				EdbInfoId:                 0,
				Source:                    utils.DATA_SOURCE_CALCULATE,
				SourceName:                "指标运算",
				EdbCode:                   "",
				FromEdbInfoId:             fromEdbInfo.EdbInfoId,
				FromEdbCode:               fromEdbInfo.EdbCode,
				FromEdbName:               fromEdbInfo.EdbName,
				FromSource:                fromEdbInfo.Source,
				FromSourceName:            fromEdbInfo.SourceName,
				FromTag:                   v.FromTag,
				Sort:                      k + 1,
				CreateTime:                time.Now(),
				ModifyTime:                time.Now(),
			}
			//calculateMappingItem.EdbCode = edbCode
			//calculateMappingItem.EdbInfoId = int(edbInfoId)
			calculateMappingList = append(calculateMappingList, calculateMappingItem)
		}
	}

	for _, v := range formulaSlice {
		formulaMap, e := utils.CheckFormula(v)
		if e != nil {
			err = fmt.Errorf("公式错误，请重新填写")
			return
		}
		//预先计算，判断公式是否正常
		ok, _ := models.CheckFormula2(edbInfoList, formulaMap, v, edbInfoIdBytes)
		if !ok {
			err = fmt.Errorf("生成计算指标失败，请使用正确的计算公式")
			return
		}
	}
	//生成指标编码
	edbCode, err := utils.GenerateEdbCode(1, "")
	if err != nil {
		errMsg = "生成计算指标失败,AddEdbInfo Err:" + err.Error()
		err = fmt.Errorf("指标编码生成失败，Err：" + err.Error())
		return
	}
	timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
	uniqueCode = utils.MD5(utils.DATA_PREFIX + "_" + timestamp)

	// 新增计算指标
	edbInfo, err = models.AddCalculateInfo(req, calculateMappingList, edbInfoList, edbCode, uniqueCode, edbInfoIdBytes)
	if err != nil {
		errMsg = "生成计算指标失败,AddEdbInfo Err:" + err.Error()
		err = fmt.Errorf("生成计算指标失败")
		return
	}
	go DisableEdbInfoNoUpdate(edbInfo)
	return
}

// StepCalculate 多公式计算
func StepCalculate(dataList []*models.EdbInfoSearchData, calculates []models.CalculatesReq) (resultData map[string]float64, dates []string, errMsg string, err error) {
	sort.Slice(calculates, func(i, j int) bool {
		return calculates[i].Sort < calculates[j].Sort
	})
	originData, e := models.EdbInfoSearchDataToData(dataList)
	if e != nil {
		err = fmt.Errorf("基础数据转换异常, err: %v", e)
		return
	}

	calculateData := originData
	dateDataMap := make(map[time.Time]float64)
	for _, v := range calculates {
		baseCalculate := models.BaseCalculate{
			DataList:      calculateData,
			Frequency:     v.Frequency,
			Formula:       v.Formula,
			Calendar:      v.Calendar,
			MoveType:      v.MoveType,
			MoveFrequency: v.MoveFrequency,
			FromFrequency: v.FromFrequency,
			Source:        v.Source,
		}

		// 计算方式
		switch baseCalculate.Source {
		case utils.EdbBaseCalculateLjzzy:
			dateDataMap, e, errMsg = baseCalculate.Ljzzy()
		case utils.EdbBaseCalculateLjzzj:
			dateDataMap, e, errMsg = baseCalculate.Ljzzj()
		case utils.EdbBaseCalculateTbz:
			dateDataMap, e, errMsg = baseCalculate.Tbz()
		case utils.EdbBaseCalculateTcz:
			dateDataMap, e, errMsg = baseCalculate.Tcz()
		case utils.EdbBaseCalculateNszydpjjs:
			dateDataMap, e, errMsg = baseCalculate.Nszydpjjs()
		case utils.EdbBaseCalculateHbz:
			dateDataMap, e, errMsg = baseCalculate.Hbz()
		case utils.EdbBaseCalculateHcz:
			dateDataMap, e, errMsg = baseCalculate.Hcz()
		case utils.EdbBaseCalculateUpFrequency:
			dateDataMap, e, errMsg = baseCalculate.UpFrequency()
		case utils.EdbBaseCalculateDownFrequency:
			dateDataMap, e, errMsg = baseCalculate.DownFrequency()
		case utils.EdbBaseCalculateTimeShift:
			dateDataMap, e, errMsg = baseCalculate.TimeShift()
		case utils.EdbBaseCalculateCjjx:
			dateDataMap, e, errMsg = baseCalculate.Cjjx()
		case utils.EdbBaseCalculateAnnualized:
			dateDataMap, e, errMsg = baseCalculate.Annualized()
		case utils.EdbBaseCalculateLjz:
			dateDataMap, e, errMsg = baseCalculate.Ljz()
		case utils.EdbBaseCalculateLjzNczj:
			dateDataMap, e, errMsg = baseCalculate.LjzNczj()
		case utils.EdbBaseCalculateExponentialSmoothing:
			dateDataMap, e, errMsg = baseCalculate.ExponentialSmoothing()
		case utils.EdbBaseCalculateRjz:
			dateDataMap, e, errMsg = baseCalculate.Rjz()
		default:
			errMsg = "计算方式无效"
			e = fmt.Errorf("%s:%d", errMsg, baseCalculate.Source)
		}
		if e != nil {
			err = fmt.Errorf("计算失败, err: %v", e)
			return
		}

		calculateData = models.TransDateData2EdbData(dateDataMap)
	}
	resultData, dates = models.GetDateDataAndDateList(dateDataMap)
	//resp.DataMap = resultData
	//resp.DateList = dates
	return
}