|
@@ -66,67 +66,3 @@ func GetEdbDataTableName(source int) (tableName string) {
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-type EdbDataBase struct {
|
|
|
- EdbDataId int `orm:"column(edb_data_id);pk"`
|
|
|
- EdbInfoId int
|
|
|
- EdbCode string
|
|
|
- DataTime string
|
|
|
- Value string
|
|
|
- Status int
|
|
|
- CreateTime time.Time
|
|
|
- ModifyTime time.Time
|
|
|
- DataTimestamp int64
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbDataAllByEdbCode(edbCode string, source, limit int) (items []*EdbInfoSearchData, err error) {
|
|
|
- var pars []interface{}
|
|
|
- pars = append(pars, edbCode)
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
-
|
|
|
- tableName := GetEdbDataTableName(source)
|
|
|
- sql := ` SELECT * FROM %s WHERE edb_code=? ORDER BY data_time DESC`
|
|
|
- if limit > 0 {
|
|
|
- sql += ` LIMIT ? `
|
|
|
- pars = append(pars, limit)
|
|
|
- }
|
|
|
- sql = fmt.Sprintf(sql, tableName)
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func GetEdbDataBaseByCodeAndDate(source int, edbCode string, startDate string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- o.Using("data")
|
|
|
- tableName := GetEdbDataTableName(source)
|
|
|
- sql := ` SELECT COUNT(1) AS count FROM %s WHERE edb_code=? AND data_time=? `
|
|
|
- sql = fmt.Sprintf(sql, tableName)
|
|
|
- err = o.Raw(sql, edbCode, startDate).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|