| | |
|---|
| | | |
|---|
| | | # ====================== 核心因子计算 ====================== |
|---|
| | | def calculate_factors(data): |
|---|
| | | data = {'-1': '284', '-10': '2', '-2': '80', '-3': '32', '-4': '11', '-5': '6', '-6': '6', '-7': '2', '-8': '0', |
|---|
| | | '-9': '1', '0': '101', '1': '1376', '10': '8', '2': '1760', '3': '964', '4': '285', '5': '108', '6': '49', |
|---|
| | | '7': '17', '8': '9', '9': '2', 'DT': 3, 'SJDT': '2', 'SJZT': '15', 'STDT': '1', 'STZT': '7', 'SZJS': 4600, |
|---|
| | | 'XDJS': 427, 'ZSZDFB': '1939,238,57,446,45,8,271,19,2,42,7,1,26,19,5,217,71,12,', 'ZT': 22, |
|---|
| | | 'sign': '市场人气较好', 'szln': 1113353, 'qscln': 3725698, 's_zrcs': 2185592, 'q_zrcs': 5573160, |
|---|
| | | 's_zrtj': 58079140, 'q_zrtj': 134866542} |
|---|
| | | # data = {'-1': '284', '-10': '2', '-2': '80', '-3': '32', '-4': '11', '-5': '6', '-6': '6', '-7': '2', '-8': '0', |
|---|
| | | # '-9': '1', '0': '101', '1': '1376', '10': '8', '2': '1760', '3': '964', '4': '285', '5': '108', '6': '49', |
|---|
| | | # '7': '17', '8': '9', '9': '2', 'DT': 3, 'SJDT': '2', 'SJZT': '15', 'STDT': '1', 'STZT': '7', 'SZJS': 4600, |
|---|
| | | # 'XDJS': 427, 'ZSZDFB': '1939,238,57,446,45,8,271,19,2,42,7,1,26,19,5,217,71,12,', 'ZT': 22, |
|---|
| | | # 'sign': '市场人气较好', 'szln': 1113353, 'qscln': 3725698, 's_zrcs': 2185592, 'q_zrcs': 5573160, |
|---|
| | | # 's_zrtj': 58079140, 'q_zrtj': 134866542} |
|---|
| | | |
|---|
| | | if data is not None and len(data) > 0: |
|---|
| | | zero = int(data.get('0')) |
|---|
| | |
|---|
| | | max_key = max(rise_and_fall_dirt, key=rise_and_fall_dirt.get) |
|---|
| | | # 找到最小值对应的键 |
|---|
| | | min_key = min(rise_and_fall_dirt, key=rise_and_fall_dirt.get) |
|---|
| | | |
|---|
| | | # 涨跌比因子 --------------------------------------------------- |
|---|
| | | factors['rise_vs_fall'] = { |
|---|
| | | 'rise_vs_fall_ratio': round(rise_sum / fall_sum, 2) if fall_sum > 0 else 0, # 涨跌比 |
|---|
| | |
|---|
| | | f"上涨家数：{rise_numbers}，下跌家数：{fall_numbers}，实际涨停家数：{actual_limit_up_numbers}，实际跌停家数：{actual_limit_down_numbers}") |
|---|
| | | logger.info(f"涨跌统计字典{data_cache.rise_and_fall_statistics_dirt}") |
|---|
| | | |
|---|
| | | usefulMoney = data_cache.account_finance_dict[0].get('usefulMoney', 0) |
|---|
| | | logger.info(f"账户可用资金==={usefulMoney}元") |
|---|
| | | # 低迷情绪比例 |
|---|
| | | low_emotion_mood_ratio = 1 |
|---|
| | | # 33分是个两级分化阶梯不好，目前不好拿捏，暂时不用 |
|---|
| | |
|---|
| | | # 定义一个今日的剩余新增持仓数量的变量 |
|---|
| | | Unfinished_opening_plan_number = 3 - addition_position_number |
|---|
| | | logger.info(f"今日的剩余新增持仓数量==={Unfinished_opening_plan_number}") |
|---|
| | | usefulMoney = data_cache.account_finance_dict[0].get('usefulMoney', 0) |
|---|
| | | logger.info(f"账户可用资金==={usefulMoney}元") |
|---|
| | | if Unfinished_opening_plan_number != 0: |
|---|
| | | # 如果GUI看盘上没有手动设置具体的下单金额，就按照评分策略的金额下单，否则就按照GUI设置的金额下单。 |
|---|
| | | if data_cache.BUY_MONEY_PER_CODE < 0: |
|---|
| | |
|---|
| | | # ((大盘综合强度分数 + 大盘指数情绪预期分数) * 0.01) * (账户可用金额 * 0.9 * 极端低迷情绪比例 / 今日最大新增持仓票数) |
|---|
| | | # data_cache.today_planned_order_amount = ((data_cache.real_time_market_strong + data_cache.index_trend_expectation_score) * 0.01) * ( |
|---|
| | | # usefulMoney * 0.9 * low_emotion_mood_ratio / Unfinished_opening_plan_number) |
|---|
| | | data_cache.today_planned_order_amount = ( |
|---|
| | | usefulMoney * 0.95 * low_emotion_mood_ratio / Unfinished_opening_plan_number) |
|---|
| | | data_cache.today_planned_order_amount = usefulMoney * 0.95 * low_emotion_mood_ratio / Unfinished_opening_plan_number |
|---|
| | | logger.info( |
|---|
| | | f"采用开仓策略计算方式=》今日计划下单金额:{data_cache.today_planned_order_amount}，") |
|---|
| | | else: |
|---|
