交易记录日志优化

Administrator

2023-10-11 cab2f4605d16dee36270138a8f7dfdd79dc6d663

 output/code_info_output.py

@@ -6,6 +6,7 @@
# 下单参数信息
# 选股宝
# 市场热度
import logging
import sys
import time
import code_attribute
@@ -352,7 +353,7 @@
                data = record[2]
                if type == trade_record_log_util.TYPE_PLACE_ORDER:
                    records_new_data.append((time_, "开盘啦推荐原因",
                                             f"{'、'.join(data['kpl_blocks'])}",
                                             f"{'、'.join([k[1] for k in data['kpl_blocks']])}",
                                             None))
                    extra_datas = []
                    if data['big_num_indexes']:
@@ -367,7 +368,12 @@
                                             f"【{format_l2_data(total_datas[data['buy_single_index']])}】-【{format_l2_data(total_datas[data['buy_exec_index']])}】",
                                             data))
                elif type == trade_record_log_util.TYPE_REAL_PLACE_ORDER_POSITION:
                    records_new_data.append((time_, "实际挂单位", f"【{format_l2_data(data['index'])}】", None))
                    for i in range(data['index'], 0, -1):
                        if total_datas[i]['val']['num'] * float(total_datas[i]['val']['price']) >= 3000:
                            records_new_data.append(
                                (time_, "实际挂单位", f"【{format_l2_data(total_datas[i])}】", None))
                            break

                elif type == trade_record_log_util.TYPE_CANCEL_WATCH_INDEXES:
                    indexes = data['watch_indexes']
                    if indexes:
@@ -395,13 +401,14 @@
                    records_new_data.append((time_, "撤单", f"原因：{data['msg']}", None))
            if records_new_data:
                for d in records_new_data:
                    records_new.append(f"【{d[0]}】"+"{:<10}".format(d[1])+d[2])
        except:
            pass
                    records_new.append(f"【{d[0]}】" + "{:<10}".format(f'【{d[1]}】') + d[2])
        except Exception as e:
            logging.exception(e)

    return break_time, records_new, records_new_data


if __name__ == '__main__':
    ts = ("0", "1", "2", "3")
    print(','.join(ts[:-1]))
    code = '603131'
    l2_data_util.load_l2_data(code)
    __load_trade_record(code, l2_data_util.local_today_datas.get(code))