Skip to content

Commit 148a7fc

Browse files
hongweyuhongweyu
authored
Update Proto.java
auto change utf-8 hex bytes string to normal string for display
1 parent 76b8363 commit 148a7fc

File tree

1 file changed

+18
-14
lines changed

1 file changed

+18
-14
lines changed

‎src/why/stock/futu/Proto.java‎

Lines changed: 18 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,10 @@ public class Proto {
4040

4141
public static final int DefaultTimeOut = 3000;
4242

43+
public static void println(GeneratedMessageV3 response){
44+
System.out.println(Baser.octal2String(response.toString(), ": \"\\"));
45+
}
46+
4347
public static void main(final String... args) throws Exception{
4448

4549
String code = "00700";
@@ -50,43 +54,43 @@ public static void main(final String... args) throws Exception{
5054
Proto ctx = OpenContext("127.0.0.1", 11111, "GetTester");
5155

5256
Thread.sleep(3000);
53-
System.out.println(response = ctx.subscribe(market, codes, Arrays.asList(SubType.SubType_Basic, SubType.SubType_Ticker, SubType.SubType_OrderBook, SubType.SubType_Broker), true));
57+
println(response = ctx.subscribe(market, codes, Arrays.asList(SubType.SubType_Basic, SubType.SubType_Ticker, SubType.SubType_OrderBook, SubType.SubType_Broker), true));
5458
Thread.sleep(3000);
55-
System.out.println(response = ctx.get_stock_quote(market, codes));
59+
println(response = ctx.get_stock_quote(market, codes));
5660
Thread.sleep(3000);
5761
System.err.println(new Date((long)((Qot_GetBasicQot.QotGetBasicQot.Response)response).getS2C().getBasicQotList(0).getUpdateTimestamp()*1000));
5862

5963
Thread.sleep(3000);
6064
response = ctx.get_rt_ticker(market, code, 1000);
6165
System.err.println("Ticker " + ((Qot_GetTicker.QotGetTicker.Response)response).getS2C().getTickerListCount());
62-
System.out.println(response = ctx.get_order_book(market, code, 10));
63-
System.out.println(response = ctx.get_broker_queue(market, code));
66+
println(response = ctx.get_order_book(market, code, 10));
67+
println(response = ctx.get_broker_queue(market, code));
6468

65-
System.out.println(response = ctx.get_acc_list());
69+
println(response = ctx.get_acc_list());
6670
List<TrdAcc> trdAccs = ((Trd_GetAccList.TrdGetAccList.Response)response).getS2C().getAccListList();
6771
TrdAcc trdAcc = Baser.firstAcc(trdAccs, TrdMarket.TrdMarket_US, true);
6872
TrdHeader trdHeader = Baser.trdAcc2Header(trdAcc);
6973

70-
System.out.println(response = ctx.unlock_trade("", true));
71-
System.out.println(response = ctx.accinfo_query(trdHeader));
72-
System.out.println(response = ctx.position_list_query(trdHeader));
73-
System.out.println(response = ctx.order_list_query(trdHeader));
74-
// System.out.println(response = ctx.place_order(trdHeader, 400, 100, code, TrdSide.TrdSide_Buy, OrderType.OrderType_Normal));
75-
// System.out.println(response = ctx.modify_order(trdHeader, ModifyOrderOp.ModifyOrderOp_Normal, ((Trd_PlaceOrder.TrdPlaceOrder.Response)response).getS2C().getOrderID(), 399, 100));
74+
println(response = ctx.unlock_trade("", true));
75+
println(response = ctx.accinfo_query(trdHeader));
76+
println(response = ctx.position_list_query(trdHeader));
77+
println(response = ctx.order_list_query(trdHeader));
78+
// println(response = ctx.place_order(trdHeader, 400, 100, code, TrdSide.TrdSide_Buy, OrderType.OrderType_Normal));
79+
// println(response = ctx.modify_order(trdHeader, ModifyOrderOp.ModifyOrderOp_Normal, ((Trd_PlaceOrder.TrdPlaceOrder.Response)response).getS2C().getOrderID(), 399, 100));
7680

77-
// System.out.println(response = ctx.subscribe(market, SubType.SubType_Ticker, codes, false));
81+
// println(response = ctx.subscribe(market, SubType.SubType_Ticker, codes, false));
7882
ctx.close();
7983

8084
Proto proto = OpenContext("127.0.0.1", 11111, true, false, "PushTester", DefaultTimeOut);
8185
System.out.println(response = proto.subscribe(market, codes, Arrays.asList(SubType.SubType_Basic, SubType.SubType_OrderBook), true));
8286
proto.push_run(new ANotifyReveiver(){
8387
@Override
8488
protected void update(Qot_UpdateBasicQot.QotUpdateBasicQot.Response response) throws IOException{
85-
System.err.println(response);
89+
println(response);
8690
}
8791
@Override
8892
protected void update(Qot_UpdateOrderBook.QotUpdateOrderBook.Response response) throws IOException{
89-
System.out.println(response);
93+
println(response);
9094
proto.close();
9195
System.exit(0);
9296
}

0 commit comments

Comments
 (0)