package data_manage

import (
	"eta_gn/eta_task/global"
	"time"
)

type BaseFromTradeZhengzhouIndex struct {
	BaseFromTradeZhengzhouIndexId int `orm:"column(base_from_trade_zhengzhou_index_id);pk"`
	Rank                          int
	DealShortName                 string
	DealName                      string
	DealCode                      string
	DealValue                     int
	DealChange                    int
	BuyShortName                  string
	BuyName                       string
	BuyCode                       string
	BuyValue                      int
	BuyChange                     int
	SoldShortName                 string
	SoldName                      string
	SoldCode                      string
	SoldValue                     int
	SoldChange                    int
	Frequency                     string
	ClassifyName                  string
	ClassifyType                  string
	CreateTime                    time.Time
	ModifyTime                    time.Time
	DataTime                      string
}

func AddBaseFromTradeZhengzhouIndex(item *BaseFromTradeZhengzhouIndex) (lastId int64, err error) {
	//o := orm.NewOrm()
	//lastId, err = o.Insert(item)

	err = global.DEFAULT_DmSQL.Create(item).Error
	if err != nil {
		return
	}
	lastId = int64(item.BaseFromTradeZhengzhouIndexId)
	return
}

func GetBaseFromTradeZhengzhouIndexAll(dateStr string) (list []*BaseFromTradeZhengzhouIndex, err error) {
	//o := orm.NewOrm()
	sql := `SELECT * FROM base_from_trade_zhengzhou_index WHERE data_time>=?`
	//_, err = o.Raw(sql, dateStr).QueryRows(&list)

	err = global.DEFAULT_DmSQL.Raw(sql, dateStr).Find(&list).Error
	return
}

func ModifyBaseFromTradeZhengzhouIndex(dealValue, buyValue, soldValue int, dataId int) (err error) {
	//o := orm.NewOrm()
	sql := `UPDATE base_from_trade_zhengzhou_index SET deal_value=?,buy_value=?,sold_value=?,modify_time=NOW() WHERE base_from_trade_zhengzhou_index_id=? `

	//_, err = o.Raw(sql, dealValue, buyValue, soldValue, dataId).Exec()
	err = global.DEFAULT_DmSQL.Exec(sql, dealValue, buyValue, soldValue, dataId).Error
	return
}

type ZhengzhouIndexResp struct {
	Ret     int
	Msg     string
	ErrMsg  string
	ErrCode string
	Data    []*BaseFromTradeZhengzhouIndex
}

func GetBaseFromTradeZhengzhouIndexMaxDate() (max_date time.Time, err error) {
	//o := orm.NewOrm()
	sql := ` SELECT max(a.data_time)as max_date FROM base_from_trade_zhengzhou_index as a `
	//err = o.Raw(sql).QueryRow(&max_date)
	err = global.DEFAULT_DmSQL.Raw(sql).Scan(&max_date).Error
	return
}