eta_task/models/data_manage/edb_info.go

package data_manage

import (
	"errors"
	"eta/eta_task/global"
	"eta/eta_task/utils"
	"fmt"
	"gorm.io/gorm"
	"strconv"
	"time"
)

type EdbInfo struct {
	EdbInfoId        int    `gorm:"primaryKey"`
	SourceName       string `description:"来源名称"`
	Source           int    `description:"来源id"`
	TerminalCode     string `description:"终端编码"`
	SubSource        int    `description:"子数据来源:0:经济数据库,1:日期序列"`
	EdbCode          string `description:"指标编码"`
	EdbName          string `description:"指标名称"`
	EdbNameSource    string `description:"指标名称来源"`
	Frequency        string `description:"频率"`
	Unit             string `description:"单位"`
	StartDate        string `description:"起始日期"`
	EndDate          string `description:"终止日期"`
	ClassifyId       int    `description:"分类id"`
	SysUserId        int
	SysUserRealName  string
	UniqueCode       string `description:"指标唯一编码"`
	CreateTime       time.Time
	ModifyTime       time.Time
	MinValue         float64 `description:"指标最小值"`
	MaxValue         float64 `description:"指标最大值"`
	CalculateFormula string  `description:"计算公式"`
	NoUpdate         int8    `description:"是否停止更新，0：继续更新；1：停止更新"`
	EdbInfoType      int     `description:"指标类型，0：普通指标，1：预测指标"`
	EdbType          int     `description:"指标类型:1:基础指标,2:计算指标"`
}

func (m *EdbInfo) AfterFind(db *gorm.DB) (err error) {
	m.StartDate = utils.GormDateStrToDateStr(m.StartDate)
	m.EndDate = utils.GormDateStrToDateStr(m.EndDate)
	return
}

func (m *EdbInfo) ConvertTimeStr() {
	m.StartDate = utils.GormDateStrToDateStr(m.StartDate)
	m.EndDate = utils.GormDateStrToDateStr(m.EndDate)
	return
}

type EdbInfoList struct {
	EdbInfoId        int       `gorm:"primaryKey"`
	SourceName       string    `description:"来源名称"`
	Source           int       `description:"来源id"`
	SubSource        int       `description:"子数据来源:0:经济数据库,1:日期序列"`
	SubSourceName    string    `description:"子数据来源名称"`
	EdbCode          string    `description:"指标编码"`
	EdbName          string    `description:"指标名称"`
	Frequency        string    `description:"频率"`
	Unit             string    `description:"单位"`
	StartDate        time.Time `description:"起始日期"`
	EndDate          time.Time `description:"终止日期"`
	ClassifyId       int       `description:"分类id"`
	UniqueCode       string    `description:"指标唯一编码"`
	CalculateFormula string    `description:"计算公式"`
	ModifyTime       string    `description:"更新时间"`
	NoUpdate         int8      `description:"是否停止更新，0：继续更新；1：停止更新"`
}

func (m *EdbInfoList) AfterFind(db *gorm.DB) (err error) {
	m.ModifyTime = utils.GormDateStrToDateStr(m.ModifyTime)
	return
}

type EdbInfoSearchData struct {
	EdbDataId int     `description:"指标数据Id"`
	DataTime  string  `description:"数据日期"`
	Value     float64 `description:"数据"`
}

func (m *EdbInfoSearchData) AfterFind(db *gorm.DB) (err error) {
	m.DataTime = utils.GormDateStrToDateStr(m.DataTime)
	return
}

type EdbInfoSearchDataV1 struct {
	DataTime string `description:"数据日期"`
	Value    string `description:"数据"`
}

func (m *EdbInfoSearchDataV1) AfterFind(db *gorm.DB) (err error) {
	m.DataTime = utils.GormDateStrToDateStr(m.DataTime)
	return
}

