华鑫适配

Administrator

2023-07-07 6793c77dfedaf90edf4da30c121fd837fb2227fb

 trade/trade_juejin.py

@@ -124,26 +124,27 @@


def run():
    print("启动读取掘金交易数据")
    # strategy_id = "e97a257e-1bba-11ed-a1b1-00e070c694ff"
    # token = "a2eed2b159e9238dc0353fc3e73734d7677f7baf"
    # gmapi.run(strategy_id, filename="trade.trade_juejin.py", mode=gmapi.MODE_LIVE, token=token)
    while True:
        try:
            if tool.is_trade_time():
                datas = get_execution_reports()
                # 上传数据
                fdatas = []
                for d in datas:
                    fdatas.append(
                        {"code": d[0], "money": d[4], "num": d[2], "price": d[3], "time": d[7], "trade_num": d[5],
                         "type": d[1] - 1})
                if fdatas:
                    network_util.send_socket_msg("127.0.0.1", 9001, {"type": 3, "data": fdatas})
        except Exception as e:
            logging.exception(e)
        # 2s更新
        time.sleep(1.5)
    if constant.TRADE_WAY == constant.TRADE_WAY_JUEJIN:
        print("启动读取掘金交易数据")
        # strategy_id = "e97a257e-1bba-11ed-a1b1-00e070c694ff"
        # token = "a2eed2b159e9238dc0353fc3e73734d7677f7baf"
        # gmapi.run(strategy_id, filename="trade.trade_juejin.py", mode=gmapi.MODE_LIVE, token=token)
        while True:
            try:
                if tool.is_trade_time():
                    datas = get_execution_reports()
                    # 上传数据
                    fdatas = []
                    for d in datas:
                        fdatas.append(
                            {"code": d[0], "money": d[4], "num": d[2], "price": d[3], "time": d[7], "trade_num": d[5],
                             "type": d[1] - 1})
                    if fdatas:
                        network_util.send_socket_msg("127.0.0.1", 9001, {"type": 3, "data": fdatas})
            except Exception as e:
                logging.exception(e)
            # 2s更新
            time.sleep(1.5)


# 获取成交列表,返回的内容为:[(代码,买(1)/卖(2),量,价格,成交金额,订单ID,委托客户端ID,成交时间,成交日期)]