bug修复

Administrator

2023-07-27 c60de4037ef58bc6ef9f07bf61b608c2e484ab00

bug修复

 l2/huaxin/huaxin_target_codes_manager.py

@@ -84,7 +84,7 @@
                zyltgb = global_util.zyltgb_map[code]

            fitem = {"code": code, "price": d[1], "volume": d[3] // 10000, "volumeUnit": 1, "time": "00:00:00",
                     "zyltgb": zyltgb, "zyltgbUnit": 1}
                     "zyltgb": zyltgb//10000, "zyltgbUnit": 1}
            flist.append(fitem)
        fdata = {"type": 22, "data": flist}
        print("首板代码数量", len(flist))
@@ -103,3 +103,17 @@
            # result, header = socket_util.recv_data(sk)
        finally:
            sk.close()


if __name__ == "__main__":
    code = "002703"
    if code not in global_util.zyltgb_map:
        zylt = kpl_api.getZYLTAmount(code)
        if zylt:
            # 保存自由流通股本
            ZYLTGBUtil.save(code, zylt // 10000, 1)
            global_util.zyltgb_map[code] = int(zylt)
    zyltgb = 0
    if code in global_util.zyltgb_map:
        zyltgb = global_util.zyltgb_map[code]
    print(zyltgb)

 trade/huaxin/trade_server.py

@@ -172,7 +172,7 @@
                            pr.enable()
                            l2_data_manager_new.L2TradeDataProcessor.process_huaxin(code, datas)
                            pr.disable()
                            pr.dump_stats(f"/home/logs/profile/{code}/{round(time.time()*1000)}.log")
                            pr.dump_stats(f"/home/logs/profile/{code}_{round(time.time()*1000)}.log")
                        finally:
                            sk.sendall(socket_util.load_header(json.dumps({"code": 0}).encode(encoding='utf-8')))