func GetEdbInfoByCondition(condition string, pars []interface{}, order int) (item []*EdbInfoList, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	if order == 1 {
		sql += ` ORDER BY end_date ASC `
	} else {
		sql += ` ORDER BY edb_info_id ASC `
	}
	err = o.Raw(sql, pars...).Find(&item).Error
	return
}

//func ModifyEdbDataInfoDate(edbInfoId int, maxDate string) (err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	sql := ` UPDATE edb_info SET end_date=?,modify_time=NOW() WHERE edb_info_id=? `
//	err = o.Exec(sql, maxDate, edbInfoId).Error
//	return
//}

type EdbInfoMaxAndMinInfo struct {
	MinDate     string  `description:"最小日期"`
	MaxDate     string  `description:"最大日期"`
	MinValue    float64 `description:"最小值"`
	MaxValue    float64 `description:"最大值"`
	LatestValue float64 `description:"最新值"`
}

func (m *EdbInfoMaxAndMinInfo) ConvertTimeStr() {
	m.MinDate = utils.GormDateStrToDateStr(m.MinDate)
	m.MaxDate = utils.GormDateStrToDateStr(m.MaxDate)
	return
}

func GetEdbInfoMaxAndMinInfo(source, subSource int, edbCode string) (item *EdbInfoMaxAndMinInfo, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ``
	tableName := GetEdbDataTableName(source, subSource)
	if tableName == "" {
		err = errors.New("无效的表名称:source:" + strconv.Itoa(source))
		return nil, err
	}
	sql = ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date,MIN(value) AS min_value,MAX(value) AS max_value FROM %s WHERE edb_code=? `
	sql = fmt.Sprintf(sql, tableName)
	err = o.Raw(sql, edbCode).First(&item).Error
	if err != nil {
		return
	}
	if item != nil {
		item.ConvertTimeStr()
	}

	var latest_value float64
	sql = ` SELECT value AS latest_value FROM %s WHERE edb_code=? ORDER BY data_time DESC LIMIT 1 `
	sql = fmt.Sprintf(sql, tableName)
	sql = utils.ReplaceDriverKeywords("", sql)
	err = o.Raw(sql, edbCode).Scan(&latest_value).Error
	item.LatestValue = latest_value
	return
}

func ModifyEdbInfoMaxAndMinInfo(edbInfoId int, item *EdbInfoMaxAndMinInfo) (err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` UPDATE edb_info SET start_date=?,end_date=?,min_value=?,max_value=?,is_update=2,latest_date=?,latest_value=?,modify_time=NOW() WHERE edb_info_id=? `
	err = o.Exec(sql, item.MinDate, item.MaxDate, item.MinValue, item.MaxValue, item.MaxDate, item.LatestValue, edbInfoId).Error
	return
}

//order:1升序，其余值为降序
func GetEdbDataListAll(condition string, pars []interface{}, source, subSource, order int) (item []*EdbInfoSearchData, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ``
	tableName := GetEdbDataTableName(source, subSource)
	sql = ` SELECT * FROM %s WHERE 1=1 `
	sql = fmt.Sprintf(sql, tableName)

	if condition != "" {
		sql += condition
	}
	if order == 1 {
		sql += ` ORDER BY data_time ASC `
	} else {
		sql += ` ORDER BY data_time DESC `
	}
	err = o.Raw(sql, pars...).Find(&item).Error
	return
}

func GetEdbDataListAllV1(condition string, pars []interface{}, source, subSource, order int) (item []*EdbInfoSearchDataV1, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ``
	tableName := GetEdbDataTableName(source, subSource)
	sql = ` SELECT * FROM %s WHERE 1=1 `
	sql = fmt.Sprintf(sql, tableName)

	if condition != "" {
		sql += condition
	}
	if order == 1 {
		sql += ` ORDER BY data_time ASC `
	} else {
		sql += ` ORDER BY data_time DESC `
	}
	err = o.Raw(sql, pars...).Find(&item).Error
	return
}

func GetEdbInfoById(edbInfoId int) (item *EdbInfo, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE edb_info_id=? `
	err = o.Raw(sql, edbInfoId).First(&item).Error
	return
}

