github_mirrors/stock-api
1
0
Fork 0
mirror of https://github.com/zhangxiangliang/stock-api.git synced 2025-02-02 22:43:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: 增加 雪球类型搜索股票代码去重、修复 雪球类型获取股票组数据不存在时报错

Browse Source
This commit is contained in:
zhangxiangliang 2020-08-22 18:38:12 +08:00
parent c5e75de970
commit 9b31d0f261
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/stocks/xueqiu/index.ts
View File

@ -1,3 +1,6 @@
// NPM
import { uniqBy } from 'lodash';
// Stocks // Stocks
import XueqiuStockTransform from "@stocks/xueqiu/transforms/stock"; import XueqiuStockTransform from "@stocks/xueqiu/transforms/stock";
import XueqiuApiCodeTransform from "@stocks/xueqiu/transforms/api-code"; import XueqiuApiCodeTransform from "@stocks/xueqiu/transforms/api-code";
@ -78,10 +81,14 @@ const Xueqiu: StockApi & { getToken(): Promise<string> } = {
return codes.map(code => { return codes.map(code => {
// 数据深解析 // 数据深解析
const transform = (new XueqiuCommonCodeTransform).transform(code); const transform = (new XueqiuCommonCodeTransform).transform(code);
const params = rows.find(i => i.quote.symbol === transform) || {}; const params = rows.find(i => i.quote && i.quote.symbol === transform) || null;
if (!params) {
return { ...DEFAULT_STOCK, code };
}
const data = (new XueqiuStockTransform(code, params.quote)); const data = (new XueqiuStockTransform(code, params.quote));
return params ? data.getStock() : { ...DEFAULT_STOCK, code }; return data.getStock();
}); });
}, },
@ -99,7 +106,8 @@ const Xueqiu: StockApi & { getToken(): Promise<string> } = {
const body = JSON.parse(res.text); const body = JSON.parse(res.text);
const rows: Dictionary<string>[] = body.stocks; const rows: Dictionary<string>[] = body.stocks;
const codes: string[] = rows.map(i => (new XueqiuApiCodeTransform).transform(i.code)); const codes: string[] = rows.map(i => (new XueqiuApiCodeTransform).transform(i.code));
return await Xueqiu.getStocks(codes);
return uniqBy(await Xueqiu.getStocks(codes), (code: Stock) => code.name);
} }
} }