| | |
|---|
| | | th_sell = 0 |
|---|
| | | deal_big_money_info = radical_buy_data_manager.get_total_deal_big_order_info( |
|---|
| | | code, gpcode_manager.get_limit_up_price_as_num(code)) |
|---|
| | | if deal_big_money_info[1] == 0 and len(codes) == 1: |
|---|
| | | |
|---|
| | | deal_big_money_info = list(deal_big_money_info) |
|---|
| | | # 没有订阅L2会出现没有值的情况，如果涨停过就拉取之前的涨停买/卖大单 |
|---|
| | | deal_big_orders_result = radical_buy_data_manager.request_deal_big_orders(code) |
|---|
| | | if deal_big_orders_result: |
|---|
| | | buy_datas, sell_datas = deal_big_orders_result[0], deal_big_orders_result[1] |
|---|
| | | limit_up_price = gpcode_manager.get_limit_up_price_as_num(code) |
|---|
| | | limit_up_price_money_list = [x[0] for x in buy_datas if x[1] == limit_up_price] |
|---|
| | | if limit_up_price_money_list: |
|---|
| | | threshold_money = BeforeSubDealBigOrderManager().compute_re_limit_up_big_money_threshold( |
|---|
| | | limit_up_price_money_list) |
|---|
| | | else: |
|---|
| | | threshold_money = 299e4 |
|---|
| | | logger_debug.info(f"{code}-临时回封均大单：{threshold_money}") |
|---|
| | | # 设置买单阈值 |
|---|
| | | th_buy = threshold_money |
|---|
| | | buy_money = sum(limit_up_price_money_list) |
|---|
| | | sell_money = sum([x[0] for x in sell_datas if x[1] == limit_up_price]) |
|---|
| | | # 涨停大单净买入 |
|---|
| | | deal_big_money_info[1] = buy_money - sell_money |
|---|
| | | deal_big_money_info[ |
|---|
| | | 2] = radical_buy_data_manager.compute_total_deal_big_order_threshold_money(code, |
|---|
| | | limit_up_price, |
|---|
| | | threshold_money) |
|---|
| | | logger_debug.info(f"{code}-累计大单阈值：{deal_big_money_info[2]}") |
|---|
| | | logger_debug.info(f"{code}非订阅大单， buy_money-{buy_money}, sell_money-{sell_money}") |
|---|
| | | |
|---|
| | | big_money_rate = radical_buy_data_manager.TotalDealBigOrderInfoManager.get_big_order_rate( |
|---|
| | | code) |
|---|
| | | if not big_money_rate: |
|---|
| | |
|---|
| | | output_util.money_desc(th_sell), # 卖单阈值 |
|---|
| | | big_money_rate * 100 # 大单成交比 |
|---|
| | | ), |
|---|
| | | # 涨停大单净买入 |
|---|
| | | output_util.money_desc(deal_big_money_info[1]), |
|---|
| | | # 累计总大单阈值 |
|---|
| | | output_util.money_desc(deal_big_money_info[2]), |
|---|
| | | # 原累计大单阈值（非人为设置） |
|---|
| | | output_util.money_desc(deal_big_money_info[3]), |
|---|
| | | # 人为设置的大单 |
|---|
| | | output_util.money_desc(deal_big_money_info[4]) if deal_big_money_info[4] else '', |
|---|
| | | ] |
|---|
| | | if len(codes) == 1: |
|---|
| | | # 加载大单详情 |
|---|
| | |
|---|
| | | # 加载涨停大单详情 |
|---|
| | | limit_up_big_order_detail = radical_buy_data_manager.get_total_detal_big_order_details( |
|---|
| | | code) |
|---|
| | | if max(limit_up_big_order_detail) == 0: |
|---|
| | | # 没有数据，从网络加载 |
|---|
| | | limit_up_big_order_detail = list(limit_up_big_order_detail) |
|---|
| | | limit_up_big_order_detail[1] = deal_big_order_detail_info[1][0] |
|---|
| | | limit_up_big_order_detail[3] = deal_big_order_detail_info[2][0] |
|---|
| | | deal_big_order_info.append( |
|---|
| | | output_util.money_desc(limit_up_big_order_detail[0] + limit_up_big_order_detail[1])) |
|---|
| | | deal_big_order_info.append( |
|---|
| | |
|---|
| | | logger_debug.error(f"可能没有获取到涨停价：{code}") |
|---|
| | | if not gpcode_manager.get_limit_up_price(code): |
|---|
| | | init_data_util.re_set_price_pre(code) |
|---|
| | | # logger_debug.exception(e) |
|---|
| | | logger_debug.exception(e) |
|---|
| | | deal_big_order_info = None |
|---|
| | | code_name = gpcode_manager.get_code_name(code) |
|---|
| | | fresults.append((code, code_name, deal_big_order_info, deal_big_order_detail_info)) |
|---|
