blob: 7734d36677d653bdc3607383e6f01157c51f5f29 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
import datetime
from serenitas.utils.db import dbconn
from citco_ops.utils import PaymentSettlement
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()
conn = dbconn("dawndb")
sql_str = "SELECT settle_date, currency, sum(payment_amount) as payment_amount FROM payment_settlements ps2 WHERE fund=%s AND asset_class in ('bond', 'spot') AND %s < (settle_date + INTERVAL '5' DAY) group by settle_date, currency;"
with conn.cursor() as c:
for fund in ("ISOSEL",):
c.execute(sql_str, (fund, args.date))
PaymentSettlement.stage_payment(c)
PaymentSettlement.email_innocap(args.date)
|