aboutsummaryrefslogtreecommitdiffstats
path: root/python/baml_fcm_fx.py
blob: 2ba8fef0b377ea88b24ce209ca2dceddbea72bdb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
import datetime
from serenitas.utils.db import dawn_engine
from citco_ops.utils import BamlFcmNotify
import pandas as pd
from exchangelib import HTMLBody

if __name__ == "__main__":
    import argparse

    parser = argparse.ArgumentParser()
    parser.add_argument(
        "date",
        nargs="?",
        type=datetime.date.fromisoformat,
        default=datetime.date.today(),
        help="working date",
    )
    args = parser.parse_args()
    sql_str = "SELECT trade_date, near_rate, near_settle_date, near_buy_currency, near_buy_amount, near_sell_currency, near_sell_amount FROM fx_swaps fs2 WHERE cash_account ='V0NSCLMSPT' AND trade_date = %s;"
    df = pd.read_sql_query(sql_str, con=dawn_engine, params=(args.date,))
    if not df.empty:
        BamlFcmNotify.email_fcm(args.date, HTMLBody(df.to_html(index=False)))