| | |
|---|
| | | code = data["code"] |
|---|
| | | datas = data["data"] |
|---|
| | | hx_logger_l2_transaction.info(f"{code}#{datas}") |
|---|
| | | try: |
|---|
| | | buyno_map = l2_data_util.local_today_buyno_map.get(code) |
|---|
| | | |
|---|
| | | hx_logger_l2_transaction(f"{code}的买入订单号数量:{len(buyno_map.keys()) if buyno_map else 0}") |
|---|
| | | buy_progress_index = None |
|---|
| | | for d in datas: |
|---|
| | |
|---|
| | | code), |
|---|
| | | l2_data_util.local_today_num_operate_map.get( |
|---|
| | | code)) |
|---|
| | | except Exception as e: |
|---|
| | | hx_logger_l2_transaction.exception(e) |
|---|
| | | |
|---|
| | | sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8')) |
|---|
| | | elif data_json["type"] == "l2_market_data": |
|---|
