fix

models/data_manage/edb_data_base.go

@@ -115,6 +115,8 @@ func GetEdbDataTableName(source int) (tableName string) {
 		tableName = "edb_data_predict_calculate_nh"
 	case utils.DATA_SOURCE_PREDICT_CALCULATE_KSZS:
 		tableName = "edb_data_predict_calculate_kszs"
+	case utils.DATA_SOURCE_BAIINFO:
+		tableName = "edb_data_baiinfo"
 	default:
 		tableName = ""
 	}

models/edb_data_base.go

@@ -114,6 +114,8 @@ func GetEdbDataTableName(source int) (tableName string) {
 		tableName = "edb_data_predict_calculate_nh"
 	case utils.DATA_SOURCE_PREDICT_CALCULATE_KSZS:
 		tableName = "edb_data_predict_calculate_kszs"
+	case utils.DATA_SOURCE_BAIINFO:
+		tableName = "edb_data_baiinfo"
 	default:
 		tableName = ""
 	}

services/data/base_edb_lib.go

@@ -50,6 +50,8 @@ func AddEdbData(source int, edbCode string) (resp *models.BaseResponse, err erro
 		urlStr = "/coal/add"
 	case utils.DATA_SOURCE_SCI:
 		urlStr = "/sci/add"
+	case utils.DATA_SOURCE_BAIINFO:
+		urlStr = "/baiinfo/add"
 	default:
 	}
 	if urlStr == "" {
@@ -112,6 +114,8 @@ func RefreshEdbData(edbInfoId, source int, edbCode, startDate string) (resp *mod
 		urlStr = "com_trade/refresh"
 	case utils.DATA_SOURCE_SCI:
 		urlStr = "/sci/refresh"
+	case utils.DATA_SOURCE_BAIINFO:
+		urlStr = "/baiinfo/refresh"
 	}
 	if urlStr == "" {
 		err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口，请联系管理员"))

utils/constants.go

@@ -88,6 +88,7 @@ const (
 	DATA_SOURCE_PREDICT_CALCULATE_JP                    //预测指标 - 计算指标(降频)->54
 	DATA_SOURCE_PREDICT_CALCULATE_NH                    //预测指标 - 计算指标(年化)->55
 	DATA_SOURCE_PREDICT_CALCULATE_KSZS                  //预测指标 - 计算指标(扩散指数)->56
+	DATA_SOURCE_BAIINFO                                 //百川盈孚 ->57
 )
 
 // 数据刷新频率