| | |
| | | pass |
| | | |
| | | |
| | | |
| | | # 获取响应发送socket |
| | | global req_rid_dict |
| | | req_rid_dict = {} |
| | |
| | | import json |
| | | import logging |
| | | import time |
| | | import l2.l2_data_util |
| | | |
| | | import constant |
| | | from code_attribute import big_money_num_manager, gpcode_manager, code_volumn_manager |
| | |
| | | def set_real_place_position(code,index): |
| | | DCancelBigNumComputer().set_real_order_index(code, index) |
| | | SecondCancelBigNumComputer().set_real_place_order_index(code, index) |
| | | |
| | | |
| | | class SecondCancelBigNumComputer: |
| | | __db = 0 |
| | |
| | | # 小金额的个数已满 |
| | | continue |
| | | # 判断当前订单是否已经撤单 |
| | | left_count = l2_data_source_util.L2DataSourceUtils.get_limit_up_buy_no_canceled_count(code,i,total_data,local_today_num_operate_map) |
| | | left_count = l2_data_source_util.L2DataSourceUtils.get_limit_up_buy_no_canceled_count(code, i, total_data, |
| | | local_today_num_operate_map.get(code)) |
| | | if left_count > 0: |
| | | watch_indexes.add(i) |
| | | if is_small_money: |
| | |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | s = {"618-1047", "604-1292", "614-5106"} |
| | | l2_log.h_cancel_debug("000333", "H撤已撤订单:{}", "test") |
| | | pass |
| | |
| | | return count |
| | | return 0 |
| | | |
| | | |
| | | # if __name__ == "__main__": |
| | | # code = "000925" |
| | | # l2_data_util.load_l2_data(code) |