定时强制更新K线

Administrator

2 天以前 d73df3ed85355d7877d9d4ff96af105d7a329b99

定时强制更新K线

 servers/huaxin_trade_server.py

@@ -234,7 +234,7 @@
                                            code, gpcode_manager.get_limit_up_price_as_num(code))
                                        deal_big_order_info = (
                                            output_util.money_desc(th), output_util.money_desc(deal_big_money_info[1]),
                                            output_util.money_desc(deal_big_money_info[2]), deal_big_money_info[0] <=0)
                                            output_util.money_desc(deal_big_money_info[2]), deal_big_money_info[0] <= 0)
                                    except:
                                        deal_big_order_info = None
                                    code_name = gpcode_manager.get_code_name(code)
@@ -271,7 +271,7 @@
                                            code, gpcode_manager.get_limit_up_price_as_num(code))
                                        deal_big_order_info = (
                                            output_util.money_desc(th), output_util.money_desc(deal_big_money_info[1]),
                                            output_util.money_desc(deal_big_money_info[2]), deal_big_money_info[0] <=0)
                                            output_util.money_desc(deal_big_money_info[2]), deal_big_money_info[0] <= 0)
                                    except:
                                        deal_big_order_info = None
                                    code_name = gpcode_manager.get_code_name(code)
@@ -857,7 +857,7 @@
                                                                     mode_desc=f"扫入买入：{buy_blocks}, 大单成交最小订单号：{min_order_no}",
                                                                     sell_info=sell_info,
                                                                     threshold_money=threshold_money,
                                                                     min_order_no= min_order_no
                                                                     min_order_no=min_order_no
                                                                     )
                            L2TradeDataProcessor.save_order_begin_data(code, order_begin_pos_info)
                            buy_result = L2TradeDataProcessor.start_buy(code, total_datas[-1], total_datas[-1]["index"],
@@ -1102,10 +1102,9 @@
        # 更新K线
        schedule.every().day.at("08:00:01").do(history_k_data_manager.update_history_k_bars)
        schedule.every().day.at("08:30:01").do(history_k_data_manager.update_history_k_bars)
        schedule.every().day.at("09:00:01").do(history_k_data_manager.update_history_k_bars)
        schedule.every().day.at("09:02:01").do(lambda: history_k_data_manager.update_history_k_bars(force=True))
        # 更新账户信息
        schedule.every().day.at("09:00:01").do(huaxin_trade_data_update.add_money_list)
        schedule.every().day.at("09:15:20").do(huaxin_trade_data_update.add_money_list)
        schedule.every().day.at("09:15:20").do(huaxin_trade_data_update.add_money_list)
        # 更新昨日实时涨停数据
        schedule.every().day.at("07:58:00").do(__update_yesterday_kpl_limit_up_datas)

 third_data/history_k_data_manager.py

@@ -15,7 +15,7 @@
from utils import tool, init_data_util


def update_history_k_bars():
def update_history_k_bars(force=False):
    """
    更新历史K线
    @return: 此次更新的数量
@@ -26,7 +26,8 @@
            try:
                datas = init_data_util.get_volumns_by_code(code, 150)
                if datas:
                    HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas)
                    HistoryKDataManager().save_history_bars(code, datas[0]['bob'].strftime("%Y-%m-%d"), datas,
                                                            force=force)
            except Exception as e:
                logger_debug.exception(e)

@@ -40,8 +41,9 @@
        for code_byte in codes_sz:
            codes.add(code_byte.decode())
    # 获取已经更新的数据
    codes_record = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
    codes = codes - codes_record
    if not force:
        codes_record = HistoryKDataManager().get_history_bars_codes(latest_trading_date)
        codes = codes - codes_record
    threading.Thread(target=lambda: update(codes), daemon=True).start()

    return len(codes)