package data_manage

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

type ChartInfo struct {
	ChartInfoId     int    `gorm:"column:chart_info_id;primaryKey"` //  `orm:"column(chart_info_id);pk"`
	ChartName       string `description:"来源名称"`
	ChartClassifyId int    `description:"图表分类id"`
	SysUserId       int
	SysUserRealName string
	UniqueCode      string `description:"图表唯一编码"`
	CreateTime      time.Time
	ModifyTime      time.Time
	DateType        int    `description:"日期类型:1:00年至今,2:10年至今,3:15年至今，4：年初至今，5:自定义时间"`
	StartDate       string `description:"自定义开始日期"`
	EndDate         string `description:"自定义结束日期"`
	IsSetName       int    `description:"设置名称"`
	EdbInfoIds      string `description:"指标id"`
	ChartType       int    `description:"生成样式:1:曲线图,2:季节性图"`
	Calendar        string `description:"公历/农历"`
	SeasonStartDate string `description:"季节性图开始日期"`
	SeasonEndDate   string `description:"季节性图开始日期"`
	ChartImage      string `description:"图表图片"`
	Sort            int    `description:"排序字段，数字越小越排前面"`
	EdbEndDate      string `description:"指标最后更新日期"`
	Source          int    `description:"1：ETA图库；2：商品价格曲线"`
	ExtraConfig     string `description:"图表额外配置,json数据"`
}

func GetAllChartInfo() (list []*ChartInfo, err error) {
	//o := orm.NewOrm()
	sql := ` SELECT * FROM chart_info  `
	//_, err = o.Raw(sql).QueryRows(&list)

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

func GetChartInfoEdbEndDate() (list []*ChartInfo, err error) {
	//o := orm.NewOrm()
	//sql := ` SELECT a.*,max(c.end_date) AS edb_end_date FROM  chart_info  AS a
	//		INNER JOIN chart_edb_mapping AS b ON a.chart_info_id=b.chart_info_id
	//		INNER JOIN edb_info AS c ON b.edb_info_id=c.edb_info_id
	//		GROUP BY a.chart_info_id  `

	sql := `SELECT a.chart_info_id, a.chart_name, a.unique_code, a.chart_classify_id, a.sys_user_id, a.sys_user_real_name, a.create_time, a.modify_time, a.date_type, a.start_date, a.end_date, a.is_set_name, a.edb_info_ids, a.chart_type, a.calendar, a.season_start_date, a.season_end_date, a.chart_image, a.sort, a.edb_end_date, a.x_min, a.x_max, a.left_min, a.left_max, a.right_min, a.right_max, a.right2_min, a.right2_max, a.min_max_save, a.chart_name_en, a.disabled, a.bar_config, a.source, a.extra_config, a.season_extra_config, a.start_year, a.chart_theme_id, a.sources_from, a.instructions, a.markers_lines, a.markers_areas, a.unit, a.unit_en, a.is_join_permission, a.forum_chart_info_id, a.chart_alias, a.date_type_num,max(c.end_date) AS edb_end_date FROM  chart_info  AS a
			INNER JOIN chart_edb_mapping AS b ON a.chart_info_id=b.chart_info_id
			INNER JOIN edb_info AS c ON b.edb_info_id=c.edb_info_id
			GROUP BY a.chart_info_id, a.chart_name, a.unique_code, a.chart_classify_id, a.sys_user_id, a.sys_user_real_name, a.create_time, a.modify_time, a.date_type, a.start_date, a.end_date, a.is_set_name, a.edb_info_ids, a.chart_type, a.calendar, a.season_start_date, a.season_end_date, a.chart_image, a.sort, a.edb_end_date, a.x_min, a.x_max, a.left_min, a.left_max, a.right_min, a.right_max, a.right2_min, a.right2_max, a.min_max_save, a.chart_name_en, a.disabled, a.bar_config, a.source, a.extra_config, a.season_extra_config, a.start_year, a.chart_theme_id, a.sources_from, a.instructions, a.markers_lines, a.markers_areas, a.unit, a.unit_en, a.is_join_permission, a.forum_chart_info_id, a.chart_alias, a.date_type_num `
	//_, err = o.Raw(sql).QueryRows(&list)

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

func ModifyChartInfoEdbEndDate(chartInfoId int, edbEndDate string) (err error) {
	//o := orm.NewOrm()
	sql := ` UPDATE chart_info SET edb_end_date=? WHERE chart_info_id=? `
	//_, err = o.Raw(sql, edbEndDate, chartInfoId).Exec()
	err = global.DEFAULT_DmSQL.Exec(sql, edbEndDate, chartInfoId).Error
	return
}

// 根据chart_info_id数组获取图表信息
func GetChartInfoByChartInfoIds(chartInfoIds []int) (list []*ChartInfo, err error) {
	//o := orm.NewOrmUsingDB("data")
	sql := ` SELECT * FROM chart_info  WHERE chart_info_id IN (` + utils.GetOrmInReplace(len(chartInfoIds)) + `) `
	//_, err = o.Raw(sql, chartInfoIds).QueryRows(&list)
	err = global.DmSQL["data"].Raw(sql, chartInfoIds).Find(&list).Error
	return
}