| | |
| | | # TODO 测试 |
| | | current_delegates, update_time = huaxin_trade_record_manager.DelegateRecordManager.list_by_day( |
| | | tool.get_now_date_str("%Y%m%d"), None, |
| | | [huaxin_util.TORA_TSTP_OST_Accepted, huaxin_util.TORA_TSTP_OST_PartTraded, huaxin_util.TORA_TSTP_OST_AllCanceled ]) |
| | | [huaxin_util.TORA_TSTP_OST_Accepted, huaxin_util.TORA_TSTP_OST_PartTraded, |
| | | huaxin_util.TORA_TSTP_OST_AllCanceled]) |
| | | fdatas = [] |
| | | if current_delegates: |
| | | codes_set = set() |
| | |
| | | if int(c["direction"]) != huaxin_util.TORA_TSTP_D_Buy: |
| | | continue |
| | | code = c["securityID"] |
| | | |
| | | # TODO 测试 |
| | | if code != '000751': |
| | | continue |
| | | |
| | | if code in codes_set: |
| | | continue |
| | | orderSysID = c.get("orderSysID") |
| | |
| | | fdata['l_down_watch_indexes_info'] = {} |
| | | if current_info: |
| | | fdata['l_down_watch_indexes_info']['current'] = current_info |
| | | except: |
| | | pass |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | | fdatas.append(fdata) |
| | | except Exception as e: |
| | | logger_debug.exception(e) |
| | |
| | | """ |
| | | # TODO 测试 |
| | | if code == '000751': |
| | | self.__cancel_watch_index_info_cache[code] = (0, 1, [4061,4062,4065,4069,4070,4073, 4074, 4077, 4080,4082,4084,4085,4086,4089,4094,4095, 4097, 4107]) |
| | | self.__real_place_order_index_dict[code] = (4098 , False) |
| | | self.__cancel_watch_index_info_cache[code] = (0, 1, |
| | | [4061, 4062, 4065, 4069, 4070, 4073, 4074, 4077, 4080, 4082, |
| | | 4084, 4085, 4086, 4089, 4094, 4095, 4097, 4107]) |
| | | self.__real_place_order_index_dict[code] = (4098, False) |
| | | watch_indexes_info = self.__get_watch_indexes_cache(code) |
| | | if not watch_indexes_info: |
| | | return None |