123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140 |
- 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
- }
- }
- // 记录旧的指标信息
- oldEdbName := fromEdbInfo.EdbName
- oldFrequency := fromEdbInfo.Frequency
- oldUnit := fromEdbInfo.Unit
- //生成指标编码
- 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
- }
- // 记录基础信息操作变更日志
- oldEdbInfo := new(models.EdbInfo)
- oldEdbInfo.EdbInfoId = fromEdbInfoId
- oldEdbInfo.EdbName = oldEdbName
- oldEdbInfo.Frequency = oldFrequency
- oldEdbInfo.Unit = oldUnit
- newEdbInfoEditRecord := new(models.EdbInfoEditRecord)
- newEdbInfoEditRecord.EdbName = req.EdbName
- newEdbInfoEditRecord.Frequency = req.Frequency
- newEdbInfoEditRecord.Unit = req.Unit
- newEdbInfoEditRecord.OperateUserId = req.AdminId
- newEdbInfoEditRecord.OperateUserRealName = req.AdminName
- err = AddEditEdbInfoRcord(oldEdbInfo, newEdbInfoEditRecord)
- if err != nil {
- errMsg = "记录基础信息操作变更日志失败,Err:" + err.Error()
- err = fmt.Errorf("操作记录保存失败")
- 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
- }
- // 记录旧的指标基本信息
- oldEdbName := edbInfo.EdbName
- oldFrequency := edbInfo.Frequency
- oldUnit := edbInfo.Unit
- // 基础指标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
- }
- // 记录基础信息操作变更日志
- oldEdbInfo := new(models.EdbInfo)
- oldEdbInfo.EdbInfoId = edbInfoId
- oldEdbInfo.EdbName = oldEdbName
- oldEdbInfo.Frequency = oldFrequency
- oldEdbInfo.Unit = oldUnit
- newEdbInfoEditRecord := new(models.EdbInfoEditRecord)
- newEdbInfoEditRecord.EdbName = req.EdbName
- newEdbInfoEditRecord.Frequency = req.Frequency
- newEdbInfoEditRecord.Unit = req.Unit
- newEdbInfoEditRecord.OperateUserId = req.AdminId
- newEdbInfoEditRecord.OperateUserRealName = req.AdminName
- err = AddEditEdbInfoRcord(oldEdbInfo, newEdbInfoEditRecord)
- if err != nil {
- errMsg = "记录基础信息操作变更日志失败,Err:" + err.Error()
- err = fmt.Errorf("操作记录保存失败")
- 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(utils.EDB_INFO_TYPE, 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
- }
|