测试

Administrator

2024-11-17 775dd0fc3807ab51aa974d57401f543101077022

测试

 huaxin_client/l1_client.py

@@ -219,6 +219,7 @@

def __test_block_in_money():
    codes = BlockInMoneyRankManager().get_codes()
    logger_debug.info("获取到测试净流入代码数量：{}", len(codes))
    page_size = 200
    total_page = len(codes) // page_size + 1

@@ -312,6 +313,10 @@
    while True:
        print("数量", len(level1_data_dict))
        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())

            if len(level1_data_dict) < 1:
                continue
            # 根据涨幅排序
@@ -343,9 +348,7 @@
            if len(datas) > 0:
                logger_l2_codes_subscript.info("开始#华鑫L1上传代码：数量-{}", len(datas))
                __upload_codes_info(queue_l1_w_strategy_r, datas)
            # 计算流入流出并上传
            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())

        except Exception as e:
            logging.exception(e)
            logger_debug.exception(e)

 servers/huaxin_trade_server.py

@@ -585,6 +585,7 @@
                val = queue_custom_block_in_money.get()
                if val:
                    in_list, out_list = val[0], val[1]
                    logger_debug.info(f"接收到流入流出数据：{len(in_list)}, {len(out_list)}")
                    RealTimeKplMarketData.set_market_jingxuan_blocks_from_custom(in_list)
                    RealTimeKplMarketData.set_market_jingxuan_out_blocks_from_custom(out_list)
            except Exception as e: