eta_api/models/data_manage/base_from_business_index.go

package data_manage

import (
	"eta_gn/eta_api/global"
	"eta_gn/eta_api/utils"
	"github.com/rdlucklib/rdluck_tools/paging"
	"time"
)

type BaseFromBusinessIndex struct {
	BaseFromBusinessIndexId int64     `orm:"column(base_from_business_index_id);pk" gorm:"primaryKey" `
	IndexCode               string    `description:"指标编码"`
	IndexName               string    `description:"指标名称"`
	Unit                    string    `description:"单位"`
	Frequency               string    `description:"频度"`
	Source                  int       `description:"数据来源"`
	SourceName              string    `description:"数据来源名称"`
	StartDate               time.Time `description:"开始日期"`
	EndDate                 time.Time `description:"结束日期"`
	Remark                  string    `description:"备注字段"`
	BaseModifyTime          time.Time `description:"基础信息(名称，单位，频度)变更时间"`
	DataUpdateTime          time.Time `description:"最近一次数据发生变化的时间"`
	CreateTime              time.Time `description:"创建时间"`
	ModifyTime              time.Time `description:"修改时间"`
}

var BaseFromBusinessIndexCols = struct {
	BaseFromBusinessIndexId string
	IndexCode               string
	IndexName               string
	Unit                    string
	Frequency               string
	Source                  string
	SourceName              string
	StartDate               string
	EndDate                 string
	Remark                  string
	BaseModifyTime          string
	DataUpdateTime          string
	CreateTime              string
	ModifyTime              string
}{
	BaseFromBusinessIndexId: "base_from_business_index_id",
	IndexCode:               "index_code",
	IndexName:               "index_name",
	Unit:                    "unit",
	Frequency:               "frequency",
	Source:                  "source",
	SourceName:              "source_name",
	StartDate:               "start_date",
	EndDate:                 "end_date",
	Remark:                  "remark",
	BaseModifyTime:          "base_modify_time",
	DataUpdateTime:          "data_update_time",
	CreateTime:              "create_time",
	ModifyTime:              "modify_time",
}

type EdbBusinessSource struct {
	EdbBusinessSourceId int64     `orm:"column(edb_business_source_id);pk" gorm:"primaryKey" `
	SourceName          string    `description:"来源名称"` // 来源名称
	CreateTime          time.Time `description:"创建时间"` // 创建时间
}

func (m *EdbBusinessSource) GetEdbBusinessSourceItem(sourceName string) (item *EdbBusinessSource, err error) {
	sql := `SELECT * FROM edb_business_source WHERE source_name = ? `
	err = global.DmSQL["data"].Raw(sql, sourceName).First(&item).Error

	return
}

func (m *EdbBusinessSource) GetAllList() (items []*EdbBusinessSource, err error) {
	o := global.DmSQL["data"]
	sql := `SELECT * FROM edb_business_source order by  edb_business_source_id desc `
	err = o.Raw(sql).Scan(&items).Error

	return
}

func (m *BaseFromBusinessIndex) GetListCount(condition string, pars []interface{}) (count int, err error) {
	sql := ` select count(1) as count FROM base_from_business_index as a WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	err = global.DmSQL["data"].Raw(sql, pars...).Scan(&count).Error

	return
}

func (m *BaseFromBusinessIndex) GetList(condition string, pars []interface{}, startSize, pageSize int) (items []*BaseFromBusinessIndex, err error) {
	sql := `select * FROM base_from_business_index AS a  WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += ` order by a.base_from_business_index_id desc limit ?,? `

	pars = append(pars, startSize)
	pars = append(pars, pageSize)
	err = global.DmSQL["data"].Raw(sql, pars...).Scan(&items).Error

	return
}

type BusinessIndexListResp struct {
	List   []*BaseFromBusinessIndexItem
	Paging *paging.PagingItem `description:"分页数据"`
}

type BaseFromBusinessIndexItem struct {
	BaseFromBusinessIndexId int64  `orm:"column(base_from_business_index_id);pk" gorm:"primaryKey" `
	IndexCode               string `description:"指标编码"`
	IndexName               string `description:"指标名称"`
	Unit                    string `description:"单位"`
	Frequency               string `description:"频度"`
	Source                  int    `description:"数据来源"`
	SourceName              string `description:"数据来源名称"`
	StartDate               string `description:"开始日期"`
	EndDate                 string `description:"结束日期"`
	Remark                  string `description:"备注字段"`
	BaseModifyTime          string `description:"基础信息(名称，单位，频度)变更时间"`
	DataUpdateTime          string `description:"最近一次数据发生变化的时间"`
	CreateTime              string `description:"创建时间"`
	ModifyTime              string `description:"修改时间"`
	EdbInfoId               int    `description:"eta指标库的id"`
	EdbUniqueCode           string `description:"指标库唯一编码"`
	EdbClassifyId           int    `description:"指标库分类ID"`
	EdbExist                int    `description:"指标库是否已添加：0-否；1-是"`
}

func (m *BaseFromBusinessIndex) GetPageItemsByCondition(condition string, pars []interface{}, orderRule string, startSize, pageSize int) (items []*BaseFromBusinessIndexItem, err error) {
	sql := `select a.*,b.edb_info_id,b.unique_code as edb_unique_code,b.classify_id as edb_classify_id FROM base_from_business_index AS a LEFT JOIN edb_info b on a.index_code=b.edb_code AND b.source=? WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	if orderRule == `` {
		sql += ` order by a.base_from_business_index_id desc`
	} else {
		sql += ` order by ` + orderRule
	}
	sql += ` limit ?,? `

	err = global.DmSQL["data"].Raw(sql, utils.DATA_SOURCE_BUSINESS, pars, startSize, pageSize).Scan(&items).Error

	return
}

func (m *BaseFromBusinessIndex) GeItemsByCondition(condition string, pars []interface{}, limitSize int) (items []*BaseFromBusinessIndexItem, err error) {
	if pars == nil {
		pars = make([]interface{}, 0)
	}

	sql := `select a.*,b.edb_info_id,b.unique_code as edb_unique_code,b.classify_id as edb_classify_id FROM base_from_business_index AS a LEFT JOIN edb_info b on a.index_code=b.edb_code AND b.source=? WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += ` order by a.base_from_business_index_id desc `

	pars = append(pars, utils.DATA_SOURCE_BUSINESS)
	if limitSize > 0 {
		sql += " limit ? "
		pars = append(pars, limitSize)
	}

	err = global.DmSQL["data"].Raw(sql, pars...).Scan(&items).Error

	return
}

func (m *BaseFromBusinessIndex) GetDetailByEdbCode(edbCode string) (item *BaseFromBusinessIndex, err error) {
	sql := `select *  FROM base_from_business_index  WHERE index_code = ? `
	o := global.DmSQL["data"]
	err = o.Raw(sql, edbCode).First(&item).Error

	return
}

type BusinessIndexDataListResp struct {
	List   []*BaseFromBusinessIndexDataItem
	Paging *paging.PagingItem `description:"分页数据"`
}

type BaseFromBusinessIndexDataItem struct {
	ID        string
	EdbDataId int `orm:"column(edb_data_id);pk" gorm:"primaryKey" `
	IndexCode string
	DataTime  string
	Value     float64
}