func GetQuarterEdbInfo() (item []*EdbInfo, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT c.* 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
			WHERE a.chart_type=2
			GROUP BY b.edb_info_id
			ORDER BY b.edb_info_id ASC  `
	err = o.Raw(sql).Find(&item).Error
	return
}

func ResetEdbInfoIsUpdate() (err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` UPDATE edb_info SET is_update=1  `
	err = o.Exec(sql).Error
	return
}

// GetEdbInfoCalculateListByCondition 获取指标关系列表
func GetEdbInfoCalculateListByCondition(condition string, pars []interface{}) (items []*EdbInfoCalculateMapping, err error) {
	o := global.DbMap[utils.DbNameIndex]
	//calculateTableName := GetEdbInfoCalculateTableName(source)
	//if calculateTableName == "" {
	//	err = errors.New("无效的表名")
	//	return
	//}

	sql := ` SELECT * FROM edb_info_calculate_mapping WHERE 1=1 `
	//sql = fmt.Sprintf(sql, calculateTableName)
	if condition != "" {
		sql += condition
	}
	err = o.Raw(sql, pars...).Find(&items).Error
	return
}

func DeleteEdbDataByIdAndSource(edbDataId, source, subSource int) (err error) {
	sql := ` DELETE FROM %s WHERE edb_data_id=? `
	tableName := GetEdbDataTableName(source, subSource)
	sql = fmt.Sprintf(sql, tableName)

	o := global.DbMap[utils.DbNameIndex]
	err = o.Exec(sql, edbDataId).Error
	return
}

type EdbInfoClassify struct {
	EdbInfoId       int    `gorm:"primaryKey"`
	SourceName      string `description:"来源名称"`
	Source          int    `description:"来源id"`
	EdbCode         string `description:"指标编码"`
	ClassifyId      int    `description:"分类id"`
	SysUserId       int
	SysUserRealName string
	UniqueCode      string `description:"指标唯一编码"`
	CreateTime      time.Time
	ModifyTime      time.Time
}

// GetAllEdbInfoClassifyListByCondition
// @Description: 获取指标与分类的关系列表
// @author: Roc
// @datetime 2024-02-29 10:55:38
// @param condition string
// @param pars []interface{}
// @return item []*EdbInfoUpdateLog
// @return err error
func GetAllEdbInfoClassifyListByCondition(condition string, pars []interface{}) (item []*EdbInfoClassify, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += `ORDER BY edb_info_id ASC `
	err = o.Raw(sql, pars...).Find(&item).Error
	return
}

// GetEdbInfoItemByCodeAndSource
// @Description: 根据指标编码和来源id获取指标信息
// @author: Roc
// @datetime 2024-03-11 16:26:23
// @param source int
// @param edbCode string
// @return item *EdbInfo
// @return err error
func GetEdbInfoItemByCodeAndSource(source int, edbCode string) (item *EdbInfoItem, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE edb_code=? AND source = ?`
	err = o.Raw(sql, source, edbCode).First(&item).Error
	if err != nil {
		return
	}
	if item != nil && item.EdbInfoId > 0 {
		item.ConvertTimeStr()
	}
	return
}

// GetEdbInfoMaxModifyTime
// @Description:  根据指标来源和编码获取该指标数据最晚修改时间
// @author: Roc
// @datetime 2024-03-11 17:01:01
// @param source int
// @param edbCode string
// @return modifyTime string
// @return err error
func GetEdbInfoMaxModifyTime(source, subSource int, edbCode string) (modifyTime string, err error) {
	o := global.DbMap[utils.DbNameIndex]
	tableName := GetEdbDataTableName(source, subSource)
	if tableName == "" {
		err = errors.New("无效的表名称:source:" + strconv.Itoa(source))
		return
	}

	sql := ` SELECT MAX(modify_time) AS modify_time FROM %s WHERE edb_code=? `
	sql = fmt.Sprintf(sql, tableName)
	err = o.Raw(sql, edbCode).Scan(&modifyTime).Error
	return
}

