|
@@ -5,6 +5,7 @@ import (
|
|
|
"github.com/beego/beego/v2/client/orm"
|
|
|
"hongze/hongze_edb_lib/services/alarm_msg"
|
|
|
"hongze/hongze_edb_lib/utils"
|
|
|
+ "strconv"
|
|
|
"strings"
|
|
|
"time"
|
|
|
)
|
|
@@ -29,7 +30,7 @@ type AddAdjustEdbData struct {
|
|
|
}
|
|
|
|
|
|
// SaveAdjustEdb 保存数据调整指标
|
|
|
-func SaveAdjustEdb(req SaveAdjustEdbReq, edbCode, uniqueCode string) (edbInfo *EdbInfo, err error, errMsg string) {
|
|
|
+func SaveAdjustEdb(req SaveAdjustEdbReq) (edbInfo *EdbInfo, err error, errMsg string) {
|
|
|
errMsg = `添加指标失败`
|
|
|
o := orm.NewOrm()
|
|
|
to, err := o.Begin()
|
|
@@ -46,7 +47,15 @@ func SaveAdjustEdb(req SaveAdjustEdbReq, edbCode, uniqueCode string) (edbInfo *E
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
+ var edbCode string
|
|
|
if req.EdbInfoId <= 0 {
|
|
|
+ //指标code生成
|
|
|
+ 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 = &EdbInfo{
|
|
|
Source: utils.DATA_SOURCE_CALCULATE_ADJUST,
|
|
|
SourceName: "数据调整",
|
|
@@ -116,6 +125,9 @@ func SaveAdjustEdb(req SaveAdjustEdbReq, edbCode, uniqueCode string) (edbInfo *E
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+ // 指标code
|
|
|
+ edbCode = edbInfo.EdbCode
|
|
|
+
|
|
|
// 清除数据
|
|
|
dataTableName := GetEdbDataTableName(utils.DATA_SOURCE_CALCULATE_ADJUST)
|
|
|
deleteSql := ` DELETE FROM %s WHERE edb_info_id=? `
|