123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142 |
- package data_manage
- import (
- "fmt"
- "rdluck_tools/orm"
- "time"
- )
- type EdbInfo struct {
- EdbInfoId int `orm:"column(edb_info_id);pk"`
- SourceName string `description:"来源名称"`
- Source int `description:"来源id"`
- EdbCode string `description:"指标编码"`
- EdbName string `description:"指标名称"`
- EdbNameSource string `description:"指标名称来源"`
- Frequency string `description:"频率"`
- Unit string `description:"单位"`
- StartDate string `description:"起始日期"`
- EndDate string `description:"终止日期"`
- ClassifyId int `description:"分类id"`
- SysUserId int
- SysUserRealName string
- UniqueCode string `description:"指标唯一编码"`
- CreateTime time.Time
- ModifyTime time.Time
- MinValue float64 `description:"指标最小值"`
- MaxValue float64 `description:"指标最大值"`
- CalculateFormula string `description:"计算公式"`
- }
- type EdbInfoList struct {
- EdbInfoId int `orm:"column(edb_info_id);pk"`
- SourceName string `description:"来源名称"`
- Source int `description:"来源id"`
- EdbCode string `description:"指标编码"`
- EdbName string `description:"指标名称"`
- Frequency string `description:"频率"`
- Unit string `description:"单位"`
- StartDate time.Time `description:"起始日期"`
- EndDate time.Time `description:"终止日期"`
- ClassifyId int `description:"分类id"`
- UniqueCode string `description:"指标唯一编码"`
- CalculateFormula string `description:"计算公式"`
- ModifyTime string `description:"更新时间"`
- }
- type EdbInfoSearchData struct {
- DataTime string `description:"数据日期"`
- Value float64 `description:"数据"`
- }
- func GetEdbInfoByCondition(condition string, pars []interface{}, order int) (item []*EdbInfoList, err error) {
- o := orm.NewOrm()
- o.Using("data")
- sql := ` SELECT * FROM edb_info WHERE 1=1 `
- if condition != "" {
- sql += condition
- }
- if order == 1 {
- sql += ` ORDER BY end_date ASC `
- } else {
- sql += ` ORDER BY edb_info_id ASC `
- }
- _, err = o.Raw(sql, pars).QueryRows(&item)
- return
- }
- func ModifyEdbDataInfoDate(edbInfoId int, maxDate string) (err error) {
- o := orm.NewOrm()
- o.Using("data")
- sql := ` UPDATE edb_info SET end_date=?,modify_time=NOW() WHERE edb_info_id=? `
- _, err = o.Raw(sql, maxDate, edbInfoId).Exec()
- return
- }
- type EdbInfoMaxAndMinInfo struct {
- MinDate string `description:"最小日期"`
- MaxDate string `description:"最大日期"`
- MinValue float64 `description:"最小值"`
- MaxValue float64 `description:"最大值"`
- }
- func GetEdbInfoMaxAndMinInfo(source int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
- o := orm.NewOrm()
- o.Using("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=? `
- sql = fmt.Sprintf(sql, tableName)
- err = o.Raw(sql, edbCode).QueryRow(&item)
- return
- }
- func ModifyEdbInfoMaxAndMinInfo(edbInfoId int, item *EdbInfoMaxAndMinInfo) (err error) {
- o := orm.NewOrm()
- o.Using("data")
- sql := ` UPDATE edb_info SET start_date=?,end_date=?,min_value=?,max_value=?,modify_time=NOW() WHERE edb_info_id=? `
- _, err = o.Raw(sql, item.MinDate, item.MaxDate, item.MinValue, item.MaxValue, edbInfoId).Exec()
- return
- }
- //order:1升序,其余值为降序
- func GetEdbDataListAll(condition string, pars []interface{}, source, order int) (item []*EdbInfoSearchData, err error) {
- o := orm.NewOrm()
- o.Using("data")
- sql := ``
- tableName := GetEdbDataTableName(source)
- sql = ` SELECT * FROM %s WHERE 1=1 `
- sql = fmt.Sprintf(sql, tableName)
- if condition != "" {
- sql += condition
- }
- if order == 1 {
- sql += ` ORDER BY data_time ASC `
- } else {
- sql += ` ORDER BY data_time DESC `
- }
- _, err = o.Raw(sql, pars).QueryRows(&item)
- return
- }
- func GetEdbInfoById(edbInfoId int) (item *EdbInfo, err error) {
- o := orm.NewOrm()
- o.Using("data")
- sql := ` SELECT * FROM edb_info WHERE edb_info_id=? `
- err = o.Raw(sql, edbInfoId).QueryRow(&item)
- return
- }
- func GetQuarterEdbInfo() (item []*EdbInfo, err error) {
- o := orm.NewOrm()
- o.Using("data")
- sql := ` SELECT c.* FROM chart_info AS a
- INNER JOIN chart_edb_mapping AS b ON a.chart_info_id=b.chart_info_id
- INNER JOIN edb_info AS c ON b.edb_info_id=c.edb_info_id
- WHERE a.chart_type=2
- GROUP BY b.edb_info_id
- ORDER BY b.edb_info_id ASC `
- _, err = o.Raw(sql).QueryRows(&item)
- return
- }
|