func GetEdbInfoPageByCondition(condition string, pars []interface{}, startPage, pageSize int) (item []*EdbInfo, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,? `
	pars = append(pars, startPage, pageSize)
	err = o.Raw(sql, pars...).Find(&item).Error
	return
}

func GetEdbInfoCountByCondition(condition string, pars []interface{}) (total int64, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT count(*) FROM edb_info WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	err = o.Raw(sql, pars...).Scan(&total).Error
	return
}

func ModifyEdbUpdateStatus(edbIdList []int, indexCodeList []string, calculateEdbInfoIds []int) (err error) {
	idNum := len(edbIdList)
	if idNum <= 0 {
		return
	}
	o := global.DbMap[utils.DbNameIndex]
	tx := o.Begin()
	if tx.Error != nil {
		return tx.Error
	}
	defer func() {
		if err != nil {
			_ = tx.Rollback()
			return
		}
		_ = tx.Commit()
	}()

	// 更改指标的更新状态
	sql := ` UPDATE edb_info SET no_update = 1 WHERE source in (?,?,?,?,?) AND edb_info_id IN (` + utils.GetOrmInReplace(idNum) + `) AND  no_update = 0`
	err = tx.Exec(sql, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, utils.DATA_SOURCE_WIND, utils.DATA_SOURCE_PB_FINANCE, utils.DATA_SOURCE_PB, utils.DATA_SOURCE_THS, edbIdList).Error
	if err != nil {
		return
	}

	// 更改钢联化工指标更新状态
	if len(indexCodeList) > 0 {
		// 更改数据源的更新状态
		sql = ` UPDATE base_from_mysteel_chemical_index SET is_stop = 1 WHERE index_code IN (` + utils.GetOrmInReplace(len(indexCodeList)) + `) and is_stop=0`
		err = tx.Exec(sql, indexCodeList).Error
		if err != nil {
			return
		}
	}

	// 更新相关的计算指标状态
	if len(calculateEdbInfoIds) > 0 {
		// 批量更新相关联的指标ID
		sql = ` UPDATE edb_info SET no_update = 1 WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(calculateEdbInfoIds)) + `) AND  no_update = 0`
		err = tx.Exec(sql, calculateEdbInfoIds).Error
		if err != nil {
			return
		}
	}
	return
}

//func StopRefreshCalculateEdbIndex(edbInfoId int) (err error) {
//	o := global.DbMap[utils.DbNameIndex]
//	// 更改指标的更新状态
//	sql := ` UPDATE edb_info SET no_update = 1,set_update_time=? WHERE edb_type =2 AND edb_info_id = ? AND  no_update = 0`
//	err = o.Exec(sql, time.Now(), edbInfoId).Error
//	return
//}

// GetEdbInfoByIdList 根据指标id集合 获取 指标列表
func GetEdbInfoByIdList(edbInfoIdList []int) (items []*EdbInfo, err error) {
	num := len(edbInfoIdList)
	if num <= 0 {
		return
	}
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE edb_info_id in (` + utils.GetOrmInReplace(num) + `) `
	err = o.Raw(sql, edbInfoIdList).Find(&items).Error
	return
}

func GetEdbInfoBySourceAndTerminalCode(source int, terminalCode string) (item *EdbInfo, err error) {
	o := global.DbMap[utils.DbNameIndex]
	sql := ` SELECT * FROM edb_info WHERE source = ? and sub_source = 0 and terminal_code = ? and frequency = '日度' and no_update = 0 limit 1 `
	err = o.Raw(sql, source, terminalCode).First(&item).Error
	return
}