| | |
|---|
| | | code = data['SecurityID'] |
|---|
| | | if code in buy_order_nos_dict: |
|---|
| | | if data['BuyNo'] in buy_order_nos_dict[code]: |
|---|
| | | temp_list = latest_big_order_transaction_orders_dict.get(code) |
|---|
| | | if not temp_list: |
|---|
| | | temp_list = [] |
|---|
| | | if temp_list: |
|---|
| | | if temp_list[-1] != data['BuyNo']: |
|---|
| | | # 不加入重复订单号 |
|---|
| | | try: |
|---|
| | | temp_list = latest_big_order_transaction_orders_dict.get(code) |
|---|
| | | if not temp_list: |
|---|
| | | temp_list = [] |
|---|
| | | if temp_list: |
|---|
| | | if temp_list[-1] != data['BuyNo']: |
|---|
| | | # 不加入重复订单号 |
|---|
| | | temp_list.append(data['BuyNo']) |
|---|
| | | if len(temp_list) > 10: |
|---|
| | | # 最多加10个订单号 |
|---|
| | | temp_list = temp_list[-10:] |
|---|
| | | else: |
|---|
| | | temp_list.append(data['BuyNo']) |
|---|
| | | if len(temp_list) > 10: |
|---|
| | | # 最多加10个订单号 |
|---|
| | | temp_list = temp_list[-10:] |
|---|
| | | else: |
|---|
| | | temp_list.append(data['BuyNo']) |
|---|
| | | latest_big_order_transaction_orders_dict[code] = temp_list |
|---|
| | | latest_big_order_transaction_orders_dict[code] = temp_list |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | tmep_transaction_queue_dict[code].put((data['SecurityID'], data['TradePrice'], data['TradeVolume'], |
|---|
| | | data['OrderTime'], data['MainSeq'], data['SubSeq'], data['BuyNo'], |
|---|
| | | data['SellNo'], data['ExecType'])) |
|---|
