清理代码

models/base_from_python.go

@@ -86,38 +86,6 @@ func AddPythonEdb(edbInfo *EdbInfo, item EdbDataFromPython, edbInfoList []*EdbIn
 	return
 }
 
-// EditPythonEdb 编辑python运算指标
-func EditPythonEdb(edbInfoId int, edbCode string, item EdbDataFromPython) (err error) {
-	var isAdd bool
-	addSql := ` INSERT INTO edb_data_python (edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) values `
-	for k, dateTimeStr := range item.Date {
-		//格式化时间
-		currentDate, tmpErr := time.ParseInLocation(utils.FormatDate, dateTimeStr, time.Local)
-		if tmpErr != nil {
-			err = tmpErr
-			return
-		}
-		timestamp := currentDate.UnixNano() / 1e6
-		timestampStr := fmt.Sprintf("%d", timestamp)
-
-		//值
-		val := item.Value[k]
-		saveVal := utils.SubFloatToString(val, 20)
-		addSql += GetAddSql(fmt.Sprint(edbInfoId), edbCode, dateTimeStr, timestampStr, saveVal)
-
-		isAdd = true
-	}
-
-	if isAdd {
-		addSql = strings.TrimRight(addSql, ",")
-		err = global.DEFAULT_DmSQL.Exec(addSql).Error
-		if err != nil {
-			return
-		}
-	}
-	return
-}
-
 // RefreshAllPythonEdb 刷新所有 python运算指标
 func RefreshAllPythonEdb(edbInfo *EdbInfo, item EdbDataFromPython) (err error) {
 	pythonDataMap := make(map[string]float64)

models/data_stat/edb_info_update_log.go

@@ -40,26 +40,6 @@ type EdbInfoUpdateLog struct {
 }
 
 func AddEdbUpdateLog(item *EdbInfoUpdateLog) (lastId int64, err error) {
-
 	err = global.DEFAULT_DmSQL.Create(item).Error
 	return
 }
-
-// GetEdbUpdateLogByCondition 获取指标更新记录
-func GetEdbUpdateLogByCondition(condition string, pars []interface{}) (item []*EdbInfoUpdateLog, err error) {
-
-	sql := ` SELECT * FROM edb_info_update_log WHERE 1=1 `
-	if condition != "" {
-		sql += condition
-	}
-	err = global.DEFAULT_DmSQL.Raw(sql, pars...).Scan(&item).Error
-	return
-}
-
-// GetEdbUpdateSourceLogByCreateDate 获取指标终端更新记录
-func GetEdbUpdateSourceLogByCreateDate(source int, startDate, endDate string) (item []*EdbInfoUpdateLog, err error) {
-
-	sql := ` SELECT * FROM edb_info_update_log WHERE source = ? and create_time >= ? and create_time < ? and is_source_refresh =1 order by data_update_result asc, id desc`
-	err = global.DEFAULT_DmSQL.Raw(sql, source, startDate, endDate).Scan(&item).Error
-	return
-}

models/data_stat/edb_info_update_stat.go

@@ -48,50 +48,6 @@ func (r *EdbInfoUpdateStat) Add(list []*EdbInfoUpdateStat) (err error) {
 	return
 }
 
-// UpdateEdbUpdateStatMulti 批量更新
-func UpdateEdbUpdateStatMulti(list []*EdbInfoUpdateStat) (err error) {
-	o := orm.NewOrm()
-	sql := `UPDATE edb_info_update_stat 
-SET 
-edb_name = ?,
-edb_name_source = ?,
-frequency = ?,
-unit = ?,
-start_date = ?,
-end_date = ?,
-edb_modify_time = ?,
-latest_date = ?,
-latest_value = ?,
-terminal_code = ?,
-modify_time = ?,
-er_data_update_date = ?,
-is_add = ?,
-need_refresh = ?,
-has_refresh = ?,
-data_update_result = ?,
-data_update_failed_reason = ?,
-data_update_time = ?, 
-update_result = ?,
-update_failed_reason = ?,
-update_time = ?
-WHERE
-	id = ?`
-	p, err := o.Raw(sql).Prepare()
-	if err != nil {
-		return
-	}
-	defer func() {
-		_ = p.Close() // 别忘记关闭 statement
-	}()
-	for _, v := range list {
-		_, err = p.Exec(v.EdbName, v.EdbNameSource, v.Frequency, v.Unit, v.StartDate, v.EndDate, v.EdbModifyTime, v.LatestDate, v.LatestValue, v.TerminalCode, v.ModifyTime, v.ErDataUpdateDate, v.IsAdd, v.NeedRefresh, v.HasRefresh, v.DataUpdateResult, v.DataUpdateFailedReason, v.DataUpdateTime, v.UpdateResult, v.UpdateFailedReason, v.UpdateTime, v.Id)
-		if err != nil {
-			return
-		}
-	}
-	return
-}
-
 // GetEdbUpdateStatByCondition 获取指标更新汇总记录
 func GetEdbUpdateStatByCondition(condition string, pars []interface{}) (item []*EdbInfoUpdateStat, err error) {
 	sql := ` SELECT * FROM edb_info_update_stat WHERE 1=1 `

models/db.go

@@ -1,8 +0,0 @@
-package models
-
-import (
-	_ "github.com/go-sql-driver/mysql"
-)
-
-func init() {
-}

models/edb_config.go

@@ -1,17 +1,5 @@
 package models
 
-import (
-	"eta_gn/eta_index_lib/global"
-)
-
 type EdbConfig struct {
 	ConfigValue string `description:"详情"`
 }
-
-// GetConfigDetailByCode 根据配置编码获取配置的值
-func GetConfigDetailByCode(configCode string) (item *EdbConfig, err error) {
-
-	sql := ` SELECT config_value FROM edb_config WHERE config_code=? `
-	err = global.DEFAULT_DmSQL.Raw(sql, configCode).First(&item).Error
-	return
-}

models/edb_data_calculate_tbz.go

@@ -300,17 +300,3 @@ func refreshAllCalculateTbz(to *gorm.DB, edbInfoId, source, subSource int, fromE
 
 	return
 }
-
-func TbzDiv(a, b float64) string {
-	var valStr string
-	if b != 0 {
-		af := decimal.NewFromFloat(a)
-		bf := decimal.NewFromFloat(b)
-		val, _ := af.Div(bf).Float64()
-		val = val - 1
-		valStr = decimal.NewFromFloat(val).Round(4).String()
-	} else {
-		valStr = "0"
-	}
-	return valStr
-}

models/edb_refresh/edb_refresh_default_config.go

@@ -65,24 +65,6 @@ func (m *EdbRefreshDefaultConfig) Delete() (err error) {
 	return
 }
 
-// GetListBySourceAndFrequency
-// @Description: 根据来源和频度获取列表
-// @author: Roc
-// @datetime 2024-01-04 17:39:47
-// @param source int
-// @param subSource int
-// @param frequency string
-// @return list []*EdbRefreshDefaultConfig
-// @return err error
-func GetListBySourceAndFrequency(source, subSource int, frequency string) (list []*EdbRefreshDefaultConfig, err error) {
-
-	sql := `SELECT * FROM edb_refresh_default_config
-         WHERE source = ? AND sub_source = ? AND frequency = ? ORDER BY id ASC `
-	err = global.DEFAULT_DmSQL.Raw(sql, source, subSource, frequency).Scan(&list).Error
-
-	return
-}
-
 // GetListByCondition
 // @Description: 根据条条件获取默认配置列表
 // @author: Roc

models/edb_source.go

@@ -46,13 +46,6 @@ func GetEdbSourceItemsByCondition(condition string, pars []interface{}, fieldArr
 	return
 }
 
-// GetEdbSourceItemByCondition 获取指标来源
-func GetEdbSourceItemByCondition(condition string, pars []interface{}) (item *EdbSource, err error) {
-	sql := fmt.Sprintf(`SELECT * FROM edb_source WHERE 1=1 %s`, condition)
-	err = global.DEFAULT_DmSQL.Raw(sql, pars...).First(&item).Error
-	return
-}
-
 // InitEdbSource 初始化时加载指标来源对应信息, 避免循环中查库, 注意edb_source表修改table_name的话需要重启服务
 func InitEdbSource() {
 	EdbSourceIdMap = make(map[int]*EdbSource)

models/edb_trade_analysis.go

@@ -55,10 +55,6 @@ func (obj EdbTradeAnalysis) Refresh(edbInfo *EdbInfo, convertData []*EdbDataList
 		cond := fmt.Sprintf(" AND %s = ?", dataOb.Cols().EdbInfoId)
 		pars := make([]interface{}, 0)
 		pars = append(pars, edbInfo.EdbInfoId)
-		//if queryDate != "" {
-		//	cond += fmt.Sprintf(" AND %s >= ?", dataOb.Cols().DataTime)
-		//	pars = append(pars, queryDate)
-		//}
 		list, e := dataOb.GetItemsByCondition(cond, pars, []string{}, "")
 		if e != nil {
 			err = fmt.Errorf("获取指标数据失败, %v", e)

models/factor_edb_series.go

@@ -350,6 +350,4 @@ type FactorEdbRecalculateReq struct {
 // FactorEdbChartRecalculateReq 因子指标关联的图表数据重计算
 type FactorEdbChartRecalculateReq struct {
 	ChartInfoId int `description:"图表ID"`
-	//EdbInfoId   int    `description:"指标ID"`
-	//EdbCode     string `description:"指标编码"`
 }

models/mgo/edb_data_business.go

@@ -502,10 +502,6 @@ func (m *EdbDataBusiness) GetLatestValue(whereParams, selectParam interface{}) (
 		fmt.Println("MgoGetColl Err:", err.Error())
 		return
 	}
-
-	//var result interface{}
-	//err = coll.Find(ctx, whereParams).Select(selectParam).One(&result)
 	err = coll.Find(ctx, whereParams).Select(selectParam).One(&latestValue)
-
 	return
 }

models/mgo/edb_data_ths_hf.go

@@ -434,17 +434,6 @@ func (m *EdbDataThsHf) HandleData(addDataList, updateDataList []EdbDataThsHf) (r
 	return
 }
 
-// EdbInfoMaxAndMinInfo 指标最新数据记录结构体
-//type EdbInfoMaxAndMinInfo struct {
-//	MinDate     time.Time `description:"最小日期" bson:"min_date"`
-//	MaxDate     time.Time `description:"最大日期" bson:"max_date"`
-//	MinValue    float64   `description:"最小值" bson:"min_value"`
-//	MaxValue    float64   `description:"最大值" bson:"max_value"`
-//	LatestValue float64   `description:"最新值" bson:"latest_value"`
-//	LatestDate  time.Time `description:"实际数据最新日期" bson:"latest_date"`
-//	EndValue    float64   `description:"最新值" bson:"end_value"`
-//}
-
 // GetEdbInfoMaxAndMinInfo
 // @Description: 获取当前指标的最大最小值
 // @author: Roc
@@ -476,11 +465,6 @@ func (m *EdbDataThsHf) GetEdbInfoMaxAndMinInfo(whereParams interface{}) (result
 	return
 }
 
-// LatestValue 指标最新数据记录结构体
-//type LatestValue struct {
-//	Value float64 `description:"值" bson:"value"`
-//}
-
 // GetLatestValue
 // @Description: 获取当前指标的最新数据记录
 // @author: Roc
@@ -502,9 +486,6 @@ func (m *EdbDataThsHf) GetLatestValue(whereParams, selectParam interface{}) (lat
 		fmt.Println("MgoGetColl Err:", err.Error())
 		return
 	}
-
-	//var result interface{}
-	//err = coll.Find(ctx, whereParams).Select(selectParam).One(&result)
 	err = coll.Find(ctx, whereParams).Select(selectParam).One(&latestValue)
 	return
 }

models/supply_analysis/base_from_stock_plant_data.go

@@ -368,7 +368,6 @@ func calculateEdb(to *gorm.DB, varietyEdbInfo *VarietyEdbInfo, dataMap map[time.
 	varietyEdbInfo.EndDate = endDate
 	varietyEdbInfo.LatestValue = latestValue
 	varietyEdbInfo.ModifyTime = time.Now()
-	//_, err = to.Update(varietyEdbInfo, "StartDate", "EndDate", "LatestValue", "ModifyTime")
 	err = to.Model(varietyEdbInfo).Select([]string{"StartDate", "EndDate", "LatestValue", "ModifyTime"}).Updates(varietyEdbInfo).Error
 	return
 }

models/supply_analysis/variety_admin_permission.go

@@ -4,7 +4,6 @@ import (
 	"time"
 )
 
-// VarietyAdminPermission variety_admin_permission 品种权限表
 type VarietyAdminPermission struct {
 	Id         int       `gorm:"primaryKey;autoIncrement;column:id" description:"ID"`
 	VarietyId  int       `gorm:"column:variety_id" description:"品种id"`

services/edb_refresh/edb_refresh.go

@@ -1,13 +1,9 @@
 package edb_refresh
 
 import (
-	"context"
 	"eta_gn/eta_index_lib/models/edb_refresh"
-	"eta_gn/eta_index_lib/services/alarm_msg"
 	"eta_gn/eta_index_lib/utils"
 	"fmt"
-	"strings"
-	"sync"
 	"time"
 )
 
@@ -59,53 +55,6 @@ func GetPreviousHalfHourDefaultConfigList(source, subSource int) (list []*edb_re
 	return
 }
 
-// ConfigRefreshData
-// @Description:  配置刷新数据
-// @author: Roc
-// @datetime 2024-01-10 13:55:05
-// @param cont context.Context
-// @return err error
-func ConfigRefreshData(cont context.Context) (err error) {
-	errMsgList := make([]string, 0)
-	defer func() {
-		if err != nil {
-			fmt.Println(err)
-		}
-	}()
-	// 一期是只做wind、同花顺、钢联、有色
-
-	now := time.Now()
-	//now = time.Date(2023, 12, 31, 19, 10, 59, 0, time.Local)
-	//now = time.Date(2023, 12, 31, 16, 50, 59, 0, time.Local)
-	defaultSourceEdbInfoListMap, err := getDefaultRefreshData(now)
-	if err != nil {
-		errMsgList = append(errMsgList, "获取默认刷新数据失败，Err:"+err.Error())
-	}
-	sourceEdbInfoListMap, err := getConfigRefreshData(now)
-	if err != nil {
-		errMsgList = append(errMsgList, "获取指标配置刷新数据失败，Err:"+err.Error())
-	}
-
-	// 将两个合并
-	allSourceEdbInfoListMap := mergeMaps(defaultSourceEdbInfoListMap, sourceEdbInfoListMap)
-	wgNum := len(allSourceEdbInfoListMap)
-	if wgNum <= 0 {
-		return
-	}
-	wg := sync.WaitGroup{}
-	wg.Add(wgNum)
-
-	for _, edbList := range allSourceEdbInfoListMap {
-		go BaseRefreshData(&wg, edbList[0].Source, edbList[0].SubSource, edbList)
-	}
-
-	wg.Wait()
-
-	fmt.Println("Refresh End")
-
-	return
-}
-
 // Function to merge two maps
 func mergeMaps(dst map[string][]*edb_refresh.EdbInfoListAndRefreshConfig, src map[string][]*edb_refresh.EdbInfoListAndRefreshConfig) map[string][]*edb_refresh.EdbInfoListAndRefreshConfig {
 	if dst == nil {
@@ -125,271 +74,6 @@ func mergeMaps(dst map[string][]*edb_refresh.EdbInfoListAndRefreshConfig, src ma
 	return dst
 }
 
-// getDefaultRefreshData
-// @Description: 根据默认配置获取需要刷新的指标列表
-// @author: Roc
-// @datetime 2024-01-10 13:55:38
-// @param now time.Time
-// @return sourceEdbInfoListMap map[string][]*edb_refresh.EdbInfoListAndRefreshConfig
-// @return err error
-func getDefaultRefreshData(now time.Time) (sourceEdbInfoListMap map[string][]*edb_refresh.EdbInfoListAndRefreshConfig, err error) {
-	errMsgList := make([]string, 0)
-	defer func() {
-		if err != nil {
-			fmt.Println(err)
-		}
-	}()
-	// 一期是只做wind、同花顺、钢联、有色
-
-	sourceEdbInfoListMap = make(map[string][]*edb_refresh.EdbInfoListAndRefreshConfig)
-
-	currTimeStr := getPreviousHalfHour(now)
-	fmt.Println(currTimeStr)
-
-	// 所有默认配置刷新项
-	list := make([]*edb_refresh.EdbRefreshDefaultConfig, 0)
-
-	//刷新频率，枚举值：每自然日、每交易日、每周、每旬、每月、每季、每半年、每年
-	refreshFrequencyList := []string{"每自然日", "每交易日", "每周", "每旬", "每月", "每季", "每半年", "每年"}
-
-	// 获取各个刷新频率的配置
-	for _, refreshFrequency := range refreshFrequencyList {
-		// 获取刷新频率条件
-		condition, pars, isHandler := getRefreshFrequencyCondition(now, refreshFrequency)
-		if !isHandler {
-			// 可能是非交易日，所以过滤不处理
-			continue
-		}
-
-		condition += ` AND refresh_frequency = ? AND refresh_time = ?`
-		pars = append(pars, refreshFrequency, currTimeStr)
-
-		// 这两个是excel的数据源，他是从公共机更新的，需要过滤掉
-		condition += ` AND source not in (?,?)`
-		pars = append(pars, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, utils.DATA_SOURCE_YS)
-
-		tmpList, tmpErr := edb_refresh.GetListByCondition(condition, pars)
-		if tmpErr != nil {
-			err = tmpErr
-			return
-		}
-		list = append(list, tmpList...)
-	}
-
-	// 更新的单元格数
-	refreshDataNumMap := make(map[string]*edb_refresh.EdbRefreshDefaultConfig)
-	// 数据源刷新频度的列表数组
-	refreshDataFrequencyListMap := make(map[int]map[int][]string)
-
-	wgNum := 0
-	// 处理待刷新的数据源，整理成数组，方便获取对应的指标
-	for _, item := range list {
-		// 更新的单元格数
-		key := fmt.Sprintf("%d_%d_%s", item.Source, item.SubSource, item.Frequency)
-		refreshDataNumMap[key] = item
-
-		// 数据源刷新频度的列表数组
-		subSourceFrequencyList, ok := refreshDataFrequencyListMap[item.Source]
-		if !ok {
-			subSourceFrequencyList = make(map[int][]string)
-		}
-		frequencyList, ok := subSourceFrequencyList[item.SubSource]
-		if !ok {
-			wgNum++
-			frequencyList = make([]string, 0)
-		}
-		subSourceFrequencyList[item.SubSource] = append(frequencyList, item.Frequency)
-		refreshDataFrequencyListMap[item.Source] = subSourceFrequencyList
-	}
-
-	for source, subSourceFrequencyListMap := range refreshDataFrequencyListMap {
-		switch source {
-		case utils.DATA_SOURCE_MYSTEEL_CHEMICAL, utils.DATA_SOURCE_YS:
-			// 这种不处理
-		default:
-			for subSource, frequencyList := range subSourceFrequencyListMap {
-				edbList, tmpErr := edb_refresh.GetDefaultRefreshEdbInfoListBySourceAndSubSource(source, subSource, frequencyList)
-				if tmpErr != nil {
-					errMsgList = append(errMsgList, fmt.Sprint("source:", source, "subSource:", subSource, "frequencyList:", strings.Join(frequencyList, ","), "err:", tmpErr.Error()))
-				}
-
-				for _, v := range edbList {
-					// 数据刷新的期数
-					dataRefreshNum := utils.DATA_REFRESH
-					key := fmt.Sprintf("%d_%d_%s", v.Source, v.SubSource, v.Frequency)
-					if edbRefreshDefaultConfig, ok := refreshDataNumMap[key]; ok {
-						if edbRefreshDefaultConfig.RefreshAllData == 1 { // 刷新所有数据期数
-							dataRefreshNum = 0
-						} else if edbRefreshDefaultConfig.RefreshDataNum > 0 { //
-							dataRefreshNum = edbRefreshDefaultConfig.RefreshDataNum
-						}
-					}
-					v.DataRefreshNum = dataRefreshNum
-				}
-
-				key := fmt.Sprint(source, "_", subSource)
-				sourceEdbInfoListMap[key] = edbList
-			}
-		}
-	}
-
-	fmt.Println("Get Refresh End")
-	return
-}
-
-// getConfigRefreshData
-// @Description: 根据指标配置获取需要刷新的指标列表
-// @author: Roc
-// @datetime 2024-01-10 13:55:59
-// @param now time.Time
-// @return sourceEdbInfoListMap map[string][]*edb_refresh.EdbInfoListAndRefreshConfig
-// @return err error
-func getConfigRefreshData(now time.Time) (sourceEdbInfoListMap map[string][]*edb_refresh.EdbInfoListAndRefreshConfig, err error) {
-	defer func() {
-		if err != nil {
-			fmt.Println(err)
-		}
-	}()
-	// 一期是只做wind、同花顺、钢联、有色
-
-	sourceEdbInfoListMap = make(map[string][]*edb_refresh.EdbInfoListAndRefreshConfig)
-
-	currTimeStr := getPreviousHalfHour(now)
-
-	// 所有默认配置刷新项
-	list := make([]*edb_refresh.EdbRefreshConfig, 0)
-
-	//刷新频率，枚举值：每自然日、每交易日、每周、每旬、每月、每季、每半年、每年
-	refreshFrequencyList := []string{"每自然日", "每交易日", "每周", "每旬", "每月", "每季", "每半年", "每年"}
-
-	// 获取各个刷新频率的配置
-	for _, refreshFrequency := range refreshFrequencyList {
-		// 获取刷新频率条件
-		condition, pars, isHandler := getRefreshFrequencyCondition(now, refreshFrequency)
-		if !isHandler {
-			// 可能是非交易日，所以过滤不处理
-			continue
-		}
-
-		condition += ` AND refresh_frequency = ? AND refresh_time = ?`
-		pars = append(pars, refreshFrequency, currTimeStr)
-
-		tmpList, tmpErr := edb_refresh.GetEdbRefreshConfigListByCondition(condition, pars)
-		if tmpErr != nil {
-			err = tmpErr
-			return
-		}
-		list = append(list, tmpList...)
-	}
-
-	// 配置列表
-	configIdEdbRefreshConfigMap := make(map[int]*edb_refresh.EdbRefreshConfig)
-	configIdList := make([]int, 0)
-	for _, v := range list {
-		configIdList = append(configIdList, v.EdbRefreshConfigId)
-		configIdEdbRefreshConfigMap[v.EdbRefreshConfigId] = v
-	}
-
-	edbInfoList, err := edb_refresh.GetConfigRefreshEdbInfoListBySourceAndSubSource([]int{utils.DATA_SOURCE_MYSTEEL_CHEMICAL, utils.DATA_SOURCE_YS}, configIdList)
-	if err != nil {
-		return
-	}
-
-	for _, v := range edbInfoList {
-		key := fmt.Sprint(v.Source, "_", v.SubSource)
-		tmpList, ok := sourceEdbInfoListMap[key]
-		if !ok {
-			tmpList = make([]*edb_refresh.EdbInfoListAndRefreshConfig, 0)
-		}
-		// 数据刷新的期数
-		dataRefreshNum := utils.DATA_REFRESH
-		if edbRefreshConfig, ok2 := configIdEdbRefreshConfigMap[v.EdbRefreshConfigId]; ok2 {
-			if edbRefreshConfig.RefreshAllData == 1 { // 刷新所有数据期数
-				dataRefreshNum = 0
-			} else if edbRefreshConfig.RefreshDataNum > 0 { //
-				dataRefreshNum = edbRefreshConfig.RefreshDataNum
-			}
-		}
-		v.DataRefreshNum = dataRefreshNum
-		sourceEdbInfoListMap[key] = append(tmpList, v)
-	}
-
-	fmt.Println("Get ConfigRefreshData End")
-	return
-}
-
-// BaseRefreshData
-// @Description: 基础数据刷新
-// @author: Roc
-// @datetime 2024-01-09 16:27:45
-// @param wg *sync.WaitGroup
-// @return err error
-func BaseRefreshData(wg *sync.WaitGroup, source, subSource int, items []*edb_refresh.EdbInfoListAndRefreshConfig) (err error) {
-	errMsgList := make([]string, 0)
-	defer func() {
-		if err != nil {
-			fmt.Println("来源：", source, "；子来源：", subSource, "；BaseRefreshData Err:"+err.Error())
-			go alarm_msg.SendAlarmMsg(fmt.Sprint("来源：", source, "；子来源：", subSource, "；BaseRefreshData ErrMsg:"+err.Error()), 3)
-		}
-		if len(errMsgList) > 0 {
-			errMsg := fmt.Sprint("来源：", source, "；子来源：", subSource, "；BaseRefreshData Err:"+strings.Join(errMsgList, "\n"))
-			fmt.Println(errMsg)
-			go alarm_msg.SendAlarmMsg(errMsg, 3)
-		}
-		wg.Done()
-	}()
-
-	// 数据刷新的期数
-	dataRefreshNum := utils.DATA_REFRESH
-	// 是否从最开始的日期更新
-	var isRefreshByStartDate bool
-
-	for _, v := range items {
-		if v.DataRefreshNum > 0 {
-			dataRefreshNum = v.DataRefreshNum
-		}
-
-		startDate := ""
-		if isRefreshByStartDate {
-			startDate = v.StartDate.Format(utils.FormatDate)
-		} else {
-			if v.Frequency == "日度" {
-				startDate = v.EndDate.AddDate(0, 0, -dataRefreshNum).Format(utils.FormatDate)
-			} else if v.Frequency == "周度" {
-				startDate = v.EndDate.AddDate(0, 0, -(dataRefreshNum * 7)).Format(utils.FormatDate)
-			} else if v.Frequency == "旬度" {
-				startDate = v.EndDate.AddDate(0, 0, -(dataRefreshNum * 10)).Format(utils.FormatDate)
-			} else if v.Frequency == "月度" {
-				startDate = v.EndDate.AddDate(0, -dataRefreshNum, 0).Format(utils.FormatDate)
-			} else if v.Frequency == "季度" {
-				startDate = v.EndDate.AddDate(0, -dataRefreshNum*3, 0).Format(utils.FormatDate)
-			} else if v.Frequency == "半年度" {
-				startDate = v.EndDate.AddDate(0, -dataRefreshNum*6, 0).Format(utils.FormatDate)
-			} else if v.Frequency == "年度" {
-				startDate = v.EndDate.AddDate(-dataRefreshNum, 0, 0).Format(utils.FormatDate)
-			} else {
-				startDate = v.EndDate.AddDate(0, 0, -utils.DATA_REFRESH).Format(utils.FormatDate)
-			}
-		}
-		fmt.Println(startDate)
-
-		// 数据更新
-		//resp, tmpErr := data.RefreshEdbData(v.EdbInfoId, v.Source, v.SubSource, v.EdbCode, startDate)
-		//if tmpErr != nil {
-		//	errMsgList = append(errMsgList, v.EdbCode+"RefreshEdbData Err:"+tmpErr.Error())
-		//	continue
-		//}
-		//if resp.Ret != 200 {
-		//	errMsgList = append(errMsgList, v.EdbCode+";RefreshEdbData Err:"+resp.Msg+";ErrMsg:"+resp.ErrMsg)
-		//	continue
-		//}
-	}
-
-	fmt.Println("来源：", source, ";子来源：", subSource, "刷新结束")
-
-	return err
-}
-
 // getRefreshFrequencyCondition
 // @Description: 根据时间和刷新频率获取条件
 // @author: Roc