| | |
| | | from code_attribute import gpcode_manager |
| | | from db.redis_manager_delegate import RedisUtils |
| | | from l2 import l2_data_log, l2_data_source_util |
| | | from log_module import log, log_export |
| | | from log_module import log, log_export, async_log_util |
| | | from db import redis_manager_delegate as redis_manager |
| | | from utils import tool |
| | | |
| | | __db = 1 |
| | | _redisManager = redis_manager.RedisManager(1) |
| | | # l2数据管理 |
| | | # 本地最新一次上传的数据 |
| | |
| | | |
| | | # 买入订单号映射,只有原生的L2数据才有 |
| | | local_today_buyno_map = {} |
| | | |
| | | # 卖出订单号映射,只有原生的L2数据才有 |
| | | local_today_sellno_map = {} |
| | | |
| | | # 已经撤单的订单号 |
| | | local_today_canceled_buyno_map = {} |
| | | |
| | | |
| | | def load_l2_data(code, load_latest=True, force=False): |
| | |
| | | # 根据今日数据加载 |
| | | load_num_operate_map(local_today_num_operate_map, code, local_today_datas.get(code), force) |
| | | load_buy_no_map(local_today_buyno_map, code, local_today_datas.get(code), force) |
| | | load_sell_no_map(local_today_sellno_map, code, local_today_datas.get(code), force) |
| | | load_canceled_buy_no_map(local_today_canceled_buyno_map, code, local_today_datas.get(code), force) |
| | | return data_normal |
| | | return True |
| | | |
| | | |
| | | # L2数据是否正常 |
| | | def l2_data_is_normal(code): |
| | | datas = local_today_datas.get(code) |
| | | if not datas: |
| | | # 初始化 |
| | | local_today_datas[code] = [] |
| | | load_num_operate_map(local_today_num_operate_map, code, local_today_datas.get(code)) |
| | | load_buy_no_map(local_today_buyno_map, code, local_today_datas.get(code)) |
| | | load_sell_no_map(local_today_sellno_map, code, local_today_datas.get(code)) |
| | | load_canceled_buy_no_map(local_today_canceled_buyno_map, code, local_today_datas.get(code)) |
| | | |
| | | if datas and len(datas) != datas[-1]["index"] + 1: |
| | | return False |
| | | return True |
| | | |
| | | |
| | | # 加载所有的l2数据 |
| | | def load_l2_data_all(force=False): |
| | | datas = log_export.load_l2_from_log() |
| | | for code in datas: |
| | | if force: |
| | | local_today_datas[code] = datas[code] |
| | | else: |
| | | if code not in local_today_datas: |
| | | local_today_datas[code] = datas[code] |
| | | load_num_operate_map(local_today_num_operate_map, code, local_today_datas.get(code), force) |
| | | load_buy_no_map(local_today_buyno_map, code, local_today_datas.get(code), force) |
| | | load_sell_no_map(local_today_sellno_map, code, local_today_datas.get(code), force) |
| | | load_canceled_buy_no_map(local_today_canceled_buyno_map, code, local_today_datas.get(code), force) |
| | | |
| | | constant.L2_DATA_IS_LOADED = True |
| | | |
| | | |
| | | # 将数据根据num-operate分类 |
| | |
| | | key = "{}".format(data["val"]["orderNo"]) |
| | | if local_today_buyno_map[code].get(key) is None: |
| | | local_today_buyno_map[code].setdefault(key, data) |
| | | |
| | | |
| | | # 将数据根据orderNo分类,原生数据才有 |
| | | def load_sell_no_map(local_today_sellno_map, code, source_datas, clear=False): |
| | | # 只有原生L2数据才会有此操作 |
| | | if constant.L2_SOURCE_TYPE != constant.L2_SOURCE_TYPE_HUAXIN: |
| | | return |
| | | if local_today_sellno_map.get(code) is None: |
| | | local_today_sellno_map[code] = {} |
| | | if clear: |
| | | local_today_sellno_map[code] = {} |
| | | |
| | | for data in source_datas: |
| | | if data["val"]["operateType"] != 2: |
| | | continue |
| | | # 只填充买入数据 |
| | | key = "{}".format(data["val"]["orderNo"]) |
| | | if local_today_sellno_map[code].get(key) is None: |
| | | local_today_sellno_map[code].setdefault(key, data) |
| | | |
| | | |
| | | # 将数据根据orderNo分类已撤订单,原生数据才有 |
| | | def load_canceled_buy_no_map(local_today_canceled_buyno_map, code, source_datas, clear=False): |
| | | # 只有原生L2数据才会有此操作 |
| | | if constant.L2_SOURCE_TYPE != constant.L2_SOURCE_TYPE_HUAXIN: |
| | | return |
| | | if local_today_canceled_buyno_map.get(code) is None: |
| | | local_today_canceled_buyno_map[code] = {} |
| | | if clear: |
| | | local_today_canceled_buyno_map[code] = {} |
| | | |
| | | for data in source_datas: |
| | | # 只留下买撤 |
| | | if data["val"]["operateType"] != 1: |
| | | continue |
| | | # 只填充买入数据 |
| | | key = "{}".format(data["val"]["orderNo"]) |
| | | if local_today_canceled_buyno_map[code].get(key) is None: |
| | | local_today_canceled_buyno_map[code].setdefault(key, data) |
| | | |
| | | |
| | | @tool.async_call |
| | |
| | | # 保存l2数据 |
| | | def save_l2_data(code, datas, add_datas): |
| | | # 只有有新曾数据才需要保存 |
| | | if len(add_datas) > 0: |
| | | if add_datas: |
| | | # 保存最近的数据 |
| | | __start_time = round(time.time() * 1000) |
| | | if datas: |
| | | RedisUtils.setex_async(_redisManager.getRedis(), "l2-data-latest-{}".format(code), tool.get_expire(), json.dumps(datas)) |
| | | RedisUtils.setex_async(__db, "l2-data-latest-{}".format(code), tool.get_expire(), |
| | | json.dumps(datas)) |
| | | # l2_data_log.l2_time(code, round(time.time() * 1000) - __start_time, "保存最近l2数据用时") |
| | | # 设置进内存 |
| | | local_latest_datas[code] = datas |
| | | set_l2_data_latest_count(code, len(datas)) |
| | | try: |
| | | log.logger_l2_data.info("{}-{}", code, add_datas) |
| | | async_log_util.l2_data_log.info(log.logger_l2_data, f"{code}-{add_datas}") |
| | | except Exception as e: |
| | | logging.exception(e) |
| | | # 暂时不将数据保存到redis |
| | | # saveL2Data(code, add_datas) |
| | | |
| | | |
| | | # 设置最新的l2数据采集的数量 |
| | |
| | | return False |
| | | |
| | | |
| | | # 是否为大单 |
| | | def is_big_money(val): |
| | | price = float(val["price"]) |
| | | money = price * int(val["num"]) |
| | | if price > 3.0: |
| | | if money >= 30000: |
| | | return True |
| | | else: |
| | | return False |
| | | else: |
| | | max_money = price * 10000 |
| | | if money >= max_money * 0.95: |
| | | return True |
| | | else: |
| | | return False |
| | | |
| | | |
| | | class L2DataUtil: |
| | | @classmethod |
| | | def is_same_time(cls, time1, time2): |
| | | if constant.TEST: |
| | | return True |
| | | time1_s = time1.split(":") |
| | | time1_second = int(time1_s[0]) * 3600 + int(time1_s[1]) * 60 + int(time1_s[2]) |
| | | time2_s = time2.split(":") |
| | | time2_second = int(time2_s[0]) * 3600 + int(time2_s[1]) * 60 + int(time2_s[2]) |
| | | if abs(time2_second - time1_second) < 3: |
| | | if abs(tool.trade_time_sub(time1, time2)) < 3: |
| | | return True |
| | | else: |
| | | return False |
| | |
| | | # 数据重复次数默认为1 |
| | | datas.append({"key": key, "val": item, "re": 1}) |
| | | dataIndexs.setdefault(key, len(datas) - 1) |
| | | # TODO 测试的时候开启,方便记录大单数据 |
| | | # 测试的时候开启,方便记录大单数据 |
| | | # l2_data_util.save_big_data(code, same_time_num, data) |
| | | return datas |
| | | |
| | |
| | | |
| | | if int(val["operateType"]) != 2: |
| | | return False |
| | | return True |
| | | |
| | | price = float(val["price"]) |
| | | num = int(val["num"]) |
| | | # if price * num * 100 < 50 * 10000: |
| | | # return False |
| | | # 涨停卖撤 |
| | | @classmethod |
| | | def is_limit_up_price_sell_cancel(cls, val): |
| | | if int(val["limitPrice"]) != 1: |
| | | return False |
| | | |
| | | if int(val["operateType"]) != 3: |
| | | return False |
| | | return True |
| | | |
| | | # 是否涨停买撤 |
| | |
| | | if int(val["operateType"]) != 1: |
| | | return False |
| | | |
| | | price = float(val["price"]) |
| | | num = int(val["num"]) |
| | | # if price * num * 100 < 50 * 10000: |
| | | # return False |
| | | return True |
| | | |
| | | @classmethod |
| | | def is_buy_cancel(cls, val): |
| | | if int(val["operateType"]) != 1: |
| | | return False |
| | | return True |
| | | |
| | | # 是否卖撤 |
| | |
| | | return True |
| | | return False |
| | | |
| | | # 是否为买 |
| | | @classmethod |
| | | def is_buy(cls, val): |
| | | if int(val["operateType"]) == 0: |
| | | return True |
| | | return False |
| | | |
| | | # l2时间差值 |
| | | @classmethod |
| | | def time_sub_as_ms(cls, val1, val2): |
| | | # 计算时间差值 |
| | | sub_s = tool.trade_time_sub(val1["time"], val2["time"]) |
| | | sub_ms = int(val1["tms"]) - int(val2["tms"]) |
| | | fs = sub_s * 1000 + sub_ms |
| | | return fs |
| | | |
| | | @classmethod |
| | | def get_time_with_ms(cls, val): |
| | | return val["time"] + "." + "{:0>3}".format(int(val["tms"])) |
| | | |
| | | |
| | | class L2TradeQueueUtils(object): |
| | | # 买入数据是否已撤 |
| | |
| | | # 是否有买撤数据 |
| | | if cancel_datas: |
| | | for cancel_data in cancel_datas: |
| | | buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data(code, cancel_data, |
| | | local_today_num_operate_map) |
| | | buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(cancel_data, |
| | | local_today_buyno_map.get( |
| | | code)) |
| | | if buy_index == data["index"]: |
| | | return True |
| | | return False |
| | |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | print(load_l2_data("002235")) |
| | | print(L2DataUtil.time_sub_as_ms({"time": "09:46:05", "tms": 480}, {"time": "09:46:04", "tms": 90})) |