|
@@ -1,36 +1,45 @@
|
|
|
package models
|
|
|
|
|
|
import (
|
|
|
+ "eta_gn/eta_index_lib/global"
|
|
|
"eta_gn/eta_index_lib/utils"
|
|
|
"fmt"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
"time"
|
|
|
-
|
|
|
- "github.com/beego/beego/v2/client/orm"
|
|
|
)
|
|
|
|
|
|
//钢联
|
|
|
|
|
|
+//type MysteelChemicalData struct {
|
|
|
+// InputValue float64 `orm:"column(value)" description:"值"`
|
|
|
+// DataTime string `orm:"column(data_time)" description:"日期"`
|
|
|
+//}
|
|
|
+
|
|
|
type MysteelChemicalData struct {
|
|
|
- InputValue float64 `orm:"column(value)" description:"值"`
|
|
|
- DataTime string `orm:"column(data_time)" description:"日期"`
|
|
|
+ InputValue float64 `gorm:"column:value" description:"值"`
|
|
|
+ DataTime string `gorm:"column:data_time" description:"日期"`
|
|
|
+}
|
|
|
+
|
|
|
+func (m *MysteelChemicalData) TableName() string {
|
|
|
+ return "base_from_mysteel_chemical_data"
|
|
|
}
|
|
|
|
|
|
func GetMysteelChemicalDataByCondition(condition string, pars []interface{}) (item []*MysteelChemicalData, err error) {
|
|
|
sql1 := ` SELECT * FROM base_from_mysteel_chemical_data WHERE 1=1 `
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
if condition != "" {
|
|
|
sql1 += condition
|
|
|
}
|
|
|
sql := `select * from (` + sql1 + ` having 1 order by modify_time DESC ) tmp GROUP BY data_time ORDER BY data_time DESC `
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ //_, err = o.Raw(sql, pars).QueryRows(&item)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars).Scan(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// AddEdbDataFromMysteelChemical 新增钢联指标数据
|
|
|
func AddEdbDataFromMysteelChemical(edbCode string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
@@ -72,7 +81,8 @@ func AddEdbDataFromMysteelChemical(edbCode string) (err error) {
|
|
|
if isAdd {
|
|
|
addSql = strings.TrimRight(addSql, ",")
|
|
|
utils.FileLog.Info("addSql:" + addSql)
|
|
|
- _, err = o.Raw(addSql).Exec()
|
|
|
+ //_, err = o.Raw(addSql).Exec()
|
|
|
+ err = global.DEFAULT_DmSQL.Exec(addSql).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -86,7 +96,7 @@ func RefreshEdbDataFromMysteelChemical(edbInfoId int, edbCode, startDate string)
|
|
|
source := utils.DATA_SOURCE_MYSTEEL_CHEMICAL
|
|
|
subSource := utils.DATA_SUB_SOURCE_EDB
|
|
|
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -192,7 +202,8 @@ func RefreshEdbDataFromMysteelChemical(edbInfoId int, edbCode, startDate string)
|
|
|
|
|
|
if isAdd {
|
|
|
addSql = strings.TrimRight(addSql, ",")
|
|
|
- _, err = o.Raw(addSql).Exec()
|
|
|
+ //_, err = o.Raw(addSql).Exec()
|
|
|
+ err = global.DEFAULT_DmSQL.Exec(addSql).Error
|
|
|
if err != nil {
|
|
|
return err
|
|
|
}
|
|
@@ -201,32 +212,64 @@ func RefreshEdbDataFromMysteelChemical(edbInfoId int, edbCode, startDate string)
|
|
|
}
|
|
|
|
|
|
// 钢联化工指标数据
|
|
|
+//type BaseFromMysteelChemicalIndex struct {
|
|
|
+// BaseFromMysteelChemicalIndexId int64 `orm:"column(base_from_mysteel_chemical_index_id);pk"`
|
|
|
+// BaseFromMysteelChemicalClassifyId int `description:"分类id"`
|
|
|
+// IndexCode string `description:"指标编码"`
|
|
|
+// IndexName string `description:"指标名称"`
|
|
|
+// Unit string `description:"单位"`
|
|
|
+// Source string `description:"数据来源"`
|
|
|
+// Frequency string `description:"频度"`
|
|
|
+// StartDate time.Time `description:"开始日期"`
|
|
|
+// EndDate time.Time `description:"结束日期"`
|
|
|
+// Describe string `description:"指标描述"`
|
|
|
+// UpdateWeek string `description:"更新周期"`
|
|
|
+// UpdateTime string `description:"更新时间,多个时间点用英文,隔开"`
|
|
|
+// UpdateTime2 string `description:"更新时间2"`
|
|
|
+// SysUserId int `description:"创建人id"`
|
|
|
+// SysUserRealName string `description:"创建人姓名"`
|
|
|
+// FilePath string `description:"文件存储路径"`
|
|
|
+// MergeFilePath string `description:"更新文件"`
|
|
|
+// FileIndex int `description:"文件索引"`
|
|
|
+// MergeUpdateWeek string `description:"合并文件的更新周"`
|
|
|
+// UpdateDate string `description:"更新日期"`
|
|
|
+// CreateTime time.Time `description:"创建时间"`
|
|
|
+// ModifyTime time.Time `description:"修改时间"`
|
|
|
+// IsStop int `description:"是否停更:1:停更,0:未停更"`
|
|
|
+// TerminalCode string `description:"终端编码"`
|
|
|
+// IsSupplierStop int `description:"是否供应商停更:1:停更,0:未停更"`
|
|
|
+//}
|
|
|
+
|
|
|
type BaseFromMysteelChemicalIndex struct {
|
|
|
- BaseFromMysteelChemicalIndexId int64 `orm:"column(base_from_mysteel_chemical_index_id);pk"`
|
|
|
- BaseFromMysteelChemicalClassifyId int `description:"分类id"`
|
|
|
- IndexCode string `description:"指标编码"`
|
|
|
- IndexName string `description:"指标名称"`
|
|
|
- Unit string `description:"单位"`
|
|
|
- Source string `description:"数据来源"`
|
|
|
- Frequency string `description:"频度"`
|
|
|
- StartDate time.Time `description:"开始日期"`
|
|
|
- EndDate time.Time `description:"结束日期"`
|
|
|
- Describe string `description:"指标描述"`
|
|
|
- UpdateWeek string `description:"更新周期"`
|
|
|
- UpdateTime string `description:"更新时间,多个时间点用英文,隔开"`
|
|
|
- UpdateTime2 string `description:"更新时间2"`
|
|
|
- SysUserId int `description:"创建人id"`
|
|
|
- SysUserRealName string `description:"创建人姓名"`
|
|
|
- FilePath string `description:"文件存储路径"`
|
|
|
- MergeFilePath string `description:"更新文件"`
|
|
|
- FileIndex int `description:"文件索引"`
|
|
|
- MergeUpdateWeek string `description:"合并文件的更新周"`
|
|
|
- UpdateDate string `description:"更新日期"`
|
|
|
- CreateTime time.Time `description:"创建时间"`
|
|
|
- ModifyTime time.Time `description:"修改时间"`
|
|
|
- IsStop int `description:"是否停更:1:停更,0:未停更"`
|
|
|
- TerminalCode string `description:"终端编码"`
|
|
|
- IsSupplierStop int `description:"是否供应商停更:1:停更,0:未停更"`
|
|
|
+ BaseFromMysteelChemicalIndexId int64 `gorm:"column:base_from_mysteel_chemical_index_id;primaryKey" description:"指标ID"`
|
|
|
+ BaseFromMysteelChemicalClassifyId int `gorm:"column:base_from_mysteel_chemical_classify_id" description:"分类id"`
|
|
|
+ IndexCode string `gorm:"column:index_code" description:"指标编码"`
|
|
|
+ IndexName string `gorm:"column:index_name" description:"指标名称"`
|
|
|
+ Unit string `gorm:"column:unit" description:"单位"`
|
|
|
+ Source string `gorm:"column:source" description:"数据来源"`
|
|
|
+ Frequency string `gorm:"column:frequency" description:"频度"`
|
|
|
+ StartDate time.Time `gorm:"column:start_date" description:"开始日期"`
|
|
|
+ EndDate time.Time `gorm:"column:end_date" description:"结束日期"`
|
|
|
+ Describe string `gorm:"column:describe" description:"指标描述"`
|
|
|
+ UpdateWeek string `gorm:"column:update_week" description:"更新周期"`
|
|
|
+ UpdateTime string `gorm:"column:update_time" description:"更新时间,多个时间点用英文,隔开"`
|
|
|
+ UpdateTime2 string `gorm:"column:update_time2" description:"更新时间2"`
|
|
|
+ SysUserId int `gorm:"column:sys_user_id" description:"创建人id"`
|
|
|
+ SysUserRealName string `gorm:"column:sys_user_real_name" description:"创建人姓名"`
|
|
|
+ FilePath string `gorm:"column:file_path" description:"文件存储路径"`
|
|
|
+ MergeFilePath string `gorm:"column:merge_file_path" description:"更新文件"`
|
|
|
+ FileIndex int `gorm:"column:file_index" description:"文件索引"`
|
|
|
+ MergeUpdateWeek string `gorm:"column:merge_update_week" description:"合并文件的更新周"`
|
|
|
+ UpdateDate string `gorm:"column:update_date" description:"更新日期"`
|
|
|
+ CreateTime time.Time `gorm:"column:create_time" description:"创建时间"`
|
|
|
+ ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"`
|
|
|
+ IsStop int `gorm:"column:is_stop" description:"是否停更:1:停更,0:未停更"`
|
|
|
+ TerminalCode string `gorm:"column:terminal_code" description:"终端编码"`
|
|
|
+ IsSupplierStop int `gorm:"column:is_supplier_stop" description:"是否供应商停更:1:停更,0:未停更"`
|
|
|
+}
|
|
|
+// tableName
|
|
|
+func (m *BaseFromMysteelChemicalIndex) TableName() string {
|
|
|
+ return "base_from_mysteel_chemical_index"
|
|
|
}
|
|
|
|
|
|
type MysteelChemicalAPiCheck struct {
|
|
@@ -236,16 +279,18 @@ type MysteelChemicalAPiCheck struct {
|
|
|
|
|
|
// GetIndexRefreshAllByMergeFile 根据合并文件去分组查询需要刷新的文件
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexRefreshAllByMergeFile() (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE merge_file_path <>'' AND base_from_mysteel_chemical_classify_id NOT IN(54,55,56,57) GROUP BY merge_file_path`
|
|
|
- _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexItem(indexCode string) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_code = ? `
|
|
|
- err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+ //err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -253,42 +298,47 @@ func (m *BaseFromMysteelChemicalIndex) GetBatchIndexItem(indexCodes []string) (i
|
|
|
if len(indexCodes) <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_code IN (%s) `
|
|
|
holder := make([]string, 0, len(indexCodes))
|
|
|
for range indexCodes {
|
|
|
holder = append(holder, "?")
|
|
|
}
|
|
|
sql = fmt.Sprintf(sql, strings.Join(holder, ","))
|
|
|
- _, err = o.Raw(sql, indexCodes).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, indexCodes).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, indexCodes).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexCreate(terminalCode string) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_name = '' AND terminal_code = ? `
|
|
|
- _, err = o.Raw(sql, terminalCode).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, terminalCode).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, terminalCode).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// Add 新增
|
|
|
func (m *BaseFromMysteelChemicalIndex) Add() (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.Insert(m)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.Insert(m)
|
|
|
+ err = global.DEFAULT_DmSQL.Create(m).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BaseFromMysteelChemicalIndex) Update(cols []string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.Update(m, cols...)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.Update(m, cols...)
|
|
|
+ err = global.DEFAULT_DmSQL.Model(m).Updates(cols).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetNoMergeIndexByFrequencyCount 获取未合并的指标总数量
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetNoMergeIndexByFrequencyCount(frequency string) (total int64, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT count(1) AS total FROM base_from_mysteel_chemical_index WHERE frequency = ? AND merge_file_path = '' AND index_name NOT LIKE "%停%" `
|
|
|
- err = o.Raw(sql, frequency).QueryRow(&total)
|
|
|
+ //err = o.Raw(sql, frequency).QueryRow(&total)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, frequency).Scan(&total).Error
|
|
|
|
|
|
return
|
|
|
}
|
|
@@ -302,9 +352,10 @@ type GetMaxFileIndexReq struct {
|
|
|
|
|
|
// GetMaxFileIndex 获取最大文件的
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetMaxFileIndex(frequency string) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE frequency=? AND index_name NOT LIKE "%停%" ORDER BY file_index DESC `
|
|
|
- err = o.Raw(sql, frequency).QueryRow(&item)
|
|
|
+ //err = o.Raw(sql, frequency).QueryRow(&item)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, frequency).Scan(&item).Error
|
|
|
|
|
|
return
|
|
|
}
|
|
@@ -317,9 +368,10 @@ type GetNoMergeIndexByFrequencyPageReq struct {
|
|
|
|
|
|
// GetNoMergeIndexByFrequencyPage 获取未合并的指标列表
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetNoMergeIndexByFrequencyPage(frequency string, limit int) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE frequency=? AND merge_file_path = '' limit ? `
|
|
|
- _, err = o.Raw(sql, frequency, limit).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, frequency, limit).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, frequency, limit).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -328,25 +380,28 @@ type GetIndexCountByMergeFilePathReq struct {
|
|
|
}
|
|
|
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexCountByMergeFilePath(mergeFilePath string) (total int64, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT count(1) AS total FROM base_from_mysteel_chemical_index WHERE merge_file_path = ?`
|
|
|
- err = o.Raw(sql, mergeFilePath).QueryRow(&total)
|
|
|
+ //err = o.Raw(sql, mergeFilePath).QueryRow(&total)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, mergeFilePath).Scan(&total).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetIndexRefreshMethanolByMergeFile 根据合并文件去分组查询需要刷新的甲醇文件
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexRefreshMethanolByMergeFile() (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE merge_file_path <> '' AND base_from_mysteel_chemical_classify_id IN(54,55,56,57) GROUP BY merge_file_path`
|
|
|
- _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetIndexRefreshMethanolByTimely 获取需要及时刷新的文件
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexRefreshMethanolByTimely() (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE merge_file_path <> '' AND is_refresh = 1 GROUP BY merge_file_path`
|
|
|
- _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -356,9 +411,10 @@ type GetIndexByFrequencyReq struct {
|
|
|
|
|
|
// GetIndexByFrequency 根据频率获取指标
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexByFrequency(frequency string) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE frequency = ? AND merge_file_path = '' `
|
|
|
- _, err = o.Raw(sql, frequency).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, frequency).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, frequency).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -370,9 +426,10 @@ type GetIndexRefreshWeekReq struct {
|
|
|
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexRefreshWeek(nowWeekZn, startTime, endTime string) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
where := `update_week = ? AND ((update_time >= ? AND update_time <= ?) OR (update_time2 >= ? AND update_time2 <= ?)) `
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := fmt.Sprintf(`SELECT * FROM base_from_mysteel_chemical_index WHERE %s `, where)
|
|
|
- _, err = o.Raw(sql, nowWeekZn, startTime, endTime, startTime, endTime).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, nowWeekZn, startTime, endTime, startTime, endTime).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, where, nowWeekZn, startTime, endTime, startTime, endTime).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -389,8 +446,9 @@ func (m *BaseFromMysteelChemicalIndex) UpdateIndex(item *BaseFromMysteelChemical
|
|
|
if len(updateCols) == 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.Update(item, updateCols...)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.Update(item, updateCols...)
|
|
|
+ err = global.DEFAULT_DmSQL.Model(item).Updates(updateCols).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -399,7 +457,7 @@ func (m *BaseFromMysteelChemicalIndex) MultiUpdateIndex(items []UpdateIndexReq)
|
|
|
if len(items) == 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
for _, v := range items {
|
|
|
if len(v.UpdateCols) == 0 {
|
|
|
continue
|
|
@@ -407,7 +465,8 @@ func (m *BaseFromMysteelChemicalIndex) MultiUpdateIndex(items []UpdateIndexReq)
|
|
|
if v.Item == nil {
|
|
|
continue
|
|
|
}
|
|
|
- if _, e := o.Update(v.Item, v.UpdateCols...); e != nil {
|
|
|
+ //if _, e := o.Update(v.Item, v.UpdateCols...); e != nil {
|
|
|
+ if e := global.DEFAULT_DmSQL.Model(v.Item).Updates(v.UpdateCols).Error; e != nil {
|
|
|
err = fmt.Errorf("update err: %s", e.Error())
|
|
|
return
|
|
|
}
|
|
@@ -433,36 +492,53 @@ type HandleMysteelIndexResp struct {
|
|
|
}
|
|
|
|
|
|
// 钢联化工指标数据
|
|
|
+//type BaseFromMysteelChemicalData struct {
|
|
|
+// BaseFromMysteelChemicalDataId int64 `orm:"column(base_from_mysteel_chemical_data_id);pk"`
|
|
|
+// BaseFromMysteelChemicalIndexId int64
|
|
|
+// IndexCode string
|
|
|
+// DataTime time.Time
|
|
|
+// Value string
|
|
|
+// UpdateDate string
|
|
|
+// CreateTime time.Time `description:"创建时间"`
|
|
|
+// ModifyTime time.Time `description:"修改时间"`
|
|
|
+//}
|
|
|
type BaseFromMysteelChemicalData struct {
|
|
|
- BaseFromMysteelChemicalDataId int64 `orm:"column(base_from_mysteel_chemical_data_id);pk"`
|
|
|
- BaseFromMysteelChemicalIndexId int64
|
|
|
- IndexCode string
|
|
|
- DataTime time.Time
|
|
|
- Value string
|
|
|
- UpdateDate string
|
|
|
- CreateTime time.Time `description:"创建时间"`
|
|
|
- ModifyTime time.Time `description:"修改时间"`
|
|
|
+ BaseFromMysteelChemicalDataId int64 `gorm:"column:base_from_mysteel_chemical_data_id;primaryKey" description:"数据ID"`
|
|
|
+ BaseFromMysteelChemicalIndexId int64 `gorm:"column:base_from_mysteel_chemical_index_id" description:"指标ID"`
|
|
|
+ IndexCode string `gorm:"column:index_code" description:"指标编码"`
|
|
|
+ DataTime time.Time `gorm:"column:data_time" description:"数据时间"`
|
|
|
+ Value string `gorm:"column:value" description:"数据值"`
|
|
|
+ UpdateDate string `gorm:"column:update_date" description:"更新日期"`
|
|
|
+ CreateTime time.Time `gorm:"column:create_time" description:"创建时间"`
|
|
|
+ ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"`
|
|
|
+}
|
|
|
+
|
|
|
+func (m *BaseFromMysteelChemicalData) TableName() string {
|
|
|
+ return "base_from_mysteel_chemical_data"
|
|
|
}
|
|
|
|
|
|
// GetIndexDataList 根据指标编码获取数据
|
|
|
func (d *BaseFromMysteelChemicalData) GetIndexDataList(indexCode string) (item []*BaseFromMysteelChemicalData, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_data WHERE index_code = ? `
|
|
|
- _, err = o.Raw(sql, indexCode).QueryRows(&item)
|
|
|
+ //_, err = o.Raw(sql, indexCode).QueryRows(&item)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// Update 修改
|
|
|
func (r *BaseFromMysteelChemicalData) Update(updateCols []string) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.Update(r, updateCols...)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.Update(r, updateCols...)
|
|
|
+ err = global.DEFAULT_DmSQL.Model(r).Updates(updateCols).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// Add 新增
|
|
|
func (r *BaseFromMysteelChemicalData) Add(list []BaseFromMysteelChemicalData) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.InsertMulti(500, list)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.InsertMulti(500, list)
|
|
|
+ err = global.DEFAULT_DmSQL.CreateInBatches(list, 500).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -471,8 +547,9 @@ func (r *BaseFromMysteelChemicalData) AddV2(list []*BaseFromMysteelChemicalData)
|
|
|
if len(list) == 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.InsertMulti(500, list)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.InsertMulti(500, list)
|
|
|
+ err = global.DEFAULT_DmSQL.CreateInBatches(list, 500).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -490,22 +567,24 @@ type GetIndexDetailReq struct {
|
|
|
|
|
|
// GetIndexCountByFrequency 获取未合并的指标总数量
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexCountByFrequency(condition string, pars []interface{}) (total int64, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
|
|
|
sql := `SELECT count(1) AS total FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- err = o.Raw(sql, pars).QueryRow(&total)
|
|
|
+ //err = o.Raw(sql, pars).QueryRow(&total)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars).Scan(&total).Error
|
|
|
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetNoMergeIndexByFrequencyPage 获取未合并的指标列表
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexLimitByFrequency(frequency string, limit int) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE frequency=? limit ? `
|
|
|
- _, err = o.Raw(sql, frequency, limit).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, frequency, limit).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, frequency, limit).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -519,20 +598,22 @@ type GetIndexPageByFrequencyPageReq struct {
|
|
|
|
|
|
// GetNoMergeIndexByFrequencyPage 获取未合并的指标列表
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexPageByFrequency(condition string, pars []interface{}, startSize, pageSize int) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += ` LIMIT ?,? `
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars, startSize, pageSize).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (d *BaseFromMysteelChemicalData) GetMysteelIndexInfoMaxAndMinInfo(indexCode string) (item *EdbInfoMaxAndMinInfo, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //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_mysteel_chemical_data WHERE index_code=? `
|
|
|
- err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+ //err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&item).Error
|
|
|
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -541,7 +622,8 @@ func (d *BaseFromMysteelChemicalData) GetMysteelIndexInfoMaxAndMinInfo(indexCode
|
|
|
// 获取最新值
|
|
|
var latest_value float64
|
|
|
sql = ` SELECT value AS latest_value FROM base_from_mysteel_chemical_data WHERE index_code=? ORDER BY data_time DESC LIMIT 1 `
|
|
|
- err = o.Raw(sql, indexCode).QueryRow(&latest_value)
|
|
|
+ //err = o.Raw(sql, indexCode).QueryRow(&latest_value)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Scan(&latest_value).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -551,35 +633,50 @@ func (d *BaseFromMysteelChemicalData) GetMysteelIndexInfoMaxAndMinInfo(indexCode
|
|
|
}
|
|
|
|
|
|
func (d *BaseFromMysteelChemicalData) ModifyMysteelIndexMaxAndMinInfo(indexCode string, item *EdbInfoMaxAndMinInfo) (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := ` UPDATE base_from_mysteel_chemical_index SET start_date=?,end_date=?,end_value=?,modify_time=NOW() WHERE index_code=? `
|
|
|
- _, err = o.Raw(sql, item.MinDate, item.MaxDate, item.LatestValue, indexCode).Exec()
|
|
|
+ //_, err = o.Raw(sql, item.MinDate, item.MaxDate, item.LatestValue, indexCode).Exec()
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, item.MinDate, item.MaxDate, item.LatestValue, indexCode).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetIndexByCondition 获取指标
|
|
|
func (m *BaseFromMysteelChemicalIndex) GetIndexByCondition(condition string, pars []interface{}) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ //o := orm.NewOrm()
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ //_, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ err = global.DEFAULT_DmSQL.Raw(sql, pars).Scan(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+//type BaseFromMysteelChemicalRecord struct {
|
|
|
+// BaseFromMysteelChemicalRecordId int64 `orm:"column(base_from_mysteel_chemical_record_id);pk"`
|
|
|
+// BaseFromMysteelChemicalIndexId int64
|
|
|
+// OldIndexName string `description:"原始名称"`
|
|
|
+// NewIndexName string `description:"新的名称"`
|
|
|
+// CreateTime time.Time `description:"记录创建时间"`
|
|
|
+// Timestamp int64 `description:"记录创建时间戳"`
|
|
|
+//}
|
|
|
type BaseFromMysteelChemicalRecord struct {
|
|
|
- BaseFromMysteelChemicalRecordId int64 `orm:"column(base_from_mysteel_chemical_record_id);pk"`
|
|
|
- BaseFromMysteelChemicalIndexId int64
|
|
|
- OldIndexName string `description:"原始名称"`
|
|
|
- NewIndexName string `description:"新的名称"`
|
|
|
- CreateTime time.Time `description:"记录创建时间"`
|
|
|
- Timestamp int64 `description:"记录创建时间戳"`
|
|
|
+ BaseFromMysteelChemicalRecordId int64 `gorm:"column:base_from_mysteel_chemical_record_id;primaryKey" description:"记录ID"`
|
|
|
+ BaseFromMysteelChemicalIndexId int64 `gorm:"column:base_from_mysteel_chemical_index_id" description:"指标ID"`
|
|
|
+ OldIndexName string `gorm:"column:old_index_name" description:"原始名称"`
|
|
|
+ NewIndexName string `gorm:"column:new_index_name" description:"新的名称"`
|
|
|
+ CreateTime time.Time `gorm:"column:create_time" description:"记录创建时间"`
|
|
|
+ Timestamp int64 `gorm:"column:timestamp" description:"记录创建时间戳"`
|
|
|
+}
|
|
|
+
|
|
|
+func (m *BaseFromMysteelChemicalRecord) TableName() string {
|
|
|
+ return "base_from_mysteel_chemical_record"
|
|
|
}
|
|
|
|
|
|
func (m *BaseFromMysteelChemicalRecord) AddBaseFromMysteelChemicalRecord() (err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- _, err = o.Insert(m)
|
|
|
+ //o := orm.NewOrm()
|
|
|
+ //_, err = o.Insert(m)
|
|
|
+ err = global.DEFAULT_DmSQL.Create(m).Error
|
|
|
return
|
|
|
}
|
|
|
|