| | |
|---|
| | | threading.Thread(target=__run_subscript_task, args=(spi,), daemon=True).start() |
|---|
| | | |
|---|
| | | # 测试 |
|---|
| | | __test_block_in_money() |
|---|
| | | # __test_block_in_money() |
|---|
| | | |
|---|
| | | # 等待程序结束 |
|---|
| | | while True: |
|---|
| | | print("数量", len(level1_data_dict)) |
|---|
| | | # print("数量", len(level1_data_dict)) |
|---|
| | | try: |
|---|
| | | # 计算流入流出并上传 |
|---|
| | | custom_block_in_money_manager.BlockInMoneyRankManager().compute() |
|---|
| | |
|---|
| | | if val: |
|---|
| | | val = json.loads(val) |
|---|
| | | in_list, out_list = val[0], val[1] |
|---|
| | | logger_debug.info(f"接收到流入流出数据：{in_list[:20]}, {out_list[:20]}") |
|---|
| | | # logger_debug.info(f"接收到流入流出数据：{in_list[:20]}, {out_list[:20]}") |
|---|
| | | RealTimeKplMarketData.set_market_jingxuan_blocks_from_custom(in_list) |
|---|
| | | RealTimeKplMarketData.set_market_jingxuan_out_blocks_from_custom(out_list) |
|---|
| | | except Exception as e: |
|---|
