L撤/H撤接口根据买入信号位置拉取

Administrator

2023-11-07 7a2e1ecbc31db9b91c8e502d5c0bec3240a298dd

L撤/H撤接口根据买入信号位置拉取

 third_data/data_server.py

@@ -332,16 +332,21 @@
            # 最新的l撤数据
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
            code = ps_dict['code']
            buy_single_index = ps_dict.get('buy_single_index')
            records = code_info_output.load_trade_record_cancel_watch_indexes(code)
            # 获取最新的L上与L下
            records.reverse()
            up_indexes = []
            down_indexes = []
            for r in records:
                if buy_single_index and buy_single_index != r[1]:
                    continue
                if r[0] == trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_L_UP:
                    up_indexes = r[2]
                    break
            for r in records:
                if buy_single_index and buy_single_index != r[1]:
                    continue
                if r[0] == trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_L_DOWN:
                    down_indexes = r[2]
                    break
@@ -352,16 +357,19 @@
            # 最新的H撤数据
            ps_dict = dict([(k, v[0]) for k, v in parse_qs(url.query).items()])
            code = ps_dict['code']
            buy_single_index = ps_dict.get('buy_single_index')
            records = code_info_output.load_trade_record_cancel_watch_indexes(code,
                                                                              trade_record_log_util.CancelWatchIndexesInfo.CANCEL_TYPE_H)
            # 获取最新的L上与L下
            records.reverse()
            indexes = []
            for r in records:
                if buy_single_index and buy_single_index != r[1]:
                    continue
                indexes = r[2]
                break
            response_data = json.dumps(
                {"code": 0, "data":indexes})
                {"code": 0, "data": indexes})
        elif url.path == "/kpl/get_limit_up_list":
            response_data = self.__get_limit_up_list()