data_server.py
@@ -380,6 +380,16 @@ # 成交大单传递 datas = self.rfile.read(int(self.headers['content-length'])) _str = str(datas, encoding="gbk") datas = json.loads(_str) for d in datas: if d[1] != 0: continue code, data = d[0], d[2] if code not in data_cache.big_order_deal_dict: data_cache.big_order_deal_dict[code] = [] data_cache.big_order_deal_dict[code].append(data) # TODO 获取买大单数量 len(data_cache.big_order_deal_dict.get(code, [])) hx_logger_l2_transaction.info(_str) # 记录日志 result_str = json.dumps({"code": 0})