|
@@ -15,7 +15,7 @@ import (
|
|
|
|
|
|
// EdbDataInsertConfig 指标数据插入配置表
|
|
|
type EdbDataInsertConfig struct {
|
|
|
- EdbInfoId int `orm:"column(edb_info_id);pk" gorm:"primaryKey" description:"指标id"`
|
|
|
+ EdbInfoId int `orm:"column(edb_info_id);pk" gorm:"primaryKey;autoIncrement:false" description:"指标id"`
|
|
|
Date time.Time `description:"插入的日期"`
|
|
|
Value string `description:"插入的值"`
|
|
|
RealDate time.Time `description:"实际数据的值日期"`
|
|
@@ -89,7 +89,7 @@ func CreateEdbDataInsertConfigAndData(edbInfo *EdbInfo, date time.Time, value st
|
|
|
err = nil
|
|
|
|
|
|
// 如果是没有配置,那么就需要添加配置
|
|
|
- if item == nil {
|
|
|
+ if item == nil || item.EdbInfoId <= 0 {
|
|
|
var currLatestDate time.Time
|
|
|
currLatestDateStr := edbInfo.LatestDate // 实际日期
|
|
|
if currLatestDateStr != `` && currLatestDateStr != `0000-00-00` {
|
|
@@ -205,7 +205,7 @@ func updateInsertConfigValueByMysql(to *gorm.DB, edbInfo *EdbInfo, oldConfigDate
|
|
|
|
|
|
// 如果是没有历史数据,那么就需要增加数据
|
|
|
if edbDateData == nil {
|
|
|
- addSql := ` INSERT INTO %s (edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) VALUES ( %d, "%s", "%s", "%s", now(), now(), %s) `
|
|
|
+ addSql := ` INSERT INTO %s (edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) VALUES ( %d, '%s', '%s', '%s', now(), now(), %s) `
|
|
|
addSql = fmt.Sprintf(addSql, tableName, edbInfo.EdbInfoId, edbInfo.EdbCode, dateStr, saveValue, timeStr)
|
|
|
err = to.Exec(addSql).Error
|
|
|
} else if value == "" {
|
|
@@ -223,7 +223,7 @@ func updateInsertConfigValueByMysql(to *gorm.DB, edbInfo *EdbInfo, oldConfigDate
|
|
|
deleteSql = fmt.Sprintf(deleteSql, tableName, edbDateData.EdbDataId)
|
|
|
err = to.Exec(deleteSql).Error
|
|
|
} else {
|
|
|
- updateSql := `UPDATE %s SET data_time = "%s", value = "%s", modify_time= now(), data_timestamp= %s WHERE edb_data_id = %d;`
|
|
|
+ updateSql := `UPDATE %s SET data_time = '%s', value = '%s', modify_time= now(), data_timestamp= %s WHERE edb_data_id = %d;`
|
|
|
updateSql = fmt.Sprintf(updateSql, tableName, dateStr, saveValue, timeStr, edbDateData.EdbDataId)
|
|
|
err = to.Exec(updateSql).Error
|
|
|
}
|