Administrator
4 小时以前 8b5f4dcda25d4aa72a35d778f8cb3757c26acc42
修改接口
4个文件已修改
32 ■■■■ 已修改文件
api/outside_api_command_callback.py 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
constant.py 3 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
servers/data_server.py 26 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
servers/huaxin_trade_server.py 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
api/outside_api_command_callback.py
@@ -1032,7 +1032,7 @@
                        except Exception as e:
                            logger_debug.exception(e)
                result = {"code": 0, "data": {"account_available_money": account_available_money, "delegates": fdatas}}
                result = {"code": 0, "data": {"account_available_money": account_available_money, "delegates": fdatas, "rate_of_increase_step": constant.L_DOWN_RATE_INCREASE_STEP}}
                self.send_response(result, client_id, request_id)
            elif ctype == "get_delegated_buy_code_infos_v2":
                account_available_money = trade_data_manager.AccountMoneyManager().get_available_money_cache()
constant.py
@@ -239,4 +239,7 @@
# 是否可以自动拉白
CAN_AUTO_ADD_WHITE = True
# L后撤单阈值变大步长
L_DOWN_RATE_INCREASE_STEP = 0.1
servers/data_server.py
@@ -948,11 +948,11 @@
        elif url.path == "/get_l2_subscript_codes":
            # 获取L2订阅的代码
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
            code = ps_dict.get('code')
            single_code = ps_dict.get('code')
            fresults = []
            try:
                if code:
                    codes = [code]
                if single_code:
                    codes = [single_code]
                else:
                    codes = huaxin_target_codes_manager.HuaXinL2SubscriptCodesManager.get_subscript_codes()
                if codes:
@@ -1006,12 +1006,21 @@
                                code)
                            if not big_money_rate:
                                big_money_rate = 0
                            # 计算涨停成交大单占累计大单阈值的比例
                            if deal_big_money_info:
                                big_deal_rate_of_threashold_total_money = round(
                                    deal_big_money_info[1] / deal_big_money_info[3], 2)
                            else:
                                big_deal_rate_of_threashold_total_money = 0
                            # 大单成交信息
                            deal_big_order_info = [
                                (output_util.money_desc(th_temp_buy_info[0] if th_temp_buy_info else 0),  # 临时买大单阈值
                                 output_util.money_desc(th_buy),  # 买大单阈值
                                 output_util.money_desc(th_sell),  # 卖单阈值
                                 big_money_rate * 100  # 大单成交比
                                 big_money_rate * 100,  # 大单成交比(成交大单占整体成交额的比例)
                                 big_deal_rate_of_threashold_total_money
                                 ),
                                # 涨停大单净买入
                                output_util.money_desc(deal_big_money_info[1]),
@@ -1022,7 +1031,7 @@
                                # 人为设置的大单
                                output_util.money_desc(deal_big_money_info[4]) if deal_big_money_info[4] else '',
                            ]
                            if len(codes) == 1:
                            if single_code:
                                # 加载大单详情
                                deal_big_order_detail_info = radical_buy_data_manager.get_l2_big_order_deal_info(code)
                                # 加载涨停大单详情
@@ -1064,12 +1073,15 @@
                        except:
                            pass
                        try:
                            is_limit_up = 1 if abs(current_price_dict.get(code, 0) - gpcode_manager.get_limit_up_price_as_num(code)) < 0.001 else 0
                            is_limit_up = 1 if abs(
                                current_price_dict.get(code, 0) - gpcode_manager.get_limit_up_price_as_num(
                                    code)) < 0.001 else 0
                        except:
                            is_limit_up = 0
                            pass
                        fresults.append(
                            (code, code_name, deal_big_order_info, deal_big_order_detail_info, big_order_enough_type, current_rate_dict.get(code, 0), is_limit_up))
                            (code, code_name, deal_big_order_info, deal_big_order_detail_info, big_order_enough_type,
                             current_rate_dict.get(code, 0), is_limit_up))
                response_data = json.dumps({"code": 0, "data": fresults})
            except Exception as e:
                response_data = json.dumps({"code": 1, "data": str(1)})
servers/huaxin_trade_server.py
@@ -1127,6 +1127,7 @@
        schedule.every().day.at("07:58:00").do(__update_yesterday_kpl_limit_up_datas)
        # 更新代码
        schedule.every().day.at("15:58:00").do(__update_l1_target_codes)
        schedule.every().day.at("08:56:00").do(__update_l1_target_codes)
        # 更新K线
        schedule.every().day.at("16:30:00").do(history_k_data_manager.update_history_k_bars)