|
@@ -17,9 +17,9 @@ type CalculateController struct {
|
|
|
}
|
|
|
|
|
|
// Add
|
|
|
-// @Title 编辑指标接口
|
|
|
-// @Description 编辑指标接口
|
|
|
-// @Success 200 {object} models.EditEdbInfoReq
|
|
|
+// @Title 新增计算指标接口
|
|
|
+// @Description 新增计算指标接口
|
|
|
+// @Success 200 {object} models.EdbInfoCalculateSaveReq
|
|
|
// @router /add [post]
|
|
|
func (this *CalculateController) Add() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
@@ -27,7 +27,7 @@ func (this *CalculateController) Add() {
|
|
|
this.Data["json"] = br
|
|
|
this.ServeJSON()
|
|
|
}()
|
|
|
- //source := utils.DATA_SOURCE_WIND
|
|
|
+
|
|
|
var req models.EdbInfoCalculateSaveReq
|
|
|
err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
if err != nil {
|
|
@@ -35,6 +35,7 @@ func (this *CalculateController) Add() {
|
|
|
br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
req.EdbName = strings.Trim(req.EdbName, " ")
|
|
|
if req.EdbName == "" {
|
|
|
br.Msg = "指标名称不能为空"
|
|
@@ -65,9 +66,16 @@ func (this *CalculateController) Add() {
|
|
|
br.Msg = "请填写指标"
|
|
|
return
|
|
|
}
|
|
|
+ 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
|
|
|
|
|
|
//加入缓存机制,避免创建同一个名称的指标 start
|
|
|
- redisKey := fmt.Sprint("edb_info:calculate:batch:save:", utils.DATA_SOURCE_CALCULATE, ":", req.EdbName)
|
|
|
+ redisKey := fmt.Sprint("edb_lib:edb_info:calculate:add:", utils.DATA_SOURCE_CALCULATE, ":", req.EdbName)
|
|
|
isExist := utils.Rc.IsExist(redisKey)
|
|
|
if isExist {
|
|
|
br.Msg = "指标正在处理,请勿重复提交"
|
|
@@ -80,15 +88,29 @@ func (this *CalculateController) Add() {
|
|
|
}()
|
|
|
}
|
|
|
|
|
|
- calculateFormula := req.CalculateFormula
|
|
|
- calculateFormula = strings.Replace(calculateFormula, "(", "(", -1)
|
|
|
- calculateFormula = strings.Replace(calculateFormula, ")", ")", -1)
|
|
|
- calculateFormula = strings.Replace(calculateFormula, ",", ",", -1)
|
|
|
- calculateFormula = strings.Replace(calculateFormula, "。", ".", -1)
|
|
|
- if strings.Contains(req.CalculateFormula, "%") {
|
|
|
- calculateFormula = strings.Replace(calculateFormula, "%", "*0.01", -1)
|
|
|
+ //判断是否重复指标
|
|
|
+ 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 {
|
|
|
+ br.Msg = "选择指标失败,请勿选择重复指标!"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoMap[tmpEdbInfo.EdbInfoId] = tmpEdbInfo.FromTag
|
|
|
+
|
|
|
+ upperFromTag := strings.ToUpper(tmpEdbInfo.FromTag)
|
|
|
+ if strings.Contains(upperCalculateFormulaStr, upperFromTag) {
|
|
|
+ newEdbInfoIdArr = append(newEdbInfoIdArr, tmpEdbInfo)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ req.EdbInfoIdArr = newEdbInfoIdArr
|
|
|
}
|
|
|
- req.CalculateFormula = calculateFormula
|
|
|
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
@@ -101,9 +123,11 @@ func (this *CalculateController) Add() {
|
|
|
br.ErrMsg = "判断指标名称是否存在失败,Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
if count > 0 {
|
|
|
br.Msg = "指标名称已存在,请重新填写"
|
|
|
br.ErrMsg = "指标名称已存在,请重新填写"
|
|
|
+ br.IsSendEmail = false
|
|
|
return
|
|
|
}
|
|
|
//检验公式
|
|
@@ -121,36 +145,97 @@ func (this *CalculateController) Add() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ //关联的指标信息
|
|
|
+ edbInfoList := make([]*models.EdbInfo, 0)
|
|
|
+ //关联的指标数据表
|
|
|
+ calculateMappingList := make([]*models.EdbInfoCalculateMapping, 0)
|
|
|
+ for k, v := range req.EdbInfoIdArr {
|
|
|
+ fromEdbInfo, err := models.GetEdbInfoById(v.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "生成计算指标失败"
|
|
|
+ br.Msg = "指标 " + strconv.Itoa(v.EdbInfoId) + " 不存在"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "生成计算指标失败"
|
|
|
+ br.Msg = "获取指标失败:Err:" + err.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)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ ok, _ := models.CheckFormula2(edbInfoList, formulaMap, calculateFormula, edbInfoIdBytes)
|
|
|
+ if !ok {
|
|
|
+ br.Msg = "生成计算指标失败,请使用正确的计算公式"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
randStr := utils.GetRandDigit(4)
|
|
|
edbCode := `C` + time.Now().Format("060102") + randStr
|
|
|
|
|
|
timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
|
|
|
uniqueCode := utils.MD5(utils.DATA_PREFIX + "_" + timestamp)
|
|
|
edbInfo := &models.EdbInfo{
|
|
|
- Source: utils.DATA_SOURCE_CALCULATE,
|
|
|
+ EdbInfoId: 0,
|
|
|
SourceName: "指标运算",
|
|
|
+ Source: utils.DATA_SOURCE_CALCULATE,
|
|
|
EdbCode: edbCode,
|
|
|
EdbName: req.EdbName,
|
|
|
EdbNameSource: req.EdbName,
|
|
|
Frequency: req.Frequency,
|
|
|
Unit: req.Unit,
|
|
|
+ StartDate: "",
|
|
|
+ EndDate: "",
|
|
|
ClassifyId: req.ClassifyId,
|
|
|
SysUserId: req.AdminId,
|
|
|
SysUserRealName: req.AdminName,
|
|
|
+ UniqueCode: uniqueCode,
|
|
|
CreateTime: time.Now(),
|
|
|
ModifyTime: time.Now(),
|
|
|
- UniqueCode: uniqueCode,
|
|
|
+ MinValue: 0,
|
|
|
+ MaxValue: 0,
|
|
|
CalculateFormula: req.CalculateFormula,
|
|
|
EdbType: 2,
|
|
|
+ Sort: 0,
|
|
|
+ MoveType: 0,
|
|
|
+ MoveFrequency: "",
|
|
|
+ NoUpdate: 0,
|
|
|
+ ServerUrl: "",
|
|
|
+ EdbInfoType: 0,
|
|
|
+ EdbNameEn: "",
|
|
|
+ UnitEn: "",
|
|
|
+ LatestDate: "",
|
|
|
+ LatestValue: 0,
|
|
|
+ ChartImage: "",
|
|
|
}
|
|
|
-
|
|
|
edbInfoId, err := models.AddEdbInfo(edbInfo)
|
|
|
if err != nil {
|
|
|
br.Msg = "生成计算指标失败"
|
|
|
br.Msg = "生成计算指标失败,AddEdbInfo Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
- edbInfo.EdbInfoId = int(edbInfoId)
|
|
|
//处理同名指标
|
|
|
{
|
|
|
edbNameList, err := models.GetEdbInfoByName(req.EdbName)
|
|
@@ -172,50 +257,19 @@ func (this *CalculateController) Add() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- edbInfoList := make([]*models.EdbInfo, 0)
|
|
|
-
|
|
|
- calculateMappingList := make([]*models.EdbInfoCalculateMapping, 0)
|
|
|
- for k, v := range req.EdbInfoIdArr {
|
|
|
- fromEdbInfo, err := models.GetEdbInfoById(v.EdbInfoId)
|
|
|
- if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
- br.Msg = "生成计算指标失败"
|
|
|
- br.Msg = "指标 " + strconv.Itoa(v.EdbInfoId) + " 不存在"
|
|
|
- return
|
|
|
- }
|
|
|
- br.Msg = "生成计算指标失败"
|
|
|
- br.Msg = "获取指标失败:Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- edbInfoList = append(edbInfoList, fromEdbInfo)
|
|
|
-
|
|
|
- //关联关系表
|
|
|
- {
|
|
|
- calculateMappingItem := &models.EdbInfoCalculateMapping{
|
|
|
- CreateTime: time.Now(),
|
|
|
- ModifyTime: time.Now(),
|
|
|
- Sort: k + 1,
|
|
|
- EdbCode: edbCode,
|
|
|
- EdbInfoId: int(edbInfoId),
|
|
|
- FromEdbInfoId: fromEdbInfo.EdbInfoId,
|
|
|
- FromEdbCode: fromEdbInfo.EdbCode,
|
|
|
- FromEdbName: fromEdbInfo.EdbName,
|
|
|
- FromSource: fromEdbInfo.Source,
|
|
|
- FromSourceName: fromEdbInfo.SourceName,
|
|
|
- FromTag: v.FromTag,
|
|
|
- Source: utils.DATA_SOURCE_CALCULATE,
|
|
|
- SourceName: "指标运算",
|
|
|
- }
|
|
|
- calculateMappingList = append(calculateMappingList, calculateMappingItem)
|
|
|
- }
|
|
|
- }
|
|
|
//关联关系表
|
|
|
{
|
|
|
+ //处理关联指标
|
|
|
+ for _, v := range calculateMappingList {
|
|
|
+ v.EdbCode = edbCode
|
|
|
+ v.EdbInfoId = int(edbInfoId)
|
|
|
+ }
|
|
|
if len(calculateMappingList) > 0 {
|
|
|
go models.AddEdbInfoCalculateMappingMulti(calculateMappingList)
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ // 指标数据入库
|
|
|
err = models.AddCalculate(edbInfoList, int(edbInfoId), edbCode, req.CalculateFormula, edbInfoIdBytes)
|
|
|
if err != nil {
|
|
|
br.Msg = "生成计算指标失败"
|
|
@@ -241,13 +295,274 @@ func (this *CalculateController) Add() {
|
|
|
br.IsAddLog = true
|
|
|
}
|
|
|
|
|
|
-// CalculateBatchSave
|
|
|
+// Edit
|
|
|
+// @Title 编辑计算指标接口
|
|
|
+// @Description 编辑计算指标接口
|
|
|
+// @Success 200 {object} models.EdbInfoCalculateSaveReq
|
|
|
+// @router /edit [post]
|
|
|
+func (this *CalculateController) Edit() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+
|
|
|
+ var req models.EdbInfoCalculateSaveReq
|
|
|
+ err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "参数解析异常!"
|
|
|
+ br.ErrMsg = "参数解析失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if req.EdbInfoId <= 0 {
|
|
|
+ br.Msg = "参数错误"
|
|
|
+ br.ErrMsg = "指标ID:" + strconv.Itoa(req.EdbInfoId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ req.EdbName = strings.Trim(req.EdbName, " ")
|
|
|
+ if req.EdbName == "" {
|
|
|
+ br.Msg = "指标名称不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if req.Frequency == "" {
|
|
|
+ br.Msg = "频率不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if req.Unit == "" {
|
|
|
+ br.Msg = "单位不能为空"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if req.ClassifyId <= 0 {
|
|
|
+ br.Msg = "请选择分类"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(req.EdbInfoIdArr) <= 0 {
|
|
|
+ br.Msg = "请选择指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if req.CalculateFormula == "" {
|
|
|
+ br.Msg = "请填写指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ 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
|
|
|
+ fmt.Println("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 {
|
|
|
+ br.Msg = "选择指标失败,请勿选择重复指标!"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoMap[tmpEdbInfo.EdbInfoId] = tmpEdbInfo.FromTag
|
|
|
+
|
|
|
+ upperFromTag := strings.ToUpper(tmpEdbInfo.FromTag)
|
|
|
+ if strings.Contains(upperCalculateFormulaStr, upperFromTag) {
|
|
|
+ newEdbInfoIdArr = append(newEdbInfoIdArr, tmpEdbInfo)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ req.EdbInfoIdArr = newEdbInfoIdArr
|
|
|
+ }
|
|
|
+
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ condition += " AND edb_name=? "
|
|
|
+ pars = append(pars, req.EdbName)
|
|
|
+
|
|
|
+ condition += " AND edb_info_id<>? "
|
|
|
+ pars = append(pars, req.EdbInfoId)
|
|
|
+
|
|
|
+ count, err := models.GetEdbInfoCountByCondition(condition, pars)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "判断指标名称是否存在失败"
|
|
|
+ br.ErrMsg = "判断指标名称是否存在失败,Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if count > 0 {
|
|
|
+ br.Msg = "指标名称已存在,请重新填写"
|
|
|
+ br.ErrMsg = "指标名称已存在,请重新填写"
|
|
|
+ br.IsSendEmail = false
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //判断公式,指标是否有改动
|
|
|
+ edbInfoDetail, err := models.GetEdbInfoById(req.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "修改失败"
|
|
|
+ br.Msg = "获取指标信息失败,GetEdbInfoById Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if edbInfoDetail == nil {
|
|
|
+ br.Msg = "修改失败"
|
|
|
+ br.Msg = "指标信息不存在,EdbInfoId:" + strconv.Itoa(req.EdbInfoId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var needCalculate bool
|
|
|
+
|
|
|
+ if edbInfoDetail.CalculateFormula != req.CalculateFormula {
|
|
|
+ needCalculate = true
|
|
|
+ }
|
|
|
+
|
|
|
+ //检验公式
|
|
|
+ var formulaStr string
|
|
|
+ var edbInfoIdBytes []string
|
|
|
+ var edbInfoIdArr []string
|
|
|
+ for _, v := range req.EdbInfoIdArr {
|
|
|
+ formulaStr += v.FromTag + ","
|
|
|
+ edbInfoIdBytes = append(edbInfoIdBytes, v.FromTag)
|
|
|
+ edbInfoIdArr = append(edbInfoIdArr, strconv.Itoa(v.EdbInfoId))
|
|
|
+ if v.EdbInfoId == req.EdbInfoId {
|
|
|
+ br.Msg = "计算指标中包含此指标,不能修改"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if needCalculate == false {
|
|
|
+ edbInfoIdStr := strings.Join(edbInfoIdArr, ",")
|
|
|
+ fromEdbInfoId, err := models.GetCalculateEdbInfo(req.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "修改失败"
|
|
|
+ br.Msg = "获取数据失败,GetCalculateEdbInfo:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if edbInfoIdStr != fromEdbInfoId {
|
|
|
+ needCalculate = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ formulaMap := services.CheckFormula(req.CalculateFormula)
|
|
|
+ for _, v := range formulaMap {
|
|
|
+ if !strings.Contains(formulaStr, v) {
|
|
|
+ br.Msg = "公式错误,请重新填写"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //重新计算
|
|
|
+ if needCalculate {
|
|
|
+ err = models.DeleteCalculateEdbInfo(req.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "修改失败"
|
|
|
+ br.Msg = "修改失败,DeleteCalculateEdbInfo Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ //calculateList := make([]*data_manage.EdbInfoCalculate, 0)
|
|
|
+ edbInfoList := make([]*models.EdbInfo, 0)
|
|
|
+
|
|
|
+ calculateMappingList := make([]*models.EdbInfoCalculateMapping, 0)
|
|
|
+ for k, v := range req.EdbInfoIdArr {
|
|
|
+ fromEdbInfo, err := models.GetEdbInfoById(v.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ if err.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "生成计算指标失败"
|
|
|
+ br.Msg = "指标 " + strconv.Itoa(v.EdbInfoId) + " 不存在"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "生成计算指标失败"
|
|
|
+ br.Msg = "获取指标失败:Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbInfoList = append(edbInfoList, fromEdbInfo)
|
|
|
+
|
|
|
+ //关联关系表
|
|
|
+ {
|
|
|
+ calculateMappingItem := &models.EdbInfoCalculateMapping{
|
|
|
+ EdbInfoCalculateMappingId: 0,
|
|
|
+ EdbInfoId: req.EdbInfoId,
|
|
|
+ Source: edbInfoDetail.Source,
|
|
|
+ SourceName: edbInfoDetail.SourceName,
|
|
|
+ EdbCode: edbInfoDetail.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(),
|
|
|
+ }
|
|
|
+ calculateMappingList = append(calculateMappingList, calculateMappingItem)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //预先计算,判断公式是否正常
|
|
|
+ ok, _ := models.CheckFormula2(edbInfoList, formulaMap, calculateFormula, edbInfoIdBytes)
|
|
|
+ if !ok {
|
|
|
+ br.Msg = "生成计算指标失败,请使用正确的计算公式"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ //关联关系表
|
|
|
+ {
|
|
|
+ if len(calculateMappingList) > 0 {
|
|
|
+ go models.AddEdbInfoCalculateMappingMulti(calculateMappingList)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ err = models.AddCalculate(edbInfoList, edbInfoDetail.EdbInfoId, edbInfoDetail.EdbCode, req.CalculateFormula, edbInfoIdBytes)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "生成计算指标失败"
|
|
|
+ br.Msg = "生成计算指标失败,Calculate Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ // 更新指标最大最小值
|
|
|
+ err, errMsg := models.UnifiedModifyEdbInfoMaxAndMinInfo(edbInfoDetail)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = errMsg
|
|
|
+ br.ErrMsg = err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 修改指标信息
|
|
|
+ err = models.ModifyCalculateEdbInfo(req.EdbName, req.Frequency, req.Unit, req.CalculateFormula, req.ClassifyId, req.EdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ br.Msg = "修改失败"
|
|
|
+ br.Msg = "修改失败,ModifyEdbInfo Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ resp := models.AddEdbInfoResp{
|
|
|
+ EdbInfoId: edbInfoDetail.EdbInfoId,
|
|
|
+ UniqueCode: edbInfoDetail.UniqueCode,
|
|
|
+ }
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "保存成功"
|
|
|
+ br.Data = resp
|
|
|
+ br.IsAddLog = true
|
|
|
+}
|
|
|
+
|
|
|
+// BatchSave
|
|
|
// @Title 累计值转月-同比值-同差等计算新增
|
|
|
// @Description 累计值转月-同比值-同差等计算新增接口
|
|
|
-// @Param request body models.EdbInfoCalculateBatchSaveReq true "type json string"
|
|
|
+// @Param request body models.EdbInfoCalculateBatchSaveReq true "type json string"
|
|
|
// @Success Ret=200 返回指标id
|
|
|
// @router /batch/save [post]
|
|
|
-func (this *CalculateController) CalculateBatchSave() {
|
|
|
+func (this *CalculateController) BatchSave() {
|
|
|
br := new(models.BaseResponse).Init()
|
|
|
defer func() {
|
|
|
this.Data["json"] = br
|
|
@@ -292,7 +607,7 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
if req.Source == utils.DATA_SOURCE_CALCULATE_NSZYDPJJS ||
|
|
|
req.Source == utils.DATA_SOURCE_CALCULATE_HBZ ||
|
|
|
req.Source == utils.DATA_SOURCE_CALCULATE_HCZ ||
|
|
|
- req.Source == utils.DATA_SOURCE_CALCULATE_TIME_SHIFT {
|
|
|
+ req.Source == utils.DATA_SOURCE_CALCULATE_TIME_SHIFT || req.Source == utils.DATA_SOURCE_CALCULATE_CJJX {
|
|
|
if req.Formula == "" {
|
|
|
br.Msg = "请填写N值"
|
|
|
return
|
|
@@ -313,16 +628,8 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- // 获取指标详情
|
|
|
- edbInfo, err := models.GetEdbInfoById(req.EdbInfoId)
|
|
|
- if err != nil {
|
|
|
- br.Msg = "指标不存在!"
|
|
|
- br.ErrMsg = "指标不存在"
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
//加入缓存机制,避免创建同一个名称的指标 start
|
|
|
- redisKey := fmt.Sprint("edb_info:calculate:batch:save:", req.Source, ":", req.EdbName)
|
|
|
+ redisKey := fmt.Sprint("edb_lib:edb_info:calculate:batch:save:", req.Source, ":", req.EdbName)
|
|
|
isExist := utils.Rc.IsExist(redisKey)
|
|
|
if isExist {
|
|
|
br.Msg = "指标正在处理,请勿重复提交"
|
|
@@ -351,6 +658,7 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
if count > 0 {
|
|
|
br.Msg = "指标名称已存在,请重新填写"
|
|
|
br.ErrMsg = "指标名称已存在,请重新填写"
|
|
|
+ br.IsSendEmail = false
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -367,27 +675,29 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
timestamp := strconv.FormatInt(time.Now().UnixNano(), 10)
|
|
|
uniqueCode := utils.MD5(utils.DATA_PREFIX + "_" + timestamp)
|
|
|
|
|
|
- adminId := req.AdminId
|
|
|
- adminName := req.AdminName
|
|
|
+ sysUserId := req.AdminId
|
|
|
+ sysUserName := req.AdminName
|
|
|
+
|
|
|
var sourName string
|
|
|
var edbInfoId int
|
|
|
+ var edbInfo *models.EdbInfo
|
|
|
if req.Source == utils.DATA_SOURCE_CALCULATE_LJZZY {
|
|
|
sourName = "累计值转月值"
|
|
|
if fromEdbInfo.Frequency != "月度" {
|
|
|
br.Msg = "请选择月度指标"
|
|
|
return
|
|
|
}
|
|
|
- edbInfoId, err = models.AddCalculateLjzzy(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateLjzzy(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_TBZ {
|
|
|
sourName = "同比值"
|
|
|
- edbInfoId, err = models.AddCalculateTbz(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateTbz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_TCZ {
|
|
|
sourName = "同差值"
|
|
|
- edbInfoId, err = models.AddCalculateTcz(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateTcz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_NSZYDPJJS {
|
|
|
sourName = "N数值移动平均计算"
|
|
|
- edbInfoId, err = models.AddCalculateNszydpjjs(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName, formulaInt)
|
|
|
- } else if req.Source == utils.DATA_SOURCE_CALCULATE_HBZ { //环比值
|
|
|
+ edbInfo, err = models.AddCalculateNszydpjjs(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
|
|
|
+ } else if req.Source == utils.DATA_SOURCE_CALCULATE_HBZ {
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
condition += " AND edb_info_id =? "
|
|
@@ -405,21 +715,21 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
return
|
|
|
}
|
|
|
sourName = "环比值"
|
|
|
- edbInfoId, err = models.AddCalculateHbz(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName, formulaInt)
|
|
|
+ edbInfo, err = models.AddCalculateHbz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_HCZ {
|
|
|
sourName = "环差值"
|
|
|
- edbInfoId, err = models.AddCalculateHcz(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName, formulaInt)
|
|
|
+ edbInfo, err = models.AddCalculateHcz(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_BP {
|
|
|
- if fromEdbInfo.Frequency == "日度" {
|
|
|
- br.Msg = "日度指标,无法进行变频操作"
|
|
|
- br.ErrMsg = "日度指标,无法进行变频操作:edbcode:" + fromEdbInfo.EdbCode
|
|
|
- return
|
|
|
- }
|
|
|
+ //if fromEdbInfo.Frequency == "日度" {
|
|
|
+ // br.Msg = "日度指标,无法进行变频操作"
|
|
|
+ // br.ErrMsg = "日度指标,无法进行变频操作:edbcode:" + fromEdbInfo.EdbCode
|
|
|
+ // return
|
|
|
+ //}
|
|
|
sourName = "变频"
|
|
|
- edbInfoId, err = models.AddCalculateBp(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateBp(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_TIME_SHIFT { //时间移位
|
|
|
sourName = "时间移位"
|
|
|
- edbInfoId, err = models.AddCalculateTimeShift(&req, fromEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateTimeShift(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_ZJPJ { //直接拼接
|
|
|
sourName = "直接拼接"
|
|
|
|
|
@@ -442,7 +752,7 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
br.ErrMsg = "两个指标不允许为同一个"
|
|
|
return
|
|
|
}
|
|
|
- edbInfoId, err = models.AddCalculateZjpj(&req, fromEdbInfo, secondEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateZjpj(&req, fromEdbInfo, secondEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
} else if req.Source == utils.DATA_SOURCE_CALCULATE_LJZTBPJ { //累计值同比拼接
|
|
|
sourName = "累计值同比拼接"
|
|
|
|
|
@@ -480,23 +790,28 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
br.ErrMsg = "两个指标不允许为同一个"
|
|
|
return
|
|
|
}
|
|
|
- edbInfoId, err = models.AddCalculateLjztbpj(&req, fromEdbInfo, tbzEdbInfo, edbCode, uniqueCode, adminId, adminName)
|
|
|
+ edbInfo, err = models.AddCalculateLjztbpj(&req, fromEdbInfo, tbzEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName)
|
|
|
+ } else if req.Source == utils.DATA_SOURCE_CALCULATE_CJJX {
|
|
|
+ sourName = "超季节性"
|
|
|
+ edbInfo, err = models.AddCalculateCjjx(&req, fromEdbInfo, edbCode, uniqueCode, sysUserId, sysUserName, formulaInt)
|
|
|
} else {
|
|
|
br.Msg = "无效计算方式"
|
|
|
br.ErrMsg = "无效计算方式,source:" + strconv.Itoa(req.Source)
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
if err != nil {
|
|
|
br.Msg = "生成" + sourName + "失败"
|
|
|
br.Msg = "生成" + sourName + "失败 Err:" + err.Error()
|
|
|
return
|
|
|
}
|
|
|
- if edbInfoId <= 0 {
|
|
|
+
|
|
|
+ if edbInfo == nil {
|
|
|
br.Msg = "生成" + sourName + "失败"
|
|
|
br.ErrMsg = "生成" + sourName + "失败,指标ID错误:" + strconv.Itoa(edbInfoId)
|
|
|
return
|
|
|
}
|
|
|
+ edbInfoId = edbInfo.EdbInfoId
|
|
|
+
|
|
|
//处理同名指标
|
|
|
{
|
|
|
edbNameList, err := models.GetEdbInfoByName(req.EdbName)
|
|
@@ -525,9 +840,10 @@ func (this *CalculateController) CalculateBatchSave() {
|
|
|
br.ErrMsg = err.Error()
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
resp := models.AddEdbInfoResp{
|
|
|
- EdbInfoId: edbInfoId,
|
|
|
- UniqueCode: uniqueCode,
|
|
|
+ EdbInfoId: edbInfo.EdbInfoId,
|
|
|
+ UniqueCode: edbInfo.UniqueCode,
|
|
|
}
|
|
|
br.Ret = 200
|
|
|
br.Success = true
|
|
@@ -792,6 +1108,24 @@ func (this *CalculateController) Refresh() {
|
|
|
errMsg = "RefreshAllPythonEdb Err:" + err.Error()
|
|
|
break
|
|
|
}
|
|
|
+ case utils.DATA_SOURCE_CALCULATE_CJJX: //超季节性
|
|
|
+ calculateCjjx, err := models.GetEdbInfoCalculateMappingDetail(edbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ errMsg = "GetEdbInfoCalculateNszydpjjsDetail Err:" + err.Error()
|
|
|
+ break
|
|
|
+ }
|
|
|
+ fromEdbInfo, err := models.GetEdbInfoById(calculateCjjx.FromEdbInfoId)
|
|
|
+ if err != nil {
|
|
|
+ errMsg = "GetEdbInfoById Err:" + err.Error()
|
|
|
+ break
|
|
|
+ }
|
|
|
+ formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
|
+ startDate = edbInfo.StartDate
|
|
|
+ err = models.RefreshAllCalculateCjjx(edbInfoId, edbInfo.Source, fromEdbInfo, calculateCjjx.EdbCode, startDate, "", formulaInt)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ errMsg = "RefreshAllCalculateCjjx Err:" + err.Error()
|
|
|
+ break
|
|
|
+ }
|
|
|
|
|
|
default:
|
|
|
br.Msg = "来源异常,请联系相关开发!"
|