test

Administrator

2024-11-17 6ec8dd04c6abf19e0f6007383ea0dc3832c32eb8

test

 huaxin_client/l1_client.py

@@ -315,7 +315,9 @@
        try:
            # 计算流入流出并上传
            custom_block_in_money_manager.BlockInMoneyRankManager().compute()
            queue_custom_block_in_money.put_nowait((custom_block_in_money_manager.BlockInMoneyRankManager().get_in_list(),  custom_block_in_money_manager.BlockInMoneyRankManager().get_out_list()))
            val = (custom_block_in_money_manager.BlockInMoneyRankManager().get_in_list(),  custom_block_in_money_manager.BlockInMoneyRankManager().get_out_list())
            val = json.dumps(val)
            queue_custom_block_in_money.put_nowait(val)

            if len(level1_data_dict) < 1:
                continue

 servers/huaxin_trade_server.py

@@ -584,6 +584,7 @@
            try:
                val = queue_custom_block_in_money.get()
                if val:
                    val = json.loads(val)
                    in_list, out_list = val[0], val[1]
                    logger_debug.info(f"接收到流入流出数据：{in_list[:20]}, {out_list[:20]}")
                    RealTimeKplMarketData.set_market_jingxuan_blocks_from_custom(in_list)