| | |
|---|
| | | # 开盘啦的涨停概念的回调函数 |
|---|
| | | def kpl_limit_up_process(datas): |
|---|
| | | # print(f"回调成功==={datas}") |
|---|
| | | now_time = tool.get_now_time_str() |
|---|
| | | if datas is not None and len(datas) > 0: |
|---|
| | | data_cache.limit_up_block_names = datas |
|---|
| | | if data_cache.CLOSING_TIME < now_time < data_cache.AFTER_CLOSING_TIME: |
|---|
| | | logger_common.info(f"收盘涨停概念列表更新==={now_time}=={datas}") |
|---|
| | | else: |
|---|
| | | data_cache.limit_up_block_names = [] |
|---|
| | | |
|---|
| | |
|---|
| | | 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, |
|---|
