-
Notifications
You must be signed in to change notification settings - Fork 213
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #87 from 1nchaos/dev
Dev
- Loading branch information
Showing
11 changed files
with
180 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,30 @@ | ||
| # -*- coding: utf-8 -*- | ||
| """ | ||
| @desc: readme | ||
| @author: 1nchaos | ||
| @time: 2024/7/23 | ||
| @log: change log | ||
| """ | ||
| from datetime import datetime, timedelta | ||
|
|
||
|
|
||
| def get_n_days_date(days=0, fmt="%Y-%m-%d"): | ||
| """ | ||
| 获取 N 天后的日期， | ||
| :param days: 天数；N可以是负数，表示N天前的日期 | ||
| :param fmt: 日期格式；默认：%Y-%m-%d | ||
| :return: 对应的日期 | ||
| """ | ||
| # 获取当前日期 | ||
| current_date = datetime.now().date() | ||
| # 计算前N天的日期 | ||
| target_date = current_date + timedelta(days=days) | ||
| # 将日期格式化为指定格式 | ||
| return target_date.strftime(fmt) | ||
|
|
||
|
|
||
| def get_cur_time(fmt="%Y-%m-%d %H:%M:%S"): | ||
| """ | ||
| 获取当前时间， | ||
| """ | ||
| return datetime.now().strftime(fmt) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,89 @@ | ||
| # -*- coding: utf-8 -*- | ||
| """ | ||
| @desc: 东方财富 | ||
| https://quote.eastmoney.com/center/ | ||
| @author: 1nchaos | ||
| @time: 2023/06/19 | ||
| @log: change log | ||
| """ | ||
|
|
||
| import pandas as pd | ||
|
|
||
| from adata.common.utils import requests | ||
| from adata.common.utils.date_utils import get_cur_time | ||
| from adata.stock.market.stock_market.stock_market_template import StockMarketTemplate | ||
|
|
||
|
|
||
| class StockMarketEast(StockMarketTemplate): | ||
| """ | ||
| 百度股票行情 | ||
| """ | ||
|
|
||
| def __init__(self) -> None: | ||
| super().__init__() | ||
|
|
||
| def get_market(self, stock_code: str = '000001', start_date='1990-01-01', end_date=None, k_type=1, | ||
| adjust_type: int = 1): | ||
| """ | ||
| :param stock_code: 6位股票代码 | ||
| :param start_date: 开始时间 | ||
| :param end_date: 结束日期 | ||
| :param k_type: k线类型：1.日；2.周；3.月 | ||
| :param adjust_type: k线复权类型：0.不复权；1.前复权；2.后复权 默认：1 前复权 | ||
| :return: k线行情数据:"时间戳", "时间","开盘","收盘","成交量","最高","最低","成交额","涨跌额","涨跌幅","换手率","昨收" | ||
| """ | ||
| # 1. 参数处理 | ||
| se_cid = 1 if stock_code.startswith('6') else 0 | ||
| start_date = start_date.replace('-', '') if start_date else '19900101' | ||
| end_date = end_date.replace('-', '') if end_date else get_cur_time("%Y%m%d") | ||
| k_type = f"10{k_type}" if k_type < 5 else k_type | ||
| params = {"fields1": "f1,f2,f3,f4,f5,f6", | ||
| "fields2": "f51,f52,f53,f54,f55,f56,f57,f58,f59,f60,f61,f116", | ||
| "ut": "7eea3edcaed734bea9cbfc24409ed989", | ||
| "klt": k_type, "fqt": adjust_type, | ||
| "secid": f"{se_cid}.{stock_code}", | ||
| "beg": start_date, "end": end_date, | ||
| "_": "1623766962675", | ||
| } | ||
| # 2. 请求url | ||
| url = "http://push2his.eastmoney.com/api/qt/stock/kline/get" | ||
| r = requests.request(method='get', url=url, params=params) | ||
| data_json = r.json() | ||
|
|
||
| # 3. 结果处理 | ||
| if not data_json["data"]: | ||
| return pd.DataFrame() | ||
| lines = data_json["data"]["klines"] | ||
| if not lines: | ||
| return pd.DataFrame() | ||
| data = [item.split(",") for item in lines] | ||
| df = pd.DataFrame(data=data, columns=["trade_date", "open", "close", "high", "low", "volume", "amount", | ||
| '', "change_pct", "change", "turnover_ratio"]) | ||
| # 4.清洗数据 | ||
| df['pre_close'] = df['close'].astype(float) - df['change'].astype(float) | ||
| df['trade_time'] = pd.to_datetime(df['trade_date']).dt.strftime('%Y-%m-%d %H:%M:%S') | ||
| df['trade_date'] = pd.to_datetime(df['trade_date']).dt.strftime('%Y-%m-%d') | ||
| df['stock_code'] = stock_code | ||
| numeric_columns = ['open', 'close', 'volume', 'high', 'low', 'amount', 'change', 'change_pct', | ||
| 'turnover_ratio', 'pre_close'] | ||
| df[numeric_columns] = df[numeric_columns].apply(pd.to_numeric) | ||
| df.reset_index(inplace=True, drop=True) | ||
| return df | ||
|
|
||
| def get_market_min(self, stock_code: str = '000001'): | ||
| """ | ||
| 获取百度的股票行情数据 | ||
| web： https://gushitong.baidu.com/stock/ab-002926 | ||
| url: https://finance.pae.baidu.com/selfselect/getstockquotation? | ||
| all=1&code=601318&isIndex=false&isBk=false&isBlock=false&isFutures=false&isStock=true&newFormat=1 | ||
| &group=quotation_minute_ab&finClientType=pc | ||
| time, price, ratio, increase, volume, avgPrice, amount, timeKey, datetime, oriAmount | ||
| :param stock_code: 6位股票代码 | ||
| :return: k线行情数据:"时间","价格","涨跌率","涨幅","均价","成交量", "成交额" | ||
| """ | ||
| pass | ||
|
|
||
|
|
||
| if __name__ == '__main__': | ||
| print(StockMarketEast().get_market(stock_code='600020', k_type=1, adjust_type=1)) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,30 @@ | ||
| # -*- coding: utf-8 -*- | ||
| """ | ||
| @desc: readme | ||
| @author: yinchao | ||
| @time: 2024/7/23 | ||
| @log: change log | ||
| """ | ||
| import requests | ||
|
|
||
| # cookie = 'BAIDUID=61D17458C811DF0B06467F8750EE21C2:FG=1; ab_sr=1.0.1_NDc4ZjNhNWJlNDk2N2M2MjI2ZGM2MzEwNzZiMGZiYTMyMGMyMzgxNWUxYTY1MjBhZDU5ODJhMWRjYmMxOTY5NWQ5MGI0M2MzMGMwYzQyMmUwZjcxNGQyNGZjZTZjNGJjN2NiODM3N2NlMjQ3YWNkNGJjNWVlNzI4YmI2OGI3NTMyMGE5NmQ0ZDZlZjZiODM1ZTIxNDAzMDYzMjIyZTE3ZQ==' | ||
| cookie = 'BAIDUID=61D17458C811DF0B06467F8750EE21C2:FG=1; ab_jid=4612ca84faa72ab407fd722d950fc31fe1d1; ab_bid=faa72ab407fd722d950fc31fe1d217e49c55; ab_sr=1.0.1_YjY5ZGYxMzM0NTc3ZmYwNjE4OTE2ZTNiMDEzMzEwN2JmMWRjMjBhOWY0Njc4YjlhNmM5M2ViMjZiZmNmYWI1MTU0NzQ3YmU0MjJmYTM2YWNiZjEyYjE1ODdjMjc0MDQxNWU4ZmI0MmNjZWFhODRlZDAyMjIxNmE0YzdkNmUyYjI5M2Q3NjE3OTc2ZDliNDIxYWUyMWRhYmVhODZjZjlhZA==; BDORZ=B490B5EBF6F3CD402E515D22BCDA1598' | ||
|
|
||
| json_headers = { | ||
| 'Host': 'finance.pae.baidu.com', | ||
| 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/110.0', | ||
| 'Accept': 'application/vnd.finance-web.v1+json', | ||
| 'Accept-Language': 'zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2', | ||
| 'Accept-Encoding': 'gzip, deflate, br', | ||
| 'Content-Type': 'application/josn', | ||
| 'Origin': 'https://gushitong.baidu.com', | ||
| 'Connection': 'keep-alive', | ||
| 'Referer': 'https://gushitong.baidu.com/', | ||
| 'Cookie': cookie | ||
| } | ||
| params = { | ||
| '_o': 'https://gushitong.baidu.com' | ||
| } | ||
| response = requests.post(url='https://miao.baidu.com/abdr', params=params) | ||
| # response = requests.get('https://gushitong.baidu.com/stock/ab-300059') | ||
| print(response.cookies) |