| | |
| | | "SubSeq": pTransaction['SubSeq'], "BuyNo": pTransaction['BuyNo'], |
| | | "SellNo": pTransaction['SellNo'], |
| | | "ExecType": pTransaction['ExecType'].decode()} |
| | | key = f"{item['SecurityID']}_{item['TradePrice']}_{item['BuyNo']}" |
| | | if self.__last_transaction_keys_dict.get(code) == key: |
| | | return |
| | | self.__last_transaction_keys_dict[code] = key |
| | | # 暂时注释掉同1单号至多上传1次 |
| | | # key = f"{item['SecurityID']}_{item['TradePrice']}_{item['BuyNo']}" |
| | | # if self.__last_transaction_keys_dict.get(code) == key: |
| | | # return |
| | | # self.__last_transaction_keys_dict[code] = key |
| | | # print("逐笔成交", item) |
| | | l2_data_manager.add_transaction_detail(item) |
| | | |