|
@@ -9,10 +9,10 @@ import (
|
|
|
"time"
|
|
|
)
|
|
|
|
|
|
-// BaseFromFenWei 涌溢咨询
|
|
|
-type BaseFromFenWei struct{}
|
|
|
+// BaseFromFenwei 涌溢咨询
|
|
|
+type BaseFromFenwei struct{}
|
|
|
|
|
|
-type BaseFromFenWeiData struct {
|
|
|
+type BaseFromFenweiData struct {
|
|
|
FenweiDataId int `orm:"column(fenwei_data_id);pk"`
|
|
|
FenweiIndexId int
|
|
|
IndexCode string
|
|
@@ -23,11 +23,11 @@ type BaseFromFenWeiData struct {
|
|
|
DataTimestamp int64
|
|
|
}
|
|
|
|
|
|
-func (m *BaseFromFenWeiData) TableName() string {
|
|
|
+func (m *BaseFromFenweiData) TableName() string {
|
|
|
return "base_from_fenwei_data"
|
|
|
}
|
|
|
|
|
|
-func GetBaseFromFenWeiDataByCondition(condition string, pars []interface{}) (list []*BaseFromFenWeiData, err error) {
|
|
|
+func GetBaseFromFenweiDataByCondition(condition string, pars []interface{}) (list []*BaseFromFenweiData, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_fenwei_data WHERE 1=1 `
|
|
|
if condition != "" {
|
|
@@ -38,7 +38,7 @@ func GetBaseFromFenWeiDataByCondition(condition string, pars []interface{}) (lis
|
|
|
}
|
|
|
|
|
|
// Add 添加
|
|
|
-func (obj BaseFromFenWei) Add(edbCode string) (err error) {
|
|
|
+func (obj BaseFromFenwei) Add(edbCode string) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
|
|
|
var condition string
|
|
@@ -47,7 +47,7 @@ func (obj BaseFromFenWei) Add(edbCode string) (err error) {
|
|
|
condition += " AND index_code=? "
|
|
|
pars = append(pars, edbCode)
|
|
|
}
|
|
|
- fenweiBaseDataAll, err := GetBaseFromFenWeiDataByCondition(condition, pars)
|
|
|
+ fenweiBaseDataAll, err := GetBaseFromFenweiDataByCondition(condition, pars)
|
|
|
if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
return
|
|
|
}
|
|
@@ -79,8 +79,8 @@ func (obj BaseFromFenWei) Add(edbCode string) (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// Refresh 刷新涌益咨询指标数据
|
|
|
-func (obj BaseFromFenWei) Refresh(edbInfoId int, edbCode, startDate string) (err error) {
|
|
|
+// Refresh 刷新汾渭数据指标数据
|
|
|
+func (obj BaseFromFenwei) Refresh(edbInfoId int, edbCode, startDate string) (err error) {
|
|
|
source := obj.GetSource()
|
|
|
o := orm.NewOrm()
|
|
|
if err != nil {
|
|
@@ -101,7 +101,7 @@ func (obj BaseFromFenWei) Refresh(edbInfoId int, edbCode, startDate string) (err
|
|
|
pars = append(pars, startDate)
|
|
|
}
|
|
|
|
|
|
- fenweiDataList, err := GetBaseFromFenWeiDataByCondition(condition, pars)
|
|
|
+ fenweiDataList, err := GetBaseFromFenweiDataByCondition(condition, pars)
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -190,16 +190,16 @@ func (obj BaseFromFenWei) Refresh(edbInfoId int, edbCode, startDate string) (err
|
|
|
}
|
|
|
|
|
|
// GetSource 获取来源编码id
|
|
|
-func (obj BaseFromFenWei) GetSource() int {
|
|
|
+func (obj BaseFromFenwei) GetSource() int {
|
|
|
return utils.DATA_SOURCE_FENWEI
|
|
|
}
|
|
|
|
|
|
// GetSourceName 获取来源名称
|
|
|
-func (obj BaseFromFenWei) GetSourceName() string {
|
|
|
+func (obj BaseFromFenwei) GetSourceName() string {
|
|
|
return utils.DATA_SOURCE_NAME_FENWEI
|
|
|
}
|
|
|
|
|
|
-type BaseFromFenWeiIndex struct {
|
|
|
+type BaseFromFenweiIndex struct {
|
|
|
FenweiIndexId int64 `orm:"column(fenwei_index_id);pk"`
|
|
|
IndexCode string
|
|
|
IndexName string
|
|
@@ -214,12 +214,54 @@ type BaseFromFenWeiIndex struct {
|
|
|
ModifyTime time.Time
|
|
|
}
|
|
|
|
|
|
-func (m *BaseFromFenWeiIndex) TableName() string {
|
|
|
+func (m *BaseFromFenweiIndex) TableName() string {
|
|
|
return "base_from_fenwei_index"
|
|
|
}
|
|
|
|
|
|
-type BaseFromFenWeiIndexList struct {
|
|
|
- FenWeiIndexId int64 `orm:"column(fenwei_index_id);pk"`
|
|
|
+func (m *BaseFromFenweiIndex) Add() (lastId int64, err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ lastId, err = o.Insert(m)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func (m *BaseFromFenweiIndex) Update(updateCols []string) (err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ _, err = o.Update(m, updateCols...)
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func (m *BaseFromFenweiIndex) ModifyIndexMaxAndMinDate(indexCode string, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ sql := ` UPDATE base_from_fenwei_index SET start_date=?,end_date=?,modify_time=NOW() WHERE index_code=? `
|
|
|
+ _, err = o.Raw(sql, item.MinDate, item.MaxDate, indexCode).Exec()
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func (m *BaseFromFenweiIndex) GetByIndexCode(indexCode string) (item *BaseFromFenweiIndex, err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ sql := ` SELECT * FROM base_from_fenwei_index WHERE index_code=? `
|
|
|
+ err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+func (m *BaseFromFenweiIndex) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BaseFromFenweiIndex, err error) {
|
|
|
+ o := orm.NewOrm()
|
|
|
+ fields := strings.Join(fieldArr, ",")
|
|
|
+ if len(fieldArr) == 0 {
|
|
|
+ fields = `*`
|
|
|
+ }
|
|
|
+ order := `ORDER BY create_time DESC`
|
|
|
+ if orderRule != "" {
|
|
|
+ order = ` ORDER BY ` + orderRule
|
|
|
+ }
|
|
|
+ sql := fmt.Sprintf(`SELECT %s FROM base_from_fenwei_index WHERE 1=1 %s %s`, fields, condition, order)
|
|
|
+ _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+type BaseFromFenweiIndexList struct {
|
|
|
+ FenweiIndexId int64 `orm:"column(fenwei_index_id);pk"`
|
|
|
IndexCode string
|
|
|
IndexName string
|
|
|
Frequency string
|
|
@@ -232,21 +274,21 @@ type BaseFromFenWeiIndexList struct {
|
|
|
ModifyTime string
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiData) GetByIndexCode(indexCode string) (list []*BaseFromFenWeiData, err error) {
|
|
|
+func (y *BaseFromFenweiData) GetByIndexCode(indexCode string) (list []*BaseFromFenweiData, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := ` SELECT * FROM base_from_fenwei_data WHERE index_code=? `
|
|
|
_, err = o.Raw(sql, indexCode).QueryRows(&list)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiData) AddMulti(item []*BaseFromFenWeiData) (err error) {
|
|
|
+func (y *BaseFromFenweiData) AddMulti(item []*BaseFromFenweiData) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
_, err = o.InsertMulti(1, item)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// HandleFenWeiExcelData 涌益咨询的excel数据
|
|
|
-type HandleFenWeiExcelData struct {
|
|
|
+// HandleFenweiExcelData 汾渭数据的excel数据
|
|
|
+type HandleFenweiExcelData struct {
|
|
|
//ClassifyName string `description:"指标目录"`
|
|
|
//ClassifySort int `description:"指标目录排序号"`
|
|
|
IndexName string `description:"指标名称"`
|
|
@@ -258,48 +300,20 @@ type HandleFenWeiExcelData struct {
|
|
|
ExcelDataMap map[string]string
|
|
|
}
|
|
|
|
|
|
-type HandleFenWeiExcelDataReq struct {
|
|
|
- List []*HandleFenWeiExcelData
|
|
|
+type HandleFenweiExcelDataReq struct {
|
|
|
+ List []*HandleFenweiExcelData
|
|
|
TerminalCode string `description:"编码"`
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiData) GetMaxAndMinDateByIndexCode(indexCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
+func (y *BaseFromFenweiData) GetMaxAndMinDateByIndexCode(indexCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
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 base_from_fenwei_data WHERE index_code=? `
|
|
|
err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiIndex) ModifyIndexMaxAndMinDate(indexCode string, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- sql := ` UPDATE base_from_fenwei_index SET start_date=?,end_date=?,modify_time=NOW() WHERE index_code=? `
|
|
|
- _, err = o.Raw(sql, item.MinDate, item.MaxDate, indexCode).Exec()
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func (y *BaseFromFenWeiIndex) GetByIndexCode(indexCode string) (item *BaseFromFenWeiIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- sql := ` SELECT * FROM base_from_fenwei_index WHERE index_code=? `
|
|
|
- err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-func (y *BaseFromFenWeiIndex) Add() (lastId int64, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- lastId, err = o.Insert(y)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-// Update 修改
|
|
|
-func (y *BaseFromFenWeiIndex) Update(updateCols []string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.Update(y, updateCols...)
|
|
|
-
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-// BaseFromFenWeiClassify 汾渭数据分类表
|
|
|
-type BaseFromFenWeiClassify struct {
|
|
|
+// BaseFromFenweiClassify 汾渭数据分类表
|
|
|
+type BaseFromFenweiClassify struct {
|
|
|
ClassifyId int `orm:"column(classify_id);pk"`
|
|
|
ClassifyName string `description:"分类名称"`
|
|
|
ParentId int `description:"父级id"`
|
|
@@ -311,27 +325,27 @@ type BaseFromFenWeiClassify struct {
|
|
|
CreateTime time.Time `description:"创建时间"`
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiClassify) Add() (lastId int64, err error) {
|
|
|
+func (y *BaseFromFenweiClassify) Add() (lastId int64, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
lastId, err = o.Insert(y)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiClassify) Update(updateCols []string) (err error) {
|
|
|
+func (y *BaseFromFenweiClassify) Update(updateCols []string) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
_, err = o.Update(y, updateCols...)
|
|
|
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiClassify) GetByClassifyName(classifyName string) (item *BaseFromFenWeiClassify, err error) {
|
|
|
+func (y *BaseFromFenweiClassify) GetByClassifyName(classifyName string) (item *BaseFromFenweiClassify, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
sql := ` SELECT * FROM base_from_fenwei_classify WHERE classify_name=? `
|
|
|
err = o.Raw(sql, classifyName).QueryRow(&item)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiClassify) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BaseFromFenWeiClassify, err error) {
|
|
|
+func (y *BaseFromFenweiClassify) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BaseFromFenweiClassify, err error) {
|
|
|
o := orm.NewOrm()
|
|
|
fields := strings.Join(fieldArr, ",")
|
|
|
if len(fieldArr) == 0 {
|
|
@@ -346,8 +360,8 @@ func (y *BaseFromFenWeiClassify) GetItemsByCondition(condition string, pars []in
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// BaseFromFenWeiClassifyItem 汾渭数据分类信息
|
|
|
-type BaseFromFenWeiClassifyItem struct {
|
|
|
+// BaseFromFenweiClassifyItem 汾渭数据分类信息
|
|
|
+type BaseFromFenweiClassifyItem struct {
|
|
|
ClassifyId int `description:"分类ID"`
|
|
|
ClassifyName string `description:"分类名称"`
|
|
|
ParentId int `description:"父级id"`
|
|
@@ -355,14 +369,14 @@ type BaseFromFenWeiClassifyItem struct {
|
|
|
Sort int `description:"排序字段"`
|
|
|
CreateTime string `description:"创建时间"`
|
|
|
ModifyTime string `description:"修改时间"`
|
|
|
- Child []*BaseFromFenWeiClassifyItem `description:"子分类"`
|
|
|
+ Child []*BaseFromFenweiClassifyItem `description:"子分类"`
|
|
|
}
|
|
|
|
|
|
-func (y *BaseFromFenWeiClassify) Format2Item(origin *BaseFromFenWeiClassify) (item *BaseFromFenWeiClassifyItem) {
|
|
|
+func (y *BaseFromFenweiClassify) Format2Item(origin *BaseFromFenweiClassify) (item *BaseFromFenweiClassifyItem) {
|
|
|
if origin == nil {
|
|
|
return
|
|
|
}
|
|
|
- item = new(BaseFromFenWeiClassifyItem)
|
|
|
+ item = new(BaseFromFenweiClassifyItem)
|
|
|
item.ClassifyId = origin.ClassifyId
|
|
|
item.ClassifyName = origin.ClassifyName
|
|
|
item.ParentId = origin.ParentId
|
|
@@ -373,8 +387,8 @@ func (y *BaseFromFenWeiClassify) Format2Item(origin *BaseFromFenWeiClassify) (it
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// MultiUpdateBaseFromFenWeiDataValue 批量更新汾渭指标数据
|
|
|
-func MultiUpdateBaseFromFenWeiDataValue(items []*BaseFromFenWeiData) (err error) {
|
|
|
+// MultiUpdateBaseFromFenweiDataValue 批量更新汾渭指标数据
|
|
|
+func MultiUpdateBaseFromFenweiDataValue(items []*BaseFromFenweiData) (err error) {
|
|
|
if len(items) == 0 {
|
|
|
return
|
|
|
}
|