| | |
|---|
| | | # 深市股东账号 |
|---|
| | | SZSE_ShareHolderID = '0345104949' |
|---|
| | | |
|---|
| | | ########B类######## |
|---|
| | | # LOCAL_IP = "192.168.84.75" |
|---|
| | | # FRONT_ADDRESS = "tcp://192.168.84.31:6500" |
|---|
| | | # FRONT_ADDRESS1 = "tcp://192.168.84.32:26500" |
|---|
| | | |
|---|
| | | ########A类######## |
|---|
| | | LOCAL_IP = "192.168.10.111" |
|---|
| | | FRONT_ADDRESS = "tcp://10.224.123.143:6500" |
|---|
| | | FRONT_ADDRESS1 = "tcp://10.224.123.147:26500" |
|---|
| | | |
|---|
| | | # # 仿真 |
|---|
| | | # from mylog import logger_trade_debug |
|---|
| | | # |
|---|
| | |
|---|
| | | cls.__front_id = front_id |
|---|
| | | |
|---|
| | | # sinfo char(32) |
|---|
| | | def buy(self, code, count, price, sinfo, order_ref, shadow_price = None): |
|---|
| | | def buy(self, code, count, price, sinfo, order_ref, shadow_price=None): |
|---|
| | | if not ENABLE_ORDER: |
|---|
| | | return |
|---|
| | | if sinfo in self.__buy_sinfo_set: |
|---|
| | |
|---|
| | | 其它字段置空 |
|---|
| | | ''' |
|---|
| | | # 给L2发送消息 |
|---|
| | | |
|---|
| | | |
|---|
| | | ret = api.ReqOrderInsert(req_field, self.req_id) |
|---|
| | | if ret != 0: |
|---|
| | |
|---|
| | | # UserProductInfo填写终端名称 |
|---|
| | | login_req.UserProductInfo = 'jiabei' |
|---|
| | | # 按照监管要求填写终端信息 |
|---|
| | | login_req.TerminalInfo = 'PC;IIP=NA;IPORT=NA;LIP=192.168.84.75;MAC=5C6F69CC2B40;HD=004bc76004aff0882b9052ba0eb00506;@jiabei' |
|---|
| | | login_req.TerminalInfo = f'PC;IIP=NA;IPORT=NA;LIP={LOCAL_IP};MAC=5C6F69CC2B40;HD=004bc76004aff0882b9052ba0eb00506;@jiabei' |
|---|
| | | # 以下内外网IP地址若不填则柜台系统自动采集，若填写则以终端填值为准报送 |
|---|
| | | # login_req.MacAddress = '5C-87-9C-96-F3-E3' |
|---|
| | | # login_req.InnerIPAddress = '10.0.1.102' |
|---|
| | |
|---|
| | | req_rid_dict[sinfo] = (client_id, request_id, sk, order_ref) |
|---|
| | | # threading.Thread(target=lambda: self.__tradeSimpleApi.buy(code, volume, price, sinfo, order_ref), |
|---|
| | | # daemon=True).start() |
|---|
| | | self.trade_thread_pool.submit(self.__tradeSimpleApi.buy, code, volume, price, sinfo, order_ref, shadow_price) |
|---|
| | | self.trade_thread_pool.submit(self.__tradeSimpleApi.buy, code, volume, price, sinfo, order_ref, |
|---|
| | | shadow_price) |
|---|
| | | |
|---|
| | | async_log_util.info(logger_trade, f"{code}华鑫本地下单线程结束") |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | |
|---|
| | | if 1: # 模拟环境，TCP 直连Front方式 |
|---|
| | | # 注册单个交易前置服务地址 |
|---|
| | | ##B类服务器## |
|---|
| | | api.RegisterFront(FRONT_ADDRESS) # 正式环境主地址 |
|---|
| | | api.RegisterFront(FRONT_ADDRESS1) # 正式环境备用地址 |
|---|
| | | |
|---|
| | | api.RegisterFront("tcp://192.168.84.31:6500") # 正式环境主地址 |
|---|
| | | api.RegisterFront("tcp://192.168.84.32:26500") # 正式环境备用地址 |
|---|
| | | ##A类服务器## |
|---|
| | | # api.RegisterFront("tcp://10.224.123.143:6500") # 正式环境主地址 |
|---|
| | | # api.RegisterFront("tcp://10.224.123.147:26500") # 正式环境备用地址 |
|---|
| | | |
|---|
| | | # TD_TCP_FrontAddress = "tcp://210.14.72.21:4400" # 仿真交易环境 |
|---|
| | | # TD_TCP_FrontAddress = "tcp://210.14.72.15:4400" # 24小时环境A套 |
|---|
