| | |
|---|
| | | return break_time, records_new, records_new_data |
|---|
| | | |
|---|
| | | |
|---|
| | | # 返回内容[（类型,buy_single_index,indexes）] |
|---|
| | | def load_trade_record_cancel_watch_indexes(code, cancel_type=None): |
|---|
| | | fresults = [] |
|---|
| | | records = [] |
|---|
| | | try: |
|---|
| | | records = log_export.load_trade_recod(code) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | if records: |
|---|
| | | for record in records: |
|---|
| | | time_ = record[0] |
|---|
| | | type = record[1] |
|---|
| | | data = record[2] |
|---|
| | | if type == trade_record_log_util.TYPE_CANCEL_WATCH_INDEXES: |
|---|
| | | indexes = data['watch_indexes'] |
|---|
| | | if indexes: |
|---|
| | | if cancel_type and cancel_type != data.get("cancel_type"): |
|---|
| | | continue |
|---|
| | | fresults.append((data.get("cancel_type"), data.get('buy_single_index'), indexes)) |
|---|
| | | return fresults |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__': |
|---|
| | | code = '002786' |
|---|
| | | l2_data_util.load_l2_data(code) |
|---|
| | | print(__load_trade_record(code, l2_data_util.local_today_datas.get(code))) |
|---|
| | | code = '000670' |
|---|
| | | fresults = load_trade_record_cancel_watch_indexes(code) |
|---|
| | | print(fresults) |
|---|
