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,12 +357,15 @@
            # 最新的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(