|
@@ -89,6 +89,10 @@ func (this *WindWsdController) Add() {
|
|
|
windUrlCacheKey := utils.CACHE_WIND_URL + ":" + req.StockCode + req.EdbCode
|
|
|
_ = utils.Rc.SetNX(windUrlCacheKey, windUrl, utils.GetTodayLastSecond())
|
|
|
|
|
|
+ // 设置指标与终端关系的缓存
|
|
|
+ terminalCodeCacheKey := utils.CACHE_EDB_TERMINAL_CODE_URL + req.StockCode
|
|
|
+ _ = utils.Rc.Put(terminalCodeCacheKey, terminalCode, utils.GetTodayLastSecond())
|
|
|
+
|
|
|
//windUrl = utils.Hz_Wind_Data_Url_LIST[1].Url
|
|
|
dataItem, errCode, err := services.GetEdbDataFromWindUrlWsd(windUrl, req.StockCode, req.EdbCode, utils.BASE_START_DATE, endDate)
|
|
|
if errCode == 421 { //指标超限
|