增加环境接口

Administrator

2025-06-27 aeced89b951065dd5620cc796827b7a6dfda4e43

 huaxin_client/l2_client.py

@@ -235,6 +235,7 @@
            logging.exception(e)

    def OnRspSubNGTSTick(self, pSpecificSecurity, pRspInfo, nRequestID, bIsLast):
        try:
        async_log_util.info(logger_local_huaxin_l2_subscript,
                            f"NGTS订阅结果：{pSpecificSecurity['SecurityID']} {pRspInfo['ErrorID']} {pRspInfo['ErrorMsg']}")
        if pRspInfo["ErrorID"] == 0:
@@ -243,6 +244,8 @@
        if bIsLast == 1:
            print("订阅响应结束", self.subscripted_codes)
            l2_data_manager.add_subscript_codes(self.subscripted_codes)
        except:
            pass

    def OnRspUnSubNGTSTick(self, pSpecificSecurity, pRspInfo, nRequestID, bIsLast):
        try:
@@ -256,6 +259,7 @@
            logging.exception(e)

    def OnRtnTransaction(self, pTransaction):
        try:
        # 输出逐笔成交数据
        if pTransaction['ExecType'] == b"2":
            # 撤单
@@ -284,6 +288,8 @@
                    "SellNo": pTransaction['SellNo'],
                    "ExecType": pTransaction['ExecType'].decode()}
            self.l2_data_upload_manager.add_transaction_detail(item)
        except:
            pass

    def OnRtnOrderDetail(self, pOrderDetail):
        # 输出逐笔委托数据