L1订阅日志添加

Administrator

2024-06-12 54012c9e60af4d4fc3537e01f497b6649d5a1548

L1订阅日志添加

 huaxin_client/l1_client_for_output.py

@@ -53,6 +53,7 @@
    def subscribe_codes(self, codes_sh, codes_sz):
        # 重新订阅代码
        printlog(f"订阅数量：sh-{len(codes_sh)}  sz-{len(codes_sz)}")
        logger_system.info(f"订阅数量：sh-{len(codes_sh)}  sz-{len(codes_sz)}")
        if codes_sh:
            ret = self.__api.SubscribeMarketData(codes_sh, xmdapi.TORA_TSTP_EXD_SSE)
            if ret != 0:
@@ -70,6 +71,7 @@
    def OnRspUserLogin(self, pRspUserLoginField, pRspInfoField, nRequestID):
        if pRspInfoField.ErrorID == 0:
            printlog('Login success! [%d]' % nRequestID)
            logger_system.info('Login success! [%d]' % nRequestID)

            '''
            订阅行情
@@ -88,6 +90,8 @@


        else:
            logger_system.info('Login fail!!! [%d] [%d] [%s]'
                               % (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))
            printlog('Login fail!!! [%d] [%d] [%s]'
                     % (nRequestID, pRspInfoField.ErrorID, pRspInfoField.ErrorMsg))

@@ -131,6 +135,7 @@

def __upload_codes_info(datas):
    printlog("上传数据数量", len(datas))
    logger_system.info("上传数据数量:{}", len(datas))
    # if not tool.is_trade_time():
    #     return
    data_bytes = socket_util.load_header(json.dumps({"type": "l1_data", "data": datas}).encode("utf-8"))