| | |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | dask_result.compute() |
|---|
| | | now_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S') |
|---|
| | | now_time = data_cache.now_time |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | return market_sift_plate_stock_dict |
|---|
| | |
|---|
| | | # 获取涨停板块名称列表并存储本地的函数 |
|---|
| | | def get_limit_up_block_names(): |
|---|
| | | # 设定当前时间点 |
|---|
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
|---|
| | | now_time = data_cache.now_time |
|---|
| | | # print(f"now_time===={now_time}") |
|---|
| | | if data_cache.SERVER_RESTART_TIME < now_time < data_cache.UPDATE_DATA_TIME: |
|---|
| | | # print(f"在时间内使用--------------------------") |
|---|
| | |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | if data_cache.position_automatic_management_switch is True: |
|---|
| | | now_time = datetime.datetime.now().strftime("%H:%M:%S") |
|---|
| | | now_time = data_cache.now_time |
|---|
| | | if data_cache.SERVER_RESTART_TIME < now_time < data_cache.UPDATE_DATA_TIME: |
|---|
| | | # 获取大盘综合强度分数 |
|---|
| | | data_cache.real_time_market_strong = get_market_strong() |
|---|
