|
@@ -37,8 +37,7 @@ type EdbInfo struct {
|
|
|
}
|
|
|
|
|
|
func AddEdbInfo(item *EdbInfo) (lastId int64, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
lastId, err = o.Insert(item)
|
|
|
return
|
|
|
}
|
|
@@ -51,8 +50,7 @@ type EdbInfoItem struct {
|
|
|
|
|
|
//用于分类展示
|
|
|
func GetEdbInfoAll() (items []*EdbClassifyItems, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT edb_info_id,classify_id,edb_name_source AS classify_name,unique_code,source_name,source,sys_user_id,sys_user_real_name,start_date,edb_code,edb_type FROM edb_info order by sort asc,edb_info_id asc`
|
|
|
_, err = o.Raw(sql).QueryRows(&items)
|
|
|
return
|
|
@@ -60,8 +58,7 @@ func GetEdbInfoAll() (items []*EdbClassifyItems, err error) {
|
|
|
|
|
|
//用于分类展示
|
|
|
func GetEdbInfoAllList() (items []*EdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info `
|
|
|
_, err = o.Raw(sql).QueryRows(&items)
|
|
|
return
|
|
@@ -90,16 +87,14 @@ type EdbInfoSearchResp struct {
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoByEdbCode(source int, edbCode string) (item *EdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE source=? AND edb_code=? `
|
|
|
err = o.Raw(sql, source, edbCode).QueryRow(&item)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoById(edbInfoId int) (item *EdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE edb_info_id=? `
|
|
|
err = o.Raw(sql, edbInfoId).QueryRow(&item)
|
|
|
return
|
|
@@ -117,8 +112,7 @@ type AddEdbInfoReq struct {
|
|
|
}
|
|
|
|
|
|
func DeleteEdbInfoAndData(edbInfoId, source int) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
o.Begin()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
@@ -156,8 +150,7 @@ func DeleteEdbInfoAndData(edbInfoId, source int) (err error) {
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT COUNT(1) AS count FROM edb_info WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -176,8 +169,7 @@ type EditEdbInfoReq struct {
|
|
|
}
|
|
|
|
|
|
func ModifyEdbInfo(item *EditEdbInfoReq) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` UPDATE edb_info
|
|
|
SET
|
|
|
edb_name =?,
|
|
@@ -225,8 +217,7 @@ type EdbInfoListResp struct {
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoByCondition(condition string, pars []interface{}) (item *EdbInfoList, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -236,8 +227,7 @@ func GetEdbInfoByCondition(condition string, pars []interface{}) (item *EdbInfoL
|
|
|
}
|
|
|
|
|
|
func GetEdbDataCountByCondition(condition string, pars []interface{}, source int) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql := ` SELECT COUNT(1) AS count FROM %s WHERE 1=1 AND status=1 `
|
|
|
sql = fmt.Sprintf(sql, tableName)
|
|
@@ -249,8 +239,7 @@ func GetEdbDataCountByCondition(condition string, pars []interface{}, source int
|
|
|
}
|
|
|
|
|
|
func GetEdbDataListByCondition(condition string, pars []interface{}, source, pageSize, startSize int) (item []*EdbData, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql := ` SELECT * FROM %s WHERE 1=1 AND status=1 `
|
|
|
sql = fmt.Sprintf(sql, tableName)
|
|
@@ -265,16 +254,14 @@ func GetEdbDataListByCondition(condition string, pars []interface{}, source, pag
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoByNewest() (item *EdbInfoList, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE 1=1 ORDER BY modify_time DESC LIMIT 1 `
|
|
|
err = o.Raw(sql).QueryRow(&item)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func ModifyEdbInfoModifyTime(edbInfoId int64) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` UPDATE edb_info SET modify_time = NOW() WHERE edb_info_id = ? `
|
|
|
_, err = o.Raw(sql, edbInfoId).Exec()
|
|
|
return
|
|
@@ -288,8 +275,7 @@ type MoveEdbInfoReq struct {
|
|
|
}
|
|
|
|
|
|
func MoveEdbInfo(edbInfoId, classifyId int) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` UPDATE edb_info
|
|
|
SET
|
|
|
classify_id = ?
|
|
@@ -299,24 +285,21 @@ func MoveEdbInfo(edbInfoId, classifyId int) (err error) {
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoByName(edbName string) (items []*EdbInfoList, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE edb_name=? `
|
|
|
_, err = o.Raw(sql, edbName).QueryRows(&items)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func ModifyEdbInfoNameSource(edbNameSource string, edbInfoId int) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` UPDATE edb_info SET edb_name_source=? WHERE edb_info_id = ? `
|
|
|
_, err = o.Raw(sql, edbNameSource, edbInfoId).Exec()
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func GetChartEdbMappingCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT COUNT(1) AS count FROM chart_edb_mapping WHERE edb_info_id=? `
|
|
|
err = o.Raw(sql, edbInfoId).QueryRow(&count)
|
|
|
return
|
|
@@ -330,8 +313,7 @@ type ChartEdbInfo struct {
|
|
|
}
|
|
|
|
|
|
func EdbInfoSearchByKeyWord(KeyWord string) (searchList []*ChartEdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT edb_info_id,edb_name,source_name FROM edb_info `
|
|
|
if KeyWord != "" {
|
|
|
sql += `WHERE (edb_name LIKE '%` + KeyWord + `%' OR edb_code LIKE '%` + KeyWord + `%' ) `
|
|
@@ -351,8 +333,7 @@ type EdbInfoMaxAndMinInfo struct {
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoMaxAndMinInfo(source int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ``
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql = ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date,MIN(value) AS min_value,MAX(value) AS max_value FROM %s WHERE edb_code=? `
|
|
@@ -368,16 +349,14 @@ func GetEdbInfoMaxAndMinInfo(source int, edbCode string) (item *EdbInfoMaxAndMin
|
|
|
}
|
|
|
|
|
|
func ModifyEdbInfoMaxAndMinInfo(edbInfoId int, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -389,8 +368,7 @@ func GetEdbInfoFilter(condition string, pars []interface{}) (list []*EdbInfoList
|
|
|
|
|
|
//order:1升序,其余值为降序
|
|
|
func GetEdbDataListAll(condition string, pars []interface{}, source, order int) (item []*EdbInfoSearchData, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ``
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql = ` SELECT * FROM %s WHERE 1=1 `
|
|
@@ -410,8 +388,7 @@ func GetEdbDataListAll(condition string, pars []interface{}, source, order int)
|
|
|
|
|
|
// GetLastEdbData 获取最近的一条指标数据
|
|
|
func GetLastEdbData(condition string, pars []interface{}, source int) (item *EdbInfoSearchData, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ``
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql = ` SELECT * FROM %s WHERE 1=1 `
|
|
@@ -427,8 +404,7 @@ func GetLastEdbData(condition string, pars []interface{}, source int) (item *Edb
|
|
|
|
|
|
//order:1升序,其余值为降序
|
|
|
func GetEdbDataCount(condition string, pars []interface{}, source int) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ``
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql = ` SELECT COUNT(1) AS count FROM %s WHERE 1=1 `
|
|
@@ -442,8 +418,7 @@ func GetEdbDataCount(condition string, pars []interface{}, source int) (count in
|
|
|
}
|
|
|
|
|
|
func ModifyCalculateEdbInfo(item *EditEdbInfoReq) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` UPDATE edb_info
|
|
|
SET
|
|
|
edb_name =?,
|
|
@@ -465,8 +440,7 @@ type AddEdbInfoResp struct {
|
|
|
|
|
|
//根据基础指标获取所有关联指标
|
|
|
func GetNeedRefreshCalculateEdbInfoFromBase(fromEdbInfo int) (list []*EdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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
|
|
@@ -476,48 +450,42 @@ func GetNeedRefreshCalculateEdbInfoFromBase(fromEdbInfo int) (list []*EdbInfo, e
|
|
|
}
|
|
|
|
|
|
func GetEdbInfoCalculateCount(edbInfoId int) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ 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.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
//calculateTableName := GetEdbInfoCalculateTableName(source)
|
|
|
//if calculateTableName == "" {
|
|
|
// err = errors.New("无效的表名")
|
|
@@ -535,8 +503,7 @@ func GetEdbInfoCalculateCountByCondition(source int, condition string, pars []in
|
|
|
|
|
|
// GetEdbInfoCalculateListByCondition 获取指标关系列表
|
|
|
func GetEdbInfoCalculateListByCondition(condition string, pars []interface{}) (items []*EdbInfoCalculateMapping, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
//calculateTableName := GetEdbInfoCalculateTableName(source)
|
|
|
//if calculateTableName == "" {
|
|
|
// err = errors.New("无效的表名")
|
|
@@ -572,8 +539,7 @@ func GetRefreshEdbInfoFromCalculate(edbInfoId, source int) (baseEdbInfoArr, calc
|
|
|
|
|
|
//获取基础指标对应的所有计算指标
|
|
|
func GetEdbInfoAllCalculate(edbInfoId int) (list []*EdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT a.*,b.start_date,b.end_date,b.frequency 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=?
|
|
@@ -602,8 +568,7 @@ func GetRefreshEdbInfoFromBase(edbInfoId, source int) (baseEdbInfoArr, calculate
|
|
|
}
|
|
|
|
|
|
func ModifyEdbInfoDataStatus(edbInfoId int64, source int, edbCode string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ``
|
|
|
tableName := GetEdbDataTableName(source)
|
|
|
sql = ` UPDATE %s SET edb_info_id=?, status=1,modify_time=NOW() WHERE edb_code=? `
|
|
@@ -614,8 +579,7 @@ func ModifyEdbInfoDataStatus(edbInfoId int64, source int, edbCode string) (err e
|
|
|
|
|
|
// GetFirstEdbInfoByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
|
|
|
func GetFirstEdbInfoByClassifyId(classifyId int) (item *EdbInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` SELECT * FROM edb_info WHERE classify_id=? order by sort asc,edb_info_id asc limit 1`
|
|
|
err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
return
|
|
@@ -623,8 +587,7 @@ func GetFirstEdbInfoByClassifyId(classifyId int) (item *EdbInfo, err error) {
|
|
|
|
|
|
// UpdateEdbInfoSortByClassifyId 根据分类id更新排序
|
|
|
func UpdateEdbInfoSortByClassifyId(classifyId, nowSort int, prevEdbInfoId int, updateSort string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
sql := ` update edb_info set sort = ` + updateSort + ` WHERE classify_id=? and sort > ?`
|
|
|
if prevEdbInfoId > 0 {
|
|
|
sql += ` or ( edb_info_id > ` + fmt.Sprint(prevEdbInfoId) + ` and sort=` + fmt.Sprint(nowSort) + ` ) `
|
|
@@ -635,8 +598,7 @@ func UpdateEdbInfoSortByClassifyId(classifyId, nowSort int, prevEdbInfoId int, u
|
|
|
|
|
|
// Update 更新指标基础信息
|
|
|
func (edbInfo *EdbInfo) Update(cols []string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
_, err = o.Update(edbInfo, cols...)
|
|
|
return
|
|
|
}
|
|
@@ -658,8 +620,7 @@ type EdbInfoReplaceReq struct {
|
|
|
|
|
|
func EdbInfoReplace(oldEdbInfo, newEdbInfo *EdbInfo, sysAdminId int, sysAdminRealName string) (replaceChartTotal, replaceCalculateTotal int, err error) {
|
|
|
var errmsg string
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
o.Begin()
|
|
|
defer func() {
|
|
|
if errmsg != "" {
|
|
@@ -908,8 +869,7 @@ type EdbInfoView struct {
|
|
|
|
|
|
//获取指标的所有计算指标,以及计算指标所依赖计算指标
|
|
|
func GetAllCalculateByEdbInfoId(edbInfoId int) (mappingList []*EdbInfoCalculateMapping, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
+ o := orm.NewOrmUsingDB("data")
|
|
|
msql := ` SELECT * FROM edb_info_calculate_mapping WHERE from_edb_info_id=? GROUP BY edb_info_id `
|
|
|
_, err = o.Raw(msql, edbInfoId).QueryRows(&mappingList)
|
|
|
if err != nil {
|