diff --git a/requirements.txt b/requirements.txt index 95daf43..9d67dfc 100644 --- a/requirements.txt +++ b/requirements.txt @@ -21,4 +21,5 @@ tqdm>=4.65.0 python-dateutil>=2.8.0 schedule akshare -TA-Lib \ No newline at end of file +TA-Lib +tabulate \ No newline at end of file diff --git a/signal_calc.py b/signal_calc.py index 3b028a8..5751539 100644 --- a/signal_calc.py +++ b/signal_calc.py @@ -9,7 +9,7 @@ import time import traceback from dingtalk import DingTalkBot import talib as ta - +from tabulate import tabulate env = "online" # env = "on" db_config = DatabaseConfig(env=env) @@ -53,6 +53,9 @@ def get_index_recent_date(code: str, limit: int = None) -> pd.DataFrame: def main(): + if datetime.today().weekday() >= 5: + logger.info(f"非交易日") + return webhook = "https://oapi.dingtalk.com/robot/send?access_token=fb70c1561d8beba94b4f11568f4bb15e3ae07ccbdc8ac19676434a9d1cd17546" # 填写你的webhook secret = "SEC1ae7cd2f1a6f9da3611af37da3e7d954c1e8533fc073c6c8cc5e5af3b6e5926b" # 填写你的加签token(如果有),否则留空 dingtalk = DingTalkBot(webhook, secret) @@ -98,9 +101,10 @@ def main(): ) # break signal_df = pd.DataFrame(signal_list) - dingtalk.send_markdown( - f"CCI信号", signal_df.to_markdown(tablefmt="simple", index=False) - ) + # dingtalk.send_markdown( + # f"CCI信号", signal_df.to_markdown(tablefmt="simple", index=False) + # ) + dingtalk.send_text(tabulate(signal_df, tablefmt='plain', headers="keys", showindex=False)) if __name__ == "__main__":