diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/citco_submission.py | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/python/citco_submission.py b/python/citco_submission.py index dfd40a32..2be5e629 100644 --- a/python/citco_submission.py +++ b/python/citco_submission.py @@ -69,10 +69,16 @@ def update_instrument(conn, instrument_id): c.execute(sql, (instrument_id,)) -def update_trade(conn, trade_id): - sql = f"UPDATE citco_trade_submission SET committed=True where dealid=%s" +def update_trade(conn, trade_id, identifier): + sql = f"UPDATE citco_trade_submission SET committed=True and identifier=%s where dealid=%s and identifier is NULL" with conn.cursor() as c: - c.execute(sql, (trade_id,)) + c.execute( + sql, + ( + trade_id, + identifier, + ), + ) def parse_errors(fh): @@ -90,7 +96,7 @@ def sql_data_process(conn, line): identifier_type = "trade" serenitas_id = line["External_Order_Id"] identifier = line["Internal_Order_Id"] - update_trade(conn, serenitas_id) + update_trade(conn, serenitas_id, identifier) else: identifier_type = "instrument" serenitas_id = line["External_Security_Id"] |