Sfoglia il codice sorgente

feat:新增获取单个指标的刷新配置列表接口

Roc 1 anno fa
parent
commit
322418ea92

+ 2 - 2
models/data_manage/edb_info.go

@@ -1748,9 +1748,9 @@ type EdbInfoSmmExistCheckResp struct {
 // @param startSize int
 // @param pageSize int
 // @return total int
-// @return items []*BaseEdbInfo
+// @return items []*BaseRefreshEdbInfo
 // @return err error
-func GetEdbBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseEdbInfo, err error) {
+func GetEdbBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseRefreshEdbInfo, err error) {
 	o := orm.NewOrmUsingDB("data")
 	// 数量汇总
 	totalSql := ` SELECT count(1) FROM edb_info WHERE 1=1 `

+ 6 - 4
models/data_manage/mysteel_chemical_index.go

@@ -340,7 +340,9 @@ func GetMysteelChemicalGroupTerminalNum() (items []*TerminalNum, err error) {
 	return
 }
 
-type BaseEdbInfo struct {
+// BaseRefreshEdbInfo
+// @Description: 刷新配置的基础指标信息结构体
+type BaseRefreshEdbInfo struct {
 	EdbInfoId       int
 	ClassifyId      int    `description:"钢联化工指标分类id"`
 	IndexCode       string `description:"指标编码"`
@@ -359,7 +361,7 @@ type BaseEdbInfo struct {
 // @Description: 刷新数据源的数据返回
 type RefreshBaseEdbInfoResp struct {
 	Paging *paging.PagingItem
-	List   []*BaseEdbInfo
+	List   []*BaseRefreshEdbInfo
 }
 
 // GetMysteelChemicalBaseInfoList
@@ -372,9 +374,9 @@ type RefreshBaseEdbInfoResp struct {
 // @param startSize int
 // @param pageSize int
 // @return total int
-// @return items []*BaseEdbInfo
+// @return items []*BaseRefreshEdbInfo
 // @return err error
-func GetMysteelChemicalBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseEdbInfo, err error) {
+func GetMysteelChemicalBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseRefreshEdbInfo, err error) {
 	o := orm.NewOrmUsingDB("data")
 
 	// 数量汇总

+ 2 - 2
models/data_manage/smm_data.go

@@ -260,9 +260,9 @@ func GetExportSmmIndexDataByCodes(indexCodes []string) (items []*ExportSmmIndexD
 // @param startSize int
 // @param pageSize int
 // @return total int
-// @return items []*BaseEdbInfo
+// @return items []*BaseRefreshEdbInfo
 // @return err error
-func GetSmmBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseEdbInfo, err error) {
+func GetSmmBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseRefreshEdbInfo, err error) {
 	o := orm.NewOrmUsingDB("data")
 
 	// 数量汇总

+ 6 - 6
services/data/edb_info_refresh.go

@@ -314,12 +314,12 @@ func SaveEdbRefreshConfig(source, subSource, classifyId int, terminalCode, frequ
 // @datetime 2024-01-10 17:00:03
 // @param source int
 // @param subSource int
-// @param list []*data_manage.BaseEdbInfo
-// @return newList []*data_manage.BaseEdbInfo
+// @param list []*data_manage.BaseRefreshEdbInfo
+// @return newList []*data_manage.BaseRefreshEdbInfo
 // @return err error
 // @return errMsg string
 // @return isSendEmail bool
-func HandleRefreshTime(source, subSource int, list []*data_manage.BaseEdbInfo) (newList []*data_manage.BaseEdbInfo, err error, errMsg string, isSendEmail bool) {
+func HandleRefreshTime(source, subSource int, list []*data_manage.BaseRefreshEdbInfo) (newList []*data_manage.BaseRefreshEdbInfo, err error, errMsg string, isSendEmail bool) {
 	isSendEmail = true
 	errMsg = "获取失败"
 	newList = list
@@ -403,13 +403,13 @@ func HandleRefreshTime(source, subSource int, list []*data_manage.BaseEdbInfo) (
 // @param startSize int
 // @param pageSize int
 // @return total int
-// @return list []*data_manage.BaseEdbInfo
+// @return list []*data_manage.BaseRefreshEdbInfo
 // @return err error
-func GetList(source, subSource, classifyId int, terminalCode, sysUserId, frequency, keyword, status string, startSize, pageSize int, sortParam, sortType string) (total int, list []*data_manage.BaseEdbInfo, err error) {
+func GetList(source, subSource, classifyId int, terminalCode, sysUserId, frequency, keyword, status string, startSize, pageSize int, sortParam, sortType string) (total int, list []*data_manage.BaseRefreshEdbInfo, err error) {
 	var pars []interface{}
 	var condition string
 
-	list = make([]*data_manage.BaseEdbInfo, 0)
+	list = make([]*data_manage.BaseRefreshEdbInfo, 0)
 
 	isStop := -1
 	if status == `暂停` {