| | |
| | | |
| | | |
| | | # 加载l2订单成交数据 |
| | | def load_huaxin_deal_record(code): |
| | | path = f"{constant.get_path_prefix()}/logs/huaxin/l2/transaction_desc.{tool.get_now_date_str()}.log" |
| | | def load_huaxin_deal_record(code,date = tool.get_now_date_str()): |
| | | path = f"{constant.get_path_prefix()}/logs/huaxin/l2/transaction_desc.{date}.log" |
| | | # 格式:[(订单号,手数,开始成交时间,成交结束时间,下单手数)] |
| | | fdatas = [] |
| | | lines = __load_file_content(path) |
| | |
| | | ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()]) |
| | | code = ps_dict['code'] |
| | | date = ps_dict.get('date') |
| | | datas = data_export_util.get_l2_datas(code, l2_data_util.local_today_datas.get(code), date = date) |
| | | logger_debug.info(f"get_l2_datas:{code} {date}") |
| | | datas = data_export_util.get_l2_datas(code, l2_data_util.local_today_datas.get(code), date=date) |
| | | code_name = gpcode_manager.get_code_name(code) |
| | | response_data = json.dumps({"code": 0, "data": {"code": code, "code_name": code_name, "data": datas}}) |
| | | except Exception as e: |
| | |
| | | |
| | | def export_l2_excel(code, date=None): |
| | | # 获取L2的数据 |
| | | fdatas = get_l2_datas(code) |
| | | fdatas = get_l2_datas(code, date=date) |
| | | __save_l2_datas(code, fdatas) |
| | | |
| | | |
| | |
| | | process_indexs = log_export.get_l2_process_position(code, date) |
| | | trade_indexs = log_export.get_l2_trade_position(code, date) |
| | | real_position_indexes = log_export.get_real_place_order_positions(code, date) |
| | | deal_list = log_export.load_huaxin_deal_record(code) |
| | | deal_list = log_export.load_huaxin_deal_record(code, date) |
| | | deal_list_dict = {} |
| | | for d in deal_list: |
| | | deal_list_dict[str(d[0])] = d |
| | |
| | | |
| | | if __name__ == "__main__": |
| | | try: |
| | | export_l2_excel("600822", date="2024-03-12") |
| | | get_l2_datas("600822", date="2024-03-12") |
| | | except Exception as e: |
| | | logging.exception(e) |