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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
import logging
import argparse
import datetime
from pandas.errors import EmptyDataError
from serenitas.analytics.dates import prev_business_day
from serenitas.utils.db import dbconn
from serenitas.utils.exchange import ExchangeMessage
from serenitas.analytics.exceptions import MissingDataError
from .sma import SMA
from .cash import CashReport
from .wires import WireReport
from .admin import CitcoReport
from .custodians import upload_to_custodian, get_custodian_download_fun
from .utils import notify_payment_settlements, notify_fx_hedge
from .misc import _fund_custodians
logging.basicConfig(
format="%(asctime)s - %(name)s - %(levelname)s - %(message)s", level=logging.INFO
)
logger = logging.getLogger(__name__)
logging.getLogger("exchangelib.fields").setLevel(logging.WARNING)
parser = argparse.ArgumentParser()
parser.add_argument(
"-s",
"--sma_positions",
action="store_true",
help="upload sma positions to hedgemark",
)
parser.add_argument(
"-c", "--cash_reports", action="store_true", help="process cash reports to database"
)
parser.add_argument(
"-i",
"--isosel_reports",
action="store_true",
help="download isosel reports to database",
)
parser.add_argument(
"-w", "--wire_reports", action="store_true", help="download wires to db"
)
parser.add_argument(
"-sc",
"--send_to_custodians",
action="store_true",
help="upload trade files to notify custodians",
)
parser.add_argument(
"-ps",
"--payment_settlements",
action="store_true",
help="notify payment settlements by email",
)
parser.add_argument(
"-fh",
"--fx_hedge",
action="store_true",
help="return fx trades",
)
parser.add_argument(
"-n", "--no-upload", action="store_true", help="do not upload, just create files"
)
parser.add_argument(
"date",
nargs="?",
type=datetime.date.fromisoformat,
default=datetime.date.today(),
)
args = parser.parse_args()
cob = prev_business_day(args.date)
if args.sma_positions:
for fund in ("BOWDST", "ISOSEL", "BRINKER"):
sma = SMA[fund](cob)
try:
sma.email_positions()
except ValueError as e:
logger.warning(e)
if args.cash_reports or args.wire_reports:
em = ExchangeMessage()
if args.cash_reports:
Report = CashReport
else:
Report = WireReport
for fund, custodians in _fund_custodians.items():
for custodian in custodians:
get_custodian_download_fun(custodian)(args.date, fund, em=em)
report = Report[custodian](args.date, fund)
try:
report.commit()
except (MissingDataError, EmptyDataError) as e:
logger.info(e)
if args.isosel_reports:
for fund in ("ISOSEL",):
for report in ("isosel_accrued", "citco_reports"):
report = CitcoReport[report](cob, fund)
try:
report.to_db()
except MissingDataError as e:
logger.warning(e)
if args.send_to_custodians:
for account in (
"BBH",
"UMB",
):
upload_to_custodian(account, args.date, not args.no_upload)
if args.payment_settlements:
conn = dbconn("dawndb")
for fund in ("SERCGMAST", "BRINKER", "BOWDST", "ISOSEL"):
notify_payment_settlements(args.date, fund, conn)
if args.fx_hedge:
conn = dbconn("dawndb")
for fund in ("SERCGMAST", "BOWDST", "ISOSEL"):
notify_fx_hedge(cob, fund, conn)
|
