eta_crawler/models/base_from_coalmine.go

package models

import (
	"github.com/rdlucklib/rdluck_tools/orm"
	"time"
)

type BaseFromCoalmineMapping struct {
	BaseFromCoalmineMappingId int       `orm:"column(base_from_coalmine_mapping_id);pk"`
	IndexName                 string    `description:"持买单量指标名称"`
	IndexCode                 string    `description:"持买单量指标编码"`
	Exchange                  string    `description:"样本统计类别"`
	Source                    string    `description:"来源"`
	Province                  string    `description:"省份"`
	Description               string    `description:"描述"`
	CreateTime                time.Time `description:"时间"`
}

type BaseFromCoalmineIndex struct {
	BaseFromCoalmineIndexId int       `orm:"column(base_from_coalmine_index_id);pk"`
	IndexName               string    `description:"持买单量指标名称"`
	IndexCode               string    `description:"持买单量指标编码"`
	Exchange                string    `description:"样本统计类别"`
	DealValue               string    `description:"成交量"`
	DataTime                string    `description:"数据日期"`
	CreateTime              time.Time `description:"插入时间"`
	ModifyTime              time.Time `description:"修改时间"`
}

type BaseFromCoalmineCompanyMapping struct {
	BaseFromCoalmineCompanyMappingId int       `orm:"column(base_from_coalmine_company_mapping_id);pk"`
	IndexName                        string    `description:"持买单量指标名称"`
	IndexCode                        string    `description:"持买单量指标编码"`
	Source                           string    `description:"来源"`
	Rank                             string    `description:"序号"`
	Province                         string    `description:"省份"`
	City                             string    `description:"城市"`
	CompanyName                      string    `description:"公司名称"`
	GroupName                        string    `description:"集团名称"`
	CreateTime                       time.Time `description:"时间"`
}

type BaseFromCoalmineCompanyIndex struct {
	BaseFromCoalmineCompanyIndexId int       `orm:"column(base_from_coalmine_company_index_id);pk"`
	IndexName                      string    `description:"持买单量指标名称"`
	IndexCode                      string    `description:"持买单量指标编码"`
	DealValue                      string    `description:"成交量"`
	DataTime                       string    `description:"数据日期"`
	CreateTime                     time.Time `description:"插入时间"`
	ModifyTime                     time.Time `description:"修改时间"`
}

//添加指标
func AddBaseFromCoalmineMapping(item *BaseFromCoalmineMapping) (lastId int64, err error) {
	o := orm.NewOrm()
	o.Using("data")
	lastId, err = o.Insert(item)
	return
}

//查询指标
func GetBaseFromCoalmineMapping() (items []*BaseFromCoalmineMapping, err error) {
	o := orm.NewOrm()
	o.Using("data")
	sql := `SELECT * FROM base_from_coalmine_mapping`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

//查询数据
func GetBaseFromCoalmineIndex() (items []*BaseFromCoalmineIndex, err error) {
	o := orm.NewOrm()
	o.Using("data")
	sql := `SELECT * FROM base_from_coalmine_index`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

func UpdateBaseFromCoalmineIndex(item *BaseFromCoalmineIndex) (err error) {
	o := orm.NewOrm()
	o.Using("data")
	sql := `UPDATE base_from_coalmine_index SET deal_value=?  WHERE index_name=?  AND  data_time = ?`
	_, err = o.Raw(sql, item.DealValue, item.IndexName, item.DataTime).Exec()
	return
}

//添加数据
func AddBaseFromCoalmineIndex(item *BaseFromCoalmineIndex) (lastId int64, err error) {
	o := orm.NewOrm()
	o.Using("data")
	lastId, err = o.Insert(item)
	return
}

//添加公司指标
func AddBaseFromCoalmineCompanyMapping(item *BaseFromCoalmineCompanyMapping) (lastId int64, err error) {
	o := orm.NewOrm()
	o.Using("data")
	lastId, err = o.Insert(item)
	return
}

//查询指标
func GetBaseFromCoalmineCompanyMapping() (items []*BaseFromCoalmineCompanyMapping, err error) {
	o := orm.NewOrm()
	o.Using("data")
	sql := `SELECT * FROM base_from_coalmine_company_mapping`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

//添加公司指标
func AddBaseFromCoalmineCompanyIndex(item *BaseFromCoalmineCompanyIndex) (lastId int64, err error) {
	o := orm.NewOrm()
	o.Using("data")
	lastId, err = o.Insert(item)
	return
}