| | |
|---|
| | | # 通过板块ID获取其下面的个股强度列表 |
|---|
| | | # print(f"======={i[0]}=======") |
|---|
| | | its_stock = json.loads(getCodesByPlate(i[0])) |
|---|
| | | |
|---|
| | | |
|---|
| | | log_data = {plate_name: its_stock['list']} |
|---|
| | | |
|---|
| | | # its_stock_list_info = its_stock['list'] |
|---|
| | | # logger.info(f"its_stock_list_info==={its_stock_list_info}") |
|---|
| | |
|---|
| | | ds.append(request_plate_codes(d)) |
|---|
| | | dask_result = batch_get_plate_codes(ds) |
|---|
| | | compute_results = dask_result.compute() |
|---|
| | | log_datas={} |
|---|
| | | log_datas = {} |
|---|
| | | for r in compute_results: |
|---|
| | | if not r: |
|---|
| | | continue |
|---|
| | |
|---|
| | | if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME: |
|---|
| | | logger.info(f"精选板块股票强度数据更新 == {market_sift_plate_stock_dict}") |
|---|
| | | # 只在盘中时间获取 |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{(market_sift_plate['list'],log_datas)}") |
|---|
| | | async_log_util.info(logger_stock_of_markets_plate, f"{(market_sift_plate['list'], log_datas)}") |
|---|
| | | |
|---|
| | | return market_sift_plate_stock_dict |
|---|
| | | |
|---|
| | |
|---|
| | | # 根据账户可用金额 计算今日计划下单金额 |
|---|
| | | # ((大盘综合强度分数 + 大盘指数情绪预期分数) * 0.01) * (账户可用金额 * 极端低迷情绪比例 / 今日最大新增持仓票数) |
|---|
| | | data_cache.today_planned_order_amount = (( |
|---|
| | | data_cache.real_time_market_strong + index_trend_expectation_score) * 0.01) * ( |
|---|
| | | usefulMoney * low_emotion_mood_ratio / Unfinished_opening_plan_number) |
|---|
| | | data_cache.real_time_market_strong + index_trend_expectation_score) * 0.01) * ( |
|---|
| | | usefulMoney * low_emotion_mood_ratio / Unfinished_opening_plan_number) |
|---|
| | | else: |
|---|
| | | data_cache.today_planned_order_amount = data_cache.BUY_MONEY_PER_CODE |
|---|
| | | |
|---|
