| | |
|---|
| | | import gpcode_manager |
|---|
| | | import authority |
|---|
| | | import juejin |
|---|
| | | from l2 import l2_data_manager_new, l2_data_manager, l2_data_log |
|---|
| | | from l2 import l2_data_manager_new, l2_data_manager, l2_data_log, l2_log |
|---|
| | | import l2_data_util |
|---|
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer, L2LimitUpMoneyStatisticUtil |
|---|
| | | import l2.l2_data_util |
|---|
| | |
|---|
| | | return_str = "OK" |
|---|
| | | if type == 0: |
|---|
| | | try: |
|---|
| | | |
|---|
| | | origin_start_time = round(time.time() * 1000) |
|---|
| | | __start_time = round(time.time() * 1000) |
|---|
| | | do_id = random.randint(0, 100000) |
|---|
| | | # level2盘口数据 |
|---|
| | | day, client, channel, code, capture_time, process_time, datas, origin_datas = l2.l2_data_util.parseL2Data( |
|---|
| | | _str) |
|---|
| | | l2_log.threadIds[code] = random.randint(0, 100000) |
|---|
| | | if channel == 0: |
|---|
| | | now_time = round(time.time() * 1000) |
|---|
| | | if self.last_time.get(channel) is not None: |
|---|
| | |
|---|
| | | # 10ms的网络传输延时 |
|---|
| | | capture_timestamp = __start_time - process_time - 10 |
|---|
| | | # print("截图时间：", process_time) |
|---|
| | | __start_time = l2_data_log.l2_time(code, do_id, round(time.time() * 1000) - __start_time, |
|---|
| | | __start_time = l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, |
|---|
| | | "截图时间：{} 数据解析时间".format(process_time)) |
|---|
| | | |
|---|
| | | cid, pid = gpcode_manager.get_listen_code_pos(code) |
|---|
| | | |
|---|
| | | __start_time = l2_data_log.l2_time(code, do_id, round(time.time() * 1000) - __start_time, |
|---|
| | | __start_time = l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, |
|---|
| | | "l2获取代码位置耗时") |
|---|
| | | # 判断目标代码位置是否与上传数据位置一致 |
|---|
| | | if cid is not None and pid is not None and client == int(cid) and channel == int(pid): |
|---|
| | |
|---|
| | | l2_code_operate.verify_with_l2_data_pos_info(code, client, channel) |
|---|
| | | __start_time = round(time.time() * 1000) |
|---|
| | | if gpcode_manager.is_listen(code): |
|---|
| | | __start_time = l2_data_log.l2_time(code, do_id, |
|---|
| | | __start_time = l2_data_log.l2_time(code, |
|---|
| | | round(time.time() * 1000) - __start_time, |
|---|
| | | "l2外部数据预处理耗时") |
|---|
| | | l2_data_manager_new.L2TradeDataProcessor.process(code, datas, capture_timestamp, |
|---|
| | | do_id) |
|---|
| | | __start_time = l2_data_log.l2_time(code, do_id, |
|---|
| | | __start_time = l2_data_log.l2_time(code, |
|---|
| | | round(time.time() * 1000) - __start_time, |
|---|
| | | "l2数据有效处理外部耗时", |
|---|
| | | False) |
|---|
| | | # 保存原始数据数量 |
|---|
| | | l2_data_util.save_l2_latest_data_number(code, len(origin_datas)) |
|---|
| | | if round(time.time() * 1000) - __start_time > 20: |
|---|
| | | l2_data_log.l2_time(code, do_id, round(time.time() * 1000) - __start_time, |
|---|
| | | l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, |
|---|
| | | "异步保存原始数据条数耗时", |
|---|
| | | False) |
|---|
| | | |
|---|
| | |
|---|
| | | __end_time = round(time.time() * 1000) |
|---|
| | | # 只记录大于40ms的数据 |
|---|
| | | if __end_time - origin_start_time > 100: |
|---|
| | | l2_data_log.l2_time(code, do_id, round(time.time() * 1000) - origin_start_time, |
|---|
| | | l2_data_log.l2_time(code, round(time.time() * 1000) - origin_start_time, |
|---|
| | | "l2数据处理总耗时", |
|---|
| | | True) |
|---|
| | | except Exception as e: |
|---|
