批量修改

models/data_manage/base_from_hisugar.go

@@ -425,9 +425,10 @@ func GetHisugarClassifyById(classifyId int) (ClassifyIds string, err error) {
 	o := global.DbMap[utils.DbNameIndex]
 	//sql := fmt.Sprintf("SELECT %s AS classify_ids FROM base_from_hisugar_classify WHERE base_from_hisugar_classify_id=? OR parent_id=?", utils.GroupUnitFunc(utils.DbDriverName, "base_from_hisugar_classify_id", ",", false, "", "", false))
 
-	sql := fmt.Sprintf("SELECT %s AS classify_ids FROM base_from_hisugar_classify WHERE base_from_hisugar_classify_id=? OR parent_id=?", utils.GenerateQuerySql(utils.GroupUnit, &utils.QueryParam{Column: "base_from_hisugar_classify_id",
-		HasDistinct: false,
-	}))
+	sql := fmt.Sprintf("SELECT %s AS classify_ids FROM base_from_hisugar_classify WHERE base_from_hisugar_classify_id=? OR parent_id=?",
+		utils.GenerateQuerySql(utils.GroupUnit, &utils.QueryParam{Column: "base_from_hisugar_classify_id",
+			HasDistinct: false,
+		}))
 	//sql := ` SELECT GROUP_CONCAT(base_from_hisugar_classify_id) AS classify_ids FROM base_from_hisugar_classify WHERE base_from_hisugar_classify_id=? OR parent_id=?`
 	//sql := ` SELECT AS classify_ids FROM base_from_hisugar_classify WHERE base_from_hisugar_classify_id=? OR parent_id=?`
 	err = o.Raw(sql, classifyId, classifyId).Scan(&ClassifyIds).Error

models/data_manage/base_from_trade_index.go

@@ -4,6 +4,7 @@ import (
 	"eta/eta_api/global"
 	"eta/eta_api/utils"
 	"fmt"
+	"gorm.io/gorm"
 	"time"
 
 	"github.com/rdlucklib/rdluck_tools/paging"
@@ -223,6 +224,21 @@ type BaseFromCoalmineJsmIndex struct {
 	ModifyTime                 string `description:"修改时间"`
 }
 
+func (baseFromCoalmineJsmIndex *BaseFromCoalmineJsmIndex) AfterFind(tx *gorm.DB) (err error) {
+	if utils.NeedDateOrTimeFormat(utils.DbDriverName) {
+		if baseFromCoalmineJsmIndex.CreateTime != "" {
+			baseFromCoalmineJsmIndex.CreateTime = utils.GormDateStrToDateTimeStr(baseFromCoalmineJsmIndex.CreateTime)
+		}
+		if baseFromCoalmineJsmIndex.ModifyTime != "" {
+			baseFromCoalmineJsmIndex.ModifyTime = utils.GormDateStrToDateTimeStr(baseFromCoalmineJsmIndex.ModifyTime)
+		}
+		if baseFromCoalmineJsmIndex.DataTime != "" {
+			baseFromCoalmineJsmIndex.DataTime = utils.GormDateStrToDateStr(baseFromCoalmineJsmIndex.DataTime)
+		}
+	}
+	return
+}
+
 // GetBaseFromCoalmineIndex 查询数据
 func GetBaseFromCoalmineIndex(startDate, endDate string) (items []*BaseFromCoalmineJsmIndex, err error) {
 	o := global.DbMap[utils.DbNameIndex]
@@ -295,6 +311,21 @@ type BaseFromCoalmineCoastalIndex struct {
 	ModifyTime                     string `description:"修改时间"`
 }
 
+func (baseFromCoalmineCoastalIndex *BaseFromCoalmineCoastalIndex) AfterFind(tx *gorm.DB) (err error) {
+	if utils.NeedDateOrTimeFormat(utils.DbDriverName) {
+		if baseFromCoalmineCoastalIndex.CreateTime != "" {
+			baseFromCoalmineCoastalIndex.CreateTime = utils.GormDateStrToDateTimeStr(baseFromCoalmineCoastalIndex.CreateTime)
+		}
+		if baseFromCoalmineCoastalIndex.ModifyTime != "" {
+			baseFromCoalmineCoastalIndex.ModifyTime = utils.GormDateStrToDateTimeStr(baseFromCoalmineCoastalIndex.ModifyTime)
+		}
+		if baseFromCoalmineCoastalIndex.DataTime != "" {
+			baseFromCoalmineCoastalIndex.DataTime = utils.GormDateStrToDateStr(baseFromCoalmineCoastalIndex.DataTime)
+		}
+	}
+	return
+}
+
 // 查询指标
 func GetBaseFromCoalmineCoastalIndex(startDate, endDate string) (items []*BaseFromCoalmineCoastalIndex, err error) {
 	o := global.DbMap[utils.DbNameIndex]

models/data_manage/sci_data.go

@@ -4,6 +4,7 @@ import (
 	"eta/eta_api/global"
 	"eta/eta_api/utils"
 	"github.com/rdlucklib/rdluck_tools/paging"
+	"gorm.io/gorm"
 )
 
 type SciClassify struct {
@@ -49,6 +50,29 @@ type SciIndex struct {
 	ModifyTime         string
 }
 
+func (sciIndex *SciIndex) AfterFind(tx *gorm.DB) (err error) {
+	if utils.NeedDateOrTimeFormat(utils.DbDriverName) {
+		if sciIndex.CreateTime != "" {
+			sciIndex.CreateTime = utils.GormDateStrToDateTimeStr(sciIndex.CreateTime)
+		}
+		if sciIndex.ModifyTime != "" {
+			sciIndex.ModifyTime = utils.GormDateStrToDateTimeStr(sciIndex.ModifyTime)
+		}
+		if sciIndex.ApiStartTime != "" {
+			sciIndex.ApiStartTime = utils.GormDateStrToDateStr(sciIndex.ApiStartTime)
+		}
+		if sciIndex.ApiUpdateTime != "" {
+			sciIndex.ApiUpdateTime = utils.GormDateStrToDateTimeStr(sciIndex.ApiUpdateTime)
+		}
+		if sciIndex.StartTime != "" {
+			sciIndex.StartTime = utils.GormDateStrToDateTimeStr(sciIndex.StartTime)
+		}
+		if sciIndex.FinishTime != "" {
+			sciIndex.FinishTime = utils.GormDateStrToDateTimeStr(sciIndex.FinishTime)
+		}
+	}
+	return
+}
 func GetSciIndex(condition string, pars []interface{}) (items []*SciIndex, err error) {
 	o := global.DbMap[utils.DbNameIndex]
 	sql := ` SELECT * FROM base_from_sci_index WHERE 1=1  `
@@ -121,6 +145,14 @@ type SciIndexData struct {
 	DataTime string `orm:"column(data_time)" description:"值"`
 }
 
+func (sciIndexData *SciIndexData) AfterFind(tx *gorm.DB) (err error) {
+	if utils.NeedDateOrTimeFormat(utils.DbDriverName) {
+		if sciIndexData.DataTime != "" {
+			sciIndexData.DataTime = utils.GormDateStrToDateStr(sciIndexData.DataTime)
+		}
+	}
+	return
+}
 func GetSciIndexData(indexCode string, startSize, pageSize int) (items []*SciIndexData, err error) {
 	o := global.DbMap[utils.DbNameIndex]
 	sql := ` SELECT *  FROM base_from_sci_data WHERE index_code=? ORDER BY data_time DESC LIMIT ?,? `

models/data_source/icpi.go

@@ -4,6 +4,7 @@ import (
 	"eta/eta_api/global"
 	"eta/eta_api/utils"
 	"github.com/rdlucklib/rdluck_tools/paging"
+	"gorm.io/gorm"
 	"time"
 )
 
@@ -57,6 +58,15 @@ type BaseFromIcpiDataView struct {
 	ModifyTime          time.Time `description:"修改时间"`
 }
 
+func (obj *BaseFromIcpiDataView) AfterFind(tx *gorm.DB) (err error) {
+	if utils.NeedDateOrTimeFormat(utils.DbDriverName) {
+		if obj.DataTime != "" {
+			obj.DataTime = utils.GormDateStrToDateStr(obj.DataTime)
+		}
+	}
+	return
+}
+
 type BaseFromIcpiIndexView struct {
 	BaseFromIcpiIndexId    int                     `description:"指标id"`
 	BaseFromIcpiClassifyId int                     `description:"分类id"`
@@ -72,6 +82,23 @@ type BaseFromIcpiIndexView struct {
 	Paging                 *paging.PagingItem      `description:"分页数据" gorm:"-"`
 }
 
+func (obj *BaseFromIcpiIndexView) AfterFind(tx *gorm.DB) (err error) {
+	if utils.NeedDateOrTimeFormat(utils.DbDriverName) {
+		if obj.CreateTime != "" {
+			obj.CreateTime = utils.GormDateStrToDateTimeStr(obj.CreateTime)
+		}
+		if obj.ModifyTime != "" {
+			obj.ModifyTime = utils.GormDateStrToDateTimeStr(obj.ModifyTime)
+		}
+		if obj.StartDate != "" {
+			obj.StartDate = utils.GormDateStrToDateStr(obj.StartDate)
+		}
+		if obj.EndDate != "" {
+			obj.EndDate = utils.GormDateStrToDateStr(obj.EndDate)
+		}
+	}
+	return
+}
 func (obj *BaseFromIcpiIndex) GetIcpiIndex(condition string, pars []interface{}) (items []*BaseFromIcpiIndexView, err error) {
 	o := global.DbMap[utils.DbNameIndex]
 	sql := ` SELECT * FROM base_from_icpi_index WHERE 1=1  `