|
@@ -1,12 +1,13 @@
|
|
|
package data_manage
|
|
|
|
|
|
import (
|
|
|
+ "eta/eta_mobile/models/mgo"
|
|
|
"eta/eta_mobile/services/alarm_msg"
|
|
|
"eta/eta_mobile/utils"
|
|
|
"fmt"
|
|
|
"github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/rdlucklib/rdluck_tools/paging"
|
|
|
- "strconv"
|
|
|
+ "go.mongodb.org/mongo-driver/bson"
|
|
|
"strings"
|
|
|
"time"
|
|
|
)
|
|
@@ -224,26 +225,16 @@ func DeleteEdbInfoAndData(edbInfoId, source, subSource int) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- var tableName string
|
|
|
- if subSource == 0 {
|
|
|
- // 删除指标数据
|
|
|
- tableName = GetEdbDataTableName(source, subSource)
|
|
|
+ // 删除指标的明细数据
|
|
|
+ if source == utils.DATA_SOURCE_BUSINESS {
|
|
|
+ err = deleteAllEdbDataByMongo(to, edbInfoId, source, subSource)
|
|
|
} else {
|
|
|
- if source == utils.DATA_SOURCE_WIND {
|
|
|
- tableName = "edb_data_wind_wsd"
|
|
|
- } else if source == utils.DATA_SOURCE_THS {
|
|
|
- tableName = "edb_data_ths_ds"
|
|
|
- }
|
|
|
+ err = deleteAllEdbDataByMysql(to, edbInfoId, source, subSource)
|
|
|
}
|
|
|
-
|
|
|
- if tableName != "" {
|
|
|
- sql = ` DELETE FROM %s WHERE edb_info_id=? `
|
|
|
- sql = fmt.Sprintf(sql, tableName)
|
|
|
- _, err = to.Raw(sql, edbInfoId).Exec()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
}
|
|
|
+
|
|
|
//calculateTableName := GetEdbInfoCalculateTableName(source)
|
|
|
//if calculateTableName != "" {
|
|
|
// sql = ` DELETE FROM %s WHERE edb_info_id=? `
|
|
@@ -263,6 +254,42 @@ func DeleteEdbInfoAndData(edbInfoId, source, subSource int) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+// deleteAllEdbDataByMysql
|
|
|
+// @Description: 删除指标的明细数据(mysql)
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-09 13:31:54
|
|
|
+// @param to orm.TxOrmer
|
|
|
+// @param edbInfoId int
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @return err error
|
|
|
+func deleteAllEdbDataByMysql(to orm.TxOrmer, edbInfoId, source, subSource int) (err error) {
|
|
|
+ tableName := GetEdbDataTableName(source, subSource)
|
|
|
+ if tableName == `` {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ sql := fmt.Sprintf(` DELETE FROM %s WHERE edb_info_id=? `, tableName)
|
|
|
+ _, err = to.Raw(sql, edbInfoId).Exec()
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// deleteAllEdbDataByMongo
|
|
|
+// @Description: 删除指标的明细数据(mongo)
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-09 13:31:37
|
|
|
+// @param to orm.TxOrmer
|
|
|
+// @param edbInfoId int
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @return err error
|
|
|
+func deleteAllEdbDataByMongo(to orm.TxOrmer, edbInfoId, source, subSource int) (err error) {
|
|
|
+ mogDataObj := mgo.EdbDataBusiness{}
|
|
|
+ err = mogDataObj.RemoveMany(bson.M{"edb_info_id": edbInfoId})
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
func GetEdbInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT COUNT(1) AS count FROM edb_info WHERE 1=1 `
|
|
@@ -537,7 +564,35 @@ type EdbInfoMaxAndMinInfo struct {
|
|
|
LatestValue float64 `description:"最新值"`
|
|
|
}
|
|
|
|
|
|
+// GetEdbInfoMaxAndMinInfo
|
|
|
+// @Description: 获取指标最大最小值
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-07 15:34:00
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @param edbCode string
|
|
|
+// @return item *EdbInfoMaxAndMinInfo
|
|
|
+// @return err error
|
|
|
func GetEdbInfoMaxAndMinInfo(source, subSource int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
+ // 自有数据需要额外处理(从mongo获取)
|
|
|
+ if source == utils.DATA_SOURCE_BUSINESS {
|
|
|
+ return GetEdbInfoMaxAndMinInfoByMongo(source, subSource, edbCode)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 默认走mysql
|
|
|
+ return GetEdbInfoMaxAndMinInfoByMysql(source, subSource, edbCode)
|
|
|
+}
|
|
|
+
|
|
|
+// GetEdbInfoMaxAndMinInfoByMysql
|
|
|
+// @Description: 从mysql中获取指标最大最小值
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-07 15:33:43
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @param edbCode string
|
|
|
+// @return item *EdbInfoMaxAndMinInfo
|
|
|
+// @return err error
|
|
|
+func GetEdbInfoMaxAndMinInfoByMysql(source, subSource int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
sql := ``
|
|
|
tableName := GetEdbDataTableName(source, subSource)
|
|
@@ -556,88 +611,72 @@ func GetEdbInfoMaxAndMinInfo(source, subSource int, edbCode string) (item *EdbIn
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func ModifyEdbInfoMaxAndMinInfo(edbInfoId int, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` UPDATE edb_info SET start_date=?,end_date=?,min_value=?,max_value=?,is_update=2,latest_date=?,latest_value=?,modify_time=NOW() WHERE edb_info_id=? `
|
|
|
- _, err = o.Raw(sql, item.MinDate, item.MaxDate, item.MinValue, item.MaxValue, item.MaxDate, item.LatestValue, edbInfoId).Exec()
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoFilter(condition string, pars []interface{}) (list []*EdbInfoList, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT * FROM edb_info WHERE 1=1 AND edb_info_type = 0 `
|
|
|
- if condition != "" {
|
|
|
- sql += condition
|
|
|
+// GetEdbInfoMaxAndMinInfoByMongo
|
|
|
+// @Description: 从mongo中获取指标最大最小值
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-07 15:33:53
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @param edbCode string
|
|
|
+// @return item *EdbInfoMaxAndMinInfo
|
|
|
+// @return err error
|
|
|
+func GetEdbInfoMaxAndMinInfoByMongo(source, subSource int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
+ mogDataObj := new(mgo.EdbDataBusiness)
|
|
|
+ pipeline := []bson.M{
|
|
|
+ {"$match": bson.M{"edb_code": edbCode}},
|
|
|
+ {"$group": bson.M{
|
|
|
+ "_id": nil,
|
|
|
+ "min_date": bson.M{"$min": "$data_time"},
|
|
|
+ "max_date": bson.M{"$max": "$data_time"},
|
|
|
+ "min_value": bson.M{"$min": "$value"},
|
|
|
+ "max_value": bson.M{"$max": "$value"},
|
|
|
+ }},
|
|
|
+ {"$project": bson.M{"_id": 0}}, // 可选,如果不需要_id字段
|
|
|
+ }
|
|
|
+ result, err := mogDataObj.GetEdbInfoMaxAndMinInfo(pipeline)
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println("EdbDataBusiness getEdbDataBusinessList Err:" + err.Error())
|
|
|
+ return
|
|
|
}
|
|
|
- sql += ` ORDER BY create_time DESC `
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&list)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-//order:1升序,其余值为降序
|
|
|
-func GetEdbDataListAll(condition string, pars []interface{}, source, subSource, order int) (item []*EdbInfoSearchData, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ``
|
|
|
- tableName := GetEdbDataTableName(source, subSource)
|
|
|
- sql = ` SELECT * FROM %s WHERE 1=1 `
|
|
|
- sql = fmt.Sprintf(sql, tableName)
|
|
|
|
|
|
- if condition != "" {
|
|
|
- sql += condition
|
|
|
+ if !result.MaxDate.IsZero() {
|
|
|
+ whereQuery := bson.M{"edb_code": edbCode, "data_time": result.MaxDate}
|
|
|
+ selectParam := bson.D{{"value", 1}, {"_id", 0}}
|
|
|
+ latestValue, tmpErr := mogDataObj.GetLatestValue(whereQuery, selectParam)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ result.LatestValue = latestValue.Value
|
|
|
+ result.EndValue = latestValue.Value
|
|
|
}
|
|
|
- if order == 1 {
|
|
|
- sql += ` ORDER BY data_time ASC `
|
|
|
- } else {
|
|
|
- sql += ` ORDER BY data_time DESC `
|
|
|
+
|
|
|
+ item = &EdbInfoMaxAndMinInfo{
|
|
|
+ MinDate: result.MinDate.Format(utils.FormatDate),
|
|
|
+ MaxDate: result.MaxDate.Format(utils.FormatDate),
|
|
|
+ MinValue: result.MinValue,
|
|
|
+ MaxValue: result.MaxValue,
|
|
|
+ LatestValue: result.LatestValue,
|
|
|
}
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// GetLastEdbData 获取最近的一条指标数据
|
|
|
-func GetLastEdbData(condition string, pars []interface{}, source, subSource int) (item *EdbInfoSearchData, err error) {
|
|
|
+func ModifyEdbInfoMaxAndMinInfo(edbInfoId int, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ``
|
|
|
- tableName := GetEdbDataTableName(source, subSource)
|
|
|
- sql = ` SELECT * FROM %s WHERE 1=1 `
|
|
|
- sql = fmt.Sprintf(sql, tableName)
|
|
|
-
|
|
|
- if condition != "" {
|
|
|
- sql += condition
|
|
|
- }
|
|
|
- sql += ` ORDER BY data_time DESC `
|
|
|
- err = o.Raw(sql, pars).QueryRow(&item)
|
|
|
+ sql := ` UPDATE edb_info SET start_date=?,end_date=?,min_value=?,max_value=?,is_update=2,latest_date=?,latest_value=?,modify_time=NOW() WHERE edb_info_id=? `
|
|
|
+ _, err = o.Raw(sql, item.MinDate, item.MaxDate, item.MinValue, item.MaxValue, item.MaxDate, item.LatestValue, edbInfoId).Exec()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//order:1升序,其余值为降序
|
|
|
-func GetEdbDataCount(condition string, pars []interface{}, source, subSource int) (count int, err error) {
|
|
|
+func GetEdbInfoFilter(condition string, pars []interface{}) (list []*EdbInfoList, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ``
|
|
|
- tableName := GetEdbDataTableName(source, subSource)
|
|
|
- sql = ` SELECT COUNT(1) AS count FROM %s WHERE 1=1 `
|
|
|
- sql = fmt.Sprintf(sql, tableName)
|
|
|
-
|
|
|
+ sql := ` SELECT * FROM edb_info WHERE 1=1 AND edb_info_type = 0 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func ModifyCalculateEdbInfo(item *EditEdbInfoReq) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` UPDATE edb_info
|
|
|
- SET
|
|
|
- edb_name =?,
|
|
|
- edb_name_source =?,
|
|
|
- frequency = ?,
|
|
|
- unit = ?,
|
|
|
- classify_id = ?,
|
|
|
- calculate_formula=?,
|
|
|
- modify_time = NOW()
|
|
|
- WHERE edb_info_id = ?`
|
|
|
- _, err = o.Raw(sql, item.EdbName, item.EdbName, item.Frequency, item.Unit, item.ClassifyId, item.CalculateFormula, item.EdbInfoId).Exec()
|
|
|
+ sql += ` ORDER BY create_time DESC `
|
|
|
+ _, err = o.Raw(sql, pars).QueryRows(&list)
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -648,69 +687,6 @@ type AddEdbInfoResp struct {
|
|
|
ExistEdbName []string `description:"重复指标名称"`
|
|
|
}
|
|
|
|
|
|
-// 根据基础指标获取所有关联指标
|
|
|
-func GetNeedRefreshCalculateEdbInfoFromBase(fromEdbInfo int) (list []*EdbInfo, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT b.*
|
|
|
- FROM edb_info_calculate AS a
|
|
|
- INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
- WHERE from_edb_info_id=? `
|
|
|
- _, err = o.Raw(sql, fromEdbInfo).QueryRows(&list)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoCalculateCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate WHERE from_edb_info_id=? `
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoCalculateLjzzyCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_ljzzy WHERE from_edb_info_id=? `
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoCalculateTbzCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_tbz WHERE from_edb_info_id=? `
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoCalculateTczCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_tcz WHERE from_edb_info_id=? `
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoCalculateNszydpjjsCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_nszydpjjs WHERE from_edb_info_id=? `
|
|
|
- err = o.Raw(sql, edbInfoId).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbInfoCalculateCountByCondition(source int, condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- //calculateTableName := GetEdbInfoCalculateTableName(source)
|
|
|
- //if calculateTableName == "" {
|
|
|
- // err = errors.New("无效的表名")
|
|
|
- // return
|
|
|
- //}
|
|
|
-
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM edb_info_calculate_mapping WHERE 1=1 `
|
|
|
- //sql = fmt.Sprintf(sql, calculateTableName)
|
|
|
- if condition != "" {
|
|
|
- sql += condition
|
|
|
- }
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
// GetEdbInfoCalculateListByCondition 获取指标关系列表
|
|
|
func GetEdbInfoCalculateListByCondition(condition string, pars []interface{}) (items []*EdbInfoCalculateMapping, err error) {
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
@@ -729,36 +705,6 @@ func GetEdbInfoCalculateListByCondition(condition string, pars []interface{}) (i
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func GetRefreshEdbInfoFromCalculate(edbInfoId, source int) (baseEdbInfoArr, calculateInfoArr []*EdbInfo, err error) {
|
|
|
- calculateList, err := GetEdbInfoCalculateMap(edbInfoId, source)
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
- return
|
|
|
- }
|
|
|
- for _, item := range calculateList {
|
|
|
- if item.EdbType == 1 {
|
|
|
- baseEdbInfoArr = append(baseEdbInfoArr, item)
|
|
|
- } else {
|
|
|
- calculateInfoArr = append(calculateInfoArr, item)
|
|
|
- newBaseEdbInfoArr, newCalculateInfoArr, _ := GetRefreshEdbInfoFromCalculate(item.EdbInfoId, item.Source)
|
|
|
- baseEdbInfoArr = append(baseEdbInfoArr, newBaseEdbInfoArr...)
|
|
|
- calculateInfoArr = append(calculateInfoArr, newCalculateInfoArr...)
|
|
|
- }
|
|
|
- }
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-// 获取基础指标对应的所有计算指标
|
|
|
-func GetEdbInfoAllCalculate(edbInfoId int) (list []*EdbInfo, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT b.* FROM edb_info_calculate_mapping AS a
|
|
|
- INNER JOIN edb_info AS b ON a.edb_info_id=b.edb_info_id
|
|
|
- WHERE a.from_edb_info_id=?
|
|
|
- GROUP BY a.edb_info_id
|
|
|
- ORDER BY a.edb_info_id ASC `
|
|
|
- _, err = o.Raw(sql, edbInfoId).QueryRows(&list)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
// GetEdbInfoAllCalculateByEdbInfoIdList 根据指标id集合 获取基础指标对应的所有计算指标
|
|
|
func GetEdbInfoAllCalculateByEdbInfoIdList(edbInfoIdList []int) (list []*EdbInfo, err error) {
|
|
|
num := len(edbInfoIdList)
|
|
@@ -1010,341 +956,6 @@ func ReplaceChartEdb(oldEdbInfo, newEdbInfo *EdbInfo) (relationEdbInfoIdList []i
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// replaceRelationEdbInfo 替换关联指标
|
|
|
-func replaceRelationEdbInfo(mappingList []*EdbInfoCalculateMapping, oldEdbInfo, newEdbInfo *EdbInfo, sysAdminId int, sysAdminRealName string) (err error) {
|
|
|
- errmsg := ``
|
|
|
- defer func() {
|
|
|
- if errmsg != "" {
|
|
|
- fmt.Println("errmsg:" + errmsg)
|
|
|
- }
|
|
|
- if err != nil && errmsg != "" {
|
|
|
- go alarm_msg.SendAlarmMsg("替换关联指标失败提醒,errmsg:"+errmsg, 3)
|
|
|
- //go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"替换指标失败提醒", "errmsg:"+errmsg, utils.EmailSendToUsers)
|
|
|
- }
|
|
|
- }()
|
|
|
- //获取计算指标关联指标
|
|
|
- allMappingList := make([]*EdbInfoCalculateMapping, 0)
|
|
|
- allMapping := make(map[int]int)
|
|
|
- tmpMapping := make(map[int]int)
|
|
|
- for _, v := range mappingList {
|
|
|
- if _, ok := allMapping[v.EdbInfoId]; !ok {
|
|
|
- allMappingList = append(allMappingList, v)
|
|
|
- }
|
|
|
- newList, _ := GetAllCalculateV2(v.EdbInfoId, newEdbInfo.EdbInfoId, tmpMapping)
|
|
|
- for _, nv := range newList {
|
|
|
- if _, ok := allMapping[v.EdbInfoId]; !ok {
|
|
|
- allMappingList = append(allMappingList, nv)
|
|
|
- }
|
|
|
- allMapping[v.EdbInfoId] = v.EdbInfoId
|
|
|
- }
|
|
|
- allMapping[v.EdbInfoId] = v.EdbInfoId
|
|
|
- }
|
|
|
- for mk, mv := range allMappingList { //原指标关联的所有计算指标
|
|
|
- fmt.Println("mk/mv", mk, mv)
|
|
|
- //重新计算计算指标
|
|
|
- {
|
|
|
- edbInfo, tmpErr := GetEdbInfoById(mv.EdbInfoId) //计算指标
|
|
|
- err = tmpErr
|
|
|
- if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
- errmsg = "计算指标已被删除"
|
|
|
- } else {
|
|
|
- errmsg = "获取计算指标失败:err:" + err.Error()
|
|
|
- }
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- fromEdbInfoList, tmpErr := GetEdbInfoCalculateDetail(mv.EdbInfoId, edbInfo.Source)
|
|
|
- err = tmpErr
|
|
|
- if err != nil {
|
|
|
- errmsg = "获取计算指标失败:err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- if len(fromEdbInfoList) <= 0 {
|
|
|
- errmsg = "计算指标所依赖指标不存在"
|
|
|
- err = fmt.Errorf("计算指标所依赖指标不存在")
|
|
|
- return
|
|
|
- }
|
|
|
- fromEdbInfoItem := fromEdbInfoList[0]
|
|
|
- if fromEdbInfoItem == nil {
|
|
|
- return
|
|
|
- }
|
|
|
- fromEdbInfo, tmpErr := GetEdbInfoById(fromEdbInfoItem.FromEdbInfoId)
|
|
|
- err = tmpErr
|
|
|
- if err != nil {
|
|
|
- errmsg = "获取计算指标 来源指标失败:err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- edbCode := edbInfo.EdbCode
|
|
|
- uniqueCode := edbInfo.UniqueCode
|
|
|
- sourName := edbInfo.SourceName
|
|
|
- source := edbInfo.Source
|
|
|
- subSource := edbInfo.SubSource
|
|
|
- edbInfoId := edbInfo.EdbInfoId
|
|
|
-
|
|
|
- req := new(EdbInfoCalculateBatchSaveReq)
|
|
|
- req.EdbInfoId = edbInfoId
|
|
|
- req.EdbName = edbInfo.EdbName
|
|
|
- req.Frequency = edbInfo.Frequency
|
|
|
- req.Unit = edbInfo.Unit
|
|
|
- req.ClassifyId = edbInfo.ClassifyId
|
|
|
- req.FromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
|
|
|
-
|
|
|
- if source == utils.DATA_SOURCE_CALCULATE {
|
|
|
- //检验公式
|
|
|
- var formulaStr string
|
|
|
- var edbInfoIdBytes []string
|
|
|
- for _, v := range fromEdbInfoList {
|
|
|
- formulaStr += v.FromTag + ","
|
|
|
- edbInfoIdBytes = append(edbInfoIdBytes, v.FromTag)
|
|
|
- }
|
|
|
- formulaStr = strings.Trim(formulaStr, ",")
|
|
|
- formulaMap := CheckFormula(edbInfo.CalculateFormula)
|
|
|
- for _, v := range formulaMap {
|
|
|
- if !strings.Contains(formulaStr, v) {
|
|
|
- errmsg = "公式错误,请重新填写"
|
|
|
- err = fmt.Errorf("公式错误,请重新填写")
|
|
|
- return
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- edbInfoList := make([]*EdbInfo, 0)
|
|
|
-
|
|
|
- for _, v := range fromEdbInfoList {
|
|
|
- edbInfo, tmpErr := GetEdbInfoById(v.FromEdbInfoId)
|
|
|
- err = tmpErr
|
|
|
- if err != nil {
|
|
|
- if err.Error() == utils.ErrNoRow() {
|
|
|
- errmsg = "指标 " + strconv.Itoa(v.FromEdbInfoId) + " 不存在"
|
|
|
- } else {
|
|
|
- errmsg = "获取指标失败:Err:" + err.Error()
|
|
|
- }
|
|
|
- return
|
|
|
- }
|
|
|
- edbInfoList = append(edbInfoList, edbInfo)
|
|
|
- }
|
|
|
- //清除历史数据
|
|
|
- err = DeleteCalculateData(edbInfoId)
|
|
|
- if err != nil {
|
|
|
- errmsg = "清空运算指标失败:Err:" + err.Error() + " edb_info_id:" + strconv.Itoa(edbInfoId)
|
|
|
- return
|
|
|
- }
|
|
|
- err = Calculate(edbInfoList, int(edbInfoId), edbCode, edbInfo.CalculateFormula, edbInfoIdBytes)
|
|
|
- if err != nil {
|
|
|
- errmsg = "生成计算指标失败,Calculate Err:" + err.Error()
|
|
|
- return
|
|
|
- }
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_LJZZY {
|
|
|
- _, err = AddCalculateLjzzy(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_TBZ {
|
|
|
- sourName = "同比值"
|
|
|
- edbInfoId, err = AddCalculateTbz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_TCZ {
|
|
|
- sourName = "同差值"
|
|
|
- edbInfoId, err = AddCalculateTcz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_NSZYDPJJS {
|
|
|
- sourName = "N数值移动平均计算"
|
|
|
- formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
|
- edbInfoId, err = AddCalculateNszydpjjs(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_HBZ {
|
|
|
- sourName = "环比值"
|
|
|
- formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
|
- edbInfoId, err = AddCalculateHbz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_HCZ {
|
|
|
- sourName = "环差值"
|
|
|
- formulaInt, _ := strconv.Atoi(edbInfo.CalculateFormula)
|
|
|
- edbInfoId, err = AddCalculateHcz(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName, formulaInt)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_BP {
|
|
|
- sourName = "变频"
|
|
|
- fmt.Println("变频", req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
|
|
|
- edbInfoId, err = AddCalculateBp(req, fromEdbInfo, edbCode, uniqueCode, sysAdminId, sysAdminRealName)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_TIME_SHIFT {
|
|
|
- req2 := &EdbInfoCalculateBatchEditReq{
|
|
|
- EdbName: edbInfo.EdbName,
|
|
|
- Frequency: edbInfo.Frequency,
|
|
|
- Unit: edbInfo.Unit,
|
|
|
- ClassifyId: edbInfo.ClassifyId,
|
|
|
- Formula: edbInfo.CalculateFormula,
|
|
|
- EdbInfoId: edbInfo.EdbInfoId,
|
|
|
- FromEdbInfoId: fromEdbInfoList[0].FromEdbInfoId,
|
|
|
- Source: edbInfo.Source,
|
|
|
- MoveType: edbInfo.MoveType,
|
|
|
- MoveFrequency: edbInfo.MoveFrequency,
|
|
|
- }
|
|
|
- sourName = "时间移位"
|
|
|
- edbInfoId, err = EditCalculateTimeShift(req2, fromEdbInfo, edbCode, edbInfo)
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_ZJPJ {
|
|
|
- edbInfoIdArr := make([]EdbInfoFromTag, 0)
|
|
|
- //A指标
|
|
|
- aFromEdbInfoId := fromEdbInfoList[0].FromEdbInfoId
|
|
|
- for _, v := range fromEdbInfoList {
|
|
|
- if v.FromTag == "A" {
|
|
|
- if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
|
|
|
- aFromEdbInfoId = newEdbInfo.EdbInfoId
|
|
|
- } else {
|
|
|
- aFromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
|
|
|
- }
|
|
|
- }
|
|
|
- if v.FromTag == "B" {
|
|
|
- if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
|
|
|
- edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
|
|
|
- EdbInfoId: newEdbInfo.EdbInfoId,
|
|
|
- FromTag: v.FromTag,
|
|
|
- MoveValue: v.MoveValue,
|
|
|
- })
|
|
|
- } else {
|
|
|
- edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
|
|
|
- EdbInfoId: v.FromEdbInfoId,
|
|
|
- FromTag: v.FromTag,
|
|
|
- MoveValue: v.MoveValue,
|
|
|
- })
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- req2 := &EdbInfoCalculateBatchEditReq{
|
|
|
- EdbName: edbInfo.EdbName,
|
|
|
- Frequency: edbInfo.Frequency,
|
|
|
- Unit: edbInfo.Unit,
|
|
|
- ClassifyId: edbInfo.ClassifyId,
|
|
|
- Formula: edbInfo.CalculateFormula,
|
|
|
- EdbInfoId: edbInfo.EdbInfoId,
|
|
|
- FromEdbInfoId: aFromEdbInfoId,
|
|
|
- Source: edbInfo.Source,
|
|
|
- MoveType: edbInfo.MoveType,
|
|
|
- MoveFrequency: edbInfo.MoveFrequency,
|
|
|
- EdbInfoIdArr: edbInfoIdArr,
|
|
|
- }
|
|
|
-
|
|
|
- sourName = "直接拼接"
|
|
|
- if len(req2.EdbInfoIdArr) != 1 {
|
|
|
- errmsg = "请传入拼接日期之后的指标"
|
|
|
- err = fmt.Errorf("请传入拼接日期之后的指标")
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- secondEdbInfoReq := req2.EdbInfoIdArr[0]
|
|
|
- secondEdbInfo, tmpErr := GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
|
|
|
- err = tmpErr
|
|
|
- if err != nil {
|
|
|
- errmsg = "获取拼接日期之后的指标信息失败:Err:" + err.Error()
|
|
|
- err = fmt.Errorf("获取拼接日期之后的指标信息失败:Err:" + err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- if fromEdbInfo.EdbInfoId == secondEdbInfo.EdbInfoId {
|
|
|
- errmsg = "两个指标不允许为同一个"
|
|
|
- err = fmt.Errorf("两个指标不允许为同一个")
|
|
|
- return
|
|
|
- }
|
|
|
- tmpEdbInfoId, tmpErr := EditCalculateZjpj(req2, edbInfo, fromEdbInfo, secondEdbInfo)
|
|
|
- err = tmpErr
|
|
|
- edbInfoId = tmpEdbInfoId
|
|
|
- } else if source == utils.DATA_SOURCE_CALCULATE_LJZTBPJ { //累计值同比拼接
|
|
|
- edbInfoIdArr := make([]EdbInfoFromTag, 0)
|
|
|
- //A指标
|
|
|
- aFromEdbInfoId := fromEdbInfoList[0].FromEdbInfoId
|
|
|
- for _, v := range fromEdbInfoList {
|
|
|
- if v.FromTag == "A" {
|
|
|
- if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
|
|
|
- aFromEdbInfoId = newEdbInfo.EdbInfoId
|
|
|
- } else {
|
|
|
- aFromEdbInfoId = fromEdbInfoList[0].FromEdbInfoId
|
|
|
- }
|
|
|
- }
|
|
|
- if v.FromTag == "B" {
|
|
|
- if v.FromEdbInfoId == oldEdbInfo.EdbInfoId {
|
|
|
- edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
|
|
|
- EdbInfoId: newEdbInfo.EdbInfoId,
|
|
|
- FromTag: v.FromTag,
|
|
|
- MoveValue: v.MoveValue,
|
|
|
- })
|
|
|
- } else {
|
|
|
- edbInfoIdArr = append(edbInfoIdArr, EdbInfoFromTag{
|
|
|
- EdbInfoId: v.FromEdbInfoId,
|
|
|
- FromTag: v.FromTag,
|
|
|
- MoveValue: v.MoveValue,
|
|
|
- })
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- req2 := &EdbInfoCalculateBatchEditReq{
|
|
|
- EdbName: edbInfo.EdbName,
|
|
|
- Frequency: edbInfo.Frequency,
|
|
|
- Unit: edbInfo.Unit,
|
|
|
- ClassifyId: edbInfo.ClassifyId,
|
|
|
- Formula: edbInfo.CalculateFormula,
|
|
|
- EdbInfoId: edbInfo.EdbInfoId,
|
|
|
- FromEdbInfoId: aFromEdbInfoId,
|
|
|
- Source: edbInfo.Source,
|
|
|
- MoveType: edbInfo.MoveType,
|
|
|
- MoveFrequency: edbInfo.MoveFrequency,
|
|
|
- EdbInfoIdArr: edbInfoIdArr,
|
|
|
- }
|
|
|
-
|
|
|
- sourName = "累计值同比拼接"
|
|
|
-
|
|
|
- if fromEdbInfo.Frequency != "月度" {
|
|
|
- errmsg = "累计值同比拼接,待拼接指标只能筛选月度指标"
|
|
|
- err = fmt.Errorf("累计值同比拼接,待拼接指标只能筛选月度指标")
|
|
|
- return
|
|
|
- }
|
|
|
- if len(req2.EdbInfoIdArr) != 1 {
|
|
|
- errmsg = "请传入同比值指标"
|
|
|
- err = fmt.Errorf("请传入同比值指标")
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- secondEdbInfoReq := req2.EdbInfoIdArr[0]
|
|
|
- tbzEdbInfo, tmpErr := GetEdbInfoById(secondEdbInfoReq.EdbInfoId)
|
|
|
- err = tmpErr
|
|
|
- if err != nil {
|
|
|
- errmsg = "获取同比值指标信息失败:Err:" + err.Error()
|
|
|
- err = fmt.Errorf("获取同比值指标信息失败:Err:" + err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- if tbzEdbInfo.Source != utils.DATA_SOURCE_CALCULATE_TBZ {
|
|
|
- errmsg = "指标必须是传入同比值指标类型"
|
|
|
- err = fmt.Errorf("指标必须是传入同比值指标类型")
|
|
|
- return
|
|
|
- }
|
|
|
- if tbzEdbInfo.Frequency != "月度" {
|
|
|
- errmsg = "同比值指标只能筛选月度指标"
|
|
|
- err = fmt.Errorf("同比值指标只能筛选月度指标")
|
|
|
- return
|
|
|
- }
|
|
|
-
|
|
|
- if fromEdbInfo.EdbInfoId == tbzEdbInfo.EdbInfoId {
|
|
|
- errmsg = "两个指标不允许为同一个"
|
|
|
- err = fmt.Errorf("两个指标不允许为同一个")
|
|
|
- return
|
|
|
- }
|
|
|
- tmpEdbInfoId, tmpErr := EditCalculateLjztbpj(req2, edbInfo, fromEdbInfo, tbzEdbInfo)
|
|
|
- err = tmpErr
|
|
|
- edbInfoId = tmpEdbInfoId
|
|
|
- } else if source == utils.DATA_SOURCE_PYTHON {
|
|
|
- //python代码运算的过滤
|
|
|
- continue
|
|
|
- } else {
|
|
|
- errmsg = "无效计算方式,source:" + strconv.Itoa(source)
|
|
|
- err = fmt.Errorf("无效计算方式,source:" + strconv.Itoa(source))
|
|
|
- return
|
|
|
- }
|
|
|
- maxAndMinItem, tmpErr := GetEdbInfoMaxAndMinInfo(source, subSource, edbCode)
|
|
|
- err = tmpErr
|
|
|
- if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
- errmsg = "生成" + sourName + "失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error()
|
|
|
- err = fmt.Errorf("生成" + sourName + "失败,GetEdbInfoMaxAndMinInfo Err:" + err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- if maxAndMinItem != nil {
|
|
|
- err = ModifyEdbInfoMaxAndMinInfo(edbInfoId, maxAndMinItem)
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
type EdbInfoView struct {
|
|
|
EdbInfoId int `orm:"column(edb_info_id);pk"`
|
|
|
EdbInfoType int `description:"指标类型,0:普通指标,1:预测指标"`
|
|
@@ -1710,6 +1321,7 @@ type EdbAndClassify struct {
|
|
|
EdbCode string `description:"指标code"`
|
|
|
UniqueCode string `description:"唯一code"`
|
|
|
EdbName string `description:"指标名称"`
|
|
|
+ ClassifyId int `description:"所属分类id"`
|
|
|
FirstClassifyId int `description:"第1级的分类id"`
|
|
|
FirstClassifyName string `description:"第1级的分类名称"`
|
|
|
SecondClassifyId int `description:"第2级的分类id"`
|
|
@@ -1723,9 +1335,7 @@ func GetEdbInfoAndClassifyListByEdbIdList(edbIdList []int) (items []*EdbAndClass
|
|
|
return
|
|
|
}
|
|
|
o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT a.edb_info_id,a.edb_code,a.unique_code,a.edb_name,b.classify_id as second_classify_id,b.classify_name as second_classify_name,c.classify_id as first_classify_id,c.classify_name as first_classify_name FROM edb_info AS a
|
|
|
- JOIN edb_classify b on a.classify_id=b.classify_id
|
|
|
- JOIN edb_classify c on b.parent_id=c.classify_id
|
|
|
+ sql := ` SELECT a.edb_info_id,a.edb_code,a.unique_code,a.edb_name,a.classify_id FROM edb_info AS a
|
|
|
WHERE a.edb_info_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
|
|
|
_, err = o.Raw(sql, edbIdList).QueryRows(&items)
|
|
@@ -1921,3 +1531,121 @@ func GetEdbInfoCount(source int, edbCode string) (count int, err error) {
|
|
|
err = o.Raw(sql, source, edbCode).QueryRow(&count)
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+// GetEdbInfoByNameArr 根据名称获取指标
|
|
|
+func GetEdbInfoByNameArr(names []string, edbInfoType int) (items []*EdbInfo, err error) {
|
|
|
+ if len(names) == 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := fmt.Sprintf(`SELECT edb_info_id, edb_code, edb_name FROM edb_info WHERE edb_name IN (%s) AND edb_info_type = ? `, utils.GetOrmInReplace(len(names)))
|
|
|
+ _, err = o.Raw(sql, names, edbInfoType).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// GetEdbCodesBySource 根据来源获取指标编码
|
|
|
+func GetEdbCodesBySource(source int) (items []*EdbInfo, err error) {
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
+ sql := ` SELECT edb_info_id, edb_code, unique_code, classify_id FROM edb_info WHERE source = ? `
|
|
|
+ _, err = o.Raw(sql, source).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// GetAllEdbDataListData
|
|
|
+// @Description: 获取指标的所有数据
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-07 15:18:27
|
|
|
+// @param edbInfoId int
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @param startDataTime string
|
|
|
+// @return dataList []*EdbData
|
|
|
+// @return err error
|
|
|
+func GetAllEdbDataListData(edbInfoId, source, subSource int, startDataTime string) (dataList []*EdbData, err error) {
|
|
|
+ // 自有数据需要额外处理(从mongo获取)
|
|
|
+ if source == utils.DATA_SOURCE_BUSINESS {
|
|
|
+ return getAllDataByMongo(edbInfoId, source, subSource, startDataTime)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 默认走mysql
|
|
|
+ return getAllDataByMysql(edbInfoId, source, subSource, startDataTime)
|
|
|
+}
|
|
|
+
|
|
|
+// getAllDataByMysql
|
|
|
+// @Description: 从mysql获取指标的所有数据
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-07 15:18:41
|
|
|
+// @param edbInfoId int
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @param startDataTime string
|
|
|
+// @return dataList []*data_manage.EdbData
|
|
|
+// @return err error
|
|
|
+func getAllDataByMysql(edbInfoId, source, subSource int, startDataTime string) (dataList []*EdbData, err error) {
|
|
|
+ dataList = make([]*EdbData, 0)
|
|
|
+ var dataCondition string
|
|
|
+ var dataPars []interface{}
|
|
|
+
|
|
|
+ dataCondition += ` AND edb_info_id=? `
|
|
|
+ dataPars = append(dataPars, edbInfoId)
|
|
|
+
|
|
|
+ // 结束日期
|
|
|
+ if startDataTime != "" {
|
|
|
+ dataCondition += ` AND data_time > ? `
|
|
|
+ dataPars = append(dataPars, startDataTime)
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取列表数据
|
|
|
+ dataList, err = GetAllEdbDataListByCondition(dataCondition, dataPars, source, subSource)
|
|
|
+ if err != nil {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// getAllDataByMongo
|
|
|
+// @Description: 从mongo获取指标的所有数据
|
|
|
+// @author: Roc
|
|
|
+// @datetime 2024-05-07 15:18:53
|
|
|
+// @param edbInfoId int
|
|
|
+// @param source int
|
|
|
+// @param subSource int
|
|
|
+// @param startDataTime string
|
|
|
+// @return dataList []*data_manage.EdbData
|
|
|
+// @return err error
|
|
|
+func getAllDataByMongo(edbInfoId, source, subSource int, startDataTime string) (dataList []*EdbData, err error) {
|
|
|
+ dataList = make([]*EdbData, 0)
|
|
|
+
|
|
|
+ mogDataObj := mgo.EdbDataBusiness{}
|
|
|
+ // 构建查询条件
|
|
|
+ queryConditions := bson.M{
|
|
|
+ "edb_info_id": edbInfoId,
|
|
|
+ }
|
|
|
+ // 结束日期
|
|
|
+ if startDataTime != "" {
|
|
|
+ startDateTime, tmpErr := time.ParseInLocation(utils.FormatDate, startDataTime, time.Local)
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ queryConditions["data_time"] = bson.M{"$gt": startDateTime}
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取列表数据
|
|
|
+ tmpDataList, tmpErr := mogDataObj.GetAllDataList(queryConditions, []string{"-data_time"})
|
|
|
+ if tmpErr != nil {
|
|
|
+ err = tmpErr
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for k, v := range tmpDataList {
|
|
|
+ dataList = append(dataList, &EdbData{
|
|
|
+ EdbDataId: k + 1,
|
|
|
+ EdbInfoId: v.EdbInfoId,
|
|
|
+ DataTime: v.DataTime.Format(utils.FormatDate),
|
|
|
+ Value: v.Value,
|
|
|
+ })
|
|
|
+ }
|
|
|
+
|
|
|
+ return
|
|
|
+}
|