华鑫适配

Administrator

2023-07-11 71fc7dde52383aea95252423b263bb98a6a5ef7e

华鑫适配

 trade/huaxin/trade_api_server.py

@@ -122,7 +122,7 @@
                                        trade_data_request_queue.put_nowait({"type": "money"})
                                else:
                                    raise Exception(resultJSON['msg'])

                            break
                        except Exception as e:
                            raise e
                    elif type_ == 'cancel_order':
@@ -160,6 +160,7 @@
                                return_str = json.dumps({"code": 1, "msg": "未处于可撤单状态"})
                        else:
                            return_str = json.dumps({"code": 1, "msg": "请上传代码"})
                        break

                    elif type_ == 'sell':
                        # 验证签名
@@ -186,6 +187,7 @@
                        result = trade_api.order(trade_api.TRADE_DIRECTION_SELL, code, volume, price)
                        print("---卖出结果----")
                        print(result)
                        break
                    elif type_ == 'delegate_list':
                        # 委托列表
                        update_time = data_json["data"]["update_time"]
@@ -201,7 +203,7 @@
                                tool.get_now_date_str("%Y%m%d"), update_time)
                        return_str = json.dumps(
                            {"code": 0, "data": {"list": results, "updateTime": update_time}, "msg": "请上传代码"})

                        break
                    elif type_ == 'deal_list':
                        # 成交列表
                        results, update_time = huaxin_trade_record_manager.DealRecordManager.list_by_day(
@@ -232,7 +234,6 @@
                            trade_data_request_queue.put_nowait({"type": "position_list"})
                        return_str = json.dumps(
                            {"code": 0, "data": {}, "msg": ""})

                    # 查询委托列表
                    elif type_ == 'test':
                        # 卖出
@@ -265,18 +266,7 @@
                        result = trade_api.set_l2_codes_data(codes_data)
                        print("\n\n---L2设置结果----")
                        print(result)
                    else:
                        while True:
                            r = sk.recv(1024 * 100)
                            if r:
                                print(r.decode('utf-8'))
                                sk.sendall("123".encode('utf-8'))

                        # result = trade_server_processor.process(data_json["data"])
                        # sk.sendall(json.dumps({"code": 0}).encode(encoding='utf-8'))
                else:
                    # 断开连接
                    break
                break
                # sk.close()
            except Exception as e:
                logging.exception(e)