1

zj

2024-06-13 8eea5be3b36875bd4ffe70e6c3a5bb07b1d829bf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
Êþº¾4
Z
J¾¿
¾ÀÁ
Â
Ã
ÄÅÆ
ÇÈ
EÉÊ
¾Ë
¾
ÇÌ
ÇÍÎÔÕÖ
×ØÕÙÚ
ÔÜ
Ý
EÞ
ßàáâ
Äãäåæ
Äçè
ßé
êë
ßì
êíîïðñòóôõö÷ø    Eùúûúüý
Äþÿ

:¾g
:


 
:

 
:

Ç

:
f
    
 

    E

 
H¾

log
Lorg/slf4j/Logger;
cryptosRealtimeHistory
Ljava/util/Map;
    Signature
aLjava/util/Map<Ljava/lang/String;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
'Lcom/yami/trading/huobi/data/DataCache;
getLatestRealTime
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
symbol
Ljava/lang/String;
depthToTrade
,(Lcom/yami/trading/bean/data/domain/Depth;)V
depth
)Lcom/yami/trading/bean/data/domain/Depth;

timeObject
6Lcom/yami/trading/huobi/data/internal/TradeTimeObject;
data
Ljava/util/List;
asks
bids
sell
buy
LocalVariableTypeTable
@Ljava/util/List<Lcom/yami/trading/bean/data/domain/TradeEntry;>;
@Ljava/util/List<Lcom/yami/trading/bean/data/domain/DepthEntry;>;
 StackMapTable
