Changes

Administrator

2022-08-25 34491829675033e41715648b1e92f339bf2f35d1

 juejin.py

@@ -44,9 +44,9 @@
    # 多个时间点获取收盘价
    gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='08:30:00')
    gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='08:50:00')
    gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='09:15:00')
    gmapi.schedule(schedule_func=get_latest_info, date_rule='1d', time_rule='09:28:00')
    gmapi.schedule(schedule_func=get_current_info, date_rule='1d', time_rule='09:25:00')
    gmapi.schedule(schedule_func=get_current_info, date_rule='1d', time_rule='09:29:00')
    gmapi.schedule(schedule_func=get_current_info, date_rule='1d', time_rule='09:29:35')
    re_subscribe_tick()
    # re_subscribe_bar()

@@ -63,14 +63,15 @@
    for c in clients:
        for i in range(0, 8):
            gpcode_manager.init_listen_code_by_pos(int(c), i)
    data = gpcode_manager.get_gp_list();
    result = JueJinManager.get_gp_latest_info(data);
    codes = gpcode_manager.get_gp_list();
    result = JueJinManager.get_gp_latest_info(codes);
    for item in result:
        sec_level = item['sec_level']
        symbol = item['symbol']
        symbol = symbol.split(".")[1]
        pre_close = tool.to_price(decimal.Decimal(str(item['pre_close'])))
        if sec_level == 1:
            if symbol in codes:
            gpcode_manager.set_price_pre(symbol, pre_close)
        else:
            gpcode_manager.rm_gp(symbol)
@@ -90,12 +91,12 @@


# 设置收盘价
def set_price_pre(code):
def re_set_price_pre(code):
    codes = [code]
    set_price_pres(codes)
    re_set_price_pres(codes)


def set_price_pres(codes):
def re_set_price_pres(codes):
    result = JueJinManager.get_gp_latest_info(codes);
    for item in result:
        symbol = item['symbol']
@@ -175,9 +176,20 @@
def recieve_msg(pipe):
    while True:
        value = pipe.recv()
        print(value)
        if value == 'resub':
        print("跨进程通信：",value)
        jsonValue= json.loads(value)
        action=jsonValue["type"]
        if action == 'resub':
            re_subscribe_tick()
        elif action == 'accpt_price':
            try:
                datas=jsonValue["data"]
                for data in datas:
                    accpt_price(data["code"],float(data["price"]))
            except Exception as e:
                print(str(e))




class JueJinManager: