fix bug

services/data/base_edb_lib.go

@@ -28,6 +28,12 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *mod
 		urlStr = "pb_finance/refresh"
 	case utils.DATA_SOURCE_MANUAL:
 		urlStr = "manual/refresh"
+	case utils.DATA_SOURCE_LZ:
+		urlStr = "lz/refresh"
+	case utils.DATA_SOURCE_YS:
+		urlStr = "smm/refresh"
+	case utils.DATA_SOURCE_GL:
+		urlStr = "mysteel/refresh"
 	case utils.DATA_SOURCE_ZZ:
 		urlStr = "zz/refresh"
 	case utils.DATA_SOURCE_DL:
@@ -40,10 +46,26 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *mod
 		urlStr = "shfe/refresh"
 	case utils.DATA_SOURCE_GIE:
 		urlStr = "gie/refresh"
+	case utils.DATA_SOURCE_LT:
+		urlStr = "lt/refresh"
+	case utils.DATA_SOURCE_COAL:
+		urlStr = "coal/refresh"
 	case utils.DATA_SOURCE_GOOGLE_TRAVEL:
 		urlStr = "google_travel/refresh"
+	case utils.DATA_SOURCE_MYSTEEL_CHEMICAL:
+		urlStr = "mysteel_chemical/refresh"
 	case utils.DATA_SOURCE_EIA_STEO:
 		urlStr = "eia_steo/refresh"
+	case utils.DATA_SOURCE_PREDICT:
+		urlStr = "predict/refresh"
+	case utils.DATA_SOURCE_COM_TRADE:
+		urlStr = "com_trade/refresh"
+	case utils.DATA_SOURCE_SCI:
+		urlStr = "sci/refresh"
+	case utils.DATA_SOURCE_BAIINFO:
+		urlStr = "baiinfo/refresh"
+	case utils.DATA_SOURCE_NATIONAL_STATISTICS:
+		urlStr = "national_statistics/refresh"
 	}
 	if urlStr == "" {
 		err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口，请联系管理员"))

services/data/edb_info.go

@@ -747,6 +747,7 @@ func RefreshDataFromLt(wg *sync.WaitGroup) (err error) {
 	}
 
 	for _, v := range items {
+		fmt.Println(v.EdbCode, v.Frequency, v.EndDate)
 		startDate := v.StartDate.Format(utils.FormatDate)
 		resp, err := RefreshEdbData(v.EdbInfoId, v.Source, v.EdbCode, startDate)
 		if err != nil {

services/data/edb_info_sync.go

@@ -54,7 +54,7 @@ func SyncManualDataBase() {
 	defer func() {
 		manualLock.Unlock()
 		if err != nil {
-			utils.FileLog.Info("SyncLzDataBase Err:" + err.Error())
+			utils.FileLog.Info("SyncManualDataBase Err:" + err.Error())
 			go utils.SendEmailByHongze("同步手工数据失败", "同步手工数据失败 Err:"+err.Error(), utils.RefreshEdbInfoEmailSendToUsers, "", "")
 		}
 	}()