1 files changed, 28 insertions, 0 deletions
diff --git a/python/markit_download.py b/python/markit_download.py
index 91bdefa5..9a90a5b6 100644
--- a/python/markit_download.py
+++ b/python/markit_download.py
@@ -43,5 +43,33 @@ with open( facility_filename, "r") as fh:
         common.cursor.execute(sqlstring, newline)
 common.conn.commit()
 
+#we update the missing facility loanxids
+sqlstring = "SELECT loanxid FROM markit_prices2 EXCEPT SELECT loanxid FROM markit_facility";
+common.cursor.execute(sqlstring)
+facility_diff_filename = os.path.join(common.root, "data", "Facility files",
+                                      "facility_diff_{0}.csv".format(workdate))
+with open( facility_diff_filename, "wb") as fh:
+    flag = False
+    for loanxid in common.cursor.fetchall():
+        r = requests.get('https://loans.markit.com/loanx/LoanXOneFacility.csv?LEGALENTITY={0}&USERNAME={1}&PASSWORD={2}&LOANXID={3}'.format(legal, username, password, loanxid[0]))
+        if flag:
+            fh.write(r.content.split('\n')[1] + "\n")
+        else:
+            fh.write(r.content.split('\n')[0] + "\n")
+            fh.write(r.content.split('\n')[1] + "\n")
+            flag = True
+
+sqlstring = "INSERT INTO markit_facility(LoanXID, PMDID, IssuerName, dealname, facility_type," \
+    "loanx_facility_type, initial_amount, initial_spread, maturity, industry, modified_time)" \
+    "VALUES( {0} )".format( ",".join( ["%s"] * 11))
+with open(facility_diff_filename, "r") as fh:
+    reader = csv.reader(fh)
+    reader.next()
+    for line in reader:
+        newline = [convertToNone(v) for v in line] + [workdate]
+        newline.pop(9)          # remove the spread to maturity value
+        common.cursor.execute(sqlstring, newline)
+common.conn.commit()
+
 common.cursor.close()
 common.conn.close()