1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
import datetime
import logging
from serenitas.analytics.dates import prev_business_day
from serenitas.utils.db import dbconn
from report_ops.utils import GFSMonitor, CDXQuoteMonitor
def check_gfs(date, fund, conn):
with conn.cursor() as c:
c.execute(
"SELECT endqty as amount, invccy as currency, periodenddate as date, port as portfolio FROM valuation_reports vr WHERE fund=%s AND abs(endqty) > 50000 AND port ='GFS_HELPER_BUSINESS_UNIT' AND periodenddate =%s;",
(
fund,
date,
),
)
for row in c:
GFSMonitor.stage(row._asdict())
GFSMonitor.email(fund)
GFSMonitor._staging_queue.clear()
def check_cleared_cds(date, fund, conn):
with conn.cursor() as c:
c.execute(
"SELECT *, abs(serenitas_quote-globeop_quote) AS difference FROM compare_globeop_quotes(%s, %s)",
(date, fund),
)
for row in c:
d = row._asdict()
match d["index"]:
case "IG":
if d["difference"] > 0.10:
CDXQuoteMonitor.stage(d)
case "HY":
if d["difference"] > 0.20:
CDXQuoteMonitor.stage(d)
CDXQuoteMonitor.email(fund)
CDXQuoteMonitor._staging_queue.clear()
if __name__ == "__main__":
import argparse
parser = argparse.ArgumentParser()
parser.add_argument(
"cob",
nargs="?",
type=datetime.date.fromisoformat,
default=prev_business_day(datetime.date.today()),
help="working date",
)
args = parser.parse_args()
logger = logging.getLogger(__name__)
conn = dbconn("dawndb")
for fund in (
"SERCGMAST",
"BOWDST",
):
check_gfs(args.cob, fund, conn)
check_cleared_cds(args.cob, fund, conn)
|
