eta_crawler/models/base_from_coal_coastal.go

package models

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

// BaseFromCoalmineCoastalIndex 沿海八省动力煤用户供耗存数据指标表
type BaseFromCoalmineCoastalIndex struct {
	BaseFromCoalmineCoastalIndexID int       `orm:"column(base_from_coalmine_coastal_index_id);pk"`
	IndexName                      string    // 省份/企业名称
	IndexCode                      string    // 持买单量指标编码
	DataTime                       string    // 指标时间
	DealValue                      string    // 数据量
	GroupName                      string    // 地区
	Source                         string    // 来源
	Unit                           string    //单位
	Frequency                      string    `description:"频率"`
	CreateTime                     time.Time `description:"插入时间"`
	ModifyTime                     time.Time `description:"修改时间"`
}

//查询指标
func GetBaseFromCoalmineCoastalIndex() (items []*BaseFromCoalmineCoastalIndex, err error) {
	o := orm.NewOrmUsingDB("data")
	sql := `SELECT * FROM base_from_coalmine_coastal_index`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

//添加数据
func AddBaseFromCoalCoastalIndex(item *BaseFromCoalmineCoastalIndex) (lastId int64, err error) {
	o := orm.NewOrmUsingDB("data")
	lastId, err = o.Insert(item)
	return
}

func UpdateBaseFromCoalCoastalIndex(item *BaseFromCoalmineCoastalIndex) (err error) {
	o := orm.NewOrmUsingDB("data")
	sql := `UPDATE base_from_coalmine_coastal_index SET deal_value=?  WHERE index_name=?  AND  data_time = ?`
	_, err = o.Raw(sql, item.DealValue, item.IndexName, item.DataTime).Exec()
	return
}