eta_data_init/models/sync_index.go

package models

import (
	"errors"
	"fmt"
	"github.com/beego/beego/v2/client/orm"
	"time"
)

type EdbClassifyItem struct {
	ClassifyID         int64 `orm:"column(classify_id);pk"`
	ClassifyType       uint32
	ClassifyName       string
	ParentID           int64
	HasData            int32
	CreateTime         time.Time
	ModifyTime         time.Time
	SysUserID          int64
	SysUserRealName    string
	Level              int64
	UniqueCode         string
	Sort               uint32
	RootID             int64
	LastModifyUserID   uint32
	LastModifyUserName string
}

// GetAllEdbClassifyListByCondition
// @Description: 获取分类列表
// @author: Roc
// @datetime 2024-02-29 10:55:38
// @param condition string
// @param pars []interface{}
// @return item []*EdbInfoUpdateLog
// @return err error
func GetAllEdbClassifyListByCondition(condition string, pars []interface{}) (item []*EdbClassifyItem, err error) {
	o := orm.NewOrmUsingDB("data")
	sql := ` SELECT * FROM edb_classify WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += ` ORDER BY classify_id ASC `
	_, err = o.Raw(sql, pars).QueryRows(&item)

	return
}

type EdbInfoItem struct {
	CalculateFormula string  `json:"calculate_formula"`
	Calendar         string  `json:"calendar"`
	ChartImage       string  `json:"chart_image"`
	ClassifyId       int     `json:"classify_id"`
	CreateTime       string  `json:"create_time"`
	DataDateType     string  `json:"data_date_type"`
	DataUpdateTime   string  `json:"data_update_time"`
	EdbCode          string  `json:"edb_code"`
	EdbInfoId        int     `json:"edb_info_id"`
	EdbInfoType      int     `json:"edb_info_type"`
	EdbName          string  `json:"edb_name"`
	EdbNameEn        string  `json:"edb_name_en"`
	EdbNameSource    string  `json:"edb_name_source"`
	EdbType          int     `json:"edb_type"`
	EmptyType        int     `json:"empty_type"`
	EndDate          string  `json:"end_date"`
	EndValue         float64 `json:"end_value"`
	ErDataUpdateDate string  `json:"er_data_update_date"`
	Extra            string  `json:"extra"`
	Frequency        string  `json:"frequency"`
	IndicatorCode    string  `json:"indicator_code"`
	IsUpdate         int     `json:"is_update"`
	LatestDate       string  `json:"latest_date"`
	LatestValue      float64 `json:"latest_value"`
	ManualSave       int     `json:"manual_save"`
	MaxEmptyType     int     `json:"max_empty_type"`
	MaxValue         float64 `json:"max_value"`
	MinValue         float64 `json:"min_value"`
	ModifyTime       string  `json:"modify_time"`
	MoveFrequency    string  `json:"move_frequency"`
	MoveType         int     `json:"move_type"`
	NoUpdate         int     `json:"no_update"`
	ServerUrl        string  `json:"server_url"`
	Sort             int     `json:"sort"`
	Source           int     `json:"source"`
	SourceIndexName  string  `json:"source_index_name"`
	SourceName       string  `json:"source_name"`
	StartDate        string  `json:"start_date"`
	StockCode        string  `json:"stock_code"`
	SubSource        int     `json:"sub_source"`
	SubSourceName    string  `json:"sub_source_name"`
	SysUserId        int     `json:"sys_user_id"`
	SysUserRealName  string  `json:"sys_user_real_name"`
	TerminalCode     string  `json:"terminal_code"`
	UniqueCode       string  `json:"unique_code"`
	Unit             string  `json:"unit"`
	UnitEn           string  `json:"unit_en"`
}

// GetAllEdbInfoListByCondition
// @Description: 获取所有的指标
// @author: Roc
// @datetime 2024-02-29 10:55:38
// @param condition string
// @param pars []interface{}
// @return item []*EdbInfoUpdateLog
// @return err error
func GetAllEdbInfoListByCondition(condition string, pars []interface{}) (item []*EdbInfoItem, err error) {
	o := orm.NewOrmUsingDB("data")
	sql := ` SELECT * FROM edb_info WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += ` ORDER BY edb_info_id ASC `
	_, err = o.Raw(sql, pars).QueryRows(&item)

	return
}

type EdbData struct {
	EdbDataId int32  `orm:"column(edb_data_id);pk" json:"edb_data_id"`
	EdbInfoId int32  `json:"edb_info_id"` // 指标id
	EdbCode   string `json:"edb_code"`    // 指标编码
	//DataTime      time.Time `json:"data_time"`      // 数据日期
	DataTime string  `json:"data_time"` // 数据日期
	Value    float64 `json:"value"`     // 数据值
	//CreateTime    time.Time `json:"create_time"`    // 创建时间
	//ModifyTime    time.Time `json:"modify_time"`    // 修改时间
	CreateTime    string `json:"create_time"`    // 创建时间
	ModifyTime    string `json:"modify_time"`    // 修改时间
	DataTimestamp int64  `json:"data_timestamp"` // 数据日期时间戳
}

// GetAllEdbDataListByCondition
// @Description: 根据指标id和表名获取指标数据
// @author: Roc
// @datetime 2024-03-14 13:22:01
// @param tableName string
// @param edbInfoId int
// @return item []*EdbData
// @return err error
func GetAllEdbDataListByCondition(tableName string, edbInfoId int) (item []*EdbData, err error) {
	if tableName == `` {
		err = errors.New("错误的表名")
		return
	}
	o := orm.NewOrmUsingDB("data")
	sql := fmt.Sprintf(` SELECT * FROM %s WHERE 1=1 and edb_info_id = ? `, tableName)
	sql += ` ORDER BY edb_data_id ASC `
	_, err = o.Raw(sql, edbInfoId).QueryRows(&item)

	return
}