Ê
getKline
\(Ljava/lang/String;Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/KlineTimeObject;
line
key
getTrend
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/TrendTimeObject;
putTrend
K(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/TrendTimeObject;)V
model
6Lcom/yami/trading/huobi/data/internal/TrendTimeObject;
putKline
](Ljava/lang/String;Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/KlineTimeObject;)V
6Lcom/yami/trading/huobi/data/internal/KlineTimeObject;
getStockTradeList
$(Ljava/lang/String;)Ljava/util/List;
V(Ljava/lang/String;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/TradeDetails;>;
putStockTradeList
%(Ljava/lang/String;Ljava/util/List;)V
BLjava/util/List<Lcom/yami/trading/bean/data/domain/TradeDetails;>;
W(Ljava/lang/String;Ljava/util/List<Lcom/yami/trading/bean/data/domain/TradeDetails;>;)V
getRealtime
realtime
,Lcom/yami/trading/bean/data/domain/Realtime;Æ
putLatestRealTime
A(Ljava/lang/String;Lcom/yami/trading/bean/data/domain/Realtime;)V
putRealtime
    putMarket
D(Ljava/lang/String;Lcom/yami/trading/bean/data/domain/StockMarket;)V
market
/Lcom/yami/trading/bean/data/domain/StockMarket;
    getMarket
C(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/StockMarket;
putDepth
K(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/DepthTimeObject;)V
6Lcom/yami/trading/huobi/data/internal/DepthTimeObject;
getDepth
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/DepthTimeObject;
putTrade
K(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/TradeTimeObject;)V
getTrade
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/TradeTimeObject;
putRealtimeHigh
'(Ljava/lang/String;Ljava/lang/Double;)V
high
Ljava/lang/Double;
getRealtimeHigh
&(Ljava/lang/String;)Ljava/lang/Double;
putRealtimeLow
low
getRealtimeLow
putKlineHoBi
>(Ljava/lang/String;Lcom/yami/trading/bean/data/domain/Kline;)V
)Lcom/yami/trading/bean/data/domain/Kline;
getKlineHoBi
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Kline;
putRealtime24HBeforeOpen
open
getRealtime24HBeforeOpen
putCryptosRealtimeHistory
    realtimes
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
S(Ljava/lang/String;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;)V
getCryptosRealtimeHistory
R(Ljava/lang/String;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
clearCryptosRealtimeHistory
(Ljava/lang/String;)V
putLatestRealTime60s
clearLatestRealTime60s
getLatestRealTime60s
lambda$depthToTrade$1
‡(Lcom/yami/trading/bean/data/domain/Depth;Lcom/yami/trading/bean/data/domain/DepthEntry;)Lcom/yami/trading/bean/data/domain/TradeEntry;

a
.Lcom/yami/trading/bean/data/domain/DepthEntry;

tradeEntry
.Lcom/yami/trading/bean/data/domain/TradeEntry;
lambda$depthToTrade$0
<clinit>

SourceFile
DataCache.javaQR
java/lang/StringBuilder
3com/yami/trading/common/constants/RedisKeyConstants
trading:latest:realtime







*com/yami/trading/bean/data/domain/Realtime


–—
4com/yami/trading/huobi/data/internal/TradeTimeObject
java/util/ArrayList






BootstrapMethods


 
!
"
#
$
%
&
'
(
)
*
+
java/util/List
,
-
.
/”•
0
1
2

_
 trading:kline
3
4
4com/yami/trading/huobi/data/internal/KlineTimeObject
4com/yami/trading/huobi/data/internal/TrendTimeObject
 trading:trend
5
6
trading:trend:list
7
2

8

9
2
:

trading:real:market
-com/yami/trading/bean/data/domain/StockMarket
 trading:depth
4com/yami/trading/huobi/data/internal/DepthTimeObject
 trading:trade
trading:realtime:high
java/lang/Double
trading:realtime:low
trading:kline:hobi
'com/yami/trading/bean/data/domain/Kline
 trading:realtime:24h:before:openMN
;
/
<


 trading:cryptos:realtime:history
=
4
trading:latest:realtime:60s
,com/yami/trading/bean/data/domain/TradeEntry
>°
?
@
A
B
C
D
A
E
C
F
G
H
I
%com/yami/trading/huobi/data/DataCache
J
K
LKL
&java/util/concurrent/ConcurrentHashMap
java/lang/Object
java/lang/String
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
&com/yami/trading/common/util/RedisUtil
get
&(Ljava/lang/String;)Ljava/lang/Object;
'com/yami/trading/bean/data/domain/Depth
    getSymbol
getAsks
()Ljava/util/List;
getBids
stream
()Ljava/util/stream/Stream;

M
N
&(Ljava/lang/Object;)Ljava/lang/Object;
E
O
^(Lcom/yami/trading/bean/data/domain/DepthEntry;)Lcom/yami/trading/bean/data/domain/TradeEntry;
apply
H(Lcom/yami/trading/bean/data/domain/Depth;)Ljava/util/function/Function;
java/util/stream/Stream
map
8(Ljava/util/function/Function;)Ljava/util/stream/Stream;
java/util/stream/Collectors
toList
()Ljava/util/stream/Collector;
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
E
P
addAll
(Ljava/util/Collection;)Z
put
$org/apache/commons/lang3/StringUtils
isBlank
(Ljava/lang/CharSequence;)Z
hGet
8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object;
hSet
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Object;)V
isAllLowerCase
toUpperCase
isAllUpperCase
toLowerCase
 java/util/Map
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
hDel
setDirection
,com/yami/trading/bean/data/domain/DepthEntry
    getAmount
()Ljava/lang/Double;
    setAmount
(Ljava/lang/Double;)V
getPrice
setPrice
getTs
()Ljava/lang/Long;
setTs
(Ljava/lang/Long;)V
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
Q
R
Vºµ´µ
"java/lang/invoke/LambdaMetafactory
metafactory
X
Lookup
InnerClasses
Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Y
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!EJKLJMN
OP#
QR
S/

*·
±T
U
VW    XY
SD
»Y·¶*¶¶¸À    °T
"U
Z[    \]
S
}†*¶
L+¸M,Ç»Y· M»Y·N*¶:*¶:¹
*º¹¸¹À:¹
*º¹¸¹À:-¹W-¹W,+-¶+,¸±TB&'
(),-$.*/<6I7[>h?q@zA€B…CUR†^_Z[

|`ahbc$bdc*\ecI=fchgch4hbi$bdj*\ejI=fihgik
ýlm    no
Sƒ+*M+¸š»Y·,¶¶+¶¶M,¸À °TFG    H!JU +Z[+p[
)q[k
ü!l    rs
S4

*¸À!°T
NU

Z[    tu
S@"*+¸#±T
RSUZ[vw
    xy
S)*N+¸š»Y·-¶¶+¶¶N-,¸#±TVW    X!Z([U*)Z[)p[
)vz'q[k
ü!l    {|S4

$*¸À°T
^U

Z[O}    ~SR$*+¸#±T
bcUZ[vc
h
v€
O    ‚Y
S•5*¸À    L+Ç(*¸%™*¶&K§*¸'™*¶(K*¸À    °+°T"f
ghij$k)m3oU5Z[
+ƒ„
k
ü…        †‡
S@*+¸#±T
tuUZ[v„
    ˆ‡
S@*+¸#±T
xyUZ[v„
    ‰Š
S@)*+¸#±T
|}UZ[‹Œ
    Ž
S4

)*¸À*°T
€U

Z[    
S@+*+¸#±T
„…UZ[v‘
    ’“
S4

+*¸À,°T
ˆU

Z[    ”•
S@-*+¸#±T
ŒUZ[va
    –—
S4

-*¸À°T
U

Z[    ˜™
S@.*+¸#±T
”•UZ[š›
    œ
S4

.*¸À/°T
˜U

Z[    ž™
S@0*+¸#±T
œUZ[Ÿ›
     
S4

0*¸À/°T
 U

Z[    ¡¢
S@1*+¸#±T
¤¥UZ[v£
    ¤¥
S4

1*¸À2°T
¨U

Z[    ¦™
S@3*+¸#±T
¬­UZ[§›
    ¨
S4

3*¸À/°T
°U

Z[    ©SV²4*+¹5W±T
´µUZ[ªc
h
ª«
O¬    ­|S7
 ²4*¹6À°T
¸U
 Z[O®    ¯°
S6
7*¸8W±T
¼½U
Z[    ±SR9*+¸#±T
ÀÁUZ[ªc
h
ª«
O¬    ²°
S6
9*¸8W±T
ÄÅU
Z[    ³|S4

9*¸À°T
ÈU

Z[O®
´µ
Sz(»:Y·;M,<¶=,+¶>¶?,+¶@¶A,*¶B¶C,°T89:;<&=U (^_(¶·
 ¸¹
ºµ
Sz(»:Y·;M,D¶=,+¶>¶?,+¶@¶A,*¶B¶C,°T01234&5U (^_(¶·
 ¸¹»R
S/E¸F³G»HY·I³4±
T
¼½
U


S
W
TÏÐÑÒÓÐÑÛÓ