| | |
|---|
| | | daemon=True).start() |
|---|
| | | |
|---|
| | | # # 开盘啦的板块强度下的个股强度回调函数 |
|---|
| | | def get_market_sift_plate_its_stock_power_process(market_sift_plate_stock_dict): |
|---|
| | | def get_market_sift_plate_its_stock_power_process(market_sift_plate_info): |
|---|
| | | # print(f"回调成功===精选板块股票强度数据更新==={market_sift_plate_stock_dict}") |
|---|
| | | # logger_kpl_jingxuan_in.info(f"{market_sift_plate_stock_dict}") |
|---|
| | | market_sift_plate_stock_dict, market_sift_plates = market_sift_plate_info[0], market_sift_plate_info[1] |
|---|
| | | if market_sift_plate_stock_dict: |
|---|
| | | data_cache.market_sift_plate_stock_dict = market_sift_plate_stock_dict |
|---|
| | | data_cache.market_sift_plates = market_sift_plates |
|---|
| | | |
|---|
| | | # 板块强度下个股强度线程 |
|---|
| | | threading.Thread(target=plate_strength_analysis.get_market_sift_plate_its_stock_power_process, |
|---|
| | |
|---|
| | | |
|---|
| | | # 实时L2买1成交量 |
|---|
| | | def OnRealTimeBuy1Info(self, code, buy1_info): |
|---|
| | | pass |
|---|
| | | # buy1_info: [买1时间,买1价格, 原始买1量, 实时买1量] |
|---|
| | | # 最终的买1为： 原始买1量+实时买1量 |
|---|
| | | async_log_util.info(logger_debug, f"OnRealTimeBuy1Info：{code}-{buy1_info}") |
|---|
| | | # async_log_util.info(logger_debug, f"OnRealTimeBuy1Info：{code}-{buy1_info}") |
|---|
| | | # L1DataProcessor.excute_sell_rule(code, buy1_info[3], buy1_info[1], "l2-real") |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | # 加载开盘啦板块日志数据 |
|---|
| | | kpl_data_manager.KPLStockOfMarketsPlateLogManager() |
|---|
| | | kpl_data_manager.KPLMarketsSiftPlateLogManager() |
|---|
| | | kpl_data_manager.KPLMarketStockHeatLogManager() |
|---|
| | | |
|---|
| | | # 启动异步日志 |
|---|
| | | threading.Thread(target=async_log_util.run_sync, daemon=True).start() |
|---|