type BaseFromMysteelChemicalIndexItem struct {
	BaseFromMysteelChemicalIndexId    int32   `json:"base_from_mysteel_chemical_index_id"`
	BaseFromMysteelChemicalClassifyId int32   `json:"base_from_mysteel_chemical_classify_id"` // 钢联化工指标分类id
	IndexCode                         string  `json:"index_code"`                             // 指标编码
	IndexName                         string  `json:"index_name"`                             // 指标名称
	Unit                              string  `json:"unit"`                                   // 单位
	Source                            string  `json:"source"`                                 // 数据来源
	Frequency                         string  `json:"frequency"`                              // 频度
	StartDate                         string  `json:"start_date"`                             // 开始日期
	EndDate                           string  `json:"end_date"`                               // 结束日期
	Describe                          string  `json:"describe"`                               // 指标描述
	UpdateWeek                        string  `json:"update_week"`                            // 更新周期
	UpdateTime                        string  `json:"update_time"`                            // 更新时间，多个时间点用英文,隔开
	UpdateTime2                       string  `json:"update_time2"`                           // 更新时间2
	SysUserId                         int32   `json:"sys_user_id"`                            // 创建人id
	SysUserRealName                   string  `json:"sys_user_real_name"`                     // 创建人姓名
	CreateTime                        string  `json:"create_time"`                            // 创建时间
	ModifyTime                        string  `json:"modify_time"`                            // 修改时间
	FilePath                          string  `json:"file_path"`                              // 文件存储路径
	Sort                              int32   `json:"sort"`                                   // 排序
	MergeFilePath                     string  `json:"merge_file_path"`
	FileIndex                         int32   `json:"file_index"`
	MergeUpdateWeek                   string  `json:"merge_update_week"`    // 合并文件的更新周
	MergeFilePathWeek                 string  `json:"merge_file_path_week"` // 更新文件
	UpdateDate                        string  `json:"update_date"`          // 更新日期
	IsRefresh                         int32   `json:"is_refresh"`           // 0:不需要及时刷新,1:需要及时刷新
	IsStop                            int32   `json:"is_stop"`              // 是否停更:1:停更,0:未停更
	TerminalCode                      string  `json:"terminal_code"`        // 所属终端编码
	EndValue                          float64 `json:"end_value"`            // 指标的最新值
}

// GetBaseFromMysteelChemicalIndexItemByCode
// @Description: 根据指标编码获取钢联指标详情
// @author: Roc
// @datetime 2024-03-11 16:42:56
// @param edbCode string
// @return item *BaseFromMysteelChemicalIndexItem
// @return err error
func GetBaseFromMysteelChemicalIndexItemByCode(edbCode string) (item *BaseFromMysteelChemicalIndexItem, err error) {
	o := orm.NewOrmUsingDB("data")
	sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE index_code = ?`
	err = o.Raw(sql, edbCode).QueryRow(&item)

	return
}

type BaseFromSmmIndexItem struct {
	BaseFromSmmIndexId int32   `json:"base_from_smm_index_id"`
	ClassifyId         int32   `json:"classify_id"` // Smm原始数据指标分类id
	Interface          string  `json:"interface"`
	Name               string  `json:"name"`
	IndexCode          string  `json:"index_code"`      // 指标编码
	IndexName          string  `json:"index_name"`      // 指标名称
	Type1              string  `json:"type_1"`          // 类型1
	Type2              string  `json:"type_2"`          // 类型2
	Type3              string  `json:"type_3"`          // 类型3
	Frequency          string  `json:"frequency"`       // 频度
	Unit               string  `json:"unit"`            // 单位
	ApiStartTime       string  `json:"api_start_time"`  // 接口开始日期
	ApiUpdateTime      string  `json:"api_update_time"` // 接口更新日期
	StartTime          string  `json:"start_time"`      // 开始日期
	FinishTime         string  `json:"finish_time"`     // 完成日期
	CreateTime         string  `json:"create_time"`
	ModifyTime         string  `json:"modify_time"`
	StartDate          string  `json:"start_date"`
	EndDate            string  `json:"end_date"`
	IsGet              int32   `json:"is_get"`           // 0:未获取数据,1:已获取数据
	Sort               int32   `json:"sort"`             // 排序
	BaseFileName       string  `json:"base_file_name"`   // 文件目录
	RenameFileName     string  `json:"rename_file_name"` // 重命名文件目录
	TerminalCode       string  `json:"terminal_code"`    // 所属终端编码
	DataState          string  `json:"data_state"`       // 指标数据状态 normal/空白-正常更新 ceased-已停更irregular-更新依赖外部会有不定期延迟
	ReleaseTime        string  `json:"release_time"`     // 预计发布时间
	IsStop             int32   `json:"is_stop"`          // 是否停更:1:停更,0:未停更
	EndValue           float64 `json:"end_value"`        // 指标的最新值
}

// GetBaseFromSmmIndexItemItemByCode
// @Description: 根据指标编码获取指标信息
// @author: Roc
// @datetime 2024-03-11 16:41:02
// @param source int
// @param edbCode string
// @return item *BaseFromSmmIndexItem
// @return err error
func GetBaseFromSmmIndexItemItemByCode(edbCode string) (item *BaseFromSmmIndexItem, err error) {
	o := orm.NewOrmUsingDB("data")
	sql := ` SELECT * FROM base_from_smm_index WHERE index_code=? `
	err = o.Raw(sql, edbCode).QueryRow(&item)

	return
}