瀏覽代碼

fix:兼容wind的另一个状态码

Roc 2 年之前
父節點
當前提交
f5e04b1a85
共有 1 個文件被更改,包括 22 次插入1 次删除
  1. 22 1
      services/base_from_wind.go

+ 22 - 1
services/base_from_wind.go

@@ -43,6 +43,17 @@ func GetEdbDataFromWind(edbCode, startDate, endDate string) (item *EdbDataFromWi
 	if len(item.ErrorCode) > 0 {
 		if item.ErrorCode["0"] != 0 {
 			if item.ErrorCode["0"] == -40522017 {
+				//{
+				//DT: {
+				//0: 1654646400000
+				//},
+				//CLOSE: {
+				//0: "CEDBService:: quota exceeded."
+				//},
+				//ErrorCode: {
+				//0: -40522017
+				//}
+				//}
 				// 设置服务器已超限
 				SetIsLimitEdbCodeInWindUrl(windUrl)
 				err = DeleteEdbCodeInWindUrl(edbCode)
@@ -50,8 +61,18 @@ func GetEdbDataFromWind(edbCode, startDate, endDate string) (item *EdbDataFromWi
 					return
 				}
 				return GetEdbDataFromWind(edbCode, startDate, endDate)
+			} else if item.ErrorCode["0"] == -40520005 {
+				//.ErrorCode=-40520005
+				//.Data=[No Python API Authority
+				SetIsLimitEdbCodeInWindUrl(windUrl)
+				err = DeleteEdbCodeInWindUrl(edbCode)
+				if err != nil {
+					return
+				}
+				go alarm_msg.SendAlarmMsg(fmt.Sprintf("wind数据服务异常,edbCode:%s,ErrorCode:%d,result:%s", edbCode, item.ErrorCode["0"], string(body)), 3)
+				return GetEdbDataFromWind(edbCode, startDate, endDate)
 			} else {
-				go alarm_msg.SendAlarmMsg(fmt.Sprintf("wind数据服务异常,edbCode:%s,ErrorCode:%d", edbCode, item.ErrorCode["0"]), 3)
+				go alarm_msg.SendAlarmMsg(fmt.Sprintf("wind数据服务异常,edbCode:%s,ErrorCode:%d,result:%s", edbCode, item.ErrorCode["0"], string(body)), 3)
 			}
 		}
 	}